1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
|
<?php
namespace App\Models;
use App\Database;
use Matrix\Enums\EventType;
use Matrix\Events\ClientEvent;
use Matrix\Events\StateEvent;
class RoomEvent
{
public function __construct(
private ClientEvent $event,
)
{}
/**
* @param array<string, mixed> $row
*/
public static function transformEvent(array $row): ClientEvent
{
return new ClientEvent(
content: json_decode($row["content"], true),
eventId: $row["id"],
originServerTimestamp: new \DateTime($row["origin_server_timestamp"])->getTimestamp(),
roomId: $row["room_id"],
sender: $row["sender"],
type: EventType::from($row["type"]),
unsigned: json_decode($row["unsigned"], true),
);
}
public function insert(): bool
{
if ($this->event instanceof StateEvent) {
return !! Database::getInstance()->query(<<<SQL
insert into room_events (id, content, type, sender, origin_server_timestamp, room_id, unsigned, state_key)
values (:id, :content, :type, :sender, to_timestamp(:origin_server_timestamp), :room_id, :unsigned, :state_key)
SQL, [
"id" => $this->event->getId(),
"content" => json_encode($this->event->getContent()),
"type" => $this->event->getType()->value,
"sender" => $this->event->getSender(),
"origin_server_timestamp" => \DateTime::createFromTimestamp($this->event->getOriginServerTimestamp())->format("U.v"),
"room_id" => $this->event->getRoomId(),
"unsigned" => json_encode($this->event->getUnsigned()),
"state_key" => $this->event->getStateKey(),
]);
}
return !! Database::getInstance()->query(<<<SQL
insert into room_events (id, content, type, sender, origin_server_timestamp, room_id, unsigned)
values (:id, :content, :type, :sender, to_timestamp(:origin_server_timestamp), :room_id, :unsigned)
SQL, [
"id" => $this->event->getId(),
"content" => json_encode($this->event->getContent()),
"type" => $this->event->getType()->value,
"sender" => $this->event->getSender(),
"origin_server_timestamp" => \DateTime::createFromTimestamp($this->event->getOriginServerTimestamp())->format("U.v"),
"room_id" => $this->event->getRoomId(),
"unsigned" => json_encode($this->event->getUnsigned()),
]);
}
}
|
