Merge branch 'public-release/v1.2.4-221' into public-release/v1.2.4-223

Signed-off-by: Uladzislau <[email protected]>

Author: KUGDev

.gitignore

@@ -3,6 +3,8 @@
 .intellijPlatform
 /build
 /ide_for_launch
+/out
+/allure-results
 
 verifier-all.jar
 

CHANGELOG.md

@@ -1,6 +1,19 @@
 # IntelliJ Plugin Changelog
 
-All notable changes to the Zowe IntelliJ Plugin will be documented in this file.
+All notable changes to the For Mainframe Plugin will be documented in this file.
+
+## [Unreleased]
+
+### Bugfixes
+
+* Bugfix: Fixed issue with cross-system folder copy with name conflicts ([c5345051](https://github.com/zowe/zowe-explorer-intellij/commit/c5345051))
+* Bugfix: Clarified 401 error ([f36ec547](https://github.com/zowe/zowe-explorer-intellij/commit/f36ec547))
+* Bugfix: Fixed issue with USS copy that would lead to incorrect encoding error ([b4cb705a](https://github.com/zowe/zowe-explorer-intellij/commit/b4cb705a))
+* Bugfix: Fixed issue with jobs DDs display in console ([8a75f21a](https://github.com/zowe/zowe-explorer-intellij/commit/8a75f21a))
+* Bugfix: Fixed issue with copying another user's folder in USS ([66676550](https://github.com/zowe/zowe-explorer-intellij/commit/66676550))
+* Bugfix: Some encodings are made unsupported ([080c25ab](https://github.com/zowe/zowe-explorer-intellij/commit/080c25ab))
+* Bugfix: Fixed issue during a file upload to a PDS ([954bf01f](https://github.com/zowe/zowe-explorer-intellij/commit/954bf01f))
+* Bugfix: Fixed issue with URL field when typing incorrect information, the last slash at the end of https:// is deleted ([91ab962d](https://github.com/zowe/zowe-explorer-intellij/commit/91ab962d))
 
 ## [1.2.3-223] (2024-10-02)
 

gradle.properties

@@ -14,7 +14,7 @@ org.gradle.jvmargs=-Xss1M
 platformVersion = 2022.3
 
 # SemVer format -> https://semver.org
-pluginVersion = 1.2.3-223
+pluginVersion = 1.2.4-223
 pluginGroup = eu.ibagroup
 pluginRepositoryUrl = https://github.com/for-mainframe/For-Mainframe
 

src/main/kotlin/eu/ibagroup/formainframe/config/connect/ui/zosmf/ConnectionDialog.kt

@@ -31,12 +31,17 @@ import eu.ibagroup.formainframe.config.connect.*
 import eu.ibagroup.formainframe.config.connect.ui.ChangePasswordDialog
 import eu.ibagroup.formainframe.config.connect.ui.ChangePasswordDialogState
 import eu.ibagroup.formainframe.dataops.DataOpsManager
-import eu.ibagroup.formainframe.dataops.operations.*
+import eu.ibagroup.formainframe.dataops.operations.ChangePasswordOperation
+import eu.ibagroup.formainframe.dataops.operations.InfoOperation
+import eu.ibagroup.formainframe.dataops.operations.ZOSInfoOperation
 import eu.ibagroup.formainframe.explorer.EXPLORER_NOTIFICATION_GROUP_ID
-import eu.ibagroup.formainframe.utils.*
 import eu.ibagroup.formainframe.utils.crudable.Crudable
 import eu.ibagroup.formainframe.utils.crudable.find
 import eu.ibagroup.formainframe.utils.crudable.getAll
+import eu.ibagroup.formainframe.utils.runTask
+import eu.ibagroup.formainframe.utils.validateConnectionName
+import eu.ibagroup.formainframe.utils.validateForBlank
+import eu.ibagroup.formainframe.utils.validateZosmfUrl
 import org.zowe.kotlinsdk.ChangePassword
 import org.zowe.kotlinsdk.annotations.ZVersion
 import java.awt.Component
@@ -59,10 +64,11 @@ class ConnectionDialog(
    * In case of DialogMode.UPDATE takes the last successful state from crudable, takes default state otherwise
    */
   private val lastSuccessfulState: ConnectionDialogState =
-    if(state.mode == DialogMode.UPDATE) crudable.find<ConnectionConfig> { it.uuid == state.connectionUuid }
+    if (state.mode == DialogMode.UPDATE) crudable.find<ConnectionConfig> { it.uuid == state.connectionUuid }
       .findAny()
       .orElseGet { state.connectionConfig }
       .toDialogState(crudable) else ConnectionDialogState()
+
   companion object {
 
     /** Show Test connection dialog and test the connection regarding the dialog state.
@@ -81,11 +87,17 @@ class ConnectionDialog(
         initialState = initialState,
         factory = { ConnectionDialog(crudable, initialState, project) },
         test = { state ->
-          val newTestedConnConfig : ConnectionConfig
+          val newTestedConnConfig: ConnectionConfig
           if (initialState.mode == DialogMode.UPDATE) {
             val newState = state.clone()
             newState.initEmptyUuids(crudable)
-            newTestedConnConfig = ConnectionConfig(newState.connectionUuid, newState.connectionName, newState.connectionUrl, newState.isAllowSsl, newState.zVersion)
+            newTestedConnConfig = ConnectionConfig(
+              newState.connectionUuid,
+              newState.connectionName,
+              newState.connectionUrl,
+              newState.isAllowSsl,
+              newState.zVersion
+            )
             CredentialService.instance.setCredentials(
               connectionConfigUuid = newState.connectionUuid,
               username = newState.username,
@@ -97,7 +109,8 @@ class ConnectionDialog(
             CredentialService.instance.setCredentials(
               connectionConfigUuid = state.connectionUuid,
               username = state.username,
-              password = state.password)
+              password = state.password
+            )
           }
           val throwable = runTask(title = "Testing Connection to ${newTestedConnConfig.url}", project = project) {
             return@runTask try {
@@ -169,7 +182,7 @@ class ConnectionDialog(
         EXPLORER_NOTIFICATION_GROUP_ID,
         "Unable to retrieve USS username",
         "Cannot retrieve USS username. An error happened while executing TSO request.\n" +
-            "When working with USS files the same username will be used that was specified by the user when connecting.",
+          "When working with USS files the same username will be used that was specified by the user when connecting.",
         NotificationType.WARNING
       ).let {
         Notifications.Bus.notify(it, project)
@@ -215,7 +228,7 @@ class ConnectionDialog(
         textField()
           .bindText(state::connectionUrl)
           .validationOnApply {
-            it.text = it.text.trim().removeTrailingSlashes()
+            it.text = it.text.trim()
             validateForBlank(it) ?: validateZosmfUrl(it)
           }
           .also { urlTextField = it.component }

src/main/kotlin/eu/ibagroup/formainframe/dataops/attributes/RemoteUssAttributes.kt

@@ -76,7 +76,8 @@ data class RemoteUssAttributes(
   val gid: Long? = null,
   val groupId: String? = null,
   val modificationTime: String? = null,
-  val symlinkTarget: String? = null
+  val symlinkTarget: String? = null,
+  var charset: Charset = DEFAULT_BINARY_CHARSET
 ) : MFRemoteFileAttributes<ConnectionConfig, UssRequester>, Copyable {
 
   /**
@@ -98,7 +99,8 @@ data class RemoteUssAttributes(
     gid = ussFile.gid,
     groupId = ussFile.groupId,
     modificationTime = ussFile.modificationTime,
-    symlinkTarget = ussFile.target
+    symlinkTarget = ussFile.target,
+    charset = DEFAULT_BINARY_CHARSET
   )
 
   /**
@@ -163,8 +165,6 @@ data class RemoteUssAttributes(
               || mode == FileModeValue.READ_WRITE_EXECUTE.mode
     }
 
-  var charset: Charset = DEFAULT_BINARY_CHARSET
-
   override var contentMode: XIBMDataType = XIBMDataType(XIBMDataType.Type.BINARY)
 
   override val isCopyPossible: Boolean

src/main/kotlin/eu/ibagroup/formainframe/dataops/attributes/RemoteUssAttributesService.kt

@@ -84,7 +84,8 @@ class RemoteUssAttributesService(
       gid = newAttributes.gid,
       groupId = newAttributes.groupId,
       modificationTime = newAttributes.modificationTime,
-      symlinkTarget = newAttributes.symlinkTarget
+      symlinkTarget = newAttributes.symlinkTarget,
+      charset = oldAttributes.charset
     )
   }
 

src/main/kotlin/eu/ibagroup/formainframe/dataops/log/AbstractMFLoggerBase.kt

@@ -122,6 +122,13 @@ abstract class AbstractMFLoggerBase<PInfo: MFProcessInfo, LFetcher: LogFetcher<P
     this.onFinishHandler = finishHandler
   }
 
+  /**
+   * Fetch log files
+   */
+  override fun fetchLog() {
+    logFetcher.fetchLog(mfProcessInfo)
+  }
+
   /**
    * Sets onNextLog handler.
    */

src/main/kotlin/eu/ibagroup/formainframe/dataops/log/MFLogger.kt

@@ -37,6 +37,11 @@ interface MFLogger<LFetcher: LogFetcher<out MFProcessInfo>> {
    */
   fun onLogFinished(finishHandler: () -> Unit)
 
+  /**
+   * Fetch log files
+   */
+  fun fetchLog()
+
   /**
    * Sets handler for event after requesting next portion of mainframe log.
    * @param nextLogHandler handler that will be invoked after next request to fetching log from mainframe.

src/main/kotlin/eu/ibagroup/formainframe/dataops/operations/InfoOperationRunner.kt

@@ -57,7 +57,11 @@ class InfoOperationRunner : OperationRunner<InfoOperation, SystemsResponse> {
       .cancelByIndicator(progressIndicator)
       .execute()
     if (!response.isSuccessful) {
-      val headMessage = responseMessageMap[response.message()] ?: response.message()
+      log.info("Test connection response: $response")
+      val zosmfMessage = response.message().trim()
+      val headMessage = if (zosmfMessage.isNotEmpty())
+        responseMessageMap[zosmfMessage] ?: zosmfMessage
+      else responseMessageMap["Unauthorized"] ?: zosmfMessage
       throw CallException(response, headMessage)
     }
     return response.body() ?: throw CallException(response, "Cannot parse z/OSMF info request body")

src/main/kotlin/eu/ibagroup/formainframe/dataops/operations/mover/CrossSystemMemberOrUssFileToPdsMover.kt

@@ -42,6 +42,8 @@ class CrossSystemMemberOrUssFileToPdsMoverFactory : OperationRunnerFactory {
  */
 class CrossSystemMemberOrUssFileToPdsMover(val dataOpsManager: DataOpsManager) : AbstractFileMover() {
 
+  private val sourceContentType = "text/plain; charset=UTF-8"
+
   /**
    * Checks that source is member or uss file, dest is partitioned data set, and they are located inside different systems.
    * @see OperationRunner.canRun
@@ -89,17 +91,22 @@ class CrossSystemMemberOrUssFileToPdsMover(val dataOpsManager: DataOpsManager) :
     else XIBMDataType(XIBMDataType.Type.TEXT)
 
     val sourceContent = sourceFile.contentsToByteArray()
-    val contentToUpload =
-      if (sourceFile.fileType.isBinary) sourceContent
-      else sourceContent.toString(sourceFile.charset).replace("\r\n", "\n")
-        .toByteArray(DEFAULT_TEXT_CHARSET).addNewLine()
+
+    // do not convert bytes to default ISO. z/OSMF does this conversion by calling iconv and produce the desired result
+    val contentToUpload = if (sourceFile.fileType.isBinary) sourceContent else
+      sourceContent
+        .toString(sourceFile.charset)
+        .replace("\r\n", "\n")
+        .toByteArray()
+        .addNewLine()
 
     val response = apiWithBytesConverter<DataAPI>(destConnectionConfig).writeToDatasetMember(
       authorizationToken = destConnectionConfig.authToken,
       datasetName = destAttributes.name,
       memberName = memberName,
       content = contentToUpload,
-      xIBMDataType = xIBMDataType
+      xIBMDataType = xIBMDataType,
+      contentType = sourceContentType
     ).applyIfNotNull(progressIndicator) { indicator ->
       cancelByIndicator(indicator)
     }.execute()

src/main/kotlin/eu/ibagroup/formainframe/dataops/operations/mover/CrossSystemUssDirMover.kt

@@ -86,7 +86,7 @@ class CrossSystemUssDirMover(val dataOpsManager: DataOpsManager) : AbstractFileM
       sourceFileFetchProvider.reload(sourceQuery)
     }
 
-    val pathToDir = destAttributes.path + "/" + sourceFile.name
+    val pathToDir = destAttributes.path + "/" + (operation.newName ?: sourceFile.name)
 
     if (operation.forceOverwriting) {
       destFile.children.firstOrNull { it.name == sourceFile.name }?.let {
@@ -110,7 +110,7 @@ class CrossSystemUssDirMover(val dataOpsManager: DataOpsManager) : AbstractFileM
     val createdDirFile = attributesService.getOrCreateVirtualFile(
       RemoteUssAttributes(
         destAttributes.path,
-        UssFile(sourceFile.name, "drwxrwxrwx"),
+        UssFile(operation.newName ?: sourceFile.name, "drwxrwxrwx"),
         destConnectionConfig.url,
         destConnectionConfig
       )
@@ -153,4 +153,4 @@ class CrossSystemUssDirMover(val dataOpsManager: DataOpsManager) : AbstractFileM
     }
     log.info("USS directory has been moved successfully")
   }
-}
+}

src/main/kotlin/eu/ibagroup/formainframe/dataops/operations/mover/UssToUssFileMover.kt

@@ -106,7 +106,7 @@ class UssToUssFileMover(private val dataOpsManager: DataOpsManager) : AbstractFi
           from = from,
           overwrite = operation.forceOverwriting,
           links = CopyDataUSS.Links.ALL,
-          preserve = CopyDataUSS.Preserve.ALL,
+          preserve = CopyDataUSS.Preserve.NONE,
           recursive = true
         ),
         filePath = FilePath(