Microsoft Dynamics 365

using Azure.Messaging.ServiceBus;
using Microsoft.Azure.Functions.Worker;
using Microsoft.Extensions.Logging;
using System.Net.Http.Json;
using System.Text.Json;

namespace Certyo.Dynamics365.Functions;

public sealed class CertyoIngestFunction
{
    private readonly HttpClient _http;
    private readonly ILogger<CertyoIngestFunction> _logger;

    public CertyoIngestFunction(
        IHttpClientFactory httpClientFactory,
        ILogger<CertyoIngestFunction> logger)
    {
        _http = httpClientFactory.CreateClient("Certyo");
        _logger = logger;
    }

    [Function("CertyoIngest")]
    public async Task Run(
        [ServiceBusTrigger("certyo-records", Connection = "ServiceBusConnection")]
        ServiceBusReceivedMessage message,
        CancellationToken cancellationToken)
    {
        var d365Event = JsonSerializer.Deserialize<D365ShipmentEvent>(
            message.Body.ToString(),
            new JsonSerializerOptions { PropertyNameCaseInsensitive = true });

        if (d365Event is null)
        {
            _logger.LogWarning("Received null event, skipping");
            return;
        }

        var certyoRecord = new
        {
            tenantId = Environment.GetEnvironmentVariable("CERTYO_TENANT_ID"),
            database = "dynamics365",
            collection = d365Event.EntityName,
            recordId = d365Event.DocumentNo,
            recordVersion = d365Event.Version ?? "1",
            operationType = "insert",
            sourceTimestamp = d365Event.PostingDate.ToString("O"),
            idempotencyKey = $"{d365Event.DocumentNo}-{d365Event.Version ?? "1"}-{d365Event.PostingDate:yyyy-MM-dd}",
            recordPayload = new
            {
                documentNo = d365Event.DocumentNo,
                entityName = d365Event.EntityName,
                sellToCustomerNo = d365Event.SellToCustomerNo,
                sellToCustomerName = d365Event.SellToCustomerName,
                shipToCode = d365Event.ShipToCode,
                postingDate = d365Event.PostingDate,
                shipmentMethodCode = d365Event.ShipmentMethodCode,
                trackingNo = d365Event.TrackingNo,
                lines = d365Event.Lines.Select(l => new
                {
                    lineNo = l.LineNo,
                    itemNo = l.ItemNo,
                    description = l.Description,
                    quantity = l.Quantity,
                    unitOfMeasureCode = l.UnitOfMeasureCode,
                    lotNo = l.LotNo,
                    serialNo = l.SerialNo
                })
            }
        };

        var response = await _http.PostAsJsonAsync(
            "/api/v1/records",
            certyoRecord,
            cancellationToken);

        if (!response.IsSuccessStatusCode)
        {
            var body = await response.Content.ReadAsStringAsync(cancellationToken);
            _logger.LogError(
                "Certyo ingestion failed for {DocumentNo}: {Status} {Body}",
                d365Event.DocumentNo, response.StatusCode, body);
            throw new InvalidOperationException(
                $"Certyo returned {response.StatusCode}");
        }

        var result = await response.Content
            .ReadFromJsonAsync<JsonElement>(cancellationToken);
        _logger.LogInformation(
            "Ingested {DocumentNo} -> recordHash: {Hash}",
            d365Event.DocumentNo,
            result.GetProperty("recordHash").GetString());
    }
}

public record D365ShipmentEvent
{
    public string DocumentNo { get; init; } = "";
    public string EntityName { get; init; } = "SalesShipmentHeader";
    public string SellToCustomerNo { get; init; } = "";
    public string SellToCustomerName { get; init; } = "";
    public string ShipToCode { get; init; } = "";
    public DateTime PostingDate { get; init; }
    public string ShipmentMethodCode { get; init; } = "";
    public string TrackingNo { get; init; } = "";
    public string? Version { get; init; }
    public List<ShipmentLine> Lines { get; init; } = new();
}

public record ShipmentLine
{
    public int LineNo { get; init; }
    public string ItemNo { get; init; } = "";
    public string Description { get; init; } = "";
    public decimal Quantity { get; init; }
    public string UnitOfMeasureCode { get; init; } = "";
    public string? LotNo { get; init; }
    public string? SerialNo { get; init; }
}

{
  "definition": {
    "$schema": "https://schema.management.azure.com/providers/Microsoft.Logic/schemas/2016-06-01/workflowdefinition.json#",
    "triggers": {
      "When_a_row_is_added_or_modified": {
        "type": "OpenApiConnectionWebhook",
        "inputs": {
          "host": {
            "connectionName": "shared_commondataserviceforapps",
            "operationId": "SubscribeWebhookTrigger",
            "apiId": "/providers/Microsoft.PowerApps/apis/shared_commondataserviceforapps"
          },
          "parameters": {
            "subscriptionRequest/message": 4,
            "subscriptionRequest/entityname": "msdyn_inventorytransaction",
            "subscriptionRequest/scope": 4,
            "subscriptionRequest/filterexpression": "msdyn_transactiontype eq 100000000"
          }
        }
      }
    },
    "actions": {
      "Initialize_Certyo_Payload": {
        "type": "Compose",
        "inputs": {
          "tenantId": "@{parameters('CertyoTenantId')}",
          "database": "dynamics365-fo",
          "collection": "InventoryTransactions",
          "recordId": "@{triggerOutputs()?['body/msdyn_inventorytransactionid']}",
          "operationType": "insert",
          "sourceTimestamp": "@{triggerOutputs()?['body/modifiedon']}",
          "idempotencyKey": "@{concat(triggerOutputs()?['body/msdyn_inventorytransactionid'], '-', formatDateTime(triggerOutputs()?['body/modifiedon'], 'yyyy-MM-dd'))}",
          "recordPayload": {
            "transactionId": "@{triggerOutputs()?['body/msdyn_inventorytransactionid']}",
            "itemNumber": "@{triggerOutputs()?['body/msdyn_itemnumber']}",
            "productName": "@{triggerOutputs()?['body/msdyn_productname']}",
            "transactionType": "@{triggerOutputs()?['body/msdyn_transactiontype']}",
            "quantity": "@{triggerOutputs()?['body/msdyn_quantity']}",
            "unit": "@{triggerOutputs()?['body/msdyn_unitid']}",
            "warehouse": "@{triggerOutputs()?['body/msdyn_warehouseid']}",
            "batchNumber": "@{triggerOutputs()?['body/msdyn_batchnumber']}",
            "serialNumber": "@{triggerOutputs()?['body/msdyn_serialnumber']}",
            "inventorySiteId": "@{triggerOutputs()?['body/msdyn_inventorysiteid']}",
            "transactionDate": "@{triggerOutputs()?['body/msdyn_transactiondate']}"
          }
        },
        "runAfter": {}
      },
      "Call_Certyo_Ingest": {
        "type": "Http",
        "inputs": {
          "method": "POST",
          "uri": "https://www.certyos.com/api/v1/records",
          "headers": {
            "X-API-Key": "@{parameters('CertyoApiKey')}",
            "Content-Type": "application/json"
          },
          "body": "@outputs('Initialize_Certyo_Payload')"
        },
        "runAfter": {
          "Initialize_Certyo_Payload": ["Succeeded"]
        },
        "runtimeConfiguration": {
          "contentTransfer": { "transferMode": "Chunked" }
        }
      },
      "Check_Response": {
        "type": "If",
        "expression": {
          "and": [
            { "equals": ["@outputs('Call_Certyo_Ingest')['statusCode']", 202] }
          ]
        },
        "actions": {
          "Log_Success": {
            "type": "Compose",
            "inputs": "Certyo accepted record @{triggerOutputs()?['body/msdyn_inventorytransactionid']} with hash @{body('Call_Certyo_Ingest')?['recordHash']}"
          }
        },
        "else": {
          "actions": {
            "Log_Failure": {
              "type": "Compose",
              "inputs": "Certyo rejected record: @{body('Call_Certyo_Ingest')}"
            }
          }
        },
        "runAfter": {
          "Call_Certyo_Ingest": ["Succeeded", "Failed"]
        }
      }
    },
    "parameters": {
      "CertyoTenantId": {
        "type": "String",
        "defaultValue": ""
      },
      "CertyoApiKey": {
        "type": "SecureString",
        "defaultValue": ""
      }
    }
  }
}

// AL Extension for Business Central
// Language: AL (displayed as TypeScript — no AL syntax option)

codeunit 50100 "Certyo Shipment Publisher"
{
    [EventSubscriber(ObjectType::Codeunit, Codeunit::"Sales-Post", 'OnAfterPostSalesDoc', '', false, false)]
    local procedure OnAfterPostSalesDoc(
        var SalesHeader: Record "Sales Header";
        var GenJnlPostLine: Codeunit "Gen. Jnl.-Post Line";
        SalesShptHdrNo: Code[20];
        RetRcpHdrNo: Code[20];
        SalesInvHdrNo: Code[20];
        SalesCrMemoHdrNo: Code[20])
    var
        SalesShipmentHeader: Record "Sales Shipment Header";
        SalesShipmentLine: Record "Sales Shipment Line";
        ServiceBusHelper: Codeunit "Certyo Service Bus Helper";
        JsonPayload: JsonObject;
        LinesArray: JsonArray;
        LineObject: JsonObject;
    begin
        if SalesShptHdrNo = '' then
            exit;

        SalesShipmentHeader.Get(SalesShptHdrNo);

        JsonPayload.Add('DocumentNo', SalesShipmentHeader."No.");
        JsonPayload.Add('EntityName', 'SalesShipmentHeader');
        JsonPayload.Add('SellToCustomerNo', SalesShipmentHeader."Sell-to Customer No.");
        JsonPayload.Add('SellToCustomerName', SalesShipmentHeader."Sell-to Customer Name");
        JsonPayload.Add('ShipToCode', SalesShipmentHeader."Ship-to Code");
        JsonPayload.Add('PostingDate', Format(SalesShipmentHeader."Posting Date", 0, '<Year4>-<Month,2>-<Day,2>'));
        JsonPayload.Add('ShipmentMethodCode', SalesShipmentHeader."Shipment Method Code");
        JsonPayload.Add('TrackingNo', SalesShipmentHeader."Package Tracking No.");

        SalesShipmentLine.SetRange("Document No.", SalesShptHdrNo);
        if SalesShipmentLine.FindSet() then
            repeat
                Clear(LineObject);
                LineObject.Add('LineNo', SalesShipmentLine."Line No.");
                LineObject.Add('ItemNo', SalesShipmentLine."No.");
                LineObject.Add('Description', SalesShipmentLine.Description);
                LineObject.Add('Quantity', SalesShipmentLine.Quantity);
                LineObject.Add('UnitOfMeasureCode', SalesShipmentLine."Unit of Measure Code");
                LinesArray.Add(LineObject);
            until SalesShipmentLine.Next() = 0;

        JsonPayload.Add('Lines', LinesArray);

        ServiceBusHelper.SendToQueue('certyo-records', JsonPayload);
    end;
}

codeunit 50101 "Certyo Service Bus Helper"
{
    procedure SendToQueue(QueueName: Text; Payload: JsonObject)
    var
        HttpClient: HttpClient;
        HttpContent: HttpContent;
        HttpHeaders: HttpHeaders;
        HttpResponseMessage: HttpResponseMessage;
        ServiceBusUri: Text;
        SasToken: Text;
        PayloadText: Text;
    begin
        ServiceBusUri := GetServiceBusUri(QueueName);
        SasToken := GenerateSasToken(QueueName);

        Payload.WriteTo(PayloadText);
        HttpContent.WriteFrom(PayloadText);
        HttpContent.GetHeaders(HttpHeaders);
        HttpHeaders.Remove('Content-Type');
        HttpHeaders.Add('Content-Type', 'application/json');
        HttpHeaders.Add('Authorization', SasToken);

        HttpClient.Post(ServiceBusUri, HttpContent, HttpResponseMessage);

        if not HttpResponseMessage.IsSuccessStatusCode() then
            Error('Failed to send to Service Bus: %1', HttpResponseMessage.ReasonPhrase());
    end;

    local procedure GetServiceBusUri(QueueName: Text): Text
    var
        Setup: Record "Certyo Setup";
    begin
        Setup.Get();
        exit(StrSubstNo('https://%1.servicebus.windows.net/%2/messages',
            Setup."Service Bus Namespace", QueueName));
    end;

    local procedure GenerateSasToken(QueueName: Text): Text
    var
        Setup: Record "Certyo Setup";
        CryptographyMgmt: Codeunit "Cryptography Management";
        Uri: Text;
        Expiry: Integer;
        StringToSign: Text;
        Signature: Text;
    begin
        Setup.Get();
        Uri := GetServiceBusUri(QueueName);
        Expiry := GetUnixTimestamp() + 3600;
        StringToSign := Uri + '\n' + Format(Expiry);
        Signature := CryptographyMgmt.GenerateHashAsBase64String(
            StringToSign, Setup."Service Bus SAS Key",
            2); // HMACSHA256
        exit(StrSubstNo('SharedAccessSignature sr=%1&sig=%2&se=%3&skn=%4',
            Uri, Signature, Expiry, Setup."Service Bus SAS Key Name"));
    end;

    local procedure GetUnixTimestamp(): Integer
    begin
        exit(Round((CurrentDateTime() - CreateDateTime(19700101D, 0T)) / 1000, 1));
    end;
}