ACPT-493: Upload csv with API request parameter

Author: aa-kashk

app/code/Magento/ImportExport/Model/Import.php

@@ -576,7 +576,15 @@ public function getErrorAggregator()
      */
     public function uploadSource()
     {
-        return $this->upload->uploadSource($this);
+        $result = $this->upload->uploadSource($this);
+        $entity = $this->getEntity();
+        // phpcs:ignore Magento2.Functions.DiscouragedFunction
+        $extension = pathinfo($result['file'], PATHINFO_EXTENSION);
+        $sourceFile = $this->getWorkingDir() . $entity . '.' . $extension;
+        $sourceFileRelative = $this->getVarDirectory()->getRelativePath($sourceFile);
+        $this->_removeBom($sourceFile);
+        $this->createHistoryReport($sourceFileRelative, $entity, $extension, $result);
+        return $sourceFile;
     }
 
     /**
@@ -626,7 +634,7 @@ public function getVarDirectory()
      * @return $this
      * @throws FileSystemException
      */
-    public function _removeBom($sourceFile)
+    protected function _removeBom($sourceFile)
     {
         $driver = $this->_varDirectory->getDriver();
         $string = $driver->fileGetContents($this->_varDirectory->getAbsolutePath($sourceFile));
@@ -809,7 +817,7 @@ public function isReportEntityType($entity = null)
      * @return $this
      * @throws LocalizedException
      */
-    public function createHistoryReport($sourceFileRelative, $entity, $extension = null, $result = null)
+    protected function createHistoryReport($sourceFileRelative, $entity, $extension = null, $result = null)
     {
         if ($this->isReportEntityType($entity)) {
             if (is_array($sourceFileRelative)) {

app/code/Magento/ImportExport/Model/Source/Upload.php

@@ -63,7 +63,7 @@ public function __construct(
      *
      * @param Import $import
      * @throws LocalizedException
-     * @return string Source file path
+     * @return array
      */
     public function uploadSource(Import $import)
     {
@@ -122,8 +122,6 @@ public function uploadSource(Import $import)
                 throw new LocalizedException(__('The source file moving process failed.'));
             }
         }
-        $import->_removeBom($sourceFile);
-        $import->createHistoryReport($sourceFileRelative, $entity, $extension, $result);
-        return $sourceFile;
+        return $result;
     }
 }