CERBERUS/LibreChat
1
0
Fork 0
mirror of https://github.com/danny-avila/LibreChat.git synced 2026-07-10 08:13:46 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

fix(langfuse): type fanout collector config

Browse source
This commit is contained in:
Ravi Kumar L 2026-06-23 00:33:38 +02:00
parent 25279f1d48
commit 59b9c8b242
3 changed files with 11 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

2
packages/api/src/agents/__tests__/run-summarization.test.ts
View file

@ -1194,7 +1194,7 @@ describe('Langfuse run config', () => {
collectorUrl: 'http://langfuse-fanout-collector:4318',
},
},
} as AppConfig,
} as unknown as AppConfig,
});
expect(callArgs.langfuse).toEqual({

8
packages/api/src/langfuse/config.ts
View file

@ -5,6 +5,10 @@ import { normalizeString } from '~/utils/text';
import { isTrueEnv } from './utils';
type LangfuseRunConfig = NonNullable<RunConfig['langfuse']>;
type LangfuseAppConfig = NonNullable<AppConfig['langfuse']>;
export type LangfuseFanoutConfig = LangfuseAppConfig['fanout'] & {
collectorUrl?: string;
};
type LangfuseRunConfigWithTraceAttributes = LangfuseRunConfig & {
librechatTraceAttributes?: Record<string, string | number | boolean | null | undefined>;
};
@ -16,7 +20,7 @@ export function isLangfuseTenantExportEnabled(): boolean {
return !isTrueEnv(process.env.LANGFUSE_FANOUT_TENANT_EXPORT_DISABLED);
}
export function isLangfuseFanoutEnabled(fanout?: AppConfig['langfuse']['fanout']): boolean {
export function isLangfuseFanoutEnabled(fanout?: LangfuseFanoutConfig): boolean {
return (
fanout?.enabled !== false &&
(fanout?.enabled === true || isTrueEnv(process.env.LANGFUSE_FANOUT_ENABLED))
@ -89,7 +93,7 @@ export function buildLangfuseConfig({
const publicKey = normalizeString(config?.publicKey);
const secretKey = normalizeString(config?.secretKey);
const hasTenantCredentials = Boolean(publicKey && secretKey);
const fanout = config?.fanout;
const fanout = config?.fanout as LangfuseFanoutConfig | undefined;
const fanoutEnabled = isLangfuseFanoutEnabled(fanout);
const fanoutCollectorUrl =
normalizeString(fanout?.collectorUrl) ??

6
packages/api/src/langfuse/destinations.ts
View file

@ -1,4 +1,5 @@
import type { AppConfig } from '@librechat/data-schemas';
import type { LangfuseFanoutConfig } from './config';
import { isLangfuseFanoutEnabled, isLangfuseTenantExportEnabled } from './config';
import { resolveLangfuseTenantDestination } from './tenantDestinations';
import { isFalseEnv, toBasicAuthorization } from './utils';
@ -69,11 +70,12 @@ function getTenantScoreDestination(appConfig?: AppConfig): LangfuseScoreDestinat
if (config?.enabled === false) {
return undefined;
}
if (!isLangfuseFanoutEnabled(config?.fanout)) {
const fanout = config?.fanout as LangfuseFanoutConfig | undefined;
if (!isLangfuseFanoutEnabled(fanout)) {
return undefined;
}
const fanoutCollectorUrl =
normalizeString(config?.fanout?.collectorUrl) ??
normalizeString(fanout?.collectorUrl) ??
normalizeString(process.env.LANGFUSE_FANOUT_COLLECTOR_URL);
if (!fanoutCollectorUrl) {
return undefined;