Add content for api response on upload SDK methods

packages/zosfiles/CHANGELOG.md

@@ -4,6 +4,7 @@ All notable changes to the Zowe z/OS files SDK package will be documented in thi
 
 ## Recent Changes
 
+- BugFix: Corrected the `apiResponse` response value from `streamToDataSet()`,`streamToUss()`,`bufferToUss()` and `bufferToDataSet()` on the Upload SDK. [#2381](https://github.com/zowe/zowe-cli/pull/2381)
 - BugFix: Corrected the `Upload.BufferToUssFile()` SDK function to properly tag uploaded files. [#2378](https://github.com/zowe/zowe-cli/pull/2378)
 
 ## `8.9.0`

packages/zosfiles/__tests__/__system__/methods/upload/Upload.system.test.ts

@@ -19,6 +19,7 @@ import { deleteFiles, getUniqueDatasetName, stripNewLines, wait, waitTime } from
 import * as fs from "fs";
 import { ITestEnvironment } from "../../../../../../__tests__/__src__/environment/ITestEnvironment";
 import { runCliScript } from "../../../../../../__tests__/__packages__/cli-test-utils/src";
+import { Readable } from "stream";
 
 let REAL_SESSION: Session;
 let testEnvironment: ITestEnvironment<ITestPropertiesSchema>;
@@ -309,6 +310,49 @@ describe("Upload Data Set", () => {
                 }
             });
 
+            it("should upload a PDS file - bufferToDataSet()", async () => {
+                let error;
+                let uploadResponse;
+                let getResponse;
+                const data: Buffer = Buffer.from(testdata);
+
+                try {
+                    uploadResponse = await Upload.bufferToDataSet(REAL_SESSION, data, dsname+"(TEST)");
+                    getResponse = await Get.dataSet(REAL_SESSION, dsname+"(TEST)");
+                } catch (err) {
+                    error = err;
+                    Imperative.console.info("Error: " + inspect(error));
+                }
+
+                expect(error).toBeFalsy();
+
+                expect(uploadResponse.apiResponse).toMatchObject({"success": true, "from": "Buffer<>","to": dsname+"(TEST)"});
+                expect(Buffer.from(getResponse.toString().trim())).toEqual(data);
+            });
+
+            it("should upload a PDS file - streamToDataSet()", async () => {
+                let error;
+                let uploadResponse;
+                let getResponse;
+
+                const inputStream = new Readable();
+                inputStream.push(testdata);
+                inputStream.push(null);
+
+                try {
+                    uploadResponse = await Upload.streamToDataSet(REAL_SESSION, inputStream, dsname+"(TEST)");
+                    getResponse = await Get.dataSet(REAL_SESSION, dsname+"(TEST)");
+                } catch (err) {
+                    error = err;
+                    Imperative.console.info("Error: " + inspect(error));
+                }
+
+                expect(error).toBeFalsy();
+
+                expect(uploadResponse.apiResponse).toMatchObject({"success": true, "from": "Stream<>","to": dsname+"(TEST)"});
+                expect(getResponse.toString().trim()).toEqual(testdata);
+            });
+
             it("should upload a file to a partitioned data set member using full path", async () => {
                 let error;
                 let response: IZosFilesResponse;
@@ -733,7 +777,7 @@ describe("Upload USS file", () => {
             await deleteFiles(REAL_SESSION, ussname);
         });
 
-        it("should upload a USS file", async () => {
+        it("should upload a USS file - bufferToUssFile()", async () => {
             let error;
             let uploadResponse;
             let getResponse;
@@ -748,9 +792,33 @@ describe("Upload USS file", () => {
             }
 
             expect(error).toBeFalsy();
+
+            expect(uploadResponse.apiResponse).toMatchObject({"success": true, "from": "Buffer<>","to": ussname});
             expect(getResponse).toEqual(Buffer.from(data.toString()));
+        });
 
+        it("should upload a USS file - streamToUssFile()", async () => {
+            let error;
+            let uploadResponse;
+            let getResponse;
+            const inputStream = new Readable();
+            inputStream.push(testdata);
+            inputStream.push(null);
+
+            try {
+                uploadResponse = await Upload.streamToUssFile(REAL_SESSION, ussname, inputStream);
+                getResponse = await Get.USSFile(REAL_SESSION, ussname);
+            } catch (err) {
+                error = err;
+                Imperative.console.info("Error: " + inspect(error));
+            }
+
+            expect(error).toBeFalsy();
+
+            expect(uploadResponse.apiResponse).toMatchObject({"success": true, "from": "Stream<>","to": ussname});
+            expect(getResponse).toEqual(Buffer.from(testdata));
         });
+
         it("should upload a USS file in binary mode", async () => {
             let error;
             let uploadResponse;

packages/zosfiles/__tests__/__unit__/methods/upload/Upload.unit.test.ts

@@ -392,6 +392,7 @@ describe("z/OS Files - Upload", () => {
 
             expect(error).toBeUndefined();
             expect(response).toBeDefined();
+            expect(response.apiResponse).toMatchObject({"from": "Buffer<>", "success": true, "to": dsName});
 
             expect(zosmfPutFullSpy).toHaveBeenCalledTimes(1);
             expect(zosmfPutFullSpy).toHaveBeenCalledWith(dummySession, {resource: endpoint,
@@ -748,6 +749,7 @@ describe("z/OS Files - Upload", () => {
 
             expect(error).toBeUndefined();
             expect(response).toBeDefined();
+            expect(response.apiResponse).toMatchObject({"from": "Stream<>", "success": true, "to": dsName});
 
             expect(zosmfPutFullSpy).toHaveBeenCalledTimes(1);
             expect(zosmfPutFullSpy).toHaveBeenCalledWith(dummySession, {resource: endpoint,
@@ -1755,6 +1757,7 @@ describe("z/OS Files - Upload", () => {
 
             expect(error).toBeUndefined();
             expect(USSresponse).toBeDefined();
+            expect(USSresponse.apiResponse).toMatchObject({"from": "Buffer<>", "success": true, "to": dsName});
 
             const normalizedData = ZosFilesUtils.normalizeNewline(data);
             expect(data.length).not.toBe(normalizedData.length);
@@ -1830,6 +1833,7 @@ describe("z/OS Files - Upload", () => {
 
             expect(error).toBeUndefined();
             expect(USSresponse).toBeDefined();
+            expect(USSresponse.apiResponse).toMatchObject({"from": "Stream<>", "success": true, "to": dsName});
             expect(USSresponse.success).toBeTruthy();
 
             expect(zosmfExpectFullSpy).toHaveBeenCalledTimes(1);

packages/zosfiles/src/methods/upload/Upload.ts

@@ -184,7 +184,11 @@ export class Upload {
         const uploadRequest: IRestClientResponse = await ZosmfRestClient.putExpectFullResponse(session, requestOptions);
 
         // By default, apiResponse is empty when uploading
-        const apiResponse: any = {};
+        const apiResponse: any = {
+            success: true,
+            from: "Buffer<>",
+            to: dataSetName
+        };
 
         // Return Etag in apiResponse, if requested
         if (options.returnEtag) {
@@ -242,7 +246,11 @@ export class Upload {
         const uploadRequest: IRestClientResponse = await ZosmfRestClient.putExpectFullResponse(session, requestOptions);
 
         // By default, apiResponse is empty when uploading
-        const apiResponse: any = {};
+        const apiResponse: any = {
+            success: true,
+            from: "Stream<>",
+            to: dataSetName
+        };
 
         // Return Etag in apiResponse, if requested
         if (options.returnEtag) {
@@ -481,7 +489,12 @@ export class Upload {
         const uploadRequest: IRestClientResponse = await ZosmfRestClient.putExpectFullResponse(session, requestOptions);
 
         // By default, apiResponse is empty when uploading
-        const apiResponse: any = {};
+        const apiResponse: any =
+        {
+            success: true,
+            from: "Buffer<>",
+            to: origUssname
+        };
 
         // Return Etag in apiResponse, if requested
         if (options.returnEtag) {
@@ -541,7 +554,11 @@ export class Upload {
         }
 
         // By default, apiResponse is empty when uploading
-        const apiResponse: any = {};
+        const apiResponse: any = {
+            success: true,
+            from: "Stream<>",
+            to: origUssname
+        };
 
         // Return Etag in apiResponse, if requested
         if (options.returnEtag) {