Use Sessions to send messages

ct-app/.configs/core_prod_config.yaml

@@ -33,12 +33,12 @@ flags:
 
     getTotalChannelFunds: 900
 
-    watchMessageQueue: On # should only be On / Off
-    relayedMessagesToDB: 120
+    observeMessageQueue: On # should only be On / Off
+    observeRelayedMessages: On # should only be On / Off
+    observeSessions: 60
 
   peer:
     messageRelayRequest: On # should only be On / Off
-    sentMessagesToDB: 120
 
 # =============================================================================
 # 
@@ -49,7 +49,6 @@ economicModel:
 
   legacy:
     proportion: 1.0
-
     apr: 12.5
 
     coefficients:
@@ -90,7 +89,7 @@ economicModel:
 # 
 # =============================================================================
 storage:
-  count: 100
+  count: 100 # wxHOPR
   timeout: 900 # seconds
 
 # =============================================================================
@@ -101,6 +100,7 @@ peer:
   initialSleep:
     mean: 30
     std: 2
+
 # =============================================================================
 # 
 # =============================================================================
@@ -109,6 +109,13 @@ channel:
   fundingAmount: 35
   maxAgeSeconds: 172800
 
+# =============================================================================
+# 
+# =============================================================================
+sessions:
+  packetSize: 462
+  numPackets: 10
+
 # =============================================================================
 # 
 # =============================================================================

ct-app/.configs/core_staging_config.yaml

@@ -33,12 +33,12 @@ flags:
 
     getTotalChannelFunds: 300
 
-    watchMessageQueue: On  # should only be On / Off
-    relayedMessagesToDB: 120
+    observeMessageQueue: On  # should only be On / Off
+    observeRelayedMessages: On # should only be On / Off
+    observeSessions: 60
 
   peer:
     messageRelayRequest: On # should only be On / Off
-    sentMessagesToDB: 120
 
 # =============================================================================
 # 
@@ -49,7 +49,7 @@ economicModel:
 
   legacy:
     proportion: 1.0
-    apr: 0.000005
+    apr: 0.0001
 
     coefficients:
       a: 1
@@ -110,6 +110,13 @@ channel:
   fundingAmount: 0.2
   maxAgeSeconds: 86400
 
+# =============================================================================
+# 
+# =============================================================================
+sessions:
+  packetSize: 462
+  numPackets: 10
+
 # =============================================================================
 # 
 # =============================================================================

ct-app/.env.example

@@ -1,10 +1,3 @@
-PGHOST="<PGHOST>"
-PGPORT="<PGPORT>"
-PGUSER="<PGUSER"
-PGPASSWORD="<PGPASSWORD"
-PGDATABASE="<PGDATABASE>"
-
-SUBGRAPH_API_KEY="<SUBGRAPH_API_KEY>"
-
+SUBGRAPH_API_KEY='<SUBGRAPH_API_KEY>'
 HOST_FORMAT='<HOST_FORMAT>'
 TOKEN='<TOKEN>'

ct-app/core/__main__.py

@@ -2,10 +2,10 @@
 import yaml
 from prometheus_client import start_http_server
 
-from .components import AsyncLoop, Base, Parameters, Utils
+from .baseclass import Base
+from .components import AsyncLoop, Parameters, Utils
 from .components.messages import MessageQueue
 from .core import Core
-from .model.database import DatabaseConnection
 from .node import Node
 
 
@@ -31,14 +31,12 @@ def main(configfile: str):
     else:
         Base.logger.info("Prometheus client started on port 8080")
 
-    DatabaseConnection.open(params.pg)
+    core = Core(nodes, params)
 
-    AsyncLoop.run(Core(nodes, params).start)
+    AsyncLoop.run(core.start, core.stop)
 
     MessageQueue.clear()
 
-    DatabaseConnection.close()
-
 
 if __name__ == "__main__":
     main()

ct-app/core/api/__init__.py

@@ -0,0 +1,4 @@
+from .hoprd_api import HoprdAPI
+from .protocol import Protocol
+
+__all__ = ["HoprdAPI", "Protocol"]

ct-app/core/components/channelstatus.py → ct-app/core/api/channelstatus.py

@@ -7,15 +7,15 @@ class ChannelStatus(Enum):
     Closed = "Closed"
 
     @property
-    def isPending(self):
+    def is_pending(self):
         return self == self.PendingToClose
 
     @property
-    def isOpen(self):
+    def is_open(self):
         return self == self.Open
 
     @property
-    def isClosed(self):
+    def is_closed(self):
         return self == self.Closed
 
     @classmethod