fix(ignore): import using node: prefix for built-in

src/adapter/adapter.ts

@@ -1,4 +1,4 @@
-import events from 'events';
+import events from 'node:events';
 
 import * as Models from '../models';
 import {BroadcastAddress} from '../zspec/enums';
@@ -17,7 +17,14 @@ interface AdapterEventMap {
     deviceLeave: [payload: AdapterEvents.DeviceLeavePayload];
 }
 
-abstract class Adapter extends events.EventEmitter<AdapterEventMap> {
+type AdapterConstructor = new (
+    networkOptions: TsType.NetworkOptions,
+    serialPortOptions: TsType.SerialPortOptions,
+    backupPath: string,
+    adapterOptions: TsType.AdapterOptions,
+) => Adapter;
+
+export abstract class Adapter extends events.EventEmitter<AdapterEventMap> {
     public hasZdoMessageOverhead: boolean;
     public manufacturerID: Zcl.ManufacturerCode;
     protected networkOptions: TsType.NetworkOptions;
@@ -50,28 +57,25 @@ abstract class Adapter extends events.EventEmitter<AdapterEventMap> {
         backupPath: string,
         adapterOptions: TsType.AdapterOptions,
     ): Promise<Adapter> {
-        const {ZStackAdapter} = await import('./z-stack/adapter');
-        const {DeconzAdapter} = await import('./deconz/adapter');
-        const {ZiGateAdapter} = await import('./zigate/adapter');
-        const {EZSPAdapter} = await import('./ezsp/adapter');
-        const {EmberAdapter} = await import('./ember/adapter');
-        const {ZBOSSAdapter} = await import('./zboss/adapter');
         const adapterLookup = {
-            zstack: ZStackAdapter,
-            deconz: DeconzAdapter,
-            zigate: ZiGateAdapter,
-            ezsp: EZSPAdapter,
-            ember: EmberAdapter,
-            zboss: ZBOSSAdapter,
+            deconz: ['./deconz/adapter/deconzAdapter', 'DeconzAdapter'],
+            ember: ['./ember/adapter/emberAdapter', 'EmberAdapter'],
+            ezsp: ['./ezsp/adapter/ezspAdapter', 'EZSPAdapter'],
+            zstack: ['./z-stack/adapter/zStackAdapter', 'ZStackAdapter'],
+            zboss: ['./zboss/adapter/zbossAdapter', 'ZBOSSAdapter'],
+            zigate: ['./zigate/adapter/zigateAdapter', 'ZiGateAdapter'],
         };
-
         const [adapter, path] = await discoverAdapter(serialPortOptions.adapter, serialPortOptions.path);
+        const detectedAdapter = adapterLookup[adapter];
 
-        if (adapterLookup[adapter]) {
+        if (detectedAdapter) {
             serialPortOptions.adapter = adapter;
             serialPortOptions.path = path;
 
-            return new adapterLookup[adapter](networkOptions, serialPortOptions, backupPath, adapterOptions);
+            const adapterModule = await import(detectedAdapter[0]);
+            const AdapterCtor = adapterModule[detectedAdapter[1]] as AdapterConstructor;
+
+            return new AdapterCtor(networkOptions, serialPortOptions, backupPath, adapterOptions);
         } else {
             throw new Error(`Adapter '${adapter}' does not exists, possible options: ${Object.keys(adapterLookup).join(', ')}`);
         }

src/adapter/adapterDiscovery.ts

@@ -1,5 +1,5 @@
-import assert from 'assert';
-import {platform} from 'os';
+import assert from 'node:assert';
+import {platform} from 'node:os';
 
 import {PortInfo} from '@serialport/bindings-cpp';
 import {Bonjour, Service} from 'bonjour-service';

src/adapter/deconz/adapter/deconzAdapter.ts

@@ -2,7 +2,7 @@
 
 import Device from '../../../controller/model/device';
 import * as Models from '../../../models';
-import {Wait, Waitress} from '../../../utils';
+import {wait, Waitress} from '../../../utils';
 import {logger} from '../../../utils/logger';
 import * as ZSpec from '../../../zspec';
 import {BroadcastAddress} from '../../../zspec/enums';
@@ -28,7 +28,7 @@ interface WaitressMatcher {
     direction: number;
 }
 
-class DeconzAdapter extends Adapter {
+export class DeconzAdapter extends Adapter {
     private driver: Driver;
     private openRequestsQueue: WaitForDataRequest[];
     private transactionID: number;
@@ -156,7 +156,7 @@ class DeconzAdapter extends Adapter {
 
             try {
                 await this.driver.writeParameterRequest(PARAM.PARAM.Network.CHANNEL_MASK, setChannelMask);
-                await Wait(500);
+                await wait(500);
                 changed = true;
             } catch (error) {
                 logger.debug('Could not set channel: ' + error, NS);
@@ -172,7 +172,7 @@ class DeconzAdapter extends Adapter {
 
             try {
                 await this.driver.writeParameterRequest(PARAM.PARAM.Network.PAN_ID, this.networkOptions.panID);
-                await Wait(500);
+                await wait(500);
                 changed = true;
             } catch (error) {
                 logger.debug('Could not set panid: ' + error, NS);
@@ -192,7 +192,7 @@ class DeconzAdapter extends Adapter {
 
             try {
                 await this.driver.writeParameterRequest(PARAM.PARAM.Network.APS_EXT_PAN_ID, this.networkOptions.extendedPanID!);
-                await Wait(500);
+                await wait(500);
                 changed = true;
             } catch (error) {
                 logger.debug('Could not set extended panid: ' + error, NS);
@@ -208,7 +208,7 @@ class DeconzAdapter extends Adapter {
 
             try {
                 await this.driver.writeParameterRequest(PARAM.PARAM.Network.NETWORK_KEY, this.networkOptions.networkKey!);
-                await Wait(500);
+                await wait(500);
                 changed = true;
             } catch (error) {
                 logger.debug('Could not set network key: ' + error, NS);
@@ -217,9 +217,9 @@ class DeconzAdapter extends Adapter {
 
         if (changed) {
             await this.driver.changeNetworkStateRequest(PARAM.PARAM.Network.NET_OFFLINE);
-            await Wait(2000);
+            await wait(2000);
             await this.driver.changeNetworkStateRequest(PARAM.PARAM.Network.NET_CONNECTED);
-            await Wait(2000);
+            await wait(2000);
         }
 
         // write endpoints
@@ -754,5 +754,3 @@ class DeconzAdapter extends Adapter {
         );
     }
 }
-
-export default DeconzAdapter;

src/adapter/deconz/driver/driver.ts

@@ -1,7 +1,7 @@
 /* istanbul ignore file */
 
-import events from 'events';
-import net from 'net';
+import events from 'node:events';
+import net from 'node:net';
 
 import slip from 'slip';
 

src/adapter/deconz/driver/frameParser.ts

@@ -1,6 +1,6 @@
 /* istanbul ignore file */
 
-import {EventEmitter} from 'stream';
+import {EventEmitter} from 'node:events';
 
 import {logger} from '../../../utils/logger';
 import * as Zdo from '../../../zspec/zdo';

src/adapter/deconz/driver/parser.ts

@@ -1,6 +1,6 @@
 /* istanbul ignore file */
 
-import {Transform, TransformCallback} from 'stream';
+import {Transform, TransformCallback} from 'node:stream';
 
 import slip from 'slip';
 
@@ -34,7 +34,7 @@ class Parser extends Transform {
         logger.debug(`<-- error '${error}'`, NS);
     }
 
-    public _transform(chunk: Buffer, _: string, cb: TransformCallback): void {
+    public override _transform(chunk: Buffer, _: string, cb: TransformCallback): void {
         //logger.debug(`<-- [${[...chunk]}]`, NS);
         this.decoder.decode(chunk);
         //logger.debug(`<-- [${[...chunk]}]`, NS);

src/adapter/deconz/driver/writer.ts

@@ -1,6 +1,6 @@
 /* istanbul ignore file */
 
-import * as stream from 'stream';
+import * as stream from 'node:stream';
 
 import slip from 'slip';
 
@@ -16,7 +16,7 @@ class Writer extends stream.Readable {
         this.push(buffer);
     }
 
-    public _read(): void {}
+    public override _read(): void {}
 }
 
 export default Writer;

src/adapter/ember/adapter/emberAdapter.ts

@@ -1,12 +1,12 @@
-import {randomBytes} from 'crypto';
-import {existsSync, readFileSync, renameSync} from 'fs';
-import path from 'path';
+import {randomBytes} from 'node:crypto';
+import {existsSync, readFileSync, renameSync} from 'node:fs';
+import path from 'node:path';
 
 import equals from 'fast-deep-equal/es6';
 
 import {Adapter, TsType} from '../..';
 import {Backup, UnifiedBackupStorage} from '../../../models';
-import {BackupUtils, Queue, Wait} from '../../../utils';
+import {BackupUtils, Queue, wait} from '../../../utils';
 import {logger} from '../../../utils/logger';
 import * as ZSpec from '../../../zspec';
 import {EUI64, ExtendedPanId, NodeId, PanId} from '../../../zspec/tstypes';
@@ -921,7 +921,7 @@ export class EmberAdapter extends Adapter {
                     '[INIT TC] Leave network',
                 );
 
-                await Wait(200); // settle down
+                await wait(200); // settle down
 
                 action = NetworkInitAction.LEFT;
             }
@@ -1271,7 +1271,7 @@ export class EmberAdapter extends Adapter {
 
             // XXX: this will block other requests for a while, but should ensure the key propagates without interference?
             //      could also stop dispatching entirely and do this outside the queue if necessary/better
-            await Wait(BROADCAST_NETWORK_KEY_SWITCH_WAIT_TIME);
+            await wait(BROADCAST_NETWORK_KEY_SWITCH_WAIT_TIME);
 
             status = await this.ezsp.ezspBroadcastNetworkKeySwitch();
 
@@ -2009,9 +2009,9 @@ export class EmberAdapter extends Adapter {
                         `~x~> [ZCL to=${ieeeAddr}:${networkAddress} apsFrame=${JSON.stringify(apsFrame)}] Failed to send request with status=${SLStatus[status]}.`,
                     );
                 } else if (status === SLStatus.ZIGBEE_MAX_MESSAGE_LIMIT_REACHED || status === SLStatus.BUSY) {
-                    await Wait(QUEUE_BUSY_DEFER_MSEC);
+                    await wait(QUEUE_BUSY_DEFER_MSEC);
                 } else if (status === SLStatus.NETWORK_DOWN) {
-                    await Wait(QUEUE_NETWORK_DOWN_DEFER_MSEC);
+                    await wait(QUEUE_NETWORK_DOWN_DEFER_MSEC);
                 } else {
                     throw new Error(
                         `~x~> [ZCL to=${ieeeAddr}:${networkAddress} apsFrame=${JSON.stringify(apsFrame)}] Failed to send request with status=${SLStatus[status]}.`,
@@ -2075,7 +2075,7 @@ export class EmberAdapter extends Adapter {
             }
 
             // NOTE: since ezspMessageSentHandler could take a while here, we don't block, it'll just be logged if the delivery failed
-            await Wait(QUEUE_BUSY_DEFER_MSEC);
+            await wait(QUEUE_BUSY_DEFER_MSEC);
         });
     }
 
@@ -2117,7 +2117,7 @@ export class EmberAdapter extends Adapter {
             }
 
             // NOTE: since ezspMessageSentHandler could take a while here, we don't block, it'll just be logged if the delivery failed
-            await Wait(QUEUE_BUSY_DEFER_MSEC);
+            await wait(QUEUE_BUSY_DEFER_MSEC);
         });
     }
 
@@ -2246,7 +2246,7 @@ export class EmberAdapter extends Adapter {
             }
 
             // let adapter settle down
-            await Wait(QUEUE_NETWORK_DOWN_DEFER_MSEC);
+            await wait(QUEUE_NETWORK_DOWN_DEFER_MSEC);
 
             this.interpanLock = false;
         });

src/adapter/ember/ezsp/ezsp.ts

@@ -1,6 +1,6 @@
 /* istanbul ignore file */
 
-import EventEmitter from 'events';
+import EventEmitter from 'node:events';
 
 import {Queue} from '../../../utils';
 import {logger} from '../../../utils/logger';

src/adapter/ember/uart/ash.ts

@@ -1,9 +1,9 @@
 /* istanbul ignore file */
 
-import {Socket} from 'net';
-import {EventEmitter} from 'stream';
+import {EventEmitter} from 'node:events';
+import {Socket} from 'node:net';
 
-import {Wait} from '../../../utils';
+import {wait} from '../../../utils';
 import {logger} from '../../../utils/logger';
 import {SerialPort} from '../../serialPort';
 import SocketPortUtils from '../../socketPortUtils';
@@ -640,7 +640,7 @@ export class UartAsh extends EventEmitter<UartAshEventMap> {
             }
 
             logger.debug(`Waiting for RSTACK... ${i}/${CONFIG_TIME_RST}`, NS);
-            await Wait(CONFIG_TIME_RST_CHECK);
+            await wait(CONFIG_TIME_RST_CHECK);
         }
 
         return EzspStatus.HOST_FATAL_ERROR;

src/adapter/ember/uart/parser.ts

@@ -1,6 +1,6 @@
 /* istanbul ignore file */
 
-import {Transform, TransformCallback, TransformOptions} from 'stream';
+import {Transform, TransformCallback, TransformOptions} from 'node:stream';
 
 // import {logger} from '../../../utils/logger';
 import {AshReservedByte} from './enums';
@@ -16,7 +16,7 @@ export class AshParser extends Transform {
         this.buffer = Buffer.alloc(0);
     }
 
-    _transform(chunk: Buffer, encoding: BufferEncoding, cb: TransformCallback): void {
+    override _transform(chunk: Buffer, encoding: BufferEncoding, cb: TransformCallback): void {
         let data = Buffer.concat([this.buffer, chunk]);
         let position: number;
 
@@ -37,7 +37,7 @@ export class AshParser extends Transform {
         cb();
     }
 
-    _flush(cb: TransformCallback): void {
+    override _flush(cb: TransformCallback): void {
         this.push(this.buffer);
 
         this.buffer = Buffer.alloc(0);

src/adapter/ember/uart/writer.ts

@@ -1,6 +1,6 @@
 /* istanbul ignore file */
 
-import {Readable, ReadableOptions} from 'stream';
+import {Readable, ReadableOptions} from 'node:stream';
 
 // import {logger} from '../../../utils/logger';
 
@@ -49,5 +49,5 @@ export class AshWriter extends Readable {
         }
     }
 
-    public _read(): void {}
+    public override _read(): void {}
 }

src/adapter/events.ts

@@ -1,13 +1,13 @@
 import {Header as ZclHeader} from '../zspec/zcl';
 
-type DeviceJoinedPayload = {
+export type DeviceJoinedPayload = {
     networkAddress: number;
     ieeeAddr: string;
 };
 
-type DeviceLeavePayload = {networkAddress?: number; ieeeAddr: string} | {networkAddress: number; ieeeAddr?: string};
+export type DeviceLeavePayload = {networkAddress?: number; ieeeAddr: string} | {networkAddress: number; ieeeAddr?: string};
 
-interface ZclPayload {
+export interface ZclPayload {
     clusterID: number;
     address: number | string;
     header: ZclHeader | undefined;
@@ -19,5 +19,3 @@ interface ZclPayload {
     wasBroadcast: boolean;
     destinationEndpoint: number;
 }
-
-export {DeviceJoinedPayload, ZclPayload, DeviceLeavePayload};

src/adapter/ezsp/adapter/backup.ts

@@ -1,6 +1,6 @@
 /* istanbul ignore file */
 
-import * as fs from 'fs';
+import * as fs from 'node:fs';
 
 import * as Models from '../../../models';
 import {BackupUtils} from '../../../utils';