[BKNDLSS-34230]: Add findCustomers method

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>com.chargify</groupId>
     <artifactId>chargify-sdk</artifactId>
-    <version>0.2.7</version>
+    <version>0.44</version>
     <packaging>jar</packaging>
 
     <name>Chargify SDK for Java</name>
@@ -16,14 +16,14 @@
     <licenses>
         <license>
             <name>The Apache License, Version 2.0</name>
-            <url>http://www.apache.org/licenses/LICENSE-2.0.txt</url>
+            <url>https://www.apache.org/licenses/LICENSE-2.0.txt</url>
         </license>
     </licenses>
 
     <developers>
         <developer>
-            <name>Sergey Chupov</name>
-            <email>scadgek@live.com</email>
+            <name>Backendless</name>
+            <email>chargify-sdk-for-java@backendless.com</email>
             <organization>Backendless</organization>
             <organizationUrl>https://backendless.com/</organizationUrl>
         </developer>
@@ -32,67 +32,100 @@
     <scm>
         <connection>scm:git:git://github.com/scadgek/chargify-java-sdk.git</connection>
         <developerConnection>scm:git:ssh://github.com:scadgek/chargify-java-sdk.git</developerConnection>
-        <url>http://github.com/github.com/scadgek/chargify-java-sdk/tree/master</url>
+        <url>https://github.com/github.com/scadgek/chargify-java-sdk/tree/master</url>
     </scm>
 
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-        <maven.compiler.source>1.8</maven.compiler.source>
-        <maven.compiler.target>1.8</maven.compiler.target>
+        <maven.compiler.source>17</maven.compiler.source>
+        <maven.compiler.target>17</maven.compiler.target>
+        <repo.bkndls_private>backendless_private</repo.bkndls_private>
+        <repo.bkndls_private.url>https://maven.backendless.com/repository/backendless_private/
+        </repo.bkndls_private.url>
     </properties>
 
     <dependencies>
         <dependency>
             <groupId>org.springframework</groupId>
-            <artifactId>spring-web</artifactId>
-            <version>5.0.5.RELEASE</version>
-        </dependency>
-
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot</artifactId>
-            <version>2.0.1.RELEASE</version>
+            <artifactId>spring-webflux</artifactId>
+            <version>6.0.12</version>
+            <scope>provided</scope>
         </dependency>
 
         <dependency>
             <groupId>com.fasterxml.jackson.core</groupId>
             <artifactId>jackson-databind</artifactId>
-            <version>2.9.5</version>
+            <version>2.14.3</version>
+            <scope>provided</scope>
         </dependency>
 
         <dependency>
             <groupId>com.fasterxml.jackson.datatype</groupId>
             <artifactId>jackson-datatype-jsr310</artifactId>
-            <version>2.9.5</version>
+            <version>2.14.3</version>
+            <scope>provided</scope>
         </dependency>
 
         <dependency>
             <groupId>ch.qos.logback</groupId>
             <artifactId>logback-classic</artifactId>
-            <version>1.2.3</version>
+            <version>1.4.11</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>3.12.0</version>
+        </dependency>
+
+        <dependency>
+            <groupId>io.projectreactor.netty</groupId>
+            <artifactId>reactor-netty</artifactId>
+            <version>1.1.11</version>
+            <scope>provided</scope>
+        </dependency>
+
+
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.28</version>
+            <scope>provided</scope>
         </dependency>
 
         <dependency>
             <groupId>junit</groupId>
             <artifactId>junit</artifactId>
-            <version>4.12</version>
+            <version>4.13.2</version>
             <scope>test</scope>
         </dependency>
 
         <dependency>
             <groupId>org.springframework</groupId>
             <artifactId>spring-test</artifactId>
-            <version>5.0.5.RELEASE</version>
+            <version>6.0.12</version>
             <scope>test</scope>
         </dependency>
 
     </dependencies>
 
+    <distributionManagement>
+        <snapshotRepository>
+            <id>${repo.bkndls_private}</id>
+            <url>${repo.bkndls_private.url}snapshots/</url>
+        </snapshotRepository>
+        <repository>
+            <id>${repo.bkndls_private}</id>
+            <url>${repo.bkndls_private.url}</url>
+        </repository>
+    </distributionManagement>
+
     <build>
         <plugins>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-source-plugin</artifactId>
+                <version>3.2.1</version>
                 <executions>
                     <execution>
                         <id>attach-sources</id>
@@ -105,6 +138,7 @@
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-javadoc-plugin</artifactId>
+                <version>3.3.1</version>
                 <executions>
                     <execution>
                         <id>attach-javadocs</id>
@@ -114,7 +148,16 @@
                     </execution>
                 </executions>
             </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>17</source>
+                    <target>17</target>
+                </configuration>
+
+            </plugin>
         </plugins>
     </build>
 
-</project>
+</project>

src/main/java/com/chargify/Chargify.java

@@ -1,99 +1,159 @@
 package com.chargify;
 
-import com.chargify.model.Allocation;
-import com.chargify.model.Component;
-import com.chargify.model.ComponentPricePointUpdate;
-import com.chargify.model.Customer;
-import com.chargify.model.Metadata;
-import com.chargify.model.Product;
-import com.chargify.model.ProductFamily;
-import com.chargify.model.ReferralCode;
-import com.chargify.model.RenewalPreview;
-import com.chargify.model.Subscription;
-import com.chargify.model.SubscriptionComponent;
-import com.chargify.model.SubscriptionMetadata;
-import com.chargify.model.Usage;
-
+import com.chargify.model.*;
+import com.chargify.model.product.Product;
+import com.chargify.model.product.ProductFamily;
+import com.chargify.model.product.ProductPricePoint;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+import java.time.LocalDateTime;
 import java.util.List;
 
 public interface Chargify
 {
-  ProductFamily createProductFamily( ProductFamily productFamily );
+  Mono<ProductFamily> createProductFamily( ProductFamily productFamily );
+
+  Mono<ProductFamily> findProductFamilyById( String id );
+
+  Flux<ProductFamily> findAllProductFamilies();
+
+  Mono<ProductFamily> archiveProductFamilyById( String id );
+
+  Mono<Product> createProduct( String productFamilyId, Product product );
+
+  Mono<Product> findProductById( String id );
+
+  Mono<Product> findProductByApiHandle( String apiHandle );
+
+  Flux<ProductPricePoint> findProductPricePointsByProductId( String productId );
+
+  Flux<PricePoint> findComponentPricePoints( int componentId );
+
+  Mono<PricePoint> updatePricePoint( int componentId, int pricePointId, PricePointUpdate pricePointUpdate );
+
+  Flux<Product> findAllProducts();
+
+  Flux<Product> findProductsByProductFamilyId( String productFamilyId );
+
+  Mono<Product> archiveProductById( String id );
+
+  Mono<Subscription> createSubscription( CreateSubscription subscription );
 
-  ProductFamily findProductFamilyById( String id );
+  Mono<Void> updateSubscription( String subscriptionId, UpdateSubscription subscription );
 
-  List<ProductFamily> findAllProductFamilies();
+  Mono<Void> updateSubscriptionNextBillingDate( String subscriptionId, LocalDateTime nextBillingDate );
 
-  ProductFamily archiveProductFamilyById( String id );
+  Mono<SubscriptionChargeResult> createSubscriptionCharge( String subscriptionId, SubscriptionCharge subscriptionCharge );
 
-  Product createProduct( String productFamilyId, Product product );
+  Mono<Subscription> findSubscriptionById( String id );
 
-  Product findProductById( String id );
+  Flux<PaymentProfile> findPaymentProfilesForCustomer( String customerId );
 
-  Product findProductByApiHandle( String apiHandle );
+  Mono<PaymentProfile> createPaymentProfile( CreatePaymentProfile paymentProfile );
 
-  List<Product> findAllProducts();
+  Mono<Void> updatePaymentProfile( String paymentProfileId, UpdatePaymentProfile paymentProfile );
 
-  List<Product> findProductsByProductFamilyId( String productFamilyId );
+  Mono<PaymentProfile> updateSubscriptionPaymentProfile( String subscriptionId, String paymentProfileId );
 
-  Product archiveProductById( String id );
+  Mono<PaymentProfile> findPaymentProfileById( String paymentProfileId );
 
-  Subscription createSubscription( Subscription subscription );
+  Mono<Void> deleteUnusedPaymentProfile( String paymentProfileId );
 
-  Subscription findSubscriptionById( String id );
+  Mono<Void> deletePaymentProfile( String subscriptionId, String paymentProfileId );
 
-  List<Subscription> findSubscriptionsByCustomerId( String customerId );
+  Flux<Subscription> findSubscriptionsByCustomerId( String customerId );
 
-  List<Subscription> findAllSubscriptions();
+  Flux<Subscription> findSubscriptionsByCustomerId( String customerId, int pageNumber, int pageSize );
 
-  List<Subscription> findSubscriptionsByState( String state, int pageNumber, int pageSize );
+  Flux<Subscription> findAllSubscriptions();
 
-  Subscription cancelSubscriptionById( String id );
+  Mono<Subscription> purgeSubscription( Subscription subscription );
 
-  Subscription cancelSubscriptionProductChange( String subscriptionId );
+  Flux<Subscription> findSubscriptionsByState( String state, int pageNumber, int pageSize );
 
-  Subscription migrateSubscription( String subscriptionId, String productHandle );
+  Mono<Subscription> cancelSubscriptionById( String id );
 
-  Subscription reactivateSubscription( String subscriptionId );
+  Mono<Subscription> cancelSubscriptionProductChange( String subscriptionId );
 
-  ComponentPricePointUpdate migrateSubscriptionComponentToPricePoint( String subscriptionId, int componentId,
+  Mono<Subscription> migrateSubscription( String subscriptionId, Migration migration );
+
+  Mono<Subscription> reactivateSubscription( String subscriptionId, boolean preserveBalance );
+
+  Mono<Subscription> reactivateSubscription( String subscriptionId, SubscriptionReactivationData reactivationData );
+
+  Mono<ComponentPricePointUpdate> migrateSubscriptionComponentToPricePoint( String subscriptionId, int componentId,
                                                                       String pricePointHandle );
 
-  Subscription changeSubscriptionProduct( String subscriptionId, String productHandle, boolean delayed );
+  Flux<ComponentPricePointUpdate> bulkUpdateSubscriptionComponentPricePoint( String subscriptionId, List<ComponentPricePointUpdate> items );
+
+  Mono<Subscription> cancelScheduledSubscriptionProductChange( String subscriptionId );
+
+  Mono<Subscription> changeSubscriptionProduct( String subscriptionId, SubscriptionProductUpdate payload );
+
+  Mono<RenewalPreview> previewSubscriptionRenewal( String subscriptionId );
+
+  Flux<Metadata> createSubscriptionMetadata( String subscriptionId, Metadata... metadata );
+
+  Mono<SubscriptionMetadata> readSubscriptionMetadata( String subscriptionId );
+
+  Flux<Metadata> updateSubscriptionMetadata( String subscriptionId, Metadata... metadata );
+
+  Mono<Component> createComponent( String productFamilyId, Component component );
+
+  Mono<Allocation> createComponentAllocation( String subscriptionId, int componentId, Allocation allocation );
+
+  Mono<AllocationPreview> previewComponentAllocation( String subscriptionId, int componentId, int quantity );
+
+  Flux<Component> findComponentsByProductFamily( String productFamilyId );
 
-  RenewalPreview previewSubscriptionRenewal( String subscriptionId );
+  Mono<Component> findComponentByIdAndProductFamily( int componentId, String productFamilyId );
 
-  List<Metadata> createSubscriptionMetadata( String subscriptionId, Metadata... metadata );
+  Mono<ComponentWithPricePoints> findComponentWithPricePointsByIdAndProductFamily( int componentId, String productFamilyId );
 
-  SubscriptionMetadata readSubscriptionMetadata( String subscriptionId );
+  Flux<SubscriptionComponent> findSubscriptionComponents( String subscriptionId );
 
-  List<Metadata> updateSubscriptionMetadata( String subscriptionId, Metadata... metadata );
+  Flux<SubscriptionStatement> findSubscriptionStatements(
+          String subscriptionId, int page, int pageSize, String sort, String direction );
 
-  Component createComponent( String productFamilyId, Component component );
+  Flux<Transaction> findSubscriptionTransactions( String subscriptionId, SubscriptionTransactionsSearchOptions options );
 
-  Allocation createComponentAllocation( String subscriptionId, String componentId, Allocation allocation );
+  Mono<SubscriptionComponent> findSubscriptionComponentById( String subscriptionId, int componentId );
 
-  List<Component> findComponentsByProductFamily( String productFamilyId );
+  Mono<Usage> reportSubscriptionComponentUsage( String subscriptionId, int componentId, Usage usage );
 
-  Component findComponentByIdAndProductFamily( String componentId, String productFamilyId );
+  Mono<Customer> createCustomer( Customer customer );
 
-  List<SubscriptionComponent> findSubscriptionComponents( String subscriptionId );
+  Mono<Customer> updateCustomer( Customer customer );
 
-  SubscriptionComponent findSubscriptionComponentById( String subscriptionId, String componentId );
+  Mono<Customer> findCustomerById( String id );
 
-  Usage reportSubscriptionComponentUsage( String subscriptionId, String componentId, Usage usage );
+  Mono<Customer> findCustomerByReference( String reference );
 
-  Customer createCustomer( Customer customer );
+  Mono<Subscription> findSubscriptionByReference( String reference );
 
-  Customer updateCustomer( Customer customer );
+  /**
+   * Search to retrieve a single or group of customers.
+   *
+   * @param criterion (string or integer) - can be email, Chargify ID, Reference (Your App), Organization
+   * @param pageNumber (start from 1) the page parameter via the query string to access subsequent pages of 50 transactions
+   * @return List of customers
+   */
+  Flux<Customer> findCustomersBy( Object criterion, int pageNumber );
 
-  Customer findCustomerById( String id );
+  /**
+   *  The first page of results is displayed
+   *  Default value for per_page is 50
+   *  For page settings and how many records to fetch in each request (perPage), use
+   *  {@link #findCustomers(int pageNumber, int perPage )}
+   */
+  Flux<Customer> findAllCustomers();
 
-  Customer findCustomerByReference( String reference );
+  Flux<Customer> findCustomers( int pageNumber, int perPage );
 
-  List<Customer> findAllCustomers();
+  Mono<Void> deleteCustomerById( String id );
 
-  void deleteCustomerById( String id );
+  Mono<ReferralCode> validateReferralCode( String code );
 
-  ReferralCode validateReferralCode( String code );
+  Mono<Adjustment> adjust( String subscriptionId, Adjustment adjustment );
 }