diff options
Diffstat (limited to 'util')
-rw-r--r-- | util/in2outmail | bin | 39392 -> 0 bytes | |||
-rw-r--r-- | util/in2outmail.c | 288 |
2 files changed, 0 insertions, 288 deletions
diff --git a/util/in2outmail b/util/in2outmail Binary files differdeleted file mode 100644 index 686944c1..00000000 --- a/util/in2outmail +++ /dev/null diff --git a/util/in2outmail.c b/util/in2outmail.c deleted file mode 100644 index fce9cc59..00000000 --- a/util/in2outmail.c +++ /dev/null @@ -1,288 +0,0 @@ -/* $Id: in2outmail.c,v 1.1 2002/03/07 15:13:46 in2 Exp $ */ -#include <stdio.h> -#include <stdlib.h> -#include <string.h> -#include <unistd.h> -#include <fcntl.h> -#include <signal.h> -#include <sys/types.h> -#include <sys/socket.h> -#include <sys/types.h> -#include <sys/param.h> -#include <sys/file.h> -#include <netinet/in.h> -#include <arpa/inet.h> -#include "config.h" -#include "pttstruct.h" - - -#ifdef HAVE_SETPROCTITLE - -#include <sys/types.h> -#include <libutil.h> - -void initsetproctitle(int argc, char **argv, char **envp) { -} - -#else - -#include <stdio.h> -#include <stdlib.h> -#include <string.h> -#include <stdarg.h> - -char **Argv = NULL; /* pointer to argument vector */ -char *LastArgv = NULL; /* end of argv */ -extern char **environ; - -void initsetproctitle(int argc, char **argv, char **envp) { - register int i; - - /* Move the environment so setproctitle can use the space at - the top of memory. */ - for(i = 0; envp[i]; i++); - environ = malloc(sizeof(char *) * (i + 1)); - for(i = 0; envp[i]; i++) - environ[i] = strdup(envp[i]); - environ[i] = NULL; - - /* Save start and extent of argv for setproctitle. */ - Argv = argv; - if(i > 0) - LastArgv = envp[i - 1] + strlen(envp[i - 1]); - else - LastArgv = argv[argc - 1] + strlen(argv[argc - 1]); -} - -static void do_setproctitle(const char *cmdline) { - char buf[256], *p; - int i; - - strncpy(buf, cmdline, 256); - buf[255] = '\0'; - i = strlen(buf); - if(i > LastArgv - Argv[0] - 2) { - i = LastArgv - Argv[0] - 2; - } - strcpy(Argv[0], buf); - p = &Argv[0][i]; - while(p < LastArgv) - *p++='\0'; - Argv[1] = NULL; -} - -void setproctitle(const char* format, ...) { - char buf[256]; - - va_list args; - va_start(args, format); - vsprintf(buf, format,args); - do_setproctitle(buf); - va_end(args); -} -#endif - - - - - -#define SPOOL BBSHOME "/out" -#define INDEX SPOOL "/.DIR" -#define NEWINDEX SPOOL "/.DIR.sending" -#define FROM ".bbs@" MYHOSTNAME -#define SMTPPORT 25 - -int waitReply(int sock) { - char buf[256]; - - if(read(sock, buf, sizeof(buf)) <= 0) - return -1; - else - return buf[0] - '0'; -} - -int sendRequest(int sock, char *request) { - return write(sock, request, strlen(request)) < 0 ? -1 : 0; -} - -int connectMailServer(char *host) { - int sock; - struct sockaddr_in addr; - - if((sock = socket(PF_INET, SOCK_STREAM, 0)) < 0) { - perror("socket"); - return -1; - } - - memset(&addr, 0, sizeof(addr)); -#ifdef FreeBSD - addr.sin_len = sizeof(addr); -#endif - addr.sin_family = AF_INET; - addr.sin_port = htons(SMTPPORT); - addr.sin_addr.s_addr = inet_addr(host); - - if(connect(sock, (struct sockaddr *)&addr, sizeof(addr)) < 0) { - perror(RELAY_SERVER_IP); - close(sock); - return -1; - } - - if(waitReply(sock) != 2) { - close(sock); - return -1; - } - - if(sendRequest(sock, "helo " MYHOSTNAME "\n") || waitReply(sock) != 2) { - close(sock); - return -1; - } else - return sock; -} - -void disconnectMailServer(int sock) { - sendRequest(sock, "quit\n"); - /* drop the reply :p */ - close(sock); -} - -void doSendBody(int sock, FILE *fp, char *from, char *to, char *subject) { - int n; - char buf[2048]; - - n = snprintf(buf, sizeof(buf), "From: %s\nTo: %s\nSubject: %s\n\n", - from, to, subject); - write(sock, buf, n); - - while(fgets(buf, sizeof(buf), fp)) { - if(buf[0] == '.' && buf[1] == '\n') - strcpy(buf, "..\n"); - write(sock, buf, strlen(buf)); - } -} - -void doSendMail(int sock, FILE *fp, char *from, char *to, char *subject) { - char buf[256]; - - snprintf(buf, sizeof(buf), "mail from: %s\n", from); - if(sendRequest(sock, buf) || waitReply(sock) != 2) - return; - - snprintf(buf, sizeof(buf), "rcpt to: %s\n", to); - if(sendRequest(sock, buf) || waitReply(sock) != 2) - return; - - if(sendRequest(sock, "data\n") || waitReply(sock) != 3) - return; - - doSendBody(sock, fp, from, to, subject); - - if(sendRequest(sock, "\n.\n") || waitReply(sock) != 2) - return; -} - -void sendMail() { - int fd, sockPTT2, sockHinet; - MailQueue mq; - - if(access(NEWINDEX, R_OK | W_OK)) { - if(link(INDEX, NEWINDEX) || unlink(INDEX)) - /* nothing to do */ - return; - } - - if( (sockPTT2 = connectMailServer("140.112.30.143")) < 0 ){ - fprintf(stderr, "connect server failed...\n"); - return; - } - sockHinet = connectMailServer("61.218.59.183"); - - fd = open(NEWINDEX, O_RDONLY); - flock(fd, LOCK_EX); - while(read(fd, &mq, sizeof(mq)) > 0) { - FILE *fp; - char buf[256]; - - snprintf(buf, sizeof(buf), "%s%s", mq.sender, FROM); - if((fp = fopen(mq.filepath, "r"))) { - setproctitle("outmail: sending %s", mq.filepath); - if( strstr(mq.rcpt, ".edu.tw") || - strstr(mq.rcpt, ".twbbs.org") || - strstr(mq.rcpt, "ptt.cc") || - strstr(mq.rcpt, "ptt2.cc") ){ - printf("relay server: ptt2, to %s\n", mq.rcpt); - doSendMail(sockPTT2, fp, buf, mq.rcpt, mq.subject); - } - else{ - printf("relay server: ezmain, to %s\n", mq.rcpt); - doSendMail( (sockHinet > 0) ? sockHinet : sockPTT2, - fp, buf, mq.rcpt, mq.subject); - } - fclose(fp); - unlink(mq.filepath); - } else { - perror(mq.filepath); - } - } - flock(fd, LOCK_UN); - close(fd); - unlink(NEWINDEX); - - if( sockHinet > 0 ) - disconnectMailServer(sockHinet); - disconnectMailServer(sockPTT2); -} - -void listQueue() { - int fd; - - if((fd = open(INDEX, O_RDONLY)) >= 0) { - int counter = 0; - MailQueue mq; - - flock(fd, LOCK_EX); - while(read(fd, &mq, sizeof(mq)) > 0) { - printf("%s:%s -> %s:%s\n", mq.filepath, mq.username, mq.rcpt, - mq.subject); - counter++; - } - flock(fd, LOCK_UN); - close(fd); - printf("\nTotal: %d mails in queue\n", counter); - } else { - perror(INDEX); - } -} - -void usage() { - fprintf(stderr, "usage: outmail [-qh]\n"); -} - -void wakeup(int s) { -} - -int main(int argc, char **argv, char **envp) { - int ch; - - signal(SIGHUP, wakeup); - initsetproctitle(argc, argv, envp); - - if(chdir(BBSHOME)) - return 1; - while((ch = getopt(argc, argv, "qh")) != -1) { - switch(ch) { - case 'q': - listQueue(); - return 0; - default: - usage(); - return 0; - } - } - for(;;) { - sendMail(); - setproctitle("outmail: sleeping"); - sleep(60 * 3); /* send mail every 3 minute */ - } - return 0; -} |