Skip to content
This repository was archived by the owner on Mar 10, 2020. It is now read-only.

Commit 48a5cd7

Browse files
committed
Extract parseMessage
1 parent 056a3af commit 48a5cd7

File tree

1 file changed

+10
-6
lines changed

1 file changed

+10
-6
lines changed

src/api/pubsub.js

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,13 @@ const removeSubscription = (subscriptions, topic) => {
2020
const addSubscription = (subscriptions, topic) => {
2121
return subscriptions.concat([topic])
2222
}
23+
const parseMessage = (message) => {
24+
return Object.assign({}, message, {
25+
from: bs58.encode(message.from),
26+
data: Base64.decode(message.data),
27+
seqno: Base64.decode(message.seqno)
28+
})
29+
}
2330

2431
module.exports = (send, config) => {
2532
return {
@@ -50,14 +57,11 @@ module.exports = (send, config) => {
5057
path: '/api/v0/pubsub/sub/' + topic
5158
}, function (response) {
5259
response.on('data', function (d) {
53-
var parsed = JSON.parse(d)
60+
var data = JSON.parse(d)
5461

5562
// skip "double subscription" error
56-
if (!parsed.Message) {
57-
parsed.from = bs58.encode(parsed.from)
58-
parsed.data = Base64.decode(parsed.data)
59-
parsed.seqno = Base64.decode(parsed.seqno)
60-
rs.emit('data', parsed)
63+
if (!data.Message) {
64+
rs.emit('data', parseMessage(data))
6165
}
6266
})
6367
response.on('end', function () {

0 commit comments

Comments
 (0)