blob: 1427a8d2b88813b36661588356466e17d5236a9f (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
use axum::{
extract::{Request, State},
middleware::Next,
response::Response,
};
use crate::{app::App, clock::RequestedAt, error::Internal};
// Expires messages and channels before each request.
pub async fn middleware(
State(app): State<App>,
RequestedAt(expired_at): RequestedAt,
req: Request,
next: Next,
) -> Result<Response, Internal> {
app.tokens().expire(&expired_at).await?;
app.invites().expire(&expired_at).await?;
app.messages().expire(&expired_at).await?;
app.messages().purge(&expired_at).await?;
app.channels().expire(&expired_at).await?;
app.channels().purge(&expired_at).await?;
Ok(next.run(req).await)
}
|
