Resolve circular dependency around Resends (cheap approach)

Author: mondoreale

packages/sdk/src/StreamrClient.ts

@@ -5,6 +5,7 @@
 import 'reflect-metadata'
 import 'timers'
 import './utils/PatchTsyringe'
+import './register'
 
 import { DhtAddress } from '@streamr/dht'
 import { ProxyDirection, StreamPartDeliveryOptions } from '@streamr/trackerless-network'

packages/sdk/src/register.ts

@@ -0,0 +1,7 @@
+import { container } from 'tsyringe'
+import { Resends } from './subscribe/Resends'
+import { Tokens } from './tokens'
+
+container.register(Tokens.Resends, {
+    useClass: Resends,
+})

packages/sdk/src/subscribe/MessagePipelineFactory.ts

@@ -10,8 +10,9 @@ import { StreamMessage } from '../protocol/StreamMessage'
 import { SignatureValidator } from '../signature/SignatureValidator'
 import { LoggerFactory } from '../utils/LoggerFactory'
 import { PushPipeline } from '../utils/PushPipeline'
-import { Resends } from './Resends'
+import type { Resends } from './Resends'
 import { MessagePipelineOptions, createMessagePipeline as _createMessagePipeline } from './messagePipeline'
+import { Tokens } from '../tokens'
 
 type MessagePipelineFactoryOptions = MarkOptional<Omit<MessagePipelineOptions,
     'resends' |
@@ -37,7 +38,7 @@ export class MessagePipelineFactory {
 
     /* eslint-disable indent */
     constructor(
-        @inject(delay(() => Resends)) resends: Resends,
+        @inject(Tokens.Resends) resends: Resends,
         streamStorageRegistry: StreamStorageRegistry,
         @inject(delay(() => StreamRegistry)) streamRegistry: StreamRegistry,
         signatureValidator: SignatureValidator,

packages/sdk/src/tokens.ts

@@ -0,0 +1,3 @@
+export const Tokens = {
+    Resends: Symbol('Resends')
+}