imap_messages.php 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378
  1. <?php
  2. /**
  3. ** imap_messages.php
  4. **
  5. ** This implements functions that manipulate messages
  6. **/
  7. if (!isset($mime_php)) include "../functions/mime.php";
  8. /******************************************************************************
  9. ** Copies specified messages to specified folder
  10. ******************************************************************************/
  11. function sqimap_messages_copy ($imap_stream, $start, $end, $mailbox) {
  12. fputs ($imap_stream, "a001 COPY $start:$end \"$mailbox\"\r\n");
  13. $read = sqimap_read_data ($imap_stream, "a001", true, $response, $message);
  14. }
  15. /******************************************************************************
  16. ** Deletes specified messages and moves them to trash if possible
  17. ******************************************************************************/
  18. function sqimap_messages_delete ($imap_stream, $start, $end, $mailbox) {
  19. global $move_to_trash, $trash_folder, $auto_expunge;
  20. if (($move_to_trash == true) && (sqimap_mailbox_exists($imap_stream, $trash_folder) && ($mailbox != $trash_folder))) {
  21. sqimap_messages_copy ($imap_stream, $start, $end, $trash_folder);
  22. sqimap_messages_flag ($imap_stream, $start, $end, "Deleted");
  23. } else {
  24. sqimap_messages_flag ($imap_stream, $start, $end, "Deleted");
  25. }
  26. }
  27. /******************************************************************************
  28. ** Sets the specified messages with specified flag
  29. ******************************************************************************/
  30. function sqimap_messages_flag ($imap_stream, $start, $end, $flag) {
  31. fputs ($imap_stream, "a001 STORE $start:$end +FLAGS (\\$flag)\r\n");
  32. $read = sqimap_read_data ($imap_stream, "a001", true, $response, $message);
  33. }
  34. /******************************************************************************
  35. ** Returns some general header information -- FROM, DATE, and SUBJECT
  36. ******************************************************************************/
  37. class small_header {
  38. var $from, $subject, $date, $to, $priority, $message_id;
  39. }
  40. function sqimap_get_small_header ($imap_stream, $id, $sent) {
  41. fputs ($imap_stream, "a001 FETCH $id BODY.PEEK[HEADER.FIELDS (Date To From Cc Subject Message-Id X-Priority Content-Type)]\r\n");
  42. $read = sqimap_read_data ($imap_stream, "a001", true, $response, $message);
  43. $subject = _("(no subject)");
  44. $from = _("Unknown Sender");
  45. $priority = "0";
  46. $messageid = "<>";
  47. $g = 0;
  48. for ($i = 0; $i < count($read); $i++) {
  49. if (eregi ("^to:", $read[$i])) {
  50. //$to = sqimap_find_displayable_name(substr($read[$i], 3));
  51. $to = substr($read[$i], 3);
  52. } else if (eregi ("^from:", $read[$i])) {
  53. //$from = sqimap_find_displayable_name(substr($read[$i], 5));
  54. $from = substr($read[$i], 5);
  55. } else if (eregi ("^x-priority:", $read[$i])) {
  56. $priority = trim(substr($read[$i], 11));
  57. } else if (eregi ("^message-id:", $read[$i])) {
  58. $messageid = trim(substr($read[$i], 11));
  59. } else if (eregi ("^cc:", $read[$i])) {
  60. $cc = substr($read[$i], 3);
  61. } else if (eregi ("^date:", $read[$i])) {
  62. $date = substr($read[$i], 5);
  63. } else if (eregi ("^subject:", $read[$i])) {
  64. $subject = htmlspecialchars(eregi_replace ("^subject: ", "", $read[$i]));
  65. if (trim($subject) == "")
  66. $subject = _("(no subject)");
  67. } else if (eregi ("^content-type:", $read[$i])) {
  68. $type = substr($read[$i], 14);
  69. $type = strtolower(trim($type));
  70. if ($pos = strpos($type, ";"))
  71. $type = substr($type, 0, $pos);
  72. $type = explode("/", $type);
  73. }
  74. }
  75. // If there isn't a date, it takes the internal date and uses
  76. // that as the normal date.
  77. if (trim($date) == "") {
  78. fputs ($imap_stream, "a002 FETCH $id INTERNALDATE\r\n");
  79. $internal_read = sqimap_read_data ($imap_stream, "a002", true, $r, $m);
  80. // * 22 FETCH (INTERNALDATE " 8-Sep-2000 13:17:07 -0500")
  81. $date = $internal_read[0];
  82. $date = eregi_replace(".*internaldate \"", "", $date);
  83. $date = eregi_replace("\".*", "", $date);
  84. $date_ary = explode(" ", trim($date));
  85. $date_ary[0] = str_replace("-", " ", $date_ary[0]);
  86. $date = implode (" ", $date_ary);
  87. }
  88. fputs ($imap_stream, "a003 FETCH $id RFC822.SIZE\r\n");
  89. $read = sqimap_read_data($imap_stream, "a003", true, $r, $m);
  90. preg_match("/([0-9]+)\)\s*$/i", $read[0], $regs);
  91. $size = $regs[1];
  92. $header = new small_header;
  93. if ($sent == true)
  94. $header->from = $to;
  95. else
  96. $header->from = $from;
  97. $header->date = $date;
  98. $header->subject = $subject;
  99. $header->to = $to;
  100. $header->priority = $priority;
  101. $header->message_id = $messageid;
  102. $header->cc = $cc;
  103. $header->size = $size;
  104. $header->type0 = $type[0];
  105. $header->type1 = $type[1];
  106. return $header;
  107. }
  108. /******************************************************************************
  109. ** Returns the flags for the specified messages
  110. ******************************************************************************/
  111. function sqimap_get_flags ($imap_stream, $i) {
  112. fputs ($imap_stream, "a001 FETCH $i:$i FLAGS\r\n");
  113. $read = sqimap_read_data ($imap_stream, "a001", true, $response, $message);
  114. if (strpos($read[0], "FLAGS")) {
  115. $tmp = ereg_replace("\(", "", $read[0]);
  116. $tmp = ereg_replace("\)", "", $tmp);
  117. $tmp = str_replace("\\", "", $tmp);
  118. $tmp = substr($tmp, strpos($tmp, "FLAGS")+6, strlen($tmp));
  119. $tmp = trim($tmp);
  120. $flags = explode(" ", $tmp);
  121. } else {
  122. $flags[0] = "None";
  123. }
  124. return $flags;
  125. }
  126. /******************************************************************************
  127. ** Returns a message array with all the information about a message. See
  128. ** the documentation folder for more information about this array.
  129. ******************************************************************************/
  130. function sqimap_get_message ($imap_stream, $id, $mailbox) {
  131. $header = sqimap_get_message_header($imap_stream, $id, $mailbox);
  132. $msg = sqimap_get_message_body($imap_stream, &$header);
  133. return $msg;
  134. }
  135. /******************************************************************************
  136. ** Wrapper function that reformats the header information.
  137. ******************************************************************************/
  138. function sqimap_get_message_header ($imap_stream, $id, $mailbox) {
  139. fputs ($imap_stream, "a001 FETCH $id:$id BODY[HEADER]\r\n");
  140. $read = sqimap_read_data ($imap_stream, "a001", true, $response, $message);
  141. $header = sqimap_get_header($imap_stream, $read);
  142. $header->id = $id;
  143. $header->mailbox = $mailbox;
  144. return $header;
  145. }
  146. /******************************************************************************
  147. ** Wrapper function that returns entity headers for use by decodeMime
  148. ******************************************************************************/
  149. /*
  150. function sqimap_get_entity_header ($imap_stream, &$read, &$type0, &$type1, &$bound, &$encoding, &$charset, &$filename) {
  151. $header = sqimap_get_header($imap_stream, $read);
  152. $type0 = $header["TYPE0"];
  153. $type1 = $header["TYPE1"];
  154. $bound = $header["BOUNDARY"];
  155. $encoding = $header["ENCODING"];
  156. $charset = $header["CHARSET"];
  157. $filename = $header["FILENAME"];
  158. }
  159. */
  160. /******************************************************************************
  161. ** Queries the IMAP server and gets all header information.
  162. ******************************************************************************/
  163. function sqimap_get_header ($imap_stream, $read) {
  164. global $where, $what;
  165. $hdr = new msg_header();
  166. $i = 0;
  167. // Set up some defaults
  168. $hdr->type0 = "text";
  169. $hdr->type1 = "plain";
  170. $hdr->charset = "us-ascii";
  171. preg_match("/\{([0-9]+)\}/", $read[$i], $regs);
  172. preg_match("/[0-9]+/", $regs[0], $regs);
  173. while ($i < count($read)) {
  174. if (substr($read[$i], 0, 17) == "MIME-Version: 1.0") {
  175. $hdr->mime = true;
  176. $i++;
  177. }
  178. /** ENCODING TYPE **/
  179. else if (substr(strtolower($read[$i]), 0, 26) == "content-transfer-encoding:") {
  180. $hdr->encoding = strtolower(trim(substr($read[$i], 26)));
  181. $i++;
  182. }
  183. /** CONTENT-TYPE **/
  184. else if (strtolower(substr($read[$i], 0, 13)) == "content-type:") {
  185. $cont = strtolower(trim(substr($read[$i], 13)));
  186. if (strpos($cont, ";"))
  187. $cont = substr($cont, 0, strpos($cont, ";"));
  188. if (strpos($cont, "/")) {
  189. $hdr->type0 = substr($cont, 0, strpos($cont, "/"));
  190. $hdr->type1 = substr($cont, strpos($cont, "/")+1);
  191. } else {
  192. $hdr->type0 = $cont;
  193. }
  194. $line = $read[$i];
  195. $i++;
  196. while ( (substr(substr($read[$i], 0, strpos($read[$i], " ")), -1) != ":") && (trim($read[$i]) != "") && (trim($read[$i]) != ")")) {
  197. str_replace("\n", "", $line);
  198. str_replace("\n", "", $read[$i]);
  199. $line = "$line $read[$i]";
  200. $i++;
  201. }
  202. /** Detect the boundary of a multipart message **/
  203. if (eregi("boundary=\"([^\"]+)\"", $line, $regs)) {
  204. $hdr->boundary = $regs[1];
  205. }
  206. /** Detect the charset **/
  207. if (strpos(strtolower(trim($line)), "charset=")) {
  208. $pos = strpos($line, "charset=") + 8;
  209. $charset = trim($line);
  210. if (strpos($line, " ", $pos) > 0) {
  211. $charset = substr($charset, $pos, strpos($line, " ", $pos));
  212. } else {
  213. $charset = substr($charset, $pos);
  214. }
  215. $charset = str_replace("\"", "", $charset);
  216. $hdr->charset = $charset;
  217. } else {
  218. $hdr->charset = "us-ascii";
  219. }
  220. }
  221. else if (strtolower(substr($read[$i], 0, 20)) == "content-disposition:") {
  222. /** Add better dontent-disposition support **/
  223. $line = $read[$i];
  224. $i++;
  225. while ( (substr(substr($read[$i], 0, strpos($read[$i], " ")), -1) != ":") && (trim($read[$i]) != "") && (trim($read[$i]) != ")")) {
  226. str_replace("\n", "", $line);
  227. str_replace("\n", "", $read[$i]);
  228. $line = "$line $read[$i]";
  229. $i++;
  230. }
  231. /** Detects filename if any **/
  232. if (strpos(strtolower(trim($line)), "filename=")) {
  233. $pos = strpos($line, "filename=") + 9;
  234. $name = trim($line);
  235. if (strpos($line, " ", $pos) > 0) {
  236. $name = substr($name, $pos, strpos($line, " ", $pos));
  237. } else {
  238. $name = substr($name, $pos);
  239. }
  240. $name = str_replace("\"", "", $name);
  241. $hdr->filename = $name;
  242. }
  243. }
  244. /** REPLY-TO **/
  245. else if (strtolower(substr($read[$i], 0, 9)) == "reply-to:") {
  246. $hdr->replyto = trim(substr($read[$i], 9, strlen($read[$i])));
  247. $i++;
  248. }
  249. /** FROM **/
  250. else if (strtolower(substr($read[$i], 0, 5)) == "from:") {
  251. $hdr->from = trim(substr($read[$i], 5, strlen($read[$i]) - 6));
  252. if ($hdr->replyto == "")
  253. $hdr->replyto = $hdr->from;
  254. $i++;
  255. }
  256. /** DATE **/
  257. else if (strtolower(substr($read[$i], 0, 5)) == "date:") {
  258. $d = substr($read[$i], 5);
  259. $d = trim($d);
  260. $d = ereg_replace(" ", " ", $d);
  261. $d = explode(" ", $d);
  262. $hdr->date = getTimeStamp($d);
  263. $i++;
  264. }
  265. /** SUBJECT **/
  266. else if (strtolower(substr($read[$i], 0, 8)) == "subject:") {
  267. $hdr->subject = trim(substr($read[$i], 8, strlen($read[$i]) - 9));
  268. if (strlen(Chop($hdr->subject)) == 0)
  269. $hdr->subject = _("(no subject)");
  270. if ($where == "SUBJECT") {
  271. $hdr->subject = eregi_replace($what, "<b>\\0</b>", $hdr->subject);
  272. }
  273. $i++;
  274. }
  275. /** CC **/
  276. else if (strtolower(substr($read[$i], 0, 3)) == "cc:") {
  277. $pos = 0;
  278. $hdr->cc[$pos] = trim(substr($read[$i], 4));
  279. $i++;
  280. while (((substr($read[$i], 0, 1) == " ") || (substr($read[$i], 0, 1) == "\t")) && (trim($read[$i]) != "")){
  281. $pos++;
  282. $hdr->cc[$pos] = trim($read[$i]);
  283. $i++;
  284. }
  285. }
  286. /** TO **/
  287. else if (strtolower(substr($read[$i], 0, 3)) == "to:") {
  288. $pos = 0;
  289. $hdr->to[$pos] = trim(substr($read[$i], 4));
  290. $i++;
  291. while (((substr($read[$i], 0, 1) == " ") || (substr($read[$i], 0, 1) == "\t")) && (trim($read[$i]) != "")){
  292. $pos++;
  293. $hdr->to[$pos] = trim($read[$i]);
  294. $i++;
  295. }
  296. }
  297. /** MESSAGE ID **/
  298. else if (strtolower(substr($read[$i], 0, 11)) == "message-id:") {
  299. $hdr->message_id = trim(substr($read[$i], 11));
  300. $i++;
  301. }
  302. /** ERROR CORRECTION **/
  303. else if (substr($read[$i], 0, 1) == ")") {
  304. if (strlen(trim($hdr->subject)) == 0)
  305. $hdr->subject = _("(no subject)");
  306. if (strlen(trim($hdr->from)) == 0)
  307. $hdr->from = _("(unknown sender)");
  308. if (strlen(trim($hdr->date)) == 0)
  309. $hdr->date = time();
  310. $i++;
  311. }
  312. else {
  313. $i++;
  314. }
  315. }
  316. return $hdr;
  317. }
  318. /******************************************************************************
  319. ** Returns the body of a message.
  320. ******************************************************************************/
  321. function sqimap_get_message_body ($imap_stream, &$header) {
  322. $id = $header->id;
  323. return decodeMime($imap_stream, $body, &$header);
  324. }
  325. /******************************************************************************
  326. ** Returns an array with the body structure
  327. ******************************************************************************/
  328. ?>