mongodb connection added, logs added, gitignore changed

This commit is contained in:
C
2022-11-17 19:33:17 +05:00
parent ee8d167322
commit c3dedbc530
27 changed files with 319365 additions and 20 deletions
+44
View File
@@ -0,0 +1,44 @@
Задача координирующего сервера создать сессию для клиента или связать клиента с сессией, запланировать сессию,
координирующий сервер знает все активные сессии и список серверов сессий с помощью файла конфига servers.json (обновляет раз в N секунд)
и постоянного соединения с серверами:
1) имеет 2 файла конфига servers.json и configuration.json
a) "servers.json" содержит список серверов "массив верхнего уровня": и их название, адрес, описание вида
{
"server_name1":"SomeName1",
"ip":"0.0.0.0", "port":"111",
"info":{
"deskription":[
{"en":"best RC and ..."},
{"ru":"луший ЖК и"}
]}
}
b) "configuration.json" содержит конфигурацию координатора
{"ip":"0.0.0.2", "port":"333", "time_between_updates_seconds":"30"}
2) Подключаемся к координатору с помощью websocket и SSL,
a) при подключении к координатору пользователь получает уникальный id
{"verb":"GET_TITLES", "range":"X-Y"} (range это сервера с X до Y, например с 0-20 или 20-213, количество серверов = Y - X + 1)
a) в случае успеха получаем {"msg":"SERVERS_FOUND", "servers":"{данные из примера "1)a)" }"}
b) в случае неудачи получаем {"msg":"SERVERS_NOT_FOUND"}
3) Пользователь планирует сессию с помощью запроса {"verb":"PLAN_SESSION", "rc_name":"SomeRC", "date":"day/month/year", "time":"00:00"}
a) в браузере доступен выбор только того времени которое не занято
b) координатор сохраняет сессию в список запланированных сессий, файл формата JSON, sessions_planned.json
и выдаёт четырёхзначный код с помощью которого можно будет подключиться к сессии в назначенное время {"msg":"CONNECTION_CODE", "code":"1234"}
4) Если пользователь хочет создать сессию без планирования то посылает запрос {"verb":"CREATE_SESSION", "rc_name":"SomeRC"},
координатор создаёт сессию на свободном сервере и возвращает {"verb":"CONNECT_TO_SESSION", "ip":"0.0.0.1", "port":"1111", "code":"1234"},
если все сервера заняты вернёт {"msg":"SERVERS_BUSY"}, когда координатор получает запрос "CREATE_SESSION":
a) координатор проверяет список планирования чтобы убедиться что на данное время нет активных записей, затем свободному серверу сессий
отправляет запрос на создание сессии {"verb":"CREATE_SESSION", "rc_name":"SomeRC", "user_id":"id123"},
если создать сессию можно, сервер сессий вернёт {"verb":"CONNECT_TO_SESSION", "ip":"0.0.0.1", "port":"1111", "code":"1234"}
b) когда клиент получил данные для подключения к сессии он устанавливает соединение с сервером сессий с помощью сокета
и разрывает соединение с координатором (может быть не стоит разрывать соединение с координатором)
5) Если пользователь хочет подключиться к сессии с помощью кода то посылает запрос
{"verb":"CONNECT_SESSION_WITH_CODE", "code":"1234"},
в ответ придёт {"verb":"CONNECT_TO_SESSION", "ip":"0.0.0.1", "port":"1111", "code":"1234"}, или
если сессии не существует {"msg":"SESSION_NOT_EXIST"}.
@@ -0,0 +1 @@
<mxfile host="app.diagrams.net" modified="2022-11-10T11:53:12.473Z" agent="5.0 (Windows)" etag="u12ahK_K-zGX4WXDl2lk" version="20.5.3"><diagram id="9KEa8YBS_3Qo23Otxjfd" name="Page-1">7Rxdc5s48Nf4oQ/OIIkP8ZjYbu9u2mnvejO9PnWIkW1aYnwYN879+hMgYUkIR3YA40w7UwKLtIbd1X6LEZo87N+lwWb1IQlJPIJWuB+h6QhCiKFL/+SQJwZxbFBClmkUljDrAPgc/UdKIODQXRSSLYOVoCxJ4izayMB5sl6TeSbBgjRNHuVhiyQOJcAmWBLpMXLA53kQk9qwL1GYrUoodoTRv5FoueK/DCx25yHggxlguwrC5FEAodkITdIkycqzh/2ExDn1ZLq8bbhbPVhK1pnJhDVa/PEu+vJtPwuePv754dH6/eN+bEO/xPMziHfslUfQjSnGuzD6SU+X+eloao3ubotjeY6Lo1Mcp6MpGOEcCeBT6VOIs8v3z544UdNktw5J/lyA3n5cRRn5vAnm+d1HKkcUtsoeYnabPR9JM7JvfHVQEZSKIkkeSJY+0SFsgm+XM5gQjm3AAI8HlgKISthKYKfLeBcwKVpWqA+EpieM1ifQ3XFxjSokpJLHLpM0WyXLZB3EswP07kA3i1593z1s2IKh7353mPI+STaMeN9Jlj2xQcEuS2TSkn2U/ZNju3HY1VfhznTPfqi4eOIXa/r+wqT88qt47zCtuOLzFsk6Yw8CnIqt+TsfZyolUbJL5+SYECPGpixIlyQ7NtJvEJSUxEEW/ZSfpXWuVw8qrjazpQUvvoig65msIqvHVWQj0KL2QgPVXrZtDY3wDtCYjZyOnJo5Za3i+LYUXmtM/zNAfpwVR1tmDZ06K46ezCCBZQzJbXFCRwI+sjyvIJgd2fj85Au5/+vviW5iOQbKEHpER3hvPc/7RRTHkyRO0mIuCh2CQ5vCt1ma/CDCHQzvkeu2Iy1j6AJFXHy3Ji62C+vigtyuxAVq9N6r8zLqlAeW41/a0ais6LU5Gi06CA6Ehg6CA+1LOgjVg16jgzDG2Ej8ezVUfLG9ag8BOwMkvH1Mkmf8WFlfW6D7lPsPlS/BR9ZUWRxHmy0Zqi1WV4QPDT033B1fHC1f/MIt82+1mmT7GD3EwdqAzC0QLbcREtE8B9eJ5qMbz6nTDSDcGeE8M01i4Fsa+a4+bNI29R91Cq1F/byCh5S+E+b4chAaOVM+8T5VUbWpzpSFtlgQdz7XLbTQ8+8ty1Rmjglzoygh9wZ7vvBPliwHXFpJco9bkilVxa3D2zyRSa/mcbDdRnOZ4Ed9tXOzNdxh4y5az+6abeyueXoBEFjqaDjKYcZeHfuFT0lEX+ag3wFSVJVtyzjKd2XToJCcVTAhJbfi+QqikhQ1RIXYVe/9EknUaDfZLNTjiF7NQj260tsFr1ejgAzT560Zhcbg9wyjAF+nUUANOoEvNaw4GHY9PdKzGbDxwM2ANXAzUC7Di5kB6Kouqw/PswNjCBRU2FZQdW0JbOOKoA+EPK/Hzo3VU47AFhBMhWC71JjO2cppuwo2+en8KY7oqkjR8yrqvlw/7+8rQDD/sSxW1cddRtEQBt/WilgvsmvAVhiuixHdXkNER5etbaDwIiZ7ppfutCpqS+U1a0NzSXrroMaaNFd+9YmkEaUJSY94tYeUpF6hnZs46FsF2s+rwKo3QXKOrHaUYJXWrhQXPNMXhiomX8XUtQrkgWH39hicZY0vlUVHpsLYlEXvxx77qkYFSmHLVBLrutlVMHUuibA3z/CqJNG04ePCkjgGntJ6hH0FibFnCKCCyrcVVJ0LY3MtJe/ukaTS/XeX8Bvj0mUqkgjOZl+6cey+FCLruwfoW+q7B7AQHps3BBxxKcu3eDbgvZ7SPwBePUfSc+3f0RQcxHDACuJouZaEJiaLrC4i4M2o6v54rlJ3YqeJJQgNFETn7UjqN6mXr4wLV6ydxDA4gm8afu/UcllFiGrirKHX5a1EAjZRCfDKdxAf4EjoZknPplxK/KvYIDf5HGoXpmRDb+pTrRqJHB3zmhgPdXpF2y+Un387qa5zclhLVUMm6xlZn6yTIhkrKh8G4musWFnoLlcz0TyIbxn4IQrDuCmPKys+fR/ni/QWUtMnPq5XZlzueklaq7sYuO9qX2XlNGnbWs520iAwrRYfTR6nrCsqYtpDL6qlFtZ1LZG8htJTR/e1NloJyeG8VVBKswCrApySaOmy2Zs70AbN3g2FgJ6avX1dFqFLFfKrNHR2LzvkldzL9bLzLt2h6A9RgVg3/vEsaX6hKoFWF/1Ll3JD2R2pScueM41uvcX8upkuVhqlUuPYurGo1R6aMfGMjUlDfr0vY1L3R/l+BlV+qpbIqgoWJ7vweU3chV4FvEHiYg2PjHFGHcBinIyFGLWMFV0501CLV9mAW1O7Wc/knpRi6oJddj3u6rkVwms94a2qj9eQAK+27Z6/47GfBDhwXMXR4u0FJ1cFLRWTr2Dq2lZ7uvR3L6J5TVXCak/m0EXTthTfD2IFh6lo2o6CCSEFU+ei2bDZosqAV5lhMVHuCkasSslS+ERO55ahpXWkQoNG7e/vNKrlWDK2QyKWZaxP3fT5IoM8jJoPAF7Nhvdc8fGeqfi8it2eyjcl9JsJet3p6Q0sgXBOAnIon5RwvI4SDlD2uG3e4NGbpdD3+V/FBlM1XBnABh5P17n92raXqh+gGADduas2FF03pGSpU363ovNkaZWT6kt3YU28ddVMv65kqYON+z/xZb+igOuRetvJUtXZDwheaMtW7hyT+0U3BtDme0Mut50cayLPX9lVLbccbkYvaDZ1kVk/2dUbKPv2wnWLiSytTmxTB/LY1kAHNljhyyRe7XN74Gs6p++IBbe+R95cZjF+FTKLr0Nm1YwsUqvxxrvpcVcySy8PX2wthx8+fItm/wM=</diagram></mxfile>
+1
View File
@@ -0,0 +1 @@
<mxfile host="app.diagrams.net" modified="2022-11-10T11:14:36.992Z" agent="5.0 (Windows)" etag="ogUHD7H2IEVB4My0YNP6" version="20.5.3"><diagram id="9KEa8YBS_3Qo23Otxjfd" name="Page-1">7Vxfc6M2EP80POZGEgijx8ROru3cTa5NZ9J76mCj2Nxh48E4tvvpK5BkJMAY2xhw2pkMgxZpEavd3/6RFcMczrefI3c5+xp6NDAQ8LaGOTIQgg5CRvIHvJ2gQMfmlGnke5wGMsKL/w8VHSV17Xt0JWicFIdhEPtLnTgJFws6iTWaG0XhRu/2FgaeRli6U6pNIyG8TNyAFrq9+l4841QHK71/of50Jt8MgXgyd2VnQVjNXC/cKCTz0TCHURjG/G6+HdIgkZ4ul6cDT/cTi+girjNgYb799tl//Xv76O6ef/+6Ab8+b+8sRDifdzdYi082kB0wjg+e/85up8mtMQLGw3165fdOesXpdWSMoOEkTKAcymahjubfH++kUKNwvfBoMi/IHm9mfkxflu4kebphesRos3geiMdifjSK6fbgp8O9QJkq0nBO42jHuogBxOIjhBLeQSiUcJMtKUQmp82U5bTF2rlCi6Z71pmg2Y2Q9Slyt2BBKtRjmieaYRTPwmm4cIPHjPqQyQ2w1o/1fCkMhn37QzbkSxguhfB+0DjeiU7uOg510dKtH/+VcPuEReu78mS0FS9KGzvR4NNO5lq9GOzTwnU0oVVCMIV4Yzea0riyJypf4IgGbuy/63NpfrXkRFUrqWcSqHPlR/agjvaDNrXfhA2ijtlT1LEs0D/BoypFfpRXJlmQ3luK3EfpFQi5qz0LSBYEzD/T41J+84NgGAZhlI4zPUwdz2L0VRyFP6nyxEFj07avYxCQ1FsV52qrMhiUrgp5Sq/3pTCy2vjzwF3UEHIDIjMdXWRIqrYiMwtbzI0UpGZC60piw8C8UR/KpB7t+CCLDCThe0oAxJGEbHDa0kZ/o5HPxEij+m65WveOe2untrd2uvXWTom3LvMuDLug9Ch7xEMaBYFCN6hQODCSQw6o+E6cOjJic8NmEhimr8hIpoFHcuA4yrNq0sPlsPftjdqTSRn2egMyBqAukFRp2UF8sfUAXTY785MY2P2CFhVbwCeCq+GFNfL4oEAOtqEGOX2FG1Qbbsxu4aYYU73S8R9/DiviotXMXSbESRCuvYZceBOWB63OgyHHrIfeDHifFNx2lDyBx7G2ni0o+QOHXNHhvjZ6wwaAGfRosVnI1jHOWo71wXC2DWC0L4Q7MfRb6LMpZTE+zqVFgxwLDsRiVG7h99O4RBfsG8ZRRKAuvbq5/hWzStIj24KaYR2xKyU90pOjfeDSt1ilfmrUiPHeR5G7UzosE6NcVdi2STTtFAXxTL04w4btuaSq0YojP+aeq2qynfrnPIgg2HUiZDm4RyDSdCJ0ShrUmmOvhSIH9KitjKds0zCvJQvvPtl/TZ2zu1r5E31NK3Xk3EUq8zYtbmfVz1hB+fopdo5LzFzSLo30LKTHKoToLPinFiK9IiOSY2TlGF07ZCTl+3JK4by4zdpq4fwOAl1EPamc9yztqm2uKjAAs8vgUKrecViQTv04LJBu6+ZyordYN0cfs25ODjiK3tbNP3K4qIUid+ATAHZfIad2JMIzwe4gp9e189Osrwe1c/lDt/9r59de7B7UzslH26NsAxgvTZx7WjsnxVrb7eBoD2vnxOmRbd1i7fwq6VEjxnsTtXNSVmH7b9fOTwSR7mvnWB4F6QWI3GTt/FTHXgtFyIUocqFSFDOeopZ0WTsHipb0sXZODlRc26mdS42UoQrOcahbOoe5wwEQtBsxYlB7d5ZA+cN/dh2I+9qVu4SBpTAYKac3eC0Rn50a7iPYXeAzg4jM4w5ozE3ny3hPcCc/p6lBPa9jxoYK+opbFMR1vVb1RsDeGRw+dGC3GeFiWLJ1cki+bwHdCkB6KMWmFdPWuAnI0kNWfAyyykLWc6Lmc8+htIx9wmgrsW9/AFVVoz3xQvSzBo6uxVKNT4U/nGfU7sYhhmVbHVfxwqf91rrrA5m1c7FDBzLb8cIW1tEUDc5Uwxwq38lDwK3pYVnB9jrR4C3poTyV3nc9hI6edGJ0nh4iM5e8NqSFrJn9gwHePfs/Debjvw==</diagram></mxfile>
+62
View File
@@ -0,0 +1,62 @@
CHECKOUT_DATABASE:
how dbs - show all dbs
se some_name_db - set current db
how collections - all collections of current db
b.stats() - stats of DB
b.users.stats() - some stats
ADD_DATA:
nsertOne() - insert document to collection
nsertMany()
EXAMPLE:
db.collection_name.insertOne({"name":"Tom", "age": 28, languages: ["english":"spanish"]})
db.collection_name.insertMany([{"name": "Bob", "age": 26, languages: ["english", "french"]},
{"name": "Alice", "age": 31, languages:["german", "english"]}])
WITH_FILE: example.js AND CONTENT
db.users.insertMany([
{"name": "Alice", "age": 31, languages: ["english", "french"]},
{"name": "Lene", "age": 29, languages: ["english", "spanish"]},
{"name": "Kate", "age": 30, languages: ["german", "russian"]}
])
load("example.js") - this command will load previous example in db
DOCUMENT_FILTER:
b.collection_name.find() - show all documents in colleciton
EXAMPLES:
db.collection_name.find({name: "Tom"}) - find documents with names
db.collection_name.find({name: "Tom", age: 32}) - find documents with name and age
db.collection_name.find({name: "Tom", languages: null}) - find documents with name Tom and languages undefined
db.collection_name.find({languages: ["english", "german"]}) - find documents with language english and german
db.collection_name.find({"languages.0": "english"}) - find documents with language english on first place and english
db.collection_name.find({name: "Tom"}, {age: 1}) - find only with name Tom and return only age
db.collection_name.find({name: "Tom"}, {age: 0}) - find only with name Tom and return everything but not age
db.collection_name.find({name: "Tom"}, {age: true, _id: false}) - find with name tom and return with age but not id
db.collection_name.find({}, {age: 1, _id: 0}) - find everything and show no id and only age
db.collection_name.insertOne({"name": "Alex", "age": 28, company: {"name":"Microsoft", "country":"USA"}})
db.collection_name.find({"company.name": "Microsoft"})
SORT_AND_PAGINATION:
db.users.find().limit(3) - get only 3
db.users.find().skip(3) - get all but skip first 3
db.users.find().skip(3).limit(3) - skip 3 and get next 3
SORT:
db.users.find().sort({name: 1}) - sort (1 up) (-1 down)
SLICE: its combination of limit+skip (have two forms) slice(limit) slice(limit, skip)
db.users.insertOne({"name": "Tom", "age": 32, languages: ["english", "german", "spanish"]})
db.users.find ({name: "Tom"}, {languages: {$slice : 1}})
db.users.find ({name: "Tom"}, {languages: {$slice : -1}})
db.users.find ({name: "Tom"}, {languages: {$slice : [-2, 1]}})
COLLECTION_CHANGES:
db.createCollection("accounts")
db.users.renameCollection("new_name")
db.createCollection("profiles", {capped:true, size:9500})
db.createCollection("profiles", {capped:true, size:9500, max: 150})
+37
View File
@@ -0,0 +1,37 @@
Задача стримингового сервера создавать сессии по запросу координатора, поддерживать соединение с клиентами в рамках сессии,
запускать приложение_ЖК и WebRTC сервер в рамках одной сессии, упраление пользователями (присвоение управления и т.д.),
завершение сессии, приложения_ЖК и WebRTC сервера.
1) Сервер сессий имеет файл config.json в котором содержатся данные о (ip, port, допустимое количество сессий и данные для работы WebRTC).
2) Координирующий сервер знает лимит сервера сессий и присылает запрос на создание сесии {"verb":"CREATE_SESSION", "user_id":"id123"},
запускает приложение_ЖК и WebRTC сервер, затем отправляет ответ координатору
{"verb":"CONNECT_TO_SESSION", "ip":"0.0.0.1", "port":"1111", "code":"1234"}
3) Затем координатор подключает пользователя к серверу сессий с помощью сокета ("ip":"0.0.0.1", "port":"1111") и присылает запрос
{"verb":"CONNECT_USER_TO_SESSION", "code":"1234", "user_id":"id123"}, после чего сервер сессий отправляет 2 запроса
первый запрос координатору который говорит о том что пользователь подключился
{"msg":"SESSION_CONNECTION_ESTABLISHED", "WebRTC_connection_data":"https://ip:port"} (список данных дополнится),
после чего пользователь подключается к стриму (процесс подключения дополнится)
4) Во время соединения пользователи могут обмениваться данными внутри сессии (список данных дополнится)
5) Если все пользователи отключились от сессии то закрывается приложение ЖК, сервер WebRTC и уничтожается сессия
Архитектура программы в порядке взаимодействия с клиентом:
сессия (класс):
публичные:
конструктор(максимальное_количетсво_пользователей,
обьект_логов(записать),
обьект_приложения(запустить, завершить),
обьект_WebRTC_сервера(запустить,завершить)
):
обьект_приложения.запустить()
обьект_WebRTC_сервера.запустить()
функции:
~деструктор:
обьект_приложения.завершить()
обьект_WebRTC_сервера.завершить()
ПОДУМАТЬ_НАД_ОБЬЕКТОМ.сообщить_серверу_сессий_что_сессия_завершилась()
Binary file not shown.
File diff suppressed because it is too large Load Diff
Binary file not shown.
File diff suppressed because it is too large Load Diff
+9
View File
@@ -0,0 +1,9 @@
прототип (3 дня):
1. координатор
1.1 клиент получает список доступных сессий с помощью запроса http
1.2 клиент делает запрос на подключение к сессии координатору
1.3 координатор запускает сессию на сервере сессий и подключает клиента к сессии
2. сервер сессий
2.1 получает запрос от координатора на создание сессии и возвращает данные для подключения к сессии
3. WebRTC сервер
3.1 получает от сервера сессий данные о создателе сессии
+33
View File
@@ -0,0 +1,33 @@
1) Может ли система масштабироваться?
Ответ: да может потому что есть координирующий сервер который обеспечивает удобный
и простой интерфейс получения доступа ко всем серверам сессий
2) Может ли у одного ЖК быть несолько копий и как это работает?
Ответ: да, может потому что координатор получает список всех серверов сессий и при создании ЖК
координатор получает свободный сервер или если происходит подключение с помощью кода координатор опрашивает
сервера для того чтобы узнать какому серверу принадлежит код и происходит подключение
3) Откуда координатор получает данные о всех жк и данные о запущенных серверах сессий?
a) на первом этапе координатор будет получать данные о доступных серверах из JSON файла
b) на втором этапе координатор будет получать данные из удалённой базы данных MySQL
4) Как работает и где хранится информация о планировании?
Ответ: планирование происходит на сайте для конкретного ЖК через дату и время, определяем можем ли мы
выбрать дату и время на основе количества серверов сессий для данного ЖК и уже имеющихся записей через координатор,
данные хранятся в соответствии с пунктом 3, если пользователь хочет задержаться в сесии когда время
истекает можно предложить продлить сессию если свободно время
5) Как происходит авторизация и ограничение планирования/создания сессий одим пользователем?
a) Предусмотрена регистрация/авторизация, после чего администратор производит модерацию и принимает/отклоняет запрос
на создание аккаунта который может создавать и планировать сессии (с определёнными ограничениями, например ограничение
количества сессий которые можно создать в определённый временной период)
b) После чего подключиться к сессии можно будет с помощью кода который получил пользователь при планировании сессии
c) Пользователям которые не планировали или не создавали сессию можно будет подключаться без авторизации
6) Как будет решена проблема с серым ip на серверах сессий?
a) Все сервера сессий будут общаться с клиентом через координатор
b) Все сервера WebRTC будут общаться с клиентом через через STUN сервер
с) потенциально можно использовать архитектуру клиент->координатор->WebRTC->приложение
7) Можно ли завершить сессию если все пользователи сессии неактивны?
если все пользователи сессии неактивны в течение N времени то сессия завершается
@@ -0,0 +1,4 @@
процесс подключения к трансляции:
1. клиент делает запрос на подключение к координатору и подключается
2. координатор делает запрос на серер сессий, сервер сессий запускает WebRTC сервер и передаёт в него данные клиента
3. WebRTC сервер подключается к клиенту
+16
View File
@@ -0,0 +1,16 @@
старый сопособ начать сессию:
демонстрация->выбор_жк (переходим на новый сайт) ->начать_демонстрацию->начать_новую->получить_код_&_соединиться->начать (переходим на новый сайт)
6 пунктов и 3 сайта
новый способ начать сессию:
демонстрация->выбор_жк->запланированть_новую||начать_новую||подключиться_к_существующей
3 пункта и 1 сайт
1) подключаемся к координатору сразу как только заходим на сайт или нажимаем кнопку демонстрации
2) после нажатия на кнопку демонстрации получаем список серверов у координатора и отображаем список возможных ЖК
3) при нажатии на ЖК, появляется возможность создать сессию или подключиться
4)
a) если создали сессию подключаемся к ней сразу же, посылаем координатору запрос на создание сессии определённого жк,
он опрашивает сервера для получения свободного, если найден свободный сервер посылает запрос на создание сесии и происходит подлючение к серверу ЖК,
если свободный сервер не найден возвращает ошибку
b) если хотим подключиться то вводим код и нажимаем подключиться, коодинатор опрашивает сервера сессий на знание кода,
если найден ЖК знающий код то подключаемся к серверу сессий, если нет то получаем код ошибки
Binary file not shown.

After

Width:  |  Height:  |  Size: 86 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 58 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 31 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 28 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 80 KiB