fix: backfill old sessions and do queue backpressure (#2449)

* fix: backfill old sessions and do queue backpressure

* fix typo

1 files changed, 12 insertions, 0 deletions

diff --git a/packages/shared/logger.ts b/packages/shared/logger.ts
index efe78ff3..f3c5d45d 100644
--- a/packages/shared/logger.ts
+++ b/packages/shared/logger.ts
@@ -14,4 +14,16 @@ const logger = winston.createLogger({
   transports: [new winston.transports.Console()],
 });
 
+export function throttledLogger(periodMs: number) {
+  let lastLogTime = 0;
+
+  return (level: string, message: string) => {
+    const now = Date.now();
+    if (now - lastLogTime >= periodMs) {
+      lastLogTime = now;
+      logger.log(level, message);
+    }
+  };
+}
+
 export default logger;