f16de6026d
The TelemetryClient only flushed at 50 events, so the server silently lost all queued telemetry on restart. Add startPeriodicFlush/stop methods to TelemetryClient, wire up 60s periodic flush in server initTelemetry, and flush on SIGTERM/SIGINT before exit. Co-Authored-By: Paperclip <noreply@paperclip.ing>
30 lines
848 B
TypeScript
30 lines
848 B
TypeScript
import path from "node:path";
|
|
import {
|
|
TelemetryClient,
|
|
resolveTelemetryConfig,
|
|
loadOrCreateState,
|
|
} from "@paperclipai/shared/telemetry";
|
|
import { resolvePaperclipInstanceRoot } from "./home-paths.js";
|
|
import { serverVersion } from "./version.js";
|
|
|
|
let client: TelemetryClient | null = null;
|
|
|
|
export function initTelemetry(fileConfig?: { enabled?: boolean }): TelemetryClient | null {
|
|
if (client) return client;
|
|
|
|
const config = resolveTelemetryConfig(fileConfig);
|
|
if (!config.enabled) return null;
|
|
|
|
const stateDir = path.join(resolvePaperclipInstanceRoot(), "telemetry");
|
|
client = new TelemetryClient(
|
|
config,
|
|
() => loadOrCreateState(stateDir, serverVersion),
|
|
serverVersion,
|
|
);
|
|
client.startPeriodicFlush(60_000);
|
|
return client;
|
|
}
|
|
|
|
export function getTelemetryClient(): TelemetryClient | null {
|
|
return client;
|
|
}
|