Stefano Zanella stefanozanella

stefanozanella / example.kt

Created August 13, 2023 15:42

Kotlin grass missing field parsing error

	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 / Hubspot_webhook_oauth_step8_authorized_client_maanger.kt

Created August 28, 2022 19:19

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

stefanozanella / Hubspot_webhook_oauth_step7_authorized_client_maanger.kt

Created August 28, 2022 19:01

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

stefanozanella / Hubspot_webhook_oauth_step7_webclient.kt

Created August 28, 2022 18:58

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

stefanozanella / Hubspot_webhook_oauth_step7_webhook_controller.kt

Created August 28, 2022 17:49

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

stefanozanella / Hubspot_webhook_oauth_step6_1_build.kts

Last active August 27, 2022 20:08

	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 / Hubspot_webhook_oauth_step6_fetch_access_token.kt

Created August 27, 2022 19:38

	@RestController
	class WebhooksController {
	// ...

	@Autowired
	private lateinit var authorizedClientService: OAuth2AuthorizedClientService

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

stefanozanella / Hubspot_webhook_oauth_step5_fetch_deal_jnfo.kt

Created August 27, 2022 10:02

	@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 / Hubspot_webhook_oauth_step5_add_webflux.kts

Created August 27, 2022 09:52

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

stefanozanella / Hubspot_webhook_oauth_step5_disable_csrf.kt

Created August 27, 2022 09:37

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