Add example web_hook configuration after registration

Signed-off-by: Federico Busetti <[email protected]>

Author: febus982

auth_volumes/kratos/kratos.yml

@@ -85,6 +85,21 @@ selfservice:
         password:
           hooks:
             - hook: session
+            - hook: web_hook
+              config:
+                url: http://dev:8000/user_registered/
+                method: "POST"
+#                headers: { }
+                # https://www.ory.sh/docs/guides/integrate-with-ory-cloud-through-webhooks#jsonnet-templating
+                body: file:///etc/config/kratos/user_registered.jsonnet
+                can_interrupt: false
+                emit_analytics_event: false
+#                auth:
+#                  type: api_key
+#                  config:
+#                    name: ""
+#                    value: ""
+#                    in: header
 #            - hook: show_verification_ui
 
 log:
@@ -107,7 +122,7 @@ hashers:
     cost: 8
 
 identity:
-  default_schema_id: staff
+  default_schema_id: default
   schemas:
     - id: staff
       url: file:///etc/config/kratos/staff.schema.json

auth_volumes/kratos/user_registered.jsonnet

@@ -0,0 +1,7 @@
+function(ctx) {
+    user_id: ctx.identity.id,
+    traits: {
+    email: ctx.identity.traits.email,
+    name: ctx.identity.traits.name,
+  }
+}

src/http_app/routes/__init__.py

@@ -1,11 +1,12 @@
 from fastapi import FastAPI
 
-from http_app.routes import api, events, graphql, hello, ping
+from http_app.routes import api, events, graphql, hello, ping, user_registered_hook
 
 
 def init_routes(app: FastAPI) -> None:
     app.include_router(api.router)
     app.include_router(ping.router)
     app.include_router(hello.router)
     app.include_router(events.router)
+    app.include_router(user_registered_hook.router)
     app.include_router(graphql.router, prefix="/graphql")

src/http_app/routes/user_registered_hook.py

@@ -0,0 +1,11 @@
+import logging
+
+from fastapi import APIRouter, Request
+
+router = APIRouter(prefix="/user_registered")
+
+
+@router.post("/")
+async def user_registered(request: Request):
+    logging.info("User registered", extra={"body": await request.json()})
+    return {"user_registered": "OK"}