Updated op25 config functions

app/routers/op25_controller.py

@@ -61,6 +61,77 @@ async def start_op25_logic():
             return False
     return False
 
+def build_op25_config(generator: ConfigGenerator) -> dict:
+    if generator.type == DecodeMode.P25:
+        channels = [ChannelConfig(
+            name=generator.systemName,
+            trunking_sysname=generator.systemName,
+            enable_analog="off",
+            demod_type="cqpsk",
+            cqpsk_tracking=True,
+            filter_type="rc",
+            meta_stream_name="stream_0"
+        )]
+        devices = [DeviceConfig()]
+        
+        trunking = TrunkingConfig(
+            module="tk_p25.py",
+            chans=[TrunkingChannelConfig(
+                sysname=generator.systemName,
+                control_channel_list=','.join(generator.channels),
+                tagsFile="/configs/active.cfg.tags.tsv",
+                whitelist="/configs/active.cfg.whitelist.tsv"
+            )]
+        )
+
+        metadata = MetadataConfig(
+            streams=[
+                MetadataStreamConfig(
+                    stream_name="stream_0",
+                    icecastServerAddress = f"{generator.icecastConfig.icecast_host}:{generator.icecastConfig.icecast_port}",
+                    icecastMountpoint = generator.icecastConfig.icecast_mountpoint,
+                    icecastPass = generator.icecastConfig.icecast_password
+                )
+            ]
+        )
+
+        terminal = TerminalConfig()
+
+        return {
+            "channels": [channel.dict() for channel in channels],
+            "devices": [device.dict() for device in devices],
+            "trunking": trunking.dict(),
+            "metadata": metadata.dict(),
+            "terminal": terminal.dict()
+        }
+    
+    elif generator.type == DecodeMode.ANALOG:
+        analog_config = generator.config
+        channels = [ChannelConfig(
+            channelName=analog_config.systemName,
+            enableAnalog="on",
+            demodType="fsk4",
+            frequency=analog_config.frequency,
+            filterType="widepulse",
+            nbfmSquelch=analog_config.nbfmSquelch
+        )]
+        devices = [DeviceConfig(gain="LNA:32")]
+
+        return {
+            "channels": [channel.dict() for channel in channels],
+            "devices": [device.dict() for device in devices]
+        }
+    else:
+        raise HTTPException(status_code=400, detail="Invalid decode mode")
+
+def save_library_sidecars(system_name: str, generator: ConfigGenerator):
+    if generator.type == DecodeMode.P25:
+        prefix = system_name
+        if prefix.endswith(".json"):
+            prefix = prefix[:-5]
+        save_talkgroup_tags(generator.tags, prefix)
+        save_whitelist(generator.whitelist, prefix)
+
 def create_op25_router():
     router = APIRouter()
 
@@ -93,46 +164,31 @@ def create_op25_router():
         active.cfg.json, and optionally restarts the radio.
         """
         try:
-            if generator.type == DecodeMode.P25:
-                # 1. Handle sidecar files (Tags/Whitelists)
-                if generator.config.talkgroupTags:
-                    save_talkgroup_tags(generator.config.talkgroupTags)
-                if generator.config.whitelist:
-                    save_whitelist(generator.config.whitelist)
-
-                # 2. Build the main OP25 dictionary structure
-                config_dict = {
-                    "channels": [c.dict() for c in generator.config.channels],
-                    "devices": [d.dict() for d in generator.config.devices],
-                    "trunking": generator.config.trunking.dict(),
-                    "metadata": generator.config.metadata.dict(),
-                    "terminal": generator.config.terminal.dict()
-                }
-            
-            elif generator.type == DecodeMode.ANALOG:
-                # Simple Analog NBFM Setup for quick testing
-                channels = [ChannelConfig(
-                    channelName=generator.config.systemName,
-                    enableAnalog="on",
-                    frequency=generator.config.frequency,
-                    demodType="fsk4",
-                    filterType="widepulse"
-                )]
-                config_dict = {
-                    "channels": [c.dict() for c in channels],
-                    "devices": [{"gain": "LNA:32"}] # Default gain for analog test
-                }
-            else:
-                raise HTTPException(status_code=400, detail="Invalid decode mode")
-
-            # 3. Clean 'None' values to prevent OP25 parsing errors and save
+            # 1. Build the configuration dictionary
+            config_dict = build_op25_config(generator)
             final_json = del_none_in_dict(config_dict)
-            
-            if save_to_library_name:
-                save_config_to_library(save_to_library_name, final_json)
 
-            with open('/configs/active.cfg.json', 'w') as f:
-                json.dump(final_json, f, indent=2)
+            # 2. Handle Storage and Activation
+            if save_to_library_name:
+                # Save to library
+                save_config_to_library(save_to_library_name, final_json)
+                save_library_sidecars(save_to_library_name, generator)
+                
+                # Activate from library (Copies json + sidecars)
+                if not activate_config_from_library(save_to_library_name):
+                     raise HTTPException(status_code=500, detail="Failed to activate saved configuration")
+            else:
+                # Save directly to active
+                with open('/configs/active.cfg.json', 'w') as f:
+                    json.dump(final_json, f, indent=2)
+                
+                if generator.type == DecodeMode.P25:
+                    save_talkgroup_tags(generator.tags)
+                    save_whitelist(generator.whitelist)
+
+            # 3. Generate Liquidsoap Script (Always required for active P25 session)
+            if generator.type == DecodeMode.P25:
+                generate_liquid_script(generator.icecastConfig)
             
             LOGGER.info("Saved new configuration to active.cfg.json")
 
@@ -162,13 +218,19 @@ def create_op25_router():
         raise HTTPException(status_code=404, detail=f"Config '{system_name}' not found in library volume")
 
     @router.post("/save_to_library")
-    async def save_to_library(system_name: str, config: dict):
+    async def save_to_library(system_name: str, config: ConfigGenerator):
         """
         Directly saves a JSON configuration to the library.
         """
-        if save_config_to_library(system_name, config):
-            return {"status": f"Config saved as {system_name}"}
-        raise HTTPException(status_code=500, detail="Failed to save configuration")
+        try:
+            config_dict = build_op25_config(config)
+            final_json = del_none_in_dict(config_dict)
+            if save_config_to_library(system_name, final_json):
+                save_library_sidecars(system_name, config)
+                return {"status": f"Config saved as {system_name}"}
+            raise HTTPException(status_code=500, detail="Failed to save configuration")
+        except Exception as e:
+            raise HTTPException(status_code=500, detail=str(e))
 
     @router.get("/library")
     async def get_library():