Added all endpoints

Cargo.toml

@@ -1,5 +1,6 @@
 [package]
 name = "ragequit"
+description = "A blazingly fast drop-in replacement for the Mastodon streaming api server"
 version = "0.1.0"
 authors = ["Julian Laubstein <contact@julianlaubstein.de>"]
 edition = "2018"

rustfmt.toml

@@ -0,0 +1 @@
+max_width = 120

src/api/http/direct.rs

@@ -0,0 +1,5 @@
+use actix_web::{HttpRequest, Responder};
+
+pub fn index(_req: HttpRequest) -> impl Responder {
+    "OMG! It works!"
+}

src/api/http/hashtag.rs

@@ -0,0 +1,9 @@
+use actix_web::{HttpRequest, Responder};
+
+pub fn index(_req: HttpRequest) -> impl Responder {
+    "OMG! It works!"
+}
+
+pub fn local(_req: HttpRequest) -> impl Responder {
+    "OMG! It works!"
+}

src/api/http/list.rs

@@ -0,0 +1,5 @@
+use actix_web::{HttpRequest, Responder};
+
+pub fn index(_req: HttpRequest) -> impl Responder {
+    "OMG! It works!"
+}

src/api/http/mod.rs

@@ -0,0 +1,5 @@
+pub mod direct;
+pub mod hashtag;
+pub mod list;
+pub mod public;
+pub mod user;

src/api/http/public.rs

@@ -0,0 +1,9 @@
+use actix_web::{HttpRequest, Responder};
+
+pub fn index(_req: HttpRequest) -> impl Responder {
+    "OMG! It works!"
+}
+
+pub fn local(_req: HttpRequest) -> impl Responder {
+    "OMG! It works!"
+}

src/api/http/user.rs

@@ -0,0 +1,5 @@
+use actix_web::{HttpRequest, Responder};
+
+pub fn index(_req: HttpRequest) -> impl Responder {
+    "OMG! It works!"
+}

src/api/mod.rs

@@ -0,0 +1,2 @@
+pub mod http;
+pub mod ws;

src/api/ws/mod.rs

@@ -0,0 +1,5 @@
+use actix_web::{HttpRequest, Responder};
+
+pub fn index(_req: HttpRequest) -> impl Responder {
+    "OMG! WebSocket works!"
+}

src/main.rs

@@ -1,4 +1,6 @@
-use actix_web::{server, App, HttpRequest, Responder};
+mod api;
+
+use actix_web::{server, App};
 use env_logger::Builder;
 use log::info;
 use std::net::SocketAddr;
@@ -19,12 +21,22 @@ fn main() {
 
     info!("starting streaming api server");
 
-    server::new(|| App::new().resource("/api/v1/streaming", |r| r.with(index)))
-        .bind(SocketAddr::from(([127, 0, 0, 1], args.port)))
-        .unwrap()
-        .run();
-}
+    let addr: SocketAddr = ([127, 0, 0, 1], args.port).into();
 
-fn index(_req: HttpRequest) -> impl Responder {
-    "OMG! It works!"
+    use api::{http, ws};
+
+    server::new(|| {
+        App::new()
+            .resource("/api/v1/streaming/user", |r| r.with(http::user::index))
+            .resource("/api/v1/streaming/public", |r| r.with(http::public::index))
+            .resource("/api/v1/streaming/public/local", |r| r.with(http::public::local))
+            .resource("/api/v1/streaming/direct", |r| r.with(http::direct::index))
+            .resource("/api/v1/streaming/hashtag", |r| r.with(http::hashtag::index))
+            .resource("/api/v1/streaming/hashtag/local", |r| r.with(http::hashtag::local))
+            .resource("/api/v1/streaming/list", |r| r.with(http::list::index))
+            .resource("/api/v1/streaming", |r| r.with(ws::index))
+    })
+    .bind(addr)
+    .unwrap()
+    .run();
 }