RTC-512 Add Room.State module and peer disconnected timeout (#178)

* Add Room.State module

* WiP

* OpenApi changes

* Fix test

* Update type

* Fix type of peer

* Send RoomDeleted after peerlessPurge

* Fix tests

* Update lib/jellyfish_web/api_spec/room.ex

Co-authored-by: Przemysław Rożnawski <48837433+roznawsk@users.noreply.github.com>

* Move Event.broadcast_server_notification to State module and telemetry.execute

* Update openapi spec

* Add logs in peer_socket.ex

* Add peer_id metadata in logger

---------

Co-authored-by: Przemysław Rożnawski <48837433+roznawsk@users.noreply.github.com>

Author: Rados13

.gitignore

@@ -1,3 +1,4 @@
+.lexical/*
 compile_commands.json
 .gdb_history
 bundlex.sh

config/config.exs

@@ -17,7 +17,7 @@ config :membrane_telemetry_metrics, enabled: true
 
 config :logger, :console,
   format: "$time $metadata[$level] $message\n",
-  metadata: [:request_id, :room_id]
+  metadata: [:request_id, :room_id, :peer_id]
 
 config :logger_json, :backend,
   metadata: [:request_id, :room_id],

lib/jellyfish/peer.ex

@@ -13,7 +13,14 @@ defmodule Jellyfish.Peer do
     :type,
     :engine_endpoint
   ]
-  defstruct @enforce_keys ++ [status: :disconnected, socket_pid: nil, tracks: %{}, metadata: nil]
+  defstruct @enforce_keys ++
+              [
+                status: :disconnected,
+                socket_pid: nil,
+                tracks: %{},
+                metadata: nil,
+                last_time_connected: nil
+              ]
 
   @type id :: String.t()
   @type peer :: WebRTC
@@ -32,7 +39,8 @@ defmodule Jellyfish.Peer do
           socket_pid: pid() | nil,
           engine_endpoint: Membrane.ChildrenSpec.child_definition(),
           tracks: %{Track.id() => Track.t()},
-          metadata: any()
+          metadata: any(),
+          last_time_connected: integer() | nil
         }
 
   @spec parse_type(String.t()) :: {:ok, peer()} | {:error, :invalid_type}