feat: parse quest using zod, basic

server/src/models/quest.ts

@@ -0,0 +1,102 @@
+/* eslint-disable max-classes-per-file */
+import fs from 'fs/promises'
+import path from 'path'
+import yaml from 'yaml'
+
+import { Quest, questSchema } from '@linux-odyssey/constants'
+import logger from '../utils/logger.js'
+
+class QuestValidationError extends Error {
+  questId: string
+  error: any
+
+  constructor(message: string, questId: string, error: any) {
+    super(message)
+    this.name = 'QuestValidationError'
+    this.questId = questId
+    this.error = error
+  }
+}
+
+class QuestManager {
+  private quests = new Map<string, Quest>()
+  private questDirectory = path.join(process.cwd(), '..', 'quests')
+
+  get(id: string) {
+    return this.quests.get(id)
+  }
+
+  getAll() {
+    return Array.from(this.quests.values())
+  }
+
+  private async mapQuests(callback: QuestCallback) {
+    const questNames = await fs.readdir(this.questDirectory, {
+      withFileTypes: true,
+    })
+
+    return Promise.all(
+      questNames
+        .filter(
+          (dirent) => dirent.isDirectory() && !dirent.name.startsWith('.')
+        )
+        .map((dirent) => {
+          const id = dirent.name
+          const questPath = path.join(this.questDirectory, id)
+          return callback(id, questPath)
+        })
+    )
+  }
+
+  private async loadGlobalExceptions() {
+    const exceptionsPath = path.join(this.questDirectory, 'exceptions.yml')
+    const body = await fs.readFile(exceptionsPath, 'utf-8')
+    return yaml.parse(body)
+  }
+
+  async loadAndUpdateQuests() {
+    const { exceptions } = await this.loadGlobalExceptions()
+    return this.mapQuests(async (id, questPath) => {
+      const files = await fs.readdir(questPath)
+      if (!files.includes('game.yml')) {
+        throw new QuestValidationError(`Missing game.yml`, id, null)
+      }
+
+      try {
+        const body = await fs.readFile(
+          path.join(questPath, 'game.yml'),
+          'utf-8'
+        )
+
+        const questData = yaml.parse(body, {
+          merge: true,
+        })
+
+        const image = files.includes('Dockerfile') ? id : 'base'
+        const quest = questSchema.parse({
+          _id: id,
+          image,
+          ...questData,
+        })
+        quest.exceptions.push(...exceptions)
+        this.quests.set(id, quest)
+      } catch (error) {
+        logger.error(`Error parsing quest`, { id, error })
+        throw new QuestValidationError(`Error parsing quest`, id, error)
+      }
+    })
+  }
+
+  async getQuestDockerfiles() {
+    const questlist = await this.mapQuests(async (id, questPath) => {
+      const files = await fs.readdir(questPath)
+      return files.includes('Dockerfile') ? { id, questPath } : null
+    })
+    return questlist.filter((quest) => quest !== null)
+  }
+}
+
+// eslint-disable-next-line no-unused-vars
+type QuestCallback = (id: string, questPath: string) => Promise<any>
+
+export const questManager = new QuestManager()