feat(core): add get record query handler

packages/core/queries/get-record/get-record.query.handler.ts

@@ -0,0 +1,18 @@
+import type { IQueryHandler } from '@egodb/domain'
+import type { IRecordQueryModel } from '../../record'
+import { WithRecordId } from '../../record'
+import type { ITableRepository } from '../../table.repository'
+import type { GetRecordQuery } from './get-record.query'
+import type { IGetRecordOutput } from './get-record.query.interface'
+
+export class GetRecordQueryHandler implements IQueryHandler<GetRecordQuery, IGetRecordOutput> {
+  constructor(protected readonly tableRepo: ITableRepository, protected readonly rm: IRecordQueryModel) {}
+
+  async execute(query: GetRecordQuery): Promise<IGetRecordOutput> {
+    const spec = WithRecordId.fromString(query.id)
+
+    const record = (await this.rm.findOne(spec)).unwrap()
+
+    return record
+  }
+}

packages/core/queries/get-record/get-record.query.input.ts

@@ -0,0 +1,6 @@
+import * as z from 'zod'
+import { recordIdSchema } from '../../record'
+
+export const getRecordQueryInput = z.object({
+  id: recordIdSchema,
+})

packages/core/queries/get-record/get-record.query.interface.ts

@@ -0,0 +1,6 @@
+import type * as z from 'zod'
+import type { getRecordQueryInput } from './get-record.query.input'
+import type { getRecordQueryOutput } from './get-record.query.output'
+
+export type IGetRecordQuery = z.infer<typeof getRecordQueryInput>
+export type IGetRecordOutput = z.infer<typeof getRecordQueryOutput>

packages/core/queries/get-record/get-record.query.output.ts

@@ -0,0 +1,3 @@
+import { queryRecordSchema } from '../../record'
+
+export const getRecordQueryOutput = queryRecordSchema.optional()

packages/core/queries/get-record/get-record.query.ts

@@ -0,0 +1,10 @@
+import { Query } from '@egodb/domain'
+import type { IGetRecordQuery } from './get-record.query.interface'
+
+export class GetRecordQuery extends Query implements IGetRecordQuery {
+  readonly id: string
+  constructor(query: IGetRecordQuery) {
+    super()
+    this.id = query.id
+  }
+}

packages/core/queries/get-record/index.ts

@@ -0,0 +1,5 @@
+export * from './get-record.query'
+export * from './get-record.query.handler'
+export * from './get-record.query.input'
+export * from './get-record.query.interface'
+export * from './get-record.query.output'

packages/core/queries/index.ts

@@ -1,3 +1,4 @@
+export * from './get-record'
 export * from './get-records'
 export * from './get-table'
 export * from './get-tables'

packages/trpc/router/record.ts

@@ -2,6 +2,9 @@ import {
   CreateRecordCommand,
   createRecordCommandInput,
   createRecordCommandOutput,
+  GetRecordQuery,
+  getRecordQueryInput,
+  getRecordQueryOutput,
   GetRecordsQuery,
   getRecordsQueryInput,
   getRecordsQueryOutput,
@@ -24,6 +27,14 @@ export const createRecordRouter =
           const cmd = new CreateRecordCommand(input)
           return commandBus.execute(cmd)
         }),
+      get: procedure
+        .meta({ openapi: { method: 'GET', path: '/record.get', tags } })
+        .input(getRecordQueryInput)
+        .output(getRecordQueryOutput)
+        .query(({ input }) => {
+          const query = new GetRecordQuery(input)
+          return queryBus.execute(query)
+        }),
       list: procedure
         .meta({ openapi: { method: 'GET', path: '/record.list', tags } })
         .input(getRecordsQueryInput)