Function generateTextResponse

gen.pollinations.ai/src/text/handler.ts:307–363

(
    c: TextContext,
    requestData: RequestData,
    contentResponse: boolean,
)

}

async function generateTextResponse(
    c: TextContext,
    requestData: RequestData,
    contentResponse: boolean,
): Promise<Response> {
    syncTextEnvironment(c.env);

    try {
        const communityEndpoint = c.var.model?.communityEndpoint;
        const gatewayContext = communityEndpoint
            ? await communityEndpointGatewayContext(
                  communityEndpoint,
                  c.var.model.definition,
                  requestData,
                  c.env.BETTER_AUTH_SECRET,
                  c.env.PORTKEY_GATEWAY_URL,
                  c.var.auth?.apiKey?.rawKey || "",
              )
            : withGatewayContext(c, requestData);
        const completion = await generateTextPortkey(
            requestData.messages,
            gatewayContext,
        );
        completion.id = completion.id || generatePollinationsId();

        if (completion.error) {
            const errorObj =
                typeof completion.error === "string"
                    ? { message: completion.error }
                    : completion.error;
            const error = new Error(
                errorObj.message || "Text generation failed",
            ) as ServiceError;
            if (typeof errorObj.status === "number") {
                error.status = remapUpstreamStatus(errorObj.status);
                error.upstreamStatus = errorObj.status;
            }
            error.details = errorObj.details;
            throw error;
        }

        if (requestData.stream) return sendTextStreamResponse(completion);
        const fallbackModel = c.var.model?.resolved;
        // Provider-reported cost is read post-response in track (clamp-and-alert
        // in the registry) — malformed/absent cost never fails the request.
        const trackingResponse = sendOpenAIResponse(completion, fallbackModel);
        const publicCompletion = publicChatCompletion(completion);
        if (contentResponse) {
            c.var.track?.overrideResponseTracking(trackingResponse.clone());
            return sendTextContentResponse(publicCompletion, fallbackModel);
        }
        c.var.track?.overrideResponseTracking(trackingResponse.clone());
        return sendOpenAIResponse(publicCompletion, fallbackModel);
    } catch (thrown: unknown) {
        throwTextError(thrown as ServiceError, c);
    }
}