-
Notifications
You must be signed in to change notification settings - Fork 13
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
a333d87
commit 8735b86
Showing
2 changed files
with
166 additions
and
0 deletions.
There are no files selected for viewing
134 changes: 134 additions & 0 deletions
134
src/main/kotlin/com/ecwid/apiclient/v3/dto/webhook/Webhook.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,134 @@ | ||
package com.ecwid.apiclient.v3.dto.webhook | ||
|
||
import com.google.gson.annotations.SerializedName | ||
|
||
@Suppress("unused") | ||
data class Webhook( | ||
val eventId: String, | ||
val eventCreated: Long, | ||
val storeId: Long, | ||
val entityId: Long, | ||
val eventType: String = "", | ||
val data: Map<String, String> = emptyMap(), | ||
) { | ||
|
||
enum class EventType { | ||
@SerializedName("application.installed") | ||
APPLICATION_INSTALLED, | ||
|
||
@SerializedName("application.uninstalled") | ||
APPLICATION_UNINSTALLED, | ||
|
||
@SerializedName("application.subscription_status_changed") | ||
APPLICATION_SUBSCRIPTION_STATUS_CHANGED, | ||
|
||
@SerializedName("application.storage_changed") | ||
APPLICATION_STORAGE_CHANGED, | ||
|
||
@SerializedName("category.created") | ||
CATEGORY_CREATED, | ||
|
||
@SerializedName("category.deleted") | ||
CATEGORY_DELETED, | ||
|
||
@SerializedName("category.updated") | ||
CATEGORY_UPDATED, | ||
|
||
@SerializedName("customer.created") | ||
CUSTOMER_CREATED, | ||
|
||
@SerializedName("customer.deleted") | ||
CUSTOMER_DELETED, | ||
|
||
@SerializedName("customer.updated") | ||
CUSTOMER_UPDATED, | ||
|
||
@SerializedName("customer.personal_data_removal_request") | ||
CUSTOMER_PERSONAL_DATA_REMOVAL_REQUEST, | ||
|
||
@SerializedName("customer.personal_data_export_request") | ||
CUSTOMER_PERSONAL_DATA_EXPORT_REQUEST, | ||
|
||
@SerializedName("order.created") | ||
ORDER_CREATED, | ||
|
||
@SerializedName("order.deleted") | ||
ORDER_DELETED, | ||
|
||
@SerializedName("order.updated") | ||
ORDER_UPDATED, | ||
|
||
@SerializedName("product.created") | ||
PRODUCT_CREATED, | ||
|
||
@SerializedName("product.deleted") | ||
PRODUCT_DELETED, | ||
|
||
@SerializedName("product.updated") | ||
PRODUCT_UPDATED, | ||
|
||
@SerializedName("product_class.created") | ||
PRODUCT_CLASS_CREATED, | ||
|
||
@SerializedName("product_class.deleted") | ||
PRODUCT_CLASS_DELETED, | ||
|
||
@SerializedName("product_class.updated") | ||
PRODUCT_CLASS_UPDATED, | ||
|
||
@SerializedName("review.created") | ||
REVIEW_CREATED, | ||
|
||
@SerializedName("review.deleted") | ||
REVIEW_DELETED, | ||
|
||
@SerializedName("review.updated") | ||
REVIEW_UPDATED, | ||
|
||
@SerializedName("profile.updated") | ||
PROFILE_UPDATED, | ||
|
||
@SerializedName("profile.subscription_status_changed") | ||
PROFILE_SUBSCRIPTION_STATUS_CHANGED, | ||
|
||
@SerializedName("profile.personal_data_removal_request") | ||
PROFILE_PERSONAL_DATA_REMOVAL_REQUEST, | ||
|
||
@SerializedName("profile.personal_data_export_request") | ||
PROFILE_PERSONAL_DATA_EXPORT_REQUEST, | ||
|
||
@SerializedName("unfinished_order.created") | ||
UNFINISHED_ORDER_CREATED, | ||
|
||
@SerializedName("unfinished_order.deleted") | ||
UNFINISHED_ORDER_DELETED, | ||
|
||
@SerializedName("unfinished_order.updated") | ||
UNFINISHED_ORDER_UPDATED, | ||
|
||
@SerializedName("discount_coupon.created") | ||
DISCOUNT_COUPON_CREATED, | ||
|
||
@SerializedName("discount_coupon.deleted") | ||
DISCOUNT_COUPON_DELETED, | ||
|
||
@SerializedName("discount_coupon.updated") | ||
DISCOUNT_COUPON_UPDATED, | ||
|
||
@SerializedName("invoice.created") | ||
INVOICE_CREATED, | ||
|
||
@SerializedName("invoice.deleted") | ||
INVOICE_DELETED, | ||
|
||
@SerializedName("promotion.created") | ||
PROMOTION_CREATED, | ||
|
||
@SerializedName("promotion.deleted") | ||
PROMOTION_DELETED, | ||
|
||
@SerializedName("promotion.updated") | ||
PROMOTION_UPDATED, | ||
} | ||
|
||
} |
32 changes: 32 additions & 0 deletions
32
src/main/kotlin/com/ecwid/apiclient/v3/dto/webhook/WebhooksUtils.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,32 @@ | ||
package com.ecwid.apiclient.v3.dto.webhook | ||
|
||
import org.apache.commons.codec.binary.Base64 | ||
import org.apache.commons.codec.digest.HmacAlgorithms | ||
import org.apache.commons.codec.digest.HmacUtils | ||
|
||
@Suppress("unused") | ||
object WebhooksUtils { | ||
|
||
const val WEBHOOK_SIGNATURE_HEADER_NAME = "X-Ecwid-Webhook-Signature" | ||
|
||
/** | ||
* Webhook signature verification | ||
* @param signature - webhook signature obtained from the X-Ecwid-Webhook-Signature header | ||
* @param webhook - the webhook itself, for which you need to check the signature | ||
* @param clientSecret - clientSecret of the application for which the webhook was sent | ||
* @return true if the signature is valid | ||
*/ | ||
@JvmStatic | ||
fun isSignatureValid(signature: String?, webhook: Webhook?, clientSecret: String): Boolean { | ||
if (webhook == null || signature.isNullOrEmpty()) { | ||
return false | ||
} | ||
|
||
val bt = HmacUtils(HmacAlgorithms.HMAC_SHA_256, clientSecret) | ||
.hmac("${webhook.eventCreated}.${webhook.eventId}") | ||
val result = Base64.encodeBase64String(bt) | ||
|
||
return signature == result | ||
} | ||
|
||
} |