Open Source Projects Europe

'use strict';

var logger, core;
var NAMESPACE = '/mobiles';
var mobileNamespace;


function sayHello(req, res) {
  logger.info('Welcome to c2net!');
  return res.json(200, {message: core.getMessage()});
}

module.exports = function(dependencies) {
  var PubSub = dependencies('pubsub').local;
  // var io = dependencies('wsserver').io;

  // console.log('Something is wrong here!!!');
  // console.log(io);
  // console.log(dependencies('wsserver'));
/*
  io.on('connection', function(socket){
    console.log("One socket client is connected !!!");
    socket.emit('notification', { hello: 'world' });
    socket.on('disconnect', function(){
      console.log("One socket client is disconnected !!!");
    });
  });
*/
  // mobileNamespace = io.of(NAMESPACE);
  // mobileNamespace.on('connection', function(socket) {
  //   logger.info('New connection on ' + NAMESPACE);
  //
  //   // socket.on('subscribe', function(bookId) {
  //   //   logger.info('Joining contact room', bookId);
  //   //   socket.join(bookId);
  //   // });
  //   //
  //   // socket.on('unsubscribe', function(bookId) {
  //   //   logger.info('Leaving contact room', bookId);
  //   //   socket.leave(bookId);
  //   // });
  // });
  //
  // mobileNamespace.emit('notification','hello');


// setInterval(function(){
//   console.log(dependencies('wsserver'));
// },5000);

  // Community -------------------------------------------------------------------------------------------
  PubSub.topic('community:join').subscribe(function(data) {
    console.log(data);
    console.log("Join community successfully!");
  });

  PubSub.topic('community:leave').subscribe(function(data) {
    console.log(data);
    console.log("Leave community successfully!");
  });

  PubSub.topic('community:membership:invitation:cancel').subscribe(function(data) {
    console.log(data);
    console.log("Cancel invitation of joining into the community!");
  });

  PubSub.topic('community:membership:invitation:decline').subscribe(function(data) {
    console.log(data);
    console.log("Invitation of membership in the community is declined!");
  });

  PubSub.topic('community:membership:request:refuse').subscribe(function(data) {
    console.log(data);
    console.log("The request of membership in the communicty is refused!");
  });

  PubSub.topic('community:membership:request:cancel').subscribe(function(data) {
    console.log(data);
    console.log("The request of membership in the community is cannceled");
  });

  PubSub.topic('community:membership:invite').subscribe(function(data) {
    console.log(data);
    console.log("There is an invitation of being a member in the community!");
  });

  PubSub.topic('community:membership:request').subscribe(function(data) {
    console.log(data);
    console.log("There is a request of being a member in the community!");
  });

  // User login ------------------------------------------------------------------------------
  PubSub.topic('login:success').subscribe(function(data) {
  // console.log(data);
    console.log("Login successfully!");
  });

  PubSub.topic('login:failure').subscribe(function(data) {
  //  console.log(data);
    console.log("Login failure!");
  });

  // Notification -----------------------------------------------------------------------------
  PubSub.topic('notification:external').subscribe(function(data) {
    console.log(data);
    console.log("notification!");
  });

  // message -------------------------------------------------------------------------
  PubSub.topic('message:activity').subscribe(function(data) {
    console.log(data);
    console.log("Activity from message!");
  });

  PubSub.topic('message:stored').subscribe(function(data) {
    console.log(data);
    console.log("Message stored!");
  });

  // invitation -------------------------------------------------------------------------
  PubSub.topic('invitation:init:failure').subscribe(function(data) {
    console.log(data);
    console.log("Failure from initation of invitation!");
  });

  PubSub.topic('invitation:init:success').subscribe(function(data) {
    console.log(data);
    console.log("Success from initation of invitation!");
  });

  PubSub.topic('invitation:finalize:failure').subscribe(function(data) {
    console.log(data);
    console.log("Failure from finalization of invitation!");
  });

  PubSub.topic('invitation:finalize:success').subscribe(function(data) {
    console.log(data);
    console.log("Success from finalization of invitation!");
  });

  PubSub.topic('invitation:process:failure').subscribe(function(data) {
    console.log(data);
    console.log("Failure from process of invitation!");
  });

  PubSub.topic('invitation:process:success').subscribe(function(data) {
    console.log(data);
    console.log("Success from process of invitation!");
  });

  // -----------------------------------------------------------------------------------------

  logger = dependencies('logger');
  core = require('./core')(dependencies);
  return {
    sayHello: sayHello
  }
};