update store

app/src/store/session.ts

@@ -0,0 +1,153 @@
+import { reactive } from 'vue'
+import { useToast } from 'vue-toastification'
+import { FileGraph, FileObject } from '@linux-odyssey/file-graph'
+import api from '../utils/api'
+import Socket from '../utils/socket'
+import SocketTerminal from '../utils/terminal'
+import { LoadQuestError, LoadSessionError } from '../utils/errors'
+
+const toast = useToast()
+
+function newSession() {
+  const graph = new FileGraph({
+    path: '/',
+    type: 'folder',
+    discovered: false,
+  })
+  return {
+    status: 'inactive',
+    graph,
+    pwd: '',
+    hints: [],
+    tasks: [],
+    responses: [],
+  }
+}
+
+const store = reactive({
+  session: newSession(),
+  questId: '',
+  quest: null,
+})
+
+const socket = new Socket()
+const term = new SocketTerminal(40, 80)
+
+function setQuest(questId: string) {
+  return api.get(`/quests/${questId}`).then((res) => {
+    store.questId = res.data._id
+    store.quest = res.data
+  })
+}
+
+async function setSession(session: any) {
+  try {
+    console.log('Setting session...', session)
+    store.session = session
+    store.session.graph = new FileGraph(session.graph)
+    term.reset()
+    await socket.connect(session)
+    term.focus()
+  } catch (err: any) {
+    console.error(err)
+    toast.error(err.message)
+    throw err
+  }
+}
+
+export async function createSession() {
+  try {
+    console.log('Creating a new session...')
+    const res = await api.post('/sessions', { questId: store.questId })
+    const { data } = res
+    await setSession(data)
+  } catch (err) {
+    console.error(err)
+    toast.error('Failed to create a new session. Please try again later.')
+  }
+}
+
+async function getActiveSession(questId: any) {
+  try {
+    const res = await api.post('/sessions/active', { questId })
+    await setSession(res.data)
+  } catch (err) {
+    console.error(err)
+    toast.warning('Failed to connect previous session. Creating a new one...')
+    await createSession()
+  }
+}
+
+function updateGraph(event: { discover: FileObject[]; pwd: string }) {
+  if (event.discover) {
+    store.session.graph.discover(event.discover)
+  }
+  if (event.pwd) {
+    store.session.pwd = event.pwd
+  }
+}
+
+function updateHints(hints: never) {
+  store.session.hints.push(hints)
+}
+
+function updateStatus(status: string) {
+  store.session.status = status
+}
+
+function setTasks(tasks: never[]) {
+  store.session.tasks = tasks
+}
+
+export function useTerminal() {
+  return term
+}
+
+export function reset() {
+  socket.reset()
+  term.reset()
+  store.session = newSession()
+  store.quest = null
+}
+
+export async function init(questId: string) {
+  if (!questId) throw new Error('No quest ID provided')
+  reset()
+  try {
+    await setQuest(questId)
+  } catch (err) {
+    console.error(err)
+    throw new LoadQuestError('Failed to load quest', questId)
+  }
+  try {
+    await getActiveSession(questId)
+  } catch (err) {
+    console.error(err)
+    throw new LoadSessionError('Failed to load session', questId)
+  }
+}
+
+function setup() {
+  socket.on('terminal', (data: any) => {
+    term.write(data)
+  })
+  term.onData((data: any) => {
+    socket.emit('terminal', data)
+  })
+  socket.on('graph', (event: { discover: FileObject[]; pwd: string }) => {
+    updateGraph(event)
+  })
+  socket.on('hints', (event: never) => {
+    updateHints(event)
+  })
+  socket.on('tasks', (tasks: never[]) => {
+    setTasks(tasks)
+  })
+  socket.on('status', (event: string) => {
+    updateStatus(event)
+  })
+}
+
+setup()
+
+export default store