Add webhook for pending transactions

Author: Ugo Lambert

src/main/java/com/ibanity/apis/client/utils/WebhooksUtils.java

@@ -94,6 +94,10 @@ private static IbanityWebhookEvent parsePontoConnectEvent(String payload, String
                 return mapWebhookResource(payload, com.ibanity.apis.client.webhooks.models.ponto_connect.AccountTransactionsCreated.mappingFunction());
             case com.ibanity.apis.client.webhooks.models.ponto_connect.AccountTransactionsUpdated.TYPE:
                 return mapWebhookResource(payload, com.ibanity.apis.client.webhooks.models.ponto_connect.AccountTransactionsUpdated.mappingFunction());
+                        case com.ibanity.apis.client.webhooks.models.ponto_connect.AccountPendingTransactionsCreated.TYPE:
+                return mapWebhookResource(payload, com.ibanity.apis.client.webhooks.models.ponto_connect.AccountPendingTransactionsCreated.mappingFunction());
+            case com.ibanity.apis.client.webhooks.models.ponto_connect.AccountPendingTransactionsUpdated.TYPE:
+                return mapWebhookResource(payload, com.ibanity.apis.client.webhooks.models.ponto_connect.AccountPendingTransactionsUpdated.mappingFunction());
             case com.ibanity.apis.client.webhooks.models.ponto_connect.SynchronizationFailed.TYPE:
                 return mapWebhookResource(payload, com.ibanity.apis.client.webhooks.models.ponto_connect.SynchronizationFailed.mappingFunction());
             case com.ibanity.apis.client.webhooks.models.ponto_connect.SynchronizationSucceededWithoutChange.TYPE:

src/main/java/com/ibanity/apis/client/webhooks/models/ponto_connect/AccountPendingTransactionsCreated.java

@@ -0,0 +1,57 @@
+package com.ibanity.apis.client.webhooks.models.ponto_connect;
+
+import com.ibanity.apis.client.jsonapi.DataApiModel;
+import com.ibanity.apis.client.jsonapi.RelationshipsApiModel;
+import com.ibanity.apis.client.models.IbanityWebhookEvent;
+import lombok.AccessLevel;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+import java.time.Instant;
+import java.util.UUID;
+import java.util.function.Function;
+
+import static com.ibanity.apis.client.mappers.IbanityWebhookEventMapper.toIbanityWebhooks;
+import static java.util.UUID.fromString;
+
+@Data
+@SuperBuilder(toBuilder = true)
+@NoArgsConstructor
+@AllArgsConstructor(access = AccessLevel.PRIVATE)
+public class AccountPendingTransactionsCreated implements IbanityWebhookEvent {
+
+    public final static String TYPE = "pontoConnect.account.pendingTransactionsCreated";
+
+    private UUID id;
+    private String type;
+    private UUID accountId;
+    private int count;
+    private UUID synchronizationId;
+    private UUID organizationId;
+    private Instant createdAt;
+
+    public static Function<DataApiModel, AccountPendingTransactionsCreated> mappingFunction() {
+        return dataApiModel -> {
+            AccountPendingTransactionsCreated accountPendingTransactionsCreated = toIbanityWebhooks(dataApiModel, AccountPendingTransactionsCreated.class);
+
+            RelationshipsApiModel accountRelationship = dataApiModel.getRelationships().get("account");
+            if (accountRelationship != null) {
+                accountPendingTransactionsCreated.setAccountId(fromString(accountRelationship.getData().getId()));
+            }
+
+            RelationshipsApiModel synchronizationRelationship = dataApiModel.getRelationships().get("synchronization");
+            if (synchronizationRelationship != null) {
+                accountPendingTransactionsCreated.setSynchronizationId(fromString(synchronizationRelationship.getData().getId()));
+            }
+
+            RelationshipsApiModel organizationRelationship = dataApiModel.getRelationships().get("organization");
+            if (organizationRelationship != null) {
+                accountPendingTransactionsCreated.setOrganizationId(fromString(organizationRelationship.getData().getId()));
+            }
+
+            return accountPendingTransactionsCreated;
+        };
+    }
+}

src/main/java/com/ibanity/apis/client/webhooks/models/ponto_connect/AccountPendingTransactionsUpdated.java

@@ -0,0 +1,57 @@
+package com.ibanity.apis.client.webhooks.models.ponto_connect;
+
+import com.ibanity.apis.client.jsonapi.DataApiModel;
+import com.ibanity.apis.client.jsonapi.RelationshipsApiModel;
+import com.ibanity.apis.client.models.IbanityWebhookEvent;
+import lombok.AccessLevel;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+import java.time.Instant;
+import java.util.UUID;
+import java.util.function.Function;
+
+import static com.ibanity.apis.client.mappers.IbanityWebhookEventMapper.toIbanityWebhooks;
+import static java.util.UUID.fromString;
+
+@Data
+@SuperBuilder(toBuilder = true)
+@NoArgsConstructor
+@AllArgsConstructor(access = AccessLevel.PRIVATE)
+public class AccountPendingTransactionsUpdated implements IbanityWebhookEvent {
+
+    public final static String TYPE = "pontoConnect.account.pendingTransactionsUpdated";
+
+    private UUID id;
+    private String type;
+    private UUID accountId;
+    private UUID synchronizationId;
+    private UUID organizationId;
+    private int count;
+    private Instant createdAt;
+
+    public static Function<DataApiModel, AccountPendingTransactionsUpdated> mappingFunction() {
+        return dataApiModel -> {
+            AccountPendingTransactionsUpdated accountPendingTransactionsUpdated = toIbanityWebhooks(dataApiModel, AccountPendingTransactionsUpdated.class);
+
+            RelationshipsApiModel accountRelationship = dataApiModel.getRelationships().get("account");
+            if (accountRelationship != null) {
+                accountPendingTransactionsUpdated.setAccountId(fromString(accountRelationship.getData().getId()));
+            }
+
+            RelationshipsApiModel synchronizationRelationship = dataApiModel.getRelationships().get("synchronization");
+            if (synchronizationRelationship != null) {
+                accountPendingTransactionsUpdated.setSynchronizationId(fromString(synchronizationRelationship.getData().getId()));
+            }
+
+            RelationshipsApiModel organizationRelationship = dataApiModel.getRelationships().get("organization");
+            if (organizationRelationship != null) {
+                accountPendingTransactionsUpdated.setOrganizationId(fromString(organizationRelationship.getData().getId()));
+            }
+
+            return accountPendingTransactionsUpdated;
+        };
+    }
+}