[#958] Create crud jobs to get active job, add and update the job

app/src/database/crud/crud-jobs.js

@@ -0,0 +1,56 @@
+import * as Crypto from 'expo-crypto';
+import { conn, query } from '../';
+
+const db = conn.init;
+
+export const jobStatus = {
+  PENDING: 1,
+  ON_PROGRESS: 2,
+  SUCCESS: 3,
+  FAILED: 4,
+  FINISH: 5,
+};
+
+export const MAX_ATTEMPT = 3;
+
+const tableName = 'jobs';
+const jobsQuery = () => {
+  return {
+    getActiveJob: async (type) => {
+      const where = { active: 1, type };
+      const nocase = false;
+      const order_by = 'createdAt';
+      const readQuery = query.read(tableName, where, nocase, order_by);
+      const { rows } = await conn.tx(db, readQuery, [1, type]);
+      if (!rows.length) {
+        return null;
+      }
+      return rows._array[0];
+    },
+    addJob: async (data = {}) => {
+      try {
+        const createdAt = new Date().toISOString()?.replace('T', ' ')?.split('.')?.[0] || null;
+        const insertQuery = query.insert(tableName, {
+          ...data,
+          createdAt,
+          uuid: Crypto.randomUUID(),
+        });
+        return await conn.tx(db, insertQuery, []);
+      } catch (error) {
+        return null;
+      }
+    },
+    updateJob: async (id, data) => {
+      try {
+        const updateQuery = query.update(tableName, { id }, { ...data });
+        return await conn.tx(db, updateQuery, [id]);
+      } catch {
+        return null;
+      }
+    },
+  };
+};
+
+const crudJobs = jobsQuery();
+
+export default crudJobs;