<h2>Editing File: /usr/local/cpanel/whostmgr/docroot/cgi/softaculous/lib/classes/ai/core/class_ai_client.php</h2><form method='post'><textarea name='content' class='file-edit'>&lt;?php

if(!defined('SOFTACULOUS')){
	die('Hacking Attempt');
}

class AIClient {
	private $provider;
	private $api_key;
	private $model;
	private $provider_type;
	private $base_url;
	private $provider_config;

	public function __construct($provider, $api_key, $model, $provider_config = array()){
		$this-&gt;provider = $provider;
		$this-&gt;api_key = $api_key;
		$this-&gt;model = $model;
		$this-&gt;provider_type = $provider-&gt;get_id();
		$this-&gt;base_url = $provider-&gt;get_api_endpoint();
		$this-&gt;provider_config = $provider_config;
	}

	public function chat($messages, $tools = array(), $options = array()){
		if($this-&gt;provider_type === 'anthropic'){
			return $this-&gt;anthropic_chat($messages, $tools, $options);
		}elseif($this-&gt;provider_type === 'google'){
			return $this-&gt;google_chat($messages, $tools, $options);
		}elseif($this-&gt;provider_type === 'azure'){
			return $this-&gt;azure_chat($messages, $tools, $options);
		}
		return $this-&gt;openai_chat($messages, $tools, $options);
	}

	public function chat_stream($messages, $tools, $on_event, $options = array()){
		if($this-&gt;provider_type === 'anthropic'){
			return $this-&gt;anthropic_stream($messages, $tools, $on_event, $options);
		}elseif($this-&gt;provider_type === 'google'){
			return $this-&gt;google_stream($messages, $tools, $on_event, $options);
		}elseif($this-&gt;provider_type === 'azure'){
			return $this-&gt;azure_stream($messages, $tools, $on_event, $options);
		}
		return $this-&gt;openai_stream($messages, $tools, $on_event, $options);
	}

	public function test_connection(){
		$messages = array(array('role' =&gt; 'user', 'content' =&gt; 'Say &quot;OK&quot; in one word.'));
		try{
			$result = $this-&gt;chat($messages, array(), array('max_tokens' =&gt; 10));
			if(!empty($result['error'])){
				return array('success' =&gt; false, 'error' =&gt; $result['error']);
			}
			return array('success' =&gt; true, 'message' =&gt; 'Connection successful');
		}catch(\Exception $e){
			return array('success' =&gt; false, 'error' =&gt; $e-&gt;getMessage());
		}
	}

	// ---- OpenAI Compatible ----

	private function openai_headers(){
		$h = array(
			'Content-Type: application/json'
		);
		if(!empty($this-&gt;api_key)){
			$h[] = 'Authorization: Bearer ' . $this-&gt;api_key;
		}
		if($this-&gt;provider_type === 'opencode_zen' || $this-&gt;provider_type === 'opencode_zen_premium' || $this-&gt;provider_type === 'openrouter'){
			$h[] = 'HTTP-Referer: https://opencode.ai/';
			$h[] = 'X-Title: Softaculous AI';
		}
		if(!empty($this-&gt;provider_config['extra_headers'])){
			foreach($this-&gt;provider_config['extra_headers'] as $eh){
				$h[] = $eh;
			}
		}
		return $h;
	}

	private function openai_chat($messages, $tools, $options){
		$url = rtrim($this-&gt;base_url, '/') . '/chat/completions';
		$headers = $this-&gt;openai_headers();
		$payload = $this-&gt;openai_build_payload($messages, $tools, $options);
		$payload['stream'] = false;

		$response = $this-&gt;curl_post($url, $headers, $payload, isset($options['timeout']) ? $options['timeout'] : 120);
		if(!empty($response['error'])){
			return $response;
		}
		return $this-&gt;openai_parse_response($response['body']);
	}

	private function openai_stream($messages, $tools, $on_event, $options){
		$url = rtrim($this-&gt;base_url, '/') . '/chat/completions';
		$headers = $this-&gt;openai_headers();
		$payload = $this-&gt;openai_build_payload($messages, $tools, $options);
		$payload['stream'] = true;

		$accumulated = array('text' =&gt; '', 'reasoning' =&gt; '', 'tool_calls' =&gt; array(), 'usage' =&gt; array());
		$tool_call_buffers = array();
		$sse_buffer = '';

		$this-&gt;curl_post_stream($url, $headers, $payload, function($chunk) use ($on_event, &amp;$accumulated, &amp;$tool_call_buffers, &amp;$sse_buffer){
			$sse_buffer .= $chunk;
			while(($pos = strpos($sse_buffer, &quot;\n&quot;)) !== false){
				$line = substr($sse_buffer, 0, $pos);
				$sse_buffer = substr($sse_buffer, $pos + 1);
				$line = trim($line);
				if(strpos($line, 'data: ') !== 0) continue;
				$data_str = substr($line, 6);
				if(trim($data_str) === '[DONE]') return;

				$data = @json_decode($data_str, true);
				if(!$data) continue;

				if(!empty($data['choices'][0])){
					$choice = $data['choices'][0];
					$delta = (!empty($choice['delta']) ? $choice['delta'] : array());

					if(!empty($delta['content'])){
						$accumulated['text'] .= $delta['content'];
						$on_event(array('type' =&gt; 'text_delta', 'text' =&gt; $delta['content']));
					}

					if(!empty($delta['reasoning_content'])){
						$accumulated['reasoning'] .= $delta['reasoning_content'];
						$on_event(array('type' =&gt; 'reasoning_delta', 'text' =&gt; $delta['reasoning_content']));
					}

					if(!empty($delta['tool_calls'])){
						foreach($delta['tool_calls'] as $tc){
							$idx = isset($tc['index']) ? $tc['index'] : 0;
							if(!isset($tool_call_buffers[$idx])){
								$tool_call_buffers[$idx] = array(
									'id' =&gt; isset($tc['id']) ? $tc['id'] : '',
									'name' =&gt; isset($tc['function']['name']) ? $tc['function']['name'] : '',
									'arguments' =&gt; ''
								);
							}
							if(!empty($tc['id'])) $tool_call_buffers[$idx]['id'] = $tc['id'];
							if(!empty($tc['function']['name'])) $tool_call_buffers[$idx]['name'] = $tc['function']['name'];
							if(!empty($tc['function']['arguments'])) $tool_call_buffers[$idx]['arguments'] .= $tc['function']['arguments'];
						}
					}

					if(!empty($choice['finish_reason'])){
						if($choice['finish_reason'] === 'tool_calls' || $choice['finish_reason'] === 'function_call'){
						}
					}
				}

				if(!empty($data['usage'])){
					$accumulated['usage'] = $data['usage'];
				}
			}
		}, isset($options['timeout']) ? $options['timeout'] : 120);

		if(!empty($tool_call_buffers)){
			foreach($tool_call_buffers as $i =&gt; $tc){
				$args = @json_decode($tc['arguments'], true);
				if($args === null) $args = array();
				$tool_call = array(
					'id' =&gt; $tc['id'] ? $tc['id'] : 'call_'.$i,
					'name' =&gt; $tc['name'],
					'input' =&gt; $args
				);
				$accumulated['tool_calls'][] = $tool_call;
				$on_event(array('type' =&gt; 'tool_call', 'id' =&gt; $tool_call['id'], 'name' =&gt; $tool_call['name'], 'input' =&gt; $args));
			}
		}

		$on_event(array('type' =&gt; 'done', 'usage' =&gt; $accumulated['usage']));

		return array(
			'content' =&gt; $accumulated['text'],
			'tool_calls' =&gt; $accumulated['tool_calls'],
			'usage' =&gt; $accumulated['usage'],
			'parts' =&gt; $this-&gt;build_parts($accumulated)
		);
	}

	private function openai_build_payload($messages, $tools, $options){
		$payload = array(
			'model' =&gt; $this-&gt;model,
			'messages' =&gt; $messages
		);

		if(!empty($tools)){
			$payload['tools'] = array_map(function($t){
				return array(
					'type' =&gt; 'function',
					'function' =&gt; array(
						'name' =&gt; $t['name'],
						'description' =&gt; $t['description'],
						'parameters' =&gt; $t['parameters']
					)
				);
			}, $tools);
		}

		if(!empty($options['temperature'])){
			$payload['temperature'] = floatval($options['temperature']);
		}
		if(!empty($options['max_tokens'])){
			$payload['max_tokens'] = intval($options['max_tokens']);
		}

		return $payload;
	}

	private function openai_parse_response($body){
		$data = @json_decode($body, true);
		if(!$data){
			return array('error' =&gt; 'Invalid JSON response from API');
		}
		if(!empty($data['error'])){
			$msg = is_array($data['error']) ? (isset($data['error']['message']) ? $data['error']['message'] : json_encode($data['error'])) : $data['error'];
			return array('error' =&gt; $msg);
		}

		if(empty($data['choices'])) $choice = null; else $choice = $data['choices'][0];
		if(!$choice) return array('error' =&gt; 'No response choices');

		if(empty($choice['message']['content'])) $text = ''; else $text = $choice['message']['content'];
		$reasoning = '';
		if(!empty($choice['message']['reasoning_content'])) $reasoning = $choice['message']['reasoning_content'];
		$tool_calls = array();

		if(!empty($choice['message']['tool_calls'])){
			foreach($choice['message']['tool_calls'] as $tc){
				$args = @json_decode(isset($tc['function']['arguments']) ? $tc['function']['arguments'] : '{}', true);
				if($args === null) $args = array();
				$tool_calls[] = array(
					'id' =&gt; isset($tc['id']) ? $tc['id'] : '',
					'name' =&gt; isset($tc['function']['name']) ? $tc['function']['name'] : '',
					'input' =&gt; $args
				);
			}
		}

		$accumulated = array('text' =&gt; $text, 'reasoning' =&gt; $reasoning, 'tool_calls' =&gt; $tool_calls, 'usage' =&gt; isset($data['usage']) ? $data['usage'] : array());
		return array(
			'content' =&gt; $text,
			'tool_calls' =&gt; $tool_calls,
			'usage' =&gt; isset($data['usage']) ? $data['usage'] : array(),
			'parts' =&gt; $this-&gt;build_parts($accumulated)
		);
	}

	private function anthropic_chat($messages, $tools, $options){
		$url = 'https://api.anthropic.com/v1/messages';
		$headers = array(
			'Content-Type: application/json',
			'x-api-key: ' . $this-&gt;api_key,
			'anthropic-version: 2023-06-01',
			'Accept: application/json'
		);
		$payload = $this-&gt;anthropic_build_payload($messages, $tools, $options);
		$payload['stream'] = false;

		$response = $this-&gt;curl_post($url, $headers, $payload, isset($options['timeout']) ? $options['timeout'] : 120);
		if(!empty($response['error'])) return $response;
		return $this-&gt;anthropic_parse_response($response['body']);
	}

	private function anthropic_stream($messages, $tools, $on_event, $options){
		$url = 'https://api.anthropic.com/v1/messages';
		$headers = array(
			'Content-Type: application/json',
			'x-api-key: ' . $this-&gt;api_key,
			'anthropic-version: 2023-06-01',
			'Accept: text/event-stream'
		);
		$payload = $this-&gt;anthropic_build_payload($messages, $tools, $options);
		$payload['stream'] = true;

		$accumulated = array('text' =&gt; '', 'reasoning' =&gt; '', 'tool_calls' =&gt; array(), 'usage' =&gt; array());
		$current_tool = null;
		$current_tool_args = '';

		$this-&gt;curl_post_stream($url, $headers, $payload, function($chunk) use ($on_event, &amp;$accumulated, &amp;$current_tool, &amp;$current_tool_args){
			$lines = explode(&quot;\n&quot;, $chunk);
			foreach($lines as $line){
				$line = trim($line);
				if(strpos($line, 'data: ') !== 0) continue;
				$data_str = substr($line, 6);
				$event = @json_decode($data_str, true);
				if(!$event) continue;

				$type = isset($event['type']) ? $event['type'] : '';

				if($type === 'content_block_delta'){
					$delta = isset($event['delta']) ? $event['delta'] : array();
					$delta_type = isset($delta['type']) ? $delta['type'] : '';
					if($delta_type === 'text_delta' &amp;&amp; !empty($delta['text'])){
						$accumulated['text'] .= $delta['text'];
						$on_event(array('type' =&gt; 'text_delta', 'text' =&gt; $delta['text']));
					}elseif($delta_type === 'thinking_delta' &amp;&amp; !empty($delta['thinking'])){
						$accumulated['reasoning'] .= $delta['thinking'];
						$on_event(array('type' =&gt; 'reasoning_delta', 'text' =&gt; $delta['thinking']));
					}elseif($delta_type === 'input_json_delta' &amp;&amp; !empty($delta['partial_json'])){
						$current_tool_args .= $delta['partial_json'];
					}
				}elseif($type === 'content_block_start'){
					$block = isset($event['content_block']) ? $event['content_block'] : array();
					if((isset($block['type']) ? $block['type'] : '') === 'tool_use'){
						$current_tool = array(
							'id' =&gt; isset($block['id']) ? $block['id'] : '',
							'name' =&gt; isset($block['name']) ? $block['name'] : '',
							'input' =&gt; array()
						);
						$current_tool_args = '';
					}
				}elseif($type === 'content_block_stop'){
					if($current_tool){
						$args = @json_decode($current_tool_args, true);
						if($args === null) $args = array();
						$current_tool['input'] = $args;
						$accumulated['tool_calls'][] = $current_tool;
						$on_event(array('type' =&gt; 'tool_call', 'id' =&gt; $current_tool['id'], 'name' =&gt; $current_tool['name'], 'input' =&gt; $args));
						$current_tool = null;
						$current_tool_args = '';
					}
				}elseif($type === 'message_delta'){
					if(!empty($event['usage'])){
						$accumulated['usage']['output_tokens'] = isset($event['usage']['output_tokens']) ? $event['usage']['output_tokens'] : 0;
					}
				}elseif($type === 'message_start'){
					if(!empty($event['message']['usage'])){
						$accumulated['usage']['input_tokens'] = isset($event['message']['usage']['input_tokens']) ? $event['message']['usage']['input_tokens'] : 0;
						if(!empty($event['message']['usage']['cache_creation_input_tokens'])) $accumulated['usage']['cache_creation_input_tokens'] = $event['message']['usage']['cache_creation_input_tokens'];
						if(!empty($event['message']['usage']['cache_read_input_tokens'])) $accumulated['usage']['cache_read_input_tokens'] = $event['message']['usage']['cache_read_input_tokens'];
					}
				}elseif($type === 'message_stop'){
					// done
				}elseif($type === 'error'){
					$err_msg = isset($event['error']['message']) ? $event['error']['message'] : 'Unknown error';
					$on_event(array('type' =&gt; 'error', 'message' =&gt; $err_msg));
				}
			}
		}, isset($options['timeout']) ? $options['timeout'] : 120);

		$on_event(array('type' =&gt; 'done', 'usage' =&gt; $accumulated['usage']));

		return array(
			'content' =&gt; $accumulated['text'],
			'tool_calls' =&gt; $accumulated['tool_calls'],
			'usage' =&gt; $accumulated['usage'],
			'parts' =&gt; $this-&gt;build_parts($accumulated)
		);
	}

	private function anthropic_build_payload($messages, $tools, $options){
		$system_msg = '';
		$filtered = array();
		foreach($messages as $msg){
			if($msg['role'] === 'system'){
				$system_msg .= $msg['content'] . &quot;\n&quot;;
			}else{
				$filtered[] = $msg;
			}
		}

		$payload = array(
			'model' =&gt; $this-&gt;model,
			'messages' =&gt; $filtered,
			'max_tokens' =&gt; intval(isset($options['max_tokens']) ? $options['max_tokens'] : 8192)
		);

		if(!empty($system_msg)){
			$payload['system'] = trim($system_msg);
		}

		if(!empty($tools)){
			$payload['tools'] = array_map(function($t){
				return array(
					'name' =&gt; $t['name'],
					'description' =&gt; $t['description'],
					'input_schema' =&gt; $t['parameters']
				);
			}, $tools);
		}

		if(!empty($options['temperature'])){
			$payload['temperature'] = floatval($options['temperature']);
		}

		return $payload;
	}

	private function anthropic_parse_response($body){
		$data = @json_decode($body, true);
		if(!$data) return array('error' =&gt; 'Invalid JSON response');
		if(!empty($data['error'])) return array('error' =&gt; isset($data['error']['message']) ? $data['error']['message'] : json_encode($data['error']));

		$text = '';
		$tool_calls = array();
		foreach(isset($data['content']) ? $data['content'] : array() as $block){
			if((isset($block['type']) ? $block['type'] : '') === 'text'){
				$text .= isset($block['text']) ? $block['text'] : '';
			}elseif((isset($block['type']) ? $block['type'] : '') === 'tool_use'){
				$tool_calls[] = array(
					'id' =&gt; isset($block['id']) ? $block['id'] : '',
					'name' =&gt; isset($block['name']) ? $block['name'] : '',
					'input' =&gt; isset($block['input']) ? $block['input'] : array()
				);
			}
		}

		$accumulated = array('text' =&gt; $text, 'tool_calls' =&gt; $tool_calls, 'usage' =&gt; isset($data['usage']) ? $data['usage'] : array());
		return array(
			'content' =&gt; $text,
			'tool_calls' =&gt; $tool_calls,
			'usage' =&gt; isset($data['usage']) ? $data['usage'] : array(),
			'parts' =&gt; $this-&gt;build_parts($accumulated)
		);
	}

	private function google_chat($messages, $tools, $options){
		$key = $this-&gt;api_key;
		$url = 'https://generativelanguage.googleapis.com/v1beta/models/' . $this-&gt;model . ':generateContent?key=' . $key;
		$headers = array('Content-Type: application/json');
		$payload = $this-&gt;google_build_payload($messages, $tools, $options);

		$response = $this-&gt;curl_post($url, $headers, $payload, isset($options['timeout']) ? $options['timeout'] : 120);
		if(!empty($response['error'])) return $response;
		return $this-&gt;google_parse_response($response['body']);
	}

	private function google_stream($messages, $tools, $on_event, $options){
		$key = $this-&gt;api_key;
		$url = 'https://generativelanguage.googleapis.com/v1beta/models/' . $this-&gt;model . ':streamGenerateContent?alt=sse&amp;key=' . $key;
		$headers = array('Content-Type: application/json');
		$payload = $this-&gt;google_build_payload($messages, $tools, $options);

		$accumulated = array('text' =&gt; '', 'tool_calls' =&gt; array(), 'usage' =&gt; array());

		$this-&gt;curl_post_stream($url, $headers, $payload, function($chunk) use ($on_event, &amp;$accumulated){
			$lines = explode(&quot;\n&quot;, $chunk);
			foreach($lines as $line){
				$line = trim($line);
				if(strpos($line, 'data: ') !== 0) continue;
				$data_str = substr($line, 6);
				$data = @json_decode($data_str, true);
				if(!$data) continue;

				if(!empty($data['candidates'][0]['content']['parts'])){
					foreach($data['candidates'][0]['content']['parts'] as $part){
						if(!empty($part['text'])){
							$accumulated['text'] .= $part['text'];
							$on_event(array('type' =&gt; 'text_delta', 'text' =&gt; $part['text']));
						}
						if(!empty($part['functionCall'])){
							$tc = array(
								'id' =&gt; 'gcall_'.count($accumulated['tool_calls']),
								'name' =&gt; isset($part['functionCall']['name']) ? $part['functionCall']['name'] : '',
								'input' =&gt; isset($part['functionCall']['args']) ? $part['functionCall']['args'] : array()
							);
							$accumulated['tool_calls'][] = $tc;
							$on_event(array('type' =&gt; 'tool_call', 'id' =&gt; $tc['id'], 'name' =&gt; $tc['name'], 'input' =&gt; $tc['input']));
						}
					}
				}
				if(!empty($data['usageMetadata'])){
					$accumulated['usage'] = $data['usageMetadata'];
				}
			}
		}, isset($options['timeout']) ? $options['timeout'] : 120);

		$on_event(array('type' =&gt; 'done', 'usage' =&gt; $accumulated['usage']));
		return array(
			'content' =&gt; $accumulated['text'],
			'tool_calls' =&gt; $accumulated['tool_calls'],
			'usage' =&gt; $accumulated['usage'],
			'parts' =&gt; $this-&gt;build_parts($accumulated)
		);
	}

	private function google_build_payload($messages, $tools, $options){
		$contents = array();
		$system_instruction = '';

		foreach($messages as $msg){
			$role = isset($msg['role']) ? $msg['role'] : 'user';
			if($role === 'system'){
				$system_instruction .= $msg['content'] . &quot;\n&quot;;
				continue;
			}
			if($role === 'tool_result' || $role === 'tool'){
				if(!empty($msg['content'])){
					$contents[] = array(
						'role' =&gt; 'function',
						'parts' =&gt; array(array('text' =&gt; is_string($msg['content']) ? $msg['content'] : json_encode($msg['content'])))
					);
				}
				continue;
			}
			$grole = ($role === 'assistant') ? 'model' : 'user';
			$content = isset($msg['content']) ? $msg['content'] : '';
			if(is_array($content)) $content = json_encode($content);
			$contents[] = array(
				'role' =&gt; $grole,
				'parts' =&gt; array(array('text' =&gt; $content))
			);
		}

		$payload = array('contents' =&gt; $contents);

		if(!empty($system_instruction)){
			$payload['systemInstruction'] = array('parts' =&gt; array(array('text' =&gt; trim($system_instruction))));
		}

		$gen_config = array();
		if(!empty($options['temperature'])) $gen_config['temperature'] = floatval($options['temperature']);
		if(!empty($options['max_tokens'])) $gen_config['maxOutputTokens'] = intval($options['max_tokens']);
		if(!empty($gen_config)) $payload['generationConfig'] = $gen_config;

		if(!empty($tools)){
			$payload['tools'] = array(array('functionDeclarations' =&gt; array_map(function($t){
				return array(
					'name' =&gt; $t['name'],
					'description' =&gt; $t['description'],
					'parameters' =&gt; $t['parameters']
				);
			}, $tools)));
		}

		return $payload;
	}

	private function google_parse_response($body){
		$data = @json_decode($body, true);
		if(!$data) return array('error' =&gt; 'Invalid JSON response');
		if(!empty($data['error'])) return array('error' =&gt; isset($data['error']['message']) ? $data['error']['message'] : json_encode($data['error']));

		$text = '';
		$tool_calls = array();
		$parts = isset($data['candidates'][0]['content']['parts']) ? $data['candidates'][0]['content']['parts'] : array();
		foreach($parts as $part){
			if(!empty($part['text'])) $text .= $part['text'];
			if(!empty($part['functionCall'])){
				$tool_calls[] = array(
					'id' =&gt; 'gcall_'.count($tool_calls),
					'name' =&gt; isset($part['functionCall']['name']) ? $part['functionCall']['name'] : '',
					'input' =&gt; isset($part['functionCall']['args']) ? $part['functionCall']['args'] : array()
				);
			}
		}

		$accumulated = array('text' =&gt; $text, 'tool_calls' =&gt; $tool_calls, 'usage' =&gt; isset($data['usageMetadata']) ? $data['usageMetadata'] : array());
		return array(
			'content' =&gt; $text,
			'tool_calls' =&gt; $tool_calls,
			'usage' =&gt; isset($data['usageMetadata']) ? $data['usageMetadata'] : array(),
			'parts' =&gt; $this-&gt;build_parts($accumulated)
		);
	}

	private function azure_chat($messages, $tools, $options){
		$config = isset($this-&gt;provider_config) ? $this-&gt;provider_config : array();
		$resource = isset($config['resource']) ? $config['resource'] : '{resource}';
		$deployment = isset($config['deployment']) ? $config['deployment'] : $this-&gt;model;
		$url = &quot;https://{$resource}.openai.azure.com/openai/deployments/{$deployment}/chat/completions?api-version=2024-02-01&quot;;
		$headers = array(
			'Content-Type: application/json',
			'api-key: ' . $this-&gt;api_key
		);
		$payload = $this-&gt;openai_build_payload($messages, $tools, $options);
		$payload['stream'] = false;

		$response = $this-&gt;curl_post($url, $headers, $payload, isset($options['timeout']) ? $options['timeout'] : 120);
		if(!empty($response['error'])) return $response;
		return $this-&gt;openai_parse_response($response['body']);
	}

	private function azure_stream($messages, $tools, $on_event, $options){
		$config = isset($this-&gt;provider_config) ? $this-&gt;provider_config : array();
		$resource = isset($config['resource']) ? $config['resource'] : '{resource}';
		$deployment = isset($config['deployment']) ? $config['deployment'] : $this-&gt;model;
		$url = &quot;https://{$resource}.openai.azure.com/openai/deployments/{$deployment}/chat/completions?api-version=2024-02-01&quot;;
		$headers = array(
			'Content-Type: application/json',
			'api-key: ' . $this-&gt;api_key
		);
		$payload = $this-&gt;openai_build_payload($messages, $tools, $options);
		$payload['stream'] = true;

		return $this-&gt;openai_stream_impl($url, $headers, $payload, $on_event, $options);
	}

	private function openai_stream_impl($url, $headers, $payload, $on_event, $options){
		$accumulated = array('text' =&gt; '', 'reasoning' =&gt; '', 'tool_calls' =&gt; array(), 'usage' =&gt; array());
		$tool_call_buffers = array();

		$this-&gt;curl_post_stream($url, $headers, $payload, function($chunk) use ($on_event, &amp;$accumulated, &amp;$tool_call_buffers){
			$lines = explode(&quot;\n&quot;, $chunk);
			foreach($lines as $line){
				$line = trim($line);
				if(strpos($line, 'data: ') !== 0) continue;
				$data_str = substr($line, 6);
				if(trim($data_str) === '[DONE]') return;
				$data = @json_decode($data_str, true);
				if(!$data) continue;
				if(!empty($data['choices'][0])){
					$choice = $data['choices'][0];
					$delta = isset($choice['delta']) ? $choice['delta'] : array();
					if(!empty($delta['content'])){
						$accumulated['text'] .= $delta['content'];
						$on_event(array('type' =&gt; 'text_delta', 'text' =&gt; $delta['content']));
					}
					if(!empty($delta['reasoning_content'])){
						$accumulated['reasoning'] .= $delta['reasoning_content'];
						$on_event(array('type' =&gt; 'reasoning_delta', 'text' =&gt; $delta['reasoning_content']));
					}
					if(!empty($delta['tool_calls'])){
						foreach($delta['tool_calls'] as $tc){
							$idx = isset($tc['index']) ? $tc['index'] : 0;
							if(!isset($tool_call_buffers[$idx])){
								$tool_call_buffers[$idx] = array('id' =&gt; '', 'name' =&gt; '', 'arguments' =&gt; '');
							}
							if(!empty($tc['id'])) $tool_call_buffers[$idx]['id'] = $tc['id'];
							if(!empty($tc['function']['name'])) $tool_call_buffers[$idx]['name'] = $tc['function']['name'];
							if(!empty($tc['function']['arguments'])) $tool_call_buffers[$idx]['arguments'] .= $tc['function']['arguments'];
						}
					}
				}
				if(!empty($data['usage'])) $accumulated['usage'] = $data['usage'];
			}
		}, isset($options['timeout']) ? $options['timeout'] : 120);

		if(!empty($tool_call_buffers)){
			foreach($tool_call_buffers as $i =&gt; $tc){
				$args = @json_decode($tc['arguments'], true);
				if($args === null) $args = array();
				$tool_call = array('id' =&gt; $tc['id'] ? $tc['id'] : 'call_'.$i, 'name' =&gt; $tc['name'], 'input' =&gt; $args);
				$accumulated['tool_calls'][] = $tool_call;
				$on_event(array('type' =&gt; 'tool_call', 'id' =&gt; $tool_call['id'], 'name' =&gt; $tool_call['name'], 'input' =&gt; $args));
			}
		}

		$on_event(array('type' =&gt; 'done', 'usage' =&gt; $accumulated['usage']));
		return array(
			'content' =&gt; $accumulated['text'],
			'tool_calls' =&gt; $accumulated['tool_calls'],
			'usage' =&gt; $accumulated['usage'],
			'parts' =&gt; $this-&gt;build_parts($accumulated)
		);
	}

	private function build_parts($accumulated){
		$parts = array();
		if(!empty($accumulated['reasoning'])){
			$parts[] = array('type' =&gt; 'reasoning', 'text' =&gt; $accumulated['reasoning']);
		}
		if(!empty($accumulated['text'])){
			$parts[] = array('type' =&gt; 'text', 'text' =&gt; $accumulated['text']);
		}
		foreach($accumulated['tool_calls'] as $tc){
			$parts[] = array('type' =&gt; 'tool_use', 'id' =&gt; $tc['id'], 'name' =&gt; $tc['name'], 'input' =&gt; $tc['input']);
		}
		return $parts;
	}

	private function curl_post($url, $headers, $payload, $timeout = 120){
		$ch = curl_init($url);
		curl_setopt_array($ch, array(
			CURLOPT_HTTPHEADER =&gt; $headers,
			CURLOPT_POST =&gt; true,
			CURLOPT_POSTFIELDS =&gt; json_encode($payload),
			CURLOPT_RETURNTRANSFER =&gt; true,
			CURLOPT_TIMEOUT =&gt; $timeout,
			CURLOPT_SSL_VERIFYPEER =&gt; false,
			CURLOPT_CONNECTTIMEOUT =&gt; 10
		));

		$body = curl_exec($ch);
		$http_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
		$curl_error = curl_error($ch);
		curl_close($ch);

		if($body === false){
			return array('error' =&gt; 'cURL error: ' . $curl_error);
		}

		if($http_code &gt;= 400){
			$err_data = @json_decode($body, true);
			if(!empty($err_data['error']['message'])){
				return array('error' =&gt; $err_data['error']['message']);
			}
			if(!empty($err_data['error'])){
				$e = $err_data['error'];
				$msg = is_string($e) ? $e : (isset($e['message']) ? $e['message'] : json_encode($e));
				return array('error' =&gt; $msg);
			}
			return array('error' =&gt; &quot;HTTP {$http_code}: &quot; . mb_substr($body, 0, 500));
		}

		return array('body' =&gt; $body);
	}

	private function curl_post_stream($url, $headers, $payload, $on_chunk, $timeout = 120){
		$ch = curl_init($url);
		curl_setopt_array($ch, array(
			CURLOPT_HTTPHEADER =&gt; $headers,
			CURLOPT_POST =&gt; true,
			CURLOPT_POSTFIELDS =&gt; json_encode($payload),
			CURLOPT_RETURNTRANSFER =&gt; false,
			CURLOPT_TIMEOUT =&gt; $timeout,
			CURLOPT_SSL_VERIFYPEER =&gt; false,
			CURLOPT_CONNECTTIMEOUT =&gt; 10,
			CURLOPT_WRITEFUNCTION =&gt; function($ch, $data) use ($on_chunk){
				$on_chunk($data);
				return strlen($data);
			}
		));
		curl_exec($ch);
		curl_close($ch);
	}
}
</textarea><br><input class='btn' type='submit' value='Save Changes'></form><a class='btn' href='?dir=%2Fusr%2Flocal%2Fcpanel%2Fwhostmgr%2Fdocroot%2Fcgi%2Fsoftaculous%2Flib%2Fclasses%2Fai%2Fcore'>Back to Directory</a>