CreatioConnector 1.0.0

CreatioConnector

A .NET 8 NuGet library for integrating with Creatio CRM/BPM via OData 4.

• ✅ Cookie-based authentication (ASPXAUTH + BPMCSRF)
• ✅ Full CRUD: SELECT, INSERT, UPDATE (PATCH), DELETE
• ✅ Auto session refresh + 401 retry
• ✅ SQL Server history logging via EF Core
• ✅ Typed options (IOptions<CreatioOptions>)
• ✅ Single-line DI registration

Installation

dotnet add package CreatioConnector

Quick Start

1. appsettings.json

{
  "ConnectionStrings": {
    "DefaultConnection": "Server=.;Database=MyDb;Trusted_Connection=True;"
  },
  "Creatio": {
    "BaseUrl":  "https://your-instance.creatio.com",
    "Username": "admin",
    "Password": "your-password",
    "SessionLifetimeMinutes": 20,
    "HttpTimeoutSeconds": 30
  }
}

2. Program.cs

using CreatioConnector.Extensions;

builder.Services.AddCreatioConnector(builder.Configuration);

var app = builder.Build();

// Auto-migrate CreatioIntegrationLogs table
app.Services.UseCreatioConnectorMigrations();

3. Inject and Use

public class ContactService
{
    private readonly ICreatioConnectorService _creatio;

    public ContactService(ICreatioConnectorService creatio)
        => _creatio = creatio;

    public async Task<List<Dictionary<string, object?>>> GetContactsAsync()
    {
        var result = await _creatio.SelectAsync(new CreatioSelectRequest
        {
            EntityName   = "Contact",
            Filter       = "contains(Name, 'Ahmed')",
            Select       = "Id,Name,Email,Phone",
            OrderBy      = "Name asc",
            Top          = 50,
            IncludeCount = true
        });

        if (!result.IsSuccess)
            throw new Exception(result.ErrorMessage);

        return result.Records; // List<Dictionary<string, object?>>
    }

    public async Task<string?> CreateContactAsync(string name, string email)
    {
        var result = await _creatio.InsertAsync(new CreatioInsertRequest
        {
            EntityName = "Contact",
            Fields     = new() { ["Name"] = name, ["Email"] = email }
        });

        return result.RecordId; // Guid string
    }

    public async Task UpdatePhoneAsync(string recordId, string phone)
    {
        await _creatio.UpdateAsync(new CreatioUpdateRequest
        {
            EntityName = "Contact",
            RecordId   = recordId,
            Fields     = new() { ["Phone"] = phone }
        });
    }

    public async Task DeleteContactAsync(string recordId)
    {
        await _creatio.DeleteAsync(new CreatioDeleteRequest
        {
            EntityName = "Contact",
            RecordId   = recordId
        });
    }
}

Use Your Existing DbContext (optional)

If you don't want a second DbContext, merge the table into yours:

// In your AppDbContext.OnModelCreating:
CreatioDbContextConfiguration.Configure(modelBuilder);

Then register without EF (pass your own repo):

services.AddScoped<ICreatioLogRepository, MyCustomCreatioLogRepository>();

Query Integration Logs

public class LogsController : ControllerBase
{
    private readonly ICreatioLogService _logs;

    public LogsController(ICreatioLogService logs) => _logs = logs;

    [HttpGet("failed")]
    public async Task<IActionResult> Failed([FromQuery] int page = 1)
        => Ok(await _logs.GetFailedLogsAsync(pageSize: 50, page: page));
}

Configuration Reference