feat: typed webhook events (catalog v2, 50 events)

src/main/java/co/commet/WebhookEvent.java

@@ -0,0 +1,281 @@
+package co.commet;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+import co.commet.models.WebhookEventType;
+
+import co.commet.models.SubscriptionCreatedData;
+import co.commet.models.SubscriptionActivatedData;
+import co.commet.models.SubscriptionCanceledData;
+import co.commet.models.SubscriptionUpdatedData;
+import co.commet.models.SubscriptionPlanChangedData;
+import co.commet.models.SubscriptionCancellationScheduledData;
+import co.commet.models.SubscriptionCancellationRevokedData;
+import co.commet.models.SubscriptionPlanChangeScheduledData;
+import co.commet.models.SubscriptionPlanChangeRevokedData;
+import co.commet.models.SubscriptionPastDueData;
+import co.commet.models.TrialStartedData;
+import co.commet.models.TrialConvertedData;
+import co.commet.models.TrialExpiredData;
+import co.commet.models.TrialWillEndData;
+import co.commet.models.TrialCheckoutReadyData;
+import co.commet.models.CheckoutReadyData;
+import co.commet.models.PaymentReceivedData;
+import co.commet.models.PaymentFailedData;
+import co.commet.models.PaymentRecoveredData;
+import co.commet.models.PaymentRefundedData;
+import co.commet.models.PaymentDisputedData;
+import co.commet.models.PaymentDisputeResolvedData;
+import co.commet.models.InvoiceCreatedData;
+import co.commet.models.InvoiceUpcomingData;
+import co.commet.models.InvoiceOverdueData;
+import co.commet.models.InvoiceVoidedData;
+import co.commet.models.PaymentMethodAttachedData;
+import co.commet.models.PaymentMethodUpdatedData;
+import co.commet.models.CustomerCreatedData;
+import co.commet.models.CustomerUpdatedData;
+import co.commet.models.CustomerStateChangedData;
+import co.commet.models.CreditsGrantedData;
+import co.commet.models.CreditsPurchasedData;
+import co.commet.models.CreditsLowData;
+import co.commet.models.CreditsDepletedData;
+import co.commet.models.CreditsExpiredData;
+import co.commet.models.BalanceToppedUpData;
+import co.commet.models.BalanceLowData;
+import co.commet.models.BalanceDepletedData;
+import co.commet.models.QuotaThresholdReachedData;
+import co.commet.models.QuotaExceededData;
+import co.commet.models.UsageRecordedData;
+import co.commet.models.SeatsUpdatedData;
+import co.commet.models.SeatsLimitReachedData;
+import co.commet.models.AddonActivatedData;
+import co.commet.models.AddonDeactivatedData;
+import co.commet.models.PayoutAvailableData;
+import co.commet.models.PayoutCreatedData;
+import co.commet.models.PayoutPaidData;
+import co.commet.models.PayoutFailedData;
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+public record WebhookEvent(
+        @JsonProperty("event") WebhookEventType event,
+        @JsonProperty("timestamp") String timestamp,
+        @JsonProperty("organizationId") String organizationId,
+        @JsonProperty("mode") String mode,
+        @JsonProperty("apiVersion") String apiVersion,
+        @JsonProperty("data") JsonNode data
+) {
+
+    private static final ObjectMapper MAPPER =
+            new ObjectMapper().findAndRegisterModules();
+
+    private <T> T convert(Class<T> type) {
+        try {
+            return MAPPER.treeToValue(data, type);
+        } catch (Exception e) {
+            throw new RuntimeException("Failed to parse webhook data as " + type.getSimpleName(), e);
+        }
+    }
+
+    public SubscriptionCreatedData asSubscriptionCreated() {
+        return convert(SubscriptionCreatedData.class);
+    }
+
+    public SubscriptionActivatedData asSubscriptionActivated() {
+        return convert(SubscriptionActivatedData.class);
+    }
+
+    public SubscriptionCanceledData asSubscriptionCanceled() {
+        return convert(SubscriptionCanceledData.class);
+    }
+
+    public SubscriptionUpdatedData asSubscriptionUpdated() {
+        return convert(SubscriptionUpdatedData.class);
+    }
+
+    public SubscriptionPlanChangedData asSubscriptionPlanChanged() {
+        return convert(SubscriptionPlanChangedData.class);
+    }
+
+    public SubscriptionCancellationScheduledData asSubscriptionCancellationScheduled() {
+        return convert(SubscriptionCancellationScheduledData.class);
+    }
+
+    public SubscriptionCancellationRevokedData asSubscriptionCancellationRevoked() {
+        return convert(SubscriptionCancellationRevokedData.class);
+    }
+
+    public SubscriptionPlanChangeScheduledData asSubscriptionPlanChangeScheduled() {
+        return convert(SubscriptionPlanChangeScheduledData.class);
+    }
+
+    public SubscriptionPlanChangeRevokedData asSubscriptionPlanChangeRevoked() {
+        return convert(SubscriptionPlanChangeRevokedData.class);
+    }
+
+    public SubscriptionPastDueData asSubscriptionPastDue() {
+        return convert(SubscriptionPastDueData.class);
+    }
+
+    public TrialStartedData asTrialStarted() {
+        return convert(TrialStartedData.class);
+    }
+
+    public TrialConvertedData asTrialConverted() {
+        return convert(TrialConvertedData.class);
+    }
+
+    public TrialExpiredData asTrialExpired() {
+        return convert(TrialExpiredData.class);
+    }
+
+    public TrialWillEndData asTrialWillEnd() {
+        return convert(TrialWillEndData.class);
+    }
+
+    public TrialCheckoutReadyData asTrialCheckoutReady() {
+        return convert(TrialCheckoutReadyData.class);
+    }
+
+    public CheckoutReadyData asCheckoutReady() {
+        return convert(CheckoutReadyData.class);
+    }
+
+    public PaymentReceivedData asPaymentReceived() {
+        return convert(PaymentReceivedData.class);
+    }
+
+    public PaymentFailedData asPaymentFailed() {
+        return convert(PaymentFailedData.class);
+    }
+
+    public PaymentRecoveredData asPaymentRecovered() {
+        return convert(PaymentRecoveredData.class);
+    }
+
+    public PaymentRefundedData asPaymentRefunded() {
+        return convert(PaymentRefundedData.class);
+    }
+
+    public PaymentDisputedData asPaymentDisputed() {
+        return convert(PaymentDisputedData.class);
+    }
+
+    public PaymentDisputeResolvedData asPaymentDisputeResolved() {
+        return convert(PaymentDisputeResolvedData.class);
+    }
+
+    public InvoiceCreatedData asInvoiceCreated() {
+        return convert(InvoiceCreatedData.class);
+    }
+
+    public InvoiceUpcomingData asInvoiceUpcoming() {
+        return convert(InvoiceUpcomingData.class);
+    }
+
+    public InvoiceOverdueData asInvoiceOverdue() {
+        return convert(InvoiceOverdueData.class);
+    }
+
+    public InvoiceVoidedData asInvoiceVoided() {
+        return convert(InvoiceVoidedData.class);
+    }
+
+    public PaymentMethodAttachedData asPaymentMethodAttached() {
+        return convert(PaymentMethodAttachedData.class);
+    }
+
+    public PaymentMethodUpdatedData asPaymentMethodUpdated() {
+        return convert(PaymentMethodUpdatedData.class);
+    }
+
+    public CustomerCreatedData asCustomerCreated() {
+        return convert(CustomerCreatedData.class);
+    }
+
+    public CustomerUpdatedData asCustomerUpdated() {
+        return convert(CustomerUpdatedData.class);
+    }
+
+    public CustomerStateChangedData asCustomerStateChanged() {
+        return convert(CustomerStateChangedData.class);
+    }
+
+    public CreditsGrantedData asCreditsGranted() {
+        return convert(CreditsGrantedData.class);
+    }
+
+    public CreditsPurchasedData asCreditsPurchased() {
+        return convert(CreditsPurchasedData.class);
+    }
+
+    public CreditsLowData asCreditsLow() {
+        return convert(CreditsLowData.class);
+    }
+
+    public CreditsDepletedData asCreditsDepleted() {
+        return convert(CreditsDepletedData.class);
+    }
+
+    public CreditsExpiredData asCreditsExpired() {
+        return convert(CreditsExpiredData.class);
+    }
+
+    public BalanceToppedUpData asBalanceToppedUp() {
+        return convert(BalanceToppedUpData.class);
+    }
+
+    public BalanceLowData asBalanceLow() {
+        return convert(BalanceLowData.class);
+    }
+
+    public BalanceDepletedData asBalanceDepleted() {
+        return convert(BalanceDepletedData.class);
+    }
+
+    public QuotaThresholdReachedData asQuotaThresholdReached() {
+        return convert(QuotaThresholdReachedData.class);
+    }
+
+    public QuotaExceededData asQuotaExceeded() {
+        return convert(QuotaExceededData.class);
+    }
+
+    public UsageRecordedData asUsageRecorded() {
+        return convert(UsageRecordedData.class);
+    }
+
+    public SeatsUpdatedData asSeatsUpdated() {
+        return convert(SeatsUpdatedData.class);
+    }
+
+    public SeatsLimitReachedData asSeatsLimitReached() {
+        return convert(SeatsLimitReachedData.class);
+    }
+
+    public AddonActivatedData asAddonActivated() {
+        return convert(AddonActivatedData.class);
+    }
+
+    public AddonDeactivatedData asAddonDeactivated() {
+        return convert(AddonDeactivatedData.class);
+    }
+
+    public PayoutAvailableData asPayoutAvailable() {
+        return convert(PayoutAvailableData.class);
+    }
+
+    public PayoutCreatedData asPayoutCreated() {
+        return convert(PayoutCreatedData.class);
+    }
+
+    public PayoutPaidData asPayoutPaid() {
+        return convert(PayoutPaidData.class);
+    }
+
+    public PayoutFailedData asPayoutFailed() {
+        return convert(PayoutFailedData.class);
+    }
+}

src/main/java/co/commet/models/AddonActivatedData.java

@@ -0,0 +1,14 @@
+package co.commet.models;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+public record AddonActivatedData(
+        @JsonProperty("subscriptionId") String subscriptionId,
+        @JsonProperty("customerId") String customerId,
+        @JsonProperty("addon") WebhookAddonRef addon,
+        @JsonProperty("featureCode") String featureCode,
+        @JsonProperty("proratedPrice") double proratedPrice,
+        @JsonProperty("currency") String currency
+) {}

src/main/java/co/commet/models/AddonDeactivatedData.java

@@ -0,0 +1,12 @@
+package co.commet.models;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+public record AddonDeactivatedData(
+        @JsonProperty("subscriptionId") String subscriptionId,
+        @JsonProperty("customerId") String customerId,
+        @JsonProperty("addon") WebhookAddonRef addon,
+        @JsonProperty("featureCode") String featureCode
+) {}

src/main/java/co/commet/models/BalanceDepletedData.java

@@ -0,0 +1,12 @@
+package co.commet.models;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+public record BalanceDepletedData(
+        @JsonProperty("subscriptionId") String subscriptionId,
+        @JsonProperty("customerId") String customerId,
+        @JsonProperty("currentBalance") double currentBalance,
+        @JsonProperty("currency") String currency
+) {}

src/main/java/co/commet/models/BalanceLowData.java

@@ -0,0 +1,13 @@
+package co.commet.models;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+public record BalanceLowData(
+        @JsonProperty("subscriptionId") String subscriptionId,
+        @JsonProperty("customerId") String customerId,
+        @JsonProperty("currentBalance") double currentBalance,
+        @JsonProperty("thresholdBalance") double thresholdBalance,
+        @JsonProperty("currency") String currency
+) {}

src/main/java/co/commet/models/BalanceToppedUpData.java

@@ -0,0 +1,14 @@
+package co.commet.models;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+public record BalanceToppedUpData(
+        @JsonProperty("subscriptionId") String subscriptionId,
+        @JsonProperty("customerId") String customerId,
+        @JsonProperty("invoiceId") String invoiceId,
+        @JsonProperty("invoiceNumber") String invoiceNumber,
+        @JsonProperty("amount") double amount,
+        @JsonProperty("currency") String currency
+) {}

src/main/java/co/commet/models/CheckoutReadyData.java

@@ -0,0 +1,15 @@
+package co.commet.models;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+public record CheckoutReadyData(
+        @JsonProperty("subscriptionId") String subscriptionId,
+        @JsonProperty("customerId") String customerId,
+        @JsonProperty("invoiceId") String invoiceId,
+        @JsonProperty("invoiceNumber") String invoiceNumber,
+        @JsonProperty("invoiceTotal") double invoiceTotal,
+        @JsonProperty("invoiceCurrency") String invoiceCurrency,
+        @JsonProperty("checkoutUrl") String checkoutUrl
+) {}

src/main/java/co/commet/models/CreditsDepletedData.java

@@ -0,0 +1,11 @@
+package co.commet.models;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+public record CreditsDepletedData(
+        @JsonProperty("subscriptionId") String subscriptionId,
+        @JsonProperty("customerId") String customerId,
+        @JsonProperty("remainingCredits") double remainingCredits
+) {}

src/main/java/co/commet/models/CreditsExpiredData.java

@@ -0,0 +1,11 @@
+package co.commet.models;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+public record CreditsExpiredData(
+        @JsonProperty("subscriptionId") String subscriptionId,
+        @JsonProperty("customerId") String customerId,
+        @JsonProperty("expiredCredits") double expiredCredits
+) {}