Fix re-login error (#60)

* refactor: put all session ref into one reactive store

* fix relogin duplicate signal

* fix: put quest data into store, fix hint reactivity

* fix: duplicate after relogin

* only register listener once

app/src/store/session.js

@@ -0,0 +1,127 @@
+import { reactive } from 'vue'
+import { FileGraph } from '@linux-odyssey/file-graph'
+import api from '../utils/api'
+import Socket from '../utils/socket'
+import SocketTerminal from '../utils/terminal'
+
+function newSession() {
+  const graph = new FileGraph({
+    path: '/',
+    type: 'folder',
+    discovered: false,
+  })
+  return {
+    status: 'inactive',
+    graph,
+    pwd: '',
+    hints: [],
+    tasks: [],
+  }
+}
+
+const store = reactive({
+  session: newSession(),
+  questId: '',
+  quest: null,
+})
+
+const socket = new Socket()
+const term = new SocketTerminal(40, 80)
+
+function setQuest(questId) {
+  api.get(`/quests/${questId}`).then((res) => {
+    store.questId = res.data._id
+    store.quest = res.data
+  })
+}
+
+async function setSession(session) {
+  store.session = session
+  store.session.graph = new FileGraph(session.graph)
+  term.reset()
+  await socket.connect(session)
+  term.focus()
+}
+
+export async function createSession() {
+  console.log('Creating a new session...')
+  const res = await api.post('/sessions', { quest_id: store.questId })
+  const { data } = res
+  await setSession(data)
+}
+
+async function getActiveSession(questId) {
+  const res = await api.post('/sessions/active', {
+    quest_id: questId,
+  })
+  const session = res.data
+  try {
+    await setSession(session)
+  } catch (err) {
+    console.log(err)
+    await createSession().catch(console.error)
+  }
+}
+
+function updateGraph(event) {
+  if (event.discover) {
+    store.session.graph.discover(event.discover)
+  }
+  if (event.pwd) {
+    store.session.pwd = event.pwd
+  }
+}
+
+function updateHints(hints) {
+  store.session.hints.push(...hints)
+}
+
+function updateStatus(status) {
+  store.session.status = status
+}
+
+function setTasks(tasks) {
+  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) {
+  reset()
+  await setQuest(questId)
+  await getActiveSession(questId)
+}
+
+function setup() {
+  socket.on('terminal', (data) => {
+    term.write(data)
+  })
+  term.onData((data) => {
+    socket.emit('terminal', data)
+  })
+  socket.on('graph', (event) => {
+    updateGraph(event)
+  })
+  socket.on('hints', (event) => {
+    updateHints(event)
+  })
+  socket.on('tasks', (tasks) => {
+    setTasks(tasks)
+  })
+  socket.on('status', (event) => {
+    updateStatus(event)
+  })
+}
+
+setup()
+
+export default store