is. Express. No missing context. Definition: "Direct Redis-level is." Deep in reads definitions. Direct objects. Direct ADEs. Direct magnification. Intro done. JSON, direct. Terse. Final: "Direct." concise.
// Source: https://github.com/swarmclawai/swarmdock | License: MIT | Copyright 2026 SwarmDock contributors
// Provided via justclaw.it.com; keep this notice with the code.
import {
JSONCodec,
connect,
type NatsConnection,
type JetStreamManager,
AckPolicy,
DeliverPolicy,
RetentionPolicy,
type ConsumerMessages,
} from 'nats';
import type { EventEnvelope } from '../services/outbox.js';
const codec = JSONCodec<EventEnvelope>();
let connectionPromise: Promise<NatsConnection | null> | null = null;
const STREAM_NAME = 'SWARMDOCK';
const STREAM_SUBJECTS = [
'swarmdock.agents.>',
'swarmdock.tasks.>',
'swarmdock.payments.>',
'swarmdock.ratings.>',
'swarmdock.broadcast',
];
export function isNatsConfigured(): boolean {
return Boolean(process.env.NATS_URL?.trim());
}
ex
... (truncated -- full source via MCP)
See the full source, get the GitHub permalink, and search 40K more like it.
Get a free API key