OLD | NEW |
---|---|
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "components/copresence/handlers/audio/audio_directive_handler.h" | 5 #include "components/copresence/handlers/audio/audio_directive_handler.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/memory/scoped_ptr.h" | |
8 #include "base/message_loop/message_loop.h" | 9 #include "base/message_loop/message_loop.h" |
9 #include "components/copresence/mediums/audio/audio_player.h" | 10 #include "components/copresence/mediums/audio/audio_manager.h" |
10 #include "components/copresence/mediums/audio/audio_recorder.h" | |
11 #include "components/copresence/test/audio_test_support.h" | |
12 #include "media/base/audio_bus.h" | |
13 #include "testing/gmock/include/gmock/gmock.h" | 11 #include "testing/gmock/include/gmock/gmock.h" |
14 #include "testing/gtest/include/gtest/gtest.h" | 12 #include "testing/gtest/include/gtest/gtest.h" |
15 | 13 |
16 using ::testing::_; | 14 using ::testing::_; |
17 using ::testing::Le; | 15 using ::testing::Le; |
18 | 16 |
19 namespace copresence { | 17 namespace copresence { |
20 | 18 |
21 class TestAudioPlayer : public AudioPlayer { | 19 class TestAudioManager : public AudioManager { |
Charlie
2014/10/17 22:42:25
We probably shouldn't be subclassing production co
rkc
2014/10/18 00:21:54
I agree that deriving a mock from a production cla
| |
22 public: | 20 public: |
23 TestAudioPlayer() {} | 21 TestAudioManager() : AudioManager() {} |
24 virtual ~TestAudioPlayer() {} | 22 virtual ~TestAudioManager() {} |
25 | 23 |
26 // AudioPlayer overrides: | 24 // AudioManager overrides: |
27 virtual void Initialize() override {} | 25 virtual void Initialize(const DecodeSamplesCallback&, |
28 virtual void Play( | 26 const EncodeTokenCallback&) override{}; |
Daniel Erat
2014/10/17 22:25:59
nit: space after 'override' and no trailing semico
rkc
2014/10/18 00:21:54
Done.
| |
29 const scoped_refptr<media::AudioBusRefCounted>& /* samples */) override { | 27 |
Daniel Erat
2014/10/17 22:25:59
nit: delete blank line
rkc
2014/10/18 00:21:54
Done.
| |
30 set_is_playing(true); | 28 virtual void StartPlaying(AudioType type) override { |
29 set_playing_for_testing(type, true); | |
31 } | 30 } |
32 virtual void Stop() override { set_is_playing(false); } | 31 |
Daniel Erat
2014/10/17 22:25:59
here too
rkc
2014/10/18 00:21:54
Done.
| |
33 virtual void Finalize() override { delete this; } | 32 virtual void StopPlaying(AudioType type) override { |
33 set_playing_for_testing(type, false); | |
34 } | |
35 | |
Daniel Erat
2014/10/17 22:25:59
here too
rkc
2014/10/18 00:21:54
Done.
| |
36 virtual void StartRecording(AudioType type) override { | |
37 set_recording_for_testing(type, true); | |
38 } | |
39 virtual void StopRecording(AudioType type) override { | |
40 set_recording_for_testing(type, false); | |
41 } | |
42 | |
43 virtual void SetToken(AudioType, const std::string&) override {} | |
34 | 44 |
35 private: | 45 private: |
36 DISALLOW_COPY_AND_ASSIGN(TestAudioPlayer); | 46 DISALLOW_COPY_AND_ASSIGN(TestAudioManager); |
37 }; | |
38 | |
39 class TestAudioRecorder : public AudioRecorder { | |
40 public: | |
41 TestAudioRecorder() : AudioRecorder(AudioRecorder::DecodeSamplesCallback()) {} | |
42 virtual ~TestAudioRecorder() {} | |
43 | |
44 // AudioRecorder overrides: | |
45 virtual void Initialize() override {} | |
46 virtual void Record() override { set_is_recording(true); } | |
47 virtual void Stop() override { set_is_recording(false); } | |
48 virtual void Finalize() override { delete this; } | |
49 | |
50 private: | |
51 DISALLOW_COPY_AND_ASSIGN(TestAudioRecorder); | |
52 }; | 47 }; |
53 | 48 |
54 class AudioDirectiveHandlerTest : public testing::Test { | 49 class AudioDirectiveHandlerTest : public testing::Test { |
Charlie
2014/10/17 22:42:25
I know this is a pain, but we really should add a
rkc
2014/10/18 00:21:54
This is actually tested in the directive handler;
Charlie
2014/10/18 00:44:11
I don't follow. This *is* the test for the directi
rkc
2014/10/18 00:51:30
In the AudioDirectiveList tests, sorry.
| |
55 public: | 50 public: |
56 AudioDirectiveHandlerTest() | 51 AudioDirectiveHandlerTest() |
57 : directive_handler_(new AudioDirectiveHandler( | 52 : directive_handler_(new AudioDirectiveHandler()) { |
58 AudioRecorder::DecodeSamplesCallback(), | 53 directive_handler_->set_audio_manager_for_testing( |
59 base::Bind(&AudioDirectiveHandlerTest::EncodeToken, | 54 make_scoped_ptr(new TestAudioManager())); |
60 base::Unretained(this)))) { | |
61 directive_handler_->set_player_audible_for_testing(new TestAudioPlayer()); | |
62 directive_handler_->set_player_inaudible_for_testing(new TestAudioPlayer()); | |
63 directive_handler_->set_recorder_for_testing(new TestAudioRecorder()); | |
64 } | 55 } |
65 virtual ~AudioDirectiveHandlerTest() {} | 56 virtual ~AudioDirectiveHandlerTest() {} |
66 | 57 |
67 void DirectiveAdded() {} | 58 void DirectiveAdded() {} |
68 | 59 |
69 protected: | 60 protected: |
70 void EncodeToken(const std::string& token, | |
71 bool audible, | |
72 const AudioDirectiveHandler::SamplesCallback& callback) { | |
73 callback.Run( | |
74 token, audible, CreateRandomAudioRefCounted(0x1337, 1, 0x7331)); | |
75 } | |
76 | |
77 copresence::TokenInstruction CreateTransmitInstruction( | 61 copresence::TokenInstruction CreateTransmitInstruction( |
78 const std::string& token, | 62 const std::string& token, |
79 bool audible) { | 63 bool audible) { |
80 copresence::TokenInstruction instruction; | 64 copresence::TokenInstruction instruction; |
81 instruction.set_token_instruction_type(copresence::TRANSMIT); | 65 instruction.set_token_instruction_type(copresence::TRANSMIT); |
82 instruction.set_token_id(token); | 66 instruction.set_token_id(token); |
83 instruction.set_medium(audible ? AUDIO_AUDIBLE_DTMF | 67 instruction.set_medium(audible ? AUDIO_AUDIBLE_DTMF |
84 : AUDIO_ULTRASOUND_PASSBAND); | 68 : AUDIO_ULTRASOUND_PASSBAND); |
85 return instruction; | 69 return instruction; |
86 } | 70 } |
87 | 71 |
88 copresence::TokenInstruction CreateReceiveInstruction() { | 72 copresence::TokenInstruction CreateReceiveInstruction(bool audible) { |
89 copresence::TokenInstruction instruction; | 73 copresence::TokenInstruction instruction; |
90 instruction.set_token_instruction_type(copresence::RECEIVE); | 74 instruction.set_token_instruction_type(copresence::RECEIVE); |
75 instruction.set_medium(audible ? AUDIO_AUDIBLE_DTMF | |
76 : AUDIO_ULTRASOUND_PASSBAND); | |
91 return instruction; | 77 return instruction; |
92 } | 78 } |
93 | 79 |
80 bool IsPlaying(AudioType type) { | |
81 return directive_handler_->audio_manager_->is_playing_for_testing(type); | |
Charlie
2014/10/17 22:42:25
These _for_testing methods, too, really only belon
rkc
2014/10/18 00:21:54
Acknowledged.
| |
82 } | |
83 | |
84 bool IsRecording(AudioType type) { | |
85 return directive_handler_->audio_manager_->is_recording_for_testing(type); | |
86 } | |
87 | |
94 // This order is important. We want the message loop to get created before | 88 // This order is important. We want the message loop to get created before |
95 // our the audio directive handler since the directive list ctor (invoked | 89 // our the audio directive handler since the directive list ctor (invoked |
96 // from the directive handler ctor) will post tasks. | 90 // from the directive handler ctor) will post tasks. |
97 base::MessageLoop message_loop_; | 91 base::MessageLoop message_loop_; |
98 scoped_ptr<AudioDirectiveHandler> directive_handler_; | 92 scoped_ptr<AudioDirectiveHandler> directive_handler_; |
99 | 93 |
100 private: | 94 private: |
101 DISALLOW_COPY_AND_ASSIGN(AudioDirectiveHandlerTest); | 95 DISALLOW_COPY_AND_ASSIGN(AudioDirectiveHandlerTest); |
102 }; | 96 }; |
103 | 97 |
104 TEST_F(AudioDirectiveHandlerTest, Basic) { | 98 TEST_F(AudioDirectiveHandlerTest, Basic) { |
105 const base::TimeDelta kTtl = base::TimeDelta::FromMilliseconds(9999); | 99 const base::TimeDelta kTtl = base::TimeDelta::FromMilliseconds(9999); |
106 directive_handler_->AddInstruction( | 100 directive_handler_->AddInstruction( |
107 CreateTransmitInstruction("token", true), "op_id1", kTtl); | 101 CreateTransmitInstruction("token", true), "op_id1", kTtl); |
108 directive_handler_->AddInstruction( | 102 directive_handler_->AddInstruction( |
109 CreateTransmitInstruction("token", false), "op_id1", kTtl); | 103 CreateTransmitInstruction("token", false), "op_id1", kTtl); |
110 directive_handler_->AddInstruction( | 104 directive_handler_->AddInstruction( |
111 CreateTransmitInstruction("token", false), "op_id2", kTtl); | 105 CreateTransmitInstruction("token", false), "op_id2", kTtl); |
112 directive_handler_->AddInstruction( | 106 directive_handler_->AddInstruction( |
113 CreateReceiveInstruction(), "op_id1", kTtl); | 107 CreateReceiveInstruction(false), "op_id1", kTtl); |
114 directive_handler_->AddInstruction( | 108 directive_handler_->AddInstruction( |
115 CreateReceiveInstruction(), "op_id2", kTtl); | 109 CreateReceiveInstruction(true), "op_id2", kTtl); |
116 directive_handler_->AddInstruction( | 110 directive_handler_->AddInstruction( |
117 CreateReceiveInstruction(), "op_id3", kTtl); | 111 CreateReceiveInstruction(false), "op_id3", kTtl); |
118 | 112 |
119 EXPECT_EQ(true, directive_handler_->player_audible_->IsPlaying()); | 113 EXPECT_TRUE(IsPlaying(AUDIBLE)); |
120 EXPECT_EQ(true, directive_handler_->player_inaudible_->IsPlaying()); | 114 EXPECT_TRUE(IsPlaying(INAUDIBLE)); |
121 EXPECT_EQ(true, directive_handler_->recorder_->IsRecording()); | 115 EXPECT_TRUE(IsRecording(AUDIBLE)); |
116 EXPECT_TRUE(IsRecording(INAUDIBLE)); | |
122 | 117 |
123 directive_handler_->RemoveInstructions("op_id1"); | 118 directive_handler_->RemoveInstructions("op_id1"); |
124 EXPECT_FALSE(directive_handler_->player_audible_->IsPlaying()); | 119 EXPECT_FALSE(IsPlaying(AUDIBLE)); |
125 EXPECT_EQ(true, directive_handler_->player_inaudible_->IsPlaying()); | 120 EXPECT_TRUE(IsPlaying(INAUDIBLE)); |
126 EXPECT_EQ(true, directive_handler_->recorder_->IsRecording()); | 121 EXPECT_TRUE(IsRecording(AUDIBLE)); |
122 EXPECT_TRUE(IsRecording(INAUDIBLE)); | |
127 | 123 |
128 directive_handler_->RemoveInstructions("op_id2"); | 124 directive_handler_->RemoveInstructions("op_id2"); |
129 EXPECT_FALSE(directive_handler_->player_inaudible_->IsPlaying()); | 125 EXPECT_FALSE(IsPlaying(INAUDIBLE)); |
130 EXPECT_EQ(true, directive_handler_->recorder_->IsRecording()); | 126 EXPECT_FALSE(IsRecording(AUDIBLE)); |
127 EXPECT_TRUE(IsRecording(INAUDIBLE)); | |
131 | 128 |
132 directive_handler_->RemoveInstructions("op_id3"); | 129 directive_handler_->RemoveInstructions("op_id3"); |
133 EXPECT_FALSE(directive_handler_->recorder_->IsRecording()); | 130 EXPECT_FALSE(IsRecording(INAUDIBLE)); |
134 } | 131 } |
135 | 132 |
136 // TODO(rkc): Write more tests that check more convoluted sequences of | 133 // TODO(rkc): Write more tests that check more convoluted sequences of |
137 // transmits/receives. | 134 // transmits/receives. |
138 | 135 |
139 } // namespace copresence | 136 } // namespace copresence |
OLD | NEW |