Michiel/add link push (#602)

* Add webpush link for push notifications

* Linting fixes

* Link formatting for push notifications

* Linting

* changelog

* Remove console.log

* Add networkSlug

* Linting

changes/michiel_add-link-push

@@ -0,0 +1 @@
+[Changed] Add link paramter and formatting for push notifications @michielmulders

config.js

@@ -19,5 +19,7 @@ module.exports = {
   testnetAPI: process.env.TESTNET_API_URL || 'http://localhost:9071',
   SENTRY_DSN: process.env.SENTRY_DSN || '',
   firebaseDatabaseUrl: process.env.PUSH_NOTIFICATIONS_DATABASE_URL || '',
+  firebasePushNotificationsFrontendUrl:
+    process.env.PUSH_NOTIFICATIONS_FRONTEND_URL || 'https://app.lunie.io',
   firebaseAdminKeySet: !!process.env.GOOGLE_APPLICATION_CREDENTIALS
 }

lib/block-listeners/cosmos-node-subscription.js

@@ -94,8 +94,6 @@ class CosmosNodeSubscription {
         validators: validatorMap
       })
       publishBlockAdded(this.network.id, block)
-      // TODO remove, only for demo purposes
-      // publishEvent(this.network.id, 'block', '', block)
 
       // For each transaction listed in a block we extract the relevant addresses. This is published to the network.
       // A GraphQL resolver is listening for these messages and sends the
@@ -104,7 +102,13 @@ class CosmosNodeSubscription {
       block.transactions.forEach(tx => {
         tx.involvedAddresses.forEach(address => {
           publishUserTransactionAddedV2(this.network.id, address, tx)
-          publishEvent(this.network.id, 'transaction', address, tx)
+          publishEvent(
+            this.network.id,
+            this.network.slug,
+            'transaction',
+            address,
+            tx
+          )
         })
       })
     } catch (error) {

lib/block-listeners/polkadot-node-subscription.js

@@ -153,16 +153,19 @@ class PolkadotNodeSubscription {
         }
       })
 
-      // TODO remove, only for demo purposes
-      // publishEvent(this.network.id, 'block', '', block)
-
       // For each transaction listed in a block we extract the relevant addresses. This is published to the network.
       // A GraphQL resolver is listening for these messages and sends the
       // transaction to each subscribed user.
       block.transactions.forEach(tx => {
         tx.involvedAddresses.forEach(address => {
           publishUserTransactionAddedV2(this.network.id, address, tx)
-          publishEvent(this.network.id, 'transaction', address, tx)
+          publishEvent(
+            this.network.id,
+            this.network.slug,
+            'transaction',
+            address,
+            tx
+          )
         })
       })
     } catch (error) {

lib/pushNotifications.js

@@ -33,7 +33,12 @@ async function pushToTopic(topic, event) {
     data: {
       event: JSON.stringify(event)
     },
-    topic
+    topic,
+    webpush: {
+      fcm_options: {
+        link: getPushLink(event.eventType, event.networkSlug)
+      }
+    }
   }
 
   try {
@@ -49,6 +54,15 @@ function getTopic({ networkId, eventType, resourceId }) {
   return [resourceId, eventType, networkId].filter(x => !!x).join('_')
 }
 
+function getPushLink(eventType, networkSlug) {
+  switch (eventType) {
+    case 'transaction':
+      return `${config.firebasePushNotificationsFrontendUrl}/${networkSlug}/transactions`
+    default:
+      return config.firebasePushNotificationsFrontendUrl
+  }
+}
+
 // users need to be registered individually per topic
 function subscribeUser(registrationToken, topics) {
   return Promise.all(

lib/subscriptions.js

@@ -53,10 +53,11 @@ module.exports = {
       })
     ),
 
-  publishEvent: (networkId, eventType, resourceId, properties) =>
+  publishEvent: (networkId, networkSlug, eventType, resourceId, properties) =>
     pubsub.publish(NEW_EVENT, {
       event: {
         networkId,
+        networkSlug,
         eventType,
         resourceId,
         properties: JSON.stringify(properties)