feat(llc): implement attachment uploads

This commit introduces the `StreamAttachmentUploader` for handling file and image uploads to the Stream CDN.

Key changes:
- Added `CdnApi` with methods for uploading and deleting files and images.
- Implemented `FeedsCdnClient` to wrap `CdnApi` and conform to the `CdnClient` interface from `stream_core`.
- Integrated `StreamAttachmentUploader` into `FeedsClientImpl`.
- Modified `ActivitiesRepository` and `CommentsRepository` to use `StreamAttachmentUploader` for uploading attachments before creating activities or comments.
- Updated `FeedAddActivityRequest` and `ActivityAddCommentRequest` to include `attachmentUploads` (list of `StreamAttachment`).
- Renamed `onSendProgress` to `onUploadProgress` in `CdnApi` for clarity.
- Updated relevant public API surfaces and internal logic to support attachment uploads.
- Regenerated `cdn_api.g.dart`.

Author: xsahil03x

packages/stream_feeds/lib/src/client/feeds_client_impl.dart

@@ -3,6 +3,8 @@ import 'dart:async';
 import 'package:stream_core/stream_core.dart';
 
 import '../feeds_client.dart';
+import '../file/cdn_api.dart';
+import '../file/feeds_cdn_client.dart';
 import '../generated/api/api.dart' as api;
 import '../models/activity_data.dart';
 import '../models/app_data.dart';
@@ -143,20 +145,23 @@ class StreamFeedsClientImpl implements StreamFeedsClient {
       ]),
     );
 
-    final apiClient = api.DefaultApi(httpClient);
-
     // endregion
 
     // region Initialize repositories
 
-    _activitiesRepository = ActivitiesRepository(apiClient);
-    _appRepository = AppRepository(apiClient);
-    _bookmarksRepository = BookmarksRepository(apiClient);
-    _commentsRepository = CommentsRepository(apiClient);
-    _devicesRepository = DevicesRepository(apiClient);
-    _feedsRepository = FeedsRepository(apiClient);
-    _moderationRepository = ModerationRepository(apiClient);
-    _pollsRepository = PollsRepository(apiClient);
+    _cdnClient = config.cdnClient ?? FeedsCdnClient(CdnApi(httpClient));
+    attachmentUploader = StreamAttachmentUploader(cdn: _cdnClient);
+
+    final feedsApi = api.DefaultApi(httpClient);
+
+    _activitiesRepository = ActivitiesRepository(feedsApi, attachmentUploader);
+    _appRepository = AppRepository(feedsApi);
+    _bookmarksRepository = BookmarksRepository(feedsApi);
+    _commentsRepository = CommentsRepository(feedsApi, attachmentUploader);
+    _devicesRepository = DevicesRepository(feedsApi);
+    _feedsRepository = FeedsRepository(feedsApi);
+    _moderationRepository = ModerationRepository(feedsApi);
+    _pollsRepository = PollsRepository(feedsApi);
 
     moderation = ModerationClient(_moderationRepository);
 
@@ -174,6 +179,11 @@ class StreamFeedsClientImpl implements StreamFeedsClient {
   late final StreamWebSocketClient _ws;
   late final ConnectionRecoveryHandler _connectionRecoveryHandler;
 
+  late final CdnClient _cdnClient;
+
+  @override
+  late final StreamAttachmentUploader attachmentUploader;
+
   late final ActivitiesRepository _activitiesRepository;
   late final AppRepository _appRepository;
   late final BookmarksRepository _bookmarksRepository;
@@ -432,14 +442,8 @@ class StreamFeedsClientImpl implements StreamFeedsClient {
   }
 
   @override
-  Future<Result<void>> deleteFile(String url) {
-    // TODO: implement deleteFile
-    throw UnimplementedError();
-  }
+  Future<Result<void>> deleteFile(String url) => _cdnClient.deleteFile(url);
 
   @override
-  Future<Result<void>> deleteImage(String url) {
-    // TODO: implement deleteImage
-    throw UnimplementedError();
-  }
+  Future<Result<void>> deleteImage(String url) => _cdnClient.deleteImage(url);
 }

packages/stream_feeds/lib/src/feeds_client.dart

@@ -696,6 +696,12 @@ abstract interface class StreamFeedsClient {
   /// Provides access to moderation configurations, content moderation, and moderation-related
   /// queries.
   ModerationClient get moderation;
+
+  /// The attachment uploader for managing file and image uploads.
+  ///
+  /// Provides functionality for uploading files and images to the Stream CDN with
+  /// support for various file types, progress tracking, and upload configurations.
+  StreamAttachmentUploader get attachmentUploader;
 }
 
 /// Extension methods for the [StreamFeedsClient] to simplify feed creation.

packages/stream_feeds/lib/src/file/cdn_api.dart

@@ -14,18 +14,32 @@ abstract interface class CdnApi {
 
   @MultiPart()
   @POST('/api/v2/uploads/file')
-  Future<Result<FileUploadResponse>> sendFile({
+  Future<Result<FileUploadResponse>> uploadFile({
     // TODO: change to single file upload once upgrade to retrofit ^4.7.0
     @Part(name: 'file') required List<MultipartFile> file,
-    @SendProgress() ProgressCallback? onSendProgress,
+    @SendProgress() ProgressCallback? onUploadProgress,
+    @CancelRequest() CancelToken? cancelToken,
   });
 
   @MultiPart()
   @POST('/api/v2/uploads/image')
-  Future<Result<FileUploadResponse>> sendImage({
+  Future<Result<ImageUploadResponse>> uploadImage({
     // TODO: change to single file upload once upgrade to retrofit ^4.7.0
     @Part(name: 'file') required List<MultipartFile> file,
-    @SendProgress() ProgressCallback? onSendProgress,
+    @SendProgress() ProgressCallback? onUploadProgress,
+    @CancelRequest() CancelToken? cancelToken,
+  });
+
+  @DELETE('/api/v2/uploads/file')
+  Future<Result<DurationResponse>> deleteFile({
+    @Query('url') String? url,
+    @CancelRequest() CancelToken? cancelToken,
+  });
+
+  @DELETE('/api/v2/uploads/image')
+  Future<Result<DurationResponse>> deleteImage({
+    @Query('url') String? url,
+    @CancelRequest() CancelToken? cancelToken,
   });
 }
 

packages/stream_feeds/lib/src/file/cdn_api.g.dart

@@ -0,0 +1,79 @@
+import 'package:stream_core/stream_core.dart';
+
+import 'cdn_api.dart';
+
+class FeedsCdnClient implements CdnClient {
+  const FeedsCdnClient(this._api);
+
+  final CdnApi _api;
+
+  @override
+  Future<Result<UploadedFile>> uploadFile(
+    AttachmentFile file, {
+    ProgressCallback? onProgress,
+    CancelToken? cancelToken,
+  }) async {
+    final multipartFile = await file.toMultipartFile();
+
+    final result = await _api.uploadFile(
+      file: [multipartFile],
+      onUploadProgress: onProgress,
+      cancelToken: cancelToken,
+    );
+
+    return result.map(
+      (response) => UploadedFile(
+        fileUrl: response.file,
+        thumbUrl: response.thumbUrl,
+      ),
+    );
+  }
+
+  @override
+  Future<Result<UploadedFile>> uploadImage(
+    AttachmentFile image, {
+    ProgressCallback? onProgress,
+    CancelToken? cancelToken,
+  }) async {
+    final multipartFile = await image.toMultipartFile();
+
+    final result = await _api.uploadImage(
+      file: [multipartFile],
+      onUploadProgress: onProgress,
+      cancelToken: cancelToken,
+    );
+
+    return result.map(
+      (response) => UploadedFile(
+        fileUrl: response.file,
+        thumbUrl: response.thumbUrl,
+      ),
+    );
+  }
+
+  @override
+  Future<Result<void>> deleteFile(
+    String url, {
+    CancelToken? cancelToken,
+  }) async {
+    final result = await _api.deleteFile(
+      url: url,
+      cancelToken: cancelToken,
+    );
+
+    return result;
+  }
+
+  @override
+  Future<Result<void>> deleteImage(
+    String url, {
+    CancelToken? cancelToken,
+  }) async {
+    final result = await _api.deleteImage(
+      url: url,
+      cancelToken: cancelToken,
+    );
+
+    return result;
+  }
+}