Commit ebd1bf8
committed
feat(firehose): flutter package (#6872)
* feat(firehose): add amplify_firehose Flutter wrapper package
- AmplifyFirehoseClient Flutter wrapper that resolves storage path
via path_provider automatically
- Platform-conditional path provider (IO/web/stub)
- Re-exports all types from amplify_firehose_dart except the Dart client
- Mirrors amplify_kinesis Flutter wrapper structure
* chore: remove accidentally committed flutter crash log
* chore(firehose): add CHANGELOG, LICENSE, and README to Flutter wrapper
* feat(firehose): add integration test infrastructure and example app
- CDK backend (infra-gen2/backends/kinesis/firehose/) with Firehose
delivery stream to S3, auth with email sign-in, IAM permissions
for PutRecord/PutRecordBatch
- Register firehose backend in deploy_gen2.dart
- Example Flutter app with Amplify Auth + Firehose client demo
- Integration tests: record/flush happy path, cache behavior,
batch records, client lifecycle
- Setup utils with AmplifyAuthCredentialsProvider
- pull_test_backend.sh for CI config download
Note: Backend needs to be deployed and S3 bucket configured before
CI can run integration tests.
* chore: regenerate workflows for firehose packages via aft generate workflows
Adds amplify_firehose.yaml, amplify_firehose_example.yaml workflows
and updates amplify_firehose_dart.yaml with native test job and
shared package path triggers.
Note: dependabot.yaml changes from aft excluded (repo-wide regen).
* chore: split Firehose into own deploy category and add backend scaffolding
- Move firehose backend from Kinesis category to its own Firehose
category in deploy_gen2.dart so it deploys independently without
touching the released KDS backend.
- Add missing npm scaffolding files (package.json, tsconfig.json,
.gitignore) for the firehose backend.
- Update pull_test_backend.sh to use AFS_FIREHOSE_GEN2_BUCKET_NAME.
- Simplify setup_utils to use amplifyConfig directly (no
amplifyEnvironments needed with dedicated category).
* fix: add network client entitlement for macOS integration tests
* test(firehose): port full integration test suite from KDS
Add all test cases from the KDS integration tests, adapted for
Firehose (no partition key, 4 MiB batch limit, 1000 KiB record limit):
- Core happy path (record+flush, empty flush, disabled drops, enable/
disable lifecycle, concurrent flush)
- Cache behavior (limit exceeded, clear cache)
- Error paths (nonexistent stream, invalid credentials, oversized record)
- Retry exhaustion (invalid stream dropped after maxRetries)
- Stress tests (high volume, repeated cycles, concurrent producers)
- Auto-flush (scheduler auto-starts, drains on interval)
- PutRecordBatch size limits (payload exceeding batch limit)
- Persistence (records survive across client instances)
- Escape hatch (SDK client accessible)
- Client lifecycle (close prevents operations)
* fix: suppress useDataProtection warning in example app for CI
* chore: format setup_utils.dart
* debug: add --debug flag to pull_test_backend.sh to diagnose S3 403
* revert: remove --debug flag from pull_test_backend.sh
* fix: add test_driver for web integration tests
* chore: add platform runners for all target platforms
Add android, ios, linux, macos, web, and windows platform
directories generated by flutter create. These are required
for CI integration tests to run on each platform.
* chore: bump amplify_firehose version to 2.11.0 to align with release train1 parent 0a6b282 commit ebd1bf8
File tree
157 files changed
+6552
-0
lines changed- .github/workflows
- infra-gen2
- backends/kinesis/firehose
- amplify
- auth
- tool
- packages/kinesis/amplify_firehose
- example
- android
- app
- src
- debug
- main
- kotlin/com/example/amplify_firehose_example
- res
- drawable-v21
- drawable
- mipmap-hdpi
- mipmap-mdpi
- mipmap-xhdpi
- mipmap-xxhdpi
- mipmap-xxxhdpi
- values-night
- values
- profile
- gradle/wrapper
- integration_test
- utils
- ios
- Flutter
- Runner.xcodeproj
- project.xcworkspace
- Runner.xcworkspace
- RunnerTests
- Runner
- Assets.xcassets
- AppIcon.appiconset
- LaunchImage.imageset
- Base.lproj
- lib
- linux
- flutter
- runner
- macos
- Flutter
- Runner.xcodeproj
- Runner.xcworkspace
- RunnerTests
- Runner
- Assets.xcassets/AppIcon.appiconset
- Base.lproj
- Configs
- test_driver
- tool
- web
- icons
- windows
- flutter
- runner
- resources
- lib
- src
- flutter_path_provider
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
157 files changed
+6552
-0
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
| 64 | + | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
| 69 | + | |
| 70 | + | |
| 71 | + | |
| 72 | + | |
| 73 | + | |
| 74 | + | |
| 75 | + | |
| 76 | + | |
| 77 | + | |
| 78 | + | |
| 79 | + | |
| 80 | + | |
| 81 | + | |
| 82 | + | |
| 83 | + | |
| 84 | + | |
| 85 | + | |
| 86 | + | |
| 87 | + | |
| 88 | + | |
| 89 | + | |
| 90 | + | |
| 91 | + | |
| 92 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
7 | 7 | | |
8 | 8 | | |
9 | 9 | | |
| 10 | + | |
10 | 11 | | |
11 | 12 | | |
12 | 13 | | |
| |||
26 | 27 | | |
27 | 28 | | |
28 | 29 | | |
| 30 | + | |
| 31 | + | |
29 | 32 | | |
30 | 33 | | |
31 | 34 | | |
32 | 35 | | |
33 | 36 | | |
34 | 37 | | |
35 | 38 | | |
| 39 | + | |
36 | 40 | | |
37 | 41 | | |
38 | 42 | | |
| |||
52 | 56 | | |
53 | 57 | | |
54 | 58 | | |
| 59 | + | |
| 60 | + | |
55 | 61 | | |
56 | 62 | | |
57 | 63 | | |
| |||
81 | 87 | | |
82 | 88 | | |
83 | 89 | | |
| 90 | + | |
| 91 | + | |
| 92 | + | |
| 93 | + | |
| 94 | + | |
| 95 | + | |
| 96 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
| 64 | + | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
| 69 | + | |
| 70 | + | |
| 71 | + | |
| 72 | + | |
| 73 | + | |
| 74 | + | |
| 75 | + | |
| 76 | + | |
| 77 | + | |
| 78 | + | |
| 79 | + | |
| 80 | + | |
| 81 | + | |
| 82 | + | |
| 83 | + | |
| 84 | + | |
| 85 | + | |
| 86 | + | |
| 87 | + | |
| 88 | + | |
| 89 | + | |
| 90 | + | |
| 91 | + | |
| 92 | + | |
| 93 | + | |
| 94 | + | |
| 95 | + | |
| 96 | + | |
| 97 | + | |
| 98 | + | |
| 99 | + | |
| 100 | + | |
| 101 | + | |
| 102 | + | |
| 103 | + | |
| 104 | + | |
| 105 | + | |
| 106 | + | |
| 107 | + | |
| 108 | + | |
| 109 | + | |
| 110 | + | |
| 111 | + | |
| 112 | + | |
| 113 | + | |
| 114 | + | |
| 115 | + | |
| 116 | + | |
| 117 | + | |
| 118 | + | |
| 119 | + | |
| 120 | + | |
| 121 | + | |
| 122 | + | |
| 123 | + | |
| 124 | + | |
| 125 | + | |
| 126 | + | |
| 127 | + | |
| 128 | + | |
| 129 | + | |
| 130 | + | |
| 131 | + | |
| 132 | + | |
| 133 | + | |
| 134 | + | |
| 135 | + | |
| 136 | + | |
| 137 | + | |
| 138 | + | |
| 139 | + | |
| 140 | + | |
| 141 | + | |
| 142 | + | |
| 143 | + | |
| 144 | + | |
| 145 | + | |
| 146 | + | |
| 147 | + | |
| 148 | + | |
| 149 | + | |
| 150 | + | |
| 151 | + | |
| 152 | + | |
| 153 | + | |
| 154 | + | |
| 155 | + | |
| 156 | + | |
| 157 | + | |
| 158 | + | |
| 159 | + | |
| 160 | + | |
| 161 | + | |
| 162 | + | |
| 163 | + | |
| 164 | + | |
| 165 | + | |
| 166 | + | |
| 167 | + | |
| 168 | + | |
| 169 | + | |
| 170 | + | |
| 171 | + | |
| 172 | + | |
| 173 | + | |
| 174 | + | |
| 175 | + | |
| 176 | + | |
| 177 | + | |
| 178 | + | |
| 179 | + | |
| 180 | + | |
| 181 | + | |
| 182 | + | |
| 183 | + | |
| 184 | + | |
| 185 | + | |
| 186 | + | |
| 187 | + | |
| 188 | + | |
| 189 | + | |
| 190 | + | |
| 191 | + | |
| 192 | + | |
| 193 | + | |
| 194 | + | |
| 195 | + | |
| 196 | + | |
| 197 | + | |
| 198 | + | |
| 199 | + | |
| 200 | + | |
| 201 | + | |
| 202 | + | |
| 203 | + | |
| 204 | + | |
| 205 | + | |
| 206 | + | |
| 207 | + | |
| 208 | + | |
| 209 | + | |
| 210 | + | |
| 211 | + | |
| 212 | + | |
| 213 | + | |
| 214 | + | |
| 215 | + | |
| 216 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
Lines changed: 4 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
Lines changed: 15 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
0 commit comments