From 1e7c3b5eaf784cd8008ca8e5d80a1eff2c6dd2a1 Mon Sep 17 00:00:00 2001
From: Karim Stekelenburg <karim@animo.id>
Date: Thu, 14 Jan 2021 16:41:27 +0100
Subject: [PATCH] Add error handling to agent actions

Signed-off-by: Karim Stekelenburg <karim@animo.id>
---
 src/agent/AgentProvider.tsx                   |  6 +++-
 .../transporters/HTTPOutboundTransporter.ts   |  3 +-
 .../transporters/PollingInboundTransporter.ts | 29 +++++++++----------
 3 files changed, 19 insertions(+), 19 deletions(-)

diff --git a/src/agent/AgentProvider.tsx b/src/agent/AgentProvider.tsx
index 474a3d3..047500f 100644
--- a/src/agent/AgentProvider.tsx
+++ b/src/agent/AgentProvider.tsx
@@ -50,7 +50,11 @@ const AgentProvider = (props: AgentContextProps) => {
   }
 
   useEffect(() => {
-    initAgent()
+    try {
+      initAgent()
+    } catch (e) {
+      console.warn(e)
+    }
   }, [])
 
   return <AgentContext.Provider value={{ loading, agent }}>{props.children}</AgentContext.Provider>
diff --git a/src/agent/transporters/HTTPOutboundTransporter.ts b/src/agent/transporters/HTTPOutboundTransporter.ts
index b8fb9fb..9db9023 100644
--- a/src/agent/transporters/HTTPOutboundTransporter.ts
+++ b/src/agent/transporters/HTTPOutboundTransporter.ts
@@ -21,7 +21,6 @@ class HttpOutboundTransporter implements OutboundTransporter {
         })
 
         const data = await response.text()
-
         const wireMessage = JSON.parse(data)
         return wireMessage
       } else {
@@ -34,7 +33,7 @@ class HttpOutboundTransporter implements OutboundTransporter {
         })
       }
     } catch (e) {
-      // console.log('error sending message', JSON.stringify(e));
+      console.error('error sending message', e)
       throw e
     }
   }
diff --git a/src/agent/transporters/PollingInboundTransporter.ts b/src/agent/transporters/PollingInboundTransporter.ts
index e781bd5..55e73d6 100644
--- a/src/agent/transporters/PollingInboundTransporter.ts
+++ b/src/agent/transporters/PollingInboundTransporter.ts
@@ -13,19 +13,19 @@ class PollingInboundTransporter implements InboundTransporter {
   }
 
   public async registerMediator(agent: Agent): Promise<void> {
-    console.log('fetching mediator url')
-    const mediatorUrl = agent.getMediatorUrl()
-    console.log(`got mediator url: ${mediatorUrl}, fetching response`)
-    const mediatorInvitationUrlResponse = await axios.get(`${mediatorUrl}/invitation`)
-    console.log(`got invite response: ${mediatorInvitationUrlResponse}`)
-    const response = await axios.get(`${mediatorUrl}/`)
-    console.log(`got response: ${response}`)
-    const { verkey: mediatorVerkey } = response.data
-    await agent.routing.provision({
-      verkey: mediatorVerkey,
-      invitationUrl: mediatorInvitationUrlResponse.data,
-    })
-    this.pollDownloadMessages(agent)
+    try {
+      const mediatorUrl = agent.getMediatorUrl()
+      const mediatorInvitationUrlResponse = await axios.get(`${mediatorUrl}/invitation`)
+      const response = await axios.get(`${mediatorUrl}/`)
+      const { verkey: mediatorVerkey } = response.data
+      await agent.routing.provision({
+        verkey: mediatorVerkey,
+        invitationUrl: mediatorInvitationUrlResponse.data,
+      })
+      this.pollDownloadMessages(agent)
+    } catch (error) {
+      console.warn(error)
+    }
   }
 
   private pollDownloadMessages(agent: Agent): void {
@@ -35,9 +35,6 @@ class PollingInboundTransporter implements InboundTransporter {
         const messages = [...downloadedMessages]
         while (messages && messages.length > 0) {
           const message = messages.shift()
-          console.log('INBOUND TRANSPORT: RECEIVED MESSAGE')
-          console.log(message)
-
           await agent.receiveMessage(message)
         }
       },