diff options
Diffstat (limited to 'src/client.rs')
| -rw-r--r-- | src/client.rs | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/src/client.rs b/src/client.rs index 880cb6b..29d390f 100644 --- a/src/client.rs +++ b/src/client.rs | |||
| @@ -204,11 +204,18 @@ impl Connect for Client { | |||
| 204 | #[allow(clippy::large_futures)] | 204 | #[allow(clippy::large_futures)] |
| 205 | self.client.connect_relay(url).await?; | 205 | self.client.connect_relay(url).await?; |
| 206 | let res = self.client.send_event_to(vec![url], event.clone()).await?; | 206 | let res = self.client.send_event_to(vec![url], event.clone()).await?; |
| 207 | if let Some(err) = res.failed.get(&Url::parse(url)?) { | ||
| 208 | bail!(if let Some(err) = err { | ||
| 209 | err.to_string() | ||
| 210 | } else { | ||
| 211 | "error: unknown".to_string() | ||
| 212 | }); | ||
| 213 | } | ||
| 207 | save_event_in_cache(git_repo_path, &event).await?; | 214 | save_event_in_cache(git_repo_path, &event).await?; |
| 208 | if event.kind().eq(&Kind::Custom(REPO_REF_KIND)) { | 215 | if event.kind().eq(&Kind::Custom(REPO_REF_KIND)) { |
| 209 | save_event_in_global_cache(git_repo_path, &event).await?; | 216 | save_event_in_global_cache(git_repo_path, &event).await?; |
| 210 | } | 217 | } |
| 211 | Ok(res) | 218 | Ok(event.id()) |
| 212 | } | 219 | } |
| 213 | 220 | ||
| 214 | async fn get_events( | 221 | async fn get_events( |