Detect an invalid x-token in Rust client

[nbaksalyar]

If I provide an invalid token, the client doesn't fail immediately.
Instead, I see a flurry of Unexpected EOF decoding stream error messages which can be confusing.
The client should return an error like InvalidToken instead.

[shuimuliang]

e.g:

use thiserror::Error;

#[derive(Debug, Error)]
pub enum Error {
    #[error("AccessToken: {0}")]
    AccessToken(String),

    #[error("Certificate: {0}")]
    Certificate(String),

    #[error("I/O: {0}")]
    Io(std::io::Error),

    #[error("Transport: {0}")]
    Transport(tonic::transport::Error),

    #[error("Invalid URI {0}: {1}")]
    InvalidUri(String, String),
}

[shuimuliang]

@nbaksalyar
which kind of x-token is invalid, any samples?

[nbaksalyar]

which kind of x-token is invalid, any samples?

Any string value besides the correct token - e.g. you can give it a try with 123. As a result, you won't get any clear indication that the token is invalid, only the Unexpected EOF ... error.

[shuimuliang]

on the gRPC server side, the request is usually check by

fn check_auth(req: Request<()>) -> Result<Request<()>, Status> {
    let token: MetadataValue<_> = "Bearer some-secret-token".parse().unwrap();

    match req.metadata().get("authorization") {
        Some(t) if token == t => Ok(req),
        _ => Err(Status::unauthenticated("No valid auth token")),
    }
}

Q:

1. where's x_token validation logic in this code base(solana-geyser-grpc)?
2. is x_token a bearer token similar to JWT, e.g:
   x_token: Bearer token
   x_token: Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJzdWIiOiIxMjM0NTY3ODkwIiwibmFtZSI6IkpvaG4gRG9lIiwiaWF0IjoxNTE2MjM5MDIyfQ.SflKxwRJSMeKKF2QT4fwpMeJf36POk6yJV_adQssw5c

[shuimuliang]

test case

    #[tokio::test]
    async fn test_channel_http_success() {
        let endpoint = "http://127.0.0.1:10000".to_owned();
        let x_token = "1234567891012141618202224268".to_owned();
        let res: Result<RetryChannel, Error> = RetryChannel::new(endpoint, Some(x_token));
        assert!(res.is_ok())
    }

    #[tokio::test]
    async fn test_channel_invalid_token_some() {
        let endpoint = "http://127.0.0.1:10000".to_owned();
        let x_token = "123".to_owned();
        let res: Result<RetryChannel, Error> = RetryChannel::new(endpoint, Some(x_token.clone()));
        assert!(res.is_err());

        if let Err(Error::XToken(_)) = res {
            assert!(true);
        } else {
            assert!(false);
        }
    }