Integrations

use aether::connectors::Connector

connector MyCustomConnector {
    config: ConnectorConfig {
        name: "my-service",
        description: "Integration with My Service",
        auth_type: AuthType::ApiKey,
    },

    receive Sync(data: SyncRequest) -> Result<SyncResponse> {
        // Your integration logic here
        let response = http::post("https://api.myservice.com/sync")
            .header("Authorization", self.config.api_key)
            .json(&data)
            .send().await?

        Ok(response.json().await?)
    }
}