Merge pull request #108 from FlowFuse/add-file-api

First pass files api for docker

docker.js

@@ -1,4 +1,5 @@
 const got = require('got')
+const FormData = require('form-data')
 const Docker = require('dockerode')
 const path = require('path')
 const { chownSync, mkdirSync, rmSync } = require('fs')
@@ -170,6 +171,10 @@ const createContainer = async (project, domain) => {
         })
 }
 
+const getStaticFileUrl = async (instance, filePath) => {
+    return `http://${instance.id}:2880/flowforge/files/_/${encodeURIComponent(filePath)}`
+}
+
 /**
  * Docker Container driver
  *
@@ -547,5 +552,62 @@ module.exports = {
         }
 
         return properties
+    },
+
+    // Static Assets API
+    listFiles: async (instance, filePath) => {
+        const fileUrl = await getStaticFileUrl(instance, filePath)
+        try {
+            return got.get(fileUrl).json()
+        } catch (err) {
+            err.statusCode = err.response.statusCode
+            throw err
+        }
+    },
+
+    updateFile: async (instance, filePath, update) => {
+        const fileUrl = await getStaticFileUrl(instance, filePath)
+        try {
+            return got.put(fileUrl, {
+                json: update
+            })
+        } catch (err) {
+            err.statusCode = err.response.statusCode
+            throw err
+        }
+    },
+
+    deleteFile: async (instance, filePath) => {
+        const fileUrl = await getStaticFileUrl(instance, filePath)
+        try {
+            return got.delete(fileUrl)
+        } catch (err) {
+            err.statusCode = err.response.statusCode
+            throw err
+        }
+    },
+    createDirectory: async (instance, filePath, directoryName) => {
+        const fileUrl = await getStaticFileUrl(instance, filePath)
+        try {
+            return got.post(fileUrl, {
+                json: { path: directoryName }
+            })
+        } catch (err) {
+            err.statusCode = err.response.statusCode
+            throw err
+        }
+    },
+    uploadFile: async (instance, filePath, fileBuffer) => {
+        const form = new FormData()
+        form.append('file', fileBuffer, { filename: filePath })
+        const fileUrl = await getStaticFileUrl(instance, filePath)
+        try {
+            return got.post(fileUrl, {
+                body: form
+            })
+        } catch (err) {
+            err.statusCode = err.response.statusCode
+            throw err
+        }
     }
 }

package.json

@@ -22,6 +22,7 @@
     "license": "Apache-2.0",
     "dependencies": {
         "dockerode": "^3.3.1",
+        "form-data": "^4.0.0",
         "got": "^11.8.0"
     },
     "devDependencies": {