Enum SensorSourceConfig 

pub enum SensorSourceConfig {
    JmapEmail {
        name: String,
        server: String,
        username: String,
        password_env: String,
        priority_senders: Vec<String>,
        blocked_senders: Vec<String>,
        poll_interval_seconds: u64,
    },
    Rss {
        name: String,
        feeds: Vec<String>,
        interest_keywords: Vec<String>,
        poll_interval_seconds: u64,
    },
    Image {
        name: String,
        watch_directory: String,
        poll_interval_seconds: u64,
    },
    Audio {
        name: String,
        watch_directory: String,
        whisper_model: String,
        known_contacts: Vec<String>,
        poll_interval_seconds: u64,
    },
    Weather {
        name: String,
        api_key_env: String,
        locations: Vec<String>,
        poll_interval_seconds: u64,
        alert_only: bool,
    },
    Webhook {
        name: String,
        path: String,
        secret_env: Option<String>,
    },
    Mcp {

        name: String,
        server: Box<McpServerEntry>,
        tool_name: String,
        tool_args: Value,
        kafka_topic: String,
        modality: SensorModality,
        poll_interval_seconds: u64,
        id_field: String,
        content_field: Option<String>,
        items_field: Option<String>,
        priority_senders: Vec<String>,
        blocked_senders: Vec<String>,
        enrich_tool: Option<String>,
        enrich_id_param: Option<String>,
        dedup_ttl_seconds: u64,
    
},
}

A sensor source definition.

Variants

JmapEmail

JMAP email sensor (push/poll).

Fields

name: String

Logical sensor name (used in events and routing).

server: String

JMAP server URL.

username: String

Account username for authentication.

password_env: String

Environment variable containing the password.

priority_senders: Vec<String>

Senders that get automatic Priority::High.

blocked_senders: Vec<String>

Senders whose emails are silently dropped during triage.

poll_interval_seconds: u64

Polling interval in seconds.

Rss

RSS/Atom feed sensor.

Fields

name: String

Logical sensor name.

feeds: Vec<String>

One or more feed URLs to poll.

interest_keywords: Vec<String>

Keywords that bump matched items to higher priority.

poll_interval_seconds: u64

Polling interval in seconds.

Image

Directory watcher for images.

Fields

name: String

Logical sensor name.

watch_directory: String

Directory to watch for new image files.

poll_interval_seconds: u64

Polling interval in seconds.

Audio

Directory watcher for audio files.

Fields

name: String

Logical sensor name.

watch_directory: String

Directory to watch for new audio files.

whisper_model: String

Whisper model size: “tiny”, “base”, “small”, “medium”, “large”.

known_contacts: Vec<String>

Known contacts whose voice recordings get priority triage.

poll_interval_seconds: u64

Polling interval in seconds.

Weather

Weather API sensor.

Fields

name: String

Logical sensor name.

api_key_env: String

Environment variable containing the API key.

locations: Vec<String>

Locations to fetch weather for.

poll_interval_seconds: u64

Polling interval in seconds.

alert_only: bool

When true, only promote weather alerts (not regular readings).

Webhook

Generic webhook receiver.

Fields

name: String

Logical sensor name.

path: String

URL path for the webhook endpoint (e.g., “/webhooks/github”).

secret_env: Option<String>

Environment variable containing the webhook secret.

Mcp

Generic MCP sensor — polls a tool on any MCP server.

Fields

name: String

Logical sensor name.

server: Box<McpServerEntry>

MCP server endpoint (string URL, {url, auth_header}, or {command, args, env}).

tool_name: String

MCP tool to call each poll cycle.

tool_args: Value

Arguments passed to the tool (default: {}).

kafka_topic: String

Kafka topic to produce events to.

modality: SensorModality

Sensory modality of produced events (default: "text").

poll_interval_seconds: u64

Poll interval in seconds (default: 60).

id_field: String

JSON field path for item ID (default: "id").

content_field: Option<String>

JSON field for event content (default: entire item as JSON).

items_field: Option<String>

JSON field containing items array in tool result (default: root is array).

priority_senders: Vec<String>

Priority senders for email triage (only when kafka_topic = "hb.sensor.email").

blocked_senders: Vec<String>

Blocked senders for email triage.

enrich_tool: Option<String>

Optional enrichment tool to call for each new item (e.g., gmail_get_message). When set, the sensor calls this tool with the item’s ID to fetch detailed metadata (headers, body, labels) before producing to Kafka.

enrich_id_param: Option<String>

Parameter name for the item ID when calling the enrichment tool (default: "id").

dedup_ttl_seconds: u64

Dedup TTL in seconds. Seen IDs older than this are evicted. Default: 7 days.

Implementations

impl SensorSourceConfig

pub fn name(&self) -> &str

Get the name of this sensor source.

pub fn sender_lists(&self) -> (&[String], &[String])

Get priority and blocked sender lists for trust resolution.

Returns (priority_senders, blocked_senders). Only email-type sources have these lists; other source types return empty slices.

Trait Implementations

impl Clone for SensorSourceConfig

fn clone(&self) -> SensorSourceConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SensorSourceConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SensorSourceConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.