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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
|
defmodule MatrixAppServiceWeb.V1.TransactionController do
@moduledoc """
Controller for transactions.
"""
use MatrixAppServiceWeb, :controller
# %{"access_token" => access_token,
# "events" => [
# %{"age" => 199,
# "content" => %{
# "body" => "test",
# "msgtype" => "m.room.message"},
# "event_id" => "$pMDN7TcsCapjLRYoITwryk0anpQGs60y2Eng3lxropc",
# "origin_server_ts" => 1588950428966,
# "room_id" => "!SrVtqmyqzuaMnfVImP:matrix.imago.local",
# "sender" => "@alice:matrix.imago.local",
# "type" => "m.room.message",
# "unsigned" => %{"age" => 199},
# "user_id" => "@alice:matrix.imago.local"}],
# "txn_id" => "269"}
defp create_event(
%{
"age" => age,
"content" => content,
"event_id" => event_id,
"origin_server_ts" => origin_server_ts,
"room_id" => room_id,
"sender" => sender,
"state_key" => state_key,
"type" => type,
"unsigned" => unsigned,
"user_id" => user_id
},
adapter
) do
event = %MatrixAppService.Event{
age: age,
content: content,
event_id: event_id,
origin_server_ts: origin_server_ts,
room_id: room_id,
sender: sender,
state_key: state_key,
type: type,
unsigned: unsigned,
user_id: user_id
}
adapter.new_event(event)
end
defp create_event(
%{
"age" => age,
"content" => content,
"event_id" => event_id,
"origin_server_ts" => origin_server_ts,
"room_id" => room_id,
"sender" => sender,
"type" => type,
"unsigned" => unsigned,
"user_id" => user_id
},
adapter
) do
event = %MatrixAppService.Event{
age: age,
content: content,
event_id: event_id,
origin_server_ts: origin_server_ts,
room_id: room_id,
sender: sender,
state_key: nil,
type: type,
unsigned: unsigned,
user_id: user_id
}
adapter.new_event(event)
end
@doc """
https://matrix.org/docs/spec/application_service/r0.1.2#put-matrix-app-v1-transactions-txnid
"""
def push(conn, %{"events" => events}) do
adapter =
conn.private[:transaction_adapter] ||
MatrixAppServiceWeb.Endpoint.config(:transaction_adapter) ||
raise "MatrixAppService: config key room_adapter missing"
Enum.each(events, &create_event(&1, adapter))
send_resp(conn, 200, "{}")
end
end
|
