push.rocks/smartchok
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(core): update

Browse Source
This commit is contained in:
Philipp Kunz
2018-10-10 17:06:40 +02:00
parent c7b0722155
commit 8f6a4f4909
9 changed files with 2782 additions and 1921 deletions
Download Patch File Download Diff File Expand all files Collapse all files

60
test/test.ts
View File

@ -1,45 +1,45 @@
import { tap, expect } from 'tapbundle'
import * as smartchok from '../ts/index'
import * as smartfile from 'smartfile'
import * as smartq from 'smartq'
import * as rx from 'rxjs/Rx'
import { tap, expect } from '@pushrocks/tapbundle';
import * as smartchok from '../ts/index';
import * as smartfile from '@pushrocks/smartfile';
import * as smartpromise from '@pushrocks/smartpromise';
import * as rx from 'rxjs/Rx';
// the module to test
let testSmartchok: smartchok.Smartchok
let testAddObservable: rx.Observable<any>
let testSubscription: rx.Subscription
let testSmartchok: smartchok.Smartchok;
let testAddObservable: rx.Observable<any>;
let testSubscription: rx.Subscription;
tap.test('should create a new instance', async () => {
testSmartchok = new smartchok.Smartchok([])
expect(testSmartchok).to.be.instanceof(smartchok.Smartchok)
})
testSmartchok = new smartchok.Smartchok([]);
expect(testSmartchok).to.be.instanceof(smartchok.Smartchok);
});
tap.test('should add some files to watch and start', async () => {
testSmartchok.add([ './test/assets/**/*.txt' ])
testSmartchok.add(['./test/assets/**/*.txt']);
let localPromise = testSmartchok.start().then(async () => {
testSmartchok.add([ './test/assets/**/*.md' ])
})
await expect(localPromise).to.eventually.be.fulfilled
})
testSmartchok.add(['./test/assets/**/*.md']);
});
await expect(localPromise).to.eventually.be.fulfilled;
});
tap.test('should get an observable for a certain event', async () => {
let localPromise = testSmartchok.getObservableFor('add').then(async (observableArg) => {
testAddObservable = observableArg
})
await expect(localPromise).to.eventually.be.fulfilled
})
let localPromise = testSmartchok.getObservableFor('add').then(async observableArg => {
testAddObservable = observableArg;
});
await expect(localPromise).to.eventually.be.fulfilled;
});
tap.test('should register an add operation', async () => {
let testDeferred = smartq.defer()
let testDeferred = smartpromise.defer();
testSubscription = testAddObservable.subscribe(x => {
testDeferred.resolve()
})
smartfile.memory.toFs('HI', './test/assets/hi.txt')
await expect(testDeferred.promise).to.eventually.be.fulfilled
})
testDeferred.resolve();
});
smartfile.memory.toFs('HI', './test/assets/hi.txt');
await expect(testDeferred.promise).to.eventually.be.fulfilled;
});
tap.test('should stop the watch process', async () => {
testSmartchok.stop()
})
testSmartchok.stop();
});
tap.start()
tap.start();