/* ** L2 - OSSP Logging Library ** Copyright (c) 2001-2002 The OSSP Project (http://www.ossp.org/) ** Copyright (c) 2001-2002 Cable & Wireless Deutschland (http://www.cw.com/de/) ** ** This file is part of OSSP L2, a flexible logging library which ** can be found at http://www.ossp.org/pkg/l2/. ** ** Permission to use, copy, modify, and distribute this software for ** any purpose with or without fee is hereby granted, provided that ** the above copyright notice and this permission notice appear in all ** copies. ** ** THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED ** WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF ** MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. ** IN NO EVENT SHALL THE AUTHORS AND COPYRIGHT HOLDERS AND THEIR ** CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, ** SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT ** LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF ** USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ** ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, ** OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT ** OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF ** SUCH DAMAGE. ** ** l2_ch_irc.c: Internet Relay Chat (IRC) channel implementation */ #include "l2.h" #include "l2_p.h" #include #include #include #include #include /* declare private channel configuration */ typedef struct { char *cpLocalProg; char *cpLocalHost; char *cpLocalUser; char *cpPassword; char *cpNickname; char *cpUsername; char *cpRealname; char *cpChannel; int bJoin; char *cpHost; char *cpPort; long nTimeout; sa_addr_t *saaServer; sa_t *saServer; } l2_ch_irc_t; /* create channel */ static l2_result_t hook_create(l2_context_t *ctx, l2_channel_t *ch) { l2_ch_irc_t *cfg; struct utsname uts; struct passwd *pw; /* allocate private channel configuration */ if ((cfg = (l2_ch_irc_t *)malloc(sizeof(l2_ch_irc_t))) == NULL) return L2_ERR_ARG; /* initialize configuration with reasonable defaults */ cfg->cpLocalProg = NULL; if ((pw = getpwuid(getuid())) != NULL) cfg->cpLocalUser = strdup(pw->pw_name); else cfg->cpLocalUser = l2_util_asprintf("uid#%d", getuid()); if (uname(&uts) == 0) cfg->cpLocalHost = strdup(uts.nodename); else cfg->cpLocalHost = strdup("localhost"); cfg->cpPassword = strdup("*"); cfg->cpNickname = strdup(cfg->cpLocalUser); cfg->cpUsername = l2_util_asprintf("%s@%s", cfg->cpLocalUser, cfg->cpLocalHost); cfg->cpRealname = strdup(cfg->cpUsername); cfg->cpChannel = strdup("#l2"); cfg->bJoin = 1; cfg->cpHost = NULL; cfg->cpPort = strdup("6667"); cfg->nTimeout = 30; cfg->saaServer = NULL; cfg->saServer = NULL; /* link private channel configuration into channel context */ ctx->vp = cfg; return L2_OK; } /* configure channel */ static l2_result_t hook_configure(l2_context_t *ctx, l2_channel_t *ch, const char *fmt, va_list ap) { l2_ch_irc_t *cfg = (l2_ch_irc_t *)ctx->vp; l2_param_t pa[12]; l2_result_t rv; l2_env_t *env; /* feed and call generic parameter parsing engine */ L2_PARAM_SET(pa[0], progname, STR, &cfg->cpLocalProg); L2_PARAM_SET(pa[1], localhost, STR, &cfg->cpLocalHost); L2_PARAM_SET(pa[2], localuser, STR, &cfg->cpLocalUser); L2_PARAM_SET(pa[3], nickname, STR, &cfg->cpNickname); L2_PARAM_SET(pa[4], username, STR, &cfg->cpUsername); L2_PARAM_SET(pa[5], realname, STR, &cfg->cpRealname); L2_PARAM_SET(pa[6], channel, STR, &cfg->cpChannel); L2_PARAM_SET(pa[7], join, INT, &cfg->bJoin); L2_PARAM_SET(pa[8], host, STR, &cfg->cpHost); L2_PARAM_SET(pa[9], port, STR, &cfg->cpPort); L2_PARAM_SET(pa[10], timeout, INT, &cfg->nTimeout); L2_PARAM_END(pa[11]); l2_channel_env(ch, &env); rv = l2_util_setparams(env, pa, fmt, ap); return rv; } /* open channel */ static l2_result_t hook_open(l2_context_t *ctx, l2_channel_t *ch) { l2_ch_irc_t *cfg = (l2_ch_irc_t *)ctx->vp; sa_rc_t rc; /* make sure a path was set */ if (cfg->cpHost == NULL) return L2_ERR_USE; /* create socket address */ if ((rc = sa_addr_create(&cfg->saaServer)) != SA_OK) return (rc == SA_ERR_SYS ? L2_ERR_SYS : L2_ERR_INT); if ((rc = sa_addr_u2a(cfg->saaServer, "inet://%s:%s", cfg->cpHost, cfg->cpPort)) != SA_OK) return (rc == SA_ERR_SYS ? L2_ERR_SYS : L2_ERR_INT); /* create socket */ if ((rc = sa_create(&cfg->saServer)) != SA_OK) return (rc == SA_ERR_SYS ? L2_ERR_SYS : L2_ERR_INT); /* configure socket parameters */ sa_timeout(cfg->saServer, SA_TIMEOUT_ALL, cfg->nTimeout, 0); sa_timeout(cfg->saServer, SA_TIMEOUT_READ, 2, 0); sa_buffer(cfg->saServer, SA_BUFFER_READ, 4096); sa_buffer(cfg->saServer, SA_BUFFER_WRITE, 4096); return L2_OK; } /* write to channel */ static l2_result_t hook_write(l2_context_t *ctx, l2_channel_t *ch, l2_level_t level, const char *buf, size_t buf_size) { l2_ch_irc_t *cfg = (l2_ch_irc_t *)ctx->vp; char caLine[1024]; sa_t *sa; sa_addr_t *saa; sa_rc_t sa_rv; size_t n; struct tm *tm; time_t t; char caDate[80]; /* * Sample IRC client transaction for reference: * | PASS secret * | NICK rse * | USER rse@engelschall.com 0 * :Ralf S. Engelschall * | :irc.engelschall.com 001 rse :Welcome to the Internet Relay Network rse!~rse@dev10.dev.de.cw.net * | :irc.engelschall.com 002 rse :Your host is irc.engelschall.com, running version 2.10.3p2 * | :irc.engelschall.com 003 rse :This server was created Wed Oct 17 2001 at 18:06:57 CEST * | :irc.engelschall.com 004 rse irc.engelschall.com 2.10.3p2 aoOirwabeiIklmnoOpqrstv * | :irc.engelschall.com 251 rse :There are 1 users and 0 services on 1 servers * | :irc.engelschall.com 254 rse 11 :channels formed * | :irc.engelschall.com 255 rse :I have 1 users, 0 services and 0 servers * | :irc.engelschall.com 375 rse :- irc.engelschall.com Message of the Day - * | :irc.engelschall.com 372 rse :- 17/10/2001 19:32 * | :irc.engelschall.com 372 rse :- Welcome to the Engelschall VISP IRC Service. * | :irc.engelschall.com 376 rse :End of MOTD command. * | :rse MODE rse :+i * | JOIN #dev * | :rse!~rse@dev10.dev.de.cw.net JOIN :#dev * | :irc.engelschall.com 353 rse = #dev :@rse * | :irc.engelschall.com 366 rse #dev :End of NAMES list. * | PRIVMSG #dev :Sample log message line 1 * | PRIVMSG #dev :Sample log message line 2 * | PRIVMSG #dev :Sample log message line 3 * | QUIT * | ERROR :Closing Link: rse[~rse@dev10.dev.de.cw.net] (I Quit) * * For more details read: * RFC 2812: Internet Relay Chat: Client Protocol; C. Kalt; April 2000. */ /* establish connection to server */ saa = cfg->saaServer; sa = cfg->saServer; if ((sa_rv = sa_connect(sa, saa)) != SA_OK) return (sa_rv == SA_ERR_SYS ? L2_ERR_SYS : L2_ERR_INT); /* determine current time */ t = time(NULL); tm = localtime(&t); strftime(caDate, sizeof(caDate), "%a, %d %b %Y %H:%M:%S %Z", tm); /* write transaction to IRC server */ sa_writef(sa, "PASS %s\r\n", cfg->cpPassword); sa_writef(sa, "NICK %s\r\n", cfg->cpNickname); sa_writef(sa, "USER %s 0 * :%s\r\n", cfg->cpUsername, cfg->cpRealname); if (cfg->bJoin) sa_writef(sa, "JOIN %s\r\n", cfg->cpChannel); sa_writef(sa, "PRIVMSG %s :", cfg->cpChannel); if (cfg->cpLocalProg != NULL) sa_writef(sa, "Program %s of user %s on host %s logged at %s:\r\n", cfg->cpLocalProg, cfg->cpLocalUser, cfg->cpLocalHost, caDate); else sa_writef(sa, "A program of user %s on host %s logged at %s:\r\n", cfg->cpLocalUser, cfg->cpLocalHost, caDate); sa_writef(sa, "PRIVMSG %s :", cfg->cpChannel); sa_write(sa, buf, buf_size-1, NULL); sa_writef(sa, "\r\n"); if (cfg->bJoin) sa_writef(sa, "PART %s\r\n", cfg->cpChannel); sa_writef(sa, "QUIT\r\n"); sa_flush(sa); /* shutdown write side of connection to server */ sa_shutdown(sa, "w"); /* still read server responses */ while (sa_readln(sa, caLine, sizeof(caLine), &n) == SA_OK) ; /* shutdown read side of connection to server */ sa_shutdown(sa, "r"); return L2_OK; } /* close channel */ static l2_result_t hook_close(l2_context_t *ctx, l2_channel_t *ch) { l2_ch_irc_t *cfg = (l2_ch_irc_t *)ctx->vp; /* destroy remote address */ if (cfg->saServer != NULL) { sa_destroy(cfg->saServer); cfg->saServer = NULL; } if (cfg->saaServer != NULL) { sa_addr_destroy(cfg->saaServer); cfg->saaServer = NULL; } return L2_OK; } /* destroy channel */ static l2_result_t hook_destroy(l2_context_t *ctx, l2_channel_t *ch) { l2_ch_irc_t *cfg = (l2_ch_irc_t *)ctx->vp; /* destroy channel configuration */ if (cfg->cpLocalProg != NULL) free(cfg->cpLocalProg); if (cfg->cpLocalHost != NULL) free(cfg->cpLocalHost); if (cfg->cpLocalUser != NULL) free(cfg->cpLocalUser); if (cfg->cpPassword != NULL) free(cfg->cpPassword); if (cfg->cpNickname != NULL) free(cfg->cpNickname); if (cfg->cpUsername != NULL) free(cfg->cpUsername); if (cfg->cpRealname != NULL) free(cfg->cpRealname); if (cfg->cpChannel != NULL) free(cfg->cpChannel); if (cfg->cpHost != NULL) free(cfg->cpHost); if (cfg->cpPort != NULL) free(cfg->cpPort); free(cfg); return L2_OK; } /* exported channel handler structure */ l2_handler_t l2_handler_irc = { "irc", L2_CHANNEL_OUTPUT, hook_create, hook_configure, hook_open, hook_write, NULL, hook_close, hook_destroy };