From 8adafaf515f65e3dc94956bd7c969c77dca1059f Mon Sep 17 00:00:00 2001 From: Anthony Ettinger Date: Sun, 14 Jun 2026 11:21:39 +0000 Subject: [PATCH 1/2] feat(irc): members-only Ergo IRC network co-located on the BBS MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Provision a self-hosted Ergo IRC network (irc.${DOMAIN}) in setup.sh §9b: single Go binary on its own ports/user, reusing Caddy's Let's Encrypt cert for 6697 TLS (refreshed by a timer; self-signed fallback on first boot), loopback 6667 + a loopback WebSocket fronted by Caddy at wss://${DOMAIN}/irc. Access is MEMBERS-ONLY: every client must authenticate with SASL, self-service registration is off, and an auth-script (deploy/ergo/auth-script.sh, installed as /usr/local/bin/ergo-auth-member) approves a login only if the account name maps to an existing AgentBBS member home dir under /users/. Passphrase is ignored — membership (the filesystem dir) is the credential. require-sasl has no IP exemption so WebSocket clients (which reach Ergo via Caddy from 127.0.0.1) can't bypass the gate; accounts are auto-created on first successful auth. Public attack surface is TLS-only (ufw opens 6697; 6667 is loopback). Toggle with IRC=0. See docs/irc.md. Co-Authored-By: Claude Opus 4.8 --- README.md | 19 + deploy/ergo/auth-script.sh | 48 ++ deploy/ergo/ircd.yaml | 1189 ++++++++++++++++++++++++++++++++++ deploy/ergo/refresh-certs.sh | 42 ++ docs/irc.md | 126 ++++ setup.sh | 148 ++++- 6 files changed, 1570 insertions(+), 2 deletions(-) create mode 100644 deploy/ergo/auth-script.sh create mode 100644 deploy/ergo/ircd.yaml create mode 100755 deploy/ergo/refresh-certs.sh create mode 100644 docs/irc.md diff --git a/README.md b/README.md index 48e58ec..e21bd39 100644 --- a/README.md +++ b/README.md @@ -33,6 +33,7 @@ plugins around one shared account system; the full product plan is in | `agent@` chat (configurable agent backend) + finger | ✅ | | M2 — admin console (`admin@`: users, sessions, moderation, plugins) | ✅ | | M3 — AgentGames (`game@` + WebSocket; TTT/C4, ELO ladder, replays) | ✅ | +| IRC (`irc.bbs.profullstack.com` — Ergo network for humans + agents) | ✅ | | M4 — Files (cl1.tech SFTP workspaces) | ⬜ | | M5 — AgentAd marketplace (built on the AgentAd standard in logicsrc) | ⬜ | @@ -99,6 +100,24 @@ The production host (`bbs.profullstack.com`) is provisioned by the idempotent Full details, required secrets, and ops commands: [`docs/deploy.md`](docs/deploy.md). +### IRC network + +`setup.sh` also stands up a co-located [Ergo](https://ergo.chat) IRC server (its +own `ergo.service`, ports 6697/TLS + a Caddy-fronted WebSocket) so humans and +agents can meet on a real IRC network. It is **members-only**: every client must +authenticate with SASL, and an auth-script approves a login only if the account +name is an existing AgentBBS member (registration is off — your BBS account *is* +your IRC identity): + +```bash +# native client — SASL account = your BBS member name +/connect irc.bbs.profullstack.com 6697 +# browser / agent over WebSocket +wss://bbs.profullstack.com/irc +``` + +Set `IRC=0` to skip it. Full details: [`docs/irc.md`](docs/irc.md). + ## Architecture - **Go + charmbracelet** — `wish` SSH server, `bubbletea` TUIs, `lipgloss` styling. diff --git a/deploy/ergo/auth-script.sh b/deploy/ergo/auth-script.sh new file mode 100644 index 0000000..77f4332 --- /dev/null +++ b/deploy/ergo/auth-script.sh @@ -0,0 +1,48 @@ +#!/usr/bin/env bash +# +# auth-script.sh — Ergo auth-script that gates the IRC network on AgentBBS +# membership. setup.sh installs this to /usr/local/bin/ergo-auth-member and +# wires it into /etc/ergo/ircd.yaml (accounts.auth-script). +# +# "Member" == a user with a home dir under the AgentBBS users dir (created when +# someone registers via `ssh join@`). IRC is members-only, so a login is +# approved iff the requested account name maps to such a dir. The passphrase is +# intentionally IGNORED — membership (a filesystem dir) IS the credential, by +# design (see docs/irc.md). Anyone who knows a member's name can connect as +# them; that tradeoff was chosen deliberately for this private, TLS-only network. +# +# Protocol (Ergo): one JSON object on stdin per attempt, one JSON line on stdout +# then exit. Input keys: accountName, passphrase, certfp, ip. Output: +# {"success":bool,"accountName":str,"error":str}. +# +# args: [""] # defaults to /var/lib/agentbbs/users +set -uo pipefail + +USERS_DIR="${1:-/var/lib/agentbbs/users}" + +# Always emit valid JSON and exit 0 — Ergo reads the JSON, not the exit code; +# a non-zero exit / no output is treated as a script error, not a clean deny. +deny() { printf '{"success":false,"error":"%s"}\n' "${1:-not a member}"; exit 0; } + +# Don't gate on read's exit code: a final line without a trailing newline still +# carries data (read returns non-zero at EOF but populates $line). +line="" +read -r line || true +[ -n "$line" ] || deny "no input" + +acct="$(printf '%s' "$line" | jq -r '.accountName // ""' 2>/dev/null || true)" + +# certfp-only attempts carry no account name; we don't support cert auth here. +[ -n "$acct" ] || deny "membership requires an account name" + +# Defense in depth against path traversal. IRC account names are a restricted +# charset anyway, but never let one escape USERS_DIR. +case "$acct" in + *[!A-Za-z0-9._-]* | "." | ".." | *..* | */* ) deny "invalid account name" ;; +esac + +if [ -d "$USERS_DIR/$acct" ]; then + printf '{"success":true,"accountName":"%s"}\n' "$acct" +else + deny "not a member" +fi diff --git a/deploy/ergo/ircd.yaml b/deploy/ergo/ircd.yaml new file mode 100644 index 0000000..9d68282 --- /dev/null +++ b/deploy/ergo/ircd.yaml @@ -0,0 +1,1189 @@ +# AgentBBS IRC network — Ergo (https://ergo.chat) config TEMPLATE. +# +# This is a TEMPLATE: setup.sh renders it to /etc/ergo/ircd.yaml on deploy, +# substituting the __TOKENS__ below. Do not point Ergo at this file directly — +# the __TOKENS__ are not valid YAML values until rendered. +# +# __NETWORK__ network name shown to clients (e.g. ProfullstackBBS) +# __DOMAIN__ the BBS domain (e.g. bbs.profullstack.com) +# __DATA__ Ergo state dir (ircd.db lives here) +# __TLS_DIR__ dir holding fullchain.pem / privkey.pem for 6697 +# __LANG_DIR__ Ergo's bundled languages/ dir (from the release) +# __OPER_PASSWORD_HASH__ bcrypt hash for /OPER admin (ergo genpasswd) +# __USERS_DIR__ AgentBBS member home dirs (the IRC membership gate) +# +# It is based on Ergo's upstream default.yaml (v2.18.0) with the AgentBBS +# listeners (public 6697 TLS, loopback 6667, loopback 8097 WebSocket fronted +# by Caddy at wss://__DOMAIN__/irc) and the network identity wired in. Tuned +# for a mixed humans + agents network: it is MEMBERS-ONLY — every client must +# authenticate with SASL, self-service registration is OFF, and an auth-script +# (deploy/ergo/auth-script.sh, installed as /usr/local/bin/ergo-auth-member) +# approves a login only if the account name maps to an existing AgentBBS member +# home dir under __USERS_DIR__. Message history (CHATHISTORY) is enabled so +# reconnecting agents and web clients can replay. See docs/irc.md. +# +# Most settings keep Ergo's recommended defaults — read the inline comments +# before changing one. A few worth knowing about: +# 1. network.name / server.name — the network identity (rendered from tokens). +# 2. server.listeners — the 6697 cert/key are refreshed from Caddy's Let's +# Encrypt cert for __DOMAIN__ by setup.sh (self-signed fallback on first run). +# 3. opers — the /OPER admin password hash (rendered from a token). +# 4. history — in-memory, messages expire after ~7 days. Switch to MySQL-backed +# persistent history (datastore.mysql) if you need durability across restarts. + +# network configuration +network: + # name of the network + name: __NETWORK__ + +# server configuration +server: + # server name + name: irc.__DOMAIN__ + + # addresses to listen on + listeners: + # Public TLS (6697) — the front door for native IRC clients (humans) and + # SASL-authenticating agents. Cert/key are refreshed from Caddy's + # Let's Encrypt cert for __DOMAIN__ by setup.sh (falls back to self-signed). + ":6697": + tls: + cert: __TLS_DIR__/fullchain.pem + key: __TLS_DIR__/privkey.pem + min-tls-version: 1.2 + + # Loopback plaintext (6667) — never exposed (firewall blocks it). Used by + # the in-BBS bridge and local tooling on the agentbbs box only. + "127.0.0.1:6667": + "[::1]:6667": + + # WebSocket (loopback) — Caddy terminates TLS and reverse-proxies + # wss://__DOMAIN__/irc to here, giving humans a browser client and agents + # a WebSocket transport without opening another public port. + "127.0.0.1:8097": + websocket: true + unix-bind-mode: 0777 + + # configure the behavior of Tor listeners (ignored if you didn't enable any): + tor-listeners: + # if this is true, connections from Tor must authenticate with SASL + require-sasl: false + + # what hostname should be displayed for Tor connections? + vhost: "tor-network.onion" + + # allow at most this many connections at once (0 for no limit): + max-connections: 64 + + # connection throttling (limit how many connection attempts are allowed at once): + throttle-duration: 10m + # set to 0 to disable throttling: + max-connections-per-duration: 64 + + # strict transport security, to get clients to automagically use TLS + # (irrelevant in the recommended configuration, with no public plaintext listener) + sts: + # whether to advertise STS + # + # to stop advertising STS, leave this enabled and set 'duration' below to "0". this will + # advertise to connecting users that the STS policy they have saved is no longer valid + enabled: false + + # how long clients should be forced to use TLS for. + # setting this to a too-long time will mean bad things if you later remove your TLS. + # the default duration below is 1 month, 2 days and 5 minutes. + duration: 1mo2d5m + + # tls port - you should be listening on this port above + port: 6697 + + # should clients include this STS policy when they ship their inbuilt preload lists? + preload: false + + websockets: + # Restrict the origin of WebSocket connections by matching the "Origin" HTTP + # header. This setting causes ergo to reject websocket connections unless + # they originate from a page on one of the whitelisted websites in this list. + # This prevents malicious websites from making their visitors connect to your + # ergo instance without their knowledge. An empty list means there are no + # restrictions. + allowed-origins: + - "https://__DOMAIN__" + # - "https://ergo.chat" + # - "https://*.ergo.chat" + + # casemapping controls what kinds of strings are permitted as identifiers (nicknames, + # channel names, account names, etc.), and how they are normalized for case. + # the recommended default is 'ascii' (traditional ASCII-only identifiers). + # the other options are 'precis', which allows UTF8 identifiers that are "sane" + # (according to UFC 8265), with additional mitigations for homoglyph attacks, + # 'permissive', which allows identifiers containing unusual characters like + # emoji, at the cost of increased vulnerability to homoglyph attacks and potential + # client compatibility problems, and the legacy mappings 'rfc1459' and + # 'rfc1459-strict'. we recommend leaving this value at its default; + # however, note that changing it once the network is already up and running is + # problematic. + casemapping: "ascii" + + # enforce-utf8 controls whether the server will preemptively discard non-UTF8 + # messages (since they cannot be relayed to websocket clients), or will allow + # them and relay them to non-websocket clients (as in traditional IRC). + enforce-utf8: true + + # whether to look up user hostnames with reverse DNS. there are 3 possibilities: + # 1. lookup-hostnames enabled, IP cloaking disabled; users will see each other's hostnames + # 2. lookup-hostnames disabled, IP cloaking disabled; users will see each other's numeric IPs + # 3. [the default] IP cloaking enabled; users will see cloaked hostnames + lookup-hostnames: false + # whether to confirm hostname lookups using "forward-confirmed reverse DNS", i.e., for + # any hostname returned from reverse DNS, resolve it back to an IP address and reject it + # unless it matches the connecting IP + forward-confirm-hostnames: true + + # use ident protocol to get usernames + check-ident: false + + # ignore the supplied user/ident string from the USER command, always setting user/ident + # to the following literal value; this can potentially reduce confusion and simplify bans. + # the value must begin with a '~' character. comment out / omit to disable: + coerce-ident: '~u' + + # 'password' allows you to require a global, shared password (the IRC `PASS` command) + # to connect to the server. for operator passwords, see the `opers` section of the + # config. for a more secure way to create a private server, see the `require-sasl` + # section. you must hash the password with `ergo genpasswd`, then enter the hash here: + #password: "$2a$04$0123456789abcdef0123456789abcdef0123456789abcdef01234" + + # motd filename + # if you change the motd, you should move it to ircd.motd + motd: ergo.motd + + # motd formatting codes + # if this is true, the motd is escaped using formatting codes like $c, $b, and $i + motd-formatting: true + + # send a configurable notice to clients immediately after they connect, + # as a way of detecting open proxies + #initial-notice: "*** Welcome to the Ergo IRC server" + + # idle timeouts for inactive clients + idle-timeouts: + # give the client this long to complete connection registration (i.e. the initial + # IRC handshake, including capability negotiation and SASL) + registration: 60s + # if the client hasn't sent anything for this long, send them a PING + ping: 1m30s + # if the client hasn't sent anything for this long (including the PONG to the + # above PING), disconnect them + disconnect: 2m30s + + # relaying using the RELAYMSG command + relaymsg: + # is relaymsg enabled at all? + enabled: true + + # which character(s) are reserved for relayed nicks? + separators: "/" + + # can channel operators use RELAYMSG in their channels? + # our implementation of RELAYMSG makes it safe for chanops to use without the + # possibility of real users being silently spoofed + available-to-chanops: true + + # IPs/CIDRs the PROXY command can be used from + # This should be restricted to localhost (127.0.0.1/8, ::1/128, and unix sockets). + # Unless you have a good reason. you should also add these addresses to the + # connection limits and throttling exemption lists. + proxy-allowed-from: + - localhost + # - "192.168.1.1" + # - "192.168.10.1/24" + + # controls the use of the WEBIRC command (by IRC<->web interfaces, bouncers and similar) + webirc: + # one webirc block -- should correspond to one set of gateways + - + # SHA-256 fingerprint of the TLS certificate the gateway must use to connect + # (comment this out to use passwords only) + certfp: "abcdef0123456789abcdef0123456789abcdef0123456789abcdef0123456789" + + # password the gateway uses to connect, made with `ergo genpasswd` + password: "$2a$04$abcdef0123456789abcdef0123456789abcdef0123456789abcde" + + # IPs/CIDRs that can use this webirc command + # you should also add these addresses to the connection limits and throttling exemption lists + hosts: + - localhost + # - "192.168.1.1" + # - "192.168.10.1/24" + + # whether to accept the hostname parameter on the WEBIRC line as the IRC hostname + # (the default/recommended Ergo configuration will use cloaks instead) + accept-hostname: false + + # maximum length of clients' sendQ in bytes + # this should be big enough to hold bursts of channel/direct messages + max-sendq: 96k + + # compatibility with legacy clients + compatibility: + # many clients require that the final parameter of certain messages be an + # RFC1459 trailing parameter, i.e., prefixed with :, whether or not this is + # actually required. this forces Ergo to send those parameters + # as trailings. this is recommended unless you're testing clients for conformance; + # defaults to true when unset for that reason. + force-trailing: true + + # some clients (ZNC 1.6.x and lower, Pidgin 2.12 and lower) do not + # respond correctly to SASL messages with the server name as a prefix: + # https://github.com/znc/znc/issues/1212 + # this works around that bug, allowing them to use SASL. + send-unprefixed-sasl: true + + # traditionally, IRC servers will truncate and send messages that are + # too long to be relayed intact. this behavior can be disabled by setting + # allow-truncation to false, in which case Ergo will reject the message + # and return an error to the client. (note that this option defaults to true + # when unset.) + allow-truncation: false + + # IP-based DoS protection + ip-limits: + # whether to limit the total number of concurrent connections per IP/CIDR + count: true + # maximum concurrent connections per IP/CIDR + max-concurrent-connections: 16 + + # whether to restrict the rate of new connections per IP/CIDR + throttle: true + # how long to keep track of connections for + window: 10m + # maximum number of new connections per IP/CIDR within the given duration + max-connections-per-window: 32 + + # how wide the CIDR should be for IPv4 (a /32 is a fully specified IPv4 address) + cidr-len-ipv4: 32 + # how wide the CIDR should be for IPv6 (a /64 is the typical prefix assigned + # by an ISP to an individual customer for their LAN) + cidr-len-ipv6: 64 + + # IPs/networks which are exempted from connection limits + exempted: + - "localhost" + # - "192.168.1.1" + # - "2001:0db8::/32" + + # custom connection limits for certain IPs/networks. + custom-limits: + #"irccloud": + # nets: + # - "192.184.9.108" # highgate.irccloud.com + # - "192.184.9.110" # ealing.irccloud.com + # - "192.184.9.112" # charlton.irccloud.com + # - "192.184.10.118" # brockwell.irccloud.com + # - "192.184.10.9" # tooting.irccloud.com + # - "192.184.8.73" # hathersage.irccloud.com + # - "192.184.8.103" # stonehaven.irccloud.com + # - "5.254.36.57" # tinside.irccloud.com + # - "5.254.36.56/29" # additional ipv4 net + # - "2001:67c:2f08::/48" + # - "2a03:5180:f::/64" + # max-concurrent-connections: 2048 + # max-connections-per-window: 2048 + + # pluggable IP ban mechanism, via subprocess invocation + # this can be used to check new connections against a DNSBL, for example + # see the manual for details on how to write an IP ban checking script + ip-check-script: + enabled: false + command: "/usr/local/bin/check-ip-ban" + # constant list of args to pass to the command; the actual query + # and result are transmitted over stdin/stdout: + args: [] + # timeout for process execution, after which we send a SIGTERM: + timeout: 9s + # how long after the SIGTERM before we follow up with a SIGKILL: + kill-timeout: 1s + # how many scripts are allowed to run at once? 0 for no limit: + max-concurrency: 64 + # if true, only check anonymous connections (not logged into an account) + # at the very end of the handshake: + exempt-sasl: false + + # IP cloaking hides users' IP addresses from other users and from channel admins + # (but not from server admins), while still allowing channel admins to ban + # offending IP addresses or networks. In place of hostnames derived from reverse + # DNS, users see fake domain names like pwbs2ui4377257x8.irc. These names are + # generated deterministically from the underlying IP address, but if the underlying + # IP is not already known, it is infeasible to recover it from the cloaked name. + # If you disable this, you should probably enable lookup-hostnames in its place. + ip-cloaking: + # whether to enable IP cloaking + enabled: true + + # whether to use these cloak settings (specifically, `netname` and `num-bits`) + # to produce unique hostnames for always-on clients. you can enable this even if + # you disabled IP cloaking for normal clients above. if this is disabled, + # always-on clients will all have an identical hostname (the server name). + enabled-for-always-on: true + + # fake TLD at the end of the hostname, e.g., pwbs2ui4377257x8.irc + # you may want to use your network name here + netname: "irc" + + # the cloaked hostname is derived only from the CIDR (most significant bits + # of the IP address), up to a configurable number of bits. this is the + # granularity at which bans will take effect for IPv4. Note that changing + # this value will invalidate any stored bans. + cidr-len-ipv4: 32 + + # analogous granularity for IPv6 + cidr-len-ipv6: 64 + + # number of bits of hash output to include in the cloaked hostname. + # more bits means less likelihood of distinct IPs colliding, + # at the cost of a longer cloaked hostname. if this value is set to 0, + # all users will receive simply `netname` as their cloaked hostname. + num-bits: 64 + + # secure-nets identifies IPs and CIDRs which are secure at layer 3, + # for example, because they are on a trusted internal LAN or a VPN. + # plaintext connections from these IPs and CIDRs will be considered + # secure (clients will receive the +Z mode and be allowed to resume + # or reattach to secure connections). note that loopback IPs are always + # considered secure: + secure-nets: + # - "10.0.0.0/8" + + # allow attempts to OPER with a password at most this often. defaults to + # 10 seconds when unset. + oper-throttle: 10s + + # Ergo will write files to disk under certain circumstances, e.g., + # CPU profiling or data export. by default, these files will be written + # to the working directory. set this to customize: + #output-path: "/home/ergo/out" + + # the hostname used by "services", e.g., NickServ, defaults to "localhost", + # e.g., `NickServ!NickServ@localhost`. uncomment this to override: + #override-services-hostname: "example.network" + + # in a "closed-loop" system where you control the server and all the clients, + # you may want to increase the maximum (non-tag) length of an IRC line from + # the default value of 512. DO NOT change this on a public server: + #max-line-len: 512 + + # send all 0's as the LUSERS (user counts) output to non-operators; potentially useful + # if you don't want to publicize how popular the server is + suppress-lusers: false + + # publish additional key-value pairs in ISUPPORT (the 005 numeric). + # keys that collide with a key published by Ergo will be silently ignored. + additional-isupport: + #"draft/FILEHOST": "https://example.com/filehost" + #"draft/bazbat": "" # empty string means no value + + # optionally map command alias names to existing ergo commands. most deployments + # should ignore this. + #command-aliases: + #"UMGEBUNG": "AMBIANCE" + +# account options +accounts: + # is account authentication enabled, i.e., can users log into existing accounts? + authentication-enabled: true + + # account registration + registration: + # MEMBERS-ONLY: self-service registration is OFF. The only way to get an + # account is the auth-script (autocreate) below, gated on AgentBBS + # membership. Operators with `accreg` can still /NICKSERV SAREGISTER. + # (require-sasl below mandates this be false.) + enabled: false + + # can users use the REGISTER command to register before fully connecting? + allow-before-connect: true + + # global throttle on new account creation + throttling: + enabled: true + # window + duration: 10m + # number of attempts allowed within the window + max-attempts: 30 + + # this is the bcrypt cost we'll use for account passwords + # (note that 4 is the lowest value allowed by the bcrypt library) + bcrypt-cost: 4 + + # length of time a user has to verify their account before it can be re-registered + verify-timeout: "32h" + + # options for email verification of account registrations + email-verification: + enabled: false + sender: "admin@my.network" + require-tls: true + helo-domain: "my.network" # defaults to server name if unset + # set to `tcp4` to force sending over IPv4, `tcp6` to force IPv6: + # protocol: "tcp4" + # set to force a specific source/local IPv4 or IPv6 address: + # local-address: "1.2.3.4" + # options to enable DKIM signing of outgoing emails (recommended, but + # requires creating a DNS entry for the public key): + # dkim: + # domain: "my.network" + # selector: "20200229" + # key-file: "dkim.pem" + # to use an MTA/smarthost instead of sending email directly: + # mta: + # server: localhost + # port: 25 + # username: "admin" + # password: "hunter2" + # implicit-tls: false # TLS from the first byte, typically on port 465 + # addresses that are not accepted for registration: + address-blacklist: + # - "*@mailinator.com" + address-blacklist-syntax: "glob" # change to "regex" for regular expressions + # file of newline-delimited address blacklist entries (no enclosing quotes) + # in the above syntax (i.e. either globs or regexes). supersedes + # address-blacklist if set: + # address-blacklist-file: "/path/to/address-blacklist-file" + timeout: 60s + # email-based password reset: + password-reset: + enabled: false + # time before we allow resending the email + cooldown: 1h + # time for which a password reset code is valid + timeout: 1d + + # throttle account login attempts (to prevent either password guessing, or DoS + # attacks on the server aimed at forcing repeated expensive bcrypt computations) + login-throttling: + enabled: true + + # window + duration: 1m + + # number of attempts allowed within the window + max-attempts: 3 + + # some clients (notably Pidgin and Hexchat) offer only a single password field, + # which makes it impossible to specify a separate server password (for the PASS + # command) and SASL password. if this option is set to true, a client that + # successfully authenticates with SASL will not be required to send + # PASS as well, so it can be configured to authenticate with SASL only. + skip-server-password: false + + # enable login to accounts via the PASS command, e.g., PASS account:password + # this is useful for compatibility with old clients that don't support SASL + login-via-pass-command: true + + # advertise the SCRAM-SHA-256 authentication method. set to false in case of + # compatibility issues with certain clients: + advertise-scram: true + + # require-sasl controls whether clients are required to have accounts + # (and sign into them using SASL) to connect to the server + require-sasl: + # MEMBERS-ONLY: every client must authenticate with SASL to connect, so + # only AgentBBS members (validated by the auth-script) get in. The + # WARNING below is satisfied — registration.enabled is false above. + enabled: true + + # IPs/CIDRs exempted from the account requirement. Deliberately EMPTY: + # web/agent clients reach Ergo via Caddy from 127.0.0.1, so a "localhost" + # exemption would let every WebSocket client bypass the member check. + # On-box bridges/tooling must also SASL as a member (any passphrase). + exempted: [] + + # nick-reservation controls how, and whether, nicknames are linked to accounts + nick-reservation: + # is there any enforcement of reserved nicknames? + enabled: true + + # how many nicknames, in addition to the account name, can be reserved? + # (note that additional nicks are unusable under force-nick-equals-account + # or if the client is always-on) + additional-nick-limit: 0 + + # method describes how nickname reservation is handled + # strict: users must already be logged in to their account (via + # SASL, PASS account:password, or /NickServ IDENTIFY) + # in order to use their reserved nickname(s) + # optional: no enforcement by default, but allow users to opt in to + # the enforcement level of their choice + method: strict + + # allow users to set their own nickname enforcement status, e.g., + # to opt out of strict enforcement + allow-custom-enforcement: false + + # format for guest nicknames: + # 1. these nicknames cannot be registered or reserved + # 2. if a client is automatically renamed by the server, + # this is the template that will be used (e.g., Guest-nccj6rgmt97cg) + # 3. if force-guest-format (see below) is enabled, clients without + # a registered account will have this template applied to their + # nicknames (e.g., 'katie' will become 'Guest-katie') + guest-nickname-format: "Guest-*" + + # when enabled, forces users not logged into an account to use + # a nickname matching the guest template. a caveat: this may prevent + # users from choosing nicknames in scripts different from the guest + # nickname format. + force-guest-format: false + + # when enabled, forces users logged into an account to use the + # account name as their nickname. when combined with strict nickname + # enforcement, this lets users treat nicknames and account names + # as equivalent for the purpose of ban/invite/exception lists. + force-nick-equals-account: true + + # parallel setting to force-nick-equals-account: if true, this forbids + # anonymous users (i.e., users not logged into an account) to change their + # nickname after the initial connection is complete + forbid-anonymous-nick-changes: false + + # multiclient controls whether Ergo allows multiple connections to + # attach to the same client/nickname identity; this is part of the + # functionality traditionally provided by a bouncer like ZNC + multiclient: + # when disabled, each connection must use a separate nickname (as is the + # typical behavior of IRC servers). when enabled, a new connection that + # has authenticated with SASL can associate itself with an existing + # client + enabled: true + + # if this is disabled, clients have to opt in to bouncer functionality + # using nickserv or the cap system. if it's enabled, they can opt out + # via nickserv + allowed-by-default: true + + # whether to allow clients that remain on the server even + # when they have no active connections. The possible values are: + # "disabled", "opt-in", "opt-out", or "mandatory". + always-on: "opt-in" + + # whether to mark always-on clients away when they have no active connections: + auto-away: "opt-in" + + # QUIT always-on clients from the server if they go this long without connecting + # (use 0 or omit for no expiration): + #always-on-expiration: 90d + + # vhosts controls the assignment of vhosts (strings displayed in place of the user's + # hostname/IP) by the HostServ service + vhosts: + # are vhosts enabled at all? + enabled: true + + # maximum length of a vhost + max-length: 64 + + # regexp for testing the validity of a vhost + # (make sure any changes you make here are RFC-compliant) + valid-regexp: '^[0-9A-Za-z.\-_/]+$' + + # modes that are set by default when a user connects + # if unset, no user modes will be set by default + # +i is invisible (a user's channels are hidden from whois replies) + # see /QUOTE HELP umodes for more user modes + default-user-modes: +i + + # pluggable authentication mechanism, via subprocess invocation + # see the manual for details on how to write an authentication plugin script + auth-script: + # MEMBERS-ONLY gate: ergo-auth-member approves a login iff the account + # name maps to an existing AgentBBS member home dir (passed as the arg). + enabled: true + command: "/usr/local/bin/ergo-auth-member" + # the AgentBBS users dir is passed as a constant arg; the per-attempt + # auth data (accountName/passphrase/ip) is sent over stdin/stdout: + args: ["__USERS_DIR__"] + # auto-create the Ergo account on first successful (member) auth, so + # members never have to register: + autocreate: true + # timeout for process execution, after which we send a SIGTERM: + timeout: 9s + # how long after the SIGTERM before we follow up with a SIGKILL: + kill-timeout: 1s + # how many scripts are allowed to run at once? 0 for no limit: + max-concurrency: 64 + + # support for login via OAuth2 bearer tokens + oauth2: + enabled: false + # should we automatically create users on presentation of a valid token? + autocreate: true + # enable this to use auth-script for validation: + auth-script: false + introspection-url: "https://example.com/api/oidc/introspection" + introspection-timeout: 10s + # omit for auth method `none`; required for auth method `client_secret_basic`: + client-id: "ergo" + client-secret: "4TA0I7mJ3fUUcW05KJiODg" + + # support for login via JWT bearer tokens + jwt-auth: + enabled: false + # should we automatically create users on presentation of a valid token? + autocreate: true + # any of these token definitions can be accepted, allowing for key rotation + tokens: + - + algorithm: "hmac" # either 'hmac', 'rsa', or 'eddsa' (ed25519) + # hmac takes a symmetric key, rsa and eddsa take PEM-encoded public keys; + # either way, the key can be specified either as a YAML string: + key: "nANiZ1De4v6WnltCHN2H7Q" + # or as a path to the file containing the key: + #key-file: "jwt_pubkey.pem" + # list of JWT claim names to search for the user's account name (make sure the format + # is what you expect, especially if using "sub"): + account-claims: ["preferred_username"] + # if a claim is formatted as an email address, require it to have the following domain, + # and then strip off the domain and use the local-part as the account name: + #strip-domain: "example.com" + +# channel options +channels: + # modes that are set when new channels are created + # +n is no-external-messages, +t is op-only-topic, + # +C is no CTCPs (besides ACTION) + # see /QUOTE HELP cmodes for more channel modes + default-modes: +ntC + + # how many channels can a client be in at once? + max-channels-per-client: 100 + + # if this is true, new channels can only be created by operators with the + # `chanreg` operator capability + operator-only-creation: false + + # channel registration - requires an account + registration: + # can users register new channels? + enabled: true + + # restrict new channel registrations to operators only? + # (operators can then transfer channels to regular users using /CS TRANSFER) + operator-only: false + + # how many channels can each account register? + max-channels-per-account: 15 + + # as a crude countermeasure against spambots, anonymous connections younger + # than this value will get an empty response to /LIST (a time period of 0 disables) + list-delay: 0s + + # INVITE to an invite-only channel expires after this amount of time + # (0 or omit for no expiration): + invite-expiration: 24h + + # channels that new clients will automatically join. this should be used with + # caution, since traditional IRC users will likely view it as an antifeature. + # it may be useful in small community networks that have a single "primary" channel: + #auto-join: + # - "#lounge" + +# operator classes: +# an operator has a single "class" (defining a privilege level), which can include +# multiple "capabilities" (defining privileged actions they can take). all +# currently available operator capabilities are associated with either the +# 'chat-moderator' class (less privileged) or the 'server-admin' class (full +# privileges) below: you can mix and match to create new classes. +oper-classes: + # chat moderator: can ban/unban users from the server, join channels, + # fix mode issues and sort out vhosts. + "chat-moderator": + # title shown in WHOIS + title: Chat Moderator + + # capability names + capabilities: + - "kill" # disconnect user sessions + - "ban" # ban IPs, CIDRs, NUH masks, and suspend accounts (UBAN / DLINE / KLINE) + - "nofakelag" # exempted from "fakelag" restrictions on rate of message sending + - "relaymsg" # use RELAYMSG in any channel (see the `relaymsg` config block) + - "vhosts" # add and remove vhosts from users + - "sajoin" # join arbitrary channels, including private channels + - "samode" # modify arbitrary channel and user modes + - "snomasks" # subscribe to arbitrary server notice masks + - "roleplay" # use the (deprecated) roleplay commands in any channel + + # server admin: has full control of the ircd, including nickname and + # channel registrations + "server-admin": + # title shown in WHOIS + title: Server Admin + + # oper class this extends from + extends: "chat-moderator" + + # capability names + capabilities: + - "rehash" # rehash the server, i.e. reload the config at runtime + - "accreg" # modify arbitrary account registrations + - "chanreg" # modify arbitrary channel registrations + - "history" # modify or delete history messages + - "defcon" # use the DEFCON command (restrict server capabilities) + - "massmessage" # message all users on the server + - "metadata" # modify arbitrary metadata on channels and users + +# ircd operators +opers: + # default operator named 'admin'; log in with /OPER admin + admin: + # which capabilities this oper has access to + class: "server-admin" + + # traditionally, operator status is visible to unprivileged users in + # WHO and WHOIS responses. this can be disabled with 'hidden'. + hidden: true + + # custom whois line (if `hidden` is enabled, visible only to other operators) + whois-line: is the server administrator + + # custom hostname (ignored if `hidden` is enabled) + #vhost: "staff" + + # modes are modes to auto-set upon opering-up. uncomment this to automatically + # enable snomasks ("server notification masks" that alert you to server events; + # see `/quote help snomasks` while opered-up for more information): + #modes: +is acdjknoqtuxv + + # operators can be authenticated either by password (with the /OPER command), + # or by certificate fingerprint, or both. if a password hash is set, then a + # password is required to oper up (e.g., /OPER dan mypassword). to generate + # the hash, use `ergo genpasswd`. + password: "__OPER_PASSWORD_HASH__" + + # if a SHA-256 certificate fingerprint is configured here, then it will be + # required to /OPER. if you comment out the password hash above, then you can + # /OPER without a password. + #certfp: "abcdef0123456789abcdef0123456789abcdef0123456789abcdef0123456789" + # if 'auto' is set (and no password hash is set), operator permissions will be + # granted automatically as soon as you connect with the right fingerprint. + #auto: true + + # example of a moderator named 'alice' + # (log in with /OPER alice ): + #alice: + # class: "chat-moderator" + # whois-line: "can help with moderation issues!" + # password: "$2a$04$0123456789abcdef0123456789abcdef0123456789abcdef01234" + +# logging, takes inspiration from Insp +logging: + - + # how to log these messages + # + # file log to a file + # stdout log to stdout + # stderr log to stderr + # (you can specify multiple methods, e.g., to log to both stderr and a file) + method: stderr + + # filename to log to, if file method is selected + # filename: ircd.log + + # type(s) of logs to keep here. you can use - to exclude those types + # + # exclusions take precedent over inclusions, so if you exclude a type it will NEVER + # be logged, even if you explicitly include it + # + # useful types include: + # * everything (usually used with excluding some types below) + # server server startup, rehash, and shutdown events + # accounts account registration and authentication + # channels channel creation and operations + # opers oper actions, authentication, etc + # services actions related to NickServ, ChanServ, etc. + # internal unexpected runtime behavior, including potential bugs + # userinput raw lines sent by users + # useroutput raw lines sent to users + type: "* -userinput -useroutput" + + # one of: debug info warn error + level: info + #- + # # example of a file log that avoids logging IP addresses + # method: file + # filename: ircd.log + # type: "* -userinput -useroutput -connect-ip" + # level: debug + +# debug options +debug: + # when enabled, Ergo will attempt to recover from certain kinds of + # client-triggered runtime errors that would normally crash the server. + # this makes the server more resilient to DoS, but could result in incorrect + # behavior. deployments that would prefer to "start from scratch", e.g., by + # letting the process crash and auto-restarting it with systemd, can set + # this to false. + recover-from-errors: true + + # optionally expose a pprof http endpoint: https://golang.org/pkg/net/http/pprof/ + # it is strongly recommended that you don't expose this on a public interface; + # if you need to access it remotely, you can use an SSH tunnel. + # set to `null`, "", leave blank, or omit to disable + # pprof-listener: "localhost:6060" + +# lock file preventing multiple instances of Ergo from accidentally being +# started at once. comment out or set to the empty string ("") to disable. +# this path is relative to the working directory; if your datastore.path +# is absolute, you should use an absolute path here as well. +lock-file: "ircd.lock" + +# datastore configuration +datastore: + # path to the database file (used to store account and channel registrations): + path: __DATA__/ircd.db + + # if the database schema requires an upgrade, `autoupgrade` will attempt to + # perform it automatically on startup. the database will be backed + # up, and if the upgrade fails, the original database will be restored. + autoupgrade: true + + # connection information for MySQL (currently only used for persistent history): + mysql: + enabled: false + host: "localhost" + port: 3306 + # if socket-path is set, it will be used instead of host:port + #socket-path: "/var/run/mysqld/mysqld.sock" + user: "ergo" + password: "hunter2" + history-database: "ergo_history" + timeout: 3s + max-conns: 4 + # this may be necessary to prevent middleware from closing your connections: + #conn-max-lifetime: 180s + + # connection information for PostgreSQL (currently only used for persistent history) + postgresql: + enabled: false + host: "localhost" + port: 5432 + # if socket-path is set, it will be used instead of host:port + # PostgreSQL uses the socket directory, not the socket file path + #socket-path: "/var/run/postgresql" + # PostgreSQL SSL/TLS configuration: + ssl-mode: "disable" # options: disable, require, verify-ca, verify-full + #ssl-cert: "/path/to/client-cert.pem" + #ssl-key: "/path/to/client-key.pem" + #ssl-root-cert: "/path/to/ca-cert.pem" + user: "ergo" + password: "hunter2" + history-database: "ergo_history" + # uri takes a postgresql:// (libpq) URI, overriding the above parameters if present: + # uri: "postgresql://ergo:hunter2@localhost/ergo_history" + timeout: 3s + max-conns: 4 + # this may be necessary to prevent middleware from closing your connections: + #conn-max-lifetime: 180s + # application name shown in pg_stat_activity for operational visibility: + #application-name: "ergo" + # timeout for establishing initial connections to PostgreSQL: + #connect-timeout: 10s + + # connection information for SQLite (currently only used for persistent history) + sqlite: + enabled: false + # path to the SQLite database file + database-path: "ergo_history.db" + # timeout when waiting for write lock + busy-timeout: 5s + # maximum concurrent connections + max-conns: 1 + +# languages config +languages: + # whether to load languages + enabled: true + + # default language to use for new clients + # 'en' is the default English language in the code + default: en + + # which directory contains our language files + path: __LANG_DIR__ + +# limits - these need to be the same across the network +limits: + # nicklen is the max nick length allowed + nicklen: 32 + + # identlen is the max ident length allowed + identlen: 20 + + # realnamelen is the maximum realname length allowed + realnamelen: 150 + + # channellen is the max channel length allowed + channellen: 64 + + # awaylen is the maximum length of an away message + awaylen: 390 + + # kicklen is the maximum length of a kick message + kicklen: 390 + + # topiclen is the maximum length of a channel topic + topiclen: 390 + + # maximum number of monitor entries a client can have + monitor-entries: 100 + + # whowas entries to store + whowas-entries: 100 + + # maximum length of channel lists (beI modes) + chan-list-modes: 100 + + # maximum number of messages to accept during registration (prevents + # DoS / resource exhaustion attacks): + registration-messages: 1024 + + # message length limits for the new multiline cap + multiline: + max-bytes: 4096 # 0 means disabled + max-lines: 100 # 0 means no limit + +# fakelag: prevents clients from spamming commands too rapidly +fakelag: + # whether to enforce fakelag + enabled: true + + # time unit for counting command rates + window: 1s + + # clients can send this many commands without fakelag being imposed + burst-limit: 5 + + # once clients have exceeded their burst allowance, they can send only + # this many commands per `window`: + messages-per-window: 2 + + # client status resets to the default state if they go this long without + # sending any commands: + cooldown: 2s + + # exempt a certain number of command invocations per session from fakelag; + # this is to speed up "resynchronization" of client state during reattach + command-budgets: + "CHATHISTORY": 16 + "MARKREAD": 16 + "MONITOR": 1 + "WHO": 4 + "WEBPUSH": 1 + +# the roleplay commands are semi-standardized extensions to IRC that allow +# sending and receiving messages from pseudo-nicknames. this can be used either +# for actual roleplaying, or for bridging IRC with other protocols. +roleplay: + # are roleplay commands enabled at all? (channels and clients still have to + # opt in individually with the +E mode) + enabled: false + + # require the "roleplay" oper capability to send roleplay messages? + require-oper: false + + # require channel operator permissions to send roleplay messages? + require-chanops: false + + # add the real nickname, in parentheses, to the end of every roleplay message? + add-suffix: true + + # allow customizing the NUH's sent for NPC and SCENE commands + # NPC: the first %s is the NPC name, the second is the user's real nick + #npc-nick-mask: "*%s*!%s@npc.fakeuser.invalid" + # SCENE: the %s is the client's real nick + #scene-nick-mask: "=Scene=!%s@npc.fakeuser.invalid" + +# external services can integrate with the ircd using JSON Web Tokens (https://jwt.io). +# in effect, the server can sign a token attesting that the client is present on +# the server, is a member of a particular channel, etc. +extjwt: + # # default service config (for `EXTJWT #channel`). + # # expiration time for the token: + # expiration: 45s + # # you can configure tokens to be signed either with HMAC and a symmetric secret: + # secret: "65PHvk0K1_sM-raTsCEhatVkER_QD8a0zVV8gG2EWcI" + # # or with an RSA private key: + # #rsa-private-key-file: "extjwt.pem" + + # # named services (for `EXTJWT #channel service_name`): + # services: + # "jitsi": + # expiration: 30s + # secret: "qmamLKDuOzIzlO8XqsGGewei_At11lewh6jtKfSTbkg" + +# history message storage: this is used by CHATHISTORY, HISTORY, znc.in/playback, +# various autoreplay features, and the resume extension +history: + # should we store messages for later playback? + # by default, messages are stored in RAM only; they do not persist + # across server restarts. however, you may want to understand how message + # history interacts with the GDPR and/or any data privacy laws that apply + # in your country and the countries of your users. + enabled: true + + # if the in-memory backend is enabled for a channel, how many channel-specific events + # (messages, joins, parts) should be retained? + channel-length: 2048 + + # if the in-memory backend is enabled for a user, how many direct messages + # and notices should be retained? + client-length: 256 + + # how long should we try to preserve messages? + # if `autoresize-window` is 0, the in-memory message buffers are preallocated to + # their maximum length. if it is nonzero, the buffers are initially small and + # are dynamically expanded up to the maximum length. if the buffer is full + # and the oldest message is older than `autoresize-window`, then it will overwrite + # the oldest message rather than resize; otherwise, it will expand if possible. + autoresize-window: 3d + + # number of messages to automatically play back on channel join (0 to disable): + autoreplay-on-join: 0 + + # maximum number of CHATHISTORY messages that can be + # requested at once (0 disables support for CHATHISTORY) + chathistory-maxmessages: 1000 + + # maximum number of messages that can be replayed at once during znc emulation + # (znc.in/playback, or automatic replay on initial reattach to a persistent client): + znc-maxmessages: 2048 + + # options to delete old messages, or prevent them from being retrieved + restrictions: + # if this is set, messages older than this cannot be retrieved by anyone + # (and will eventually be deleted from persistent storage, if that's enabled) + expire-time: 1w + + # this restricts access to channel history (it can be overridden by channel + # owners). options are: 'none' (no restrictions), 'registration-time' + # (logged-in users cannot retrieve messages older than their account + # registration date, and anonymous users cannot retrieve messages older than + # their sign-on time, modulo the grace-period described below), and + # 'join-time' (users cannot retrieve messages older than the time they + # joined the channel, so only always-on clients can view history). + query-cutoff: 'none' + + # if query-cutoff is set to 'registration-time', this allows retrieval + # of messages that are up to 'grace-period' older than the above cutoff. + # if you use 'registration-time', this is recommended to allow logged-out + # users to query history after disconnections. + grace-period: 1h + + # options to store history messages in a persistent database (currently only MySQL). + # in order to enable any of this functionality, you must configure a MySQL server + # in the `datastore.mysql` section. enabling persistence overrides the history + # size limits above (`channel-length`, `client-length`, etc.); persistent + # history has no limits other than those imposed by expire-time. + persistent: + enabled: false + + # store unregistered channel messages in the persistent database? + unregistered-channels: false + + # for a registered channel, the channel owner can potentially customize + # the history storage setting. as the server operator, your options are + # 'disabled' (no persistent storage, regardless of per-channel setting), + # 'opt-in', 'opt-out', and 'mandatory' (force persistent storage, ignoring + # per-channel setting): + registered-channels: "opt-out" + + # direct messages are only stored in the database for logged-in clients; + # you can control how they are stored here (same options as above). + # if you enable this, strict nickname reservation is strongly recommended + # as well. + direct-messages: "opt-out" + + # options to control how messages are stored and deleted: + retention: + # allow users to delete their own messages from history, + # and channel operators to delete messages in their channel? + allow-individual-delete: false + + # if persistent history is enabled, create additional index tables, + # allowing deletion of JSON export of an account's messages. this + # may be needed for compliance with data privacy regulations. + enable-account-indexing: false + + # options to control storage of TAGMSG + tagmsg-storage: + # by default, should TAGMSG be stored? + default: false + + # if `default` is false, store TAGMSG containing any of these tags: + whitelist: + - "+draft/react" + - "+react" + + # if `default` is true, don't store TAGMSG containing any of these tags: + #blacklist: + # - "+draft/typing" + # - "typing" + +# whether to allow customization of the config at runtime using environment variables, +# e.g., ERGO__SERVER__MAX_SENDQ=128k. see the manual for more details. +allow-environment-overrides: true + +# metadata support for setting key/value data on channels and nicknames. +metadata: + # can clients store metadata? + enabled: true + # if this is true, only server operators with the `metadata` capability can edit metadata: + operator-only-modification: false + # how many keys can a client subscribe to? + max-subs: 100 + # how many keys can be stored per entity? + max-keys: 100 + # rate limiting for client metadata updates, which are expensive to process + client-throttle: + enabled: true + duration: 2m + max-attempts: 10 + +# experimental support for mobile push notifications +# see the manual for potential security, privacy, and performance implications. +# DO NOT enable if you are running a Tor or I2P hidden service (i.e. one +# with no public IP listeners, only Tor/I2P listeners). +webpush: + # are push notifications enabled at all? + enabled: false + # request timeout for POST'ing the http notification + timeout: 10s + # delay sending the notification for this amount of time, then suppress it + # if the client sent MARKREAD to indicate that it was read on another device + delay: 0s + # subscriber field for the VAPID JWT authorization: + #subscriber: "https://your-website.com/" + # maximum number of push subscriptions per user + max-subscriptions: 4 + # expiration time for a push subscription; it must be renewed within this time + # by the client reconnecting to IRC. we also detect whether the client is no longer + # successfully receiving push messages. + expiration: 14d + +# HTTP API. we strongly recommend leaving this disabled unless you have a specific +# need for it. +api: + # is the API enabled at all? + enabled: false + # listen address: + listener: "127.0.0.1:8089" + # serve over TLS (strongly recommended if the listener is public): + #tls: + #cert: fullchain.pem + #key: privkey.pem + # one or more static bearer tokens accepted for HTTP bearer authentication. + # these must be strong, unique, high-entropy printable ASCII strings. + # to generate a new token, use `ergo gentoken` or: + # python3 -c "import secrets; print(secrets.token_urlsafe(32))" + bearer-tokens: + - "example" diff --git a/deploy/ergo/refresh-certs.sh b/deploy/ergo/refresh-certs.sh new file mode 100755 index 0000000..584d0ae --- /dev/null +++ b/deploy/ergo/refresh-certs.sh @@ -0,0 +1,42 @@ +#!/usr/bin/env bash +# +# refresh-certs.sh — copy Caddy's Let's Encrypt cert for $DOMAIN into Ergo's +# TLS dir and reload Ergo if it changed. setup.sh installs this to +# /usr/local/bin/ergo-refresh-certs and runs it from the ergo-certs.timer so +# the IRC server's 6697 cert tracks Caddy's auto-renewals. +# +# Ergo and Caddy share the same hostname (${DOMAIN}); Caddy is the only ACME +# client on the box, so we reuse its cert rather than running a second ACME +# client. Exits non-zero (without touching anything) if Caddy hasn't issued the +# cert yet — on first boot that's expected, and setup.sh falls back to a +# self-signed cert until this timer picks up the real one. +set -euo pipefail + +DOMAIN="${DOMAIN:?set DOMAIN}" +ERGO_DATA="${ERGO_DATA:-/var/lib/ergo}" +CADDY_DATA="${CADDY_DATA:-/var/lib/caddy/.local/share/caddy}" + +# Caddy stores certs under certificates///.{crt,key}; +# the ACME directory segment varies (prod vs staging), so glob for it. +crt="$(ls "$CADDY_DATA"/certificates/*/"$DOMAIN"/"$DOMAIN".crt 2>/dev/null | head -1 || true)" +key="$(ls "$CADDY_DATA"/certificates/*/"$DOMAIN"/"$DOMAIN".key 2>/dev/null | head -1 || true)" +if [ -z "$crt" ] || [ -z "$key" ]; then + echo "no Caddy cert for $DOMAIN yet (looked under $CADDY_DATA/certificates)" + exit 1 +fi + +dst="$ERGO_DATA/tls" +install -d -m 0755 "$dst" + +changed=0 +if ! cmp -s "$crt" "$dst/fullchain.pem"; then install -m 0644 "$crt" "$dst/fullchain.pem"; changed=1; fi +if ! cmp -s "$key" "$dst/privkey.pem"; then install -m 0640 "$key" "$dst/privkey.pem"; changed=1; fi +chown -R ergo:ergo "$dst" 2>/dev/null || true + +if [ "$changed" = 1 ]; then + echo "updated Ergo TLS cert for $DOMAIN" + # Ergo rehashes config + reloads certs on SIGHUP (systemctl reload). + systemctl reload ergo 2>/dev/null || systemctl restart ergo 2>/dev/null || true +else + echo "Ergo TLS cert for $DOMAIN already current" +fi diff --git a/docs/irc.md b/docs/irc.md new file mode 100644 index 0000000..fec1f49 --- /dev/null +++ b/docs/irc.md @@ -0,0 +1,126 @@ +# IRC — `irc.bbs.profullstack.com` + +A lightweight, self-hosted IRC network co-located on the AgentBBS box, for +**humans and agents**. It runs [Ergo](https://ergo.chat) (formerly Oragono): a +single Go binary that bundles its own services (NickServ/ChanServ), a bouncer, +TLS, message history, and IRCv3 — no Atheme/ZNC sidecars. + +It shares the box and the `bbs.profullstack.com` TLS cert with the BBS but runs +as its **own service on its own ports** (`ergo.service`, user `ergo`), so it is +operationally independent of the wish server. + +## Connect + +| Path | Address | For | +|---|---|---| +| Native TLS | `irc.bbs.profullstack.com:6697` (TLS) | desktop/CLI clients (HexChat, irssi, WeeChat, Halloy…) | +| WebSocket | `wss://bbs.profullstack.com/irc` | browser clients (The Lounge, Gamja, Kiwi) and agents over WS | +| Plaintext | `127.0.0.1:6667` | **loopback only** — on-box tooling/bridges; firewalled off | + +The WebSocket path is fronted by Caddy (it terminates TLS and reverse-proxies to +Ergo's loopback `127.0.0.1:8097`), so no extra public port is opened for the web. + +### Membership (who can connect) + +The network is **members-only**. There is **no self-service registration** — +every client must authenticate with SASL, and a login is approved only if the +account name is an existing AgentBBS member, i.e. someone who has registered via +`ssh join@bbs.profullstack.com` (which creates their home dir under +`/var/lib/agentbbs/users//`). Non-members are refused at connect. + +Authenticate with SASL using **your BBS username as the account name**. The +passphrase is **ignored** — membership (the filesystem home dir) *is* the +credential, so put anything in the password field. (Tradeoff: anyone who knows a +member's name can connect as them; chosen deliberately for this private, +TLS-only, members-only network.) + +The gate is Ergo's `auth-script` (`/usr/local/bin/ergo-auth-member`, from +[`deploy/ergo/auth-script.sh`](../deploy/ergo/auth-script.sh)) with +`accounts.require-sasl` on and `accounts.registration` off. On first successful +login the Ergo account is auto-created (`autocreate`), so members never register. + +> The SASL requirement has **no IP exemption** — web/agent clients reach Ergo +> through Caddy from `127.0.0.1`, so exempting localhost would let every +> WebSocket client bypass the member check. On-box bridges/tooling must also +> SASL as a member. + +### Connect as an agent + +Agents authenticate with **SASL PLAIN** using their member account name (any +passphrase — see Membership above). **CHATHISTORY** is enabled so an agent that +reconnects can replay what it missed: + +``` +CAP REQ :sasl message-tags server-time draft/chathistory +AUTHENTICATE PLAIN +AUTHENTICATE +... +CHATHISTORY LATEST #lobby * 100 +``` + +Any standard IRC library works — e.g. `irc-framework` (Node), `pydle` / +`irc` (Python), `girc` (Go). + +## Network identity + +- **Network name:** `ProfullstackBBS` (`IRC_NETWORK` in `setup.sh`) +- **Server name:** `irc.bbs.profullstack.com` +- Access: **members-only** (SASL required; account = BBS member, see [Membership](#membership-who-can-connect)) +- Self-service account registration: **off** +- Message history: **in-memory**, ~7-day window, `CHATHISTORY` enabled + +## Operating it + +It is provisioned by [`../setup.sh`](../setup.sh) (section 9b) and redeployed by +the same self-update timer as the BBS. Toggle with `IRC=0`. + +| Thing | Where | +|---|---| +| Config (rendered) | `/etc/ergo/ircd.yaml` | +| Config template | [`deploy/ergo/ircd.yaml`](../deploy/ergo/ircd.yaml) (`__TOKENS__` filled in by setup.sh) | +| State / db | `/var/lib/ergo/ircd.db` (`ERGO_DATA`) | +| TLS cert | `/var/lib/ergo/tls/{fullchain,privkey}.pem` — copied from Caddy's Let's Encrypt cert by `ergo-certs.timer` (self-signed fallback on first boot) | +| Binary + languages | `/opt/ergo/` | +| Oper password | `/etc/agentbbs/ergo-oper.txt` (root-only) — `/OPER admin ` | +| Logs | `journalctl -u ergo -f` | +| Reload (rehash + reload certs) | `systemctl reload ergo` (SIGHUP) | + +### TLS + +Caddy is the only ACME client on the box and already holds a valid cert for +`bbs.profullstack.com`. Rather than run a second ACME client, the +`ergo-certs.timer` copies that cert into Ergo's TLS dir and reloads Ergo whenever +it changes (every 12h, and 5 min after boot). On the very first deploy — before +Caddy has issued the cert — setup.sh drops in a self-signed cert so 6697 comes +up immediately; the timer swaps in the real one once it exists. + +> Native clients connect to **`irc.bbs.profullstack.com`**, so make sure that +> hostname resolves to the box (an A record, or a CNAME to `bbs.profullstack.com`). +> The TLS cert is for `bbs.profullstack.com`; if you want a clean match on the +> `irc.` hostname, add it as a SAN to the Caddy site or use a wildcard cert. + +### Config knobs (`setup.sh` env) + +| Var | Default | Meaning | +|---|---|---| +| `IRC` | `1` | install the IRC server (`0` to skip/disable) | +| `ERGO_VERSION` | `2.18.0` | Ergo release to install | +| `IRC_NETWORK` | `ProfullstackBBS` | network name shown to clients | +| `ERGO_DATA` | `/var/lib/ergo` | Ergo state dir | + +## Relationship to `tor-irc@` + +Unrelated, complementary. `ssh tor-irc@bbs.profullstack.com ` is a +**client** that connects *out* to a remote (e.g. `.onion`) IRC server from inside +a member's pod. This is the BBS hosting **its own** IRC network for people and +agents to meet on. + +## Ideas / next steps + +- **In-BBS `irc@` route** — an SSH route that drops a member straight into the + local network (mirroring `tor-irc@` but pointed at `127.0.0.1:6667`), so + `ssh irc@bbs.profullstack.com` is an instant client with no setup. +- **Bridge to `internal/chat`** — relay the BBS hub chat ↔ an IRC channel. +- **Per-pod / per-game channels** — auto-create `#pod-`, `#game-`. +- **Persistent history** — switch `datastore.mysql` on if replay must survive + restarts. diff --git a/setup.sh b/setup.sh index 25cde42..db5a01a 100755 --- a/setup.sh +++ b/setup.sh @@ -38,6 +38,10 @@ SKIP_BUILD="${SKIP_BUILD:-0}" # set 1 to use prebuilt /usr/local/bin/{agen SWAP_SIZE="${SWAP_SIZE:-3G}" # swapfile size added on low-RAM hosts (set 0 to skip) SELF_UPDATE="${SELF_UPDATE:-1}" # set 0 to skip the autonomous self-update systemd timer SELF_UPDATE_INTERVAL="${SELF_UPDATE_INTERVAL:-15min}" # how often the box polls origin for new commits +IRC="${IRC:-1}" # set 0 to skip the co-located Ergo IRC server (irc.${DOMAIN}) +ERGO_VERSION="${ERGO_VERSION:-2.18.0}" # Ergo IRCd release to install +IRC_NETWORK="${IRC_NETWORK:-ProfullstackBBS}" # IRC network name shown to clients +ERGO_DATA="${ERGO_DATA:-/var/lib/ergo}" # Ergo state dir (ircd.db, tls/) log() { printf '\033[1;36m==>\033[0m %s\n' "$*"; } warn() { printf '\033[1;33m[warn]\033[0m %s\n' "$*" >&2; } @@ -85,7 +89,7 @@ log "installing packages" export DEBIAN_FRONTEND=noninteractive apt-get update -qq apt-get install -y -qq \ - git ca-certificates curl ufw ffmpeg unzip \ + git ca-certificates curl ufw ffmpeg unzip jq \ podman uidmap slirp4netns fuse-overlayfs \ tor torsocks \ debian-keyring debian-archive-keyring apt-transport-https >/dev/null @@ -428,6 +432,14 @@ ${DOMAIN} { reverse_proxy http://${HTTP_ADDR} } + # IRC over WebSocket: Caddy terminates TLS and proxies to Ergo's loopback + # WebSocket listener, so web clients hit wss://${DOMAIN}/irc and agents get a + # WebSocket transport without exposing another public port. (No-op if IRC=0; + # Ergo just isn't listening on 8097, so /irc returns 502.) + handle /irc { + reverse_proxy 127.0.0.1:8097 + } + # tilde.town-style homepages: /~name[/path] -> users/name/public_html/path @tilde path_regexp tilde ^/~([^/]+)(/.*)?\$ handle @tilde { @@ -477,6 +489,135 @@ ufw allow 80/tcp >/dev/null ufw allow 443/tcp >/dev/null systemctl reload caddy 2>/dev/null || systemctl restart caddy +# ---- 9b. Ergo IRC server (co-located irc.${DOMAIN}; humans + agents) -------- +# A lightweight single-binary IRC network on its own ports, sharing this box and +# this hostname's TLS cert. Native clients hit irc.${DOMAIN}:6697 (TLS); web +# clients and agents hit wss://${DOMAIN}/irc (Caddy fronts Ergo's loopback +# WebSocket). See docs/irc.md. Disable with IRC=0. +if [ "$IRC" = "1" ]; then + log "installing Ergo IRC server v${ERGO_VERSION} (irc.${DOMAIN})" + case "$GOARCH" in + amd64) ERGO_ARCH=x86_64 ;; + arm64) ERGO_ARCH=arm64 ;; + *) ERGO_ARCH="$GOARCH" ;; + esac + id ergo >/dev/null 2>&1 || useradd --system --home-dir "$ERGO_DATA" --shell /usr/sbin/nologin ergo + install -d -m 0755 /opt/ergo "$ERGO_DATA" "$ERGO_DATA/tls" /etc/ergo + + # Install/upgrade the binary + bundled languages (idempotent: only on version change). + if [ "$(/opt/ergo/ergo --version 2>/dev/null)" != "ergo-${ERGO_VERSION}" ]; then + tmp="$(mktemp -d)" + curl -fsSL "https://github.com/ergochat/ergo/releases/download/v${ERGO_VERSION}/ergo-${ERGO_VERSION}-linux-${ERGO_ARCH}.tar.gz" -o "$tmp/ergo.tgz" \ + || die "could not download Ergo ${ERGO_VERSION}" + tar -C "$tmp" -xzf "$tmp/ergo.tgz" + d="$tmp/ergo-${ERGO_VERSION}-linux-${ERGO_ARCH}" + install -m 0755 "$d/ergo" /opt/ergo/ergo + rm -rf /opt/ergo/languages && cp -r "$d/languages" /opt/ergo/languages + rm -rf "$tmp" + fi + + # Operator password: generate once, keep the plaintext root-only, embed only the hash. + if [ ! -f "$ENV_DIR/ergo-oper.txt" ]; then + OPER_PASS="$(head -c18 /dev/urandom | base64 | tr -dc 'A-Za-z0-9' | head -c24)" + printf '%s\n' "$OPER_PASS" > "$ENV_DIR/ergo-oper.txt" + chmod 600 "$ENV_DIR/ergo-oper.txt" + fi + OPER_PASS="$(cat "$ENV_DIR/ergo-oper.txt")" + OPER_HASH="$(printf '%s\n%s\n' "$OPER_PASS" "$OPER_PASS" | /opt/ergo/ergo genpasswd 2>/dev/null | tail -1)" + + # Render the config template from the repo (the __TOKENS__ become real values). + sed -e "s|__NETWORK__|${IRC_NETWORK}|g" \ + -e "s|__DOMAIN__|${DOMAIN}|g" \ + -e "s|__DATA__|${ERGO_DATA}|g" \ + -e "s|__TLS_DIR__|${ERGO_DATA}/tls|g" \ + -e "s|__LANG_DIR__|/opt/ergo/languages|g" \ + -e "s|__OPER_PASSWORD_HASH__|${OPER_HASH}|g" \ + -e "s|__USERS_DIR__|${DATA_DIR}/users|g" \ + "${SRC_DIR}/deploy/ergo/ircd.yaml" > /etc/ergo/ircd.yaml + chmod 640 /etc/ergo/ircd.yaml + + # IRC is members-only: this auth-script approves a SASL login only if the + # account name maps to an AgentBBS member home dir under ${DATA_DIR}/users. + install -m 0755 "${SRC_DIR}/deploy/ergo/auth-script.sh" /usr/local/bin/ergo-auth-member + + # TLS for 6697: reuse Caddy's Let's Encrypt cert for ${DOMAIN}; self-signed + # fallback on first run before Caddy has issued it (the timer swaps it in). + install -m 0755 "${SRC_DIR}/deploy/ergo/refresh-certs.sh" /usr/local/bin/ergo-refresh-certs + DOMAIN="$DOMAIN" ERGO_DATA="$ERGO_DATA" /usr/local/bin/ergo-refresh-certs || true + if [ ! -s "$ERGO_DATA/tls/fullchain.pem" ]; then + warn "no Caddy cert for ${DOMAIN} yet — using a self-signed cert on 6697 until the ergo-certs timer swaps in the real one" + ( cd /etc/ergo && /opt/ergo/ergo mkcerts --conf /etc/ergo/ircd.yaml --quiet 2>/dev/null ) \ + || openssl req -newkey rsa:2048 -nodes -days 90 -x509 \ + -keyout "$ERGO_DATA/tls/privkey.pem" -out "$ERGO_DATA/tls/fullchain.pem" \ + -subj "/CN=irc.${DOMAIN}" 2>/dev/null + fi + chown -R ergo:ergo "$ERGO_DATA" /etc/ergo + + # Initialize the datastore once. + [ -f "$ERGO_DATA/ircd.db" ] || sudo -u ergo /opt/ergo/ergo initdb --conf /etc/ergo/ircd.yaml --quiet + + log "installing ergo.service" + cat > /etc/systemd/system/ergo.service < /etc/systemd/system/ergo-certs.service < /etc/systemd/system/ergo-certs.timer </dev/null 2>&1 || true + systemctl restart ergo + systemctl enable --now ergo-certs.timer >/dev/null 2>&1 || true + ufw allow 6697/tcp >/dev/null + sleep 1 + systemctl is-active --quiet ergo \ + || warn "ergo failed to start — check: journalctl -u ergo -n50" +else + systemctl disable --now ergo ergo-certs.timer >/dev/null 2>&1 || true +fi + # ---- 10. firewall + start agentbbs on :22 ---------------------------------- log "configuring firewall + starting agentbbs" ufw allow 22/tcp >/dev/null @@ -503,9 +644,12 @@ cat < a member's homepage https:// a member's homepage on a custom domain (auto-HTTPS) + IRC irc.${DOMAIN}:6697 (TLS) native clients ${IRC:+(set IRC=0 to disable)} + wss://${DOMAIN}/irc web clients + agents over WebSocket + /OPER admin oper password in ${ENV_DIR}/ergo-oper.txt Config ${ENV_DIR}/agentbbs.env (set CoinPay + LiveKit, then: systemctl restart agentbbs) - Logs journalctl -u agentbbs -f + Logs journalctl -u agentbbs -f (IRC: journalctl -u ergo -f) Update re-run this script (git pull + rebuild + restart) DONE warn "Before you log out: open a new terminal and confirm ssh -p ${ADMIN_SSH_PORT} @${DOMAIN} works." From 302259f65cd0eeec7b7cf0336cd31aee87f0b1a5 Mon Sep 17 00:00:00 2001 From: Anthony Ettinger Date: Sun, 14 Jun 2026 11:35:09 +0000 Subject: [PATCH 2/2] feat(irc): add `ssh irc@` built-in client for the members-only network Adds an in-process IRC client (internal/irc) and an `irc@` SSH route that drops a member straight into the BBS's own Ergo network with no client to install and no SASL to configure. - internal/irc/client.go: minimal IRC client (SASL PLAIN, IRCv3 CAP, PING, PRIVMSG/JOIN/PART/NICK, event stream). Dials Ergo on the loopback 127.0.0.1:6667; presents the member's account name (the SSH key already proved membership; Ergo's auth-script ignores the passphrase by design). - internal/irc/tui.go: Bubble Tea TUI over the SSH PTY (mirrors internal/chat) with /join /part /msg /me /names /nick /help and a current-channel input. - cmd/agentbbs: handleIRC resolves the member by key (members-only, free) and runs the client; routed via auth.IsIRCName. AGENTBBS_IRC_ADDR overrides the target on dev hosts. - auth: reserve `irc` as a route name. Unlike copying tor-irc@ (a third-party client in a pod), this runs our own Go code in-process, so there is no /exec shell-escape surface, and the host process can reach Ergo's loopback listener directly. Validated live against a members-only Ergo: non-members are rejected, a member authenticates via SASL, and channel messages are received. Co-Authored-By: Claude Opus 4.8 --- README.md | 6 +- cmd/agentbbs/main.go | 87 +++++++++++- docs/irc.md | 22 +++- internal/auth/auth.go | 10 +- internal/irc/client.go | 291 +++++++++++++++++++++++++++++++++++++++++ internal/irc/tui.go | 226 ++++++++++++++++++++++++++++++++ 6 files changed, 631 insertions(+), 11 deletions(-) create mode 100644 internal/irc/client.go create mode 100644 internal/irc/tui.go diff --git a/README.md b/README.md index e21bd39..28a60a0 100644 --- a/README.md +++ b/README.md @@ -110,13 +110,17 @@ name is an existing AgentBBS member (registration is off — your BBS account *i your IRC identity): ```bash +# zero-setup: built-in client over SSH (members only) +ssh -t irc@bbs.profullstack.com # native client — SASL account = your BBS member name /connect irc.bbs.profullstack.com 6697 # browser / agent over WebSocket wss://bbs.profullstack.com/irc ``` -Set `IRC=0` to skip it. Full details: [`docs/irc.md`](docs/irc.md). +`ssh irc@` is a built-in IRC client (`internal/irc`) that authenticates you to +the network automatically — no client to install. Set `IRC=0` to skip the +server. Full details: [`docs/irc.md`](docs/irc.md). ## Architecture diff --git a/cmd/agentbbs/main.go b/cmd/agentbbs/main.go index ecd776a..2045799 100644 --- a/cmd/agentbbs/main.go +++ b/cmd/agentbbs/main.go @@ -28,6 +28,7 @@ import ( "encoding/binary" "errors" "fmt" + "io" "net" "net/http" "os" @@ -53,6 +54,7 @@ import ( "github.com/profullstack/agentbbs/internal/forwardemail" "github.com/profullstack/agentbbs/internal/games" "github.com/profullstack/agentbbs/internal/hub" + "github.com/profullstack/agentbbs/internal/irc" "github.com/profullstack/agentbbs/internal/mail" "github.com/profullstack/agentbbs/internal/payments" "github.com/profullstack/agentbbs/internal/plugin" @@ -253,6 +255,8 @@ func (a *app) router() wish.Middleware { a.handleTorIRC(s) case auth.IsTorName(user): a.handleTorCmd(s) + case auth.IsIRCName(user): + a.handleIRC(s) case isVideo: a.handleVideo(s, code) case user == "agent": @@ -320,6 +324,41 @@ func (a *app) teaHandler(s ssh.Session) (tea.Model, []tea.ProgramOption) { return hub.New(u, ctx, a.enabledPlugins()), []tea.ProgramOption{tea.WithAltScreen()} } +// readLine reads one line of interactive input from an SSH session that is +// running under a client-allocated PTY. That detail is the whole reason this +// helper exists: when the client requests a PTY (which `ssh join@host` does by +// default) it puts its OWN terminal into raw mode, so it sends raw keystrokes — +// Enter arrives as '\r', not '\n' — and does NO local echo. bufio.ReadString +// ('\n') therefore blocks forever (the '\n' never comes) and the user sees a +// dead prompt. So we read byte-by-byte, accept either '\r' or '\n' as the line +// terminator, handle backspace, and echo printable bytes back ourselves. +func readLine(s ssh.Session, in *bufio.Reader) (string, error) { + var b []byte + for { + c, err := in.ReadByte() + if err != nil { + return "", err + } + switch c { + case '\r', '\n': + wish.Print(s, "\r\n") + return string(b), nil + case 0x03, 0x04: // Ctrl-C / Ctrl-D: treat as abort + return "", io.EOF + case 0x7f, '\b': // DEL / backspace: erase last char on screen too + if len(b) > 0 { + b = b[:len(b)-1] + wish.Print(s, "\b \b") + } + default: + if c >= 0x20 { // printable byte; ignore other control codes + b = append(b, c) + wish.Print(s, string(c)) + } + } + } +} + // handleJoin runs onboarding interactively in one SSH session: register the // visitor's key, confirm their email with a code we email them, then offer the // $10 lifetime Premium membership (CoinPay). It then disconnects. @@ -398,7 +437,7 @@ func (a *app) registerNewMember(s ssh.Session, in *bufio.Reader, fp string) (sto for tries := 0; tries < 5; tries++ { wish.Print(s, "\n Username ["+def+"]: ") - line, err := in.ReadString('\n') + line, err := readLine(s, in) if err != nil { return store.User{}, err } @@ -433,7 +472,7 @@ func (a *app) verifyEmailInteractive(s ssh.Session, in *bufio.Reader, u *store.U var email string for tries := 0; tries < 3; tries++ { wish.Print(s, "\n Email: ") - line, err := in.ReadString('\n') + line, err := readLine(s, in) if err != nil { return false } @@ -472,7 +511,7 @@ func (a *app) verifyEmailInteractive(s ssh.Session, in *bufio.Reader, u *store.U for tries := 0; tries < 3; tries++ { wish.Print(s, " Enter the code: ") - line, err := in.ReadString('\n') + line, err := readLine(s, in) if err != nil { return false } @@ -891,6 +930,48 @@ func (a *app) handleTorIRC(s ssh.Session) { } } +// handleIRC drops a member into the BBS's own (members-only) IRC network using +// an in-process client: it authenticates to Ergo over SASL as the member and +// runs a Bubble Tea TUI. Free for any registered member; needs a PTY. Distinct +// from tor-irc@ (a client for remote servers over Tor). +func (a *app) handleIRC(s ssh.Session) { + fp := auth.Fingerprint(s.PublicKey()) + if fp == "" { + wish.Println(s, "irc@ needs your registered SSH key. New here? ssh join@"+a.host) + _ = s.Exit(1) + return + } + u, found, err := a.st.UserByFingerprint(fp) + if err != nil || !found { + wish.Println(s, "the IRC network is members-only — register first: ssh join@"+a.host) + _ = s.Exit(1) + return + } + if u.Banned { + wish.Println(s, "this account is suspended.") + _ = s.Exit(1) + return + } + sessID, _ := a.st.RecordSession(u.ID, s.User(), remoteIP(s), "irc") + defer func() { _ = a.st.EndSession(sessID) }() + + addr := strings.TrimSpace(os.Getenv("AGENTBBS_IRC_ADDR")) + if addr == "" { + addr = irc.DefaultAddr + } + log.Info("irc connect", "user", u.Name, "addr", addr) + c, err := irc.Dial(s.Context(), addr, u.Name) + if err != nil { + wish.Println(s, "irc: "+err.Error()) + _ = s.Exit(1) + return + } + _ = c.Join(irc.DefaultChannel) + if err := irc.Run(s, c); err != nil { + wish.Println(s, "irc: "+err.Error()) + } +} + // handleTorCmd runs an arbitrary command through Tor (torsocks) inside the // member's pod, never on the host. Premium; requires a PTY. func (a *app) handleTorCmd(s ssh.Session) { diff --git a/docs/irc.md b/docs/irc.md index fec1f49..74d6afe 100644 --- a/docs/irc.md +++ b/docs/irc.md @@ -13,13 +13,26 @@ operationally independent of the wish server. | Path | Address | For | |---|---|---| +| In-BBS | `ssh -t irc@bbs.profullstack.com` | members — zero-setup built-in client (see below) | | Native TLS | `irc.bbs.profullstack.com:6697` (TLS) | desktop/CLI clients (HexChat, irssi, WeeChat, Halloy…) | | WebSocket | `wss://bbs.profullstack.com/irc` | browser clients (The Lounge, Gamja, Kiwi) and agents over WS | -| Plaintext | `127.0.0.1:6667` | **loopback only** — on-box tooling/bridges; firewalled off | +| Plaintext | `127.0.0.1:6667` | **loopback only** — on-box tooling/the `irc@` client; firewalled off | The WebSocket path is fronted by Caddy (it terminates TLS and reverse-proxies to Ergo's loopback `127.0.0.1:8097`), so no extra public port is opened for the web. +### `ssh irc@` — the built-in client + +`ssh -t irc@bbs.profullstack.com` drops a member straight into the network with +no client to install or SASL to configure. It is an **in-process IRC client** +(`internal/irc`) running inside the agentbbs process: it reaches Ergo on the +loopback `127.0.0.1:6667` and authenticates as you (your SSH key already proved +you're a member, so it presents your account name over SASL). Because the client +is our own Go code — not a third-party client in a pod — there is no `/exec` +shell-escape surface. You land in `#lobby`; type to talk, or use +`/join #chan`, `/msg `, `/me`, `/names`, `/nick`, `/help`, and +`esc` to leave. Override the target with `AGENTBBS_IRC_ADDR` on a dev host. + ### Membership (who can connect) The network is **members-only**. There is **no self-service registration** — @@ -112,14 +125,11 @@ up immediately; the timer swaps in the real one once it exists. Unrelated, complementary. `ssh tor-irc@bbs.profullstack.com ` is a **client** that connects *out* to a remote (e.g. `.onion`) IRC server from inside -a member's pod. This is the BBS hosting **its own** IRC network for people and -agents to meet on. +a member's pod. `irc@` (above) and the 6697/WebSocket listeners are the BBS +hosting **its own** IRC network for people and agents to meet on. ## Ideas / next steps -- **In-BBS `irc@` route** — an SSH route that drops a member straight into the - local network (mirroring `tor-irc@` but pointed at `127.0.0.1:6667`), so - `ssh irc@bbs.profullstack.com` is an instant client with no setup. - **Bridge to `internal/chat`** — relay the BBS hub chat ↔ an IRC channel. - **Per-pod / per-game channels** — auto-create `#pod-`, `#game-`. - **Persistent history** — switch `datastore.mysql` on if replay must survive diff --git a/internal/auth/auth.go b/internal/auth/auth.go index b8276d5..7c5bcf8 100644 --- a/internal/auth/auth.go +++ b/internal/auth/auth.go @@ -56,6 +56,11 @@ var TorIRCNames = map[string]bool{"tor-irc": true} // member's pod (premium). Checked after the more specific tor-* routes. var TorNames = map[string]bool{"tor": true} +// IRCNames route a member straight into the BBS's own (members-only) IRC +// network via an in-process client. Distinct from tor-irc@, which is a client +// for connecting OUT to remote IRC servers over Tor. +var IRCNames = map[string]bool{"irc": true} + // GameNames are usernames that route to AgentGames: the line-delimited-JSON // agent-vs-agent match protocol (PRD §5.2). `play@` stays a guest hub alias. var GameNames = map[string]bool{"game": true, "games": true} @@ -84,6 +89,9 @@ func IsTorIRCName(u string) bool { return TorIRCNames[strings.ToLower(u)] } // IsTorName reports whether the SSH username requests the generic tor passthrough. func IsTorName(u string) bool { return TorNames[strings.ToLower(u)] } +// IsIRCName reports whether the SSH username requests the in-BBS IRC client. +func IsIRCName(u string) bool { return IRCNames[strings.ToLower(u)] } + // systemReserved are names that don't drive an SSH route but would still // collide with a per-user subdomain (.), the agent route, or common // infra hostnames — so members may not claim them as account names. @@ -100,7 +108,7 @@ var systemReserved = map[string]bool{ func IsReservedName(name string) bool { n := strings.ToLower(name) if GuestNames[n] || PodNames[n] || JoinNames[n] || DomainNames[n] || AdminNames[n] || - TorURLNames[n] || TorIRCNames[n] || TorNames[n] || systemReserved[n] { + TorURLNames[n] || TorIRCNames[n] || TorNames[n] || IRCNames[n] || systemReserved[n] { return true } return strings.HasPrefix(n, "video-") // video- call routes diff --git a/internal/irc/client.go b/internal/irc/client.go new file mode 100644 index 0000000..84a7868 --- /dev/null +++ b/internal/irc/client.go @@ -0,0 +1,291 @@ +// Package irc is a minimal, in-process IRC client for the `irc@` route: it +// connects a member to the BBS's own (members-only) Ergo network and drives a +// Bubble Tea TUI (see tui.go). It runs inside the agentbbs process on the host, +// so it reaches Ergo's loopback listener directly and — unlike running a +// third-party client like irssi in a pod — offers no /exec shell escape. +// +// The member is already authenticated to the BBS by their SSH key; we present +// their account name to Ergo over SASL PLAIN. Ergo's auth-script approves the +// login on membership alone (the passphrase is ignored, by design), so we send +// a placeholder. +package irc + +import ( + "bufio" + "context" + "encoding/base64" + "fmt" + "net" + "strings" + "time" +) + +// DefaultAddr is the host-local plaintext Ergo listener (loopback only; the +// public front door is 6697/TLS). Overridable for dev hosts. +const DefaultAddr = "127.0.0.1:6667" + +// Event is one thing that happened on the connection, already formatted for +// display. Kind groups them so the TUI can colorize. +type Event struct { + Kind EventKind + // Channel is the conversation the event belongs to ("" = server/status). + Channel string + Nick string + Text string +} + +type EventKind int + +const ( + EvMessage EventKind = iota // a PRIVMSG to a channel or to us + EvNotice // a NOTICE (often from services) + EvJoin + EvPart + EvQuit + EvNick + EvSystem // numerics, topics, names, errors, our own status lines + EvClosed // the connection ended; Text carries the reason +) + +// Client is a single member's connection to the network. +type Client struct { + conn net.Conn + w *bufio.Writer + r *bufio.Reader + nick string + events chan Event +} + +// Dial connects to addr, performs the SASL PLAIN handshake as nick, and blocks +// until the server welcomes us (001) or the attempt fails. On success the read +// loop is running and Events() is live. +func Dial(ctx context.Context, addr, nick string) (*Client, error) { + if addr == "" { + addr = DefaultAddr + } + d := net.Dialer{Timeout: 10 * time.Second} + conn, err := d.DialContext(ctx, "tcp", addr) + if err != nil { + return nil, fmt.Errorf("could not reach the IRC server (%s): %w", addr, err) + } + c := &Client{ + conn: conn, + w: bufio.NewWriter(conn), + r: bufio.NewReader(conn), + nick: nick, + events: make(chan Event, 256), + } + if err := c.handshake(nick); err != nil { + _ = conn.Close() + return nil, err + } + go c.readLoop() + return c, nil +} + +// Events is the stream the TUI consumes. It is closed when the connection ends. +func (c *Client) Events() <-chan Event { return c.events } + +// Nick reports the connection's current nickname. +func (c *Client) Nick() string { return c.nick } + +func (c *Client) send(format string, a ...any) error { + if _, err := fmt.Fprintf(c.w, format+"\r\n", a...); err != nil { + return err + } + return c.w.Flush() +} + +// handshake authenticates with SASL PLAIN and waits for welcome (001) or an +// auth failure (904/906) / error. The membership gate lives server-side; the +// passphrase is a placeholder the auth-script ignores. +func (c *Client) handshake(nick string) error { + _ = c.conn.SetDeadline(time.Now().Add(20 * time.Second)) + if err := c.send("CAP LS 302"); err != nil { + return err + } + if err := c.send("NICK %s", nick); err != nil { + return err + } + if err := c.send("USER %s 0 * :%s", nick, nick); err != nil { + return err + } + if err := c.send("CAP REQ :sasl"); err != nil { + return err + } + for { + line, err := c.r.ReadString('\n') + if err != nil { + return fmt.Errorf("connection closed during login: %w", err) + } + msg := parse(line) + switch msg.command { + case "PING": + _ = c.send("PONG :%s", msg.trailing()) + case "CAP": + // params: <*> ACK :sasl → start PLAIN exchange + if len(msg.params) >= 2 && msg.params[1] == "ACK" { + _ = c.send("AUTHENTICATE PLAIN") + } + case "AUTHENTICATE": + if msg.first() == "+" { + tok := base64.StdEncoding.EncodeToString([]byte("\x00" + nick + "\x00x")) + _ = c.send("AUTHENTICATE %s", tok) + } + case "903": // SASL success → close capability negotiation so we get 001 + _ = c.send("CAP END") + case "900": // RPL_LOGGEDIN (informational; 903 drives CAP END) + case "904", "905", "906": // SASL failed/aborted + return fmt.Errorf("the network is members-only and rejected %q — register first: ssh join@", nick) + case "433": // nick in use + return fmt.Errorf("nickname %q is already in use on the network", nick) + case "ERROR": + return fmt.Errorf("server refused the connection: %s", msg.trailing()) + case "001": // welcome — we're in + _ = c.conn.SetDeadline(time.Time{}) // clear; read loop manages liveness + return nil + } + } +} + +// readLoop turns inbound IRC into Events until the connection drops. +func (c *Client) readLoop() { + defer close(c.events) + for { + line, err := c.r.ReadString('\n') + if err != nil { + c.emit(Event{Kind: EvClosed, Text: "disconnected"}) + return + } + msg := parse(line) + switch msg.command { + case "PING": + _ = c.send("PONG :%s", msg.trailing()) + case "PRIVMSG": + c.emit(Event{Kind: EvMessage, Channel: msg.first(), Nick: msg.nick(), Text: msg.trailing()}) + case "NOTICE": + c.emit(Event{Kind: EvNotice, Channel: msg.first(), Nick: msg.nick(), Text: msg.trailing()}) + case "JOIN": + c.emit(Event{Kind: EvJoin, Channel: msg.first(), Nick: msg.nick()}) + case "PART": + c.emit(Event{Kind: EvPart, Channel: msg.first(), Nick: msg.nick(), Text: msg.trailing()}) + case "QUIT": + c.emit(Event{Kind: EvQuit, Nick: msg.nick(), Text: msg.trailing()}) + case "NICK": + n := msg.nick() + if n == c.nick { + c.nick = msg.trailing() + } + c.emit(Event{Kind: EvNick, Nick: n, Text: msg.trailing()}) + case "332": // RPL_TOPIC + c.emit(Event{Kind: EvSystem, Channel: msg.nth(1), Text: "topic: " + msg.trailing()}) + case "353": // RPL_NAMREPLY + c.emit(Event{Kind: EvSystem, Channel: msg.nth(2), Text: "names: " + msg.trailing()}) + case "ERROR": + c.emit(Event{Kind: EvClosed, Text: msg.trailing()}) + return + default: + // Surface numeric replies (server info, MOTD, errors) as status. + if len(msg.command) == 3 && msg.command[0] >= '0' && msg.command[0] <= '9' { + c.emit(Event{Kind: EvSystem, Text: msg.trailing()}) + } + } + } +} + +func (c *Client) emit(e Event) { + select { + case c.events <- e: + default: // drop if the TUI is far behind rather than block the read loop + } +} + +// Privmsg sends a message to a channel or nick. +func (c *Client) Privmsg(target, text string) error { return c.send("PRIVMSG %s :%s", target, text) } + +// Join joins a channel. +func (c *Client) Join(ch string) error { return c.send("JOIN %s", ch) } + +// Part leaves a channel. +func (c *Client) Part(ch string) error { return c.send("PART %s", ch) } + +// Raw sends a pre-formed IRC command (for /-commands the TUI doesn't model). +func (c *Client) Raw(line string) error { return c.send("%s", line) } + +// Close quits cleanly and tears down the socket. +func (c *Client) Close() error { + _ = c.send("QUIT :leaving") + return c.conn.Close() +} + +// --- minimal message parsing ------------------------------------------------ + +type message struct { + prefix string + command string + params []string // includes the trailing param as the last element + hasTrail bool +} + +func parse(line string) message { + line = strings.TrimRight(line, "\r\n") + var m message + if strings.HasPrefix(line, "@") { // strip IRCv3 tags; we don't use them here + if i := strings.IndexByte(line, ' '); i >= 0 { + line = line[i+1:] + } + } + if strings.HasPrefix(line, ":") { + i := strings.IndexByte(line, ' ') + if i < 0 { + return m + } + m.prefix = line[1:i] + line = line[i+1:] + } + // trailing param + if i := strings.Index(line, " :"); i >= 0 { + trail := line[i+2:] + line = line[:i] + m.command, m.params = splitCmd(line) + m.params = append(m.params, trail) + m.hasTrail = true + return m + } + m.command, m.params = splitCmd(line) + return m +} + +func splitCmd(s string) (string, []string) { + f := strings.Fields(s) + if len(f) == 0 { + return "", nil + } + return strings.ToUpper(f[0]), f[1:] +} + +// nick returns the nick from the prefix (nick!user@host). +func (m message) nick() string { + if i := strings.IndexByte(m.prefix, '!'); i >= 0 { + return m.prefix[:i] + } + return m.prefix +} + +// first returns the first param (often the target/channel), else "". +func (m message) first() string { return m.nth(0) } + +func (m message) nth(i int) string { + if i >= 0 && i < len(m.params) { + return m.params[i] + } + return "" +} + +// trailing returns the trailing (message) param, else the last param. +func (m message) trailing() string { + if len(m.params) == 0 { + return "" + } + return m.params[len(m.params)-1] +} diff --git a/internal/irc/tui.go b/internal/irc/tui.go new file mode 100644 index 0000000..ffae9b5 --- /dev/null +++ b/internal/irc/tui.go @@ -0,0 +1,226 @@ +package irc + +import ( + "fmt" + "strings" + + tea "github.com/charmbracelet/bubbletea" + "github.com/charmbracelet/lipgloss" + "github.com/charmbracelet/ssh" +) + +const historyLines = 500 + +// DefaultChannel is joined automatically when a member enters via irc@. +const DefaultChannel = "#lobby" + +var ( + cTitle = lipgloss.NewStyle().Bold(true).Foreground(lipgloss.Color("#c084fc")) + cNick = lipgloss.NewStyle().Foreground(lipgloss.Color("#4ade80")) + cSelf = lipgloss.NewStyle().Foreground(lipgloss.Color("#38bdf8")) + cSys = lipgloss.NewStyle().Foreground(lipgloss.Color("241")) + cNote = lipgloss.NewStyle().Foreground(lipgloss.Color("#fbbf24")) + cErr = lipgloss.NewStyle().Foreground(lipgloss.Color("203")) +) + +// Run drives the IRC TUI over the SSH session until the member leaves; leaving +// ends the session (irc@ is a dedicated route, like agent@). +func Run(s ssh.Session, c *Client) error { + ptyReq, winCh, hasPty := s.Pty() + if !hasPty { + _, _ = s.Write([]byte("irc needs a terminal (ssh -t irc@)\r\n")) + return nil + } + m := &model{ + c: c, + channel: DefaultChannel, + width: ptyReq.Window.Width, + height: ptyReq.Window.Height, + } + m.lines = append(m.lines, + cSys.Render(fmt.Sprintf("connected as %s — joined %s. /help for commands, esc to leave.", c.Nick(), DefaultChannel))) + p := tea.NewProgram(m, tea.WithInput(s), tea.WithOutput(s), tea.WithAltScreen()) + go func() { + for w := range winCh { + p.Send(tea.WindowSizeMsg{Width: w.Width, Height: w.Height}) + } + }() + _, err := p.Run() + _ = c.Close() + return err +} + +// waitEvent blocks on the next connection event and delivers it to the model. +func waitEvent(c *Client) tea.Cmd { + return func() tea.Msg { + e, ok := <-c.Events() + if !ok { + return Event{Kind: EvClosed, Text: "disconnected"} + } + return e + } +} + +type model struct { + c *Client + channel string // current conversation target for typed lines + lines []string + input string + + width, height int +} + +func (m *model) Init() tea.Cmd { return waitEvent(m.c) } + +func (m *model) push(line string) { + m.lines = append(m.lines, line) + if len(m.lines) > historyLines { + m.lines = m.lines[len(m.lines)-historyLines:] + } +} + +func (m *model) Update(msg tea.Msg) (tea.Model, tea.Cmd) { + switch msg := msg.(type) { + case tea.WindowSizeMsg: + m.width, m.height = msg.Width, msg.Height + case Event: + return m.handleEvent(msg) + case tea.KeyMsg: + switch msg.String() { + case "ctrl+c", "esc": + return m, tea.Quit + case "enter": + return m.handleInput() + case "backspace": + if len(m.input) > 0 { + m.input = m.input[:len(m.input)-1] + } + default: + if msg.Type == tea.KeyRunes || msg.String() == " " { + m.input += string(msg.Runes) + } + } + } + return m, nil +} + +func (m *model) handleEvent(e Event) (tea.Model, tea.Cmd) { + switch e.Kind { + case EvMessage: + where := "" + if !strings.HasPrefix(e.Channel, "#") { // a direct message to us + where = cNote.Render("[dm] ") + } + m.push(where + cNick.Render(e.Nick) + " " + e.Text) + case EvNotice: + m.push(cNote.Render("-"+e.Nick+"- ") + e.Text) + case EvJoin: + m.push(cSys.Render(fmt.Sprintf("→ %s joined %s", e.Nick, e.Channel))) + case EvPart: + m.push(cSys.Render(fmt.Sprintf("← %s left %s %s", e.Nick, e.Channel, e.Text))) + case EvQuit: + m.push(cSys.Render(fmt.Sprintf("← %s quit (%s)", e.Nick, e.Text))) + case EvNick: + m.push(cSys.Render(fmt.Sprintf("* %s is now %s", e.Nick, e.Text))) + case EvSystem: + if e.Text != "" { + m.push(cSys.Render(e.Text)) + } + case EvClosed: + m.push(cErr.Render("* connection closed: " + e.Text)) + return m, tea.Quit + } + return m, waitEvent(m.c) +} + +func (m *model) handleInput() (tea.Model, tea.Cmd) { + text := strings.TrimSpace(m.input) + m.input = "" + if text == "" { + return m, nil + } + if strings.HasPrefix(text, "/") { + return m, m.command(text) + } + // plain line → message to the current channel + if err := m.c.Privmsg(m.channel, text); err != nil { + m.push(cErr.Render("send failed: " + err.Error())) + return m, nil + } + m.push(cSelf.Render(m.c.Nick()) + " " + text) + return m, nil +} + +// command handles the small set of /-commands the TUI models; anything else is +// passed through raw so power users can drive the server directly. +func (m *model) command(text string) tea.Cmd { + fields := strings.Fields(text) + cmd := strings.ToLower(fields[0]) + arg := strings.TrimSpace(strings.TrimPrefix(text, fields[0])) + switch cmd { + case "/help": + m.push(cSys.Render("commands: /join #chan /part [#chan] /msg /me /names /nick /quit")) + case "/join": + if arg == "" { + m.push(cErr.Render("usage: /join #channel")) + break + } + ch := arg + if !strings.HasPrefix(ch, "#") { + ch = "#" + ch + } + _ = m.c.Join(ch) + m.channel = ch + m.push(cSys.Render("joining " + ch)) + case "/part": + ch := m.channel + if arg != "" { + ch = arg + } + _ = m.c.Part(ch) + m.push(cSys.Render("leaving " + ch)) + case "/msg": + f := strings.SplitN(arg, " ", 2) + if len(f) < 2 { + m.push(cErr.Render("usage: /msg ")) + break + } + _ = m.c.Privmsg(f[0], f[1]) + m.push(cSelf.Render(m.c.Nick()) + " " + cNote.Render("→"+f[0]+" ") + f[1]) + case "/me": + if arg == "" { + break + } + _ = m.c.Privmsg(m.channel, "\x01ACTION "+arg+"\x01") + m.push(cSelf.Render("* "+m.c.Nick()) + " " + arg) + case "/names": + _ = m.c.Raw("NAMES " + m.channel) + case "/nick": + if arg == "" { + m.push(cErr.Render("usage: /nick ")) + break + } + _ = m.c.Raw("NICK " + arg) + case "/quit": + return tea.Quit + default: + _ = m.c.Raw(strings.TrimPrefix(text, "/")) + m.push(cSys.Render("» " + strings.TrimPrefix(text, "/"))) + } + return nil +} + +func (m *model) View() string { + rows := m.height - 4 + if rows < 3 { + rows = 3 + } + start := 0 + if len(m.lines) > rows { + start = len(m.lines) - rows + } + body := strings.Join(m.lines[start:], "\n") + header := cTitle.Render("irc@ — "+m.channel) + cSys.Render(" ("+m.c.Nick()+" · esc to leave)") + prompt := cSys.Render(m.channel+" ") + "› " + m.input + "█" + return lipgloss.NewStyle().Padding(0, 1).Render(header + "\n" + body + "\n\n" + prompt) +}