/***************************************************************************** * * $Id$ * Purpose ...............: AreaMgr * ***************************************************************************** * Copyright (C) 1997-2002 * * Michiel Broek FIDO: 2:280/2802 * Beekmansbos 10 * 1971 BV IJmuiden * the Netherlands * * This file is part of MBSE BBS. * * This BBS is free software; you can redistribute it and/or modify it * under the terms of the GNU General Public License as published by the * Free Software Foundation; either version 2, or (at your option) any * later version. * * MBSE BBS is distributed in the hope that it will be useful, but * WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * General Public License for more details. * * You should have received a copy of the GNU General Public License * along with MBSE BBS; see the file COPYING. If not, write to the Free * Software Foundation, 675 Mass Ave, Cambridge, MA 02139, USA. *****************************************************************************/ #include "../lib/libs.h" #include "../lib/structs.h" #include "../lib/users.h" #include "../lib/records.h" #include "../lib/common.h" #include "../lib/clcomm.h" #include "../lib/msg.h" #include "../lib/msgtext.h" #include "../lib/dbcfg.h" #include "../lib/dbnode.h" #include "../lib/dbmsgs.h" #include "../lib/dbdupe.h" #include "../lib/dbuser.h" #include "../lib/dbftn.h" #include "../lib/diesel.h" #include "sendmail.h" #include "mgrutil.h" #include "scan.h" #include "createm.h" #include "areamgr.h" #define LIST_LIST 0 #define LIST_NOTIFY 1 #define LIST_QUERY 2 #define LIST_UNLINK 3 /* * External declarations */ extern int do_quiet; /* * Global variables */ extern int net_bad; /* Bad netmails (tracking errors */ int areamgr = 0; /* Nr of AreaMgr messages */ int a_help = FALSE; /* Send AreaMgr help */ int a_list = FALSE; /* Send AreaMgr list */ int a_query = FALSE; /* Send AreaMgr query */ int a_stat = FALSE; /* Send AreaMgr status */ int a_unlnk = FALSE; /* Send AreaMgr unlinked */ int a_flow = FALSE; /* Send AreaMgr flow */ unsigned long a_msgs = 0; /* Messages to rescan */ void A_Help(faddr *, char *); void A_Help(faddr *t, char *replyid) { FILE *fp, *fi; char *line,*subject; int res; Syslog('+', "AreaMgr: Help"); subject = calloc(255, sizeof(char)); sprintf(subject,"AreaMgr Help"); MacroVars("SsNAP", "sssss", CFG.sysop_name, nodes.Sysop, "Areamgr", ascfnode(bestaka_s(t), 0xf), nodes.Apasswd ); GetRpSubject("areamgr.help",subject); if ((fp = SendMgrMail(t, CFG.ct_KeepMgr, FALSE, (char *)"Areamgr", subject , replyid)) != NULL) { if ((fi = OpenMacro("areamgr.help", nodes.Language)) != NULL ){ line = calloc(255, sizeof(char)); while ( fgets(line, 254, fi) != NULL ){ fprintf( fp, "%s", ParseMacro(line,&res)); } MacroClear(); free(line); fclose(fi); }else{ fprintf(fp, "Address all requests to '%s' (without quotes)\r", (char *)"Areamgr"); fprintf(fp, "Your AreaMgr password goes on the subject line.\r\r"); fprintf(fp, "In the body of the message to AreaMgr:\r\r"); fprintf(fp, "+ To connect to an echomail area\r"); fprintf(fp, "- To disconnect from an echomail area\r"); fprintf(fp, "%%+ALL To connect to all echomail areas\r"); fprintf(fp, "%%-ALL To disconnect from all echomail areas\r"); fprintf(fp, "%%+ To connect all echomail areas of a group\r"); fprintf(fp, "%%- To disconnect from all echomail areas of a group\r"); fprintf(fp, "%%HELP To request this help message\r"); fprintf(fp, "%%LIST To request a list of echomail areas available to you\r"); fprintf(fp, "%%QUERY To request a list of echomail areas for which you are active\r"); fprintf(fp, "%%UNLINKED To request a list of echomail areas available to you\r"); fprintf(fp, " to which you are not already connected\r"); fprintf(fp, "%%FLOW To request a flow report of available areas\r"); fprintf(fp, "%%STATUS To request a status report for your system\r"); fprintf(fp, "%%PAUSE To temporary disconnect from the connected echomail areas\r"); fprintf(fp, "%%RESUME To reconnect the temporary disconnected echomail areas\r"); fprintf(fp, "%%PWD=newpwd To set a new AreaMgr and FileMgr password\r"); fprintf(fp, "%%MSGS To set max. number of messages to be rescanned\r"); fprintf(fp, "%%RESCAN To request messages from 'area' again\r"); fprintf(fp, "%%NOTIFY=On/Off To switch the notify function on or off\r"); fprintf(fp, "[---] Everything below the tearline is ignored\r\r"); fprintf(fp, "Example:\r\r"); fprintf(fp, " By: %s\r", nodes.Sysop); fprintf(fp, " To: %s, %s\r", (char *)"Areamgr", ascfnode(bestaka_s(t), 0xf)); fprintf(fp, " Re: %s\r", nodes.Apasswd); fprintf(fp, " St: Pvt Local Kill\r"); fprintf(fp, " ----------------------------------------------------------\r"); fprintf(fp, " +SYSOPS\r"); fprintf(fp, " -GENERAL\r"); fprintf(fp, " %%QUERY\r"); fprintf(fp, " %%LIST\r\r"); } fprintf(fp, "%s\r", TearLine()); CloseMail(fp, t); } else WriteError("Can't create netmail"); free(subject); MacroClear(); } void A_Query(faddr *, char *); void A_Query(faddr *t, char *replyid) { A_List(t, replyid, LIST_QUERY); } void A_List(faddr *t, char *replyid, int Notify) { FILE *qp, *gp, *mp, *fi; char *temp, *Group, *line, *subject; int i, First = TRUE, SubTot, Total = 0, Cons, res; char Stat[5]; faddr *f, *g; sysconnect System; long msgptr; fpos_t fileptr,fileptr1,fileptr2; subject = calloc(255, sizeof(char)); MacroVars("SsKyY", "ssdss", CFG.sysop_name, nodes.Sysop, Notify, ascfnode(t, 0xff), ascfnode(bestaka_s(t), 0xf) ); if (Notify==LIST_NOTIFY){ Syslog('+', "AreaMgr: Notify to %s", ascfnode(t, 0xff)); sprintf(subject,"AreaMgr Notify"); GetRpSubject("areamgr.notify.list",subject); } if (Notify==LIST_LIST){ Syslog('+', "AreaMgr: List"); sprintf(subject,"AreaMgr list"); GetRpSubject("areamgr.list",subject); } if (Notify==LIST_QUERY){ Syslog('+', "AreaMgr: Query"); sprintf(subject,"AreaMgr Query"); GetRpSubject("areamgr.query",subject); } if (Notify>=LIST_UNLINK){ Syslog('+', "AreaMgr: Unlinked"); sprintf(subject,"AreaMgr: Unlinked areas"); GetRpSubject("areamgr.unlink",subject); } f = bestaka_s(t); if ((qp = SendMgrMail(t, CFG.ct_KeepMgr, FALSE, (char *)"Areamgr", subject, replyid)) != NULL) { /* * Mark begin of message in .pkt */ msgptr = ftell(qp); fi=NULL; if (Notify==LIST_LIST){ fi=OpenMacro("areamgr.list", nodes.Language); WriteMailGroups(qp, f); } if (Notify==LIST_NOTIFY){ fi=OpenMacro("areamgr.notify.list", nodes.Language); WriteMailGroups(qp, f); } if (Notify==LIST_QUERY) fi=OpenMacro("areamgr.query", nodes.Language); if (Notify>=LIST_UNLINK) fi=OpenMacro("areamgr.unlink", nodes.Language); line=calloc(256,sizeof(char)); if (fi != NULL){ while ( (fgets(line, 254, fi) != NULL) && ((line[0]!='@') || (line[1]!='|'))){ fprintf( qp, "%s", ParseMacro(line,&res)); } fgetpos(fi,&fileptr); }else{ fprintf(qp, "The following is a list of message areas\r\r"); } temp = calloc(PATH_MAX, sizeof(char)); sprintf(temp, "%s/etc/mareas.data", getenv("MBSE_ROOT")); if ((mp = fopen(temp, "r")) == NULL) { WriteError("$Can't open %s", temp); free(temp); free(line); free(subject); MacroClear(); return; } fread(&msgshdr, sizeof(msgshdr), 1, mp); Cons = msgshdr.syssize / sizeof(System); sprintf(temp, "%s/etc/mgroups.data", getenv("MBSE_ROOT")); if ((gp = fopen(temp, "r")) == NULL) { WriteError("$Can't open %s", temp); free(temp); free(line); free(subject); MacroClear(); fclose(mp); return; } fread(&mgrouphdr, sizeof(mgrouphdr), 1, gp); free(temp); while (TRUE) { Group = GetNodeMailGrp(First); if (Group == NULL) break; First = FALSE; fseek(gp, mgrouphdr.hdrsize, SEEK_SET); while (fread(&mgroup, mgrouphdr.recsize, 1, gp) == 1) { g = bestaka_s(fido2faddr(mgroup.UseAka)); if ((!strcmp(mgroup.Name, Group)) && (g->zone == f->zone) && (g->net == f->net) && (g->node == f->node) && (g->point == f->point)) { SubTot = 0; if (fi != NULL){ MacroVars("GHI", "sss",mgroup.Name, mgroup.Comment, aka2str(mgroup.UseAka) ); fsetpos(fi,&fileptr); while ( (fgets(line, 254, fi) != NULL) && ((line[0]!='@') || (line[1]!='|'))){ fprintf( qp, "%s", ParseMacro(line,&res)); } fgetpos(fi,&fileptr1); }else{ fprintf(qp, "Group %s - %s (%s)\r\r", mgroup.Name, mgroup.Comment, aka2str(mgroup.UseAka)); fprintf(qp, "Con Message area Description\r"); fprintf(qp, "----------------------------------------------------------------------------\r"); } fseek(mp, msgshdr.hdrsize, SEEK_SET); while (fread(&msgs, msgshdr.recsize, 1, mp) == 1) { if (!strcmp(Group, msgs.Group) && msgs.Active) { memset(&Stat, ' ', sizeof(Stat)); Stat[sizeof(Stat)-1] = '\0'; /* * Now check if this node is connected, if so, set the Stat bits */ for (i = 0; i < Cons; i++) { fread(&System, sizeof(System), 1, mp); if ((t->zone == System.aka.zone) && (t->net == System.aka.net) && (t->node == System.aka.node) && (t->point == System.aka.point)) { if (System.receivefrom) Stat[0] = 'S'; if (System.sendto) Stat[1] = 'R'; if (System.pause) Stat[2] = 'P'; if (System.cutoff) Stat[3] = 'C'; } } if ( (Notify == LIST_LIST) || (Notify == LIST_NOTIFY) || ((Notify == LIST_QUERY) && ((Stat[0]=='S') || (Stat[1]=='R'))) || ((Notify >= LIST_UNLINK) && ((Stat[0]!='S') && (Stat[1]!='R')))){ if (fi !=NULL){ MacroVars("XTNsrpc", "sssdddd", Stat, msgs.Tag, msgs.Name, (Stat[0] == 'S'), (Stat[1] == 'R'), (Stat[2] == 'P'), (Stat[3] == 'C') ); fsetpos(fi,&fileptr1); while ( (fgets(line, 254, fi) != NULL) && ((line[0]!='@') || (line[1]!='|'))){ fprintf( qp, "%s", ParseMacro(line,&res)); } fgetpos(fi,&fileptr2); }else{ fprintf(qp, "%s %-25s %s\r", Stat, msgs.Tag, msgs.Name); } SubTot++; Total++; } } else fseek(mp, msgshdr.syssize, SEEK_CUR); } if (fi != NULL){ MacroVars("ZA", "dd", (int) 0 , SubTot ); fsetpos(fi,&fileptr2); while ( (fgets(line, 254, fi) != NULL) && ((line[0]!='@') || (line[1]!='|'))){ if (((ftell(qp) - msgptr) / 1024) >= CFG.new_split) { MacroVars("Z","d",1); Syslog('-', " Splitting message at %ld bytes", ftell(qp) - msgptr); CloseMail(qp, t); qp = SendMgrMail(t, CFG.ct_KeepMgr, FALSE, (char *)"Areamgr", subject, replyid); msgptr = ftell(qp); } fprintf( qp, "%s", ParseMacro(line,&res)); } }else{ fprintf(qp, "----------------------------------------------------------------------------\r"); fprintf(qp, "%d area(s)\r\r\r", SubTot); if (((ftell(qp) - msgptr) / 1024) >= CFG.new_split) { fprintf(qp, "To be continued....\r\r"); Syslog('-', " Splitting message at %ld bytes", ftell(qp) - msgptr); CloseMail(qp, t); qp = SendMgrMail(t, CFG.ct_KeepMgr, FALSE, (char *)"Areamgr", subject, replyid); msgptr = ftell(qp); } } } } } if (fi != NULL){ MacroVars("B", "d", Total ); while ( fgets(line, 254, fi) != NULL ){ fprintf( qp, "%s", ParseMacro(line,&res)); } MacroClear(); fclose(fi); }else{ fprintf(qp, "Total: %d available area(s)\r\r\r", Total); fprintf(qp, "Con means:\r"); fprintf(qp, " R - You receive mail from my system\r"); fprintf(qp, " S - You may send mail to my system\r"); fprintf(qp, " P - The message area is temporary paused\r"); fprintf(qp, " C - You are cutoff from this area\r\r"); fprintf(qp, "With regards, %s\r\r", CFG.sysop_name); } fclose(mp); fclose(gp); free(line); fprintf(qp, "%s\r", TearLine()); CloseMail(qp, t); } else WriteError("Can't create netmail"); free(subject); MacroClear(); } void A_Flow(faddr *t, char *replyid, int Notify) { FILE *qp, *gp, *mp, *fi; char *temp, *Group, *line, *subject; int i, First = TRUE, Cons, res; char Stat[2]; faddr *f, *g; sysconnect System; time_t Now; struct tm *tt; int lmonth; long rlw, rlm, rlt, plw, plm, plt; long msgptr; fpos_t fileptr, fileptr1, fileptr2; Now = time(NULL); tt = localtime(&Now); lmonth = tt->tm_mon; if (lmonth) lmonth--; else lmonth = 11; subject = calloc(255, sizeof(char)); MacroVars("SsKyY", "ssdss", CFG.sysop_name, nodes.Sysop, Notify, ascfnode(t, 0xff), ascfnode(bestaka_s(t), 0xf) ); if (Notify){ Syslog('+', "AreaMgr: Flow report to %s", ascfnode(t, 0xff)); sprintf(subject,"AreaMgr Notify Flow Report"); GetRpSubject("areamgr.notify.flow",subject); }else{ Syslog('+', "AreaMgr: Flow report"); sprintf(subject,"AreaMgr Flow Report"); GetRpSubject("areamgr.flow",subject); } f = bestaka_s(t); if ((qp = SendMgrMail(t, CFG.ct_KeepMgr, FALSE, (char *)"Areamgr", subject, replyid)) != NULL) { fi=NULL; if (Notify){ fi=OpenMacro("areamgr.notify.flow", nodes.Language); }else{ fi=OpenMacro("areamgr.flow", nodes.Language); } /* * Mark begin of message in .pkt */ msgptr = ftell(qp); temp = calloc(PATH_MAX, sizeof(char)); line = calloc(256, sizeof(char)); sprintf(temp, "%s/etc/mareas.data", getenv("MBSE_ROOT")); if ((mp = fopen(temp, "r")) == NULL) { WriteError("$Can't open %s", temp); free(temp); free(line); free(subject); return; } fread(&msgshdr, sizeof(msgshdr), 1, mp); Cons = msgshdr.syssize / sizeof(System); sprintf(temp, "%s/etc/mgroups.data", getenv("MBSE_ROOT")); if ((gp = fopen(temp, "r")) == NULL) { WriteError("$Can't open %s", temp); free(temp); free(line); free(subject); fclose(mp); return; } fread(&mgrouphdr, sizeof(mgrouphdr), 1, gp); free(temp); if (fi != NULL){ while ( (fgets(line, 254, fi) != NULL) && ((line[0]!='@') || (line[1]!='|'))){ fprintf( qp, "%s", ParseMacro(line,&res)); } fgetpos(fi,&fileptr); }else{ fprintf(qp, "The following is a flow report of all message areas\r\r"); } while (TRUE) { Group = GetNodeMailGrp(First); if (Group == NULL) break; First = FALSE; plm = plw = plt = rlm = rlw = rlt = 0; fseek(gp, mgrouphdr.hdrsize, SEEK_SET); while (fread(&mgroup, mgrouphdr.recsize, 1, gp) == 1) { g = bestaka_s(fido2faddr(mgroup.UseAka)); if ((!strcmp(mgroup.Name, Group)) && (g->zone == f->zone) && (g->net == f->net) && (g->node == f->node) && (g->point == f->point)) { if (fi != NULL){ MacroVars("GHI", "sss",mgroup.Name, mgroup.Comment, aka2str(mgroup.UseAka) ); fsetpos(fi,&fileptr); while ( (fgets(line, 254, fi) != NULL) && ((line[0]!='@') || (line[1]!='|'))){ fprintf( qp, "%s", ParseMacro(line,&res)); } fgetpos(fi,&fileptr1); }else{ fprintf(qp, "Group %s - %s\r\r", mgroup.Name, mgroup.Comment); fprintf(qp, "Con Message area Last week Last Month\r"); fprintf(qp, "---------------------------------------------------------------------------\r"); } fseek(mp, msgshdr.hdrsize, SEEK_SET); while (fread(&msgs, msgshdr.recsize, 1, mp) == 1) { if (!strcmp(Group, msgs.Group) && msgs.Active) { memset(&Stat, ' ', sizeof(Stat)); Stat[sizeof(Stat)-1] = '\0'; /* * Now check if this node is connected, if so, set the Stat bits */ for (i = 0; i < Cons; i++) { fread(&System, sizeof(System), 1, mp); if ((t->zone == System.aka.zone) && (t->net == System.aka.net) && (t->node == System.aka.node) && (t->point == System.aka.point)) { if ((System.receivefrom || System.sendto) && (!System.pause) && (!System.cutoff)) Stat[0] = 'C'; } } if (fi !=NULL){ MacroVars("XAWMTwmtx", "csddddddd", Stat[0], msgs.Tag, msgs.Received.lweek, msgs.Received.month[lmonth], msgs.Received.total, msgs.Posted.lweek, msgs.Posted.month[lmonth], msgs.Posted.total, (Stat[0] == 'C') ); fsetpos(fi,&fileptr1); while ( (fgets(line, 254, fi) != NULL) && ((line[0]!='@') || (line[1]!='|'))){ fprintf( qp, "%s", ParseMacro(line,&res)); } fgetpos(fi,&fileptr2); }else{ fprintf(qp, "%s %s %9lu %10lu\r", Stat, padleft(msgs.Tag, 50, ' '), msgs.Received.lweek, msgs.Received.month[lmonth]); } rlm += msgs.Received.month[lmonth]; rlw += msgs.Received.lweek; rlt += msgs.Received.total; plm += msgs.Posted.month[lmonth]; plw += msgs.Posted.lweek; plt += msgs.Posted.total; } else fseek(mp, msgshdr.syssize, SEEK_CUR); } if (fi != NULL){ MacroVars("ZBCDbcd", "ddddddd", (int) 0 , rlw, rlm, rlt, plw, plm, plt); fsetpos(fi,&fileptr2); while ( (fgets(line, 254, fi) != NULL) && ((line[0]!='@') || (line[1]!='|'))){ if (((ftell(qp) - msgptr) / 1024) >= CFG.new_split) { MacroVars("Z","d",1); Syslog('-', " Splitting message at %ld bytes", ftell(qp) - msgptr); CloseMail(qp, t); qp = SendMgrMail(t, CFG.ct_KeepMgr, FALSE, (char *)"Areamgr", subject, replyid); msgptr = ftell(qp); } fprintf( qp, "%s", ParseMacro(line,&res)); } }else{ fprintf(qp, "---------------------------------------------------------------------------\r"); fprintf(qp, "Total %58lu %10lu\r\r\r", rlw, rlm); if (((ftell(qp) - msgptr) / 1024) >= CFG.new_split) { fprintf(qp, "To be continued....\r\r"); Syslog('-', " Splitting message at %ld bytes", ftell(qp) - msgptr); CloseMail(qp, t); qp = SendMgrMail(t, CFG.ct_KeepMgr, FALSE, (char *)"Areamgr", subject, replyid); msgptr = ftell(qp); } } } } } if (fi != NULL){ while ( fgets(line, 254, fi) != NULL ){ fprintf( qp, "%s", ParseMacro(line,&res)); } MacroClear(); fclose(fi); }else{ fprintf(qp, "Con means:\r"); fprintf(qp, " C - You connected to this area\r"); fprintf(qp, "With regards, %s\r\r", CFG.sysop_name); fprintf(qp, "%s\r", TearLine()); } CloseMail(qp, t); fclose(mp); fclose(gp); free(line); } else WriteError("Can't create netmail"); free(subject); } void A_Status(faddr *, char *); void A_Status(faddr *t, char *replyid) { FILE *fp, *fi; int i,res; char *line, *subject; subject = calloc(255, sizeof(char)); sprintf(subject,"AreaMgr Status"); if (Miy == 0) i = 11; else i = Miy - 1; MacroVars("DCHNLRWMTwmtSsYy","ddddcsddddddssss", nodes.Direct, nodes.Crash, nodes.Hold, nodes.Notify, nodes.Language, aka2str(nodes.RouteVia), nodes.MailSent.lweek, nodes.MailSent.month[i], nodes.MailSent.total, nodes.MailRcvd.lweek, nodes.MailRcvd.month[i], nodes.MailRcvd.total, CFG.sysop_name, nodes.Sysop, ascfnode(t, 0xff), ascfnode(bestaka_s(t), 0xf) ); GetRpSubject("areamgr.status",subject); Syslog('+', "AreaMgr: Status"); if ((fp = SendMgrMail(t, CFG.ct_KeepMgr, FALSE, (char *)"Areamgr", subject, replyid)) != NULL) { if ( (fi=OpenMacro("areamgr.status", nodes.Language)) != NULL ){ line = calloc(255, sizeof(char)); while ( fgets(line, 254, fi) != NULL ){ fprintf( fp, "%s", ParseMacro(line,&res)); } free(line); fclose(fi); }else{ fprintf(fp, "Here is your (echo)mail status:\r\r"); fprintf(fp, "Netmail direct %s\r", GetBool(nodes.Direct)); fprintf(fp, "Netmail crash %s\r", GetBool(nodes.Crash)); fprintf(fp, "Netmail hold %s\r", GetBool(nodes.Hold)); if (nodes.RouteVia.zone) fprintf(fp, "Route via %s\r", aka2str(nodes.RouteVia)); fprintf(fp, "\r\rMailflow:\r\r"); fprintf(fp, " Last week Last month Total ever\r"); fprintf(fp, " ---------- ---------- ----------\r"); fprintf(fp, "Messages to you %-10ld %-10ld %-10ld\r", nodes.MailSent.lweek, nodes.MailSent.month[i], nodes.MailSent.total); fprintf(fp, "Messages from you %-10ld %-10ld %-10ld\r", nodes.MailRcvd.lweek, nodes.MailRcvd.month[i], nodes.MailRcvd.total); fprintf(fp, "\rWith regards, %s\r\r", CFG.sysop_name); } fprintf(fp, "%s\r", TearLine()); CloseMail(fp, t); } else WriteError("Can't create netmail"); MacroClear(); free(subject); } void A_Unlinked(faddr *, char *); void A_Unlinked(faddr *t, char *replyid) { A_List(t, replyid, LIST_UNLINK); } void A_Disconnect(faddr *, char *, FILE *); void A_Disconnect(faddr *t, char *Area, FILE *tmp) { int i, First; char *Group; faddr *b; sysconnect Sys; Syslog('+', "AreaMgr: \"%s\"", Area); ShiftBuf(Area, 1); for (i=0; i < strlen(Area); i++ ) Area[i]=toupper(Area[i]); if (!SearchMsgs(Area)) { MacroVars("SsP", "sss", CFG.sysop_name, nodes.Sysop, "Areamgr"); MacroVars("RABCDE", "ssssss","ERR_DISC_NOTFOUND",Area,"","","",""); if (!MsgResult("areamgr.responses",tmp)) fprintf(tmp, "Area %s not found\n", Area); Syslog('+', " Area not found"); MacroClear(); return; } Syslog('m', " Found %s group %s", msgs.Tag, mgroup.Name); First = TRUE; while ((Group = GetNodeMailGrp(First)) != NULL) { First = FALSE; if (strcmp(Group, mgroup.Name) == 0) break; } if (Group == NULL) { MacroVars("SsP", "sss", CFG.sysop_name, nodes.Sysop, "Areamgr"); MacroVars("RABCDE", "ssssss","ERR_DISC_NOTGROUP",Area,"","","",""); if (!MsgResult("areamgr.responses",tmp)) fprintf(tmp, "You may not disconnect from area %s\n", Area); Syslog('+', " Group %s not available for %s", mgroup.Name, ascfnode(t, 0x1f)); MacroClear(); return; } b = bestaka_s(t); i = metric(b, fido2faddr(msgs.Aka)); Syslog('m', "Aka match level is %d", i); if (i >= METRIC_NET) { MacroVars("SsP", "sss", CFG.sysop_name, nodes.Sysop, "Areamgr"); MacroVars("RABCDE", "ssssss","ERR_DISC_BADADD",Area,ascfnode(t, 0x1f),"","",""); if (!MsgResult("areamgr.responses",tmp)) fprintf(tmp, "You may not disconnect area %s with nodenumber %s\n", Area, ascfnode(t, 0x1f)); Syslog('+', " %s may not disconnect from group %s", ascfnode(t, 0x1f), mgroup.Name); MacroClear(); return; } memset(&Sys, 0, sizeof(Sys)); memcpy(&Sys.aka, faddr2fido(t), sizeof(fidoaddr)); Sys.sendto = FALSE; Sys.receivefrom = FALSE; if (!MsgSystemConnected(Sys)) { MacroVars("SsP", "sss", CFG.sysop_name, nodes.Sysop,"Areamgr"); MacroVars("RABCDE", "ssssss","ERR_DISC_NC",Area,"","","",""); if (!MsgResult("areamgr.responses",tmp)) fprintf(tmp, "You are not connected to %s\n", Area); Syslog('+', " %s is not connected to %s", ascfnode(t, 0x1f), Area); MacroClear(); return; } if (MsgSystemConnect(&Sys, FALSE)) { /* * Make sure to write an overview afterwards. */ a_list = TRUE; Syslog('+', "Disconnected echo area %s", Area); MacroVars("SsP", "sss", CFG.sysop_name, nodes.Sysop,"Areamgr"); MacroVars("RABCDE", "ssssss","OK_DISC",Area,"","","",""); if (!MsgResult("areamgr.responses",tmp)) fprintf(tmp, "Disconnected from area %s\n", Area); MacroClear(); return; } MacroVars("SsP", "sss", CFG.sysop_name, nodes.Sysop,"Areamgr"); MacroVars("RABCDE", "ssssss","ERR_DISC_NOTAVAIL",Area,"","","",""); if (!MsgResult("areamgr.responses",tmp)) fprintf(tmp, "You may not disconnect area %s\n", Area); Syslog('+', "Didn't disconnect %s from mandatory or cutoff echo area %s", ascfnode(t, 0x1f), Area); MacroClear(); } void A_Connect(faddr *, char *, FILE *); void A_Connect(faddr *t, char *Area, FILE *tmp) { int i, First; char *Group, *temp; faddr *b; sysconnect Sys; FILE *gp; Syslog('+', "AreaMgr: \"%s\"", printable(Area, 0)); if (Area[0] == '+') ShiftBuf(Area, 1); for (i=0; i < strlen(Area); i++ ) Area[i]=toupper(Area[i]); if (!SearchMsgs(Area)) { /* * Close noderecord, autocreate will destroy it. */ UpdateNode(); Syslog('m', " Area not found, trying to create"); temp = calloc(PATH_MAX, sizeof(char)); sprintf(temp, "%s/etc/mgroups.data", getenv("MBSE_ROOT")); if ((gp = fopen(temp, "r")) == NULL) { WriteError("$Can't open %s", temp); free(temp); return; } fread(&mgrouphdr, sizeof(mgrouphdr), 1, gp); fseek(gp, mgrouphdr.hdrsize, SEEK_SET); while ((fread(&mgroup, mgrouphdr.recsize, 1, gp)) == 1) { if ((mgroup.UseAka.zone == t->zone) && (mgroup.UseAka.net == t->net) && mgroup.UpLink.zone && strlen(mgroup.AreaFile) && mgroup.Active && mgroup.UserChange) { if (CheckEchoGroup(Area, TRUE, t) == 0) { MacroVars("SsP", "sss", CFG.sysop_name, nodes.Sysop,"Areamgr"); MacroVars("RABCDE", "ssssss","ERR_CONN_FORWARD",Area,aka2str(mgroup.UpLink),"","",""); if (!MsgResult("areamgr.responses",tmp)) fprintf(tmp, "Area %s not available, requested from uplink %s\n", Area, aka2str(mgroup.UpLink)); break; } } } fclose(gp); free(temp); /* * Restore noderecord and try to load the area again */ SearchNodeFaddr(t); if (!SearchMsgs(Area)) { MacroVars("SsP", "sss", CFG.sysop_name, nodes.Sysop, "Areamgr"); MacroVars("RABCDE", "ssssss","ERR_CONN_NOTFOUND",Area,"","","",""); if (!MsgResult("areamgr.responses",tmp)) fprintf(tmp, "Area %s not found\n", Area); Syslog('+', "Area %s not found", Area); MacroClear(); return; } } Syslog('m', " Found %s group %s", msgs.Tag, mgroup.Name); First = TRUE; while ((Group = GetNodeMailGrp(First)) != NULL) { First = FALSE; if (strcmp(Group, mgroup.Name) == 0) break; } if (Group == NULL) { MacroVars("SsP", "sss", CFG.sysop_name, nodes.Sysop, "Areamgr"); MacroVars("RABCDE", "ssssss","ERR_CONN_NOTGROUP",Area,"","","",""); if (!MsgResult("areamgr.responses",tmp)) fprintf(tmp, "You may not connect to area %s\n", Area); Syslog('+', " Group %s not available for node %s", mgroup.Name, ascfnode(t, 0x1f)); MacroClear(); return; } b = bestaka_s(t); i = metric(b, fido2faddr(msgs.Aka)); Syslog('m', "Aka match level is %d", i); if (i >= METRIC_NET) { MacroVars("SsP", "sss", CFG.sysop_name, nodes.Sysop,"Areamgr"); MacroVars("RABCDE", "ssssss","ERR_CONN_BADADD",Area,ascfnode(t, 0x1f),"","",""); if (!MsgResult("areamgr.responses",tmp)) fprintf(tmp, "You may not connect area %s with nodenumber %s\n", Area, ascfnode(t, 0x1f)); Syslog('+', " %s may not connect to group %s", ascfnode(t, 0x1f), mgroup.Name); MacroClear(); return; } memset(&Sys, 0, sizeof(Sys)); memcpy(&Sys.aka, faddr2fido(t), sizeof(fidoaddr)); Sys.sendto = TRUE; Sys.receivefrom = TRUE; if (MsgSystemConnected(Sys)) { MacroVars("SsP", "sss", CFG.sysop_name, nodes.Sysop,"Areamgr"); MacroVars("RABCDE", "ssssss","ERR_CONN_ALREADY",Area,"","","",""); if (!MsgResult("areamgr.responses",tmp)) fprintf(tmp, "You are already connected to %s\n", Area); Syslog('+', " %s is already connected to %s", ascfnode(t, 0x1f), Area); MacroClear(); return; } if (MsgSystemConnect(&Sys, TRUE)) { /* * Make sure to write an overview afterwards. */ a_list = TRUE; Syslog('+', "Connected echo area %s", Area); MacroVars("SsP", "sss", CFG.sysop_name, nodes.Sysop,"Areamgr"); MacroVars("RABCDE", "ssssss","OK_CONN",Area,aka2str(msgs.Aka),"","",""); if (!MsgResult("areamgr.responses",tmp)) fprintf(tmp, "Connected to area %s using aka %s\n", Area, aka2str(msgs.Aka)); MacroClear(); return; } MacroVars("SsP", "sss", CFG.sysop_name, nodes.Sysop,"Areamgr"); MacroVars("RABCDE", "ssssss","ERR_CONN_NOTAVAIL",Area,"","","",""); if (!MsgResult("areamgr.responses",tmp)) fprintf(tmp, "Not connected to %s, this is not allowed\n", Area); WriteError("Can't connect node %s to echo area %s", ascfnode(t, 0x1f), Area); MacroClear(); } void A_All(faddr *, int, FILE *, char *); void A_All(faddr *t, int Connect, FILE *tmp, char *Grp) { FILE *mp, *gp; char *Group, *temp; faddr *f; int i, Link, First = TRUE, Cons; sysconnect Sys; long Pos; if (Grp == NULL) { if (Connect) Syslog('+', "AreaMgr: Connect All"); else Syslog('+', "AreaMgr: Disconnect All"); } else { if (Connect) Syslog('+', "AreaMgr: Connect group %s", Grp); else Syslog('+', "AreaMgr: Disconnect group %s", Grp); } f = bestaka_s(t); temp = xstrcpy(ascfnode(t, 0x1f)); Syslog('m', "Bestaka for %s is %s", temp, ascfnode(f, 0x1f)); free(temp); temp = calloc(PATH_MAX, sizeof(char)); sprintf(temp, "%s/etc/mareas.data", getenv("MBSE_ROOT")); if ((mp = fopen(temp, "r+")) == NULL) { WriteError("$Can't open %s", temp); free(temp); return; } fread(&msgshdr, sizeof(msgshdr), 1, mp); Cons = msgshdr.syssize / sizeof(Sys); sprintf(temp, "%s/etc/mgroups.data", getenv("MBSE_ROOT")); if ((gp = fopen(temp, "r")) == NULL) { WriteError("$Can't open %s", temp); free(temp); fclose(mp); return; } fread(&mgrouphdr, sizeof(mgrouphdr), 1, gp); free(temp); while (TRUE) { Group = GetNodeMailGrp(First); if (Group == NULL) break; First = FALSE; fseek(gp, mgrouphdr.hdrsize, SEEK_SET); while (fread(&mgroup, mgrouphdr.recsize, 1, gp) == 1) { if ((!strcmp(mgroup.Name, Group)) && ((Grp == NULL) || (!strcmp(Group, Grp)))) { fseek(mp, msgshdr.hdrsize, SEEK_SET); while (fread(&msgs, msgshdr.recsize, 1, mp) == 1) { if ((!strcmp(Group, msgs.Group)) && (msgs.Active) && (!msgs.Mandatory) && strlen(msgs.Tag) && ((msgs.Type == ECHOMAIL) || (msgs.Type == NEWS) || (msgs.Type == LIST)) && (metric(fido2faddr(msgs.Aka), f) < METRIC_NET)) { if (Connect) { Link = FALSE; for (i = 0; i < Cons; i++) { fread(&Sys, sizeof(Sys), 1, mp); if (metric(fido2faddr(Sys.aka), t) == METRIC_EQUAL) Link = TRUE; } if (!Link) { Pos = ftell(mp); fseek(mp, - msgshdr.syssize, SEEK_CUR); for (i = 0; i < Cons; i++) { fread(&Sys, sizeof(Sys), 1, mp); if (!Sys.aka.zone) { memset(&Sys, 0, sizeof(Sys)); memcpy(&Sys.aka, faddr2fido(t), sizeof(fidoaddr)); Sys.sendto = TRUE; Sys.receivefrom = TRUE; fseek(mp, - sizeof(Sys), SEEK_CUR); fwrite(&Sys, sizeof(Sys), 1, mp); Syslog('+', "AreaMgr: Connected %s", msgs.Tag); MacroVars("SsP", "sss", CFG.sysop_name, nodes.Sysop,"Areamgr"); MacroVars("RABCDE", "ssssss","OK_CONN",msgs.Tag,aka2str(msgs.Aka),"","",""); if (!MsgResult("areamgr.responses",tmp)) fprintf(tmp, "Connected area %s using aka %s\n", msgs.Tag, aka2str(msgs.Aka)); MacroClear(); a_list = TRUE; break; } } fseek(mp, Pos, SEEK_SET); } } else { for (i = 0; i < Cons; i++) { fread(&Sys, sizeof(Sys), 1, mp); if ((metric(fido2faddr(Sys.aka), t) == METRIC_EQUAL) && (!Sys.cutoff)) { memset(&Sys, 0, sizeof(Sys)); fseek(mp, - sizeof(Sys), SEEK_CUR); fwrite(&Sys, sizeof(Sys), 1, mp); Syslog('+', "AreaMgr: Disconnected %s", msgs.Tag); MacroVars("SsP", "sss", CFG.sysop_name, nodes.Sysop,"Areamgr"); MacroVars("RABCDE", "ssssss","OK_DISC",msgs.Tag,"","","",""); if (!MsgResult("areamgr.responses",tmp)) fprintf(tmp, "Disconnected area %s\n", msgs.Tag); MacroClear(); a_list = TRUE; } } } } else fseek(mp, msgshdr.syssize, SEEK_CUR); } } } } fclose(gp); fclose(mp); } void A_Group(faddr *, char *, int, FILE *); void A_Group(faddr *t, char *Area, int Connect, FILE *tmp) { int i; ShiftBuf(Area, 2); CleanBuf(Area); for (i = 0; i < strlen(Area); i++ ) Area[i] = toupper(Area[i]); A_All(t, Connect, tmp, Area); } void A_Pause(faddr *, int, FILE *); void A_Pause(faddr *t, int Pause, FILE *tmp) { FILE *mp; faddr *f; int i, Cons; sysconnect Sys; char *temp; if (Pause) Syslog('+', "AreaMgr: Pause"); else Syslog('+', "AreaMgr: Resume"); f = bestaka_s(t); Syslog('m', "Bestaka for %s is %s", ascfnode(t, 0x1f), ascfnode(f, 0x1f)); temp = calloc(PATH_MAX, sizeof(char)); sprintf(temp, "%s/etc/mareas.data", getenv("MBSE_ROOT")); if ((mp = fopen(temp, "r+")) == NULL) { WriteError("$Can't open %s", temp); free(temp); return; } free(temp); fread(&msgshdr, sizeof(msgshdr), 1, mp); Cons = msgshdr.syssize / sizeof(Sys); while (fread(&msgs, msgshdr.recsize, 1, mp) == 1) { if (msgs.Active) { for (i = 0; i < Cons; i++) { fread(&Sys, sizeof(Sys), 1, mp); if ((metric(fido2faddr(Sys.aka), t) == METRIC_EQUAL) && (!Sys.cutoff)) { Sys.pause = Pause; fseek(mp, - sizeof(Sys), SEEK_CUR); fwrite(&Sys, sizeof(Sys), 1, mp); Syslog('+', "AreaMgr: %s area %s", Pause?"Pause":"Resume", msgs.Tag); MacroVars("SsP", "sss", CFG.sysop_name, nodes.Sysop,"Areamgr"); MacroVars("RABCDE", "ssssss","OK_PAUSE",msgs.Tag,ascfnode(t, 0x1f),"",""); if (!MsgResult("areamgr.responses",tmp)) fprintf(tmp, "%s area %s\n", Pause?"Pause":"Resume", msgs.Tag); a_list = TRUE; } } } else { fseek(mp, msgshdr.syssize, SEEK_CUR); } } fclose(mp); } void A_Rescan(faddr *, char *, FILE *); void A_Rescan(faddr *t, char *Area, FILE *tmp) { int i,result; /* * First strip leading garbage */ ShiftBuf(Area, 7); CleanBuf(Area); for (i = 0; i < strlen(Area); i++ ) Area[i] = toupper(Area[i]); Syslog('+', "AreaMgr: Rescan %s, MSGS=%lu", Area, a_msgs); result = RescanOne(t, Area, a_msgs); MacroVars("SsP", "sss", CFG.sysop_name, nodes.Sysop,"Areamgr"); if (result == 0){ MacroVars("RABCDE", "ssdsss","OK_RESCAN",Area,a_msgs,"","",""); if (!MsgResult("areamgr.responses",tmp)){ if (a_msgs > 0) fprintf(tmp, "Rescan area %s, %lu last msgs.\n", Area, a_msgs); else fprintf(tmp, "Rescan area %s \n", Area); } } else if (result == 1) MacroVars("RABCDE", "ssssss","ERR_RESCAN_UNK",Area,"","","",""); if (!MsgResult("areamgr.responses",tmp)) fprintf(tmp, "Can't rescan unknown area %s\n", Area); else if (result == 2) MacroVars("RABCDE", "ssssss","ERR_RESCAN_NOTAVAIL",Area,ascfnode(t, 0x1f),"","",""); if (!MsgResult("areamgr.responses",tmp)) fprintf(tmp, "%s can't rescan area %s\n", ascfnode(t, 0x1f), Area); else MacroVars("RABCDE", "ssssss","ERR_RESCAN_FATAL",Area,ascfnode(t, 0x1f),"","",""); if (!MsgResult("areamgr.responses",tmp)) fprintf(tmp, "Fatal Error Rescanning area %s\n", Area); MacroClear(); } void A_Msgs(char *, int); void A_Msgs(char *Buf, int skip) { /* * First strip leading garbage */ ShiftBuf(Buf, skip); CleanBuf(Buf); a_msgs = strtoul( Buf, (char **)NULL, 10 ); Syslog('+', "AreaMgr: msgs %s ", Buf ); } int AreaMgr(faddr *f, faddr *t, char *replyid, char *subj, time_t mdate, int flags, FILE *fp) { int i, rc = 0, spaces; char *Buf, *subject; FILE *tmp, *np; a_help = a_stat = a_unlnk = a_list = a_query = FALSE; areamgr++; if (SearchFidonet(f->zone)) f->domain = xstrcpy(fidonet.domain); Syslog('+', "AreaMgr msg from %s", ascfnode(f, 0xff)); /* * If the password failed, we return silently and don't respond. */ if ((!strlen(subj)) || (strcasecmp(subj, nodes.Apasswd))) { WriteError("AreaMgr: password expected \"%s\", got \"%s\"", nodes.Apasswd, subj); net_bad++; return FALSE; } if ((tmp = tmpfile()) == NULL) { WriteError("$AreaMgr: Can't open tmpfile()"); net_bad++; return FALSE; } Buf = calloc(2049, sizeof(char)); rewind(fp); while ((fgets(Buf, 2048, fp)) != NULL) { /* * Make sure we have the nodes record loaded */ SearchNodeFaddr(f); spaces = 0; for (i = 0; i < strlen(Buf); i++) { if (*(Buf + i) == ' ') spaces++; if (*(Buf + i) == '\t') spaces++; if (*(Buf + i) == '\0') break; if (*(Buf + i) == '\n') *(Buf + i) = '\0'; if (*(Buf + i) == '\r') *(Buf + i) = '\0'; } if (!strncmp(Buf, "---", 3)) break; if (strlen(Buf) && (*(Buf) != '\001') && (spaces <= 1)) { if (!strncasecmp(Buf, "%help", 5)) a_help = TRUE; else if (!strncasecmp(Buf, "%query", 6)) a_query = TRUE; else if (!strncasecmp(Buf, "%linked", 7)) a_query = TRUE; else if (!strncasecmp(Buf, "%list", 5)) a_list = TRUE; else if (!strncasecmp(Buf, "%status", 7)) a_stat = TRUE; else if (!strncasecmp(Buf, "%unlinked", 9)) a_unlnk = TRUE; else if (!strncasecmp(Buf, "%flow", 5)) a_flow = TRUE; else if (!strncasecmp(Buf, "%msgs", 5)) A_Msgs(Buf, 5); else if (!strncasecmp(Buf, "%rescan", 7)) A_Rescan(f, Buf, tmp); else if (!strncasecmp(Buf, "%+all", 5)) A_All(f, TRUE, tmp, NULL); else if (!strncasecmp(Buf, "%-all", 5)) A_All(f, FALSE, tmp, NULL); else if (!strncasecmp(Buf, "%+*", 3)) A_All(f, TRUE, tmp, NULL); else if (!strncasecmp(Buf, "%-*", 3)) A_All(f, FALSE, tmp, NULL); else if (!strncasecmp(Buf, "%+", 2)) A_Group(f, Buf, TRUE, tmp); else if (!strncasecmp(Buf, "%-", 2)) A_Group(f, Buf, FALSE, tmp); else if (!strncasecmp(Buf, "%pause", 6)) A_Pause(f, TRUE, tmp); else if (!strncasecmp(Buf, "%resume", 7)) A_Pause(f, FALSE, tmp); else if (!strncasecmp(Buf, "%passive", 8)) A_Pause(f, TRUE, tmp); else if (!strncasecmp(Buf, "%active", 7)) A_Pause(f, FALSE, tmp); else if (!strncasecmp(Buf, "%password", 9)) MgrPasswd(f, Buf, tmp, 9, 0); else if (!strncasecmp(Buf, "%pwd", 4)) MgrPasswd(f, Buf, tmp, 4, 0); else if (!strncasecmp(Buf, "%notify", 7)) MgrNotify(f, Buf, tmp, 0); else if (*(Buf) == '-') A_Disconnect(f, Buf, tmp); else A_Connect(f, Buf, tmp); } } /* * If the temporary response file isn't empty, * create a response netmail about what we did. */ if (ftell(tmp)) { subject=calloc(256,sizeof(char)); MacroVars("SsP", "sss", CFG.sysop_name, nodes.Sysop,"Areamgr"); MacroVars("RABCDE", "ssssss","","","","","",""); sprintf(subject,"Your AreaMgr request"); GetRpSubject("areamgr.responses",subject); if ((np = SendMgrMail(f, CFG.ct_KeepMgr, FALSE, (char *)"Areamgr", subject, replyid)) != NULL) { MacroVars("RABCDE", "ssssss","WELLCOME","","","","",""); if (!MsgResult("areamgr.responses",np)){ fprintf(np, " Dear %s\r\r", nodes.Sysop); fprintf(np, "Here is the result of your AreaMgr request:\r\r"); } fseek(tmp, 0, SEEK_SET); while ((fgets(Buf, 2048, tmp)) != NULL) { while ((Buf[strlen(Buf) - 1]=='\n') || (Buf[strlen(Buf) - 1]=='\r')) { Buf[strlen(Buf) - 1] = '\0'; } fprintf(np, "%s\r", Buf); Syslog('m', "Rep: %s", Buf); } MacroVars("RABCDE", "ssssss","GOODBYE","","","","",""); if (!MsgResult("areamgr.responses",np)) fprintf(np, "\rWith regards, %s\r\r", CFG.sysop_name); fprintf(np, "%s\r", TearLine()); CloseMail(np, t); } else WriteError("Can't create netmail"); free(subject); } MacroClear(); free(Buf); fclose(tmp); if (a_stat) A_Status(f, replyid); if (a_query) A_Query(f, replyid); if (a_list) A_List(f, replyid, FALSE); if (a_flow) A_Flow(f, replyid, FALSE); if (a_unlnk) A_Unlinked(f, replyid); if (a_help) A_Help(f, replyid); return rc; }