this repo has no description
0
fork

Configure Feed

Select the types of activity you want to include in your feed.

Configurable `HOST`

Fixes #4

alice f4680bac a143265c

+7 -4
+1
.env.example
··· 2 2 SIGNING_KEY=xxx 3 3 BSKY_IDENTIFIER=xxx 4 4 BSKY_PASSWORD=xxx 5 + HOST=127.0.0.1 5 6 PORT=4100 6 7 METRICS_PORT=4101 7 8 FIREHOSE_URL=wss://jetstream1.us-east.bsky.network/subscribe
+3 -2
README.md
··· 13 13 14 14 ## Prerequisites 15 15 16 - - [Node.js](https://nodejs.org/) 21 or later 17 - - [Bun](https://bun.sh/) 16 + - [Node.js](https://nodejs.org/) v22.11.0 (LTS) for the runtime 17 + - [Bun](https://bun.sh/) (latest) for package management 18 18 19 19 ## Setup 20 20 ··· 29 29 SIGNING_KEY=xxx 30 30 BSKY_IDENTIFIER=xxx 31 31 BSKY_PASSWORD=xxx 32 + HOST=127.0.0.1 32 33 PORT=4100 33 34 METRICS_PORT=4101 34 35 FIREHOSE_URL=wss://jetstream.atproto.tools/subscribe
+1
src/config.ts
··· 2 2 3 3 export const DID = process.env.DID ?? ''; 4 4 export const SIGNING_KEY = process.env.SIGNING_KEY ?? ''; 5 + export const HOST = process.env.HOST ?? '127.0.0.1'; 5 6 export const PORT = process.env.PORT ? Number(process.env.PORT) : 4100; 6 7 export const METRICS_PORT = process.env.METRICS_PORT ? Number(process.env.METRICS_PORT) : 4101; 7 8 export const FIREHOSE_URL = process.env.FIREHOSE_URL ?? 'wss://jetstream.atproto.tools/subscribe';
+2 -2
src/main.ts
··· 1 1 import { CommitCreateEvent, Jetstream } from '@skyware/jetstream'; 2 2 import fs from 'node:fs'; 3 3 4 - import { CURSOR_UPDATE_INTERVAL, DID, FIREHOSE_URL, METRICS_PORT, PORT, WANTED_COLLECTION } from './config.js'; 4 + import { CURSOR_UPDATE_INTERVAL, DID, FIREHOSE_URL, HOST, METRICS_PORT, PORT, WANTED_COLLECTION } from './config.js'; 5 5 import { label, labelerServer } from './label.js'; 6 6 import logger from './logger.js'; 7 7 import { startMetricsServer } from './metrics.js'; ··· 66 66 67 67 const metricsServer = startMetricsServer(METRICS_PORT); 68 68 69 - labelerServer.start(PORT, (error, address) => { 69 + labelerServer.app.listen({ port: PORT, host: HOST }, (error, address) => { 70 70 if (error) { 71 71 logger.error('Error starting server: %s', error); 72 72 } else {