Crate cloudevents_sdk_actix_web

This crate integrates the cloudevents-sdk with Actix web to easily send and receive CloudEvents.

To deserialize an HTTP request as CloudEvent:

use cloudevents_sdk_actix_web::HttpRequestExt;
use actix_web::{HttpRequest, web, post};

#[post("/")]
async fn post_event(req: HttpRequest, payload: web::Payload) -> Result<String, actix_web::Error> {
    let event = req.to_event(payload).await?;
    println!("Received Event: {:?}", event);
    Ok(format!("{:?}", event))
}

To serialize a CloudEvent to an HTTP response:

use cloudevents_sdk_actix_web::HttpResponseBuilderExt;
use actix_web::{HttpRequest, web, get, HttpResponse};
use cloudevents::{EventBuilderV10, EventBuilder};
use serde_json::json;

#[get("/")]
async fn get_event() -> Result<HttpResponse, actix_web::Error> {
    Ok(HttpResponse::Ok()
        .event(
            EventBuilderV10::new()
                .id("0001")
                .ty("example.test")
                .source("http://localhost/")
                .data("application/json", json!({"hello": "world"}))
                .build()
                .expect("No error while building the event"),
        )
        .await?
    )
}

Check out the cloudevents-sdk docs for more details on how to use cloudevents::Event

Structs

HttpRequestDeserializer	Wrapper for HttpRequest that implements MessageDeserializer trait.
HttpResponseSerializer	Wrapper for [HttpResponseBuilder] that implements StructuredSerializer and BinarySerializer.

Traits

HttpRequestExt	Extention Trait for HttpRequest which acts as a wrapper for the function request_to_event().
HttpResponseBuilderExt	Extension Trait for [HttpResponseBuilder] which acts as a wrapper for the function event_to_response().

Functions

event_to_response	Method to fill an [HttpResponseBuilder] with an Event.
request_to_event	Method to transform an incoming HttpRequest to Event.