feat(chrono): add cat-file use-case

Author: zzhenryquezz

packages/chrono/.eslintrc.json

@@ -1,4 +1,12 @@
 {
     "root": true,
-    "extends": "@index-san/eslint-config/ts"
+    "extends": "@index-san/eslint-config/ts",
+    "overrides": [
+        {
+            "files": ["playground/*.ts"],
+            "rules": {
+                "no-console": "off"
+            }
+        }
+    ]
 }

packages/chrono/playground/PlayApp.ts

@@ -7,6 +7,12 @@ const hash = new PlayHash()
 
 const app = new ChronoApp(drive, hash)
 
-// app.init()
+async function run() {
+    // app.init()
 
-app.hashFile('message.md')
+    // app.hashFile('message.md')
+
+    console.log(await app.catFile('1cd0ff195e53a0a31601aae77b23e20e63f6d244'))
+}
+
+run()

packages/chrono/src/ChronoApp.ts

@@ -4,6 +4,7 @@ import BlobRepositoryImpl from './repositories/BlobRepositoryImpl'
 import IBlobRepository from './repositories/IBlobRepository'
 import IObjectRepository from './repositories/IObjectRepository'
 import ObjectRepositoryImpl from './repositories/ObjectRepositoryImpl'
+import CatFileUseCase from './use-cases/CatFileUseCase'
 import HashFileUseCase from './use-cases/HashFileUseCase'
 import InitUseCase from './use-cases/InitUseCase'
 
@@ -30,4 +31,10 @@ export default class ChronoApp {
 
         await useCase.execute({ path })
     }
+
+    public async catFile(objectHash: string) {
+        const useCase = new CatFileUseCase(this.objectRepository)
+
+        return await useCase.execute({ objectHash })
+    }
 }

packages/chrono/src/use-cases/CatFileUseCase.spec.ts

@@ -0,0 +1,33 @@
+import { test, expect, describe } from 'vitest'
+import InMemoryDrive from '../__tests__/InMemoryDrive'
+import HelperService from '../services/HelperService'
+import CatFileUseCase from './CatFileUseCase'
+import InMemoryHash from '../__tests__/InMemoryHash'
+import ObjectRepositoryImpl from '../repositories/ObjectRepositoryImpl'
+import ChronoObject from '../entities/ChronoObject'
+
+const drive = new InMemoryDrive()
+const hash = new InMemoryHash()
+const objectRepository = new ObjectRepositoryImpl(drive, hash)
+
+const useCase = new CatFileUseCase(objectRepository)
+
+describe('CatFileUseCase', () => {
+    test('should return chrono object', async () => {
+        await drive.write('message.md', HelperService.encode('Hello World!'))
+
+        const { objectHash } = await objectRepository.save(
+            new ChronoObject({
+                type: 'blob',
+                blobHash: '123',
+            })
+        )
+
+        const result = await useCase.execute({ objectHash })
+
+        expect(result).toEqual({
+            type: 'blob',
+            blobHash: '123',
+        })
+    })
+})

packages/chrono/src/use-cases/CatFileUseCase.ts

@@ -0,0 +1,20 @@
+import BaseException from '../exceptions/BaseException'
+import IObjectRepository from '../repositories/IObjectRepository'
+
+interface CatUseCaseParams {
+    objectHash: string
+}
+
+export default class CatFileUseCase {
+    constructor(private readonly objectRepository: IObjectRepository) {}
+
+    async execute({ objectHash }: CatUseCaseParams) {
+        const object = await this.objectRepository.find(objectHash)
+
+        if (!object) {
+            throw new BaseException(`Object ${objectHash} not found`)
+        }
+
+        return object
+    }
+}