mirror of
https://github.com/linux-odyssey/linux-odyssey.git
synced 2026-11-05 19:20:12 +08:00
feat: add build qeust images script
This commit is contained in:
1 parent
8bbd5da513
commit
7b1591a6e3
8 files changed
+114
-41
No files matched your search
+2
-1
@@ -23,7 +23,8 @@
|
||||
"test:e2e": "yarn workspace tests test",
|
||||
"analytics": "yarn workspace analytics dev",
|
||||
"setup": "yarn workspace server setup",
|
||||
"clean": "yarn workspace server clean"
|
||||
"clean": "yarn workspace server clean",
|
||||
"build:image": "yarn workspace server build"
|
||||
},
|
||||
"devDependencies": {
|
||||
"@vue/eslint-config-prettier": "^7.1.0",
|
||||
|
||||
@@ -1,3 +1,3 @@
|
||||
FROM lancatlin/linux-odyssey:base
|
||||
|
||||
COPY ./home ${HOME}
|
||||
COPY home ${HOME}
|
||||
@@ -1,3 +1,3 @@
|
||||
FROM lancatlin/linux-odyssey:base
|
||||
|
||||
COPY ./home ${HOME}
|
||||
COPY home ${HOME}
|
||||
+2
-1
@@ -8,7 +8,8 @@
|
||||
"dev": "nodemon src/index.js",
|
||||
"test": "yarn node --experimental-vm-modules $(yarn bin jest)",
|
||||
"setup": "node src/cli/setup.js",
|
||||
"clean": "node src/cli/clean.js"
|
||||
"clean": "node src/cli/clean.js",
|
||||
"build": "node src/cli/build.js"
|
||||
},
|
||||
"dependencies": {
|
||||
"@linux-odyssey/constants": "*",
|
||||
|
||||
@@ -0,0 +1,24 @@
|
||||
import { getQuestDockerfiles } from '../utils/quest.js'
|
||||
import { buildQuestImage } from '../containers/docker.js'
|
||||
|
||||
async function buildImages() {
|
||||
const quests = await getQuestDockerfiles()
|
||||
console.log(`Building ${quests.length} images`)
|
||||
return Promise.all(
|
||||
quests.map(({ id, questPath }) => {
|
||||
console.log(`Building image for ${id}`)
|
||||
return buildQuestImage(questPath, id)
|
||||
})
|
||||
)
|
||||
}
|
||||
|
||||
buildImages()
|
||||
.then((result) => {
|
||||
console.log(result)
|
||||
console.log('Done!')
|
||||
process.exit(0)
|
||||
})
|
||||
.catch((err) => {
|
||||
console.error(err)
|
||||
process.exit(1)
|
||||
})
|
||||
@@ -78,3 +78,41 @@ export async function deleteContainer(id) {
|
||||
}
|
||||
await container.remove()
|
||||
}
|
||||
|
||||
export function buildQuestImage(questPath, questId) {
|
||||
return new Promise((resolve, reject) => {
|
||||
engine.buildImage(
|
||||
{
|
||||
context: questPath,
|
||||
src: ['Dockerfile', 'home'],
|
||||
},
|
||||
{ t: `${config.dockerImage}:${questId}` },
|
||||
(err, response) => {
|
||||
if (err) {
|
||||
reject(err)
|
||||
}
|
||||
response.on('data', (data) => {
|
||||
// Process the data (this could be Docker build output)
|
||||
const { stream, error } = JSON.parse(data.toString())
|
||||
if (stream) {
|
||||
console.log(stream)
|
||||
}
|
||||
if (error) {
|
||||
console.error(error)
|
||||
reject(error)
|
||||
}
|
||||
})
|
||||
|
||||
response.on('end', () => {
|
||||
console.log(`Build completed for ${questId}`)
|
||||
resolve(questId)
|
||||
})
|
||||
|
||||
response.on('error', (error) => {
|
||||
console.error(`Build failed for ${questId}:`, error)
|
||||
reject(error)
|
||||
})
|
||||
}
|
||||
)
|
||||
})
|
||||
}
|
||||
+1
-1
@@ -9,7 +9,7 @@ import connectDB from '@linux-odyssey/models'
|
||||
import './auth/passport.js'
|
||||
import socketServer from './api/socket.js'
|
||||
import apiRouter from './api/routes/index.js'
|
||||
import loadAndUpdateQuests from './utils/quest.js'
|
||||
import { loadAndUpdateQuests } from './utils/quest.js'
|
||||
import config from './config.js'
|
||||
import errorHandler from './middleware/error.js'
|
||||
import { globalRateLimit } from './middleware/rateLimiter.js'
|
||||
|
||||
+45
-36
@@ -6,51 +6,60 @@ import { Quest } from '@linux-odyssey/models'
|
||||
|
||||
const questDirectory = path.join(process.cwd(), '..', 'quests')
|
||||
|
||||
export default async function loadAndUpdateQuests() {
|
||||
async function mapQuests(callback) {
|
||||
const questNames = await fs.readdir(questDirectory, {
|
||||
withFileTypes: true,
|
||||
})
|
||||
|
||||
const quests = Promise.all(
|
||||
return Promise.all(
|
||||
questNames
|
||||
.filter((dirent) => dirent.isDirectory() && !dirent.name.startsWith('.'))
|
||||
.map(async (dirent) => {
|
||||
.map((dirent) => {
|
||||
const id = dirent.name
|
||||
const questPath = path.join(questDirectory, id)
|
||||
const files = await fs.readdir(questPath)
|
||||
if (!files.includes('game.yml')) {
|
||||
throw new Error(`Quest ${id} is missing game.yml`)
|
||||
}
|
||||
|
||||
try {
|
||||
const body = await fs.readFile(
|
||||
path.join(questPath, 'game.yml'),
|
||||
'utf-8'
|
||||
)
|
||||
|
||||
const quest = yaml.parse(body, {
|
||||
merge: true,
|
||||
})
|
||||
|
||||
const image = files.includes('Dockerfile') ? id : 'base'
|
||||
|
||||
return Quest.findByIdAndUpdate(
|
||||
id,
|
||||
{
|
||||
_id: id,
|
||||
image,
|
||||
...quest,
|
||||
},
|
||||
{
|
||||
upsert: true,
|
||||
}
|
||||
)
|
||||
} catch (error) {
|
||||
console.error(`Error parsing quest ${id}:`, error)
|
||||
throw error
|
||||
}
|
||||
return callback(id, questPath)
|
||||
})
|
||||
)
|
||||
}
|
||||
|
||||
return quests
|
||||
export function loadAndUpdateQuests() {
|
||||
return mapQuests(async (id, questPath) => {
|
||||
const files = await fs.readdir(questPath)
|
||||
if (!files.includes('game.yml')) {
|
||||
throw new Error(`Quest ${id} is missing game.yml`)
|
||||
}
|
||||
|
||||
try {
|
||||
const body = await fs.readFile(path.join(questPath, 'game.yml'), 'utf-8')
|
||||
|
||||
const quest = yaml.parse(body, {
|
||||
merge: true,
|
||||
})
|
||||
|
||||
const image = files.includes('Dockerfile') ? id : 'base'
|
||||
|
||||
return Quest.findByIdAndUpdate(
|
||||
id,
|
||||
{
|
||||
_id: id,
|
||||
image,
|
||||
...quest,
|
||||
},
|
||||
{
|
||||
upsert: true,
|
||||
}
|
||||
)
|
||||
} catch (error) {
|
||||
console.error(`Error parsing quest ${id}:`, error)
|
||||
throw 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)
|
||||
}
|
||||
Reference in new issue
Block a user