Merge branch 'feat/send-message-limits' into 'dev'

feat(rosenet-node): make `sendMessage` code more defensive

Closes #78

See merge request ergo/rosen-bridge/rosenet!38

.changeset/cold-shirts-accept.md

@@ -0,0 +1,5 @@
+---
+'@rosen-bridge/rosenet-node': minor
+---
+
+Limit the number of concurrent pending messages, while also applying different timeouts during message sending

packages/rosenet-node/lib/constants.ts

@@ -4,11 +4,9 @@ export const RELAY_DISCOVERY_RESTART_INTERVAL = 10_000;
 export const ROSENET_DIRECT_PROTOCOL_V1 = '/rosenet/direct/1';
 export const DEFAULT_NODE_PORT = 55123;
 export const ACK_BYTE = 1;
-/**
- * Worst inter-continent ping RTT is around 250ms at the time of this commit,
- * and an ack requires 1 RTT. We use 2 RTT as the timeout for an ack.
- */
-export const ACK_TIMEOUT = 500;
-export const MESSAGE_RETRY_ATTEMPTS = 3;
-export const MESSAGE_RETRY_EXPONENT = 5;
-export const MESSAGE_RETRY_INITIAL_DELAY = 5000;
+export const MESSAGE_ROUNDTRIP_TIMEOUT = 1000;
+export const MESSAGE_RETRY_ATTEMPTS = 5;
+export const MESSAGE_RETRY_INITIAL_DELAY = 2000;
+export const MAX_CONCURRENT_ROSENET_DIRECT_MESSAGES_ALLOWED = 1000;
+export const MAX_CONCURRENT_ROSENET_DIRECT_MESSAGES_QUEUE_SIZE = 2000;
+export const ROSENET_DIRECT_STREAM_CREATION_TIMEOUT = 500;

packages/rosenet-node/lib/errors/RoseNetDirectError.ts

@@ -0,0 +1,18 @@
+import RoseNetNodeError from './RoseNetNodeError';
+
+export enum RoseNetDirectErrorType {
+  Timeout = 'Timeout',
+  InvalidAckChunks = 'InvalidAckChunks',
+  InvalidAckByte = 'InvalidAckByte',
+}
+
+class RoseNetDirectError extends RoseNetNodeError {
+  constructor(
+    message: string,
+    public type: RoseNetDirectErrorType,
+  ) {
+    super(message);
+  }
+}
+
+export default RoseNetDirectError;

packages/rosenet-node/lib/errors/RoseNetNodeError.ts

@@ -2,9 +2,12 @@ class RoseNetNodeError extends Error {
   constructor(
     public message: string,
     public stack = '',
+    cause?: unknown,
   ) {
     super(message);
 
+    this.cause = cause;
+
     if (stack) {
       this.stack = stack;
     } else {