main/config_default/nats_daemon.sh

0001 #!/bin/bash
0002 set -e
0003
0004 # Environment variables
0005 if [ ! -z "$NATS_TOKEN" ]; then
0006     echo "NATS_TOKEN is defined: $NATS_TOKEN"
0007     export NATS_TOKEN=${NATS_TOKEN}
0008 else
0009     echo "NATS_TOKEN is not defined"
0010     export NATS_TOKEN=my_default_token
0011 fi
0012
0013
0014 # Start NATS in the background
0015 # /usr/local/bin/nats-server --jetstream --store_dir /var/log/idds --auth ${NATS_TOKEN} &
0016 /usr/local/bin/nats-server --addr 0.0.0.0 --jetstream --store_dir /var/log/idds --auth ${NATS_TOKEN} &
0017
0018 # Wait for NATS to be ready
0019 echo "Waiting for NATS to start..."
0020 until nats --server nats://127.0.0.1:4222 --token ${NATS_TOKEN} account info >/dev/null 2>&1; do
0021     sleep 1
0022 done
0023 echo "NATS is up!"
0024
0025 # Create the JetStream stream
0026 nats --server nats://127.0.0.1:4222 --token ${NATS_TOKEN} stream add event_stream \
0027     --subjects="event.*" \
0028     --replicas=1 \
0029     --storage=memory \
0030     --retention=work \
0031     --discard=old \
0032     --max-age=10m \
0033     --dupe-window=5m \
0034     --max-msgs=-1 \
0035     --max-msgs-per-subject=-1 \
0036     --no-allow-rollup \
0037     --max-bytes=-1 \
0038     --max-msg-size=-1 \
0039     --no-deny-delete \
0040     --no-deny-purge || true
0041
0042 # Wait for NATS to exit (keep it in foreground)
0043 wait
0044