#2

1 files changed, 470 insertions, 0 deletions

diff --git a/src/core/texts.c b/src/core/texts.c
new file mode 100644
index 0000000..f983744
--- /dev/null
+++ b/src/core/texts.c
@@ -0,0 +1,470 @@
+#include "hybbx/texts.h"
+#include "hybbx/session.h"
+#include "hybbx/service.h"
+#include "hybbx/auth.h"
+#include "hybbx/util.h"
+#include "hybbx/limits.h"
+#include "hybbx/hybbx.h"
+
+#include <stdio.h>
+#include <string.h>
+#include <time.h>
+
+void hybbx_texts_config_defaults(hybbx_texts_config_t *texts)
+{
+    if (texts == NULL) {
+        return;
+    }
+
+    hybbx_strlcpy(texts->path, HYBBX_DEFAULT_TEXTS_PATH, sizeof(texts->path));
+}
+
+hybbx_result_t hybbx_texts_resolve(const hybbx_texts_config_t *texts,
+                                   const char *filename,
+                                   char *out, size_t out_len)
+{
+    if (texts == NULL || filename == NULL || out == NULL || out_len == 0) {
+        return HYBBX_ERR_INVALID;
+    }
+
+    return hybbx_path_join(out, out_len, texts->path, filename);
+}
+
+static size_t append_token_expanded(char *out, size_t out_len, size_t pos,
+                                    const char *value)
+{
+    size_t value_len;
+
+    if (out == NULL || out_len == 0 || value == NULL) {
+        return pos;
+    }
+
+    value_len = strlen(value);
+
+    if (pos + value_len >= out_len) {
+        return out_len - 1;
+    }
+
+    memcpy(out + pos, value, value_len);
+    return pos + value_len;
+}
+
+static void expand_text_line(char *out, size_t out_len,
+                             const char *line,
+                             const char *version,
+                             const char *service_name,
+                             const char *username,
+                             const char *os_name,
+                             const char *time_text,
+                             const char *date_text)
+{
+    size_t pos = 0;
+    size_t i = 0;
+
+    if (out == NULL || out_len == 0 || line == NULL) {
+        return;
+    }
+
+    out[0] = '\0';
+
+    if (version == NULL) {
+        version = HYBBX_VERSION_STRING;
+    }
+    if (service_name == NULL || service_name[0] == '\0') {
+        service_name = HYBBX_DEFAULT_SERVICE_NAME;
+    }
+    if (username == NULL) {
+        username = "";
+    }
+    if (os_name == NULL) {
+        os_name = "";
+    }
+    if (time_text == NULL) {
+        time_text = "";
+    }
+    if (date_text == NULL) {
+        date_text = "";
+    }
+
+    while (line[i] != '\0' && pos + 1 < out_len) {
+        if (strncmp(line + i, HYBBX_BANNER_TOKEN_VERSION,
+                    strlen(HYBBX_BANNER_TOKEN_VERSION)) == 0) {
+            pos = append_token_expanded(out, out_len, pos, version);
+            i += strlen(HYBBX_BANNER_TOKEN_VERSION);
+            continue;
+        }
+
+        if (strncmp(line + i, HYBBX_BANNER_TOKEN_SERVICE,
+                    strlen(HYBBX_BANNER_TOKEN_SERVICE)) == 0) {
+            pos = append_token_expanded(out, out_len, pos, service_name);
+            i += strlen(HYBBX_BANNER_TOKEN_SERVICE);
+            continue;
+        }
+
+        if (strncmp(line + i, HYBBX_TEXT_TOKEN_USERNAME,
+                    strlen(HYBBX_TEXT_TOKEN_USERNAME)) == 0) {
+            pos = append_token_expanded(out, out_len, pos, username);
+            i += strlen(HYBBX_TEXT_TOKEN_USERNAME);
+            continue;
+        }
+
+        if (strncmp(line + i, HYBBX_TEXT_TOKEN_OS,
+                    strlen(HYBBX_TEXT_TOKEN_OS)) == 0) {
+            pos = append_token_expanded(out, out_len, pos, os_name);
+            i += strlen(HYBBX_TEXT_TOKEN_OS);
+            continue;
+        }
+
+        if (strncmp(line + i, HYBBX_TEXT_TOKEN_TIME,
+                    strlen(HYBBX_TEXT_TOKEN_TIME)) == 0) {
+            pos = append_token_expanded(out, out_len, pos, time_text);
+            i += strlen(HYBBX_TEXT_TOKEN_TIME);
+            continue;
+        }
+
+        if (strncmp(line + i, HYBBX_TEXT_TOKEN_DATE,
+                    strlen(HYBBX_TEXT_TOKEN_DATE)) == 0) {
+            pos = append_token_expanded(out, out_len, pos, date_text);
+            i += strlen(HYBBX_TEXT_TOKEN_DATE);
+            continue;
+        }
+
+        out[pos++] = line[i++];
+    }
+
+    out[pos] = '\0';
+}
+
+static void format_text_tokens(char *time_text, size_t time_len,
+                               char *date_text, size_t date_len,
+                               const struct tm *tm)
+{
+    if (time_text != NULL && time_len > 0) {
+        time_text[0] = '\0';
+        if (tm != NULL) {
+            (void)hybbx_time_format_time(time_text, time_len, tm, NULL);
+        }
+    }
+
+    if (date_text != NULL && date_len > 0) {
+        date_text[0] = '\0';
+        if (tm != NULL) {
+            (void)hybbx_time_format_date(date_text, date_len, tm, NULL);
+        }
+    }
+}
+
+static void fill_os_name(char *os_name, size_t os_len)
+{
+    if (os_name == NULL || os_len == 0) {
+        return;
+    }
+
+    if (hybbx_platform_os_name(os_name, os_len) != HYBBX_OK) {
+        hybbx_strlcpy(os_name, "unknown", os_len);
+    }
+}
+
+static void expand_banner_line(char *out, size_t out_len,
+                               const char *line,
+                               const char *version,
+                               const char *service_name,
+                               const char *time_text,
+                               const char *date_text)
+{
+    expand_text_line(out, out_len, line, version, service_name, NULL, NULL,
+                     time_text, date_text);
+}
+
+typedef struct texts_line_emitter {
+    hybbx_session_t *session;
+    unsigned pending_blank;
+} texts_line_emitter_t;
+
+static void texts_emit_expanded_line(texts_line_emitter_t *emitter,
+                                     const char *expanded)
+{
+    unsigned i;
+
+    if (emitter == NULL || emitter->session == NULL || expanded == NULL) {
+        return;
+    }
+
+    if (expanded[0] == '\0') {
+        emitter->pending_blank++;
+        return;
+    }
+
+    for (i = 0; i < emitter->pending_blank; i++) {
+        hybbx_session_write(emitter->session, "\n");
+    }
+    emitter->pending_blank = 0;
+    hybbx_session_write_line(emitter->session, expanded);
+}
+
+static void texts_trim_trailing_cr(char *expanded)
+{
+    size_t n;
+
+    if (expanded == NULL) {
+        return;
+    }
+
+    n = strlen(expanded);
+    while (n > 0 && (expanded[n - 1] == '\n' || expanded[n - 1] == '\r')) {
+        expanded[--n] = '\0';
+    }
+}
+
+static hybbx_result_t send_banner_fallback(hybbx_session_t *session,
+                                           const char *version,
+                                           const char *service_name)
+{
+    char line[HYBBX_LINE_MAX];
+
+    if (version == NULL) {
+        version = HYBBX_VERSION_STRING;
+    }
+    if (service_name == NULL || service_name[0] == '\0') {
+        service_name = HYBBX_DEFAULT_SERVICE_NAME;
+    }
+
+    snprintf(line, sizeof(line), "HyBBX %s", version);
+    hybbx_session_write_line(session, line);
+    snprintf(line, sizeof(line), "Online at %s", service_name);
+    hybbx_session_write_line(session, line);
+    return HYBBX_OK;
+}
+
+hybbx_result_t hybbx_texts_send_banner(const hybbx_texts_config_t *texts,
+                                       hybbx_session_t *session,
+                                       const char *version,
+                                       const char *service_name)
+{
+    char path[HYBBX_PATH_MAX];
+    char expanded[HYBBX_LINE_MAX];
+    FILE *fp;
+    char line[HYBBX_LINE_MAX];
+    char time_text[32];
+    char date_text[32];
+    struct tm now_tm;
+    const struct tm *tm_ptr = NULL;
+    hybbx_result_t rc;
+
+    if (texts == NULL || session == NULL) {
+        return HYBBX_ERR_INVALID;
+    }
+
+    if (hybbx_time_local_now(&now_tm) == HYBBX_OK) {
+        tm_ptr = &now_tm;
+    }
+    format_text_tokens(time_text, sizeof(time_text),
+                       date_text, sizeof(date_text), tm_ptr);
+
+    rc = hybbx_texts_resolve(texts, HYBBX_TEXT_BANNER, path, sizeof(path));
+    if (rc != HYBBX_OK) {
+        return send_banner_fallback(session, version, service_name);
+    }
+
+    fp = fopen(path, "r");
+    if (fp == NULL) {
+        return send_banner_fallback(session, version, service_name);
+    }
+
+    {
+        texts_line_emitter_t emitter;
+
+        emitter.session = session;
+        emitter.pending_blank = 0;
+
+        while (fgets(line, sizeof(line), fp) != NULL) {
+            expand_banner_line(expanded, sizeof(expanded), line, version,
+                              service_name, time_text, date_text);
+            texts_trim_trailing_cr(expanded);
+            texts_emit_expanded_line(&emitter, expanded);
+        }
+    }
+
+    fclose(fp);
+    return HYBBX_OK;
+}
+
+hybbx_result_t hybbx_texts_send_motd(const hybbx_texts_config_t *texts,
+                                     hybbx_session_t *session)
+{
+    char path[HYBBX_PATH_MAX];
+    char expanded[HYBBX_LINE_MAX];
+    FILE *fp;
+    char line[HYBBX_LINE_MAX];
+    char time_text[32];
+    char date_text[32];
+    struct tm now_tm;
+    const struct tm *tm_ptr = NULL;
+    const char *username;
+    hybbx_result_t rc;
+
+    if (texts == NULL || session == NULL) {
+        return HYBBX_ERR_INVALID;
+    }
+
+    username = hybbx_session_display_name(session);
+    if (username[0] == '\0') {
+        username = "visitor";
+    }
+
+    if (hybbx_time_local_now(&now_tm) == HYBBX_OK) {
+        tm_ptr = &now_tm;
+    }
+    format_text_tokens(time_text, sizeof(time_text),
+                       date_text, sizeof(date_text), tm_ptr);
+
+    rc = hybbx_texts_resolve(texts, HYBBX_TEXT_MOTD, path, sizeof(path));
+    if (rc != HYBBX_OK) {
+        return rc;
+    }
+
+    fp = fopen(path, "r");
+    if (fp == NULL) {
+        return HYBBX_ERR_NOT_FOUND;
+    }
+
+    {
+        texts_line_emitter_t emitter;
+
+        emitter.session = session;
+        emitter.pending_blank = 0;
+
+        while (fgets(line, sizeof(line), fp) != NULL) {
+            expand_text_line(expanded, sizeof(expanded), line, NULL, NULL,
+                             username, NULL, time_text, date_text);
+            texts_trim_trailing_cr(expanded);
+            texts_emit_expanded_line(&emitter, expanded);
+        }
+    }
+
+    fclose(fp);
+    return HYBBX_OK;
+}
+
+hybbx_result_t hybbx_texts_send_file(const hybbx_texts_config_t *texts,
+                                     hybbx_session_t *session,
+                                     const char *filename)
+{
+    char path[HYBBX_PATH_MAX];
+    char expanded[HYBBX_LINE_MAX];
+    FILE *fp;
+    char line[HYBBX_LINE_MAX];
+    char time_text[32];
+    char date_text[32];
+    char os_name[64];
+    struct tm now_tm;
+    const struct tm *tm_ptr = NULL;
+    hybbx_result_t rc;
+
+    if (texts == NULL || session == NULL || filename == NULL) {
+        return HYBBX_ERR_INVALID;
+    }
+
+    if (hybbx_time_local_now(&now_tm) == HYBBX_OK) {
+        tm_ptr = &now_tm;
+    }
+    format_text_tokens(time_text, sizeof(time_text),
+                       date_text, sizeof(date_text), tm_ptr);
+    fill_os_name(os_name, sizeof(os_name));
+
+    rc = hybbx_texts_resolve(texts, filename, path, sizeof(path));
+    if (rc != HYBBX_OK) {
+        return rc;
+    }
+
+    fp = fopen(path, "r");
+    if (fp == NULL) {
+        return HYBBX_ERR_NOT_FOUND;
+    }
+
+    {
+        texts_line_emitter_t emitter;
+
+        emitter.session = session;
+        emitter.pending_blank = 0;
+
+        while (fgets(line, sizeof(line), fp) != NULL) {
+            expand_text_line(expanded, sizeof(expanded), line,
+                             HYBBX_VERSION_STRING, NULL, NULL, os_name,
+                             time_text, date_text);
+            texts_trim_trailing_cr(expanded);
+            texts_emit_expanded_line(&emitter, expanded);
+        }
+    }
+
+    fclose(fp);
+    return HYBBX_OK;
+}
+
+static hybbx_result_t send_version_fallback(hybbx_session_t *session,
+                                            const char *os_name)
+{
+    char line[HYBBX_LINE_MAX];
+
+    snprintf(line, sizeof(line), "HyBBX %s", HYBBX_VERSION_STRING);
+    hybbx_session_write_line(session, line);
+    snprintf(line, sizeof(line), "Operating system: %s",
+             (os_name != NULL && os_name[0] != '\0') ? os_name : "unknown");
+    hybbx_session_write_line(session, line);
+    return HYBBX_OK;
+}
+
+hybbx_result_t hybbx_texts_send_version(const hybbx_texts_config_t *texts,
+                                        hybbx_session_t *session)
+{
+    char path[HYBBX_PATH_MAX];
+    char expanded[HYBBX_LINE_MAX];
+    FILE *fp;
+    char line[HYBBX_LINE_MAX];
+    char time_text[32];
+    char date_text[32];
+    char os_name[64];
+    struct tm now_tm;
+    const struct tm *tm_ptr = NULL;
+    hybbx_result_t rc;
+
+    if (texts == NULL || session == NULL) {
+        return HYBBX_ERR_INVALID;
+    }
+
+    fill_os_name(os_name, sizeof(os_name));
+
+    if (hybbx_time_local_now(&now_tm) == HYBBX_OK) {
+        tm_ptr = &now_tm;
+    }
+    format_text_tokens(time_text, sizeof(time_text),
+                       date_text, sizeof(date_text), tm_ptr);
+
+    rc = hybbx_texts_resolve(texts, HYBBX_TEXT_VERSION, path, sizeof(path));
+    if (rc != HYBBX_OK) {
+        return send_version_fallback(session, os_name);
+    }
+
+    fp = fopen(path, "r");
+    if (fp == NULL) {
+        return send_version_fallback(session, os_name);
+    }
+
+    {
+        texts_line_emitter_t emitter;
+
+        emitter.session = session;
+        emitter.pending_blank = 0;
+
+        while (fgets(line, sizeof(line), fp) != NULL) {
+            expand_text_line(expanded, sizeof(expanded), line,
+                             HYBBX_VERSION_STRING, NULL, NULL, os_name,
+                             time_text, date_text);
+            texts_trim_trailing_cr(expanded);
+            texts_emit_expanded_line(&emitter, expanded);
+        }
+    }
+
+    fclose(fp);
+    return HYBBX_OK;
+}