All files / providers GeminiProvider.ts

3.44% Statements 1/29
0% Branches 0/16
0% Functions 0/6
3.57% Lines 1/28

Press n or j to go to the next uncovered block, b, p or k for the previous block.

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78    1x                                                                                                                                                      
import { AIProvider, AIResponse, ChatOptions, Message } from '../core/interfaces';
 
export class GeminiProvider implements AIProvider {
  readonly name = 'Google Gemini';
  readonly type = 'gemini' as const;
 
  constructor(
    private readonly apiKey: string,
    readonly modelName: string,
    private readonly baseUrl: string,
    private readonly timeout: number
  ) {}
 
  async isAvailable(): Promise<boolean> {
    Iif (!this.apiKey) return false;
    try {
      const url = `${this.baseUrl}/models?key=${this.apiKey}`;
      const resp = await fetch(url, { signal: AbortSignal.timeout(3000) });
      return resp.ok;
    } catch {
      return false;
    }
  }
 
  async chat(messages: Message[], options: ChatOptions = {}): Promise<AIResponse> {
    const contents = messages
      .filter(m => m.role !== 'system')
      .map(m => ({
        role: m.role === 'assistant' ? 'model' : 'user',
        parts: [{ text: m.content }],
      }));
 
    const body: Record<string, unknown> = {
      contents,
      generationConfig: {
        maxOutputTokens: options.maxTokens ?? 4096,
        temperature: options.temperature ?? 0.1,
      },
    };
 
    Iif (options.systemPrompt) {
      body['systemInstruction'] = { parts: [{ text: options.systemPrompt }] };
    }
 
    const url = `${this.baseUrl}/models/${this.modelName}:generateContent?key=${this.apiKey}`;
    const resp = await fetch(url, {
      method: 'POST',
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify(body),
      signal: AbortSignal.timeout(this.timeout),
    });
 
    Iif (!resp.ok) {
      const err = await resp.text();
      throw new Error(`Gemini ${resp.status}: ${err}`);
    }
 
    const data = await resp.json() as {
      candidates: Array<{ content: { parts: Array<{ text: string }> } }>;
      usageMetadata: { promptTokenCount: number; candidatesTokenCount: number };
    };
 
    return {
      content: data.candidates[0]?.content?.parts[0]?.text ?? '',
      model: this.modelName,
      usage: {
        promptTokens: data.usageMetadata?.promptTokenCount ?? 0,
        completionTokens: data.usageMetadata?.candidatesTokenCount ?? 0,
      },
    };
  }
 
  async complete(prompt: string, options?: ChatOptions): Promise<string> {
    const resp = await this.chat([{ role: 'user', content: prompt }], options);
    return resp.content;
  }
}