Merge pull request #19 from yogesh-aggarwal/chore/refactor

chore: missing code organization techniques in ingestion server

Author: preeesha

ingestion/.vscode/settings.json

@@ -0,0 +1,7 @@
+{
+   "explorer.fileNesting.enabled": true,
+   "explorer.fileNesting.patterns": {
+      "package.json": "package-lock.json, .env, .env.example, .gitignore, .prettierrc, Dockerfile, nodemon.json, tsconfig.json, *.lock, README.md",
+      "*.ts": "$(capture).*.ts"
+   }
+}

ingestion/bun.lock

@@ -0,0 +1,19 @@
+import { RC_APP_URI } from "@/core/constants"
+import { CodeModelRelation } from "@/models/code"
+
+export async function establishRelations(relations: CodeModelRelation[]): Promise<boolean> {
+   try {
+      const res = await fetch(`${RC_APP_URI}/establishRelations`, {
+         method: "POST",
+         headers: {
+            "Content-Type": "application/json",
+         },
+         body: JSON.stringify({ relations }),
+      })
+
+      return res.status === 200
+   } catch (e) {
+      console.log(e)
+      return false
+   }
+}

ingestion/bun.lockb

@@ -0,0 +1,3 @@
+export { purgeDB } from "./purge-db"
+export { insertBatch } from "./insert-batch"
+export { establishRelations } from "./establish-relations"

ingestion/src/api/establish-relations.ts

@@ -0,0 +1,29 @@
+import { RC_APP_URI } from "@/core/constants"
+import { CodeModel } from "@/models/code"
+import { DocumentationModel } from "@/models/devdoc"
+
+export async function insertBatch(batchID: string, nodes: (CodeModel | DocumentationModel)[]): Promise<boolean> {
+   let tries = 5
+   while (tries--) {
+      try {
+         const res = await fetch(`${RC_APP_URI}/ingest`, {
+            method: "POST",
+            headers: {
+               accept: "application/json",
+               "Content-Type": "application/json",
+            },
+            body: JSON.stringify({ nodes, batchID }),
+         })
+
+         if (res.status !== 200) {
+            console.log(res)
+            return false
+         }
+
+         return true
+      } catch (e) {
+         console.log(e)
+      }
+   }
+   return false
+}

ingestion/src/api/index.ts

@@ -0,0 +1,18 @@
+import { RC_APP_URI } from "@/core/constants"
+
+export async function purgeDB(): Promise<boolean> {
+   try {
+      const res = await fetch(`${RC_APP_URI}/purgeDB`, {
+         method: "POST",
+         headers: {
+            accept: "application/json",
+            "Content-Type": "application/json",
+         },
+      })
+
+      return res.status === 200
+   } catch (e) {
+      console.log(e)
+      return false
+   }
+}