This repository has been archived on 2024-04-08. You can view files and clone it, but cannot push or open issues or pull requests.
deb-mbse/mbfido/areamgr.c
2002-03-31 13:09:23 +00:00

1288 lines
39 KiB
C

/*****************************************************************************
*
* $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 *subject;
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 ){
MacroRead(fi, fp);
MacroClear();
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, "+<areaname> To connect to an echomail area\r");
fprintf(fp, "-<areaname> 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, "%%+<group> To connect all echomail areas of a group\r");
fprintf(fp, "%%-<group> 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 <n> To set max. number of messages to be rescanned\r");
fprintf(fp, "%%RESCAN <area> 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, *subject;
int i, First = TRUE, SubTot, Total = 0, Cons;
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);
if (fi != NULL){
MacroRead(fi, qp);
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(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(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);
MacroRead(fi, qp);
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);
MacroRead(fi, qp);
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);
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);
}
MacroRead(fi, qp);
}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 );
MacroRead(fi, qp);
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);
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, *subject;
int i, First = TRUE, Cons;
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));
sprintf(temp, "%s/etc/mareas.data", getenv("MBSE_ROOT"));
if ((mp = fopen(temp, "r")) == NULL) {
WriteError("$Can't open %s", temp);
free(temp);
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(subject);
fclose(mp);
return;
}
fread(&mgrouphdr, sizeof(mgrouphdr), 1, gp);
free(temp);
if (fi != NULL){
MacroRead(fi, qp);
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);
MacroRead(fi, qp);
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);
MacroRead(fi, qp);
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);
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);
}
MacroRead(fi, qp);
}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){
MacroRead(fi, qp);
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);
} 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;
char *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 ){
MacroRead(fi, fp);
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;
}