.github/workflows/ci.yml

@@ -90,11 +90,15 @@ jobs:
         env:
           # Required to allow Datadog to trace Vitest tests
           NODE_OPTIONS: -r ${{ env.DD_TRACE_PACKAGE }} --import ${{ env.DD_TRACE_ESM_IMPORT }}
+          # Set timezone to Singapore to ensure that the tests are run in the correct timezone
+          TZ: Asia/Singapore
       - name: Test Components
         run: turbo test-ci:unit --filter=@opengovsg/isomer-components --env-mode=loose
         env:
           # Required to allow Datadog to trace Vitest tests
           NODE_OPTIONS: -r ${{ env.DD_TRACE_PACKAGE }} --import ${{ env.DD_TRACE_ESM_IMPORT }}
+          # Set timezone to Singapore to ensure that the tests are run in the correct timezone
+          TZ: Asia/Singapore
 
   end-to-end-tests:
     name: End-to-end tests

apps/studio/prisma/constants.ts

@@ -1,5 +1,5 @@
 export const ISOMER_ADMINS = [
-  "alex",
+  "alexander",
   "jan",
   "jiachin",
   "sehyun",
@@ -19,4 +19,6 @@ export const ISOMER_MIGRATORS = [
   "yongteng",
   "huaying",
   "weiping",
+  "sophie",
+  "felicia",
 ]

apps/studio/prisma/scripts/FileLogger.ts

@@ -0,0 +1,46 @@
+import fs from "fs"
+import path from "path"
+
+export class FileLogger {
+  private logFilePath: string
+
+  constructor(logFilePath: string) {
+    this.logFilePath = logFilePath
+
+    // Ensure the directory for the log file exists
+    const logDir = path.dirname(logFilePath)
+    if (!fs.existsSync(logDir)) {
+      fs.mkdirSync(logDir, { recursive: true })
+    }
+  }
+
+  private formatLog(level: string, message: string): string {
+    const timestamp = new Date().toISOString()
+    return `[${timestamp}] [${level.toUpperCase()}] ${message}\n`
+  }
+
+  private writeLog(logMessage: string): void {
+    fs.appendFile(this.logFilePath, logMessage, (err) => {
+      if (err) {
+        console.error("Failed to write log:", err)
+      }
+    })
+  }
+
+  log(level: string, message: string): void {
+    const logMessage = this.formatLog(level, message)
+    this.writeLog(logMessage)
+  }
+
+  info(message: string): void {
+    this.log("info", message)
+  }
+
+  error(message: string): void {
+    this.log("error", message)
+  }
+
+  debug(message: string): void {
+    this.log("debug", message)
+  }
+}

apps/studio/prisma/scripts/moh-tosp/README.md

@@ -0,0 +1,71 @@
+# MOH-TOSP Scripts
+
+## Summary
+
+This folder contains developer/ops scripts to update MOH TOSP collection in our DB.
+
+Note: The full steps are covered in [runbook](https://www.notion.so/opengov/Isomer-Next-Runbook-13177dbba78880f4835cdd370c11eef6?pvs=4#16477dbba7888045aadad0fee69c5f79).
+
+To perform the update, this is the overall sequence we will undertake:
+
+1. We will backup the existing collection
+2. Load the new collection into DB with all resources in "Draft" state in a different permalink e.g. `cost-financing-new`
+3. We will verify the new collection on Studio
+4. We will rename the old collection's permalink and swap it with the new collection. E.g. `/cost-financing` becomes `/cost-financing-old`, `/cost-financing-new` is renamed to become `/cost-financing`
+5. We will then publish this new draft collection
+
+### Pre-requisites
+
+- Ensure you have the necessary environment variables set up before running these scripts.
+
+### Running the scripts
+
+Use `source .env && npx tsx prisma/scripts/moh-tosp/<script-name>` within `isomer/apps/studio` directory to run any of the scripts.
+
+## Scripts
+
+### 1. `backupCollectionById.ts`
+
+This script takes in 2 input arguments which is the `collectionId` and the `backupDirectory`. Given these params, the script "downloads" the existing collection into the local path of your computer for backup purposes.
+
+### 2. `createCollectionFromLocal.ts`
+
+Pre-requisites:
+You will need a folder with the collection to be loaded in the following structure:
+
+```
+/content                  ----> contentDir
+    /cost-financing       ----> collectionName
+    cost-financing.json   ----> indexPageName
+```
+
+This script takes in the following arguments:
+
+1. `contentDir`: path to the folder that contains the collection to be loaded into DB
+2. `collectionName`: name of the collection to be loaded into DB (e.g. `cost-financing`)
+3. `indexPageName`: name of the index page of the collection to be loaded into DB (e.g. `cost-financing`)
+4. `indexPageTitle`: name of the index page to show visually (e.g. `Cost financing`)
+5. `nameOfNewCollectionToCreate`: This is the name of collection to be created in the DB. This will also become the permalink for the new collection. e.g. `cost-financing-new`
+6. `siteId`: ID of the site to create the collection into
+
+### 3. `publishDraftCollection.ts`
+
+This script publishes the draft collection that was created. To do so, it requires the following arguments:
+
+1. `publisherId`: ID of the Studio user who is publishing the collection. This ID can be obtained from the `User` table. Make sure this user has access to the site as well.
+2. `collectionId`: ID of the collection to be published. You can check this in the `Resource` table on the `id` column.
+
+### 4. `deleteCollectionById.ts`
+
+**Note: Use this with caution as it is NON-RECOVERABLE**.
+
+This script deletes a collection and its contents. It takes the following arguments:
+
+1. `collectionIdToDelete`: ID of the collection to be deleted. Can be checked in the `Resource` table
+2. `siteId`: ID of the site to which the collection belongs to
+
+## Recovery Options
+
+In case that the migration needs to be unrolled back to original state, we can execute the same steps described in "Summary" section using the backup taken.
+
+For full details, refer to the [runbook](https://www.notion.so/opengov/Isomer-Next-Runbook-13177dbba78880f4835cdd370c11eef6?pvs=4#16477dbba7888045aadad0fee69c5f79).

apps/studio/prisma/scripts/moh-tosp/backupCollectionById.ts

@@ -0,0 +1,90 @@
+import fs from "fs/promises" // Use the promise-based version of fs for async/await
+import path from "path"
+
+import { db } from "~/server/modules/database"
+import { FileLogger } from "../FileLogger"
+
+// Update the logger path if required
+const logger = new FileLogger("./backupCollectionById.log")
+
+interface BackupCollectionInput {
+  resourceId: string
+  backupDir: string
+}
+
+/**
+ * Backup a collection and its relevant resources to JSON files.
+ * @param {string} resourceId - ID of the collection resource to back up.
+ * @param {string} backupDir - Directory to save the backup files.
+ */
+export async function backupCollection({
+  resourceId,
+  backupDir,
+}: BackupCollectionInput): Promise<void> {
+  try {
+    // Ensure the backup directory exists
+    await fs.mkdir(backupDir, { recursive: true })
+
+    // Fetch the collection resource
+    const collection = await db
+      .selectFrom("Resource")
+      .selectAll()
+      .where("id", "=", resourceId)
+      .executeTakeFirst()
+
+    if (!collection) {
+      throw new Error(`Collection with ID ${resourceId} not found.`)
+    }
+
+    // Fetch all child resources
+    const children = await db
+      .selectFrom("Resource")
+      .selectAll()
+      .where("parentId", "=", resourceId)
+      .execute()
+
+    // Write all the children's published version to the backup directory as JSON files
+    for (const child of children) {
+      // fetch the blob
+      const blob = await db
+        .selectFrom("Blob")
+        .select("content")
+        .innerJoin("Version", "Blob.id", "Version.blobId")
+        .where("Version.id", "=", child.publishedVersionId)
+        .executeTakeFirst()
+
+      if (!blob) {
+        throw new Error(
+          `Published version of child with ID ${child.id} not found.`,
+        )
+      }
+
+      logger.info(`Writing backup for child with ID ${child.id}`)
+
+      // Parse blob content and write to a file
+      const blobBuffer = blob.content // Assuming blob.content is a buffer
+      const blobJsonPath = path.join(backupDir, `${child.permalink}.json`)
+      await fs.writeFile(blobJsonPath, JSON.stringify(blobBuffer, null, 2))
+    }
+
+    logger.info(`Backup completed successfully in directory: ${backupDir}`)
+  } catch (error) {
+    if (error instanceof Error) {
+      logger.error(`Error backing up collection: ${error.message}`)
+    }
+  }
+}
+
+// Run the backup
+// NOTE: TODO: Put in the collection ID to backup
+const collectionId = "0"
+const backupDirectory = "/Users/XYZ/<your-path>"
+
+await backupCollection({
+  resourceId: collectionId,
+  backupDir: backupDirectory,
+}).catch((err) => {
+  if (err instanceof Error) {
+    logger.error(`Unhandled error: ${err.message}`)
+  }
+})