FM / lib

/opt/canhelp/node_modules/openai/src/lib/

/opt/canhelp/node_modules/openai/src/lib

Name	Size	Mode	Actions
responses/	-	0755	rm
.keep	225	0644	edit dl rm
AbstractChatCompletionRunner.ts	14187	0644	edit dl rm
AssistantStream.ts	24396	0644	edit dl rm
ChatCompletionRunner.ts	1710	0644	edit dl rm
ChatCompletionStream.ts	27008	0644	edit dl rm
ChatCompletionStreamingRunner.ts	1973	0644	edit dl rm
chatCompletionUtils.ts	614	0644	edit dl rm
EventEmitter.ts	3899	0644	edit dl rm
EventStream.ts	8164	0644	edit dl rm
jsonschema.ts	5172	0644	edit dl rm
parser.ts	9416	0644	edit dl rm
ResponsesParser.ts	7327	0644	edit dl rm
RunnableFunction.ts	3770	0644	edit dl rm
transform.ts	6159	0644	edit dl rm
Util.ts	780	0644	edit dl rm

Edit: /opt/canhelp/node_modules/openai/src/lib/ChatCompletionRunner.ts (1710B)

export interface ChatCompletionRunnerEvents extends AbstractChatCompletionRunnerEvents {
  content: (content: string) => void;
}

export type ChatCompletionToolRunnerParams<FunctionsArgs extends BaseFunctionsArgs> = Omit<
  ChatCompletionCreateParamsNonStreaming,
  'tools'
> & {
  tools: RunnableTools<FunctionsArgs> | AutoParseableTool<any, true>[];
};

export class ChatCompletionRunner<ParsedT = null> extends AbstractChatCompletionRunner<
  ChatCompletionRunnerEvents,
  ParsedT
> {
  static runTools<ParsedT>(
    client: OpenAI,
    params: ChatCompletionToolRunnerParams<any[]>,
    options?: RunnerOptions,
  ): ChatCompletionRunner<ParsedT> {
    const runner = new ChatCompletionRunner<ParsedT>();
    const opts = {
      ...options,
      headers: { ...options?.headers, 'X-Stainless-Helper-Method': 'runTools' },
    };
    runner._run(() => runner._runTools(client, params, opts));
    return runner;
  }

override _addMessage(
    this: ChatCompletionRunner<ParsedT>,
    message: ChatCompletionMessageParam,
    emit: boolean = true,
  ) {
    super._addMessage(message, emit);
    if (isAssistantMessage(message) && message.content) {
      this._emit('content', message.content as string);
    }
  }
}

import { type ChatCompletionMessageParam, type ChatCompletionCreateParamsNonStreaming, } from '../resources/chat/completions'; import { type BaseFunctionsArgs, RunnableTools } from './RunnableFunction'; import { AbstractChatCompletionRunner, AbstractChatCompletionRunnerEvents, RunnerOptions, } from './AbstractChatCompletionRunner'; import { isAssistantMessage } from './chatCompletionUtils'; import OpenAI from '../index'; import { AutoParseableTool } from '../lib/parser'; export interface ChatCompletionRunnerEvents extends AbstractChatCompletionRunnerEvents { content: (content: string) => void; } export type ChatCompletionToolRunnerParams = Omit< ChatCompletionCreateParamsNonStreaming, 'tools' > & { tools: RunnableTools | AutoParseableTool[]; }; export class ChatCompletionRunner extends AbstractChatCompletionRunner< ChatCompletionRunnerEvents, ParsedT > { static runTools( client: OpenAI, params: ChatCompletionToolRunnerParams, options?: RunnerOptions, ): ChatCompletionRunner { const runner = new ChatCompletionRunner(); const opts = { ...options, headers: { ...options?.headers, 'X-Stainless-Helper-Method': 'runTools' }, }; runner._run(() => runner._runTools(client, params, opts)); return runner; } override _addMessage( this: ChatCompletionRunner, message: ChatCompletionMessageParam, emit: boolean = true, ) { super._addMessage(message, emit); if (isAssistantMessage(message) && message.content) { this._emit('content', message.content as string); } } }