logos-messaging/js-waku
1
0
Fork 0
mirror of https://github.com/logos-messaging/js-waku.git synced 2026-01-07 08:13:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: add logging to LocalHistory for storage init

Browse Source
This commit is contained in:
Danish Arora 2025-11-26 22:40:12 -05:00
parent 907572956b
commit 3e3c5111b7
No known key found for this signature in database
GPG Key ID: 1C6EF37CDAE1426E
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
packages/sds/src/message_channel/mem_local_history.ts
View File

@ -1,3 +1,4 @@
import { Logger } from "@waku/utils";
import _ from "lodash"; import _ from "lodash";
import { type ChannelId, ContentMessage, isContentMessage } from "./message.js"; import { type ChannelId, ContentMessage, isContentMessage } from "./message.js";
@ -53,6 +54,8 @@ export type MemLocalHistoryOptions = {
maxSize?: number; maxSize?: number;
}; };
const log = new Logger("sds:local-history");
export class MemLocalHistory implements ILocalHistory { export class MemLocalHistory implements ILocalHistory {
private items: ContentMessage[] = []; private items: ContentMessage[] = [];
private readonly storage?: PersistentStorage; private readonly storage?: PersistentStorage;
@ -70,10 +73,13 @@ export class MemLocalHistory implements ILocalHistory {
this.maxSize = maxSize ?? DEFAULT_MAX_LENGTH; this.maxSize = maxSize ?? DEFAULT_MAX_LENGTH;
if (storage instanceof PersistentStorage) { if (storage instanceof PersistentStorage) {
this.storage = storage; this.storage = storage;
log.info("Using explicit persistent storage");
} else if (typeof storage === "string") { } else if (typeof storage === "string") {
this.storage = PersistentStorage.create(storage); this.storage = PersistentStorage.create(storage);
log.info("Creating persistent storage for channel", storage);
} else { } else {
this.storage = undefined; this.storage = undefined;
log.info("Using in-memory storage");
} }
this.load(); this.load();