Merge pull request #80 from juni-b-queer/agent-save-session-data

feat: New IsNewPost validator to easily filter out the imported posts

.gitignore

@@ -8,6 +8,7 @@
 /dist
 
 .env
+tests/temp
 
 .idea/
 

src/validations/message-validators/post/PostValidators.ts

@@ -66,3 +66,24 @@ export class IsReplyValidator extends AbstractMessageValidator {
         return handlerAgent.hasPostReply(message);
     }
 }
+
+export class IsNewPost extends AbstractMessageValidator {
+    constructor() {
+        super();
+    }
+
+    static make(): IsNewPost {
+        return new IsNewPost();
+    }
+
+    async handle(
+        handlerAgent: HandlerAgent,
+        message: CreateSkeetMessage
+    ): Promise<boolean> {
+        const createdAt = new Date(message.record.createdAt);
+        const now = new Date();
+        const oneDay = 24 * 60 * 60 * 1000;
+
+        return now.getTime() - createdAt.getTime() < oneDay;
+    }
+}

tests/validations/post/PostValidators/IsNewPost.test.ts

@@ -0,0 +1,60 @@
+import {
+    CreateSkeetMessage,
+    CreateSkeetMessageFactory,
+    CreateSkeetRecord,
+    CreateSkeetRecordFactory,
+    HandlerAgent,
+    IsNewPost,
+} from '../../../../src';
+import { BskyAgent } from '@atproto/api';
+import dotenv from 'dotenv';
+import fs from 'fs';
+
+const sessPath = './tests/temp/val/post/isNewPost';
+dotenv.config();
+process.env.SESSION_DATA_PATH = sessPath;
+
+describe('IsNewPost', () => {
+    afterAll(() => {
+        fs.rmSync(sessPath, {
+            recursive: true,
+            force: true,
+        });
+    });
+    fs.mkdirSync(sessPath, { recursive: true });
+    const validator = IsNewPost.make();
+    const botDid = 'did:plc:bot';
+    const bskyAgent: BskyAgent = {
+        session: {
+            did: botDid,
+        },
+    } as BskyAgent;
+    const handlerAgent: HandlerAgent = new HandlerAgent(
+        'name',
+        'handle',
+        'password',
+        bskyAgent
+    );
+
+    test('handle returns true if message is created within the last 24 hours', async () => {
+        const recentDate = new Date();
+        recentDate.setHours(recentDate.getHours() - 1);
+        const message: CreateSkeetMessage = CreateSkeetMessageFactory.factory()
+            .record({
+                createdAt: recentDate.toISOString(),
+            } as CreateSkeetRecord)
+            .create();
+
+        expect(await validator.handle(handlerAgent, message)).toBe(true);
+    });
+
+    test('handle returns false if message is created more than 24 hours ago', async () => {
+        const oldDate = new Date();
+        oldDate.setDate(oldDate.getDate() - 2);
+        const message: CreateSkeetMessage = CreateSkeetMessageFactory.factory()
+            .record({ createdAt: oldDate.toISOString() } as CreateSkeetRecord)
+            .create();
+
+        expect(await validator.handle(handlerAgent, message)).toBe(false);
+    });
+});