Hubspot_webhook_oauth_step5_fetch_deal_jnfo.kt

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

  @PostMapping("/webhooks/hubspot")
  fun hubspot(@RequestBody events: List<Map<String, String>>) {
    events
      .map { event ->
        client
          .get()
          .uri("https://api.hubapi.com/crm/v3/objects/deals/{objectId}") { uri ->
            uri
              .queryParam("properties", "hubspot_owner_id,hs_arr,amount,dealstage")
              .build(event["objectId"])
          }
          .retrieve()
          .bodyToMono<String>()
          .block()
      }
      .forEach(::println)
  }
}