kick user from tribe, respond to kickedout msg

api/controllers/chatTribes.ts

@@ -10,7 +10,7 @@ import { Op } from 'sequelize'
 
 const constants = require(path.join(__dirname,'../../config/constants.json'))
 
-async function joinTribe(req, res){
+export async function joinTribe(req, res){
 	console.log('=> joinTribe')
 	const { uuid, group_key, name, host, amount, img, owner_pubkey, owner_alias } = req.body
 
@@ -93,7 +93,7 @@ async function joinTribe(req, res){
 	})
 }
 
-async function editTribe(req, res) {
+export async function editTribe(req, res) {
 	const {
 		name,
 		is_listed,
@@ -152,7 +152,7 @@ async function editTribe(req, res) {
 	}
 }
 
-async function replayChatHistory(chat, contact) {
+export async function replayChatHistory(chat, contact) {
 	if(!(chat&&chat.id&&contact&&contact.id)){
 		return console.log('[tribes] cant replay history')
 	}
@@ -206,8 +206,7 @@ async function replayChatHistory(chat, contact) {
 	})
 }
 
-
+export async function createTribeChatParams(owner, contactIds, name, img, price_per_message, price_to_join, escrow_amount, escrow_millis): Promise<{[k:string]:any}> {
-async function createTribeChatParams(owner, contactIds, name, img, price_per_message, price_to_join, escrow_amount, escrow_millis): Promise<{[k:string]:any}> {
 	let date = new Date()
 	date.setMilliseconds(0)
 	if (!(owner && contactIds && Array.isArray(contactIds))) {
@@ -237,12 +236,6 @@ async function createTribeChatParams(owner, contactIds, name, img, price_per_mes
 	}
 }
 
-export {
-    joinTribe, editTribe,
-    replayChatHistory,
-    createTribeChatParams
-}
-
 async function asyncForEach(array, callback) {
 	for (let index = 0; index < array.length; index++) {
 	  	await callback(array[index], index, array);

api/controllers/chats.ts

@@ -13,7 +13,7 @@ import {replayChatHistory,createTribeChatParams} from './chatTribes'
 
 const constants = require(path.join(__dirname,'../../config/constants.json'))
 
-async function kickChatMember(req, res){
+export async function kickChatMember(req, res){
 	const chatId = parseInt(req.params['chat_id'])
 	const contactId = parseInt(req.params['contact_id'])
 	if(!chatId || !contactId) {
@@ -46,13 +46,13 @@ async function kickChatMember(req, res){
 	success(res, true)
 }
 
-async function getChats(req, res) {
+export async function getChats(req, res) {
 	const chats = await models.Chat.findAll({ where:{deleted:false}, raw: true })
 	const c = chats.map(chat => jsonUtils.chatToJson(chat));
 	success(res, c)
 }
 
-async function mute(req, res) {
+export async function mute(req, res) {
 	const chatId = req.params['chat_id']
 	const mute = req.params['mute_unmute']
 
@@ -73,7 +73,7 @@ async function mute(req, res) {
 
 // just add self here if tribes
 // or can u add contacts as members?
-async function createGroupChat(req, res) {
+export async function createGroupChat(req, res) {
 	const {
 		name,
 		is_tribe,
@@ -159,7 +159,7 @@ async function createGroupChat(req, res) {
 }
 
 // only owner can do for tribe?
-async function addGroupMembers(req, res) {
+export async function addGroupMembers(req, res) {
 	const {
 		contact_ids,
 	} = req.body
@@ -199,7 +199,7 @@ async function addGroupMembers(req, res) {
 	})
 }
 
-const deleteChat = async (req, res) => {
+export const deleteChat = async (req, res) => {
 	const { id } = req.params
 
 	const owner = await models.Contact.findOne({ where: { isOwner: true } })
@@ -234,7 +234,7 @@ const deleteChat = async (req, res) => {
 	success(res, { chat_id: id })
 }
 
-async function receiveGroupJoin(payload) {
+export async function receiveGroupJoin(payload) {
 	console.log('=> receiveGroupJoin')
 	const { sender_pub_key, sender_alias, chat_uuid, chat_members, chat_type, isTribeOwner, date_string } = await helpers.parseReceiveParams(payload)
 
@@ -323,9 +323,9 @@ async function receiveGroupJoin(payload) {
 	})
 }
 
-async function receiveGroupLeave(payload) {
+export async function receiveGroupLeave(payload) {
 	console.log('=> receiveGroupLeave')
-	const { sender_pub_key, chat_uuid, chat_type, sender_alias, isTribeOwner, date_string } = await helpers.parseReceiveParams(payload)
+	const { sender_pub_key, chat_uuid, chat_type, sender_alias, isTribeOwner, date_string, chat_members } = await helpers.parseReceiveParams(payload)
 
 	const chat = await models.Chat.findOne({ where: { uuid: chat_uuid } })
 	if (!chat) return
@@ -333,6 +333,7 @@ async function receiveGroupLeave(payload) {
 	const isTribe = chat_type===constants.chat_types.tribe
 
 	let sender
+	// EITHER private chat OR tribeOwner
 	if(!isTribe || isTribeOwner) {
 		sender = await models.Contact.findOne({ where: { publicKey: sender_pub_key } })
 		if (!sender) return
@@ -354,8 +355,39 @@ async function receiveGroupLeave(payload) {
 			}
 		}
 	} else {
+		console.log('==> received leave as subsribers')
 		// check if im the only one in "members"
-		// and delete chat??
+		// if im the one in members
+		// i've been kicked out!
+		const owner = await models.Contact.findOne({where:{isOwner:true}})
+		let imKickedOut = false
+		for (let [pubkey, _] of Object.entries(chat_members)) {
+			console.log('==> member pubkey', pubkey, owner.publicKey)
+			if(pubkey===owner.publicKey) {
+				imKickedOut = true
+			}
+		}
+		if(imKickedOut) {
+			console.log('==> IM kicked out!')
+			await chat.update({
+				deleted: true, 
+				uuid:'', 
+				groupKey:'',
+				host:'',
+				photoUrl:'',
+				contactIds:'[]',
+				name:''
+			})
+			await models.Message.destroy({ where: { chatId: chat.id } })
+			socket.sendJson({
+				type: 'group_leave',
+				response: {
+					contact: jsonUtils.contactToJson(owner),
+					chat: jsonUtils.chatToJson(chat),
+				}
+			})
+			return // done - I've been kicked out
+		}
 	}
 
 	var date = new Date();
@@ -394,7 +426,7 @@ async function validateTribeOwner(chat_uuid: string, pubkey: string){
 	}
 	return false
 }
-async function receiveGroupCreateOrInvite(payload) {
+export async function receiveGroupCreateOrInvite(payload) {
 	const { sender_pub_key, chat_members, chat_name, chat_uuid, chat_type, chat_host, chat_key } = await helpers.parseReceiveParams(payload)
 
 	// maybe this just needs to move to adding tribe owner ChatMember?
@@ -511,12 +543,6 @@ function createGroupChatParams(owner, contactIds, members, name) {
 	}
 }
 
-export {
-	getChats, mute, addGroupMembers, kickChatMember,
-	receiveGroupCreateOrInvite, createGroupChat,
-	deleteChat, receiveGroupLeave, receiveGroupJoin,
-}
-
 async function asyncForEach(array, callback) {
 	for (let index = 0; index < array.length; index++) {
 	  	await callback(array[index], index, array);

api/controllers/contacts.ts

@@ -10,7 +10,7 @@ import { Op } from 'sequelize'
 
 const constants = require(path.join(__dirname,'../../config/constants.json'))
 
-const getContacts = async (req, res) => {
+export const getContacts = async (req, res) => {
 	const contacts = await models.Contact.findAll({ where:{deleted:false}, raw: true })
 	const invites = await models.Invite.findAll({ raw: true })
 	const chats = await models.Chat.findAll({ where:{deleted:false}, raw: true })
@@ -37,7 +37,7 @@ const getContacts = async (req, res) => {
 	})
 }
 
-const generateToken = async (req, res) => {
+export const generateToken = async (req, res) => {
 	console.log('=> generateToken called', { body: req.body, params: req.params, query: req.query })
 
 	const owner = await models.Contact.findOne({ where: { isOwner: true, authToken: null }})
@@ -66,7 +66,7 @@ const generateToken = async (req, res) => {
 	}
 }
 
-const updateContact = async (req, res) => {
+export const updateContact = async (req, res) => {
 	console.log('=> updateContact called', { body: req.body, params: req.params, query: req.query })
 
 	let attrs = extractAttrs(req.body)
@@ -97,7 +97,7 @@ const updateContact = async (req, res) => {
 	})
 }
 
-const exchangeKeys = async (req, res) => {
+export const exchangeKeys = async (req, res) => {
 	console.log('=> exchangeKeys called', { body: req.body, params: req.params, query: req.query })
 
 	const contact = await models.Contact.findOne({ where: { id: req.params.id }})
@@ -112,7 +112,7 @@ const exchangeKeys = async (req, res) => {
 	})
 }
 
-const createContact = async (req, res) => {
+export const createContact = async (req, res) => {
 	console.log('=> createContact called', { body: req.body, params: req.params, query: req.query })
 
 	let attrs = extractAttrs(req.body)
@@ -140,7 +140,7 @@ const createContact = async (req, res) => {
 	})
 }
 
-const deleteContact = async (req, res) => {
+export const deleteContact = async (req, res) => {
 	const id = parseInt(req.params.id||'0')
 	if(!id || id===1) {
 		failure(res, 'Cannot delete self')
@@ -195,7 +195,7 @@ const deleteContact = async (req, res) => {
 	success(res, {})
 }
 
-const receiveContactKey = async (payload) => {
+export const receiveContactKey = async (payload) => {
 	console.log('=> received contact key', JSON.stringify(payload))
 
 	const dat = payload.content || payload
@@ -230,7 +230,7 @@ const receiveContactKey = async (payload) => {
 	})
 }
 
-const receiveConfirmContactKey = async (payload) => {
+export const receiveConfirmContactKey = async (payload) => {
 	console.log(`=> confirm contact key for ${payload.sender&&payload.sender.pub_key}`, JSON.stringify(payload))
 
 	const dat = payload.content || payload
@@ -268,13 +268,3 @@ const extractAttrs = body => {
 	return attrs
 }
 
-export {
-	generateToken,
-	exchangeKeys,
-	getContacts,
-	updateContact,
-	createContact,
-	deleteContact,
-	receiveContactKey,
-	receiveConfirmContactKey
-}

api/controllers/details.ts

@@ -12,7 +12,7 @@ const defaultLogFiles = [
 	'/home/lnd/.pm2/logs/app-error.log',
 	'/var/log/syslog',
 ]
-async function getLogsSince(req, res) {
+export async function getLogsSince(req, res) {
 	const logFiles = config.log_file ? [config.log_file] : defaultLogFiles
 	let txt
 	let err
@@ -34,7 +34,7 @@ async function getLogsSince(req, res) {
 	else failure(res, err)
 }
 
-const getInfo = async (req, res) => {
+export const getInfo = async (req, res) => {
 	const lightning = loadLightning()
 	var request = {}
 	lightning.getInfo(request, function(err, response) {
@@ -48,7 +48,7 @@ const getInfo = async (req, res) => {
 	});
 };
 
-const getChannels = async (req, res) => {
+export const getChannels = async (req, res) => {
   const lightning = loadLightning()
 	var request = {}
 	lightning.listChannels(request, function(err, response) {
@@ -62,7 +62,7 @@ const getChannels = async (req, res) => {
 	});
 };
 
-const getBalance = (req, res) => {
+export const getBalance = (req, res) => {
   const lightning = loadLightning()
 	var request = {}
 	lightning.channelBalance(request, function(err, response) {
@@ -76,7 +76,7 @@ const getBalance = (req, res) => {
 	});
 };
 
-const getLocalRemoteBalance = async (req, res) => {
+export const getLocalRemoteBalance = async (req, res) => {
 	const lightning = loadLightning()
 	lightning.listChannels({}, (err, channelList) => {
 		const { channels } = channelList
@@ -96,7 +96,7 @@ const getLocalRemoteBalance = async (req, res) => {
 	  })
 };
 
-const getNodeInfo = async (req, res) => {
+export const getNodeInfo = async (req, res) => {
 	var ipOfSource = req.connection.remoteAddress;
 	if(!(ipOfSource.includes('127.0.0.1') || ipOfSource.includes('localhost'))){
 		res.status(401)
@@ -109,15 +109,6 @@ const getNodeInfo = async (req, res) => {
 	res.end()
 }
 
-export { 
-	getInfo, 
-	getBalance, 
-	getChannels, 
-	getLocalRemoteBalance,
-	getLogsSince,
-	getNodeInfo,
-}
-
 async function asyncForEach(array, callback) {
 	for (let index = 0; index < array.length; index++) {
 	  	await callback(array[index], index, array);

api/controllers/index.ts

@@ -20,7 +20,7 @@ const env = process.env.NODE_ENV || 'development';
 console.log("=> env:",env)
 const constants = require(path.join(__dirname,'../../config/constants.json'))
 
-async function set(app) {
+export async function set(app) {
 	
 	if(models && models.Subscription){
 		subcriptions.initializeCronJobs()
@@ -117,7 +117,7 @@ const login = (req, res) => {
 }
 
 const msgtypes = constants.message_types
-const ACTIONS = {
+export const ACTIONS = {
     [msgtypes.contact_key]: contacts.receiveContactKey,
     [msgtypes.contact_key_confirmation]: contacts.receiveConfirmContactKey,
     [msgtypes.message]: messages.receiveMessage,
@@ -135,5 +135,3 @@ const ACTIONS = {
 	[msgtypes.delete]: messages.receiveDeleteMessage,
 	[msgtypes.repayment]: ()=>{},
 }
-
-export {set, ACTIONS} 

api/controllers/invites.ts

@@ -3,7 +3,7 @@ import * as crypto from 'crypto'
 import * as jsonUtils from '../utils/json'
 import {finishInviteInHub, createInviteInHub, payInviteInvoice} from '../hub'
 
-const finishInvite = async (req, res) => {
+export const finishInvite = async (req, res) => {
 	const {
 		invite_string
   	} = req.body
@@ -27,7 +27,7 @@ const finishInvite = async (req, res) => {
     finishInviteInHub(params, onSuccess, onFailure)
 }
 
-const payInvite = async (req, res) => {
+export const payInvite = async (req, res) => {
 	// const params = {
 	// 	node_ip: process.env.NODE_IP
 	// }
@@ -62,7 +62,7 @@ const payInvite = async (req, res) => {
 	payInviteInvoice(dbInvite.invoice, onSuccess, onFailure)
 }
 
-const createInvite = async (req, res) => {
+export const createInvite = async (req, res) => {
 	const {
 		nickname,
 		welcome_message
@@ -115,8 +115,3 @@ const createInvite = async (req, res) => {
     createInviteInHub(params, onSuccess, onFailure)
 }
 
-export {
-	createInvite,
-	finishInvite,
-	payInvite
-}

api/controllers/invoices.ts

@@ -18,7 +18,7 @@ function stripLightningPrefix(s){
   return s
 }
 
-const payInvoice = async (req, res) => {
+export const payInvoice = async (req, res) => {
   const lightning = await loadLightning()
   const payment_request = stripLightningPrefix(req.body.payment_request)
 
@@ -75,13 +75,13 @@ const payInvoice = async (req, res) => {
   call.write({ payment_request })
 };
 
-const cancelInvoice = (req, res) => {
+export const cancelInvoice = (req, res) => {
   res.status(200);
   res.json({ success: false });
   res.end();
 };
 
-const createInvoice = async (req, res) => {
+export const createInvoice = async (req, res) => {
   const lightning = await loadLightning()
 
   const {
@@ -180,7 +180,7 @@ const createInvoice = async (req, res) => {
   }
 };
 
-const listInvoices = async (req, res) => {
+export const listInvoices = async (req, res) => {
   const lightning = await loadLightning()
 
   lightning.listInvoices({}, (err, response) => {
@@ -195,7 +195,7 @@ const listInvoices = async (req, res) => {
   });
 };
 
-const receiveInvoice = async (payload) => {
+export const receiveInvoice = async (payload) => {
   console.log('received invoice', payload)
 
   const total_spent = 1
@@ -246,14 +246,6 @@ const receiveInvoice = async (payload) => {
   sendConfirmation({ chat:theChat, sender: owner, msg_id })
 }
 
-export {
-  listInvoices,
-  payInvoice,
-  cancelInvoice,
-  createInvoice,
-  receiveInvoice
-}
-
 // lnd invoice stuff
 
 function decodePaymentRequest(paymentRequest) {

api/controllers/media.ts

@@ -39,7 +39,7 @@ purchase_accept should update the original attachment message with the terms and
 purchase_deny returns the sats
 */
 
-const sendAttachmentMessage = async (req, res) => {
+export const sendAttachmentMessage = async (req, res) => {
   // try {
   //   schemas.attachment.validateSync(req.body)
   // } catch(e) {
@@ -143,7 +143,7 @@ const sendAttachmentMessage = async (req, res) => {
   })
 }
 
-function saveMediaKeys(muid, mediaKeyMap, chatId, messageId, mediaType){
+export function saveMediaKeys(muid, mediaKeyMap, chatId, messageId, mediaType){
   if (typeof mediaKeyMap!=='object'){
     console.log('wrong type for mediaKeyMap')
     return
@@ -163,7 +163,7 @@ function saveMediaKeys(muid, mediaKeyMap, chatId, messageId, mediaType){
   }
 }
 
-const purchase = async (req, res) => {
+export const purchase = async (req, res) => {
   const {
     chat_id,
     contact_id,
@@ -218,7 +218,7 @@ const purchase = async (req, res) => {
 
 /* RECEIVERS */
 
-const receivePurchase = async (payload) => {
+export const receivePurchase = async (payload) => {
   console.log('=> received purchase', { payload })
 
   var date = new Date();
@@ -346,7 +346,7 @@ const receivePurchase = async (payload) => {
   })
 }
 
-const receivePurchaseAccept = async (payload) => {
+export const receivePurchaseAccept = async (payload) => {
   console.log('=> receivePurchaseAccept')
   var date = new Date();
   date.setMilliseconds(0)
@@ -391,7 +391,7 @@ const receivePurchaseAccept = async (payload) => {
   })
 }
 
-const receivePurchaseDeny = async (payload) => {
+export const receivePurchaseDeny = async (payload) => {
   console.log('=> receivePurchaseDeny')
   var date = new Date()
   date.setMilliseconds(0)
@@ -418,7 +418,7 @@ const receivePurchaseDeny = async (payload) => {
   })
 }
 
-const receiveAttachment = async (payload) => {
+export const receiveAttachment = async (payload) => {
   // console.log('received attachment', { payload })
 
   var date = new Date();
@@ -463,7 +463,7 @@ const receiveAttachment = async (payload) => {
   sendConfirmation({ chat:theChat, sender: owner, msg_id })
 }
 
-async function signer(req, res) {
+export async function signer(req, res) {
   if(!req.params.challenge) return resUtils.failure(res, "no challenge")
   try {
     const sig = await signBuffer(
@@ -479,7 +479,7 @@ async function signer(req, res) {
   }
 }
 
-async function verifier(msg, sig) {
+export async function verifier(msg, sig) {
   try {
     const res = await verifyMessage(msg, sig)
     return res
@@ -488,7 +488,7 @@ async function verifier(msg, sig) {
   }
 }
 
-async function getMyPubKey(){
+export async function getMyPubKey(){
   return new Promise((resolve,reject)=>{
     const lightning = loadLightning()
     var request = {}
@@ -500,7 +500,7 @@ async function getMyPubKey(){
   })
 }
 
-async function cycleMediaToken() {
+export async function cycleMediaToken() {
   try{
     if (process.env.TEST_LDAT) testLDAT()
 
@@ -520,7 +520,7 @@ async function cycleMediaToken() {
 
 const mediaURL = 'http://' + config.media_host + '/'
 
-async function getMediaToken(force) {
+export async function getMediaToken(force) {
   if(!force && meme.mediaToken) return meme.mediaToken
   await helpers.sleep(3000)
   try {
@@ -556,7 +556,7 @@ async function getMediaToken(force) {
   }
 }
 
-async function getMediaInfo(muid) {
+export async function getMediaInfo(muid) {
   try {
     const token = await getMediaToken(null)
     const res = await rp.get(mediaURL+'mymedia/'+muid,{
@@ -572,15 +572,3 @@ async function getMediaInfo(muid) {
   }
 }
 
-export {
-  sendAttachmentMessage,
-  receiveAttachment,
-  receivePurchase,
-  receivePurchaseAccept,
-  receivePurchaseDeny,
-  purchase,
-  signer,
-  verifier,
-  getMediaToken,
-  cycleMediaToken
-}

api/controllers/messages.ts

@@ -14,7 +14,7 @@ import * as short from 'short-uuid'
 
 const constants = require(path.join(__dirname,'../../config/constants.json'))
 
-const getMessages = async (req, res) => {
+export const getMessages = async (req, res) => {
 	const dateToReturn = req.query.date;
 
 	if (!dateToReturn) {
@@ -88,7 +88,7 @@ const getMessages = async (req, res) => {
 	res.end()
 }
 
-const getAllMessages = async (req, res) => {
+export const getAllMessages = async (req, res) => {
 	const limit = (req.query.limit && parseInt(req.query.limit)) || 1000
 	const offset = (req.query.offset && parseInt(req.query.offset)) || 0
 
@@ -106,7 +106,7 @@ const getAllMessages = async (req, res) => {
 	})
 };
 
-async function deleteMessage(req, res){
+export async function deleteMessage(req, res){
 	const id = parseInt(req.params.id)
 
 	const message = await models.Message.findOne({where:{id}})
@@ -137,7 +137,7 @@ async function deleteMessage(req, res){
 	})
 }
 
-const sendMessage = async (req, res) => {
+export const sendMessage = async (req, res) => {
 	// try {
 	// 	schemas.message.validateSync(req.body)
 	// } catch(e) {
@@ -198,7 +198,7 @@ const sendMessage = async (req, res) => {
 	})
 }
 
-const receiveMessage = async (payload) => {
+export const receiveMessage = async (payload) => {
 	// console.log('received message', { payload })
 
 	var date = new Date();
@@ -246,7 +246,7 @@ const receiveMessage = async (payload) => {
 	sendConfirmation({ chat:theChat, sender: owner, msg_id })
 }
 
-const receiveDeleteMessage = async (payload) => {
+export const receiveDeleteMessage = async (payload) => {
 	console.log('=> received delete message')
 	const {owner, sender, chat, chat_type, msg_uuid} = await helpers.parseReceiveParams(payload)
 	if(!owner || !sender || !chat) {
@@ -269,7 +269,7 @@ const receiveDeleteMessage = async (payload) => {
 	})
 }
 
-const readMessages = async (req, res) => {
+export const readMessages = async (req, res) => {
 	const chat_id = req.params.chat_id;
 	
 	const owner = await models.Contact.findOne({ where: { isOwner: true }})
@@ -286,19 +286,8 @@ const readMessages = async (req, res) => {
 	success(res, {})
 }
 
-const clearMessages = (req, res) => {
+export const clearMessages = (req, res) => {
 	models.Message.destroy({ where: {}, truncate: true })
 
 	success(res, {})
 }
-
-export {
-  getMessages,
-  sendMessage,
-  receiveMessage,
-  clearMessages,
-  readMessages,
-  deleteMessage,
-  getAllMessages,
-  receiveDeleteMessage,
-}

api/controllers/payment.ts

@@ -10,7 +10,7 @@ import * as constants from '../../config/constants.json'
 import * as network from '../network'
 import * as short from 'short-uuid'
 
-const sendPayment = async (req, res) => {
+export const sendPayment = async (req, res) => {
   const {
     amount,
     chat_id,
@@ -125,7 +125,7 @@ const sendPayment = async (req, res) => {
   })
 };
 
-const receivePayment = async (payload) => {
+export const receivePayment = async (payload) => {
   console.log('received payment', { payload })
 
   var date = new Date();
@@ -167,7 +167,7 @@ const receivePayment = async (payload) => {
   sendNotification(chat, msg.senderAlias||sender.alias, 'message')
 }
 
-const listPayments = async (req, res) => {
+export const listPayments = async (req, res) => {
   const limit = (req.query.limit && parseInt(req.query.limit)) || 100
   const offset = (req.query.offset && parseInt(req.query.offset)) || 0
   
@@ -217,8 +217,3 @@ const listPayments = async (req, res) => {
   success(res, payments.splice(offset, limit))
 };
 
-export {
-  sendPayment,
-  receivePayment,
-  listPayments,
-}

api/controllers/schemas.ts

@@ -5,25 +5,19 @@ These schemas validate payloads coming from app,
 do not necessarily match up with Models
 */
 
-const attachment = yup.object().shape({
+export const attachment = yup.object().shape({
     muid: yup.string().required(),
     media_type: yup.string().required(),
     media_key_map: yup.object().required(),
 })
 
-const message = yup.object().shape({
+export const message = yup.object().shape({
     contact_id: yup.number().required(),
 })
 
-const purchase = yup.object().shape({
+export const purchase = yup.object().shape({
     chat_id: yup.number().required(),
     contact_id: yup.number().required(),
     media_token: yup.string().required(),
     amount: yup.number().required()
 })
-
-export {
-    attachment, 
-    purchase,
-    message,
-}

api/controllers/subscriptions.ts

@@ -17,7 +17,7 @@ const constants = require(path.join(__dirname,'../../config/constants.json'))
 let jobs = {}
 
 // init jobs from DB
-const initializeCronJobs = async () => {
+export const initializeCronJobs = async () => {
   await helpers.sleep(1000)
   const subs = await getRawSubs({ where: { ended: false } })
   subs.length && subs.forEach(sub => {
@@ -189,7 +189,7 @@ async function sendSubscriptionPayment(sub, isFirstMessage) {
 }
 
 // pause sub
-async function pauseSubscription(req, res) {
+export async function pauseSubscription(req, res) {
   const id = parseInt(req.params.id)
   try {
     const sub = await models.Subscription.findOne({ where: { id } })
@@ -207,7 +207,7 @@ async function pauseSubscription(req, res) {
 };
 
 // restart sub
-async function restartSubscription(req, res) {
+export async function restartSubscription(req, res) {
   const id = parseInt(req.params.id)
   try {
     const sub = await models.Subscription.findOne({ where: { id } })
@@ -235,7 +235,7 @@ async function getRawSubs(opts = {}) {
 }
 
 // all subs
-const getAllSubscriptions = async (req, res) => {
+export const getAllSubscriptions = async (req, res) => {
   try {
     const subs = await getRawSubs()
     success(res, subs.map(sub => jsonUtils.subscriptionToJson(sub,null)))
@@ -246,7 +246,7 @@ const getAllSubscriptions = async (req, res) => {
 };
 
 // one sub by id
-async function getSubscription(req, res) {
+export async function getSubscription(req, res) {
   try {
     const sub = await models.Subscription.findOne({ where: { id: req.params.id } })
     success(res, jsonUtils.subscriptionToJson(sub,null))
@@ -257,7 +257,7 @@ async function getSubscription(req, res) {
 };
 
 // delete sub by id
-async function deleteSubscription(req, res) {
+export async function deleteSubscription(req, res) {
   const id = req.params.id
   if (!id) return
   try {
@@ -274,7 +274,7 @@ async function deleteSubscription(req, res) {
 };
 
 // all subs for contact id
-const getSubscriptionsForContact = async (req, res) => {
+export const getSubscriptionsForContact = async (req, res) => {
   try {
     const subs = await getRawSubs({ where: { contactId: req.params.contactId } })
     success(res, subs.map(sub => jsonUtils.subscriptionToJson(sub,null)))
@@ -285,7 +285,7 @@ const getSubscriptionsForContact = async (req, res) => {
 };
 
 // create new sub
-async function createSubscription(req, res) {
+export async function createSubscription(req, res) {
   const date = new Date()
   date.setMilliseconds(0)
   const s = jsonToSubscription({
@@ -321,7 +321,7 @@ async function createSubscription(req, res) {
   }
 };
 
-async function editSubscription(req, res) {
+export async function editSubscription(req, res) {
   console.log('======> editSubscription')
   const date = new Date()
   date.setMilliseconds(0)
@@ -376,14 +376,3 @@ function jsonToSubscription(j) {
   })
 }
 
-export {
-  initializeCronJobs,
-  getAllSubscriptions,
-  getSubscription,
-  createSubscription,
-  getSubscriptionsForContact,
-  pauseSubscription,
-  restartSubscription,
-  deleteSubscription,
-  editSubscription,
-}

api/controllers/uploads.ts

@@ -22,7 +22,7 @@ var avatarStorage = multer.diskStorage({
     }
   }
 })
-var avatarUpload = multer({ storage: avatarStorage })
+export var avatarUpload = multer({ storage: avatarStorage })
 
 function hasProtocol(ip){
   if(ip.startsWith('https://')) return true
@@ -30,7 +30,7 @@ function hasProtocol(ip){
   return false
 }
 
-const uploadFile = async (req, res) => {
+export const uploadFile = async (req, res) => {
   const { contact_id, chat_id } = req.body
   const { file } = req
 
@@ -62,8 +62,3 @@ const uploadFile = async (req, res) => {
   });
   res.end();
 }
-
-export {
-  avatarUpload,
-	uploadFile
-}

api/grpc/index.ts

@@ -12,7 +12,7 @@ const constants = require(path.join(__dirname,'../../config/constants.json'))
 const ERR_CODE_UNAVAILABLE = 14
 const ERR_CODE_STREAM_REMOVED = 2
 
-function subscribeInvoices(parseKeysendInvoice) {	
+export function subscribeInvoices(parseKeysendInvoice) {	
 	return new Promise(async(resolve,reject)=>{
 		const lightning = await loadLightning()
 
@@ -134,6 +134,3 @@ async function reconnectToLND(innerCtx:number){
 	}
 }
 
-export {
-	subscribeInvoices,
-}

api/helpers.ts

@@ -4,7 +4,7 @@ import * as network from './network'
 
 const constants = require('../config/constants.json');
 
-const findOrCreateChat = async (params) => {
+export const findOrCreateChat = async (params) => {
 	const { chat_id, owner_id, recipient_id } = params
 	let chat
 	let date = new Date();
@@ -35,7 +35,7 @@ const findOrCreateChat = async (params) => {
 	return chat
 }
 
-const sendContactKeys = async (args) => {
+export const sendContactKeys = async (args) => {
 	const { type, contactIds, contactPubKey, sender, success, failure } = args
 	const msg = newkeyexchangemsg(type, sender)
 
@@ -76,7 +76,7 @@ const sendContactKeys = async (args) => {
 	}
 }
 
-const performKeysendMessage = async ({ destination_key, amount, msg, success, failure, sender }) => {
+export const performKeysendMessage = async ({ destination_key, amount, msg, success, failure, sender }) => {
 	const opts = {
 		dest: destination_key,
 		data: msg || {},
@@ -92,7 +92,7 @@ const performKeysendMessage = async ({ destination_key, amount, msg, success, fa
 	}
 }
 
-async function findOrCreateContactByPubkey(senderPubKey) {
+export async function findOrCreateContactByPubkey(senderPubKey) {
 	let sender = await models.Contact.findOne({ where: { publicKey: senderPubKey } })
 	if (!sender) {
 		sender = await models.Contact.create({
@@ -111,7 +111,7 @@ async function findOrCreateContactByPubkey(senderPubKey) {
 	return sender
 }
 
-async function findOrCreateChatByUUID(chat_uuid, contactIds) {
+export async function findOrCreateChatByUUID(chat_uuid, contactIds) {
 	let chat = await models.Chat.findOne({ where: { uuid: chat_uuid } })
 	if (!chat) {
 		var date = new Date();
@@ -127,11 +127,11 @@ async function findOrCreateChatByUUID(chat_uuid, contactIds) {
 	return chat
 }
 
-async function sleep(ms) {
+export async function sleep(ms) {
 	return new Promise(resolve => setTimeout(resolve, ms))
 }
 
-async function parseReceiveParams(payload) {
+export async function parseReceiveParams(payload) {
 	const dat = payload.content || payload
 	const sender_pub_key = dat.sender.pub_key
 	const sender_alias = dat.sender.alias
@@ -180,16 +180,6 @@ async function parseReceiveParams(payload) {
 	return { owner, sender, chat, sender_pub_key, sender_alias, isTribeOwner, chat_uuid, amount, content, mediaToken, mediaKey, mediaType, originalMuid, chat_type, msg_id, chat_members, chat_name, chat_host, chat_key, remote_content, msg_uuid, date_string, reply_uuid, skip_payment_processing, purchaser_id, sender_photo_url }
 }
 
-export {
-	findOrCreateChat,
-	sendContactKeys,
-	findOrCreateContactByPubkey,
-	findOrCreateChatByUUID,
-	sleep,
-	parseReceiveParams,
-	performKeysendMessage
-}
-
 async function asyncForEach(array, callback) {
 	for (let index = 0; index < array.length; index++) {
 	  	await callback(array[index], index, array);

dist/api/controllers/chats.js

@@ -194,7 +194,7 @@ function addGroupMembers(req, res) {
     });
 }
 exports.addGroupMembers = addGroupMembers;
-const deleteChat = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
+exports.deleteChat = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     const { id } = req.params;
     const owner = yield models_1.models.Contact.findOne({ where: { isOwner: true } });
     const chat = yield models_1.models.Chat.findOne({ where: { id } });
@@ -223,7 +223,6 @@ const deleteChat = (req, res) => __awaiter(void 0, void 0, void 0, function* ()
     yield models_1.models.Message.destroy({ where: { chatId: id } });
     res_1.success(res, { chat_id: id });
 });
-exports.deleteChat = deleteChat;
 function receiveGroupJoin(payload) {
     return __awaiter(this, void 0, void 0, function* () {
         console.log('=> receiveGroupJoin');
@@ -314,12 +313,13 @@ exports.receiveGroupJoin = receiveGroupJoin;
 function receiveGroupLeave(payload) {
     return __awaiter(this, void 0, void 0, function* () {
         console.log('=> receiveGroupLeave');
-        const { sender_pub_key, chat_uuid, chat_type, sender_alias, isTribeOwner, date_string } = yield helpers.parseReceiveParams(payload);
+        const { sender_pub_key, chat_uuid, chat_type, sender_alias, isTribeOwner, date_string, chat_members } = yield helpers.parseReceiveParams(payload);
         const chat = yield models_1.models.Chat.findOne({ where: { uuid: chat_uuid } });
         if (!chat)
             return;
         const isTribe = chat_type === constants.chat_types.tribe;
         let sender;
+        // EITHER private chat OR tribeOwner
         if (!isTribe || isTribeOwner) {
             sender = yield models_1.models.Contact.findOne({ where: { publicKey: sender_pub_key } });
             if (!sender)
@@ -342,8 +342,39 @@ function receiveGroupLeave(payload) {
             }
         }
         else {
+            console.log('==> received leave as subsribers');
             // check if im the only one in "members"
-            // and delete chat??
+            // if im the one in members
+            // i've been kicked out!
+            const owner = yield models_1.models.Contact.findOne({ where: { isOwner: true } });
+            let imKickedOut = false;
+            for (let [pubkey, _] of Object.entries(chat_members)) {
+                console.log('==> member pubkey', pubkey, owner.publicKey);
+                if (pubkey === owner.publicKey) {
+                    imKickedOut = true;
+                }
+            }
+            if (imKickedOut) {
+                console.log('==> IM kicked out!');
+                yield chat.update({
+                    deleted: true,
+                    uuid: '',
+                    groupKey: '',
+                    host: '',
+                    photoUrl: '',
+                    contactIds: '[]',
+                    name: ''
+                });
+                yield models_1.models.Message.destroy({ where: { chatId: chat.id } });
+                socket.sendJson({
+                    type: 'group_leave',
+                    response: {
+                        contact: jsonUtils.contactToJson(owner),
+                        chat: jsonUtils.chatToJson(chat),
+                    }
+                });
+                return; // done - I've been kicked out
+            }
         }
         var date = new Date();
         date.setMilliseconds(0);

dist/api/controllers/contacts.js

@@ -19,7 +19,7 @@ const password_1 = require("../utils/password");
 const path = require("path");
 const sequelize_1 = require("sequelize");
 const constants = require(path.join(__dirname, '../../config/constants.json'));
-const getContacts = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
+exports.getContacts = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     const contacts = yield models_1.models.Contact.findAll({ where: { deleted: false }, raw: true });
     const invites = yield models_1.models.Invite.findAll({ raw: true });
     const chats = yield models_1.models.Chat.findAll({ where: { deleted: false }, raw: true });
@@ -40,8 +40,7 @@ const getContacts = (req, res) => __awaiter(void 0, void 0, void 0, function* ()
         subscriptions: subsResponse
     });
 });
-exports.getContacts = getContacts;
+exports.generateToken = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
-const generateToken = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     console.log('=> generateToken called', { body: req.body, params: req.params, query: req.query });
     const owner = yield models_1.models.Contact.findOne({ where: { isOwner: true, authToken: null } });
     const pwd = password_1.default;
@@ -65,8 +64,7 @@ const generateToken = (req, res) => __awaiter(void 0, void 0, void 0, function*
         res_1.failure(res, {});
     }
 });
-exports.generateToken = generateToken;
+exports.updateContact = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
-const updateContact = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     console.log('=> updateContact called', { body: req.body, params: req.params, query: req.query });
     let attrs = extractAttrs(req.body);
     const contact = yield models_1.models.Contact.findOne({ where: { id: req.params.id } });
@@ -89,8 +87,7 @@ const updateContact = (req, res) => __awaiter(void 0, void 0, void 0, function*
         type: constants.message_types.contact_key,
     });
 });
-exports.updateContact = updateContact;
+exports.exchangeKeys = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
-const exchangeKeys = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     console.log('=> exchangeKeys called', { body: req.body, params: req.params, query: req.query });
     const contact = yield models_1.models.Contact.findOne({ where: { id: req.params.id } });
     const owner = yield models_1.models.Contact.findOne({ where: { isOwner: true } });
@@ -101,8 +98,7 @@ const exchangeKeys = (req, res) => __awaiter(void 0, void 0, void 0, function* (
         type: constants.message_types.contact_key,
     });
 });
-exports.exchangeKeys = exchangeKeys;
+exports.createContact = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
-const createContact = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     console.log('=> createContact called', { body: req.body, params: req.params, query: req.query });
     let attrs = extractAttrs(req.body);
     const owner = yield models_1.models.Contact.findOne({ where: { isOwner: true } });
@@ -125,8 +121,7 @@ const createContact = (req, res) => __awaiter(void 0, void 0, void 0, function*
         type: constants.message_types.contact_key,
     });
 });
-exports.createContact = createContact;
+exports.deleteContact = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
-const deleteContact = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     const id = parseInt(req.params.id || '0');
     if (!id || id === 1) {
         res_1.failure(res, 'Cannot delete self');
@@ -176,8 +171,7 @@ const deleteContact = (req, res) => __awaiter(void 0, void 0, void 0, function*
     yield models_1.models.Subscription.destroy({ where: { contactId: id } });
     res_1.success(res, {});
 });
-exports.deleteContact = deleteContact;
+exports.receiveContactKey = (payload) => __awaiter(void 0, void 0, void 0, function* () {
-const receiveContactKey = (payload) => __awaiter(void 0, void 0, void 0, function* () {
     console.log('=> received contact key', JSON.stringify(payload));
     const dat = payload.content || payload;
     const sender_pub_key = dat.sender.pub_key;
@@ -207,8 +201,7 @@ const receiveContactKey = (payload) => __awaiter(void 0, void 0, void 0, functio
         type: constants.message_types.contact_key_confirmation,
     });
 });
-exports.receiveContactKey = receiveContactKey;
+exports.receiveConfirmContactKey = (payload) => __awaiter(void 0, void 0, void 0, function* () {
-const receiveConfirmContactKey = (payload) => __awaiter(void 0, void 0, void 0, function* () {
     console.log(`=> confirm contact key for ${payload.sender && payload.sender.pub_key}`, JSON.stringify(payload));
     const dat = payload.content || payload;
     const sender_pub_key = dat.sender.pub_key;
@@ -232,7 +225,6 @@ const receiveConfirmContactKey = (payload) => __awaiter(void 0, void 0, void 0,
         });
     }
 });
-exports.receiveConfirmContactKey = receiveConfirmContactKey;
 const extractAttrs = body => {
     let fields_to_update = ["public_key", "node_alias", "alias", "photo_url", "device_id", "status", "contact_key", "from_group", "private_photo"];
     let attrs = {};

dist/api/controllers/details.js

@@ -48,7 +48,7 @@ function getLogsSince(req, res) {
     });
 }
 exports.getLogsSince = getLogsSince;
-const getInfo = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
+exports.getInfo = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     const lightning = lightning_1.loadLightning();
     var request = {};
     lightning.getInfo(request, function (err, response) {
@@ -62,8 +62,7 @@ const getInfo = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
         res.end();
     });
 });
-exports.getInfo = getInfo;
+exports.getChannels = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
-const getChannels = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     const lightning = lightning_1.loadLightning();
     var request = {};
     lightning.listChannels(request, function (err, response) {
@@ -77,8 +76,7 @@ const getChannels = (req, res) => __awaiter(void 0, void 0, void 0, function* ()
         res.end();
     });
 });
-exports.getChannels = getChannels;
+exports.getBalance = (req, res) => {
-const getBalance = (req, res) => {
     const lightning = lightning_1.loadLightning();
     var request = {};
     lightning.channelBalance(request, function (err, response) {
@@ -92,8 +90,7 @@ const getBalance = (req, res) => {
         res.end();
     });
 };
-exports.getBalance = getBalance;
+exports.getLocalRemoteBalance = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
-const getLocalRemoteBalance = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     const lightning = lightning_1.loadLightning();
     lightning.listChannels({}, (err, channelList) => {
         const { channels } = channelList;
@@ -111,8 +108,7 @@ const getLocalRemoteBalance = (req, res) => __awaiter(void 0, void 0, void 0, fu
         res.end();
     });
 });
-exports.getLocalRemoteBalance = getLocalRemoteBalance;
+exports.getNodeInfo = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
-const getNodeInfo = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     var ipOfSource = req.connection.remoteAddress;
     if (!(ipOfSource.includes('127.0.0.1') || ipOfSource.includes('localhost'))) {
         res.status(401);
@@ -124,7 +120,6 @@ const getNodeInfo = (req, res) => __awaiter(void 0, void 0, void 0, function* ()
     res.json(node);
     res.end();
 });
-exports.getNodeInfo = getNodeInfo;
 function asyncForEach(array, callback) {
     return __awaiter(this, void 0, void 0, function* () {
         for (let index = 0; index < array.length; index++) {

dist/api/controllers/details.js.map

@@ -1 +1 @@
-{"version":3,"file":"details.js","sourceRoot":"","sources":["../../../api/controllers/details.ts"],"names":[],"mappings":";;;;;;;;;;;AAAA,kDAAgD;AAChD,sCAA+C;AAC/C,iDAAgD;AAChD,gDAA6C;AAC7C,6BAA4B;AAE5B,MAAM,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC,QAAQ,IAAI,aAAa,CAAC;AAClD,MAAM,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,EAAC,uBAAuB,CAAC,CAAC,CAAC,GAAG,CAAC,CAAA;AAEzE,MAAM,eAAe,GAAG;IACvB,+BAA+B;IAC/B,mCAAmC;IACnC,iBAAiB;CACjB,CAAA;AACD,SAAe,YAAY,CAAC,GAAG,EAAE,GAAG;;QACnC,MAAM,QAAQ,GAAG,MAAM,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,eAAe,CAAA;QACtE,IAAI,GAAG,CAAA;QACP,IAAI,GAAG,CAAA;QACP,MAAM,YAAY,CAAC,QAAQ,EAAE,CAAM,QAAQ,EAAA,EAAE;YAC5C,IAAG,CAAC,GAAG,EAAC;gBACP,IAAI;oBACH,MAAM,KAAK,GAAG,MAAM,aAAa,CAAC,IAAI,CAAC,QAAQ,EAAE,GAAG,CAAC,CAAA;oBACrD,IAAG,KAAK,EAAE;wBACT,IAAI,UAAU,GAAG,KAAK,CAAC,KAAK,CAAC,IAAI,CAAC,CAAA;wBAClC,UAAU,CAAC,OAAO,EAAE,CAAA;wBACpB,GAAG,GAAG,UAAU,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;qBAC3B;iBACD;gBAAC,OAAM,CAAC,EAAE;oBACV,GAAG,GAAG,CAAC,CAAA;iBACP;aACD;QACF,CAAC,CAAA,CAAC,CAAA;QACF,IAAG,GAAG;YAAE,aAAO,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;;YACpB,aAAO,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;IACvB,CAAC;CAAA;AAkFA,oCAAY;AAhFb,MAAM,OAAO,GAAG,CAAO,GAAG,EAAE,GAAG,EAAE,EAAE;IAClC,MAAM,SAAS,GAAG,yBAAa,EAAE,CAAA;IACjC,IAAI,OAAO,GAAG,EAAE,CAAA;IAChB,SAAS,CAAC,OAAO,CAAC,OAAO,EAAE,UAAS,GAAG,EAAE,QAAQ;QAChD,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;QAChB,IAAI,GAAG,IAAI,IAAI,EAAE;YAChB,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,IAAI,EAAE,QAAQ,EAAE,CAAC,CAAC;SACtC;aAAM;YACN,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC,CAAC;SAC7B;QACD,GAAG,CAAC,GAAG,EAAE,CAAC;IACX,CAAC,CAAC,CAAC;AACJ,CAAC,CAAA,CAAC;AAgED,0BAAO;AA9DR,MAAM,WAAW,GAAG,CAAO,GAAG,EAAE,GAAG,EAAE,EAAE;IACrC,MAAM,SAAS,GAAG,yBAAa,EAAE,CAAA;IAClC,IAAI,OAAO,GAAG,EAAE,CAAA;IAChB,SAAS,CAAC,YAAY,CAAC,OAAO,EAAE,UAAS,GAAG,EAAE,QAAQ;QACrD,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;QAChB,IAAI,GAAG,IAAI,IAAI,EAAE;YAChB,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,IAAI,EAAE,QAAQ,EAAE,CAAC,CAAC;SACtC;aAAM;YACN,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC,CAAC;SAC7B;QACD,GAAG,CAAC,GAAG,EAAE,CAAC;IACX,CAAC,CAAC,CAAC;AACJ,CAAC,CAAA,CAAC;AAoDD,kCAAW;AAlDZ,MAAM,UAAU,GAAG,CAAC,GAAG,EAAE,GAAG,EAAE,EAAE;IAC9B,MAAM,SAAS,GAAG,yBAAa,EAAE,CAAA;IAClC,IAAI,OAAO,GAAG,EAAE,CAAA;IAChB,SAAS,CAAC,cAAc,CAAC,OAAO,EAAE,UAAS,GAAG,EAAE,QAAQ;QACvD,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;QAChB,IAAI,GAAG,IAAI,IAAI,EAAE;YAChB,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,IAAI,EAAE,QAAQ,EAAE,CAAC,CAAC;SACtC;aAAM;YACN,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC,CAAC;SAC7B;QACD,GAAG,CAAC,GAAG,EAAE,CAAC;IACX,CAAC,CAAC,CAAC;AACJ,CAAC,CAAC;AAqCD,gCAAU;AAnCX,MAAM,qBAAqB,GAAG,CAAO,GAAG,EAAE,GAAG,EAAE,EAAE;IAChD,MAAM,SAAS,GAAG,yBAAa,EAAE,CAAA;IACjC,SAAS,CAAC,YAAY,CAAC,EAAE,EAAE,CAAC,GAAG,EAAE,WAAW,EAAE,EAAE;QAC/C,MAAM,EAAE,QAAQ,EAAE,GAAG,WAAW,CAAA;QAEhC,MAAM,aAAa,GAAG,QAAQ,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,aAAa,CAAC,CAAA;QACxD,MAAM,cAAc,GAAG,QAAQ,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,cAAc,CAAC,CAAA;QAC1D,MAAM,iBAAiB,GAAG,aAAa,CAAC,MAAM,CAAC,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,CAAC,QAAQ,CAAC,CAAC,CAAC,GAAG,QAAQ,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAA;QACtF,MAAM,kBAAkB,GAAG,cAAc,CAAC,MAAM,CAAC,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,CAAC,QAAQ,CAAC,CAAC,CAAC,GAAG,QAAQ,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAA;QAExF,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;QAChB,IAAI,GAAG,IAAI,IAAI,EAAE;YAChB,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,IAAI,EAAE,QAAQ,EAAE,EAAE,aAAa,EAAE,iBAAiB,EAAE,cAAc,EAAE,kBAAkB,EAAE,EAAE,CAAC,CAAC;SAChH;aAAM;YACN,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC,CAAC;SAC7B;QACD,GAAG,CAAC,GAAG,EAAE,CAAC;IACT,CAAC,CAAC,CAAA;AACL,CAAC,CAAA,CAAC;AAmBD,sDAAqB;AAjBtB,MAAM,WAAW,GAAG,CAAO,GAAG,EAAE,GAAG,EAAE,EAAE;IACtC,IAAI,UAAU,GAAG,GAAG,CAAC,UAAU,CAAC,aAAa,CAAC;IAC9C,IAAG,CAAC,CAAC,UAAU,CAAC,QAAQ,CAAC,WAAW,CAAC,IAAI,UAAU,CAAC,QAAQ,CAAC,WAAW,CAAC,CAAC,EAAC;QAC1E,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;QACf,GAAG,CAAC,GAAG,EAAE,CAAA;QACT,OAAM;KACN;IACD,MAAM,IAAI,GAAG,MAAM,mBAAQ,EAAE,CAAA;IAC7B,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;IACf,GAAG,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;IACd,GAAG,CAAC,GAAG,EAAE,CAAA;AACV,CAAC,CAAA,CAAA;AAQA,kCAAW;AAGZ,SAAe,YAAY,CAAC,KAAK,EAAE,QAAQ;;QAC1C,KAAK,IAAI,KAAK,GAAG,CAAC,EAAE,KAAK,GAAG,KAAK,CAAC,MAAM,EAAE,KAAK,EAAE,EAAE;YAChD,MAAM,QAAQ,CAAC,KAAK,CAAC,KAAK,CAAC,EAAE,KAAK,EAAE,KAAK,CAAC,CAAC;SAC7C;IACF,CAAC;CAAA"}
+{"version":3,"file":"details.js","sourceRoot":"","sources":["../../../api/controllers/details.ts"],"names":[],"mappings":";;;;;;;;;;;AAAA,kDAAgD;AAChD,sCAA+C;AAC/C,iDAAgD;AAChD,gDAA6C;AAC7C,6BAA4B;AAE5B,MAAM,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC,QAAQ,IAAI,aAAa,CAAC;AAClD,MAAM,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,EAAC,uBAAuB,CAAC,CAAC,CAAC,GAAG,CAAC,CAAA;AAEzE,MAAM,eAAe,GAAG;IACvB,+BAA+B;IAC/B,mCAAmC;IACnC,iBAAiB;CACjB,CAAA;AACD,SAAsB,YAAY,CAAC,GAAG,EAAE,GAAG;;QAC1C,MAAM,QAAQ,GAAG,MAAM,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,eAAe,CAAA;QACtE,IAAI,GAAG,CAAA;QACP,IAAI,GAAG,CAAA;QACP,MAAM,YAAY,CAAC,QAAQ,EAAE,CAAM,QAAQ,EAAA,EAAE;YAC5C,IAAG,CAAC,GAAG,EAAC;gBACP,IAAI;oBACH,MAAM,KAAK,GAAG,MAAM,aAAa,CAAC,IAAI,CAAC,QAAQ,EAAE,GAAG,CAAC,CAAA;oBACrD,IAAG,KAAK,EAAE;wBACT,IAAI,UAAU,GAAG,KAAK,CAAC,KAAK,CAAC,IAAI,CAAC,CAAA;wBAClC,UAAU,CAAC,OAAO,EAAE,CAAA;wBACpB,GAAG,GAAG,UAAU,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;qBAC3B;iBACD;gBAAC,OAAM,CAAC,EAAE;oBACV,GAAG,GAAG,CAAC,CAAA;iBACP;aACD;QACF,CAAC,CAAA,CAAC,CAAA;QACF,IAAG,GAAG;YAAE,aAAO,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;;YACpB,aAAO,CAAC,GAAG,EAAE,GAAG,CAAC,CAAA;IACvB,CAAC;CAAA;AApBD,oCAoBC;AAEY,QAAA,OAAO,GAAG,CAAO,GAAG,EAAE,GAAG,EAAE,EAAE;IACzC,MAAM,SAAS,GAAG,yBAAa,EAAE,CAAA;IACjC,IAAI,OAAO,GAAG,EAAE,CAAA;IAChB,SAAS,CAAC,OAAO,CAAC,OAAO,EAAE,UAAS,GAAG,EAAE,QAAQ;QAChD,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;QAChB,IAAI,GAAG,IAAI,IAAI,EAAE;YAChB,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,IAAI,EAAE,QAAQ,EAAE,CAAC,CAAC;SACtC;aAAM;YACN,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC,CAAC;SAC7B;QACD,GAAG,CAAC,GAAG,EAAE,CAAC;IACX,CAAC,CAAC,CAAC;AACJ,CAAC,CAAA,CAAC;AAEW,QAAA,WAAW,GAAG,CAAO,GAAG,EAAE,GAAG,EAAE,EAAE;IAC5C,MAAM,SAAS,GAAG,yBAAa,EAAE,CAAA;IAClC,IAAI,OAAO,GAAG,EAAE,CAAA;IAChB,SAAS,CAAC,YAAY,CAAC,OAAO,EAAE,UAAS,GAAG,EAAE,QAAQ;QACrD,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;QAChB,IAAI,GAAG,IAAI,IAAI,EAAE;YAChB,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,IAAI,EAAE,QAAQ,EAAE,CAAC,CAAC;SACtC;aAAM;YACN,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC,CAAC;SAC7B;QACD,GAAG,CAAC,GAAG,EAAE,CAAC;IACX,CAAC,CAAC,CAAC;AACJ,CAAC,CAAA,CAAC;AAEW,QAAA,UAAU,GAAG,CAAC,GAAG,EAAE,GAAG,EAAE,EAAE;IACrC,MAAM,SAAS,GAAG,yBAAa,EAAE,CAAA;IAClC,IAAI,OAAO,GAAG,EAAE,CAAA;IAChB,SAAS,CAAC,cAAc,CAAC,OAAO,EAAE,UAAS,GAAG,EAAE,QAAQ;QACvD,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;QAChB,IAAI,GAAG,IAAI,IAAI,EAAE;YAChB,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,IAAI,EAAE,QAAQ,EAAE,CAAC,CAAC;SACtC;aAAM;YACN,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC,CAAC;SAC7B;QACD,GAAG,CAAC,GAAG,EAAE,CAAC;IACX,CAAC,CAAC,CAAC;AACJ,CAAC,CAAC;AAEW,QAAA,qBAAqB,GAAG,CAAO,GAAG,EAAE,GAAG,EAAE,EAAE;IACvD,MAAM,SAAS,GAAG,yBAAa,EAAE,CAAA;IACjC,SAAS,CAAC,YAAY,CAAC,EAAE,EAAE,CAAC,GAAG,EAAE,WAAW,EAAE,EAAE;QAC/C,MAAM,EAAE,QAAQ,EAAE,GAAG,WAAW,CAAA;QAEhC,MAAM,aAAa,GAAG,QAAQ,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,aAAa,CAAC,CAAA;QACxD,MAAM,cAAc,GAAG,QAAQ,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,cAAc,CAAC,CAAA;QAC1D,MAAM,iBAAiB,GAAG,aAAa,CAAC,MAAM,CAAC,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,CAAC,QAAQ,CAAC,CAAC,CAAC,GAAG,QAAQ,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAA;QACtF,MAAM,kBAAkB,GAAG,cAAc,CAAC,MAAM,CAAC,CAAC,CAAC,EAAE,CAAC,EAAE,EAAE,CAAC,QAAQ,CAAC,CAAC,CAAC,GAAG,QAAQ,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAA;QAExF,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC;QAChB,IAAI,GAAG,IAAI,IAAI,EAAE;YAChB,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,IAAI,EAAE,QAAQ,EAAE,EAAE,aAAa,EAAE,iBAAiB,EAAE,cAAc,EAAE,kBAAkB,EAAE,EAAE,CAAC,CAAC;SAChH;aAAM;YACN,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC,CAAC;SAC7B;QACD,GAAG,CAAC,GAAG,EAAE,CAAC;IACT,CAAC,CAAC,CAAA;AACL,CAAC,CAAA,CAAC;AAEW,QAAA,WAAW,GAAG,CAAO,GAAG,EAAE,GAAG,EAAE,EAAE;IAC7C,IAAI,UAAU,GAAG,GAAG,CAAC,UAAU,CAAC,aAAa,CAAC;IAC9C,IAAG,CAAC,CAAC,UAAU,CAAC,QAAQ,CAAC,WAAW,CAAC,IAAI,UAAU,CAAC,QAAQ,CAAC,WAAW,CAAC,CAAC,EAAC;QAC1E,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;QACf,GAAG,CAAC,GAAG,EAAE,CAAA;QACT,OAAM;KACN;IACD,MAAM,IAAI,GAAG,MAAM,mBAAQ,EAAE,CAAA;IAC7B,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;IACf,GAAG,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;IACd,GAAG,CAAC,GAAG,EAAE,CAAA;AACV,CAAC,CAAA,CAAA;AAED,SAAe,YAAY,CAAC,KAAK,EAAE,QAAQ;;QAC1C,KAAK,IAAI,KAAK,GAAG,CAAC,EAAE,KAAK,GAAG,KAAK,CAAC,MAAM,EAAE,KAAK,EAAE,EAAE;YAChD,MAAM,QAAQ,CAAC,KAAK,CAAC,KAAK,CAAC,EAAE,KAAK,EAAE,KAAK,CAAC,CAAC;SAC7C;IACF,CAAC;CAAA"}

dist/api/controllers/index.js

@@ -115,7 +115,7 @@ const login = (req, res) => {
     }
 };
 const msgtypes = constants.message_types;
-const ACTIONS = {
+exports.ACTIONS = {
     [msgtypes.contact_key]: contacts.receiveContactKey,
     [msgtypes.contact_key_confirmation]: contacts.receiveConfirmContactKey,
     [msgtypes.message]: messages.receiveMessage,
@@ -133,5 +133,4 @@ const ACTIONS = {
     [msgtypes.delete]: messages.receiveDeleteMessage,
     [msgtypes.repayment]: () => { },
 };
-exports.ACTIONS = ACTIONS;
 //# sourceMappingURL=index.js.map

dist/api/controllers/invites.js

@@ -13,7 +13,7 @@ const models_1 = require("../models");
 const crypto = require("crypto");
 const jsonUtils = require("../utils/json");
 const hub_1 = require("../hub");
-const finishInvite = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
+exports.finishInvite = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     const { invite_string } = req.body;
     const params = {
         invite: {
@@ -32,8 +32,7 @@ const finishInvite = (req, res) => __awaiter(void 0, void 0, void 0, function* (
     }
     hub_1.finishInviteInHub(params, onSuccess, onFailure);
 });
-exports.finishInvite = finishInvite;
+exports.payInvite = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
-const payInvite = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     // const params = {
     // 	node_ip: process.env.NODE_IP
     // }
@@ -64,8 +63,7 @@ const payInvite = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     // payInviteInHub(invite_string, params, onSuccess, onFailure)
     hub_1.payInviteInvoice(dbInvite.invoice, onSuccess, onFailure);
 });
-exports.payInvite = payInvite;
+exports.createInvite = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
-const createInvite = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     const { nickname, welcome_message } = req.body;
     const owner = yield models_1.models.Contact.findOne({ where: { isOwner: true } });
     const params = {
@@ -105,5 +103,4 @@ const createInvite = (req, res) => __awaiter(void 0, void 0, void 0, function* (
     };
     hub_1.createInviteInHub(params, onSuccess, onFailure);
 });
-exports.createInvite = createInvite;
 //# sourceMappingURL=invites.js.map

dist/api/controllers/invites.js.map

@@ -1 +1 @@
-{"version":3,"file":"invites.js","sourceRoot":"","sources":["../../../api/controllers/invites.ts"],"names":[],"mappings":";;;;;;;;;;;AAAA,sCAAgC;AAChC,iCAAgC;AAChC,2CAA0C;AAC1C,gCAA6E;AAE7E,MAAM,YAAY,GAAG,CAAO,GAAG,EAAE,GAAG,EAAE,EAAE;IACvC,MAAM,EACL,aAAa,EACX,GAAG,GAAG,CAAC,IAAI,CAAA;IACd,MAAM,MAAM,GAAG;QACd,MAAM,EAAE;YACP,GAAG,EAAE,aAAa;SAClB;KACD,CAAA;IAED,SAAS,SAAS;QACjB,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;QACf,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,IAAI,EAAE,CAAC,CAAA;QAC3B,GAAG,CAAC,GAAG,EAAE,CAAA;IACV,CAAC;IACD,SAAS,SAAS;QACjB,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;QACf,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC,CAAA;QAC5B,GAAG,CAAC,GAAG,EAAE,CAAA;IACV,CAAC;IAEE,uBAAiB,CAAC,MAAM,EAAE,SAAS,EAAE,SAAS,CAAC,CAAA;AACnD,CAAC,CAAA,CAAA;AA4FA,oCAAY;AA1Fb,MAAM,SAAS,GAAG,CAAO,GAAG,EAAE,GAAG,EAAE,EAAE;IACpC,mBAAmB;IACnB,gCAAgC;IAChC,IAAI;IAEJ,MAAM,aAAa,GAAG,GAAG,CAAC,MAAM,CAAC,eAAe,CAAC,CAAA;IACjD,MAAM,QAAQ,GAAG,MAAM,eAAM,CAAC,MAAM,CAAC,OAAO,CAAC,EAAE,KAAK,EAAE,EAAE,YAAY,EAAE,aAAa,EAAE,EAAC,CAAC,CAAA;IAEvF,MAAM,SAAS,GAAG,CAAO,QAAQ,EAAE,EAAE;QACpC,iCAAiC;QACjC,kCAAkC;QAClC,iDAAiD;QACjD,qDAAqD;QACrD,IAAI;QACJ,IAAG,QAAQ,CAAC,aAAa,EAAE;YAC1B,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;YACf,GAAG,CAAC,IAAI,CAAC,EAAC,OAAO,EAAC,KAAK,EAAE,KAAK,EAAC,QAAQ,CAAC,aAAa,EAAC,CAAC,CAAA;YACvD,GAAG,CAAC,GAAG,EAAE,CAAA;SACT;aAAM;YACN,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;YACf,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,IAAI,EAAE,QAAQ,EAAE,EAAE,MAAM,EAAE,SAAS,CAAC,YAAY,CAAC,QAAQ,CAAC,EAAE,EAAE,CAAC,CAAA;YACnF,GAAG,CAAC,GAAG,EAAE,CAAA;SACT;IACF,CAAC,CAAA,CAAA;IAED,MAAM,SAAS,GAAG,CAAC,QAAQ,EAAE,EAAE;QAC9B,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;QACf,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC,CAAA;QAC5B,GAAG,CAAC,GAAG,EAAE,CAAA;IACV,CAAC,CAAA;IAED,8DAA8D;IAC9D,sBAAgB,CAAC,QAAQ,CAAC,OAAO,EAAE,SAAS,EAAE,SAAS,CAAC,CAAA;AACzD,CAAC,CAAA,CAAA;AA0DA,8BAAS;AAxDV,MAAM,YAAY,GAAG,CAAO,GAAG,EAAE,GAAG,EAAE,EAAE;IACvC,MAAM,EACL,QAAQ,EACR,eAAe,EACb,GAAG,GAAG,CAAC,IAAI,CAAA;IAEb,MAAM,KAAK,GAAG,MAAM,eAAM,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE,KAAK,EAAE,EAAE,OAAO,EAAE,IAAI,EAAE,EAAC,CAAC,CAAA;IAExE,MAAM,MAAM,GAAG;QACd,MAAM,EAAE;YACP,QAAQ,EAAE,KAAK,CAAC,KAAK;YACrB,MAAM,EAAE,KAAK,CAAC,SAAS;YACvB,gBAAgB,EAAE,QAAQ;YAC1B,OAAO,EAAE,eAAe;YACxB,GAAG,EAAE,MAAM,CAAC,WAAW,CAAC,EAAE,CAAC,CAAC,QAAQ,CAAC,KAAK,CAAC;SAC3C;KACD,CAAA;IAED,MAAM,SAAS,GAAG,CAAO,QAAQ,EAAE,EAAE;QACpC,OAAO,CAAC,GAAG,CAAC,UAAU,EAAE,QAAQ,CAAC,CAAA;QAEjC,MAAM,aAAa,GAAG,QAAQ,CAAC,MAAM,CAAA;QAErC,MAAM,OAAO,GAAG,MAAM,eAAM,CAAC,OAAO,CAAC,MAAM,CAAC;YAC3C,KAAK,EAAE,QAAQ;YACf,MAAM,EAAE,CAAC;SACT,CAAC,CAAA;QACF,MAAM,MAAM,GAAG,MAAM,eAAM,CAAC,MAAM,CAAC,MAAM,CAAC;YACzC,cAAc,EAAE,aAAa,CAAC,OAAO;YACrC,SAAS,EAAE,OAAO,CAAC,EAAE;YACrB,MAAM,EAAE,aAAa,CAAC,aAAa;YACnC,YAAY,EAAE,aAAa,CAAC,GAAG;SAE/B,CAAC,CAAA;QACF,IAAI,WAAW,GAAG,SAAS,CAAC,aAAa,CAAC,OAAO,CAAC,CAAA;QAClD,IAAI,MAAM,EAAE;YACX,WAAW,CAAC,MAAM,GAAG,SAAS,CAAC,YAAY,CAAC,MAAM,CAAC,CAAA;SACnD;QAED,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;QACf,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,IAAI,EAAE,OAAO,EAAE,WAAW,EAAE,CAAC,CAAA;QACjD,GAAG,CAAC,GAAG,EAAE,CAAA;IACV,CAAC,CAAA,CAAA;IAED,MAAM,SAAS,GAAG,CAAC,QAAQ,EAAE,EAAE;QAC9B,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;QACf,GAAG,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAA;QAClB,GAAG,CAAC,GAAG,EAAE,CAAA;IACV,CAAC,CAAA;IAEE,uBAAiB,CAAC,MAAM,EAAE,SAAS,EAAE,SAAS,CAAC,CAAA;AACnD,CAAC,CAAA,CAAA;AAGA,oCAAY"}
+{"version":3,"file":"invites.js","sourceRoot":"","sources":["../../../api/controllers/invites.ts"],"names":[],"mappings":";;;;;;;;;;;AAAA,sCAAgC;AAChC,iCAAgC;AAChC,2CAA0C;AAC1C,gCAA6E;AAEhE,QAAA,YAAY,GAAG,CAAO,GAAG,EAAE,GAAG,EAAE,EAAE;IAC9C,MAAM,EACL,aAAa,EACX,GAAG,GAAG,CAAC,IAAI,CAAA;IACd,MAAM,MAAM,GAAG;QACd,MAAM,EAAE;YACP,GAAG,EAAE,aAAa;SAClB;KACD,CAAA;IAED,SAAS,SAAS;QACjB,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;QACf,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,IAAI,EAAE,CAAC,CAAA;QAC3B,GAAG,CAAC,GAAG,EAAE,CAAA;IACV,CAAC;IACD,SAAS,SAAS;QACjB,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;QACf,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC,CAAA;QAC5B,GAAG,CAAC,GAAG,EAAE,CAAA;IACV,CAAC;IAEE,uBAAiB,CAAC,MAAM,EAAE,SAAS,EAAE,SAAS,CAAC,CAAA;AACnD,CAAC,CAAA,CAAA;AAEY,QAAA,SAAS,GAAG,CAAO,GAAG,EAAE,GAAG,EAAE,EAAE;IAC3C,mBAAmB;IACnB,gCAAgC;IAChC,IAAI;IAEJ,MAAM,aAAa,GAAG,GAAG,CAAC,MAAM,CAAC,eAAe,CAAC,CAAA;IACjD,MAAM,QAAQ,GAAG,MAAM,eAAM,CAAC,MAAM,CAAC,OAAO,CAAC,EAAE,KAAK,EAAE,EAAE,YAAY,EAAE,aAAa,EAAE,EAAC,CAAC,CAAA;IAEvF,MAAM,SAAS,GAAG,CAAO,QAAQ,EAAE,EAAE;QACpC,iCAAiC;QACjC,kCAAkC;QAClC,iDAAiD;QACjD,qDAAqD;QACrD,IAAI;QACJ,IAAG,QAAQ,CAAC,aAAa,EAAE;YAC1B,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;YACf,GAAG,CAAC,IAAI,CAAC,EAAC,OAAO,EAAC,KAAK,EAAE,KAAK,EAAC,QAAQ,CAAC,aAAa,EAAC,CAAC,CAAA;YACvD,GAAG,CAAC,GAAG,EAAE,CAAA;SACT;aAAM;YACN,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;YACf,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,IAAI,EAAE,QAAQ,EAAE,EAAE,MAAM,EAAE,SAAS,CAAC,YAAY,CAAC,QAAQ,CAAC,EAAE,EAAE,CAAC,CAAA;YACnF,GAAG,CAAC,GAAG,EAAE,CAAA;SACT;IACF,CAAC,CAAA,CAAA;IAED,MAAM,SAAS,GAAG,CAAC,QAAQ,EAAE,EAAE;QAC9B,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;QACf,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC,CAAA;QAC5B,GAAG,CAAC,GAAG,EAAE,CAAA;IACV,CAAC,CAAA;IAED,8DAA8D;IAC9D,sBAAgB,CAAC,QAAQ,CAAC,OAAO,EAAE,SAAS,EAAE,SAAS,CAAC,CAAA;AACzD,CAAC,CAAA,CAAA;AAEY,QAAA,YAAY,GAAG,CAAO,GAAG,EAAE,GAAG,EAAE,EAAE;IAC9C,MAAM,EACL,QAAQ,EACR,eAAe,EACb,GAAG,GAAG,CAAC,IAAI,CAAA;IAEb,MAAM,KAAK,GAAG,MAAM,eAAM,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE,KAAK,EAAE,EAAE,OAAO,EAAE,IAAI,EAAE,EAAC,CAAC,CAAA;IAExE,MAAM,MAAM,GAAG;QACd,MAAM,EAAE;YACP,QAAQ,EAAE,KAAK,CAAC,KAAK;YACrB,MAAM,EAAE,KAAK,CAAC,SAAS;YACvB,gBAAgB,EAAE,QAAQ;YAC1B,OAAO,EAAE,eAAe;YACxB,GAAG,EAAE,MAAM,CAAC,WAAW,CAAC,EAAE,CAAC,CAAC,QAAQ,CAAC,KAAK,CAAC;SAC3C;KACD,CAAA;IAED,MAAM,SAAS,GAAG,CAAO,QAAQ,EAAE,EAAE;QACpC,OAAO,CAAC,GAAG,CAAC,UAAU,EAAE,QAAQ,CAAC,CAAA;QAEjC,MAAM,aAAa,GAAG,QAAQ,CAAC,MAAM,CAAA;QAErC,MAAM,OAAO,GAAG,MAAM,eAAM,CAAC,OAAO,CAAC,MAAM,CAAC;YAC3C,KAAK,EAAE,QAAQ;YACf,MAAM,EAAE,CAAC;SACT,CAAC,CAAA;QACF,MAAM,MAAM,GAAG,MAAM,eAAM,CAAC,MAAM,CAAC,MAAM,CAAC;YACzC,cAAc,EAAE,aAAa,CAAC,OAAO;YACrC,SAAS,EAAE,OAAO,CAAC,EAAE;YACrB,MAAM,EAAE,aAAa,CAAC,aAAa;YACnC,YAAY,EAAE,aAAa,CAAC,GAAG;SAE/B,CAAC,CAAA;QACF,IAAI,WAAW,GAAG,SAAS,CAAC,aAAa,CAAC,OAAO,CAAC,CAAA;QAClD,IAAI,MAAM,EAAE;YACX,WAAW,CAAC,MAAM,GAAG,SAAS,CAAC,YAAY,CAAC,MAAM,CAAC,CAAA;SACnD;QAED,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;QACf,GAAG,CAAC,IAAI,CAAC,EAAE,OAAO,EAAE,IAAI,EAAE,OAAO,EAAE,WAAW,EAAE,CAAC,CAAA;QACjD,GAAG,CAAC,GAAG,EAAE,CAAA;IACV,CAAC,CAAA,CAAA;IAED,MAAM,SAAS,GAAG,CAAC,QAAQ,EAAE,EAAE;QAC9B,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;QACf,GAAG,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAA;QAClB,GAAG,CAAC,GAAG,EAAE,CAAA;IACV,CAAC,CAAA;IAEE,uBAAiB,CAAC,MAAM,EAAE,SAAS,EAAE,SAAS,CAAC,CAAA;AACnD,CAAC,CAAA,CAAA"}

dist/api/controllers/invoices.js

@@ -27,7 +27,7 @@ function stripLightningPrefix(s) {
         return s.substring(10);
     return s;
 }
-const payInvoice = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
+exports.payInvoice = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     const lightning = yield lightning_1.loadLightning();
     const payment_request = stripLightningPrefix(req.body.payment_request);
     if (!payment_request) {
@@ -74,14 +74,12 @@ const payInvoice = (req, res) => __awaiter(void 0, void 0, void 0, function* ()
     }));
     call.write({ payment_request });
 });
-exports.payInvoice = payInvoice;
+exports.cancelInvoice = (req, res) => {
-const cancelInvoice = (req, res) => {
     res.status(200);
     res.json({ success: false });
     res.end();
 };
-exports.cancelInvoice = cancelInvoice;
+exports.createInvoice = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
-const createInvoice = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     const lightning = yield lightning_1.loadLightning();
     const { amount, memo, remote_memo, chat_id, contact_id, expiry, } = req.body;
     var request = {
@@ -166,8 +164,7 @@ const createInvoice = (req, res) => __awaiter(void 0, void 0, void 0, function*
         });
     }
 });
-exports.createInvoice = createInvoice;
+exports.listInvoices = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
-const listInvoices = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     const lightning = yield lightning_1.loadLightning();
     lightning.listInvoices({}, (err, response) => {
         console.log({ err, response });
@@ -181,8 +178,7 @@ const listInvoices = (req, res) => __awaiter(void 0, void 0, void 0, function* (
         }
     });
 });
-exports.listInvoices = listInvoices;
+exports.receiveInvoice = (payload) => __awaiter(void 0, void 0, void 0, function* () {
-const receiveInvoice = (payload) => __awaiter(void 0, void 0, void 0, function* () {
     console.log('received invoice', payload);
     const total_spent = 1;
     const dat = payload.content || payload;
@@ -225,7 +221,6 @@ const receiveInvoice = (payload) => __awaiter(void 0, void 0, void 0, function*
     const theChat = Object.assign(Object.assign({}, chat.dataValues), { contactIds: [sender.id] });
     confirmations_1.sendConfirmation({ chat: theChat, sender: owner, msg_id });
 });
-exports.receiveInvoice = receiveInvoice;
 // lnd invoice stuff
 function decodePaymentRequest(paymentRequest) {
     var decodedPaymentRequest = decodeUtils.decode(paymentRequest);

dist/api/controllers/media.js

@@ -47,7 +47,7 @@ purchase_accept should update the original attachment message with the terms and
 
 purchase_deny returns the sats
 */
-const sendAttachmentMessage = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
+exports.sendAttachmentMessage = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     // try {
     //   schemas.attachment.validateSync(req.body)
     // } catch(e) {
@@ -130,7 +130,6 @@ const sendAttachmentMessage = (req, res) => __awaiter(void 0, void 0, void 0, fu
         failure: error => resUtils.failure(res, error.message),
     });
 });
-exports.sendAttachmentMessage = sendAttachmentMessage;
 function saveMediaKeys(muid, mediaKeyMap, chatId, messageId, mediaType) {
     if (typeof mediaKeyMap !== 'object') {
         console.log('wrong type for mediaKeyMap');
@@ -150,7 +149,8 @@ function saveMediaKeys(muid, mediaKeyMap, chatId, messageId, mediaType) {
         }
     }
 }
-const purchase = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
+exports.saveMediaKeys = saveMediaKeys;
+exports.purchase = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     const { chat_id, contact_id, amount, media_token, } = req.body;
     var date = new Date();
     date.setMilliseconds(0);
@@ -194,9 +194,8 @@ const purchase = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
         failure: error => resUtils.failure(res, error.message),
     });
 });
-exports.purchase = purchase;
 /* RECEIVERS */
-const receivePurchase = (payload) => __awaiter(void 0, void 0, void 0, function* () {
+exports.receivePurchase = (payload) => __awaiter(void 0, void 0, void 0, function* () {
     console.log('=> received purchase', { payload });
     var date = new Date();
     date.setMilliseconds(0);
@@ -316,8 +315,7 @@ const receivePurchase = (payload) => __awaiter(void 0, void 0, void 0, function*
         failure: error => console.log('=> couldnt send purchase accept', error),
     });
 });
-exports.receivePurchase = receivePurchase;
+exports.receivePurchaseAccept = (payload) => __awaiter(void 0, void 0, void 0, function* () {
-const receivePurchaseAccept = (payload) => __awaiter(void 0, void 0, void 0, function* () {
     console.log('=> receivePurchaseAccept');
     var date = new Date();
     date.setMilliseconds(0);
@@ -358,8 +356,7 @@ const receivePurchaseAccept = (payload) => __awaiter(void 0, void 0, void 0, fun
         response: jsonUtils.messageToJson(msg, chat, sender)
     });
 });
-exports.receivePurchaseAccept = receivePurchaseAccept;
+exports.receivePurchaseDeny = (payload) => __awaiter(void 0, void 0, void 0, function* () {
-const receivePurchaseDeny = (payload) => __awaiter(void 0, void 0, void 0, function* () {
     console.log('=> receivePurchaseDeny');
     var date = new Date();
     date.setMilliseconds(0);
@@ -385,8 +382,7 @@ const receivePurchaseDeny = (payload) => __awaiter(void 0, void 0, void 0, funct
         response: jsonUtils.messageToJson(msg, chat, sender)
     });
 });
-exports.receivePurchaseDeny = receivePurchaseDeny;
+exports.receiveAttachment = (payload) => __awaiter(void 0, void 0, void 0, function* () {
-const receiveAttachment = (payload) => __awaiter(void 0, void 0, void 0, function* () {
     // console.log('received attachment', { payload })
     var date = new Date();
     date.setMilliseconds(0);
@@ -427,7 +423,6 @@ const receiveAttachment = (payload) => __awaiter(void 0, void 0, void 0, functio
     const theChat = Object.assign(Object.assign({}, chat.dataValues), { contactIds: [sender.id] });
     confirmations_1.sendConfirmation({ chat: theChat, sender: owner, msg_id });
 });
-exports.receiveAttachment = receiveAttachment;
 function signer(req, res) {
     return __awaiter(this, void 0, void 0, function* () {
         if (!req.params.challenge)
@@ -474,6 +469,7 @@ function getMyPubKey() {
         });
     });
 }
+exports.getMyPubKey = getMyPubKey;
 function cycleMediaToken() {
     return __awaiter(this, void 0, void 0, function* () {
         try {
@@ -549,4 +545,5 @@ function getMediaInfo(muid) {
         }
     });
 }
+exports.getMediaInfo = getMediaInfo;
 //# sourceMappingURL=media.js.map

dist/api/controllers/messages.js

@@ -23,10 +23,10 @@ const path = require("path");
 const network = require("../network");
 const short = require("short-uuid");
 const constants = require(path.join(__dirname, '../../config/constants.json'));
-const getMessages = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
+exports.getMessages = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     const dateToReturn = req.query.date;
     if (!dateToReturn) {
-        return getAllMessages(req, res);
+        return exports.getAllMessages(req, res);
     }
     console.log(dateToReturn);
     const owner = yield models_1.models.Contact.findOne({ where: { isOwner: true } });
@@ -84,8 +84,7 @@ const getMessages = (req, res) => __awaiter(void 0, void 0, void 0, function* ()
     res.status(200);
     res.end();
 });
-exports.getMessages = getMessages;
+exports.getAllMessages = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
-const getAllMessages = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     const limit = (req.query.limit && parseInt(req.query.limit)) || 1000;
     const offset = (req.query.offset && parseInt(req.query.offset)) || 0;
     const messages = yield models_1.models.Message.findAll({ order: [['id', 'asc']], limit, offset });
@@ -98,7 +97,6 @@ const getAllMessages = (req, res) => __awaiter(void 0, void 0, void 0, function*
         confirmed_messages: []
     });
 });
-exports.getAllMessages = getAllMessages;
 function deleteMessage(req, res) {
     return __awaiter(this, void 0, void 0, function* () {
         const id = parseInt(req.params.id);
@@ -128,7 +126,7 @@ function deleteMessage(req, res) {
     });
 }
 exports.deleteMessage = deleteMessage;
-const sendMessage = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
+exports.sendMessage = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     // try {
     // 	schemas.message.validateSync(req.body)
     // } catch(e) {
@@ -177,8 +175,7 @@ const sendMessage = (req, res) => __awaiter(void 0, void 0, void 0, function* ()
         message: msgToSend,
     });
 });
-exports.sendMessage = sendMessage;
+exports.receiveMessage = (payload) => __awaiter(void 0, void 0, void 0, function* () {
-const receiveMessage = (payload) => __awaiter(void 0, void 0, void 0, function* () {
     // console.log('received message', { payload })
     var date = new Date();
     date.setMilliseconds(0);
@@ -220,8 +217,7 @@ const receiveMessage = (payload) => __awaiter(void 0, void 0, void 0, function*
     const theChat = Object.assign(Object.assign({}, chat.dataValues), { contactIds: [sender.id] });
     confirmations_1.sendConfirmation({ chat: theChat, sender: owner, msg_id });
 });
-exports.receiveMessage = receiveMessage;
+exports.receiveDeleteMessage = (payload) => __awaiter(void 0, void 0, void 0, function* () {
-const receiveDeleteMessage = (payload) => __awaiter(void 0, void 0, void 0, function* () {
     console.log('=> received delete message');
     const { owner, sender, chat, chat_type, msg_uuid } = yield helpers.parseReceiveParams(payload);
     if (!owner || !sender || !chat) {
@@ -242,8 +238,7 @@ const receiveDeleteMessage = (payload) => __awaiter(void 0, void 0, void 0, func
         response: jsonUtils.messageToJson(message, chat, sender)
     });
 });
-exports.receiveDeleteMessage = receiveDeleteMessage;
+exports.readMessages = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
-const readMessages = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     const chat_id = req.params.chat_id;
     const owner = yield models_1.models.Contact.findOne({ where: { isOwner: true } });
     models_1.models.Message.update({ seen: true }, {
@@ -256,10 +251,8 @@ const readMessages = (req, res) => __awaiter(void 0, void 0, void 0, function* (
     });
     res_1.success(res, {});
 });
-exports.readMessages = readMessages;
+exports.clearMessages = (req, res) => {
-const clearMessages = (req, res) => {
     models_1.models.Message.destroy({ where: {}, truncate: true });
     res_1.success(res, {});
 };
-exports.clearMessages = clearMessages;
 //# sourceMappingURL=messages.js.map

dist/api/controllers/payment.js

@@ -20,7 +20,7 @@ const ldat_1 = require("../utils/ldat");
 const constants = require("../../config/constants.json");
 const network = require("../network");
 const short = require("short-uuid");
-const sendPayment = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
+exports.sendPayment = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     const { amount, chat_id, contact_id, destination_key, media_type, muid, text, remote_text, dimensions, remote_text_map, contact_ids, reply_uuid, } = req.body;
     console.log('[send payment]', req.body);
     const owner = yield models_1.models.Contact.findOne({ where: { isOwner: true } });
@@ -117,8 +117,7 @@ const sendPayment = (req, res) => __awaiter(void 0, void 0, void 0, function* ()
         })
     });
 });
-exports.sendPayment = sendPayment;
+exports.receivePayment = (payload) => __awaiter(void 0, void 0, void 0, function* () {
-const receivePayment = (payload) => __awaiter(void 0, void 0, void 0, function* () {
     console.log('received payment', { payload });
     var date = new Date();
     date.setMilliseconds(0);
@@ -156,8 +155,7 @@ const receivePayment = (payload) => __awaiter(void 0, void 0, void 0, function*
     });
     hub_1.sendNotification(chat, msg.senderAlias || sender.alias, 'message');
 });
-exports.receivePayment = receivePayment;
+exports.listPayments = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
-const listPayments = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     const limit = (req.query.limit && parseInt(req.query.limit)) || 100;
     const offset = (req.query.offset && parseInt(req.query.offset)) || 0;
     const payments = [];
@@ -200,5 +198,4 @@ const listPayments = (req, res) => __awaiter(void 0, void 0, void 0, function* (
     payments.sort((a, b) => b.date - a.date);
     res_1.success(res, payments.splice(offset, limit));
 });
-exports.listPayments = listPayments;
 //# sourceMappingURL=payment.js.map

dist/api/controllers/schemas.js

@@ -5,21 +5,18 @@ const yup = require("yup");
 These schemas validate payloads coming from app,
 do not necessarily match up with Models
 */
-const attachment = yup.object().shape({
+exports.attachment = yup.object().shape({
     muid: yup.string().required(),
     media_type: yup.string().required(),
     media_key_map: yup.object().required(),
 });
-exports.attachment = attachment;
+exports.message = yup.object().shape({
-const message = yup.object().shape({
     contact_id: yup.number().required(),
 });
-exports.message = message;
+exports.purchase = yup.object().shape({
-const purchase = yup.object().shape({
     chat_id: yup.number().required(),
     contact_id: yup.number().required(),
     media_token: yup.string().required(),
     amount: yup.number().required()
 });
-exports.purchase = purchase;
 //# sourceMappingURL=schemas.js.map

dist/api/controllers/schemas.js.map

@@ -1 +1 @@
-{"version":3,"file":"schemas.js","sourceRoot":"","sources":["../../../api/controllers/schemas.ts"],"names":[],"mappings":";;AAAA,2BAA0B;AAE1B;;;EAGE;AAEF,MAAM,UAAU,GAAG,GAAG,CAAC,MAAM,EAAE,CAAC,KAAK,CAAC;IAClC,IAAI,EAAE,GAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;IAC7B,UAAU,EAAE,GAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;IACnC,aAAa,EAAE,GAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;CACzC,CAAC,CAAA;AAcE,gCAAU;AAZd,MAAM,OAAO,GAAG,GAAG,CAAC,MAAM,EAAE,CAAC,KAAK,CAAC;IAC/B,UAAU,EAAE,GAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;CACtC,CAAC,CAAA;AAYE,0BAAO;AAVX,MAAM,QAAQ,GAAG,GAAG,CAAC,MAAM,EAAE,CAAC,KAAK,CAAC;IAChC,OAAO,EAAE,GAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;IAChC,UAAU,EAAE,GAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;IACnC,WAAW,EAAE,GAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;IACpC,MAAM,EAAE,GAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;CAClC,CAAC,CAAA;AAIE,4BAAQ"}
+{"version":3,"file":"schemas.js","sourceRoot":"","sources":["../../../api/controllers/schemas.ts"],"names":[],"mappings":";;AAAA,2BAA0B;AAE1B;;;EAGE;AAEW,QAAA,UAAU,GAAG,GAAG,CAAC,MAAM,EAAE,CAAC,KAAK,CAAC;IACzC,IAAI,EAAE,GAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;IAC7B,UAAU,EAAE,GAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;IACnC,aAAa,EAAE,GAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;CACzC,CAAC,CAAA;AAEW,QAAA,OAAO,GAAG,GAAG,CAAC,MAAM,EAAE,CAAC,KAAK,CAAC;IACtC,UAAU,EAAE,GAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;CACtC,CAAC,CAAA;AAEW,QAAA,QAAQ,GAAG,GAAG,CAAC,MAAM,EAAE,CAAC,KAAK,CAAC;IACvC,OAAO,EAAE,GAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;IAChC,UAAU,EAAE,GAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;IACnC,WAAW,EAAE,GAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;IACpC,MAAM,EAAE,GAAG,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;CAClC,CAAC,CAAA"}

dist/api/controllers/subscriptions.js

@@ -25,7 +25,7 @@ const constants = require(path.join(__dirname, '../../config/constants.json'));
 // store all current running jobs in memory
 let jobs = {};
 // init jobs from DB
-const initializeCronJobs = () => __awaiter(void 0, void 0, void 0, function* () {
+exports.initializeCronJobs = () => __awaiter(void 0, void 0, void 0, function* () {
     yield helpers.sleep(1000);
     const subs = yield getRawSubs({ where: { ended: false } });
     subs.length && subs.forEach(sub => {
@@ -33,7 +33,6 @@ const initializeCronJobs = () => __awaiter(void 0, void 0, void 0, function* ()
         startCronJob(sub);
     });
 });
-exports.initializeCronJobs = initializeCronJobs;
 function startCronJob(sub) {
     return __awaiter(this, void 0, void 0, function* () {
         jobs[sub.id] = new cron_1.CronJob(sub.cron, function () {
@@ -254,7 +253,7 @@ function getRawSubs(opts = {}) {
     });
 }
 // all subs
-const getAllSubscriptions = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
+exports.getAllSubscriptions = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     try {
         const subs = yield getRawSubs();
         res_1.success(res, subs.map(sub => jsonUtils.subscriptionToJson(sub, null)));
@@ -264,7 +263,6 @@ const getAllSubscriptions = (req, res) => __awaiter(void 0, void 0, void 0, func
         res_1.failure(res, e);
     }
 });
-exports.getAllSubscriptions = getAllSubscriptions;
 // one sub by id
 function getSubscription(req, res) {
     return __awaiter(this, void 0, void 0, function* () {
@@ -303,7 +301,7 @@ function deleteSubscription(req, res) {
 exports.deleteSubscription = deleteSubscription;
 ;
 // all subs for contact id
-const getSubscriptionsForContact = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
+exports.getSubscriptionsForContact = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     try {
         const subs = yield getRawSubs({ where: { contactId: req.params.contactId } });
         res_1.success(res, subs.map(sub => jsonUtils.subscriptionToJson(sub, null)));
@@ -313,7 +311,6 @@ const getSubscriptionsForContact = (req, res) => __awaiter(void 0, void 0, void
         res_1.failure(res, e);
     }
 });
-exports.getSubscriptionsForContact = getSubscriptionsForContact;
 // create new sub
 function createSubscription(req, res) {
     return __awaiter(this, void 0, void 0, function* () {

dist/api/controllers/uploads.js

@@ -32,8 +32,7 @@ var avatarStorage = multer.diskStorage({
         }
     }
 });
-var avatarUpload = multer({ storage: avatarStorage });
+exports.avatarUpload = multer({ storage: avatarStorage });
-exports.avatarUpload = avatarUpload;
 function hasProtocol(ip) {
     if (ip.startsWith('https://'))
         return true;
@@ -41,7 +40,7 @@ function hasProtocol(ip) {
         return true;
     return false;
 }
-const uploadFile = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
+exports.uploadFile = (req, res) => __awaiter(void 0, void 0, void 0, function* () {
     const { contact_id, chat_id } = req.body;
     const { file } = req;
     const ip = String(process.env.NODE_IP);
@@ -71,5 +70,4 @@ const uploadFile = (req, res) => __awaiter(void 0, void 0, void 0, function* ()
     });
     res.end();
 });
-exports.uploadFile = uploadFile;
 //# sourceMappingURL=uploads.js.map

dist/api/controllers/uploads.js.map

@@ -1 +1 @@
-{"version":3,"file":"uploads.js","sourceRoot":"","sources":["../../../api/controllers/uploads.ts"],"names":[],"mappings":";;;;;;;;;;;AAAA,sCAAgC;AAChC,6BAA4B;AAE5B,MAAM,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC,QAAQ,IAAI,aAAa,CAAC;AAClD,MAAM,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,EAAC,uBAAuB,CAAC,CAAC,CAAC,GAAG,CAAC,CAAA;AAEzE,qBAAqB;AACrB,IAAI,MAAM,GAAG,OAAO,CAAC,QAAQ,CAAC,CAAA;AAC9B,IAAI,aAAa,GAAG,MAAM,CAAC,WAAW,CAAC;IACrC,WAAW,EAAE,CAAC,GAAG,EAAE,IAAI,EAAE,EAAE,EAAE,EAAE;QAC7B,IAAI,GAAG,GAAG,SAAS,CAAC,QAAQ,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,EAAC,IAAI,CAAC,CAAC,CAAC,CAAC,SAAS,CAAA;QAC9E,EAAE,CAAC,IAAI,EAAE,GAAG,GAAG,uBAAuB,CAAC,CAAA;IACzC,CAAC;IACD,QAAQ,EAAE,CAAC,GAAG,EAAE,IAAI,EAAE,EAAE,EAAE,EAAE;QAC1B,MAAM,IAAI,GAAG,IAAI,CAAC,QAAQ,CAAA;QAC1B,MAAM,IAAI,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;QAC5B,MAAM,GAAG,GAAG,IAAI,CAAC,IAAI,CAAC,MAAM,GAAC,CAAC,CAAC,CAAA;QAC/B,IAAG,GAAG,CAAC,IAAI,CAAC,OAAO,EAAC;YAClB,EAAE,CAAC,IAAI,EAAE,QAAQ,GAAG,CAAC,IAAI,CAAC,OAAO,YAAY,GAAG,EAAE,CAAC,CAAA;SACpD;aAAM;YACL,EAAE,CAAC,IAAI,EAAE,GAAG,GAAG,CAAC,IAAI,CAAC,UAAU,oBAAoB,GAAG,EAAE,CAAC,CAAA;SAC1D;IACH,CAAC;CACF,CAAC,CAAA;AACF,IAAI,YAAY,GAAG,MAAM,CAAC,EAAE,OAAO,EAAE,aAAa,EAAE,CAAC,CAAA;AA0CnD,oCAAY;AAxCd,SAAS,WAAW,CAAC,EAAE;IACrB,IAAG,EAAE,CAAC,UAAU,CAAC,UAAU,CAAC;QAAE,OAAO,IAAI,CAAA;IACzC,IAAG,EAAE,CAAC,UAAU,CAAC,SAAS,CAAC;QAAE,OAAO,IAAI,CAAA;IACxC,OAAO,KAAK,CAAA;AACd,CAAC;AAED,MAAM,UAAU,GAAG,CAAO,GAAG,EAAE,GAAG,EAAE,EAAE;IACpC,MAAM,EAAE,UAAU,EAAE,OAAO,EAAE,GAAG,GAAG,CAAC,IAAI,CAAA;IACxC,MAAM,EAAE,IAAI,EAAE,GAAG,GAAG,CAAA;IAEpB,MAAM,EAAE,GAAG,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC,OAAO,CAAC,CAAA;IACtC,IAAI,KAAK,GAAG,EAAE,CAAA;IACd,IAAG,CAAC,WAAW,CAAC,EAAE,CAAC,EAAE;QACnB,KAAK,GAAC,MAAM,CAAC,kBAAkB,GAAG,KAAK,GAAG,EAAE,CAAA;KAC7C;IACD,MAAM,SAAS,GAAG,KAAK;QACrB,kBAAkB;QAClB,IAAI,CAAC,QAAQ,CAAA;IAEf,IAAG,UAAU,EAAC;QACZ,MAAM,OAAO,GAAG,MAAM,eAAM,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE,KAAK,EAAE,EAAE,EAAE,EAAE,UAAU,EAAE,EAAE,CAAC,CAAA;QAC3E,IAAG,OAAO;YAAE,OAAO,CAAC,MAAM,CAAC,EAAE,QAAQ,EAAE,SAAS,EAAE,CAAC,CAAA;KACpD;IAED,IAAG,OAAO,EAAC;QACT,MAAM,IAAI,GAAG,MAAM,eAAM,CAAC,IAAI,CAAC,OAAO,CAAC,EAAE,KAAK,EAAE,EAAE,EAAE,EAAE,OAAO,EAAE,EAAE,CAAC,CAAA;QAClE,IAAG,IAAI;YAAE,IAAI,CAAC,MAAM,CAAC,EAAE,QAAQ,EAAE,SAAS,EAAE,CAAC,CAAA;KAC9C;IAED,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;IACf,GAAG,CAAC,IAAI,CAAC;QACP,OAAO,EAAE,IAAI;QACb,UAAU,EAAE,QAAQ,CAAC,UAAU,IAAE,CAAC,CAAC;QACnC,OAAO,EAAE,QAAQ,CAAC,OAAO,IAAE,CAAC,CAAC;QAC7B,SAAS;KACV,CAAC,CAAC;IACH,GAAG,CAAC,GAAG,EAAE,CAAC;AACZ,CAAC,CAAA,CAAA;AAIA,gCAAU"}
+{"version":3,"file":"uploads.js","sourceRoot":"","sources":["../../../api/controllers/uploads.ts"],"names":[],"mappings":";;;;;;;;;;;AAAA,sCAAgC;AAChC,6BAA4B;AAE5B,MAAM,GAAG,GAAG,OAAO,CAAC,GAAG,CAAC,QAAQ,IAAI,aAAa,CAAC;AAClD,MAAM,MAAM,GAAG,OAAO,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,EAAC,uBAAuB,CAAC,CAAC,CAAC,GAAG,CAAC,CAAA;AAEzE,qBAAqB;AACrB,IAAI,MAAM,GAAG,OAAO,CAAC,QAAQ,CAAC,CAAA;AAC9B,IAAI,aAAa,GAAG,MAAM,CAAC,WAAW,CAAC;IACrC,WAAW,EAAE,CAAC,GAAG,EAAE,IAAI,EAAE,EAAE,EAAE,EAAE;QAC7B,IAAI,GAAG,GAAG,SAAS,CAAC,QAAQ,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,EAAC,IAAI,CAAC,CAAC,CAAC,CAAC,SAAS,CAAA;QAC9E,EAAE,CAAC,IAAI,EAAE,GAAG,GAAG,uBAAuB,CAAC,CAAA;IACzC,CAAC;IACD,QAAQ,EAAE,CAAC,GAAG,EAAE,IAAI,EAAE,EAAE,EAAE,EAAE;QAC1B,MAAM,IAAI,GAAG,IAAI,CAAC,QAAQ,CAAA;QAC1B,MAAM,IAAI,GAAG,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAA;QAC5B,MAAM,GAAG,GAAG,IAAI,CAAC,IAAI,CAAC,MAAM,GAAC,CAAC,CAAC,CAAA;QAC/B,IAAG,GAAG,CAAC,IAAI,CAAC,OAAO,EAAC;YAClB,EAAE,CAAC,IAAI,EAAE,QAAQ,GAAG,CAAC,IAAI,CAAC,OAAO,YAAY,GAAG,EAAE,CAAC,CAAA;SACpD;aAAM;YACL,EAAE,CAAC,IAAI,EAAE,GAAG,GAAG,CAAC,IAAI,CAAC,UAAU,oBAAoB,GAAG,EAAE,CAAC,CAAA;SAC1D;IACH,CAAC;CACF,CAAC,CAAA;AACS,QAAA,YAAY,GAAG,MAAM,CAAC,EAAE,OAAO,EAAE,aAAa,EAAE,CAAC,CAAA;AAE5D,SAAS,WAAW,CAAC,EAAE;IACrB,IAAG,EAAE,CAAC,UAAU,CAAC,UAAU,CAAC;QAAE,OAAO,IAAI,CAAA;IACzC,IAAG,EAAE,CAAC,UAAU,CAAC,SAAS,CAAC;QAAE,OAAO,IAAI,CAAA;IACxC,OAAO,KAAK,CAAA;AACd,CAAC;AAEY,QAAA,UAAU,GAAG,CAAO,GAAG,EAAE,GAAG,EAAE,EAAE;IAC3C,MAAM,EAAE,UAAU,EAAE,OAAO,EAAE,GAAG,GAAG,CAAC,IAAI,CAAA;IACxC,MAAM,EAAE,IAAI,EAAE,GAAG,GAAG,CAAA;IAEpB,MAAM,EAAE,GAAG,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC,OAAO,CAAC,CAAA;IACtC,IAAI,KAAK,GAAG,EAAE,CAAA;IACd,IAAG,CAAC,WAAW,CAAC,EAAE,CAAC,EAAE;QACnB,KAAK,GAAC,MAAM,CAAC,kBAAkB,GAAG,KAAK,GAAG,EAAE,CAAA;KAC7C;IACD,MAAM,SAAS,GAAG,KAAK;QACrB,kBAAkB;QAClB,IAAI,CAAC,QAAQ,CAAA;IAEf,IAAG,UAAU,EAAC;QACZ,MAAM,OAAO,GAAG,MAAM,eAAM,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE,KAAK,EAAE,EAAE,EAAE,EAAE,UAAU,EAAE,EAAE,CAAC,CAAA;QAC3E,IAAG,OAAO;YAAE,OAAO,CAAC,MAAM,CAAC,EAAE,QAAQ,EAAE,SAAS,EAAE,CAAC,CAAA;KACpD;IAED,IAAG,OAAO,EAAC;QACT,MAAM,IAAI,GAAG,MAAM,eAAM,CAAC,IAAI,CAAC,OAAO,CAAC,EAAE,KAAK,EAAE,EAAE,EAAE,EAAE,OAAO,EAAE,EAAE,CAAC,CAAA;QAClE,IAAG,IAAI;YAAE,IAAI,CAAC,MAAM,CAAC,EAAE,QAAQ,EAAE,SAAS,EAAE,CAAC,CAAA;KAC9C;IAED,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAA;IACf,GAAG,CAAC,IAAI,CAAC;QACP,OAAO,EAAE,IAAI;QACb,UAAU,EAAE,QAAQ,CAAC,UAAU,IAAE,CAAC,CAAC;QACnC,OAAO,EAAE,QAAQ,CAAC,OAAO,IAAE,CAAC,CAAC;QAC7B,SAAS;KACV,CAAC,CAAC;IACH,GAAG,CAAC,GAAG,EAAE,CAAC;AACZ,CAAC,CAAA,CAAA"}

dist/api/grpc/index.js.map

@@ -1 +1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../api/grpc/index.ts"],"names":[],"mappings":";;;;;;;;;;;AAAA,sCAAgC;AAChC,0CAAyC;AACzC,gCAAsD;AACtD,2CAA0C;AAC1C,+CAA8C;AAC9C,kDAAgD;AAChD,sCAAqC;AACrC,iCAAgC;AAChC,6BAA4B;AAE5B,MAAM,SAAS,GAAG,OAAO,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,EAAC,6BAA6B,CAAC,CAAC,CAAA;AAC7E,MAAM,oBAAoB,GAAG,EAAE,CAAA;AAC/B,MAAM,uBAAuB,GAAG,CAAC,CAAA;AAEjC,SAAS,iBAAiB,CAAC,mBAAmB;IAC7C,OAAO,IAAI,OAAO,CAAC,CAAM,OAAO,EAAC,MAAM,EAAC,EAAE;QACzC,MAAM,SAAS,GAAG,MAAM,yBAAa,EAAE,CAAA;QAEvC,IAAI,IAAI,GAAG,SAAS,CAAC,iBAAiB,EAAE,CAAA;QACxC,IAAI,CAAC,EAAE,CAAC,MAAM,EAAE,UAAe,QAAQ;;gBACtC,IAAI,QAAQ,CAAC,OAAO,CAAC,KAAK,SAAS,EAAE;oBACpC,OAAM;iBACN;gBACD,iDAAiD;gBACjD,IAAG,QAAQ,CAAC,UAAU,EAAE;oBACvB,mBAAmB,CAAC,QAAQ,CAAC,CAAA;iBAC7B;qBAAM;oBACN,MAAM,OAAO,GAAG,MAAM,eAAM,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE,KAAK,EAAE,EAAE,IAAI,EAAE,SAAS,CAAC,aAAa,CAAC,OAAO,EAAE,eAAe,EAAE,QAAQ,CAAC,iBAAiB,CAAC,EAAE,EAAE,CAAC,CAAA;oBAChJ,IAAI,OAAO,IAAI,IAAI,EAAE;wBACpB,+EAA+E;wBAC/E,MAAM,MAAM,GAAG,QAAQ,CAAC,iBAAiB,CAAC,CAAA;wBAC1C,MAAM,MAAM,GAAG,QAAQ,CAAC,cAAc,CAAC,CAAA;wBACvC,IAAI,OAAO,CAAC,GAAG,CAAC,gBAAgB,KAAG,MAAM,EAAC;4BACzC,iBAAW,CAAC,MAAM,EAAE,MAAM,CAAC,CAAA;yBAC3B;wBACD,MAAM,CAAC,QAAQ,CAAC;4BACf,IAAI,EAAE,iBAAiB;4BACvB,QAAQ,EAAE,EAAC,OAAO,EAAE,MAAM,EAAC;yBAC3B,CAAC,CAAA;wBACF,OAAM;qBACN;oBACD,eAAM,CAAC,OAAO,CAAC,MAAM,CAAC,EAAE,MAAM,EAAE,SAAS,CAAC,QAAQ,CAAC,SAAS,EAAE,EAAE,EAAE,KAAK,EAAE,EAAE,EAAE,EAAE,OAAO,CAAC,EAAE,EAAE,EAAE,CAAC,CAAA;oBAE9F,IAAI,qBAAqB,GAAG,WAAW,CAAC,MAAM,CAAC,QAAQ,CAAC,iBAAiB,CAAC,CAAC,CAAC;oBAE5E,IAAI,WAAW,GAAG,EAAE,CAAC;oBACrB,KAAK,IAAI,CAAC,GAAC,CAAC,EAAE,CAAC,GAAC,qBAAqB,CAAC,MAAM,CAAC,CAAC,MAAM,CAAC,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE;wBAClE,IAAI,GAAG,GAAG,qBAAqB,CAAC,MAAM,CAAC,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,CAAC;wBACnD,IAAI,GAAG,CAAC,aAAa,CAAC,IAAI,cAAc,EAAE;4BACzC,WAAW,GAAG,GAAG,CAAC,OAAO,CAAC,CAAC;4BAC3B,MAAM;yBACN;qBACD;oBAED,IAAI,UAAU,GAAG,QAAQ,CAAC,QAAQ,CAAC,aAAa,CAAC,GAAG,KAAK,CAAC,CAAC;oBAE3D,MAAM,IAAI,GAAG,MAAM,eAAM,CAAC,IAAI,CAAC,OAAO,CAAC,EAAE,KAAK,EAAE,EAAE,EAAE,EAAE,OAAO,CAAC,MAAM,EAAE,EAAE,CAAC,CAAA;oBACzE,MAAM,UAAU,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,UAAU,CAAC,CAAA;oBAC9C,MAAM,QAAQ,GAAG,UAAU,CAAC,IAAI,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,IAAI,OAAO,CAAC,MAAM,CAAC,CAAA;oBAE5D,MAAM,OAAO,GAAG,MAAM,eAAM,CAAC,OAAO,CAAC,MAAM,CAAC;wBAC3C,MAAM,EAAE,OAAO,CAAC,MAAM;wBACtB,IAAI,EAAE,SAAS,CAAC,aAAa,CAAC,OAAO;wBACrC,MAAM,EAAE,QAAQ;wBAChB,MAAM,EAAE,QAAQ,CAAC,cAAc,CAAC;wBAChC,UAAU,EAAE,QAAQ,CAAC,eAAe,CAAC;wBACrC,WAAW,EAAE,WAAW;wBACxB,IAAI,EAAE,IAAI,IAAI,CAAC,UAAU,CAAC;wBAC1B,cAAc,EAAE,QAAQ,CAAC,MAAM,CAAC;wBAChC,MAAM,EAAE,SAAS,CAAC,QAAQ,CAAC,SAAS;wBACpC,SAAS,EAAE,IAAI,IAAI,CAAC,UAAU,CAAC;wBAC/B,SAAS,EAAE,IAAI,IAAI,CAAC,UAAU,CAAC;qBAC/B,CAAC,CAAA;oBAEF,MAAM,MAAM,GAAG,MAAM,eAAM,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE,KAAK,EAAE,EAAE,EAAE,EAAE,QAAQ,EAAE,EAAE,CAAC,CAAA;oBAExE,MAAM,CAAC,QAAQ,CAAC;wBACf,IAAI,EAAE,SAAS;wBACf,QAAQ,EAAE,SAAS,CAAC,aAAa,CAAC,OAAO,EAAE,IAAI,EAAE,MAAM,CAAC;qBACxD,CAAC,CAAA;oBAEF,sBAAgB,CAAC,IAAI,EAAE,MAAM,CAAC,KAAK,EAAE,SAAS,CAAC,CAAA;iBAC/C;YACF,CAAC;SAAA,CAAC,CAAC;QACH,IAAI,CAAC,EAAE,CAAC,QAAQ,EAAE,UAAS,MAAM;YAChC,OAAO,CAAC,GAAG,CAAC,QAAQ,EAAE,MAAM,CAAC,CAAC;YAC9B,kDAAkD;YAClD,IAAI,MAAM,CAAC,IAAI,IAAI,oBAAoB,IAAI,MAAM,CAAC,IAAI,IAAI,uBAAuB,EAAE;gBAClF,CAAC,GAAG,CAAC,CAAA;gBACL,cAAc,CAAC,IAAI,CAAC,MAAM,EAAE,CAAC,CAAC;aAC9B;iBAAM;gBACN,OAAO,CAAC,MAAM,CAAC,CAAC;aAChB;QACF,CAAC,CAAC,CAAA;QACF,IAAI,CAAC,EAAE,CAAC,OAAO,EAAE,UAAS,GAAG;YAC5B,MAAM,GAAG,GAAG,MAAM,EAAE,CAAC,MAAM,CAAC,qBAAqB,CAAC,CAAC,IAAI,EAAE,CAAC;YAC1D,OAAO,CAAC,KAAK,CAAC,aAAa,EAAC,GAAG,EAAC,GAAG,CAAC,IAAI,CAAC,CAAA;YACzC,IAAI,GAAG,CAAC,IAAI,IAAI,oBAAoB,IAAI,GAAG,CAAC,IAAI,IAAI,uBAAuB,EAAE;gBAC5E,CAAC,GAAG,CAAC,CAAA;gBACL,cAAc,CAAC,IAAI,CAAC,MAAM,EAAE,CAAC,CAAC;aAC9B;iBAAM;gBACN,MAAM,CAAC,GAAG,CAAC,CAAA;aACX;QACF,CAAC,CAAC,CAAA;QACF,IAAI,CAAC,EAAE,CAAC,KAAK,EAAE;YACd,MAAM,GAAG,GAAG,MAAM,EAAE,CAAC,MAAM,CAAC,qBAAqB,CAAC,CAAC,IAAI,EAAE,CAAC;YAC1D,OAAO,CAAC,GAAG,CAAC,iBAAiB,GAAG,EAAE,CAAC,CAAC;YACpC,oCAAoC;YACpC,CAAC,GAAG,CAAC,CAAA;YACL,cAAc,CAAC,IAAI,CAAC,MAAM,EAAE,CAAC,CAAA;QAC9B,CAAC,CAAC,CAAA;QACF,UAAU,CAAC,GAAE,EAAE;YACd,OAAO,CAAC,IAAI,CAAC,CAAA;QACd,CAAC,EAAC,GAAG,CAAC,CAAA;IACP,CAAC,CAAA,CAAC,CAAA;AACH,CAAC;AAsBA,8CAAiB;AApBlB,IAAI,CAAC,GAAG,CAAC,CAAA;AACT,IAAI,GAAG,GAAG,CAAC,CAAA;AACX,SAAe,cAAc,CAAC,QAAe;;QAC5C,GAAG,GAAG,QAAQ,CAAA;QACd,CAAC,EAAE,CAAA;QACH,OAAO,CAAC,GAAG,CAAC,qCAAqC,CAAC,EAAE,CAAC,CAAA;QACrD,IAAI;YACH,MAAM,OAAO,CAAC,qBAAqB,EAAE,CAAA;YACrC,MAAM,GAAG,GAAG,MAAM,EAAE,CAAC,MAAM,CAAC,qBAAqB,CAAC,CAAC,IAAI,EAAE,CAAC;YAC1D,OAAO,CAAC,GAAG,CAAC,yBAAyB,GAAG,EAAE,CAAC,CAAA;SAC3C;QAAC,OAAM,CAAC,EAAE;YACV,UAAU,CAAC,GAAO,EAAE;gBACnB,IAAG,GAAG,KAAG,QAAQ,EAAE,EAAE,iDAAiD;oBACrE,MAAM,cAAc,CAAC,QAAQ,CAAC,CAAA;iBAC9B;YACF,CAAC,CAAA,EAAC,IAAI,CAAC,CAAA;SACP;IACF,CAAC;CAAA"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../../../api/grpc/index.ts"],"names":[],"mappings":";;;;;;;;;;;AAAA,sCAAgC;AAChC,0CAAyC;AACzC,gCAAsD;AACtD,2CAA0C;AAC1C,+CAA8C;AAC9C,kDAAgD;AAChD,sCAAqC;AACrC,iCAAgC;AAChC,6BAA4B;AAE5B,MAAM,SAAS,GAAG,OAAO,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,EAAC,6BAA6B,CAAC,CAAC,CAAA;AAC7E,MAAM,oBAAoB,GAAG,EAAE,CAAA;AAC/B,MAAM,uBAAuB,GAAG,CAAC,CAAA;AAEjC,SAAgB,iBAAiB,CAAC,mBAAmB;IACpD,OAAO,IAAI,OAAO,CAAC,CAAM,OAAO,EAAC,MAAM,EAAC,EAAE;QACzC,MAAM,SAAS,GAAG,MAAM,yBAAa,EAAE,CAAA;QAEvC,IAAI,IAAI,GAAG,SAAS,CAAC,iBAAiB,EAAE,CAAA;QACxC,IAAI,CAAC,EAAE,CAAC,MAAM,EAAE,UAAe,QAAQ;;gBACtC,IAAI,QAAQ,CAAC,OAAO,CAAC,KAAK,SAAS,EAAE;oBACpC,OAAM;iBACN;gBACD,iDAAiD;gBACjD,IAAG,QAAQ,CAAC,UAAU,EAAE;oBACvB,mBAAmB,CAAC,QAAQ,CAAC,CAAA;iBAC7B;qBAAM;oBACN,MAAM,OAAO,GAAG,MAAM,eAAM,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE,KAAK,EAAE,EAAE,IAAI,EAAE,SAAS,CAAC,aAAa,CAAC,OAAO,EAAE,eAAe,EAAE,QAAQ,CAAC,iBAAiB,CAAC,EAAE,EAAE,CAAC,CAAA;oBAChJ,IAAI,OAAO,IAAI,IAAI,EAAE;wBACpB,+EAA+E;wBAC/E,MAAM,MAAM,GAAG,QAAQ,CAAC,iBAAiB,CAAC,CAAA;wBAC1C,MAAM,MAAM,GAAG,QAAQ,CAAC,cAAc,CAAC,CAAA;wBACvC,IAAI,OAAO,CAAC,GAAG,CAAC,gBAAgB,KAAG,MAAM,EAAC;4BACzC,iBAAW,CAAC,MAAM,EAAE,MAAM,CAAC,CAAA;yBAC3B;wBACD,MAAM,CAAC,QAAQ,CAAC;4BACf,IAAI,EAAE,iBAAiB;4BACvB,QAAQ,EAAE,EAAC,OAAO,EAAE,MAAM,EAAC;yBAC3B,CAAC,CAAA;wBACF,OAAM;qBACN;oBACD,eAAM,CAAC,OAAO,CAAC,MAAM,CAAC,EAAE,MAAM,EAAE,SAAS,CAAC,QAAQ,CAAC,SAAS,EAAE,EAAE,EAAE,KAAK,EAAE,EAAE,EAAE,EAAE,OAAO,CAAC,EAAE,EAAE,EAAE,CAAC,CAAA;oBAE9F,IAAI,qBAAqB,GAAG,WAAW,CAAC,MAAM,CAAC,QAAQ,CAAC,iBAAiB,CAAC,CAAC,CAAC;oBAE5E,IAAI,WAAW,GAAG,EAAE,CAAC;oBACrB,KAAK,IAAI,CAAC,GAAC,CAAC,EAAE,CAAC,GAAC,qBAAqB,CAAC,MAAM,CAAC,CAAC,MAAM,CAAC,CAAC,MAAM,EAAE,CAAC,EAAE,EAAE;wBAClE,IAAI,GAAG,GAAG,qBAAqB,CAAC,MAAM,CAAC,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,CAAC;wBACnD,IAAI,GAAG,CAAC,aAAa,CAAC,IAAI,cAAc,EAAE;4BACzC,WAAW,GAAG,GAAG,CAAC,OAAO,CAAC,CAAC;4BAC3B,MAAM;yBACN;qBACD;oBAED,IAAI,UAAU,GAAG,QAAQ,CAAC,QAAQ,CAAC,aAAa,CAAC,GAAG,KAAK,CAAC,CAAC;oBAE3D,MAAM,IAAI,GAAG,MAAM,eAAM,CAAC,IAAI,CAAC,OAAO,CAAC,EAAE,KAAK,EAAE,EAAE,EAAE,EAAE,OAAO,CAAC,MAAM,EAAE,EAAE,CAAC,CAAA;oBACzE,MAAM,UAAU,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,UAAU,CAAC,CAAA;oBAC9C,MAAM,QAAQ,GAAG,UAAU,CAAC,IAAI,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,IAAI,OAAO,CAAC,MAAM,CAAC,CAAA;oBAE5D,MAAM,OAAO,GAAG,MAAM,eAAM,CAAC,OAAO,CAAC,MAAM,CAAC;wBAC3C,MAAM,EAAE,OAAO,CAAC,MAAM;wBACtB,IAAI,EAAE,SAAS,CAAC,aAAa,CAAC,OAAO;wBACrC,MAAM,EAAE,QAAQ;wBAChB,MAAM,EAAE,QAAQ,CAAC,cAAc,CAAC;wBAChC,UAAU,EAAE,QAAQ,CAAC,eAAe,CAAC;wBACrC,WAAW,EAAE,WAAW;wBACxB,IAAI,EAAE,IAAI,IAAI,CAAC,UAAU,CAAC;wBAC1B,cAAc,EAAE,QAAQ,CAAC,MAAM,CAAC;wBAChC,MAAM,EAAE,SAAS,CAAC,QAAQ,CAAC,SAAS;wBACpC,SAAS,EAAE,IAAI,IAAI,CAAC,UAAU,CAAC;wBAC/B,SAAS,EAAE,IAAI,IAAI,CAAC,UAAU,CAAC;qBAC/B,CAAC,CAAA;oBAEF,MAAM,MAAM,GAAG,MAAM,eAAM,CAAC,OAAO,CAAC,OAAO,CAAC,EAAE,KAAK,EAAE,EAAE,EAAE,EAAE,QAAQ,EAAE,EAAE,CAAC,CAAA;oBAExE,MAAM,CAAC,QAAQ,CAAC;wBACf,IAAI,EAAE,SAAS;wBACf,QAAQ,EAAE,SAAS,CAAC,aAAa,CAAC,OAAO,EAAE,IAAI,EAAE,MAAM,CAAC;qBACxD,CAAC,CAAA;oBAEF,sBAAgB,CAAC,IAAI,EAAE,MAAM,CAAC,KAAK,EAAE,SAAS,CAAC,CAAA;iBAC/C;YACF,CAAC;SAAA,CAAC,CAAC;QACH,IAAI,CAAC,EAAE,CAAC,QAAQ,EAAE,UAAS,MAAM;YAChC,OAAO,CAAC,GAAG,CAAC,QAAQ,EAAE,MAAM,CAAC,CAAC;YAC9B,kDAAkD;YAClD,IAAI,MAAM,CAAC,IAAI,IAAI,oBAAoB,IAAI,MAAM,CAAC,IAAI,IAAI,uBAAuB,EAAE;gBAClF,CAAC,GAAG,CAAC,CAAA;gBACL,cAAc,CAAC,IAAI,CAAC,MAAM,EAAE,CAAC,CAAC;aAC9B;iBAAM;gBACN,OAAO,CAAC,MAAM,CAAC,CAAC;aAChB;QACF,CAAC,CAAC,CAAA;QACF,IAAI,CAAC,EAAE,CAAC,OAAO,EAAE,UAAS,GAAG;YAC5B,MAAM,GAAG,GAAG,MAAM,EAAE,CAAC,MAAM,CAAC,qBAAqB,CAAC,CAAC,IAAI,EAAE,CAAC;YAC1D,OAAO,CAAC,KAAK,CAAC,aAAa,EAAC,GAAG,EAAC,GAAG,CAAC,IAAI,CAAC,CAAA;YACzC,IAAI,GAAG,CAAC,IAAI,IAAI,oBAAoB,IAAI,GAAG,CAAC,IAAI,IAAI,uBAAuB,EAAE;gBAC5E,CAAC,GAAG,CAAC,CAAA;gBACL,cAAc,CAAC,IAAI,CAAC,MAAM,EAAE,CAAC,CAAC;aAC9B;iBAAM;gBACN,MAAM,CAAC,GAAG,CAAC,CAAA;aACX;QACF,CAAC,CAAC,CAAA;QACF,IAAI,CAAC,EAAE,CAAC,KAAK,EAAE;YACd,MAAM,GAAG,GAAG,MAAM,EAAE,CAAC,MAAM,CAAC,qBAAqB,CAAC,CAAC,IAAI,EAAE,CAAC;YAC1D,OAAO,CAAC,GAAG,CAAC,iBAAiB,GAAG,EAAE,CAAC,CAAC;YACpC,oCAAoC;YACpC,CAAC,GAAG,CAAC,CAAA;YACL,cAAc,CAAC,IAAI,CAAC,MAAM,EAAE,CAAC,CAAA;QAC9B,CAAC,CAAC,CAAA;QACF,UAAU,CAAC,GAAE,EAAE;YACd,OAAO,CAAC,IAAI,CAAC,CAAA;QACd,CAAC,EAAC,GAAG,CAAC,CAAA;IACP,CAAC,CAAA,CAAC,CAAA;AACH,CAAC;AArGD,8CAqGC;AAED,IAAI,CAAC,GAAG,CAAC,CAAA;AACT,IAAI,GAAG,GAAG,CAAC,CAAA;AACX,SAAe,cAAc,CAAC,QAAe;;QAC5C,GAAG,GAAG,QAAQ,CAAA;QACd,CAAC,EAAE,CAAA;QACH,OAAO,CAAC,GAAG,CAAC,qCAAqC,CAAC,EAAE,CAAC,CAAA;QACrD,IAAI;YACH,MAAM,OAAO,CAAC,qBAAqB,EAAE,CAAA;YACrC,MAAM,GAAG,GAAG,MAAM,EAAE,CAAC,MAAM,CAAC,qBAAqB,CAAC,CAAC,IAAI,EAAE,CAAC;YAC1D,OAAO,CAAC,GAAG,CAAC,yBAAyB,GAAG,EAAE,CAAC,CAAA;SAC3C;QAAC,OAAM,CAAC,EAAE;YACV,UAAU,CAAC,GAAO,EAAE;gBACnB,IAAG,GAAG,KAAG,QAAQ,EAAE,EAAE,iDAAiD;oBACrE,MAAM,cAAc,CAAC,QAAQ,CAAC,CAAA;iBAC9B;YACF,CAAC,CAAA,EAAC,IAAI,CAAC,CAAA;SACP;IACF,CAAC;CAAA"}

dist/api/helpers.js

@@ -13,7 +13,7 @@ const models_1 = require("./models");
 const md5 = require("md5");
 const network = require("./network");
 const constants = require('../config/constants.json');
-const findOrCreateChat = (params) => __awaiter(void 0, void 0, void 0, function* () {
+exports.findOrCreateChat = (params) => __awaiter(void 0, void 0, void 0, function* () {
     const { chat_id, owner_id, recipient_id } = params;
     let chat;
     let date = new Date();
@@ -41,8 +41,7 @@ const findOrCreateChat = (params) => __awaiter(void 0, void 0, void 0, function*
     }
     return chat;
 });
-exports.findOrCreateChat = findOrCreateChat;
+exports.sendContactKeys = (args) => __awaiter(void 0, void 0, void 0, function* () {
-const sendContactKeys = (args) => __awaiter(void 0, void 0, void 0, function* () {
     const { type, contactIds, contactPubKey, sender, success, failure } = args;
     const msg = newkeyexchangemsg(type, sender);
     let yes = null;
@@ -62,7 +61,7 @@ const sendContactKeys = (args) => __awaiter(void 0, void 0, void 0, function* ()
             const contact = yield models_1.models.Contact.findOne({ where: { id: contactId } });
             destination_key = contact.publicKey;
         }
-        performKeysendMessage({
+        exports.performKeysendMessage({
             sender,
             destination_key,
             amount: 3,
@@ -82,8 +81,7 @@ const sendContactKeys = (args) => __awaiter(void 0, void 0, void 0, function* ()
         success(yes);
     }
 });
-exports.sendContactKeys = sendContactKeys;
+exports.performKeysendMessage = ({ destination_key, amount, msg, success, failure, sender }) => __awaiter(void 0, void 0, void 0, function* () {
-const performKeysendMessage = ({ destination_key, amount, msg, success, failure, sender }) => __awaiter(void 0, void 0, void 0, function* () {
     const opts = {
         dest: destination_key,
         data: msg || {},
@@ -101,7 +99,6 @@ const performKeysendMessage = ({ destination_key, amount, msg, success, failure,
             failure(e);
     }
 });
-exports.performKeysendMessage = performKeysendMessage;
 function findOrCreateContactByPubkey(senderPubKey) {
     return __awaiter(this, void 0, void 0, function* () {
         let sender = yield models_1.models.Contact.findOne({ where: { publicKey: senderPubKey } });
@@ -112,7 +109,7 @@ function findOrCreateContactByPubkey(senderPubKey) {
                 status: 1
             });
             const owner = yield models_1.models.Contact.findOne({ where: { isOwner: true } });
-            sendContactKeys({
+            exports.sendContactKeys({
                 contactIds: [sender.id],
                 sender: owner,
                 type: constants.message_types.contact_key,

dist/public/index.html

@@ -1,11 +0,0 @@
-<!DOCTYPE html>
-<html>
-  <head>
-    <title>React app</title>
-  </head>
-  <body>
-    <div id="app"></div>
-    <script src="/static/js/app.js"></script>
-    <link href="/static/semantic.min.css" rel="stylesheet" />
-  </body>
-</html>