nimble-protocol 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 nimble_participant::ParticipantId;

use nimble_protocol::host_to_client::{AuthoritativeStepRanges, InternalAuthoritativeStepRanges};

use nimble_protocol::serialize::{
    CombinedSteps, InternalAllParticipantVectors, InternalAuthoritativeStepRange,
    InternalStepVectorForOneParticipant,
};
use nimble_protocol::{ClientRequestId, Version};

use nimble_protocol::client_to_host::ConnectRequest;
use nimble_sample_step::SampleStep;
use nimble_step_map::StepMap;
use std::io;
use tick_id::TickId;

#[test_log::test]
fn check_version() {
    let mut out_stream = OutOctetStream::new();
    let version = Version {
        major: 4,
        minor: 3,
        patch: 2,
    };
    version.to_stream(&mut out_stream).unwrap()
}

#[test_log::test]
fn check_connect() {
    let mut out_stream = OutOctetStream::new();
    let version = Version {
        major: 4,
        minor: 3,
        patch: 2,
    };
    let nimble_version = Version {
        major: 99,
        minor: 66,
        patch: 33,
    };
    let connect = ConnectRequest {
        nimble_version,
        use_debug_stream: false,
        application_version: version,
        client_request_id: ClientRequestId(0xff),
    };
    connect.to_stream(&mut out_stream).unwrap();

    let mut in_stream = InOctetStream::new(out_stream.octets_ref());

    let received_connect = ConnectRequest::from_stream(&mut in_stream).unwrap();

    assert_eq!(received_connect, connect);
}

#[test_log::test]
fn check_authoritative() -> io::Result<()> {
    // Prepare all steps
    let mut range_for_all_participants =
        StepMap::<InternalStepVectorForOneParticipant<SampleStep>>::new();

    const PARTICIPANT_COUNT: usize = 2;
    let first_steps = vec![
        SampleStep::Jump,
        SampleStep::MoveLeft(-10),
        SampleStep::MoveRight(32000),
    ];
    let first_participant_id = ParticipantId(255);
    let first_vector = InternalStepVectorForOneParticipant::<SampleStep> {
        delta_tick_id: 0,
        steps: first_steps.clone(),
    };

    range_for_all_participants
        .insert(first_participant_id, first_vector)
        .expect("first participant should be unique");

    let second_steps = vec![SampleStep::MoveLeft(40), SampleStep::Jump, SampleStep::Jump];
    let second_participant_id = ParticipantId(1);
    let second_vector = InternalStepVectorForOneParticipant::<SampleStep> {
        delta_tick_id: 0,
        steps: second_steps.clone(),
    };

    range_for_all_participants
        .insert(second_participant_id, second_vector)
        .expect("second participant should be unique");

    let range_to_send = InternalAuthoritativeStepRange::<SampleStep> {
        delta_tick_id_from_previous: 0,
        authoritative_steps: InternalAllParticipantVectors {
            participant_step_vectors: range_for_all_participants,
        },
    };

    const EXPECTED_TICK_ID: TickId = TickId(909);
    let ranges_to_send = InternalAuthoritativeStepRanges {
        root_tick_id: EXPECTED_TICK_ID,
        ranges: vec![range_to_send],
    };

    // Write the ranges to stream
    let mut out_stream = OutOctetStream::new();

    ranges_to_send.to_stream(&mut out_stream)?;

    // Read back the stream
    let mut in_stream = OctetRefReader::new(out_stream.octets_ref());
    let received_ranges =
        InternalAuthoritativeStepRanges::<SampleStep>::from_stream(&mut in_stream)?;

    // Verify the deserialized data
    assert_eq!(received_ranges.ranges.len(), ranges_to_send.ranges.len());
    assert_eq!(received_ranges.root_tick_id, EXPECTED_TICK_ID);

    let first_and_only_range = &received_ranges.ranges[0];
    assert_eq!(first_and_only_range.delta_tick_id_from_previous, 0);
    assert_eq!(
        first_and_only_range
            .authoritative_steps
            .participant_step_vectors
            .len(),
        2
    );

    let hash_map = &first_and_only_range
        .authoritative_steps
        .participant_step_vectors;

    assert_eq!(hash_map.len(), PARTICIPANT_COUNT);

    let first_participant_steps_in_range = &hash_map[&first_participant_id];
    assert_eq!(
        first_participant_steps_in_range.steps.len(),
        first_steps.len()
    );
    assert_eq!(*first_participant_steps_in_range.steps, first_steps);

    let second_participant_steps_in_range = &hash_map[&second_participant_id];
    assert_eq!(
        second_participant_steps_in_range.steps.len(),
        second_steps.len()
    );
    assert_eq!(*second_participant_steps_in_range.steps, second_steps);

    Ok(())
}

fn create_authoritative_step_range() -> CombinedSteps<SampleStep> {
    const PARTICIPANT_COUNT: usize = 2;
    let steps_per_participant = vec![
        [
            SampleStep::Jump,
            SampleStep::MoveLeft(-10),
            SampleStep::MoveRight(32000),
        ],
        [SampleStep::MoveLeft(40), SampleStep::Jump, SampleStep::Jump],
    ];

    let mut authoritative_steps = Vec::new();
    for index in 0..3 {
        let mut authoritative_participants = StepMap::new();
        for participant_index in 0..PARTICIPANT_COUNT {
            let sample_step = &steps_per_participant[participant_index][index];
            authoritative_participants
                .insert(ParticipantId(participant_index as u8), sample_step.clone())
                .expect("should be unique participants ids");
        }
        authoritative_steps.push(authoritative_participants);
    }

    CombinedSteps {
        tick_id: TickId(1),
        steps: authoritative_steps,
    }
}

#[test]
fn serialize_auth() -> io::Result<()> {
    let ranges_to_send = AuthoritativeStepRanges::<SampleStep> {
        ranges: [create_authoritative_step_range()].into(),
    };

    // Write the ranges to stream
    let mut out_stream = OutOctetStream::new();
    ranges_to_send.serialize(&mut out_stream)?;

    // Read back
    let mut in_stream = OctetRefReader::new(out_stream.octets_ref());
    let received_ranges = AuthoritativeStepRanges::<SampleStep>::deserialize(&mut in_stream)?;

    // Verify
    assert_eq!(received_ranges.ranges.len(), 1);
    assert_eq!(received_ranges.ranges[0], ranges_to_send.ranges[0]);

    Ok(())
}