FetchNodeinfoPipeline.php 1.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556
  1. <?php
  2. namespace App\Jobs\InstancePipeline;
  3. use Illuminate\Bus\Queueable;
  4. use Illuminate\Contracts\Queue\ShouldBeUnique;
  5. use Illuminate\Contracts\Queue\ShouldQueue;
  6. use Illuminate\Foundation\Bus\Dispatchable;
  7. use Illuminate\Queue\InteractsWithQueue;
  8. use Illuminate\Queue\SerializesModels;
  9. use Illuminate\Support\Facades\Http;
  10. use App\Instance;
  11. use App\Profile;
  12. use App\Services\NodeinfoService;
  13. class FetchNodeinfoPipeline implements ShouldQueue
  14. {
  15. use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
  16. protected $instance;
  17. /**
  18. * Create a new job instance.
  19. *
  20. * @return void
  21. */
  22. public function __construct(Instance $instance)
  23. {
  24. $this->instance = $instance;
  25. }
  26. /**
  27. * Execute the job.
  28. *
  29. * @return void
  30. */
  31. public function handle()
  32. {
  33. $instance = $this->instance;
  34. $ni = NodeinfoService::get($instance->domain);
  35. if($ni) {
  36. if(isset($ni['software']) && is_array($ni['software']) && isset($ni['software']['name'])) {
  37. $software = $ni['software']['name'];
  38. $instance->software = strtolower(strip_tags($software));
  39. $instance->last_crawled_at = now();
  40. $instance->user_count = Profile::whereDomain($instance->domain)->count();
  41. $instance->save();
  42. }
  43. } else {
  44. $instance->user_count = Profile::whereDomain($instance->domain)->count();
  45. $instance->last_crawled_at = now();
  46. $instance->save();
  47. }
  48. }
  49. }