LibrePages/conductor
4
0
Fork 0
Code Issues 4 Pull requests 4 Projects Releases Packages Wiki Activity

feat: Process events with conductor object
All checks were successful
ci/woodpecker/push/woodpecker Pipeline was successful
Details

Browse source
This commit is contained in:
Aravinth Manivannan 2022-10-05 17:00:55 +05:30
parent a73111b36f
commit 96cd918dfe
Signed by: realaravinth
GPG key ID: AD9F0F08E855ED88
1 changed files with 4 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/api/v1/webhook.rs
View file

@ -19,6 +19,8 @@ use std::collections::HashMap;
use actix_web::{web, HttpRequest, HttpResponse, Responder}; use actix_web::{web, HttpRequest, HttpResponse, Responder};
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
use libconductor::{Conductor, EventType};
use crate::errors::*; use crate::errors::*;
use crate::AppCtx; use crate::AppCtx;
use crate::*; use crate::*;
@ -42,23 +44,15 @@ pub fn services(cfg: &mut web::ServiceConfig) {
cfg.service(post_event); 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")] #[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> { async fn post_event(ctx: AppCtx, payload: web::Json<EventType>) -> ServiceResult<impl Responder> {
ctx.conductor.process(payload.into_inner()).await;
Ok(HttpResponse::Created()) Ok(HttpResponse::Created())
} }
#[cfg(test)] #[cfg(test)]
pub mod tests { pub mod tests {
use actix_web::{ use actix_web::{http::StatusCode, test, App};
http::{header, StatusCode},
test, App,
};
use super::*; use super::*;