feat: webhook-connector (#2355)

dozer-ingestion/Cargo.toml

@@ -19,6 +19,7 @@ dozer-ingestion-mysql = { path = "./mysql" }
 dozer-ingestion-object-store = { path = "./object-store" }
 dozer-ingestion-postgres = { path = "./postgres" }
 dozer-ingestion-snowflake = { path = "./snowflake", optional = true }
+dozer-ingestion-webhook = { path = "./webhook" }
 
 tokio = { version = "1", features = ["full"] }
 futures = "0.3.28"

dozer-ingestion/src/lib.rs

@@ -28,6 +28,7 @@ use dozer_ingestion_postgres::{
 };
 #[cfg(feature = "snowflake")]
 use dozer_ingestion_snowflake::connector::SnowflakeConnector;
+use dozer_ingestion_webhook::connector::WebhookConnector;
 use errors::ConnectorError;
 use tokio::runtime::Runtime;
 
@@ -132,6 +133,9 @@ pub fn get_connector(
         ConnectionConfig::Dozer(dozer_config) => {
             Ok(Box::new(NestedDozerConnector::new(dozer_config)))
         }
+        ConnectionConfig::Webhook(webhook_config) => {
+            Ok(Box::new(WebhookConnector::new(webhook_config)))
+        }
         ConnectionConfig::JavaScript(javascript_config) => Ok(Box::new(JavaScriptConnector::new(
             runtime,
             javascript_config,

dozer-ingestion/webhook/Cargo.toml

@@ -0,0 +1,15 @@
+[package]
+name = "dozer-ingestion-webhook"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+dozer-ingestion-connector = { path = "../connector" }
+actix-web = "4.4.1"
+env_logger = "0.11.1"
+
+[dev-dependencies]
+tokio = { version = "1.0", features = ["full", "test-util"] }
+reqwest = { version = "0.11.23", features = ["json", "blocking"] }