Skip to content

Commit

Permalink
refa: adding some logs and allowing webhook error for now (#169)
Browse files Browse the repository at this point in the history
  • Loading branch information
nicolasauler authored Dec 8, 2024
1 parent 6906daa commit 40954d6
Show file tree
Hide file tree
Showing 2 changed files with 34 additions and 19 deletions.
52 changes: 33 additions & 19 deletions src/hypermedia/service/pluggy.rs
Original file line number Diff line number Diff line change
Expand Up @@ -21,27 +21,41 @@ pub async fn widget(
};

// TODO: what to do with webhook stuff
let Ok(webhook_url) = create_user_endpoint(&env.svix_api_key, user.id).await else {
return (
StatusCode::INTERNAL_SERVER_ERROR,
PluggyWidgetModalErrorTemplate {},
)
.into_response();
let webhook_url = match create_user_endpoint(&env.svix_api_key, user.id).await {
Ok(url) => url,
Err(e) => {
tracing::error!(?e, "couldn't create user endpoint");
// return (
// StatusCode::INTERNAL_SERVER_ERROR,
// PluggyWidgetModalErrorTemplate {},
// )
// .into_response();
"https://fina.requestcatcher.com/test".to_owned()
}
};

let Ok(CreateConnectTokenOutcome::Success(connect_token)) = create_connect_token(
pluggy_api_key,
// "https://fina.requestcatcher.com/test".to_owned(),
webhook_url,
user.id,
)
.await
else {
return (
StatusCode::FAILED_DEPENDENCY,
PluggyWidgetModalErrorTemplate {},
)
.into_response();
let connect_token = match create_connect_token(pluggy_api_key, webhook_url, user.id).await {
Ok(CreateConnectTokenOutcome::Success(connect_token)) => connect_token,
Ok(
CreateConnectTokenOutcome::Forbidden
| CreateConnectTokenOutcome::NotFound
| CreateConnectTokenOutcome::Internal,
) => {
tracing::error!("pluggy returned error outcome on create connect token");
return (
StatusCode::FAILED_DEPENDENCY,
PluggyWidgetModalErrorTemplate {},
)
.into_response();
}
Err(e) => {
tracing::error!(?e, "pluggy failed to give a response");
return (
StatusCode::INTERNAL_SERVER_ERROR,
PluggyWidgetModalErrorTemplate {},
)
.into_response();
}
};

return PluggyConnectWidgetTemplate {
Expand Down
1 change: 1 addition & 0 deletions src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -293,6 +293,7 @@ fn renew_pluggy_task(

let mut pluggy_api_key = pluggy_api_key.lock().await;
*pluggy_api_key = new_pluggy_api_key.api_key;
tracing::info!("renewed pluggy api key");
}
})
}
Expand Down

0 comments on commit 40954d6

Please sign in to comment.