diff --git a/src/rdrama/services/CommentProcessor.ts b/src/rdrama/services/CommentProcessor.ts index d692f1b..226d98d 100644 --- a/src/rdrama/services/CommentProcessor.ts +++ b/src/rdrama/services/CommentProcessor.ts @@ -32,7 +32,7 @@ export class CommentProcessor { const exists = await RedisCommentService.retrieveComment(comment.id.toString()); if (exists) { - console.log(`Comment ${comment.id} exists`) + console.log(`${new Date()} Comment ${comment.id} exists`) stopFetching = true; break; // Stop processing this batch of comments } @@ -41,7 +41,7 @@ export class CommentProcessor { // Optionally publish the comment to a Redis channel for subscribers await RedisCommentService.publishComment(comment); - console.log(`Published Comment ${comment.id}`) + console.log(`${new Date()} Published Comment ${comment.id}`) // prevent accidental recognition of a previous comment comments.push(comment); }