328 lines
8.4 KiB
C
328 lines
8.4 KiB
C
/* $Id: capifaxrcvd.c,v 1.2 1998/10/23 12:50:48 fritz Exp $
|
|
*
|
|
* A FAX receive daemon for CAPI.
|
|
* This stuff is based heavily on AVM's CAPI-adk for linux.
|
|
*
|
|
* This program 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.
|
|
* * This program 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 this program; if not, write to the Free Software
|
|
* Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
|
|
*
|
|
* $Log: capifaxrcvd.c,v $
|
|
* Revision 1.2 1998/10/23 12:50:48 fritz
|
|
* Added RCS keywords and GPL notice.
|
|
*
|
|
*/
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
#include <signal.h>
|
|
#include <assert.h>
|
|
#include <errno.h>
|
|
#include <unistd.h>
|
|
#include <syslog.h>
|
|
#include <sys/types.h>
|
|
#include <sys/stat.h>
|
|
#include <linux/capi.h>
|
|
#include <capi20.h>
|
|
|
|
#include "c20msg.h"
|
|
#include "capi.h"
|
|
#include "connect.h"
|
|
#include "contr.h"
|
|
#include "data.h"
|
|
#include "id.h"
|
|
#include "init.h"
|
|
#include "fax.h"
|
|
|
|
extern char *stationID;
|
|
extern char *headLine;
|
|
|
|
static char *CalledPartyNumber = NULL;
|
|
static char *RcvDir = NULL;
|
|
static char *notifyCmd = NULL;
|
|
static char RcvName[1024];
|
|
|
|
static ConnectionID Slot;
|
|
|
|
#define B1PROTOCOL 4
|
|
#define B2PROTOCOL 4
|
|
#define B3PROTOCOL 4
|
|
|
|
#define QueueSize 8
|
|
|
|
typedef struct __DataElement {
|
|
char DATA[SendBlockSize];
|
|
unsigned short DATA_LENGTH;
|
|
unsigned SENT;
|
|
} _DataElement;
|
|
|
|
typedef struct __DataQueue {
|
|
_DataElement Element[QueueSize];
|
|
unsigned Head;
|
|
unsigned Tail;
|
|
unsigned Fill;
|
|
} _DataQueue;
|
|
|
|
_DataQueue Queue;
|
|
|
|
static unsigned FileReceive = FALSE; /* signals if transfer is in progress */
|
|
static FILE *f;
|
|
static int reason;
|
|
static int reason_b3;
|
|
static int rres;
|
|
static int rpages;
|
|
static char rid[50];
|
|
|
|
/*
|
|
* MainDataAvailable: signals received data blocks
|
|
* This function is called after a DATA_B3_INDication is received. The flag
|
|
* DiscardData tells CAPI to free the memora area directly after the return
|
|
* of this function when set to TRUE (1) which is the preset. When the flag
|
|
* is set to FALSE (0) the data area MUST be freed later with ReleaseData.
|
|
* The datahandle identifies the memory area. When reaching 7 unconfirmed
|
|
* blocks, no more incoming data will be signaled until freeing at least
|
|
* one block.
|
|
*/
|
|
static void MainDataAvailable(ConnectionID Connection, void *Data, unsigned short DataLength,
|
|
unsigned short DataHandle, int *DiscardData) {
|
|
assert (Connection != INVALID_CONNECTION_ID);
|
|
if ((FileReceive) && (f != NULL))
|
|
fwrite(Data, 1, DataLength, f);
|
|
*DiscardData = TRUE;
|
|
}
|
|
|
|
/*
|
|
* MainStateChange: signals a state change on both B-channels (connected,
|
|
* disconnected). Whenever a channel changes his state this function is called
|
|
*/
|
|
static void MainStateChange(ConnectionID Connection, ConnectionState State) {
|
|
faxNCPI_t *faxNCPI;
|
|
|
|
assert (Connection != INVALID_CONNECTION_ID);
|
|
if (State == Disconnected) {
|
|
unsigned short r3 = GetB3Reason(Connection);
|
|
unsigned short r = GetReason(Connection);
|
|
|
|
Slot = INVALID_CONNECTION_ID;
|
|
reason = r;
|
|
reason_b3 = r3;
|
|
#if 0
|
|
printf("Disconnected.\n");
|
|
printf(" Reason : %04x %s\n", r, Decode_Info(r));
|
|
printf(" Reason-B3 : %04x %s\n", r3, Decode_Info(r3));
|
|
#endif
|
|
if ((faxNCPI = GetFaxNCPI(Connection))) {
|
|
strcpy(rid, faxNCPI->id);
|
|
rres = faxNCPI->resolution;
|
|
rpages = faxNCPI->pages;
|
|
|
|
#if 0
|
|
printf(" Remote Station ID : %s\n", faxNCPI->id);
|
|
printf(" Transfer-Rate : %d bps\n", faxNCPI->rate);
|
|
printf(" Resolution : %s\n", faxNCPI->resolution ? "high" : "low");
|
|
printf(" Number of Pages : %d\n", faxNCPI->pages);
|
|
#endif
|
|
}
|
|
}
|
|
}
|
|
|
|
/*
|
|
* MainIncomingCall: signals an incoming call
|
|
* This function will be executed if a CONNECT_INDication appears to
|
|
* inform the user.
|
|
*/
|
|
static void MainIncomingCall(ConnectionID Connection, char *CallingPartyNumber) {
|
|
B3_PROTO_FAXG3 B3conf;
|
|
|
|
assert (Connection != INVALID_CONNECTION_ID);
|
|
syslog(LOG_INFO, "Incoming Call from %s\n", CallingPartyNumber);
|
|
SetupB3Config(&B3conf, FAX_SFF_FORMAT);
|
|
if (CalledPartyNumber && strlen(CalledPartyNumber)) {
|
|
syslog(LOG_INFO, "Called #: %s\n", GetCalledPartyNumber(Connection));
|
|
if (strcmp(GetCalledPartyNumber(Connection), CalledPartyNumber)) {
|
|
AnswerCall(Connection, IGNORE, 4, 4, 4, (_cstruct)&B3conf);
|
|
syslog(LOG_INFO, "Call from %s ignored\n", CallingPartyNumber);
|
|
return;
|
|
}
|
|
}
|
|
if (Slot == INVALID_CONNECTION_ID) {
|
|
Slot = Connection;
|
|
sprintf(RcvName, "rc-%s-%08lx", CallingPartyNumber, time(NULL));
|
|
f = fopen(RcvName, "wb");
|
|
if (f != NULL) {
|
|
FileReceive = TRUE;
|
|
syslog(LOG_INFO, "Call from %s accepted\n", CallingPartyNumber);
|
|
AnswerCall(Connection, ACCEPT, 4, 4, 4, (_cstruct)&B3conf);
|
|
chmod(RcvName, 0600);
|
|
return;
|
|
}
|
|
}
|
|
AnswerCall(Connection, REJECT, 4, 4, 4, (_cstruct)&B3conf);
|
|
syslog(LOG_INFO, "Call from %s rejected\n", CallingPartyNumber);
|
|
}
|
|
|
|
void InitQueue(void) {
|
|
unsigned x;
|
|
|
|
for (x=0; x<QueueSize; x++)
|
|
Queue.Element[x].SENT = FALSE;
|
|
Queue.Head = 0;
|
|
Queue.Tail = 0;
|
|
Queue.Fill = 0;
|
|
}
|
|
|
|
unsigned ReceiveFax() {
|
|
int gotdata;
|
|
int ret = 0;
|
|
|
|
reason = reason_b3 = rpages = rres = 0;
|
|
rid[0] = '\0';
|
|
syslog(LOG_INFO, "Start listening\n");
|
|
InitQueue();
|
|
Listen(0x1FFF03FF);
|
|
while (Slot == INVALID_CONNECTION_ID)
|
|
Handle_CAPI_Msg();
|
|
while (Slot != INVALID_CONNECTION_ID)
|
|
Handle_CAPI_Msg();
|
|
FileReceive = FALSE;
|
|
gotdata = (ftell(f) != 0L);
|
|
fclose(f);
|
|
switch (reason) {
|
|
case 0:
|
|
case 0x3490: /* Normal call clearing */
|
|
case 0x349f: /* Normal, unspecified */
|
|
ret = reason_b3;
|
|
break;
|
|
default:
|
|
ret = reason;
|
|
}
|
|
if (gotdata && (!ret) && rpages) {
|
|
/* Rename fax to reflect resolution, pages and remote-id */
|
|
int i;
|
|
int l;
|
|
char newname[1024];
|
|
|
|
sprintf(newname, "f%c%03d%08lx", (rres)?'f':'n', rpages,
|
|
time(NULL));
|
|
l = strlen(newname);
|
|
for (i=0; rid[i]; i++) {
|
|
switch(rid[i]) {
|
|
case ' ':
|
|
newname[l++] = '_';
|
|
break;
|
|
case '/':
|
|
case '\\':
|
|
case '&':
|
|
case ';':
|
|
case '(':
|
|
case ')':
|
|
case '>':
|
|
case '<':
|
|
case '|':
|
|
case '?':
|
|
case '*':
|
|
case '\'':
|
|
case '"':
|
|
case '`':
|
|
if (newname[l-1] != '-' )
|
|
newname[l++] = '-';
|
|
break;
|
|
default:
|
|
newname[l++] = rid[i];
|
|
}
|
|
}
|
|
newname[l] = '\0';
|
|
rename(RcvName, newname);
|
|
chmod(newname, 0640);
|
|
syslog(LOG_INFO, "Received a FAX\n");
|
|
if (notifyCmd) {
|
|
sprintf(RcvName, "%s %s", notifyCmd, newname);
|
|
system(RcvName);
|
|
}
|
|
} else
|
|
remove(RcvName);
|
|
return ret;
|
|
}
|
|
|
|
void usage(void) {
|
|
fprintf(stderr, "usage: capifaxrcvd [-i stationID] [-h header] [-l listenNumber] [-n notifyCmd] rcvDirectory\n");
|
|
exit(1);
|
|
}
|
|
|
|
int main(int argc, char **argv) {
|
|
int numController;
|
|
int BChannels, Contr;
|
|
int c;
|
|
|
|
while ((c = getopt(argc, argv, "l:i:h:n:")) != EOF) {
|
|
switch (c) {
|
|
case 'l':
|
|
CalledPartyNumber = strdup(optarg);
|
|
break;
|
|
case 'i':
|
|
stationID = strdup(optarg);
|
|
break;
|
|
case 'h':
|
|
headLine = strdup(optarg);
|
|
break;
|
|
case 'n':
|
|
notifyCmd = strdup(optarg);
|
|
break;
|
|
case '?':
|
|
usage();
|
|
}
|
|
}
|
|
if (argc < optind + 1)
|
|
usage();
|
|
RcvDir = argv[optind];
|
|
if (chdir(RcvDir) != 0) {
|
|
perror(RcvDir);
|
|
return -1;
|
|
}
|
|
Slot = INVALID_CONNECTION_ID;
|
|
MainStateChange_p = MainStateChange;
|
|
MainDataAvailable_p = MainDataAvailable;
|
|
MainIncomingCall_p = MainIncomingCall;
|
|
if (!RegisterCAPI())
|
|
return -1;
|
|
atexit (ReleaseCAPI);
|
|
InitConnectionIDHandling();
|
|
if (!(numController = GetNumController())) {
|
|
fprintf(stderr, "No CAPI controllers available\n");
|
|
return -2;
|
|
}
|
|
BChannels = 0;
|
|
for (Contr=1; Contr<=numController; Contr++)
|
|
BChannels += GetNumOfSupportedBChannels(Contr);
|
|
if (!BChannels) {
|
|
fprintf(stderr, "No B-Channels available\n");
|
|
return -3;
|
|
}
|
|
switch (fork()) {
|
|
case 0:
|
|
openlog("capifaxrcvd", LOG_PID, LOG_DAEMON);
|
|
close(0);
|
|
close(1);
|
|
close(2);
|
|
while (1)
|
|
ReceiveFax();
|
|
if ((Slot != INVALID_CONNECTION_ID) &&
|
|
(GetState(Slot) != Disconnected) &&
|
|
(GetState(Slot) != D_DisconnectPending))
|
|
Disconnect(Slot);
|
|
break;
|
|
case -1:
|
|
perror("fork");
|
|
exit(errno);
|
|
break;
|
|
}
|
|
return 0;
|
|
}
|