diff --git a/services/apps/packages_worker/src/config.ts b/services/apps/packages_worker/src/config.ts index 94854d105d..de5268b4e6 100644 --- a/services/apps/packages_worker/src/config.ts +++ b/services/apps/packages_worker/src/config.ts @@ -10,6 +10,10 @@ function requireEnvInt(name: string): number { return parseInt(requireEnv(name), 10) } +export function getPackagesTinybirdToken(): string { + return requireEnv('CROWD_PACKAGES_TB_TOKEN') +} + export function getPackagesDbConfig() { return { host: requireEnv('CROWD_PACKAGES_DB_WRITE_HOST'), diff --git a/services/apps/packages_worker/src/member-contributors/__tests__/syncGitActivityContributors.test.ts b/services/apps/packages_worker/src/member-contributors/__tests__/syncGitActivityContributors.test.ts index 0bbe40449d..1947534ec3 100644 --- a/services/apps/packages_worker/src/member-contributors/__tests__/syncGitActivityContributors.test.ts +++ b/services/apps/packages_worker/src/member-contributors/__tests__/syncGitActivityContributors.test.ts @@ -18,6 +18,7 @@ import { } from '../git-activity/syncGitActivityContributors' vi.mock('@temporalio/activity', () => ({ heartbeat: vi.fn() })) +vi.mock('../../config', () => ({ getPackagesTinybirdToken: () => 'packages-token' })) vi.mock('../../db', () => ({ getPackagesDb: vi.fn() })) vi.mock('@crowd/database', () => ({ TinybirdClient: vi.fn() })) @@ -254,6 +255,7 @@ describe('syncGitActivityContributors', () => { const counts = await syncGitActivityContributors({ full: true }) + expect(TinybirdClient).toHaveBeenCalledWith('packages-token') expect(counts.full).toBe(true) expect(counts.removed).toBe(2) expect(executeSql.mock.calls[1][1]).toEqual({ limit: 5000 }) diff --git a/services/apps/packages_worker/src/member-contributors/git-activity/syncGitActivityContributors.ts b/services/apps/packages_worker/src/member-contributors/git-activity/syncGitActivityContributors.ts index 84aa011783..00d777ba20 100644 --- a/services/apps/packages_worker/src/member-contributors/git-activity/syncGitActivityContributors.ts +++ b/services/apps/packages_worker/src/member-contributors/git-activity/syncGitActivityContributors.ts @@ -5,6 +5,7 @@ import { prepareBulkInsert } from '@crowd/data-access-layer/src/utils' import { TinybirdClient } from '@crowd/database' import { getServiceChildLogger } from '@crowd/logging' +import { getPackagesTinybirdToken } from '../../config' import { getPackagesDb } from '../../db' import { canonicalGovernanceRepoUrl } from '../governance/mapRows' import { findRepoIdsByUrl, readRunStart } from '../governance/syncGovernanceContributors' @@ -203,7 +204,7 @@ export async function syncGitActivityContributors( options: GitActivitySyncOptions, ): Promise { const pkgsQx = await getPackagesDb() - const tb = new TinybirdClient() + const tb = new TinybirdClient(getPackagesTinybirdToken()) const runStartedAt = await readRunStart(pkgsQx) const watermark = await readWatermark(pkgsQx)