scripts/utils/mobile-notify-user.js

   1 #!/usr/bin/env node
   2 'use strict';
   3
   4 const userService = require('gitter-web-users');
   5 const troupeService = require('gitter-web-rooms/lib/troupe-service');
   6 const chatService = require('gitter-web-chats');
   7 const pushNotificationGateway = require('../../server/gateways/push-notification-gateway');
   8 const serializer = require('../../server/serializers/notification-serializer');
   9 const oneToOneRoomService = require('gitter-web-rooms/lib/one-to-one-room-service');
  10 const shutdown = require('shutdown');
  11 const Promise = require('bluebird');
  12
  13 const opts = require('yargs')
  14   .option('username', {
  15     description: 'username to look up e.g trevorah',
  16     required: true,
  17     string: true
  18   })
  19   .option('room-uri', {
  20     description: 'room uri for chat'
  21   })
  22   .option('other-user', {
  23     description: 'Other user'
  24   })
  25   .help('help')
  26   .alias('help', 'h').argv;
  27
  28 async function findRoom(user, opts) {
  29   if (opts.roomUri) {
  30     return troupeService.findByUri(opts.roomUri);
  31   }
  32
  33   if (opts.otherUser) {
  34     const otherUser = await userService.findByUsername(opts.otherUser);
  35     return oneToOneRoomService.findOneToOneRoom(user._id, otherUser._id);
  36   }
  37
  38   throw new Error('Require either other user or roomUri');
  39 }
  40
  41 async function exec() {
  42   if (opts.username) {
  43     const user = await userService.findByUsername(opts.username).bind({});
  44
  45     const room = await findRoom(user, opts);
  46
  47     const chats = await chatService.findChatMessagesForTroupe(room._id, {
  48       limit: 2
  49     });
  50     var troupeStrategy = new serializer.TroupeIdStrategy({ recipientUserId: user._id });
  51     var chatStrategy = new serializer.ChatIdStrategy();
  52
  53     const serializedRoom = await serializer.serializeObject(room._id, troupeStrategy);
  54     const serializedChats = await serializer.serialize(
  55       chats.map(function(x) {
  56         return x._id;
  57       }),
  58       chatStrategy
  59     );
  60
  61     return pushNotificationGateway.sendUserNotification('new_chat', user.id, {
  62       chats: serializedChats,
  63       room: serializedRoom,
  64       hasMentions: false
  65     });
  66   } else {
  67     return Promise.try(function() {
  68       throw new Error('username or appleToken required');
  69     });
  70   }
  71 }
  72
  73 exec()
  74   .catch(function(err) {
  75     console.error(err, err.stack);
  76   })
  77   .finally(function() {
  78     shutdown.shutdownGracefully();
  79   });