nyx-agent-api 0.1.0

Implementation-detail loopback HTTP API and WebSocket server for nyx-agent.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

//! Loopback HTTP + WebSocket surface for the nyx-agent daemon.
//!
//! This crate is published so the `nyx-agent` binary can be installed
//! from crates.io with versioned internal dependencies. It is an
//! implementation detail of Nyx Agent, not a stable public API.
//!
//! The `nyx-agent` binary owns the long-lived daemon process and
//! wires three things into [`ServerState`]:
//!
//! - a connected [`nyx_agent_core::Store`] for read-only queries,
//! - a tokio broadcast sink ([`nyx_agent_types::event::EventSink`])
//!   that the run dispatcher publishes lifecycle events through,
//! - a [`ScanTrigger`] handle the API uses to kick off a manual scan.
//!
//! Subscribers attach to the broadcast sink through the
//! `/api/v1/events?run_id=<id>` WebSocket endpoint without the
//! dispatcher knowing about them.

pub mod integrations;
pub mod router;
pub mod state;
pub mod webhook;

pub use integrations::spawn_integration_delivery_task;
pub use router::build_router;
pub use state::{
    ApiError, AuthConfig, AuthSetupAgent, AuthSetupAgentError, AuthSetupAgentFuture,
    AuthSetupAgentOutput, AuthSetupAgentRequest, AuthSetupJobStore, EventReplay, ProjectSetupAgent,
    ProjectSetupAgentError, ProjectSetupAgentFuture, ProjectSetupAgentOutput,
    ProjectSetupAgentRequest, ProjectSetupJobStore, RemediationAgent, RemediationAgentError,
    RemediationAgentFuture, RemediationAgentOutput, RemediationAgentRequest,
    RemediationChangedFile, RemediationJobError, RemediationJobRecord, RemediationJobStore,
    ScanRunOverrides, ScanTrigger, ScanTriggerError, ScanTriggerSource, SeedSetupAgent,
    SeedSetupAgentError, SeedSetupAgentFuture, SeedSetupAgentOutput, SeedSetupAgentRequest,
    ServerState, SetupContext,
};
pub use webhook::{
    sign as sign_webhook, verify_signature as verify_webhook_signature, EnvSecretResolver,
    StaticSecretResolver, WebhookConcurrencyLimit, WebhookConfig, WebhookRateLimiter,
    WebhookResponse, WebhookSecretResolver, DEFAULT_WEBHOOK_MAX_CONCURRENT,
    DEFAULT_WEBHOOK_RATE_LIMIT_BURST, DEFAULT_WEBHOOK_RATE_LIMIT_MAX_IPS,
    DEFAULT_WEBHOOK_RATE_LIMIT_PER_MINUTE, MAX_WEBHOOK_BODY_BYTES,
};