From 96cd918dfe3faa2b9dbc1f44efe8ef3bd0aa271a Mon Sep 17 00:00:00 2001
From: realaravinth <realaravinth@batsense.net>
Date: Wed, 5 Oct 2022 17:00:55 +0530
Subject: [PATCH] feat: Process events with conductor object

---
 src/api/v1/webhook.rs | 14 ++++----------
 1 file changed, 4 insertions(+), 10 deletions(-)

diff --git a/src/api/v1/webhook.rs b/src/api/v1/webhook.rs
index 47ffafe..c6d8f6d 100644
--- a/src/api/v1/webhook.rs
+++ b/src/api/v1/webhook.rs
@@ -19,6 +19,8 @@ use std::collections::HashMap;
 use actix_web::{web, HttpRequest, HttpResponse, Responder};
 use serde::{Deserialize, Serialize};
 
+use libconductor::{Conductor, EventType};
+
 use crate::errors::*;
 use crate::AppCtx;
 use crate::*;
@@ -42,23 +44,15 @@ pub fn services(cfg: &mut web::ServiceConfig) {
     cfg.service(post_event);
 }
 
-#[derive(Deserialize, Serialize, Debug)]
-#[serde(untagged)]
-enum EventType {
-    NewHostname(String),
-}
-
 #[actix_web_codegen_const_routes::post(path = "API_V1_ROUTES.webhook.post_event")]
 async fn post_event(ctx: AppCtx, payload: web::Json<EventType>) -> ServiceResult<impl Responder> {
+    ctx.conductor.process(payload.into_inner()).await;
     Ok(HttpResponse::Created())
 }
 
 #[cfg(test)]
 pub mod tests {
-    use actix_web::{
-        http::{header, StatusCode},
-        test, App,
-    };
+    use actix_web::{http::StatusCode, test, App};
 
     use super::*;