/******************************************************************************/
-/* postlicyd: a postfix policy daemon with a lot of features */
+/* pfixtools: a collection of postfix related tools */
/* ~~~~~~~~~ */
/* ________________________________________________________________________ */
/* */
#include "mem.h"
#include "buffer.h"
+#define DAEMON_NAME "srsd"
#define DEFAULT_ENCODER_PORT 10000
#define DEFAULT_DECODER_PORT 10001
#define __tostr(x) #x
}
}
+void urldecode(char *s, char *end)
+{
+ char *p = s;
+
+ while (*p) {
+ if (*p == '%' && end - p >= 3) {
+ int h = (hexval(p[1]) << 4) | hexval(p[2]);
+
+ if (h >= 0) {
+ *s++ = h;
+ p += 3;
+ continue;
+ }
+ }
+
+ *s++ = *p++;
+ }
+ *s++ = '\0';
+}
+
int process_srs(srs_t *srs, const char *domain, srsd_t *srsd)
{
while (srsd->ibuf.len > 4) {
char buf[BUFSIZ], *p, *q, *nl;
int err;
+ nl = strchr(srsd->ibuf.data + 4, '\n');
+ if (!nl) {
+ if (srsd->ibuf.len > BUFSIZ) {
+ syslog(LOG_ERR, "unreasonnable amount of data without a \\n");
+ return -1;
+ }
+ return 0;
+ }
+
if (strncmp("get ", srsd->ibuf.data, 4)) {
syslog(LOG_ERR, "bad request, not starting with \"get \"");
return -1;
}
- nl = strchr(srsd->ibuf.data + 4, '\n');
- if (!nl)
- return 0;
-
for (p = srsd->ibuf.data + 4; p < nl && isspace(*p); p++);
for (q = nl++; q >= p && isspace(*q); *q-- = '\0');
if (p == q) {
+ buffer_addstr(&srsd->obuf, "400 empty request ???\n");
syslog(LOG_WARNING, "empty request");
goto skip;
}
+ urldecode(p, q);
+
if (srsd->decoder) {
err = srs_reverse(srs, buf, ssizeof(buf), p);
} else {
if (err == 0) {
buffer_addstr(&srsd->obuf, "200 ");
buffer_addstr(&srsd->obuf, buf);
- buffer_addstr(&srsd->obuf, "\r\n");
} else {
switch (SRS_ERROR_TYPE(err)) {
case SRS_ERRTYPE_SRS:
break;
}
buffer_addstr(&srsd->obuf, srs_strerror(err));
- buffer_addstr(&srsd->obuf, "\r\n");
}
+ buffer_addch(&srsd->obuf, '\n');
skip:
buffer_consume(&srsd->ibuf, nl - srsd->ibuf.data);
int sock;
addr.sin_port = htons(port);
- sock = tcp_listen((const struct sockaddr *)&addr, sizeof(addr));
+ sock = tcp_listen_nonblock((const struct sockaddr *)&addr, sizeof(addr));
if (sock < 0) {
return -1;
}
static int main_initialize(void)
{
- openlog("srsd", LOG_PID, LOG_MAIL);
+ openlog(DAEMON_NAME, LOG_PID, LOG_MAIL);
signal(SIGPIPE, SIG_IGN);
signal(SIGINT, &common_sighandler);
signal(SIGTERM, &common_sighandler);
void usage(void)
{
- fputs("usage: srsd [ -e <port> ] [ -d <port> ] domain secrets\n"
+ fputs("usage: "DAEMON_NAME" [ -e <port> ] [ -d <port> ] domain secrets\n"
"\n"
" -e <port> port to listen to for encoding requests\n"
" (default: "STR(DEFAULT_ENCODER_PORT)")\n"
srsd_t *tmp;
int sock;
- sock = accept(srsd->fd, NULL, NULL);
+ sock = accept_nonblock(srsd->fd);
if (sock < 0) {
UNIXERR("accept");
continue;
return EXIT_FAILURE;
}
+ if (daemon_detach() < 0) {
+ syslog(LOG_CRIT, "unable to fork");
+ return EXIT_FAILURE;
+ }
return main_loop(srs, argv[optind], port_enc, port_dec);
}