feat: add the database notification accessor

Author: papac

docker-compose.yml

@@ -15,15 +15,14 @@ networks:
 services:
     mysql:
         container_name: bowphp_mysql
-        image: mysql/mysql-server:8.0
+        image: mysql:8.3.0
         restart: unless-stopped
         ports:
             - "3306:3306"
         environment:
             MYSQL_DATABASE: test_db
             MYSQL_ROOT_PASSWORD: password
-            MYSQL_ROOT_HOST: "%"
-            MYSQL_ALLOW_EMPTY_PASSWORD: "no"
+            MYSQL_ALLOW_EMPTY_PASSWORD: "yes"
         command: --default-authentication-plugin=mysql_native_password
         volumes:
             - mysql_data:/var/lib/mysql

src/Database/Barry/Model.php

@@ -279,9 +279,9 @@ public static function latest(): ?Model
     /**
      * Get first rows
      *
-     * @return array|object
+     * @return array|object|null
      */
-    public static function first(): array|object
+    public static function first(): array|object|null
     {
         return static::query()->first();
     }
@@ -451,7 +451,6 @@ public static function create(array $data): Model
 
         // Override the olds model attributes
         $model->setAttributes($data);
-        $model->persist();
 
         return $model;
     }

src/Database/Notification/DatabaseNotification.php

@@ -0,0 +1,35 @@
+<?php
+
+namespace Bow\Database\Notification;
+
+use Bow\Database\Barry\Model;
+use Bow\Database\Database;
+
+class DatabaseNotification extends Model
+{
+    /**
+     * Cast data as json
+     *
+     * @var array|string[]
+     */
+    protected array $casts = [
+        'data' => 'array',
+    ];
+
+    public function __construct(array $attributes = [])
+    {
+        parent::__construct($attributes);
+
+        $this->table = config('notification.table') ?: 'notifications';
+    }
+
+    /**
+     * Mark notification as read
+     *
+     * @return bool|int
+     */
+    public function markAsRead(): bool|int
+    {
+        return $this->update(['read_at' => app_now()]);
+    }
+}

src/Database/Notification/WithNotification.php

@@ -0,0 +1,35 @@
+<?php
+
+namespace Bow\Database\Notification;
+
+use Bow\Database\Exception;
+use Bow\Database\Exception\ConnectionException;
+
+trait WithNotification
+{
+    /**
+     * @throws ConnectionException|Exception\QueryBuilderException
+     */
+    public function notifications()
+    {
+        return (new DatabaseNotification())
+            ->where('concern_id', $this->getKeyValue())
+            ->where('concern_type', get_class($this));
+    }
+
+    /**
+     * @throws ConnectionException|Exception\QueryBuilderException
+     */
+    public function markAsRead(string $notification_id)
+    {
+       return $this->notifications()->where('id', $notification_id)->update(['read_at' => app_now()]);
+    }
+
+    /**
+     * @throws ConnectionException|Exception\QueryBuilderException
+     */
+    public function markAllAsRead()
+    {
+        return $this->notifications()->update(['read_at' => app_now()]);
+    }
+}

src/Mail/Adapters/SmtpAdapter.php

@@ -151,7 +151,7 @@ public function send(Envelop $envelop): bool
 
         // SMTP command
         if ($envelop->getFrom() !== null) {
-            $this->write('MAIL FROM: <' . $envelop->getFrom() . '>', 250);
+            $this->write('MAIL FROM: ' . $envelop->getFrom(), 250);
         } elseif ($this->username !== null) {
             $this->write('MAIL FROM: <' . $this->username . '>', 250);
         }

src/Messaging/Adapters/DatabaseChannelAdapter.php

@@ -23,12 +23,12 @@ public function send(Model $context, Messaging $message): void
 
         $database = $message->toDatabase($context);
 
-        Database::table('notifications')->insert([
+        Database::table(config('messaging.notification.table') ?? 'notifications')->insert([
             'id' => str_uuid(),
             'data' => $database['data'],
             'concern_id' => $context->getKey(),
             'concern_type' => get_class($context),
-            'type' => $database['type'],
+            'type' => $database['type'] ?? 'notification',
         ]);
     }
 }

tests/Application/ApplicationTest.php

@@ -4,6 +4,7 @@
 
 use Bow\Application\Application;
 use Bow\Container\Capsule;
+use Bow\Http\Exception\BadRequestException;
 use Bow\Http\Request;
 use Bow\Http\Response;
 use Bow\Router\Exception\RouterException;
@@ -87,6 +88,11 @@ public function test_send_application_with_404_status()
         $app->send();
     }
 
+    /**
+     * @throws BadRequestException
+     * @throws \ReflectionException
+     * @throws RouterException
+     */
     public function test_send_application_with_matched_route()
     {
         $response = Mockery::mock(Response::class);

tests/Config/stubs/mail.php

@@ -5,7 +5,7 @@
     'charset' => 'utf8',
 
     'smtp' => [
-        'hostname' => 'localhost',
+        'hostname' => '192.168.1.3',
         'username' => 'test@test.dev',
         'password' => null,
         'port' => 1025,

tests/Database/Query/ModelQueryTest.php

@@ -147,6 +147,7 @@ public function test_insert_by_create_method(string $name)
         $next_id = PetModelStub::all()->count() + 1;
 
         $insert_result = PetModelStub::create(['name' => 'Tor']);
+        $insert_result->persist();
         $select_result = PetModelStub::retrieveBy('id', $next_id)->first();
 
         $this->assertInstanceOf(PetModelStub::class, $insert_result);