1 files changed, 209 insertions, 0 deletions
diff --git a/syslogd/main.c b/syslogd/main.c
new file mode 100644
index 0000000..a5702b7
--- /dev/null
+++ b/syslogd/main.c
@@ -0,0 +1,209 @@
+/* SPDX-License-Identifier: GPL-3.0-or-later */
+/*
+ * Copyright (C) 2018 - David Oberhollenzer
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <https://www.gnu.org/licenses/>.
+ */
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <sys/socket.h>
+#include <unistd.h>
+#include <stdlib.h>
+#include <signal.h>
+#include <string.h>
+#include <errno.h>
+#include <stdio.h>
+#include <ctype.h>
+
+#include "logfile.h"
+#include "util.h"
+
+
+#define SYSLOG_SOCKET "/dev/log"
+#define SYSLOG_PATH "/var/log"
+
+
+static volatile sig_atomic_t syslog_run = 1;
+static logfile_t *logfiles = NULL;
+
+static const enum_map_t facilities[] = {
+	{ "kernel.log", 0 },
+	{ "user.log", 1 },
+	{ "mail.log", 2 },
+	{ "daemon.log", 3 },
+	{ "auth.log", 4 },
+	{ "syslog.log", 5 },
+	{ "lpr.log", 6 },
+	{ "news.log", 7 },
+	{ "uucp.log", 8 },
+	{ "clock.log", 9 },
+	{ "authpriv.log", 10 },
+	{ "ftp.log", 11 },
+	{ "ntp.log", 12 },
+	{ "audit.log", 13 },
+	{ "alert.log", 14 },
+	{ "cron.log", 15 },
+	{ "local0.log", 16 },
+	{ "local1.log", 17 },
+	{ "local2.log", 18 },
+	{ "local3.log", 19 },
+	{ "local4.log", 20 },
+	{ "local5.log", 21 },
+	{ "local6.log", 22 },
+	{ "local7.log", 23 },
+	{ NULL, 0 },
+};
+
+static const enum_map_t levels[] = {
+	{ "emergency", 0 },
+	{ "alert", 1 },
+	{ "critical", 2 },
+	{ "error", 3 },
+	{ "warning", 4 },
+	{ "notice", 5 },
+	{ "info", 6 },
+	{ "debug", 7 },
+	{ NULL, 0 },
+};
+
+
+static int directory_setup(void)
+{
+	if (mkdir(SYSLOG_PATH, 0755)) {
+		if (errno != EEXIST) {
+			perror("mkdir " SYSLOG_PATH);
+			return -1;
+		}
+	}
+
+	if (chdir(SYSLOG_PATH)) {
+		perror("cd " SYSLOG_PATH);
+		return -1;
+	}
+
+	return 0;
+}
+
+static void sighandler(int signo)
+{
+	switch (signo) {
+	case SIGINT:
+	case SIGTERM:
+		syslog_run = 0;
+		break;
+	default:
+		break;
+	}
+}
+
+static void signal_setup(void)
+{
+	struct sigaction act;
+
+	memset(&act, 0, sizeof(act));
+	act.sa_handler = sighandler;
+
+	sigaction(SIGINT, &act, NULL);
+	sigaction(SIGTERM, &act, NULL);
+}
+
+static int print_to_log(int facility, int level, const char *data)
+{
+	const char *fac_name, *lvl_str;
+	logfile_t *log;
+
+	fac_name = enum_to_name(facilities, facility);
+	if (fac_name == NULL)
+		return -1;
+
+	lvl_str = enum_to_name(levels, level);
+	if (lvl_str == NULL)
+		return -1;
+
+	for (log = logfiles; log != NULL; log = log->next) {
+		if (!strcmp(log->name, fac_name))
+			break;
+	}
+
+	if (log == NULL) {
+		log = logfile_create(fac_name);
+		if (log == NULL)
+			return -1;
+		log->next = logfiles;
+		logfiles = log;
+	}
+
+	logfile_write(log, "[%s] %s", lvl_str, data);
+	return 0;
+}
+
+static int handle_data(int fd)
+{
+	char buffer[2048], *ptr;
+	int i = 0, priority;
+	ssize_t ret;
+
+	memset(buffer, 0, sizeof(buffer));
+
+	ret = read(fd, buffer, sizeof(buffer));
+	if (ret <= 0)
+		return -1;
+
+	for (ptr = buffer; isspace(*ptr); ++ptr)
+		;
+	if (*(ptr++) != '<')
+		return -1;
+	if (!isdigit(*ptr))
+		return -1;
+	for (priority = 0; isdigit(*ptr); ++ptr)
+		priority = priority * 10 + (*ptr) - '0';
+	if (*(ptr++) != '>')
+		return -1;
+	while (isspace(*ptr))
+		++ptr;
+
+	return print_to_log(priority >> 3, priority & 0x07, ptr);
+}
+
+int main(void)
+{
+	int sfd, status = EXIT_FAILURE;
+	logfile_t *log;
+
+	signal_setup();
+
+	sfd = mksock(SYSLOG_SOCKET, SOCK_FLAG_EVERYONE | SOCK_FLAG_DGRAM);
+	if (sfd < 0)
+		return EXIT_FAILURE;
+
+	if (directory_setup())
+		goto out;
+
+	while (syslog_run) {
+		handle_data(sfd);
+	}
+
+	status = EXIT_SUCCESS;
+out:
+	while (logfiles != NULL) {
+		log = logfiles;
+		logfiles = logfiles->next;
+
+		logfile_destroy(log);
+	}
+	if (sfd > 0)
+		close(sfd);
+	unlink(SYSLOG_SOCKET);
+	return status;
+}