#23 Upsert System

scylla-server/src/services/systems.services.ts

@@ -1,11 +1,29 @@
 import prisma from '../prisma/prisma-client';
-import { ResponseFunction } from '../utils/message-maps.utils';
 
 /**
  * CRUD operation to get all systems with ResponseFunction type
- * @returns string contianing all the systems in the db
+ * @returns Promise<string> contianing all the systems in the db
  */
-export const getAllSystems: ResponseFunction = async () => {
+export async function getAllSystems(): Promise<string> {
   const data = await prisma.system.findMany();
   return JSON.stringify(data);
-};
+}
+
+/**
+ * CRUD opertation that creates system if it doesn't exist, otherwise does nothing.
+ * Currently designated private so not hooked up to server.
+ * @param system_name name of the system as string
+ * @returns Promise<void>
+ */
+export async function upsertSystems(system_name: string): Promise<void> {
+  await prisma.system.upsert({
+    where: {
+      name: system_name
+    },
+    update: {},
+    create: {
+      name: system_name,
+      runs: undefined,
+    }
+  });
+}

scylla-server/tests/systems-services.test.ts

@@ -1,16 +1,56 @@
-import prisma from '../src/prisma/prisma-client';
 import { describe, test, expect } from 'vitest';
+import { getAllSystems, upsertSystems } from '../src/services/systems.services';
 
-/**
- * Tests for CRUD service functions
- */
+import prisma from '../src/prisma/prisma-client';
 
 /**
- * basic ahh unit test for get all systems
+ * Tests for CRUD Service functions
  */
 describe('CRUD Systems', () => {
+  /**
+   * updated unit test for get all systems
+   */
   test('Get All Systems Works', async () => {
-    const allSystems = await prisma.system.findMany();
-    expect(allSystems).toStrictEqual([]);
+    const expected = [];
+    const result = await getAllSystems();
+
+    // Parse result to a JavaScript object from the JSON string
+    const parsedResult = JSON.parse(result);
+
+    // Use toEqual to compare parsedResult with the expected array
+    expect(parsedResult).toEqual(expected);
+  });
+
+  /**
+   * unit test for upsert system
+   * testing creating system if doesn't exist
+   */
+  test('Upsert System Creates', async () => {
+    const expected = [{ name: 'test' }];
+    await upsertSystems('test');
+    const result = JSON.parse(await getAllSystems());
+
+    // Use toEqual to compare parsedResult with the expected array
+    expect(result).toEqual(expected);
+  });
+
+  /**
+   * unit test for upsert system
+   * testing does nothing if system does exist
+   */
+  test('Upsert System Does Nothing', async () => {
+    const expected = [{ name: 'test' }];
+    upsertSystems('test');
+    const result = JSON.parse(await getAllSystems());
+
+    // Use toEqual to compare result with the expected array
+    expect(result).toEqual(expected);
+
+    //cleaning up
+    await prisma.system.delete({
+      where: {
+        name: 'test'
+      }
+    });
   });
 });