fix: make plugin work on nodes

The workspace is not accessible directly inside plugins, the plugin must use a FileCallable that is serialized and called on the node having the workspace.

Author: baptistemesta

README.md

@@ -17,13 +17,19 @@ Configure as follow where
 pipeline {
     agent any
     stages {
+        stage('prepare file ') {
+            steps {
+                sh "echo 'someContent' > toUpload.txt"
+            }
+        }
         stage("upload to gdrive") {
             steps {
                 withCredentials([string(credentialsId: 'gdrive', variable: 'GDRIVE_CREDENTIALS')]) {
                     gdriveUpload(
                         googleCredentials: GDRIVE_CREDENTIALS,
-                        source: "/Users/baptiste/work/test_upload",
-                        destinationId: "14_Xpzuld0lGyg7HgZojwNsJsITW5jTh9"
+                        source: "toUpload.txt",
+                        destinationId: "14_Xpzuld0lGyg7HgZojwNsJsITW5jTh9",
+                        renameTo: "uploaded.txt"
                     )
                 }
             }

gdrive-core/src/main/kotlin/org/bonitasoft/gdrive/core/GDriveUploadTask.kt

@@ -43,15 +43,21 @@ class GDriveUploadTask(private val googleCredentials: String,
 	private fun copy(drive: Drive, file: java.io.File, destinationFolder: File, renameTo: String = "") {
 		logger.debug("Processing ${file.absolutePath}")
 		val fileName = renameTo.trim().ifEmpty { file.name }
+		if (fileName != file.name) {
+			logger.info("'${file.name}' will be renamed to '$fileName'")
+		}
+		if (!file.exists()) {
+			throw RuntimeException("The source file does not exists: ${file.absolutePath}");
+		}
 		if (file.isDirectory) {
 			val newFolder = createFolder(drive, fileName, destinationFolder)
-			logger.debug("created folder ${newFolder.name} with id ${newFolder.id}")
+			logger.debug("Created folder $fileName with id ${newFolder.id}")
 			file.listFiles().forEach { child ->
 				copy(drive, child, newFolder)
 			}
 		} else {
 			val uploadFile = uploadFile(drive, file, fileName, destinationFolder)
-			logger.info("Uploaded file folder ${uploadFile.name} with id ${uploadFile.id}")
+			logger.info("Uploaded file ${uploadFile.name} with id ${uploadFile.id}")
 		}
 	}
 

gdrive-jenkins/src/main/kotlin/org/bonitasoft/gdrive/jenkins/GDriveUploadStepExecution.kt

@@ -1,11 +1,17 @@
 package org.bonitasoft.gdrive.jenkins
 
 import hudson.AbortException
+import hudson.FilePath
+import hudson.FilePath.FileCallable
 import hudson.model.TaskListener
+import hudson.remoting.VirtualChannel
 import org.bonitasoft.gdrive.core.GDriveUploadTask
 import org.bonitasoft.gdrive.core.Logger
 import org.jenkinsci.plugins.workflow.steps.StepContext
 import org.jenkinsci.plugins.workflow.steps.SynchronousNonBlockingStepExecution
+import org.jenkinsci.remoting.RoleChecker
+import java.io.File
+import java.io.Serializable
 
 
 class GDriveUploadStepExecution(
@@ -18,14 +24,10 @@ class GDriveUploadStepExecution(
 	override fun run(): Void? {
 		val logger = context.get(TaskListener::class.java)?.logger!!
 		try {
-			val gdriveLogger = object : Logger {
-				override fun debug(message: String) = logger.println("DEBUG: $message")
-				override fun info(message: String) = logger.println("INFO: $message")
-				override fun warn(message: String) = logger.println("WARN: $message")
-				override fun error(message: String) = logger.println("ERROR: $message")
-			}
-			val task = GDriveUploadTask(googleCredentials, source, destinationId, gdriveLogger, renameTo)
-			task.execute()
+
+			val workspace = context.get(FilePath::class.java)!!
+			val logs = workspace.child(source).act(UploadFile(googleCredentials, destinationId, renameTo))
+			logs.forEach { logger.println(it) }
 			return null
 		} catch (e: Throwable) {
 			e.printStackTrace()
@@ -35,3 +37,33 @@ class GDriveUploadStepExecution(
 
 
 }
+
+class UploadFile(val googleCredentials: String, val destinationId: String, val renameTo: String) : FileCallable<List<String>>, Serializable {
+
+	override fun checkRoles(p0: RoleChecker?) = Unit
+	override fun invoke(file: File?, p1: VirtualChannel?): List<String> {
+		if (file == null) {
+			return listOf("File argument is null")
+		}
+		val logs = mutableListOf<String>()
+		val gdriveLogger = object : Logger {
+			override fun debug(message: String) {
+//				logs.add("DEBUG: $message")
+			}
+
+			override fun info(message: String) {
+				logs.add("INFO: $message")
+			}
+
+			override fun warn(message: String) {
+				logs.add("WARN: $message")
+			}
+
+			override fun error(message: String) {
+				logs.add("ERROR: $message")
+			}
+		}
+		GDriveUploadTask(googleCredentials, file.absolutePath, destinationId, gdriveLogger, renameTo).execute()
+		return logs
+	}
+}