wrapper_property.ts

/*
  Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
 
  Licensed under the Apache License, Version 2.0 (the "License").
  You may not use this file except in compliance with the License.
  You may obtain a copy of the License at
 
  http://www.apache.org/licenses/LICENSE-2.0
 
  Unless required by applicable law or agreed to in writing, software
  distributed under the License is distributed on an "AS IS" BASIS,
  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  See the License for the specific language governing permissions and
  limitations under the License.
*/

import { ConnectionProvider } from "./connection_provider";
import { DatabaseDialect } from "./database_dialect/database_dialect";
import { ClusterTopologyMonitorImpl } from "./host_list_provider/monitoring/cluster_topology_monitor";
import { BlueGreenStatusProvider } from "./plugins/bluegreen/blue_green_status_provider";

export interface AwsClientConfig {
  /** Comma separated list of connection plugin codes */
  plugins?: string;
  /** This flag is enabled by default, meaning that the plugins order will be automatically adjusted. Disable it at your own risk or if you really need plugins to be executed in a particular order. */
  autoSortWrapperPluginOrder?: boolean;
  /** A unique identifier for the supported database dialect. */
  dialect?: string;
  /** The connection provider used to create connections. */
  connectionProvider?: ConnectionProvider;
  /** Timeout in milliseconds for the wrapper to execute queries against MySQL database engines */
  mysqlQueryTimeout?: number;
  /** Timeout in milliseconds for the wrapper to create a connection. */
  wrapperConnectTimeout?: number;
  /** Timeout in milliseconds for the wrapper to execute queries. */
  wrapperQueryTimeout?: number;
  /** Enables session state transfer to a new connection. */
  transferSessionStateOnSwitch?: boolean;
  /** Enables resetting a connection's session state before closing it. */
  resetSessionStateOnClose?: boolean;
  /** Enables to rollback a current transaction being in progress when switching to a new connection. */
  rollbackOnSwitch?: boolean;
  /** An override for specifying the default host availability change strategy. */
  defaultHostAvailabilityStrategy?: string;
  /** Max number of retries for checking a host's availability. */
  hostAvailabilityStrategyMaxRetries?: number;
  /** The initial backoff time in seconds. */
  hostAvailabilityStrategyInitialBackoffTimeSec?: number;
  /** Interval in millis between measuring response time to a database host. */
  responseMeasurementIntervalMs?: number;
  /** Overrides the host that is used to generate the IAM token */
  iamHost?: string;
  /** Overrides default port that is used to generate the IAM token */
  iamDefaultPort?: number;
  /** Overrides AWS region that is used to generate the IAM token */
  iamRegion?: string;
  /** The ARN of the IAM Role that is to be assumed. */
  iamRoleArn?: string;
  /** The ARN of the identity provider */
  iamIdpArn?: string;
  /** IAM token cache expiration in seconds */
  iamTokenExpiration?: number;
  /** The federated user name */
  idpUsername?: string;
  /** The federated user password */
  idpPassword?: string;
  /** The hosting URL of the Identity Provider */
  idpEndpoint?: string;
  /** The hosting port of the Identity Provider */
  idpPort?: number;
  /** The ID of the AWS application configured on Okta */
  appId?: string;
  /** The relaying party identifier */
  rpIdentifier?: string;
  /** The IAM user used to access the database */
  dbUser?: string;
  /** The options to be passed into the httpsAgent */
  httpsAgentOptions?: Record<string, any>;
  /** The name or the ARN of the secret to retrieve. */
  secretId?: string;
  /** The region of the secret to retrieve. */
  secretRegion?: string;
  /** The endpoint of the secret to retrieve. */
  secretEndpoint?: string;
  /** Cluster topology refresh rate in millis during a writer failover process. During the writer failover process, cluster topology may be refreshed at a faster pace than normal to speed up discovery of the newly promoted writer. */
  failoverClusterTopologyRefreshRateMs?: number;
  /** Maximum allowed time for the failover process. */
  failoverTimeoutMs?: number;
  /** Interval of time to wait between attempts to reconnect to a failed writer during a writer failover process. */
  failoverWriterReconnectIntervalMs?: number;
  /** Reader connection attempt timeout during a reader failover process. */
  failoverReaderConnectTimeoutMs?: number;
  /** Enable/disable cluster-aware failover logic. */
  enableClusterAwareFailover?: boolean;
  /** Set host role to follow during failover. */
  failoverMode?: string;
  /** The strategy that should be used to select a new reader host while opening a new connection. */
  failoverReaderHostSelectorStrategy?: string;
  /** Cluster topology refresh rate in millis. The cached topology for the cluster will be invalidated after the specified time, after which it will be updated during the next interaction with the connection. */
  clusterTopologyRefreshRateMs?: number;
  /** Cluster topology high refresh rate in millis. */
  clusterTopologyHighRefreshRateMs?: number;
  /** A unique identifier for the cluster. Connections with the same cluster id share a cluster topology cache. If unspecified, a cluster id is automatically created for AWS RDS clusters. */
  clusterId?: string;
  /** The cluster instance DNS pattern that will be used to build a complete instance endpoint. A "?" character in this pattern should be used as a placeholder for cluster instance names. This pattern is required to be specified for IP address or custom domain connections to AWS RDS clusters. Otherwise, if unspecified, the pattern will be automatically created for AWS RDS clusters. */
  clusterInstanceHostPattern?: string;
  /** Set to true if you are providing a connection string with multiple comma-delimited hosts and your cluster has only one writer. The writer must be the first host in the connection string */
  singleWriterConnectionString?: boolean;
  /** The strategy that should be used to select a new reader host. */
  readerHostSelectorStrategy?: string;
  /** Maximum allowed time for the retries opening a connection. */
  openConnectionRetryTimeoutMs?: number;
  /** Time between each retry of opening a connection. */
  openConnectionRetryIntervalMs?: number;
  /** Interval in millis between sending SQL to the server and the first probe to database host. */
  failureDetectionTime?: number;
  /** Enable enhanced failure detection logic. */
  failureDetectionEnabled?: boolean;
  /** Interval in millis between probes to database host. */
  failureDetectionInterval?: number;
  /** Number of failed connection checks before considering database host unhealthy. */
  failureDetectionCount?: number;
  /** Interval in milliseconds for a monitor to be considered inactive and to be disposed. */
  monitorDisposalTime?: number;
  /** Comma separated list of database host-weight pairs in the format of `<host>:<weight>`. */
  roundRobinHostWeightPairs?: string;
  /** The default weight for any hosts that have not been configured with the `roundRobinHostWeightPairs` parameter. */
  roundRobinDefaultWeight?: number;
  /** Enables telemetry and observability of the wrapper */
  enableTelemetry?: boolean;
  /** Force submitting traces related to calls as top level traces. */
  telemetrySubmitToplevel?: boolean;
  /** Method to export telemetry traces of the wrapper. */
  telemetryTracesBackend?: string;
  /** Method to export telemetry metrics of the wrapper. */
  telemetryMetricsBackend?: string;
  /** Post an additional top-level trace for failover process. */
  telemetryFailoverAdditionalTopTrace?: boolean;
  /** If the cache of transaction router info is empty and a new connection is made, this property toggles whether the plugin will wait and synchronously fetch transaction router info before selecting a transaction router to connect to, or to fall back to using the provided DB Shard Group endpoint URL. */
  limitlessWaitForTransactionRouterInfo?: boolean;
  /** Interval in millis between retries fetching Limitless Transaction Router information. */
  limitlessGetTransactionRouterInfoRetryIntervalMs?: number;
  /** Max number of connection retries fetching Limitless Transaction Router information. */
  limitlessGetTransactionRouterInfoMaxRetries?: number;
  /** Interval in millis between polling for Limitless Transaction Routers to the database. */
  limitlessTransactionRouterMonitorIntervalMs?: number;
  /** Max number of connection retries the Limitless Connection Plugin will attempt. */
  limitlessConnectMaxRetries?: number;
  /** Interval in milliseconds for an Limitless router monitor to be considered inactive and to be disposed. */
  limitlessTransactionRouterMonitorDisposalTimeMs?: number;
  /** Map containing any keepAlive properties that the target driver accepts in the client configuration. */
  wrapperKeepAliveProperties?: Map<string, any>;
  /** A reference to a custom database dialect object. */
  customDatabaseDialect?: DatabaseDialect;
  /** A reference to a custom AwsCredentialsProviderHandler object. */
  customAwsCredentialProviderHandler?: any;
  /** Name of the AWS Profile to use for IAM or SecretsManager auth. */
  awsProfile?: string;
  /** Driver configuration profile name */
  profileName?: string;
  /** Controls how frequently custom endpoint monitors fetch custom endpoint info, in milliseconds. */
  customEndpointInfoRefreshRateMs?: number;
  /** Controls whether to wait for custom endpoint info to become available before connecting or executing a method. Waiting is only necessary if a connection to a given custom endpoint has not been opened or used recently. Note that disabling this may result in occasional connections to instances outside of the custom endpoint. */
  waitForCustomEndpointInfo?: boolean;
  /** Controls the maximum amount of time that the plugin will wait for custom endpoint info to be made available by the custom endpoint monitor, in milliseconds. */
  waitForCustomEndpointInfoTimeoutMs?: number;
  /** Controls how long a monitor should run without use before expiring and being removed, in milliseconds. */
  customEndpointMonitorExpirationMs?: number;
  /** The region of the cluster's custom endpoints. If not specified, the region will be parsed from the URL. */
  customEndpointRegion?: string;
  /** Enables replacing a green host name with the original hostname after a blue/green switchover and the green name no longer resolves. */
  enableGreenHostReplacement?: boolean;
  /** Connect timeout in milliseconds during Blue/Green Deployment switchover. */
  bgConnectTimeoutMs?: number;
  /** Blue/Green Deployment ID */
  bgdId?: string;
  /** Baseline Blue/Green Deployment status checking interval in milliseconds. */
  bgBaselineMs?: number;
  /** Increased Blue/Green Deployment status checking interval in milliseconds. */
  bgIncreasedMs?: number;
  /** High Blue/Green Deployment status checking interval in milliseconds. */
  bgHighMs?: number;
  /** Blue/Green Deployment switchover timeout in milliseconds. */
  bgSwitchoverTimeoutMs?: number;
  /** Enables Blue/Green Deployment switchover to suspend new blue connection requests while the switchover process is in progress. */
  bgSuspendNewBlueConnections?: boolean;
}

export class WrapperProperty<T> {
  name: string;
  description: string;
  defaultValue: any;

  constructor(name: string, description: string, defaultValue?: any) {
    this.name = name;
    this.description = description;
    this.defaultValue = defaultValue;
  }

  get(props: Map<string, any>): T {
    const val = props.get(this.name);
    if (val === undefined && this.defaultValue !== undefined) {
      return this.defaultValue;
    }

    return val;
  }

  set(props: Map<string, any>, val: T) {
    props.set(this.name, val);
  }
}

export class WrapperProperties {
  static readonly MONITORING_PROPERTY_PREFIX: string = "monitoring_";
  static readonly DEFAULT_PLUGINS = "auroraConnectionTracker,failover,efm2";
  static readonly DEFAULT_TOKEN_EXPIRATION_SEC = 15 * 60;

  static readonly PLUGINS = new WrapperProperty<string>(
    "plugins",
    "Comma separated list of connection plugin codes",
    WrapperProperties.DEFAULT_PLUGINS
  );

  static readonly AUTO_SORT_PLUGIN_ORDER = new WrapperProperty<boolean>(
    "autoSortWrapperPluginOrder",
    "This flag is enabled by default, meaning that the plugins order will be automatically adjusted. Disable it at your own risk or if you really need plugins to be executed in a particular order.",
    true
  );

  static readonly USER = new WrapperProperty<string>("user", "Database user name", null);
  static readonly PASSWORD = new WrapperProperty<string>("password", "Database password", null);
  static readonly DATABASE = new WrapperProperty<string>("database", "Database name", null);
  static readonly PORT = new WrapperProperty<number>("port", "Database port", -1);
  static readonly HOST = new WrapperProperty<string>("host", "Database host", null);

  static readonly DIALECT = new WrapperProperty<string>("dialect", "A unique identifier for the supported database dialect.", null);
  static readonly CONNECTION_PROVIDER = new WrapperProperty<ConnectionProvider>(
    "connectionProvider",
    "The connection provider used to create connections.",
    null
  );

  /**
   * @deprecated since version 1.1.0 and replaced by wrapper property WRAPPER_QUERY_TIMEOUT.
   */
  static readonly INTERNAL_QUERY_TIMEOUT = new WrapperProperty<number>(
    "mysqlQueryTimeout",
    "Timeout in milliseconds for the wrapper to execute queries against MySQL database engines",
    20000
  );

  static readonly WRAPPER_CONNECT_TIMEOUT = new WrapperProperty<number>(
    "wrapperConnectTimeout",
    "Timeout in milliseconds for the wrapper to create a connection.",
    10000
  );

  static readonly WRAPPER_QUERY_TIMEOUT = new WrapperProperty<number>(
    "wrapperQueryTimeout",
    "Timeout in milliseconds for the wrapper to execute queries.",
    20000
  );

  static readonly TRANSFER_SESSION_STATE_ON_SWITCH = new WrapperProperty<boolean>(
    "transferSessionStateOnSwitch",
    "Enables session state transfer to a new connection.",
    true
  );
  static readonly RESET_SESSION_STATE_ON_CLOSE = new WrapperProperty<boolean>(
    "resetSessionStateOnClose",
    "Enables resetting a connection's session state before closing it.",
    true
  );
  static readonly ROLLBACK_ON_SWITCH = new WrapperProperty<boolean>(
    "rollbackOnSwitch",
    "Enables to rollback a current transaction being in progress when switching to a new connection.",
    true
  );

  static readonly DEFAULT_HOST_AVAILABILITY_STRATEGY = new WrapperProperty<string>(
    "defaultHostAvailabilityStrategy",
    "An override for specifying the default host availability change strategy.",
    null
  );
  static readonly HOST_AVAILABILITY_STRATEGY_MAX_RETRIES = new WrapperProperty<number>(
    "hostAvailabilityStrategyMaxRetries",
    "Max number of retries for checking a host's availability.",
    5
  );
  static readonly HOST_AVAILABILITY_STRATEGY_INITIAL_BACKOFF_TIME_SEC = new WrapperProperty<number>(
    "hostAvailabilityStrategyInitialBackoffTimeSec",
    "The initial backoff time in seconds.",
    30
  );

  static readonly RESPONSE_MEASUREMENT_INTERVAL_MILLIS = new WrapperProperty<number>(
    "responseMeasurementIntervalMs",
    "Interval in millis between measuring response time to a database host.",
    30000
  );

  static readonly IAM_HOST = new WrapperProperty<string>("iamHost", "Overrides the host that is used to generate the IAM token", null);
  static readonly IAM_DEFAULT_PORT = new WrapperProperty<number>(
    "iamDefaultPort",
    "Overrides default port that is used to generate the IAM token",
    null
  );
  static readonly IAM_REGION = new WrapperProperty<string>("iamRegion", "Overrides AWS region that is used to generate the IAM token", null);
  static readonly IAM_ROLE_ARN = new WrapperProperty<string>("iamRoleArn", "The ARN of the IAM Role that is to be assumed.", null);
  static readonly IAM_IDP_ARN = new WrapperProperty<string>("iamIdpArn", "The ARN of the identity provider", null);
  static readonly IAM_TOKEN_EXPIRATION = new WrapperProperty<number>(
    "iamTokenExpiration",
    "IAM token cache expiration in seconds",
    this.DEFAULT_TOKEN_EXPIRATION_SEC
  );

  static readonly IDP_USERNAME = new WrapperProperty<string>("idpUsername", "The federated user name", null);
  static readonly IDP_PASSWORD = new WrapperProperty<string>("idpPassword", "The federated user password", null);
  static readonly IDP_ENDPOINT = new WrapperProperty<string>("idpEndpoint", "The hosting URL of the Identity Provider", null);
  static readonly IDP_PORT = new WrapperProperty<number>("idpPort", "The hosting port of the Identity Provider", 443);

  static readonly APP_ID = new WrapperProperty<string>("appId", "The ID of the AWS application configured on Okta", null);

  static readonly RELAYING_PARTY_ID = new WrapperProperty<string>("rpIdentifier", "The relaying party identifier", "urn:amazon:webservices");

  static readonly DB_USER = new WrapperProperty<string>("dbUser", "The IAM user used to access the database", null);

  static readonly HTTPS_AGENT_OPTIONS = new WrapperProperty<Record<string, any>>(
    "httpsAgentOptions",
    "The options to be passed into the httpsAgent",
    null
  );

  static readonly SECRET_ID = new WrapperProperty<string>("secretId", "The name or the ARN of the secret to retrieve.", null);
  static readonly SECRET_REGION = new WrapperProperty<string>("secretRegion", "The region of the secret to retrieve.", null);
  static readonly SECRET_ENDPOINT = new WrapperProperty<string>("secretEndpoint", "The endpoint of the secret to retrieve.", null);

  static readonly FAILOVER_CLUSTER_TOPOLOGY_REFRESH_RATE_MS = new WrapperProperty<number>(
    "failoverClusterTopologyRefreshRateMs",
    "Cluster topology refresh rate in millis during a writer failover process. " +
      "During the writer failover process, " +
      "cluster topology may be refreshed at a faster pace than normal to speed up " +
      "discovery of the newly promoted writer.",
    2000
  );
  static readonly FAILOVER_TIMEOUT_MS = new WrapperProperty<number>("failoverTimeoutMs", "Maximum allowed time for the failover process.", 300000);
  static readonly FAILOVER_WRITER_RECONNECT_INTERVAL_MS = new WrapperProperty<number>(
    "failoverWriterReconnectIntervalMs",
    "Interval of time to wait between attempts to reconnect to a failed writer during a writer failover process.",
    2000
  );
  static readonly FAILOVER_READER_CONNECT_TIMEOUT_MS = new WrapperProperty<number>(
    "failoverReaderConnectTimeoutMs",
    "Reader connection attempt timeout during a reader failover process.",
    30000
  );
  static readonly ENABLE_CLUSTER_AWARE_FAILOVER = new WrapperProperty<boolean>(
    "enableClusterAwareFailover",
    "Enable/disable cluster-aware failover logic.",
    true
  );
  static readonly FAILOVER_MODE = new WrapperProperty<string>("failoverMode", "Set host role to follow during failover.", "");

  static readonly FAILOVER_READER_HOST_SELECTOR_STRATEGY = new WrapperProperty<string>(
    "failoverReaderHostSelectorStrategy",
    "The strategy that should be used to select a new reader host while opening a new connection.",
    "random"
  );

  static readonly CLUSTER_TOPOLOGY_REFRESH_RATE_MS = new WrapperProperty<number>(
    "clusterTopologyRefreshRateMs",
    "Cluster topology refresh rate in millis. " +
      "The cached topology for the cluster will be invalidated after the specified time, " +
      "after which it will be updated during the next interaction with the connection.",
    30000
  );

  static readonly CLUSTER_TOPOLOGY_HIGH_REFRESH_RATE_MS = new WrapperProperty<number>(
    "clusterTopologyHighRefreshRateMs",
    "Cluster topology high refresh rate in millis.",
    100
  );

  static readonly CLUSTER_ID = new WrapperProperty<string>(
    "clusterId",
    "A unique identifier for the cluster. " +
      "Connections with the same cluster id share a cluster topology cache. " +
      "If unspecified, a cluster id is automatically created for AWS RDS clusters.",
    null
  );

  static readonly CLUSTER_INSTANCE_HOST_PATTERN = new WrapperProperty<string>(
    "clusterInstanceHostPattern",
    "The cluster instance DNS pattern that will be used to build a complete instance endpoint. " +
      'A "?" character in this pattern should be used as a placeholder for cluster instance names. ' +
      "This pattern is required to be specified for IP address or custom domain connections to AWS RDS " +
      "clusters. Otherwise, if unspecified, the pattern will be automatically created for AWS RDS clusters."
  );

  static readonly SINGLE_WRITER_CONNECTION_STRING = new WrapperProperty<boolean>(
    "singleWriterConnectionString",
    "Set to true if you are providing a connection string with multiple comma-delimited hosts and your cluster has only one writer. The writer must be the first host in the connection string",
    "false"
  );

  static readonly ENABLE_GREEN_HOST_REPLACEMENT = new WrapperProperty<boolean>(
    "enableGreenHostReplacement",
    "Enables replacing a green host name with the original hostname after a blue/green switchover and the green name no longer resolves.",
    "false"
  );

  static readonly READER_HOST_SELECTOR_STRATEGY = new WrapperProperty<string>(
    "readerHostSelectorStrategy",
    "The strategy that should be used to select a new reader host.",
    "random"
  );
  static readonly OPEN_CONNECTION_RETRY_TIMEOUT_MS = new WrapperProperty<number>(
    "openConnectionRetryTimeoutMs",
    "Maximum allowed time for the retries opening a connection.",
    30000
  );
  static readonly OPEN_CONNECTION_RETRY_INTERVAL_MS = new WrapperProperty<number>(
    "openConnectionRetryIntervalMs",
    "Time between each retry of opening a connection.",
    1000
  );

  static readonly FAILURE_DETECTION_TIME_MS = new WrapperProperty<number>(
    "failureDetectionTime",
    "Interval in millis between sending SQL to the server and the first probe to database host.",
    30000
  );

  static readonly FAILURE_DETECTION_ENABLED = new WrapperProperty<boolean>(
    "failureDetectionEnabled",
    "Enable enhanced failure detection logic.",
    true
  );

  static readonly FAILURE_DETECTION_INTERVAL_MS = new WrapperProperty<number>(
    "failureDetectionInterval",
    "Interval in millis between probes to database host.",
    5000
  );

  static readonly FAILURE_DETECTION_COUNT = new WrapperProperty<number>(
    "failureDetectionCount",
    "Number of failed connection checks before considering database host unhealthy.",
    3
  );

  static readonly MONITOR_DISPOSAL_TIME_MS = new WrapperProperty<number>(
    "monitorDisposalTime",
    "Interval in milliseconds for a monitor to be considered inactive and to be disposed.",
    600000 // 10 minutes
  );

  static readonly ROUND_ROBIN_HOST_WEIGHT_PAIRS = new WrapperProperty<string>(
    "roundRobinHostWeightPairs",
    "Comma separated list of database host-weight pairs in the format of `<host>:<weight>`.",
    null
  );

  static readonly ROUND_ROBIN_DEFAULT_WEIGHT = new WrapperProperty<number>(
    "roundRobinDefaultWeight",
    "The default weight for any hosts that have not been configured with the `roundRobinHostWeightPairs` parameter.",
    1
  );

  static readonly ENABLE_TELEMETRY = new WrapperProperty<boolean>("enableTelemetry", "Enables telemetry and observability of the wrapper", false);

  static readonly TELEMETRY_SUBMIT_TOPLEVEL = new WrapperProperty<boolean>(
    "telemetrySubmitToplevel",
    "Force submitting traces related to calls as top level traces.",
    false
  );

  static readonly TELEMETRY_TRACES_BACKEND = new WrapperProperty<string>(
    "telemetryTracesBackend",
    "Method to export telemetry traces of the wrapper.",
    null
  );

  static readonly TELEMETRY_METRICS_BACKEND = new WrapperProperty<string>(
    "telemetryMetricsBackend",
    "Method to export telemetry metrics of the wrapper.",
    null
  );

  static readonly TELEMETRY_FAILOVER_ADDITIONAL_TOP_TRACE = new WrapperProperty<boolean>(
    "telemetryFailoverAdditionalTopTrace",
    "Post an additional top-level trace for failover process.",
    false
  );

  static readonly WAIT_F0R_ROUTER_INFO = new WrapperProperty<boolean>(
    "limitlessWaitForTransactionRouterInfo",
    "If the cache of transaction router info is empty and a new connection is made, this property toggles whether " +
      "the plugin will wait and synchronously fetch transaction router info before selecting a transaction " +
      "router to connect to, or to fall back to using the provided DB Shard Group endpoint URL.",
    true
  );

  static readonly GET_ROUTER_RETRY_INTERVAL_MILLIS = new WrapperProperty<number>(
    "limitlessGetTransactionRouterInfoRetryIntervalMs",
    "Interval in millis between retries fetching Limitless Transaction Router information.",
    300
  );

  static readonly GET_ROUTER_MAX_RETRIES = new WrapperProperty<number>(
    "limitlessGetTransactionRouterInfoMaxRetries",
    "Max number of connection retries fetching Limitless Transaction Router information.",
    5
  );

  static readonly INTERVAL_MILLIS = new WrapperProperty<number>(
    "limitlessTransactionRouterMonitorIntervalMs",
    "Interval in millis between polling for Limitless Transaction Routers to the database.",
    15000
  );

  static readonly MAX_RETRIES = new WrapperProperty<number>(
    "limitlessConnectMaxRetries",
    "Max number of connection retries the Limitless Connection Plugin will attempt.",
    5
  );

  static readonly LIMITLESS_MONITOR_DISPOSAL_TIME_MS = new WrapperProperty<number>(
    "limitlessTransactionRouterMonitorDisposalTimeMs",
    "Interval in milliseconds for an Limitless router monitor to be considered inactive and to be disposed.",
    600_000 // 10 min
  );

  static readonly KEEPALIVE_PROPERTIES = new WrapperProperty<Map<string, any>>(
    "wrapperKeepAliveProperties",
    "Map containing any keepAlive properties that the target driver accepts in the client configuration.",
    null
  );

  static readonly CUSTOM_DATABASE_DIALECT = new WrapperProperty<DatabaseDialect>(
    "customDatabaseDialect",
    "A reference to a custom database dialect object.",
    null
  );

  static readonly CUSTOM_AWS_CREDENTIAL_PROVIDER_HANDLER = new WrapperProperty<any>(
    "customAwsCredentialProviderHandler",
    "A reference to a custom AwsCredentialsProviderHandler object.",
    null
  );

  static readonly AWS_PROFILE = new WrapperProperty<string>("awsProfile", "Name of the AWS Profile to use for IAM or SecretsManager auth.", null);

  static readonly PROFILE_NAME = new WrapperProperty<string>("profileName", "Driver configuration profile name", null);

  static readonly CUSTOM_ENDPOINT_INFO_REFRESH_RATE = new WrapperProperty<number>(
    "customEndpointInfoRefreshRateMs",
    "Controls how frequently custom endpoint monitors fetch custom endpoint info, in milliseconds.",
    10_000
  );

  static readonly WAIT_FOR_CUSTOM_ENDPOINT_INFO = new WrapperProperty<boolean>(
    "waitForCustomEndpointInfo",
    "Controls whether to wait for custom endpoint info to become available before connecting or executing a " +
      "method. Waiting is only necessary if a connection to a given custom endpoint has not been opened or used " +
      "recently. Note that disabling this may result in occasional connections to instances outside of the " +
      "custom endpoint.",
    true
  );

  static readonly WAIT_FOR_CUSTOM_ENDPOINT_INFO_TIMEOUT_MS = new WrapperProperty<number>(
    "waitForCustomEndpointInfoTimeoutMs",
    "Controls the maximum amount of time that the plugin will wait for custom endpoint info to be made available by the custom endpoint monitor, in milliseconds.",
    10_000
  );

  static readonly CUSTOM_ENDPOINT_MONITOR_IDLE_EXPIRATION_MS = new WrapperProperty<number>(
    "customEndpointMonitorExpirationMs",
    "Controls how long a monitor should run without use before expiring and being removed, in milliseconds.",
    900_000 // 15 min
  );

  static readonly CUSTOM_ENDPOINT_REGION = new WrapperProperty<string>(
    "customEndpointRegion",
    "The region of the cluster's custom endpoints. If not specified, the region will be parsed from the URL.",
    null
  );

  static readonly BG_CONNECT_TIMEOUT_MS = new WrapperProperty<number>(
    "bgConnectTimeoutMs",
    "Connect timeout in milliseconds during Blue/Green Deployment switchover.",
    30000
  );

  static readonly BGD_ID = new WrapperProperty<string>("bgdId", "Blue/Green Deployment ID", "1");

  static readonly BG_INTERVAL_BASELINE_MS = new WrapperProperty<number>(
    "bgBaselineMs",
    "Baseline Blue/Green Deployment status checking interval in milliseconds.",
    60000
  );

  static readonly BG_INTERVAL_INCREASED_MS = new WrapperProperty<number>(
    "bgIncreasedMs",
    "Increased Blue/Green Deployment status checking interval in milliseconds.",
    1000
  );

  static readonly BG_INTERVAL_HIGH_MS = new WrapperProperty<number>(
    "bgHighMs",
    "High Blue/Green Deployment status checking interval in milliseconds.",
    100
  );

  static readonly BG_SWITCHOVER_TIMEOUT_MS = new WrapperProperty<number>(
    "bgSwitchoverTimeoutMs",
    "Blue/Green Deployment switchover timeout in milliseconds.",
    180000 // 3min
  );

  static readonly BG_SUSPEND_NEW_BLUE_CONNECTIONS = new WrapperProperty<boolean>(
    "bgSuspendNewBlueConnections",
    "Enables Blue/Green Deployment switchover to suspend new blue connection requests while the switchover process is in progress.",
    false
  );

  private static readonly PREFIXES = [
    WrapperProperties.MONITORING_PROPERTY_PREFIX,
    ClusterTopologyMonitorImpl.MONITORING_PROPERTY_PREFIX,
    BlueGreenStatusProvider.MONITORING_PROPERTY_PREFIX
  ];

  private static startsWithPrefix(key: string): boolean {
    return WrapperProperties.PREFIXES.some((prefix) => key.startsWith(prefix));
  }

  static removeWrapperProperties(props: Map<string, any>): Map<string, any> {
    const persistingProperties = [
      WrapperProperties.USER.name,
      WrapperProperties.PASSWORD.name,
      WrapperProperties.DATABASE.name,
      WrapperProperties.PORT.name,
      WrapperProperties.HOST.name
    ];

    const copy = new Map(props);

    for (const key of props.keys()) {
      if (!WrapperProperties.startsWithPrefix(key)) {
        continue;
      }

      copy.delete(key);
    }

    Object.values(WrapperProperties).forEach((prop) => {
      if (prop instanceof WrapperProperty) {
        const propertyName = (prop as WrapperProperty<any>).name;
        if (!persistingProperties.includes(propertyName) && copy.has(propertyName)) {
          copy.delete(propertyName);
        }
      }
    });

    return copy;
  }
}