Changed passwordSupplier to passwordPublisher

Motivation:
To Improve code readability and maintain consistency in variable and parameter names.

Modification:
Replaced all instances of the variable and parameter name passwordSupplier with passwordPublisher throughout the codebase.
Added an explanation for passwordPublisher to clarify its purpose and usage.

Result:
Clean up

Author: bhosale

README.md

@@ -139,6 +139,7 @@ ConnectionFactoryOptions options = ConnectionFactoryOptions.builder()
     .option(Option.valueOf("tcpKeepAlive"), true) // optional, default false
     .option(Option.valueOf("tcpNoDelay"), true) // optional, default false
     .option(Option.valueOf("autodetectExtensions"), false) // optional, default false
+    .option(Option.valueOf("passwordPublisher"), Mono.just("password")) // optional, default null, null means has no passwordPublisher (since 1.0.5 / 0.9.6)
     .build();
 ConnectionFactory connectionFactory = ConnectionFactories.get(options);
 
@@ -186,6 +187,7 @@ MySqlConnectionConfiguration configuration = MySqlConnectionConfiguration.builde
     .tcpNoDelay(true) // optional, controls TCP No Delay, default is false
     .autodetectExtensions(false) // optional, controls extension auto-detect, default is true
     .extendWith(MyExtension.INSTANCE) // optional, manual extend an extension into extensions, default using auto-detect
+    .passwordPublisher(Mono.just("password")) // optional, default null, null means has no password publisher (since 1.0.5 / 0.9.6)
     .build();
 ConnectionFactory connectionFactory = MySqlConnectionFactory.from(configuration);
 
@@ -233,6 +235,7 @@ Mono<Connection> connectionMono = Mono.from(connectionFactory.create());
 | zeroDateOption | Any value of `ZeroDateOption` | Optional, default `USE_NULL` | The option indicates "zero date" handling, see following notice |
 | autodetectExtensions | `true` or `false` | Optional, default is `true` | Controls auto-detect `Extension`s |
 | useServerPrepareStatement | `true`, `false` or `Predicate<String>` | Optional, default is `false` | See following notice |
+| passwordPublisher | A `Publisher<String>` | Optional, default is `null` | The password publisher, see following notice |
 
 - `SslMode` Considers security level and verification for SSL, make sure the database server supports SSL before you want change SSL mode to `REQUIRED` or higher. **The Unix Domain Socket only offers "DISABLED" available**
   - `DISABLED` I don't care about security and don't want to pay the overhead for encryption
@@ -258,6 +261,7 @@ Mono<Connection> connectionMono = Mono.from(connectionFactory.create());
   - It is **NOT** RECOMMENDED, enable the `autodetectExtensions` is the best way for extensions
   - The `Extensions` will not remove duplicates, make sure it would be not extended twice or more
   - The auto-detected `Extension`s will not affect manual extends and will not remove duplicates
+- `passwordPublisher` Every time the client attempts to authenticate, it will use the password provided by the `passwordPublisher`.(Since `1.0.5` / `0.9.6`) e.g., You can employ this method for IAM-based authentication when connecting to an AWS Aurora RDS database.
 
 Should use `enum` in [Programmatic](#programmatic-configuration) configuration that not like discovery configurations, except `TlsVersions` (All elements of `TlsVersions` will be always `String` which is case-sensitive).
 

src/main/java/io/asyncer/r2dbc/mysql/MySqlConnectionConfiguration.java

@@ -94,14 +94,14 @@ public final class MySqlConnectionConfiguration {
     private final Extensions extensions;
 
     @Nullable
-    private final Publisher<String> passwordSupplier;
+    private final Publisher<String> passwordPublisher;
 
     private MySqlConnectionConfiguration(boolean isHost, String domain, int port, MySqlSslConfiguration ssl,
         boolean tcpKeepAlive, boolean tcpNoDelay, @Nullable Duration connectTimeout,
         @Nullable Duration socketTimeout, ZeroDateOption zeroDateOption, @Nullable ZoneId serverZoneId,
         String user, @Nullable CharSequence password, @Nullable String database,
         @Nullable Predicate<String> preferPrepareStatement, int queryCacheSize, int prepareCacheSize,
-        Extensions extensions, @Nullable Publisher<String> passwordSupplier) {
+        Extensions extensions, @Nullable Publisher<String> passwordPublisher) {
         this.isHost = isHost;
         this.domain = domain;
         this.port = port;
@@ -119,7 +119,7 @@ private MySqlConnectionConfiguration(boolean isHost, String domain, int port, My
         this.queryCacheSize = queryCacheSize;
         this.prepareCacheSize = prepareCacheSize;
         this.extensions = extensions;
-        this.passwordSupplier = passwordSupplier;
+        this.passwordPublisher = passwordPublisher;
     }
 
     /**
@@ -210,8 +210,8 @@ Extensions getExtensions() {
     }
 
     @Nullable
-    Publisher<String> getPasswordSupplier() {
-        return passwordSupplier;
+    Publisher<String> getPasswordPublisher() {
+        return passwordPublisher;
     }
 
     @Override
@@ -240,34 +240,34 @@ public boolean equals(Object o) {
             queryCacheSize == that.queryCacheSize &&
             prepareCacheSize == that.prepareCacheSize &&
             extensions.equals(that.extensions) &&
-            Objects.equals(passwordSupplier, that.passwordSupplier);
+            Objects.equals(passwordPublisher, that.passwordPublisher);
     }
 
     @Override
     public int hashCode() {
         return Objects.hash(isHost, domain, port, ssl, tcpKeepAlive, tcpNoDelay,
-            connectTimeout, socketTimeout, serverZoneId, zeroDateOption, user, password, database,
-            preferPrepareStatement, queryCacheSize, prepareCacheSize, extensions, passwordSupplier);
+                            connectTimeout, socketTimeout, serverZoneId, zeroDateOption, user, password, database,
+                            preferPrepareStatement, queryCacheSize, prepareCacheSize, extensions, passwordPublisher);
     }
 
     @Override
     public String toString() {
         if (isHost) {
             return "MySqlConnectionConfiguration{, host='" + domain + "', port=" + port + ", ssl=" + ssl +
-                ", tcpNoDelay=" + tcpNoDelay + ", tcpKeepAlive=" + tcpKeepAlive + ", connectTimeout=" +
-                connectTimeout + ", socketTimeout=" + socketTimeout + ", serverZoneId=" + serverZoneId +
-                ", zeroDateOption=" + zeroDateOption + ", user='" + user + '\'' + ", password=" + password +
-                ", database='" + database + "', preferPrepareStatement=" + preferPrepareStatement +
-                ", queryCacheSize=" + queryCacheSize + ", prepareCacheSize=" + prepareCacheSize +
-                ", extensions=" + extensions + ", passwordSupplier="+ passwordSupplier + '}';
+                   ", tcpNoDelay=" + tcpNoDelay + ", tcpKeepAlive=" + tcpKeepAlive + ", connectTimeout=" +
+                   connectTimeout + ", socketTimeout=" + socketTimeout + ", serverZoneId=" + serverZoneId +
+                   ", zeroDateOption=" + zeroDateOption + ", user='" + user + '\'' + ", password=" + password +
+                   ", database='" + database + "', preferPrepareStatement=" + preferPrepareStatement +
+                   ", queryCacheSize=" + queryCacheSize + ", prepareCacheSize=" + prepareCacheSize +
+                   ", extensions=" + extensions + ", passwordPublisher=" + passwordPublisher + '}';
         }
 
         return "MySqlConnectionConfiguration{, unixSocket='" + domain + "', connectTimeout=" +
-            connectTimeout + ", socketTimeout=" + socketTimeout + ", serverZoneId=" + serverZoneId +
-            ", zeroDateOption=" + zeroDateOption + ", user='" + user + "', password=" + password +
-            ", database='" + database + "', preferPrepareStatement=" + preferPrepareStatement +
-            ", queryCacheSize=" + queryCacheSize + ", prepareCacheSize=" + prepareCacheSize +
-            ", extensions=" + extensions +  ", passwordSupplier="+ passwordSupplier + '}';
+               connectTimeout + ", socketTimeout=" + socketTimeout + ", serverZoneId=" + serverZoneId +
+               ", zeroDateOption=" + zeroDateOption + ", user='" + user + "', password=" + password +
+               ", database='" + database + "', preferPrepareStatement=" + preferPrepareStatement +
+               ", queryCacheSize=" + queryCacheSize + ", prepareCacheSize=" + prepareCacheSize +
+               ", extensions=" + extensions + ", passwordPublisher=" + passwordPublisher + '}';
     }
 
     /**
@@ -339,7 +339,7 @@ public static final class Builder {
         private final List<Extension> extensions = new ArrayList<>();
 
         @Nullable
-        private Publisher<String> passwordSupplier;
+        private Publisher<String> passwordPublisher;
 
         /**
          * Builds an immutable {@link MySqlConnectionConfiguration} with current options.
@@ -365,7 +365,7 @@ public MySqlConnectionConfiguration build() {
             return new MySqlConnectionConfiguration(isHost, domain, port, ssl, tcpKeepAlive, tcpNoDelay,
                 connectTimeout, socketTimeout, zeroDateOption, serverZoneId, user, password, database,
                 preferPrepareStatement, queryCacheSize, prepareCacheSize,
-                Extensions.from(extensions, autodetectExtensions), passwordSupplier);
+                Extensions.from(extensions, autodetectExtensions), passwordPublisher);
         }
 
         /**
@@ -794,12 +794,12 @@ public Builder extendWith(Extension extension) {
         }
 
         /**
-         * Registers a password supplier function.
-         * @param passwordSupplier function to retrieve password before making connection.
+         * Registers a password publisher function.
+         * @param passwordPublisher function to retrieve password before making connection.
          * @return this {@link Builder}.
          */
-        public Builder passwordSupplier(Publisher<String> passwordSupplier) {
-            this.passwordSupplier = passwordSupplier;
+        public Builder passwordPublisher(Publisher<String> passwordPublisher) {
+            this.passwordPublisher = passwordPublisher;
             return this;
         }
 

src/main/java/io/asyncer/r2dbc/mysql/MySqlConnectionFactory.java

@@ -94,9 +94,9 @@ public static MySqlConnectionFactory from(MySqlConnectionConfiguration configura
             Extensions extensions = configuration.getExtensions();
             Predicate<String> prepare = configuration.getPreferPrepareStatement();
             int prepareCacheSize = configuration.getPrepareCacheSize();
-            Publisher<String> passwordSupplier = configuration.getPasswordSupplier();
-            if (Objects.nonNull(passwordSupplier)) {
-                return Mono.from(passwordSupplier)
+            Publisher<String> passwordPublisher = configuration.getPasswordPublisher();
+            if (Objects.nonNull(passwordPublisher)) {
+                return Mono.from(passwordPublisher)
                         .flatMap(token -> getMySqlConnection(
                             configuration, queryCache,
                             ssl, address,

src/main/java/io/asyncer/r2dbc/mysql/MySqlConnectionFactoryProvider.java

@@ -205,12 +205,12 @@ public final class MySqlConnectionFactoryProvider implements ConnectionFactoryPr
     public static final Option<Boolean> AUTODETECT_EXTENSIONS = Option.valueOf("autodetectExtensions");
 
     /**
-     * Password Supplier function can be used to retrieve password before creating a connection.
+     * Password Publisher function can be used to retrieve password before creating a connection.
      * This can be used with Amazon RDS Aurora IAM authentication, wherein it requires token to be generated.
      * The token is valid for 15 minutes, and this token will be used as password.
      *
      */
-    public static final Option<Publisher<String>> PASSWORD_SUPPLIER = Option.valueOf("passwordSupplier");
+    public static final Option<Publisher<String>> PASSWORD_PUBLISHER = Option.valueOf("passwordPublisher");
 
     @Override
     public ConnectionFactory create(ConnectionFactoryOptions options) {
@@ -270,8 +270,8 @@ static MySqlConnectionConfiguration setup(ConnectionFactoryOptions options) {
             .to(builder::socketTimeout);
         mapper.optional(DATABASE).asString()
             .to(builder::database);
-        mapper.optional(PASSWORD_SUPPLIER).as(Publisher.class)
-            .to(builder::passwordSupplier);
+        mapper.optional(PASSWORD_PUBLISHER).as(Publisher.class)
+              .to(builder::passwordPublisher);
 
         return builder.build();
     }

src/test/java/io/asyncer/r2dbc/mysql/MySqlConnectionConfigurationTest.java

@@ -34,7 +34,6 @@
 import java.util.List;
 import java.util.Objects;
 import java.util.function.Function;
-import java.util.function.Supplier;
 
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.assertThatIllegalArgumentException;
@@ -198,10 +197,10 @@ void validPasswordSupplier() {
         Mono.from(MySqlConnectionConfiguration.builder()
                 .host(HOST)
                 .user(USER)
-                .passwordSupplier(passwordSupplier)
+                .passwordPublisher(passwordSupplier)
                 .autodetectExtensions(false)
                 .build()
-                .getPasswordSupplier())
+                .getPasswordPublisher())
             .as(StepVerifier::create)
             .expectNext("123456")
             .verifyComplete();

src/test/java/io/asyncer/r2dbc/mysql/MySqlConnectionFactoryProviderTest.java

@@ -36,9 +36,8 @@
 import java.util.Collections;
 import java.util.function.Function;
 import java.util.function.Predicate;
-import java.util.function.Supplier;
 
-import static io.asyncer.r2dbc.mysql.MySqlConnectionFactoryProvider.PASSWORD_SUPPLIER;
+import static io.asyncer.r2dbc.mysql.MySqlConnectionFactoryProvider.PASSWORD_PUBLISHER;
 import static io.asyncer.r2dbc.mysql.MySqlConnectionFactoryProvider.USE_SERVER_PREPARE_STATEMENT;
 import static io.r2dbc.spi.ConnectionFactoryOptions.CONNECT_TIMEOUT;
 import static io.r2dbc.spi.ConnectionFactoryOptions.DATABASE;
@@ -402,7 +401,7 @@ void validPasswordSupplier() {
             .option(DRIVER, "mysql")
             .option(HOST, "127.0.0.1")
             .option(USER, "root")
-            .option(PASSWORD_SUPPLIER, passwordSupplier)
+            .option(PASSWORD_PUBLISHER, passwordSupplier)
             .build();
 
         assertThat(ConnectionFactories.get(options)).isExactlyInstanceOf(MySqlConnectionFactory.class);