Replies: 1 comment 3 replies
-
|
@rahulmr what are the problems exactly?
|
Beta Was this translation helpful? Give feedback.
3 replies
-
|
I hope you don't mind me keeping this discussion open for sometime. Thanks for your help.
use warp::{http, hyper::body::Bytes, Filter, Rejection, Reply};
use warp_reverse_proxy::{
extract_request_data_filter, proxy_to_and_forward_response, Body, Headers,
};
async fn log_response(response: http::Response<Bytes>) -> Result<impl Reply, Rejection> {
println!("{:?}", response);
Ok(response)
}
#[tokio::main]
async fn main() {
// let hello = warp::path!("hello" / String).map(|name| format!("Hello port, {}!", name));
// // spawn base server
// tokio::spawn(warp::serve(hello).run(([0, 0, 0, 0], 9080)));
let request_filter = extract_request_data_filter();
let app = warp::path!("")
// build the request with data from previous filters
.and(request_filter)
.and_then(
|path, query, method, mut headers: Headers, mut body: Body| {
headers
.insert("Content-Type", "application/json".parse().unwrap())
.unwrap();
proxy_to_and_forward_response(
"https://api.github.com".to_string(),
"".to_string(),
path,
query,
method,
headers,
body,
)
},
)
.and_then(log_response);
// spawn proxy server
warp::serve(app).run(([0, 0, 0, 0], 3040)).await;
}I am getting below error Also, if I put
It seems like I am missing something with the above code. use warp::{http, hyper::body::Bytes, Filter, Rejection, Reply};
use warp_reverse_proxy::{
extract_request_data_filter, proxy_to_and_forward_response, Body, Headers,
};
async fn log_response(response: http::Response<Bytes>) -> Result<impl Reply, Rejection> {
println!("{:?}", response);
Ok(response)
}
#[tokio::main]
async fn main() {
// let hello = warp::path!("hello" / String).map(|name| format!("Hello port, {}!", name));
// // spawn base server
// tokio::spawn(warp::serve(hello).run(([0, 0, 0, 0], 9080)));
let request_filter = extract_request_data_filter();
let app = warp::path!("webhook")
// build the request with data from previous filters
.and(request_filter)
.and_then(
|path, query, method, mut headers: Headers, mut body: Body| {
headers
.insert("Content-Type", "application/json".parse().unwrap())
.unwrap();
proxy_to_and_forward_response(
"https://api.github.com".to_string(),
"".to_string(),
path,
query,
method,
headers,
body,
)
},
)
.and_then(log_response);
// spawn proxy server
warp::serve(app).run(([0, 0, 0, 0], 3040)).await;
}The using curl I am trying to get the repos from But I am not getting any response. Expected response is something like below with original endpoint of github Sorry for the long description above. I am really stuck at it. It is very easy to do this using |
Beta Was this translation helpful? Give feedback.
-
|
@rahulmr, I don't have too much time to help you with this. But from what I see I think the problem is that you are matching the exact path. I think you may be interested in using |
Beta Was this translation helpful? Give feedback.
-
|
ok thanks, I will check it out. |
Beta Was this translation helpful? Give feedback.
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
First of all, Thanks to you I was finally able to work with warp and warp-reverse-proxy.
I need some help in my implementation, following problems statements:
https://api.example.comso it is SSL.https://webhook.myexample.comwhich internally sends all requests tohttps://api.example.comwith same route and same method if post then post, if get then get, if put/delete/patch then put/delete/patch"token" : "my very long token"and"content-type" : "application/json"https://api.example.com/login,https://api.example.com/somemore, etc. etc.Beta Was this translation helpful? Give feedback.
All reactions