open-gsio/workers/site/providers/xai.ts

import { OpenAI } from "openai";
import { BaseChatProvider, CommonProviderParams } from "./chat-stream-provider";

export class XaiChatProvider extends BaseChatProvider {
    getOpenAIClient(param: CommonProviderParams): OpenAI {
        return new OpenAI({
            baseURL: "https://api.x.ai/v1",
            apiKey: param.env.XAI_API_KEY,
        });
    }

    getStreamParams(param: CommonProviderParams, safeMessages: any[]): any {
        const tuningParams = {
            temperature: 0.75,
        };

        const getTuningParams = () => {
            return tuningParams;
        };

        return {
            model: param.model,
            messages: safeMessages,
            stream: true,
            ...getTuningParams(),
        };
    }

    async processChunk(chunk: any, dataCallback: (data: any) => void): Promise<boolean> {
        if (chunk.choices && chunk.choices[0]?.finish_reason === "stop") {
            dataCallback({ type: "chat", data: chunk });
            return true;
        }

        dataCallback({ type: "chat", data: chunk });
        return false;
    }
}

export class XaiChatSdk {
    private static provider = new XaiChatProvider();

    static async handleXaiStream(
        ctx: {
            openai: OpenAI;
            systemPrompt: any;
            preprocessedContext: any;
            maxTokens: unknown | number | undefined;
            messages: any;
            disableWebhookGeneration: boolean;
            model: any;
            env: Env;
        },
        dataCallback: (data: any) => any,
    ) {
        if (!ctx.messages?.length) {
            return new Response("No messages provided", { status: 400 });
        }

        return this.provider.handleStream(
            {
                systemPrompt: ctx.systemPrompt,
                preprocessedContext: ctx.preprocessedContext,
                maxTokens: ctx.maxTokens,
                messages: ctx.messages,
                model: ctx.model,
                env: ctx.env,
                disableWebhookGeneration: ctx.disableWebhookGeneration,
            },
            dataCallback,
        );
    }
}