Implement logout and logout/all endpoints

lib/matrix_server/account.ex

@@ -47,12 +47,11 @@ defmodule MatrixServer.Account do
     |> Multi.run(:device_with_access_token, &Device.insert_new_access_token/2)
   end
 
-  def get_by_access_token(access_token) do
-    from(a in Account,
-      join: d in assoc(a, :devices),
-      where: d.access_token == ^access_token,
-      preload: [devices: d]
-    )
+  def by_access_token(access_token) do
+    Device
+    |> where([d], d.access_token == ^access_token)
+    |> join(:inner, [d], a in assoc(d, :account))
+    |> select([d, a], {a, d})
     |> Repo.one()
   end
 

lib/matrix_server/device.ex

@@ -1,7 +1,9 @@
 defmodule MatrixServer.Device do
   use Ecto.Schema
-  import Ecto.Changeset
-  alias MatrixServer.{Account, Device}
+
+  import Ecto.{Changeset, Query}
+
+  alias MatrixServer.{Account, Device, Repo}
 
   @primary_key false
   schema "devices" do
@@ -45,4 +47,23 @@ defmodule MatrixServer.Device do
 
     "#{localpart}_#{time_string}"
   end
+
+  def login(account, device_id, access_token, params) do
+    update_query =
+      from(d in Device)
+      |> update(set: [access_token: ^access_token, device_id: ^device_id])
+
+    update_query =
+      if params[:display_name] != nil do
+        update(update_query, set: [display_name: ^params.display_name])
+      else
+        update_query
+      end
+
+    Ecto.build_assoc(account, :devices)
+    |> Map.put(:device_id, device_id)
+    |> Map.put(:access_token, access_token)
+    |> Device.changeset(params)
+    |> Repo.insert(on_conflict: update_query, conflict_target: [:localpart, :device_id])
+  end
 end