( organizationId: Organisation.OrganisationId, )
| 269 | }; |
| 270 | |
| 271 | const getOrganizationBucket = async ( |
| 272 | organizationId: Organisation.OrganisationId, |
| 273 | ) => { |
| 274 | const [bucket] = await db() |
| 275 | .select() |
| 276 | .from(s3Buckets) |
| 277 | .where( |
| 278 | and( |
| 279 | eq(s3Buckets.organizationId, organizationId), |
| 280 | eq(s3Buckets.active, true), |
| 281 | ), |
| 282 | ) |
| 283 | .orderBy(desc(s3Buckets.updatedAt)) |
| 284 | .limit(1); |
| 285 | |
| 286 | return bucket ?? null; |
| 287 | }; |
| 288 | |
| 289 | const getS3InputCredentials = async (input: S3ConfigInput) => { |
| 290 | const hasAccessKeyId = input.accessKeyId.trim().length > 0; |
no test coverage detected