Function deleteSubscription

apps/sim/lib/webhooks/providers/gitlab.ts:176–224

(ctx: DeleteSubscriptionContext)

  },

  async deleteSubscription(ctx: DeleteSubscriptionContext): Promise<void> {
    const config = getProviderConfig(ctx.webhook)
    const accessToken = config.accessToken as string | undefined
    const projectId = config.projectId as string | undefined
    const externalId = config.externalId as string | undefined
    const host = config.host as string | undefined

    if (!accessToken || !projectId || !externalId) {
      if (ctx.strict) throw new Error('Missing GitLab credentials or hook ID for webhook deletion.')
      logger.warn(
        `[${ctx.requestId}] Skipping GitLab webhook cleanup — missing token, project, or hook ID`
      )
      return
    }

    // A structurally unsafe host must not abort cleanup in non-strict mode — mirror
    // the graceful skip used for missing credentials above.
    try {
      getGitLabApiBase(host)
    } catch (error) {
      if (error instanceof UnsafeGitLabHostError) {
        if (ctx.strict) {
          throw new Error('Cannot delete GitLab webhook: the configured host is invalid.')
        }
        logger.warn(
          `[${ctx.requestId}] Skipping GitLab webhook cleanup — configured host is invalid`
        )
        return
      }
      throw error
    }

    const res = await secureFetchWithValidation(
      `${gitlabProjectHooksUrl(projectId, host)}/${externalId}`,
      {
        method: 'DELETE',
        headers: { 'PRIVATE-TOKEN': accessToken },
      }
    )

    if (!res.ok && res.status !== 404) {
      if (ctx.strict) throw new Error(`Failed to delete GitLab webhook: ${res.status}`)
      logger.warn(
        `[${ctx.requestId}] Failed to delete GitLab webhook ${externalId} (non-fatal): ${res.status}`
      )
      return
    }
    logger.info(`[${ctx.requestId}] Deleted GitLab webhook ${externalId}`)
  },
}