487 lines
10 KiB
C
487 lines
10 KiB
C
|
/*****************************************************************************
|
||
|
|
*
|
||
|
|
* File ..................: mbcico/ftsc.c
|
||
|
|
* Purpose ...............: Fidonet mailer
|
||
|
|
* Last modification date : 08-Jun-2001
|
||
|
|
*
|
||
|
|
*****************************************************************************
|
||
|
|
* Copyright (C) 1997-2001
|
||
|
|
*
|
||
|
|
* 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/records.h"
|
||
|
|
#include "../lib/common.h"
|
||
|
|
#include "../lib/clcomm.h"
|
||
|
|
#include "session.h"
|
||
|
|
#include "ttyio.h"
|
||
|
|
#include "statetbl.h"
|
||
|
|
#include "config.h"
|
||
|
|
#include "ftsc.h"
|
||
|
|
#include "rdoptions.h"
|
||
|
|
#include "recvbark.h"
|
||
|
|
#include "filelist.h"
|
||
|
|
#include "sendbark.h"
|
||
|
|
#include "respfreq.h"
|
||
|
|
#include "xmrecv.h"
|
||
|
|
#include "xmsend.h"
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
extern int master;
|
||
|
|
extern int made_request;
|
||
|
|
static int rxftsc(void);
|
||
|
|
static int txftsc(void);
|
||
|
|
static int recvfiles(void);
|
||
|
|
static file_list *tosend;
|
||
|
|
extern int Loaded;
|
||
|
|
|
||
|
|
|
||
|
|
int rx_ftsc(void)
|
||
|
|
{
|
||
|
|
int rc;
|
||
|
|
|
||
|
|
Syslog('+', "Start inbound FTS-0001 session");
|
||
|
|
IsDoing("FTS-0001 inbound");
|
||
|
|
|
||
|
|
session_flags |= SESSION_BARK;
|
||
|
|
if ((rc = rxftsc())) {
|
||
|
|
WriteError("Session failed: rc=%d",rc);
|
||
|
|
PUTCHAR(CAN);
|
||
|
|
PUTCHAR(CAN);
|
||
|
|
PUTCHAR(CAN);
|
||
|
|
} else
|
||
|
|
Syslog('+', "FTS-0001 session completed");
|
||
|
|
|
||
|
|
tidy_filelist(tosend, (rc == 0));
|
||
|
|
tosend = NULL;
|
||
|
|
return rc;
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
int tx_ftsc(void)
|
||
|
|
{
|
||
|
|
int rc;
|
||
|
|
|
||
|
|
Syslog('+', "Start outbound FTS-0001 session with %s", ascfnode(remote->addr,0x1f));
|
||
|
|
IsDoing("FTS-0001 to %s", ascfnode(remote->addr, 0x0f));
|
||
|
|
|
||
|
|
if ((rc = txftsc())) {
|
||
|
|
WriteError("Session failed: rc=%d",rc);
|
||
|
|
PUTCHAR(CAN);
|
||
|
|
PUTCHAR(CAN);
|
||
|
|
PUTCHAR(CAN);
|
||
|
|
} else
|
||
|
|
Syslog('+', "FTS-0001 session completed");
|
||
|
|
|
||
|
|
tidy_filelist(tosend, (rc == 0));
|
||
|
|
tosend = NULL;
|
||
|
|
return rc;
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
SM_DECL(txftsc,(char *)"txftsc")
|
||
|
|
SM_STATES
|
||
|
|
wait_command,
|
||
|
|
recv_mail,
|
||
|
|
send_req,
|
||
|
|
recv_req
|
||
|
|
SM_NAMES
|
||
|
|
(char *)"wait_command",
|
||
|
|
(char *)"recv_mail",
|
||
|
|
(char *)"send_req",
|
||
|
|
(char *)"recv_req"
|
||
|
|
SM_EDECL
|
||
|
|
int c,rc;
|
||
|
|
char *nonhold_mail;
|
||
|
|
int mailsent = FALSE, mailrcvd = FALSE;
|
||
|
|
|
||
|
|
if (localoptions & NOHOLD)
|
||
|
|
nonhold_mail = (char *)ALL_MAIL;
|
||
|
|
else
|
||
|
|
nonhold_mail = (char *)NONHOLD_MAIL;
|
||
|
|
tosend = create_filelist(remote,nonhold_mail,2);
|
||
|
|
|
||
|
|
Syslog('s', "txftsc SEND_MAIL");
|
||
|
|
if ((rc = xmsndfiles(tosend)))
|
||
|
|
return rc;
|
||
|
|
mailsent = TRUE;
|
||
|
|
|
||
|
|
SM_START(wait_command)
|
||
|
|
|
||
|
|
SM_STATE(wait_command)
|
||
|
|
|
||
|
|
Syslog('s', "txftsc WAIT_COMMAND");
|
||
|
|
c = GETCHAR(30);
|
||
|
|
if (c == TIMEOUT) {
|
||
|
|
Syslog('+', "timeout waiting for remote action, try receive");
|
||
|
|
SM_PROCEED(recv_mail);
|
||
|
|
} else if (c < 0) {
|
||
|
|
if (mailrcvd && mailsent) {
|
||
|
|
/*
|
||
|
|
* Some systems hangup after sending mail, so if we did
|
||
|
|
* send and receive mail we consider the session OK.
|
||
|
|
*/
|
||
|
|
Syslog('+', "Lost carrier, FTSC session looks complete");
|
||
|
|
SM_SUCCESS;
|
||
|
|
} else {
|
||
|
|
Syslog('+', "got error waiting for TSYNC: received %d",c);
|
||
|
|
SM_ERROR;
|
||
|
|
}
|
||
|
|
} else switch (c) {
|
||
|
|
case TSYNC: SM_PROCEED(recv_mail);
|
||
|
|
break;
|
||
|
|
case SYN: SM_PROCEED(recv_req);
|
||
|
|
break;
|
||
|
|
case ENQ: SM_PROCEED(send_req);
|
||
|
|
break;
|
||
|
|
case 'C':
|
||
|
|
case NAK: PUTCHAR(EOT);
|
||
|
|
SM_PROCEED(wait_command);
|
||
|
|
break;
|
||
|
|
case CAN: SM_SUCCESS; /* this is not in BT */
|
||
|
|
break;
|
||
|
|
default: Syslog('s', "got '%s' waiting command", printablec(c));
|
||
|
|
PUTCHAR(SUB);
|
||
|
|
SM_PROCEED(wait_command);
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
|
||
|
|
SM_STATE(recv_mail)
|
||
|
|
|
||
|
|
Syslog('s', "txftsc RECV_MAIL");
|
||
|
|
if (recvfiles()) {
|
||
|
|
SM_ERROR;
|
||
|
|
} else {
|
||
|
|
mailrcvd = TRUE;
|
||
|
|
SM_PROCEED(wait_command);
|
||
|
|
}
|
||
|
|
|
||
|
|
SM_STATE(send_req)
|
||
|
|
|
||
|
|
Syslog('s', "txftsc SEND_BARK");
|
||
|
|
if (sendbark()) {
|
||
|
|
SM_ERROR;
|
||
|
|
} else {
|
||
|
|
SM_SUCCESS;
|
||
|
|
}
|
||
|
|
|
||
|
|
SM_STATE(recv_req)
|
||
|
|
|
||
|
|
Syslog('s', "txftsc RECV_BARK");
|
||
|
|
if (recvbark()) {
|
||
|
|
SM_ERROR;
|
||
|
|
} else {
|
||
|
|
SM_PROCEED(wait_command);
|
||
|
|
}
|
||
|
|
|
||
|
|
SM_END
|
||
|
|
SM_RETURN
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
SM_DECL(rxftsc,(char *)"rxftsc")
|
||
|
|
SM_STATES
|
||
|
|
recv_mail,
|
||
|
|
send_mail,
|
||
|
|
send_req,
|
||
|
|
recv_req
|
||
|
|
SM_NAMES
|
||
|
|
(char *)"recv_mail",
|
||
|
|
(char *)"send_mail",
|
||
|
|
(char *)"send_req",
|
||
|
|
(char *)"recv_req"
|
||
|
|
SM_EDECL
|
||
|
|
int c, count = 0, didwazoo = FALSE;
|
||
|
|
int sentmail = FALSE, rcvdmail = FALSE;
|
||
|
|
file_list *request = NULL, *tmpfl;
|
||
|
|
|
||
|
|
SM_START(recv_mail)
|
||
|
|
|
||
|
|
SM_STATE(recv_mail)
|
||
|
|
|
||
|
|
Syslog('s', "rxftsc RECV_MAIL");
|
||
|
|
if (recvfiles()) {
|
||
|
|
SM_ERROR;
|
||
|
|
} else {
|
||
|
|
rcvdmail = TRUE;
|
||
|
|
SM_PROCEED(send_mail);
|
||
|
|
}
|
||
|
|
|
||
|
|
SM_STATE(send_mail)
|
||
|
|
|
||
|
|
Syslog('s', "rxftsc SEND_MAIL count=%d", count);
|
||
|
|
if (count++ > 45) {
|
||
|
|
SM_ERROR;
|
||
|
|
}
|
||
|
|
|
||
|
|
/*
|
||
|
|
* If we got a wazoo request, add files now.
|
||
|
|
*/
|
||
|
|
request = respond_wazoo();
|
||
|
|
if (request != NULL) {
|
||
|
|
didwazoo = TRUE;
|
||
|
|
tmpfl = tosend;
|
||
|
|
tosend = request;
|
||
|
|
for (; request->next; request = request->next);
|
||
|
|
request->next = tmpfl;
|
||
|
|
|
||
|
|
request = NULL;
|
||
|
|
}
|
||
|
|
|
||
|
|
if (tosend == NULL) {
|
||
|
|
count = 0;
|
||
|
|
SM_PROCEED(send_req);
|
||
|
|
}
|
||
|
|
|
||
|
|
PUTCHAR(TSYNC);
|
||
|
|
c = GETCHAR(1);
|
||
|
|
Syslog('x', "Got char 0x%02x", c);
|
||
|
|
if (c == TIMEOUT) {
|
||
|
|
Syslog('x', " timeout");
|
||
|
|
SM_PROCEED(send_mail);
|
||
|
|
} else if (c < 0) {
|
||
|
|
Syslog('+', "got error waiting for NAK: received %d",c);
|
||
|
|
SM_ERROR;
|
||
|
|
} else switch (c) {
|
||
|
|
case 'C':
|
||
|
|
case NAK: if (xmsndfiles(tosend)) {
|
||
|
|
SM_ERROR;
|
||
|
|
} else {
|
||
|
|
sentmail = TRUE;
|
||
|
|
count = 0;
|
||
|
|
SM_PROCEED(send_req);
|
||
|
|
}
|
||
|
|
break;
|
||
|
|
case CAN: Syslog('+', "Remote refused to pickup mail");
|
||
|
|
SM_SUCCESS;
|
||
|
|
break;
|
||
|
|
case EOT: PUTCHAR(ACK);
|
||
|
|
SM_PROCEED(send_mail);
|
||
|
|
break;
|
||
|
|
default: Syslog('s', "Got '%s' waiting NAK", printablec(c));
|
||
|
|
SM_PROCEED(send_mail);
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
|
||
|
|
SM_STATE(send_req)
|
||
|
|
|
||
|
|
Syslog('s', "rxftsc SEND_REQ count=%d", count);
|
||
|
|
|
||
|
|
if (didwazoo) {
|
||
|
|
SM_SUCCESS;
|
||
|
|
}
|
||
|
|
|
||
|
|
if (count > 15) {
|
||
|
|
SM_ERROR;
|
||
|
|
}
|
||
|
|
|
||
|
|
if (!made_request) {
|
||
|
|
SM_PROCEED(recv_req);
|
||
|
|
}
|
||
|
|
|
||
|
|
PUTCHAR(SYN);
|
||
|
|
c = GETCHAR(5);
|
||
|
|
Syslog('x', "Got char 0x%02x", c);
|
||
|
|
count++;
|
||
|
|
if (c == TIMEOUT) {
|
||
|
|
Syslog('x', " timeout");
|
||
|
|
SM_PROCEED(send_req);
|
||
|
|
} else if (c < 0) {
|
||
|
|
Syslog('+', "got error waiting for ENQ: received %d",c);
|
||
|
|
SM_ERROR;
|
||
|
|
} else switch (c) {
|
||
|
|
case ENQ: if (sendbark()) {
|
||
|
|
SM_ERROR;
|
||
|
|
} else {
|
||
|
|
SM_PROCEED(recv_req);
|
||
|
|
}
|
||
|
|
break;
|
||
|
|
case CAN: Syslog('+', "Remote refused to accept request");
|
||
|
|
SM_PROCEED(recv_req);
|
||
|
|
break;
|
||
|
|
case 'C':
|
||
|
|
case NAK: PUTCHAR(EOT);
|
||
|
|
SM_PROCEED(send_req);
|
||
|
|
break;
|
||
|
|
case SUB: SM_PROCEED(send_req);
|
||
|
|
break;
|
||
|
|
default: Syslog('s', "got '%s' waiting ENQ", printablec(c));
|
||
|
|
SM_PROCEED(send_req);
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
|
||
|
|
SM_STATE(recv_req)
|
||
|
|
|
||
|
|
Syslog('s', "rxftsc RECV_REQ");
|
||
|
|
if (recvbark()) {
|
||
|
|
if (sentmail && rcvdmail) {
|
||
|
|
Syslog('+', "Consider session OK");
|
||
|
|
SM_SUCCESS;
|
||
|
|
} else {
|
||
|
|
SM_ERROR;
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
SM_SUCCESS;
|
||
|
|
}
|
||
|
|
|
||
|
|
SM_END
|
||
|
|
SM_RETURN
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
SM_DECL(recvfiles,(char *)"recvfiles")
|
||
|
|
SM_STATES
|
||
|
|
recv_packet,
|
||
|
|
scan_packet,
|
||
|
|
recv_file
|
||
|
|
SM_NAMES
|
||
|
|
(char *)"recv_packet",
|
||
|
|
(char *)"scan_packet",
|
||
|
|
(char *)"recv_file"
|
||
|
|
SM_EDECL
|
||
|
|
int rc=0;
|
||
|
|
char recvpktname[16];
|
||
|
|
char *fpath;
|
||
|
|
FILE *fp;
|
||
|
|
faddr f,t;
|
||
|
|
fa_list **tmpl;
|
||
|
|
|
||
|
|
SM_START(recv_packet)
|
||
|
|
Loaded = FALSE;
|
||
|
|
|
||
|
|
SM_STATE(recv_packet)
|
||
|
|
|
||
|
|
sprintf(recvpktname,"%08lx.pkt",(unsigned long)sequencer());
|
||
|
|
if ((rc = xmrecv(recvpktname)) == 1) {
|
||
|
|
SM_SUCCESS;
|
||
|
|
} else if (rc == 0) {
|
||
|
|
if (master) {
|
||
|
|
SM_PROCEED(recv_file);
|
||
|
|
} else {
|
||
|
|
SM_PROCEED(scan_packet);
|
||
|
|
}
|
||
|
|
} else {
|
||
|
|
SM_ERROR;
|
||
|
|
}
|
||
|
|
|
||
|
|
SM_STATE(scan_packet)
|
||
|
|
|
||
|
|
fpath = xstrcpy(inbound);
|
||
|
|
fpath = xstrcat(fpath,(char *)"/");
|
||
|
|
fpath = xstrcat(fpath,recvpktname);
|
||
|
|
fp = fopen(fpath,"r");
|
||
|
|
free(fpath);
|
||
|
|
if (fp == NULL) {
|
||
|
|
WriteError("$cannot open received packet");
|
||
|
|
SM_ERROR;
|
||
|
|
}
|
||
|
|
switch (getheader(&f , &t, fp, recvpktname)) {
|
||
|
|
case 3: Syslog('+', "remote mistook us for %s",ascfnode(&t,0x1f));
|
||
|
|
fclose(fp);
|
||
|
|
SM_ERROR;
|
||
|
|
case 0: Syslog('+', "accepting session");
|
||
|
|
fclose(fp);
|
||
|
|
for (tmpl=&remote;*tmpl;tmpl=&((*tmpl)->next));
|
||
|
|
(*tmpl)=(fa_list*)malloc(sizeof(fa_list));
|
||
|
|
(*tmpl)->next=NULL;
|
||
|
|
(*tmpl)->addr=(faddr*)malloc(sizeof(faddr));
|
||
|
|
(*tmpl)->addr->zone=f.zone;
|
||
|
|
(*tmpl)->addr->net=f.net;
|
||
|
|
(*tmpl)->addr->node=f.node;
|
||
|
|
(*tmpl)->addr->point=f.point;
|
||
|
|
(*tmpl)->addr->name=NULL;
|
||
|
|
(*tmpl)->addr->domain=NULL;
|
||
|
|
for (tmpl=&remote;*tmpl;tmpl=&((*tmpl)->next)) {
|
||
|
|
(void)nodelock((*tmpl)->addr);
|
||
|
|
/* try lock all remotes, ignore locking result */
|
||
|
|
if (!Loaded)
|
||
|
|
if (noderecord((*tmpl)->addr))
|
||
|
|
Loaded = TRUE;
|
||
|
|
}
|
||
|
|
|
||
|
|
history.aka.zone = remote->addr->zone;
|
||
|
|
history.aka.net = remote->addr->net;
|
||
|
|
history.aka.node = remote->addr->node;
|
||
|
|
history.aka.point = remote->addr->point;
|
||
|
|
if (remote->addr->domain && strlen(remote->addr->domain))
|
||
|
|
sprintf(history.aka.domain, "%s", remote->addr->domain);
|
||
|
|
|
||
|
|
if (((nlent=getnlent(remote->addr))) && (nlent->pflag != NL_DUMMY)) {
|
||
|
|
Syslog('+', "remote is a listed system");
|
||
|
|
if (inbound)
|
||
|
|
free(inbound);
|
||
|
|
inbound = xstrcpy(CFG.inbound);
|
||
|
|
sprintf(history.system_name, "%s", nlent->name);
|
||
|
|
sprintf(history.location, "%s", nlent->location);
|
||
|
|
} else {
|
||
|
|
sprintf(history.system_name, "Unknown");
|
||
|
|
sprintf(history.location, "Somewhere");
|
||
|
|
}
|
||
|
|
|
||
|
|
if (nlent)
|
||
|
|
rdoptions(Loaded);
|
||
|
|
|
||
|
|
/*
|
||
|
|
* It appears that if the remote gave no password, the
|
||
|
|
* getheader function fills in a password itself. Maybe
|
||
|
|
* that's the reason why E.C did not switch to protected
|
||
|
|
* inbound, because of the failing password check. MB.
|
||
|
|
*/
|
||
|
|
if (f.name) {
|
||
|
|
Syslog('+', "Password correct, protected FTS-0001 session");
|
||
|
|
if (inbound)
|
||
|
|
free(inbound);
|
||
|
|
inbound = xstrcpy(CFG.pinbound);
|
||
|
|
}
|
||
|
|
|
||
|
|
tosend = create_filelist(remote,(char *)ALL_MAIL,1);
|
||
|
|
if (rc == 0) {
|
||
|
|
SM_PROCEED(recv_file);
|
||
|
|
} else {
|
||
|
|
SM_SUCCESS;
|
||
|
|
}
|
||
|
|
default: Syslog('+', "received bad packet apparently from",ascfnode(&f,0x1f));
|
||
|
|
fclose(fp);
|
||
|
|
SM_ERROR;
|
||
|
|
}
|
||
|
|
|
||
|
|
SM_STATE(recv_file)
|
||
|
|
|
||
|
|
switch (xmrecv(NULL)) {
|
||
|
|
case 0: SM_PROCEED(recv_file);
|
||
|
|
break;
|
||
|
|
case 1: SM_SUCCESS;
|
||
|
|
break;
|
||
|
|
default: SM_ERROR;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
|
||
|
|
SM_END
|
||
|
|
SM_RETURN
|
||
|
|
|