Thomas Camlong
67ac2bbc7c
- Redis get() rejects legacy expire=0 entries and cleans them up - transferOwnership invalidates previous owner in addition to new - SVG regex uses non-greedy match and handles self-closing <svg /> - SVG fallback returns empty string instead of HTML wrapper - Memory channel comment: FIFO eviction, not timestamp-based
35 lines
992 B
TypeScript
35 lines
992 B
TypeScript
import EventEmitter from "node:events";
|
|
|
|
import superjson from "superjson";
|
|
|
|
const emitter = new EventEmitter();
|
|
emitter.setMaxListeners(100);
|
|
|
|
const lastData = new Map<string, { data: string; timestamp: number }>();
|
|
const MAX_ENTRIES = 500;
|
|
|
|
export const memoryPublish = (channel: string, data: unknown) => {
|
|
const serialized = superjson.stringify(data);
|
|
lastData.set(channel, { data: serialized, timestamp: Date.now() });
|
|
|
|
// ponytail: FIFO eviction by Map insertion order, not timestamp.
|
|
if (lastData.size > MAX_ENTRIES) {
|
|
const oldest = lastData.keys().next().value;
|
|
if (oldest) lastData.delete(oldest);
|
|
}
|
|
|
|
emitter.emit(channel, serialized);
|
|
};
|
|
|
|
export const memorySubscribe = (channel: string, callback: (data: string) => void) => {
|
|
emitter.on(channel, callback);
|
|
return () => {
|
|
emitter.off(channel, callback);
|
|
};
|
|
};
|
|
|
|
export const memoryGetLast = (channel: string): string | null => {
|
|
const entry = lastData.get(channel);
|
|
return entry?.data ?? null;
|
|
};
|