wip: 83B78D40-D7CB-4419-9FE7-E7D858909443

1 files changed, 40 insertions, 0 deletions

diff --git a/src/push/handlers/register.rs b/src/push/handlers/register.rs
new file mode 100644
index 0000000..201928b
--- /dev/null
+++ b/src/push/handlers/register.rs
@@ -0,0 +1,40 @@
+use axum::extract::{Json, State};
+use web_push::SubscriptionInfo;
+
+use crate::{app::App, error::Internal, push::Id, token::extract::Identity};
+
+#[derive(serde::Deserialize)]
+pub struct Request {
+    endpoint: String,
+    p256dh: String,
+    auth: String,
+}
+
+#[derive(serde::Serialize)]
+pub struct Response {
+    id: Id,
+}
+
+pub async fn handler(
+    State(app): State<App>,
+    identity: Identity,
+    Json(request): Json<Request>,
+) -> Result<Json<Response>, Internal> {
+    let subscription = request.into();
+
+    let id = app.push().register(&identity.user, &subscription).await?;
+
+    Ok(Json(Response { id }))
+}
+
+impl From<Request> for SubscriptionInfo {
+    fn from(request: Request) -> Self {
+        let Request {
+            endpoint,
+            p256dh,
+            auth,
+        } = request;
+        let info = Self::new(endpoint, p256dh, auth);
+        info
+    }
+}