drifting-in-space / driftdb Goto Github PK

$ git clone ...
$ cd driftdb
$ cargo build --release
...
   Compiling worker-macros v0.0.6
   Compiling worker v0.0.11
   Compiling driftdb-server v0.1.1 (/memfs/git/driftdb/driftdb-server)
   Compiling driftdb-worker v0.1.1 (/memfs/git/driftdb/driftdb-worker)
error: driftdb-worker should only be compiled to WebAssembly. Use driftdb-server for other targets.
   --> driftdb-worker/src/lib.rs:102:1
    |
102 | / compile_error!(
103 | |     "driftdb-worker should only be compiled to WebAssembly. Use driftdb-server for other targets."
104 | | );
    | |_^

error: could not compile `driftdb-worker` due to previous error
warning: build failed, waiting for other jobs to finish...

$ xh post http://localhost:8080/new
HTTP/1.1 405 Method Not Allowed
Allow: GET,HEAD
Content-Length: 0
Date: Sat, 04 Feb 2023 13:31:05 GMT

$ ./driftdb-server
2023-02-04T13:31:05.110411Z  INFO request{method=POST uri=/new version=HTTP/1.1}: tower_http::trace::on_response: finished processing request latency=0 ms status=405

Create a room by sending a POST request to /new. It returns a JSON object with the following fields:

    room: random string uniqely representing the new room (string).
    socket_url: WebSocket URL to connect to the room for real-time reads and write (string).
    http_url: HTTP URL to send messages to the room from non-WebSocket clients (string).

Given a room ID returned by /new, you can receive the same JSON object by sending a GET request to /room/<ROOM_ID>.

fetch('http://localhost:3000/new', {method:"post"}).then((response) => response.json()).then((data) => console.log(data))

fetch('http://localhost:3000/room/<UUID from previous step>/send', {method:"post", mode: "cors", body: JSON.stringify({
    "action": {"type": "append"},
    "key": "slider",
    "type": "push",
    "value": 55
})}).catch((error) => console.dir(error))

POST http://localhost:3000/room/28573b90-a80c-4369-a2fa-c809c440a9d5/send 415 (Unsupported Media Type)
(anonymous) @ VM65:1

fetch('http://localhost:3000/room/28573b90-a80c-4369-a2fa-c809c440a9d5/send', {method:"post", mode: "cors", headers: { 'Content-Type': "application/json"}, body: JSON.stringify({
    "action": {"type": "append"},
    "key": "slider",
    "type": "push",
    "value": 55
})}).catch((error) => console.dir(error))

Access to fetch at 'http://localhost:3000/room/28573b90-a80c-4369-a2fa-c809c440a9d5/send' from origin 'https://driftdb.com' has been blocked by CORS policy: Request header field content-type is not allowed by Access-Control-Allow-Headers in preflight response.

diff --git a/Cargo.lock b/Cargo.lock
index 2af49be..546c066 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -281,6 +281,7 @@ dependencies = [
  "clap",
  "dashmap",
  "driftdb",
+ "http",
  "hyper",
  "serde",
  "serde_json",
@@ -462,9 +463,9 @@ dependencies = [
 
 [[package]]
 name = "http"
-version = "0.2.8"
+version = "0.2.9"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "75f43d41e26995c17e71ee126451dd3941010b0514a81a9d11f3b341debc2399"
+checksum = "bd6effc99afb63425aff9b05836f029929e345a6148a14b7ecd5ab67af944482"
 dependencies = [
  "bytes",
  "fnv",
diff --git a/driftdb-server/Cargo.toml b/driftdb-server/Cargo.toml
index 96b4bd2..e22dd10 100644
--- a/driftdb-server/Cargo.toml
+++ b/driftdb-server/Cargo.toml
@@ -23,3 +23,4 @@ tracing-subscriber = { version = "0.3.16", features = ["env-filter"] }
 driftdb = {path = "../driftdb", version="0.1.0"}
 dashmap = "5.4.0"
 uuid = { version = "1.3.0", features = ["v4"] }
+http = "0.2.9"
diff --git a/driftdb-server/src/server.rs b/driftdb-server/src/server.rs
index 7d37dd2..f9890aa 100644
--- a/driftdb-server/src/server.rs
+++ b/driftdb-server/src/server.rs
@@ -16,6 +16,7 @@ use tower_http::{
     cors::{AllowOrigin, CorsLayer},
     trace::{DefaultMakeSpan, DefaultOnRequest, DefaultOnResponse, TraceLayer},
 };
+use http::header::{CONTENT_TYPE};
 use tracing::Level;
 use uuid::Uuid;
 
@@ -213,7 +214,8 @@ impl RoomResult {
 
 pub fn api_routes() -> Result<Router> {
     let cors = CorsLayer::new()
-        .allow_methods([Method::GET])
+        .allow_methods([Method::GET, Method::POST])
+        .allow_headers([CONTENT_TYPE])
         .allow_origin(AllowOrigin::any());
 
     let room_map = RoomMap::new();