2024-04-09 19:30:05 +01:00
|
|
|
use std::ops::Deref;
|
|
|
|
|
2024-04-11 18:30:36 +01:00
|
|
|
use crate::server::actors::repo::ValidateRepo;
|
|
|
|
|
2024-04-09 19:30:05 +01:00
|
|
|
#[derive(Clone, Debug, PartialEq, Eq)]
|
|
|
|
pub struct WebhookId(String);
|
|
|
|
impl WebhookId {
|
|
|
|
#[allow(dead_code)]
|
|
|
|
pub const fn new(id: String) -> Self {
|
|
|
|
Self(id)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
impl Deref for WebhookId {
|
|
|
|
type Target = String;
|
|
|
|
fn deref(&self) -> &Self::Target {
|
|
|
|
&self.0
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
pub async fn unregister(
|
|
|
|
_webhook_id: WebhookId,
|
|
|
|
_repo_details: crate::server::config::RepoDetails,
|
|
|
|
_addr: actix::prelude::Addr<super::RepoActor>,
|
|
|
|
_net: kxio::network::Network,
|
|
|
|
) {
|
|
|
|
// TODO: (#17) unregister webhook
|
|
|
|
// on success - stop the actor
|
|
|
|
}
|
|
|
|
|
|
|
|
pub async fn register(
|
|
|
|
_repo_details: crate::server::config::RepoDetails,
|
2024-04-11 18:30:36 +01:00
|
|
|
addr: actix::prelude::Addr<super::RepoActor>,
|
2024-04-09 19:30:05 +01:00
|
|
|
_net: kxio::network::Network,
|
|
|
|
) {
|
|
|
|
// TODO: (#15) register webhook - on success send webhook id to RepoActor
|
2024-04-11 18:30:36 +01:00
|
|
|
tokio::time::sleep(std::time::Duration::from_secs(10)).await;
|
|
|
|
addr.do_send(ValidateRepo);
|
2024-04-09 19:30:05 +01:00
|
|
|
}
|