initial

.gitignore

@@ -0,0 +1,4 @@
+node_modules/
+pages/
+public/
+coverage/

dist/index.d.ts

@@ -0,0 +1,36 @@
+/// <reference types="chokidar" />
+/// <reference types="q" />
+import * as plugins from './smartchok.plugins';
+import { Stringmap } from 'lik';
+export declare type TSmartchokStatus = 'idle' | 'starting' | 'watching';
+export declare type TFsEvent = 'add' | 'addDir' | 'change' | 'error' | 'unlink' | 'unlinkDir' | 'ready' | 'raw';
+export declare class Smartchok {
+    watchStringmap: Stringmap;
+    chokidarOptions: plugins.chokidar.WatchOptions;
+    status: TSmartchokStatus;
+    private watcher;
+    private watchingDeferred;
+    private eventObservablemap;
+    constructor(watchArrayArg: string[], optionsArg?: plugins.chokidar.WatchOptions);
+    /**
+     * adds files to the list of watched files
+     */
+    add(pathArrayArg: string[]): void;
+    /**
+     * removes files from the list of watched files
+     */
+    remove(pathArg: string): void;
+    /**
+     * gets an observable for a certain event
+     */
+    getObservableFor(fsEvent: TFsEvent): plugins.q.Promise<plugins.rx.Observable<any>>;
+    /**
+     * starts the watcher
+     * @returns Promise<void>
+     */
+    start(): plugins.q.Promise<void>;
+    /**
+     * stop the watcher process if watching
+     */
+    stop(): void;
+}

dist/index.js

@@ -0,0 +1,81 @@
+"use strict";
+const plugins = require("./smartchok.plugins");
+const lik_1 = require("lik");
+class Smartchok {
+    constructor(watchArrayArg, optionsArg = {}) {
+        this.watchStringmap = new lik_1.Stringmap();
+        this.watchingDeferred = plugins.q.defer(); // used to run things when watcher is initialized
+        this.eventObservablemap = new plugins.lik.Observablemap(); // register one observable per event
+        this.watchStringmap.addStringArray(watchArrayArg);
+        this.chokidarOptions = optionsArg;
+    }
+    /**
+     * adds files to the list of watched files
+     */
+    add(pathArrayArg) {
+        this.watchStringmap.addStringArray(pathArrayArg);
+        this.watchingDeferred.promise.then(() => {
+            this.watcher.add(pathArrayArg);
+        });
+    }
+    /**
+     * removes files from the list of watched files
+     */
+    remove(pathArg) {
+        this.watchStringmap.removeString(''); // TODO
+        this.watchingDeferred.promise.then(() => {
+            this.watcher.unwatch(pathArg);
+        });
+    }
+    /**
+     * gets an observable for a certain event
+     */
+    getObservableFor(fsEvent) {
+        let done = plugins.q.defer();
+        this.watchingDeferred.promise.then(() => {
+            let eventObservable = this.eventObservablemap.getObservableForEmitterEvent(this.watcher, fsEvent);
+            done.resolve(eventObservable);
+        });
+        return done.promise;
+    }
+    /**
+     * starts the watcher
+     * @returns Promise<void>
+     */
+    start() {
+        let done = plugins.q.defer();
+        this.status = 'starting';
+        this.watcher = plugins.chokidar.watch(this.watchStringmap.getStringArray(), this.chokidarOptions);
+        this.watcher.on('ready', () => {
+            this.status = 'watching';
+            this.watchingDeferred.resolve();
+            done.resolve();
+        });
+        return done.promise;
+    }
+    /**
+     * stop the watcher process if watching
+     */
+    stop() {
+        let closeWatcher = () => {
+            let watchedFiles = this.watcher.getWatched();
+            for (let key in watchedFiles) {
+                let files = watchedFiles[key];
+                for (let file in files) {
+                    let filePath = plugins.path.join(key, file);
+                    this.watcher.unwatch(filePath);
+                }
+            }
+            this.watcher.close();
+        };
+        if (this.status === 'watching') {
+            console.log('closing while watching');
+            closeWatcher();
+        }
+        else if (this.status === 'starting') {
+            this.watchingDeferred.promise.then(() => { closeWatcher(); });
+        }
+    }
+}
+exports.Smartchok = Smartchok;
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsK0NBQThDO0FBQzlDLDZCQUErQjtBQUsvQjtJQVFJLFlBQVksYUFBdUIsRUFBRSxVQUFVLEdBQWtDLEVBQUU7UUFQbkYsbUJBQWMsR0FBRyxJQUFJLGVBQVMsRUFBRSxDQUFBO1FBSXhCLHFCQUFnQixHQUFHLE9BQU8sQ0FBQyxDQUFDLENBQUMsS0FBSyxFQUFRLENBQUEsQ0FBQyxpREFBaUQ7UUFDNUYsdUJBQWtCLEdBQUcsSUFBSSxPQUFPLENBQUMsR0FBRyxDQUFDLGFBQWEsRUFBRSxDQUFBLENBQUMsb0NBQW9DO1FBRzdGLElBQUksQ0FBQyxjQUFjLENBQUMsY0FBYyxDQUFDLGFBQWEsQ0FBQyxDQUFBO1FBQ2pELElBQUksQ0FBQyxlQUFlLEdBQUcsVUFBVSxDQUFBO0lBQ3JDLENBQUM7SUFFRDs7T0FFRztJQUNILEdBQUcsQ0FBQyxZQUFzQjtRQUN0QixJQUFJLENBQUMsY0FBYyxDQUFDLGNBQWMsQ0FBQyxZQUFZLENBQUMsQ0FBQTtRQUNoRCxJQUFJLENBQUMsZ0JBQWdCLENBQUMsT0FBTyxDQUFDLElBQUksQ0FBQztZQUMvQixJQUFJLENBQUMsT0FBTyxDQUFDLEdBQUcsQ0FBQyxZQUFZLENBQUMsQ0FBQTtRQUNsQyxDQUFDLENBQUMsQ0FBQTtJQUNOLENBQUM7SUFFRDs7T0FFRztJQUNILE1BQU0sQ0FBQyxPQUFlO1FBQ2xCLElBQUksQ0FBQyxjQUFjLENBQUMsWUFBWSxDQUFDLEVBQUUsQ0FBQyxDQUFBLENBQUMsT0FBTztRQUM1QyxJQUFJLENBQUMsZ0JBQWdCLENBQUMsT0FBTyxDQUFDLElBQUksQ0FBQztZQUMvQixJQUFJLENBQUMsT0FBTyxDQUFDLE9BQU8sQ0FBQyxPQUFPLENBQUMsQ0FBQTtRQUNqQyxDQUFDLENBQUMsQ0FBQTtJQUNOLENBQUM7SUFFRDs7T0FFRztJQUNILGdCQUFnQixDQUFDLE9BQWlCO1FBQzlCLElBQUksSUFBSSxHQUFHLE9BQU8sQ0FBQyxDQUFDLENBQUMsS0FBSyxFQUE4QixDQUFBO1FBQ3hELElBQUksQ0FBQyxnQkFBZ0IsQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDO1lBQy9CLElBQUksZUFBZSxHQUFHLElBQUksQ0FBQyxrQkFBa0IsQ0FBQyw0QkFBNEIsQ0FBQyxJQUFJLENBQUMsT0FBTyxFQUFFLE9BQU8sQ0FBQyxDQUFBO1lBQ2pHLElBQUksQ0FBQyxPQUFPLENBQUMsZUFBZSxDQUFDLENBQUE7UUFDakMsQ0FBQyxDQUFDLENBQUE7UUFDRixNQUFNLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQTtJQUN2QixDQUFDO0lBRUQ7OztPQUdHO0lBQ0gsS0FBSztRQUNELElBQUksSUFBSSxHQUFHLE9BQU8sQ0FBQyxDQUFDLENBQUMsS0FBSyxFQUFRLENBQUE7UUFDbEMsSUFBSSxDQUFDLE1BQU0sR0FBRyxVQUFVLENBQUE7UUFDeEIsSUFBSSxDQUFDLE9BQU8sR0FBRyxPQUFPLENBQUMsUUFBUSxDQUFDLEtBQUssQ0FBQyxJQUFJLENBQUMsY0FBYyxDQUFDLGNBQWMsRUFBRSxFQUFFLElBQUksQ0FBQyxlQUFlLENBQUMsQ0FBQTtRQUNqRyxJQUFJLENBQUMsT0FBTyxDQUFDLEVBQUUsQ0FBQyxPQUFPLEVBQUU7WUFDckIsSUFBSSxDQUFDLE1BQU0sR0FBRyxVQUFVLENBQUE7WUFDeEIsSUFBSSxDQUFDLGdCQUFnQixDQUFDLE9BQU8sRUFBRSxDQUFBO1lBQy9CLElBQUksQ0FBQyxPQUFPLEVBQUUsQ0FBQTtRQUNsQixDQUFDLENBQUMsQ0FBQTtRQUNGLE1BQU0sQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFBO0lBQ3ZCLENBQUM7SUFFRDs7T0FFRztJQUNILElBQUk7UUFDQSxJQUFJLFlBQVksR0FBRztZQUNmLElBQUksWUFBWSxHQUFHLElBQUksQ0FBQyxPQUFPLENBQUMsVUFBVSxFQUFFLENBQUE7WUFDNUMsR0FBRyxDQUFDLENBQUMsSUFBSSxHQUFHLElBQUksWUFBWSxDQUFDLENBQUMsQ0FBQztnQkFDM0IsSUFBSSxLQUFLLEdBQUcsWUFBWSxDQUFDLEdBQUcsQ0FBQyxDQUFBO2dCQUM3QixHQUFHLENBQUMsQ0FBQyxJQUFJLElBQUksSUFBSSxLQUFLLENBQUMsQ0FBQyxDQUFDO29CQUNyQixJQUFJLFFBQVEsR0FBRyxPQUFPLENBQUMsSUFBSSxDQUFDLElBQUksQ0FBQyxHQUFHLEVBQUMsSUFBSSxDQUFDLENBQUE7b0JBQzFDLElBQUksQ0FBQyxPQUFPLENBQUMsT0FBTyxDQUFDLFFBQVEsQ0FBQyxDQUFBO2dCQUNsQyxDQUFDO1lBQ0wsQ0FBQztZQUNELElBQUksQ0FBQyxPQUFPLENBQUMsS0FBSyxFQUFFLENBQUE7UUFDeEIsQ0FBQyxDQUFBO1FBQ0QsRUFBRSxDQUFDLENBQUMsSUFBSSxDQUFDLE1BQU0sS0FBSyxVQUFVLENBQUMsQ0FBQyxDQUFDO1lBQzdCLE9BQU8sQ0FBQyxHQUFHLENBQUMsd0JBQXdCLENBQUMsQ0FBQTtZQUNyQyxZQUFZLEVBQUUsQ0FBQTtRQUNsQixDQUFDO1FBQUMsSUFBSSxDQUFDLEVBQUUsQ0FBQyxDQUFDLElBQUksQ0FBQyxNQUFNLEtBQUssVUFBVSxDQUFDLENBQUMsQ0FBQztZQUNwQyxJQUFJLENBQUMsZ0JBQWdCLENBQUMsT0FBTyxDQUFDLElBQUksQ0FBQyxRQUFRLFlBQVksRUFBRSxDQUFBLENBQUMsQ0FBQyxDQUFDLENBQUE7UUFDaEUsQ0FBQztJQUNMLENBQUM7Q0FDSjtBQW5GRCw4QkFtRkMifQ==

dist/smartchok.plugins.d.ts

@@ -0,0 +1,6 @@
+import 'typings-global';
+export import chokidar = require('chokidar');
+export import lik = require('lik');
+export import path = require('path');
+export import q = require('q');
+export import rx = require('rxjs/Rx');

dist/smartchok.plugins.js

@@ -0,0 +1,8 @@
+"use strict";
+require("typings-global");
+exports.chokidar = require("chokidar");
+exports.lik = require("lik");
+exports.path = require("path");
+exports.q = require("q");
+exports.rx = require("rxjs/Rx");
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRjaG9rLnBsdWdpbnMuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9zbWFydGNob2sucGx1Z2lucy50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsMEJBQXVCO0FBQ3ZCLHVDQUE0QztBQUM1Qyw2QkFBa0M7QUFDbEMsK0JBQW9DO0FBQ3BDLHlCQUE4QjtBQUM5QixnQ0FBcUMifQ==

npmextra.json

@@ -0,0 +1,5 @@
+{
+    "npmts": {
+        "mode": "default"
+    }
+}

package.json

@@ -0,0 +1,36 @@
+{
+  "name": "smartchok",
+  "version": "1.0.0",
+  "description": "smart wrapper for chokidar",
+  "main": "dist/index.js",
+  "typings": "dist/index.d.ts",
+  "scripts": {
+    "test": "(npm run prepareTest && npmts)",
+    "prepareTest":"(rm -f ./test/assets/hi.txt)"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+ssh://git@gitlab.com/pushrocks/smartchok.git"
+  },
+  "author": "Lossless GmbH",
+  "license": "MIT",
+  "bugs": {
+    "url": "https://gitlab.com/pushrocks/smartchok/issues"
+  },
+  "homepage": "https://gitlab.com/pushrocks/smartchok#README",
+  "dependencies": {
+    "@types/chokidar": "^1.4.29",
+    "@types/q": "0.0.31",
+    "chokidar": "^1.6.0",
+    "lik": "^1.0.20",
+    "q": "^1.4.1",
+    "rxjs": "^5.0.0-beta.12",
+    "typings-global": "^1.0.14"
+  },
+  "devDependencies": {
+    "@types/should": "^8.1.30",
+    "should": "^11.1.0",
+    "smartfile": "^4.0.20",
+    "typings-test": "^1.0.3"
+  }
+}

test/assets/hi.txt

@@ -0,0 +1 @@
+HI

test/assets/test1.txt

@@ -0,0 +1 @@
+# This is a textfile that will be cloned

test/test.d.ts

@@ -0,0 +1 @@
+import 'typings-test';

test/test.js

@@ -0,0 +1,35 @@
+"use strict";
+require("typings-test");
+const should = require("should");
+const smartfile = require("smartfile");
+const smartchok = require("../dist/index");
+describe('smartchok', function () {
+    let testSmartchok;
+    let testAddObservable;
+    let testSubscription;
+    it('should create a new instance', function () {
+        testSmartchok = new smartchok.Smartchok([]);
+        should(testSmartchok).be.instanceof(smartchok.Smartchok);
+    });
+    it('should add some files to watch and start', function (done) {
+        testSmartchok.add(['./test/assets/**/*.txt']);
+        testSmartchok.start().then(() => { done(); }).catch(err => { console.log(err); });
+    });
+    it('should get an observable for a certain event', function (done) {
+        testSmartchok.getObservableFor('add').then((observableArg) => {
+            testAddObservable = observableArg;
+            done();
+        }).catch(err => { console.log(err); });
+    });
+    it('should register an add operation', function (done) {
+        this.timeout(5000);
+        testSubscription = testAddObservable.subscribe(x => {
+            done();
+        });
+        smartfile.memory.toFs('HI', './test/assets/hi.txt');
+    });
+    it('should stop the watch process', function () {
+        testSmartchok.stop();
+    });
+});
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGVzdC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbInRlc3QudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLHdCQUFxQjtBQUNyQixpQ0FBZ0M7QUFDaEMsdUNBQXNDO0FBRXRDLDJDQUEwQztBQUUxQyxRQUFRLENBQUMsV0FBVyxFQUFDO0lBQ2pCLElBQUksYUFBa0MsQ0FBQTtJQUN0QyxJQUFJLGlCQUFxQyxDQUFBO0lBQ3pDLElBQUksZ0JBQWlDLENBQUE7SUFDckMsRUFBRSxDQUFDLDhCQUE4QixFQUFDO1FBQzlCLGFBQWEsR0FBRyxJQUFJLFNBQVMsQ0FBQyxTQUFTLENBQUMsRUFBRSxDQUFDLENBQUE7UUFDM0MsTUFBTSxDQUFDLGFBQWEsQ0FBQyxDQUFDLEVBQUUsQ0FBQyxVQUFVLENBQUMsU0FBUyxDQUFDLFNBQVMsQ0FBQyxDQUFBO0lBQzVELENBQUMsQ0FBQyxDQUFBO0lBQ0YsRUFBRSxDQUFDLDBDQUEwQyxFQUFDLFVBQVMsSUFBSTtRQUN2RCxhQUFhLENBQUMsR0FBRyxDQUFDLENBQUMsd0JBQXdCLENBQUMsQ0FBQyxDQUFBO1FBQzdDLGFBQWEsQ0FBQyxLQUFLLEVBQUUsQ0FBQyxJQUFJLENBQUMsUUFBUSxJQUFJLEVBQUUsQ0FBQSxDQUFDLENBQUMsQ0FBQyxDQUFDLEtBQUssQ0FBQyxHQUFHLE1BQU0sT0FBTyxDQUFDLEdBQUcsQ0FBQyxHQUFHLENBQUMsQ0FBQSxDQUFDLENBQUMsQ0FBQyxDQUFBO0lBQ25GLENBQUMsQ0FBQyxDQUFBO0lBQ0YsRUFBRSxDQUFDLDhDQUE4QyxFQUFDLFVBQVMsSUFBSTtRQUMzRCxhQUFhLENBQUMsZ0JBQWdCLENBQUMsS0FBSyxDQUFDLENBQUMsSUFBSSxDQUFDLENBQUMsYUFBYTtZQUNyRCxpQkFBaUIsR0FBRyxhQUFhLENBQUE7WUFDakMsSUFBSSxFQUFFLENBQUE7UUFDVixDQUFDLENBQUMsQ0FBQyxLQUFLLENBQUMsR0FBRyxNQUFNLE9BQU8sQ0FBQyxHQUFHLENBQUMsR0FBRyxDQUFDLENBQUEsQ0FBQyxDQUFDLENBQUMsQ0FBQTtJQUN6QyxDQUFDLENBQUMsQ0FBQTtJQUNGLEVBQUUsQ0FBQyxrQ0FBa0MsRUFBQyxVQUFTLElBQUk7UUFDL0MsSUFBSSxDQUFDLE9BQU8sQ0FBQyxJQUFJLENBQUMsQ0FBQTtRQUNsQixnQkFBZ0IsR0FBRyxpQkFBaUIsQ0FBQyxTQUFTLENBQUMsQ0FBQztZQUM1QyxJQUFJLEVBQUUsQ0FBQTtRQUNWLENBQUMsQ0FBQyxDQUFBO1FBQ0YsU0FBUyxDQUFDLE1BQU0sQ0FBQyxJQUFJLENBQUMsSUFBSSxFQUFDLHNCQUFzQixDQUFDLENBQUE7SUFDdEQsQ0FBQyxDQUFDLENBQUE7SUFDRixFQUFFLENBQUMsK0JBQStCLEVBQUM7UUFDL0IsYUFBYSxDQUFDLElBQUksRUFBRSxDQUFBO0lBQ3hCLENBQUMsQ0FBQyxDQUFBO0FBQ04sQ0FBQyxDQUFDLENBQUEifQ==

test/test.ts

@@ -0,0 +1,35 @@
+import 'typings-test'
+import * as should from 'should'
+import * as smartfile from 'smartfile'
+import * as rx from 'rxjs/Rx'
+import * as smartchok from '../dist/index'
+
+describe('smartchok',function(){
+    let testSmartchok: smartchok.Smartchok
+    let testAddObservable: rx.Observable<any>
+    let testSubscription: rx.Subscription
+    it('should create a new instance',function(){
+        testSmartchok = new smartchok.Smartchok([])
+        should(testSmartchok).be.instanceof(smartchok.Smartchok)
+    })
+    it('should add some files to watch and start',function(done){
+        testSmartchok.add(['./test/assets/**/*.txt'])
+        testSmartchok.start().then(() => { done() }).catch(err => { console.log(err) })
+    })
+    it('should get an observable for a certain event',function(done){
+        testSmartchok.getObservableFor('add').then((observableArg) => {
+            testAddObservable = observableArg
+            done()
+        }).catch(err => { console.log(err) })
+    })
+    it('should register an add operation',function(done){
+        this.timeout(5000)
+        testSubscription = testAddObservable.subscribe(x => {
+            done()
+        })
+        smartfile.memory.toFs('HI','./test/assets/hi.txt')
+    })
+    it('should stop the watch process',function() {
+        testSmartchok.stop()
+    })
+})

ts/index.ts

@@ -0,0 +1,82 @@
+import * as plugins from './smartchok.plugins'
+import { Stringmap } from 'lik'
+
+export type TSmartchokStatus = 'idle' | 'starting' | 'watching'
+export type TFsEvent = 'add' | 'addDir' | 'change' | 'error' | 'unlink' | 'unlinkDir' | 'ready' | 'raw'
+
+export class Smartchok {
+    watchStringmap = new Stringmap()
+    chokidarOptions: plugins.chokidar.WatchOptions
+    status: TSmartchokStatus
+    private watcher
+    private watchingDeferred = plugins.q.defer<void>() // used to run things when watcher is initialized
+    private eventObservablemap = new plugins.lik.Observablemap() // register one observable per event
+
+    constructor(watchArrayArg: string[], optionsArg: plugins.chokidar.WatchOptions = {}) {
+        this.watchStringmap.addStringArray(watchArrayArg)
+        this.chokidarOptions = optionsArg
+    }
+
+    /**
+     * adds files to the list of watched files
+     */
+    add(pathArrayArg: string[]) {
+        this.watchStringmap.addStringArray(pathArrayArg)
+        this.watchingDeferred.promise.then(() => {
+            this.watcher.add(pathArrayArg)
+        })
+    }
+
+    /**
+     * removes files from the list of watched files
+     */
+    remove(pathArg: string) {
+        this.watchStringmap.removeString('') // TODO
+        this.watchingDeferred.promise.then(() => {
+            this.watcher.unwatch(pathArg)
+        })
+    }
+
+    /**
+     * gets an observable for a certain event
+     */
+    getObservableFor(fsEvent: TFsEvent): plugins.q.Promise<plugins.rx.Observable<any>> {
+        let done = plugins.q.defer<plugins.rx.Observable<any>>()
+        this.watchingDeferred.promise.then(() => {
+            let eventObservable = this.eventObservablemap.getObservableForEmitterEvent(this.watcher, fsEvent)
+            done.resolve(eventObservable)
+        })
+        return done.promise
+    }
+
+    /**
+     * starts the watcher
+     * @returns Promise<void>
+     */
+    start(): plugins.q.Promise<void> {
+        let done = plugins.q.defer<void>()
+        this.status = 'starting'
+        this.watcher = plugins.chokidar.watch(this.watchStringmap.getStringArray(), this.chokidarOptions)
+        this.watcher.on('ready', () => {
+            this.status = 'watching'
+            this.watchingDeferred.resolve()
+            done.resolve()
+        })
+        return done.promise
+    }
+
+    /**
+     * stop the watcher process if watching
+     */
+    stop() {
+        let closeWatcher = () => {
+            this.watcher.close()
+        }
+        if (this.status === 'watching') {
+            console.log('closing while watching')
+            closeWatcher()
+        } else if (this.status === 'starting') {
+            this.watchingDeferred.promise.then(() => { closeWatcher() })
+        }
+    }
+}

ts/smartchok.plugins.ts

@@ -0,0 +1,6 @@
+import 'typings-global'
+export import chokidar = require('chokidar')
+export import lik = require('lik')
+export import path = require('path')
+export import q = require('q')
+export import rx = require('rxjs/Rx')

tslint.json

@@ -0,0 +1,3 @@
+{
+    "extends": "tslint-config-standard"
+}