chore(flipcash): update user_flags to populate supported on ramp providers

Signed-off-by: Brandon McAnsh <git@bmcreations.dev>

Author: bmc08gt

definitions/flipcash/protos/src/main/proto/account/v1/flipcash_account_service.proto

@@ -53,6 +53,8 @@ message LoginResponse {
 message GetUserFlagsRequest {
 	common.v1.UserId user_id = 1;
 	common.v1.Auth auth = 2;
+	common.v1.Platform platform = 3;
+	common.v1.CountryCode country_code = 4;
 }
 message GetUserFlagsResponse {
 	Result result = 1;
@@ -69,4 +71,11 @@ message UserFlags {
 	bool is_staff = 2;
 	// Does this user require IAP for registration in the account creation flow?
 	bool requires_iap_for_registration = 3;
+	// The set of supported on ramp providers for the user, based on their platform
+	// and locale if provided
+	repeated OnRampProvider supported_on_ramp_providers = 4 ;
+	enum OnRampProvider {
+		UNKNOWN  = 0;
+		COINBASE = 1;
+	}
 }

definitions/flipcash/protos/src/main/proto/common/v1/common.proto

@@ -94,3 +94,7 @@ message Response {
         ERROR = 1;
     }
 }
+message CountryCode {
+    // ISO 3166-1 Alpha-2
+    string value = 1 ;
+}

definitions/flipcash/protos/src/main/proto/event/v1/event_streaming_service.proto

@@ -0,0 +1,53 @@
+syntax = "proto3";
+package flipcash.event.v1;
+option go_package = "github.com/code-payments/flipcash-protobuf-api/generated/go/event/v1;eventpb";
+option java_package = "com.codeinc.flipcash.gen.events.v1";
+option objc_class_prefix = "FPBEventV1";
+import "event/v1/model.proto";
+import "common/v1/common.proto";
+import "google/protobuf/timestamp.proto";
+
+service EventStreaming {
+    // StreamEvents streams events for the requesting user.
+    rpc StreamEvents(stream StreamEventsRequest) returns (stream StreamEventsResponse);
+    // ForwardEvents is an internal RPC for forwarding events to another server.
+    rpc ForwardEvents(ForwardEventsRequest) returns (ForwardEventsResponse);
+}
+message StreamEventsRequest {
+    oneof type {
+        Params     params = 1;
+        ClientPong pong   = 2;
+    }
+    message Params {
+        common.v1.Auth auth = 1;
+        // ts contains the time for stream open.
+        //
+        // It is used primarily as a nonce for auth. Server may reject
+        // timestamps that are too far in the future or past.
+        google.protobuf.Timestamp ts = 2;
+    }
+}
+message StreamEventsResponse {
+    oneof type {
+        ServerPing  ping   = 1;
+        StreamError error  = 2;
+        EventBatch  events = 3;
+    }
+    message StreamError {
+        Code code = 1;
+        enum Code {
+            DENIED            = 0;
+            INVALID_TIMESTAMP = 1;
+        }
+    }
+}
+message ForwardEventsRequest {
+    UserEventBatch user_events = 1;
+}
+message ForwardEventsResponse {
+    Result result = 1;
+    enum Result {
+        OK     = 0;
+        DENIED = 1;
+    }
+}

definitions/flipcash/protos/src/main/proto/event/v1/model.proto

@@ -0,0 +1,68 @@
+syntax = "proto3";
+package flipcash.event.v1;
+option go_package = "github.com/code-payments/flipcash-protobuf-api/generated/go/event/v1;eventpb";
+option java_package = "com.codeinc.flipcash.gen.events.v1";
+option objc_class_prefix = "FPBEventV1";
+import "common/v1/common.proto";
+import "pool/v1/model.proto";
+import "google/protobuf/duration.proto";
+import "google/protobuf/timestamp.proto";
+
+message EventId {
+    bytes id = 1 ;
+}
+ // todo: define additional events
+message Event {
+    EventId id = 1;
+    google.protobuf.Timestamp ts = 2;
+    oneof type {
+        TestEvent test = 3;
+        //
+        // Section: Betting pools
+        //
+        PoolResolvedEvent  pool_resolved   = 100;
+        PoolBetUpdateEvent pool_bet_update = 101;
+    }
+}
+message EventBatch {
+    repeated Event events = 1 ;
+}
+message UserEvent {
+    common.v1.UserId user_id = 1;
+    Event event = 2;
+}
+message UserEventBatch {
+    repeated UserEvent events = 1 ;
+}
+message TestEvent {
+    repeated string hops = 1;
+    uint64 nonce = 2;
+}
+// Event sent when a pool has been resolved
+message PoolResolvedEvent {
+    // The latest signed pool metadata, which is guaranteed to contain a resolution
+    pool.v1.SignedPoolMetadata pool = 1;
+    // The final bet summary for the pool
+    pool.v1.BetSummary bet_summary = 2;
+    // The user's outcome for the pool
+    pool.v1.UserPoolSummary user_summary = 3;
+}
+// Event sent when a bet is made against a pool
+message PoolBetUpdateEvent {
+    // The pool ID the bet update is for
+    pool.v1.PoolId pool_id = 1;
+    // The latest bet summary for the pool
+    pool.v1.BetSummary bet_summary = 2;
+}
+message ServerPing {
+    // Timestamp the ping was sent on the stream, for client to get a sense
+    // of potential network latency
+    google.protobuf.Timestamp timestamp = 1;
+    // The delay server will apply before sending the next ping
+    google.protobuf.Duration ping_delay = 2;
+}
+message ClientPong {
+    // Timestamp the Pong was sent on the stream, for server to get a sense
+    // of potential network latency
+    google.protobuf.Timestamp timestamp = 1;
+}

services/flipcash/src/main/kotlin/com/flipcash/services/controllers/AccountController.kt

@@ -4,11 +4,13 @@ import com.flipcash.services.internal.model.account.UserFlags
 import com.flipcash.services.repository.AccountRepository
 import com.flipcash.services.user.UserManager
 import com.getcode.opencode.model.core.ID
+import com.getcode.util.locale.LocaleHelper
 import javax.inject.Inject
 
 class AccountController @Inject constructor(
     private val repository: AccountRepository,
     private val userManager: UserManager,
+    private val localeHelper: LocaleHelper,
 ) {
     suspend fun createAccount(): Result<ID> {
         val owner = userManager.accountCluster?.authority?.keyPair
@@ -29,9 +31,12 @@ class AccountController @Inject constructor(
         val userId = userManager.accountId
             ?: return Result.failure(Throwable("No user ID in UserManager"))
 
+        val countryCode = localeHelper.getDefaultCountry()
+
         return repository.getUserFlags(
             owner = owner,
-            userId = userId
+            userId = userId,
+            countryCode = countryCode
         )
     }
 }

services/flipcash/src/main/kotlin/com/flipcash/services/internal/domain/UserFlagsMapper.kt

@@ -2,6 +2,7 @@ package com.flipcash.services.internal.domain
 
 import com.codeinc.flipcash.gen.account.v1.FlipcashAccountService
 import com.flipcash.services.internal.model.account.UserFlags
+import com.flipcash.services.internal.model.thirdparty.OnRampProvider
 import com.getcode.opencode.mapper.Mapper
 import javax.inject.Inject
 
@@ -11,7 +12,13 @@ internal class UserFlagsMapper @Inject constructor():
         return UserFlags(
             isRegistered = from.isRegisteredAccount,
             isStaff = from.isStaff,
-            requiresIapForRegistration = from.requiresIapForRegistration
+            requiresIapForRegistration = from.requiresIapForRegistration,
+            supportedOnRampProviders = from.supportedOnRampProvidersList.map {
+                when (it) {
+                    FlipcashAccountService.UserFlags.OnRampProvider.COINBASE -> OnRampProvider.Coinbase
+                    else -> OnRampProvider.Unknown
+                }
+            }
         )
     }
 }

services/flipcash/src/main/kotlin/com/flipcash/services/internal/model/account/UserFlags.kt

@@ -1,7 +1,10 @@
 package com.flipcash.services.internal.model.account
 
+import com.flipcash.services.internal.model.thirdparty.OnRampProvider
+
 data class UserFlags(
     val isStaff: Boolean,
     val isRegistered: Boolean,
-    val requiresIapForRegistration: Boolean
+    val requiresIapForRegistration: Boolean,
+    val supportedOnRampProviders: List<OnRampProvider>,
 )

services/flipcash/src/main/kotlin/com/flipcash/services/internal/model/thirdparty/OnRampProvider.kt

@@ -0,0 +1,6 @@
+package com.flipcash.services.internal.model.thirdparty
+
+enum class OnRampProvider {
+    Unknown,
+    Coinbase;
+}

services/flipcash/src/main/kotlin/com/flipcash/services/internal/network/api/AccountApi.kt

@@ -1,7 +1,9 @@
 package com.flipcash.services.internal.network.api
 
 import com.codeinc.flipcash.gen.account.v1.AccountGrpcKt
+import com.codeinc.flipcash.gen.common.v1.Common
 import com.flipcash.services.internal.annotations.FlipcashManagedChannel
+import com.flipcash.services.internal.network.extensions.asCountryCode
 import com.flipcash.services.internal.network.extensions.asPublicKey
 import com.flipcash.services.internal.network.extensions.asUserId
 import com.flipcash.services.internal.network.extensions.authenticate
@@ -61,9 +63,12 @@ internal class AccountApi @Inject constructor(
     suspend fun getUserFlags(
         userId: ID,
         owner: KeyPair,
+        countryCode: String,
     ): RpcAccountService.GetUserFlagsResponse {
         val request = RpcAccountService.GetUserFlagsRequest.newBuilder()
             .setUserId(userId.asUserId())
+            .setPlatform(Common.Platform.GOOGLE)
+            .setCountryCode(countryCode.asCountryCode())
             .apply { setAuth(authenticate(owner)) }
             .build()
 

services/flipcash/src/main/kotlin/com/flipcash/services/internal/network/extensions/LocalToProtobuf.kt

@@ -138,4 +138,8 @@ internal fun Pair<ApiProvider, String>.asApiKey(): ThirdPartyModels.ApiKey {
         )
         .setValue(second)
         .build()
+}
+
+internal fun String.asCountryCode(): Common.CountryCode {
+    return Common.CountryCode.newBuilder().setValue(this).build()
 }