Initial revision

git-svn-id: http://opensvn.csie.org/pttbbs/pttbbs/trunk/pttbbs@1 63ad8ddf-47c3-0310-b6dd-a9e9d9715204

1 files changed, 194 insertions, 0 deletions

diff --git a/util/inndBM.c b/util/inndBM.c
new file mode 100644
index 00000000..426fa6f5
--- /dev/null
+++ b/util/inndBM.c
@@ -0,0 +1,194 @@
+/* 依據 .BOARD檔 & newsfeeds.bbs 列出參與轉信的所有板資料 */
+
+#include <stdio.h>
+#include <string.h>
+#include <sys/types.h>
+#include <sys/ipc.h>
+#include <sys/shm.h>
+#include "config.h"
+#include "pttstruct.h"
+#define INNDHOME  BBSHOME"/innd"
+
+#define INND_NEWSFEED  INNDHOME "/newsfeeds.bbs"
+#define INND_NODELIST  INNDHOME "/nodelist.bbs"
+#define INND_SCRIPT    INNDHOME "/bbsnnrpall.auto.sh"
+
+extern bcache_t *brdshm;
+extern boardheader_t *bcache;
+extern int numboards;
+int istran[MAX_BOARD];
+
+typedef 
+struct newssvr_t
+{
+  char name[30];
+  char address[256];
+  char type[10];
+}newssvr_t; 
+
+typedef
+struct newsfeed_t
+{
+  char group[128];
+  char board[15];
+  char server[30];
+}newsfeed_t;   
+
+newssvr_t server[128];
+newsfeed_t feedline[MAX_BOARD];
+int servercount;
+int feedcount;
+
+int newsfeed_cmp(newsfeed_t *a,newsfeed_t *b)
+{
+   int i;
+   i=strcasecmp(a->server,b->server);
+   if(i) return i;
+   return strcasecmp(a->board,b->board);
+}
+
+int get_server(char *name)
+{
+  int i;
+  for(i=0;i<servercount;i++)
+     if(!strcasecmp(server[i].name,name)) 
+	{return i;}
+  return -1;
+}
+
+int load_server()
+{
+    FILE *fp;
+    char str[128];
+
+    if (!(fp = fopen(INND_NODELIST, "r")))
+    {
+	return 0;
+    }
+
+    for(servercount=0; fgets(str, 128, fp); servercount++)
+    {
+        if(str[0]=='#') continue;
+        sscanf(str,"%s %s %s",server[servercount].name,
+		server[servercount].address,
+		server[servercount].type);
+    }
+    fclose(fp);
+   return servercount;
+}
+
+int load_newsfeeds()
+{
+    int bid;
+    FILE *fp;
+    char str[128];
+    if (!(fp = fopen(INND_NEWSFEED, "r")))
+    {
+	return 0;
+    }
+
+    for(feedcount=0; fgets(str, 128, fp); feedcount++)
+    {
+        if(str[0]=='#') continue;
+        sscanf(str,"%s %s %s",
+		feedline[feedcount].group,feedline[feedcount].board,
+		feedline[feedcount].server);
+        bid=getbnum(feedline[feedcount].board);
+        if(!bid) {feedcount--;continue; /*移除沒有的看板i*/}
+        strcpy(feedline[feedcount].board,bcache[bid-1].brdname);
+        /*校正大小寫 */
+
+        istran[bid-1]=1; 
+        
+    }
+    fclose(fp);
+   qsort(feedline, feedcount, sizeof(newsfeed_t), newsfeed_cmp);
+   return feedcount;
+}
+int dobbsnnrp(char *serverstr, int serverid,FILE *fpscript)
+{
+  char buf[256];
+  printf("set %s\r\n",serverstr);
+          strtok(serverstr,";\r\n");
+          strtok(server[serverid].address,";\r\n"); //防hack
+          sprintf(buf,INNDHOME"/bbsnnrp -c %s "
+              INNDHOME"/active/%s.auto.active >>"
+              INNDHOME"/log/inndBM.log 2>>"
+              INNDHOME"/log/inndBM.log.err &\r\n",
+              server[serverid].address,
+              serverstr);
+          system(buf);
+          if(fpscript)
+		fprintf(fpscript,INNDHOME"/bbsnnrp %s "
+			INNDHOME"/active/%s.auto.active >>"
+			INNDHOME"/log/inndBM.log 2>>"
+			INNDHOME"/log/inndBM.log.err &\r\n",
+			server[serverid].address,serverstr);
+  return 0;
+}
+int main()
+{
+    int i,serverid=0;
+    FILE *fp=NULL,*fpscript=fopen(INND_SCRIPT,"w");
+    char buf[256],serverstr[30]="";
+    resolve_boards();
+    memset(istran,0,sizeof(int)*MAX_BOARD);
+    load_server();
+    load_newsfeeds();
+
+    for(i=0;i<feedcount;i++)
+	{
+	  if(strcasecmp(serverstr,feedline[i].server))
+	   {
+	     if(get_server(feedline[i].server)==-1) continue;
+	     if(fp) {
+			fclose(fp);	
+                        dobbsnnrp(serverstr,serverid,fpscript);
+		    }
+	     strcpy(serverstr,feedline[i].server);
+	     serverid=get_server(feedline[i].server);
+	     sprintf(buf,INNDHOME"/active/%s.auto.active",serverstr);
+	     fp=fopen(buf,"w");
+	   }
+          if(fp)
+             fprintf(fp,"%-35s 0000000000 0000000000 y\r\n",feedline[i].group);
+	}
+    if(fp) 
+    {
+      dobbsnnrp(serverstr,serverid,fpscript);
+      fclose(fp);
+    }
+    if(fpscript)
+     {
+	fclose(fpscript);
+	chmod(INND_SCRIPT,0700);
+     }
+
+    // 重設轉信與不轉信版標記
+    for(i=0;i<numboards;i++)
+     {
+       if(bcache[i].brdname[0]=='\0' ||
+	   (bcache[i].brdattr & BRD_GROUPBOARD) ) continue;
+       if((bcache[i].brdattr & BRD_NOTRAN )&& istran[i])
+         {
+           while(brdshm->busystate) {safe_sleep(1);}
+  	   brdshm->busystate = 1;
+           bcache[i].brdattr = bcache[i].brdattr & ~BRD_NOTRAN;
+           strncpy(bcache[i].title + 5, "●", 2);
+	   brdshm->busystate = 0;
+
+           substitute_record(BBSHOME"/.BOARDS", &bcache[i],sizeof(boardheader_t),i+1);
+	 }
+       else if(!(bcache[i].brdattr & BRD_NOTRAN) && !istran[i]) 
+         {
+           while(brdshm->busystate) {safe_sleep(1);}
+           brdshm->busystate = 1;
+           bcache[i].brdattr = bcache[i].brdattr | BRD_NOTRAN;
+           strncpy(bcache[i].title + 5, "◎", 2);
+           brdshm->busystate = 0;
+           substitute_record(BBSHOME"/.BOARDS", &bcache[i],sizeof(boardheader_t),i+1);
+	 }
+
+     }
+    return 0;
+}