Fetches coolify secrets for webhook job host

1 files changed, 4 insertions, 2 deletions

diff --git a/worker/scripts/coolify_webhook.ts b/worker/scripts/coolify_webhook.ts
index d1b4eb0..8859023 100755
--- a/worker/scripts/coolify_webhook.ts
+++ b/worker/scripts/coolify_webhook.ts
@@ -43,8 +43,10 @@ await LogMetricTraceable.ofLogTraceable(_logJob)
     .map(async (tEitherJobVault) => {
         const eitherJobVault = await tEitherJobVault.get();
         return eitherJobVault.flatMapAsync(async ({ job, key, vault }) => {
-            tEitherJobVault.trace.trace('fetching coolify secret from vault...');
-            const eitherSecret = await vault.fetchSecret<SecureNote>(tEitherJobVault, key, 'coolify');
+            const coolifyHost = new URL(job.arguments.webhookUrl).hostname;
+            const secretName = `coolify--${coolifyHost}`;
+            tEitherJobVault.trace.trace(`fetching coolify secret from vault (${secretName})...`);
+            const eitherSecret = await vault.fetchSecret<SecureNote>(tEitherJobVault, key, secretName);
             await vault.lock(tEitherJobVault, key);
 
             eitherSecret.fold(