matrix/authentication-service
1
0
Fork 0
mirror of https://github.com/matrix-org/matrix-authentication-service.git synced 2025-11-20 12:02:22 +03:00
Code Activity

Lint

Browse Source
This commit is contained in:
Quentin Gliech
2023-04-13 17:32:35 +02:00
parent 5b4fee15e7
commit 2c937bda26
4 changed files with 23 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
crates/tasks/src/database.rs
View File

@@ -17,7 +17,7 @@
use std::str::FromStr;
use apalis_core::{
builder::{WorkerBuilder, WorkerFactory, WorkerFactoryFn},
builder::{WorkerBuilder, WorkerFactoryFn},
context::JobContext,
executor::TokioExecutor,
job::Job,

2
crates/tasks/src/email.rs
View File

@@ -14,7 +14,7 @@
use anyhow::Context;
use apalis_core::{
builder::{WorkerBuilder, WorkerFactory, WorkerFactoryFn},
builder::{WorkerBuilder, WorkerFactoryFn},
context::JobContext,
executor::TokioExecutor,
job::Job,

13
crates/tasks/src/matrix.rs
View File

@@ -14,7 +14,7 @@
use anyhow::Context;
use apalis_core::{
builder::{WorkerBuilder, WorkerFactory, WorkerFactoryFn},
builder::{WorkerBuilder, WorkerFactoryFn},
context::JobContext,
executor::TokioExecutor,
job::Job,
@@ -45,6 +45,7 @@ pub struct HomeserverConnection {
}
impl HomeserverConnection {
#[must_use]
pub fn new(homeserver: String, endpoint: Url, access_token: String) -> Self {
Self {
homeserver,
@@ -64,7 +65,7 @@ struct ExternalID {
#[serde(rename_all = "lowercase")]
enum ThreePIDMedium {
Email,
MSISDN,
Msisdn,
}
#[derive(Serialize, Deserialize)]
@@ -142,14 +143,14 @@ async fn provision_user(
display_name,
three_pids,
external_ids: vec![ExternalID {
auth_provider: "oauth-delegated".to_string(),
auth_provider: "oauth-delegated".to_owned(),
external_id: user.sub,
}],
};
repo.cancel().await?;
let path = format!("_synapse/admin/v2/users/{user_id}", user_id = mxid,);
let path = format!("_synapse/admin/v2/users/{mxid}",);
let mut req = Request::put(matrix.endpoint.join(&path)?.as_str());
req.headers_mut()
.context("Failed to get headers")?
@@ -212,7 +213,7 @@ async fn provision_device(
homeserver = matrix.homeserver
);
let path = format!("_synapse/admin/v2/users/{user_id}/devices", user_id = mxid);
let path = format!("_synapse/admin/v2/users/{mxid}/devices");
let mut req = Request::post(matrix.endpoint.join(&path)?.as_str());
req.headers_mut()
.context("Failed to get headers")?
@@ -228,7 +229,7 @@ async fn provision_device(
match response.status() {
StatusCode::CREATED => {
info!(%user.id, %mxid, device.id = job.device_id(), "Device created")
info!(%user.id, %mxid, device.id = job.device_id(), "Device created");
}
code => anyhow::bail!("Failed to provision device. Status code: {code}"),
}