diff --git a/src/configurations/build.ts b/src/configurations/build.ts index cf7fc7861ad593421f76ca0341a2f6302c1259b1..53b1a0e1580e385b94c68ab33e463cdc8b66297a 100644 --- a/src/configurations/build.ts +++ b/src/configurations/build.ts @@ -14,6 +14,7 @@ const defaultPublishEndpoint = "/usp/endpoint"; const defaultSubscribeEndpoint = "/usp/controller"; const defaultIdEndpoint = "obuspa/EndpointID"; const defaultFromId = "proto::interop-usp-controller"; +const defaultConnectionTimeout = 5000; const idResolveTimeout = 5000; const fixId = (s: string) => s.split("+").join("%2B"); diff --git a/src/configurations/iopsys.ts b/src/configurations/iopsys.ts index 83fa68323d61bab1fa52f279ae9990b37da1d0e8..e51c9a7aa9f630aa14982d284ee28860ba5481f5 100644 --- a/src/configurations/iopsys.ts +++ b/src/configurations/iopsys.ts @@ -16,6 +16,7 @@ const isURL = (opts: ConnectionOptions): opts is URLConnectionOptions => "url" in opts; const connectClient = (opts: ConnectionOptions): ConnectionClient => { + console.log({ opts }) if (isURL(opts)) return mqttAsync.connectAsync( opts.url, @@ -24,9 +25,9 @@ const connectClient = (opts: ConnectionOptions): ConnectionClient => { else return opts.protocol?.startsWith("ws") ? (mqttAsync.connectAsync( - `${opts.protocol}://${opts.host}:${opts.port}`, - opts as any - ) as unknown as ConnectionClient) + `${opts.protocol}://${opts.host}:${opts.port}`, + opts as any + ) as unknown as ConnectionClient) : (mqttAsync.connectAsync(opts) as unknown as ConnectionClient); }; diff --git a/src/types.ts b/src/types.ts index 944bfbb79441b0063d654ee5d10e917a7c2e06ed..05b3aee79191d86cf43b765b252eac25fee1b3f3 100644 --- a/src/types.ts +++ b/src/types.ts @@ -450,6 +450,7 @@ export interface OtherConnectionOptions { cert?: CertType; closeOnDisconnect?: boolean; reconnectsBeforeClosing?: number; + connectTimeout?: number; } export type ConnectionOptions = URLConnectionOptions | HostConnectionOptions;