feat(chrono): add LogUseCase

Author: zzhenryquezz

packages/chrono/playground/PlayApp.ts

@@ -48,6 +48,10 @@ async function run() {
             name: 'checkout',
             method: 'checkout',
         },
+        {
+            name: 'log',
+            method: 'log',
+        },
     ]
 
     const command = options.find((o) => o.name === commandName)

packages/chrono/src/ChronoApp.ts

@@ -13,13 +13,14 @@ import LocalHeadEntryRepository from './repositories/implementations/LocalHeadEn
 
 import InitUseCase from './use-cases/InitUseCase'
 import CatFileUseCase from './use-cases/CatFileUseCase'
-import HashFileUseCase from './use-cases/HashEntryUseCase'
+import HashEntryUseCase from './use-cases/HashEntryUseCase'
 import RemoveUseCase from './use-cases/RemoveUseCase'
 import CommitUseCase from './use-cases/CommitUseCase'
 import StatusUseCase from './use-cases/StatusUseCase'
 import AddUseCase from './use-cases/AddUseCase'
 import ListFilesUseCase from './use-cases/ListFilesUseCase'
 import CheckoutUseCase from './use-cases/CheckoutUseCase'
+import LogUseCase from './use-cases/LogUseCase'
 
 export default class ChronoApp {
     private readonly drive: IDrive
@@ -47,7 +48,7 @@ export default class ChronoApp {
     }
 
     public async hashEntry(path: string) {
-        const useCase = new HashFileUseCase(this.drive, this.objectRepository, this.blobRepository)
+        const useCase = new HashEntryUseCase(this.drive, this.objectRepository, this.blobRepository)
 
         return useCase.execute({ path })
     }
@@ -113,4 +114,10 @@ export default class ChronoApp {
 
         return useCase.execute({ hash, path })
     }
+
+    public async log() {
+        const useCase = new LogUseCase(this.objectRepository)
+
+        return useCase.execute()
+    }
 }

packages/chrono/src/entities/ChronoObject.ts

@@ -6,6 +6,7 @@ export default class ChronoObject {
     public static readonly HEAD_SEPARATOR = '\n\0\n'
 
     public content = ''
+    public hash = ''
 
     public get headText() {
         const [head] = this.content.split(ChronoObject.HEAD_SEPARATOR)
@@ -35,7 +36,11 @@ export default class ChronoObject {
         return this.head.type
     }
 
-    constructor(content: string | Uint8Array) {
+    constructor(content: string | Uint8Array, hash?: string) {
+        if (hash) {
+            this.hash = hash
+        }
+
         if (typeof content === 'string') {
             this.content = content
         }

packages/chrono/src/entities/ChronoObjectCommit.ts

@@ -20,6 +20,10 @@ export default class ChronoObjectCommit extends ChronoObject {
         return this.head.parent
     }
 
+    public get date() {
+        return this.head.date
+    }
+
     public static from(payload: Payload) {
         const object = ChronoObject.fromObject({ ...payload, type: 'commit' }, payload.body)
 
@@ -28,8 +32,12 @@ export default class ChronoObjectCommit extends ChronoObject {
 
     public serialize() {
         return {
-            ...super.serialize(),
+            hash: this.hash,
+            type: this.type,
             message: this.message,
+            tree: this.tree,
+            parent: this.parent,
+            date: this.date,
         }
     }
 }

packages/chrono/src/repositories/IObjectRepository.ts

@@ -1,6 +1,7 @@
 import ChronoObject from '../entities/ChronoObject'
 
 export default interface IObjectRepository {
+    findAll(): Promise<ChronoObject[]>
     find(objectHash: string): Promise<ChronoObject | null>
     findOrFail(objectHash: string): Promise<ChronoObject>
     save(object: ChronoObject): Promise<{ objectHash: string }>

packages/chrono/src/repositories/implementations/LocalObjectRepository.ts

@@ -25,11 +25,28 @@ export default class LocalObjectRepository implements IObjectRepository {
 
         await this.drive.write(filePath, chronoObject.toBytes())
 
+        chronoObject.hash = objectHash
+
         return {
             objectHash,
         }
     }
 
+    public findAll: IObjectRepository['findAll'] = async () => {
+        const files = await this.drive.readdir(this.directory, {
+            recursive: true,
+            onlyFiles: true,
+        })
+
+        const result: ChronoObject[] = []
+
+        for await (const file of files) {
+            result.push(await this.findOrFail(file.replace('/', '')))
+        }
+
+        return result
+    }
+
     public find: IObjectRepository['find'] = async (objectHash) => {
         const startHash = objectHash.slice(0, 2)
         const endHash = objectHash.slice(2)
@@ -60,7 +77,7 @@ export default class LocalObjectRepository implements IObjectRepository {
             return null
         }
 
-        const chronoObject = new ChronoObject(bytes)
+        const chronoObject = new ChronoObject(bytes, objectHash)
 
         return chronoObject
     }

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

@@ -143,6 +143,7 @@ export default class CommitUseCase {
         const payload: any = {
             message,
             tree: rooTreeHash,
+            date: new Date().toISOString(),
         }
 
         const headContents = await this.drive.read('.chrono/head')
@@ -166,9 +167,6 @@ export default class CommitUseCase {
 
         await this.entryRepository.saveAll(entries)
 
-        return {
-            commitHash,
-            commit: commit.serialize(),
-        }
+        return commit.serialize()
     }
 }

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

@@ -0,0 +1,16 @@
+import ChronoObjectCommit from '../entities/ChronoObjectCommit'
+import IObjectRepository from '../repositories/IObjectRepository'
+
+export default class LogUseCase {
+    constructor(private readonly objectRepository: IObjectRepository) {}
+
+    public async execute() {
+        const objects = await this.objectRepository.findAll()
+
+        return objects
+            .filter((object) => object.type === 'commit')
+            .map((o) => new ChronoObjectCommit(o.content, o.hash))
+            .map((o) => o.serialize())
+            .toSorted((a, b) => new Date(b.date).getTime() - new Date(a.date).getTime())
+    }
+}