Problems with HMS-800W-2T

[tiehfood]

I'm trying to get your project running with my HMS-800W-2T.
I disabled the software version check and have to use active communication, as no message arrives from the DTU in passive mode.
Although setting the dtuStepTime worked fine and also all basic infos are retrieved fine.
But I'm currently getting this error message:

NFO  | 2023-10-05 11:30:27 | [nioEventLoopGroup-2-1] dtu.DtuMessageDecoder (DtuMessageDecoder.java:101) - <-- end
INFO  | 2023-10-05 11:30:27 | [nioEventLoopGroup-2-1] dtu.SimpleMessageAggregator (SimpleMessageAggregator.java:40) - Next message, last=true
ERROR | 2023-10-05 11:30:27 | [nioEventLoopGroup-2-1] dtu.DtuClient$InboundHandler (DtuClient.java:188) - exceptionCaught: io.netty.handler.codec.MessageAggregationException: Message number mismatch
io.netty.handler.codec.DecoderException: io.netty.handler.codec.MessageAggregationException: Message number mismatch
	at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:98) ~[hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:327) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:299) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:722) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:658) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:584) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:496) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [hoymiles-dtu-1.0-SNAPSHOT-jar-with-dependencies.jar:?]
	at java.lang.Thread.run(Thread.java:833) [?:?]

[tiehfood]

The incoming messages look like:

INFO  | 2023-10-06 08:23:18 | [nioEventLoopGroup-2-1] dtu.DtuMessageDecoder (DtuMessageDecoder.java:67) - header=HM, msgId=41489, counter=1, dataCrc=50591, msgLen=139
INFO  | 2023-10-06 08:23:18 | [nioEventLoopGroup-2-1] dtu.DtuMessageDecoder (DtuMessageDecoder.java:97) - dtuSn: "----", time: 1696573397, packetCount: 1, ver: 1, sgsDatas {,   sn: ----,   ver: 1,   v: 2330,   freq: 4998,   p: 170,   i: 7,   pf: 999,   temp: 103,   wnum: 1,   crc: 28864,   link: 1,   miSignal: 8913086, }, pvDatas {,   sn: ----,   pi: 1,   v: 320,   i: 28,   p: 90,   et: 2321,   ed: 3,   code: 50921472, }, pvDatas {,   sn: ----,   pi: 2,   v: 327,   i: 27,   p: 89,   et: 2320,   ed: 3,   code: 50331648, }, 12: 170, 13: 6,
INFO  | 2023-10-06 08:22:09 | [nioEventLoopGroup-2-1] dtu.DtuMessageDecoder (DtuMessageDecoder.java:101) - <-- end
INFO  | 2023-10-06 08:22:09 | [nioEventLoopGroup-2-1] dtu.SimpleMessageAggregator (SimpleMessageAggregator.java:40) - Next message, last=true
ERROR | 2023-10-06 08:22:09 | [nioEventLoopGroup-2-1] dtu.DtuClient$InboundHandler (DtuClient.java:187) - exceptionCaught: io.netty.handler.codec.MessageAggregationException: Message number mismatch

The message Id maps to TAG_AppRealDataReq_X, which should be processed here router.register(DtuClientConstants.TAG_AppRealDataReq_X, event -> new RealDataEvent(realDataMapper.map((RealDataNew.RealReqDTO) event.getProto())));. But this step never seems to be reached

[tiehfood]

I got it working by removing channel.pipeline().addLast("aggregator", new DtuMessageAggregator(dtuCommand));. As the messages should never be as large to be split in two, this should be fine. But it's just a workaround

[culixnet]

Hi @tiehfood ,

I also own the HMS-800W and try to get it running within Homeassistant. How did you disable the version check?
How does your config look like?

Thx!

[tiehfood]

@culixnet as it's not an ideal solution, I don't opened up a PR. But this is what I've done:

• modify version check in DtuRepository.java (if (appInfo.getDtuInfo().getDtuSw() >= 260) ...)
• remove DtuMessageAggregator in the DtuClient.java like mentioned above (not ideal, a few times a day - maybe 4-5 time - a message arrives which might need this step. But this message is not needed to get the measurements and I could live with the error thrown in that case)
• I also changed something in the error handling, because it didn't reconnect properly the next day ... I might have to look this up. But this is not needed to get it running at lease

...
  "dtu": {
    "host": "HOYMILES_IP",
    "port": 10081,
    "watchdog_timeout": 300
  },
  "mqtt": {
    "host": "MQTT_IP",
    "port": 1883,
    "username": "YOUR_USERNAME",
    "password": "YOUR_PASSWORD"
  },
  "app": {
    "store_messages_in_excel": false,
    "mode": "active"
  }
...

In homeassistant you should see the device under the MQTT integration