![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to qwknodes.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Synchronet] / sbbs / src / sbbs3|
Return to qwknodes.c CVS log | Up to [Synchronet] / sbbs / src / sbbs3 |
1.1 root 1: /* $Id: qwknodes.c,v 1.16 2005/12/04 20:41:51 rswindell Exp $ */
2:
3: /* Synchronet QWKnet node list or route.dat file generator */
4:
5: /****************************************************************************
6: * @format.tab-size 4 (Plain Text/Source Code File Header) *
7: * @format.use-tabs true (see http://www.synchro.net/ptsc_hdr.html) *
8: * *
9: * Copyright 2005 Rob Swindell - http://www.synchro.net/copyright.html *
10: * *
11: * This program is free software; you can redistribute it and/or *
12: * modify it under the terms of the GNU General Public License *
13: * as published by the Free Software Foundation; either version 2 *
14: * of the License, or (at your option) any later version. *
15: * See the GNU General Public License for more details: gpl.txt or *
16: * http://www.fsf.org/copyleft/gpl.html *
17: * *
18: * Anonymous FTP access to the most recent released source is available at *
19: * ftp://vert.synchro.net, ftp://cvs.synchro.net and ftp://ftp.synchro.net *
20: * *
21: * Anonymous CVS access to the development source and modification history *
22: * is available at cvs.synchro.net:/cvsroot/sbbs, example: *
23: * cvs -d :pserver:[email protected]:/cvsroot/sbbs login *
24: * (just hit return, no password is necessary) *
25: * cvs -d :pserver:[email protected]:/cvsroot/sbbs checkout src *
26: * *
27: * For Synchronet coding style and modification guidelines, see *
28: * http://www.synchro.net/source.html *
29: * *
30: * You are encouraged to submit any modifications (preferably in Unix diff *
31: * format) via e-mail to [email protected] *
32: * *
33: * Note: If this box doesn't appear square, then you need to fix your tabs. *
34: ****************************************************************************/
35:
36: #include "sbbs.h"
37: #include "nopen.h"
38: #include "crc16.h"
39: #include "crc32.h"
40: #include "conwrap.h" /* kbhit */
41:
42: unsigned _stklen=10000;
43: smb_t smb;
44: scfg_t cfg;
45:
46: void stripctrla(uchar *str)
47: {
48: uchar out[256];
49: int i,j;
50:
51: for(i=j=0;str[i] && j<sizeof(out)-1;i++) {
52: if(str[i]==CTRL_A && str[i+1]!=0)
53: i++;
54: else
55: out[j++]=str[i];
56: }
57: out[j]=0;
58: strcpy(str,out);
59: }
60:
61: int lputs(char* str)
62: {
63: char tmp[256];
64: int i,j,k;
65:
66: j=strlen(str);
67: for(i=k=0;i<j;i++) /* remove CRs */
68: if(str[i]==CR && str[i+1]==LF)
69: continue;
70: else
71: tmp[k++]=str[i];
72: tmp[k]=0;
73: return(fputs(tmp,stderr));
74: }
75: /****************************************************************************/
76: /* Performs printf() through local assembly routines */
77: /* Called from everywhere */
78: /****************************************************************************/
79: int lprintf(char *fmat, ...)
80: {
81: va_list argptr;
82: char sbuf[256];
83: int chcount;
84:
85: va_start(argptr,fmat);
86: chcount=vsnprintf(sbuf,sizeof(sbuf),fmat,argptr);
87: sbuf[sizeof(sbuf)-1]=0;
88: va_end(argptr);
89: lputs(sbuf);
90: return(chcount);
91: }
92: void bail(int code)
93: {
94: exit(code);
95: }
96:
97: char *loadmsgtail(smbmsg_t msg)
98: {
99: char *buf=NULL;
100: ushort xlat;
101: int i;
102: long l=0,length;
103:
104: for(i=0;i<msg.hdr.total_dfields;i++) {
105: if(msg.dfield[i].type!=TEXT_TAIL)
106: continue;
107: fseek(smb.sdt_fp,msg.hdr.offset+msg.dfield[i].offset
108: ,SEEK_SET);
109: fread(&xlat,2,1,smb.sdt_fp);
110: if(xlat!=XLAT_NONE) /* no translations supported */
111: continue;
112: length=msg.dfield[i].length-2;
113: if((buf=realloc(buf,l+msg.dfield[i].length+1))==NULL)
114: return(buf);
115: l+=fread(buf+l,1,length,smb.sdt_fp);
116: buf[l]=0;
117: }
118: return(buf);
119: }
120:
121:
122: void gettag(smbmsg_t msg, char *tag)
123: {
124: char *buf,*p;
125:
126: tag[0]=0;
127: buf=loadmsgtail(msg);
128: if(buf==NULL)
129: return;
130: truncsp(buf);
131: stripctrla(buf);
132: p=strrchr(buf,LF);
133: if(!p) p=buf;
134: else p++;
135: if(!strnicmp(p," � Synchronet � ",16))
136: p+=16;
137: if(!strnicmp(p," * Synchronet * ",16))
138: p+=16;
139: while(*p && *p<=' ') p++;
140: strcpy(tag,p);
141: free(buf);
142: }
143:
144:
145: #define FEED (1<<0)
146: #define LOCAL (1<<1)
147: #define APPEND (1<<2)
148: #define TAGS (1<<3)
149:
150: #define ROUTE (1<<1)
151: #define NODES (1<<2)
152: #define USERS (1<<3)
153:
154: char *usage="\nusage: qwknodes [-opts] cmds"
155: "\n"
156: "\n cmds: r = create route.dat"
157: "\n u = create users.dat"
158: "\n n = create nodes.dat"
159: "\n"
160: "\n opts: f = format addresses for nodes that feed from this system"
161: "\n a = append existing output files"
162: "\n t = include tag lines in nodes.dat"
163: "\n l = include local users in users.dat"
164: "\n m# = maximum message age set to # days"
165: "\n";
166:
167: int main(int argc, char **argv)
168: {
169: char str[256],tmp[128],tag[256],addr[256],*p;
170: int i,j,mode=0,cmd=0,o_mode,max_age=0;
171: ushort smm,sbl;
172: ulong *crc=NULL,curcrc,total_crcs=0,l;
173: FILE *route,*users,*nodes;
174: time_t now;
175: smbmsg_t msg;
176: char *ctrl_dir;
177: char revision[16];
178:
179: sscanf("$Revision: 1.16 $", "%*s %s", revision);
180:
181: fprintf(stderr,"\nSynchronet QWKnet Node/Route/User List Generator v%s-%s\n"
182: ,revision, PLATFORM_DESC);
183:
184: for(i=1;i<argc;i++)
185: for(j=0;argv[i][j];j++)
186: switch(toupper(argv[i][j])) {
187: case '/':
188: case '-':
189: while(argv[i][++j])
190: switch(toupper(argv[i][j])) {
191: case 'F':
192: mode|=FEED;
193: break;
194: case 'L':
195: mode|=LOCAL;
196: break;
197: case 'A':
198: mode|=APPEND;
199: break;
200: case 'T':
201: mode|=TAGS;
202: break;
203: case 'M':
204: j++;
205: max_age=atoi(argv[i]+j);
206: while(isdigit(argv[i][j+1])) j++;
207: break;
208: default:
209: printf(usage);
210: return(1);
211: }
212: j--;
213: break;
214: case 'R':
215: cmd|=ROUTE;
216: break;
217: case 'U':
218: cmd|=USERS;
219: break;
220: case 'N':
221: cmd|=NODES;
222: break;
223: default:
224: printf(usage);
225: return(1);
226: }
227:
228: if(!cmd) {
229: printf(usage);
230: return(1);
231: }
232:
233: if(mode&APPEND)
234: o_mode=O_WRONLY|O_CREAT|O_APPEND;
235: else
236: o_mode=O_WRONLY|O_CREAT|O_TRUNC;
237:
238: if(cmd&NODES)
239: if((nodes=fnopen(&i,"nodes.dat",o_mode))==NULL) {
240: printf("\7\nError opening nodes.dat\n");
241: return(1);
242: }
243:
244: if(cmd&USERS)
245: if((users=fnopen(&i,"users.dat",o_mode))==NULL) {
246: printf("\7\nError opening users.dat\n");
247: return(1);
248: }
249:
250: if(cmd&ROUTE)
251: if((route=fnopen(&i,"route.dat",o_mode))==NULL) {
252: printf("\7\nError opening route.dat\n");
253: return(1);
254: }
255:
256: cfg.size=sizeof(cfg);
257: ctrl_dir=getenv("SBBSCTRL");
258: if(ctrl_dir==NULL || ctrl_dir[0]==0) {
259: ctrl_dir="/sbbs/ctrl"; /* Not set? Use default */
260: printf("!SBBSCTRL environment variable not set, using default value: %s\n\n"
261: ,ctrl_dir);
262: }
263: SAFECOPY(cfg.ctrl_dir, ctrl_dir);
264:
265: if(!load_cfg(&cfg, NULL, TRUE, str)) {
266: printf("\7\n%s\n",str);
267: }
268:
269: now=time(NULL);
270: smm=crc16("smm",0);
271: sbl=crc16("sbl",0);
272: fprintf(stderr,"\n\n");
273: for(i=0;i<cfg.total_subs;i++) {
274: if(!(cfg.sub[i]->misc&SUB_QNET))
275: continue;
276: fprintf(stderr,"%-*s %s\n"
277: ,LEN_GSNAME,cfg.grp[cfg.sub[i]->grp]->sname,cfg.sub[i]->lname);
278: sprintf(smb.file,"%s%s",cfg.sub[i]->data_dir,cfg.sub[i]->code);
279: smb.retry_time=30;
280: smb.subnum=i;
281: if((j=smb_open(&smb))!=0) {
282: printf("smb_open returned %d\n",j);
283: continue;
284: }
285: if((j=smb_locksmbhdr(&smb))!=0) {
286: printf("smb_locksmbhdr returned %d\n",j);
287: smb_close(&smb);
288: continue;
289: }
290: if((j=smb_getstatus(&smb))!=0) {
291: printf("smb_getstatus returned %d\n",j);
292: smb_close(&smb);
293: continue;
294: }
295: smb_unlocksmbhdr(&smb);
296: msg.offset=smb.status.total_msgs;
297: if(!msg.offset) {
298: smb_close(&smb);
299: printf("Empty.\n");
300: continue;
301: }
302: while(!kbhit() && !ferror(smb.sid_fp) && msg.offset) {
303: msg.offset--;
304: fseek(smb.sid_fp,msg.offset*sizeof(idxrec_t),SEEK_SET);
305: if(!fread(&msg.idx,1,sizeof(idxrec_t),smb.sid_fp))
306: break;
307: fprintf(stderr,"%-5lu\r",msg.offset+1);
308: if(msg.idx.to==smm || msg.idx.to==sbl)
309: continue;
310: if(max_age && now-msg.idx.time>((ulong)max_age*24UL*60UL*60UL))
311: continue;
312: if((j=smb_lockmsghdr(&smb,&msg))!=0) {
313: printf("smb_lockmsghdr returned %d\n",j);
314: break;
315: }
316: if((j=smb_getmsghdr(&smb,&msg))!=0) {
317: printf("smb_getmsghdr returned %d\n",j);
318: break;
319: }
320: smb_unlockmsghdr(&smb,&msg);
321: if((mode&LOCAL && msg.from_net.type==NET_NONE)
322: || msg.from_net.type==NET_QWK) {
323: if(msg.from_net.type!=NET_QWK)
324: msg.from_net.addr="";
325: if(cmd&USERS) {
326: sprintf(str,"%s%s",msg.from_net.addr,msg.from);
327: curcrc=crc32(str,0);
328: }
329: else
330: curcrc=crc32(msg.from_net.addr,0);
331: for(l=0;l<total_crcs;l++)
332: if(curcrc==crc[l])
333: break;
334: if(l==total_crcs) {
335: total_crcs++;
336: if((crc=(ulong *)realloc(crc
337: ,sizeof(ulong)*total_crcs))==NULL) {
338: printf("Error allocating %lu bytes\n"
339: ,sizeof(ulong)*total_crcs);
340: break;
341: }
342: crc[l]=curcrc;
343: if(cmd&ROUTE && msg.from_net.type==NET_QWK) {
344: strcpy(addr,msg.from_net.addr);
345: if(mode&FEED) {
346: p=strrchr(addr,'/');
347: if(!p)
348: p=addr;
349: else
350: *(p++)=0;
351: sprintf(str,"%s %s:%s%c%s"
352: ,unixtodstr(&cfg,msg.hdr.when_written.time,tmp)
353: ,p,cfg.sys_id,p==addr ? 0 : '/'
354: ,addr);
355: fprintf(route,"%s\r\n",str);
356: }
357: else {
358: p=strrchr(addr,'/');
359: if(p) {
360: *(p++)=0;
361: fprintf(route,"%s %s:%.*s\r\n"
362: ,unixtodstr(&cfg,msg.hdr.when_written.time,str)
363: ,p
364: ,(uint)(p-addr)
365: ,addr);
366: }
367: }
368: }
369: if(cmd&USERS) {
370: if(msg.from_net.type!=NET_QWK)
371: strcpy(str,cfg.sys_id);
372: else if(mode&FEED)
373: sprintf(str,"%s/%s",cfg.sys_id,msg.from_net.addr);
374: else
375: strcpy(str,msg.from_net.addr);
376: p=strrchr(str,'/');
377: if(p)
378: fprintf(users,"%-25.25s %-8.8s %s (%s)\r\n"
379: ,msg.from,p+1
380: ,unixtodstr(&cfg,msg.hdr.when_written.time,tmp)
381: ,str);
382: else
383: fprintf(users,"%-25.25s %-8.8s %s\r\n"
384: ,msg.from,str
385: ,unixtodstr(&cfg,msg.hdr.when_written.time,tmp));
386: }
387: if(cmd&NODES && msg.from_net.type==NET_QWK) {
388: if(mode&TAGS)
389: gettag(msg,tag);
390: if(mode&FEED)
391: sprintf(str,"%s/%s",cfg.sys_id,msg.from_net.addr);
392: else
393: strcpy(str,msg.from_net.addr);
394: p=strrchr(str,'/');
395: if(p) {
396: if(mode&TAGS)
397: fprintf(nodes,"%-8.8s %s\r\n"
398: ,p+1
399: ,tag);
400: else
401: fprintf(nodes,"%-8.8s %s (%s)\r\n"
402: ,p+1
403: ,unixtodstr(&cfg,msg.hdr.when_written.time,tmp)
404: ,str);
405: }
406: else
407: fprintf(nodes,"%-8.8s %s\r\n"
408: ,str
409: ,mode&TAGS
410: ? tag
411: : unixtodstr(&cfg,msg.hdr.when_written.time,tmp));
412: }
413: }
414: }
415: smb_freemsgmem(&msg);
416: }
417:
418: smb_close(&smb);
419: if(kbhit()) {
420: getch();
421: fprintf(stderr,"Key pressed.\n");
422: break;
423: }
424: }
425: fprintf(stderr,"Done.\n");
426:
427: return(0);
428: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.