From aea43c0a8e015140b07014fcacdc42b6a54e7d96 Mon Sep 17 00:00:00 2001 From: x032205 Date: Thu, 3 Jul 2025 22:18:40 -0400 Subject: [PATCH] Final tweaks --- .../bitbucket-secret-scanning-factory.ts | 12 +++++---- .../bitbucket-secret-scanning-service.ts | 27 ++----------------- 2 files changed, 9 insertions(+), 30 deletions(-) diff --git a/backend/src/ee/services/secret-scanning-v2/bitbucket/bitbucket-secret-scanning-factory.ts b/backend/src/ee/services/secret-scanning-v2/bitbucket/bitbucket-secret-scanning-factory.ts index 74418d02f..8055cf5a0 100644 --- a/backend/src/ee/services/secret-scanning-v2/bitbucket/bitbucket-secret-scanning-factory.ts +++ b/backend/src/ee/services/secret-scanning-v2/bitbucket/bitbucket-secret-scanning-factory.ts @@ -44,6 +44,8 @@ export const BitbucketSecretScanningFactory = () => { TBitbucketConnection, TBitbucketDataSourceCredentials > = async ({ connection, payload }, callback) => { + const cfg = getConfig(); + const { email, apiToken } = connection.credentials; const authHeader = `Basic ${Buffer.from(`${email}:${apiToken}`).toString("base64")}`; @@ -51,7 +53,7 @@ export const BitbucketSecretScanningFactory = () => { `${IntegrationUrls.BITBUCKET_API_URL}/2.0/workspaces/${payload.config.workspaceSlug}/hooks`, { description: "Infisical webhook for push events", - url: `https://tunnel.util.lol/secret-scanning/webhooks/bitbucket`, // TODO(andrey): Swap to ${cfg.SITE_URL} + url: `${cfg.SITE_URL}/secret-scanning/webhooks/bitbucket`, active: true, events: ["repo:push"] }, @@ -140,9 +142,9 @@ export const BitbucketSecretScanningFactory = () => { filteredRepos.push(...repos.filter((repo) => includeRepos.includes(repo.full_name))); } - return filteredRepos.map(({ slug, full_name }) => ({ + return filteredRepos.map(({ full_name }) => ({ name: full_name, - externalId: slug.toString(), + externalId: full_name, type: SecretScanningResource.Repository })); }; @@ -176,10 +178,10 @@ export const BitbucketSecretScanningFactory = () => { const getDiffScanResourcePayload: TSecretScanningFactoryGetDiffScanResourcePayload< TQueueBitbucketResourceDiffScan["payload"] - > = ({ repository, dataSourceId }) => { + > = ({ repository }) => { return { name: repository.full_name, - externalId: dataSourceId, + externalId: repository.full_name, type: SecretScanningResource.Repository }; }; diff --git a/backend/src/ee/services/secret-scanning-v2/bitbucket/bitbucket-secret-scanning-service.ts b/backend/src/ee/services/secret-scanning-v2/bitbucket/bitbucket-secret-scanning-service.ts index ad5a59453..4a29245ed 100644 --- a/backend/src/ee/services/secret-scanning-v2/bitbucket/bitbucket-secret-scanning-service.ts +++ b/backend/src/ee/services/secret-scanning-v2/bitbucket/bitbucket-secret-scanning-service.ts @@ -9,28 +9,6 @@ export const bitBucketSecretScanningService = ( secretScanningV2DAL: TSecretScanningV2DALFactory, secretScanningV2Queue: Pick ) => { - const handleInstallationDeletedEvent = async (installationId: number) => { - const dataSource = await secretScanningV2DAL.dataSources.findOne({ - externalId: String(installationId), - type: SecretScanningDataSource.Bitbucket - }); - - if (!dataSource) { - logger.error( - `secretScanningV2RemoveEvent: Bitbucket - Could not find data source [installationId=${installationId}]` - ); - return; - } - - logger.info( - `secretScanningV2RemoveEvent: Bitbucket - installation deleted [installationId=${installationId}] [dataSourceId=${dataSource.id}]` - ); - - await secretScanningV2DAL.dataSources.updateById(dataSource.id, { - isDisconnected: true - }); - }; - const handlePushEvent = async (payload: TBitbucketPushEvent & { dataSourceId: string }) => { const { push, repository } = payload; @@ -44,7 +22,7 @@ export const bitBucketSecretScanningService = ( } const dataSource = (await secretScanningV2DAL.dataSources.findOne({ - externalId: payload.dataSourceId, + id: payload.dataSourceId, type: SecretScanningDataSource.Bitbucket })) as TBitbucketDataSource | undefined; @@ -81,7 +59,6 @@ export const bitBucketSecretScanningService = ( }; return { - handlePushEvent, - handleInstallationDeletedEvent + handlePushEvent }; };