@@ -317,7 +317,7 @@ tests.integration(path.join(__dirname, '..'), {
317317 resolve ( ) ;
318318 } ) ;
319319 } ) ;
320- } ) . timeout ( 20000 ) ;
320+ } ) . timeout ( 25000 ) ;
321321
322322 it ( 'Plug states should be created' , async ( ) => {
323323 //await harness.objects.delObject('ecoflow-mqtt.0.HW52ZDH4SF12345.plug_heartbeat.brightness');
@@ -373,17 +373,35 @@ tests.integration(path.join(__dirname, '..'), {
373373 }
374374 }
375375 } ) ;
376+ it ( 'Stream AC states should be created' , async ( ) => {
377+ //await harness.objects.delObject('ecoflow-mqtt.0.BK32Z123456789012.inverter_heartbeat.permanentWatts');
378+ for ( let channel in streamacstates [ 'deviceStatesDict' ] [ 'stream_ac' ] ) {
379+ for ( let state in streamacstates [ 'deviceStatesDict' ] [ 'stream_ac' ] [ channel ] ) {
380+ await harness . objects . getObject (
381+ 'ecoflow-mqtt.0.BK32Z123456789012.' + channel + '.' + state ,
382+ function ( err , obj ) {
383+ if ( err ) console . error ( 'stream ac TEST' + channel + '.' + state + ' -> ' + err ) ;
384+
385+ if ( ! obj ) {
386+ console . error ( 'stream ac state ' + channel + '.' + state + ' not set' ) ;
387+ }
388+ expect ( obj ) . to . exist ;
389+ } ,
390+ ) ;
391+ }
392+ }
393+ } ) ;
376394 it ( 'Stream AC pro states should be created' , async ( ) => {
377395 //await harness.objects.delObject('ecoflow-mqtt.0.HW51ZOH5SF412345.inverter_heartbeat.permanentWatts');
378396 for ( let channel in streamacstates [ 'deviceStatesDict' ] [ 'stream_ac_pro' ] ) {
379397 for ( let state in streamacstates [ 'deviceStatesDict' ] [ 'stream_ac_pro' ] [ channel ] ) {
380398 await harness . objects . getObject (
381399 'ecoflow-mqtt.0.BK31Z123456789012.' + channel + '.' + state ,
382400 function ( err , obj ) {
383- if ( err ) console . error ( 'stream ac TEST' + channel + '.' + state + ' -> ' + err ) ;
401+ if ( err ) console . error ( 'stream ac pro TEST' + channel + '.' + state + ' -> ' + err ) ;
384402
385403 if ( ! obj ) {
386- console . error ( 'stream ac state ' + channel + '.' + state + ' not set' ) ;
404+ console . error ( 'stream ac pro state ' + channel + '.' + state + ' not set' ) ;
387405 }
388406 expect ( obj ) . to . exist ;
389407 } ,
@@ -589,6 +607,29 @@ tests.integration(path.join(__dirname, '..'), {
589607 }
590608 }
591609 } ) ;
610+ it ( 'Delta3 Max plus should be created' , async ( ) => {
611+ //await harness.objects.delObject('ecoflow-mqtt.0.D3M1ZE1234567890.mppt.');
612+ for ( let channel in delta3plusstates [ 'deviceStatesDict' ] [ 'delta3maxplus' ] ) {
613+ for ( let state in delta3plusstates [ 'deviceStatesDict' ] [ 'delta3maxplus' ] [ channel ] ) {
614+ if (
615+ delta3plusstates [ 'deviceStatesDict' ] [ 'delta3maxplus' ] [ channel ] [ state ] [ 'entity' ] !== 'icon'
616+ ) {
617+ await harness . objects . getObject (
618+ 'ecoflow-mqtt.0.D3M1ZE1234567890.' + channel + '.' + state ,
619+ function ( err , obj ) {
620+ if ( err )
621+ console . error ( 'delta3max plus TEST' + channel + '.' + state + ' -> ' + err ) ;
622+
623+ if ( ! obj ) {
624+ console . error ( 'delta3max plus state ' + channel + '.' + state + ' not set' ) ;
625+ }
626+ expect ( obj ) . to . exist ;
627+ } ,
628+ ) ;
629+ }
630+ }
631+ }
632+ } ) ;
592633 it ( 'River2Pro should be created' , async ( ) => {
593634 //await harness.objects.delObject('ecoflow-mqtt.0.R621ZEB4XEC12345.mppt.');
594635 for ( let channel in river2prostates [ 'deviceStatesDict' ] [ 'river2pro' ] ) {
@@ -768,7 +809,26 @@ tests.integration(path.join(__dirname, '..'), {
768809 }
769810 }
770811 } ) ;
812+ it ( 'Glacier55L should be created' , async ( ) => {
813+ //await harness.objects.delObject('ecoflow-mqtt.0.RF45Z11234567.mppt.');
814+ for ( let channel in glacierstates [ 'deviceStatesDict' ] [ 'glacier55' ] ) {
815+ for ( let state in glacierstates [ 'deviceStatesDict' ] [ 'glacier55' ] [ channel ] ) {
816+ if ( glacierstates [ 'deviceStatesDict' ] [ 'glacier55' ] [ channel ] [ state ] [ 'entity' ] !== 'icon' ) {
817+ await harness . objects . getObject (
818+ 'ecoflow-mqtt.0.RF45Z11234567.' + channel + '.' + state ,
819+ function ( err , obj ) {
820+ if ( err ) console . error ( 'glacier55 TEST' + channel + '.' + state + ' -> ' + err ) ;
771821
822+ if ( ! obj ) {
823+ console . error ( 'glacier55 state ' + channel + '.' + state + ' not set' ) ;
824+ }
825+ expect ( obj ) . to . exist ;
826+ } ,
827+ ) ;
828+ }
829+ }
830+ }
831+ } ) ;
772832 it ( 'Generator should be created' , async ( ) => {
773833 //await harness.objects.delObject('ecoflow-mqtt.0.BX11ZFB5EF412345.mppt.');
774834 for ( let channel in generatorstates [ 'deviceStatesDict' ] [ 'generator' ] ) {
0 commit comments