nimble-rectify 0.0.16

/*
 * Copyright (c) Peter Bjorklund. All rights reserved. https://github.com/nimble-rust/nimble
 * Licensed under the MIT License. See LICENSE in the project root for license information.
 */
use flood_rs::prelude::*;
use log::info;
use nimble_assent::AssentCallback;
use nimble_participant::ParticipantId;
use nimble_rectify::{Rectify, RectifyCallback};
use nimble_seer::SeerCallback;
use nimble_step::Step;
use nimble_step_map::StepMap;
use std::fmt::Display;
use std::io;
use tick_id::TickId;

#[derive(Clone)]
pub struct TestGame {
    pub position_x: i32,
}

impl TestGame {
    pub fn on_tick(&mut self, steps: &StepMap<Step<TestGameStep>>) {
        info!("sim tick!");
        for (_, step) in steps {
            match step {
                Step::Custom(TestGameStep::MoveLeft) => self.position_x -= 1,
                Step::Custom(TestGameStep::MoveRight) => self.position_x += 1,
                Step::Forced => todo!(),
                Step::WaitingForReconnect => todo!(),
                Step::Joined(_) => todo!(),
                Step::Left => todo!(),
            }
        }
    }
}

#[derive(Debug, Clone)]
pub enum TestGameStep {
    MoveLeft,
    MoveRight,
}

impl Display for TestGameStep {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        write!(f, "{:?}", self)
    }
}

impl Deserialize for TestGameStep {
    fn deserialize(stream: &mut impl ReadOctetStream) -> io::Result<Self> {
        let x = stream.read_u8()?;
        match x {
            0 => Ok(TestGameStep::MoveRight),
            _ => Ok(TestGameStep::MoveLeft),
        }
    }
}

impl Serialize for TestGameStep {
    fn serialize(&self, stream: &mut impl WriteOctetStream) -> io::Result<()> {
        let v = match self {
            TestGameStep::MoveRight => 0,
            TestGameStep::MoveLeft => 1,
        };
        stream.write_u8(v)
    }
}

pub struct CombinedGame {
    pub authoritative_game: TestGame,
    pub predicted_game: TestGame,
}

impl RectifyCallback for CombinedGame {
    fn on_copy_from_authoritative(&mut self) {
        info!("on_copy_from_authoritative");
        self.predicted_game = self.authoritative_game.clone();
    }
}

impl SeerCallback<StepMap<Step<TestGameStep>>> for CombinedGame {
    fn on_tick(&mut self, combined_step: &StepMap<Step<TestGameStep>>) {
        info!("predict tick!");

        self.predicted_game.on_tick(combined_step);
    }
}

impl AssentCallback<StepMap<Step<TestGameStep>>> for CombinedGame {
    fn on_tick(&mut self, combined_step: &StepMap<Step<TestGameStep>>) {
        info!("authoritative tick!");
        self.authoritative_game.on_tick(combined_step);
    }
}

#[test_log::test]
fn one_prediction() {
    let authoritative_game = TestGame { position_x: -44 };
    let predicted_game = TestGame { position_x: -44 };

    let mut callbacks = CombinedGame {
        authoritative_game,
        predicted_game,
    };

    let mut rectify = Rectify::<CombinedGame, StepMap<Step<TestGameStep>>>::default();
    let mut participant_step_combined = StepMap::<Step<TestGameStep>>::new();
    participant_step_combined
        .insert(ParticipantId(0), Step::Custom(TestGameStep::MoveLeft))
        .expect("Should be able to move left");

    rectify
        .push_predicted(TickId(0), participant_step_combined)
        .expect("Should be able to move left");

    rectify.update(&mut callbacks);

    assert_eq!(callbacks.authoritative_game.position_x, -44);
    assert_eq!(callbacks.predicted_game.position_x, -45);
}

#[test_log::test]
fn one_authoritative_and_one_prediction() {
    let authoritative_game = TestGame { position_x: -44 };
    let predicted_game = TestGame { position_x: -44 };

    let mut callbacks = CombinedGame {
        authoritative_game,
        predicted_game,
    };

    let mut rectify = Rectify::<CombinedGame, StepMap<Step<TestGameStep>>>::default();

    let mut authoritative_step_combined = StepMap::<Step<TestGameStep>>::new();
    authoritative_step_combined
        .insert(ParticipantId(0), Step::Custom(TestGameStep::MoveRight))
        .expect("should work");
    rectify
        .push_authoritative_with_check(TickId(0), authoritative_step_combined)
        .expect("should work");

    let mut predicted_step_combined = StepMap::<Step<TestGameStep>>::new();
    predicted_step_combined
        .insert(ParticipantId(0), Step::Custom(TestGameStep::MoveLeft))
        .expect("should work");

    rectify
        .push_predicted(TickId(0), predicted_step_combined)
        .expect("should work");
    rectify.update(&mut callbacks);

    assert_eq!(callbacks.authoritative_game.position_x, -43);
    assert_eq!(callbacks.predicted_game.position_x, -44);
}

#[test_log::test]
fn one_authoritative_and_x_predictions() {
    let authoritative_game = TestGame { position_x: -44 };
    let predicted_game = TestGame { position_x: -44 };

    let mut callbacks = CombinedGame {
        authoritative_game,
        predicted_game,
    };

    let mut rectify = Rectify::<CombinedGame, StepMap<Step<TestGameStep>>>::default();

    assert_eq!(rectify.waiting_for_authoritative_tick_id(), TickId(0));
    let mut authoritative_step_combined = StepMap::<Step<TestGameStep>>::new();
    authoritative_step_combined
        .insert(ParticipantId(0), Step::Custom(TestGameStep::MoveRight))
        .expect("should work");
    rectify
        .push_authoritative_with_check(TickId(0), authoritative_step_combined)
        .expect("should work");
    assert_eq!(rectify.waiting_for_authoritative_tick_id(), TickId(1));
    let mut predicted_step_combined = StepMap::<Step<TestGameStep>>::new();
    predicted_step_combined
        .insert(ParticipantId(0), Step::Custom(TestGameStep::MoveLeft))
        .expect("should work");

    let predicted_step_combined_final = predicted_step_combined;

    let mut tick = TickId(0);
    rectify
        .push_predicted(tick, predicted_step_combined_final.clone())
        .expect("should work");

    tick += 1;
    rectify
        .push_predicted(tick, predicted_step_combined_final.clone())
        .expect("should work");
    tick += 1;
    rectify
        .push_predicted(tick, predicted_step_combined_final.clone())
        .expect("should work");
    rectify.update(&mut callbacks);

    assert_eq!(callbacks.authoritative_game.position_x, -43);
    assert_eq!(callbacks.predicted_game.position_x, -45);
}