Added partial channelGroups for chatEngine server tests. (#19)

* Added partial channelGroups for chatEngine server tests. * Rm unused CG functions for breaking coverage.

Author: crgbaumgart

src/modules/pubnub.js

@@ -114,6 +114,36 @@ const pubnubInterface = {
  });
  });
  },
+ channelGroups: {
+ addChannels: (obj) => {
+ return new Promise((resolve) => {
+ if (typeof(obj) !== 'object' || (!obj.channels && !obj.channelGroup)) {
+ let err = '[channelGroups.addChannels] expects Object with [channels] and \'channelGroup\'';
+ throw Error(err);
+ }
+
+ resolve({
+ error: false,
+ operation: "PNAddChannelsToGroupOperation",
+ status: 200
+ });
+ });
+ },
+ removeChannels: (obj) => {
+ return new Promise((resolve) => {
+ if (typeof(obj) !== 'object' || (!obj.channelGroup)) {
+ let err = '[channelGroups.addChannels] expects Object with [channels] and \'channelGroup\'';
+ throw Error(err);
+ }
+
+ resolve({
+ error: false,
+ operation: "PNRemoveChannelsFromGroupOperation",
+ status: 200
+ });
+ });
+ },
+ },
 };
 pubnubInterface.fire = pubnubInterface.publish;
 

test/endpointEventHandler.js

@@ -226,6 +226,33 @@ export default (request, response) => {
  }).catch(testFail);
  }
 
+ if (request.channelGroups) {
+ let pubnub = require('pubnub');
+ let channelGroups = request.channelGroups;
+
+ if (channelGroups.addChannels) {
+ return pubnub.channelGroups.addChannels(channelGroups.addChannels).then((value) => {
+ if (value) {
+ response.status = 200;
+ return response.send(value)
+ } else {
+ return testFail(value);
+ }
+ })
+ }
+
+ if (channelGroups.removeChannels) {
+ return pubnub.channelGroups.removeChannels(channelGroups.removeChannels).then((value) => {
+ if (value) {
+ response.status = 200;
+ return response.send(value)
+ } else {
+ return testFail(value);
+ }
+ })
+ }
+ }
+
  response.status = 200;
  return response.send('Hello World!');
 };

test/unit.test.js

@@ -903,4 +903,65 @@ describe('#endpoint', () => {
  done();
  });
  });
+
+ it('adds a channel to channelGroups API', function(done) {
+ let request = Object.assign({}, endpointRequestObject);
+ let response = Object.assign({}, endpointResponseObject);
+
+ request.channelGroups = {
+ addChannels: {
+ channels: ['abcAsEasyAs123'],
+ channelGroup: 'yahBoiMichealJackson',
+ uuid: 'USER-MJ-0',
+ }
+ };
+
+ let correctResult = {
+ body: {
+ error: false,
+ operation: "PNAddChannelsToGroupOperation",
+ status: 200
+ },
+ status: 200
+ }
+
+ endpoint(request, response).then((testResult) => {
+ assert.equal(testResult.status, correctResult.status, 'status');
+ assert.equal(testResult.body.error, correctResult.body.error, 'body.error');
+ assert.equal(testResult.body.operation, correctResult.body.operation, 'body.operation');
+ assert.equal(testResult.body.status, correctResult.body.status, 'body.status');
+ done();
+ });
+ });
+
+ it('removes a channel from channelGroups API', function(done) {
+ let request = Object.assign({}, endpointRequestObject);
+ let response = Object.assign({}, endpointResponseObject);
+
+ request.channelGroups = {
+ removeChannels: {
+ channels: ['abcAsEasyAs123'],
+ channelGroup: 'yahBoiMichealJackson',
+ uuid: 'USER-MJ-1',
+ }
+ };
+
+ let correctResult = {
+ body: {
+ error: false,
+ operation: "PNRemoveChannelsFromGroupOperation",
+ status: 200
+ },
+ status: 200
+ };
+
+ endpoint(request, response).then((testResult) => {
+ assert.equal(testResult.status, correctResult.status, 'status');
+ assert.equal(testResult.body.error, correctResult.body.error, 'body.error');
+ assert.equal(testResult.body.operation, correctResult.body.operation, 'body.operation');
+ assert.equal(testResult.body.status, correctResult.body.status, 'body.status');
+ done();
+ });
+
+ });
 });