Skip to content
This repository has been archived by the owner on Aug 16, 2023. It is now read-only.

Commit

Permalink
Allow agent connections to multiple RTCs (#241)
Browse files Browse the repository at this point in the history
  • Loading branch information
@feymartynov
feymartynov authored May 19, 2021
1 parent 37038db commit 14b06b6
Show file tree
Hide file tree
Showing 12 changed files with 165 additions and 38 deletions.
Binary file modified docs/data/conference.schema.png
View file
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
2 changes: 1 addition & 1 deletion docs/data/conference.schema.xml
View file
Original file line number Diff line number Diff line change
@@ -1 +1 @@
<mxfile modified="2021-03-19T05:07:47.385Z" host="app.diagrams.net" agent="5.0 (Macintosh)" etag="O_ob6If4-mYaeSuaFBPp" version="14.4.3" type="device"><diagram id="oY3ui7ZUPCmgsgYIyXuZ" name="Page-1">7V1bc9s2E/01enRH4sWWHiPZTtM6qRvna+O+aCARluhQhEpCtuRf/4EkqIux1MUmCSLdTmZqQryAwMHh7uJg0bIHs+XHiMynn5lHg5bV9pYt+7JlWR2n64j/JSUrWdLuWVnJJPI9WbYpuPNfaH6iLF34Ho13TuSMBdyf7xaOWRjSMd8pI1HEnndPe2DB7lPnZEKVgrsxCdTSv32PT7PSrtvelP9K/ck0f3KnLX+ZkfxkWRBPiceet4rsq5Y9iBjj2V+z5YAGSevl7ZJdd13w67piEQ35MRdcDW5H7b/bd/aX6Punj7ckfLHuz2w7u80TCRbyjUWNZrLGfJU3Q/zszwISiqP+Awv5nfylLY7HUz/wbsiKLZJqxJyMf+RH/SmL/BdxPgnETx1RIH6OuOxl6zy5mx8EAxawKH2OPfboqDvaufIuuaN8VkRjce1t/s6dV0WfyXLnxBsS87yWLAjIPPZHab2TC2ckmvhhn3Eu3jc7KX/L691KPaT/id9J4E9CUTYWz6JR3hbZ23Sc9PUi9oNuXWqf2z1bdEBf7S3ZgU804nS5VSR77yNlM8qjlThF/mp1JZLkWHLav7hZwfMGmVaOv+kWKq1zOQyJHA2T9c03gBF/SMycgh9HwU9y/gdRtBAjV8XRlMyTP0VDcJ8EX8WQJeEk+bXP2Vx2Q0Af8m6L5Eskf4/yrupsdUV2bj9pRV+M2g+yeOZ7XnrXbXyFLAVwPCdjP5zcZE+xnU3RV/m0pIiJWz4E6YCdipvRMKkN44ST0Rr6c+aHPG1Sty/+iZYfJH3iijcdiOPO5lj8S06P+ICFAiTET1FABT6faYLRvhex+TeBSJq/7fYwc19BzQIBtX+AH4bZKgfLcaCy21VhylUwdfv7u5E02h7oACqOBdQuekoDzyF8JK8pof9WJDgFSFh/PGXldr5POwjZgoRdKyLOFURwf0YznuExf4lE19NqyKZ9GBvpzQxnmjqYxT2SWXIGKh9HFwqOdPNKhh1zSeW8AASlkUp1YOgqYCALz6fhOCcWuuTIKQ3nlK6lm1N6yCklc0q3AATN5xSnrYBhHFHCqTckXLKKMFyEFzyb8xckl4aTS6fd1cwuTkcBFLLLu9hlPUQbzS6P393J7x+f7n+7GfSj++cPy+Cze9ZRg3UjMv5BQxlxoeECiNwhp7ydUwCQHEkzxZyS++F1cAoMIzVmh5yyj1OOpopddOwZww3iFPUDE9GYRk/SCUpaCyml4ZRy3tZNKRZSij5KKTBidVGK6hBzMokzOnmMWYh80nQ+6dYYqIUhrfrRyCd18UlPG530Zv4X52IR3JLbu86vffLvwH4666h8Ir2eYT7VTCbijYZVTTf/V5mlirnl3FCog1lANFnILG8PqOwfn40OqNg3n4a/OZ+8l7vnP+++WN+vbpeXZ4Dvw8dD0f2RaPfhnAX+eIWhFXPYxa4xXAsCCt2gt5PL3hHaaG6B48xqlE2QiwoHFFa2miastN3ecTyynh8qHz2qBg51lU3SVTpFarrm6iodVUWHusoSJhTdAiQ0X1fpqHq4RP0/rJ5q0OotjVe0qyodVUinm1XMsXr3j0vzzF5X9alRAWUuuWiXV7roUpdMLq65PnVXDd4+knARD3MZlC7v+uFhPO710LuGvGvX2vWucwHeFog6XQhF+VxB+TBSv1H1zCShg308Ta3H+nscbBBYlblTXfVbhQ72+z9Y3co/WNUhQlXsTkko+mPtYov26qIVXKsVfDqzAC42/MmqzPBByW7ZpFI0u9goK/j6r6fYdW/8fxbL6A+/e/nn8MvtmRq0i2kc+yxEUjGJVADXujJSAXGEYbu3c8regWkepWDQ7mdiFmjZYr3UgkG7kqnFiJgdqOBRrZUxSdqcr3CBkTGEAqxZrIxQQBShrVKysM4IWwVcnqAqo0YkIOGYRkNklsYtNeoWoGfP0sXKmAWEkyqKQmapa6WR2yxmUU0VMveH4oWT4ArmhDKHVID1i/WSCpor+kjlQhupwFhVly9mmoV0qRGPKNGXbRllC8fLFuy2A6RbhmnFLmFZABgGUKcTcVVAo0QLRWshGyFaACGlziyiZuH98brKZxcrkyx02mrwFjUL2mN2JxOLds1Cp61+rXQTS7Ot4IMo2IzNRoftQEZUzeDEAMaVRgZRinbFAqYFKttOMSJ3BwjffB8pTAtkPrHUKliA0YS2Ssm2ynp8mkct6z3cttAQkBENcA7AHEqpU7JQgCLM3V66/2NE8naYD9WJ5jgxT0YrNFbMYpY6JQswlHAbq7KNFXO3seqpc824N56BrFKnZgEGEm5kVTarGLGRFRgXUkWWuCDEXHKB0i7XG7lFlWXJgdvKk85V6BefK31PvQnN5Rei2aZswkISXG1KRXsvQo96srU359ywFBtJSz5SzleyKcmCM1E05bNcC0WXPv++9fd9cqtfXHl0mUuZ0oNVfhCKF15flBxsXZUcbi5Lj/LrUt3VhyhKIXP1VXJSUphondaXeJtTZiRcZWVbZ6hQkF0cs0U0pvsoQp7Ic7op/ETJcZh0wF4miWhAuP9Ed+pRATYujMNG2zBs5Pkqt7Gxb26ofmjAc3/QRlVjFnmCrNVvCWZVbukWUOZ5nk5OqpxHbsuHkDplWI8GASWUxxs2neOBpiGxMlxldfIQNZQlrHmufAaxOkSoqtr0U4L+c73+c0kMU2eKZbjKajxGN78Y7j93ilLhNsqBhjdcUsEQ08mMpu2X67OzqH/WlkgvzaaXOpMsw4jC8FzZm6IZEZ+Dqw7klxONuYhxJzRjGAUSVNZMKbgEumxKMSJly8MwnN/8z/Pvv317/Itfh18//dMH0sulaicVEBi2a+kO253vhu06F2rYDpw6XMuiSkePGrXDiJ2miN3e0d3INc9gjTFe984P1N5x2uhwHVhzYKtO3AatLpO3HE6pc7kzWGOM0JVMJ0YE6MCaq67PWtyPUn+DOKXO9c5gjVGRWzKnGCHIBbOaqU4QCnKbkaGwmGuasd4ZhBMud9aXoNDSxixwXFGBAob7zbJTal3rDGJI/Tohnbwv2G+CoQJHgdRgSubvyIonqZR1xf0Hl1f9br+Fcf/DcX+nfWy207UxA0FJPm4z2tfP6756ngU+0DoCuiQQzRUKW7ifrAOIFQSv3/UdoFajO7suPc5ENGEmwjp5f3PtUxGWKr3BuYgS5iIq199UhwhVf6PmX0WTvFaT/HRi0T4fYaEAp2xOMVeAY+MGjz8TuWifmLDR4S+ZXGwjPH5wKzlX6foal2y3W9Uv2T68GvuoRd0qEo5dsp3H9w4u53fkJ6q8NdvppeLNyGrrBDk4Nne+ZalNmvv21sWucy/56vrI0x1pu2xAmVXgrS49iFqtSShOQa32hAEQ+vYpNswGn+WUCz5wCsjRAr430h/YqwehtNctPwilgjmy0lNNgL0DrIBJ8gQIg9lLNhll4YOPKScqimEfmGw/KeWE26kz5QQMJdULx5QTNYeND0BqDwWcEjauLOUEXD9VGoZh41pVHNnI1hI2hlUlas56+cFC2alGddhb2KXOdBMwljBzvUZ5WNOUp8DqGDqmwgofPvkeZRm5jBgLkFgaTix1JpqAsYSrZDQSi9MwYlEnEXJiIQvPR2Ixh1hqzTcBgwkV7RqZpSBcp41ZVFFVEnV5jnyOAbwmB/Beq0KPj+CVkX0CxhIcDMYIXsMjeBkHNDeCB+izMIJX71erwKbRFsFTY7pxsp0tetkNM4YPUIv28J2thoJ1E8t/yBbuNcsWBqSfKaugi20Wq2iP3aHmUyOr2AV+kzZWUcMtqZkyjOhstMlCjazScFbRH7iz1eklpJXaaMVuGK0A62wTOwVpxTBaATJS1EwrmNJeI624DaOVn35Xwez9TtVo79126fBik4JerkekbatfgYb26dv6Zq+cuOF9k+uw6+2bEts5n/Spvp0LFqW8ysay3jwxv0VWMXnVprdOXivz6jmuPC5cLKNkiWm/AstJi2XEYcQY3z49IvPpZ+bR5Iz/Aw==</diagram></mxfile>
<mxfile modified="2021-05-17T08:46:47.011Z" host="app.diagrams.net" agent="5.0 (Macintosh)" etag="MNVKEZw1G5kleuLzEa0f" version="14.4.9" type="device"><diagram id="oY3ui7ZUPCmgsgYIyXuZ" name="Page-1">7V1bV9s4F/01PDLLlxiSxyZApzOUoaXftPQlS4lFYupYGVsBwq//ZEfOTcdJIPJFXWdW1xqsyLYsbW0dHW0dnbi9ycvHmEzHn5lPwxPH8l9O3IsTx7HP2ufif2nKXKZYHXeRMooDX6atEu6CV5pnlKmzwKfJRkbOWMiD6WbikEURHfKNNBLH7Hkz2wMLN986JSOqJNwNSaimfg98Pl6ktj1rlf4nDUbj/M22JX+ZkDyzTEjGxGfPa0nu5Ynbixnji78mLz0aprWX18vivquCX5cFi2nED7nhsnc7sL5bd+5N/OPTx1sSvTr3p65sjScSzuQXixJNZIn5PK+G5DmYhCQSV90HFvE7+YslrofjIPSvyZzN0mIknAx/5VfdMYuDV5GfhOInWySIn2MuW9k5S58WhGGPhSzO3uMOfTpoDzbuvEufKN8V00Tce5t/s72V9Jm8bGS8JgnPS8nCkEyTYJCVO71xQuJREHUZ5+J7F5nyr7zaLNRD9p/4nYTBKBJpQ/EuGud1sfgau5V9Xsx+0bVb3TO344oG6KqtJRvwicacvqwlydb7SNmE8ngusshfnbZEkuxLLesPb5HwvEKmk+NvvIZK56wle4TsDaPlw1eAEX9IzLwFPy0FP2n+DyJpJnquiqMxmaZ/iorgAQm/ii5LolH6a5ezqWyGkD7kzRbLj0j/HuRNZa81xSJvN63FQPTaDzJ5Evh+9tR1fEUsA3AyJcMgGl0v3uK2Vklf5dvSJCYe+RBmHXYsHkajtDSME04GS+hPWRDxrEq9rvgnar6XtoknvrQnru3VtfiXZo95j0UCJCTIUEAFPp9pitGuH7PpN4FImn/tejfztqDmgIDa3cH3w2yeg+UwULlWWZjyFEzd/n00kgbrHR1AxaGA2kSPNvDsw0f6mRL670VCqwAJy8FTFm5jfNpAyBok3EoRcaYgggcTuuAZnvDXWDQ9LYdsrP3YyB5mONNUwSzegcySM5B+HJ0rOKqbVxbYMZdUzgpAoI1UygNDWwEDmfkBjYY5sdAXjpzScE5pO3VzSgc5RTOntAtA0HxOaVkKGIYxJZz6fcIlqwjDRcyCJ1P+iuTScHKxrXbN7NKyFUAhuxzFLssu2mh2efzhjf7++HT/13WvG98/f3gJP3untuqsG5DhLxpJjwuNZoDnDjmlWZySz8Or4BQYRqrPDjnlUE7Z3TEN5BR1gIlpQuMnOQlKawsppeGUcmbVTSkOUopmSilaHmo+pagTYk5GyYJOHhMWIZ80nU/aFTpqYfSr82jkk6P4pFMAgkbRSWcS3LTOZ+Etub2z/+yS/3ru06mt8omc9fTzpWYyEh/fL2u5GZlF39pybihUwSwgmhxklvczy+7+2Whqca8/9f9qffJf756/3N04Py5vXy5OgbkPH/ZF88ei3vtTFgbDObpWzGEXt0J3LQgonAa9n1x29tBGcwvsZ1a9bIJcVDigsPKkacJK96xzGI8s14f0o0fVwKGuskm6ylaRmq65usqWqqJDXaWGBUWvAAnN11W2VD1cqv7vl081aPVq45XaVZUtVUhXN6uYY/Xu7pfmmb2eOqdGBZS55FK7vNLDKbVmcvHMnVO3VeftI4lmST+XQdU1u354GA47HZxdQ7Nrz9mcXecCvDUQ2W0IRflagX4YqWNUNStJOME+nKaWff2YCTYIrNKmU211rMIJ9vEDVrv0Aas8RKiK3TGJRHssp9iivtpoBVdqBb+dWYApNjxklWb4oGRXN6kYIdm9+vcp8bzr4OfsJf4naF986d/cnqpOu4QmScAiJBWTSAWYWpdGKiCO0G33fk7Z2THNoxR02v1OzAJtW6yWWtBpp5lajPDZgQoe1VoZkrTO+Rw3GBlDKMCexdIIBUQR2iqahXVG2CrgTgZVGTUgIYmGNO4jsxjHLMDWxdKYBYSTKopCZjlqp1HpcqjSoKCaKmQa9MWHpM4VjAllDqkA+xerJRU0VzSTihHmCgxfdfviQrOQbTXiMSX1RVtG2cLhsgXXbgHhlmFacTVsCwDdAOpyIu4KaJRooWgvZCNECyCk1JVF1Cwc768rfXWxNMmCbanOW9Qs1G4Ev5lYatcs2JY6WtVNLOZYwXv6ZqPtYJARVTM4NYBxp5FBlFK7YgHDAum2U4yI3QHCt6OaKRgWyFBiqVSwAKMJbRXNtsqyf5pHLcsz3NbQEJIBDXENwBxKqVKyUIAijN2uff5jRPB2mA/VheYkNU8GczRWzGKWKiULMJTwGCvdxoq5x1h11LVmPBvPQFapUrMAAwkPstLNKkYcZAX6hVSRJW4IMZdcoLDL1XpuUWWp2XFrhMqyYBJ3prQ99Uc0l1+IahuzEYtIeLlKFfU9i3zqy9pe5blmGTbSmnyknM9lVZIZZyJpzCe5Foq+BPzH2t/36aP+8OTVRS5lyi7m+UUkPnh5U3qxdld6ubotu8rvy3RXH+I4g8zlV8lJaWKqdVre4q+yTEg0X6St5VChIJs4YbN4SHdRhMzIc7opHKJkP0wbYCeTxDQkPHiiG+UoARvnxmHDMgwbebzKdWzsWhuqHhrw2h90UNWQxb4ga3UswajKJ3ULKPM4T28Oqpx7bvVDSF0yrEaDgBLKww2bwoOv3iKhLC2wMlxkdfEQNZQa9jyXvoJYHiJUVW02lOD8udr5syaGqTLEMlxk1R9TN78YPn+2i0LhNmoCDR+4pIIhoaMJzeov12cvvP6LukR6aTa9VBlkGUYUuud0H4pmhH8OLjoQX05U5izBk9CMYRRIUFkxpeAWaN2UYsQe6Id+NL3+nx/cf/v2+C+/ir5++tkFwstlaicVEOi2O6nbbXe26baz26rbDlw6XMqitKNH9dqhx64mj93O3t3IPc9gidFfd+QAtbOfNtpdB5YcOKoTj0GryuTVwylVbncGS4weOs10YoSDDiy5OvVZivtR6m8Qp1S53xksMSpyNXOKEYJcMACaOglCQa6xxFLpfmcQTrjdWXOAwtInP+V5ahUooLvfMDqpcq8ziCF1dEI6Oc7ZbwKdwF4g1ZmymO/IgqehlOvy+/cuLrvt7gn6/ff7/VvWodFO7V3RTuXrVr19+b721vsc8IXOAdAloaiuSNjC3XQfQKIgePmtB4E6uLpxbfuL3SZ98tXu/Aq//0wAc2lzRo8LERUsRABkuN8n3do5cla5EgECC6OvvmP0PHhU3ARIcc9uzkqEo7qRcYtC0xY8nSLX9NGrE+XhSlX4IdFoWPIsXeZXHiJUmZ8a5rkcrsGZvzZiqTJqCFxk1Pnp5hRzdX4uniP7O5GLXWXYEBhQ6FjUzC6uEZ5F8MhKT2n6xoaG2Be94aAgEGqLHhriIV8P0Be6IbtVFJjM1zJI7K6efMsym3F5hJK16eOTeoqrA7O3pGNxhZlFAeC7W9sOxW235CLehbzrKBchiM5ag9pYb0Bn7QFIcnSuByDZpQCrGcXO+ZtQvJ1dALMYxe8AH7j63KoFfO+MgPMe0B6Etl2u+71gc3SD7Sh9BrAJL/UDCmPaT885ZtFDgFFvmriMthX1xnOqjHoDQ0mdoaNLuUaX8u7+3sioN3CRVXUqupSPF5LZpWtUS0NEvui2EaItG7BQ+V6V60cTu1QZ8QbGEh6eoVuhasTZGXDRgQ16dEiFFd5/CnzKFuQyYCxEYmk4sVQZ6wbGEm7U000sRuzUg4uuri/kxEJmfoDEYg6xVBryBgYTbqrRzSxOAQoMYBZVcJV6XZ7jgKMDr8kOvG1h+uEePB0BcGAswc5g9OA1yYO37PDmePAA7RZ68DSMWqULuMpDhOrTTdITtXGWXacx/HZqqd1956qu4LqJxXRbuOjUr+bbwoAsNGMVnGKbxSq1++5QDqqbVcyQg8JFV90tmZnSj+lksAqEj6zScFap33HnqstLSCvH0YpbgAIDaEVdH8rsFKQVw2gFCIpTMa3gqRq6acWIUzXgov/2B5uqbQhItHce9Lb3tNr86NKGiLRddRRoaJse1DY75Yg1tM37dmtsxTHy5HaMwu0a23GPbGsLF2Vs17DqAM77QZB7tOsCwd5Wc73O5iMKNnuZjiZwh0stIwvYznvRtTOIxoHoqptR8l3RFWFAXMaM8fXsMZmOPzOfpjn+Dw==</diagram></mxfile>
3 changes: 3 additions & 0 deletions migrations/2021-05-17-082412_add_rtc_id_to_agent_connection/down.sql
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
ALTER TABLE agent_connection DROP CONSTRAINT agent_connection_pkey;
ALTER TABLE agent_connection ADD PRIMARY KEY (agent_id);
ALTER TABLE agent_connection DROP COLUMN rtc_id;
9 changes: 9 additions & 0 deletions migrations/2021-05-17-082412_add_rtc_id_to_agent_connection/up.sql
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,9 @@
TRUNCATE agent_connection;
ALTER TABLE agent_connection ADD COLUMN rtc_id UUID NOT NULL;

ALTER TABLE agent_connection
ADD CONSTRAINT agent_conenction_rtc_id_fk
FOREIGN KEY (rtc_id) REFERENCES rtc (id) ON DELETE CASCADE;

ALTER TABLE agent_connection DROP CONSTRAINT agent_connection_pkey;
ALTER TABLE agent_connection ADD PRIMARY KEY (agent_id, rtc_id);
2 changes: 1 addition & 1 deletion src/app/endpoint/room.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1006,7 +1006,7 @@ mod test {
assert_eq!(topic, expected_topic);
assert_eq!(reqp.method(), "subscription.create");
assert_eq!(payload.subject, agent.agent_id().to_owned());
assert_eq!(payload.object, vec!["rooms", &room_id]);
assert_eq!(payload.object, vec!["rooms", &room_id, "events"]);
});
}

Expand Down
104 changes: 88 additions & 16 deletions src/app/endpoint/rtc.rs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1010,22 +1010,40 @@ mod test {
let room1 =
shared_helpers::insert_room_with_backend_id(&conn, backend1.id());

let _rtc1 = shared_helpers::insert_rtc_with_room(&conn, &room1);
let rtc1 = shared_helpers::insert_rtc_with_room(&conn, &room1);

let s1a1 = TestAgent::new("web", "s1a1", USR_AUDIENCE);
shared_helpers::insert_connected_agent(&conn, s1a1.agent_id(), room1.id());

shared_helpers::insert_connected_agent(
&conn,
s1a1.agent_id(),
room1.id(),
rtc1.id(),
);

// The second backend has 2 agents.
let room2 =
shared_helpers::insert_room_with_backend_id(&conn, backend2.id());

let _rtc2 = shared_helpers::insert_rtc_with_room(&conn, &room2);
let rtc2 = shared_helpers::insert_rtc_with_room(&conn, &room2);

let s2a1 = TestAgent::new("web", "s2a1", USR_AUDIENCE);
shared_helpers::insert_connected_agent(&conn, s2a1.agent_id(), room2.id());

shared_helpers::insert_connected_agent(
&conn,
s2a1.agent_id(),
room2.id(),
rtc2.id(),
);

let s2a2 = TestAgent::new("web", "s2a2", USR_AUDIENCE);
shared_helpers::insert_connected_agent(&conn, s2a2.agent_id(), room2.id());

shared_helpers::insert_connected_agent(
&conn,
s2a2.agent_id(),
room2.id(),
rtc2.id(),
);

// The new rtc for which we will balance the stream.
let rtc3 = shared_helpers::insert_rtc(&conn);
Expand Down Expand Up @@ -1437,12 +1455,18 @@ mod test {
let rtc = shared_helpers::insert_rtc_with_room(&conn, &room);

// Insert active agents.
shared_helpers::insert_connected_agent(&conn, writer.agent_id(), room.id());
shared_helpers::insert_connected_agent(
&conn,
writer.agent_id(),
room.id(),
rtc.id(),
);

shared_helpers::insert_connected_agent(
&conn,
reader1.agent_id(),
room.id(),
rtc.id(),
);

factory::Agent::new()
Expand Down Expand Up @@ -1613,28 +1637,57 @@ mod test {
.insert(&conn);

// Insert rtcs for each room.
let _rtc1 = shared_helpers::insert_rtc_with_room(&conn, &room1);
let _rtc2 = shared_helpers::insert_rtc_with_room(&conn, &room2);
let rtc1 = shared_helpers::insert_rtc_with_room(&conn, &room1);
let rtc2 = shared_helpers::insert_rtc_with_room(&conn, &room2);
let rtc3 = shared_helpers::insert_rtc_with_room(&conn, &room3);

// Insert writer for room 1 @ backend 1
let agent = TestAgent::new("web", "writer1", USR_AUDIENCE);
shared_helpers::insert_connected_agent(&conn, agent.agent_id(), room1.id());

shared_helpers::insert_connected_agent(
&conn,
agent.agent_id(),
room1.id(),
rtc1.id(),
);

// Insert two readers for room 1 @ backend 1
let agent = TestAgent::new("web", "reader1-1", USR_AUDIENCE);
shared_helpers::insert_connected_agent(&conn, agent.agent_id(), room1.id());

shared_helpers::insert_connected_agent(
&conn,
agent.agent_id(),
room1.id(),
rtc1.id(),
);

let agent = TestAgent::new("web", "reader1-2", USR_AUDIENCE);
shared_helpers::insert_connected_agent(&conn, agent.agent_id(), room1.id());

shared_helpers::insert_connected_agent(
&conn,
agent.agent_id(),
room1.id(),
rtc1.id(),
);

// Insert writer for room 2 @ backend 2
let agent = TestAgent::new("web", "writer2", USR_AUDIENCE);
shared_helpers::insert_connected_agent(&conn, agent.agent_id(), room2.id());
shared_helpers::insert_connected_agent(
&conn,
agent.agent_id(),
room2.id(),
rtc2.id(),
);

// Insert reader for room 2 @ backend 2
let agent = TestAgent::new("web", "reader2", USR_AUDIENCE);
shared_helpers::insert_connected_agent(&conn, agent.agent_id(), room2.id());

shared_helpers::insert_connected_agent(
&conn,
agent.agent_id(),
room2.id(),
rtc2.id(),
);

(rtc3, backend2)
})
Expand Down Expand Up @@ -1743,7 +1796,13 @@ mod test {

// Insert writer for room 1
let agent = TestAgent::new("web", "writer1", USR_AUDIENCE);
shared_helpers::insert_connected_agent(&conn, agent.agent_id(), room1.id());

shared_helpers::insert_connected_agent(
&conn,
agent.agent_id(),
room1.id(),
rtc1.id(),
);

// Insert 450 readers for room 1
for i in 0..450 {
Expand All @@ -1754,16 +1813,29 @@ mod test {
&conn,
agent.agent_id(),
room1.id(),
rtc1.id(),
);
}

// Insert writer for room 3
let agent = TestAgent::new("web", "writer3", USR_AUDIENCE);
shared_helpers::insert_connected_agent(&conn, agent.agent_id(), room2.id());

shared_helpers::insert_connected_agent(
&conn,
agent.agent_id(),
room2.id(),
rtc3.id(),
);

// Insert reader for room 3
let agent = TestAgent::new("web", "reader3", USR_AUDIENCE);
shared_helpers::insert_connected_agent(&conn, agent.agent_id(), room3.id());

shared_helpers::insert_connected_agent(
&conn,
agent.agent_id(),
room3.id(),
rtc3.id(),
);

([rtc1, rtc2, rtc3], backend)
})
Expand Down
Loading

0 comments on commit 14b06b6

Please sign in to comment.