1
- import {
2
- CopyObjectCommandOutput ,
3
- DeleteObjectCommandOutput ,
4
- GetObjectCommandOutput ,
5
- PutObjectCommandInput ,
6
- } from '@aws-sdk/client-s3'
1
+ import { DeleteObjectCommandOutput , GetObjectCommandOutput , PutObjectCommandInput } from '@aws-sdk/client-s3'
7
2
import { Upload } from '@aws-sdk/lib-storage'
8
3
import { S3Handler } from 'aws-lambda'
9
4
import { isNil , last , split } from 'ramda'
10
5
import ValidationReport from 'rdf-validate-shacl/src/validation-report'
11
6
12
7
import { getAsset , updateAsset , validateAndCreateMetadata } from '../../../asset'
13
8
import { ExtractedFileWithCID , ManifestExtractedFiles } from '../../../asset/types'
14
- import { copyFile , deleteFile , readFile , writeFile } from '../../../aws'
9
+ import { deleteFile , readFile , writeFile } from '../../../aws'
15
10
import { createGroup , uploadFile } from '../../../ipfs'
16
11
import { log } from '../../../logger'
17
12
import { Asset , AssetMetadata , AssetStatus } from '../../../types'
@@ -20,7 +15,6 @@ export const _main =
20
15
( {
21
16
readFile,
22
17
writeFile,
23
- copyFile,
24
18
deleteFile,
25
19
validateAndCreateMetadata,
26
20
getAsset,
@@ -30,15 +24,6 @@ export const _main =
30
24
} : {
31
25
readFile : ( { Bucket, Key } : { Bucket : string ; Key : string } ) => Promise < GetObjectCommandOutput >
32
26
writeFile : ( params : PutObjectCommandInput ) => Upload
33
- copyFile : ( {
34
- Bucket,
35
- CopySource,
36
- Key,
37
- } : {
38
- Bucket : string
39
- CopySource : string
40
- Key : string
41
- } ) => Promise < CopyObjectCommandOutput | undefined >
42
27
deleteFile : ( { Bucket, Key } : { Bucket : string ; Key : string } ) => Promise < DeleteObjectCommandOutput | undefined >
43
28
validateAndCreateMetadata : (
44
29
byteArray : Uint8Array ,
@@ -97,32 +82,9 @@ export const _main =
97
82
98
83
return
99
84
}
100
- // Copy asset ZIP file to S3 with CID as name
101
- await copyFile ( {
102
- Bucket,
103
- CopySource : `${ Bucket } /${ Key } ` ,
104
- Key : assetCID ,
105
- } )
106
85
107
86
// Handle files for registered users
108
- const { owner, registeredUser } = files
109
-
110
- if ( owner ) {
111
- const writeFilesToAssetPromises = owner . map (
112
- async ( { path, arrayBuffer } : { path : string ; arrayBuffer : ArrayBuffer } ) => {
113
- const writeToAsset = writeFile ( {
114
- Bucket,
115
- Key : `${ assetCID } /${ path } ` ,
116
- Body : Buffer . from ( arrayBuffer ) ,
117
- ContentEncoding : 'base64' ,
118
- } )
119
-
120
- return writeToAsset . done ( )
121
- } ,
122
- )
123
-
124
- Promise . all ( writeFilesToAssetPromises )
125
- }
87
+ const { registeredUser } = files
126
88
127
89
if ( visualizationFiles ) {
128
90
const writeFilesToIpfsPromises = visualizationFiles . map (
@@ -170,9 +132,6 @@ export const _main =
170
132
171
133
// Update stored asset in DB
172
134
await updateAsset ( assetCID , Key , AssetStatus . pending , metadata , modifiedManifest )
173
-
174
- // Delete uploaded asset with the "old" name from S3
175
- await deleteFile ( { Bucket, Key } )
176
135
} catch ( err ) {
177
136
console . log ( err )
178
137
throw err
@@ -182,7 +141,6 @@ export const _main =
182
141
export const main = _main ( {
183
142
readFile,
184
143
writeFile,
185
- copyFile,
186
144
deleteFile,
187
145
validateAndCreateMetadata,
188
146
getAsset,
0 commit comments