![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to main_wfc.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Synchronet] / sbbs / sbbs2|
Return to main_wfc.c CVS log | Up to [Synchronet] / sbbs / sbbs2 |
1.1 root 1: #line 1 "MAIN_WFC.C"
2:
3: /* Developed 1990-1997 by Rob Swindell; PO Box 501, Yorba Linda, CA 92885 */
4:
5: #include "sbbs.h"
6: #include "etext.h"
7: #include "cmdshell.h"
8: #include "qwk.h"
9:
10: extern char onquiet,nmi,llo,qwklogon;
11: extern char term_ret;
12: extern ulong connect_rate; /* already connected at xbps */
13: extern char *wday[],*mon[];
14: extern char *hungupstr;
15: extern char cidarg[];
16:
17: void reset_logon_vars(void)
18: {
19: int i;
20:
21: sys_status&=~(SS_USERON|SS_TMPSYSOP|SS_LCHAT|SS_ABORT
22: |SS_PAUSEON|SS_PAUSEOFF|SS_EVENT|SS_NEWUSER|SS_NEWDAY);
23: keybufbot=keybuftop=lbuflen=slcnt=altul=timeleft_warn=0;
24: logon_uls=logon_ulb=logon_dls=logon_dlb=0;
25: logon_posts=logon_emails=logon_fbacks=0;
26: batdn_total=batup_total=0;
27: usrgrps=usrlibs=0;
28: curgrp=curlib=0;
29: for(i=0;i<total_libs;i++)
30: curdir[i]=0;
31: for(i=0;i<total_grps;i++)
32: cursub[i]=0;
33: }
34:
35: void mail_maint(void)
36: {
37: int i;
38:
39: lprintf("\r\n\r\nPurging deleted/expired e-mail...");
40: sprintf(smb.file,"%sMAIL",data_dir);
41: smb.retry_time=smb_retry_time;
42: if((i=smb_open(&smb))!=0)
43: errormsg(WHERE,ERR_OPEN,smb.file,i);
44: else {
45: if((i=smb_locksmbhdr(&smb))!=0)
46: errormsg(WHERE,ERR_LOCK,smb.file,i);
47: else
48: delmail(0,MAIL_ALL);
49: smb_close(&smb); }
50: }
51:
52: /*************************************************************/
53: /* Returns 0 to reinitialize modem and start WFC cycle again */
54: /* Returns 1 to continue checking things peacefully */
55: /*************************************************************/
56: char wfc_events(time_t lastnodechk)
57: {
58: char str[256],str2[256],*buf;
59: int i,j,k,file,ret=1,chunk;
60: ulong l,m;
61: user_t user;
62: node_t node;
63: struct ffblk ff;
64: struct tm *gm;
65: struct date lastdate;
66:
67: for(i=0;i<total_qhubs;i++) {
68: gm=localtime(&now); /* Qnet call out based on time */
69: unixtodos(qhub[i]->last,&date,&curtime);
70: if(node_num==qhub[i]->node /* or frequency */
71: && (qhub[i]->last==-1L
72: || ((qhub[i]->freq
73: && (now-qhub[i]->last)/60>qhub[i]->freq)
74: || (qhub[i]->time
75: && (gm->tm_hour*60)+gm->tm_min>=qhub[i]->time
76: && (gm->tm_mday!=date.da_day || gm->tm_mon!=date.da_mon-1)))
77: && qhub[i]->days&(1<<gm->tm_wday))) {
78: offhook();
79: lputc(FF);
80: sprintf(str,"%sQNET\\%s.NOW"
81: ,data_dir,qhub[i]->id);
82: remove(str); /* Remove semaphore file */
83: sprintf(str,"%sQNET\\%s.PTR"
84: ,data_dir,qhub[i]->id);
85: file=nopen(str,O_RDONLY);
86: for(j=0;j<qhub[i]->subs;j++) {
87: sub[qhub[i]->sub[j]]->ptr=0;
88: lseek(file,sub[qhub[i]->sub[j]]->ptridx*4L,SEEK_SET);
89: read(file,&sub[qhub[i]->sub[j]]->ptr,4); }
90: if(file!=-1)
91: close(file);
92: if(pack_rep(i)) {
93: if((file=nopen(str,O_WRONLY|O_CREAT))==-1)
94: errormsg(WHERE,ERR_OPEN,str,O_WRONLY|O_CREAT);
95: else {
96: for(j=l=0;j<qhub[i]->subs;j++) {
97: while(filelength(file)<sub[qhub[i]->sub[j]]->ptridx*4L)
98: write(file,&l,4); /* initialize ptrs to null */
99: lseek(file,sub[qhub[i]->sub[j]]->ptridx*4L,SEEK_SET);
100: write(file,&sub[qhub[i]->sub[j]]->ptr,4); }
101: close(file); } }
102: delfiles(temp_dir,"*.*");
103:
104: qhub[i]->last=time(NULL);
105: sprintf(str,"%sQNET.DAB",ctrl_dir);
106: if((file=nopen(str,O_WRONLY))==-1) {
107: errormsg(WHERE,ERR_OPEN,str,O_WRONLY);
108: bail(1); }
109: lseek(file,sizeof(time_t)*i,SEEK_SET);
110: write(file,&qhub[i]->last,sizeof(time_t));
111: close(file);
112:
113: if(qhub[i]->call[0]) {
114: getnodedat(node_num,&thisnode,1);
115: thisnode.status=NODE_NETTING;
116: putnodedat(node_num,thisnode);
117: lputc(FF);
118: external(cmdstr(qhub[i]->call,nulstr,nulstr,NULL),EX_SWAP);
119: ret=0; }
120: for(j=0;j<10;j++) {
121: sprintf(str,"%s%s.QW%c",data_dir,qhub[i]->id,j ? (j-1)+'0' : 'K');
122: if(fexist(str)) {
123: lclini(node_scrnlen-1);
124: delfiles(temp_dir,"*.*");
125: unpack_qwk(str,i); } }
126: lputc(FF); } }
127:
128: for(i=0;i<total_phubs;i++) {
129: gm=localtime(&now); /* PostLink call out based on time */
130: unixtodos(phub[i]->last,&date,&curtime);
131: if(node_num==phub[i]->node /* or frequency */
132: && ((phub[i]->freq
133: && (now-phub[i]->last)/60>phub[i]->freq)
134: || (phub[i]->time
135: && (gm->tm_hour*60)+gm->tm_min>=phub[i]->time
136: && (gm->tm_mday!=date.da_day || gm->tm_mon!=date.da_mon-1)))
137: && phub[i]->days&(1<<gm->tm_wday)) {
138: offhook();
139: lputc(FF);
140:
141: phub[i]->last=time(NULL);
142: sprintf(str,"%sPNET.DAB",ctrl_dir);
143: if((file=nopen(str,O_WRONLY))==-1) {
144: errormsg(WHERE,ERR_OPEN,str,O_WRONLY);
145: bail(1); }
146: lseek(file,sizeof(time_t)*i,SEEK_SET);
147: write(file,&phub[i]->last,sizeof(time_t));
148: close(file);
149:
150: if(phub[i]->call[0]) {
151: getnodedat(node_num,&thisnode,1);
152: thisnode.status=NODE_NETTING;
153: putnodedat(node_num,thisnode);
154: lputc(FF);
155: external(cmdstr(phub[i]->call,nulstr,nulstr,NULL),EX_SWAP);
156: ret=0; } } }
157:
158: for(i=0;i<total_events;i++) {
159: if(!event[i]->node || event[i]->node>sys_nodes)
160: continue;
161: gm=localtime(&now);
162: unixtodos(event[i]->last,&date,&curtime);
163: if(event[i]->last==-1
164: || ((gm->tm_hour*60)+gm->tm_min>=event[i]->time
165: && (gm->tm_mday!=date.da_day || gm->tm_mon!=date.da_mon-1)
166: && event[i]->days&(1<<gm->tm_wday))) {
167:
168: if(event[i]->misc&EVENT_EXCL) { /* exclusive event */
169: offhook();
170: lputc(FF);
171: if(event[i]->node!=node_num) {
172: lprintf("Waiting for node %d to run timed event.\r\n\r\n"
173: ,event[i]->node);
174: lputs("Hit any key to abort wait...");
175: getnodedat(node_num,&thisnode,1);
176: thisnode.status=NODE_EVENT_LIMBO;
177: thisnode.aux=event[i]->node;
178: putnodedat(node_num,thisnode);
179: lastnodechk=0; /* really last event time check */
180: while(!lkbrd(0)) {
181: mswait(1);
182: now=time(NULL);
183: if(now-lastnodechk<10)
184: continue;
185: getnodedat(node_num,&thisnode,0);
186: if(thisnode.misc&NODE_DOWN)
187: return(0);
188: lastnodechk=now;
189: sprintf(str,"%sTIME.DAB",ctrl_dir);
190: if((file=nopen(str,O_RDONLY))==-1) {
191: errormsg(WHERE,ERR_OPEN,str,O_RDONLY);
192: event[i]->last=now;
193: return(0); }
194: lseek(file,(long)i*4L,SEEK_SET);
195: read(file,&event[i]->last,sizeof(time_t));
196: close(file);
197: if(now-event[i]->last<(60*60)) /* event is done */
198: break; }
199: sprintf(str,"%s%s.NOW",data_dir,event[i]->code);
200: remove(str);
201: event[i]->last=now;
202: ret=0; }
203: else {
204: lputs("Waiting for all nodes to become inactive before "
205: "running timed event.\r\n\r\n");
206: lputs("Hit any key to abort wait and run event now...\r\n\r\n");
207: getnodedat(node_num,&thisnode,1);
208: thisnode.status=NODE_EVENT_WAITING;
209: putnodedat(node_num,thisnode);
210: lastnodechk=0;
211: while(!lkbrd(0)) {
212: mswait(1);
213: now=time(NULL);
214: if(now-lastnodechk<10)
215: continue;
216: lastnodechk=now;
217: getnodedat(node_num,&thisnode,0);
218: if(thisnode.misc&NODE_DOWN)
219: return(0);
220: for(j=1;j<=sys_nodes;j++) {
221: if(j==node_num)
222: continue;
223: getnodedat(j,&node,0);
224: if(node.status==NODE_EVENT_WAITING) /* two nodes */
225: break; /* waiting ?!?! */
226: if(node.status!=NODE_OFFLINE
227: && node.status!=NODE_EVENT_LIMBO)
228: break; }
229: if(j>sys_nodes) /* all nodes either offline or in limbo */
230: break;
231: lprintf("\rWaiting for node %d (status=%d)"
232: ,j,node.status);
233: lputc(CLREOL); } } }
234: if(event[i]->node!=node_num)
235: event[i]->last=now;
236: else {
237: sprintf(str,"%s%s.NOW",data_dir,event[i]->code);
238: remove(str);
239: offhook();
240: lputc(FF);
241: getnodedat(node_num,&thisnode,1);
242: thisnode.status=NODE_EVENT_RUNNING;
243: putnodedat(node_num,thisnode);
244: if(event[i]->dir[0]) {
245: if(event[i]->dir[1]==':') /* drive letter specified */
246: setdisk(toupper(event[i]->dir[0])-'A');
247: if(chdir(event[i]->dir))
248: errormsg(WHERE,ERR_CHDIR,event[i]->dir,0); }
249:
250: external(cmdstr(event[i]->cmd,nulstr,nulstr,NULL),0); /* EX_CC */
251: event[i]->last=time(NULL);
252: sprintf(str,"%sTIME.DAB",ctrl_dir);
253: if((file=nopen(str,O_WRONLY))==-1) {
254: errormsg(WHERE,ERR_OPEN,str,O_WRONLY);
255: return(ret); }
256: lseek(file,(long)i*4L,SEEK_SET);
257: write(file,&event[i]->last,sizeof(time_t));
258: close(file);
259: ret=0; } } }
260:
261:
262: if(sys_status&SS_DAILY || thisnode.misc&NODE_EVENT) { /* daily events */
263:
264: offhook();
265: lputc(FF);
266:
267: if(sys_status&SS_DAILY) {
268:
269: getnodedat(node_num,&thisnode,1);
270: now=time(NULL);
271: j=lastuser();
272: thisnode.status=NODE_EVENT_RUNNING;
273: putnodedat(node_num,thisnode);
274:
275: lprintf("Running system daily maintenance...\r\n\r\n");
276: logentry("!:","Ran system daily maintenance");
277: for(i=1;i<=j;i++) {
278:
279: lprintf("\rChecking user %5u of %-5u",i,j);
280: user.number=i;
281: getuserdat(&user);
282:
283: /***********************************************/
284: /* Fix name (NAME.DAT and USER.DAT) mismatches */
285: /***********************************************/
286: if(user.misc&DELETED) {
287: if(strcmp(username(i,str2),"DELETED USER"))
288: putusername(i,nulstr);
289: continue; }
290:
291: if(strcmp(user.alias,username(i,str2)))
292: putusername(i,user.alias);
293:
294: if(!(user.misc&(DELETED|INACTIVE))
295: && user.expire && (ulong)user.expire<=(ulong)now) {
296: putsmsg(i,text[AccountHasExpired]);
297: sprintf(str,"%s #%u Expired",user.alias,user.number);
298: logentry("!%",str);
299: if(level_misc[user.level]&LEVEL_EXPTOVAL
300: && level_expireto[user.level]<10) {
301: user.flags1=val_flags1[level_expireto[user.level]];
302: user.flags2=val_flags2[level_expireto[user.level]];
303: user.flags3=val_flags3[level_expireto[user.level]];
304: user.flags4=val_flags4[level_expireto[user.level]];
305: user.exempt=val_exempt[level_expireto[user.level]];
306: user.rest=val_rest[level_expireto[user.level]];
307: if(val_expire[level_expireto[user.level]])
308: user.expire=now
309: +(val_expire[level_expireto[user.level]]*24*60*60);
310: else
311: user.expire=0;
312: user.level=val_level[level_expireto[user.level]]; }
313: else {
314: if(level_misc[user.level]&LEVEL_EXPTOLVL)
315: user.level=level_expireto[user.level];
316: else
317: user.level=expired_level;
318: user.flags1&=~expired_flags1; /* expired status */
319: user.flags2&=~expired_flags2; /* expired status */
320: user.flags3&=~expired_flags3; /* expired status */
321: user.flags4&=~expired_flags4; /* expired status */
322: user.exempt&=~expired_exempt;
323: user.rest|=expired_rest;
324: user.expire=0; }
325: putuserrec(i,U_LEVEL,2,itoa(user.level,str,10));
326: putuserrec(i,U_FLAGS1,8,ultoa(user.flags1,str,16));
327: putuserrec(i,U_FLAGS2,8,ultoa(user.flags2,str,16));
328: putuserrec(i,U_FLAGS3,8,ultoa(user.flags3,str,16));
329: putuserrec(i,U_FLAGS4,8,ultoa(user.flags4,str,16));
330: putuserrec(i,U_EXPIRE,8,ultoa(user.expire,str,16));
331: putuserrec(i,U_EXEMPT,8,ultoa(user.exempt,str,16));
332: putuserrec(i,U_REST,8,ultoa(user.rest,str,16));
333: if(expire_mod[0]) {
334: useron=user;
335: online=ON_LOCAL;
336: exec_bin(expire_mod,&main_csi);
337: online=0; }
338: }
339:
340: /***********************************************************/
341: /* Auto deletion based on expiration date or days inactive */
342: /***********************************************************/
343: if(!(user.exempt&FLAG('P')) /* Not a permanent account */
344: && !(user.misc&(DELETED|INACTIVE)) /* alive */
345: && (sys_autodel && (now-user.laston)/(long)(24L*60L*60L)
346: > sys_autodel)) { /* Inactive too long */
347: sprintf(str,"Auto-Deleted %s #%u",user.alias,user.number);
348: logentry("!*",str);
349: delallmail(i);
350: putusername(i,nulstr);
351: putuserrec(i,U_MISC,8,ultoa(user.misc|DELETED,str,16)); }
352:
353: if(!(user.misc&(DELETED|INACTIVE))
354: && preqwk_ar[0] && chk_ar(preqwk_ar,user)) { /* Pre-QWK */
355: for(k=1;k<=sys_nodes;k++) {
356: getnodedat(k,&node,0);
357: if((node.status==NODE_INUSE || node.status==NODE_QUIET
358: || node.status==NODE_LOGON) && node.useron==i)
359: break; }
360: if(k<=sys_nodes) /* Don't pre-pack with user online */
361: continue;
362: lclini(node_scrnlen-1);
363: lclatr(LIGHTGRAY);
364: lputc(FF);
365: console|=CON_L_ECHO;
366: lprintf("Pre-packing QWK for %s...\r\n"
367: ,user.alias);
368: useron=user;
369: online=ON_LOCAL;
370: statline=sys_def_stat;
371: statusline();
372: useron.qwk&=~QWK_FILES; /* turn off for pre-packing */
373: useron.misc|=(ANSI|COLOR);
374: delfiles(temp_dir,"*.*");
375: getmsgptrs();
376: getusrsubs();
377: batdn_total=0;
378: sprintf(str,"%sFILE\\%04u.QWK"
379: ,data_dir,useron.number);
380: if(pack_qwk(str,&l,1)) {
381: qwk_success(l,0,1);
382: putmsgptrs(); }
383: delfiles(temp_dir,"*.*");
384: lclatr(LIGHTGRAY);
385: lclini(node_scrnlen);
386: online=0;
387: lputc(FF); } }
388:
389: mail_maint();
390:
391: lprintf("\r\n\r\nRunning system daily event...\r\n");
392: logentry("!:","Ran system daily event");
393: sys_status&=~SS_DAILY;
394: if(sys_daily[0])
395: external(cmdstr(sys_daily,nulstr,nulstr,NULL),0); } /* EX_CC */
396:
397: if(thisnode.misc&NODE_EVENT) {
398: getnodedat(node_num,&thisnode,1);
399: thisnode.status=NODE_EVENT_RUNNING;
400: putnodedat(node_num,thisnode);
401: if(node_daily[0])
402: external(cmdstr(node_daily,nulstr,nulstr,NULL),0); /* EX_CC */
403: getnodedat(node_num,&thisnode,1);
404: thisnode.misc&=~NODE_EVENT;
405: putnodedat(node_num,thisnode); }
406: ret=0; }
407: return(ret);
408: }
409:
410: /****************************************************************************/
411: /* This function waits for either a caller or a local logon. It returns 0 */
412: /* if the user failed the logon procedure, a 1 if the user succeeded */
413: /* Called from function main */
414: /****************************************************************************/
415: char waitforcall()
416: {
417: static uint calls;
418: uchar str[256],str2[256],cname[LEN_CID+1],c,gotcaller=0,x,y,dcd,*p
419: ,ans=0,hbeat=0,menuon=0,blank=0
420: ,*ok=mdm_misc&MDM_VERBAL ? "OK":"0"
421:
422: /* IP logging vars added by enigma */
423: , ipstr[256], *ips;
424:
425: uint i,j,k,nodes,lastnodes=0;
426: long l,m;
427: int file,result_code=0;
428: time_t start,lastnodechk=0,laststatchk=0,laststatfdate=0;
429: node_t node;
430: struct tm *gm;
431: struct dfree d;
432: stats_t stats,node_stats;
433:
434: reset_logon_vars();
435: ipstr[0]=cid[0]=cname[0]=0;
436: online=console=0;
437: start=time(NULL);
438:
439: getnodedat(node_num,&thisnode,1);
440: thisnode.status=NODE_WFC;
441: thisnode.misc&=~(NODE_INTR|NODE_MSGW|NODE_NMSG|NODE_UDAT|NODE_POFF|NODE_AOFF);
442: putnodedat(node_num,thisnode);
443: catsyslog(0);
444: if(term_ret)
445: return(terminal());
446: /***
447: if(com_port)
448: rioctl(0x10f); /* for blanking debug line */
449: ***/
450:
451: if(qoc && calls) {
452: if(qoc==1)
453: offhook();
454: lclini(node_scrnlen);
455: lputc(FF);
456: bail(0); }
457: useron.misc=0;
458: rows=24;
459: lputc(FF);
460: if(node_misc&NM_RESETVID) {
461: textmode(C40);
462: textmode(C80);
463: _setcursortype(_NORMALCURSOR); }
464:
465: lclatr(curatr=LIGHTGRAY);
466: lclini(node_scrnlen);
467:
468:
469: lputc(FF);
470: if(com_port && !connect_rate) { /* Initialize the modem */
471: lprintf("\rSetting DTE rate: %lu baud",com_rate);
472: lputc(CLREOL);
473: #ifdef __OS2__
474: if((i=setbaud(com_rate))!=0) {
475: #else
476: if((i=setbaud((uint)(com_rate&0xffffL)))!=0) {
477: #endif
478: lprintf(" - Failed! (%d)\r\n",i);
479: bail(1); }
480: c=0;
481: if(!nmi && !(mdm_misc&MDM_DUMB)) /* if not dumb */
482: while(c<4) {
483: rioctl(IOFB);
484: rioctl(IOCM|PAUSE|ABORT);
485: rioctl(IOCS|PAUSE|ABORT);
486:
487: if(mdm_misc&MDM_CTS)
488: if(!(rioctl(IOSTATE)&CTS)) {
489: lputs("\rWaiting up to 30 seconds for CTS to raise ( )\b\b\b");
490: for(i=0;i<30 && !lkbrd(0);i++) { /* wait upto 15 seconds */
491: lprintf("%2d\b\b",i+1);
492: mswait(1000);
493: if(rioctl(IOSTATE)&CTS)
494: break; }
495: if(i==30) {
496: lputs("\r\n\r\nModem configured for hardware flow "
497: "control and CTS is stuck low.\r\n");
498: logline("@!","CTS stuck low. Can't initialize.");
499: bail(1); } }
500:
501: lputs("\rInitializing modem...");
502: lputc(CLREOL);
503:
504: dtr(5); /* in case we're still connected to somebody */
505: dtr(1);
506: mswait(750); /* DTR is sometimes slow */
507: rioctl(IOFB); /* crap comes in when dtr is raised ? */
508: if(rioctl(IOSTATE)&DCD && mdm_hang[0]) {
509: mdmcmd(mdm_hang);
510: if(strcmp(str,"0") && strcmp(str,"OK"))
511: getmdmstr(str,SEC_OK); }
512:
513: /******************************************/
514: /* Take phone off-hook while initializing */
515: /******************************************/
516: offhook();
517: getmdmstr(str,SEC_OK);
518: if(strcmp(str,"0") && strcmp(str,"OK"))
519: getmdmstr(str,SEC_OK);
520:
521: /*********************************************************/
522: /* Send User Configured (broken?) initialization strings */
523: /*********************************************************/
524: mdmcmd(mdm_init);
525: if(mdm_spec[0]) {
526: getmdmstr(str,SEC_OK);
527: if(strcmp(str,"0") && strcmp(str,"OK"))
528: getmdmstr(str,SEC_OK);
529: mdmcmd(mdm_spec); }
530: getmdmstr(str,SEC_OK);
531: if(strcmp(str,"0") && strcmp(str,"OK"))
532: getmdmstr(str,SEC_OK);
533:
534: /*****************************/
535: /* Send AT&C1 if DCD is high */
536: /*****************************/
537: if(rioctl(IOSTATE)&DCD) {
538: lputs("\r\nDCD is high. Sending AT&C1 to modem...");
539: mdmcmd("AT&C1");
540: getmdmstr(str,SEC_OK);
541: if(strcmp(str,ok))
542: getmdmstr(str,SEC_OK); }
543:
544: /**********************************************/
545: /* DCD still high? Pause and try dropping DTR */
546: /**********************************************/
547: if(rioctl(IOSTATE)&DCD) {
548: lputs("\r\nDCD is high. Pausing...");
549: dtr(0);
550: mswait(2000);
551: rioctl(MSR);
552: if(rioctl(IOSTATE)&DCD) {
553: lputs("\rDCD was high after modem init.\r\n");
554: logentry("@!","DCD was high after modem init");
555: if(mdm_misc&MDM_NODTR)
556: mdmcmd(mdm_hang);
557: else
558: dtr(15);
559: if(rioctl(IOSTATE)&DCD) {
560: lputs("Hanging up failed to lower DCD.\r\n");
561: logentry("@!","Hanging up failed to lower DCD");
562: if(++c==4)
563: break;
564: continue; } }
565: dtr(1); }
566:
567: /************************************************************/
568: /* Let's repair any damage the user configured init strings */
569: /* may have caused */
570: /************************************************************/
571: for(i=0;i<4;i++) {
572: rioctl(IOFB);
573: mdmcmd("AT");
574: if(!getmdmstr(str,SEC_OK) || !strcmp(str,ok))
575: break;
576: if(!strcmp(str,"AT")) { /* Echoing commands? */
577: getmdmstr(str,SEC_OK); /* Get OK */
578: lputs("\r\nCommand echoed. Sending ATE0 to modem...");
579: mdmcmd("ATE0"); }
580: else if(mdm_misc&MDM_VERBAL && !strcmp(str,"0")) { /* numeric? */
581: lputs("\r\nNumeric response. Sending ATV1 to modem...");
582: mdmcmd("ATV1"); }
583: else if(!(mdm_misc&MDM_VERBAL) && !strcmp(str,"OK")) {
584: lputs("\r\nVerbal response. Sending ATV0 to modem...");
585: mdmcmd("ATV0"); }
586: else {
587: lprintf("\r\nUnrecognized response '%s'. Sending AT to modem..."
588: ,str);
589: mdmcmd("AT"); }
590: if(getmdmstr(str,SEC_OK) && !strcmp(str,ok))
591: break; }
592:
593: /************************************************/
594: /* Put phone back on-hook and check result code */
595: /************************************************/
596: if(!mdm_hang[0])
597: mdmcmd("ATH");
598: else
599: mdmcmd(mdm_hang);
600: if(!getmdmstr(str,SEC_OK)) {
601: lputs("\r\nNo response.\r\n");
602: logentry("@!","No response"); }
603: else {
604: if(!strcmp(str,ok))
605: break;
606: lprintf("\r\nInvalid result code: '%s' "
607: "instead of '%s'.\r\n",str,ok);
608: sprintf(tmp,"Invalid result code: '%s' instead of '%s'.",str,ok);
609: logentry("@!",tmp); }
610: if(++c==4)
611: break;
612: rioini(0,0); /* remove com routines */
613: sys_status&=~SS_COMISR;
614: comini();
615: setrate(); }
616: if(c==4) {
617: lputs("\r\nModem failed initialization.\r\n");
618: errorlog("Modem failed initialization.");
619: offhook();
620: bail(1); }
621: lputc(FF); }
622:
623: else if(com_port && connect_rate) {
624: gotcaller=1;
625: console=CON_R_ECHO|CON_L_ECHO|CON_R_INPUT|CON_L_INPUT;
626: online=ON_REMOTE;
627: sprintf(connection,"%lu",connect_rate);
628: cur_rate=connect_rate;
629: cur_cps=connect_rate/10;
630: connect_rate=0;
631: if(cidarg[0]) { /* Caller-id passed as argument */
632: mdm_misc|=MDM_CALLERID;
633: p=strstr(cidarg,"NUMBER:");
634: if(p) p+=8;
635: else {
636: p=strstr(cidarg,"NMBR");
637: if(p) p+=7; }
638: if(p) { /* 3 message format */
639: sprintf(cid,"%.*s",LEN_CID,p);
640: for(i=strlen(cid);!isdigit(cid[i]) && i;i--)
641: ;
642: cid[i+1]=0; /* chop off non-numbers */
643: p=strstr(cidarg,"NAME:");
644: if(p) p+=6;
645: else {
646: p=strstr(cidarg,"NAME");
647: if(p) p+=7; }
648: if(p)
649: sprintf(cname,"%.*s",LEN_CID,p); }
650: else if(strlen(cidarg)>12) /* Single message format */
651: sprintf(cid,"%.*s",LEN_CID,cidarg+12);
652: else
653: sprintf(cid,"ERROR: '%s'",cidarg); } }
654:
655:
656: if(!online) {
657: /*******************************************************/
658: /* To make sure that BBS print routines work correctly */
659: /*******************************************************/
660: useron.number=1;
661: getuserdat(&useron);
662: if(!useron.number)
663: useron.misc=ANSI|COLOR; }
664:
665: useron.misc&=~UPAUSE; /* make sure pause is off */
666:
667: if(llo) {
668: quicklogonstuff();
669: sys_status&=~SS_USERON;
670: gotcaller=1; }
671:
672: if(!(useron.misc&EXPERT) && !gotcaller) { /* Novice sysop */
673: console=CON_L_ECHO;
674: online=ON_LOCAL;
675: lputc(FF);
676: tos=1;
677: lncntr=0;
678: menu("WFC");
679: menuon=1;
680: online=0; }
681:
682: while(!gotcaller) {
683: mswait(0); /* give up rest of time slice */
684:
685: console=CON_L_ECHO;
686: now=time(NULL);
687:
688: if(node_scrnblank && (now-start)/60>node_scrnblank
689: && !blank) { /* blank screen */
690: lputc(FF);
691: menuon=0;
692: blank=1; }
693: if(mdm_reinit && (now-start)/60>mdm_reinit) /* reinitialize modem */
694: return(0);
695: if(now-lastnodechk>node_sem_check) { /* check node.dab every x seconds */
696:
697: #if 1
698: if((i=heapcheck())!=_HEAPOK) {
699: lputc(FF);
700: offhook();
701: errormsg(WHERE,ERR_CHK,"heap",i);
702: bail(1); }
703: #endif
704:
705: for(i=0;i<total_qhubs;i++)
706: if(node_num==qhub[i]->node) {
707: sprintf(str,"%sQNET\\%s.NOW",data_dir,qhub[i]->id);
708: if(fexist(str))
709: qhub[i]->last=-1; }
710:
711: for(i=0;i<total_events;i++)
712: if(node_num==event[i]->node || event[i]->misc&EVENT_EXCL) {
713: sprintf(str,"%s%s.NOW",data_dir,event[i]->code);
714: if(fexist(str))
715: event[i]->last=-1; }
716:
717: lastnodechk=now;
718: getnodedat(node_num,&thisnode,0);
719: if(thisnode.misc&NODE_DOWN) {
720: lputc(FF);
721: offhook();
722: bail(0); }
723: if(thisnode.status!=NODE_WFC) {
724: getnodedat(node_num,&thisnode,1);
725: thisnode.status=NODE_WFC;
726: putnodedat(node_num,thisnode); }
727: if(thisnode.misc&NODE_RRUN) { /* Re-run the node */
728: offhook();
729: lputc(FF);
730: getnodedat(node_num,&thisnode,1);
731: thisnode.status=NODE_OFFLINE;
732: thisnode.misc=0;
733: putnodedat(node_num,thisnode);
734: close(nodefile);
735: close(node_ext);
736: sys_status&=~SS_NODEDAB;
737: if(sys_status&SS_LOGOPEN)
738: close(logfile);
739: if(sys_status&SS_COMISR)
740: rioini(0,0);
741: sys_status&=~(SS_COMISR|SS_INITIAL|SS_LOGOPEN);
742: p=strchr(orgcmd,' ');
743: if(p)
744: p++;
745: close(5);
746: if(execle(orgcmd,orgcmd,p,NULL,envp)) {
747: lprintf("\r\nCouldn't execute %s!\r\n",orgcmd);
748: bail(1); } } }
749:
750: if(!wfc_events(lastnodechk))
751: return(0);
752:
753: if(!menuon) {
754: /******************/
755: /* Roaming cursor */
756: /******************/
757: x=lclwx();
758: y=lclwy();
759: switch(random(5)) {
760: case 0:
761: if(x>1)
762: x--;
763: break;
764: case 1:
765: if(x<79)
766: x++;
767: break;
768: case 2:
769: if(y>1)
770: y--;
771: break;
772: case 4:
773: if(y<node_scrnlen-2)
774: y++;
775: break; } }
776: else { /* across the bottom */
777: y=25;
778: x=lclwx();
779: if(x%2) x+=2;
780: else x-=2;
781: if(x<1)
782: x=1;
783: else if(x>80)
784: x=80;
785: /*
786: lclxy(x,y);
787: gettext(x,y,x,y,&i);
788: lclatr(random(0xf)+1);
789: lputc(i);
790: lclatr(LIGHTGRAY);
791: */
792: /**
793: mswait(100);
794: puttext(x,y,x,y,&i);
795: **/ }
796:
797: #ifndef __FLAT__ // Heart beat always for 32-bit OSs
798: if(inDV) {
799: #endif
800: lclxy(80,1);
801: if(hbeat) {
802: lclatr(RED|HIGH);
803: lputc(3); }
804: else
805: lputc(0);
806: hbeat=!hbeat;
807: lclatr(LIGHTGRAY);
808: #ifndef __FLAT__
809: }
810: #endif
811:
812: lclxy(x,y);
813: mswait(100);
814:
815: /* Wait for call screen */
816: /* check every 10 seconds */
817:
818: if(node_misc&NM_WFCSCRN && now-laststatchk>node_stat_check
819: && !menuon && !blank) {
820: laststatchk=now;
821: sprintf(str,"%sDSTS.DAB",ctrl_dir);
822: if(fdate(str)!=laststatfdate) { /* system statistics */
823: lclxy(1,1);
824: lclatr(LIGHTGRAY);
825: lputs("Retrieving Statistics.");
826: lputc(CLREOL);
827: if(!laststatfdate) /* First time this WFC */
828: getstats(node_num,&node_stats);
829: lputc('.');
830: laststatfdate=fdate(str);
831: getstats(0,&stats);
832: lputc('.');
833: l=m=0;
834: if(node_misc&NM_WFCMSGS) {
835: for(i=0;i<total_subs;i++)
836: l+=getposts(i); /* l=total posts */
837: lputc('.');
838: for(i=0;i<total_dirs;i++)
839: m+=getfiles(i); /* m=total files */
840: lputc('.'); }
841: i=getmail(0,0); /* i=total email */
842: lputc('.');
843: j=getmail(1,0); /* j=total fback */
844: lclxy(1,1);
845: lclatr(GREEN);
846: lprintf("Node #: ");
847: lclatr(GREEN|HIGH);
848: gm=localtime(&now);
849: lprintf("%-3u ",node_num);
850: lclatr(GREEN);
851: lprintf("%-3.3s %-2u Space: ",mon[gm->tm_mon],gm->tm_mday);
852: if(temp_dir[1]==':')
853: k=temp_dir[0]-'A'+1;
854: else k=0;
855: getdfree(k,&d);
856: if((ulong)d.df_bsec*(ulong)d.df_sclus
857: *(ulong)d.df_avail<((ulong)min_dspace*1024L)*2L)
858: lclatr(RED|HIGH|BLINK);
859: else
860: lclatr(GREEN|HIGH);
861: sprintf(str,"%sk",ultoac(((ulong)d.df_bsec
862: *(ulong)d.df_sclus*(ulong)d.df_avail)/1024UL,tmp));
863: lprintf("%-12.12s",str);
864: if(lastuseron[0]) {
865: lclatr(GREEN);
866: lprintf("Laston: ");
867: lclatr(GREEN|HIGH);
868: lprintf(lastuseron);
869: lclatr(GREEN);
870: if(thisnode.connection)
871: lprintf(" %u",thisnode.connection);
872: else
873: lprintf(" Local"); }
874: lprintf("\r\n");
875: lclatr(GREEN);
876: lprintf("Logons: ");
877: lclatr(GREEN|HIGH);
878: sprintf(tmp,"%lu/%lu",node_stats.ltoday,stats.ltoday);
879: lprintf("%-12.12s",tmp);
880: lclatr(GREEN);
881: lprintf("Total: ");
882: lclatr(GREEN|HIGH);
883: lprintf("%-12.12s",ultoac(stats.logons,tmp));
884: lclatr(GREEN);
885: lprintf("Timeon: ");
886: lclatr(GREEN|HIGH);
887: sprintf(tmp,"%lu/%lu",node_stats.ttoday,stats.ttoday);
888: lprintf("%-12.12s",tmp);
889: lclatr(GREEN);
890: lprintf("Total: ");
891: lclatr(GREEN|HIGH);
892: lprintf("%-12.12s\r\n",ultoac(stats.timeon,tmp));
893: lclatr(GREEN);
894: lprintf("Emails: ");
895: lclatr(GREEN|HIGH);
896: sprintf(str,"%u/%u",(uint)stats.etoday,i);
897: lprintf("%-12.12s",str);
898: lclatr(GREEN);
899: lprintf("Posts: ");
900: lclatr(GREEN|HIGH);
901: sprintf(str,"%u",(uint)stats.ptoday);
902: if(node_misc&NM_WFCMSGS) {
903: strcat(str,"/");
904: strcat(str,ultoa(l,tmp,10)); }
905: lprintf("%-12.12s",str);
906: lclatr(GREEN);
907: lprintf("Fbacks: ");
908: lclatr(GREEN|HIGH);
909: sprintf(str,"%u/%u",(uint)stats.ftoday,j);
910: lprintf("%-12.12s",str);
911: lclatr(GREEN);
912: lprintf("Users: ");
913: lclatr(GREEN|HIGH);
914: sprintf(str,"%u/%u",stats.nusers,lastuser());
915: lprintf("%-12.12s\r\n",str);
916: lclatr(GREEN);
917: lprintf("Uloads: ");
918: lclatr(GREEN|HIGH);
919: ultoac(stats.ulb/1024UL,tmp);
920: strcat(tmp,"k");
921: lprintf("%-12.12s",tmp);
922: lclatr(GREEN);
923: lprintf("Files: ");
924: lclatr(GREEN|HIGH);
925: sprintf(str,"%u",(uint)stats.uls);
926: if(node_misc&NM_WFCMSGS) {
927: strcat(str,"/");
928: strcat(str,ultoa(m,tmp,10)); }
929: lprintf("%-12.12s",str);
930: lclatr(GREEN);
931: lprintf("Dloads: ");
932: lclatr(GREEN|HIGH);
933: ultoac(stats.dlb/1024UL,tmp);
934: strcat(tmp,"k");
935: lprintf("%-12.12s",tmp);
936: lclatr(GREEN);
937: lprintf("Files: ");
938: lclatr(GREEN|HIGH);
939: lprintf("%-12.12s\r\n",ultoac(stats.dls,tmp)); }
940: lclatr(curatr=LIGHTGRAY);
941: lclxy(1,6);
942: nodes=0;
943: for(i=1;i<=sys_nodes;i++) {
944: getnodedat(i,&node,0);
945: if((node.status!=NODE_WFC && node.status!=NODE_OFFLINE)
946: || node.errors) {
947: lputc(CLREOL);
948: printnodedat(i,node);
949: nodes++; } }
950: if(nodes<lastnodes) {
951: i=j=lclwy();
952: j+=(lastnodes-nodes)+1;
953: for(;i<=node_scrnlen && i<j;i++) {
954: lclxy(1,i);
955: lputc(CLREOL); } }
956: lastnodes=nodes;
957: lclatr(curatr=LIGHTGRAY); }
958:
959:
960: if(!(node_misc&NM_NO_LKBRD) && lkbrd(1)) {
961: start=time(NULL);
962: /* menuon=0; */
963: lputc(FF);
964: tos=1;
965: lncntr=0;
966: i=lkbrd(0);
967: if(!(i&0xff) && (i>=0x3b00 && i<=0x4400)
968: || i==0x8500 || i==0x8600) { /* F1-F12 */
969: if(i>=0x3b00 && i<=0x4400)
970: i=((i-0x3b00)>>8);
971: else if(i==0x8500)
972: i=10;
973: else
974: i=11;
975: offhook();
976: external(cmdstr(wfc_scmd[i],nulstr,nulstr,NULL),EX_SWAP);
977: return(0); }
978:
979: if(isdigit(i&0xff)) {
980: offhook();
981: external(cmdstr(wfc_cmd[i&0xf],nulstr,nulstr,NULL),0);
982: return(0); }
983:
984: switch(toupper(i)) {
985: case 'A': /* forced answer */
986: ans=1;
987: break;
988: case 'C': /* configure */
989: if(node_misc&NM_SYSPW) {
990: quicklogonstuff();
991: if(!chksyspass(1))
992: return(0); }
993: offhook();
994: if(sys_status&SS_LOGOPEN) {
995: close(logfile);
996: sys_status&=~SS_LOGOPEN; }
997: if(sys_status&SS_COMISR) {
998: rioini(0,0); /* replace COM i/o vectors */
999: sys_status&=~SS_COMISR; }
1000: close(nodefile);
1001: close(node_ext);
1002: sys_status&=~SS_NODEDAB;
1003: sprintf(str,"%sEXECSBBS.%s",exec_dir,
1004: #ifdef __OS2__
1005: "EXE"
1006: #else
1007: "COM"
1008: #endif
1009: );
1010: sprintf(tmp,"\"%s \"",cmdstr(scfg_cmd,nulstr,nulstr,NULL));
1011: if(execl(str,str,".",tmp,orgcmd,NULL,envp)) {
1012: errormsg(WHERE,ERR_EXEC,str,0);
1013: bail(1); }
1014: case 'D': /* Dos shell */
1015: offhook();
1016: external(comspec,0);
1017: return(0);
1018: case 'F': /* Force Network Call-out */
1019: quicklogonstuff();
1020: lclatr(YELLOW);
1021: lputs("QWK Hub ID: ");
1022: lclatr(WHITE);
1023: if(!getstr(str,8,K_UPPER))
1024: return(0);
1025: for(i=0;i<total_qhubs;i++)
1026: if(!stricmp(str,qhub[i]->id)) {
1027: if(qhub[i]->node==node_num)
1028: qhub[i]->last=-1;
1029: else {
1030: sprintf(tmp,"%sQNET\\%s.NOW",data_dir,str);
1031: if((file=nopen(tmp,O_CREAT|O_TRUNC|O_WRONLY))
1032: !=-1)
1033: close(file); }
1034: break; }
1035: return(0);
1036: case 'L': /* Log */
1037: if(node_misc&NM_SYSPW) {
1038: quicklogonstuff();
1039: if(!chksyspass(1))
1040: return(0); }
1041: offhook();
1042: now=time(NULL);
1043: unixtodos(now,&date,&curtime);
1044: sprintf(str,"%sLOGS\\%2.2d%2.2d%2.2d.LOG"
1045: ,data_dir,date.da_mon,date.da_day,date.da_year-1900);
1046: external(cmdstr(node_viewer,str,nulstr,NULL),0);
1047: return(0);
1048: case 'M': /* Read all mail */
1049: quicklogonstuff();
1050: if(node_misc&NM_SYSPW && !chksyspass(1))
1051: return(0);
1052: readmail(1,MAIL_ALL);
1053: online=console=0;
1054: return(0);
1055: case 'N': /* Node statistics */
1056: quicklogonstuff();
1057: if(node_misc&NM_SYSPW && !chksyspass(1))
1058: return(0);
1059: useron.misc|=UPAUSE;
1060: printstatslog(node_num);
1061: pause();
1062: return(0);
1063: case 'Q': /* Quit */
1064: offhook();
1065: bail(0);
1066: case 'R': /* Read feedback */
1067: quicklogonstuff();
1068: if(node_misc&NM_SYSPW && !chksyspass(1))
1069: return(0);
1070: readmail(1,MAIL_YOUR);
1071: return(0);
1072: case 'K': /* Sent mail */
1073: quicklogonstuff();
1074: if(node_misc&NM_SYSPW && !chksyspass(1))
1075: return(0);
1076: readmail(1,MAIL_SENT);
1077: return(0);
1078: case 'S': /* System Statistics */
1079: quicklogonstuff();
1080: if(node_misc&NM_SYSPW && !chksyspass(1))
1081: return(0);
1082: useron.misc|=UPAUSE;
1083: printstatslog(0);
1084: pause();
1085: return(0);
1086: case 'T': /* Terminal mode */
1087: if(!com_port) {
1088: lprintf("No COM port configured.");
1089: getch();
1090: lputc(FF);
1091: return(0); }
1092: if(node_misc&NM_SYSPW) {
1093: quicklogonstuff();
1094: if(!chksyspass(1))
1095: return(0); }
1096: return(terminal());
1097: case 'U': /* User edit */
1098: quicklogonstuff();
1099: useredit(0,1);
1100: return(0);
1101: case 'E':
1102: case 'W': /* Write e-mail */
1103: quicklogonstuff();
1104: if(node_misc&NM_SYSPW && !chksyspass(1))
1105: return(0);
1106: bputs(text[Email]);
1107: if(!getstr(str,50,0))
1108: return(0);
1109: if(!strchr(str,'@') && (i=finduser(str))!=0)
1110: email(i,nulstr,nulstr,WM_EMAIL);
1111: else
1112: netmail(str,nulstr,0);
1113: return(0);
1114: case 'X': /* Exit with phone on-hook */
1115: bail(0);
1116: case 'Y': /* Yesterday's log */
1117: if(node_misc&NM_SYSPW) {
1118: quicklogonstuff();
1119: if(!chksyspass(1))
1120: return(0); }
1121: offhook();
1122: now=time(NULL);
1123: now-=(ulong)60L*24L*60L;
1124: unixtodos(now,&date,&curtime);
1125: sprintf(str,"%sLOGS\\%2.2d%2.2d%2.2d.LOG"
1126: ,data_dir,date.da_mon,date.da_day,date.da_year-1900);
1127: external(cmdstr(node_viewer,str,nulstr,NULL),0);
1128: return(0);
1129: case 'Z':
1130: mail_maint();
1131: return(0);
1132: case '?': /* Menu */
1133: if(menuon) {
1134: menuon=0;
1135: lputc(FF);
1136: laststatchk=0;
1137: laststatfdate=0; }
1138: else {
1139: online=ON_LOCAL;
1140: menu("WFC");
1141: menuon=1;
1142: blank=0;
1143: online=0; }
1144: continue;
1145: case SP: /* Log on */
1146: lclatr(WHITE|HIGH); lputc('Y'); lclatr(GREEN);
1147: lputs(" Yes\r\n");
1148: lclatr(WHITE|HIGH); lputc('Z'); lclatr(GREEN);
1149: lputs(" Yes, Quiet\r\n");
1150: lclatr(WHITE|HIGH); lputc('F'); lclatr(GREEN);
1151: lputs(" Fast User #1\r\n");
1152: lclatr(WHITE|HIGH); lputc('Q'); lclatr(GREEN);
1153: lputs(" Fast User #1, Quiet\r\n");
1154: lclatr(BROWN|HIGH);
1155: lputs("\r\nLog on? [No]: ");
1156: lclatr(LIGHTGRAY);
1157: i=getch();
1158: switch(toupper(i)) {
1159: case 'Z':
1160: onquiet=1;
1161: case 'Y': /* Yes, logon */
1162: lputc(FF);
1163: quicklogonstuff();
1164: sys_status&=~SS_USERON;
1165: useron.misc=(UPAUSE|ANSI|COLOR);
1166: gotcaller=1;
1167: continue;
1168: case 'Q':
1169: onquiet=1;
1170: case 'F':
1171: lputc(FF);
1172: quicklogonstuff();
1173: if(sys_misc&SM_REQ_PW || node_misc&NM_SYSPW) {
1174: useron.misc=(UPAUSE|ANSI|COLOR);
1175: gotcaller=1;
1176: continue; }
1177: if(!useron.number) {
1178: lputc(7);
1179: lputs("A Sysop account hasn't been created");
1180: getch();
1181: return(0); }
1182: return(logon());
1183: default:
1184: return(0); }
1185: default:
1186: lputs("Hit '?' for a menu.");
1187: continue; } }
1188: if(com_port) {
1189: if(mdm_misc&MDM_VERBAL) {
1190: if(rioctl(RXBC)) {
1191: lputc(FF);
1192: getmdmstr(str,SEC_RING);
1193: if(!strcmp(str,"RING"))
1194: ans=1; } }
1195: else { /* numeric */
1196: if(incom()=='2')
1197: ans=1; }
1198: if(mdm_misc&MDM_DUMB && DCDHIGH)
1199: ans=1; }
1200: if(ans) {
1201: lputc(FF);
1202: if(mdm_misc&MDM_CALLERID) {
1203: lputs("Obtaining Caller-ID...");
1204: getmdmstr(str,SEC_CID);
1205: lprintf("\r\nCID: %s",str);
1206: if(!strncmpi(str,"TIME:",5)) { /* 3 message format */
1207: getmdmstr(str,SEC_CID);
1208: lprintf("\r\nCID: %s",str);
1209: p=strchr(str,':');
1210: if(p)
1211: strcpy(cid,p+2); /* Phone Number */
1212: getmdmstr(str,SEC_CID);
1213: lprintf("\r\nCID: %s",str);
1214: p=strchr(str,':');
1215: if(p)
1216: sprintf(cname,"%.*s",LEN_CID,p+2); } /* Caller Name */
1217: else if(!strncmpi(str,"DATE =",6)) { /* Supra format */
1218: getmdmstr(str,SEC_CID);
1219: lprintf("\r\nCID: %s",str); /* TIME = line */
1220: getmdmstr(str,SEC_CID);
1221: lprintf("\r\nCID: %s",str); /* NMBR = line */
1222: p=strchr(str,'=');
1223: if(p)
1224: sprintf(strstr(str,"NAME") ? cname:cid,"%.*s",LEN_CID,p+2);
1225: getmdmstr(str,SEC_CID); /* NAME = line */
1226: lprintf("\r\nCID: %s",str);
1227: p=strchr(str,'=');
1228: if(p)
1229: sprintf(strstr(str,"NAME") ? cname:cid,"%.*s",LEN_CID,p+2);
1230: }
1231: else if(strlen(str)>12) /* Single message format */
1232: sprintf(cid,"%.*s",LEN_CID,str+12);
1233: else
1234: sprintf(cid,"ERROR: '%s'",str);
1235: lputs(crlf); }
1236: cur_rate=cur_cps=0;
1237: connection[0]=0;
1238: result_code=0;
1239: if(!(mdm_misc&MDM_DUMB)) {
1240: if(mdm_rings>1) {
1241: lputs("Ring\r\n");
1242: for(i=1;i<mdm_rings;i++)
1243: if(!getmdmstr(str,10))
1244: break;
1245: else
1246: lputs("Ring\r\n");
1247: if(i<mdm_rings)
1248: return(0);
1249: lputs(crlf); }
1250: lputs("Answering...");
1251: mdmcmd(mdm_answ);
1252: rioctl(IOFI); // flush extra ring results
1253: while(!cur_rate || rioctl(RXBC)) { // no connect or more rsults
1254: if(!getmdmstr(str,SEC_ANSWER)) {
1255: if(cur_rate)
1256: break;
1257: lprintf("\r\nNO CARRIER\r\n");
1258: if(!(mdm_misc&MDM_NODTR)) {
1259: dtr(15);
1260: dtr(1);
1261: mswait(500); }
1262: mdmcmd(nulstr);
1263: hangup();
1264: return(0); }
1265: i=0;
1266: while(i<2
1267: && (!strcmp(str,"2")
1268: || !strcmp(str,"RING"))) { /* Ring? Get next result */
1269: lputs("Ring\r\n");
1270: if(i) {
1271: mdmcmd(mdm_answ); /* Give a second ATA */
1272: rioctl(IOFI); }
1273: if(!getmdmstr(str,SEC_ANSWER)) {
1274: if(!(mdm_misc&MDM_NODTR)) {
1275: dtr(15);
1276: dtr(1);
1277: mswait(500); }
1278: mdmcmd(nulstr);
1279: hangup(); /* Get next result code from modem */
1280: return(0); }
1281: i++; }
1282: if(!strcmp(str,"3") || !strcmp(str,"NO CARRIER")) {
1283: lprintf("\r\nNO CARRIER\r\n");
1284: hangup();
1285: return(0); }
1286:
1287: lprintf("\r\nResult Code: %s\r\n",str);
1288:
1289: /* IP (vmodem) logging additions by enigma */
1290: ips = strstr(str, "TEL FROM ");
1291: if(ips) {
1292: strcpy(ipstr, ips+9);
1293: }
1294:
1295: if(strstr(str,"FAX") || strstr(str,"+FCO")) {
1296: /* Just for the ZyXEL's */
1297: mswait(1500); /* 1 and a half second wait for ZyXEL */
1298: sys_misc&=~SM_ERRALARM;
1299: bail(100); }
1300:
1301: if(mdm_misc&MDM_VERBAL) {
1302: if(!cur_rate
1303: && (!strnicmp(str,"CONNECT ",8)
1304: || !strnicmp(str,"CARRIER ",8))) {
1305: cur_rate=atol(str+8);
1306: // build description
1307: for(i=8,j=0;str[i] && j<LEN_MODEM;i++) {
1308: if(j==2 && isdigit(str[i])
1309: && str[i+1]=='0' && str[i+2]=='0'
1310: && !isdigit(str[i+3]) && j+1<LEN_MODEM) {
1311: connection[j++]='.';
1312: connection[j++]=str[i];
1313: i+=2; }
1314: else
1315: connection[j++]=str[i]; }
1316: connection[j]=0; }
1317: if(!cur_rate && !strcmp(str,"CONNECT"))
1318: cur_rate=com_rate;
1319: if(cur_rate
1320: && (strstr(str,"ARQ") || strstr(str,"MNP")
1321: || strstr(str,"V42") || strstr(str,"LAPM")
1322: || strstr(str,"REL")))
1323: cur_cps=cur_rate/9; }
1324: else { /* numeric */
1325: j=atoi(str);
1326: for(i=0;i<mdm_results;i++)
1327: if(mdm_result[i].code==j) break;
1328: if(!cur_rate) {
1329: if(i==mdm_results) {
1330: lprintf("Unknown result code: '%s'\r\n",str);
1331: sprintf(tmp,"Unknown modem result code: '%s'",str);
1332: errorlog(tmp);
1333: if(mdm_misc&MDM_KNOWNRES || !mdm_results) {
1334: hangup();
1335: return(0); } /* Don't allow invalid codes */
1336: i--; } /* Use last configured result code */
1337: else
1338: result_code=mdm_result[i].code; }
1339: if(!strncmpi(mdm_result[i].str,"EXIT ",5))
1340: bail(atoi(mdm_result[i].str+5));
1341: if(!strcmpi(mdm_result[i].str,"FAX")) {
1342: lputs("FAX Connection\r\n");
1343: bail(100); }
1344: if(!strcmpi(mdm_result[i].str,"IGNORE") || cur_rate)
1345: lputs("Ignored\r\n");
1346: else {
1347: cur_rate=mdm_result[i].rate;
1348: cur_cps=mdm_result[i].cps;
1349: strcpy(connection,mdm_result[i].str); } } } }
1350: else /* dumb modem */
1351: cur_rate=com_rate;
1352:
1353: if(!connection[0])
1354: sprintf(connection,"%lu",cur_rate);
1355: lprintf("Logging Caller in at %s\r\n",connection);
1356: if(!cur_cps)
1357: cur_cps=cur_rate/10L;
1358:
1359: rioctl(IOCE|((RXLOST|FERR|PERR|OVRR)<<8)); /* clear error flags */
1360: console=CON_R_ECHO|CON_L_ECHO|CON_R_INPUT|CON_L_INPUT;
1361: online=ON_REMOTE;
1362: gotcaller=1;
1363: putcom(crlf);
1364: #if defined(__OS2__)
1365: putcom(decrypt(VersionNoticeOS2,0));
1366: #elif defined(__WIN32__)
1367: putcom(decrypt(VersionNoticeW32,0));
1368: #else
1369: putcom(decrypt(VersionNoticeDOS,0));
1370: #endif
1371: putcom(crlf);
1372: lprintf("Pausing %u Seconds...",mdm_ansdelay);
1373: if(node_misc&NM_ANSALARM) {
1374: now=time(NULL);
1375: while(time(NULL)-now<mdm_ansdelay)
1376: for(x=0;x<10;x++)
1377: for(y=0;y<10;y++)
1378: beep((x*100)+(y*5),10); }
1379: else
1380: secwait(mdm_ansdelay);
1381: nosound();
1382: rioctl(IOFI); } } /* flush input buffer */
1383:
1384: reset_logon_vars();
1385: calls++;
1386: useron.misc=0;
1387: answertime=logontime=starttime=time(NULL);
1388: if(online==ON_REMOTE) {
1389: setrate();
1390:
1391: now=time(NULL);
1392: gm=localtime(&now);
1393: sprintf(str,"%02d:%02d%c %s %s %02d %u Node %3u %5lubps (%s)"
1394: ,gm->tm_hour>12 ? gm->tm_hour-12 : gm->tm_hour==0 ? 12 : gm->tm_hour
1395: ,gm->tm_min,gm->tm_hour>=12 ? 'p' : 'a',wday[gm->tm_wday]
1396: ,mon[gm->tm_mon],gm->tm_mday,gm->tm_year+1900,node_num,cur_rate
1397: ,connection);
1398: if(result_code) {
1399: sprintf(tmp," [%d]",result_code);
1400: strcat(str,tmp); }
1401: logline("@",str);
1402:
1403: /* IP trashcan modification by enigma */
1404: if(trashcan(ipstr,"IP")) {
1405: sprintf(tmp, "IP Trashcan: %s, hanging up!\r\n", ipstr);
1406: logline("@!",tmp);
1407: hangup();
1408: return(0); }
1409:
1410: if(mdm_misc&MDM_CALLERID) {
1411: outcom(0xC);
1412: #if defined(__OS2__)
1413: putcom(decrypt(VersionNoticeOS2,0));
1414: #elif defined(__WIN32__)
1415: putcom(decrypt(VersionNoticeW32,0));
1416: #else
1417: putcom(decrypt(VersionNoticeDOS,0));
1418: #endif
1419: putcom(crlf);
1420: sprintf(str,"CID: %-*s %s",LEN_CID,cid,cname);
1421: logline("@*",str);
1422: if(trashcan(cid,"CID")) {
1423: hangup();
1424: return(0); } } }
1425: lclini(node_scrnlen-1);
1426: if(online==ON_REMOTE) {
1427: if(node_dollars_per_call) { /* Billing node stuff */
1428: now=time(NULL);
1429: bprintf(text[BillingNodeMsg],sys_name,node_dollars_per_call);
1430: while(online && now-answertime<30) {
1431: if(incom()!=NOINP) {
1432: if(!(mdm_misc&MDM_NODTR))
1433: dtr(15);
1434: else
1435: mdmcmd(mdm_hang); }
1436: checkline();
1437: now=time(NULL); }
1438: if(!online)
1439: return(0); }
1440: rioctl(IOFI);
1441: putcom("\x1b[99B\x1b[6n\x1b[!_\x1b[0t_\x1b[0m_\xC");
1442: lputc(FF);
1443: i=l=lncntr=autoterm=0;
1444: tos=1;
1445: #if defined(__OS2__)
1446: strcpy(str,decrypt(VersionNoticeOS2,0));
1447: #elif defined(__WIN32__)
1448: strcpy(str,decrypt(VersionNoticeW32,0));
1449: #else
1450: strcpy(str,decrypt(VersionNoticeDOS,0));
1451: #endif
1452: strcat(str,decrypt(CopyrightNotice,0));
1453: center(str);
1454: while(i++<30 && l<40) { /* wait up to 3 seconds for response */
1455: if((c=(incom()&0x7f))=='R') { /* break immediately if response */
1456: str[l++]=c;
1457: mswait(110);
1458: break; }
1459: if(c) {
1460: str[l++]=c;
1461: if(l==1 && c!=ESC)
1462: break; }
1463: else
1464: mswait(100); }
1465:
1466: if(rioctl(RXBC)) /* wait a bit for extra RIP reply chars */
1467: mswait(550);
1468:
1469: while((i=(incom()&0x7f))!=NOINP && l<40)
1470: str[l++]=i;
1471: str[l]=0;
1472:
1473: #if 0
1474: for(i=0;str[i];i++)
1475: lprintf("%02X ",str[i]);
1476: lputs(crlf);
1477: #endif
1478:
1479: if(l) {
1480: if(str[0]==ESC && str[1]=='[') {
1481: useron.misc|=(ANSI|COLOR);
1482: autoterm|=ANSI;
1483: rows=((str[2]&0xf)*10)+(str[3]&0xf);
1484: if(rows<10 || rows>99) rows=24; }
1485: truncsp(str);
1486: if(strstr(str,"RIPSCRIP")) {
1487: logline("@R",strstr(str,"RIPSCRIP"));
1488: useron.misc|=(RIP|COLOR|ANSI);
1489: autoterm|=(RIP|COLOR|ANSI); }
1490: else if(strstr(str,"DC-TERM")
1491: && toupper(*(strstr(str,"DC-TERM")+12))=='W') {
1492: logline("@W",strstr(str,"DC-TERM"));
1493: useron.misc|=(WIP|COLOR|ANSI);
1494: autoterm|=(WIP|COLOR|ANSI); } }
1495: rioctl(IOFI); /* flush left-over or late response chars */
1496: sprintf(str,"%sANSWER",text_dir);
1497: sprintf(tmp,"%s.%s",str,autoterm&WIP ? "WIP":"RIP");
1498: sprintf(str2,"%s.ANS",str);
1499: if(autoterm&(RIP|WIP) && fexist(tmp))
1500: strcat(str,autoterm&WIP ? ".WIP":".RIP");
1501: else if(autoterm&ANSI && fexist(str2))
1502: strcat(str,".ANS");
1503: else
1504: strcat(str,".ASC");
1505: rioctl(IOSM|PAUSE);
1506: sys_status|=SS_PAUSEON;
1507: tos=1;
1508: printfile(str,P_NOABORT);
1509: sys_status&=~SS_PAUSEON;
1510: CRLF; }
1511: else
1512: useron.misc=(UPAUSE|ANSI|COLOR);
1513:
1514: useron.number=0;
1515:
1516: exec_bin(login_mod,&main_csi);
1517:
1518: if(!useron.number)
1519: hangup();
1520: if(!online) {
1521: logout();
1522: return(0); }
1523:
1524: if(online==ON_REMOTE && mdm_misc&MDM_CALLERID) {
1525: strcpy(useron.note,cid);
1526: putuserrec(useron.number,U_NOTE,LEN_NOTE,useron.note); }
1527:
1528: /* log the IP by enigma */
1529:
1530: if(online==ON_REMOTE && ipstr[0]!='\0') {
1531: sprintf(useron.note, "Telnet: %s", ipstr);
1532: putuserrec(useron.number,U_NOTE,LEN_NOTE,useron.note);
1533: logline("@*", useron.note); }
1534:
1535: if(!(sys_status&SS_USERON)) {
1536: errormsg(WHERE,ERR_CHK,"User not logged on",0);
1537: hangup();
1538: logout();
1539: return(0); }
1540:
1541: return(1);
1542: }
1543:
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.