Primitively implement main cms flow

If the cms is started with ssgOptions, then proceed to initing the
editor with the rootDirectory (started from $ writ start)

Otherwise ($ writ create or desktop app), try to find the most recent
project in a workspace directory (writ projects). If found, init the
editor with the project's path. Else, proceed to onboarding.

Onboarding makes sure the workspace + a new project now exist.

While at it:
- Keep watched directory in state so when ssg.watch() is called, we can
check if a specific directory is watched or not. And if a different
directory was being watched when ssg.watch() is called, stop the watcher
and start watching the new one.
- Pass the api object itself to its members, so they can sphagettify

Author: scriptype

src/cms/api/index.js

@@ -1,21 +1,22 @@
 const createAPI = (providers) => {
-  return {
-    settings: require('./models/settings')(providers),
-    fileSystemTree: require('./models/fileSystemTree')(providers),
-    contentModel: require('./models/contentModel')(providers),
-    collections: require('./models/collections')(providers),
-    categories: require('./models/categories')(providers),
-    category: require('./models/category')(providers),
-    posts: require('./models/posts')(providers),
-    post: require('./models/post')(providers),
-    subpages: require('./models/subpages')(providers),
-    subpage: require('./models/subpage')(providers),
-    homepage: require('./models/homepage')(providers),
-    tags: require('./models/tags')(providers),
-    tag: require('./models/tag')(providers),
-    ssg: require('./models/ssg')(providers),
-    ssgOptions: require('./models/ssgOptions')(providers),
-  }
+  const api = {}
+  api.settings = require('./models/settings')(providers, api)
+  api.fileSystemTree = require('./models/fileSystemTree')(providers, api)
+  api.contentModel = require('./models/contentModel')(providers, api)
+  api.collections = require('./models/collections')(providers, api)
+  api.categories = require('./models/categories')(providers, api)
+  api.category = require('./models/category')(providers, api)
+  api.posts = require('./models/posts')(providers, api)
+  api.post = require('./models/post')(providers, api)
+  api.subpages = require('./models/subpages')(providers, api)
+  api.subpage = require('./models/subpage')(providers, api)
+  api.homepage = require('./models/homepage')(providers, api)
+  api.tags = require('./models/tags')(providers, api)
+  api.tag = require('./models/tag')(providers, api)
+  api.ssg = require('./models/ssg')(providers, api)
+  api.ssgOptions = require('./models/ssgOptions')(providers, api)
+  api.workspace = require('./models/workspace')(providers, api)
+  return api
 }
 
 module.exports = createAPI

src/cms/api/models/ssg.js

@@ -15,7 +15,12 @@ const createSSGModel = (state) => {
 
     async watch({ rootDirectory, refreshTheme, debug, cli }) {
       if (state.isWatching()) {
-        return false
+        if (state.isWatching(rootDirectory)) {
+          console.log(`is already watching, not gonna do a thing (watching: ${rootDirectory})`)
+          return false
+        }
+        console.log(`was watching another. stopping it so now watch: ${rootDirectory}`)
+        await this.stopWatcher()
       }
       const { result, watcher } = await ssg.watch({
         rootDirectory,
@@ -24,7 +29,10 @@ const createSSGModel = (state) => {
         cli,
         onChange: state.setState
       })
-      state.startWatcher(watcher.stop)
+      state.startWatcher({
+        directory: rootDirectory,
+        stop: watcher.stop
+      })
       state.setState(result)
       return true
     },

src/cms/api/models/workspace.js

@@ -0,0 +1,61 @@
+const { homedir } = require('os')
+const { join } = require('path')
+const { mkdir, readdir, stat } = require('fs/promises')
+
+const createWorkspaceModel = (state) => {
+  const directoryName = 'writ projects'
+  const directoryPath = join(homedir(), directoryName)
+
+  const createProject = async (name) => {
+    const path = join(directoryPath, name)
+    const stats = await stat(path)
+    return {
+      name,
+      path,
+      dateModified: stats.mtime
+    }
+  }
+
+  return {
+    async get() {
+      try {
+        const directory = await readdir(directoryPath, { withFileTypes: true })
+        const isProject = item => item.isDirectory()
+        const projects = await Promise.all(
+          directory
+            .filter(isProject)
+            .map(item => createProject(item.name))
+            .sort((a, b) => b.dateModified - a.dateModified)
+        )
+        return {
+          projects
+        }
+      } catch (e) {
+        return {}
+      }
+    },
+
+    async create() {
+      try {
+        console.log('api.workspace.creating workspace folder')
+        await mkdir(directoryPath)
+      } catch (e) {
+        if (e.code !== 'EEXIST') {
+          console.log('api.workspace.create.error', e)
+          throw e
+        }
+        console.log('workspace already exists')
+      }
+      return this.get()
+    },
+
+    async createProject({ name }) {
+      await this.create()
+      const path = join(directoryPath, name)
+      await mkdir(path)
+      return createProject(name)
+    }
+  }
+}
+
+module.exports = createWorkspaceModel

src/cms/index.js

@@ -9,6 +9,7 @@ const createCMS = (initialState = {}) => {
       fileSystemTree: [],
       contentModel: {},
       watcher: {
+        directory: undefined,
         isRunning: false,
         stop: _=>_
       }
@@ -19,14 +20,21 @@ const createCMS = (initialState = {}) => {
       getFileSystemTree: () => state.fileSystemTree,
       getContentModel: () => state.contentModel,
       getSSGOptions: () => state.ssgOptions,
-      isWatching: () => state.watcher.isRunning,
+      isWatching: (directory) => {
+        if (directory) {
+          return state.watcher.isRunning && state.watcher.directory === directory
+        }
+        return state.watcher.isRunning
+      },
       stopWatcher: () => {
         state.watcher.stop()
         state.watcher.isRunning = false
+        state.watcher.directory = undefined
       },
-      startWatcher: (stopFn) => {
+      startWatcher: ({ directory, stop }) => {
+        state.watcher.directory = directory
         state.watcher.isRunning = true
-        state.watcher.stop = stopFn
+        state.watcher.stop = stop
       },
 
       setState: (newState) => {

src/cms/server/public/api.js

@@ -53,6 +53,39 @@ const api = {
     }
   },
 
+  workspace: {
+    get: async () => {
+      const response = await fetch('/api/workspace', {
+        method: 'get',
+        headers: {
+          'content-type': 'application/json'
+        }
+      })
+      return response.json()
+    },
+
+    create: async () => {
+      const response = await fetch('/api/workspace', {
+        method: 'post',
+        headers: {
+          'content-type': 'application/json'
+        }
+      })
+      return response.json()
+    },
+
+    createProject: async (options) => {
+      const response = await fetch('/api/workspace/project', {
+        method: 'post',
+        headers: {
+          'content-type': 'application/json'
+        },
+        body: JSON.stringify(options)
+      })
+      return response.json()
+    }
+  },
+
   category: {
     get: async (options) => {
       const { name } = options

src/cms/server/public/app.js

@@ -1,5 +1,54 @@
+import api from './api.js'
 import { setIframeSrc } from './common.js'
 
-window.addEventListener('DOMContentLoaded', () => {
+const findMostRecentProject = async () => {
+  console.log('checking workspace')
+  const workspace = await api.workspace.get()
+  if (!workspace.projects) {
+    console.log('workspace not found')
+    return undefined
+  }
+  if (!workspace.projects.length) {
+    console.log('no project not found')
+    return undefined
+  }
+  console.log('workspace projects', workspace.projects)
+  return workspace.projects[0]
+}
+
+const onboarding = async () => {
+  console.log('first time onboarding')
+  const newProject = await api.workspace.createProject({
+    name: prompt('Project name')
+  })
+  return editProject({
+    ssgOptions: {
+      rootDirectory: newProject.path
+    }
+  })
+}
+
+const editProject = async ({ ssgOptions }) => {
+  console.log('starting editor with ssgOptions', ssgOptions)
+  await api.ssg.watch(ssgOptions)
   setIframeSrc()
+}
+
+window.addEventListener('DOMContentLoaded', async () => {
+  const ssgOptions = await api.ssgOptions.get()
+  if (ssgOptions.rootDirectory) {
+    return editProject({
+      ssgOptions
+    })
+  }
+  const mostRecentProject = await findMostRecentProject()
+  if (mostRecentProject) {
+    console.log('running most recent project', mostRecentProject)
+    return editProject({
+      ssgOptions: {
+        rootDirectory: mostRecentProject.path
+      }
+    })
+  }
+  onboarding()
 })

src/cms/server/router/api/index.js

@@ -16,3 +16,4 @@ module.exports = express.Router()
   .use('/tag', require('./tag'))
   .use('/ssg', require('./ssg'))
   .use('/ssgOptions', require('./ssgOptions'))
+  .use('/workspace', require('./workspace'))

src/cms/server/router/api/workspace.js

@@ -0,0 +1,33 @@
+const express = require('express')
+
+module.exports = express.Router()
+  .get('/', async (req, res, next) => {
+    try {
+      res.status(200).json(
+        await req.api.workspace.get()
+      )
+    } catch (e) {
+      console.log('Error running workspace.get', e)
+      res.status(500).send(e)
+    }
+  })
+  .post('/', async (req, res, next) => {
+    try {
+      res.status(200).json(
+        await req.api.workspace.create()
+      )
+    } catch (e) {
+      console.log('Error running workspace.create', e)
+      res.status(500).send(e)
+    }
+  })
+  .post('/project', async (req, res, next) => {
+    try {
+      res.status(200).json(
+        await req.api.workspace.createProject(req.body)
+      )
+    } catch (e) {
+      console.log('Error running workspace.createProject', e)
+      res.status(500).send(e)
+    }
+  })