wmantly
fe71ec1bcc
The announcer half of AGENT_LOCAL_DISCOVERY_SPEC.md / MULTI_SITE_SPEC.md Appendix B -- advertises which public hostnames this site fronts (and at what local IP) via mDNS, so a theta-agent on the same LAN segment with prefer_local_directory enabled can skip the relay/WAN path. Opt-in via THETA_LOCAL_DISCOVERY_HOSTS (comma-separated); no-op if unset, so this changes nothing for an install that doesn't configure it. Only ever advertises which hostnames map to which local IP -- no identity/ trust information -- consistent with the hard rule on the listening side (theta-agent) that local-discovery may change DNS resolution but must never touch certificate validation. Verified end-to-end against the real theta-agent Go binary: announce, discover, apply, and clean revert on disappearance all confirmed working over real multicast between two containers.
55 lines
1.9 KiB
JavaScript
55 lines
1.9 KiB
JavaScript
#!/usr/bin/env node
|
|
'use strict';
|
|
|
|
// Boots BOTH faces of the jump host: the SSH front door (services/ssh_server)
|
|
// and the web UI/API (app.js + Socket.IO). One process, one redis, shared
|
|
// audit store.
|
|
|
|
const http = require('http');
|
|
const conf = require('@simpleworkjs/conf');
|
|
const { Server } = require('socket.io');
|
|
|
|
// @simpleworkjs/conf loads ./config/jump-secrets.js synchronously, then
|
|
// @simpleworkjs/bao-conf deep-merges secret/jump-host/conf from OpenBao over
|
|
// it. The OIDC clientSecret is captured at require time inside models (via
|
|
// createOidcClient), so the fetch MUST resolve before require('../models').
|
|
// Fail-soft: if OpenBao is unreachable, init() leaves conf as the file-loaded
|
|
// fallback and boot continues from ./config/jump-secrets.js.
|
|
require('@simpleworkjs/bao-conf').init({ path: 'jump-host', conf }).then(async () => {
|
|
require('../models');
|
|
const { bootstrapWireguard } = require('../services/wg_bootstrap');
|
|
await bootstrapWireguard();
|
|
const { startMdnsAnnounce } = require('../services/mdns_announce');
|
|
await startMdnsAnnounce();
|
|
|
|
const app = require('../app');
|
|
const middleware = require('../middleware/auth');
|
|
const sshServer = require('../services/ssh_server');
|
|
|
|
const webPort = (conf.web && conf.web.port) || 3002;
|
|
const server = http.createServer(app);
|
|
|
|
// Socket.IO — the client framework (app-base.js) opens an authenticated socket.
|
|
// We don't push anything yet, but serving /socket.io keeps the shared front-end
|
|
// working exactly as it does in the sibling apps.
|
|
const io = new Server(server);
|
|
io.use(middleware.authIO);
|
|
app.io = io;
|
|
|
|
server.listen(webPort, () => {
|
|
console.log(`[web] jump-host UI/API on :${server.address().port}`);
|
|
});
|
|
|
|
sshServer.start();
|
|
|
|
function shutdown() {
|
|
console.log('[jump-host] shutting down');
|
|
server.close();
|
|
process.exit(0);
|
|
}
|
|
process.on('SIGTERM', shutdown);
|
|
process.on('SIGINT', shutdown);
|
|
}).catch(err => {
|
|
console.error('boot failed:', err);
|
|
process.exit(1);
|
|
}); |