Add prohibit_control option to devices

Author: alufers

at2-web/src/components/RelayGroupControl.tsx

@@ -200,6 +200,7 @@ export const RelayGroupControl: FC<RelayGroupControlProps> = ({
                 <Switch
                   id={"switch-" + entity.id}
                   checked={entity.state === "ON"}
+                  disabled={entity.prohibit_control}
                   onCheckedChange={(checked) =>
                     handleSwitchClick(entity, checked)
                   }

at2-web/src/schema.ts

@@ -90,6 +90,7 @@ export interface RelayEntity {
   localized_name: LocalizedName | null;
   type: string;
   state: RelayState | null;
+  prohibit_control?: boolean;
 }
 
 /**

config.go

@@ -50,6 +50,9 @@ type EntityConfig struct {
 
 	// How the device should be represented in the UI (light, fan, etc.)
 	Representation string `yaml:"representation"`
+
+	// Prohibits controlling this device from the web page
+	ProhibitControl bool `yaml:"prohibit_control"`
 }
 
 type RoomConfig struct {

control_test.go

@@ -172,4 +172,19 @@ func TestMQTTAdapter_ControlDevice_Validation(t *testing.T) {
 	} else if !strings.Contains(err.Error(), "not a relay") {
 		t.Errorf("Expected 'not a relay' error, got: %v", err)
 	}
+	// Test 6: Prohibited Control -> Error
+	prohibitedDev := &VirtualDevice{
+		ID:              "relay/prohibited",
+		Type:            VdevTypeRelay,
+		MapperData:      &Zigbee2MQTTMapperData{BaseTopic: "p1"},
+		ProhibitControl: true,
+	}
+	mgr.AddDevices([]*VirtualDevice{prohibitedDev})
+
+	err = adapter.ControlDevice("relay/prohibited", "ON")
+	if err == nil {
+		t.Errorf("Expected error for prohibited device, got nil")
+	} else if !strings.Contains(err.Error(), "prohibited") {
+		t.Errorf("Expected 'prohibited' error, got: %v", err)
+	}
 }

mqtt_adapter.go

@@ -41,6 +41,9 @@ type MQTTAdapter struct {
 	// Virtual device manager extracted from previous in-struct logic.
 	vdevMgr *VdevManager
 	mappers []MQTTMapper
+
+	// deviceSettings maps device ID to its configuration (for prohibited control etc)
+	deviceSettings map[string]EntityConfig
 }
 
 // atomicBool (simple mutex-backed boolean) avoids importing sync/atomic for minimal usage.
@@ -65,8 +68,17 @@ func NewMQTTAdapter(cfg *Config, vdevMgr *VdevManager) (*MQTTAdapter, error) {
 
 	a := &MQTTAdapter{
 
+
 		config:  cfg,
 		vdevMgr: vdevMgr,
+		deviceSettings: make(map[string]EntityConfig),
+	}
+
+	// Index device configurations for fast lookup
+	for _, room := range cfg.Rooms {
+		for _, entity := range room.Entities {
+			a.deviceSettings[entity.ID] = entity
+		}
 	}
 
 	// Build client options first.
@@ -167,6 +179,12 @@ func (a *MQTTAdapter) handleMapperMessage(mapper MQTTMapper, topic string, paylo
 		log.Printf("[mqtt] discovery error on topic %s: %v", topic, derr)
 	}
 	if len(discovered) > 0 {
+		// Enrich discovered devices with config data
+		for _, d := range discovered {
+			if cfg, ok := a.deviceSettings[d.ID]; ok {
+				d.ProhibitControl = cfg.ProhibitControl
+			}
+		}
 		a.vdevMgr.AddDevices(discovered)
 	}
 
@@ -220,6 +238,11 @@ func (a *MQTTAdapter) ControlDevice(deviceID string, state any) error {
 		return fmt.Errorf("device %s is not a relay (type: %s)", deviceID, targetDev.Type)
 	}
 
+	// 2.5 Validation: ProhibitControl
+	if targetDev.ProhibitControl {
+		return fmt.Errorf("control is prohibited for device %s", deviceID)
+	}
+
 	// 3. Validation: State must be ON or OFF
 	stateStr, ok := state.(string)
 	if !ok {

vdev_manager.go

@@ -30,6 +30,8 @@ type VirtualDevice struct {
 	MapperData any `json:"mapper_data"`
 	// Fresh indicates if the state is from a live update (true) or restored/initial (false).
 	Fresh bool `json:"fresh"`
+	// ProhibitControl indicates if this device cannot be controlled.
+	ProhibitControl bool `json:"prohibit_control"`
 }
 
 // DeviceStateProvider defines the interface for retrieving persisted device state.