Do every API call async

ct-app/.configs/core_prod_config.yaml

@@ -25,9 +25,9 @@ flags:
     retrieveChannels: 600
     retrieveBalances: 900
 
-    openChannels: 300
-    fundChannels: 300
-    closeOldChannels: 300
+    openChannels: 900
+    fundChannels: 1200
+    closeOldChannels: 900
     closePendingChannels: 1800
     closeIncomingChannels: Off
 
@@ -91,8 +91,8 @@ economicModel:
 # 
 # =============================================================================
 storage:
-  count: 25
-  timeout: 3600 # seconds
+  count: 100
+  timeout: 900 # seconds
 
 # =============================================================================
 # 

ct-app/.configs/core_staging_config.yaml

@@ -10,7 +10,7 @@ flags:
 
     connectedPeers: 120
     registeredNodes: 600
-    topology: 600
+    topology: 60
     allocations: 600
     EOABalances: 600
     NFTHolders: 600
@@ -22,23 +22,23 @@ flags:
   node:
     healthcheck: 60
     retrievePeers: 120
-    retrieveChannels: 600
+    retrieveChannels: 60
     retrieveBalances: 120
 
-    openChannels: 120
-    fundChannels: 120
-    closeOldChannels: 120
-    closePendingChannels: 120
+    openChannels: 900
+    fundChannels: 900
+    closeOldChannels: 900
+    closePendingChannels: 900
     closeIncomingChannels: Off
 
     getTotalChannelFunds: 300
 
     watchMessageQueue: On  # should only be On / Off
-    relayedMessagesToDB: Off
+    relayedMessagesToDB: 120
 
   peer:
     messageRelayRequest: On # should only be On / Off
-    sentMessagesToDB: Off
+    sentMessagesToDB: 120
 
 # =============================================================================
 # 
@@ -91,8 +91,8 @@ economicModel:
 # 
 # =============================================================================
 storage:
-  count: 100000
-  timeout: 43200 # seconds
+  count: 1000
+  timeout: 3600 # seconds
 
 # =============================================================================
 # 

ct-app/core/__main__.py

@@ -3,6 +3,7 @@
 from prometheus_client import start_http_server
 
 from .components import AsyncLoop, Base, Parameters, Utils
+from .components.messages import MessageQueue
 from .core import Core
 from .model.database import DatabaseConnection
 from .node import Node
@@ -34,6 +35,8 @@ def main(configfile: str):
 
     AsyncLoop.run(Core(nodes, params).start)
 
+    MessageQueue.clear()
+
     DatabaseConnection.close()
 
 

ct-app/core/components/api_types.py

@@ -0,0 +1,100 @@
+from typing import Any
+
+from .channelstatus import ChannelStatus
+
+
+def _convert(value: Any):
+    if value is None:
+        return None
+
+    try:
+        value = float(value)
+    except ValueError:
+        pass
+
+    try:
+        integer = int(value)
+        if integer == value:
+            value = integer
+
+    except ValueError:
+        pass
+
+    return value
+
+
+class ApiObject:
+    def __init__(self, data: dict):
+        for key, value in self.keys.items():
+            setattr(self, key, _convert(data.get(value, None)))
+
+        self.post_init()
+
+    def post_init(self):
+        pass
+
+    def __str__(self):
+        return str(self.__dict__)
+
+    def __repr__(self):
+        return str(self)
+
+
+class Addresses(ApiObject):
+    keys = {"hopr": "hopr", "native": "native"}
+
+
+class Balances(ApiObject):
+    keys = {
+        "hopr": "hopr",
+        "native": "native",
+        "safe_native": "safeNative",
+        "safe_hopr": "safeHopr",
+    }
+
+
+class Infos(ApiObject):
+    keys = {"hopr_node_safe": "hoprNodeSafe"}
+
+
+class ConnectedPeer(ApiObject):
+    keys = {"address": "peerAddress", "peer_id": "peerId", "version": "reportedVersion"}
+
+
+class Channel(ApiObject):
+    keys = {
+        "balance": "balance",
+        "id": "channelId",
+        "destination_address": "destinationAddress",
+        "destination_peer_id": "destinationPeerId",
+        "source_address": "sourceAddress",
+        "source_peer_id": "sourcePeerId",
+        "status": "status",
+    }
+
+    def post_init(self):
+        self.status = ChannelStatus.fromString(self.status)
+
+
+class TicketPrice(ApiObject):
+    keys = {"value": "price"}
+
+    def post_init(self):
+        self.value = float(self.value) / 1e18
+
+
+class OpenedChannel(ApiObject):
+    keys = {"channel_id": "channelId", "receipt": "transactionReceipt"}
+
+
+class Channels:
+    def __init__(self, data: dict):
+        self.all = [Channel(channel) for channel in data.get("all", [])]
+        self.incoming = []
+        self.outgoing = []
+
+    def __str__(self):
+        return str(self.__dict__)
+
+    def __repr__(self):
+        return str(self)

ct-app/core/components/decorators.py

@@ -83,9 +83,9 @@ async def wrapper(self, *args, **kwargs):
             delay = None
 
         if delay == 0:
-            self.info(f"Running `{params_raw[index]}` continuously")
+            self.info(f"Running `{func.__name__}` continuously")
         elif delay is not None:
-            self.info(f"Running `{params_raw[index]}` every {delay} seconds")
+            self.info(f"Running `{func.__name__}` every {delay} seconds")
 
         while self.running:
             await func(self, *args, **kwargs)