Fixed storage e2e test for S3

This commit is contained in:
Anton SHEPILOV
2024-11-04 14:44:23 +07:00
committed by Anton Shepilov
parent 20ef64f04f
commit 2c5cf0bb8d
4 changed files with 5 additions and 4 deletions
@@ -113,7 +113,7 @@ export default class S3ConnectorService implements StorageConnectorAPI {
break; break;
} }
} catch (e) { } catch (e) {
logger.error("Error getting information from S3", e); logger.error(e, `Error getting information from S3 for path: ${path}`);
} }
if (i === tries) { if (i === tries) {
@@ -69,7 +69,8 @@ export default class StorageService extends TdriveService<StorageAPI> implements
} }
exists(path: string, options?: ReadOptions): Promise<boolean> { exists(path: string, options?: ReadOptions): Promise<boolean> {
return this.getConnector().exists(path, options); //TODO[ASH] check for all the file chunks
return this.getConnector().exists(path + "/chunk1", options);
} }
async write(path: string, stream: Stream, options?: WriteOptions): Promise<WriteMetadata> { async write(path: string, stream: Stream, options?: WriteOptions): Promise<WriteMetadata> {
@@ -431,7 +431,7 @@ export class FileServiceImpl {
id: externalId, id: externalId,
company_id: "00000000-0000-4000-0000-000000000000", company_id: "00000000-0000-4000-0000-000000000000",
}); });
const exist = await gr.platformServices.storage.exists(getFilePath(file) + "/chunk1"); const exist = await gr.platformServices.storage.exists(getFilePath(file));
if (exist) { if (exist) {
return { exist: true, file }; return { exist: true, file };
} else { } else {
+1 -1
View File
@@ -1,4 +1,4 @@
version: "2" version: "3"
services: services:
# rabbitmq: # rabbitmq: