First pass at file api

index.js

@@ -11,6 +11,7 @@ if (NODE_MAJOR_VERSION > 14) {
 
 const { Launcher } = require('./lib/launcher')
 const { AdminInterface } = require('./lib/admin')
+const { filesInterface } = require('./lib/files')
 
 const cmdLineOptions = [
     { name: 'port', alias: 'p', type: Number },
@@ -111,6 +112,7 @@ async function main () {
         await launcher.logAuditEvent('start-failed', { error })
     }
 
+    filesInterface(adminInterface.app, launcher.settings)
     // const wss = new ws.Server({ clientTracking: false, noServer: true })
     //
     // server.on('upgrade', (req, socket, head) => {

lib/admin.js

@@ -13,6 +13,7 @@ class AdminInterface {
         this.launcher = launcher
 
         const app = express()
+        this.app = app
         this.server = http.createServer(app)
 
         app.use(bodyParser.json({}))

lib/files/index.js

@@ -0,0 +1,120 @@
+const { mkdir, readdir, rm, rename, stat, writeFile } = require('fs/promises')
+const { existsSync }  = require('fs')
+const { dirname, join, normalize } = require('path')
+const multer = require('multer')
+
+const  filesInterface = (app, settings)  => {
+    const BASE_PATH = join(settings.rootDir, settings.userDir, 'storage')
+    // not sure about this yet, need to check how file storage works
+    const storage = multer.memoryStorage()
+    const upload = multer({storage: storage})
+
+    const regex = /^\/flowforge\/files\/_\/([\.a-zA-Z0-9\/\-_ ]*)$/
+
+    const listDirectory = async (path = '') => {
+        const fullPath = normalize(join(BASE_PATH, path))
+        if (fullPath.startsWith(BASE_PATH)) {
+            const files = await readdir(fullPath, {withFileTypes: true})
+            const response = {
+                meta: {
+                    next_cursor: ''
+                },
+                files: [],
+                count: files.length
+            }
+            for (i in files) {
+                const file = files[i]
+                const fullPath = join(file.path, file.name)
+                const s = await stat(fullPath)
+                const rep = {
+                    name: file.name,
+                    lastModified: s.mtime
+                }
+                if (file.isFile()) {
+                    rep.type = 'file'
+                    rep.size = s.size
+
+                } else if (file.isDirectory()) {
+                    rep.type = 'directory'
+                }
+                response.files.push(rep)
+            }
+            return response
+        } else {
+            return []
+        }
+    }
+
+    app.get(regex, async (request, reply) => {
+        try {
+            const files = await listDirectory(request.params[0])
+            reply.send(files)
+        } catch (err) {
+            if (err.code === 'ENOENT') {
+                reply.status(404).send()
+            }
+        }
+    })
+
+    app.put(regex, async (request, reply) => {
+        const fullPath = normalize(join(BASE_PATH, request.params[0]))
+        const newPath = normalize(join(BASE_PATH, request.body.path))
+        if (fullPath.startsWith(BASE_PATH) && newPath.startsWith(BASE_PATH)) {
+            if (existsSync(fullPath) && existsSync(dirname(newPath))) {
+                await rename(fullPath, newPath)
+                reply.status(202).send()
+            } else {
+                reply.status(404).send()
+            }
+        }
+        reply.status(403).send()
+    })
+
+    app.post(regex, upload.single('file'), async (request, reply) => {
+        const startPath = normalize(join(BASE_PATH, request.params[0]))
+        console.log(startPath)
+        if (startPath.startsWith(BASE_PATH)) {
+            console.log(request.get('content-type'))
+            if (request.get('content-type') === 'application/json') {
+                const newPath = request.body.path
+                const fullPath = normalize(join(startPath, newPath))
+                console.log(fullPath)
+                if (fullPath.startsWith(BASE_PATH)) {
+                    await mkdir(fullPath, {recursive: true})
+                    reply.status(201).send()
+                } else {
+                    console.log('problem')
+                    reply.status(500).send()
+                }
+            } else if (request.get('content-type').startsWith('multipart/form-data')) {
+                await writeFile(startPath, request.file.buffer)
+                reply.status(201).send()
+            } else {
+                reply.status(406).send()
+            }
+        } else {
+            reply.status(403).send()
+        }
+    })
+
+    app.delete(regex, async (request, reply) => {
+        const fullPath = normalize(join(BASE_PATH, request.params[0]))
+        if (fullPath !== BASE_PATH && fullPath.startsWith(BASE_PATH)) {
+            if (existsSync(fullPath)) {
+                await rm(fullPath, {
+                    force: true,
+                    recursive: true
+                })
+                reply.status(204).send()
+            } else {
+                reply.status(404).send()
+            }
+        } else {
+            reply.status(403).send()
+        }
+    })
+}
+
+module.exports = {
+    filesInterface
+}

package.json

@@ -55,6 +55,7 @@
         "got": "^11.8.6",
         "json-stringify-safe": "5.0.1",
         "memorystore": "^1.6.7",
+        "multer": "^1.4.5-lts.1",
         "oauth": "^0.9.15",
         "parse-prometheus-text-format": "^1.1.1",
         "passport": "0.6.0",