isNatsConfigured (nats.ts)

swarmdock · nats, jetstream, pub-sub, email, event-stream

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