topical media & game development
[] readme course(s) preface I 1 2 II 3 4 III 5 6 7 IV 8 9 10 V 11 12 afterthought(s) appendix reference(s) example(s) resource(s) _

talk show tell print

professional-ajax-09-AjaxMail-inc-AjaxMail.inc.php / php



  <?php
  
  class JSONObject {}
  
  class AjaxMailAttachmentHeader {
      var id;
      var filename;
      
      function AjaxMailAttachmentHeader(id, filename, size) {
          this->id = id;
          this->filename = filename;
          this->size = "".(round(size/1024*100)/100)." KB";
      }    
  }
  
  class AjaxMailAttachment {
      
      var contentType;
      var filename;
          var size;
      var data;
          
  
      function AjaxMailAttachment(contentType, filename, size, data) {
          this->contentType = contentType;
          this->filename = filename;
          this->size = size;
          this->data = data;
      }
  }
  
  class AjaxMailMessage {
  
      var to;
      var from;
      var cc;
      var bcc;
      var subject;
      var message;
      var date;
      var attachments;
      var unread;
      var hasAttachments;
      var id;
      
      function AjaxMailMessage() {
          this->attachments = array();
      }
  
  }
  
  class AjaxMailbox {
  
      function connect() {
          conn = mysql_connect(DB_SERVER, DB_USER, DB_PASSWORD) or die("Could not connect : " . mysql_error());
          mysql_select_db(DB_NAME);
          return conn;    
      }
      
      function disconnect(conn) {
          mysql_close(conn);
      }
  
      function getFolderPage(folder, page) {
      
          //first make sure you have the most recent mail info
          this->checkMail();
   
          //connect to the database
          conn = this->connect();
          
          //first get the total number of e-mails in the folder
          query = "select count(MessageId) as count from AjaxMailMessages";
          query .= " where FolderId=folder";
          result = mysql_query(query, conn);
          row = mysql_fetch_assoc(result);
          
          //assign basic mail info
          info = new JSONObject();
          info->messageCount = (int) row["count"];
          info->page = page;
          info->pageCount = (int) ceil(info->messageCount/MESSAGES_PER_PAGE);
          info->folder = folder;
          
          //calculate first and last message to retrieve
          firstMessageNum = (page-1) * MESSAGES_PER_PAGE;
          
          //add info to the mail info
          info->firstMessage = firstMessageNum+1; //DB is 0-based, people like to see it 1-based :)
          info->messages = array();
          
          info->unreadCount = this->getUnreadCount(conn);       
  
          
          //get the message information
          query = "select * from AjaxMailMessages where FolderId=folder";
          query .= " order by date desc limit firstMessageNum, ";
          query .= MESSAGES_PER_PAGE;
                  
          result = mysql_query(query, conn);
                  
          if (!result) {
              info->error = mysql_error(conn);
          } else {                
              //get the data and assign into new message info
              while (row = mysql_fetch_assoc(result)) {
                  message = new JSONObject();
                  message->id = row['MessageId'];
                  message->from = row['From'];
                  message->subject = row['Subject'];               
                  message->date = date("M j Y", intval(row["Date"]));
                  message->hasAttachments = (row['HasAttachments']==1);
                  message->unread = (row['Unread']==1);        
                  info->messages[] = message;
              }
          }
          
                  
          //close the database connection
                      this->disconnect(conn);
                  
                      //return the information
          return info;   
      }
      
      function getUnreadCount(conn) {
          query = "select count(MessageId) as UnreadCount from AjaxMailMessages where FolderId=1 and Unread=1";
          result = mysql_query(query, conn);
          row = mysql_fetch_assoc(result);
          return intval(row["UnreadCount"]);      
      }
  
      function getMessage(messageId) {
          conn = this->connect();
          
          //get the information
          query = "select MessageId, `To`, `From`, CC, BCC, Subject, Date, ";
          query .= "Message, HasAttachments, Unread from AjaxMailMessages where";
          query .= " MessageId=messageId";
          result = mysql_query(query, conn);
          row = mysql_fetch_assoc(result);
          
          //assign information to message object
          message = new AjaxMailMessage();
          message->id = row["MessageId"];
          message->to = row["To"];
          message->cc = row["CC"];
          message->bcc = row["BCC"];
          message->unread = (row["Unread"]==1);
          message->from = row["From"];
          message->subject = row["Subject"];
          message->date = date("M j, Y h:i A", intval(row["Date"]));
          message->hasAttachments = (row["HasAttachments"]==1);
          message->unreadCount = this->getUnreadCount(conn);
          message->message = row["Message"];
          
          //if there are attachments, get them
          if (message->hasAttachments) {
              query = "select AttachmentId, Filename, Size from AjaxMailAttachments where MessageId=messageId";
              result = mysql_query(query, conn);
              while (row = mysql_fetch_assoc(result)) {
                  message->attachments[] = new AjaxMailAttachmentHeader(row["AttachmentId"], row["Filename"], (int) row["Size"]);              
              }
          }
          
                  
          this->disconnect(conn);
          
          return message;
      }
          
      function getAttachment(attachmentId) {
          conn = this->connect();
          
          query = "select * from AjaxMailAttachments where ";
          query .= " AttachmentId=attachmentId";
          result = mysql_query(query, conn);
          row = mysql_fetch_assoc(result);
          
          this->disconnect(conn);
          
          return new AjaxMailAttachment(row["ContentType"], row["Filename"], row["Size"], row["Data"]);        
      }
      
      function clearAll() {
          conn = this->connect();
          
          query = "truncate table AjaxMailMessages";
          mysql_query(query,conn);
          
          query = "truncate table AjaxMailAttachments";
          mysql_query(query,conn);
          
          this->disconnect(conn);
      }
      
  
      function deleteMessage(messageId) {
          conn = this->connect();
          
          query = "update AjaxMailMessages set FolderId=2 where ";
          query .= " MessageId=messageId";
          mysql_query(query,conn);
          
          this->disconnect(conn);
      }
      
      function emptyTrash() {
          conn = this->connect();
          
          //delete any attachments
          query = "delete from AjaxMailAttachments where MessageId in (select MessageId from AjaxMailMessages where FolderId=2)";
          mysql_query(query, conn);
          
          //delete the e-mails
          query = "delete from AjaxMailMessages where FolderId=2";
          mysql_query(query,conn);
          
          this->disconnect(conn);        
      }
      
      function markMessageAsRead(messageId) {
          conn = this->connect();
          
          query = "update AjaxMailMessages set Unread=0 where MessageId=messageId";
          mysql_query(query,conn);
          
          this->disconnect(conn);    
      }
          
      function markMessageAsUnread(messageId) {
          conn = this->connect();
          
          query = "update AjaxMailMessages set Unread=1 where MessageId=messageId";
          mysql_query(query,conn);
          
          this->disconnect(conn);    
      }
      
      function restoreMessage(messageId) {
          conn = this->connect();
          
          query = "update AjaxMailMessages set FolderId=1 where MessageId=messageId";
          mysql_query(query,conn);
          
          this->disconnect(conn);    
      }
      
      function checkMail() {
          pop = new Pop3(POP3_SERVER, POP3_USER, POP3_PASSWORD);
          
          if (pop->login()) {
  
              if (pop->mailCount > 0) {
                  
                  conn = this->connect();
                  pop->getEmails();
                  
                  foreach (pop->messages as message) {
                      query = "insert into AjaxMailMessages(`To`,CC,BCC,`From`,";
                      query .= 
                            "Subject,`Date`,Message,HasAttachments,FolderId,Unread)";
                      query .= " values('\%s','\%s','\%s','\%s','\%s',\%s,'\%s',"
                                .message->hasAttachments.",1,1)";
                      query = sprintf(query, 
                                       (addslashes(message->to)),
                                       (addslashes(message->cc)),
                                       (addslashes(message->bcc)),
                                       (addslashes(message->from)),
                                       (addslashes(message->subject)),
                                       message->unixTimeStamp,
                                       (addslashes(message->getTextMessage()))
                               );
                                          
                      result = mysql_query(query, conn);
                                          
                      if (message->hasAttachments) {
  
                          messageId = mysql_insert_id(conn);   
  
                          foreach (message->attachments as attachment) {
                              query = "insert into AjaxMailAttachments(MessageId,";
                              query .= "Filename, ContentType, Size, Data)";
                              query .= "values(messageId, '\%s', '\%s', '\%s', '\%s')";
                              query = sprintf(query,
                                               addslashes(attachment->fileName),
                                               attachment->contentType,
                                               strlen(attachment->data),
                                               addslashes(attachment->data));  
                              mysql_query(query, conn);                        
                          }
                      } 
                                     
                  }
                  this->disconnect(conn);                 
              }
          
              pop->logoff();   
          } 
      }
  
          
            function sendMail(to, subject, message, cc="") {
          mailer = new PHPMailer();
              
          //Add To's
          tos = preg_split ("/;|,/", to);
          foreach (tos as to) {
              preg_match("/(.*?)<?(.*?)>?/i", to, matches);
              
              mailer->AddAddress(matches[2],str_replace('"','',matches[1]));
          }
              
          //Add the CCs
          if (cc != "") {
              ccs = preg_split ("/;|,/", cc);
              
              foreach (ccs as cc) {
                  preg_match("/(.*?)<?(.*?)>?/i", cc, matches);
                  
                  mailer->AddCC(matches[2],str_replace('"','',matches[1]));
              }
          }
      
          //set other information
          mailer->From = EMAIL_FROM_ADDRESS;
          mailer->FromName = EMAIL_FROM_NAME;
          mailer->Subject = subject;
          mailer->Body = message;
          mailer->SMTPAuth = SMTP_DO_AUTHORIZATION;
          mailer->Username = SMTP_USER;
          mailer->Password = SMTP_PASSWORD;
          
          mailer->Host = SMTP_SERVER;
          
          mailer->Mailer = "smtp";
          
          mailer->Send();        
          
          mailer->SmtpClose();
          
          response = new JSONObject();
          
          if (mailer->IsError()) {
              response->error = true;
              response->message = mailer->ErrorInfo;
          } else {
              response->error = false;
              response->message = "Your message has been sent.";
          }
          
          return response;
      }
          
  }
  
  ?>
[] readme course(s) preface I 1 2 II 3 4 III 5 6 7 IV 8 9 10 V 11 12 afterthought(s) appendix reference(s) example(s) resource(s) _

(C) Æliens 20/2/2008

You may not copy or print any of this material without explicit permission of the author or the publisher. In case of other copyright issues, contact the author.