Add check on thing association for device credentials connection

Squashed commit of the following:

commit d3085bb36b8b73abd9999ebb654fa5abd9b82cf4
Author: pirropirro <[email protected]>
Date:   Wed Jun 7 16:12:40 2023 +0200

    Bump version

commit 18c7baa39174142b79aa084bcc78d44a124723f7
Author: pirropirro <[email protected]>
Date:   Wed Jun 7 16:11:59 2023 +0200

    Add waiting to thing in device connection handler

Author: pirropirro

package.json

@@ -1,6 +1,6 @@
 {
   "name": "arduino-iot-js",
-  "version": "0.10.0",
+  "version": "0.11.0",
   "license": "GPLv3",
   "description": "JS module providing Arduino Create IoT Cloud Connection",
   "main": "./lib/index.js",

src/builder/CredentialsClientBuilder.ts

@@ -16,7 +16,8 @@ export class CredentialsClientBuilder implements ICloudClientBuilder {
 
   public async build(options: CredentialsOptions & CloudOptions): Promise<ISinglePropertyCloudClient> {
     const connection = await this.connection(options);
-    return new SinglePropertyCloudClient(connection, options, `/a/d/${options.deviceId}/e/i`);
+    const client = new SinglePropertyCloudClient(connection, options, `/a/d/${options.deviceId}/e/i`);
+    return client.getThing().then(() => client);
   }
 
   private async connection(options: CredentialsOptions & CloudOptions): Promise<IConnection> {

src/client/SinglePropertyCloudClient.ts

@@ -10,6 +10,9 @@ export class SinglePropertyCloudClient extends BaseCloudClient implements ISingl
   private subscription: Subscription;
   private propertiesCbs: { [key: string]: OnMessageCallback<any>[] } = {};
 
+  private onThingRejection: (reason: any) => void;
+  private onThingResponse: (value: string | PromiseLike<string>) => void;
+
   constructor(connection: IConnection, options: CloudOptions, private deviceTopic: string) {
     super(connection, options);
     this.observe(this.deviceTopic).subscribe(({ value }) => this.onThingIdReceived(value as string));
@@ -23,7 +26,14 @@ export class SinglePropertyCloudClient extends BaseCloudClient implements ISingl
   }
 
   private onThingIdReceived(thingId: string): void {
+    if (!thingId) {
+      if (this.onThingRejection) this.onThingRejection(new Error('Error: no thing associated'));
+      return;
+    }
+
+    console.log('found association to thing:', thingId);
     this.thingId = thingId;
+    if (this.onThingResponse) this.onThingResponse(thingId);
     this.subscription = this.observe(`/a/t/${this.thingId}/e/i`).subscribe((v) => {
       (this.propertiesCbs[v.propertyName] || []).forEach((cb) => cb(v.value));
     });
@@ -42,4 +52,14 @@ export class SinglePropertyCloudClient extends BaseCloudClient implements ISingl
     this.propertiesCbs[name] = this.propertiesCbs[name] || [];
     this.propertiesCbs[name].push(cb);
   }
+
+  public async getThing(): Promise<string> {
+    if (this.thingId) return this.thingId;
+
+    return new Promise<string>((res, rej) => {
+      this.onThingResponse = res;
+      this.onThingRejection = rej;
+      setTimeout(() => rej(new Error('Error: no thing associated')), 10000);
+    });
+  }
 }