1 files changed, 134 insertions, 0 deletions
diff --git a/src/core/proxychat.c b/src/core/proxychat.c
new file mode 100644
index 0000000..d26a178
--- /dev/null
+++ b/src/core/proxychat.c
@@ -0,0 +1,134 @@
+#include "hybbx/proxychat.h"
+#include "hybbx/mains_proxy.h"
+#include "hybbx/service.h"
+#include "hybbx/session.h"
+
+#include <stdio.h>
+#include <string.h>
+
+typedef struct proxychat_fanout_ctx {
+    hybbx_session_t *from;
+    const char *line;
+    const char *from_address;
+} proxychat_fanout_ctx_t;
+
+static void proxychat_local_visitor(hybbx_session_t *session, void *userdata)
+{
+    proxychat_fanout_ctx_t *ctx = (proxychat_fanout_ctx_t *)userdata;
+    char line[HYBBX_PROXYMAIL_ADDRESS_MAX + HYBBX_LINE_MAX + 8];
+
+    if (session == NULL || ctx == NULL || ctx->line == NULL) {
+        return;
+    }
+
+    if (session == ctx->from) {
+        return;
+    }
+
+    if (hybbx_session_area(session) != HYBBX_AREA_PROXYCHAT) {
+        return;
+    }
+
+    if (hybbx_session_is_guest(session)) {
+        return;
+    }
+
+    snprintf(line, sizeof(line), "<%s> %s",
+             ctx->from_address != NULL ? ctx->from_address : "?",
+             ctx->line);
+    hybbx_session_write_line(session, line);
+}
+
+static void proxychat_show_local(hybbx_session_t *session,
+                                 const char *from_address,
+                                 const char *line)
+{
+    char out[HYBBX_PROXYMAIL_ADDRESS_MAX + HYBBX_LINE_MAX + 8];
+
+    snprintf(out, sizeof(out), "<%s> %s",
+             from_address != NULL ? from_address : "?", line);
+    hybbx_session_write_line(session, out);
+}
+
+hybbx_result_t hybbx_proxychat_post(hybbx_service_t *service,
+                                    hybbx_session_t *session,
+                                    const char *line)
+{
+    char from_address[HYBBX_PROXYMAIL_ADDRESS_MAX];
+    proxychat_fanout_ctx_t ctx;
+    hybbx_result_t rc;
+
+    if (session == NULL || line == NULL || line[0] == '\0') {
+        return HYBBX_ERR_INVALID;
+    }
+
+    if (service == NULL) {
+        return HYBBX_ERR_INVALID;
+    }
+
+    snprintf(from_address, sizeof(from_address), "%s@%s",
+             hybbx_session_display_name(session),
+             hybbx_service_get_name(service));
+
+    proxychat_show_local(session, from_address, line);
+
+    if (!hybbx_mains_proxy_mesh_active()) {
+        hybbx_session_write_line(session,
+            "Mains proxy is not running — message shown locally only.");
+        return HYBBX_OK;
+    }
+
+    ctx.from = session;
+    ctx.line = line;
+    ctx.from_address = from_address;
+    hybbx_service_visit_sessions(service, proxychat_local_visitor, &ctx);
+
+    rc = hybbx_mains_proxy_send_chat(service, from_address, line);
+    if (rc == HYBBX_ERR_UNSUPPORTED) {
+        hybbx_session_write_line(session,
+            "No outbound peer links — message shown locally only.");
+        return HYBBX_OK;
+    }
+    if (rc == HYBBX_ERR_NOT_FOUND) {
+        hybbx_session_write_line(session,
+            "No peer links available to relay your message.");
+        return HYBBX_OK;
+    }
+
+    return rc;
+}
+
+void hybbx_proxychat_receive(hybbx_service_t *service,
+                             const char *from_address,
+                             const char *line)
+{
+    proxychat_fanout_ctx_t ctx;
+
+    if (service == NULL || line == NULL || line[0] == '\0') {
+        return;
+    }
+
+    ctx.from = NULL;
+    ctx.line = line;
+    ctx.from_address = from_address;
+    hybbx_service_visit_sessions(service, proxychat_local_visitor, &ctx);
+}
+
+void hybbx_proxychat_show_banner(hybbx_session_t *session)
+{
+    if (session == NULL) {
+        return;
+    }
+
+    hybbx_session_write_line(session,
+        "Proxychat — talk with users on linked mains.");
+    if (hybbx_mains_proxy_mesh_active()) {
+        hybbx_session_write_line(session,
+            "Type a line to send; /leave or /main to exit.");
+    } else {
+        hybbx_session_write_line(session,
+            "No peer links active — check mains_proxy configuration.");
+        hybbx_session_write_line(session,
+            "Type a line to try; /leave or /main to exit.");
+    }
+}