gitea_admin/erp_naurua
1
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Allow Shopify worker reuse from central cron

Browse Source
This commit is contained in:
gitea_admin committed 2026-09-06 15:35:25 +02:00
1 parent 85617b5b34
commit 307affbb67
1 file changed
+16 -14
Download Patch File Download Diff File Expand all files Collapse all files
modules/erp/import-integration/shopify-webhook-worker.php
+16 -14
View File
@@ -132,19 +132,21 @@ function shopify_webhook_worker_run(PDO $pdo, array $env, int $limit): array
} }
} }
$argvLimit = 20; if (PHP_SAPI === 'cli' && realpath($_SERVER['SCRIPT_FILENAME'] ?? '') === __FILE__) {
foreach ($argv as $argument) { $argvLimit = 20;
if (str_starts_with($argument, '--limit=')) { foreach ($argv as $argument) {
$argvLimit = max(1, min(100, (int) substr($argument, 8))); if (str_starts_with($argument, '--limit=')) {
$argvLimit = max(1, min(100, (int) substr($argument, 8)));
}
}
try {
$env = expand_env_values(parse_env_file(__DIR__ . '/../../../.env'));
$pdo = connect_database($env);
echo json_encode(shopify_webhook_worker_run($pdo, $env, $argvLimit), JSON_UNESCAPED_SLASHES) . PHP_EOL;
exit(0);
} catch (Throwable $error) {
fwrite(STDERR, $error->getMessage() . PHP_EOL);
exit(1);
} }
} }
try {
$env = expand_env_values(parse_env_file(__DIR__ . '/../../../.env'));
$pdo = connect_database($env);
echo json_encode(shopify_webhook_worker_run($pdo, $env, $argvLimit), JSON_UNESCAPED_SLASHES) . PHP_EOL;
exit(0);
} catch (Throwable $error) {
fwrite(STDERR, $error->getMessage() . PHP_EOL);
exit(1);
}