Warning message Product nn is not responding for nodes after the firs…

…t 20 nodes

Fixes #264

README.md

@@ -260,6 +260,10 @@ The values of the state provide multiple manipulation modes:
 	### __WORK IN PROGRESS__
 -->
 <!-- prettier-ignore -->
+### __WORK IN PROGRESS__
+
+-   (Michael Schroeder) [#264](https://github.com/MiSchroe/ioBroker.klf200/issues/264) Fixed an issue during startup of the adapter if more than 20 nodes are present.
+
 ### 1.3.4 (2024-11-19)
 
 -   (Michael Schroeder) [#259](https://github.com/MiSchroe/ioBroker.klf200/issues/259) Fixed issues found by the adapter checker.

src/klf200Adapter.ts

@@ -990,34 +990,34 @@ export class Klf200 extends utils.Adapter implements HasConnectionInterface, Has
 
 	private async checkResponsiveProducts(productIds: number[]): Promise<ResponsiveProductResult[]> {
 		const responsiveProducts: ResponsiveProductResult[] = [];
-		let sessionId = -1;
-		let handler: Disposable | undefined = undefined;
-		const handlerPromise = timeout(
-			new Promise<ResponsiveProductResult[]>((resolve, reject) => {
-				try {
-					handler = this._Connection?.on(
-						(event) => {
-							if (event instanceof GW_SESSION_FINISHED_NTF && event.SessionID === sessionId) {
-								handler?.dispose();
-								handler = undefined;
-								resolve(responsiveProducts.sort());
-							} else if (event instanceof GW_STATUS_REQUEST_NTF && event.SessionID === sessionId) {
-								responsiveProducts.push({
-									NodeID: event.NodeID,
-									FPs: event.ParameterData?.map((parameter) => parameter.ID) || [],
-								});
-							}
-						},
-						[GatewayCommand.GW_SESSION_FINISHED_NTF, GatewayCommand.GW_STATUS_REQUEST_NTF],
-					);
-				} catch (error) {
-					reject(error);
-				}
-			}),
-			30_000,
-		);
 		const chunkSize = 20;
 		for (let i = 0; i < Math.ceil(productIds.length / chunkSize); i++) {
+			let sessionId = -1;
+			let handler: Disposable | undefined = undefined;
+			const handlerPromise = timeout(
+				new Promise<ResponsiveProductResult[]>((resolve, reject) => {
+					try {
+						handler = this._Connection?.on(
+							(event) => {
+								if (event instanceof GW_SESSION_FINISHED_NTF && event.SessionID === sessionId) {
+									handler?.dispose();
+									handler = undefined;
+									resolve(responsiveProducts);
+								} else if (event instanceof GW_STATUS_REQUEST_NTF && event.SessionID === sessionId) {
+									responsiveProducts.push({
+										NodeID: event.NodeID,
+										FPs: event.ParameterData?.map((parameter) => parameter.ID) || [],
+									});
+								}
+							},
+							[GatewayCommand.GW_SESSION_FINISHED_NTF, GatewayCommand.GW_STATUS_REQUEST_NTF],
+						);
+					} catch (error) {
+						reject(error);
+					}
+				}),
+				30_000,
+			);
 			const statusRequestReq = new GW_STATUS_REQUEST_REQ(
 				productIds.slice(i * chunkSize, (i + 1) * chunkSize),
 				StatusType.RequestCurrentPosition,
@@ -1031,7 +1031,7 @@ export class Klf200 extends utils.Adapter implements HasConnectionInterface, Has
 				return Promise.reject(new Error(statusRequestCfm?.getError()));
 			}
 		}
-		return responsiveProducts;
+		return responsiveProducts.sort();
 	}
 
 	private async disposeOnConnectionClosed(): Promise<void> {

test/integration.ts

@@ -606,6 +606,16 @@ tests.integration(path.join(__dirname, ".."), {
 							expect(sut).to.have.property("val", 0);
 							expect(sut).to.have.property("ack", true);
 						});
+
+						it("Should have limitation states for product 30", async function () {
+							const sut = await Promise.resolve(
+								getState(harness, `${harness.adapterName}.0.products.30.limitationMPMinRaw`),
+							);
+							expect(sut).not.to.be.undefined;
+							expect(sut).not.to.be.null;
+							expect(sut).to.be.an("object");
+							expect(sut).to.have.property("val");
+						});
 					});
 				});
 			},