sending messages creates message event in database

1 files changed, 86 insertions, 0 deletions

diff --git a/src/Events/RoomMessageEvent.php b/src/Events/RoomMessageEvent.php
new file mode 100644
index 0000000..3ccc408
--- /dev/null
+++ b/src/Events/RoomMessageEvent.php
@@ -0,0 +1,86 @@
+<?php
+
+namespace App\Events;
+
+use App\Database;
+use App\Support\ConnectsToDatabase;
+use App\Types\EventType;
+use App\Types\MembershipState;
+use App\Types\MessageType;
+
+class RoomMessageEvent extends Event implements ConnectsToDatabase
+{
+  public function __construct(
+    private string $id = "",
+    private string $sender = "",
+    private \DateTime $originServerTimestamp = new \DateTime("now"),
+    private array $content = [],
+    private array $unsigned = [],
+    private string $roomId = "",
+  )
+  {
+    parent::__construct(EventType::ROOM_MESSAGE);
+  }
+
+  public function fromJson(string $json): self
+  {
+  }
+
+  public function toJsonEncodeable(): array
+  {
+    return [
+      "type" => $this->type,
+      "sender" => $this->sender,
+      "event_id" => $this->id,
+      "origin_server_ts" => $this->originServerTimestamp->format("U.v"),
+      "content" => [
+        "body" => $this->body,
+        "msgtype" => MessageType::TEXT,
+      ],
+      "unsigned" => [
+        "age" => 1234,
+        "membership" => MembershipState::JOIN,
+      ],
+      "room_id" => $this->roomId,
+    ];
+  }
+
+  public static function fromDatabase(array $row): self
+  {
+  }
+
+  public static function fetch(): ?self
+  {
+  }
+
+  public static function fetchAll(): array
+  {
+  }
+
+  public function insert(): bool
+  {
+    return !! Database::getInstance()->query(
+      <<<SQL
+        insert into room_events (id, type, sender, origin_server_timestamp, content, unsigned, room_id)
+        values (:id, :type, :sender, to_timestamp(:origin_server_timestamp), :content, :unsigned, :room_id)
+      SQL,
+      [
+        "id" => $this->id,
+        "type" => $this->type->value,
+        "sender" => $this->sender,
+        "origin_server_timestamp" => (new \DateTime("now"))->format("U.v"),
+        "content" => json_encode($this->content),
+        "unsigned" => json_encode($this->unsigned),
+        "room_id" => $this->roomId,
+      ]
+    );
+  }
+
+  public function update(): bool
+  {
+  }
+
+  public function delete(): bool
+  {
+  }
+}