![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to un_rep.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Synchronet] / sbbs / sbbs2|
Return to un_rep.c CVS log | Up to [Synchronet] / sbbs / sbbs2 |
1.1 root 1: #line 1 "UN_REP.C"
2:
3: /* Developed 1990-1997 by Rob Swindell; PO Box 501, Yorba Linda, CA 92885 */
4:
5: #include "sbbs.h"
6: #include "qwk.h"
7:
8: /****************************************************************************/
9: /* Unpacks .REP packet, 'repname' is the path and filename of the packet */
10: /****************************************************************************/
11: void unpack_rep()
12: {
13: uchar ch,str[256],fname[128],block[128]
14: ,*AttemptedToUploadREPpacket="Attempted to upload REP packet";
15: int file;
16: uint h,i,j,k,msgs,lastsub=INVALID_SUB;
17: ulong n;
18: long l,size,misc,crc;
19: node_t node;
20: time_t t;
21: file_t f;
22: struct ffblk ff;
23: FILE *rep;
24:
25: sprintf(str,"%s%s.REP",temp_dir,sys_id);
26: if(!fexist(str)) {
27: bputs(text[QWKReplyNotReceived]);
28: logline("U!",AttemptedToUploadREPpacket);
29: logline(nulstr,"REP file not received");
30: return; }
31: for(k=0;k<total_fextrs;k++)
32: if(!stricmp(fextr[k]->ext,useron.tmpext) && chk_ar(fextr[k]->ar,useron))
33: break;
34: if(k>=total_fextrs)
35: k=0;
36: i=external(cmdstr(fextr[k]->cmd,str,"*.*",NULL),EX_OUTL|EX_OUTR);
37: if(i) {
38: bputs(text[QWKExtractionFailed]);
39: logline("U!",AttemptedToUploadREPpacket);
40: logline(nulstr,"Extraction failed");
41: return; }
42: sprintf(str,"%s%s.MSG",temp_dir,sys_id);
43: if(!fexist(str)) {
44: bputs(text[QWKReplyNotReceived]);
45: logline("U!",AttemptedToUploadREPpacket);
46: logline(nulstr,"MSG file not received");
47: return; }
48: if((rep=fnopen(&file,str,O_RDONLY))==NULL) {
49: errormsg(WHERE,ERR_OPEN,str,O_RDONLY);
50: return; }
51: size=filelength(file);
52: fread(block,128,1,rep);
53: if(strncmpi(block,sys_id,strlen(sys_id))) {
54: fclose(rep);
55: bputs(text[QWKReplyNotReceived]);
56: logline("U!",AttemptedToUploadREPpacket);
57: logline(nulstr,"Incorrect BBSID");
58: return; }
59: logline("U+","Uploaded REP packet");
60: /********************/
61: /* Process messages */
62: /********************/
63: bputs(text[QWKUnpacking]);
64:
65: for(l=128;l<size;l+=i*128) {
66: lncntr=0; /* defeat pause */
67: fseek(rep,l,SEEK_SET);
68: fread(block,128,1,rep);
69: sprintf(tmp,"%.6s",block+116);
70: i=atoi(tmp); /* i = number of 128 byte records */
71: if(i<2) {
72: sprintf(tmp,"%s blocks",str);
73: errormsg(WHERE,ERR_CHK,tmp,i);
74: i=1;
75: continue; }
76: if(atoi(block+1)==0) { /**********/
77: if(useron.rest&FLAG('E')) { /* E-mail */
78: bputs(text[R_Email]); /**********/
79: continue; }
80:
81: sprintf(str,"%25.25s",block+21);
82: truncsp(str);
83: if(!stricmp(str,"NETMAIL")) { /* QWK to FidoNet NetMail */
84: qwktonetmail(rep,block,NULL,0);
85: continue; }
86: if(strchr(str,'@')) {
87: qwktonetmail(rep,block,str,0);
88: continue; }
89: if(!stricmp(str,"SBBS")) { /* to SBBS, config stuff */
90: qwkcfgline(block+71,INVALID_SUB);
91: continue; }
92:
93: if(useron.etoday>=level_emailperday[useron.level]
94: && !(useron.rest&FLAG('Q'))) {
95: bputs(text[TooManyEmailsToday]);
96: continue; }
97: j=atoi(str);
98: if(j && j>lastuser())
99: j=0;
100: if(!j &&
101: (!stricmp(str,"SYSOP")
102: || !stricmp(str,sys_id)
103: || !stricmp(str,sys_op)))
104: j=1;
105: if(!j)
106: j=matchuser(str);
107: if(!j) {
108: bputs(text[UnknownUser]);
109: continue; }
110: if(j==1 && useron.rest&FLAG('S')) {
111: bprintf(text[R_Feedback],sys_op);
112: continue; }
113:
114: getuserrec(j,U_MISC,8,str);
115: misc=ahtoul(str);
116: if(misc&NETMAIL && sys_misc&SM_FWDTONET) {
117: getuserrec(j,U_NETMAIL,LEN_NETMAIL,str);
118: qwktonetmail(rep,block,str,0);
119: continue; }
120:
121: sprintf(smb.file,"%sMAIL",data_dir);
122: smb.retry_time=smb_retry_time;
123:
124: if(lastsub!=INVALID_SUB) {
125: smb_close(&smb);
126: lastsub=INVALID_SUB; }
127:
128: if((k=smb_open(&smb))!=0) {
129: errormsg(WHERE,ERR_OPEN,smb.file,k);
130: continue; }
131:
132: if(!filelength(fileno(smb.shd_fp))) {
133: smb.status.max_crcs=mail_maxcrcs;
134: smb.status.max_msgs=MAX_SYSMAIL;
135: smb.status.max_age=mail_maxage;
136: smb.status.attr=SMB_EMAIL;
137: if((k=smb_create(&smb))!=0) {
138: smb_close(&smb);
139: errormsg(WHERE,ERR_CREATE,smb.file,k);
140: continue; } }
141:
142: if((k=smb_locksmbhdr(&smb))!=0) {
143: smb_close(&smb);
144: errormsg(WHERE,ERR_LOCK,smb.file,k);
145: continue; }
146:
147: if((k=smb_getstatus(&smb))!=0) {
148: smb_close(&smb);
149: errormsg(WHERE,ERR_READ,smb.file,k);
150: continue; }
151:
152: smb_unlocksmbhdr(&smb);
153:
154: if(!qwktomsg(rep,block,0,INVALID_SUB,j)) {
155: smb_close(&smb);
156: continue; }
157: smb_close(&smb);
158:
159: if(j==1) {
160: useron.fbacks++;
161: logon_fbacks++;
162: putuserrec(useron.number,U_FBACKS,5
163: ,itoa(useron.fbacks,tmp,10)); }
164: else {
165: useron.emails++;
166: logon_emails++;
167: putuserrec(useron.number,U_EMAILS,5
168: ,itoa(useron.emails,tmp,10)); }
169: useron.etoday++;
170: putuserrec(useron.number,U_ETODAY,5
171: ,itoa(useron.etoday,tmp,10));
172: bprintf(text[Emailed],username(j,tmp),j);
173: sprintf(str,"E-mailed %s #%d",username(j,tmp),j);
174: logline("E+",str);
175: if(useron.rest&FLAG('Q')) {
176: sprintf(tmp,"%-25.25s",block+46);
177: truncsp(tmp); }
178: else
179: strcpy(tmp,useron.alias);
180: for(k=1;k<=sys_nodes;k++) { /* Tell user, if online */
181: getnodedat(k,&node,0);
182: if(node.useron==j && !(node.misc&NODE_POFF)
183: && (node.status==NODE_INUSE
184: || node.status==NODE_QUIET)) {
185: sprintf(str,text[EmailNodeMsg]
186: ,node_num,tmp);
187: putnmsg(k,str);
188: break; } }
189: if(k>sys_nodes) {
190: sprintf(str,text[UserSentYouMail],tmp);
191: putsmsg(j,str); } } /* end of email */
192:
193: /**************************/
194: else { /* message on a sub-board */
195: /**************************/
196: n=atol((char *)block+1); /* conference number */
197: for(j=0;j<usrgrps;j++) {
198: for(k=0;k<usrsubs[j];k++)
199: if(sub[usrsub[j][k]]->qwkconf==n)
200: break;
201: if(k<usrsubs[j])
202: break; }
203:
204: if(j>=usrgrps) {
205: if(n<1000) { /* version 1 method, start at 101 */
206: j=n/100;
207: k=n-(j*100); }
208: else { /* version 2 method, start at 1001 */
209: j=n/1000;
210: k=n-(j*1000); }
211: j--; /* j is group */
212: k--; /* k is sub */
213: if(j>=usrgrps || k>=usrsubs[j]) {
214: bprintf(text[QWKInvalidConferenceN],n);
215: sprintf(str,"Invalid conference number %d",n);
216: logline("P!",str);
217: continue; } }
218:
219: n=usrsub[j][k];
220:
221: /* if posting, add to new-scan config for QWKnet nodes automatically */
222: if(useron.rest&FLAG('Q'))
223: sub[n]->misc|=SUB_NSCAN;
224:
225: sprintf(str,"%-25.25s","SBBS");
226: if(!strnicmp((char *)block+21,str,25)) { /* to SBBS, config stuff */
227: qwkcfgline((char *)block+71,n);
228: continue; }
229:
230: if(!SYSOP && sub[n]->misc&SUB_QNET) { /* QWK Netted */
231: sprintf(str,"%-25.25s","DROP"); /* Drop from new-scan? */
232: if(!strnicmp((char *)block+71,str,25)) /* don't allow post */
233: continue;
234: sprintf(str,"%-25.25s","ADD"); /* Add to new-scan? */
235: if(!strnicmp((char *)block+71,str,25)) /* don't allow post */
236: continue; }
237:
238: if(useron.rest&FLAG('Q') && !(sub[n]->misc&SUB_QNET)) {
239: bputs(text[CantPostOnSub]);
240: logline("P!","Attempted to post on non-QWKnet sub");
241: continue; }
242:
243: if(useron.rest&FLAG('P')) {
244: bputs(text[R_Post]);
245: logline("P!","Post attempted");
246: continue; }
247:
248: if(useron.ptoday>=level_postsperday[useron.level]
249: && !(useron.rest&FLAG('Q'))) {
250: bputs(text[TooManyPostsToday]);
251: continue; }
252:
253: if(useron.rest&FLAG('N')
254: && sub[n]->misc&(SUB_FIDO|SUB_PNET|SUB_QNET|SUB_INET)) {
255: bputs(text[CantPostOnSub]);
256: logline("P!","Networked post attempted");
257: continue; }
258:
259: if(!chk_ar(sub[n]->post_ar,useron)) {
260: bputs(text[CantPostOnSub]);
261: logline("P!","Post attempted");
262: continue; }
263:
264: if((block[0]=='*' || block[0]=='+')
265: && !(sub[n]->misc&SUB_PRIV)) {
266: bputs(text[PrivatePostsNotAllowed]);
267: logline("P!","Private post attempt");
268: continue; }
269:
270: if(block[0]=='*' || block[0]=='+' /* Private post */
271: || sub[n]->misc&SUB_PONLY) {
272: sprintf(str,"%-25.25s",nulstr);
273: sprintf(tmp,"%-25.25s","ALL");
274: if(!strnicmp((char *)block+21,str,25)
275: || !strnicmp((char *)block+21,tmp,25)) { /* to blank */
276: bputs(text[NoToUser]); /* or all */
277: continue; } }
278:
279: if(!SYSOP && !(useron.rest&FLAG('Q'))) {
280: sprintf(str,"%-25.25s","SYSOP");
281: if(!strnicmp((char *)block+21,str,25)) {
282: sprintf(str,"%-25.25s",username(1,tmp));
283: memcpy((char *)block+21,str,25); } } /* change from sysop */
284: /* to user #1 */
285:
286: #if 0 /* TWIT FILTER */
287: sprintf(str,"%25.25s",block+46); /* From user */
288: truncsp(str);
289:
290: if(!stricmp(str,"Lee Matherne")
291: || !stricmp(str,"Big Joe")
292: ) {
293: bprintf(text[Posted],grp[sub[n]->grp]->sname
294: ,sub[n]->lname);
295: continue; }
296: #endif
297:
298: if(n!=lastsub) {
299: if(lastsub!=INVALID_SUB)
300: smb_close(&smb);
301: lastsub=INVALID_SUB;
302: sprintf(smb.file,"%s%s",sub[n]->data_dir,sub[n]->code);
303: smb.retry_time=smb_retry_time;
304: if((j=smb_open(&smb))!=0) {
305: errormsg(WHERE,ERR_OPEN,smb.file,j);
306: continue; }
307:
308: if(!filelength(fileno(smb.shd_fp))) {
309: smb.status.max_crcs=sub[n]->maxcrcs;
310: smb.status.max_msgs=sub[n]->maxmsgs;
311: smb.status.max_age=sub[n]->maxage;
312: smb.status.attr=sub[n]->misc&SUB_HYPER ? SMB_HYPERALLOC:0;
313: if((j=smb_create(&smb))!=0) {
314: smb_close(&smb);
315: lastsub=INVALID_SUB;
316: errormsg(WHERE,ERR_CREATE,smb.file,j);
317: continue; } }
318:
319: if((j=smb_locksmbhdr(&smb))!=0) {
320: smb_close(&smb);
321: lastsub=INVALID_SUB;
322: errormsg(WHERE,ERR_LOCK,smb.file,j);
323: continue; }
324: if((j=smb_getstatus(&smb))!=0) {
325: smb_close(&smb);
326: lastsub=INVALID_SUB;
327: errormsg(WHERE,ERR_READ,smb.file,j);
328: continue; }
329: smb_unlocksmbhdr(&smb);
330: lastsub=n; }
331:
332: if(!qwktomsg(rep,block,0,n,0))
333: continue;
334:
335: useron.ptoday++;
336: useron.posts++;
337: // if(!(useron.rest&FLAG('Q')))
338: logon_posts++;
339: putuserrec(useron.number,U_POSTS,5,itoa(useron.posts,str,10));
340: putuserrec(useron.number,U_PTODAY,5,itoa(useron.ptoday,str,10));
341: bprintf(text[Posted],grp[sub[n]->grp]->sname
342: ,sub[n]->lname);
343: sprintf(str,"Posted on %s %s",grp[sub[n]->grp]->sname
344: ,sub[n]->lname);
345: if(sub[n]->misc&SUB_FIDO && sub[n]->echomail_sem[0]) /* semaphore */
346: if((file=nopen(sub[n]->echomail_sem,O_WRONLY|O_CREAT|O_TRUNC))!=-1)
347: close(file);
348: logline("P+",str); } } /* end of public message */
349:
350: update_qwkroute(NULL); /* Write ROUTE.DAT */
351:
352: if(lastsub!=INVALID_SUB)
353: smb_close(&smb);
354: fclose(rep);
355:
356: if(useron.rest&FLAG('Q')) { /* QWK Net Node */
357: sprintf(str,"%s%s.MSG",temp_dir,sys_id);
358: remove(str);
359: sprintf(str,"%s%s.REP",temp_dir,sys_id);
360: remove(str);
361:
362: sprintf(str,"%s*.*",temp_dir);
363: i=findfirst(str,&ff,0);
364: if(!i) {
365: sprintf(str,"%sQNET\\%s.IN",data_dir,useron.alias);
366: mkdir(str); }
367: while(!i) { /* Extra files */
368: sprintf(str,"%s%s",temp_dir,ff.ff_name);
369: sprintf(fname,"%sQNET\\%s.IN\\%s",data_dir,useron.alias,ff.ff_name);
370: mv(str,fname,1);
371: sprintf(str,text[ReceivedFileViaQWK],ff.ff_name,useron.alias);
372: putsmsg(1,str);
373: i=findnext(&ff); } }
374:
375: bputs(text[QWKUnpacked]);
376: CRLF;
377: /**********************************************/
378: /* Hang-up now if that's what the user wanted */
379: /**********************************************/
380: autohangup();
381:
382: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.