Function encode_decode_request

libs/@local/codec/src/harpc/wire.rs:235–277

()

    #[test]
    fn encode_decode_request() {
        // Setup
        let mut codec = RequestCodec::new();
        let mut buffer = BytesMut::new();

        // Create a request with known data
        let request = create_test_request();

        // Encode the request
        codec
            .encode(request.clone(), &mut buffer)
            .expect("should successfully encode request");

        // Verify buffer has enough data (at least the header)
        assert!(
            buffer.len() >= 32,
            "Buffer should contain at least the header"
        );

        // Decode the request
        let decoded = codec
            .decode(&mut buffer)
            .expect("should successfully decode")
            .expect("should have a decoded request");

        // Verify decoded request matches original
        assert_eq!(request.header.request_id, decoded.header.request_id);

        if let RequestBody::Begin(begin) = &request.body {
            if let RequestBody::Begin(decoded_begin) = &decoded.body {
                assert_eq!(begin.subsystem.id, decoded_begin.subsystem.id);
                assert_eq!(begin.procedure.id, decoded_begin.procedure.id);
                assert_eq!(begin.payload, decoded_begin.payload);
            } else {
                panic!("Decoded request body should be Begin");
            }
        } else {
            panic!("Request body should be Begin");
        }

        // Buffer should be empty after decoding
        assert_eq!(buffer.len(), 0, "Buffer should be empty after decoding");
    }

    #[test]
    fn encode_decode_response() {