Merge pull request #17 from lancatlin/app-graph-frontend

* display graph from data
* show the discovery state of each node
* accept graph event from socket
* store graph in sessionManager
* update new graph by file-graph algorithm

file-graph:
* add file discovery state merging

server
* update file structure in docker
This commit is contained in:
Lin, Hung-Shin authored and GitHub committed 2023-08-30 11:11:11 +08:00
commit 52c6c6ab93
27 files changed
+417 -218

No files matched your search

+23 -3
View File
@@ -1,12 +1,32 @@
name: CI/CD Workflow name: CI/CD
on: on:
push: push:
branches:
- main
jobs: jobs:
ci:
runs-on: ubuntu-latest
steps:
- name: Checkout
uses: actions/checkout@v3
- uses: actions/setup-node@v3
with:
node-version: 20
- name: Install dependencies
run: yarn install
- name: Lint
run: yarn lint
- name: Test
run: yarn test
build-and-push: build-and-push:
needs: ci
if: github.ref == 'refs/heads/main'
runs-on: ubuntu-latest runs-on: ubuntu-latest
steps: steps:
-22
View File
@@ -1,22 +0,0 @@
name: ESLint Checks
on:
push:
jobs:
lint:
runs-on: ubuntu-latest
steps:
- name: Checkout
uses: actions/checkout@v3
- uses: actions/setup-node@v3
with:
node-version: 20
- name: Install dependencies
run: yarn install
- name: Lint
run: yarn lint
+8 -4
View File
@@ -1,14 +1,18 @@
# Build stage # Build stage
FROM node as build-stage FROM node as build-stage
WORKDIR /app WORKDIR /app
COPY app/package.json yarn.lock ./ COPY package.json yarn.lock ./
RUN yarn install COPY app/package.json ./app/package.json
COPY app . COPY packages/file-graph/package.json ./packages/file-graph/package.json
RUN yarn install --frozen-lockfile
COPY app ./app
COPY packages/file-graph ./packages/file-graph
RUN yarn build RUN yarn build
# Production stage # Production stage
FROM nginx:stable-alpine as production-stage FROM nginx:stable-alpine as production-stage
COPY --from=build-stage /app/dist /usr/share/nginx/html COPY --from=build-stage /app/app/dist /usr/share/nginx/html
COPY deployment/nginx.conf /etc/nginx/conf.d/default.conf COPY deployment/nginx.conf /etc/nginx/conf.d/default.conf
EXPOSE 80 EXPOSE 80
CMD ["nginx", "-g", "daemon off;"] CMD ["nginx", "-g", "daemon off;"]
+5 -2
View File
@@ -1,7 +1,10 @@
FROM node FROM node
WORKDIR /app WORKDIR /app
COPY app/package.json yarn.lock ./ COPY package.json yarn.lock ./
COPY app/package.json ./app/package.json
COPY packages/file-graph/package.json ./packages/file-graph/package.json
RUN yarn install --frozen-lockfile RUN yarn install --frozen-lockfile
COPY app .
WORKDIR /app/app
CMD [ "yarn", "dev:docker", "--host", "0.0.0.0" ] CMD [ "yarn", "dev:docker", "--host", "0.0.0.0" ]
+1
View File
@@ -11,6 +11,7 @@
"preview": "vite preview" "preview": "vite preview"
}, },
"dependencies": { "dependencies": {
"@linux-odyssey/file-graph": "*",
"@fortawesome/fontawesome-svg-core": "^6.4.0", "@fortawesome/fontawesome-svg-core": "^6.4.0",
"@fortawesome/free-brands-svg-icons": "^6.4.0", "@fortawesome/free-brands-svg-icons": "^6.4.0",
"@fortawesome/free-regular-svg-icons": "^6.4.0", "@fortawesome/free-regular-svg-icons": "^6.4.0",
+3
View File
@@ -20,6 +20,9 @@ onMounted(async () => {
console.log('Disconnected from the server.') console.log('Disconnected from the server.')
}) })
socket.on('message', console.log) socket.on('message', console.log)
socket.on('graph', (event) => {
sessionManager.handleGraphUpdate(event)
})
}) })
</script> </script>
+29
View File
@@ -0,0 +1,29 @@
<template>
<a href="#" :class="nodeClass()">{{ node.discovered ? node.name : '???' }}</a>
<ul :class="nodeClass()" v-if="node.children && node.children.length > 0">
<li :class="nodeClass()" v-for="child in node.children" :key="child.path">
<FileNode :node="child" :pwd="pwd" />
</li>
</ul>
</template>
<script setup>
const props = defineProps({
node: {
type: Object,
required: true,
},
pwd: {
type: String,
required: true,
default: '',
},
})
function nodeClass() {
const classes = []
if (props.node.discovered) classes.push('discovered')
if (props.node.path === props.pwd) classes.push('pwd')
return classes
}
</script>
+15 -54
View File
@@ -1,56 +1,16 @@
<script setup></script> <script setup>
import FileNode from './FileNode.vue'
import sessionManager from '../utils/session.js'
</script>
<template> <template>
<div class="tree w-max h-max"> <div class="tree w-max h-max">
<ul> <ul>
<li> <li>
<a href="#">Parent</a> <FileNode
<ul> :node="sessionManager.graph.value"
<li> :pwd="sessionManager.pwd.value"
<a href="#">Child</a> />
<ul>
<li>
<a href="#">Grand Child</a>
</li>
</ul>
</li>
<li>
<a href="#">Child</a>
<ul>
<li><a href="#">Grand Child</a></li>
<li>
<a href="#">Grand Child</a>
<ul>
<li>
<a href="#">Great Grand Child</a>
</li>
<li>
<a href="#">Great Grand Child</a>
</li>
<li>
<a href="#">Great Grand Child</a>
<ul>
<li><a>Grand Child</a></li>
<li>
<a>Grand Child</a>
<ul>
<li>
<a>Great Grand Child</a>
</li>
<li>
<a>Great Grand Child</a>
</li>
</ul>
</li>
<li><a>Grand Child</a></li>
</ul>
</li>
</ul>
</li>
<li><a href="#">Grand Child</a></li>
</ul>
</li>
</ul>
</li> </li>
</ul> </ul>
</div> </div>
@@ -149,17 +109,18 @@
-moz-transition: all 0.5s; -moz-transition: all 0.5s;
} }
.tree li a:hover, a.discovered {
.tree li a:hover + ul li a {
background: #c8e4f8; background: #c8e4f8;
color: #000; color: #000;
border: 1px solid #94a0b4; border: 1px solid #94a0b4;
} }
.tree li a:hover + ul li::after, ul.discovered,
.tree li a:hover + ul li::before, li.discovered {
.tree li a:hover + ul::before,
.tree li a:hover + ul ul::before {
border-color: #94a0b4; border-color: #94a0b4;
} }
a.pwd {
box-shadow: 0 0 10px rgba(255, 255, 255, 0.5); /* 水平偏移、垂直偏移、模糊半徑、顏色 */
}
</style> </style>
+22 -1
View File
@@ -1,10 +1,19 @@
import { ref } from 'vue' import { ref } from 'vue'
import { FileGraph } from '@linux-odyssey/file-graph'
import api from './api' import api from './api'
class SessionManager { class SessionManager {
constructor(questId) { constructor(questId) {
this.questId = questId this.questId = questId
this.session = ref(null) this.session = ref(null)
this.graph = ref(
new FileGraph({
path: '/',
type: 'folder',
discovered: false,
})
)
this.pwd = ref('')
} }
getSession() { getSession() {
@@ -14,6 +23,16 @@ class SessionManager {
setSession(session) { setSession(session) {
console.log('Update session:', session) console.log('Update session:', session)
this.session.value = session this.session.value = session
this.graph.value = new FileGraph(session.graph)
}
handleGraphUpdate(event) {
if (event.discover) {
this.graph.value.discover(event.discover)
}
if (event.pwd) {
this.pwd.value = event.pwd
}
} }
async createSession() { async createSession() {
@@ -37,7 +56,8 @@ class SessionManager {
if (sessions.length === 0) { if (sessions.length === 0) {
return return
} }
const session = sessions[sessions.length - 1] const { _id: sessionId } = sessions[sessions.length - 1]
const { data: session } = await api.get(`/sessions/${sessionId}`)
console.log( console.log(
`Last Session ID: ${session._id}, Quest: ${session.quest}, Created At: ${session.createdAt}` `Last Session ID: ${session._id}, Quest: ${session.quest}, Created At: ${session.createdAt}`
) )
@@ -49,6 +69,7 @@ class SessionManager {
if (!this.session.value) { if (!this.session.value) {
await this.createSession() await this.createSession()
} }
console.log(this.session.value)
} }
} }
+5 -3
View File
@@ -9,7 +9,8 @@ services:
networks: networks:
- internal - internal
volumes: volumes:
- ./app/src:/app/src - ./app:/app/app
- ./packages/file-graph:/app/packages/file-graph
backend: backend:
build: build:
context: . context: .
@@ -21,8 +22,9 @@ services:
- '3000:3000' - '3000:3000'
volumes: volumes:
- /var/run/docker.sock:/var/run/docker.sock - /var/run/docker.sock:/var/run/docker.sock
- ./server/src:/app/src - ./server/src:/app/server/src
- ./server/swagger.yaml:/app/swagger.yaml - ./server/swagger.yaml:/app/server/swagger.yaml
- ./packages:/app/packages
- ./quests:/app/quests - ./quests:/app/quests
environment: environment:
- MONGO_URL=mongodb://db:27017/odyssey-test - MONGO_URL=mongodb://db:27017/odyssey-test
+2
View File
@@ -13,10 +13,12 @@
"scripts": { "scripts": {
"app": "yarn workspace app dev", "app": "yarn workspace app dev",
"app:local": "yarn workspace app dev:local", "app:local": "yarn workspace app dev:local",
"build": "yarn workspace app build",
"server": "yarn workspace server dev", "server": "yarn workspace server dev",
"cli": "yarn workspace client start", "cli": "yarn workspace client start",
"lint": "eslint --ext .js,.vue .", "lint": "eslint --ext .js,.vue .",
"format": "prettier --ignore-path .prettierignore --write app server", "format": "prettier --ignore-path .prettierignore --write app server",
"test": "yarn node --experimental-vm-modules $(yarn bin jest)",
"clean": "yarn workspace server clean" "clean": "yarn workspace server clean"
}, },
"devDependencies": { "devDependencies": {
+5 -2
View File
@@ -2,7 +2,7 @@ import { basename } from './utils.js'
export default class File { export default class File {
constructor({ path, type, discovered }) { constructor({ path, type, discovered }) {
this.path = path this.path = path.trimEnd('/')
this.name = basename(path) this.name = basename(path)
this.type = type this.type = type
this.discovered = discovered this.discovered = discovered
@@ -13,6 +13,9 @@ export default class File {
} }
contains(file) { contains(file) {
return this.isDirectory() && file.path.startsWith(this.path) if (!this.isDirectory()) return false
if (this.path === file.path) return true
const parentPath = this.path.endsWith('/') ? this.path : `${this.path}/`
return file.path.startsWith(parentPath)
} }
} }
+49
View File
@@ -0,0 +1,49 @@
import File from './file.js'
describe('File', () => {
let file
beforeEach(() => {
file = new File({ path: '/home/user', type: 'folder', discovered: true })
})
const filesToCompare = [
{
name: 'direct children',
path: '/home/user/file1.txt',
answer: true,
},
{
name: 'nested children',
path: '/home/user/folder1/file1.txt',
answer: true,
},
{
name: 'outer file',
path: '/etc/file1.txt',
answer: false,
},
{
name: 'fake children',
path: '/home/user2/file2.txt',
answer: false,
},
{
name: 'same',
path: '/home/user',
answer: true,
},
{
name: 'same with trailing',
path: '/home/user/',
answer: true,
},
]
filesToCompare.forEach(({ name, path, answer }) => {
test(`${name}: ${path}`, () => {
const fileToCompare = new File({ path, type: 'file', discovered: true })
console.log(fileToCompare)
expect(file.contains(fileToCompare)).toBe(answer)
})
})
})
+4 -8
View File
@@ -1,17 +1,13 @@
import FileNode from './fileNode.js' import FileNode from './fileNode.js'
export default class FileGraph { export default class FileGraph extends FileNode {
constructor(root) {
this.root = new FileNode(root)
}
add(files) { add(files) {
// Logic to add the file node to the graph // Logic to add the file node to the graph
// You can implement the logic to find the appropriate location in the file graph // You can implement the logic to find the appropriate location in the file graph
// If the file node already exists, throw an error // If the file node already exists, throw an error
files.forEach((file) => { files.forEach((file) => {
this.root.addChild(file, { makeParents: true }) this.addChild(file, { makeParents: true })
}) })
} }
@@ -21,7 +17,7 @@ export default class FileGraph {
// If the file node doesn't exist, throw an error // If the file node doesn't exist, throw an error
files.forEach((file) => { files.forEach((file) => {
this.root.removeChild(file) this.removeChild(file)
}) })
} }
@@ -36,7 +32,7 @@ export default class FileGraph {
newNode.addChild(file, { makeParents: true }) newNode.addChild(file, { makeParents: true })
}) })
this.root.merge(newNode) this.merge(newNode)
} }
handleEvent(event) { handleEvent(event) {
+46 -16
View File
@@ -30,9 +30,9 @@ describe('FileGraph', () => {
fileGraph.add(filesToAdd) fileGraph.add(filesToAdd)
console.log(fileGraph.root.toString()) console.log(fileGraph.toString())
expect(fileGraph.root.children.length).toBe(1) expect(fileGraph.children.length).toBe(1)
expect(fileGraph.root.children[0].children[0].children.length).toBe(2) expect(fileGraph.children[0].children[0].children.length).toBe(2)
}) })
test('remove files from graph', () => { test('remove files from graph', () => {
@@ -76,14 +76,44 @@ describe('FileGraph', () => {
fileGraph.remove(filesToRemove) fileGraph.remove(filesToRemove)
console.log(fileGraph.root.toString()) console.log(fileGraph.toString())
expect(fileGraph.root.children[0].children[0].children.length).toBe(1) expect(fileGraph.children[0].children[0].children.length).toBe(1)
expect(fileGraph.root.children[0].children[0].children[0].name).toBe( expect(fileGraph.children[0].children[0].children[0].name).toBe('folder1')
'folder1' expect(fileGraph.children[0].children[0].children[0].children.length).toBe(
0
)
})
test('discover', () => {
const fileGraph = new FileGraph(root)
const discoverFiles = [
{
path: '/home/user/folder1',
type: 'folder',
discovered: true,
},
{
path: '/home/user/folder1/file1.txt',
type: 'file',
discovered: true,
},
{
path: '/home/user/folder1/file2.txt',
type: 'file',
discovered: true,
},
{
path: '/home/user/folder1/file3.txt',
type: 'file',
discovered: true,
},
]
fileGraph.discover(discoverFiles)
console.log(fileGraph.toString())
expect(fileGraph.children[0].children[0].children[0].children.length).toBe(
3
) )
expect(
fileGraph.root.children[0].children[0].children[0].children.length
).toBe(0)
}) })
test('discover new files', () => { test('discover new files', () => {
@@ -113,7 +143,7 @@ describe('FileGraph', () => {
] ]
fileGraph.add(filesToAdd) fileGraph.add(filesToAdd)
console.log(fileGraph.root.toString()) console.log(fileGraph.toString())
const newFiles = [ const newFiles = [
{ {
@@ -140,10 +170,10 @@ describe('FileGraph', () => {
fileGraph.discover(newFiles) fileGraph.discover(newFiles)
console.log(fileGraph.root.toString()) console.log(fileGraph.toString())
expect(fileGraph.root.children[0].children[0].children.length).toBe(2) expect(fileGraph.children[0].children[0].children.length).toBe(2)
expect( expect(fileGraph.children[0].children[0].children[0].children.length).toBe(
fileGraph.root.children[0].children[0].children[0].children.length 3
).toBe(3) )
}) })
}) })
+23 -9
View File
@@ -9,7 +9,8 @@ import { basename, dirname } from './utils.js'
export default class FileNode extends File { export default class FileNode extends File {
constructor(file) { constructor(file) {
super(file) super(file)
this.children = file.children || [] this.children = []
if (file.children) this.children = file.children.map((f) => new FileNode(f))
} }
addChild(fileInput, { makeParents } = {}) { addChild(fileInput, { makeParents } = {}) {
@@ -76,7 +77,12 @@ export default class FileNode extends File {
// Merge the children of the provided file node into this node // Merge the children of the provided file node into this node
// If a child already exists, merge the children of that child // If a child already exists, merge the children of that child
// If a child does not exist, add it to this node // If a child does not exist, add it to this node
// If this is the same node, merge the children
if (fileNode.path === this.path) { if (fileNode.path === this.path) {
// Update the state of this node
this.discovered = this.discovered || fileNode.discovered
fileNode.children.forEach((child) => { fileNode.children.forEach((child) => {
const existingChild = this.children.find((c) => c.path === child.path) const existingChild = this.children.find((c) => c.path === child.path)
if (existingChild) { if (existingChild) {
@@ -92,12 +98,17 @@ export default class FileNode extends File {
fileNode.children.some((c) => c.path === child.path) fileNode.children.some((c) => c.path === child.path)
) )
} }
} else if (this.contains(fileNode)) { }
// If this contains the parent node
else if (this.contains(fileNode)) {
const childNode = this.children.find((child) => child.contains(fileNode)) const childNode = this.children.find((child) => child.contains(fileNode))
// If a child node exists, merge the provided node into the child node
if (childNode) { if (childNode) {
childNode.merge(fileNode) childNode.merge(fileNode)
} else { }
this.addChild(fileNode) // If a child node does not exist, add the provided node as a child
else {
this.addChild(fileNode, { makeParents: true })
} }
} else { } else {
throw new Error( throw new Error(
@@ -108,12 +119,15 @@ export default class FileNode extends File {
} }
} }
toString() { toString(level = 0) {
const indent = ' '.repeat(this.path.split('/').length - 1) let { name } = this
const suffix = this.isDirectory() ? '/' : '' const indent = ' '.repeat(level)
name = `${indent}${name}`
if (this.isDirectory()) name += '/'
if (!this.discovered) name += `*`
const childrenString = this.children const childrenString = this.children
.map((child) => child.toString()) .map((child) => child.toString(level + 1))
.join('') .join('')
return `${indent}${this.name}${suffix}\n${childrenString}` return `${name}\n${childrenString}`
} }
} }
+65
View File
@@ -193,6 +193,35 @@ describe('FileNode', () => {
mergeTest(files1, files2, expected) mergeTest(files1, files2, expected)
}) })
test('merge-hidden', () => {
const root = {
path: '/',
type: 'folder',
}
const files1 = [
root,
{ path: '/a', type: 'file', discovered: true },
{ path: '/.b', type: 'file', discovered: false },
{ path: '/c', type: 'folder', discovered: true },
{ path: '/c/.d', type: 'file', discovered: false },
]
const files2 = [
{ path: '/c', type: 'folder', discovered: true },
{ path: '/c/.d', type: 'file', discovered: true },
]
const expected = [
root,
{ path: '/a', type: 'file', discovered: true },
{ path: '/.b', type: 'file', discovered: false },
{ path: '/c', type: 'folder', discovered: true },
{ path: '/c/.d', type: 'file', discovered: true },
]
mergeTest(files1, files2, expected)
})
test('remove-child', () => { test('remove-child', () => {
const root = { const root = {
path: '/', path: '/',
@@ -219,3 +248,39 @@ describe('FileNode', () => {
removeChildTest(files, fileToRemove, expected) removeChildTest(files, fileToRemove, expected)
}) })
}) })
test('load nested fileNode', () => {
const data = {
path: '/',
type: 'folder',
children: [
{
path: '/a',
type: 'file',
},
{
path: '/b',
type: 'folder',
children: [
{
path: '/b/c',
type: 'folder',
children: [
{
path: '/b/c/d',
type: 'file',
},
],
},
],
},
],
}
const node = new FileNode(data)
console.log(node.toString())
expect(node.children.length).toBe(2)
expect(node.children[1].children.length).toBe(1)
expect(node.children[1].children[0].children.length).toBe(1)
})
+3
View File
@@ -0,0 +1,3 @@
export { default as File } from './file.js'
export { default as FileNode } from './fileNode.js'
export { default as FileGraph } from './fileGraph.js'
+3 -4
View File
@@ -1,10 +1,9 @@
{ {
"name": "file-graph", "name": "@linux-odyssey/file-graph",
"version": "1.0.0", "version": "1.0.0",
"main": "index.js", "main": "index.js",
"exports": "./index.js",
"license": "MIT", "license": "MIT",
"type": "module", "type": "module",
"scripts": { "scripts": {}
"test": "yarn node --experimental-vm-modules $(yarn bin jest)"
}
} }
+7 -3
View File
@@ -1,13 +1,17 @@
FROM node FROM node
WORKDIR /app WORKDIR /app
COPY server/package.json yarn.lock ./ COPY ./package.json yarn.lock ./
COPY server/package.json ./server/package.json
COPY packages/file-graph/package.json ./packages/file-graph/package.json
RUN yarn install --frozen-lockfile --production RUN yarn install --frozen-lockfile --production
COPY server/src ./src COPY ./server ./server
COPY server/swagger.yaml . COPY packages/file-graph ./packages/file-graph
COPY quests ./quests COPY quests ./quests
WORKDIR /app/server
ENV NODE_ENV=production ENV NODE_ENV=production
ENV HOST=0.0.0.0 ENV HOST=0.0.0.0
ENV PORT=3000 ENV PORT=3000
+4 -2
View File
@@ -1,7 +1,9 @@
FROM node FROM node
WORKDIR /app WORKDIR /app
COPY server/package.json yarn.lock ./ COPY package.json yarn.lock ./
COPY server/package.json ./server/package.json
COPY packages/file-graph/package.json ./packages/file-graph/package.json
RUN yarn install --frozen-lockfile RUN yarn install --frozen-lockfile
ENV NODE_ENV=development ENV NODE_ENV=development
@@ -9,4 +11,4 @@ ENV HOST=0.0.0.0
ENV PORT=3000 ENV PORT=3000
EXPOSE 3000 EXPOSE 3000
CMD [ "yarn", "dev" ] CMD [ "yarn", "server" ]
+1
View File
@@ -10,6 +10,7 @@
"clean": "node src/cli/clean.js" "clean": "node src/cli/clean.js"
}, },
"dependencies": { "dependencies": {
"@linux-odyssey/file-graph": "*",
"commander": "^11.0.0", "commander": "^11.0.0",
"dockerode": "^3.3.5", "dockerode": "^3.3.5",
"express": "^4.18.2", "express": "^4.18.2",
@@ -2,7 +2,7 @@
import Command from '../../models/command.js' import Command from '../../models/command.js'
import Session from '../../models/session.js' import Session from '../../models/session.js'
import { verifySessionJWT } from '../../utils/auth.js' import { verifySessionJWT } from '../../utils/auth.js'
import commandHandler from '../../game/commandHandler.js' import CommandHandler from '../../game/commandHandler.js'
export async function newCommand(req, res) { export async function newCommand(req, res) {
console.log('new command:', req.body) console.log('new command:', req.body)
@@ -48,7 +48,9 @@ export async function newCommand(req, res) {
await c.save() await c.save()
const response = await commandHandler(session, c, additionalData) const commandHandler = new CommandHandler(session, c, additionalData)
const response = await commandHandler.run()
console.log(response) console.log(response)
res.status(201).json(response) res.status(201).json(response)
+68 -26
View File
@@ -1,4 +1,5 @@
import minimist from 'minimist' import minimist from 'minimist'
import { FileGraph } from '@linux-odyssey/file-graph'
import Quest from '../models/quest.js' import Quest from '../models/quest.js'
import { pushToSession } from '../api/socket.js' import { pushToSession } from '../api/socket.js'
@@ -11,41 +12,83 @@ const checkMatch = (pattern, input) => {
}) })
} }
async function commandHandler(session, commandInput, additionalData) { export default class CommandHandler {
const quest = await Quest.findById(session.quest) constructor(session, commandInput, additionalData) {
const stage = quest.stages.find((s) => s.id === session.progress) this.session = session
this.commandInput = commandInput
this.argv = minimist(this.commandInput.command.split(' '))
this.additionalData = additionalData
}
handleEvent() {
if (this.additionalData.discover) this.discoverHandler()
}
handleCommand() {
const command = this.argv._[0]
switch (command) {
case 'cd':
pushToSession(this.session.id, 'graph', {
pwd: this.commandInput.pwd,
})
break
case 'ls':
pushToSession(this.session.id, 'graph', {
pwd: this.commandInput.pwd,
discover: this.additionalData.discover,
})
break
default:
break
}
}
async discoverHandler() {
const graph = new FileGraph(this.session.graph)
graph.discover(this.additionalData.discover)
this.session.graph = graph
await this.session.save()
}
async run() {
const quest = await Quest.findById(this.session.quest)
const stage = quest.stages.find((s) => s.id === this.session.progress)
if (!stage) { if (!stage) {
console.error('stage not found', session.progress) console.error('stage not found', this.session.progress)
return {} return {}
} }
const argv = minimist(commandInput.command.split(' ')) this.handleEvent()
this.handleCommand()
if ('discover' in additionalData) { const commandMatch = checkMatch(
pushToSession(session.id, 'graph', { stage.condition.command,
pwd: commandInput.pwd, this.commandInput.command
discover: additionalData.discover, )
}) const outputMatch = checkMatch(
} else if (argv._[0] === 'cd') { stage.condition.output,
pushToSession(session.id, 'graph', { pwd: commandInput.pwd }) this.commandInput.output
} )
const errorMatch = checkMatch(
const commandMatch = checkMatch(stage.condition.command, commandInput.command) stage.condition.error,
const outputMatch = checkMatch(stage.condition.output, commandInput.output) this.commandInput.output
const errorMatch = checkMatch(stage.condition.error, commandInput.output) )
if (!commandMatch || !outputMatch || !errorMatch) return {} if (!commandMatch || !outputMatch || !errorMatch) return {}
session.completion.push(session.progress) this.session.completion.push(this.session.progress)
session.hints.push(...stage.hints) this.session.hints.push(...stage.hints)
session.progress = stage.next this.session.progress = stage.next
await session.save() await this.session.save()
if (stage.next === 'END') { if (stage.next === 'END') {
session.status = 'finished' this.session.status = 'finished'
session.finishedAt = new Date() this.session.finishedAt = new Date()
await session.save() await this.session.save()
} }
return { return {
@@ -54,5 +97,4 @@ async function commandHandler(session, commandInput, additionalData) {
end: stage.next === 'END', end: stage.next === 'END',
} }
} }
}
export default commandHandler
+21
View File
@@ -1,4 +1,18 @@
import { model, Schema } from 'mongoose' import { model, Schema } from 'mongoose'
import { FileNode } from '@linux-odyssey/file-graph'
const nodeSchema = new Schema({
path: String,
type: String,
discovered: {
type: Boolean,
default: false,
},
})
nodeSchema.add({
children: [nodeSchema],
})
const Session = model( const Session = model(
'Session', 'Session',
@@ -28,6 +42,13 @@ const Session = model(
progress: String, progress: String,
completion: [String], completion: [String],
hints: [String], hints: [String],
graph: {
type: nodeSchema,
default: new FileNode({
path: '/',
type: 'folder',
}),
},
}, },
{ timestamps: true } { timestamps: true }
) )
+1 -1
View File
@@ -4,7 +4,7 @@ import yaml from 'yaml'
import Quest from '../models/quest.js' import Quest from '../models/quest.js'
const questDirectory = path.join(process.cwd(), 'quests') const questDirectory = path.join(process.cwd(), '..', 'quests')
export default async function loadAndUpdateQuests() { export default async function loadAndUpdateQuests() {
const questNames = await fs.readdir(questDirectory) const questNames = await fs.readdir(questDirectory)
@@ -1,56 +0,0 @@
import jest from 'jest'
import * as sessionController from '../../src/api/controllers/sessionController'
import Session from '../../src/models/session'
jest.mock('../../src/models/session')
describe('Session Controller', () => {
let mockReq
let mockRes
beforeEach(() => {
mockReq = {
user: { id: 'userid' },
body: {},
params: {},
}
mockRes = {
status: jest.fn().mockReturnThis(),
json: jest.fn().mockReturnThis(),
end: jest.fn().mockReturnThis(),
}
})
test('getSessionList returns a list of sessions', async () => {
Session.find.mockResolvedValue(['session1', 'session2'])
await sessionController.getSessionList(mockReq, mockRes)
expect(mockRes.json).toHaveBeenCalledWith(['session1', 'session2'])
})
test('createSession creates a new session', async () => {
mockReq.body.exercise_id = 'exerciseid'
const mockSession = { user: 'userid', exercise: 'exerciseid' }
Session.mockReturnValue(mockSession)
mockSession.save = jest.fn().mockResolvedValue('newsess')
await sessionController.createSession(mockReq, mockRes)
expect(mockRes.status).toHaveBeenCalledWith(201)
expect(mockRes.json).toHaveBeenCalledWith('newsess')
})
test('getSessionById returns the correct session', async () => {
mockReq.params.session_id = 'sessionid'
const mockSession = { user: 'userid', _id: 'sessionid' }
Session.findOne.mockResolvedValue(mockSession)
await sessionController.getSessionById(mockReq, mockRes)
expect(mockRes.json).toHaveBeenCalledWith(mockSession)
})
test('deleteSessionById deletes a session', async () => {
mockReq.params.session_id = 'sessionid'
const mockSession = { user: 'userid', _id: 'sessionid' }
Session.findOneAndDelete.mockResolvedValue(mockSession)
await sessionController.deleteSessionById(mockReq, mockRes)
expect(mockRes.status).toHaveBeenCalledWith(204)
expect(mockRes.end).toHaveBeenCalled()
})
})