hyperlane-macros 1.6.0

hyperlane-macros

hyperlane macro.

Installation

To use this crate, you can run cmd:

cargo add hyperlane-macros

Available Macros

Server Instance Macros

#[hyperlane(variable_name)] - Create a new Server instance with the specified variable name at the beginning of the function

HTTP Method Macros

#[methods(method1, method2, ...)] - Accepts multiple HTTP methods
#[get] - GET method handler
#[post] - POST method handler
#[put] - PUT method handler
#[delete] - DELETE method handler
#[patch] - PATCH method handler
#[head] - HEAD method handler
#[options] - OPTIONS method handler
#[connect] - CONNECT method handler
#[trace] - TRACE method handler

Protocol Check Macros

#[ws] - WebSocket check, ensures function only executes for WebSocket upgrade requests
#[http] - HTTP check, ensures function only executes for standard HTTP requests
#[h2c] - HTTP/2 Cleartext check, ensures function only executes for HTTP/2 cleartext requests
#[http0_9] - HTTP/0.9 check, ensures function only executes for HTTP/0.9 protocol requests
#[http1_0] - HTTP/1.0 check, ensures function only executes for HTTP/1.0 protocol requests
#[http1_1] - HTTP/1.1 check, ensures function only executes for HTTP/1.1 protocol requests
#[http1_1_or_higher] - HTTP/1.1 or higher version check, ensures function only executes for HTTP/1.1 or newer protocol versions
#[http2] - HTTP/2 check, ensures function only executes for HTTP/2 protocol requests
#[http3] - HTTP/3 check, ensures function only executes for HTTP/3 protocol requests
#[tls] - TLS check, ensures function only executes for TLS-secured connections

Response Setting Macros

#[response_status_code(code)] - Set response status code (supports literals and global constants)
#[response_reason_phrase("phrase")] - Set response reason phrase (supports literals and global constants)
#[response_header("key", "value")] - Set response header (supports literals and global constants)
#[response_body("data")] - Set response body (supports literals and global constants)

Send Operation Macros

#[send] - Send complete response (headers and body) after function execution
#[send_body] - Send only response body after function execution
#[send_once] - Send complete response exactly once after function execution
#[send_once_body] - Send response body exactly once after function execution

Flush Macros

#[flush] - Flush response stream after function execution to ensure immediate data transmission

Aborted Macros

#[aborted] - Handle aborted requests, providing cleanup logic for prematurely terminated connections

Closed Operation Macros

#[closed] - Handle closed streams, providing cleanup logic for completed connections

Filter Macros

#[filter_unknown_method] - Filter unknown HTTP methods, handling requests with non-standard methods
#[filter_unknown_upgrade] - Filter unknown upgrade requests, handling requests with non-standard upgrade protocols
#[filter_unknown_version] - Filter unknown HTTP versions, handling requests with non-standard HTTP protocol versions
#[filter_unknown] - Combined filter for unknown method, upgrade, and version

Request Body Macros

#[request_body(variable_name)] - Extract raw request body into specified variable with RequestBody type
#[request_body_json(variable_name: type)] - Parse request body as JSON into specified variable and type

Attribute Macros

#[attribute(key => variable_name: type)] - Extract a specific attribute by key into a typed variable

Attributes Macros

#[attributes(variable_name)] - Get all attributes as a HashMap for comprehensive attribute access

Route Param Macros

#[route_param(key => variable_name)] - Extract a specific route parameter by key into a variable

Route Params Macros

#[route_params(variable_name)] - Get all route parameters as a collection

Request Query Macros

#[request_query(key => variable_name)] - Extract a specific query parameter by key from the URL query string

Request Querys Macros

#[request_querys(variable_name)] - Get all query parameters as a collection

Request Header Macros

#[request_header(key => variable_name)] - Extract a specific HTTP header by name from the request

Request Headers Macros

#[request_headers(variable_name)] - Get all HTTP headers as a collection

Hook Macros

#[pre_hook(function_name)] - Execute specified function before the main handler function
#[post_hook(function_name)] - Execute specified function after the main handler function

Response Header Macros

#[response_header(key => value)] - Set a specific HTTP response header with the given key and value

Response Body Macros

#[response_body(value)] - Set the HTTP response body with the given value

Best Practice Warning

Request related macros are mostly query functions, while response related macros are mostly assignment functions.
When using pre_hook or post_hook macros, it is not recommended to combine them with other macros (such as #[get], #[post], #[http], etc.) on the same function. These macros should be placed in the hook functions themselves. If you are not clear about how macros are expanded, combining them may lead to problematic code behavior.

Example Usage

#![allow(dead_code)]
use hyperlane::*;
use hyperlane_macros::*;
use serde::{Deserialize, Serialize};

const TEST_ATTRIBUTE_KEY: &str = "test_attribute_key";
const CUSTOM_STATUS_CODE: i32 = 200;
const CUSTOM_REASON: &str = "Accepted";
const CUSTOM_HEADER_NAME: &str = "X-Custom-Header";
const CUSTOM_HEADER_VALUE: &str = "custom-value";
const RESPONSE_DATA: &str = "{\"status\": \"success\"}";

#[derive(Debug, Serialize, Deserialize, Clone)]
struct TestData {
    name: String,
    age: u32,
}

#[get]
#[http]
async fn ctx_pre_hook(ctx: Context) {}

#[flush]
#[send]
#[response_status_code(200)]
async fn ctx_post_hook(ctx: Context) {}

#[send]
#[response_status_code(201)]
#[response_reason_phrase("Created")]
#[response_header("Content-Type" => "application/json")]
#[response_body("{\"message\": \"Resource created\"}")]
async fn test_new_macros_literals(ctx: Context) {}

#[send]
#[response_status_code(CUSTOM_STATUS_CODE)]
#[response_reason_phrase(CUSTOM_REASON)]
#[response_header(CUSTOM_HEADER_NAME => CUSTOM_HEADER_VALUE)]
#[response_body(RESPONSE_DATA)]
async fn response(ctx: Context) {}

#[connect]
async fn connect(ctx: Context) {
    let _ = ctx.set_response_body("connect").await.send().await;
}

#[delete]
async fn delete(ctx: Context) {
    let _ = ctx.set_response_body("delete").await.send().await;
}

#[head]
async fn head(ctx: Context) {
    let _ = ctx.set_response_body("head").await.send().await;
}

#[options]
async fn options(ctx: Context) {
    let _ = ctx.set_response_body("options").await.send().await;
}

#[patch]
async fn patch(ctx: Context) {
    let _ = ctx.set_response_body("patch").await.send().await;
}

#[put]
async fn put(ctx: Context) {
    let _ = ctx.set_response_body("put").await.send().await;
}

#[trace]
async fn trace(ctx: Context) {
    let _ = ctx.set_response_body("trace").await.send().await;
}

#[send]
#[h2c]
async fn h2c(ctx: Context) {
    let _ = ctx.set_response_body("h2c").await;
}

#[send]
#[http]
async fn http_only(ctx: Context) {
    let _ = ctx.set_response_body("http").await;
}

#[send]
#[http0_9]
async fn http0_9(ctx: Context) {
    let _ = ctx.set_response_body("http0.9").await;
}

#[send]
#[http1_0]
async fn http1_0(ctx: Context) {
    let _ = ctx.set_response_body("http1.0").await;
}

#[send]
#[http1_1]
async fn http1_1(ctx: Context) {
    let _ = ctx.set_response_body("http1.1").await;
}

#[send]
#[http2]
async fn http2(ctx: Context) {
    let _ = ctx.set_response_body("http2").await;
}

#[send]
#[http3]
async fn http3(ctx: Context) {
    let _ = ctx.set_response_body("http3").await;
}

#[send]
#[tls]
async fn tls(ctx: Context) {
    let _ = ctx.set_response_body("tls").await;
}

#[send]
#[http1_1_or_higher]
async fn http1_1_or_higher(ctx: Context) {
    let _ = ctx.set_response_body("http1.1+").await;
}

#[send]
#[filter_unknown_method]
async fn unknown_method(ctx: Context) {
    let _ = ctx.set_response_body("unknown method").await;
}

#[send]
#[filter_unknown_upgrade]
async fn unknown_upgrade(ctx: Context) {
    let _ = ctx.set_response_body("unknown upgrade").await;
}

#[send]
#[filter_unknown_version]
async fn unknown_version(ctx: Context) {
    let _ = ctx.set_response_body("unknown version").await;
}

#[send]
#[filter_unknown]
async fn unknown_all(ctx: Context) {
    let _ = ctx.set_response_body("unknown all").await;
}

#[send_body]
#[ws]
#[get]
async fn get(ctx: Context) {
    let _ = ctx.set_response_body("get").await;
}

#[send_once]
#[post]
async fn post(ctx: Context) {
    let _ = ctx.set_response_body("post").await;
}

#[send_once_body]
#[ws]
async fn websocket(ctx: Context) {
    let _ = ctx.set_response_body("websocket").await;
}

#[send]
#[pre_hook(ctx_pre_hook)]
#[post_hook(ctx_post_hook)]
async fn ctx_hook(ctx: Context) {
    let _ = ctx.set_response_body("Testing hook macro").await;
}

#[closed]
#[send]
#[response_reason_phrase("OK")]
#[response_status_code(200)]
#[methods(get, post)]
#[http]
async fn get_post(ctx: Context) {
    let _ = ctx.set_response_body("get_post").await;
}

#[send]
#[attributes(request_attributes)]
async fn attributes(ctx: Context) {
    let response: String = format!("{:?}", request_attributes);
    let _ = ctx.set_response_body(response).await;
}

#[send]
#[route_params(request_route_params)]
async fn route_params(ctx: Context) {
    let response: String = format!("{:?}", request_route_params);
    let _ = ctx.set_response_body(response).await;
}

#[send]
#[request_querys(request_querys)]
async fn request_querys(ctx: Context) {
    let response: String = format!("{:?}", request_querys);
    let _ = ctx.set_response_body(response).await;
}

#[send]
#[request_headers(request_headers)]
async fn request_headers(ctx: Context) {
    let response: String = format!("{:?}", request_headers);
    let _ = ctx.set_response_body(response).await;
}

#[send]
#[route_param("test" => request_route_param)]
async fn route_param(ctx: Context) {
    if let Some(data) = request_route_param {
        let _ = ctx.set_response_body(data).await;
    }
}

#[send]
#[request_query("test" => request_query_option)]
async fn request_query(ctx: Context) {
    if let Some(data) = request_query_option {
        let _ = ctx.set_response_body(data).await;
    }
}

#[send]
#[request_header(HOST => request_header_option)]
async fn request_header(ctx: Context) {
    if let Some(data) = request_header_option {
        let _ = ctx.set_response_body(data).await;
    }
}

#[send]
#[request_body(raw_body)]
async fn request_body(ctx: Context) {
    let response: String = format!("Raw body: {:?}", raw_body);
    let _ = ctx.set_response_body(response).await;
}

#[send]
#[attribute(TEST_ATTRIBUTE_KEY => request_attribute_option: TestData)]
async fn attribute(ctx: Context) {
    if let Some(data) = request_attribute_option {
        let response: String = format!("name={}, age={}", data.name, data.age);
        let _ = ctx.set_response_body(response).await;
    }
}

#[send]
#[request_body_json(request_data_result: TestData)]
async fn request_body_json(ctx: Context) {
    if let Ok(data) = request_data_result {
        let response: String = format!("name={}, age={}", data.name, data.age);
        let _ = ctx.set_response_body(response).await;
    }
}

fn main() {}

License

This project is licensed under the MIT License. See the LICENSE file for details.

Contributing

Contributions are welcome! Please open an issue or submit a pull request.

Contact

For any inquiries, please reach out to the author at root@ltpp.vip.