linux-odyssey/server/src/utils/quest.js

import fs from 'fs/promises'
import path from 'path'
import yaml from 'yaml'

import { Quest } from '@linux-odyssey/models'
import logger from './logger.js'

const questDirectory = path.join(process.cwd(), '..', 'quests')

class QuestValidationError extends Error {
  constructor(message, questId, error) {
    super(message)
    this.name = 'QuestValidationError'
    this.questId = questId
    this.error = error
  }
}

async function mapQuests(callback) {
  const questNames = await fs.readdir(questDirectory, {
    withFileTypes: true,
  })

  return Promise.all(
    questNames
      .filter((dirent) => dirent.isDirectory() && !dirent.name.startsWith('.'))
      .map((dirent) => {
        const id = dirent.name
        const questPath = path.join(questDirectory, id)
        return callback(id, questPath)
      })
  )
}

export async function loadAndUpdateQuests() {
  await Quest.deleteMany({})
  return mapQuests(async (id, questPath) => {
    const files = await fs.readdir(questPath)
    if (!files.includes('game.yml')) {
      throw new QuestValidationError(`Missing game.yml`, id)
    }

    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 = new Quest({
        _id: id,
        image,
        ...questData,
      })
      await quest.save()
    } catch (error) {
      logger.error(`Error parsing quest`, { id, error })
      throw new QuestValidationError(`Error parsing quest`, id, error)
    }
  })
}

export async function getQuestDockerfiles() {
  const quests = await mapQuests(async (id, questPath) => {
    const files = await fs.readdir(questPath)
    return files.includes('Dockerfile') ? { id, questPath } : null
  })
  return quests.filter((quest) => quest !== null)
}