[platform+module] app manager to enable app share

dna2github · dna2github · commit 0ed3cc33e67d · 2018-02-22T19:25:49.000+08:00
- import app from another NodeBase app manager server
- manage local app
- embed app manger files in NodeBase apk
diff --git a/app/app/src/main/java/seven/drawalive/nodebase/ModuleAppManager.java b/app/app/src/main/java/seven/drawalive/nodebase/ModuleAppManager.java
@@ -0,0 +1,42 @@
+package seven.drawalive.nodebase;
+
+import android.content.Context;
+
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStream;
+
+public class ModuleAppManager {
+   public static String appManagerJs(Context context) {
+      InputStream reader = context.getResources().openRawResource(R.raw.app_manager);
+      try {
+         byte[] buf = new byte[(int) reader.available()];
+         reader.read(buf);
+         return new String(buf);
+      } catch (IOException e) {
+         return null;
+      } finally {
+         if (reader != null) try { reader.close(); } catch (Exception e) {}
+      }
+   }
+
+   public static String appManagerReadme() {
+      return "# NodeBase Application Manager\nrunning: 20180\nparams:  (no params)\n";
+   }
+
+   public static String appManagerConfig() {
+      return "name=NodeBase Application Manager\nport=20180\n";
+   }
+
+   public static void InstallAppManager(Context context, String workdir) {
+      String appdir = workdir + "/app_manager";
+      File dir = new File(appdir);
+      if (dir.exists()) {
+         return;
+      }
+      dir.mkdir();
+      Storage.write(appManagerJs(context), appdir + "/index.js");
+      Storage.write(appManagerReadme(), appdir + "/readme");
+      Storage.write(appManagerConfig(), appdir + "/config");
+   }
+}
diff --git a/app/app/src/main/java/seven/drawalive/nodebase/NodeBase.java b/app/app/src/main/java/seven/drawalive/nodebase/NodeBase.java
@@ -51,8 +51,9 @@ protected void onDestroy() {
    @Override
    public boolean onCreateOptionsMenu(Menu menu) {
       menu.add(Menu.NONE, 101, Menu.NONE, "NICs");
-      menu.add(Menu.NONE, 102, Menu.NONE, "Node Version");
-      menu.add(Menu.NONE, 103, Menu.NONE, "Node Upgrade");
+      menu.add(Menu.NONE, 110, Menu.NONE, "Install App Manager");
+      menu.add(Menu.NONE, 120, Menu.NONE, "Node Version");
+      menu.add(Menu.NONE, 121, Menu.NONE, "Node Upgrade");
       menu.add(Menu.NONE, 199, Menu.NONE, "Reset");
       return true;
    }
@@ -63,10 +64,13 @@ public boolean onOptionsItemSelected(MenuItem item) {
          case 101: // Show Network Interfaces
             showNicIps();
             break;
-         case 102: // Show NodeJS Version
+         case 110: // Install App Manager
+            installAppManager();
+            break;
+         case 120: // Show NodeJS Version
             showNodeVersion();
             break;
-         case 103: // Upgrade NodeJS
+         case 121: // Upgrade NodeJS
             copyBinNodeFromNodebaseWorkdir();
             break;
          case 199: // Reset NodeJS
@@ -260,6 +264,12 @@ public void run() {
       }).act("Downlaod NodeJS", Configuration.NODE_URL, upgrade_node_filename);
    }
 
+   private void installAppManager() {
+      String workdir = config.workDir();
+      ModuleAppManager.InstallAppManager(this, workdir);
+      Alarm.showToast(this, "successful");
+   }
+
    // state
    private Configuration config;
    private ArrayList<NodeBaseApp> _appList;
diff --git a/app/app/src/main/java/seven/drawalive/nodebase/NodeService.java b/app/app/src/main/java/seven/drawalive/nodebase/NodeService.java
@@ -136,7 +136,9 @@ public boolean stopService() {
 
       public NodeMonitor restartService() {
          stopService();
-         return new NodeMonitor(service_name, command);
+         NodeMonitor m = new NodeMonitor(service_name, command);
+         if (event != null) m.setEvent(event);
+         return m;
       }
 
       public boolean isRunning() {
diff --git a/modules/app_manager/config b/modules/app_manager/config
@@ -0,0 +1,2 @@
+name=NodeBase Application Manager
+port=20180
diff --git a/modules/app_manager/index.js b/modules/app_manager/index.js
@@ -0,0 +1,268 @@
+const http = require('http');
+const url = require('url');
+const mime = require('mime');
+const path = require('path');
+const fs = require('fs');
+
+function get_ip (req) {
+   let ip = null;
+   if (req.headers['x-forwarded-for']) {
+      ip = req.headers['x-forwarded-for'].split(",")[0];
+   } else if (req.connection && req.connection.remoteAddress) {
+      ip = req.connection.remoteAddress;
+   } else {
+      ip = req.ip;
+   }
+   return ip;
+}
+
+function process_app_import(req, res, api, appname, appfiles, rename) {
+   function random_tmp_name() {
+      return 'tmp-' + Math.random();
+   }
+   function download_file(api, appname, appfiles, index, tmpdir, cb) {
+      if (index >= appfiles.length) {
+         cb();
+         return;
+      }
+      if (!appfiles[index]) {
+         download_file(api, appname, appfiles, index+1, tmpdir, cb);
+         return;
+      }
+      let filename = appfiles[index];
+      let tmpfile = path.join(tmpdir, filename);
+      let subtmpdir = path.dirname(tmpfile);
+      if (!fs.existsSync(subtmpdir)) {
+         fs.mkdirSync(subtmpdir);
+      }
+      let file = fs.createWriteStream(tmpfile);
+      let request = http.get(api + '/download/' + appname + '/' + filename, (obj) => {
+         obj.pipe(file);
+         download_file(api, appname, appfiles, index+1, tmpdir, cb);
+      }).on('error', (e) => {
+         errors.push('failed to download: ' + appfiles[index]);
+         download_file(api, appname, appfiles, index+1, tmpdir, cb);
+      });
+   }
+   let errors = [];
+   let tmpdir = path.join(Storage.work_dir, random_tmp_name());
+   let targetdir = path.join(Storage.work_dir, rename);
+   if (fs.existsSync(targetdir)) {
+      res.end('app exists: ' + rename);
+      return;
+   }
+   fs.mkdirSync(tmpdir);
+   download_file(api, appname, appfiles, 0, tmpdir, () => {
+      if (errors.length > 0) {
+         Storage.rmtree(tmpdir);
+         res.end(errors.join('\n'));
+         return;
+      }
+      fs.renameSync(tmpdir, targetdir);
+      res.end('');
+   });
+}
+
+function route(req, res) {
+   let r = url.parse(req.url);
+   let f = router;
+   let path = r.pathname.split('/');
+   let query = {};
+   r.query && r.query.split('&').forEach((one) => {
+      let key, val;
+      let i = one.indexOf('=');
+      if (i < 0) {
+         key = one;
+         val = '';
+      } else {
+         key = one.substring(0, i);
+         val = one.substring(i+1);
+      }
+      if (key in query) {
+         if(Array.isArray(query[key])) {
+            query[key].push(val);
+         } else {
+            query[key] = [query[key], val];
+         }
+      } else {
+         query[key] = val;
+      }
+   });
+   path.shift();
+   while (path.length > 0) {
+      let key = path.shift();
+      f = f[key];
+      if (!f) break;
+      if (typeof(f) === 'function') {
+         return f(req, res, {
+            path: path,
+            query: query
+         });
+      }
+   }
+   router.static(req, res, r.pathname);
+   // router.code(req, res, 404, 'Not Found');
+}
+
+const Storage = {
+   work_dir: path.dirname(__dirname),
+   list_directories: (dir) => {
+      return fs.readdirSync(dir).filter((name) => {
+         let subdir = path.join(dir, name);
+         let state = fs.lstatSync(subdir);
+         return state.isDirectory();
+      });
+   },
+   list_files: (dir) => {
+      let queue = [dir], list = [];
+      while (queue.length > 0) {
+         list_dir(queue.shift(), queue, list);
+      }
+      return list;
+
+      function list_dir(dir, queue, list) {
+         fs.readdirSync(dir).forEach((name) => {
+            let filename = path.join(dir, name);
+            let state = fs.lstatSync(filename);
+            if (state.isDirectory()) {
+               queue.push(filename);
+            } else {
+               list.push(filename);
+            }
+         });
+      }
+   },
+   rmtree: (dir) => {
+      if (dir.length < Storage.work_dir.length) {
+         return false;
+      }
+      if (dir.indexOf(Storage.work_dir) !== 0) {
+         return false;
+      }
+      if (!fs.existsSync(dir)) {
+         return false;
+      }
+      fs.readdirSync(dir).forEach(function(file, index){
+         var curPath = path.join(dir, file);
+         if (fs.lstatSync(curPath).isDirectory()) {
+            // recurse
+            rmtree(curPath);
+         } else { // delete file
+            fs.unlinkSync(curPath);
+         }
+      });
+      fs.rmdirSync(dir);
+      return true;
+   }
+};
+
+const router = {
+   app: {
+      list: (req, res, options) => {
+         let dir = path.dirname(__dirname);
+         if (!fs.existsSync(dir)) {
+            return router.code(req, res, 404, 'Not Found');
+         }
+         let names = Storage.list_directories(Storage.work_dir).filter((name) => {
+            if (name.startsWith('.')) return false;
+            if (name === 'node_modules') return false;
+            return true;
+         });
+         res.end(names.join('\n'));
+      },
+      files: (req, res, options) => {
+         let name = options.path[0];
+         if (!name) {
+            return router.code(req, res, 404, 'Not Found');
+         }
+         let subdir = path.join(Storage.work_dir, name);
+         if (!fs.existsSync(subdir)) {
+            return router.code(req, res, 404, 'Not Found');
+         }
+         let files = Storage.list_files(subdir).map((filename) => {
+            return filename.substring(subdir.length+1);
+         });
+         res.end(files.join('\n'));
+      },
+      download: (req, res, options) => {
+         if (options.path.indexOf('..') >= 0) {
+            return router.code(req, res, 404, 'Not Found');
+         }
+         let filename = path.join(...options.path);
+         filename = path.join(Storage.work_dir, filename);
+         if (!fs.existsSync(filename)) {
+            return router.code(req, res, 404, 'Not Found');
+         }
+         res.setHeader('Content-Disposition', 'attachment; filename=' + path.basename(filename));
+         //res.setHeader('Content-Type', 'application/octet-stream');
+         res.setHeader('Content-Type', 'text/plain');
+         let buf = fs.readFileSync(filename);
+         res.end(buf, 'binary');
+      },
+      delete: (req, res, options) => {
+         let name = options.path[0];
+         if (!name) {
+            return router.code(req, res, 404, 'Not Found');
+         }
+         let filename = path.join(Storage.work_dir, name);
+         // !!!! dangerous action
+         Storage.rmtree(filename);
+         res.end('');
+      },
+      import: (req, res, options) => {
+         // options.path [ip:port, appname, rename]
+         let host = options.path[0];
+         let appname = options.path[1];
+         let name = options.path[2] || appname;
+         let api = 'http://' + host + '/app';
+         http.get(api + '/files/' + appname, (obj) => {
+            if (~~(obj.statusCode/100) !== 2) {
+               obj.resume();
+               return router.code(req, res, 404, 'Not Found');
+            }
+            let raw = '';
+            obj.on('data', (chunk) => { raw += chunk; });
+            obj.on('end', () => {
+               process_app_import(req, res, api, appname, raw.split('\n'), name);
+            });
+         }).on('error', (e) => {
+            return router.code(req, res, 404, 'Not Found');
+         });
+      }
+   },
+   test: (req, res, options) => {
+      res.end('hello');
+   },
+   static: (req, res, filename) => {
+      if (!filename || filename === '/') {
+         filename = 'index.html';
+      }
+      filename = filename.split('/');
+      if (!filename[0]) filename.shift();
+      if (filename.length === 0 || filename.indexOf('..') >= 0) {
+         return router.code(req, res, 404, 'Not Found');
+      }
+      filename = path.join(__dirname, 'static', ...filename);
+      if (!fs.existsSync(filename)) {
+         return router.code(req, res, 404, 'Not Found');
+      }
+      res.setHeader('Content-Type', mime.lookup(filename));
+      let buf = fs.readFileSync(filename);
+      res.end(buf, 'binary');
+   },
+   code: (req, res, code, text) => {
+      res.writeHead(code || 404, text || '');
+      res.end();
+   }
+};
+
+init();
+
+const server = http.createServer((req, res) => {
+   route(req, res);
+});
+
+const instance = server.listen(20180, '0.0.0.0', () => {
+   console.log(instance.address());
+   console.log(`NodeBase Application Manager is listening at 0.0.0.0:20180`);
+});
diff --git a/modules/app_manager/readme b/modules/app_manager/readme
@@ -0,0 +1,3 @@
+# NodeBase Application Manager
+running: 20180
+params:  (no params)
diff --git a/modules/app_manager/static/index.html b/modules/app_manager/static/index.html

Original file line number	Diff line number	Diff line change
`@@ -136,7 +136,9 @@ public boolean stopService() {`
`136`	`136`
`137`	`137`	`public NodeMonitor restartService() {`
`138`	`138`	`stopService();`
`139`		`- return new NodeMonitor(service_name, command);`
	`139`	`+ NodeMonitor m = new NodeMonitor(service_name, command);`
	`140`	`+ if (event != null) m.setEvent(event);`
	`141`	`+ return m;`
`140`	`142`	`}`
`141`	`143`
`142`	`144`	`public boolean isRunning() {`
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,2 @@`
	`1`	`+name=NodeBase Application Manager`
	`2`	`+port=20180`
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+# NodeBase Application Manager`
	`2`	`+running: 20180`
	`3`	`+params: (no params)`