Add logging

Author: bielaski

src/services/webhooks.ts

@@ -5,33 +5,41 @@ import { GITLAB_EVENT_WEBTRIGGER, STORAGE_KEYS, STORAGE_SECRETS } from '../const
 import { generateSignature } from '../utils/generate-signature-utils';
 
 export const setupAndValidateWebhook = async (groupId: number): Promise<number> => {
-  const [existingWebhook, groupToken] = await Promise.all([
-    storage.get(`${STORAGE_KEYS.WEBHOOK_KEY_PREFIX}${groupId}`),
-    storage.getSecret(`${STORAGE_SECRETS.GROUP_TOKEN_KEY_PREFIX}${groupId}`),
-  ]);
-
-  const isWebhookValid = existingWebhook && (await getGroupWebhook(groupId, existingWebhook, groupToken)) !== null;
-
-  if (isWebhookValid) {
-    return existingWebhook;
+  console.log('Setting up webhook');
+  try {
+    const [existingWebhook, groupToken] = await Promise.all([
+      storage.get(`${STORAGE_KEYS.WEBHOOK_KEY_PREFIX}${groupId}`),
+      storage.getSecret(`${STORAGE_SECRETS.GROUP_TOKEN_KEY_PREFIX}${groupId}`),
+    ]);
+
+    const isWebhookValid = existingWebhook && (await getGroupWebhook(groupId, existingWebhook, groupToken)) !== null;
+
+    if (isWebhookValid) {
+      console.log('Using existing webhook');
+      return existingWebhook;
+    }
+
+    const webtriggerURL = await webTrigger.getUrl(GITLAB_EVENT_WEBTRIGGER);
+    const webtriggerURLWithGroupId = `${webtriggerURL}?groupId=${groupId}`;
+    const webhookSignature = generateSignature();
+    const webhookId = await registerGroupWebhook({
+      groupId,
+      url: webtriggerURLWithGroupId,
+      token: groupToken,
+      signature: webhookSignature,
+    });
+
+    await Promise.all([
+      storage.set(`${STORAGE_KEYS.WEBHOOK_KEY_PREFIX}${groupId}`, webhookId),
+      storage.set(`${STORAGE_KEYS.WEBHOOK_SIGNATURE_PREFIX}${groupId}`, webhookSignature),
+    ]);
+
+    console.log('Successfully created webhook');
+    return webhookId;
+  } catch (e) {
+    console.log('Error setting up webhook, ', e);
+    return null;
   }
-
-  const webtriggerURL = await webTrigger.getUrl(GITLAB_EVENT_WEBTRIGGER);
-  const webtriggerURLWithGroupId = `${webtriggerURL}?groupId=${groupId}`;
-  const webhookSignature = generateSignature();
-  const webhookId = await registerGroupWebhook({
-    groupId,
-    url: webtriggerURLWithGroupId,
-    token: groupToken,
-    signature: webhookSignature,
-  });
-
-  await Promise.all([
-    storage.set(`${STORAGE_KEYS.WEBHOOK_KEY_PREFIX}${groupId}`, webhookId),
-    storage.set(`${STORAGE_KEYS.WEBHOOK_SIGNATURE_PREFIX}${groupId}`, webhookSignature),
-  ]);
-
-  return webhookId;
 };
 
 export const deleteWebhook = async (groupId: number): Promise<void> => {