mirror of
https://github.com/n08i40k/schedule-parser-rusted.git
synced 2025-12-06 17:57:47 +03:00
Compare commits
2 Commits
release/v1
...
6c9d3b3b31
| Author | SHA1 | Date | |
|---|---|---|---|
|
6c9d3b3b31
|
|||
|
a348b1b99b
|
2
Cargo.lock
generated
2
Cargo.lock
generated
@@ -3538,7 +3538,7 @@ dependencies = [
|
||||
|
||||
[[package]]
|
||||
name = "schedule-parser-rusted"
|
||||
version = "1.2.1"
|
||||
version = "1.2.2"
|
||||
dependencies = [
|
||||
"actix-macros 0.1.0",
|
||||
"actix-test",
|
||||
|
||||
@@ -3,7 +3,7 @@ members = ["actix-macros", "actix-test", "providers"]
|
||||
|
||||
[package]
|
||||
name = "schedule-parser-rusted"
|
||||
version = "1.2.1"
|
||||
version = "1.2.2"
|
||||
edition = "2024"
|
||||
publish = false
|
||||
|
||||
|
||||
@@ -49,10 +49,12 @@ pub async fn telegram_auth(
|
||||
let web_app_user =
|
||||
serde_json::from_str::<WebAppUser>(init_data.data_map.get("user").unwrap()).unwrap();
|
||||
|
||||
let user =
|
||||
match Query::find_user_by_telegram_id(app_state.get_database(), web_app_user.id).await {
|
||||
Ok(Some(value)) => Ok(value),
|
||||
_ => {
|
||||
let user = match Query::find_user_by_telegram_id(app_state.get_database(), web_app_user.id)
|
||||
.await
|
||||
.expect("Failed to find user by telegram id")
|
||||
{
|
||||
Some(value) => value,
|
||||
None => {
|
||||
let new_user = ActiveUser {
|
||||
id: Set(ObjectId::new().unwrap().to_string()),
|
||||
username: Set(format!("telegram_{}", web_app_user.id)), // можно оставить, а можно поменять
|
||||
@@ -64,10 +66,12 @@ pub async fn telegram_auth(
|
||||
android_version: Set(None),
|
||||
};
|
||||
|
||||
new_user.insert(app_state.get_database()).await
|
||||
new_user
|
||||
.insert(app_state.get_database())
|
||||
.await
|
||||
.expect("Failed to insert user")
|
||||
}
|
||||
}
|
||||
.expect("Failed to get or add user");
|
||||
};
|
||||
|
||||
let access_token = utility::jwt::encode(&user.id);
|
||||
Ok(Response::new(&access_token, user.group.is_some())).into()
|
||||
|
||||
Reference in New Issue
Block a user