add repository for project

Author: jjnp

services/src/kysely/migrations/2024-04-28T09:42:38Z_init.ts

@@ -11,7 +11,7 @@ export async function up(db: Kysely<unknown>): Promise<void> {
 	await createTableMigration(db, 'projects')
 		.addColumn('name', 'text', (col) => col.unique().notNull())
 		.addColumn('base_language', 'integer', (col) =>
-			col.references('languages.id').onDelete('restrict').notNull()
+			col.references('languages.id').onDelete('restrict')
 		)
 		.execute()
 

services/src/project/project-repository.integration.test.ts

@@ -0,0 +1,52 @@
+import { beforeEach, describe, expect, it } from 'vitest'
+import type { PojectCreationParams, SelectableProject } from './project'
+import { db } from '../db/database'
+import { runMigration } from '../db/database-migration-util'
+import { createProject, deleteProjectById, getProjectById } from './project.repository'
+
+const projectCreationObject: PojectCreationParams = {
+  name: 'some project name'
+}
+
+beforeEach(async () => {
+  db.reset()
+  await runMigration()
+})
+
+describe('Project Repository', () => {
+  describe('createProject', () => {
+    it('should create a project with the correct attributes', async () => {
+      await createProject(projectCreationObject)
+
+      const projects = await db.selectFrom('projects').selectAll().execute()
+      expect(projects).toHaveLength(1)
+
+      const project = projects[0] as SelectableProject
+
+      expect(project).toMatchObject(projectCreationObject)
+      expect(project.id).toBeTypeOf('number')
+    })
+  })
+
+  describe('getProjectById', () => {
+    it('should get a created project with its ID', async () => {
+      const createdProject = await createProject(projectCreationObject)
+
+      const retrievedProject = await getProjectById(createdProject.id)
+
+      expect(retrievedProject.id).toBe(createdProject.id)
+    })
+  })
+
+  describe('deleteProjectById', () => {
+    it('should delete a project based on its ID', async () => {
+      const createdProject = await createProject(projectCreationObject)
+
+      const retrievedProject = await getProjectById(createdProject.id)
+      expect(retrievedProject).toBeTruthy()
+
+      await deleteProjectById(createdProject.id)
+      expect(() => getProjectById(createdProject.id)).rejects.toThrowError()
+    })
+  })
+})

services/src/project/project.repository.ts

@@ -0,0 +1,24 @@
+import { db } from '../db/database'
+import type { PojectCreationParams } from './project'
+
+export function createProject(projectParams: PojectCreationParams) {
+	return db
+		.insertInto('projects')
+		.values({
+			...projectParams
+		})
+		.returningAll()
+		.executeTakeFirstOrThrow(() => new Error('Error creating Project'))
+}
+
+export function getProjectById(projectId: number) {
+	return db
+		.selectFrom('projects')
+		.selectAll()
+		.where('projects.id', '==', projectId)
+		.executeTakeFirstOrThrow(() => new Error(`Could not find Project with ID "${projectId}"`))
+}
+
+export function deleteProjectById(projectId: number) {
+	return db.deleteFrom('projects').where('projects.id', '==', projectId).execute()
+}

services/src/project/project.ts

@@ -0,0 +1,7 @@
+import type { Insertable, Selectable } from 'kysely'
+import type { Projects } from 'kysely-codegen'
+
+export type PojectCreationParams = Insertable<
+  Omit<Projects, 'id' | 'created_at' | 'updated_at' | 'base_language'>
+>
+export type SelectableProject = Selectable<Projects>