Support testcase for push service handle

Update manifest to allow getting push from podio

Author: phucpnt

package.json

@@ -92,6 +92,7 @@
     "chrome-storage-local": "^0.1.5",
     "classnames": "^2.2.5",
     "crossmessaging": "^0.2.0",
+    "faye": "^1.1.2",
     "moment": "^2.13.0",
     "podio-js": "^1.4.2",
     "react": "^0.14.7 || ^15.0.0",

src/app/containers/task/action-task.js

@@ -27,8 +27,9 @@ export function filterPanel({ status, category, assignee }) {
 
     let _assignee;
     if (assignee) {
-      _assignee = assignee.map(item => (item === 'me' ? getState().app.myAccount.data.id : item));
+      _assignee = assignee.map(item => (item === 'me' ? getState().app.myAccount.data.profileId : item));
     }
+
     return getRepo({})
         .then(api => api.task.filterList({ status, assignee: _assignee, category }))
         .then(data => {

src/app/struct/contact.js

@@ -9,6 +9,7 @@ const Contact = t.struct({
   avatar: t.maybe(t.String),
   avatarThumbnail: t.maybe(t.String),
   name: t.String,
+  profileId: t.Number
 });
 
 export default Contact;

src/browser/extension/connect/podio/create-push-service.js

@@ -0,0 +1,51 @@
+/**
+ * Created by phucpnt on 6/4/16.
+ */
+
+import faye from 'faye';
+
+export default function createPushService(podio, { workspaceId, messageHandle }) {
+
+
+  return podio.request('GET', `/space/${workspaceId}`).then(response => {
+    return new Promise((resolve, reject) => {
+      // Initialize faye client
+      const fayeClient = new faye.Client('https://push.podio.com/faye');
+
+      // Simple push object for handling a subscription
+      const push = {
+        subscription: null,
+        channel: null,
+        messageReceived(message) {
+          messageHandle(message);
+        },
+        addSubscription(channel) {
+          this.channel = channel;
+          this.subscription = fayeClient.subscribe(this.channel.channel, this.messageReceived);
+
+          this.subscription.then(function () {
+            console.log('Subscription is now active');
+            resolve(fayeClient);
+          }, function (error) {
+            console.error('Subscription failed: ', error.message, error);
+            reject(error);
+          });
+        }
+      };
+
+      // Extend faye client with signature and timestamp used for authentication
+      fayeClient.addExtension({
+        outgoing: function (message, callback) {
+          message.ext = message.ext || {};
+          message.ext = {
+            private_pub_signature: push.channel.signature,
+            private_pub_timestamp: push.channel.timestamp
+          };
+          callback(message);
+        }
+      });
+      push.addSubscription(response.push);
+
+    });
+  });
+}

src/browser/extension/connect/podio/helper/podio-id-list.js

@@ -22,10 +22,11 @@ export const DevTaskField = {
 
 export const ContactField = {
   id: 'profile.user_id',
+  profileId: 'profile.profile_id',
   name: 'profile.name',
   link: 'profile.link',
   avatar: 'profile.image.link',
   avatarThumbnail: 'profile.image.thumbnail_link',
   type: 'profile.type',
-  role: 'role'
+  role: 'role',
 };

src/browser/extension/connect/podio/repo-podio.js

@@ -2,6 +2,7 @@ import { isConnected } from './connect-podio';
 import taskOps from './task';
 import contactOps from './contact';
 import { DevTaskField } from './helper/podio-id-list';
+import createPushServicePodio from './create-push-service';
 
 export default function getApi({
     workspaceId = 4555999,
@@ -11,13 +12,21 @@ export default function getApi({
     taskAppId=15818250,
 }) {
 
+  const updateCallbacks = [];
+
   const api = podio => ({
     task: taskOps(podio, { appId: taskAppId, appField: DevTaskField }),
-    contact: contactOps(podio, { workspaceId })
+    contact: contactOps(podio, { workspaceId }),
+    addListenerForUpdates(callback) {
+      updateCallbacks.push(callback);
+    }
   });
 
+  const createPushService = podio => {
+    return podio;
+  };
 
-  return isConnected().then(api).catch(err => {
+  return isConnected().then(createPushService).then(api).catch(err => {
     throw err;
   });
 }

src/browser/extension/connect/podio/space.js

@@ -0,0 +1,3 @@
+/**
+ * Created by phucpnt on 6/4/16.
+ */

src/browser/extension/manifest.dev.json

@@ -23,5 +23,5 @@
     "webRequest",
     "webRequestBlocking"
   ],
-  "content_security_policy": "default-src 'self'; script-src 'self' http://localhost:3000 'unsafe-eval' 'unsafe-inline'; connect-src http://localhost:3000 ws://localhost:3000 ws://localhost:35729 http://*/ https://*/; style-src 'self' data: chrome-extension-resource: blob: 'unsafe-inline'; img-src 'self' data: http://*/ https://*/; frame-src 'self' http://*/ https://*/;"
+  "content_security_policy": "default-src 'self'; script-src 'self' https://*.podio.com/ http://localhost:3000 'unsafe-eval' 'unsafe-inline'; connect-src http://localhost:3000 ws://localhost:3000 ws://localhost:35729 http://*/ https://*/ wss://*/; style-src 'self' data: chrome-extension-resource: blob: 'unsafe-inline'; img-src 'self' data: http://*/ https://*/; frame-src 'self' http://*/ https://*/;"
 }

test/inbrowser/connect/podio/create-push-service.spec.js

@@ -0,0 +1,46 @@
+/**
+ * Created by phucpnt on 6/4/16.
+ */
+
+import { expect } from 'chai';
+import { spy } from 'sinon';
+import moment from 'moment';
+
+import createPushService from '../../../../src/browser/extension/connect/podio/create-push-service';
+import taskOps from '../../../../src/browser/extension/connect/podio/task';
+import connectPodio, { getAppTaskDetails } from '../../helper/connect-podio';
+
+const TEST_WORKSPACE_ID = 4572579;
+
+connectPodio(podio => {
+  const testTaskApp = getAppTaskDetails();
+  const apiTask = taskOps(podio, { appId: testTaskApp.appId, appField: testTaskApp.appFields });
+  describe.only('Podio Push Service', () => {
+
+    const fakeHandle = spy();
+    before(done => {
+      createPushService(podio, {
+        workspaceId: TEST_WORKSPACE_ID,
+        messageHandle: (...args) => {
+          console.log(args);
+          fakeHandle(...args);
+        },
+      }).then(() => done());
+    });
+
+    it('it should receive message when new task is created', (done) => {
+      apiTask.create({ subject: 'Test App', startDate: moment().format('YYYY-MM-DD HH:mm:ss') }).then(task => {
+        console.log(task);
+        setTimeout(() => {
+          expect(fakeHandle.called).to.be.true;
+          const pushedData = fakeHandle.getCall(0).args[0];
+          expect(pushedData).to.have.deep.property('data.data.context_ref');
+          expect(pushedData).to.have.deep.property('data.data.data_ref');
+          expect(pushedData.data.data.context_ref.id).to.equal(task.id);
+          done();
+        }, 1000);
+      });
+    });
+  });
+
+});

test/inbrowser/connect/podio/task.spec.js

@@ -37,7 +37,7 @@ connectPodio((podio) => {
 
   const task = taskOps(podio, { appId, appField });
 
-  describe.only('Task App Podio', () => {
+  describe('Task App Podio', () => {
     const taskApi = taskOps(podio, { appId: 15818250, appField });
     it('it support getting app setup', done => {
       taskApi.getAppSetup().then(response => {