···

       
236
       
236
       
 
       
        preg_match('/at:\/\/(did:plc:[a-z0-9]+)\/app.bsky.feed.post\/([a-z0-9]+)/', $feed->post, $uriComponents);

     

       
237
       
237
       
 
       
        $did = $uriComponents[1];

     

       
238
       
238
       
 
       
        $rkey = $uriComponents[2];

     

       
239
       
239
       
-
       
        return async(fn() => $this->getPost($did, $rkey, true));

     

       
239
       
239
       
+
       
        return $this->getPost($did, $rkey, true);

     

       
240
       
240
       
 
       
      }, $body->feed)));

     

       
241
       
241
       
 
       
      

     

       
242
       
242
       
 
       
      return $res;

     
···

       
420
       
420
       
 
       
  }

     

       
421
       
421
       
 
       
  

     

       
422
       
422
       
 
       
  function getReplyRecords(string $post):array {

     

       
423
       
423
       
-
       
    $ret = $this->getConstellationLinkData($post, "app.bsky.feed.post", ".reply.root.uri");

     

       
423
       
423
       
+
       
    /*$ret = $this->getConstellationLinkData($post, "app.bsky.feed.post", ".reply.root.uri");

     

       
424
       
424
       
 
       
    if ($ret) {

     

       
425
       
425
       
-
       
      return await(all(array_map(function ($rec) {

     

       
426
       
426
       
-
       
        return async(fn() => $this->sanitizePost($this->getSlingshotData($rec->did, $rec->collection, $rec->rkey, ['reverse' => true]), true));

     

       
427
       
427
       
-
       
      }, $ret->linking_records)));

     

       
428
       
428
       
-
       
    }

     

       
425
       
425
       
+
       
      return array_map(function ($rec) {

     

       
426
       
426
       
+
       
        $slingshotRecord = $this->getSlingshotData($rec->did, $rec->collection, $rec->rkey, ['reverse' => true]);

     

       
427
       
427
       
+
       
        return $this->sanitizePost($slingshotRecord, true);

     

       
428
       
428
       
+
       
      }, $ret->linking_records);

     

       
429
       
429
       
+
       
    }*/

     

       
429
       
430
       
 
       
    return [];

     

       
430
       
431
       
 
       
  }

     

       
431
       
432
       
 
       
  

     
···

       
442
       
443
       
 
       
      $uriComponents = $this->splitAtUri($p->uri);

     

       
443
       
444
       
 
       
      $cache = \requestPostCache($uriComponents->rkey);

     

       
444
       
445
       
 
       
      if ($cache) return $this->sanitizeCachedPost($cache);

     

       
445
       
445
       
-
       
      return async(fn() => $this->getPost($uriComponents->did, $uriComponents->rkey, true));

     

       
446
       
446
       
+
       
      $post = $this->getPost($uriComponents->did, $uriComponents->rkey, true);

     

       
447
       
447
       
+
       
      return $post;

     

       
446
       
448
       
 
       
    }, $postData->records)));

     

       
447
       
449
       
 
       
    return $postData;

     

       
448
       
450
       
 
       
  }

     
···

       
542
       
544
       
 
       
    $rkey = $uriComponents[2];

     

       
543
       
545
       
 
       
    $authorInfo = $this->getUserInfo($did, 'did');

     

       
544
       
546
       
 
       
    $facets = property_exists($post->value, 'facets') ? $this->sanitizeFacets($post->value->facets) : [];

     

       
545
       
545
       
-
       
    $waitingFor = await(all([

     

       
546
       
546
       
-
       
      'authorInfo' => async(fn() => $this->getUserInfo($did, 'did')),

     

       
547
       
547
       
-
       
      'replyCount' => async(fn() => $this->getReplies($post->uri)),

     

       
548
       
548
       
-
       
      'repostCount' => async(fn() => $this->getReposts($post->uri)),

     

       
549
       
549
       
-
       
      'likeCount' => async(fn() => $this->getLikes($post->uri)),

     

       
550
       
550
       
-
       
      'quoteCount' => async(fn() => $this->getQuotes($post->uri))

     

       
551
       
551
       
-
       
    ]));

     

       
552
       
547
       
 
       
    $ret = (object) [

     

       
553
       
548
       
 
       
      'author' => (object) [

     

       
554
       
554
       
-
       
        'displayName' => $waitingFor['authorInfo']->displayName,

     

       
555
       
555
       
-
       
        'handle' => $waitingFor['authorInfo']->handle,

     

       
556
       
556
       
-
       
        'avatar' => $waitingFor['authorInfo']->avatar,

     

       
549
       
549
       
+
       
        'displayName' => $authorInfo->displayName,

     

       
550
       
550
       
+
       
        'handle' => $authorInfo->handle,

     

       
551
       
551
       
+
       
        'avatar' => $authorInfo->avatar,

     

       
557
       
552
       
 
       
        'did' => $did,

     

       
558
       
558
       
-
       
        'profileLink' => '/u/'.$waitingFor['authorInfo']->handle,

     

       
553
       
553
       
+
       
        'profileLink' => '/u/'.$authorInfo->handle,

     

       
559
       
554
       
 
       
      ],

     

       
560
       
555
       
 
       
      'uri' => $post->uri,

     

       
561
       
556
       
 
       
      'pds' => $authorInfo->pds,

     

       
562
       
557
       
 
       
      'postId' => $rkey,

     

       
563
       
558
       
 
       
      'postLink' => '/u/'.$authorInfo->handle.'/'.$rkey,

     

       
564
       
559
       
 
       
      'content' => property_exists($post->value, 'text') ? $this->applyFacets($post->value->text, $facets) : '',

     

       
565
       
565
       
-
       
      'replyCount' => $waitingFor['replyCount'],

     

       
566
       
566
       
-
       
      'repostCount' => $waitingFor['repostCount'],

     

       
567
       
567
       
-
       
      'likeCount' => $waitingFor['likeCount'],

     

       
568
       
568
       
-
       
      'quoteCount' => $waitingFor['quoteCount'],

     

       
560
       
560
       
+
       
      'replyCount' => $this->getReplies($post->uri),

     

       
561
       
561
       
+
       
      'repostCount' => $this->getReposts($post->uri),

     

       
562
       
562
       
+
       
      'likeCount' => $this->getLikes($post->uri),

     

       
563
       
563
       
+
       
      'quoteCount' => $this->getQuotes($post->uri),

     

       
569
       
564
       
 
       
      'createdAt' => $post->value->createdAt,

     

       
570
       
565
       
 
       
      'embedType' => property_exists($post->value, 'embed') ? $post->value->embed->{'$type'} : null,

     

       
571
       
566
       
 
       
      'embeds' => property_exists($post->value, 'embed') ? $this->sanitizeEmbeds($post->value->embed, $authorInfo) : [],