Macro impl_job_registry 

macro_rules! impl_job_registry {
    ($state:ty, $($job_type:ty),*) => { ... };
}

A macro for implementing a job registry that handles job dispatch.

This macro generates a Jobs struct that implements JobRegistry for your application state. It creates a match statement that routes jobs to their appropriate handlers based on the job name.

Usage

use cja::impl_job_registry;
use cja::jobs::Job;
use cja::app_state::AppState;
use cja::server::cookies::CookieKey;
use serde::{Serialize, Deserialize};

// Define your app state
#[derive(Clone)]
struct MyAppState {
    db: sqlx::PgPool,
    cookie_key: CookieKey,
}

impl AppState for MyAppState {
    fn version(&self) -> &str { "1.0.0" }
    fn db(&self) -> &sqlx::PgPool { &self.db }
    fn cookie_key(&self) -> &CookieKey { &self.cookie_key }
}

// Define your job types
#[derive(Debug, Serialize, Deserialize, Clone)]
struct ProcessPaymentJob {
    user_id: i32,
    amount_cents: i64,
}

#[derive(Debug, Serialize, Deserialize, Clone)]
struct SendNotificationJob {
    user_id: i32,
    message: String,
}

// Implement the Job trait for each job type
#[async_trait::async_trait]
impl Job<MyAppState> for ProcessPaymentJob {
    const NAME: &'static str = "ProcessPaymentJob";
    async fn run(&self, _: MyAppState) -> color_eyre::Result<()> {
        println!("Processing payment for user {}", self.user_id);
        Ok(())
    }
}

#[async_trait::async_trait]
impl Job<MyAppState> for SendNotificationJob {
    const NAME: &'static str = "SendNotificationJob";
    async fn run(&self, _: MyAppState) -> color_eyre::Result<()> {
        println!("Sending notification to user {}: {}", self.user_id, self.message);
        Ok(())
    }
}

// Register all your job types with the macro
impl_job_registry!(MyAppState, ProcessPaymentJob, SendNotificationJob);