src/Entity/AiRequest.php line 17

  1. <?php
  3. namespace App\Entity;
  5. use ApiPlatform\Core\Annotation\ApiResource;
  6. use App\Repository\AiRequestRepository;
  7. use Doctrine\DBAL\Types\Types;
  8. use Doctrine\ORM\Mapping as ORM;
  9. use Symfony\Component\Serializer\Annotation\Groups;
  11. #[ORM\Entity(repositoryClass: AiRequestRepository::class)]
  12. #[ApiResource(
  13.     normalizationContext: ['groups' => ['read','thread_ai_request']],
  14.     denormalizationContext: ['groups' => ['write','thread_ai_request']],
  15.     
  16.     )]
  17. class AiRequest
  18. {
  20.     #[Groups(['read','thread_ai_request'])]
  21.     #[ORM\Id]
  22.     #[ORM\GeneratedValue]
  23.     #[ORM\Column]
  24.     private ?int $id = null;
  25.     #[Groups(['read','thread_ai_request', 'write'])]
  26.     #[ORM\Column(type: Types::TEXT, nullable: true)]
  27.     private ?string $question = null;
  28.     #[Groups(['read', 'write'])]
  29.     #[ORM\Column(type: Types::DATETIME_MUTABLE, nullable: true)]
  30.     private ?\DateTimeInterface $createdAt = null;
  31.     #[Groups(['read', 'write'])]
  32.     #[ORM\ManyToOne(inversedBy: 'aiRequests')]
  33.     private ?User $user = null;
  36.     #[Groups(['read','thread_ai_request', 'write'])]
  37.     #[ORM\Column(length: 255, nullable: true)]
  38.     private ?string $namespace = null;
  39.     #[Groups(['read','thread_ai_request', 'write'])]
  40.     #[ORM\Column(length: 255, nullable: true)]
  41.     private ?string $entity = null;
  43.     #[ORM\Column(nullable: true)]
  44.     private ?int $tokensUsed = null;
  46.     #[ORM\Column(nullable: true)]
  47.     private ?int $promptTokens = null;
  49.     #[ORM\Column(nullable: true)]
  50.     private ?int $completionTokens = null;
  52.     #[ORM\Column(length: 255, nullable: true)]
  53.     private ?string $requestId = null;
  55.     #[ORM\Column(nullable: true)]
  56.     private ?int $createdNumber = null;
  58.     #[ORM\Column(length: 255, nullable: true)]
  59.     private ?string $modelUsed = null;
  61.     #[ORM\Column(length: 255, nullable: true)]
  62.     private ?string $handledEntity = null;
  64.     #[ORM\Column(nullable: true)]
  65.     private ?int $handledEntityId = null;
  67.     #[Groups(['read', 'write'])]
  68.     #[ORM\ManyToOne(inversedBy: 'aiRequests',cascade:["persist"])]
  69.     private ?ThreadAiRequest $threadAiRequest = null;
  71.     #[ORM\Column(type: Types::TEXT, nullable: true)]
  72.     private ?string $jsonRequest = null;
  73.     
  74.     #[ORM\Column(type: Types::TEXT, nullable: true)]
  75.     private ?string $jsonResponse = null;
  76.     #[Groups(['read', 'write'])]
  77.     #[ORM\Column(length: 255, nullable: true)]
  78.     private ?string $status = null;
  79.     #[Groups(['read','thread_ai_request', 'write'])]
  80.     #[ORM\Column(length: 255, nullable: true)]
  81.     private ?string $action = null;
  85.     public function __toString()
  86.     {
  87.         $status = $this->status ? $this->status : 'none';
  88.         return (string)("#".$this->id."-".$this->question."(status:".$status.")");
  89.     }
  91.     public function getId(): ?int
  92.     {
  93.         return $this->id;
  94.     }
  96.     public function getQuestion(): ?string
  97.     {
  98.         return $this->question;
  99.     }
  101.     public function setQuestion(?string $question): static
  102.     {
  103.         $this->question = $question;
  105.         return $this;
  106.     }
  108.     public function getCreatedAt(): ?\DateTimeInterface
  109.     {
  110.         return $this->createdAt;
  111.     }
  113.     public function setCreatedAt(?\DateTimeInterface $createdAt): static
  114.     {
  115.         $this->createdAt = $createdAt;
  117.         return $this;
  118.     }
  120.     public function getUser(): ?User
  121.     {
  122.         return $this->user;
  123.     }
  125.     public function setUser(?User $user): static
  126.     {
  127.         $this->user = $user;
  129.         return $this;
  130.     }
  134.     public function getNamespace(): ?string
  135.     {
  136.         return $this->namespace;
  137.     }
  139.     public function setNamespace(?string $namespace): static
  140.     {
  141.         $this->namespace = $namespace;
  143.         return $this;
  144.     }
  146.     public function getEntity(): ?string
  147.     {
  148.         return $this->entity;
  149.     }
  151.     public function setEntity(?string $entity): static
  152.     {
  153.         $this->entity = $entity;
  155.         return $this;
  156.     }
  158.     public function getTokensUsed(): ?int
  159.     {
  160.         return $this->tokensUsed;
  161.     }
  163.     public function setTokensUsed(?int $tokensUsed): static
  164.     {
  165.         $this->tokensUsed = $tokensUsed;
  167.         return $this;
  168.     }
  170.     public function getPromptTokens(): ?int
  171.     {
  172.         return $this->promptTokens;
  173.     }
  175.     public function setPromptTokens(?int $promptTokens): static
  176.     {
  177.         $this->promptTokens = $promptTokens;
  179.         return $this;
  180.     }
  182.     public function getCompletionTokens(): ?int
  183.     {
  184.         return $this->completionTokens;
  185.     }
  187.     public function setCompletionTokens(?int $completionTokens): static
  188.     {
  189.         $this->completionTokens = $completionTokens;
  191.         return $this;
  192.     }
  194.     public function getRequestId(): ?string
  195.     {
  196.         return $this->requestId;
  197.     }
  199.     public function setRequestId(?string $requestId): static
  200.     {
  201.         $this->requestId = $requestId;
  203.         return $this;
  204.     }
  206.     public function getCreatedNumber(): ?int
  207.     {
  208.         return $this->createdNumber;
  209.     }
  211.     public function setCreatedNumber(?int $createdNumber): static
  212.     {
  213.         $this->createdNumber = $createdNumber;
  215.         return $this;
  216.     }
  218.     public function getModelUsed(): ?string
  219.     {
  220.         return $this->modelUsed;
  221.     }
  223.     public function setModelUsed(?string $modelUsed): static
  224.     {
  225.         $this->modelUsed = $modelUsed;
  227.         return $this;
  228.     }
  230.     public function getHandledEntity(): ?string
  231.     {
  232.         return $this->handledEntity;
  233.     }
  235.     public function setHandledEntity(?string $handledEntity): static
  236.     {
  237.         $this->handledEntity = $handledEntity;
  239.         return $this;
  240.     }
  242.     public function getHandledEntityId(): ?int
  243.     {
  244.         return $this->handledEntityId;
  245.     }
  247.     public function setHandledEntityId(?int $handledEntityId): static
  248.     {
  249.         $this->handledEntityId = $handledEntityId;
  251.         return $this;
  252.     }
  254.     public function getThreadAiRequest(): ?ThreadAiRequest
  255.     {
  256.         return $this->threadAiRequest;
  257.     }
  259.     public function setThreadAiRequest(?ThreadAiRequest $threadAiRequest): static
  260.     {
  261.         $this->threadAiRequest = $threadAiRequest;
  263.         return $this;
  264.     }
  267.     #[Groups(['read', 'write'])]
  268.     public function getAiResponse(){
  269.         $data = null;
  270.         if (!empty($this->getJsonResponse())){
  271.             
  272.                 
  273.                     $data = $this->getJsonResponse();
  274.               
  275.         }
  277.         return json_encode($data);
  278.     }
  282.     #[Groups(['read', 'write'])]
  283.     public function getFunctionCall(){
  284.         $data = "Nothing to generate";
  285.         if (!empty($this->getJsonResponse())){
  286.             
  287.             //dd($this->getJsonResponse());
  288.             if(!array_key_exists("choices",$this->getJsonResponse()) and !array_key_exists("candidates",$this->getJsonResponse())){
  289.                 return  ["text"=>$data];
  290.             } 
  294.             //Gemini Google AI
  295.             if(array_key_exists("candidates",$this->getJsonResponse())){
  296.                 foreach ($this->getJsonResponse()["candidates"] as $result) {
  297.                     //
  298.                     
  299.                     
  300.     
  301.                     if(array_key_exists("parts",$result["content"])){
  302.                         //dd($result);
  303.                             if($result["content"]["parts"][0]["text"]){
  304.                                 $data = $result["content"]["parts"][0]["text"];
  305.                                 return  ["text"=>$data];
  306.                             }
  307.     
  308.                             if($result["content"]["parts"][0]["functionCall"]){
  309.                                 $data = $result["content"]["parts"][0]["functionCall"];
  310.                                 return  ["text"=>$data];
  311.                             }
  312.                             
  313.                         
  314.                     }
  315.                    
  316.                     
  317.                         $data ="Nothing generated";
  318.                         return  ["text"=>$data];
  319.                         //break;
  320.                     
  321.     
  322.                     
  323.     
  324.     
  325.                 }
  326.             }
  327.             
  328.             if(array_key_exists("choices",$this->getJsonResponse())){
  329.                 foreach ($this->getJsonResponse()["choices"] as $result) {
  330.                     //
  331.                     
  332.     
  333.                     if(array_key_exists("functionCall",$result["message"])){
  334.                         //dd($result);
  335.                             if($result["message"]["functionCall"]){
  336.                                 $data = $result["message"]["functionCall"]["arguments"];
  337.                                 return  json_decode($this->convertToUTF8($data),true);
  338.                             }
  339.                             
  340.                         
  341.                     }
  342.                    
  343.                     if(array_key_exists("content",$result["message"])){
  344.                         //dd($result);
  345.                         if($result["message"]["content"]){
  346.                             
  347.                             $data = $result["message"]["content"];
  348.                             return  json_decode($this->convertToUTF8($data),true);
  349.                             
  350.                         }
  351.                         
  352.                     }
  353.                     // if(array_key_exists("toolCalls",$result["message"])){
  354.                     //     //dd($result);
  355.                         
  356.                     //         $data = $result["message"]["toolCalls"][0]["function"]["arguments"];
  357.                     //         return  $data;
  358.                     //         //break;
  359.                         
  360.                     // }
  361.                     
  362.                     $data ="Nothing generated";
  363.                     return  ["text"=>$data];
  364.                         //break;
  365.                     
  366.     
  367.                     
  368.     
  369.                     // $result->index; // 0
  370.                     // $result->message->role; // 'assistant'
  371.                     // $result->message->content; // null
  372.                     // $result->message->toolCalls[0]->id; // 'call_123'
  373.                     // $result->message->toolCalls[0]->type; // 'function'
  374.                     // $result->message->toolCalls[0]->function->name; // 'get_current_weather'
  375.                     // $result->finishReason; // 'tool_calls'
  376.                 }
  377.             }
  378.              
  379.               
  380.         }
  382.         return ["text"=>$data];
  383.     }
  386.     public function getFunctionCallToPrecise(){
  387.         $data = "Nothing to generate";
  388.         if (!empty($this->getJsonResponse())){
  389.             
  390.             //dd($this->getJsonResponse());
  391.             if(!array_key_exists("choices",$this->getJsonResponse()) and !array_key_exists("candidates",$this->getJsonResponse())){
  392.                 return  ["text"=>$data];
  393.             } 
  397.             //Gemini Google AI
  398.             if(array_key_exists("candidates",$this->getJsonResponse())){
  399.                 foreach ($this->getJsonResponse()["candidates"] as $result) {
  400.                     //
  401.                     
  402.                     
  403.     
  404.                     if(array_key_exists("parts",$result["content"])){
  405.                         //dd($result);
  406.                             if($result["content"]["parts"][0]["text"]){
  407.                                 $data = $result["content"]["parts"][0]["text"];
  408.                                 return  ["text"=>$data];
  409.                             }
  410.     
  411.                             if($result["content"]["parts"][0]["functionCall"]){
  412.                                 $data = $result["content"]["parts"][0]["functionCall"];
  413.                                 return  ["functionCall"=>$data];
  414.                             }
  415.                             
  416.                         
  417.                     }
  418.                    
  419.                     
  420.                         $data ="Nothing generated";
  421.                         return  ["text"=>$data];
  422.                         //break;
  423.                     
  424.     
  425.                     
  426.     
  427.     
  428.                 }
  429.             }
  430.             
  431.             if(array_key_exists("choices",$this->getJsonResponse())){
  432.                 foreach ($this->getJsonResponse()["choices"] as $result) {
  433.                     //
  434.                     
  435.     
  436.                     if(array_key_exists("functionCall",$result["message"])){
  437.                         //dd($result);
  438.                             if($result["message"]["functionCall"]){
  439.                                 $data = $result["message"]["functionCall"]["arguments"];
  440.                                 return  $data;
  441.                             }
  442.                             
  443.                         
  444.                     }
  445.                    
  446.                     if(array_key_exists("content",$result["message"])){
  447.                         //dd($result);
  448.                         if($result["message"]["content"]){
  449.                             
  450.                             $data = $result["message"]["content"];
  451.                             return  $data;
  452.                             
  453.                         }
  454.                         
  455.                     }
  457.                     
  458.                     $data ="Nothing generated";
  459.                     return  ["text"=>$data];
  461.                 }
  462.             }
  463.              
  464.               
  465.         }
  467.         return ["text"=>$data];
  468.     }
  470.     #[Groups(['read', 'write'])]
  471.     public function getFunctionName(){
  472.         $data = null;
  473.         // if (!empty($this->getJsonResponse())){
  474.             
  476.         //     if(!array_key_exists("choices",$this->getJsonResponse())){
  477.         //         return null;
  478.         //     }   
  480.         //      foreach ($this->getJsonResponse()["choices"] as $result) {
  483.                 
  485.         //         $data = $result["message"]["toolCalls"][0]["function"]["name"]; // "{\n  \"location\": \"Boston, MA\"\n}"
  487.         //         // $result->index; // 0
  488.         //         // $result->message->role; // 'assistant'
  489.         //         // $result->message->content; // null
  490.         //         // $result->message->toolCalls[0]->id; // 'call_123'
  491.         //         // $result->message->toolCalls[0]->type; // 'function'
  492.         //         // $result->message->toolCalls[0]->function->name; // 'get_current_weather'
  493.         //         // $result->finishReason; // 'tool_calls'
  494.         //     }
  495.               
  496.         // }
  498.         return $data;
  499.     }
  501.     #[Groups(['read', 'write'])]
  502.     public function getToolCallId(){
  503.         $data = null;
  504.         // if (!empty($this->getJsonResponse())){
  505.             
  507.         //     if(!array_key_exists("choices",$this->getJsonResponse())){
  508.         //         return null;
  509.         //     }   
  511.         //      foreach ($this->getJsonResponse()["choices"] as $result) {
  513.         //         if(isset($result["message"]["content"])){
  514.         //             $data = $result["message"]["content"];
  515.         //         }else{
  516.         //             $data = $result["message"]["toolCalls"][0]["id"];
  517.         //         }
  520.         //          // "{\n  \"location\": \"Boston, MA\"\n}"
  522.         //         // $result->index; // 0
  523.         //         // $result->message->role; // 'assistant'
  524.         //         // $result->message->content; // null
  525.         //         // $result->message->toolCalls[0]->id; // 'call_123'
  526.         //         // $result->message->toolCalls[0]->type; // 'function'
  527.         //         // $result->message->toolCalls[0]->function->name; // 'get_current_weather'
  528.         //         // $result->finishReason; // 'tool_calls'
  529.         //     }
  530.               
  531.         // }
  533.         return $data;
  534.     }
  537.     #[Groups(['read', 'write'])]
  538.     public function getFunctionCallEscaped(){
  539.         //$data = $this->convertToUTF8((string)$this->getFunctionCall());
  540.         $data = $this->getFunctionCall();
  541.         return $data;
  542.     }
  547.    
  551.     public function getJsonRequest(): ?string
  552.     {
  553.         return $this->jsonRequest;
  554.     }
  556.     public function setJsonRequest(?string $jsonRequest): static
  557.     {
  558.         $this->jsonRequest = $jsonRequest;
  560.         return $this;
  561.     }
  563.     public function getJsonResponse(): ?array
  564.     {
  565.         return json_decode($this->jsonResponse,true);
  566.     }
  568.     public function setJsonResponse(?string $jsonResponse): static
  569.     {
  570.         $this->jsonResponse = $jsonResponse;
  572.         return $this;
  573.     }
  575.     public function getStatus(): ?string
  576.     {
  577.         return $this->status;
  578.     }
  579.     public function setStatus(?string $status): static
  580.     {
  581.         $this->status = $status;
  583.         return $this;
  584.     }
  586.     public function getExecuteFunctionCall()
  587.     {
  588.         return "executeFunctionCall";
  589.     }
  591.     public function getAction(): ?string
  592.     {
  593.         return $this->action;
  594.     }
  596.     public function setAction(?string $action): static
  597.     {
  598.         $this->action = $action;
  600.         return $this;
  601.     }
  603.     function convertToUTF8($input) {
  604.         if (is_array($input)) {
  605.             foreach ($input as $key => $value) {
  606.                 $input[$key] = $this->convertToUTF8($value);
  607.             }
  608.         } elseif (is_string($input)) {
  609.             return mb_convert_encoding($input, 'UTF-8', 'UTF-8');
  610.         }
  611.         return $input;
  612.     }
  613. }