feat: initial structure

2026-10-20 08:20:52 +00:00 · 2024-08-15 14:49:30 +08:00
parent f4244c6d4d
commit f4384bb01e
13 changed files with 409 additions and 0 deletions
@@ -0,0 +1,44 @@
+import { TDbClient } from "@app/db";
+import { TableName } from "@app/db/schemas";
+import { ormify, selectAllTableCols } from "@app/lib/knex";
+
+export type TCertificateTemplateDALFactory = ReturnType<typeof certificateTemplateDALFactory>;
+
+export const certificateTemplateDALFactory = (db: TDbClient) => {
+  const certificateTemplateOrm = ormify(db, TableName.CertificateTemplate);
+
+  const getCertTemplatesByProjectId = async (projectId: string) => {
+    const certTemplates = await db
+      .replicaNode()(TableName.CertificateTemplate)
+      .join(
+        TableName.CertificateAuthority,
+        `${TableName.CertificateAuthority}.id`,
+        `${TableName.CertificateTemplate}.caId`
+      )
+      .where(`${TableName.CertificateAuthority}.projectId`, "=", projectId)
+      .select(selectAllTableCols(TableName.CertificateTemplate));
+
+    return certTemplates;
+  };
+
+  const getById = async (id: string) => {
+    const certTemplate = await db
+      .replicaNode()(TableName.CertificateTemplate)
+      .join(
+        TableName.CertificateAuthority,
+        `${TableName.CertificateAuthority}.id`,
+        `${TableName.CertificateTemplate}.caId`
+      )
+      .where(`${TableName.CertificateTemplate}.id`, "=", id)
+      .select(selectAllTableCols(TableName.CertificateTemplate))
+      .select(
+        db.ref("projectId").withSchema(TableName.CertificateAuthority),
+        db.ref("friendlyName").as("caName").withSchema(TableName.CertificateAuthority)
+      )
+      .first();
+
+    return certTemplate;
+  };
+
+  return { ...certificateTemplateOrm, getCertTemplatesByProjectId, getById };
+};