Refactor thread to accept topic tag

Author: sertxudev

app/Jobs/PostToThreadsJob.php

@@ -42,7 +42,9 @@ public function handle(Threads $threads): void
     {
         $user = User::query()->where('threads_user_id', '9093830107340733')->firstOrFail();
 
-        $threads->writePost($user, $this->post->toThreads());
+        $threadData = $this->post->toThreads();
+
+        $threads->writePost($user, $threadData['content'], $threadData['topic_tag']);
 
         $this->post->updateQuietly(['posted_on_threads' => true]);
     }

app/Models/Concerns/Threadable.php

@@ -4,22 +4,33 @@
 
 namespace App\Models\Concerns;
 
-use Spatie\Tags\Tag;
-
 trait Threadable
 {
     abstract public function threadsUrl(): string;
 
-    public function toThreads(): string
+    public function toThreads(): array
     {
-        $tags = $this->tags
-            ->map(fn (Tag $tag) => $tag->name)
-            ->map(fn (string $tagName) => '#'.str_replace(' ', '', $tagName))
-            ->implode(' ');
+        $primaryTag = null;
+        $primaryTagForContent = '';
+
+        if ($this->tags->isNotEmpty()) {
+            $firstName = $this->tags->first()->name;
+            $primaryTag = str_replace([' ', '.', '&', '@', '!', '?', ',', ';', ':'], '', $firstName);
+            if ($primaryTag === '') {
+                $primaryTag = null;
+            } else {
+                $primaryTagForContent = '#'.$primaryTag;
+            }
+        }
 
-        return '🔗 '.$this->title
+        $content = '🔗 '.$this->title
             .PHP_EOL."\n"
             .PHP_EOL.$this->threadsUrl()
-            .PHP_EOL.$tags;
+            .($primaryTagForContent ? PHP_EOL.$primaryTagForContent : '');
+
+        return [
+            'content' => $content,
+            'topic_tag' => $primaryTag,
+        ];
     }
 }

app/Services/Threads/Threads.php

@@ -83,13 +83,19 @@ public function refreshToken(User $user): void
     /**
      * Write a post to Threads.
      */
-    public function writePost(User $user, string $content): void
+    public function writePost(User $user, string $content, ?string $topicTag = null): void
     {
-        $response = Http::post("{$this->base_url}/v1.0/{$user->threads_user_id}/threads", [
+        $payload = [
             'media_type' => 'TEXT', // TEXT, IMAGE, VIDEO
             'text' => $content,
             'access_token' => $user->threads_access_token,
-        ]);
+        ];
+
+        if ($topicTag !== null) {
+            $payload['topic_tag'] = $topicTag;
+        }
+
+        $response = Http::post("{$this->base_url}/v1.0/{$user->threads_user_id}/threads", $payload);
 
         if ($response->failed()) {
             abort(403, 'Failed to write post to Threads.');

tests/Feature/Concerns/ThreadableTest.php

@@ -15,12 +15,14 @@
 
     $thread = $post->toThreads();
 
-    expect($thread)->toContain('🔗 Building a Laravel Package')
+    expect($thread['content'])->toContain('🔗 Building a Laravel Package')
         ->toContain(route('posts.show', [$post, 'utm_source' => 'threads', 'utm_medium' => 'post']))
         ->toContain('#Laravel');
+
+    expect($thread['topic_tag'])->toBe('Laravel');
 });
 
-it('formats a thread with multiple tags', function () {
+it('formats a thread with multiple tags - only primary in content', function () {
     $post = Post::factory()->create([
         'title' => 'Testing with Pest',
     ]);
@@ -31,8 +33,10 @@
 
     $thread = $post->toThreads();
 
-    expect($thread)->toContain('#PHP')
-        ->toContain('#Testing');
+    expect($thread['content'])->toContain('#PHP')
+        ->not->toContain('#Testing');
+
+    expect($thread['topic_tag'])->toBe('PHP');
 });
 
 it('formats a thread with tags containing spaces', function () {
@@ -45,7 +49,9 @@
 
     $thread = $post->toThreads();
 
-    expect($thread)->toContain('#VueJS');
+    expect($thread['content'])->toContain('#VueJS');
+
+    expect($thread['topic_tag'])->toBe('VueJS');
 });
 
 it('formats a thread without tags', function () {
@@ -55,6 +61,8 @@
 
     $thread = $post->toThreads();
 
-    expect($thread)->toContain('🔗 Hello World')
+    expect($thread['content'])->toContain('🔗 Hello World')
         ->not->toContain('#');
+
+    expect($thread['topic_tag'])->toBeNull();
 });

tests/Feature/Jobs/PostToThreadsJobTest.php

@@ -34,6 +34,7 @@
     $job = new PostToThreadsJob($post);
     $job->handle(app(Threads::class));
 
+    Http::assertSentCount(2);
     expect((bool) $post->refresh()->posted_on_threads)->toBeTrue();
 });