Yama's Memorandum

<?php
class Bluesky
{
    public $jwt;
    public $handle;

    public function __construct($handle, $password)
    {
        $this->handle = $handle;
        $this->jwt = $this->getJwt($handle, $password);
        // parent::__construct();
    }

    private function getJwt($handle, $password)
    {
        $ch = curl_init("https://bsky.social/xrpc/com.atproto.server.createSession");
        curl_setopt_array($ch, [
            CURLOPT_CONNECTTIMEOUT => 10,
            CURLOPT_SSL_VERIFYPEER => false,
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_POST => true,
            CURLOPT_HTTPHEADER => ["Content-Type: application/json"],
            CURLOPT_POSTFIELDS => json_encode([
                "identifier" => $handle,
                "password" => $password,
            ]),
        ]);
        $response = curl_exec($ch);
        curl_close($ch);

        $responseJson = json_decode($response, true);
        if (isset($responseJson["accessJwt"])) {
            return $responseJson["accessJwt"];
        } else {
            throw new \Exception("Failed to obtain JWT: " . $response);
        }
    }

    public function post_mod($text, $imagePath = null, $link = null)
    {
        $imageUri = $imagePath ? $this->uploadImage($imagePath) : null;

        $record = [
            "\$type" => "app.bsky.feed.post",
            "text" => $text,
            //"createdAt" => Carbon::now()->format('c'),
            "createdAt" => (new DateTime())->format("c"),
        ];

        if ($imageUri) {
            $record['embed'] = [
                '$type' => 'app.bsky.embed.images',
                'images' => [
                    [
                        'image' => $imageUri,
                        'alt' => 'Image description'
                    ]
                ]
            ];
        }
        if ($link) {
            $n_link = count($link);
            $facets = [];

            //create facets
            for($i=0; $i < $n_link; $i++) {
              $linkStart = $link[$i][2];
              $linkEnd   = $link[$i][3];

              $facets[] = [
                 'index' => [
                     'byteStart' => $linkStart,
                     'byteEnd'   => $linkEnd
                 ],
                 'features' => [
                    [
                       '$type' => 'app.bsky.richtext.facet#link',
                       'uri' => $link[$i][0]
                    ]
                ]
             ];
           }

           if(!empty($facets)) {
             $record['facets'] = $facets;
           }
        }

        $ch = curl_init("https://bsky.social/xrpc/com.atproto.repo.createRecord");
        curl_setopt_array($ch, [
            CURLOPT_CONNECTTIMEOUT => 10,
            CURLOPT_SSL_VERIFYPEER => false,
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_POST => true,
            CURLOPT_HTTPHEADER => [
                "Content-Type: application/json",
                "Authorization: Bearer {$this->jwt}",
            ],
            CURLOPT_POSTFIELDS => json_encode([
                "repo" => $this->handle,
                "collection" => "app.bsky.feed.post",
                "record" => $record,
            ]),
        ]);

        $response = curl_exec($ch);
        curl_close($ch);

        return json_decode($response, true);
    }

    private function uploadImage($imagePath)
    {
        $imageData = file_get_contents($imagePath);
        $mime = mime_content_type($imagePath);

        $ch = curl_init("https://bsky.social/xrpc/com.atproto.repo.uploadBlob");
        curl_setopt_array($ch, [
            CURLOPT_CONNECTTIMEOUT => 10,
            CURLOPT_SSL_VERIFYPEER => false,
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_POST => true,
            CURLOPT_HTTPHEADER => [
                "Content-Type: $mime",
                "Authorization: Bearer {$this->jwt}",
            ],
            CURLOPT_POSTFIELDS => $imageData,
        ]);

        $response = curl_exec($ch);
        $httpcode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        curl_close($ch);

        if ($httpcode == 200) {
            $responseJson = json_decode($response, true);
            return $responseJson['blob'] ?? null;
        } else {
            throw new \Exception("Failed to upload image: HTTP $httpcode - $response");
        }
    }
}