#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <ctype.h>
#include <time.h>
#include <sys/select.h>
#include <errno.h>
#include <signal.h>
#include <stdarg.h>
#include <search.h>
#include "ircxmpp.h"
#ifdef IX_LIB
#define BUG(...) bug(__FILE__, __func__, __LINE__, __VA_ARGS__)
__attribute__((noreturn)) static void bug (const char * file, const char * function, int line, const char * format, ...) {
va_list ap;
va_start(ap, format);
fprintf(stderr, "BUG DETECTED in %s()@%s:%d REPORT TO anton@šijanec.eu and attach core.\n"
"additional description: ", file, function, line);
vfprintf(stderr, format, ap);
abort();
va_end(ap); /* this is never called */
}
static void free_bridge (struct bridge ** bridge, const char * razlog) {
if (!bridge || !*bridge)
return;
fprintf(stderr, "freeing bridge with reason: %s\n", razlog);
if ((*bridge)->irc) {
irc_cmd_quit((*bridge)->irc, razlog);
irc_run_once(*bridge); // verjetno je to potrebno, da pošlje quit
irc_destroy_session((*bridge)->irc);
}
if ((*bridge)->conn)
xmpp_conn_release((*bridge)->conn); // graceful disconnect, what is that?
free((*bridge)->identifier);
for (size_t i = 0; i < (*bridge)->messages_length; i++)
free((*bridge)->messages[i]);
free((*bridge)->messages);
if ((*bridge)->next)
(*bridge)->next->prev = (*bridge)->prev;
struct bridge * tofree = *bridge;
if ((*bridge)->prev)
(*bridge)->prev->next = (*bridge)->next;
else {
if ((*bridge)->next)
(*bridge)->next->prev = (*bridge)->prev;
*bridge = (*bridge)->next;
}
free(tofree);
}
static void free_bridges (struct bridge ** bridges) {
while (*bridges) { // enkrat bo *bridges NULL, ker ne bo nobenega več notri
if ((*bridges)->prev)
BUG("(*bridges)->prev is set");
free_bridge(bridges, "vsi mostovi se podirajo, ker se ircxmpp izklaplja");
}
}
static struct bridge ** find_bridge (struct bridge ** bridges, const char * id, enum side side) {
s:
if (!bridges || !*bridges)
return NULL;
if ((*bridges)->side == side && !strcmp((*bridges)->identifier, id))
return bridges;
bridges = &((*bridges)->next);
goto s;
}
static void jid2ircnick (char * jid) { /* edits a jid into an irc nick. libera trims nicks. */
char * c = strchr(jid, '/');
if (c) {
c++;
memmove(jid, c, strlen(c)+1);
}
if (*jid && isdigit(*jid))
*jid = '_';
#define VALID_NICK "{}[]_^`|\\"
while (*++jid != '\0')
if (!(isalnum(*jid) || memchr(VALID_NICK, *jid, strlen(VALID_NICK))))
*jid = '_';
}
static void jid2ircuser (char * jid) {
char * c = strchr(jid, '/');
if (c) {
c++;
memmove(jid, c, strlen(c)+1);
}
if (*jid && isdigit(*jid)) {
*jid = '_';
}
#define VALID_USER ""
while (*++jid != '\0')
if (!(isalnum(*jid) || memchr(VALID_USER, *jid, strlen(VALID_USER))))
*jid = 'x';
}
static void bridge_forward (const char * f, const char * m, struct ircxmpp * ircxmpp, enum side s) {
struct bridge ** bridge_resp = find_bridge(&ircxmpp->bridges, f, !s);
if (strstr(f, "ircxmpp_") || (ircxmpp->irchost && strstr(f, ircxmpp->irchost)))
return;
fprintf(stderr, "sending text from %s to %s: %s\n", f, s == IRC ? "IRC" : "XMPP",
m ? m : "[join only]");
struct bridge * bridge;
if (!bridge_resp) {
bridge = calloc(1, sizeof(struct bridge));
if (ircxmpp->bridges)
ircxmpp->bridges->prev = bridge;
bridge->next = ircxmpp->bridges;
ircxmpp->bridges = bridge;
bridge->identifier = strdup(f);
bridge->ircxmpp = ircxmpp;
bridge->side = !s;
if (s == IRC)
init_irc(bridge);
else {
bridge->conn = xmpp_conn_new(bridge->ircxmpp->ctx);
xmpp_conn_set_jid(bridge->conn, bridge->ircxmpp->jid);
xmpp_conn_set_pass(bridge->conn, bridge->ircxmpp->password);
xmpp_connect_client(bridge->conn, NULL, 0, conn_handler_bridge, bridge);
}
} else
bridge = *bridge_resp;
if (s == IRC) {
irc_cmd_join(bridge->irc, ircxmpp->channel, ircxmpp->channel_password);
irc_run_once(bridge);
if (m) {
char b[1024];
strncpy(b, m, 1023);
b[1023] = '\0';
char * c = b;
while (*++c != '\0')
if (!(isprint(*c) || * (unsigned char *) c > 0x7F /* UTF-8 */))
*c = ' '; /* to prevent newline message smuggling */
irc_cmd_msg(bridge->irc, ircxmpp->channel, m);
}
irc_run_once(bridge);
} else if (m) {
bridge->messages = realloc(bridge->messages,
sizeof(*bridge->messages) * (bridge->messages_length+1));
bridge->messages[bridge->messages_length++] = strdup(m);
}
} /* m can be NULL, in that case we only join. */
static int message_handler (xmpp_conn_t * const c, xmpp_stanza_t * const stanza, void * const ud) {
if (!c) /* just to get rid of -Wunused-parameter */
return 1;
struct ircxmpp * ircxmpp = (struct ircxmpp *) ud;
xmpp_stanza_t * body;
const char * type;
char * intext;
body = xmpp_stanza_get_child_by_name(stanza, "body");
if (body == NULL)
return 1;
type = xmpp_stanza_get_type(stanza);
if (type != NULL && strcmp(type, "error") == 0)
return 1;
if (!strncmp(ircxmpp->jid, xmpp_stanza_get_from(stanza), strlen(ircxmpp->jid)))
return 1; // this is our message
if (xmpp_stanza_get_child_by_name_and_ns(stanza, "delay", "urn:xmpp:delay"))
return 1; // MUC MAM history
intext = xmpp_stanza_get_text(body);
printf("Incoming message from %s: %s\n", xmpp_stanza_get_from(stanza), intext);
bridge_forward(xmpp_stanza_get_from(stanza), intext, ircxmpp, IRC);
xmpp_free(ircxmpp->ctx, intext);
return 1;
}
static int presence_handler (xmpp_conn_t * const c, xmpp_stanza_t * const stanza, void * const ud) {
struct ircxmpp * ircxmpp = (struct ircxmpp *) ud;
if (!c || !xmpp_stanza_get_from(stanza) || !strchr(xmpp_stanza_get_from(stanza), '/'))
return 1;
if (xmpp_stanza_get_type(stanza) && !strcmp("unavailable", xmpp_stanza_get_type(stanza))) {
fprintf(stderr, "sogovornik %s je zapustil MUC\n", xmpp_stanza_get_from(stanza));
free_bridge(find_bridge(&ircxmpp->bridges, xmpp_stanza_get_from(stanza), XMPP),
"ircxmpp: sogovornik je zapustil XMPP MUC sobo");
}
if (!xmpp_stanza_get_type(stanza)) {
fprintf(stderr, "sogovornik %s se je pridružil MUC\n", xmpp_stanza_get_from(stanza));
bridge_forward(xmpp_stanza_get_from(stanza), NULL, ircxmpp, IRC);
}
return 1;
}
static void conn_handler (xmpp_conn_t * const conn, const xmpp_conn_event_t status,
const int error, xmpp_stream_error_t * const stream_error, void * const userdata) {
struct ircxmpp * ircxmpp = (struct ircxmpp *) userdata;
if (stream_error) /* just for -Wunused-parameter */
fprintf(stderr, "stream_error in conn_handler, error = %d\n", error);
if (status == XMPP_CONN_CONNECT) {
xmpp_stanza_t * pres;
fprintf(stderr, "DEBUG: connected.\n");
xmpp_handler_add(conn, message_handler, NULL, "message", NULL, ircxmpp);
xmpp_handler_add(conn, presence_handler, NULL, "presence", NULL, ircxmpp);
/* Send initial <presence/> so that we appear online to contacts */
// pres = xmpp_presence_new(ctx); // somehow send can only be called once?
// xmpp_send(conn, pres);
// xmpp_stanza_release(pres);
pres = xmpp_presence_new(ircxmpp->ctx); // joining a MUC
char b[512];
snprintf(b, 512, "%s/ircxmpp_%x", ircxmpp->muc, rand());
xmpp_stanza_set_to(pres, b);
xmpp_stanza_t * x = xmpp_stanza_new(ircxmpp->ctx);
xmpp_stanza_set_name(x, "x");
xmpp_stanza_set_ns(x, "http://jabber.org/protocol/muc");
xmpp_stanza_add_child(pres, x);
xmpp_stanza_release(x);
xmpp_send(conn, pres);
xmpp_stanza_release(pres);
} else {
fprintf(stderr, "DEBUG: disconnected\n");
// xmpp_stop(ircxmpp->ctx);
}
}
static void conn_handler_bridge (xmpp_conn_t * const conn, const xmpp_conn_event_t status,
const int error, xmpp_stream_error_t * const stream_error, void * const userdata) {
struct bridge * bridge = (struct bridge *) userdata;
if (stream_error) /* just for -Wunused-parameter */
fprintf(stderr, "stream_error in conn_handler, error = %d\n", error);
if (!conn) /* just for -Wunused-parameter */
return;
if (status == XMPP_CONN_CONNECT) {
char stanzato[512];
snprintf(stanzato, 512, "%s/%s ircxmpp_%x", bridge->ircxmpp->muc,
bridge->identifier, rand());
fprintf(stderr, "joining muc %s (to)\n", stanzato);
xmpp_stanza_t * pres = xmpp_presence_new(bridge->ircxmpp->ctx); // joining a MUC
xmpp_stanza_set_to(pres, stanzato);
xmpp_stanza_t * x = xmpp_stanza_new(bridge->ircxmpp->ctx);
xmpp_stanza_set_name(x, "x");
xmpp_stanza_set_ns(x, "http://jabber.org/protocol/muc");
xmpp_stanza_add_child(pres, x);
xmpp_stanza_release(x);
xmpp_send(bridge->conn, pres);
xmpp_stanza_release(pres);
} else {
fprintf(stderr, "DEBUG: disconnected\n");
// xmpp_stop(ircxmpp->ctx);
}
}
/* IRC */
static void dump_event (
irc_session_t * s, const char * e, const char * o, const char ** p, unsigned c) {
if (!s) /* just for -Wunused-parameter */
return;
fprintf(stderr, "Event %s, origin %s, params %d [", e, o ? o : "NULL", c);
for (unsigned int i = 0; i < c; i++) {
if (i)
fprintf(stderr, "|");
fprintf(stderr, "%s", p[i]);
}
fprintf(stderr, "]\n");
}
static void event_connect (
irc_session_t * s, const char * e, const char * o, const char ** p, unsigned c) {
dump_event(s, e, o, p, c);
struct bridge * bridge = (struct bridge *) irc_get_ctx(s);
irc_cmd_join(s, bridge->ircxmpp->channel, bridge->ircxmpp->channel_password);
}
static void event_connect_control (
irc_session_t * s, const char * e, const char * o, const char ** p, unsigned c) {
dump_event(s, e, o, p, c);
struct ircxmpp * ircxmpp = (struct ircxmpp *) irc_get_ctx(s);
irc_cmd_join(s, ircxmpp->channel, ircxmpp->channel_password);
}
static void event_privmsg (
irc_session_t * s, const char * e, const char * o, const char ** p, unsigned c) {
dump_event(s, e, o, p, c); /* SAME FOR _control. do NOT use irc_get_ctx here!!! */
char nickbuf[512];
irc_target_get_nick(o, nickbuf, sizeof(nickbuf));
irc_cmd_msg(s, nickbuf, "ircxmpp (še) ne podpira zasebnih sporočil xmpp uporabnikom. ircxmpp se razvija na http://git.sijanec.eu/sijanec/ircxmpp/.");
}
static void event_partquit_control (
irc_session_t * s, const char * e, const char * o, const char ** p, unsigned c) {
dump_event(s, e, o, p, c);
struct ircxmpp * ircxmpp = (struct ircxmpp *) irc_get_ctx(s);
struct bridge ** bridge = find_bridge(&ircxmpp->bridges, o /* indeed n!u@h */, IRC);
free_bridge(bridge, "part or quit from irc");
} /* part and quit events */
static void event_channel_control (
irc_session_t * s, const char * e, const char * o, const char ** p, unsigned c) {
dump_event(s, e, o, p, c); /* o je avtor, p[0] je kanal p[1] je besedilo */
if (c != 2) /* no message text */
return;
struct ircxmpp * ircxmpp = (struct ircxmpp *) irc_get_ctx(s);
bridge_forward(o /* indeed n!u@h */, p[1], ircxmpp, XMPP);
}
static void event_join_control (
irc_session_t * s, const char * e, const char * o, const char ** p, unsigned c) {
dump_event(s, e, o, p, c);
struct ircxmpp * ircxmpp = (struct ircxmpp *) irc_get_ctx(s);
char buf[512];
strncpy(buf, o, 512-1);
buf[511] = '\0';
if (!strlen(buf))
strcpy(buf, "a");
char * cp = strchr(buf, '!');
if (cp)
*cp = '\0';
else
cp = buf;
if (ircxmpp->ircnick && !strcmp(buf, ircxmpp->ircnick)) {
cp = strchr(++cp, '@');
if (cp) {
free(ircxmpp->irchost);
ircxmpp->irchost = strdup(++cp);
fprintf(stderr, "FOUND OUR HOSTNAME: %s\n", ircxmpp->irchost);
}
}
bridge_forward(o /* indeed n!u@h */, NULL, ircxmpp, XMPP);
}
static void event_nick_control (
irc_session_t * s, const char * e, const char * o, const char ** p, unsigned c) {
dump_event(s, e, o, p, c); /* o je originalen nick, p[0] je nov nick */
if (!c)
return;
struct ircxmpp * ircxmpp = (struct ircxmpp *) irc_get_ctx(s);
struct bridge ** bridge = find_bridge(&ircxmpp->bridges, o /* indeed n!u@h */, IRC);
if (!bridge || !*bridge)
return;
free_bridge(bridge, "nick change from irc");
char buf[512];
snprintf(buf, 512, "%s%s", p[0], strchr(o, '!') ? strchr(o, '!')
: "neznan uporabnik@neznan strežnik");
bridge_forward(buf, NULL, ircxmpp, XMPP); /* and now connect */
}
static void event_topic_control (
irc_session_t * s, const char * e, const char * o, const char ** p, unsigned c) {
dump_event(s, e, o, p, c); /* o je avtor, p[0] je kanal, p[1] je nova tema/zadeva */
struct ircxmpp * ircxmpp = (struct ircxmpp *) irc_get_ctx(s);
char buf[1024];
snprintf(buf, 1024, "/me je nastavil IRC temo na: %s", p[1]);
bridge_forward(o, buf, ircxmpp, XMPP);
} /* TODO */
static void event_numeric (
irc_session_t * s, unsigned int e, const char * o, const char ** p, unsigned c) {
char b[512];
struct bridge * bridge = (struct bridge *) irc_get_ctx(s);
sprintf(b, "%d", e);
dump_event(s, b, o, p, c);
switch (e) {
case ERR_NONICKNAMEGIVEN:
case ERR_ERRONEUSNICKNAME:
case ERR_NICKNAMEINUSE:
case ERR_NICKCOLLISION:
strncpy(b, bridge->identifier, sizeof(b));
b[511] = '\0';
jid2ircnick(b); /* RFC 1495 says that nicks are at least 9 characters */
if (strlen(b))
sprintf(strlen(b) >= 7 ? b+7 : b+strlen(b), "_%x", rand());
else
sprintf(b, "xmpp_%x", rand());
irc_cmd_nick(s, b);
break;
}
}
static void event_numeric_control (
irc_session_t * s, unsigned int e, const char * o, const char ** p, unsigned c) {
char b[512];
struct ircxmpp * ircxmpp = (struct ircxmpp *) irc_get_ctx(s);
sprintf(b, "%d", e);
dump_event(s, b, o, p, c);
switch (e) {
case ERR_NONICKNAMEGIVEN:
case ERR_ERRONEUSNICKNAME:
case ERR_NICKNAMEINUSE:
case ERR_NICKCOLLISION:
sprintf(b, "ircxmpp%X", rand());
free(ircxmpp->ircnick);
ircxmpp->ircnick = strdup(b);
irc_cmd_nick(s, b);
break;
}
}
static int irc_run_once (struct bridge * bridge) { /* returns nonzero if connection failed */
if (!irc_is_connected(bridge->irc)) {
char b[512], u[512];
strncpy(b, bridge->identifier, sizeof(b)-1);
b[511] = '\0';
strcpy(u, b);
jid2ircnick(b);
jid2ircuser(u);
if (!strlen(b))
sprintf(b, "xmpp_%x", rand());
if (!strlen(u))
strcpy(u, "ircxmpp");
fprintf(stderr, "CONNECTING bridge %s!%s@host\n", b, u);
if (irc_connect(bridge->irc, bridge->ircxmpp->hostname, bridge->ircxmpp->port,
NULL, b, u, bridge->identifier)) {
fprintf(stderr, "could not connect: %s\n",
irc_strerror(irc_errno(bridge->irc)));
return 1;
}
}
struct timeval tv;
fd_set in_set, out_set;
int maxfd = 0;
tv.tv_usec = 0; /* polling */
tv.tv_sec = 0;
FD_ZERO(&in_set);
FD_ZERO(&out_set);
irc_add_select_descriptors(bridge->irc, &in_set, &out_set, &maxfd);
if (select(maxfd+1, &in_set, &out_set, NULL, &tv) < 0) {
if (errno == EINTR)
return 0;
fprintf(stderr, "SELECT failed in bridge!\n");
return 1;
}
if (irc_process_select_descriptors(bridge->irc, &in_set, &out_set)) {
fprintf(stderr, "PROCESS_SELECT failed in bridge!\n");
return 1;
}
return 0;
}
static int irc_run_once_control (struct ircxmpp * ircxmpp) { /* returns nonzero if failed */
if (!ircxmpp->irc)
return 1;
if (!irc_is_connected(ircxmpp->irc)) {
char b[512];
sprintf(b, "ircxmpp_%X", rand());
fprintf(stderr, "CONNECTING control %s!ircxmpp@host\n", b);
free(ircxmpp->ircnick);
ircxmpp->ircnick = strdup(b);
if (irc_connect(ircxmpp->irc, ircxmpp->hostname, ircxmpp->port,
NULL, b, "ircxmpp", "http git.sijanec.eu/sijanec/ircxmpp")) {
fprintf(stderr, "could not connect: %s\n",
irc_strerror(irc_errno(ircxmpp->irc)));
return 2;
}
return 0;
}
struct timeval tv;
fd_set in_set, out_set;
int maxfd = 0;
tv.tv_usec = 0; /* polling */
tv.tv_sec = 0;
FD_ZERO(&in_set);
FD_ZERO(&out_set);
irc_add_select_descriptors(ircxmpp->irc, &in_set, &out_set, &maxfd);
if (select(maxfd+1, &in_set, &out_set, NULL, &tv) < 0) {
if (errno == EINTR)
return 0;
return 3;
}
if (irc_process_select_descriptors(ircxmpp->irc, &in_set, &out_set))
return 4;
return 0;
}
static void init_irc (struct bridge * bridge) {
irc_callbacks_t callbacks;
irc_session_t * s;
memset(&callbacks, 0, sizeof(callbacks));
callbacks.event_connect = event_connect;
callbacks.event_nick = dump_event;
callbacks.event_quit = dump_event;
callbacks.event_join = dump_event;
callbacks.event_part = dump_event;
callbacks.event_mode = dump_event;
callbacks.event_umode = dump_event;
callbacks.event_topic = dump_event;
callbacks.event_kick = dump_event;
callbacks.event_channel = dump_event;
callbacks.event_privmsg = event_privmsg;
callbacks.event_notice = dump_event;
callbacks.event_channel_notice = dump_event;
callbacks.event_invite = dump_event;
callbacks.event_ctcp_req = dump_event;
callbacks.event_ctcp_rep = dump_event;
callbacks.event_ctcp_action = dump_event;
callbacks.event_unknown = dump_event;
callbacks.event_numeric = event_numeric;
// callbacks.event_dcc_chat_req = dump_event;
// callbacks.event_dcc_send_req = dump_event;
if (!(s = irc_create_session(&callbacks))) {
fprintf(stderr, "could not create IRC session!\n");
return;
}
bridge->irc = s;
irc_set_ctx(s, bridge);
irc_run_once(bridge);
return;
}
static void init_irc_control (struct ircxmpp * ircxmpp) {
irc_callbacks_t callbacks;
irc_session_t * s;
memset(&callbacks, 0, sizeof(callbacks));
callbacks.event_connect = event_connect_control;
callbacks.event_nick = event_nick_control;
callbacks.event_quit = event_partquit_control;
callbacks.event_join = event_join_control;
callbacks.event_part = event_partquit_control;
callbacks.event_mode = dump_event;
callbacks.event_umode = dump_event;
callbacks.event_topic = event_topic_control;
callbacks.event_kick = dump_event;
callbacks.event_channel = event_channel_control;
callbacks.event_privmsg = event_privmsg;
callbacks.event_notice = dump_event;
callbacks.event_channel_notice = dump_event;
callbacks.event_invite = dump_event;
callbacks.event_ctcp_req = dump_event;
callbacks.event_ctcp_rep = dump_event;
callbacks.event_ctcp_action = dump_event;
callbacks.event_unknown = dump_event;
callbacks.event_numeric = event_numeric_control;
// callbacks.event_dcc_chat_req = dump_event;
// callbacks.event_dcc_send_req = dump_event;
if (!(s = irc_create_session(&callbacks))) {
fprintf(stderr, "could not create IRC control session!\n");
return;
}
ircxmpp->irc = s;
irc_set_ctx(s, ircxmpp);
irc_run_once_control(ircxmpp);
return;
}
/* /IRC */ /* irc_is_connected(irc_session_t * session): 1 ali 0 */
struct ircxmpp * ircxmpp_init (void) {
xmpp_initialize();
return calloc(1, sizeof(struct ircxmpp));
}
void ircxmpp_set_jid (struct ircxmpp * ircxmpp, const char * jid) {
free(ircxmpp->jid);
ircxmpp->jid = strdup(jid);
}
void ircxmpp_set_password (struct ircxmpp * ircxmpp, const char * password) {
free(ircxmpp->password);
ircxmpp->password = strdup(password);
}
void ircxmpp_set_hostname (struct ircxmpp * ircxmpp, const char * hostname) {
free(ircxmpp->hostname);
ircxmpp->hostname = strdup(hostname);
}
void ircxmpp_set_port (struct ircxmpp * ircxmpp, unsigned short int port) {
ircxmpp->port = port;
}
void ircxmpp_set_channel (struct ircxmpp * ircxmpp, const char * channel) {
free(ircxmpp->channel);
ircxmpp->channel = strdup(channel);
}
void ircxmpp_set_muc (struct ircxmpp * ircxmpp, const char * muc) {
free(ircxmpp->muc);
ircxmpp->muc = strdup(muc);
}
void ircxmpp_set_channel_password (struct ircxmpp * ircxmpp, const char * channel_password) {
free(ircxmpp->channel_password);
ircxmpp->channel_password = strdup(channel_password);
}
void ircxmpp_run_once (struct ircxmpp * ircxmpp) {
if (!ircxmpp->ctx || !ircxmpp->conn || (!xmpp_conn_is_connected(ircxmpp->conn)
&& !xmpp_conn_is_connecting(ircxmpp->conn))) {
fprintf(stderr, "XMPP control is DISCONNECTED! CONNECTING!\n");
if (ircxmpp->conn)
xmpp_conn_release(ircxmpp->conn);
if (ircxmpp->ctx)
xmpp_ctx_free(ircxmpp->ctx);
ircxmpp->ctx = xmpp_ctx_new(NULL, xmpp_get_default_logger(XMPP_LEVEL_DEBUG));
ircxmpp->conn = xmpp_conn_new(ircxmpp->ctx);
xmpp_conn_set_jid(ircxmpp->conn, ircxmpp->jid);
xmpp_conn_set_pass(ircxmpp->conn, ircxmpp->password);
xmpp_connect_client(ircxmpp->conn, NULL, 0, conn_handler, ircxmpp);
}
xmpp_run_once(ircxmpp->ctx, 1); /* no need to run for bridges, as they share the ctx */
int ret = 0;
if ((ret = irc_run_once_control(ircxmpp))) {
fprintf(stderr, "IRC control is DISCONNECTED with code %d. CONNECTING!\n", ret);
if (ircxmpp->irc)
irc_destroy_session(ircxmpp->irc);
init_irc_control(ircxmpp);
}
struct bridge ** bridge = &ircxmpp->bridges;
while (bridge && *bridge) {
struct bridge ** next = NULL;
if ((*bridge)->next)
next = &((*bridge)->next);
if ((*bridge)->irc && irc_run_once(*bridge)) {
free_bridge(bridge, "irc connection dropped");
goto cont;
}
if ((*bridge)->conn && !xmpp_conn_is_connected((*bridge)->conn)
&& !xmpp_conn_is_connecting(((*bridge)->conn))) {
if ((*bridge)->side == IRC && (*bridge)->messages_length) {
fprintf(stderr, "RECONNECTING BRIDGE BECAUSE IT DIED and has msgs!");
xmpp_connect_client((*bridge)->conn, NULL, 0,
conn_handler_bridge, *bridge);
} else
free_bridge(bridge, "xmpp connection dropped");
goto cont;
}
while ((*bridge)->conn && xmpp_conn_is_connected((*bridge)->conn)
&& (*bridge)->messages_length
&& xmpp_conn_get_bound_jid((*bridge)->conn)) {
char id[64];
fprintf(stderr, "sending xmpp msg from %s\n", (*bridge)->identifier);
sprintf(id, "ircxmpp-%x", rand());
xmpp_stanza_t * stan = xmpp_message_new(ircxmpp->ctx,
"groupchat", ircxmpp->muc, id);
xmpp_message_set_body(stan,
(*bridge)->messages[(*bridge)->messages_length-1]);
xmpp_stanza_set_from(stan, xmpp_conn_get_bound_jid((*bridge)->conn));
xmpp_send((*bridge)->conn, stan);
xmpp_stanza_release(stan);
free((*bridge)->messages[--(*bridge)->messages_length]);
}
cont:
bridge = next;
}
}
void ircxmpp_free (struct ircxmpp * ircxmpp) {
free_bridges(&ircxmpp->bridges);
xmpp_conn_release(ircxmpp->conn);
xmpp_ctx_free(ircxmpp->ctx);
xmpp_shutdown();
irc_cmd_quit(ircxmpp->irc, "vsesplošni izklop programa");
irc_run_once_control(ircxmpp); // verjetno je to potrebno, da pošlje quit
irc_destroy_session(ircxmpp->irc);
free(ircxmpp->ircnick);
free(ircxmpp->irchost);
free(ircxmpp->jid);
free(ircxmpp->password);
free(ircxmpp->hostname);
free(ircxmpp->channel);
free(ircxmpp->muc);
free(ircxmpp->channel_password);
free(ircxmpp);
}
#else
int shouldexit = 0;
void signalhandler (int s) {
shouldexit += s+1; /* only for -Wunused-parameter */
}
const char * str2str (const char * str) {
return str;
}
int main (void) {
srand(time(NULL));
#define USAGE " *** ircxmpp is developed at http://git.sijanec.eu/sijanec/ircxmpp ***\n" \
"Usage: IX_JID=jid@xmpp.server IX_PASS=pass IX_HOST=irc.server IX_PORT=6666 " \
"IX_CHANNEL=#channel IX_MUC=muc@xmpp.srv ircxmpp\n" \
"multiple links can be specified by appending a consecutive number, starting with " \
"2, to every environment variable. first link is IX_*, second is IX_*2, and so on.\n"
size_t handles_length = 0;
ircxmpp ** handles = NULL;
while (1) { // note that if input config is invalid we leak memory before exiting
char b[64]; // i don't free any allocated shit and just return, probably it's ok
if (handles_length++)
sprintf(b, "IX_JID%d", handles_length);
else
strcpy(b, "IX_JID");
if (!getenv(b)) {
if (handles_length == 1) {
fprintf(stderr, USAGE "FAIL: at least one link is required!\n");
return 1;
}
handles_length--;
break;
}
handles = realloc(handles, sizeof(ircxmpp *)*handles_length);
handles[handles_length-1] = ircxmpp_init();
#define PREPARE_HANDLE(value, config, function, required) \
if (handles_length == 1) \
sprintf(b, "IX_" config); \
else \
sprintf(b, "IX_" config "%d", handles_length); \
if (getenv(b)) \
ircxmpp_set_##value(handles[handles_length-1], function(getenv(b))); \
else if (required) \
fprintf(stderr, USAGE "FAIL: environment variable %s was expected to be set.\n", b)
PREPARE_HANDLE(jid, "JID", str2str, 1);
PREPARE_HANDLE(password, "PASS", str2str, 1);
PREPARE_HANDLE(hostname, "HOST", str2str, 1);
PREPARE_HANDLE(port, "PORT", atoi, 1);
PREPARE_HANDLE(channel, "CHANNEL", str2str, 1);
PREPARE_HANDLE(muc, "MUC", str2str, 1);
PREPARE_HANDLE(channel_password, "CHPASS", str2str, 0);
}
signal(SIGTERM, signalhandler);
signal(SIGINT, signalhandler);
// signal(SIGPIPE, SIG_IGN);
while (!shouldexit) { /* TEH EVENT LOOP */
for (size_t i = 0; i < handles_length; i++)
ircxmpp_run_once(handles[i]);
struct timespec ts = {
.tv_sec = 0,
.tv_nsec = getenv("IX_LOOPDELAY") ? atoi(getenv("IX_LOOPDELAY"))/1000 : 1e8
};
nanosleep(&ts, NULL);
}
fprintf(stderr, "signal received, cleaning up!\n");
for (size_t i = 0; i < handles_length; i++)
ircxmpp_free(handles[i]);
free(handles);
return 0;
}
#endif
