Muonroi.Integration.Connectors 2.0.2

Muonroi.Integration.Connectors

Ready-to-use connector implementations for the Muonroi Connector Registry — HTTP/REST, SMTP, Slack, SQL, Redis, and a suite of third-party presets.

This package ships the concrete IServiceTaskConnector implementations defined in Muonroi.Integration.Abstractions. It registers all connectors and the DefaultConnectorRegistry through a single DI extension, giving workflows immediate access to HTTP, email, Slack, SQL, Redis, and preset integrations for GitHub, Jira Cloud, Confluence, Azure DevOps, Notion, and Jira Server / Confluence Server.

Installation

dotnet add package Muonroi.Integration.Connectors --prerelease

Quick Start

using Muonroi.Integration.Connectors.Registration;
using Muonroi.Integration.Abstractions;

var builder = WebApplication.CreateBuilder(args);

// Register all built-in connectors + DefaultConnectorRegistry in one call.
builder.Services.AddMBuiltInConnectors();

var app = builder.Build();

// Resolve the registry and dispatch to a connector by its type key.
app.MapGet("/ping-api", async (IConnectorRegistry registry, CancellationToken ct) =>
{
    IServiceTaskConnector? connector = registry.Resolve("http");
    if (connector is null) return Results.NotFound("connector not found");

    using JsonDocument config = JsonDocument.Parse("""{"url":"https://httpbin.org/get"}""");
    var context = new ConnectorContext
    {
        Config = config,
        InputFacts = [],
        Credentials = [],
        TenantId = "demo",
        CorrelationId = Guid.NewGuid().ToString()
    };

    ConnectorResult result = await connector.ExecuteAsync(context, ct);
    return result.Success ? Results.Ok(result.OutputFacts) : Results.Problem(result.ErrorMessage);
});

 await app.RunAsync();

Features

• HTTP / REST (type = "http") — GET, POST, PUT, DELETE, PATCH; configurable headers, body (Scriban template syntax), content-type, timeout, and responseMapping to project JSON response fields into the FactBag. Bearer and API-key auth from credentials.

• Email / SMTP (type = "email") — Sends plain-text or HTML email via MailKit over STARTTLS. Server, port, and credentials supplied at runtime through ConnectorContext.

• Slack Webhook (type = "slack") — Posts messages to Slack channels via incoming webhooks. Webhook URL sourced from credentials or connector config.

• SQL Query (type = "sql") — Parameterized, read-only-by-default ADO.NET queries. Resolves IDbConnection from DI; write operations (INSERT, UPDATE, DELETE, DROP, ALTER, CREATE) are blocked unless readOnly: false is set explicitly.

• Redis (type = "redis") — GET, SET (with optional TTL), and PUBLISH operations via IConnectionMultiplexer. Connector is a no-op when Redis is not registered in DI.

• Third-party presets — Delegate 100% to HttpConnector with pre-wired auth and field schemas for fast UI-driven configuration:

  Connector type key	Display name	Auth style
  jira-cloud	Jira Cloud	Basic (email + API token)
  confluence	Confluence Cloud	Basic (email + API token)
  generic-rest	Generic REST	Configurable
  jira-server	Jira Server	PAT (Bearer)
  confluence-server	Confluence Server	PAT (Bearer)
  azure-devops	Azure DevOps	PAT (Bearer)
  notion	Notion	Bearer token
  github	GitHub	PAT (Bearer)

• DefaultConnectorRegistry — In-memory registry built from all DI-registered IServiceTaskConnector instances. Supports Resolve(type) (case-insensitive) and ListAvailable().

Configuration

DI registration

services.AddMBuiltInConnectors();

This single call:

1. Registers a named HttpClient ("MuonroiConnector") for all HTTP-based connectors.
2. Registers HttpConnector, SmtpConnector, SlackWebhookConnector, SqlQueryConnector, and RedisConnector as IServiceTaskConnector.
3. Registers all preset connectors as IServiceTaskConnector.
4. Registers DefaultConnectorRegistry as IConnectorRegistry (using TryAddSingleton).

Per-connector configuration schema

Each connector exposes its accepted configuration via GetConfigSchema(), which returns a JSON Schema JsonElement. The schemas below document the ConnectorContext.Config fields each connector reads.

HTTP (HttpConnector)

Auth is read from ConnectorContext.Credentials:

• authorization → raw Authorization header value
• apiKey + apiKeyHeader → custom header name + value

Email (SmtpConnector) — config fields

Credentials: smtpHost, smtpPort, smtpUsername, smtpPassword.

Slack (SlackWebhookConnector) — config fields

Credentials: webhookUrl (overrides any config value).

SQL (SqlQueryConnector) — config fields

Requires IDbConnection registered in DI. Output facts: sqlRows (list of row objects), sqlRowCount (integer).

Redis (RedisConnector) — config fields

Requires IConnectionMultiplexer registered in DI.

API Reference

Compatibility

• Target framework: net8.0
• License: Apache-2.0 (OSS)

Related Packages

• Muonroi.Integration.Abstractions — Contracts: IServiceTaskConnector, IConnectorRegistry, ConnectorContext, ConnectorResult, ConnectorMetadata
• Muonroi.Core.Abstractions — Core exception and shared types used by connectors

Ecosystem Combinations

+ Integration.Abstractions → Implements IServiceTaskConnector

Connectors are the concrete IServiceTaskConnector implementations — HTTP APIs, gRPC services, database adapters.

+ Resilience → Resilient Connector Calls

Every connector call is wrapped with a Polly pipeline (retry + circuit breaker + timeout) automatically when Muonroi.Resilience is registered.

+ Tenancy → Per-Tenant Connector Configuration

Each tenant can have different connector endpoints and credentials resolved via ITenantConnectionStringFactory.

+ Observability → Connector Call Tracing

Each connector execution creates an OTel span with connector type, target endpoint, and result status.

Samples

• Quickstart.Integration
• Quickstart.Integration.Abstractions

License

Apache-2.0. See LICENSE-APACHE.