开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 模拟服务器 > 查看源码
mail.c
资源名称：saac.tar.gz　[点击查看]
上传用户：qys8201
上传日期：2021-12-11
资源大小：978k
文件大小：17k
源码类别：

模拟服务器

开发平台：

C/C++

mail.c：源码内容
  1. #define _MAIL_C_
  3. #include "main.h"
  4. #include "mail.h"
  5. #include "util.h"
  6. #include "saacproto_serv.h"
  8. #include <malloc.h>
  9. #include <stdio.h>
  10. #include <time.h>
  11. #include <sys/types.h>
  12. #include <dirent.h>
  13. #include <sys/stat.h>
  15. typedef enum
  16. {
  17.     MS_NOUSE = 0,
  18.     MS_NEWMESSAGE,
  19.     MS_WAIT_ACK,
  20. } MAILSTATE;
  22. #define TEXT_MAX 1024
  23. struct mail
  24. {
  25.     int use;
  26.     unsigned int id_charname_hash;
  27.     char id_to[USERID_MAX];
  28.     char charname_to[CHARNAME_MAX];
  29.     char id_from[USERID_MAX];
  30.     char charname_from[CHARNAME_MAX];
  31.     char text[TEXT_MAX];
  32.     int option;
  33.     unsigned int message_id;
  34.     MAILSTATE state;
  35.     time_t recv_time;
  36. };
  38. struct mail *mailbuf;
  39. int mailbufsize = 0;
  42. static unsigned int
  43. getNextMessageID(void)
  44. {
  45.     FILE *fp;
  46.     unsigned int i;
  47.     char filename[1024];
  48.     char line[1000];
  49.     snprintf( filename, sizeof( filename ),
  50.               "%s/mail_id" , maildir );
  51.     fp = fopen( filename, "r" );
  52.     if( fp == NULL ){
  53.         fp = fopen( filename ,"w" );
  54.         if( fp == NULL ){
  55.             log( "不能创建 %s ... 使用同样的邮件ID,"
  56.                  " saac 发送变得缓慢!(id:9999)n", filename );
  57.             return 9999;
  58.         }
  59.         fprintf( fp, "10000n" );
  60.         fclose(fp);
  61.         return 1000;
  62.     }
  63.     fgets( line, sizeof(line), fp);
  64.     i = strtoul( line, NULL, 10 );
  65.     fclose(fp);
  67.     fp = fopen( filename, "w" );
  68.     if( fp == NULL ){
  69.         log( "不能写入新的ID到 %s ... 使用同样的数字!n", filename );
  70.         return i;
  71.     }
  72.     fprintf( fp, "%u", i+1 );
  73.     fclose(fp);
  75.     log( "新邮件ID:%un", i);
  76.     return i;
  77. }
  79. static int reallocMailBuf( void )
  80. {
  81.     struct mail *previous = mailbuf;
  82.     struct mail *newbuf;
  83.     int new_mailbufsize;
  84.     if( mailbufsize == 0 ){
  85.         new_mailbufsize = 1;
  86.     } else {
  87.         new_mailbufsize = mailbufsize * 2;
  88.     }
  90.     newbuf = ( struct mail * )calloc( 1, new_mailbufsize *
  91.                                       sizeof( struct mail ));
  92.     if( newbuf == NULL ){
  93.         log( "回复邮件缓冲: 内件不足!! 新邮件大小:%dn",
  94.              new_mailbufsize );
  95.         return -1;
  96.     }
  97.     memset( newbuf, 0 , new_mailbufsize * sizeof( struct mail ));
  98.     if( previous ) memcpy( (char*)newbuf, (char*)previous,
  99.                            mailbufsize * sizeof( struct mail ));
  100.     free( previous );
  101.     mailbufsize = new_mailbufsize;
  102.     mailbuf = newbuf;
  104.     log( "重新分配邮件缓冲: "
  105.          "新邮件缓冲:%d 旧地址:%x 新地址:%xn",
  106.          new_mailbufsize, (unsigned int)previous,(unsigned int)newbuf );
  107.     return 0;
  108. }
  110. static int mailbuf_finder = 0;
  111. static int allocMail( int use_msgid, unsigned int msgid  )
  112. {
  113.     int i;
  114.     for(i=0;i<mailbufsize;i++){
  115.         mailbuf_finder ++;
  116.         if( mailbuf_finder == mailbufsize ) mailbuf_finder = 0;
  117.         if( mailbuf[mailbuf_finder].use == 0 ){
  118.             mailbuf[mailbuf_finder].use = 1;
  119.             mailbuf[mailbuf_finder].text[0] = 0;
  120.             mailbuf[mailbuf_finder].id_to[0] = 0;
  121.             mailbuf[mailbuf_finder].charname_to[0] = 0;
  122.             mailbuf[mailbuf_finder].id_from[0] = 0;
  123.             mailbuf[mailbuf_finder].charname_from[0] = 0;
  124.             if( use_msgid ){
  125.                 mailbuf[mailbuf_finder].message_id = msgid;
  126.             } else {
  127.                 mailbuf[mailbuf_finder].message_id = getNextMessageID();
  128.             }
  129.             mailbuf[mailbuf_finder].state = MS_NEWMESSAGE;
  130.             mailbuf[mailbuf_finder].recv_time = time(NULL);
  131.             return mailbuf_finder;
  132.         }
  133.     }
  134.     log( "分配邮件: 邮件缓冲失败.正在进行分配...n" );
  135.     if( reallocMailBuf() < 0 ){
  136.         log( "分配邮件: 分配失败n" );
  137.     } else {
  138.         return allocMail(use_msgid, msgid );
  139.     }
  141.     return -1;
  142. }
  144. void receiveMail( char *id_from,
  145.              char *charname_from,
  146.              char *id_to,
  147.              char *charname_to,
  148.              char *message,
  149.              int option,
  150.              int use_msgid,
  151.              unsigned int msgid 
  152.              )
  153. {
  154.     char id_charname[1024];
  155.     int h, mbindex;
  157.     snprintf( id_charname, sizeof( id_charname), "%s_%s", id_to, charname_to );
  158.     h = hashpjw( id_charname ) & 0xff ;
  159.     if( (mbindex = allocMail(use_msgid, msgid )) < 0 ){
  160.         log( "回复邮件: 获取新的邮件缓冲失败.n" );
  161.         return;
  162.     }
  163.     mailbuf[mbindex].id_charname_hash = h;
  164.     snprintf( mailbuf[mbindex].text, sizeof( mailbuf[mbindex].text ), "%s", message );
  165.     snprintf( mailbuf[mbindex].id_to, sizeof( mailbuf[mbindex].id_to ), "%s", id_to );
  166.     snprintf( mailbuf[mbindex].charname_to, sizeof( mailbuf[mbindex].charname_to ), "%s", charname_to );
  167.     snprintf( mailbuf[mbindex].id_from, sizeof( mailbuf[mbindex].id_from ),"%s", id_from );
  168.     snprintf( mailbuf[mbindex].charname_from, sizeof( mailbuf[mbindex].charname_from ),"%s", charname_from );
  169.     mailbuf[mbindex].option = option;
  171.     {
  172.         char childname[1000];
  173.         char savefile[1000];
  174.         char charname2[CHARNAME_MAX*2+1];
  175.         char text2[TEXT_MAX*2+1];
  176.         FILE *fp;
  177.         
  178.         snprintf( childname, sizeof( childname ),"%u" ,
  179.                   mailbuf[mbindex].message_id );
  180.         makeDirFilename( savefile , sizeof(savefile), maildir, h, childname );
  181.         fp = fopen( savefile, "w" );
  182.         if( fp == NULL ){
  183.             log( "回复邮件 : 不能保存邮件文件: %s %sn",
  184.                  savefile, strerror( errno ));
  185.             return;
  186.         }
  187. #define TO_ID_HEAD "ToID: "
  188. #define TO_CHAR_HEAD "ToChar: "
  189. #define FROM_ID_HEAD "FromID: "
  190. #define FROM_CHAR_HEAD "FromChar: "
  191. #define OPTION_HEAD "Option: "
  192. #define TEXT_HEAD "Text: "
  193.         
  194.         fprintf( fp, TO_ID_HEAD "%sn", id_to );
  195.         snprintf( charname2, sizeof( charname2), "%s", charname_to );
  196.         fprintf( fp, TO_CHAR_HEAD "%sn", makeEscapeString( charname_to,
  197.                                                charname2,sizeof(charname2)) );
  198.         fprintf( fp, FROM_ID_HEAD "%sn", id_from );
  199.         snprintf( charname2, sizeof( charname2), "%s", charname_from );
  200.         fprintf( fp, FROM_CHAR_HEAD "%sn", makeEscapeString( charname_from,
  201.                                                charname2,sizeof(charname2)) );
  202.         fprintf( fp, OPTION_HEAD "%dn", option );
  203.         snprintf( text2, sizeof( text2 ) , "%s", message );
  204.         fprintf( fp, TEXT_HEAD "%sn", makeEscapeString( message,
  205.                                                text2, sizeof(text2)) );
  206.         fclose(fp);
  207. {
  208. static int mailnum=0;
  209. if( mailnum%10 == 0)
  210. log(".");
  211. mailnum = (++mailnum%1000);
  212. if( mailnum == 0 )
  213. log("n");
  214. }
  215.     }
  216.     {
  217.         extern gmsv gs[MAXCONNECTION];
  218.         int i;
  219.         for(i=0;i<MAXCONNECTION;i++){
  220.             if( gs[i].use && gs[i].name[0] ){
  221.                 saacproto_Message_send( i,
  222.                                         id_from, charname_from,
  223.                                         id_to, charname_to,
  224.                                         message, option,
  225.                                         mailbuf[mbindex].message_id );
  226.                 mailbuf[mbindex].state = MS_WAIT_ACK;
  227.             }
  228.         }
  229.     }
  230. }
  232. void receiveMailAck( char *id, char *charname, int a , int mesgid )
  233. {
  234.     int i;
  235.     unsigned int h;
  236.     char id_charname[1024];
  237.     snprintf( id_charname, sizeof( id_charname), "%s_%s", id, charname );    
  238.     h = hashpjw( id_charname ) & 0xff ;
  239.     for(i=0;i<mailbufsize;i++){
  240.         if( mailbuf[i].message_id == mesgid ){
  241.             if( mailbuf[i].use
  242.                 && mailbuf[i].id_charname_hash == h
  243.                 && strcmp( mailbuf[i].id_to, id ) == 0
  244.                 && strcmp( mailbuf[i].charname_to, charname ) == 0
  245.                 && mailbuf[i].state == MS_WAIT_ACK ){
  246.                 char savefile[1024];
  247.                 char childname[1000];
  248.                 snprintf( childname,sizeof(childname),"%u",
  249.                           mailbuf[i].message_id );
  250.                 makeDirFilename( savefile, sizeof(savefile),maildir,
  251.                                  h, childname );
  252.                 if( unlink( savefile ) != 0 ){
  253.                     log( "failed to unlink %s: %sn",
  254.                          savefile, strerror(errno ));
  255.                 } else {
  256.                     log( "回复邮件: 删除邮件 "
  257.                          "%u 从 %s(%s) to %s(%s)n",
  258.                          mailbuf[i].message_id,
  259.                          mailbuf[i].id_from,
  260.                          mailbuf[i].charname_from,
  261.                          mailbuf[i].id_to,
  262.                          mailbuf[i].charname_to );
  263.                 }
  264.                 memset( &mailbuf[i], 0 , sizeof( mailbuf[0] ));
  265.                 return;
  266.             } else {
  267.                 log( "回复邮件: 无用信息或ID或名称或声明严重错误" );
  268.                 log( "use[%d] h[%d][%d] id[%s][%s] nm[%s][%s] st[%d]n",
  269.                      mailbuf[i].use, mailbuf[i].id_charname_hash, h,
  270.                      mailbuf[i].id_to, id,
  271.                      mailbuf[i].charname_to, charname,
  272.                      mailbuf[i].state);
  273.             }
  274.         }
  275.     }
  276.     log( "回复邮件: 邮件 %u 不能从 %s(%s) 找到n",
  277.          mesgid, id,charname );
  278. }
  280. void flushMail( int fd,
  281.            char *id,
  282.            char *charname )
  283. {
  284.     int i,c=0;
  285.     unsigned int h ;
  286.     char id_charname[1000];
  287. #define MAX_FLUSH_MAIL 1024
  288.     int flush_index[MAX_FLUSH_MAIL];
  289.     int flush_i=0;
  290.     snprintf( id_charname, sizeof( id_charname ) , "%s_%s", id, charname );
  291.     h = hashpjw( id_charname );
  292.     // Nuke +1
  293.     log("邮件缓冲大小:%d (%s)n",mailbufsize,chartime());
  294.     // Nuke *1
  295.     for(i=0;(i<mailbufsize)&&(i<MAX_FLUSH_MAIL);i++){
  296.         if( mailbuf[i].id_charname_hash == h &&
  297.             mailbuf[i].use &&
  298.             strcmp( mailbuf[i].id_to , id ) == 0 &&
  299.             strcmp( mailbuf[i].charname_to, charname ) == 0 ){
  300.             log( "消息ID:%un", mailbuf[i].message_id );
  301.             flush_index[flush_i++] = i;
  302.             c++;
  303.         }
  304.     }
  306.     for(i=0; i< flush_i ; i++ ){
  307.         int j;
  308.         for(j=0; j < flush_i-1 ; j++ ){
  309.             if( mailbuf[flush_index[j]].message_id >
  310.                 mailbuf[flush_index[j+1]].message_id ){
  311.                 int sw = flush_index[j];
  312.                 flush_index[j] = flush_index[j+1];
  313.                 flush_index[j+1] = sw;
  314.                 log( "inverted %d and %d in %d n", flush_index[j],
  315.                      flush_index[j+1], j );
  316.             }
  317.         }
  318.     }
  320.     /*   端卞霜耨允月 */
  321.     for(i=0;i< flush_i; i++ ){
  322.         /* flush 及桦宁反｝flush毛霜耨仄化五凶必□丞扔□田□卞
  323.            覆仄化分仃霜耨允木壬中中 */
  324.         saacproto_Message_send( fd,
  325.                                 mailbuf[flush_index[i]].id_from,
  326.                                 mailbuf[flush_index[i]].charname_from,
  327.                                 mailbuf[flush_index[i]].id_to,
  328.                                 mailbuf[flush_index[i]].charname_to,
  329.                                 mailbuf[flush_index[i]].text,
  330.                                 mailbuf[flush_index[i]].option,
  331.                                 mailbuf[flush_index[i]].message_id );
  332.         mailbuf[flush_index[i]].state = MS_WAIT_ACK;
  333.         log( "分类邮件ID:%un",
  334.                 mailbuf[flush_index[i]].message_id );
  335.     }
  336.     // Nuke *1
  337.     log( "邮件: 发送 %d 封邮件到 %s(%s)(%s)n", c, id, charname ,chartime());
  338. }
  340. // Nuke start: To expire undelivered mail
  341. #define MAIL_EXPIRE_TIME 3600
  342. void
  343. expireMail()
  344. {
  345.     int i,c=0;
  346.     unsigned int h ;
  347.     char id_charname[1000];
  348.     time_t now=time(NULL);
  349.     
  350.     /* 1荚及flush 匹霜耨允月    醒 */
  351. #define MAX_FLUSH_MAIL 1024
  352.     int flush_index[MAX_FLUSH_MAIL];
  353.     int flush_i=0;
  354.     // Nuke +1
  355.     log("邮件缓冲大小:%d (%s)n",mailbufsize,chartime());
  356.     // Nuke *1
  357.     for(i=0;(i<mailbufsize)&&(i<MAX_FLUSH_MAIL);i++){
  358.         if(mailbuf[i].use && (now - mailbuf[i].recv_time >= MAIL_EXPIRE_TIME)) {
  359.             log( "消息ID:%u 已过期n", mailbuf[i].message_id );
  360.             flush_index[flush_i++] = i;
  361.             c++;
  362.         }
  363.     }
  365.     /*   端卞霜耨允月 */
  366.     for(i=0;i< flush_i; i++ ){
  367.         
  368.         snprintf( id_charname, sizeof( id_charname), "%s_%s", 
  369.          mailbuf[flush_index[i]].id_to, 
  370.          mailbuf[flush_index[i]].charname_to );
  371.         h = hashpjw( id_charname ) & 0xff ;
  372. {
  373.             char savefile[1024];
  374.             char childname[1000];
  375.             snprintf( childname,sizeof(childname),"%u",
  376.              mailbuf[flush_index[i]].message_id );
  377.             makeDirFilename( savefile, sizeof(savefile),maildir,
  378.              h, childname );
  379.             if( unlink( savefile ) != 0 ){
  380.                 log( "failed to unlink %s: %sn",
  381.                 savefile, strerror(errno ));
  382.             } else {
  383.                 log( "过期邮件: 删除游戏 "
  384.                  "%u 从 %s(%s) 到 %s(%s)n",
  385.                         mailbuf[flush_index[i]].message_id,
  386.                         mailbuf[flush_index[i]].id_from,
  387.                         mailbuf[flush_index[i]].charname_from,
  388.                         mailbuf[flush_index[i]].id_to,
  389.                         mailbuf[flush_index[i]].charname_to );
  390.             }
  391.             memset( &mailbuf[flush_index[i]], 0 , sizeof( mailbuf[0] ));
  392. }
  393.     }
  394.     // Nuke *1
  395.     log( "过期邮件: 过期 %d 消息 (%s)n", c ,chartime());
  396. }
  398. int readMail( char *dir )
  399. {
  400.     int i, read_count=0;
  401.     for( i=0; i<256; i++){
  402.         char dirname[1000];
  403.         DIR *d;
  405.         snprintf(dirname, sizeof( dirname ), "%s/0x%x", dir, i );
  406.         d = opendir(dirname);
  407.         if(d == NULL ){
  408. mkdir( dirname, 0755);
  409. log("创建 %sn", dirname);
  410.             continue;
  411.         }
  412.         while(1){
  413.             struct dirent *de;        
  414.             de = readdir( d );
  415.             if( de == NULL )break;
  416.             if( de->d_name[0] != '.' ){
  417.                 char filename[1000];
  418.                 FILE *fp;
  419.                 struct stat s;
  420.                 snprintf( filename, sizeof( filename),
  421.                           "%s/%s", dirname, de->d_name );
  422.                 if( stat( filename, &s ) < 0 ){
  423.                     continue;
  424.                 }
  425.                 if( !(s.st_mode & S_IFREG)) continue;
  426.                 fp = fopen( filename, "r" );
  427.                 if( fp == NULL ){
  428.                     log( "不能打开文件 %s %sn",filename,strerror(errno));
  429.                     continue;
  430.                 }
  431.                 {
  432.                     char line[16384];
  433.                     char toid[1000] , fromid[1000];
  434.                     char tochar[CHARNAME_MAX*2+1];
  435.                     char fromchar[CHARNAME_MAX*2+1];
  436.                     char text[TEXT_MAX*2+1];
  437.                     int opt=0;
  438.                     toid[0] = fromid[0] = tochar[0] =
  439.                         fromchar[0] = text[0] = 0;
  440.                     fgets( line, sizeof(line), fp );                    
  441.                     chop(line);
  442.                     if( strncmp( TO_ID_HEAD , line, strlen(TO_ID_HEAD) )==0){
  443.                         snprintf( toid , sizeof( toid ),"%s",
  444.                                   line+strlen(TO_ID_HEAD ));
  445.                     }
  446.                     fgets( line, sizeof( line ), fp );
  447.                     chop(line);
  448.                     if( strncmp( TO_CHAR_HEAD, line,strlen(TO_CHAR_HEAD))==0){
  449.                         snprintf( tochar, sizeof( tochar ), "%s",
  450.                                   line+strlen( TO_CHAR_HEAD ));
  451.                         makeStringFromEscaped( tochar );
  452.                     }
  453.                     fgets( line, sizeof( line ),fp );
  454.                     chop(line);                    
  455.                     if( strncmp( FROM_ID_HEAD,line,strlen(FROM_ID_HEAD))==0){
  456.                         snprintf( fromid, sizeof( fromid ),"%s",
  457.                                   line + strlen( FROM_ID_HEAD ));
  458.                     }
  459.                     fgets( line,sizeof(line),fp);
  460.                     chop(line);                    
  461.                     if(strncmp(FROM_CHAR_HEAD,line,strlen(FROM_CHAR_HEAD))==0){
  462.                         snprintf( fromchar, sizeof( fromchar ),
  463.                                   line + strlen(FROM_CHAR_HEAD ));
  464.                         makeStringFromEscaped( fromchar );
  465.                     }
  466.                     fgets( line,sizeof(line),fp);
  467.                     chop(line);                    
  468.                     if( strncmp( OPTION_HEAD,line, strlen(OPTION_HEAD))==0){
  469.                         opt = atoi( line + strlen( OPTION_HEAD ) );
  470.                     }
  471. fgets( line, sizeof( line),fp);
  472.                     chop(line);                    
  473.                     if( strncmp(TEXT_HEAD,line,strlen(TEXT_HEAD))==0){
  474.                         snprintf( text, sizeof( text), "%s",
  475.                                   line + strlen( TEXT_HEAD ));
  476.                         makeStringFromEscaped( text );
  477.                     }
  478.                     if( toid[0] == 0 || fromid[0] == 0 ||
  479.                         tochar[0] == 0 || fromchar[0] == 0 ||
  480.                         text[0] == 0 ){
  481.                         log( "有问题邮件! %s 接收ID[%c] 接收名字[%c]"
  482.                              " 发送ID[%c] 发送名字[%c] 文本[%c]n",
  483.                              filename,
  484.                              toid[0], tochar[0], fromid[0], fromchar[0],
  485.                              text[0] );
  486.                         // Nuke +1 1027: Close for safe
  487.                         fclose(fp);
  488.                         continue;
  489.                     }
  490.                     receiveMail( fromid, fromchar,
  491.                                  toid, tochar,
  492.                                  text, opt , 1,
  493.                                  strtoul(de->d_name,NULL,10));
  494.                     read_count++;                    
  495.                 }
  496.                 fclose(fp);
  498.             }
  499.         }
  500.         closedir(d);
  501.     }
  502.     log( "读取邮件: 在'%s'目录里读取到 %d 封邮件 n", dir, read_count );
  503.     return 0;
  504. }