Function rpc_router

libs/@local/graph/api/src/rpc/mod.rs:66–96

(
    dependencies: Dependencies<S, C>,
    notifications: N,
)

}

pub fn rpc_router<S, C, N>(
    dependencies: Dependencies<S, C>,
    notifications: N,
) -> (
    Router<impl Route<RequestBody, ResponseBody: Send, Future: Send> + Send>,
    Task<Account, N>,
)
where
    S: StorePool + Send + Sync + 'static,
    C: ReportEncoder + ReportDecoder + Clone + Send + Sync + 'static,
    for<'p> S::Store<'p>: PrincipalStore,
{
    let builder = RouterBuilder::new(dependencies.codec)
        .with_builder(|builder| {
            builder
                .layer(HandleReportLayer::new())
                .layer(HandleBodyReportLayer::new())
        })
        .register(AuthenticationDelegate::new(AuthenticationServer))
        .register(AccountDelegate::new(AccountServer {
            store_pool: dependencies.store,
            temporal_client: dependencies.temporal_client,
        }))
        .register(EchoDelegate::new(EchoServer));

    let task = builder.background_task(notifications);

    let router = builder.build();

    (router, task)
}