@@ -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()
@@ -96,7 +100,7 @@ class VectorUnifiedPushMessagingReceiverTest {
96
100
handleInvalidResult = handleInvalidResult,
97
101
),
98
102
)
99
- vectorUnifiedPushMessagingReceiver.onMessage(context, " " .toByteArray( ), A_SECRET )
103
+ vectorUnifiedPushMessagingReceiver.onMessage(context, aPushMessage( " " ), A_SECRET )
100
104
advanceUntilIdle()
101
105
handleInvalidResult.assertions().isCalledOnce()
102
106
}
@@ -127,7 +131,7 @@ class VectorUnifiedPushMessagingReceiverTest {
127
131
unifiedPushNewGatewayHandler = unifiedPushNewGatewayHandler,
128
132
)
129
133
endpointRegistrationHandler.state.test {
130
- vectorUnifiedPushMessagingReceiver.onNewEndpoint(context, " anEndpoint" , A_SECRET )
134
+ vectorUnifiedPushMessagingReceiver.onNewEndpoint(context, aPushEndpoint( " anEndpoint" ) , A_SECRET )
131
135
advanceUntilIdle()
132
136
assertThat(awaitItem()).isEqualTo(
133
137
RegistrationResult (
@@ -170,7 +174,7 @@ class VectorUnifiedPushMessagingReceiverTest {
170
174
unifiedPushNewGatewayHandler = unifiedPushNewGatewayHandler,
171
175
)
172
176
endpointRegistrationHandler.state.test {
173
- vectorUnifiedPushMessagingReceiver.onNewEndpoint(context, " anEndpoint " , A_SECRET )
177
+ vectorUnifiedPushMessagingReceiver.onNewEndpoint(context, aPushEndpoint() , A_SECRET )
174
178
advanceUntilIdle()
175
179
assertThat(awaitItem()).isEqualTo(
176
180
RegistrationResult (
@@ -207,3 +211,19 @@ class VectorUnifiedPushMessagingReceiverTest {
207
211
}
208
212
}
209
213
}
214
+
215
+ private fun aPushMessage (
216
+ data : String = UnifiedPushParserTest .UNIFIED_PUSH_DATA ,
217
+ decrypted : Boolean = true,
218
+ ) = PushMessage (
219
+ content = data.toByteArray(),
220
+ decrypted = decrypted,
221
+ )
222
+
223
+ private fun aPushEndpoint (
224
+ url : String = "anEndpoint",
225
+ pubKeySet : PublicKeySet ? = null,
226
+ ) = PushEndpoint (
227
+ url = url,
228
+ pubKeySet = pubKeySet,
229
+ )
0 commit comments