Stash: create collection data access logic WIP

Author: GPortas

src/collections/domain/repositories/ICollectionsRepository.ts

@@ -3,5 +3,5 @@ import { Collection } from '../models/Collection'
 
 export interface ICollectionsRepository {
   getCollection(collectionIdOrAlias: number | string): Promise<Collection>
-  createCollection(collectionDTO: CollectionDTO): Promise<void>
+  createCollection(collectionDTO: CollectionDTO, parentCollectionId: string): Promise<void>
 }

src/collections/domain/useCases/CreateCollection.ts

@@ -12,7 +12,7 @@ export class CreateCollection implements UseCase<void> {
   /**
    * TODO
    */
-  async execute(newCollection: CollectionDTO): Promise<void> {
-    await this.collectionsRepository.createCollection(newCollection)
+  async execute(newCollection: CollectionDTO, parentCollectionId = 'root'): Promise<void> {
+    await this.collectionsRepository.createCollection(newCollection, parentCollectionId)
   }
 }

src/collections/infra/repositories/CollectionsRepository.ts

@@ -19,8 +19,25 @@ export class CollectionsRepository extends ApiRepository implements ICollections
       })
   }
 
-  public async createCollection(collectionDTO: CollectionDTO): Promise<void> {
-    console.log(collectionDTO.alias)
-    // TODO
+  public async createCollection(
+    collectionDTO: CollectionDTO,
+    parentCollectionId = 'root'
+  ): Promise<void> {
+    const dataverseContacts = collectionDTO.contacts.map((contact) => ({
+      contactEmail: contact
+    }))
+
+    const requestBody = {
+      alias: collectionDTO.alias,
+      name: collectionDTO.name,
+      dataverseContacts: dataverseContacts,
+      dataverseType: collectionDTO.type.toString()
+    }
+
+    return this.doPost(`/${this.collectionsResourceName}/${parentCollectionId}`, requestBody)
+      .then(() => undefined)
+      .catch((error) => {
+        throw error
+      })
   }
 }

test/integration/collections/CollectionsRepository.test.ts

@@ -4,6 +4,7 @@ import { ReadError } from '../../../src'
 import { ApiConfig } from '../../../src'
 import { DataverseApiAuthMechanism } from '../../../src/core/infra/repositories/ApiConfig'
 import {
+  createCollectionDTO,
   createCollectionViaApi,
   deleteCollectionViaApi
 } from '../../testHelpers/collections/collectionHelper'
@@ -85,4 +86,11 @@ describe('CollectionsRepository', () => {
       })
     })
   })
+
+  describe('createCollection', () => {
+    test('should create collection in root when no parent collection is set', async () => {
+      const newCollectionDTO = createCollectionDTO()
+      await sut.createCollection(newCollectionDTO)
+    })
+  })
 })

test/integration/files/DirectUploadClient.test.ts

@@ -22,7 +22,7 @@ import {
 } from '../../testHelpers/files/filesHelper'
 import { FileUploadCancelError } from '../../../src/files/infra/clients/errors/FileUploadCancelError'
 
-describe('DirectUploadClient', () => {
+describe.skip('DirectUploadClient', () => {
   const testCollectionAlias = 'directUploadTestCollection'
   let testDataset1Ids: CreatedDatasetIdentifiers
   let testDataset2Ids: CreatedDatasetIdentifiers