llmadapter.class.php

Go to the documentation of this file.

<?php
/* Copyright (C) 2026   Laurent Destailleur   <eldy@users.sourceforge.net>
 * Copyright (C) 2026   Nick Fragoulis
 * Copyright (C) 2026 Jose Martinez     <jose.martinez@pichinov.com>
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY, without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program. If not, see <https://www.gnu.org/licenses/>.
 * or see https://www.gnu.org/
 */
 
class UniversalLLMAdapter
{
  public $lastRequest = "";
 
  public $lastResponse = "";
 
  private $type;
 
  private $key;
 
  private $baseUrl;
 
  private $model;
 
  private $timeout;
 
  public function __construct(string $type, string $key, string $baseUrl, string $model, int $timeout)
  {
    $this->type = strtolower($type);
    $this->key = $key;
    $this->baseUrl = rtrim($baseUrl, '/');
    $this->model = $model;
    $this->timeout = $timeout;
  }
 
  public function generate(string $system, string $userMsg, string $mode = 'text', array $attachments = array()): ?string
  {
    switch ($this->type) {
      case 'anthropic':
        return $this->callAnthropic($system, $userMsg, $mode, $attachments);
      case 'google':
        return $this->callGoogle($system, $userMsg, $mode, $attachments);
      default:
        return $this->callOpenAI($system, $userMsg, $mode, $attachments);
    }
  }
 
  private function callOpenAI(string $sys, string $msg, string $mode = 'text', array $attachments = array()): ?string
  {
    $url = $this->baseUrl;
    if (strpos($url, '/chat/completions') === false && strpos($url, '/generate') === false) {
      $url .= '/chat/completions';
    }
 
    // With attachments, the user content becomes an array of typed parts
    // (vision input); without, it stays a plain string (widest compatibility).
    $userContent = $msg;
    if (!empty($attachments)) {
      $userContent = array(array("type" => "text", "text" => $msg));
      foreach ($attachments as $att) {
        $userContent[] = array(
          "type" => "image_url",
          "image_url" => array("url" => "data:".$att['mime'].";base64,".$att['data'])
        );
      }
    }
 
    $data = array(
      "model" => $this->model,
      "messages" => array(
        array("role" => "system", "content" => $sys),
        array("role" => "user", "content" => $userContent)
      ),
      "temperature" => 0.1
    );
 
    // Only force JSON mode if explicitly requested
    // This allows Email/Webpage generation to return raw HTML
    if ($mode === 'json') {
      // Apply to specific providers known to support this parameter safely
      if (strpos($url, 'openai') !== false || strpos($url, 'deepseek') !== false || strpos($url, 'perplexity') !== false || strpos($url, 'mistral') !== false || strpos($url, 'zai') !== false) {
        $data["response_format"] = array("type" => "json_object");
      }
    }
 
    $this->lastRequest = json_encode($data, JSON_PRETTY_PRINT);
 
    return $this->curl($url, $data, array("Content-Type: application/json", "Authorization: Bearer " . $this->key));
  }
 
  private function callAnthropic(string $sys, string $msg, string $mode = 'text', array $attachments = array())
  {
 
    $url = $this->baseUrl . (strpos($this->baseUrl, '/messages') === false ? '/messages' : '');
 
    // With attachments, content becomes an array of typed blocks: PDFs go as
    // 'document' blocks, images as 'image' blocks (Anthropic native formats).
    $userContent = $msg;
    $maxTokens = 1024;
    if (!empty($attachments)) {
      $userContent = array();
      foreach ($attachments as $att) {
        $userContent[] = array(
          "type" => ($att['mime'] === 'application/pdf' ? "document" : "image"),
          "source" => array("type" => "base64", "media_type" => $att['mime'], "data" => $att['data'])
        );
      }
      $userContent[] = array("type" => "text", "text" => $msg);
      $maxTokens = 4096;  // document extraction answers are much longer than intent JSON
    }
 
    $data = array(
      "model" => $this->model,
      "system" => $sys,
      "messages" => array(array("role" => "user", "content" => $userContent)),
      "max_tokens" => $maxTokens
    );
 
    $this->lastRequest = json_encode($data, JSON_PRETTY_PRINT);
 
    return $this->curl($url, $data, array("content-type: application/json", "x-api-key: " . $this->key, "anthropic-version: 2023-06-01"), true);
  }
 
  private function callGoogle(string $sys, string $msg, string $mode = 'text', array $attachments = array())
  {
    $url = $this->baseUrl;
 
    // Strict type check for string position
    if (strpos($url, ':generateContent') === false) {
      if (strpos($url, '/models/') === false) {
        $url .= "/models/" . $this->model;
      }
      $url .= ":generateContent";
    }
 
    $url .= "?key=" . $this->key;
 
    // With attachments, prepend native inline_data parts (Gemini vision /
    // document understanding) before the text part.
    $parts = array();
    foreach ($attachments as $att) {
      $parts[] = array("inline_data" => array("mime_type" => $att['mime'], "data" => $att['data']));
    }
    $parts[] = array("text" => $sys . "\nUser: " . $msg);
 
    $data = array(
      "contents" => array(
        array("parts" => $parts)
      ),
      "generationConfig" => array("temperature" => 0.1)
    );
 
    $this->lastRequest = json_encode($data, JSON_PRETTY_PRINT);
 
    return $this->curl($url, $data, array("Content-Type: application/json"), false, true);
  }
 
  private function curl(string $url, array $data, array $headers, bool $isClaude = false, bool $isGemini = false): ?string
  {
    include_once DOL_DOCUMENT_ROOT.'/core/lib/geturl.lib.php';
 
    // By default, we accept only external endpoints ($dolibarr_ai_allow_local_endpoints is not set).
    // To allow local endpoints, we must set $dolibarr_ai_allow_local_endpoints to 1 or 2 in conf.php.
    global $dolibarr_ai_allow_local_endpoints;
    $localurl = $dolibarr_ai_allow_local_endpoints ?? 0;
 
    // Pass $this->timeout as the response timeout so the LLM-specific value configured
    // at construction time is honored (getURLContent's $timeoutresponse is the 10th arg;
    // preceding args $ssl_verifypeer=-1 and $timeoutconnect=0 keep their defaults).
    $result = getURLContent($url, 'POST', json_encode($data), 1, $headers, array('http', 'https'), $localurl, -1, 0, $this->timeout);
 
    $body         = (string) ($result['content'] ?? '');
    $httpCode     = (int) ($result['http_code'] ?? 0);
    $effectiveUrl = (string) ($result['url'] ?? $url);
    // Store an enriched payload so the admin Log Viewer ("VIEW LOGS" in the AI Server
    // MCP setup page) shows something actionable when something goes wrong, not just
    // a bare "Invalid JSON response from API." with an empty body.
    $this->lastResponse = "HTTP " . $httpCode . " from " . $effectiveUrl . "\n--- body (" . strlen($body) . " bytes) ---\n" . $body;
 
    if (!empty($result['curl_error_no'])) {
      return "Error: cURL #" . $result['curl_error_no'] . " " . $result['curl_error_msg'] . " (url=" . $effectiveUrl . ")";
    }
 
    $json = json_decode($body, true);
 
    if ($json === null && json_last_error() !== JSON_ERROR_NONE) {
      // Common real-world causes: HTTP 4xx/5xx with empty body, HTML error page
      // from a proxy, gateway timeout, etc. Surface the HTTP code and a short
      // body snippet so the admin can diagnose without re-running with curl.
      $snippet = substr($body, 0, 500);
      return "Error: Invalid JSON response from API (HTTP " . $httpCode . ", " . strlen($body) . " bytes). Body snippet: " . ($snippet !== '' ? $snippet : '<empty>');
    }
 
    if (isset($json['error'])) {
      $msg = $json['error']['message'] ?? json_encode($json['error']);
      return "Error: API " . $msg;
    }
 
    // Extraction Logic
    if ($isClaude) {
      return $json['content'][0]['text'] ?? null;
    }
    if ($isGemini) {
      return $json['candidates'][0]['content']['parts'][0]['text'] ?? null;
    }
 
    // Default (OpenAI compatible)
    return $json['choices'][0]['message']['content'] ?? null;
  }
}