Add subscription API introduced in json-git 0.2.0

CHANGELOG.md

@@ -0,0 +1,5 @@
+# Changelog
+
+## 15/03/2017
+
+v0.2.0 - Add subscription API introduced in json-git 0.2.0

README.md

@@ -123,6 +123,8 @@ Note that **you must subscribe your component to the head of your repository** i
 * `getJSON(repositoryName)` exports a snapshot of a repository
 * `getLog(repositoryName)` returns the full history of a repository
 * `getTree(repositoryName)` returns the current tree of a repository
+* `subscribe(repositoryName, subscriber)` subscribe a subscriber to a repository
+* `unsubscribe(repositoryName, subscriber)` unsubscribe a subscriber from a repository
 
 To use them, just import them from `json-git-redux`:
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "json-git-redux",
-  "version": "0.1.1",
+  "version": "0.2.0",
   "description": "Official json-git bindings for Redux",
   "main": "./lib/index.js",
   "scripts": {
@@ -35,7 +35,7 @@
     "mocha": "3.2.0"
   },
   "peerDependencies": {
-    "json-git": "~0.1.0",
+    "json-git": "~0.2.0",
     "redux": "~3.6.0"
   }
 }

src/index.js

@@ -12,6 +12,8 @@ export const getDiff = createSelector(selectors.getDiff);
 export const getLog = createSelector(selectors.getLog);
 export const getTree = createSelector(selectors.getTree);
 export const getJSON = createSelector(selectors.getJSON);
+export const subscribe = createSelector(selectors.subscribe);
+export const unsubscribe = createSelector(selectors.unsubscribe);
 
 export function createReducer(repositories) {
     Object

src/selectors.js

@@ -33,3 +33,15 @@ export function getJSON(registry, repositoryName) {
 
     return registry.get(repositoryName).toJSON();
 }
+
+export function subscribe(registry, repositoryName, subscriber) {
+    ensureRepository(registry, repositoryName);
+
+    return registry.get(repositoryName).subscribe(subscriber);
+}
+
+export function unsubscribe(registry, repositoryName, subscriber) {
+    ensureRepository(registry, repositoryName);
+
+    return registry.get(repositoryName).unsubscribe(subscriber);
+}

src/selectorsSpec.js

@@ -5,6 +5,8 @@ import {
     getLog,
     getTree,
     getJSON,
+    subscribe,
+    unsubscribe,
 } from './selectors';
 
 describe('Selectors', () => {
@@ -21,7 +23,9 @@ describe('Selectors', () => {
             },
             diff: expect.createSpy().andReturn('i am a diff'),
             apply: expect.createSpy().andReturn('i am a tree'),
+            subscribe: expect.createSpy().andReturn('subscribed'),
             toJSON: expect.createSpy().andReturn('i am a json'),
+            unsubscribe: expect.createSpy().andReturn('unsubscribed'),
         };
 
         registry = {
@@ -91,4 +95,28 @@ describe('Selectors', () => {
         registry.has.andReturn(false);
         expect(() => getJSON(registry, 'test')).toThrow(/Repository test not found/);
     });
+
+    it('should call repository.subscribe() on a repository when subscribe() is called and return the result', () => {
+        expect(subscribe(registry, 'test', 'subscriber')).toBe('subscribed');
+        expect(registry.has).toHaveBeenCalledWith('test');
+        expect(registry.get).toHaveBeenCalledWith('test');
+        expect(repository.subscribe).toHaveBeenCalledWith('subscriber');
+    });
+
+    it("should throw an error is the repository doesn't exist when subscribe is called", () => {
+        registry.has.andReturn(false);
+        expect(() => subscribe(registry, 'test')).toThrow(/Repository test not found/);
+    });
+
+    it('should call repository.unsubscribe() on a repository when unsubscribe() is called and return the result', () => {
+        expect(unsubscribe(registry, 'test', 'subscriber')).toBe('unsubscribed');
+        expect(registry.has).toHaveBeenCalledWith('test');
+        expect(registry.get).toHaveBeenCalledWith('test');
+        expect(repository.unsubscribe).toHaveBeenCalledWith('subscriber');
+    });
+
+    it("should throw an error is the repository doesn't exist when unsubscribe is called", () => {
+        registry.has.andReturn(false);
+        expect(() => unsubscribe(registry, 'test')).toThrow(/Repository test not found/);
+    });
 });