1
0
mirror of https://github.com/anope/anope.git synced 2026-07-04 12:43:11 +02:00

BUILD : 1.7.7 (550) BUGS : N/A NOTES : Anope SMTP client

git-svn-id: svn://svn.anope.org/anope/trunk@550 31f1291d-b8d6-0310-a050-a5561fc1590b


git-svn-id: http://anope.svn.sourceforge.net/svnroot/anope/trunk@403 5417fbe8-f217-4b02-8779-1006273d7864
This commit is contained in:
trystan trystan@31f1291d-b8d6-0310-a050-a5561fc1590b
2005-01-20 05:37:46 +00:00
parent 1ef4a60c46
commit 278a99ca2d
7 changed files with 713 additions and 4 deletions
+1
View File
@@ -1,6 +1,7 @@
Anope Version S V N
-------------------
Provided by Anope Dev. <dev@anope.org> - 2005
01/19 A Add simple smtp client, read the README in src/tools for info [ #00]
01/16 A Support for PTlinks VHOST (NEWMASK) command. [ #00]
01/16 A Ulines Servers are now except from NOJOIN bans [#281]
01/16 F Help messages restricted to the right access level. [#272]
+10 -3
View File
@@ -20,9 +20,9 @@ LDFLAGS=@LDFLAGS@
RUNGROUP=@RUNGROUP@
IRCDFILE=@IRCDFILE@
all: language headers build modules
strict: language headers strict_build strict_modules
profile: language headers profile_build profile_modules
all: language headers build tools modules
strict: language headers strict_build tools strict_modules
profile: language headers profile_build tools profile_modules
MAKEARGS = 'CFLAGS=${CFLAGS}' 'CC=${CC}' 'ANOPELIBS=${ANOPELIBS}' \
'LDFLAGS=${LDFLAGS}' 'BINDEST=${BINDEST}' 'INSTALL=${INSTALL}' \
@@ -53,6 +53,10 @@ modules: build
(cd src/modules ; ./configure ; ${MAKE} ${MAKEARGS} all; )
@echo "*** All done, now (g)make install to install Anope/Modules";
tools: build
(cd src/tools ; ${MAKE} ${MAKEARGS} all; )
@echo "*** All done, now (g)make install to install Anope/Modules/Tools";
strict_modules: strict_build
(cd src/modules ; ./configure ; ${MAKE} ${MAKEARGS} 'CFLAGS=$(CFLAGS) $(STRICT)' all; )
@echo "*** All done, now (g)make install to install Anope/Modules";
@@ -71,14 +75,17 @@ clean:
(cd lang ; ${MAKE} ${MAKEARGS} clean )
(cd include ; ${MAKE} ${MAKEARGS} clean )
(cd src ; ${MAKE} ${MAKEARGS} clean )
(cd src/tools ; ${MAKE} ${MAKEARGS} clean )
distclean: clean
(cd lang ; ${MAKE} ${MAKEARGS} distclean )
(cd include ; ${MAKE} ${MAKEARGS} distclean )
(cd src ; ${MAKE} ${MAKEARGS} distclean )
(cd src/tools ; ${MAKE} ${MAKEARGS} distclean )
rm -f config.log config.status config.cache Makefile
install: DUMMY
(cd src ; ${MAKE} ${MAKEARGS} install)
(cd src/tools ; ${MAKE} ${MAKEARGS} install)
DUMMY:
+34
View File
@@ -0,0 +1,34 @@
OBJS = anopesmpt.o
SRCS = anopesmpt.c
INCLUDES = ../../include/services.h
MAKEARGS = 'CFLAGS=${CFLAGS}' 'CC=${CC}' 'ANOPELIBS=${ANOPELIBS}' \
'LDFLAGS=${LDFLAGS}' 'BINDEST=${BINDEST}' 'INSTALL=${INSTALL}' \
'INCLUDEDIR=${INCLUDEDIR}' 'RM=${RM}' 'CP=${CP}' \
'TOUCH=${TOUCH}' 'SHELL=${SHELL}' 'DATDEST=${DATDEST}' \
'RUNGROUP=${RUNGROUP}'
.c.o:
$(CC) $(CFLAGS) -I../include/ -c $<
all: anopesmtp
distclean: clean spotless
anopesmpt: $(OBJS)
$(CC) $(CFLAGS) $(OBJS) $(ANOPELIBS) $(MLIBS) -o $@ $(LDFLAGS)
$(OBJS): Makefile
anopesmpt.o: anopesmpt.c $(INCLUDES)
clean:
rm -f *.o anopesmtp a.out
spotless: clean
install: anopesmtp
test -d ${BINDEST} || mkdir ${BINDEST}
$(INSTALL) anopesmtp $(BINDEST)/anopesmtp
DUMMY:
+19
View File
@@ -0,0 +1,19 @@
Anope SMTP Client
- Provided with Anope is a simple SMTP client which can be used to replace programs like
SendMail in some cases.
- To use the SMTP client find the line in your services.conf for the "SendMailPath", enter
the path to your services installation directory, followed by the "anopesmtp" and the IP address
of a valid SMTP server. It should look something like
SendMailPath "/home/usersname/services/anopesmtp 194.97.50.135"
- If you run into a problem you can compile a debug into the code by opening smtp.h and at the
bottom you should find "smtp_debug" change the 0 to a 1 and recompile the code. This should
generate a log file of what happened when it attempted to connect to the SMTP server.
Credits:
Orginally written by Dominick Meglio <codemastr@unrealircd.com>
Ported to *nix by Trystan Scott Lee <trystan@nomadirc.net>
+550
View File
@@ -0,0 +1,550 @@
/* smtp stuff handler for win32.
*
* (C) 2003 Anope Team
* Contact us at info@anope.org
*
* Please read COPYING and README for furhter details.
*
* Based on the original code of Epona by Lara.
* Based on the original code of Services by Andy Church.
*
* Written by Dominick Meglio <codemastr@unrealircd.com>
* *nix port by Trystan Scott Lee <trystan@nomadirc.net>
*
*/
#include "smtp.h"
static FILE *logfile;
static int curday = 0;
/*************************************************************************/
static int get_logname(char *name, int count, struct tm *tm)
{
char timestamp[32];
if (!tm) {
time_t t;
time(&t);
tm = localtime(&t);
}
strftime(timestamp, count, "%Y%m%d", tm);
snprintf(name, count, "logs/%s.%s", "anopesmtp", timestamp);
curday = tm->tm_yday;
return 1;
}
/*************************************************************************/
/* Close the log file. */
void close_log(void)
{
if (!logfile)
return;
fclose(logfile);
logfile = NULL;
}
/*************************************************************************/
static void remove_log(void)
{
time_t t;
struct tm tm;
char name[PATH_MAX];
time(&t);
t -= (60 * 60 * 24 * 30);
tm = *localtime(&t);
if (!get_logname(name, sizeof(name), &tm))
return;
unlink(name);
}
/*************************************************************************/
static void checkday(void)
{
time_t t;
struct tm tm;
time(&t);
tm = *localtime(&t);
if (curday != tm.tm_yday) {
close_log();
remove_log();
open_log();
}
}
/*************************************************************************/
/* Open the log file. Return -1 if the log file could not be opened, else
* return 0. */
int open_log(void)
{
char name[PATH_MAX];
if (logfile)
return 0;
if (!get_logname(name, sizeof(name), NULL))
return 0;
logfile = fopen(name, "a");
if (logfile)
setbuf(logfile, NULL);
return logfile != NULL ? 0 : -1;
}
/*************************************************************************/
/* Log stuff to the log file with a datestamp. Note that errno is
* preserved by this routine and log_perror().
*/
void alog(const char *fmt, ...)
{
va_list args;
time_t t;
struct tm tm;
char buf[256];
int errno_save = errno;
if (!smtp_debug) {
return;
}
checkday();
if (!fmt) {
return;
}
va_start(args, fmt);
time(&t);
tm = *localtime(&t);
strftime(buf, sizeof(buf) - 1, "[%b %d %H:%M:%S %Y] ", &tm);
if (logfile && args) {
fputs(buf, logfile);
vfprintf(logfile, fmt, args);
fputc('\n', logfile);
}
va_end(args);
errno = errno_save;
}
/*************************************************************************/
/* Remove a trailing \r\n */
char *strip(char *buf)
{
char *c;
if ((c = strchr(buf, '\n')))
*c = 0;
if ((c = strchr(buf, '\r')))
*c = 0;
return buf;
}
/*************************************************************************/
/* Convert a trailing \n to \r\n
* The caller must free the allocated memory
*/
char *lftocrlf(char *buf)
{
char *result = malloc(strlen(buf) + 2);
strip(buf);
strcpy(result, buf);
strcat(result, "\r\n");
return result;
}
/*************************************************************************/
/* Add a header to the list */
void smtp_add_header(char *header)
{
struct smtp_header *head = malloc(sizeof(struct smtp_header));
head->header = lftocrlf(header);
head->next = NULL;
if (!mail.smtp_headers) {
mail.smtp_headers = head;
}
if (mail.smtp_headers_tail) {
mail.smtp_headers_tail->next = head;
}
mail.smtp_headers_tail = head;
}
/*************************************************************************/
/* Is the buffer a header? */
int smtp_is_header(char *buf)
{
char *tmp = strchr(buf, ' ');
if (!tmp)
return 0;
if (*(tmp - 1) == ':')
return 1;
return 0;
}
/*************************************************************************/
/* Parse a header into a name and value */
void smtp_parse_header(char *buf, char **header, char **value)
{
strip(buf);
*header = strtok(buf, " ");
*value = strtok(NULL, "");
if (*header)
(*header)[strlen(*header) - 1] = 0;
}
/*************************************************************************/
/* Have we reached the end of input? */
int smtp_is_end(char *buf)
{
if (*buf == '.')
if (*(buf + 1) == '\r' || *(buf + 1) == '\n')
return 1;
return 0;
}
/*************************************************************************/
/* Set who the email is from */
void smtp_set_from(char *from)
{
mail.from = strdup(from);
}
/*************************************************************************/
/* Set who the email is to */
void smtp_set_to(char *to)
{
char *c;
if ((c = strrchr(to, '<')) && *(c + 1)) {
to = c + 1;
to[strlen(to) - 1] = 0;
}
mail.to = strdup(to);
}
/*************************************************************************/
/* Add a line of body text */
void smtp_add_body_line(char *line)
{
struct smtp_body_line *body;
body = malloc(sizeof(struct smtp_body_line));
body->line = lftocrlf(line);
body->next = NULL;
if (!mail.smtp_body)
mail.smtp_body = body;
if (mail.smtp_body_tail)
mail.smtp_body_tail->next = body;
mail.smtp_body_tail = body;
}
/*************************************************************************/
/* Establish a connection to the SMTP server */
int smtp_connect(char *host, unsigned short port)
{
struct sockaddr_in addr;
if ((mail.sock = socket(AF_INET, SOCK_STREAM, 0)) == SOCKET_ERROR)
return 0;
if ((addr.sin_addr.s_addr = inet_addr(host)) == INADDR_NONE) {
struct hostent *hent;
if (!(hent = gethostbyname(host)))
return 0;
memcpy(&addr.sin_addr, hent->h_addr, hent->h_length);
}
addr.sin_family = AF_INET;
addr.sin_port = htons(port ? port : 25);
if (connect(mail.sock, (struct sockaddr *) &addr, sizeof(struct sockaddr_in)) == SOCKET_ERROR) {
ano_sockclose(mail.sock);
return 0;
}
return 1;
}
/*************************************************************************/
/* Send a line of text */
int smtp_send(char *text)
{
int result = ano_sockwrite(mail.sock, text, strlen(text));
alog("SMTP: sent %s",text);
if (result == SOCKET_ERROR)
ano_sockclose(mail.sock);
return result;
}
/*************************************************************************/
/* Read a line of text */
int smtp_read(char *buf, int len)
{
int result;
memset(buf, 0, len);
result = ano_sockread(mail.sock, buf, len);
if (result == SOCKET_ERROR)
ano_sockclose(mail.sock);
return result;
}
/*************************************************************************/
/* Retrieve a response code */
int smtp_get_code(char *text)
{
char *tmp = strtok(text, " ");
if (!tmp)
return 0;
return atol(tmp);
}
/*************************************************************************/
/* Send the email */
int smtp_send_email()
{
char buf[1024];
struct smtp_header *head;
struct smtp_body_line *body;
int code;
int skip_done = 0;
if (!smtp_read(buf, 1024)) {
alog("SMTP: error reading buffer");
return 0;
}
code = smtp_get_code(buf);
if (code != 220) {
alog("SMTP: error expected code 220 got %d",code);
return 0;
}
if (!smtp_send("HELO anope\r\n")) {
alog("SMTP: error writting to socket");
return 0;
}
if (!smtp_read(buf, 1024)) {
alog("SMTP: error reading buffer");
return 0;
}
code = smtp_get_code(buf);
if (code != 250) {
alog("SMTP: error expected code 250 got %d",code);
return 0;
}
strcpy(buf, "MAIL FROM: <");
strcat(buf, mail.from);
strcat(buf, ">\r\n");
if (!smtp_send(buf)) {
alog("SMTP: error writting to socket");
return 0;
}
if (!smtp_read(buf, 1024)) {
alog("SMTP: error reading buffer");
return 0;
}
code = smtp_get_code(buf);
if (code != 250)
return 0;
strcpy(buf, "RCPT TO: <");
strcat(buf, mail.to);
strcat(buf, ">\r\n");
if (!smtp_send(buf)) {
alog("SMTP: error writting to socket");
return 0;
}
if (!smtp_read(buf, 1024)) {
alog("SMTP: error reading buffer");
return 0;
}
code = smtp_get_code(buf);
if (smtp_get_code(buf) != 250) {
alog("SMTP: error expected code 250 got %d",code);
return 0;
}
if (!smtp_send("DATA\r\n")) {
alog("SMTP: error writting to socket");
return 0;
}
if (!smtp_read(buf, 1024)) {
alog("SMTP: error reading buffer");
return 0;
}
code = smtp_get_code(buf);
if (code != 354) {
alog("SMTP: error expected code 354 got %d",code);
return 0;
}
for (head = mail.smtp_headers; head; head = head->next) {
if (!smtp_send(head->header)) {
alog("SMTP: error writting to socket");
return 0;
}
}
if (!smtp_send("\r\n")) {
alog("SMTP: error writting to socket");
return 0;
}
for (body = mail.smtp_body; body; body = body->next) {
if (skip_done) {
if (!smtp_send(body->line)) {
alog("SMTP: error writting to socket");
return 0;
}
} else {
skip_done = 1;
}
}
if (!smtp_send("\r\n.\r\n")) {
alog("SMTP: error writting to socket");
return 0;
}
return 1;
}
/*************************************************************************/
void smtp_disconnect()
{
smtp_send("QUIT\r\n");
ano_sockclose(mail.sock);
}
/*************************************************************************/
int main(int argc, char *argv[])
{
char buf[8192];
struct smtp_body_line *b;
struct smtp_header *h;
int headers_done = 0;
/* Win32 stuff */
#ifdef _WIN32
WSADATA wsa;
#endif
char *server, *aport;
short port;
if (argc == 1)
return 0;
server = strtok(argv[1], ":");
if ((aport = strtok(NULL, ""))) {
port = atoi(aport);
} else {
port = 25;
}
if (!server) {
alog("No Server");
return;
} else {
alog("SMTP: server %s port %d",server,port);
}
memset(&mail, 0, sizeof(mail));
/* The WSAStartup function initiates use of WS2_32.DLL by a process. */
/* guessing we can skip it under *nix */
#ifdef _WIN32
if (WSAStartup(MAKEWORD(1, 1), &wsa) != 0)
return 0;
#endif
/* Read the message and parse it */
while (fgets(buf, 8192, stdin)) {
if (smtp_is_header(buf) && !headers_done) {
char *header, *value;
smtp_add_header(buf);
smtp_parse_header(buf, &header, &value);
if (!strcasecmp(header, "from")) {
alog("SMTP: from: %s",value);
smtp_set_from(value);
} else if (!strcasecmp(header, "to")) {
alog("SMTP: to: %s",value);
smtp_set_to(value);
} else if (smtp_is_end(buf)) {
break;
} else {
headers_done = 1;
smtp_add_body_line(buf);
}
} else {
smtp_add_body_line(buf);
}
}
if (!smtp_connect(server, port)) {
alog("SMTP: failed to connect to %s:%d",server, port);
return 0;
}
if (!smtp_send_email()) {
alog("SMTP: error during sending of mail");
return 0;
}
smtp_disconnect();
return 1;
}
+94
View File
@@ -0,0 +1,94 @@
/*
*
* (C) 2003 Anope Team
* Contact us at info@anope.org
*
* Please read COPYING and README for furhter details.
*
* Based on the original code of Epona by Lara.
* Based on the original code of Services by Andy Church.
*
*
*/
#ifndef SMTP_H
#define SMTP_H
/*************************************************************************/
/* Some Linux boxes (or maybe glibc includes) require this for the
* prototype of strsignal(). */
#define _GNU_SOURCE
#include <stdarg.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <signal.h>
#include <time.h>
#include <errno.h>
#include <grp.h>
#include <limits.h>
#include <netdb.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <sys/time.h>
#include <fcntl.h>
#include <ctype.h>
#ifdef _AIX
extern int strcasecmp(const char *, const char *);
extern int strncasecmp(const char *, const char *, size_t);
# if 0 /* These break on some AIX boxes (4.3.1 reported). */
extern int socket(int, int, int);
extern int connect(int, struct sockaddr *, int);
# endif
#endif /* _AIX */
/*************************************************************************/
#ifdef _WIN32
#include <winsock.h>
typedef SOCKET ano_socket_t;
#define ano_sockclose(fd) closesocket(fd)
#define ano_sockread(fd, buf, len) recv(fd, buf, len, 0)
#define ano_sockwrite(fd, buf, len) send(fd, buf, len, 0)
#else
typedef int ano_socket_t;
#define ano_sockclose(fd) close(fd)
#define ano_sockread(fd, buf, len) read(fd, buf, len)
#define ano_sockwrite(fd, buf, len) write(fd, buf, len)
#define SOCKET_ERROR -1
#endif
/* Data structures */
struct smtp_header {
char *header;
struct smtp_header *next;
};
struct smtp_body_line {
char *line;
struct smtp_body_line *next;
};
struct smtp_message {
struct smtp_header *smtp_headers, *smtp_headers_tail;
struct smtp_body_line *smtp_body, *smtp_body_tail;
char *from;
char *to;
ano_socket_t sock;
};
struct smtp_message mail;
/* set this to 1 if you want to get a log otherwise it runs silent */
int smtp_debug = 0;
#endif /* SMTP_H */
+5 -1
View File
@@ -8,10 +8,14 @@
VERSION_MAJOR="1"
VERSION_MINOR="7"
VERSION_PATCH="7"
VERSION_BUILD="549"
VERSION_BUILD="550"
# $Log$
#
# BUILD : 1.7.7 (550)
# BUGS : N/A
# NOTES : Anope SMTP client
#
# BUILD : 1.7.7 (549)
# BUGS : N/A
# NOTES : Fixes a segfault with the last commit