mirror of
https://gitlab.gnome.org/GNOME/calls.git
synced 2024-11-04 23:51:17 +00:00
1056cba62a
Previously our code assumed that g_cancellable_cancel() the async DBus calls to libfeedback would guarantee that the underlying operation would not be performed (i.e. triggering or ending a feedback). However the endless ringing exhibited in #470 shows this assumption not to hold. Therefore we avoid using g_cancellable_cancel () completely and default to waiting for the async operation to finish. update_ring () now sets the target state by inspecting managed calls and the main logic will now step towards the target state: Changing from regular/loud to soft/quiet ringing (or vice versa) requires we first end feedback before (re)triggering it. Additionally the "is-quiet" and "is-ringing" properties are replaced by a new "state" property to allow changing the combination atomically. Closes: #470
365 lines
11 KiB
C
365 lines
11 KiB
C
/*
|
|
* Copyright (C) 2021 Purism SPC
|
|
*
|
|
* SPDX-License-Identifier: GPL-3.0-or-later
|
|
*
|
|
* Author: Evangelos Ribeiro Tzaras <devrtz@fortysixandtwo.eu>
|
|
*
|
|
*/
|
|
|
|
#include "calls-manager.h"
|
|
#include "calls-ringer.h"
|
|
#include "calls-ui-call-data.h"
|
|
#include "mock-call.h"
|
|
#include "mock-libfeedback.h"
|
|
#include "mock-contacts-provider.h"
|
|
|
|
|
|
/* mock calls_contacts_provider_new() */
|
|
CallsContactsProvider *
|
|
__wrap_calls_contacts_provider_new (void)
|
|
{
|
|
return NULL;
|
|
}
|
|
|
|
|
|
/* add or remove calls */
|
|
|
|
static void
|
|
add_call (CallsManager *manager,
|
|
CallsUiCallData *call)
|
|
{
|
|
g_assert (CALLS_IS_MANAGER (manager));
|
|
g_assert (CALLS_IS_UI_CALL_DATA (call));
|
|
|
|
g_signal_emit_by_name (manager, "ui-call-added", call, NULL);
|
|
}
|
|
|
|
|
|
static void
|
|
remove_call (CallsManager *manager,
|
|
CallsUiCallData *call)
|
|
{
|
|
g_assert (CALLS_IS_MANAGER (manager));
|
|
g_assert (CALLS_IS_UI_CALL_DATA (call));
|
|
|
|
g_signal_emit_by_name (manager, "ui-call-removed", call, NULL);
|
|
}
|
|
|
|
/* RingerFixture setup and tear down */
|
|
typedef struct {
|
|
CallsManager *manager;
|
|
CallsRinger *ringer;
|
|
CallsMockCall *call_one;
|
|
CallsUiCallData *ui_call_one;
|
|
CallsMockCall *call_two;
|
|
CallsUiCallData *ui_call_two;
|
|
GMainLoop *loop;
|
|
} RingerFixture;
|
|
|
|
|
|
static void
|
|
setup_ringer (RingerFixture *fixture,
|
|
gconstpointer user_data)
|
|
{
|
|
|
|
fixture->manager = calls_manager_get_default ();
|
|
fixture->ringer = calls_ringer_new ();
|
|
fixture->call_one = calls_mock_call_new ();
|
|
fixture->ui_call_one = calls_ui_call_data_new (CALLS_CALL (fixture->call_one), NULL);
|
|
fixture->call_two = calls_mock_call_new ();
|
|
fixture->ui_call_two = calls_ui_call_data_new (CALLS_CALL (fixture->call_two), NULL);
|
|
fixture->loop = g_main_loop_new (NULL, FALSE);
|
|
}
|
|
|
|
|
|
static void
|
|
tear_down_ringer (RingerFixture *fixture,
|
|
gconstpointer user_data)
|
|
{
|
|
g_assert_finalize_object (fixture->ui_call_one);
|
|
g_assert_finalize_object (fixture->call_one);
|
|
g_assert_finalize_object (fixture->ui_call_two);
|
|
g_assert_finalize_object (fixture->call_two);
|
|
g_assert_finalize_object (fixture->ringer);
|
|
g_main_loop_unref (fixture->loop);
|
|
}
|
|
|
|
/* t1: test_ringing_incoming_call */
|
|
static void
|
|
t1_on_ringer_call_accepted (CallsRinger *ringer,
|
|
GParamSpec *pspec,
|
|
gpointer user_data)
|
|
{
|
|
static guint test_phase = 0;
|
|
RingerFixture *fixture = user_data;
|
|
|
|
switch (test_phase++) {
|
|
case 0: /* incoming call */
|
|
g_assert_cmpint (calls_ringer_get_state (ringer), ==, CALLS_RING_STATE_RINGING);
|
|
calls_call_answer (CALLS_CALL (fixture->call_one));
|
|
break;
|
|
case 1: /* incoming call accepted */
|
|
g_assert_cmpint (calls_ringer_get_state (ringer), ==, CALLS_RING_STATE_INACTIVE);
|
|
g_main_loop_quit ((GMainLoop *) fixture->loop);
|
|
break;
|
|
default:
|
|
g_assert_not_reached (); /* did not find equivalent cmocka assertion */
|
|
}
|
|
}
|
|
|
|
|
|
static void
|
|
test_ringing_accept_call (RingerFixture *fixture,
|
|
gconstpointer user_data)
|
|
{
|
|
g_assert_cmpint (calls_ringer_get_state (fixture->ringer), ==, CALLS_RING_STATE_INACTIVE);
|
|
|
|
g_signal_connect (fixture->ringer,
|
|
"notify::state",
|
|
G_CALLBACK (t1_on_ringer_call_accepted),
|
|
fixture);
|
|
|
|
calls_call_set_state (CALLS_CALL (fixture->call_one), CALLS_CALL_STATE_INCOMING);
|
|
add_call (fixture->manager, fixture->ui_call_one);
|
|
|
|
/* main loop will quit in callback of notify::state */
|
|
g_main_loop_run (fixture->loop);
|
|
|
|
remove_call (fixture->manager, fixture->ui_call_one);
|
|
g_assert_cmpint (calls_ringer_get_state (fixture->ringer), ==, CALLS_RING_STATE_INACTIVE);
|
|
}
|
|
|
|
/* t2: test_ringing_hang_up_call */
|
|
static void
|
|
t2_on_ringer_call_hang_up (CallsRinger *ringer,
|
|
GParamSpec *pspec,
|
|
gpointer user_data)
|
|
{
|
|
static guint test_phase = 0;
|
|
RingerFixture *fixture = user_data;
|
|
|
|
switch (test_phase++) {
|
|
case 0: /* incoming call */
|
|
g_assert_cmpint (calls_ringer_get_state (ringer), ==, CALLS_RING_STATE_RINGING);
|
|
calls_call_hang_up (CALLS_CALL (fixture->call_one));
|
|
break;
|
|
case 1: /* incoming call hung up */
|
|
g_assert_cmpint (calls_ringer_get_state (ringer), ==, CALLS_RING_STATE_INACTIVE);
|
|
g_main_loop_quit ((GMainLoop *) fixture->loop);
|
|
break;
|
|
default:
|
|
g_assert_not_reached (); /* did not find equivalent cmocka assertion */
|
|
}
|
|
}
|
|
|
|
|
|
static void
|
|
test_ringing_hang_up_call (RingerFixture *fixture,
|
|
gconstpointer user_data)
|
|
{
|
|
g_assert_cmpint (calls_ringer_get_state (fixture->ringer), ==, CALLS_RING_STATE_INACTIVE);
|
|
|
|
g_signal_connect (fixture->ringer,
|
|
"notify::state",
|
|
G_CALLBACK (t2_on_ringer_call_hang_up),
|
|
fixture);
|
|
|
|
calls_call_set_state (CALLS_CALL (fixture->call_one), CALLS_CALL_STATE_INCOMING);
|
|
add_call (fixture->manager, fixture->ui_call_one);
|
|
|
|
/* main loop will quit in callback of notify::state */
|
|
g_main_loop_run (fixture->loop);
|
|
|
|
remove_call (fixture->manager, fixture->ui_call_one);
|
|
g_assert_cmpint (calls_ringer_get_state (fixture->ringer), ==, CALLS_RING_STATE_INACTIVE);
|
|
}
|
|
|
|
|
|
/* t3: test_ringing_silence_call */
|
|
static void
|
|
t3_on_ringer_call_silence (CallsRinger *ringer,
|
|
GParamSpec *pspec,
|
|
gpointer user_data)
|
|
{
|
|
static guint test_phase = 0;
|
|
RingerFixture *fixture = user_data;
|
|
|
|
switch (test_phase++) {
|
|
case 0: /* incoming call */
|
|
g_assert_cmpint (calls_ringer_get_state (fixture->ringer), ==, CALLS_RING_STATE_RINGING);
|
|
calls_ui_call_data_silence_ring (fixture->ui_call_one);
|
|
g_assert_true (calls_ui_call_data_get_silenced (fixture->ui_call_one));
|
|
break;
|
|
case 1: /* incoming call hung up */
|
|
g_assert_cmpint (calls_ringer_get_state (fixture->ringer), ==, CALLS_RING_STATE_INACTIVE);
|
|
g_main_loop_quit ((GMainLoop *) fixture->loop);
|
|
break;
|
|
default:
|
|
g_assert_not_reached (); /* did not find equivalent cmocka assertion */
|
|
}
|
|
}
|
|
|
|
|
|
static void
|
|
test_ringing_silence_call (RingerFixture *fixture,
|
|
gconstpointer user_data)
|
|
{
|
|
g_assert_cmpint (calls_ringer_get_state (fixture->ringer), ==, CALLS_RING_STATE_INACTIVE);
|
|
|
|
g_signal_connect (fixture->ringer,
|
|
"notify::state",
|
|
G_CALLBACK (t3_on_ringer_call_silence),
|
|
fixture);
|
|
|
|
calls_call_set_state (CALLS_CALL (fixture->call_one), CALLS_CALL_STATE_INCOMING);
|
|
add_call (fixture->manager, fixture->ui_call_one);
|
|
|
|
/* main loop will quit in callback of notify::state */
|
|
g_main_loop_run (fixture->loop);
|
|
|
|
remove_call (fixture->manager, fixture->ui_call_one);
|
|
g_assert_cmpint (calls_ringer_get_state (fixture->ringer), ==, CALLS_RING_STATE_INACTIVE);
|
|
}
|
|
|
|
|
|
/* t4: test_ringing_multiple_call */
|
|
static gboolean
|
|
t4_remove_calls (gpointer user_data)
|
|
{
|
|
static guint test_phase = 0;
|
|
RingerFixture *fixture = user_data;
|
|
|
|
if (test_phase == 0) {
|
|
remove_call (fixture->manager, fixture->ui_call_one);
|
|
test_phase++;
|
|
return G_SOURCE_CONTINUE;
|
|
}
|
|
|
|
g_assert_cmpint (calls_ringer_get_state (fixture->ringer), ==, CALLS_RING_STATE_RINGING);
|
|
remove_call (fixture->manager, fixture->ui_call_two);
|
|
|
|
return G_SOURCE_REMOVE;
|
|
}
|
|
|
|
|
|
static void
|
|
t4_on_ringer_multiple_calls (CallsRinger *ringer,
|
|
GParamSpec *pspec,
|
|
gpointer user_data)
|
|
{
|
|
static guint test_phase = 0;
|
|
RingerFixture *fixture = user_data;
|
|
|
|
switch (test_phase++) {
|
|
case 0: /* add second call, and schedule call removal */
|
|
g_assert_cmpint (calls_ringer_get_state (fixture->ringer), ==, CALLS_RING_STATE_RINGING);
|
|
add_call (fixture->manager, fixture->ui_call_two);
|
|
g_timeout_add (25, t4_remove_calls, fixture);
|
|
break;
|
|
case 1: /* both calls should be removed now */
|
|
g_assert_cmpint (calls_ringer_get_state (fixture->ringer), ==, CALLS_RING_STATE_INACTIVE);
|
|
g_main_loop_quit ((GMainLoop *) fixture->loop);
|
|
break;
|
|
default:
|
|
g_assert_not_reached (); /* did not find equivalent cmocka assertion */
|
|
}
|
|
}
|
|
|
|
|
|
static void
|
|
test_ringing_multiple_calls (RingerFixture *fixture,
|
|
gconstpointer user_data)
|
|
{
|
|
g_assert_cmpint (calls_ringer_get_state (fixture->ringer), ==, CALLS_RING_STATE_INACTIVE);
|
|
|
|
g_signal_connect (fixture->ringer,
|
|
"notify::state",
|
|
G_CALLBACK (t4_on_ringer_multiple_calls),
|
|
fixture);
|
|
|
|
calls_call_set_state (CALLS_CALL (fixture->call_one), CALLS_CALL_STATE_INCOMING);
|
|
add_call (fixture->manager, fixture->ui_call_one);
|
|
|
|
/* main loop will quit in callback of notify::state */
|
|
g_main_loop_run (fixture->loop);
|
|
|
|
g_assert_cmpint (calls_ringer_get_state (fixture->ringer), ==, CALLS_RING_STATE_INACTIVE);
|
|
}
|
|
|
|
|
|
static void
|
|
t5_on_ringer_multiple_calls_with_restart (CallsRinger *ringer,
|
|
GParamSpec *pspec,
|
|
gpointer user_data)
|
|
{
|
|
static guint test_phase = 0;
|
|
RingerFixture *fixture = user_data;
|
|
|
|
switch (test_phase++) {
|
|
case 0:
|
|
g_assert_cmpint (calls_ringer_get_state (fixture->ringer), ==, CALLS_RING_STATE_RINGING);
|
|
|
|
calls_call_answer (CALLS_CALL (fixture->call_one));
|
|
break;
|
|
case 1:
|
|
g_assert_cmpint (calls_ringer_get_state (fixture->ringer), ==, CALLS_RING_STATE_RINGING_SOFT);
|
|
|
|
calls_call_hang_up (CALLS_CALL (fixture->call_one));
|
|
break;
|
|
case 2:
|
|
g_assert_cmpint (calls_ringer_get_state (fixture->ringer), ==, CALLS_RING_STATE_RINGING);
|
|
|
|
calls_call_hang_up (CALLS_CALL (fixture->call_two));
|
|
break;
|
|
case 3:
|
|
g_assert_cmpint (calls_ringer_get_state (fixture->ringer), ==, CALLS_RING_STATE_INACTIVE);
|
|
|
|
g_main_loop_quit (fixture->loop);
|
|
break;
|
|
default:
|
|
g_assert_not_reached ();
|
|
}
|
|
}
|
|
|
|
static void
|
|
test_ringing_multiple_calls_with_restart (RingerFixture *fixture,
|
|
gconstpointer user_data)
|
|
{
|
|
g_assert_cmpint (calls_ringer_get_state (fixture->ringer), ==, CALLS_RING_STATE_INACTIVE);
|
|
|
|
g_signal_connect (fixture->ringer,
|
|
"notify::state",
|
|
G_CALLBACK (t5_on_ringer_multiple_calls_with_restart),
|
|
fixture);
|
|
|
|
calls_call_set_state (CALLS_CALL (fixture->call_one), CALLS_CALL_STATE_INCOMING);
|
|
add_call (fixture->manager, fixture->ui_call_one);
|
|
calls_call_set_state (CALLS_CALL (fixture->call_two), CALLS_CALL_STATE_INCOMING);
|
|
add_call (fixture->manager, fixture->ui_call_two);
|
|
|
|
/* main loop will quit in callback of notify::state */
|
|
g_main_loop_run (fixture->loop);
|
|
|
|
g_assert_cmpint (calls_ringer_get_state (fixture->ringer), ==, CALLS_RING_STATE_INACTIVE);
|
|
}
|
|
|
|
int
|
|
main (int argc,
|
|
char *argv[])
|
|
{
|
|
g_test_init (&argc, &argv, NULL);
|
|
|
|
g_test_add ("/Calls/Ringer/accept_call", RingerFixture, NULL,
|
|
setup_ringer, test_ringing_accept_call, tear_down_ringer);
|
|
g_test_add ("/Calls/Ringer/hang_up_call", RingerFixture, NULL,
|
|
setup_ringer, test_ringing_hang_up_call, tear_down_ringer);
|
|
g_test_add ("/Calls/Ringer/silence_call", RingerFixture, NULL,
|
|
setup_ringer, test_ringing_silence_call, tear_down_ringer);
|
|
g_test_add ("/Calls/Ringer/multiple_call", RingerFixture, NULL,
|
|
setup_ringer, test_ringing_multiple_calls, tear_down_ringer);
|
|
g_test_add ("/Calls/Ringer/multiple_call_restart", RingerFixture, NULL,
|
|
setup_ringer, test_ringing_multiple_calls_with_restart, tear_down_ringer);
|
|
|
|
return g_test_run ();
|
|
}
|