@@ -200,11 +200,8 @@ defmodule BuddyMatchingWeb.PlayersChannelTest do
200200 { socket1 , player1 , topic1 } = setup_socket ( @ base_player1 )
201201 { socket2 , player2 , topic2 } = setup_socket ( @ base_player2 )
202202
203- { :ok , _ , channel1 } = socket1 |> subscribe_and_join ( PlayersChannel , topic1 , player1 )
204- { :ok , _ , channel2 } = socket2 |> subscribe_and_join ( PlayersChannel , topic2 , player2 )
205-
206- :ok = close ( channel1 )
207- :ok = close ( channel2 )
203+ { :ok , _ , _channel1 } = socket1 |> subscribe_and_join ( PlayersChannel , topic1 , player1 )
204+ { :ok , _ , _channel2 } = socket2 |> subscribe_and_join ( PlayersChannel , topic2 , player2 )
208205
209206 # assert player 1 got no one else
210207 assert_receive % Phoenix.Socket.Message {
@@ -233,8 +230,7 @@ defmodule BuddyMatchingWeb.PlayersChannelTest do
233230 player = generate_player ( auth_player . id )
234231 data = Poison.Parser . parse! ( player )
235232
236- { :ok , _ , channel } = socket |> subscribe_and_join ( PlayersChannel , topic , data )
237- :ok = close ( channel )
233+ { :ok , _ , _channel } = socket |> subscribe_and_join ( PlayersChannel , topic , data )
238234
239235 assert_receive % Phoenix.Socket.Message {
240236 topic: ^ topic ,
@@ -257,13 +253,10 @@ defmodule BuddyMatchingWeb.PlayersChannelTest do
257253 { socket2 , player2 , topic2 } = setup_socket ( @ base_player2 )
258254
259255 { :ok , _ , channel1 } = socket1 |> subscribe_and_join ( PlayersChannel , topic1 , player1 )
260- { :ok , _ , channel2 } = socket2 |> subscribe_and_join ( PlayersChannel , topic2 , player2 )
256+ { :ok , _ , _channel2 } = socket2 |> subscribe_and_join ( PlayersChannel , topic2 , player2 )
261257
262258 push ( channel1 , "request_match" , % { "player" => player2 } )
263259
264- :ok = close ( channel1 )
265- :ok = close ( channel2 )
266-
267260 assert_receive % Phoenix.Socket.Message {
268261 topic: ^ topic2 ,
269262 event: @ request_event ,
@@ -277,11 +270,8 @@ defmodule BuddyMatchingWeb.PlayersChannelTest do
277270 { socket1 , player1 , topic1 } = setup_socket ( @ base_player1 )
278271 { socket2 , player2 , topic2 } = setup_socket ( @ base_player1 )
279272
280- { :ok , _ , channel1 } = socket1 |> subscribe_and_join ( PlayersChannel , topic1 , player1 )
281- { :ok , _ , channel2 } = socket2 |> subscribe_and_join ( PlayersChannel , topic2 , player2 )
282-
283- :ok = close ( channel1 )
284- :ok = close ( channel2 )
273+ { :ok , _ , _channel1 } = socket1 |> subscribe_and_join ( PlayersChannel , topic1 , player1 )
274+ { :ok , _ , _channel2 } = socket2 |> subscribe_and_join ( PlayersChannel , topic2 , player2 )
285275
286276 assert_receive % Phoenix.Socket.Message {
287277 topic: ^ topic2 ,
@@ -295,13 +285,10 @@ defmodule BuddyMatchingWeb.PlayersChannelTest do
295285 { socket2 , player2 , topic2 } = setup_socket ( @ base_player2 )
296286
297287 { :ok , _ , channel1 } = socket1 |> subscribe_and_join ( PlayersChannel , topic1 , player1 )
298- { :ok , _ , channel2 } = socket2 |> subscribe_and_join ( PlayersChannel , topic2 , player2 )
288+ { :ok , _ , _channel2 } = socket2 |> subscribe_and_join ( PlayersChannel , topic2 , player2 )
299289
300290 push ( channel1 , "respond_to_request" , % { "id" => player2 . id , "response" => "accepted" } )
301291
302- :ok = close ( channel1 )
303- :ok = close ( channel2 )
304-
305292 # player2 should recive the request response from player1
306293 assert_receive % Phoenix.Socket.Message {
307294 topic: ^ topic2 ,
@@ -315,31 +302,30 @@ defmodule BuddyMatchingWeb.PlayersChannelTest do
315302 { socket2 , player2 , topic2 } = setup_socket ( @ base_player2 )
316303
317304 { :ok , _ , channel1 } = socket1 |> subscribe_and_join ( PlayersChannel , topic1 , player1 )
318- { :ok , _ , channel2 } = socket2 |> subscribe_and_join ( PlayersChannel , topic2 , player2 )
305+ { :ok , _ , _channel2 } = socket2 |> subscribe_and_join ( PlayersChannel , topic2 , player2 )
319306
320307 assert_receive % Phoenix.Socket.Message {
321308 topic: ^ topic1 ,
322309 event: @ new_match_event ,
323310 payload: ^ player2
324311 }
325312
326- :ok = close ( channel1 )
313+ Process . unlink ( channel1 . channel_pid )
314+ _ = leave ( channel1 )
327315
328316 assert_receive % Phoenix.Socket.Message {
329317 topic: ^ topic2 ,
330318 event: @ unmatch_event ,
331319 payload: ^ player1
332320 }
333-
334- :ok = close ( channel2 )
335321 end
336322
337323 test "send leave event to player 2 when player 1 crashes" do
338324 { socket1 , player1 , topic1 } = setup_socket ( @ base_player1 )
339325 { socket2 , player2 , topic2 } = setup_socket ( @ base_player2 )
340326
341327 { :ok , _ , channel1 } = socket1 |> subscribe_and_join ( PlayersChannel , topic1 , player1 )
342- { :ok , _ , channel2 } = socket2 |> subscribe_and_join ( PlayersChannel , topic2 , player2 )
328+ { :ok , _ , _channel2 } = socket2 |> subscribe_and_join ( PlayersChannel , topic2 , player2 )
343329
344330 # unlink to first to avoid test being killed as well
345331 Process . unlink ( channel1 . channel_pid )
@@ -350,8 +336,6 @@ defmodule BuddyMatchingWeb.PlayersChannelTest do
350336 event: @ unmatch_event ,
351337 payload: ^ player1
352338 }
353-
354- :ok = close ( channel2 )
355339 end
356340
357341 @ tag :only
@@ -360,7 +344,7 @@ defmodule BuddyMatchingWeb.PlayersChannelTest do
360344 { socket2 , player2 , topic2 } = setup_socket ( @ base_player2 )
361345
362346 { :ok , _ , channel1 } = socket1 |> subscribe_and_join ( PlayersChannel , topic1 , player1 )
363- { :ok , _ , channel2 } = socket2 |> subscribe_and_join ( PlayersChannel , topic2 , player2 )
347+ { :ok , _ , _channel2 } = socket2 |> subscribe_and_join ( PlayersChannel , topic2 , player2 )
364348
365349 # assert player 1 got no one else
366350 assert_receive % Phoenix.Socket.Message {
@@ -393,9 +377,6 @@ defmodule BuddyMatchingWeb.PlayersChannelTest do
393377 event: @ unmatch_event ,
394378 payload: ^ narrow_player1
395379 }
396-
397- :ok = close ( channel1 )
398- :ok = close ( channel2 )
399380 end
400381
401382 test "update criteria sends error if criteria can't be parsed" do
@@ -425,16 +406,14 @@ defmodule BuddyMatchingWeb.PlayersChannelTest do
425406 } ,
426407 2000
427408 )
428-
429- :ok = close ( channel1 )
430409 end
431410
432411 test "update criteria sends unmatch events when no longer matching" do
433412 { socket1 , player1 , topic1 } = setup_socket ( @ base_player1 )
434413 { socket2 , player2 , topic2 } = setup_socket ( @ base_player2 )
435414
436415 { :ok , _ , channel1 } = socket1 |> subscribe_and_join ( PlayersChannel , topic1 , player1 )
437- { :ok , _ , channel2 } = socket2 |> subscribe_and_join ( PlayersChannel , topic2 , player2 )
416+ { :ok , _ , _channel2 } = socket2 |> subscribe_and_join ( PlayersChannel , topic2 , player2 )
438417
439418 # assert player 1 got no one else
440419 assert_receive (
@@ -485,9 +464,6 @@ defmodule BuddyMatchingWeb.PlayersChannelTest do
485464 % Phoenix.Socket.Message { topic: ^ topic2 , event: @ unmatch_event , payload: ^ narrow_player1 } ,
486465 2000
487466 )
488-
489- :ok = close ( channel1 )
490- :ok = close ( channel2 )
491467 end
492468
493469 test "update criteria sends unmatch events when no longer matching, and match event
@@ -498,7 +474,7 @@ defmodule BuddyMatchingWeb.PlayersChannelTest do
498474 setup_socket ( % Player { @ base_player2 | criteria: @ player_broad_criteria } )
499475
500476 { :ok , _ , channel1 } = socket1 |> subscribe_and_join ( PlayersChannel , topic1 , player1 )
501- { :ok , _ , channel2 } = socket2 |> subscribe_and_join ( PlayersChannel , topic2 , player2 )
477+ { :ok , _ , _channel2 } = socket2 |> subscribe_and_join ( PlayersChannel , topic2 , player2 )
502478
503479 # assert player 1 got no one else
504480 assert_receive (
@@ -559,8 +535,5 @@ defmodule BuddyMatchingWeb.PlayersChannelTest do
559535 % Phoenix.Socket.Message { topic: ^ topic2 , event: @ new_match_event , payload: ^ broad_player1 } ,
560536 2000
561537 )
562-
563- :ok = close ( channel1 )
564- :ok = close ( channel2 )
565538 end
566539end
0 commit comments