{"version":3,"file":"IdentifiableSessionLogRecordProcessor.cjs","names":["ATTR_LOG_RECORD_UID","generateUUID","ATTR_SESSION_ID","ATTR_SESSION_PREVIOUS_ID"],"sources":["../../../src/processors/IdentifiableSessionLogRecordProcessor/IdentifiableSessionLogRecordProcessor.ts"],"sourcesContent":["import type { LogRecordProcessor, SdkLogRecord } from '@opentelemetry/sdk-logs';\nimport {\n  ATTR_LOG_RECORD_UID,\n  ATTR_SESSION_ID,\n  ATTR_SESSION_PREVIOUS_ID,\n} from '@opentelemetry/semantic-conventions/incubating';\nimport type { SpanSessionManager } from '../../api-sessions/index.ts';\nimport { generateUUID } from '../../utils/index.ts';\nimport type { IdentifiableSessionLogRecordProcessorArgs } from './types.ts';\n\nexport class IdentifiableSessionLogRecordProcessor\n  implements LogRecordProcessor\n{\n  private readonly _spanSessionManager: SpanSessionManager;\n\n  public constructor({\n    spanSessionManager,\n  }: IdentifiableSessionLogRecordProcessorArgs) {\n    this._spanSessionManager = spanSessionManager;\n  }\n\n  // no-op\n  public forceFlush(): Promise<void> {\n    return Promise.resolve(undefined);\n  }\n\n  public onEmit(logRecord: SdkLogRecord) {\n    logRecord.setAttributes({\n      [ATTR_LOG_RECORD_UID]: generateUUID(),\n      [ATTR_SESSION_ID]: this._spanSessionManager.getSessionId(),\n      [ATTR_SESSION_PREVIOUS_ID]:\n        this._spanSessionManager.getPreviousSessionId(),\n    });\n  }\n\n  // no-op\n  public shutdown(): Promise<void> {\n    return Promise.resolve(undefined);\n  }\n}\n"],"mappings":";;;;;AAUA,IAAa,wCAAb,MAEA;CACE;CAEA,YAAmB,EACjB,sBAC4C;AAC5C,OAAK,sBAAsB;;CAI7B,aAAmC;AACjC,SAAO,QAAQ,QAAQ,KAAA,EAAU;;CAGnC,OAAc,WAAyB;AACrC,YAAU,cAAc;IACrBA,+CAAAA,sBAAsBC,2BAAAA,cAAc;IACpCC,+CAAAA,kBAAkB,KAAK,oBAAoB,cAAc;IACzDC,+CAAAA,2BACC,KAAK,oBAAoB,sBAAsB;GAClD,CAAC;;CAIJ,WAAiC;AAC/B,SAAO,QAAQ,QAAQ,KAAA,EAAU"}