Fix stream

app/processing/get-file.js

@@ -10,9 +10,9 @@ const download = async (fileName, directoryName, shareName) => {
   const share = shareServiceClient.getShareClient(shareName)
   const directory = share.getDirectoryClient(directoryName)
   const file = directory.getFileClient(fileName)
-  const downloaded = await file.download()
+  const downloaded = await file.downloadToBuffer()
   console.log(`Found ${fileName}`)
-  return downloaded.readableStreamBody
+  return downloaded.toString()
 }
 
 module.exports = getFile

app/processing/transfer-file.js

@@ -3,8 +3,8 @@ const getFile = require('./get-file')
 const writeFile = require('./write-file')
 
 const transferFile = async (fileName, directoryName, shareName) => {
-  const file = await getFile(fileName, directoryName, shareName)
-  await writeFile(fileName, file)
+  const fileContent = await getFile(fileName, directoryName, shareName)
+  await writeFile(fileName, fileContent)
   await deleteFile(fileName, directoryName, shareName)
   console.log(`Successfully transferred ${fileName}`)
 }

package.json

@@ -1,6 +1,6 @@
 {
   "name": "ffc-pay-file-receiver",
-  "version": "1.0.6",
+  "version": "1.0.7",
   "description": "Transfer files from DAX",
   "homepage": "https://github.com/DEFRA/ffc-pay-file-receiver",
   "main": "app/index.js",

test/integration/narrow/app/storage/get-container.test.js

@@ -14,21 +14,21 @@ jest.mock('../../../../../app/config/get-storage-config')
 const getStorageConfig = require('../../../../../app/config/get-storage-config')
 const { getContainer } = require('../../../../../app/storage/get-container')
 
-let retreivedGetStorageConfig
+let retrievedGetStorageConfig
 
 describe('get container object', () => {
   beforeEach(() => {
-    retreivedGetStorageConfig = JSON.parse(JSON.stringify(require('../../../../mocks/storage-config')))
-    getStorageConfig.mockResolvedValue(retreivedGetStorageConfig)
+    retrievedGetStorageConfig = JSON.parse(JSON.stringify(require('../../../../mocks/storage-config')))
+    getStorageConfig.mockResolvedValue(retrievedGetStorageConfig)
   })
 
   afterEach(() => {
     jest.clearAllMocks()
   })
 
   test('should call getStorageConfig', async () => {
-    retreivedGetStorageConfig.useBlobConnectionStr = true
-    getStorageConfig.mockResolvedValue(retreivedGetStorageConfig)
+    retrievedGetStorageConfig.useBlobConnectionStr = true
+    getStorageConfig.mockResolvedValue(retrievedGetStorageConfig)
     await getContainer()
     expect(getStorageConfig).toHaveBeenCalled()
   })

test/unit/processing/get-file.test.js

@@ -5,7 +5,7 @@ const mockStorageConfig = require('../../mocks/storage-config')
 const mockDelete = jest.fn()
 
 const mockGetFileClient = {
-  download: jest.fn().mockResolvedValue({ readableStreamBody: mockFileContent }),
+  downloadToBuffer: jest.fn().mockResolvedValue(mockFileContent),
   delete: mockDelete
 }
 const mockGetDirectoryClient = {