feagi-agent 0.0.1

use crate::command_and_control::agent_embodiment_configuration_message::AgentEmbodimentConfigurationMessage;
use crate::command_and_control::agent_registration_message::AgentRegistrationMessage;
use crate::command_and_control::health_check_message::HealthCheckMessage;
use crate::command_and_control::messages::burst_engine::BurstEnginesMessage;
use crate::FeagiAgentError;
use feagi_io::AgentID;
use feagi_serialization::FeagiByteContainer;
use feagi_structures::FeagiJSON;
use serde::{Deserialize, Serialize};

// All Command and Control messages are within this nested enum.
#[allow(clippy::large_enum_variant)]
#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
#[serde(rename_all = "snake_case")]
pub enum FeagiMessage {
    HeartBeat,
    AgentRegistration(AgentRegistrationMessage),
    HealthCheck(HealthCheckMessage),
    AgentConfiguration(AgentEmbodimentConfigurationMessage),
    BurstEngine(BurstEnginesMessage),
}

impl FeagiMessage {
    pub fn serialize_to_byte_container(
        &self,
        container: &mut FeagiByteContainer,
        session_id: AgentID,
        increment_value: u16,
    ) -> Result<(), FeagiAgentError> {
        let json: serde_json::Value = serde_json::to_value(self).unwrap();
        let feagi_json: FeagiJSON = FeagiJSON::from_json_value(json);
        container.overwrite_byte_data_with_single_struct_data(&feagi_json, increment_value)?;
        container.set_agent_identifier(session_id)?;
        Ok(())
    }
}

// TODO we should consider our ownh implementation for feagi messages instead of just piggybacking off of JSON
// Note: We do not get messages at a high rate. We can simply instantiate on the stack them every time
impl TryFrom<&FeagiByteContainer> for FeagiMessage {
    type Error = FeagiAgentError;
    fn try_from(value: &FeagiByteContainer) -> Result<Self, Self::Error> {
        let serialized_data = value.try_create_new_struct_from_index(0)?;
        let feagi_json: FeagiJSON = serialized_data.try_into()?;
        let json = feagi_json.borrow_json_value().clone();
        serde_json::from_value(json)
            .map_err(|err| FeagiAgentError::UnableToDecodeReceivedData(err.to_string()))
    }
}

// TODO we should consider our ownh implementation for feagi messages instead of just piggybacking off of JSON
impl From<FeagiMessage> for FeagiByteContainer {
    fn from(message: FeagiMessage) -> Self {
        let json: serde_json::Value = serde_json::to_value(&message).unwrap();
        let feagi_json: FeagiJSON = FeagiJSON::from_json_value(json);
        let mut byte_container: FeagiByteContainer = FeagiByteContainer::new_empty();
        byte_container
            .overwrite_byte_data_with_single_struct_data(&feagi_json, 0)
            .unwrap();
        byte_container
    }
}