diff --git a/packages/api/src/admin/langfuse.handler.spec.ts b/packages/api/src/admin/langfuse.handler.spec.ts index 26431454bd..bf20ae2df1 100644 --- a/packages/api/src/admin/langfuse.handler.spec.ts +++ b/packages/api/src/admin/langfuse.handler.spec.ts @@ -514,9 +514,8 @@ describe('createAdminLangfuseHandlers', () => { const [publicUrl, publicInit] = (global.fetch as unknown as jest.Mock).mock.calls[1]; expect(publicUrl).toBe('https://cloud.langfuse.com/api/public/ingestion'); expect(publicInit.method).toBe('POST'); - expect( - Buffer.from(publicInit.headers.Authorization.replace('Basic ', ''), 'base64').toString(), - ).toBe('pk:sk'); + expect(publicInit.headers.Authorization).toBe('Bearer pk'); + expect(publicInit.headers['X-Langfuse-Public-Key']).toBe('pk'); expect(publicInit.headers['Content-Type']).toBe('application/json'); expect(JSON.parse(publicInit.body)).toEqual({ batch: [] }); expect(publicInit.signal).toBe(init.signal); diff --git a/packages/api/src/admin/langfuse.ts b/packages/api/src/admin/langfuse.ts index 332eb95da8..39e6e1edef 100644 --- a/packages/api/src/admin/langfuse.ts +++ b/packages/api/src/admin/langfuse.ts @@ -118,7 +118,8 @@ async function verifyLangfuseCredentials( const publicResponse = await fetch(`${destination.baseUrl}/api/public/ingestion`, { method: 'POST', headers: { - Authorization: `Basic ${auth}`, + Authorization: `Bearer ${publicKey}`, + 'X-Langfuse-Public-Key': publicKey, 'Content-Type': 'application/json', }, body: JSON.stringify({ batch: [] }),