Official Discord: https://discord.gg/NWpN5mmg3x | Powerful web framework for Rust | https://github.com/actix/actix-web/wiki/FAQ
When I write my integration tests in tests/ folder, and try to invoke tests using vim-test keybindings, the tests always get filtered out. Running "cargo test" runs fine, the issue only happens when using vim-test plugin. Checking here if anyone else also encountered similar issue?
Hello, I have a question how to use add a validator for an object passed via json.
My Request Handler looks like this.
pub async fn handle(req_args: web::Json<HashMap<String, String>>, r: HttpRequest, auth: BasicAuth, app_state_wrapper: web::Data<AppStateWrapper<T, F>>) -> impl Responder {
...
}Now I want to validate that the Strings of the HashMap do not contain controll characters.
struct Wrapper {
#[validate(length(min = 1), custom = "my_validator")]
content: HashMap<String, String>
}Unfortunatly I can't change the client-side to send this wrapper object.
Do you have any ideas for me how to do this?
3 replies
Hello there
There is an example https://github.com/actix/examples/tree/master/json/json_decode_error
This example returns error information as a simple text.
Json deserialize error: missing field `name` at line 1 column 16But it is not so user-friendly. Is it possible to get some struct with error info? E.g:
{
errors: [
{
"field": "name",
"reason": "missing field",
"line": 1,
"column": 16
},
{
"field": "address.countryCode",
"reason": "Wrong country code abcd `ABCD`",
},
{
"field": "age",
"reason": "Should be between 0 and 100 years",
},
{
"field": "email",
"reason": [
"Too long",
"Incorrect email format"
],
}
]
}Looks like it is a restriction of serde_json not actix-web
Thanks
impl Handler<MessageChat> for MessageStore {
type Result = Result<(Uuid,), Error>;
fn handle(&mut self, msg: MessageChat, ctx: &mut Self::Context) -> Self::Result {
// Here i need to run async function and getting result
}
}
HttpServer::new(move || {
App::new()
.service(web::scope("/cables")
.service(web::resource("")
.route(web::get().to(utils::get::<Cable>))
.route(web::post().to(utils::add::<Cable>)))utils::add::<Cable> the wrong json, like maybe a string instead of a number, actix will just spit back a 400 because I'm assuming the serde part failedCan I intercept this error somehow to actually tell the user what they did wrong?
Hello, I have a question about the Data<T> we pass to actix web's App. I want to allow concurrent writing to it with custom RwLock inside T.
Basically I have a big Hashmap<String, MyType>, I want to lock every MyType to avoir concurrent writing but I don't want to lock the entire Hashmap
Data<T> object?
1 reply
RwLock stuff, thanks !
App data and app_data ?
1 reply
Arc directly
1 reply
I'm having some issue with redis integration. A redis::Connection needs to be mutable in order to write something (in my case, a queue with XADD). So I have to use a RwLock for the redis connection in my app_data and it slows down the API a lot:
- without redis I have 70k operations done in 60s
- with redis I have barely 30k
Since the Connection is a Pin<Box<>> I thought I could also clone it but it doesn't seem to work.
How do other people handle redis connections using actix?
fn call(&self, req: S::Request) -> Self::Future {
TimeoutServiceResponse {
fut: self.service.call(req),
sleep: Sleep::new(clock::now() + self.timeout),
}
}
| ^^^^^^^ associated type
Request not found"
call method should be of type Req, not of type S::Request
- Afaict, the future returned by
HttpServer.run()only resolves when we shutdown the webserver.
- Afaict, it's the same thing for the matrix-rust-sdk.
- According to my experiments, it looks like
HttpServer::runcannot be called from atokio::task::spawn.
#[actix_web::main] was doing some magic.
https://github.com/actix/actix-net/blob/master/actix-macros/src/lib.rs#L88
std::thread::spawn(move || {
actix_web::rt::System::new().block_on(async move {
...
})
})
Consider an endpoint for post requests via post macro (https://docs.rs/actix-web/3.3.2/actix_web/attr.post.html). For example using #[post("/login")].
Is it possible to define the path elsewhere like const LOGIN: &str = "/login" and use it in the post macro? I would like to collect all endpoints at one place.
I couldn't make it work. I tried #[post(LOGIN)] and #[post("{}", LOGIN)] as well as #[post("{LOGIN}")] but without success.
Cheers
3 replies
Hi everyone!
I'm getting thread panic in runtime after upgrading actix from 0.10 to either 0.11 or 0.12 with
thread 'main' panicked at '`spawn_local` called from outside of a `task::LocalSet`', /Users/stepan/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.12.0/src/task/local.rs:305:18The only change I've made to my code is that I've removed the name argument from the actix::System::new:
let sys = actix::System::new();
let db = SyncArbiter::start(3, move || DbActor(pool.clone()));
let coordinator: Addr<_> = CoordinatorActor::default().start();
HttpServer::new(move || {
let state = create_state(db.clone(), coordinator.clone(), config.clone());
let cors_middleware = Cors::default().allow_any_origin();
App::new()
.data(state)
.wrap(cors_middleware)
.wrap(middleware::NormalizePath::new(
middleware::normalize::TrailingSlash::MergeOnly,
))
.wrap(middleware::Logger::default())
.wrap(middleware::Compress::default())
.configure(router)
})
.bind(listen_addresses.clone())
.unwrap_or_else(|_| panic!("Can't bind to {}", listen_addresses))
.keep_alive(keep_alive)
.shutdown_timeout(0)
.workers(worker_processes)
.run();
sys.run()My current dependencies are
actix = "0.12"
actix-cors = "0.5.4"
actix-rt = "1.1"
actix-web = "3.3.2"What am I missing?