Compare View
Commits (2)
Changes
Showing 4 changed files Side-by-side Diff
lib/addressbook.js
... | ... | @@ -14,7 +14,7 @@ function _composeKeyword(partner) { |
14 | 14 | } |
15 | 15 | |
16 | 16 | function get(partner) { |
17 | - partner = partner.toUpperCase(); | |
17 | + partner = partner.toUpperCase().replace(/@.*$/, ''); | |
18 | 18 | return new Promise(function(resolve) { |
19 | 19 | if (_caches[partner]) { |
20 | 20 | resolve(_caches[partner]); |
... | ... | @@ -42,6 +42,7 @@ function get(partner) { |
42 | 42 | } |
43 | 43 | |
44 | 44 | function put(partner, chatId) { |
45 | + partner = partner.toUpperCase().replace(/@.*$/, ''); | |
45 | 46 | if (!partner || !chatId) { |
46 | 47 | return; |
47 | 48 | } |
lib/transport.js
... | ... | @@ -84,6 +84,7 @@ async function send(partner, msg) { |
84 | 84 | const chatId = await addressbook.get(partner); |
85 | 85 | if (!chatId) { |
86 | 86 | logger.info('Not sending message because partner does not exist on address book', {transport: 'telegram', me: me, partner: partner, msg: msg }); |
87 | + return; | |
87 | 88 | } |
88 | 89 | |
89 | 90 | logger.info('Sending message via Telegram transport', { transport: 'telegram', me: me, partner: partner, msg: msg }); |
package-lock.json