feat(samples): add Kotlin backend routes and core infrastructure

pengying · claude · pengying · commit 75a5bcad46b3 · 2026-02-12T14:45:42.000-08:00
Add all Kotlin source files for the Grid API sample app backend:
- Core infrastructure: Config, GridClientBuilder, WebhookStream, JsonUtils
- Application entry point with CORS and SSE configuration
- Route handlers: Customers, ExternalAccounts, Quotes, Sandbox, Webhooks, SSE
- Fix build.gradle.kts to use correct SDK coordinates (com.grid.api:grid-kotlin)

Co-Authored-By: Claude Opus 4.6 &lt;noreply@anthropic.com&gt;
diff --git a/samples/kotlin/build.gradle.kts b/samples/kotlin/build.gradle.kts
@@ -19,6 +19,7 @@ application {
 }
 
 repositories {
+    mavenLocal()
     mavenCentral()
 }
 
@@ -32,7 +33,7 @@ dependencies {
     implementation("io.ktor:ktor-server-config-yaml:3.1.3")
 
     // Grid Kotlin SDK
-    implementation("com.lightspark.grid:lightspark-grid-kotlin:0.4.0")
+    implementation("com.grid.api:grid-kotlin:0.0.1")
 
     // JSON
     implementation("com.fasterxml.jackson.module:jackson-module-kotlin:2.18.2")
diff --git a/samples/kotlin/src/main/kotlin/com/grid/sample/Application.kt b/samples/kotlin/src/main/kotlin/com/grid/sample/Application.kt
@@ -0,0 +1,33 @@
+package com.grid.sample
+
+import com.grid.sample.routes.*
+import io.ktor.http.*
+import io.ktor.server.application.*
+import io.ktor.server.plugins.cors.routing.*
+import io.ktor.server.routing.*
+import io.ktor.server.sse.*
+
+fun main(args: Array<String>) {
+    io.ktor.server.netty.EngineMain.main(args)
+}
+
+fun Application.module() {
+    install(CORS) {
+        allowMethod(HttpMethod.Options)
+        allowMethod(HttpMethod.Get)
+        allowMethod(HttpMethod.Post)
+        allowHeader(HttpHeaders.ContentType)
+        allowHeader(HttpHeaders.Authorization)
+        allowCredentials = true
+        anyHost()
+    }
+    install(SSE)
+    routing {
+        customerRoutes()
+        externalAccountRoutes()
+        quoteRoutes()
+        sandboxRoutes()
+        webhookRoutes()
+        sseRoutes()
+    }
+}
diff --git a/samples/kotlin/src/main/kotlin/com/grid/sample/Config.kt b/samples/kotlin/src/main/kotlin/com/grid/sample/Config.kt
@@ -0,0 +1,21 @@
+package com.grid.sample
+
+import io.github.cdimascio.dotenv.dotenv
+
+object Config {
+    private val dotenv = dotenv {
+        directory = "./"
+        ignoreIfMalformed = true
+        ignoreIfMissing = true
+    }
+
+    val apiTokenId: String = getEnvVar("GRID_API_TOKEN_ID")
+    val apiClientSecret: String = getEnvVar("GRID_API_CLIENT_SECRET")
+    val webhookPublicKey: String = getEnvVar("GRID_WEBHOOK_PUBLIC_KEY").replace("\\n", "\n")
+
+    private fun getEnvVar(key: String): String =
+        System.getProperty(key)
+            ?: dotenv[key]
+            ?: System.getenv(key)
+            ?: throw IllegalStateException("$key environment variable not set")
+}
diff --git a/samples/kotlin/src/main/kotlin/com/grid/sample/GridClientBuilder.kt b/samples/kotlin/src/main/kotlin/com/grid/sample/GridClientBuilder.kt
@@ -0,0 +1,13 @@
+package com.grid.sample
+
+import com.grid.api.client.GridClient
+import com.grid.api.client.okhttp.GridOkHttpClient
+
+object GridClientBuilder {
+    val client: GridClient by lazy {
+        GridOkHttpClient.builder()
+            .username(Config.apiTokenId)
+            .password(Config.apiClientSecret)
+            .build()
+    }
+}
diff --git a/samples/kotlin/src/main/kotlin/com/grid/sample/JsonUtils.kt b/samples/kotlin/src/main/kotlin/com/grid/sample/JsonUtils.kt
@@ -0,0 +1,18 @@
+package com.grid.sample
+
+import com.fasterxml.jackson.databind.ObjectMapper
+import com.fasterxml.jackson.databind.SerializationFeature
+import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper
+
+object JsonUtils {
+    val mapper: ObjectMapper = jacksonObjectMapper().apply {
+        enable(SerializationFeature.INDENT_OUTPUT)
+    }
+
+    fun prettyPrint(obj: Any): String =
+        try {
+            mapper.writeValueAsString(obj)
+        } catch (e: Exception) {
+            """{"error": "Failed to serialize response: ${e.message}"}"""
+        }
+}
diff --git a/samples/kotlin/src/main/kotlin/com/grid/sample/WebhookStream.kt b/samples/kotlin/src/main/kotlin/com/grid/sample/WebhookStream.kt
@@ -0,0 +1,15 @@
+package com.grid.sample
+
+import kotlinx.coroutines.flow.MutableSharedFlow
+import kotlinx.coroutines.flow.SharedFlow
+import kotlinx.coroutines.flow.asSharedFlow
+
+object WebhookStream {
+    private val _eventFlow = MutableSharedFlow<String>(replay = 10)
+    val eventFlow: SharedFlow<String> = _eventFlow.asSharedFlow()
+
+    fun addEvent(event: String) {
+        println("Broadcasting webhook: $event")
+        _eventFlow.tryEmit(event)
+    }
+}
diff --git a/samples/kotlin/src/main/kotlin/com/grid/sample/routes/Customers.kt b/samples/kotlin/src/main/kotlin/com/grid/sample/routes/Customers.kt
@@ -0,0 +1,58 @@
+package com.grid.sample.routes
+
+import com.fasterxml.jackson.databind.JsonNode
+import com.grid.api.models.customers.CustomerCreateParams
+import com.grid.api.models.customers.CustomerCreateParams.CreateCustomerRequest
+import com.grid.api.models.customers.CustomerType
+import com.grid.sample.GridClientBuilder
+import com.grid.sample.JsonUtils
+import io.ktor.http.*
+import io.ktor.server.request.*
+import io.ktor.server.response.*
+import io.ktor.server.routing.*
+
+fun Route.customerRoutes() {
+    route("/api/customers") {
+        post {
+            try {
+                val body = call.receiveText()
+                val json = JsonUtils.mapper.readTree(body)
+
+                val individualRequest = CreateCustomerRequest
+                    .IndividualCustomerCreateRequest.builder()
+                    .customerType(CustomerType.INDIVIDUAL)
+                    .platformCustomerId(json.requiredText("platformCustomerId"))
+                    .apply {
+                        json.optText("fullName")?.let { fullName(it) }
+                        json.optText("nationality")?.let { nationality(it) }
+                    }
+                    .build()
+
+                val params = CustomerCreateParams.builder()
+                    .createCustomerRequest(
+                        CreateCustomerRequest.ofIndividualCustomerCreate(individualRequest)
+                    )
+                    .build()
+
+                val customer = GridClientBuilder.client.customers().create(params)
+                call.respondText(
+                    JsonUtils.prettyPrint(customer),
+                    ContentType.Application.Json,
+                    HttpStatusCode.Created
+                )
+            } catch (e: Exception) {
+                call.respondText(
+                    """{"error": "${e.message}"}""",
+                    ContentType.Application.Json,
+                    HttpStatusCode.InternalServerError
+                )
+            }
+        }
+    }
+}
+
+private fun JsonNode.optText(field: String): String? =
+    if (has(field) && !get(field).isNull) get(field).asText() else null
+
+private fun JsonNode.requiredText(field: String): String =
+    optText(field) ?: throw IllegalArgumentException("$field is required")
diff --git a/samples/kotlin/src/main/kotlin/com/grid/sample/routes/ExternalAccounts.kt b/samples/kotlin/src/main/kotlin/com/grid/sample/routes/ExternalAccounts.kt
@@ -0,0 +1,105 @@
+package com.grid.sample.routes
+
+import com.fasterxml.jackson.databind.JsonNode
+import com.grid.api.models.customers.externalaccounts.BaseExternalAccountInfo
+import com.grid.api.models.customers.externalaccounts.BeneficiaryOneOf
+import com.grid.api.models.customers.externalaccounts.ExternalAccountCreate
+import com.grid.api.models.customers.externalaccounts.ExternalAccountCreateParams
+import com.grid.api.models.customers.externalaccounts.ExternalAccountInfoOneOf
+import com.grid.api.models.customers.externalaccounts.IndividualBeneficiary
+import com.grid.api.models.customers.externalaccounts.BaseBeneficiary
+import com.grid.api.models.customers.externalaccounts.UsAccountInfo
+import com.grid.sample.GridClientBuilder
+import com.grid.sample.JsonUtils
+import io.ktor.http.*
+import io.ktor.server.request.*
+import io.ktor.server.response.*
+import io.ktor.server.routing.*
+import java.time.LocalDate
+
+fun Route.externalAccountRoutes() {
+    route("/api/customers/{customerId}/external-accounts") {
+        post {
+            try {
+                val customerId = call.parameters["customerId"]
+                    ?: return@post call.respondText(
+                        """{"error": "customerId is required"}""",
+                        ContentType.Application.Json,
+                        HttpStatusCode.BadRequest
+                    )
+
+                val body = call.receiveText()
+                val json = JsonUtils.mapper.readTree(body)
+                val accountInfo = json.get("accountInfo")
+
+                val beneficiaryNode = json.get("beneficiary")
+                val beneficiary = if (beneficiaryNode != null && !beneficiaryNode.isNull) {
+                    BeneficiaryOneOf.ofIndividualBeneficiary(
+                        IndividualBeneficiary.builder()
+                            .beneficiaryType(BaseBeneficiary.BeneficiaryType.INDIVIDUAL)
+                            .fullName(beneficiaryNode.optText("fullName") ?: "")
+                            .nationality(beneficiaryNode.optText("nationality") ?: "US")
+                            .birthDate(LocalDate.parse(
+                                beneficiaryNode.optText("birthDate") ?: "1990-01-01"
+                            ))
+                            .build()
+                    )
+                } else {
+                    BeneficiaryOneOf.ofIndividualBeneficiary(
+                        IndividualBeneficiary.builder()
+                            .beneficiaryType(BaseBeneficiary.BeneficiaryType.INDIVIDUAL)
+                            .fullName("Account Holder")
+                            .nationality("US")
+                            .birthDate(LocalDate.parse("1990-01-01"))
+                            .build()
+                    )
+                }
+
+                val accountCategory = when (accountInfo.optText("accountType")?.uppercase()) {
+                    "SAVINGS" -> UsAccountInfo.AccountCategory.SAVINGS
+                    else -> UsAccountInfo.AccountCategory.CHECKING
+                }
+
+                val usAccountInfo = ExternalAccountInfoOneOf
+                    .UsAccountExternalAccountInfo.builder()
+                    .accountType(BaseExternalAccountInfo.AccountType.US_ACCOUNT)
+                    .accountCategory(accountCategory)
+                    .accountNumber(accountInfo.get("accountNumber").asText())
+                    .routingNumber(accountInfo.get("routingNumber").asText())
+                    .beneficiary(beneficiary)
+                    .build()
+
+                val externalAccountCreate = ExternalAccountCreate.builder()
+                    .accountInfo(
+                        ExternalAccountInfoOneOf.ofUsAccountExternalAccountInfo(usAccountInfo)
+                    )
+                    .currency(json.optText("currency") ?: "USD")
+                    .customerId(customerId)
+                    .apply {
+                        json.optText("platformAccountId")?.let { platformAccountId(it) }
+                    }
+                    .build()
+
+                val params = ExternalAccountCreateParams.builder()
+                    .externalAccountCreate(externalAccountCreate)
+                    .build()
+
+                val account = GridClientBuilder.client.customers().externalAccounts().create(params)
+                call.respondText(
+                    JsonUtils.prettyPrint(account),
+                    ContentType.Application.Json,
+                    HttpStatusCode.Created
+                )
+            } catch (e: Exception) {
+                call.respondText(
+                    """{"error": "${e.message}"}""",
+                    ContentType.Application.Json,
+                    HttpStatusCode.InternalServerError
+                )
+            }
+        }
+    }
+}
+
+private fun JsonNode.optText(field: String): String? =
+    if (has(field) && !get(field).isNull) get(field).asText() else null
diff --git a/samples/kotlin/src/main/kotlin/com/grid/sample/routes/Quotes.kt b/samples/kotlin/src/main/kotlin/com/grid/sample/routes/Quotes.kt
diff --git a/samples/kotlin/src/main/kotlin/com/grid/sample/routes/Sandbox.kt b/samples/kotlin/src/main/kotlin/com/grid/sample/routes/Sandbox.kt
diff --git a/samples/kotlin/src/main/kotlin/com/grid/sample/routes/Sse.kt b/samples/kotlin/src/main/kotlin/com/grid/sample/routes/Sse.kt
diff --git a/samples/kotlin/src/main/kotlin/com/grid/sample/routes/Webhooks.kt b/samples/kotlin/src/main/kotlin/com/grid/sample/routes/Webhooks.kt

Original file line number	Diff line number	Diff line change
`@@ -19,6 +19,7 @@ application {`
`19`	`19`	`}`
`20`	`20`
`21`	`21`	`repositories {`
	`22`	`+ mavenLocal()`
`22`	`23`	`mavenCentral()`
`23`	`24`	`}`
`24`	`25`
`@@ -32,7 +33,7 @@ dependencies {`
`32`	`33`	`implementation("io.ktor:ktor-server-config-yaml:3.1.3")`
`33`	`34`
`34`	`35`	`// Grid Kotlin SDK`
`35`		`- implementation("com.lightspark.grid:lightspark-grid-kotlin:0.4.0")`
	`36`	`+ implementation("com.grid.api:grid-kotlin:0.0.1")`
`36`	`37`
`37`	`38`	`// JSON`
`38`	`39`	`implementation("com.fasterxml.jackson.module:jackson-module-kotlin:2.18.2")`