FetchFederationInfo.php 4.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113
  1. <?php
  2. namespace App\Console\Commands;
  3. use Illuminate\Console\Command;
  4. use Zttp\Zttp;
  5. use App\Instance;
  6. use GuzzleHttp\Exception\RequestException;
  7. class FetchFederationInfo extends Command
  8. {
  9. /**
  10. * The name and signature of the console command.
  11. *
  12. * @var string
  13. */
  14. protected $signature = 'instance:federation';
  15. /**
  16. * The console command description.
  17. *
  18. * @var string
  19. */
  20. protected $description = 'Command description';
  21. /**
  22. * Create a new command instance.
  23. *
  24. * @return void
  25. */
  26. public function __construct()
  27. {
  28. parent::__construct();
  29. }
  30. /**
  31. * Execute the console command.
  32. *
  33. * @return mixed
  34. */
  35. public function handle()
  36. {
  37. $url = 'https://the-federation.info/graphql?query=query%20Platform(%24name%3A%20String!)%20%7B%0A%20%20platforms(name%3A%20%24name)%20%7B%0A%20%20%20%20name%0A%20%20%20%20code%0A%20%20%20%20displayName%0A%20%20%20%20description%0A%20%20%20%20tagline%0A%20%20%20%20website%0A%20%20%20%20icon%0A%20%20%20%20__typename%0A%20%20%7D%0A%20%20nodes(platform%3A%20%24name)%20%7B%0A%20%20%20%20id%0A%20%20%20%20name%0A%20%20%20%20version%0A%20%20%20%20openSignups%0A%20%20%20%20host%0A%20%20%20%20platform%20%7B%0A%20%20%20%20%20%20name%0A%20%20%20%20%20%20icon%0A%20%20%20%20%20%20__typename%0A%20%20%20%20%7D%0A%20%20%20%20countryCode%0A%20%20%20%20countryFlag%0A%20%20%20%20countryName%0A%20%20%20%20services%20%7B%0A%20%20%20%20%20%20name%0A%20%20%20%20%20%20__typename%0A%20%20%20%20%7D%0A%20%20%20%20__typename%0A%20%20%7D%0A%20%20statsGlobalToday(platform%3A%20%24name)%20%7B%0A%20%20%20%20usersTotal%0A%20%20%20%20usersHalfYear%0A%20%20%20%20usersMonthly%0A%20%20%20%20localPosts%0A%20%20%20%20localComments%0A%20%20%20%20__typename%0A%20%20%7D%0A%20%20statsNodes(platform%3A%20%24name)%20%7B%0A%20%20%20%20node%20%7B%0A%20%20%20%20%20%20id%0A%20%20%20%20%20%20__typename%0A%20%20%20%20%7D%0A%20%20%20%20usersTotal%0A%20%20%20%20usersHalfYear%0A%20%20%20%20usersMonthly%0A%20%20%20%20localPosts%0A%20%20%20%20localComments%0A%20%20%20%20__typename%0A%20%20%7D%0A%7D%0A&operationName=Platform&variables=%7B%22name%22%3A%22pixelfed%22%7D';
  38. $res = Zttp::timeout(60)->accept('application/json')->get($url);
  39. $b = $res->json();
  40. if(!$b) {
  41. return;
  42. }
  43. foreach($b['data']['nodes'] as $n) {
  44. $host = $n['host'];
  45. $this->info("checking {$host}");
  46. try {
  47. $online = Zttp::timeout(60)->get("https://{$host}/");
  48. } catch (\Zttp\ConnectionException $e) {
  49. $i = Instance::whereDomain($host)->first();
  50. if($i) {
  51. $i->approved_at = null;
  52. $i->save();
  53. }
  54. continue;
  55. } catch (\GuzzleHttp\Exception\RequestException $e) {
  56. $i = Instance::whereDomain($host)->first();
  57. if($i) {
  58. $i->approved_at = null;
  59. $i->save();
  60. }
  61. continue;
  62. }
  63. // if(Instance::whereDomain($host)->exists()) {
  64. // continue;
  65. // }
  66. try {
  67. $t = Zttp::withOptions(['http_errors' => 0, 'verify' => 0])->get("https://{$host}/api/nodeinfo/2.0.json");
  68. if($t->isOk()) {
  69. $body = $t->body();
  70. $json = $t->json();
  71. if(!isset($json['openRegistrations'])) {
  72. $i = Instance::whereDomain($host)->first();
  73. $i->approved_at = null;
  74. $i->save();
  75. continue;
  76. }
  77. if($json['openRegistrations'] == false) {
  78. $i = Instance::whereDomain($host)->first();
  79. if($i != null) {
  80. $i->approved_at = null;
  81. $i->save();
  82. }
  83. continue;
  84. }
  85. $i = Instance::firstOrCreate(['domain' => $host]);
  86. $i->name = $host;
  87. $i->nodeinfo = $body;
  88. $i->user_count = $json['usage']['users']['total'];
  89. $i->post_count = $json['usage']['localPosts'];
  90. $i->approved_at = now();
  91. $i->save();
  92. $this->call('instance:fetch', ['domain' => $host]);
  93. $this->info($host);
  94. }
  95. } catch (RequestException $e) {
  96. continue;
  97. }
  98. }
  99. return;
  100. }
  101. }