<?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
  {
  }
}