src/Service/LinkedInApiService.php line 43

Open in your IDE?
  1. <?php
  2. // src/Service/LinkedInApiService.php
  4. namespace App\Service;
  6. use App\Repository\LinkedInTokenRepository;
  7. use GuzzleHttp\Client;
  8. use Symfony\Component\Security\Core\Security;
  10. class LinkedInApiService
  11. {
  12.     private Client $client;
  13.     private LinkedInTokenRepository $linkedInTokenRepository;
  14.     private Security $security;
  15.     private array $mimeTypes = [];
  17.     public function __construct(
  18.         LinkedInTokenRepository $linkedInTokenRepository,
  19.         Security $security
  20.     ) {
  21.         $this->client = new Client();
  22.         $this->linkedInTokenRepository = $linkedInTokenRepository;
  23.         $this->security = $security;
  24.     }
  26.     private function getAccessToken(string $_site)
  27.     {
  28.         $user = $this->security->getUser();
  30.         if (!$user) {
  31.             throw new \RuntimeException('User not logged in.');
  32.         }
  34.         $linkedInToken = $this->linkedInTokenRepository->findValidTokenByUser($user,$_site);
  36.         if (!$linkedInToken) {
  37.             throw new \RuntimeException('No valid LinkedIn token found for the user.');
  38.         }
  40.         return $linkedInToken;
  41.     }
  43.     public function publishPost(string $text, string $type, array $mediaUrls = [], string $_site): array
  44.     {
  45.         $accessToken = $this->getAccessToken($_site);
  46.         $uploadedMedia = $this->upload($type, $mediaUrls,$_site);
  47.     
  48.         // Construire les données du post
  49.         $postData = [
  50.             'author' => 'urn:li:organization:' . $accessToken->getLinkedInOrganizationId(),
  51.             'lifecycleState' => 'PUBLISHED',
  52.             'specificContent' => [
  53.                 'com.linkedin.ugc.ShareContent' => [
  54.                     'shareCommentary' => ['text' => $this->cleanHtmlForLinkedIn($text)],
  55.                     'shareMediaCategory' => $type,
  56.                     'media' => $uploadedMedia, // Utilisation des URNs retournés par upload
  57.                 ],
  58.             ],
  59.             'visibility' => ['com.linkedin.ugc.MemberNetworkVisibility' => 'PUBLIC'],
  60.         ];
  61.     
  62.         try {
  63.             $response = $this->client->post('https://api.linkedin.com/v2/ugcPosts', [
  64.                 'headers' => [
  65.                     'Authorization' => "Bearer {$accessToken->getToken()}",
  66.                     'Content-Type' => 'application/json',
  67.                     'X-Restli-Protocol-Version' => '2.0.0',
  68.                 ],
  69.                 'json' => $postData,
  70.             ]);
  71.     
  72.             $linkedInId = json_decode($response->getBody()->getContents(), true);
  73.             return  $linkedInId;
  74.         } catch (\GuzzleHttp\Exception\ClientException $e) {
  75.             return [
  76.                 'error' => true,
  77.                 'message' => $e->getResponse()->getBody()->getContents(),
  78.             ];
  79.         }
  80.     }
  82.     public function updatePost(string $existingLinkedInId, string $text, string $type, array $mediaUrls = [], string $_site): array
  83.     {
  84.         $this->deletePost($existingLinkedInId,$_site);
  85.         return $this->publishPost($text, $type, $mediaUrls, $_site);
  86.     }
  88.     public function deletePost(string $linkedInId, string $_site): bool
  89.     {
  90.         $accessToken = $this->getAccessToken($_site);
  91.         $urn = rawurlencode($linkedInId);
  92.         $url = "https://api.linkedin.com/rest/posts/{$urn}";
  93.         $response = $this->client->delete($url, [
  94.                 'headers' => [
  95.                 'Authorization' => "Bearer {$accessToken->getToken()}",
  96.                 'X-Restli-Protocol-Version' => '2.0.0',
  97.                 'LinkedIn-Version' => '202306',
  98.             ],
  99.         ]);
  101.         return $response->getStatusCode() === 204;
  102.     }
  105.     public function upload(string $type, array $mediaUrls = [], string $_site): array
  106.     {
  107.         $accessToken = $this->getAccessToken($_site);
  108.         $uploadedMedia = [];
  109.     
  110.         foreach ($mediaUrls as $mediaUrl) {
  111.             // Step 1: Check if the type is a document
  112.             // Handle other media types (images, videos) using the existing logic
  113.             $recipe = $this->getRecipeByMediaCategory($type);
  114.             $mimeType = mime_content_type($mediaUrl);
  116.             // Register upload for images/videos
  117.             $response = $this->client->request('POST', 'https://api.linkedin.com/v2/assets?action=registerUpload', [
  118.                 'headers' => [
  119.                     'Authorization' => "Bearer {$accessToken->getToken()}",
  120.                     'Content-Type' => 'application/json',
  121.                     'X-Restli-Protocol-Version' => '2.0.0',
  122.                 ],
  123.                 'json' => [
  124.                     'registerUploadRequest' => [
  125.                         'owner' => 'urn:li:organization:' . $accessToken->getLinkedInOrganizationId(),
  126.                         'recipes' => [$recipe],
  127.                         'serviceRelationships' => [
  128.                             [
  129.                                 'identifier' => 'urn:li:userGeneratedContent',
  130.                                 'relationshipType' => 'OWNER',
  131.                             ],
  132.                         ],
  133.                     ],
  134.                 ],
  135.             ]);
  137.             $data = json_decode($response->getBody()->getContents(), true);
  139.             if (!isset($data['value']['uploadMechanism']['com.linkedin.digitalmedia.uploading.MediaUploadHttpRequest']['uploadUrl'])) {
  140.                 throw new \RuntimeException('uploadUrl is missing in LinkedIn API response: ' . json_encode($data));
  141.             }
  143.             $uploadUrl = $data['value']['uploadMechanism']['com.linkedin.digitalmedia.uploading.MediaUploadHttpRequest']['uploadUrl'];
  144.             $asset = $data['value']['asset']; // URN of the media
  146.             // Upload the file
  147.             $this->client->request('PUT', $uploadUrl, [
  148.                 'headers' => [
  149.                     'Authorization' => "Bearer {$accessToken->getToken()}",
  150.                     'Content-Type' => $mimeType,
  151.                 ],
  152.                 'body' => file_get_contents($mediaUrl),
  153.             ]);
  155.             $uploadedMedia[] = [
  156.                 'status' => 'READY',
  157.                 'media' => $asset, // Use the asset URN
  158.             ];
  159.         }
  160.     
  161.         return $uploadedMedia;
  162.     }
  164.     private function getRecipeByMediaCategory(string $categoryType): string
  165.     {
  166.         switch ($categoryType) {
  167.             case 'IMAGE':
  168.                 return 'urn:li:digitalmediaRecipe:feedshare-image';
  169.             case 'VIDEO':
  170.                 return 'urn:li:digitalmediaRecipe:feedshare-video';
  171.             default:
  172.                 throw new \RuntimeException("Unsupported media type: $categoryType");
  173.         }
  174.     }
  176.     function cleanHtmlForLinkedIn(string $html): string
  177.     {
  178.         // 1. Remplacer les balises <p> par des doubles sauts de ligne
  179.         $html = preg_replace('#<p>(.*?)</p>#s', "$1\n\n", $html);
  181.         // 2. Remplacer les balises <br> par des sauts de ligne
  182.         $html = preg_replace('#<br\s*/?>#i', "\n", $html);
  184.         // 3. Remplacer les balises <ul> et <li> par des sauts de ligne avec tirets pour les listes
  185.         $html = preg_replace('#<b>(.*?)</b>#s', "$1", $html); // Supprimer <ul>
  187.         // 4. Remplacer les balises <ul> et <li> par des sauts de ligne avec tirets pour les listes
  188.         $html = preg_replace('#<i>(.*?)</i>#s', "$1", $html); // Supprimer <ul>
  190.         // 5. Remplacer les balises <ul> et <li> par des sauts de ligne avec tirets pour les listes
  191.         $html = preg_replace('#<ul>(.*?)</ul>#s', "$1", $html); // Supprimer <ul>
  192.         $html = preg_replace('#<li>(.*?)</li>#s', "- $1\n", $html); // Préfixer les <li> avec un tiret
  194.         // 6. Remplacer les balises <a> par leur texte avec l'URL entre parenthèses
  195.         $html = preg_replace_callback('#<a\s+href=["\'](.*?)["\'].*?>(.*?)</a>#s', function ($matches) {
  196.             return $matches[2] . ' (' . $matches[1] . ')';
  197.         }, $html);
  199.         // 7. Supprimer les balises spécifiques aux émojis <span class="ql-emojiblot">
  200.         $html = preg_replace('#<span\s+class=["\']ql-emojiblot["\'].*?>\s*<span[^>]*>(.*?)</span>\s*</span>#s', '$1', $html);
  201.         $html = preg_replace('#</span>#i', '', $html);
  203.         // 8. Supprimer les lignes vides multiples
  204.         $html = preg_replace("/\n{3,}/", "\n\n", trim($html)); 
  206.         return $html;
  207.     }
  208. }