Trigger event when message created

Author: ksidibe

composer.json

@@ -7,7 +7,7 @@
     "html2text/html2text": "^4.3",
     "illuminate/support": "^8.81",
     "illuminate/database": "^8.81",
-    "spatie/laravel-query-builder": "^4.0"
+    "spatie/laravel-query-builder": "^4.0.2"
   },
 
   "license": "MIT",

src/Contracts/Models/IMessage.php

@@ -17,9 +17,11 @@
  * @property string|null $body_plain_text
  * @property string|null $from_type
  * @property string|null $from_id
- * @property string|null $created_at
- * @property string|null $updated_at
- * @property string|null $deleted_at
+ * @property \Carbon\Carbon|null $created_at
+ * @property \Carbon\Carbon|null $updated_at
+ * @property \Carbon\Carbon|null $deleted_at
+ *
+ * @property \Illuminate\Database\Eloquent\Model $from
  */
 interface IMessage
 {

src/Contracts/Models/IParticipant.php

@@ -8,6 +8,11 @@
  * @author Kolado Sidibe <ksidibe@yahoo.com>
  * @copyright 2022 Andale Technologies, SARL.
  * @license MIT
+ *
+ * @property string $nano_id
+ * @property \Illuminate\Database\Eloquent\Model $thread
+ * @property \Illuminate\Database\Eloquent\Model $message
+ * @property \Illuminate\Database\Eloquent\Model $participant
  */
 interface IParticipant
 {

src/Events/MessageCreated.php

@@ -0,0 +1,25 @@
+<?php
+
+namespace Andaletech\Inbox\Events;
+
+use Illuminate\Queue\SerializesModels;
+use Illuminate\Foundation\Events\Dispatchable;
+use Andaletech\Inbox\Contracts\Models\IMessage;
+use Illuminate\Broadcasting\InteractsWithSockets;
+
+class MessageCreated
+{
+  use Dispatchable, InteractsWithSockets, SerializesModels;
+
+  public $message;
+
+  /**
+   * Create a new event instance.
+   *
+   * @return void
+   */
+  public function __construct(IMessage $message)
+  {
+    $this->message = $message;
+  }
+}

src/Models/Participant.php

@@ -62,6 +62,11 @@ public function __construct(array $attributes = [])
   protected static function boot()
   {
     parent::boot();
+    static::creating(function ($participant) {
+      if (empty($participant->nano_id)) {
+        $participant->nano_id = Utils::getNanoId();
+      }
+    });
   }
 
   #region relationships

src/Traits/HasInbox.php

@@ -4,10 +4,10 @@
 
 use Html2Text\Html2Text;
 use Illuminate\Database\Eloquent\Model;
+use Andaletech\Inbox\Events\MessageCreated;
 use Illuminate\Database\Eloquent\Collection;
 use Psr\Container\NotFoundExceptionInterface;
 use Psr\Container\ContainerExceptionInterface;
-// use Andaletech\Inbox\Http\Contract\Models\IHasInbox;
 use Andaletech\Inbox\Contracts\Models\IHasInbox;
 use Illuminate\Database\Eloquent\Relations\Relation;
 use Illuminate\Contracts\Container\BindingResolutionException;
@@ -18,12 +18,6 @@
  */
 trait HasInbox
 {
-  // protected static $inboxThreadsTable;
-
-  // protected static $inboxMessagesTable;
-
-  // protected static $inboxParticipantsTable;
-
   /**
    * @var bool
    */
@@ -71,67 +65,23 @@ trait HasInbox
    */
   public function threads()
   {
-    // $threadClass = config('andale-inbox.eloquent.models.thread');
-
-    // return $threadClass::whereIn(
-    //   'id',
-    // );
     /**
      * @var \Illuminate\Database\Eloquent\Model $this
      */
     $query = $this->belongsToMany(
       config('andale-inbox.eloquent.models.thread'),
       config('andale-inbox.tables.participants'),
-      // config('andale-inbox.eloquent.models.participant'),
       'participant_id',
       'thread_id'
     )->where('participant_type', get_class($this))->distinct();
 
-    // return $this->addMultitenancyColumnIfNeeded($query);
     if ($this->isMultitenant()) {
       $query = $query->withPivot([config('andale-inbox.tenancy.tenant_id_column', 'tenant_id')]);
     }
 
     return $query;
-    // return $this->belongsToMany();
-    return $this->morphedByMany(
-      config('andale-inbox.eloquent.models.thread'),
-      'participantxxx',
-      config('andale-inbox.eloquent.models.participant'),
-      'xxxxxx'
-    );
-
-    return $this->hasMany(config('andale-inbox.eloquent.models.thread'));
-    // $query = $this->morphMany(config('andale-inbox.eloquent.models.thread'), 'owner');
-    // if ($this->isMultitenant()) {
-    //   $query = $query->with([config('andale-inbox.tenancy.tenant_id_column', 'tenant_id')]);
-    // }
-
-    // return $query;
   }
 
-  // public function threadX()
-  // {
-  //   return
-  // }
-
-  // /**
-  //  *
-  //  * @return \Illuminate\Database\Eloquent\Relations\MorphMany
-  //  * @throws BindingResolutionException
-  //  * @throws NotFoundExceptionInterface
-  //  * @throws ContainerExceptionInterface
-  //  */
-  // public function threadsXXXX()
-  // {
-  //   $query = $this->morphMany(config('andale-inbox.eloquent.models.thread'), 'owner');
-  //   if ($this->isMultitenant()) {
-  //     $query = $query->with([config('andale-inbox.tenancy.tenant_id_column', 'tenant_id')]);
-  //   }
-
-  //   return $query;
-  // }
-
   public function messages()
   {
     $query = $this->morphMany(config('andale-inbox.eloquent.models.message'), 'from');
@@ -254,6 +204,7 @@ protected function createInboxMessage($thread, $sendingUser = null)
     }
     $thread->messages()->save($message);
     $message->addParticipants([$this, ...$this->inboxNewMessageRecipients]);
+    event(new MessageCreated($message));
 
     return $message;
   }

src/database/migrations/2021_12_25_104649_create_inbox_participants_table.php

@@ -15,6 +15,7 @@ public function up()
   {
     Schema::create(config('andale-inbox.tables.participants', 'inbox_participants'), function (Blueprint $table) {
       $table->bigIncrements('id');
+      $table->string('nano_id')->index();
       $table->unsignedBigInteger('thread_id');
       $table->unsignedBigInteger('message_id');
       $table->morphs('participant');