add workspace Cargo.toml and docker-compose.yml

Cargo.toml

@@ -0,0 +1,2 @@
+[workspace]
+members = [ "datafetcher","dataworker"]

datafetcher/Cargo.toml

@@ -0,0 +1,12 @@
+[package]
+name = "datafetcher"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+chrono = "0.4.39"
+maud = { version = "0.26.0", features = ["rocket"] }
+reqwest = "0.12.12"
+rocket = "0.5.1"
+tokio = { version = "1.43.0", features = ["rt-multi-thread", "macros", "time"] }
+dataworker = { path = "../dataworker" }

datafetcher/src/lib.rs

@@ -0,0 +1,5 @@
+use std::time::Duration;
+
+fn main() {
+    let time_window = Duration::from_secs(3600);
+}

datafetcher/src/main.rs

@@ -0,0 +1,42 @@
+#[macro_use]
+extern crate rocket;
+use maud::{html, Markup};
+use rocket::response::stream::{Event, EventStream};
+use rocket::tokio::time::{interval, Duration};
+
+#[get("/sse")]
+async fn sse() -> EventStream![] {
+    EventStream! {
+        let mut interval = interval(Duration::from_secs(2));
+        loop {
+            interval.tick().await;
+            yield Event::data(format!("Updated time: {:?}", chrono::Utc::now()));
+        }
+    }
+}
+
+#[get("/")]
+fn index() -> Markup {
+    html! {
+        html {
+            head {
+                title { "Live Updates with SSE" }
+                script {
+                    "const eventSource = new EventSource('/sse');
+                    eventSource.onmessage = (event) => {
+                        document.getElementById('updates').innerText = event.data;
+                    };"
+                }
+            }
+            body {
+                h1 { "Live Updates Example" }
+                div id="updates" { "Waiting for updates..." }
+            }
+        }
+    }
+}
+
+#[launch]
+fn rocket() -> _ {
+    rocket::build().mount("/", routes![index, sse])
+}

docker-compose.yml

@@ -0,0 +1,10 @@
+services:
+
+  db:
+    image: postgres
+    restart: always
+    environment:
+      POSTGRES_HOST_AUTH_METHOD: trust
+      POSTGRES_USER: postgres
+    ports:
+      - 5432:5432