modules
3 years ago
admin.php
3 years ago
ai.php
3 years ago
answer.php
3 years ago
core.php
3 years ago
init.php
3 years ago
openai.php
3 years ago
query.php
3 years ago
queryimage.php
3 years ago
querytext.php
3 years ago
rest.php
3 years ago
ui.php
3 years ago
openai.php
279 lines
| 1 | <?php |
| 2 | |
| 3 | class Meow_MWAI_OpenAI |
| 4 | { |
| 5 | private $core = null; |
| 6 | private $apiKey = null; |
| 7 | |
| 8 | public function __construct($core) |
| 9 | { |
| 10 | $this->core = $core; |
| 11 | $this->apiKey = $this->core->get_option('openai_apikey'); |
| 12 | } |
| 13 | |
| 14 | public function listFiles() |
| 15 | { |
| 16 | return $this->run('GET', '/files'); |
| 17 | } |
| 18 | |
| 19 | function getSuffixForModel($model) |
| 20 | { |
| 21 | preg_match("/:([a-zA-Z\-]{1,40})-([0-9]{4})-([0-9]{2})-([0-9]{2})/", $model, $matches); |
| 22 | if (count($matches) > 0) { |
| 23 | return $matches[1]; |
| 24 | } |
| 25 | return 'N/A'; |
| 26 | } |
| 27 | |
| 28 | function getBaseModel($model) |
| 29 | { |
| 30 | preg_match("/:([a-zA-Z\-]{1,40})-([0-9]{4})-([0-9]{2})-([0-9]{2})/", $model, $matches); |
| 31 | if (count($matches) > 0) { |
| 32 | return $matches[1]; |
| 33 | } |
| 34 | return 'N/A'; |
| 35 | } |
| 36 | |
| 37 | public function listFineTunes( $clean = false ) |
| 38 | { |
| 39 | $finetunes = $this->run('GET', '/fine-tunes'); |
| 40 | |
| 41 | if ( $clean ) { |
| 42 | $deleted = []; |
| 43 | $finetunes['data'] = array_filter( $finetunes['data'], function ( $finetune ) use ( &$deleted ) { |
| 44 | $name = $finetune['fine_tuned_model']; |
| 45 | $isSucceeded = $finetune['status'] === 'succeeded'; |
| 46 | $exist = true; |
| 47 | if ($isSucceeded) { |
| 48 | try { |
| 49 | $finetune = $this->getModel( $name ); |
| 50 | } |
| 51 | catch ( Exception $e ) { |
| 52 | $exist = false; |
| 53 | $deleted[] = $name; |
| 54 | } |
| 55 | } |
| 56 | return $exist; |
| 57 | }); |
| 58 | $this->core->update_option( 'openai_finetunes_deleted', $deleted ); |
| 59 | } |
| 60 | |
| 61 | $finetunes['data'] = array_map( function ( $finetune ) { |
| 62 | $finetune['suffix'] = $this->getSuffixForModel( $finetune['fine_tuned_model'] ); |
| 63 | return $finetune; |
| 64 | }, $finetunes['data']); |
| 65 | |
| 66 | // Get option openai_finetunes_deleted |
| 67 | $deleted_finetunes = $this->core->get_option('openai_finetunes_deleted'); |
| 68 | |
| 69 | // Remove all deleted finetunes from the list, make a new array, without using array_filter |
| 70 | $finetunes['data'] = array_values(array_filter($finetunes['data'], function ($finetune) use ($deleted_finetunes) { |
| 71 | return !in_array($finetune['fine_tuned_model'], $deleted_finetunes); |
| 72 | })); |
| 73 | |
| 74 | $finetunes_option = $this->core->get_option('openai_finetunes'); |
| 75 | $fresh_finetunes_options = array_map(function ($finetune) use ($finetunes_option) { |
| 76 | $entry = []; |
| 77 | $model = $finetune['fine_tuned_model']; |
| 78 | $entry['suffix'] = $finetune['suffix']; |
| 79 | $entry['model'] = $model; |
| 80 | $entry['enabled'] = true; |
| 81 | for ($i = 0; $i < count($finetunes_option); $i++) { |
| 82 | if ($finetunes_option[$i]['model'] === $model) { |
| 83 | $entry['enabled'] = $finetunes_option[$i]['enabled']; |
| 84 | break; |
| 85 | } |
| 86 | } |
| 87 | return $entry; |
| 88 | }, $finetunes['data']); |
| 89 | $this->core->update_option('openai_finetunes', $fresh_finetunes_options); |
| 90 | return $finetunes; |
| 91 | } |
| 92 | |
| 93 | public function uploadFile( $filename, $data ) |
| 94 | { |
| 95 | $result = $this->run('POST', '/files', null, ['data' => $data, 'filename' => $filename]); |
| 96 | return $result; |
| 97 | } |
| 98 | |
| 99 | public function deleteFile( $fileId ) |
| 100 | { |
| 101 | return $this->run('DELETE', '/files/' . $fileId); |
| 102 | } |
| 103 | |
| 104 | public function getModel( $modelId ) |
| 105 | { |
| 106 | return $this->run('GET', '/models/' . $modelId); |
| 107 | } |
| 108 | |
| 109 | public function deleteFineTune( $modelId ) |
| 110 | { |
| 111 | return $this->run('DELETE', '/models/' . $modelId); |
| 112 | } |
| 113 | |
| 114 | public function downloadFile( $fileId ) |
| 115 | { |
| 116 | return $this->run('GET', '/files/' . $fileId . '/content', null, null, false); |
| 117 | } |
| 118 | |
| 119 | public function fineTuneFile($fileId, $model, $suffix) |
| 120 | { |
| 121 | $result = $this->run('POST', '/fine-tunes', [ |
| 122 | 'training_file' => $fileId, |
| 123 | 'model' => $model, |
| 124 | 'suffix' => $suffix |
| 125 | ]); |
| 126 | return $result; |
| 127 | } |
| 128 | |
| 129 | public function create_body_for_file($file, $boundary) |
| 130 | { |
| 131 | $fields = array( |
| 132 | 'purpose' => 'fine-tune', |
| 133 | 'file' => $file['filename'] |
| 134 | ); |
| 135 | |
| 136 | $body = ''; |
| 137 | foreach ($fields as $name => $value) { |
| 138 | $body .= "--$boundary\r\n"; |
| 139 | $body .= "Content-Disposition: form-data; name=\"$name\""; |
| 140 | if ($name == 'file') { |
| 141 | $body .= "; filename=\"{$value}\"\r\n"; |
| 142 | $body .= "Content-Type: application/json\r\n\r\n"; |
| 143 | $body .= $file['data'] . "\r\n"; |
| 144 | } else { |
| 145 | $body .= "\r\n\r\n$value\r\n"; |
| 146 | } |
| 147 | } |
| 148 | $body .= "--$boundary--\r\n"; |
| 149 | return $body; |
| 150 | } |
| 151 | |
| 152 | public function run($method, $url, $query = null, $file = null, $json = true) |
| 153 | { |
| 154 | $apiKey = $this->apiKey; |
| 155 | $headers = "Content-Type: application/json\r\n" . "Authorization: Bearer " . $apiKey . "\r\n"; |
| 156 | $body = $query ? json_encode($query) : null; |
| 157 | if (!empty($file)) { |
| 158 | $boundary = wp_generate_password(24, false); |
| 159 | $headers = [ |
| 160 | 'Content-Type' => 'multipart/form-data; boundary=' . $boundary, |
| 161 | 'Authorization' => 'Bearer ' . $this->apiKey, |
| 162 | ]; |
| 163 | $body = $this->create_body_for_file($file, $boundary); |
| 164 | } |
| 165 | |
| 166 | $url = 'https://api.openai.com/v1' . $url; |
| 167 | $options = [ |
| 168 | "headers" => $headers, |
| 169 | "method" => $method, |
| 170 | "timeout" => 120, |
| 171 | "body" => $body, |
| 172 | "sslverify" => false |
| 173 | ]; |
| 174 | |
| 175 | try { |
| 176 | $response = wp_remote_request($url, $options); |
| 177 | if (is_wp_error($response)) { |
| 178 | throw new Exception($response->get_error_message()); |
| 179 | } |
| 180 | $response = wp_remote_retrieve_body($response); |
| 181 | $data = $json ? json_decode($response, true) : $response; |
| 182 | |
| 183 | // Error handling |
| 184 | if (isset($data['error'])) { |
| 185 | $message = $data['error']['message']; |
| 186 | // If the message contains "Incorrect API key provided: THE_KEY.", replace the key by "----". |
| 187 | if (preg_match('/API key provided(: .*)\./', $message, $matches)) { |
| 188 | $message = str_replace($matches[1], '', $message); |
| 189 | } |
| 190 | throw new Exception($message); |
| 191 | } |
| 192 | |
| 193 | return $data; |
| 194 | } |
| 195 | catch (Exception $e) { |
| 196 | error_log($e->getMessage()); |
| 197 | throw new Exception('Error while calling OpenAI: ' . $e->getMessage()); |
| 198 | } |
| 199 | } |
| 200 | |
| 201 | private function calculatePrice( $model, $units, $option = null ) |
| 202 | { |
| 203 | foreach ( MWAI_OPENAI_PRICING as $price ) { |
| 204 | if ( $price['model'] == $model ) { |
| 205 | if ( $price['type'] == 'image' ) { |
| 206 | if ( !$option ) { |
| 207 | error_log( "AI Engine: Image models require an option." ); |
| 208 | return null; |
| 209 | } |
| 210 | else { |
| 211 | foreach ( $price['options'] as $imageType ) { |
| 212 | if ( $imageType['option'] == $option ) { |
| 213 | return $imageType['price'] * $units; |
| 214 | } |
| 215 | } |
| 216 | } |
| 217 | } |
| 218 | else { |
| 219 | return $price['price'] * $price['unit'] * $units; |
| 220 | } |
| 221 | } |
| 222 | } |
| 223 | error_log( "AI Engine: Invalid model ($model)." ); |
| 224 | return null; |
| 225 | } |
| 226 | |
| 227 | public function getPrice( Meow_MWAI_Query $query, Meow_MWAI_Answer $answer ) |
| 228 | { |
| 229 | $model = $query->model; |
| 230 | $modelBase = null; |
| 231 | $units = 0; |
| 232 | $option = null; |
| 233 | if ( is_a( $query, 'Meow_MWAI_QueryText' ) ) { |
| 234 | // Finetuned models |
| 235 | if ( preg_match('/^([a-zA-Z]{0,32}):/', $model, $matches ) ) { |
| 236 | $modelBase = "fn-" . $matches[1]; |
| 237 | } |
| 238 | // Standard models |
| 239 | else if ( preg_match('/^text-(\w+)-\d+/', $model, $matches ) ) { |
| 240 | $modelBase = $matches[1]; |
| 241 | } |
| 242 | if ( empty( $modelBase ) ) { |
| 243 | error_log("AI Engine: Cannot find the base model for $model."); |
| 244 | return null; |
| 245 | } |
| 246 | $units = $answer->getTotalTokens(); |
| 247 | } |
| 248 | else if ( is_a( $query, 'Meow_MWAI_QueryImage' ) ) { |
| 249 | $modelBase = 'dall-e'; |
| 250 | $units = $query->maxResults; |
| 251 | $option = "1024x1024"; |
| 252 | } |
| 253 | return $this->calculatePrice( $modelBase, $units, $option ); |
| 254 | } |
| 255 | |
| 256 | public function getIncidents() { |
| 257 | $url = 'https://status.openai.com/history.rss'; |
| 258 | $response = wp_remote_get( $url ); |
| 259 | if ( is_wp_error( $response ) ) { |
| 260 | throw new Exception( $response->get_error_message() ); |
| 261 | } |
| 262 | $response = wp_remote_retrieve_body( $response ); |
| 263 | $xml = simplexml_load_string( $response ); |
| 264 | $incidents = array(); |
| 265 | $oneWeekAgo = time() - 7 * 24 * 60 * 60; |
| 266 | foreach ( $xml->channel->item as $item ) { |
| 267 | $date = strtotime( $item->pubDate ); |
| 268 | if ( $date > $oneWeekAgo ) { |
| 269 | $incidents[] = array( |
| 270 | 'title' => (string) $item->title, |
| 271 | 'description' => (string) $item->description, |
| 272 | 'date' => $date |
| 273 | ); |
| 274 | } |
| 275 | } |
| 276 | return $incidents; |
| 277 | } |
| 278 | } |
| 279 |