feat(firehose): integrate amplify_foundation_dart v3 types

- Replace amplify_core credential/exception types with foundation v3 equivalents
- Exceptions extend AmplifyException from amplify_foundation_dart
- Barrel exports re-export AWSCredentials, AWSCredentialsProvider, StaticCredentials, TemporaryCredentials, Logger
- Add _CredentialsProviderAdapter in sdk_bridge to convert foundation provider to amplify_core for Smithy SDK
- Add V2CredentialsProviderBridge for V2→V3 credential migration
- Options include optional Logger parameter
- Update tests and mocks for v3 types

Author: ekjotmultani

packages/kinesis/aws_amazon_firehose/lib/aws_amazon_firehose.dart

@@ -4,14 +4,20 @@
 /// Amplify Amazon Data Firehose client for Dart.
 library;
 
-// TODO(v3): Replace with V3 credentials provider type.
-export 'package:amplify_core/amplify_core.dart'
-    show AWSCredentials, AWSCredentialsProvider;
+export 'package:amplify_foundation_dart/amplify_foundation_dart.dart'
+    show
+        AWSCredentials,
+        AWSCredentialsProvider,
+        StaticCredentials,
+        TemporaryCredentials,
+        Logger;
 
 // Options
 export 'src/amazon_data_firehose_options.dart';
 // Main client
 export 'src/amplify_firehose_client.dart';
+// V2 → V3 credentials bridge
+export 'src/credentials/credentials_bridge.dart';
 // Exceptions
 export 'src/exception/amplify_firehose_exception.dart';
 // Flush strategies

packages/kinesis/aws_amazon_firehose/lib/src/amazon_data_firehose_options.dart

@@ -1,11 +1,9 @@
 // Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
 // SPDX-License-Identifier: Apache-2.0
 
+import 'package:amplify_foundation_dart/amplify_foundation_dart.dart';
 import 'package:aws_amazon_firehose/src/flush_strategy/flush_strategy.dart';
 
-// TODO(v3): Import V3 Logger type once available.
-// import 'package:amplify_v3_core/amplify_v3_core.dart' show Logger;
-
 /// {@template aws_amazon_firehose.amplify_firehose_client_options}
 /// Configuration options for [AmplifyFirehoseClient].
 ///
@@ -27,8 +25,7 @@ class AmplifyFirehoseClientOptions {
     this.maxRecords = 500,
     this.maxRetries = 5,
     this.flushStrategy = const AmazonDataFirehoseInterval(),
-    // TODO(v3): Add logger parameter once V3 Logger type is available.
-    // this.logger,
+    this.logger,
   });
 
   /// Maximum size of the local cache in bytes.
@@ -56,9 +53,8 @@ class AmplifyFirehoseClientOptions {
   /// Defaults to [AmazonDataFirehoseInterval] with a 30-second interval.
   final AmazonDataFirehoseFlushStrategy flushStrategy;
 
-  // TODO(v3): Uncomment once V3 Logger type is available.
-  // /// Optional logger for debug and error output.
-  // final Logger? logger;
+  /// Optional logger for debug and error output.
+  final Logger? logger;
 }
 
 /// Deprecated: Use [AmplifyFirehoseClientOptions] instead.

packages/kinesis/aws_amazon_firehose/lib/src/amplify_firehose_client.dart

@@ -3,7 +3,7 @@
 
 import 'dart:typed_data';
 
-import 'package:amplify_core/amplify_core.dart';
+import 'package:amplify_foundation_dart/amplify_foundation_dart.dart';
 import 'package:aws_amazon_firehose/src/amazon_data_firehose_options.dart';
 import 'package:aws_amazon_firehose/src/db/firehose_record_database.dart';
 import 'package:aws_amazon_firehose/src/impl/auto_flush_scheduler.dart';
@@ -15,9 +15,6 @@ import 'package:aws_amazon_firehose/src/model/clear_cache_data.dart';
 import 'package:aws_amazon_firehose/src/model/flush_data.dart';
 import 'package:aws_amazon_firehose/src/sdk/firehose.dart';
 
-// TODO(v3): Update credentialsProvider type to V3
-// `AWSCredentialsProvider<AWSCredentials>` once available.
-
 /// {@template aws_amazon_firehose.amplify_firehose_client}
 /// Client for recording and streaming data to Amazon Data Firehose.
 ///
@@ -50,7 +47,7 @@ class AmplifyFirehoseClient {
   /// {@macro aws_amazon_firehose.amplify_firehose_client}
   AmplifyFirehoseClient({
     required String region,
-    required AWSCredentialsProvider credentialsProvider,
+    required AWSCredentialsProvider<AWSCredentials> credentialsProvider,
     AmplifyFirehoseClientOptions options = const AmplifyFirehoseClientOptions(),
     String? storagePath,
   }) : this._internal(
@@ -62,7 +59,7 @@ class AmplifyFirehoseClient {
 
   AmplifyFirehoseClient._internal({
     required String region,
-    required AWSCredentialsProvider credentialsProvider,
+    required AWSCredentialsProvider<AWSCredentials> credentialsProvider,
     required AmplifyFirehoseClientOptions options,
     required String storagePath,
   })  : _region = region,

packages/kinesis/aws_amazon_firehose/lib/src/credentials/credentials_bridge.dart

@@ -0,0 +1,52 @@
+// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+import 'package:amplify_core/amplify_core.dart' as v2;
+import 'package:amplify_foundation_dart/amplify_foundation_dart.dart' as v3;
+
+/// {@template aws_amazon_firehose.v2_credentials_provider_bridge}
+/// Bridges a V2 [v2.AWSCredentialsProvider] (from `amplify_core`) to a V3
+/// [v3.AWSCredentialsProvider] (from `amplify_foundation_dart`).
+///
+/// This allows users who obtain credentials from the existing Amplify Auth
+/// plugin (V2) to pass them directly to the Firehose client without
+/// boilerplate.
+///
+/// ## Usage
+///
+/// ```dart
+/// import 'package:amplify_core/amplify_core.dart' as v2;
+/// import 'package:aws_amazon_firehose/aws_amazon_firehose.dart';
+///
+/// // Obtain V2 credentials from Amplify Auth
+/// final session = await Amplify.Auth.fetchAuthSession();
+/// final v2Provider = v2.AWSCredentialsProvider(session.credentials);
+///
+/// // Bridge to V3 and pass to the Firehose client
+/// final client = AmplifyFirehoseClient(
+///   region: 'us-east-1',
+///   credentialsProvider: V2CredentialsProviderBridge(v2Provider),
+/// );
+/// ```
+/// {@endtemplate}
+class V2CredentialsProviderBridge
+    implements v3.AWSCredentialsProvider<v3.AWSCredentials> {
+  /// {@macro aws_amazon_firehose.v2_credentials_provider_bridge}
+  const V2CredentialsProviderBridge(this._v2Provider);
+
+  final v2.AWSCredentialsProvider _v2Provider;
+
+  @override
+  Future<v3.AWSCredentials> resolve() async {
+    final creds = await _v2Provider.retrieve();
+    if (creds.sessionToken != null) {
+      return v3.TemporaryCredentials(
+        creds.accessKeyId,
+        creds.secretAccessKey,
+        creds.sessionToken!,
+        creds.expiration ?? DateTime.now().add(const Duration(hours: 1)),
+      );
+    }
+    return v3.StaticCredentials(creds.accessKeyId, creds.secretAccessKey);
+  }
+}

packages/kinesis/aws_amazon_firehose/lib/src/exception/amplify_firehose_exception.dart

@@ -1,51 +1,105 @@
 // Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
 // SPDX-License-Identifier: Apache-2.0
 
-// TODO(v3): Replace with `extends AmplifyException` once V3 foundational
-// library is available. For now we implement Exception directly.
+import 'package:amplify_foundation_dart/amplify_foundation_dart.dart';
 
+/// {@template aws_amazon_firehose.amplify_firehose_exception}
 /// Base exception for Amplify Firehose errors.
-sealed class AmplifyFirehoseException implements Exception {
-  const AmplifyFirehoseException(this.message, {this.recoverySuggestion, this.underlyingException});
-  final String message;
-  final String? recoverySuggestion;
-  final Object? underlyingException;
+/// {@endtemplate}
+sealed class AmplifyFirehoseException extends AmplifyException {
+  /// {@macro aws_amazon_firehose.amplify_firehose_exception}
+  AmplifyFirehoseException({
+    required super.message,
+    required super.recoverySuggestion,
+    super.cause,
+  });
+
   @override
   String toString() {
-    final buf = StringBuffer('$runtimeType: $message');
-    if (recoverySuggestion != null) buf.write('\nRecovery suggestion: $recoverySuggestion');
-    if (underlyingException != null) buf.write('\nCaused by: $underlyingException');
+    final buf = StringBuffer('AmplifyFirehoseException: $message');
+    if (recoverySuggestion.isNotEmpty) {
+      buf.write('\nRecovery suggestion: $recoverySuggestion');
+    }
+    if (cause != null) buf.write('\nCaused by: $cause');
     return buf.toString();
   }
 }
 
+/// {@template aws_amazon_firehose.firehose_storage_exception}
 /// Thrown when a local cache/database error occurs.
+/// {@endtemplate}
 class FirehoseStorageException extends AmplifyFirehoseException {
-  const FirehoseStorageException(super.message, {super.underlyingException}) : super(recoverySuggestion: 'Try clearing the cache or reinitializing.');
+  /// {@macro aws_amazon_firehose.firehose_storage_exception}
+  FirehoseStorageException(String message, {Object? cause})
+      : super(
+          message: message,
+          recoverySuggestion: 'Try clearing the cache or reinitializing.',
+          cause: cause,
+        );
 }
 
+/// {@template aws_amazon_firehose.firehose_service_exception}
 /// Thrown when a Firehose SDK/API error occurs. Inspect [sdkException] for details.
+/// {@endtemplate}
 class FirehoseServiceException extends AmplifyFirehoseException {
-  const FirehoseServiceException(super.message, {this.sdkException, super.underlyingException}) : super(recoverySuggestion: 'Check sdkException for details.');
+  /// {@macro aws_amazon_firehose.firehose_service_exception}
+  FirehoseServiceException(String message, {this.sdkException, Object? cause})
+      : super(
+          message: message,
+          recoverySuggestion: 'Check sdkException for details.',
+          cause: cause,
+        );
+
+  /// The underlying SDK exception, if any.
   final Object? sdkException;
 }
 
+/// {@template aws_amazon_firehose.firehose_limit_exceeded_exception}
 /// Thrown when the local cache is full.
+/// {@endtemplate}
 class FirehoseLimitExceededException extends AmplifyFirehoseException {
-  const FirehoseLimitExceededException() : super('Cache is full', recoverySuggestion: 'Call flush() or clearCache().');
+  /// {@macro aws_amazon_firehose.firehose_limit_exceeded_exception}
+  FirehoseLimitExceededException()
+      : super(
+          message: 'Cache is full',
+          recoverySuggestion: 'Call flush() or clearCache().',
+        );
 }
 
+/// {@template aws_amazon_firehose.firehose_unknown_exception}
 /// Catch-all for unexpected errors.
+/// {@endtemplate}
 class FirehoseUnknownException extends AmplifyFirehoseException {
-  const FirehoseUnknownException(super.message, {super.underlyingException}) : super(recoverySuggestion: 'Unexpected error. Please file a bug.');
+  /// {@macro aws_amazon_firehose.firehose_unknown_exception}
+  FirehoseUnknownException(String message, {Object? cause})
+      : super(
+          message: message,
+          recoverySuggestion: 'Unexpected error. Please file a bug.',
+          cause: cause,
+        );
 }
 
+/// {@template aws_amazon_firehose.firehose_network_exception}
 /// Thrown when a network error prevents communication with Firehose.
+/// {@endtemplate}
 class FirehoseNetworkException extends AmplifyFirehoseException {
-  const FirehoseNetworkException(super.message, {super.underlyingException}) : super(recoverySuggestion: 'Check network connectivity and try again.');
+  /// {@macro aws_amazon_firehose.firehose_network_exception}
+  FirehoseNetworkException(String message, {Object? cause})
+      : super(
+          message: message,
+          recoverySuggestion: 'Check network connectivity and try again.',
+          cause: cause,
+        );
 }
 
+/// {@template aws_amazon_firehose.client_closed_exception}
 /// Thrown when an operation is attempted on a closed client.
+/// {@endtemplate}
 class ClientClosedException extends AmplifyFirehoseException {
-  const ClientClosedException() : super('Client has been closed', recoverySuggestion: 'Create a new AmplifyFirehoseClient instance.');
+  /// {@macro aws_amazon_firehose.client_closed_exception}
+  ClientClosedException()
+      : super(
+          message: 'Client has been closed',
+          recoverySuggestion: 'Create a new AmplifyFirehoseClient instance.',
+        );
 }

packages/kinesis/aws_amazon_firehose/lib/src/impl/firehose_sender.dart

@@ -4,10 +4,12 @@
 import 'dart:io';
 import 'dart:typed_data';
 
-import 'package:amplify_core/amplify_core.dart';
+import 'package:amplify_foundation_dart/amplify_foundation_dart.dart'
+    as foundation;
 import 'package:aws_amazon_firehose/src/exception/amplify_firehose_exception.dart';
 import 'package:aws_amazon_firehose/src/sdk/firehose.dart';
 import 'package:aws_amazon_firehose/src/sdk/sdk_bridge.dart';
+import 'package:aws_common/aws_common.dart';
 import 'package:smithy/smithy.dart';
 
 /// Result of a PutRecordBatch operation.
@@ -47,7 +49,8 @@ class FirehoseSender {
   /// {@macro aws_amazon_firehose.firehose_sender}
   FirehoseSender({
     required String region,
-    required AWSCredentialsProvider credentialsProvider,
+    required foundation.AWSCredentialsProvider<foundation.AWSCredentials>
+        credentialsProvider,
     AWSHttpClient? httpClient,
   }) : _firehoseClient = WrappedFirehoseClient(
           region: region,
@@ -118,13 +121,13 @@ class FirehoseSender {
       // Network-level errors (DNS, connection refused, etc.)
       throw FirehoseNetworkException(
         'Failed to connect to Firehose: $e',
-        underlyingException: e,
+        cause: e,
       );
     } on SocketException catch (e) {
       // Socket-level errors (no internet, connection reset, etc.)
       throw FirehoseNetworkException(
         'Network error: ${e.message}',
-        underlyingException: e,
+        cause: e,
       );
     }
   }

packages/kinesis/aws_amazon_firehose/lib/src/impl/record_client.dart

@@ -54,12 +54,12 @@ class RecordClient {
   /// Throws [ClientClosedException] if the client has been closed.
   /// Throws [FirehoseLimitExceededException] if the cache is full.
   Future<void> record(FirehoseDataRecord record) async {
-    if (_closed) throw const ClientClosedException();
+    if (_closed) throw ClientClosedException();
     if (!_enabled) return;
 
     final currentSize = await _storage.getCurrentCacheSize();
     if (currentSize + record.dataSize > _storage.maxCacheBytes) {
-      throw const FirehoseLimitExceededException();
+      throw FirehoseLimitExceededException();
     }
 
     await _storage.saveRecord(record);
@@ -71,7 +71,7 @@ class RecordClient {
   ///
   /// Throws [ClientClosedException] if the client has been closed.
   Future<FlushData> flush() async {
-    if (_closed) throw const ClientClosedException();
+    if (_closed) throw ClientClosedException();
     if (!_enabled) return const FlushData();
 
     if (_flushing) return const FlushData(flushInProgress: true);