erp_naurua/modules/erp/import-integration/service.php

<?php
declare(strict_types=1);

function derive_label_webhook_url(array $localEnv): string
{
    $explicit = env_value('N8N_LABEL_WEBHOOK_URL', $localEnv);
    if ($explicit !== '') {
        return $explicit;
    }

    $legacy = env_value('N8N_OUTBOUND_URL_ADRESSE', $localEnv);
    if ($legacy !== '' && str_contains(strtolower($legacy), 'adressetikette')) {
        return $legacy;
    }

    $base = env_value('N8N_BASE_URL', $localEnv);
    if ($base === '') {
        return '';
    }

    $root = preg_replace('#/api/v1/?$#', '', rtrim($base, '/'));
    if (!is_string($root) || $root === '') {
        return '';
    }

    return $root . '/webhook/naurua_erp_adressetikette';
}

function derive_excel_webhook_url(array $localEnv): string
{
    $explicit = env_value('N8N_EXCEL_WEBHOOK_URL', $localEnv);
    if ($explicit !== '') {
        return $explicit;
    }

    $legacy = env_value('N8N_OUTBOUND_URL_ADRESSE', $localEnv);
    if ($legacy !== '' && str_contains(strtolower($legacy), 'excel_befuellen')) {
        return $legacy;
    }

    $base = env_value('N8N_BASE_URL', $localEnv);
    if ($base === '') {
        return '';
    }

    $root = preg_replace('#/api/v1/?$#', '', rtrim($base, '/'));
    if (!is_string($root) || $root === '') {
        return '';
    }

    return $root . '/webhook/excel_befuellen';
}

function post_json(string $url, array $payload, array $headers = [], int $timeoutSeconds = 15): array
{
    $body = json_encode($payload, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
    if ($body === false) {
        return ['ok' => false, 'status' => 0, 'body' => '', 'error' => 'Could not encode payload'];
    }

    $headerLines = ['Content-Type: application/json'];
    foreach ($headers as $name => $value) {
        if ($name === '' || $value === '') {
            continue;
        }
        $headerLines[] = $name . ': ' . $value;
    }

    $context = stream_context_create([
        'http' => [
            'method' => 'POST',
            'header' => implode("\r\n", $headerLines),
            'content' => $body,
            'timeout' => $timeoutSeconds,
            'ignore_errors' => true,
        ],
    ]);

    $responseBody = @file_get_contents($url, false, $context);
    $responseHeaders = $http_response_header ?? [];

    $status = 0;
    if (isset($responseHeaders[0]) && preg_match('#HTTP/\S+\s+(\d{3})#', $responseHeaders[0], $m) === 1) {
        $status = (int) $m[1];
    }

    if ($responseBody === false) {
        $responseBody = '';
    }

    return [
        'ok' => $status >= 200 && $status < 300,
        'status' => $status,
        'body' => substr($responseBody, 0, 500),
        'error' => ($status === 0) ? 'Request failed or timed out' : '',
    ];
}

function trigger_shipping_label_flow(array $order, array $localEnv): array
{
    $url = derive_label_webhook_url($localEnv);
    if ($url === '') {
        return [
            'enabled' => false,
            'ok' => false,
            'message' => 'Label webhook URL not configured',
        ];
    }

    $headers = [];
    $secret = env_value('N8N_WEBHOOK_SECRET', $localEnv);
    if ($secret !== '') {
        $headers['X-Webhook-Secret'] = $secret;
        $headers['X-N8N-Secret'] = $secret;
        $headers['X-API-Key'] = $secret;
        $headers['Authorization'] = 'Bearer ' . $secret;
    }

    throttle_webhook_channel('label', 10);
    $result = post_json($url, $order, $headers, 20);

    return [
        'enabled' => true,
        'ok' => $result['ok'],
        'status' => $result['status'],
        'url' => $url,
        'message' => $result['ok'] ? 'Label webhook triggered' : ($result['error'] !== '' ? $result['error'] : 'Label webhook returned non-2xx'),
        'responseBody' => $result['body'],
    ];
}

function trigger_excel_webhook(string $externalRef, array $localEnv): array
{
    $url = derive_excel_webhook_url($localEnv);
    if ($url === '') {
        return [
            'enabled' => false,
            'ok' => false,
            'message' => 'Excel webhook URL not configured',
        ];
    }

    $headers = [];
    $secret = env_value('N8N_WEBHOOK_SECRET', $localEnv);
    if ($secret !== '') {
        $headers['X-Webhook-Secret'] = $secret;
        $headers['X-N8N-Secret'] = $secret;
        $headers['X-API-Key'] = $secret;
        $headers['Authorization'] = 'Bearer ' . $secret;
    }

    throttle_webhook_channel('excel', 10);
    $result = post_json($url, ['Bestellnummer' => $externalRef], $headers, 20);

    return [
        'enabled' => true,
        'ok' => $result['ok'],
        'status' => $result['status'],
        'url' => $url,
        'message' => $result['ok'] ? 'Excel webhook triggered' : ($result['error'] !== '' ? $result['error'] : 'Excel webhook returned non-2xx'),
        'responseBody' => $result['body'],
    ];
}