···

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

     

       
241
       
241
       
 
       
      

     

       
242
       
242
       
 
       
      return $res;

     

       
243
       
243
       
-
       
      

     

       
244
       
244
       
-
       
      /*return array_map(function($item) {

     

       
245
       
245
       
-
       
        return $item->json();

     

       
246
       
246
       
-
       
      }, $res);*/

     

       
247
       
243
       
 
       
    }));

     

       
248
       
244
       
 
       
    $body->feed = $ret;

     

       
249
       
249
       
-
       
    /*$body->feed = array_map(function ($feed) {

     

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

     

       
251
       
251
       
-
       
      $did = $uriComponents[1];

     

       
252
       
252
       
-
       
      $rkey = $uriComponents[2];

     

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

     

       
254
       
254
       
-
       
    }, $body->feed);*/

     

       
255
       
245
       
 
       
    return $body;

     

       
256
       
246
       
 
       
  }

     

       
257
       
247
       
 
       
  

     
···

       
430
       
420
       
 
       
  }

     

       
431
       
421
       
 
       
  

     

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

     

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

     

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

     

       
434
       
424
       
 
       
    if ($ret) {

     

       
435
       
435
       
-
       
      return array_map(function ($rec) {

     

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

     

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

     

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

     

       
439
       
439
       
-
       
    }*/

     

       
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
       
+
       
    }

     

       
440
       
429
       
 
       
    return [];

     

       
441
       
430
       
 
       
  }

     

       
442
       
431
       
 
       
  

     
···

       
449
       
438
       
 
       
      'cursor' => $cursor

     

       
450
       
439
       
 
       
    ]);

     

       
451
       
440
       
 
       
    if (!$postData) return false;

     

       
452
       
452
       
-
       
    $postData = array_map(function($p) {

     

       
441
       
441
       
+
       
    $postData = await(all(array_map(function($p) {

     

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

     

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

     

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

     

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

     

       
457
       
457
       
-
       
      return $post;

     

       
458
       
458
       
-
       
    }, $postData->records);

     

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

     

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

     

       
459
       
447
       
 
       
    return $postData;

     

       
460
       
448
       
 
       
  }

     

       
461
       
449
       
 
       
  

     
···

       
554
       
542
       
 
       
    $rkey = $uriComponents[2];

     

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

     

       
556
       
544
       
 
       
    $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
       
+
       
    ]));

     

       
557
       
552
       
 
       
    $ret = (object) [

     

       
558
       
553
       
 
       
      'author' => (object) [

     

       
559
       
559
       
-
       
        'displayName' => $authorInfo->displayName,

     

       
560
       
560
       
-
       
        'handle' => $authorInfo->handle,

     

       
561
       
561
       
-
       
        'avatar' => $authorInfo->avatar,

     

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

     

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

     

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

     

       
562
       
557
       
 
       
        'did' => $did,

     

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

     

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

     

       
564
       
559
       
 
       
      ],

     

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

     

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

     

       
567
       
562
       
 
       
      'postId' => $rkey,

     

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

     

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

     

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

     

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

     

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

     

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

     

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

     

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

     

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

     

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

     

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

     

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

     

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