stefanozanella

import com.github.doyaaaaaken.kotlincsv.dsl.csvReader
import io.blackmo18.kotlin.grass.dsl.grass

val csv = """
firstName,lastName,email
John,Doe,[email protected]    
""".trimIndent()

data class Contact(
    val firstName: String?,

stefanozanella

@Bean
fun authorizedClientManager(
  clientRegistrationRepository: ClientRegistrationRepository,
  authorizedClientService: OAuth2AuthorizedClientService,
) =
  AuthorizedClientServiceOAuth2AuthorizedClientManager(
    clientRegistrationRepository,
    authorizedClientService,
  ).apply {
    setAuthorizedClientProvider(

stefanozanella

  @Bean
  fun authorizedClientManager(
    clientRegistrationRepository: ClientRegistrationRepository,
    authorizedClientService: OAuth2AuthorizedClientService,
  ) =
    AuthorizedClientServiceOAuth2AuthorizedClientManager(
      clientRegistrationRepository,
      authorizedClientService,
    ).apply {
      setAuthorizedClientProvider(

stefanozanella

@Bean
fun webClient(authorizedClientManager: OAuth2AuthorizedClientManager): WebClient =
  WebClient
    .builder()
    .apply(
      ServletOAuth2AuthorizedClientExchangeFilterFunction(
        authorizedClientManager
      ).oauth2Configuration()
    )
    .build()

stefanozanella

client
  // ...
  .attributes(
    ServerOAuth2AuthorizedClientExchangeFilterFunction
      .oauth2AuthorizedClient(
        authorizedClientService.loadAuthorizedClient("hubspot", event["portalId"])
      )
  )
  .retrieve()
  .bodyToMono<String>()

stefanozanella

dependencies {
  // ...
  implementation("org.springframework.boot:spring-boot-starter-jdbc")
	implementation("org.flywaydb:flyway-core") // Optional, but highly recommended
	implementation("org.postgresql:postgresql") // Add the driver for your favourite database here
}

stefanozanella

@RestController
class WebhooksController {
  // ...
  
  @Autowired
  private lateinit var authorizedClientService: OAuth2AuthorizedClientService

  @PostMapping("/webhooks/hubspot")
  fun hubspot(@RequestBody events: List<Map<String, String>>) {
    events

stefanozanella

@RestController
class WebhooksController {
  @Autowired
  private lateinit var client: WebClient

  @PostMapping("/webhooks/hubspot")
  fun hubspot(@RequestBody events: List<Map<String, String>>) {
    events
      .map { event ->
        client

stefanozanella

dependencies {
  // ...
  implementation("org.springframework.boot:spring-boot-starter-webflux")
  // ...  
}

stefanozanella

  @Bean
  fun oauth2Configuration(http: HttpSecurity): SecurityFilterChain =
    http
      .oauth2Client()
      // ...
      .and().and()
      .csrf().disable()
      .build()