@@ -32,6 +32,10 @@ import org.junit.Assert.assertThrows
32
32
import org.junit.Test
33
33
import org.junit.runner.RunWith
34
34
import org.robolectric.RobolectricTestRunner
35
+ import org.unifiedpush.android.connector.FailedReason
36
+ import org.unifiedpush.android.connector.data.PublicKeySet
37
+ import org.unifiedpush.android.connector.data.PushEndpoint
38
+ import org.unifiedpush.android.connector.data.PushMessage
35
39
36
40
@RunWith(RobolectricTestRunner ::class )
37
41
class VectorUnifiedPushMessagingReceiverTest {
@@ -56,7 +60,7 @@ class VectorUnifiedPushMessagingReceiverTest {
56
60
fun `onRegistrationFailed does nothing` () = runTest {
57
61
val context = InstrumentationRegistry .getInstrumentation().context
58
62
val vectorUnifiedPushMessagingReceiver = createVectorUnifiedPushMessagingReceiver()
59
- vectorUnifiedPushMessagingReceiver.onRegistrationFailed(context, A_SECRET )
63
+ vectorUnifiedPushMessagingReceiver.onRegistrationFailed(context, FailedReason . NETWORK , A_SECRET )
60
64
}
61
65
62
66
@Test
@@ -68,7 +72,7 @@ class VectorUnifiedPushMessagingReceiverTest {
68
72
handleResult = pushHandlerResult
69
73
),
70
74
)
71
- vectorUnifiedPushMessagingReceiver.onMessage(context, UnifiedPushParserTest . UNIFIED_PUSH_DATA .toByteArray (), A_SECRET )
75
+ vectorUnifiedPushMessagingReceiver.onMessage(context, aPushMessage (), A_SECRET )
72
76
advanceUntilIdle()
73
77
pushHandlerResult.assertions()
74
78
.isCalledOnce()
@@ -93,7 +97,7 @@ class VectorUnifiedPushMessagingReceiverTest {
93
97
handleResult = pushHandlerResult
94
98
),
95
99
)
96
- vectorUnifiedPushMessagingReceiver.onMessage(context, " " .toByteArray( ), A_SECRET )
100
+ vectorUnifiedPushMessagingReceiver.onMessage(context, aPushMessage( " " ), A_SECRET )
97
101
advanceUntilIdle()
98
102
pushHandlerResult.assertions()
99
103
.isNeverCalled()
@@ -125,7 +129,7 @@ class VectorUnifiedPushMessagingReceiverTest {
125
129
unifiedPushNewGatewayHandler = unifiedPushNewGatewayHandler,
126
130
)
127
131
endpointRegistrationHandler.state.test {
128
- vectorUnifiedPushMessagingReceiver.onNewEndpoint(context, " anEndpoint" , A_SECRET )
132
+ vectorUnifiedPushMessagingReceiver.onNewEndpoint(context, aPushEndpoint( " anEndpoint" ) , A_SECRET )
129
133
advanceUntilIdle()
130
134
assertThat(awaitItem()).isEqualTo(
131
135
RegistrationResult (
@@ -168,7 +172,7 @@ class VectorUnifiedPushMessagingReceiverTest {
168
172
unifiedPushNewGatewayHandler = unifiedPushNewGatewayHandler,
169
173
)
170
174
endpointRegistrationHandler.state.test {
171
- vectorUnifiedPushMessagingReceiver.onNewEndpoint(context, " anEndpoint " , A_SECRET )
175
+ vectorUnifiedPushMessagingReceiver.onNewEndpoint(context, aPushEndpoint() , A_SECRET )
172
176
advanceUntilIdle()
173
177
assertThat(awaitItem()).isEqualTo(
174
178
RegistrationResult (
@@ -205,3 +209,19 @@ class VectorUnifiedPushMessagingReceiverTest {
205
209
}
206
210
}
207
211
}
212
+
213
+ private fun aPushMessage (
214
+ data : String = UnifiedPushParserTest .UNIFIED_PUSH_DATA ,
215
+ decrypted : Boolean = true,
216
+ ) = PushMessage (
217
+ content = data.toByteArray(),
218
+ decrypted = decrypted,
219
+ )
220
+
221
+ private fun aPushEndpoint (
222
+ url : String = "anEndpoint",
223
+ pubKeySet : PublicKeySet ? = null,
224
+ ) = PushEndpoint (
225
+ url = url,
226
+ pubKeySet = pubKeySet,
227
+ )
0 commit comments