Adds bundling and working unit tests

Author: msusur

.gitignore

@@ -1 +1,2 @@
-node_modules/
+node_modules/
+dist/

.npmignore

@@ -1,2 +1,3 @@
 bower.json
-tsconfig.json
+tsconfig.json
+npm-debug.log

CHANGELOG.md

@@ -1,3 +1,5 @@
+## v1.1.2
+Added unit tests for the service and project restructure updated to use the benefits of webpack and bundling.
 
 ## v1.1.1
 Recovery fix and added interfaces.
@@ -33,7 +35,7 @@ declare class PubSubService{
 ```
 -------
 ## v1.0.0
-A simple publisher/subscriber service. 
+A simple publisher/subscriber service.
 
 ### Class Overview
 ```typescript

README.md

@@ -2,16 +2,21 @@
 
 A simple publisher/subscriber service. 
 
+## Contributers
+
+- [Semih KEŞKEK](http://github.com/sqlProvider)
+- [Mert SUSUR](http://github.com/msusur)
+
 ## Usage
  - Import service in your codes or download via npm or bower.
 
 `npm i --save angular2-pubsub` | `bower i --save angular2-pubsub`
 
- - Add service to App Module providers.
+ - Add module bundle to imports in your application.
 ```typescript
 ...
 
-import { EventDispatcherService } from './path/to/service/angular2-pubsub.service'; // <= HERE
+import { PubSubModule } from 'angular2-pubsub'; // <= HERE
 
 @NgModule({
 declarations: [
@@ -22,9 +27,10 @@ declarations: [
 imports: [
 	BrowserModule,
 	FormsModule,
-	HttpModule
+	HttpModule,
+	PubSubModule.forRoot() // <= AND HERE
 ],
-providers: [EventDispatcherService], // <= AND HERE
+providers: [], 
 bootstrap: [RootComponent]
 })
 
@@ -37,7 +43,7 @@ bootstrap: [RootComponent]
 #### Class Overview
 
 ```typescript
-declare class PubSubService{
+declare class PubSubService {
 	private events: Object;
 	$pub(event: string, eventObject?: any): void;
 	$sub(): undefined;
@@ -99,4 +105,15 @@ this.closeSidenavSub = this.pubsub.$sub('pleaseCloseSidenav').subscribe((from) =
 });
 
 // => 0 
-```
+```
+
+## Build the source
+
+Follow the steps to run the tests and build the source code.
+```sh
+npm install
+npm test
+npm run build
+```
+Commands above will generate the ready to use bundles under the `./dist` folder.
+

bower.json

@@ -1,10 +1,11 @@
 {
   "name": "angular2-pubsub",
   "description": "Pub/Sub service for Angular 2",
-  "version": "1.1.1",
-  "main": "",
+  "version": "1.1.2",
+  "main": "./umd/angular2-pubsub.js",
   "authors": [
-    "Semih KEŞKEK"
+    "Semih KEŞKEK",
+    "Mert SUSUR"
   ],
   "license": "ISC",
   "keywords": [

karma-test-runner.js

@@ -0,0 +1,29 @@
+
+Error.stackTraceLimit = Infinity;
+
+require('reflect-metadata');
+require('zone.js/dist/zone');;
+require('zone.js/dist/long-stack-trace-zone');
+require('zone.js/dist/async-test');
+require('zone.js/dist/fake-async-test');
+require('zone.js/dist/sync-test');
+require('zone.js/dist/proxy');
+require('zone.js/dist/jasmine-patch');
+
+var testing = require('@angular/core/testing');
+var browser = require('@angular/platform-browser-dynamic/testing');
+
+testing.TestBed.initTestEnvironment(
+  browser.BrowserDynamicTestingModule,
+  browser.platformBrowserDynamicTesting()
+);
+
+Object.assign(global, testing);
+
+var testContext = require.context('./src', true, /\.spec\.ts/);
+
+function requireAll(requireContext) {
+  return requireContext.keys().map(requireContext);
+}
+
+var modules = requireAll(testContext);

karma.conf.js

@@ -0,0 +1,16 @@
+module.exports = function (config) {
+    config.set({
+        browsers: ['PhantomJS'],
+        frameworks: ['jasmine'],
+        reporters: ['mocha'],
+        singleRun: true,
+        preprocessors: { './karma-test-runner.js': ['webpack', 'sourcemap'] },
+        files: [
+            { pattern: 'node_modules/babel-polyfill/browser.js', instrument: false },
+            { pattern: './karma-test-runner.js', watched: false }
+        ],
+        webpack: require('./webpack.config.test.js'),
+
+        webpackServer: { noInfo: true }
+    });
+};

package.json

@@ -2,13 +2,20 @@
   "name": "angular2-pubsub",
   "version": "1.1.2",
   "description": "Pub/Sub service for Angular 2",
+  "main": "./umd/angular2-pubsub.js",
+  "module": "./esm/src/index.js",
+  "typings": "./esm/src/index.d.ts",
   "repository": {
     "type": "git",
     "url": "git+https://github.com/sqlProvider/angular2-pubsub.git"
   },
   "scripts": {
-    "test": "",
-    "build": ""
+    "test": "karma start",
+    "clean": "rm -rf dist",
+    "build-umd": "webpack --config webpack.config.umd.js",
+    "build-angular": "ngc -p tsconfig-ngc.json",
+    "copy-package-info": "cp ./package.json ./dist/package.json && cp ./bower.json ./dist/bower.json",
+    "build": "npm run clean && npm run build-umd && npm run build-angular && npm run copy-package-info"
   },
   "keywords": [
     "Angular2",
@@ -19,6 +26,13 @@
     "name": "Semih KEŞKEK",
     "email": "keskeksmh@gmail.com"
   },
+  "contributors": [
+    {
+      "name": "Mert Susur",
+      "email": "mail@mertsusur.com",
+      "url": "http://github.com/msusur"
+    }
+  ],
   "license": "ISC",
   "bugs": {
     "url": "https://github.com/sqlProvider/angular2-pubsub/issues"
@@ -37,6 +51,7 @@
   },
   "devDependencies": {
     "@angular/compiler-cli": "^2.4.7",
+    "@angular/platform-browser-dynamic": "^2.4.7",
     "@types/es6-shim": "^0.31.32",
     "@types/jasmine": "^2.5.41",
     "@types/node": "^7.0.5",
@@ -46,6 +61,7 @@
     "codelyzer": "^2.0.0",
     "commitizen": "^2.9.5",
     "compression-webpack-plugin": "^0.3.2",
+    "extract-text-webpack-plugin": "^1.0.1",
     "imports-loader": "^0.7.0",
     "karma": "^1.4.1",
     "karma-chrome-launcher": "^2.0.0",
@@ -68,11 +84,11 @@
     "tslint": "^4.0.2",
     "tslint-loader": "^3.3.0",
     "typedoc": "^0.5.0",
-    "typescript": "~2.0.3",
+    "typescript": "^2.1.6",
     "validate-commit-msg": "^2.8.0",
     "webpack": "^1.13.0",
     "webpack-dev-server": "^1.16.1",
     "webpack-fix-default-import-plugin": "^1.0.1",
     "zone.js": "^0.7.4"
   }
-}
+}

src/angular2-pubsub.service.spec.ts

@@ -0,0 +1,49 @@
+/* tslint:disable:no-unused-variable */
+
+import { PubSubService } from './angular2-pubsub.service';
+import { Observable, Subscriber } from 'rxjs';
+
+describe('PubSubService', (): void => {
+    let pubService: PubSubService;
+
+    beforeEach(() => {
+        pubService = new PubSubService();
+    });
+
+    describe('$sub', (): void => {
+        it('should throw an error when event is falsy', (): void => {
+            expect(pubService.$sub.bind(undefined)).toThrow();
+        });
+
+        it('should return an observable when there is no callback', (): void => {
+            let result: any = pubService.$sub('test');
+            expect(result instanceof Observable).toBeTruthy();
+        });
+
+        it('should return a subscriber when there is a callback specified', (): void => {
+            let result: any = pubService.$sub('test', (v: any): void => {
+                '';
+            });
+            expect(result instanceof Subscriber).toBeTruthy();
+        });
+    });
+
+    describe('$pub', (): void => {
+        it('should throw an error when event is falsy', (): void => {
+            expect(pubService.$pub.bind(undefined)).toThrow();
+        });
+
+        it('should throw an error when event is not registered', (): void => {
+            expect(pubService.$pub.bind('not-registered')).toThrow();
+        });
+
+        it('should publish with parameters if the event is registered', (): void => {
+            let subscriberEventSpy: jasmine.Spy = jasmine.createSpy('subscriberEvent');
+            pubService.$sub('new-event', subscriberEventSpy);
+
+            pubService.$pub('new-event', 'foo');
+
+            expect(subscriberEventSpy).toHaveBeenCalledWith('foo');
+        });
+    });
+});

src/angular2-pubsub.service.ts

@@ -7,52 +7,38 @@ const ServiceName: string = "PubSub Service";
 
 @Injectable()
 export class PubSubService implements IPubSubService {
-	private events = {};
+	private events = { };
 
 	constructor() { }
 
-	$sub(event: string): Observable<any>;
-	$sub(event: string, callback: (value: any) => void): Subscription;
-	$sub(event: string, callback: (value: any) => void, error: (error: any) => void): Subscription;
-	$sub(event: string, callback: (value: any) => void, error: (error: any) => void, complete: () => void): Subscription;
-	$sub(event: string, callback?: (value: any) => void, error?: (error: any) => void, complete?: () => void) {
-		if (event == undefined) {
+	public $sub(event: string, callback?: (value: any) => void, error?: (error: any) => void, complete?: () => void) {
+		if (!event) {
 			throw new Error(`[${ServiceName}] => Subscription method must get event name.`);
-		};
+		}
 
 		if (this.events[event] === undefined) {
 			this.events[event] = new BehaviorSubject<any>(0);
 		}
 
-		if (!callback || typeof callback !== 'function') {
+		if (typeof callback !== 'function') {
 			return this.events[event].asObservable();
-		}
-		else {
+		} else {
 			return this.events[event].asObservable().subscribe(callback, error, complete);
 		}
 	}
 
-	$pub(event: string, eventObject?: any) {
-		if (event == undefined) {
+	public $pub(event: string, eventObject?: any) {
+		if (!event) {
 			throw new Error(`[${ServiceName}] => Publish method must get event name.`);
-		}
-		else if (this.events[event] === undefined) {
+		} else if (!this.events[event]) {
 			throw new Error(`[${ServiceName}] => No recorded events found for ${event}.`);
 		}
 
 		this.events[event].next(eventObject);
 	}
 }
 
-interface IPubSubService {
+export interface IPubSubService {
 	$pub(event: string, eventObject?: any);
-	$sub: I$sub;
+	$sub(event: string, callback?: (value: any) => void, error?: (error: any) => void, complete?: () => void);
 }
-
-interface I$sub {
-	(event: string): Observable<any>;
-	(event: string, callback: (value: any) => void): Subscription;
-	(event: string, callback: (value: any) => void, error: (error: any) => void): Subscription;
-	(event: string, callback: (value: any) => void, error: (error: any) => void, complete: () => void): Subscription;
-}
-