Function test_call_enum_remote_error

cln-rpc/src/test.rs:88–127

()

#[tokio::test]
async fn test_call_enum_remote_error() {
    // Set up the rpc-connection
    // The frame represents a Mock rpc-server
    let (uds1, uds2) = UnixStream::pair().unwrap();
    let mut cln = ClnRpc::from_stream(uds1).unwrap();
    let mut frame = Framed::new(uds2, JsonCodec::default());

    // Construct the request and response
    let req = Request::Ping(requests::PingRequest {
        id: PublicKey::from_str(
            "0364aeb75519be29d1af7b8cc6232dbda9fdabb79b66e4e1f6a223750954db210b",
        )
        .unwrap(),
        len: None,
        pongbytes: None,
    });

    let mock_resp = json!({
        "id" : 1,
        "jsonrpc" : "2.0",
        "error" : {
            "code" : 666,
            "message" : "MOCK_ERROR"
        }
    });

    // Spawn the task which calls the rpc
    let handle = tokio::task::spawn(async move { cln.call(req).await });

    // Ensure the mock receives the request and returns a response
    let _ = dbg!(frame.next().await.unwrap().unwrap());
    frame.send(mock_resp).await.unwrap();

    let rpc_response: Result<_, RpcError> = handle.await.unwrap();
    let rpc_error: RpcError = rpc_response.unwrap_err();

    println!("RPC_ERROR : {:?}", rpc_error);
    assert_eq!(rpc_error.code.unwrap(), 666);
    assert_eq!(rpc_error.message, "MOCK_ERROR");
}

#[tokio::test]
async fn test_call_enum() {