Skip to content
Snippets Groups Projects
Commit 5b6a68bb authored by Marin Karamihalev's avatar Marin Karamihalev
Browse files

added connectTimeout option to connect, untested

parent add843e9
No related branches found
No related tags found
No related merge requests found
...@@ -14,6 +14,7 @@ const defaultPublishEndpoint = "/usp/endpoint"; ...@@ -14,6 +14,7 @@ const defaultPublishEndpoint = "/usp/endpoint";
const defaultSubscribeEndpoint = "/usp/controller"; const defaultSubscribeEndpoint = "/usp/controller";
const defaultIdEndpoint = "obuspa/EndpointID"; const defaultIdEndpoint = "obuspa/EndpointID";
const defaultFromId = "proto::interop-usp-controller"; const defaultFromId = "proto::interop-usp-controller";
const defaultConnectionTimeout = 5000;
const idResolveTimeout = 5000; const idResolveTimeout = 5000;
const fixId = (s: string) => s.split("+").join("%2B"); const fixId = (s: string) => s.split("+").join("%2B");
......
...@@ -16,6 +16,7 @@ const isURL = (opts: ConnectionOptions): opts is URLConnectionOptions => ...@@ -16,6 +16,7 @@ const isURL = (opts: ConnectionOptions): opts is URLConnectionOptions =>
"url" in opts; "url" in opts;
const connectClient = (opts: ConnectionOptions): ConnectionClient => { const connectClient = (opts: ConnectionOptions): ConnectionClient => {
console.log({ opts })
if (isURL(opts)) if (isURL(opts))
return mqttAsync.connectAsync( return mqttAsync.connectAsync(
opts.url, opts.url,
...@@ -24,9 +25,9 @@ const connectClient = (opts: ConnectionOptions): ConnectionClient => { ...@@ -24,9 +25,9 @@ const connectClient = (opts: ConnectionOptions): ConnectionClient => {
else else
return opts.protocol?.startsWith("ws") return opts.protocol?.startsWith("ws")
? (mqttAsync.connectAsync( ? (mqttAsync.connectAsync(
`${opts.protocol}://${opts.host}:${opts.port}`, `${opts.protocol}://${opts.host}:${opts.port}`,
opts as any opts as any
) as unknown as ConnectionClient) ) as unknown as ConnectionClient)
: (mqttAsync.connectAsync(opts) as unknown as ConnectionClient); : (mqttAsync.connectAsync(opts) as unknown as ConnectionClient);
}; };
......
...@@ -444,6 +444,7 @@ export interface OtherConnectionOptions { ...@@ -444,6 +444,7 @@ export interface OtherConnectionOptions {
cert?: CertType; cert?: CertType;
closeOnDisconnect?: boolean; closeOnDisconnect?: boolean;
reconnectsBeforeClosing?: number; reconnectsBeforeClosing?: number;
connectTimeout?: number;
} }
export type ConnectionOptions = URLConnectionOptions | HostConnectionOptions; export type ConnectionOptions = URLConnectionOptions | HostConnectionOptions;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment