From 4e4ed089cdf73e5baa071baa95ecacd4202a2883 Mon Sep 17 00:00:00 2001
From: Ellie Huxtable <ellie@posthog.com>
Date: Thu, 14 Sep 2023 13:49:34 +0100
Subject: [PATCH] Format and delete

---
 capture-server/src/main.rs |  2 +-
 capture/src/main.rs        | 43 --------------------------------------
 2 files changed, 1 insertion(+), 44 deletions(-)
 delete mode 100644 capture/src/main.rs

diff --git a/capture-server/src/main.rs b/capture-server/src/main.rs
index 2bc1609..c2f22bc 100644
--- a/capture-server/src/main.rs
+++ b/capture-server/src/main.rs
@@ -1,7 +1,7 @@
 use std::env;
 use std::net::SocketAddr;
 
-use capture::{time, sink, router};
+use capture::{router, sink, time};
 
 #[tokio::main]
 async fn main() {
diff --git a/capture/src/main.rs b/capture/src/main.rs
deleted file mode 100644
index b7e549f..0000000
--- a/capture/src/main.rs
+++ /dev/null
@@ -1,43 +0,0 @@
-use std::env;
-use std::net::SocketAddr;
-
-use crate::time::SystemTime;
-
-mod api;
-mod capture;
-mod event;
-mod router;
-mod sink;
-mod time;
-mod token;
-mod utils;
-
-#[tokio::main]
-async fn main() {
-    let use_print_sink = env::var("PRINT_SINK").is_ok();
-    let address = env::var("ADDRESS").unwrap_or(String::from("127.0.0.1:3000"));
-
-    let app = if use_print_sink {
-        router::router(SystemTime {}, sink::PrintSink {})
-    } else {
-        let brokers = env::var("KAFKA_BROKERS").expect("Expected KAFKA_BROKERS");
-        let topic = env::var("KAFKA_TOPIC").expect("Expected KAFKA_TOPIC");
-
-        let sink = sink::KafkaSink::new(topic, brokers).unwrap();
-
-        router::router(SystemTime {}, sink)
-    };
-
-    // initialize tracing
-    tracing_subscriber::fmt::init();
-
-    // run our app with hyper
-    // `axum::Server` is a re-export of `hyper::Server`
-
-    tracing::info!("listening on {}", address);
-
-    axum::Server::bind(&address.parse().unwrap())
-        .serve(app.into_make_service_with_connect_info::<SocketAddr>())
-        .await
-        .unwrap();
-}