StatusEntityLexer.php 2.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118
  1. <?php
  2. namespace App\Jobs\StatusPipeline;
  3. use App\Hashtag;
  4. use App\Jobs\MentionPipeline\MentionPipeline;
  5. use App\Mention;
  6. use App\Profile;
  7. use App\Status;
  8. use App\StatusHashtag;
  9. use App\Util\Lexer\Autolink;
  10. use App\Util\Lexer\Extractor;
  11. use DB;
  12. use Illuminate\Bus\Queueable;
  13. use Illuminate\Contracts\Queue\ShouldQueue;
  14. use Illuminate\Foundation\Bus\Dispatchable;
  15. use Illuminate\Queue\InteractsWithQueue;
  16. use Illuminate\Queue\SerializesModels;
  17. class StatusEntityLexer implements ShouldQueue
  18. {
  19. use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
  20. protected $status;
  21. protected $entities;
  22. protected $autolink;
  23. /**
  24. * Create a new job instance.
  25. *
  26. * @return void
  27. */
  28. public function __construct(Status $status)
  29. {
  30. $this->status = $status;
  31. }
  32. /**
  33. * Execute the job.
  34. *
  35. * @return void
  36. */
  37. public function handle()
  38. {
  39. $status = $this->status;
  40. $this->parseEntities();
  41. }
  42. public function parseEntities()
  43. {
  44. $this->extractEntities();
  45. }
  46. public function extractEntities()
  47. {
  48. $this->entities = Extractor::create()->extract($this->status->caption);
  49. $this->autolinkStatus();
  50. }
  51. public function autolinkStatus()
  52. {
  53. $this->autolink = Autolink::create()->autolink($this->status->caption);
  54. $this->storeEntities();
  55. }
  56. public function storeEntities()
  57. {
  58. $this->storeHashtags();
  59. $this->storeMentions();
  60. DB::transaction(function () {
  61. $status = $this->status;
  62. $status->rendered = nl2br($this->autolink);
  63. $status->entities = json_encode($this->entities);
  64. $status->save();
  65. });
  66. }
  67. public function storeHashtags()
  68. {
  69. $tags = array_unique($this->entities['hashtags']);
  70. $status = $this->status;
  71. foreach ($tags as $tag) {
  72. DB::transaction(function () use ($status, $tag) {
  73. $slug = str_slug($tag);
  74. $hashtag = Hashtag::firstOrCreate(
  75. ['name' => $tag, 'slug' => $slug]
  76. );
  77. StatusHashtag::firstOrCreate(
  78. ['status_id' => $status->id, 'hashtag_id' => $hashtag->id]
  79. );
  80. });
  81. }
  82. }
  83. public function storeMentions()
  84. {
  85. $mentions = array_unique($this->entities['mentions']);
  86. $status = $this->status;
  87. foreach ($mentions as $mention) {
  88. $mentioned = Profile::whereUsername($mention)->firstOrFail();
  89. if (empty($mentioned) || !isset($mentioned->id)) {
  90. continue;
  91. }
  92. DB::transaction(function () use ($status, $mentioned) {
  93. $m = new Mention();
  94. $m->status_id = $status->id;
  95. $m->profile_id = $mentioned->id;
  96. $m->save();
  97. MentionPipeline::dispatch($status, $m);
  98. });
  99. }
  100. }
  101. }