zksync_consensus_network 0.13.0

use assert_matches::assert_matches;
use rand::Rng;
use zksync_concurrency::{ctx, io, scope, testonly::abort_on_panic};
use zksync_consensus_roles::node;
use zksync_protobuf::testonly::test_encode_random;

use super::*;
use crate::{frame, noise, testonly};

#[test]
fn test_schema_encode_decode() {
    let rng = &mut ctx::test_root(&ctx::RealClock).rng();
    test_encode_random::<Handshake>(rng);
}

#[tokio::test]
async fn test_session_id_mismatch() {
    abort_on_panic();
    let ctx = &ctx::test_root(&ctx::RealClock);
    let rng = &mut ctx.rng();

    let cfg0 = testonly::make_config(rng.gen());
    let cfg1 = testonly::make_config(rng.gen());
    let genesis: validator::GenesisHash = rng.gen();

    // MitM attempt detected on the inbound end.
    scope::run!(ctx, |ctx, s| async {
        let (s1, s2) = noise::testonly::pipe(ctx).await;
        let (s3, s4) = noise::testonly::pipe(ctx).await;
        let (r2, w2) = io::split(s2);
        let (r3, w3) = io::split(s3);
        s.spawn_bg(async {
            testonly::forward(ctx, r2, w3).await;
            Ok(())
        });
        s.spawn_bg(async {
            testonly::forward(ctx, r3, w2).await;
            Ok(())
        });
        s.spawn(async {
            let mut s4 = s4;
            match inbound(ctx, &cfg0, genesis, &mut s4).await {
                Err(Error::SessionIdMismatch) => Ok(()),
                res => panic!("unexpected res: {res:?}"),
            }
        });
        s.spawn(async {
            let mut s1 = s1;
            match outbound(ctx, &cfg1, genesis, &mut s1, &cfg0.gossip.key.public()).await {
                Err(Error::Stream(..)) => Ok(()),
                res => panic!("unexpected res: {res:?}"),
            }
        });
        anyhow::Ok(())
    })
    .await
    .unwrap();

    // MitM attempt detected on the outbound end.
    scope::run!(ctx, |ctx, s| async {
        let (mut s1, s2) = noise::testonly::pipe(ctx).await;
        s.spawn_bg(async {
            let mut s2 = s2;
            let _: Handshake = frame::recv_proto(ctx, &mut s2, MAX_FRAME).await?;
            frame::send_proto(
                ctx,
                &mut s2,
                &Handshake {
                    session_id: cfg1.gossip.key.sign_msg(rng.gen::<node::SessionId>()),
                    genesis,
                    is_static: false,
                    build_version: None,
                },
            )
            .await?;
            Ok(())
        });
        match outbound(ctx, &cfg0, genesis, &mut s1, &cfg1.gossip.key.public()).await {
            Err(Error::SessionIdMismatch) => anyhow::Ok(()),
            res => panic!("unexpected res: {res:?}"),
        }
    })
    .await
    .unwrap();
}

#[tokio::test]
async fn test_peer_mismatch() {
    abort_on_panic();
    let ctx = &ctx::test_root(&ctx::RealClock);
    let rng = &mut ctx.rng();

    let cfg0 = testonly::make_config(rng.gen());
    let cfg1 = testonly::make_config(rng.gen());
    let cfg2 = testonly::make_config(rng.gen());

    let genesis: validator::GenesisHash = rng.gen();

    scope::run!(ctx, |ctx, s| async {
        let (s0, s1) = noise::testonly::pipe(ctx).await;
        s.spawn(async {
            let mut s0 = s0;
            assert_eq!(
                cfg1.gossip.key.public(),
                inbound(ctx, &cfg0, genesis, &mut s0).await?.key
            );
            Ok(())
        });
        s.spawn(async {
            let mut s1 = s1;
            match outbound(ctx, &cfg1, genesis, &mut s1, &cfg2.gossip.key.public()).await {
                Err(Error::PeerMismatch) => Ok(()),
                res => panic!("unexpected res: {res:?}"),
            }
        });
        anyhow::Ok(())
    })
    .await
    .unwrap();
}

#[tokio::test]
async fn test_genesis_mismatch() {
    abort_on_panic();
    let ctx = &ctx::test_root(&ctx::RealClock);
    let rng = &mut ctx.rng();

    let cfg0 = testonly::make_config(rng.gen());
    let cfg1 = testonly::make_config(rng.gen());

    tracing::trace!("test that inbound handshake rejects mismatching genesis");
    scope::run!(ctx, |ctx, s| async {
        let (s0, mut s1) = noise::testonly::pipe(ctx).await;
        s.spawn(async {
            let mut s0 = s0;
            let res = outbound(
                ctx,
                &cfg0,
                ctx.rng().gen(),
                &mut s0,
                &cfg1.gossip.key.public(),
            )
            .await;
            assert_matches!(res, Err(Error::Stream(_)));
            Ok(())
        });
        let res = inbound(ctx, &cfg1, rng.gen(), &mut s1).await;
        assert_matches!(res, Err(Error::GenesisMismatch));
        anyhow::Ok(())
    })
    .await
    .unwrap();

    tracing::trace!("test that outbound handshake rejects mismatching genesis");
    scope::run!(ctx, |ctx, s| async {
        let (s0, mut s1) = noise::testonly::pipe(ctx).await;
        s.spawn(async {
            let mut s0 = s0;
            let res = outbound(
                ctx,
                &cfg0,
                ctx.rng().gen(),
                &mut s0,
                &cfg1.gossip.key.public(),
            )
            .await;
            assert_matches!(res, Err(Error::GenesisMismatch));
            Ok(())
        });
        let session_id = node::SessionId(s1.id().encode());
        let _: Handshake = frame::recv_proto(ctx, &mut s1, MAX_FRAME).await.unwrap();
        frame::send_proto(
            ctx,
            &mut s1,
            &Handshake {
                session_id: cfg1.gossip.key.sign_msg(session_id),
                genesis: rng.gen(),
                is_static: false,
                build_version: None,
            },
        )
        .await
        .unwrap();
        anyhow::Ok(())
    })
    .await
    .unwrap();
}

#[tokio::test]
async fn test_invalid_signature() {
    abort_on_panic();
    let ctx = &ctx::test_root(&ctx::RealClock);
    let rng = &mut ctx.rng();

    let cfg0 = testonly::make_config(rng.gen());
    let cfg1 = testonly::make_config(rng.gen());

    let genesis: validator::GenesisHash = rng.gen();

    // Bad signature detected on outbound end.
    scope::run!(ctx, |ctx, s| async {
        let (mut s0, s1) = noise::testonly::pipe(ctx).await;
        s.spawn_bg(async {
            let mut s1 = s1;
            let mut h: Handshake = frame::recv_proto(ctx, &mut s1, MAX_FRAME).await?;
            h.session_id.key = cfg1.gossip.key.public();
            frame::send_proto(ctx, &mut s1, &h).await?;
            Ok(())
        });
        match outbound(ctx, &cfg0, genesis, &mut s0, &cfg1.gossip.key.public()).await {
            Err(Error::Signature(..)) => anyhow::Ok(()),
            res => panic!("unexpected res: {res:?}"),
        }
    })
    .await
    .unwrap();

    // Bad signature detected on inbound end.
    scope::run!(ctx, |ctx, s| async {
        let (mut s0, s1) = noise::testonly::pipe(ctx).await;
        s.spawn_bg(async {
            let mut s1 = s1;
            let mut h = Handshake {
                session_id: cfg0.gossip.key.sign_msg(node::SessionId(s1.id().encode())),
                genesis,
                is_static: true,
                build_version: None,
            };
            h.session_id.key = cfg1.gossip.key.public();
            frame::send_proto(ctx, &mut s1, &h).await
        });
        match inbound(ctx, &cfg0, genesis, &mut s0).await {
            Err(Error::Signature(..)) => Ok(()),
            res => panic!("unexpected res: {res:?}"),
        }
    })
    .await
    .unwrap();
}