@@ -3,6 +3,7 @@ package com.flipcash.services.internal.network.api
33import com.codeinc.flipcash.gen.activity.v1.ActivityFeedGrpcKt
44import com.codeinc.flipcash.gen.activity.v1.ActivityFeedService
55import com.codeinc.flipcash.gen.activity.v1.Model
6+ import com.codeinc.flipcash.gen.activity.v1.validate
67import com.flipcash.services.internal.annotations.FlipcashManagedChannel
78import com.flipcash.services.internal.network.extensions.asQueryOptions
89import com.flipcash.services.internal.network.extensions.authenticate
@@ -12,6 +13,7 @@ import com.flipcash.services.models.QueryOptions
1213import com.getcode.ed25519.Ed25519.KeyPair
1314import com.getcode.opencode.internal.network.core.GrpcApi
1415import com.getcode.opencode.model.core.ID
16+ import dev.bmcreations.protovalidate.orThrow
1517import io.grpc.ManagedChannel
1618import kotlinx.coroutines.Dispatchers
1719import kotlinx.coroutines.withContext
@@ -45,6 +47,8 @@ internal class ActivityFeedApi @Inject constructor(
4547 .apply { setAuth(authenticate(owner)) }
4648 .build()
4749
50+ request.validate().orThrow()
51+
4852 return withContext(Dispatchers .IO ) {
4953 api.getLatestNotifications(request)
5054 }
@@ -68,6 +72,8 @@ internal class ActivityFeedApi @Inject constructor(
6872 .apply { setAuth(authenticate(owner)) }
6973 .build()
7074
75+ request.validate().orThrow()
76+
7177 return withContext(Dispatchers .IO ) {
7278 api.getPagedNotifications(request)
7379 }
@@ -90,6 +96,8 @@ internal class ActivityFeedApi @Inject constructor(
9096 setAuth(authenticate(owner))
9197 }.build()
9298
99+ request.validate().orThrow()
100+
93101 return withContext(Dispatchers .IO ) {
94102 api.getBatchNotifications(request)
95103 }
0 commit comments