use bevy::prelude::*;
use crate::{nature, settings, actor, audio, hud};

const MIN_INTERACT_DISTANCE: f32 = 30.0;
const ASSET_CONVERSATIONS: &str = "scenes/conversations.scn.ron";

pub struct ActorPlugin;
impl Plugin for ActorPlugin {
    fn build(&self, app: &mut App) {
        app.add_systems(Startup, setup);
        app.register_type::<ChatBranch>();
        app.register_type::<ChatChoice>();
        app.add_systems(FixedUpdate, (
            update_physics_lifeforms,
            update_physics_actors,
        ));
        app.add_systems(Update, (
            handle_new_conversations,
            handle_conversations,
            handle_input,
        ));
        app.add_event::<StartConversationEvent>();
    }
}

#[derive(Event)]
pub struct StartConversationEvent {
    pub talker: Talker,
}

#[derive(Component)]
pub struct Actor {
    pub hp: f32,
    pub m: f32, // mass
    pub v: Vec3, // velocity
    pub angular_momentum: Quat,
}

impl Default for Actor {
    fn default() -> Self {
        Self {
            hp: 100.0,
            m: 100.0,
            v: Vec3::ZERO,
            angular_momentum: Quat::from_euler(EulerRot::XYZ, 0.001, 0.01, 0.003),
        }
    }
}

#[derive(Component)] pub struct Player;
#[derive(Component)] pub struct PlayerInConversation;
#[derive(Component)] pub struct InConversationWithPlayer;

#[derive(Component, Reflect, Default)]
#[reflect(Component)]
pub struct ChatBranch {
    pub id: String,
    pub name: String,
    pub label: String,
    pub delay: f64,
    pub sound: String,
    pub reply: String,
    pub goto: String,
}

#[derive(Component, Reflect, Default)]
#[reflect(Component)]
pub struct ChatChoice {
    pub id: String,
    pub label: String,
    pub choice: String,
    pub goto: String,
}

#[derive(Component)]
pub struct Chat {
    pub id: String,
    pub label: String,
    pub timer: f64,
}

#[derive(Component)]
#[derive(Clone)]
pub struct Talker {
    pub conv_id: String,
}

#[derive(Component)]
pub struct LifeForm {
    pub adrenaline: f32,
    pub adrenaline_baseline: f32,
    pub adrenaline_jolt: f32,
}
impl Default for LifeForm { fn default() -> Self { Self {
    adrenaline: 0.3,
    adrenaline_baseline: 0.3,
    adrenaline_jolt: 0.0,
}}}

#[derive(Component)]
pub struct Suit {
    pub oxygen: f32,
    pub power: f32,
    pub oxygen_max: f32,
    pub power_max: f32,
}
impl Default for Suit { fn default() -> Self { SUIT_SIMPLE } }

const SUIT_SIMPLE: Suit = Suit {
    power: 1e5,
    power_max: 1e5,
    oxygen: nature::OXY_D,
    oxygen_max: nature::OXY_D,
};

pub fn setup(
    mut commands: Commands,
    asset_server: Res<AssetServer>,
) {
    commands.spawn(DynamicSceneBundle {
        scene: asset_server.load(ASSET_CONVERSATIONS),
        ..default()
    });
}

pub fn update_physics_actors(
    time: Res<Time>,
    mut q_actors: Query<(&mut Actor, &mut Transform)>,
) {
    let d = time.delta_seconds();
    for (actor, mut transform) in q_actors.iter_mut() {
        transform.rotate(actor.angular_momentum);
        // TODO: animate only a step based on time between update:
        //transform.rotate(actor.angular_momentum.slerp(Quat::IDENTITY, d)); // not working
        transform.translation += d * actor.v;
    }
}

pub fn update_physics_lifeforms(
    time: Res<Time>,
    mut query: Query<(&mut LifeForm, &mut Suit)>,
) {
    let d = time.delta_seconds();
    for (mut lifeform, mut suit) in query.iter_mut() {
        if lifeform.adrenaline_jolt.abs() > 1e-3 {
            lifeform.adrenaline_jolt *= 0.99;
        }
        else {
            lifeform.adrenaline_jolt = 0.0
        }
        lifeform.adrenaline = (lifeform.adrenaline - 0.0001 + lifeform.adrenaline_jolt * 0.01).clamp(0.0, 1.0);
        suit.oxygen = (suit.oxygen - nature::OXY_S*d).clamp(0.0, 1.0);
    }
}

pub fn handle_input(
    keyboard_input: Res<ButtonInput<KeyCode>>,
    settings: ResMut<settings::Settings>,
    query: Query<(&Talker, &Transform)>,
    player: Query<&Transform, With<actor::Player>>,
    mut ew_conv: EventWriter<StartConversationEvent>,
)
{
    if keyboard_input.just_pressed(settings.key_interact) {
        let mindist = MIN_INTERACT_DISTANCE * MIN_INTERACT_DISTANCE;
        if let Ok(player) = player.get_single() {
            for (talker, transform) in &query {
                if transform.translation.distance_squared(player.translation) <= mindist {
                    ew_conv.send(StartConversationEvent{talker: talker.clone()});
                    break;
                }
            }
        }
    }
}

pub fn handle_new_conversations(
    mut commands: Commands,
    mut er_conv: EventReader<StartConversationEvent>,
    mut ew_sfx: EventWriter<audio::PlaySfxEvent>,
    q_conv: Query<&Chat>,
    time: Res<Time>,
) {
    let label = "INIT";
    for event in er_conv.read() {
        // check for existing chats with this id
        let id = &event.talker.conv_id;
        let chats: Vec<&Chat> = q_conv.iter().filter(|c| c.id == *id).collect();
        if chats.len() > 0 {
            ew_sfx.send(audio::PlaySfxEvent(audio::Sfx::Ping));
            continue;
        }

        // no existing chats yet, let's create a new one
        commands.spawn(Chat {
            id: id.to_string(),
            label: label.to_string(),
            timer: time.elapsed_seconds_f64(),
        });
        break;
    }
}

pub fn handle_conversations(
    mut commands: Commands,
    mut log: ResMut<hud::Log>,
    mut q_conv: Query<(Entity, &mut Chat)>,
    mut ew_sfx: EventWriter<audio::PlaySfxEvent>,
    time: Res<Time>,
    chat_branches: Query<&ChatBranch>, // TODO: use Table for faster iteration?
    //chat_choices: Query<&ChatChoice>,
) {
    let now = time.elapsed_seconds_f64();
    for (entity, mut chat) in &mut q_conv {
        if chat.label == "EXIT" {
            debug!("Despawning chat.");
            commands.entity(entity).despawn();
            continue;
        }
        if now < chat.timer {
            continue;
        }

        let branches: Vec<&ChatBranch> = chat_branches.iter()
            .filter(|branch| branch.id == chat.id && branch.label == chat.label)
            .collect();
        if branches.len() != 1 {
            error!("Expected 1 branch with ID '{}' and label '{}', but got {}! Aborting conversation.", chat.id, chat.label, branches.len());
            continue;
        }
        let branch = branches[0];
        log.chat(branch.reply.clone(), branch.name.clone());
        if chat.label == "EXIT" {
            continue;
        }
        chat.label = branch.goto.clone();
        if branch.sound != "" {
            let sfx = audio::str2sfx(branch.sound.as_str());
            ew_sfx.send(audio::PlaySfxEvent(sfx));
        }
        chat.timer = now + branch.delay;
    }
}