Merge pull request #8 from janithcooray/sync-change

Sync change

bin/index.js

@@ -0,0 +1,3 @@
+#! /usr/bin/env node
+import Init from "../src/init.js";
+new Init();

package.json

@@ -3,7 +3,10 @@
     "version": "1.0.0",
     "description": "",
     "type": "module",
-    "main": "index.js",
+    "main": "./bin/index.js",
+    "bin": {
+        "syncstat": "./bin/index.js"
+    },
     "repository": {
         "type": "git",
         "url": "git+https://github.com/janithcooray/sync-stat.git"
@@ -16,7 +19,9 @@
     "homepage": "https://sync-stat.nova64.xyz/",
     "dependencies": {
         "chokidar": "^3.5.3",
-        "stdio": "^2.1.1"
+        "js-yaml": "^4.1.0",
+        "stdio": "^2.1.1",
+        "yargs": "^17.5.1"
     },
     "scripts": {
         "test": "node index -m test"

src/abstract/ymlVersion.js

@@ -0,0 +1,44 @@
+import { default as Log } from "./log.js";
+
+export default class YamlVersion extends Log {
+
+    constructor(context){
+        super();
+        this.yml = context.yml;
+        this.context = context;
+    }
+
+
+    /**
+     * will Throw an error if version is below expected
+     */
+    checkCompatibility(){
+        //if (this.version > context.version) {
+       //     this.output("ignoring error - " + this.issueMessage)
+       // }
+    }
+
+    /**
+     * Some Yaml functions will be limited to versions
+     */
+    setMinVersion(version){
+        this.version = version;
+    }
+
+    getMinVersion(){
+        return this.version;
+    }
+
+    /**
+     * set Version Incompatibility Issue
+     * @param {*} text 
+     */
+    whenOnIncompatible(text){
+        this.issueMessage = text;
+    }
+
+    onIncompatible(){
+        return this.issueMessage;
+    }
+
+}

src/init.js

@@ -2,6 +2,7 @@ import fs from 'fs';
 import { default as stdio } from 'stdio';
 import Log from "./abstract/log.js";
 import Convert from './convert.js';
+import ProcessLinkYml from './processYML.js';
 import Sync from './sync.js';
 
 export default class Init extends Log {
@@ -10,79 +11,46 @@ export default class Init extends Log {
         /**
          * Add init 
          */
-        let ops =  stdio.getopt({
-            'mode': {key: 'm', args: 1, description: ' GCS or Local??',required: true, default : ["run"]},
-        });
+
+        const args_ = process.argv.slice(2);
 
-        switch (ops.mode) {
+        switch (args_[0]) {
             case "run":
-                    let volumes = this.getAllVolumes();
-                    this.assignSync(volumes);    
+                    new ProcessLinkYml();
                 break;
-            case "install":
+            case "convert":
                     new Convert();
                 break;
             case "test":
-                this.output("OK")
+                this.output("OK");
+            case "help":
+                this.help()
+            case "--help":
+                this.help()
+            case "-h":
+                this.help()
                 break;
+            case null:
+                this.output("Missing Command!");
+                this.help()
             default:
+                this.output(`Unknown Command "${args_[0]}"`);
+                this.help()
                 break;
         }
-
-
-
     }
 
-    /**
-     * retuns the state of 
-     * 
-     * Is it the first time this is running
-     */
-    getState = () => {
-       return JSON.parse(fs.readFileSync( this.getProjectRoot() +'/package.json', 'utf8'));
-    }
-
-    //parse Convertdata
-    getCompose = () => {
-        return JSON.parse(fs.readFileSync( this.getProjectRoot() +'/sync-compose.json', 'utf8'));
-    };
-
-    getContainers = (compose) =>{
-        let containers = []
-        Object.entries(compose).forEach(([key, value]) => {
-            containers.push(key);
-        });
-        return containers;
-    };
-
-    getVolumesAttached = (compose,container) => {
-        let volumes = [];
-        Object.entries(compose[container].volumes).forEach(element => {
-            volumes.push(element);
-        });
-        return volumes;
-    };
+help(){
+this.output(
+`Commands: [Option] <ARG1> <ARG2> ...
 
-    getAllVolumes = () => {
-        let compose = this.getCompose()["containers"];
-        let containers = this.getContainers(compose);
+    run                 - run sync compose
+    help,-h , --help    - display this help message
+    convert             - convert an existing docker-compose.yml
+    version             - Display Version
 
-        let allVolumes = [];
-        containers.forEach(element => {
-          let container = element;
-          let volumes = this.getVolumesAttached(compose,container);
-          volumes.forEach(vols => {
-            allVolumes.push([ container,vols[0], vols[1]]);
-          });
-        });
-        return allVolumes;
-    };
+    `);
+}
 
-    assignSync = (volumes) => {
-        volumes.forEach(element => {
-            this.output(`in ${element[0]} from ${element[2]} to ${element[1]}`);
-            //let sync = new Sync(element[0],element[1],element[2]);
-            //sync.startSync();      
-        });
-    };
+
 }

src/process.js

@@ -0,0 +1,19 @@
+/**
+ * ProccessAction 
+ * 
+ * Will decide if the project uses JSON verion or YAML version
+ */
+import Log from "./abstract/log.js";
+import ProcessJSON from "./processJSON.js";
+
+export default class ProccessAction extends Log {
+
+  constructor(){
+    /**
+     * For now Only JSON version Will work
+     */
+    let ProccessJSON =new ProcessJSON();
+    let volumes = ProccessJSON.getAllVolumes();
+    ProccessJSON.assignSync(volumes); 
+  }
+}

src/processJSON.js

@@ -0,0 +1,56 @@
+import Log from "./abstract/log.js";
+
+export default class ProcessJSON extends Log {
+    /**
+     * retuns the state of 
+     * 
+     * Is it the first time this is running
+     */
+     getState = () => {
+        return JSON.parse(fs.readFileSync( this.getProjectRoot() +'/package.json', 'utf8'));
+     }
+
+     //parse Convertdata
+     getCompose = () => {
+         return JSON.parse(fs.readFileSync( this.getProjectRoot() +'/sync-compose.json', 'utf8'));
+     };
+
+     getContainers = (compose) =>{
+         let containers = []
+         Object.entries(compose).forEach(([key, value]) => {
+             containers.push(key);
+         });
+         return containers;
+     };
+
+     getVolumesAttached = (compose,container) => {
+         let volumes = [];
+         Object.entries(compose[container].volumes).forEach(element => {
+             volumes.push(element);
+         });
+         return volumes;
+     };
+
+     getAllVolumes = () => {
+         let compose = this.getCompose()["containers"];
+         let containers = this.getContainers(compose);
+
+         let allVolumes = [];
+         containers.forEach(element => {
+           let container = element;
+           let volumes = this.getVolumesAttached(compose,container);
+           volumes.forEach(vols => {
+             allVolumes.push([ container,vols[0], vols[1]]);
+           });
+         });
+         return allVolumes;
+     };
+
+     assignSync = (volumes) => {
+         volumes.forEach(element => {
+             this.output(`in ${element[0]} from ${element[2]} to ${element[1]}`);
+             //let sync = new Sync(element[0],element[1],element[2]);
+             //sync.startSync();      
+         });
+     };
+}

src/processYML.js

@@ -0,0 +1,13 @@
+/**
+ * Process YML file
+ */
+import Log from "./abstract/log.js";
+import yaml from "js-yaml";
+import ProcessYML from "./ymlProcess/yamlProcess.js";
+export default class ProcessLinkYml extends Log {
+
+    constructor(){
+        super();
+        new ProcessYML();
+    }
+}

src/ymlProcess/getContainers.js

@@ -0,0 +1,22 @@
+import YamlVersion from "../abstract/ymlVersion.js";
+
+export default class GetContainers extends YamlVersion {
+
+    constructor(context){
+        super(context);
+        this.setMinVersion(1);
+        this.whenOnIncompatible("Cannot be under version 1, Please Update sync-compose");
+        this.checkCompatibility();
+
+        return this.getContainersFunction();
+    }
+
+    getContainersFunction = () => {
+        let containers = [];
+        this.yml.containers.forEach((key) => {
+            containers.push(key);
+        });
+        return containers;
+    }
+
+}

src/ymlProcess/getVolumes.js

@@ -0,0 +1,27 @@
+import YamlVersion from "../abstract/ymlVersion.js";
+import VolumeInfo from "./volumeData.js";
+
+export default class getVolumes extends YamlVersion{
+
+    constructor(context){
+        super(context);
+        this.setMinVersion(1);
+        this.whenOnIncompatible("Cannot be under version 1, Please Update sync-compose");
+        this.checkCompatibility();
+
+        //return this.getVolumesFunction();
+    }
+
+    getVolumesFunction = (container) => {
+        let volumes = []
+
+        Object.entries(container).forEach(([key, value]) => {
+            Object.entries(value.volumes).forEach(([id, volume]) => {
+                volumes.push(new VolumeInfo({container: key,id: id, volume}));
+            });
+        });
+
+        return volumes;
+    }
+
+}

src/ymlProcess/loadYML.js

@@ -0,0 +1,27 @@
+import yaml from "js-yaml";
+import fs from 'fs';
+import Log from "../abstract/log.js";
+
+export default class LoadYML extends Log {
+
+    constructor(){
+        super();
+        return this.getYML();
+    }
+
+    /**
+     * 
+     * @returns yml data
+     */
+    getYML(){
+        return yaml.load(this.getCompose());
+    }
+
+    /**
+     * 
+     * @returns sync-compose.yml
+     */
+    getCompose = () => {
+        return fs.readFileSync( this.getProjectRoot() +'/sync-compose.yml', 'utf8');
+    };
+}

src/ymlProcess/volumeData.js

@@ -0,0 +1,25 @@
+export default class VolumeInfo {
+    constructor(object){
+       return this.parse(object);
+    }
+
+    parse(object){
+        let volumeInfo = object.volume.volume;
+        volumeInfo.id = object.id; 
+        volumeInfo.container = object.container; 
+        return this.convert(volumeInfo);
+    }
+
+    convert(object){
+        this.container = object.container;
+        this.volumeId = object.id;
+        this.from= object.from,
+        this.to= object.to,
+        this.mode = object.mode,
+        this.owner = object.owner,
+        this.cmd = object.cmd,
+        this.ignore = object.ignore,
+        this.replace = object.replace
+
+    }
+}