1+ import { describe , it , before , after } from 'mocha' ;
2+ import { expect } from 'chai' ;
3+ import fs from 'fs-extra' ;
4+ import path from 'node:path' ;
5+ import { spawn } from 'node:child_process' ;
6+ import * as url from 'node:url' ;
7+
8+ // eslint-disable-next-line unicorn/prefer-module
9+ const thisDir = url . fileURLToPath ( new URL ( '.' , import . meta. url || `file://${ __filename } ) ) ;
10+
11+ const testDir = path . join ( thisDir , 'testDataLifecycle' ) ;
12+ const testConfigPath = path . join ( testDir , 'iobroker.json' ) ;
13+
14+ /**
15+ * Test configuration for adapter lifecycle tests
16+ */
17+ const testConfig = {
18+ system : {
19+ memoryLimitMB : 0 ,
20+ hostname : '' ,
21+ instanceStartInterval : 2000
22+ } ,
23+ objects : {
24+ type : 'file' ,
25+ host : '127.0.0.1' ,
26+ port : 19011 ,
27+ dataDir : path . join ( testDir , 'objects' )
28+ } ,
29+ states : {
30+ type : 'file' ,
31+ host : '127.0.0.1' ,
32+ port : 19010 ,
33+ dataDir : path . join ( testDir , 'states' )
34+ } ,
35+ log : {
36+ level : 'warn' ,
37+ noStdout : true ,
38+ transport : {
39+ file1 : {
40+ type : 'file' ,
41+ enabled : false
42+ }
43+ }
44+ } ,
45+ dataDir : testDir ,
46+ plugins : { }
47+ } ;
48+
49+ /**
50+ * Helper function to run CLI commands for lifecycle tests
51+ */
52+ function runCliCommand ( args : string [ ] , timeout = 45000 ) : Promise < { exitCode : number | null ; stdout : string ; stderr : string } > {
53+ return new Promise ( ( resolve ) => {
54+ const nodeExecutable = process . execPath ;
55+ const cliScript = path . join ( thisDir , '../../controller/iobroker.js' ) ;
56+
57+ // Set environment variable for test config
58+ const env = { ...process . env , IOB_CONF_FILE : testConfigPath } ;
59+
60+ const child = spawn ( nodeExecutable , [ cliScript , ...args ] , {
61+ env,
62+ cwd : path . join ( thisDir , '../..' ) ,
63+ stdio : [ 'pipe' , 'pipe' , 'pipe' ]
64+ } ) ;
65+
66+ let stdout = '' ;
67+ let stderr = '' ;
68+
69+ child . stdout ?. on ( 'data' , ( data ) => {
70+ stdout += data . toString ( ) ;
71+ } ) ;
72+
73+ child . stderr ?. on ( 'data' , ( data ) => {
74+ stderr += data . toString ( ) ;
75+ } ) ;
76+
77+ const timeoutId = setTimeout ( ( ) => {
78+ child . kill ( 'SIGTERM' ) ;
79+ resolve ( { exitCode : - 1 , stdout, stderr : stderr + '\nTIMEOUT' } ) ;
80+ } , timeout ) ;
81+
82+ child . on ( 'close' , ( exitCode ) => {
83+ clearTimeout ( timeoutId ) ;
84+ resolve ( { exitCode, stdout, stderr } ) ;
85+ } ) ;
86+
87+ child . on ( 'error' , ( error ) => {
88+ clearTimeout ( timeoutId ) ;
89+ resolve ( { exitCode : - 1 , stdout, stderr : stderr + error . message } ) ;
90+ } ) ;
91+ } ) ;
92+ }
93+
94+ describe ( 'Adapter Lifecycle Tests' , function ( ) {
95+ this . timeout ( 120000 ) ; // Increase timeout for adapter operations
96+
97+ before ( async function ( ) {
98+ // Ensure test directory exists and is clean
99+ if ( await fs . pathExists ( testDir ) ) {
100+ await fs . remove ( testDir ) ;
101+ }
102+ await fs . ensureDir ( testDir ) ;
103+ await fs . ensureDir ( path . join ( testDir , 'objects' ) ) ;
104+ await fs . ensureDir ( path . join ( testDir , 'states' ) ) ;
105+
106+ // Write test configuration
107+ await fs . writeJSON ( testConfigPath , testConfig , { spaces : 2 } ) ;
108+ } ) ;
109+
110+ after ( async function ( ) {
111+ // Clean up test directory
112+ if ( await fs . pathExists ( testDir ) ) {
113+ await fs . remove ( testDir ) ;
114+ }
115+ } ) ;
116+
117+ describe ( 'Adapter and Instance Management Lifecycle' , function ( ) {
118+ // Use a test adapter that should be available - we'll use 'admin' as it's always present in ioBroker
119+ const testAdapter = 'admin' ;
120+
121+ it ( 'should successfully install an adapter (if not already installed)' , async function ( ) {
122+ // First check if adapter is already installed
123+ const listResult = await runCliCommand ( [ 'list' , 'adapters' ] ) ;
124+ expect ( listResult . exitCode ) . to . equal ( 0 ) ;
125+
126+ if ( ! listResult . stdout . includes ( testAdapter ) ) {
127+ // Try to install the adapter - this might fail in test environment, which is OK
128+ const installResult = await runCliCommand ( [ 'install' , testAdapter ] ) ;
129+ // We don't assert success here as it depends on network connectivity and repos
130+ console . log ( `Install result for ${ testAdapter } ${ installResult . exitCode } ) ;
131+ }
132+ } ) ;
133+
134+ it ( 'should list adapters and show installed adapters' , async function ( ) {
135+ const result = await runCliCommand ( [ 'list' , 'adapters' ] ) ;
136+
137+ expect ( result . exitCode ) . to . equal ( 0 ) ;
138+ // Should not timeout or crash
139+ expect ( result . stderr ) . to . not . include ( 'TIMEOUT' ) ;
140+ } ) ;
141+
142+ it ( 'should create an adapter instance (if adapter is available)' , async function ( ) {
143+ // First check if adapter exists
144+ const listResult = await runCliCommand ( [ 'list' , 'adapters' ] ) ;
145+
146+ if ( listResult . stdout . includes ( testAdapter ) ) {
147+ // Try to create an instance
148+ const result = await runCliCommand ( [ 'add' , testAdapter , '--enabled' , 'false' ] ) ;
149+
150+ // The command should complete without crashing
151+ expect ( result . stderr ) . to . not . include ( 'TIMEOUT' ) ;
152+
153+ // If successful, should show in instance list
154+ if ( result . exitCode === 0 ) {
155+ const instancesResult = await runCliCommand ( [ 'list' , 'instances' ] ) ;
156+ expect ( instancesResult . exitCode ) . to . equal ( 0 ) ;
157+ // Should show the instance we just created
158+ expect ( instancesResult . stdout ) . to . include ( `${ testAdapter } ) ;
159+ }
160+ } else {
161+ console . log ( `Skipping instance creation - ${ testAdapter } ) ;
162+ this . skip ( ) ;
163+ }
164+ } ) ;
165+
166+ it ( 'should list instances and show created instances' , async function ( ) {
167+ const result = await runCliCommand ( [ 'list' , 'instances' ] ) ;
168+
169+ expect ( result . exitCode ) . to . equal ( 0 ) ;
170+ expect ( result . stderr ) . to . not . include ( 'TIMEOUT' ) ;
171+ } ) ;
172+
173+ it ( 'should delete adapter instance (if one exists)' , async function ( ) {
174+ // List existing instances first
175+ const listResult = await runCliCommand ( [ 'list' , 'instances' ] ) ;
176+
177+ if ( listResult . stdout . includes ( `${ testAdapter } ) ) {
178+ // Extract instance number from output (assuming format adapter.X)
179+ const instanceMatch = listResult . stdout . match ( new RegExp ( `${ testAdapter } ) ) ;
180+
181+ if ( instanceMatch ) {
182+ const instanceNum = instanceMatch [ 1 ] ;
183+ const result = await runCliCommand ( [ 'del' , `${ testAdapter } ${ instanceNum } ] ) ;
184+
185+ // Should complete without crashing
186+ expect ( result . stderr ) . to . not . include ( 'TIMEOUT' ) ;
187+
188+ // Verify deletion by listing instances again
189+ const afterDeleteResult = await runCliCommand ( [ 'list' , 'instances' ] ) ;
190+ expect ( afterDeleteResult . exitCode ) . to . equal ( 0 ) ;
191+ }
192+ } else {
193+ console . log ( `Skipping instance deletion - no ${ testAdapter } ) ;
194+ this . skip ( ) ;
195+ }
196+ } ) ;
197+
198+ it ( 'should handle attempt to delete non-existent instance gracefully' , async function ( ) {
199+ const result = await runCliCommand ( [ 'del' , 'non-existent-adapter.99' ] ) ;
200+
201+ // Should not crash or timeout
202+ expect ( result . stderr ) . to . not . include ( 'TIMEOUT' ) ;
203+ // Should return with some error indication but not crash
204+ expect ( result . exitCode ) . to . not . equal ( - 1 ) ;
205+ } ) ;
206+
207+ it ( 'should handle attempt to add non-existent adapter gracefully' , async function ( ) {
208+ const result = await runCliCommand ( [ 'add' , 'definitely-non-existent-adapter-xyz123' ] ) ;
209+
210+ // Should not crash or timeout
211+ expect ( result . stderr ) . to . not . include ( 'TIMEOUT' ) ;
212+ // Should return error code for non-existent adapter
213+ expect ( result . exitCode ) . to . not . equal ( 0 ) ;
214+ } ) ;
215+ } ) ;
216+
217+ describe ( 'Database State Validation' , function ( ) {
218+ it ( 'should have clean database state after operations' , async function ( ) {
219+ // Verify that database operations completed successfully
220+ const objectsDir = path . join ( testDir , 'objects' ) ;
221+ const statesDir = path . join ( testDir , 'states' ) ;
222+
223+ expect ( await fs . pathExists ( objectsDir ) ) . to . be . true ;
224+ expect ( await fs . pathExists ( statesDir ) ) . to . be . true ;
225+
226+ // Check if database files were created during testing
227+ const objectFiles = await fs . readdir ( objectsDir ) ;
228+ const stateFiles = await fs . readdir ( statesDir ) ;
229+
230+ // Should have at least some files if operations occurred
231+ console . log ( `Objects directory contains ${ objectFiles . length } ) ;
232+ console . log ( `States directory contains ${ stateFiles . length } ) ;
233+ } ) ;
234+ } ) ;
235+ } ) ;
0 commit comments