![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to data.cpp CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Synchronet] / sbbs / sbbs3|
Return to data.cpp CVS log | Up to [Synchronet] / sbbs / sbbs3 |
1.1 root 1: /* data.cpp */
2:
3: /* Synchronet data access routines */
4:
1.1.1.2 ! root 5: /* $Id: data.cpp,v 1.19 2004/04/05 11:24:26 rswindell Exp $ */
1.1 root 6:
7: /****************************************************************************
8: * @format.tab-size 4 (Plain Text/Source Code File Header) *
9: * @format.use-tabs true (see http://www.synchro.net/ptsc_hdr.html) *
10: * *
1.1.1.2 ! root 11: * Copyright 2003 Rob Swindell - http://www.synchro.net/copyright.html *
1.1 root 12: * *
13: * This program is free software; you can redistribute it and/or *
14: * modify it under the terms of the GNU General Public License *
15: * as published by the Free Software Foundation; either version 2 *
16: * of the License, or (at your option) any later version. *
17: * See the GNU General Public License for more details: gpl.txt or *
18: * http://www.fsf.org/copyleft/gpl.html *
19: * *
20: * Anonymous FTP access to the most recent released source is available at *
21: * ftp://vert.synchro.net, ftp://cvs.synchro.net and ftp://ftp.synchro.net *
22: * *
23: * Anonymous CVS access to the development source and modification history *
24: * is available at cvs.synchro.net:/cvsroot/sbbs, example: *
25: * cvs -d :pserver:[email protected]:/cvsroot/sbbs login *
26: * (just hit return, no password is necessary) *
27: * cvs -d :pserver:[email protected]:/cvsroot/sbbs checkout src *
28: * *
29: * For Synchronet coding style and modification guidelines, see *
30: * http://www.synchro.net/source.html *
31: * *
32: * You are encouraged to submit any modifications (preferably in Unix diff *
33: * format) via e-mail to [email protected] *
34: * *
35: * Note: If this box doesn't appear square, then you need to fix your tabs. *
36: ****************************************************************************/
37:
38: /**************************************************************/
39: /* Functions that store and retrieve data from disk or memory */
40: /**************************************************************/
41:
42: #include "sbbs.h"
43:
44: /****************************************************************************/
45: /* Looks for close or perfect matches between str and valid usernames and */
46: /* numbers and prompts user for near perfect matches in names. */
47: /* Returns the number of the matched user or 0 if unsuccessful */
48: /* Called from functions main_sec, useredit and readmailw */
49: /****************************************************************************/
50: uint sbbs_t::finduser(char *instr)
51: {
52: int file,i;
53: char str[128],str2[256],str3[256],ynq[25],c,pass=1;
54: ulong l,length;
55: FILE *stream;
56:
57: i=atoi(instr);
58: if(i>0) {
59: username(&cfg, i,str2);
60: if(str2[0] && strcmp(str2,"DELETED USER"))
61: return(i); }
62: strcpy(str,instr);
63: strupr(str);
64: sprintf(str3,"%suser/name.dat",cfg.data_dir);
65: if(flength(str3)<1L)
66: return(0);
67: if((stream=fnopen(&file,str3,O_RDONLY))==NULL) {
68: errormsg(WHERE,ERR_OPEN,str3,O_RDONLY);
69: return(0); }
70: sprintf(ynq,"%.2s",text[YN]);
71: ynq[2]='Q';
72: ynq[3]=0;
73: length=filelength(file);
74: while(pass<3) {
75: fseek(stream,0L,SEEK_SET); /* seek to beginning for each pass */
76: for(l=0;l<length;l+=LEN_ALIAS+2) {
77: if(!online) break;
78: fread(str2,LEN_ALIAS+2,1,stream);
79: for(c=0;c<LEN_ALIAS;c++)
80: if(str2[c]==ETX) break;
81: str2[c]=0;
82: if(!c) /* deleted user */
83: continue;
84: strcpy(str3,str2);
85: strupr(str2);
86: if(pass==1 && !strcmp(str,str2)) {
87: fclose(stream);
88: return((l/(LEN_ALIAS+2))+1); }
89: if(pass==2 && strstr(str2,str)) {
90: bprintf(text[DoYouMeanThisUserQ],str3
91: ,(uint)(l/(LEN_ALIAS+2))+1);
92: c=(char)getkeys(ynq,0);
93: if(sys_status&SS_ABORT) {
94: fclose(stream);
95: return(0); }
96: if(c==text[YN][0]) {
97: fclose(stream);
98: return((l/(LEN_ALIAS+2))+1); }
99: if(c=='Q') {
100: fclose(stream);
101: return(0); } } }
102: pass++; }
103: bputs(text[UnknownUser]);
104: fclose(stream);
105: return(0);
106: }
107:
108: /****************************************************************************/
109: /* Returns the number of user transfers in XFER.IXT for either a dest user */
110: /* source user, or filename. */
111: /****************************************************************************/
112: int sbbs_t::getuserxfers(int fromuser, int destuser, char *fname)
113: {
114: char str[256];
115: int file,found=0;
116: FILE *stream;
117:
118: sprintf(str,"%sxfer.ixt",cfg.data_dir);
119: if(!fexist(str))
120: return(0);
121: if(!flength(str)) {
122: remove(str);
123: return(0); }
124: if((stream=fnopen(&file,str,O_RDONLY))==NULL) {
125: errormsg(WHERE,ERR_OPEN,str,O_RDONLY);
126: return(0); }
127: while(!ferror(stream)) {
128: if(!fgets(str,81,stream))
129: break;
130: str[22]=0;
131: if(fname!=NULL && fname[0] && !strncmp(str+5,fname,12))
132: found++;
133: else if(fromuser && atoi(str+18)==fromuser)
134: found++;
135: else if(destuser && atoi(str)==destuser)
136: found++; }
137: fclose(stream);
138: return(found);
139: }
140:
141: /****************************************************************************/
142: /* Fills the timeleft variable with the correct value. Hangs up on the */
143: /* user if their time is up. */
144: /* Called from functions main_sec and xfer_sec */
145: /****************************************************************************/
146: void sbbs_t::gettimeleft(void)
147: {
148: char str[128];
149: char tmp[512];
150: int i;
151: time_t thisevent;
152: long tleft;
1.1.1.2 ! root 153: struct tm tm, last_tm;
1.1 root 154:
155: now=time(NULL);
156:
1.1.1.2 ! root 157: if(localtime_r(&now,&tm)==NULL)
! 158: memset(&tm,0,sizeof(tm));
1.1 root 159: if(useron.exempt&FLAG('T')) { /* Time online exemption */
160: timeleft=cfg.level_timepercall[useron.level]*60;
161: if(timeleft<10) /* never get below 10 for exempt users */
1.1.1.2 ! root 162: timeleft=10;
! 163: } else {
1.1 root 164: tleft=(((long)cfg.level_timeperday[useron.level]-useron.ttoday)
165: +useron.textra)*60L;
166: if(tleft<0) tleft=0;
167: if(tleft>cfg.level_timepercall[useron.level]*60)
168: tleft=cfg.level_timepercall[useron.level]*60;
169: tleft+=useron.min*60L;
170: tleft-=now-starttime;
171: if(tleft>0x7fffL)
172: timeleft=0x7fff;
173: else
1.1.1.2 ! root 174: timeleft=tleft;
! 175: }
1.1 root 176:
177: /* Timed event time reduction handler */
178:
1.1.1.2 ! root 179: event_time=0;
1.1 root 180: for(i=0;i<cfg.total_events;i++) {
1.1.1.2 ! root 181: if(!cfg.event[i]->node || cfg.event[i]->node>cfg.sys_nodes
! 182: || cfg.event[i]->misc&EVENT_DISABLED)
1.1 root 183: continue;
184: if(!(cfg.event[i]->misc&EVENT_FORCE)
185: || (!(cfg.event[i]->misc&EVENT_EXCL) && cfg.event[i]->node!=cfg.node_num)
1.1.1.2 ! root 186: || !(cfg.event[i]->days&(1<<tm.tm_wday))
! 187: || (cfg.event[i]->mdays!=0 && !(cfg.event[i]->mdays&(1<<tm.tm_mday))))
1.1 root 188: continue;
189:
1.1.1.2 ! root 190: tm.tm_hour=cfg.event[i]->time/60;
! 191: tm.tm_min=cfg.event[i]->time%60;
! 192: tm.tm_sec=0;
! 193: thisevent=mktime(&tm);
! 194:
! 195: if(localtime_r(&cfg.event[i]->last,&last_tm)==NULL)
1.1 root 196: memset(&last_tm,0,sizeof(last_tm));
1.1.1.2 ! root 197:
! 198: if(tm.tm_mday==last_tm.tm_mday && tm.tm_mon==last_tm.tm_mon)
1.1 root 199: thisevent+=24L*60L*60L; /* already ran today, so add 24hrs */
1.1.1.2 ! root 200: if(!event_time || thisevent<event_time) {
! 201: event_time=thisevent;
! 202: event_code=cfg.event[i]->code;
! 203: }
! 204: }
! 205: if(event_time && now+(time_t)timeleft>event_time) { /* less time, set flag */
! 206: if(event_time<now)
! 207: timeleft=0;
! 208: else
! 209: timeleft=event_time-now;
! 210: if(!(sys_status&SS_EVENT)) {
! 211: lprintf(LOG_NOTICE,"Node %d Time reduced (to %s) due to upcoming event (%s) on %s"
! 212: ,cfg.node_num,sectostr(timeleft,tmp),event_code,timestr(&event_time));
! 213: sys_status|=SS_EVENT;
! 214: }
1.1 root 215: }
216:
1.1.1.2 ! root 217: if((long)timeleft<0) /* timeleft can't go negative */
1.1 root 218: timeleft=0;
219: if(thisnode.status==NODE_NEWUSER) {
220: timeleft=cfg.level_timepercall[cfg.new_level];
221: if(timeleft<10*60L)
1.1.1.2 ! root 222: timeleft=10*60L;
! 223: }
1.1 root 224:
225: if(gettimeleft_inside) /* The following code is not recursive */
226: return;
227: gettimeleft_inside=1;
228:
229: if(!timeleft && !SYSOP && !(sys_status&SS_LCHAT)) {
230: logline(nulstr,"Ran out of time");
231: SAVELINE;
232: if(sys_status&SS_EVENT)
1.1.1.2 ! root 233: bprintf(text[ReducedTime],timestr(&event_time));
1.1 root 234: bputs(text[TimesUp]);
235: if(!(sys_status&(SS_EVENT|SS_USERON)) && useron.cdt>=100L*1024L
236: && !(cfg.sys_misc&SM_NOCDTCVT)) {
237: sprintf(tmp,text[Convert100ktoNminQ],cfg.cdt_min_value);
238: if(yesno(tmp)) {
239: logline(" ","Credit to Minute Conversion");
240: useron.min=adjustuserrec(&cfg,useron.number,U_MIN,10,cfg.cdt_min_value);
241: useron.cdt=adjustuserrec(&cfg,useron.number,U_CDT,10,-(102400L));
242: sprintf(str,"Credit Adjustment: %ld",-(102400L));
243: logline("$-",str);
244: sprintf(str,"Minute Adjustment: %u",cfg.cdt_min_value);
245: logline("*+",str);
246: RESTORELINE;
247: gettimeleft();
248: gettimeleft_inside=0;
1.1.1.2 ! root 249: return;
! 250: }
! 251: }
1.1 root 252: if(cfg.sys_misc&SM_TIME_EXP && !(sys_status&SS_EVENT)
253: && !(useron.exempt&FLAG('E'))) {
254: /* set to expired values */
255: bputs(text[AccountHasExpired]);
256: sprintf(str,"%s Expired",useron.alias);
257: logentry("!%",str);
258: if(cfg.level_misc[useron.level]&LEVEL_EXPTOVAL
259: && cfg.level_expireto[useron.level]<10) {
260: useron.flags1=cfg.val_flags1[cfg.level_expireto[useron.level]];
261: useron.flags2=cfg.val_flags2[cfg.level_expireto[useron.level]];
262: useron.flags3=cfg.val_flags3[cfg.level_expireto[useron.level]];
263: useron.flags4=cfg.val_flags4[cfg.level_expireto[useron.level]];
264: useron.exempt=cfg.val_exempt[cfg.level_expireto[useron.level]];
265: useron.rest=cfg.val_rest[cfg.level_expireto[useron.level]];
266: if(cfg.val_expire[cfg.level_expireto[useron.level]])
267: useron.expire=now
268: +(cfg.val_expire[cfg.level_expireto[useron.level]]*24*60*60);
269: else
270: useron.expire=0;
271: useron.level=cfg.val_level[cfg.level_expireto[useron.level]]; }
272: else {
273: if(cfg.level_misc[useron.level]&LEVEL_EXPTOLVL)
274: useron.level=cfg.level_expireto[useron.level];
275: else
276: useron.level=cfg.expired_level;
277: useron.flags1&=~cfg.expired_flags1; /* expired status */
278: useron.flags2&=~cfg.expired_flags2; /* expired status */
279: useron.flags3&=~cfg.expired_flags3; /* expired status */
280: useron.flags4&=~cfg.expired_flags4; /* expired status */
281: useron.exempt&=~cfg.expired_exempt;
282: useron.rest|=cfg.expired_rest;
1.1.1.2 ! root 283: useron.expire=0;
! 284: }
1.1 root 285: putuserrec(&cfg,useron.number,U_LEVEL,2,ultoa(useron.level,str,10));
286: putuserrec(&cfg,useron.number,U_FLAGS1,8,ultoa(useron.flags1,str,16));
287: putuserrec(&cfg,useron.number,U_FLAGS2,8,ultoa(useron.flags2,str,16));
288: putuserrec(&cfg,useron.number,U_FLAGS3,8,ultoa(useron.flags3,str,16));
289: putuserrec(&cfg,useron.number,U_FLAGS4,8,ultoa(useron.flags4,str,16));
290: putuserrec(&cfg,useron.number,U_EXPIRE,8,ultoa(useron.expire,str,16));
291: putuserrec(&cfg,useron.number,U_EXEMPT,8,ultoa(useron.exempt,str,16));
292: putuserrec(&cfg,useron.number,U_REST,8,ultoa(useron.rest,str,16));
293: if(cfg.expire_mod[0])
294: exec_bin(cfg.expire_mod,&main_csi);
295: RESTORELINE;
296: gettimeleft();
297: gettimeleft_inside=0;
1.1.1.2 ! root 298: return;
! 299: }
1.1 root 300: SYNC;
1.1.1.2 ! root 301: hangup();
! 302: }
1.1 root 303: gettimeleft_inside=0;
304: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.