From bcb8d551260ab71f255630ffec5d0bd34543ed71 Mon Sep 17 00:00:00 2001
From: Jarno Rankinen <jarno@oranki.net>
Date: Thu, 2 Mar 2023 13:36:49 +0200
Subject: [PATCH] gh-10 0.0.7 Check that only one of mutex coils is 1 at a time

---
 enervent-ctrl-go/main.go                |  2 +-
 enervent-ctrl-go/pingvinKL/pingvinKL.go | 30 ++++++++++++++++---------
 2 files changed, 21 insertions(+), 11 deletions(-)

diff --git a/enervent-ctrl-go/main.go b/enervent-ctrl-go/main.go
index 8090862..ec7fb81 100644
--- a/enervent-ctrl-go/main.go
+++ b/enervent-ctrl-go/main.go
@@ -19,7 +19,7 @@ import (
 var static embed.FS
 
 var (
-	version = "0.0.6"
+	version = "0.0.7"
 	pingvin pingvinKL.PingvinKL
 	DEBUG   = false
 )
diff --git a/enervent-ctrl-go/pingvinKL/pingvinKL.go b/enervent-ctrl-go/pingvinKL/pingvinKL.go
index 12edee8..2e64ccd 100644
--- a/enervent-ctrl-go/pingvinKL/pingvinKL.go
+++ b/enervent-ctrl-go/pingvinKL/pingvinKL.go
@@ -278,6 +278,9 @@ func (p *PingvinKL) WriteCoil(n uint16, val bool) bool {
 	handler := p.getHandler()
 	p.buslock.Lock()
 	err := handler.Connect()
+	if val {
+		p.checkMutexCoils(n, handler)
+	}
 	if err != nil {
 		log.Println("WARNING: WriteCoil: failed to connect handler")
 		return false
@@ -363,16 +366,23 @@ func (p *PingvinKL) WriteCoils(startaddr uint16, quantity uint16, vals []bool) e
 	return nil
 }
 
-// // TODO
-// func (p *PingvinKL) checkMutexCoils(addr uint16) {
-// 	for i := 0; i < len(mutexcoils); i++ {
-// 		if mutexcoils[i] == addr {
-// 			log.Println("Resetting mode coils")
-// 			// TODO
-// 			return
-// 		}
-// 	}
-// }
+func (p *PingvinKL) checkMutexCoils(addr uint16, handler *modbus.RTUClientHandler) error {
+	for _, mutexcoil := range mutexcoils {
+		if mutexcoil == addr {
+			for _, n := range mutexcoils {
+				if p.Coils[n].Value {
+					_, err := modbus.NewClient(handler).WriteSingleCoil(n, 0)
+					if err != nil {
+						log.Println("ERROR: checkMutexCoils:", err)
+						return err
+					}
+				}
+			}
+			return nil
+		}
+	}
+	return nil
+}
 
 func (p *PingvinKL) populateStatus() {
 	hpct := p.Registers[49].Value / p.Registers[49].Multiplier