Transfers file to SFTP server

OutboundSFTP.groovy

import com.axeda.drm.sdk.Context
import com.axeda.drm.sdk.scripto.Request
import com.axeda.drm.sdk.audit.AuditCategory
import com.axeda.drm.sdk.audit.AuditMessage
import com.axeda.drm.sdk.contact.Location
import com.axeda.drm.sdk.contact.Organization
import com.axeda.drm.sdk.data.UploadedFile
import com.axeda.drm.sdk.device.Device
import com.axeda.drm.sdk.rules.ActionContext
import com.axeda.drm.util.Emailer
import com.axeda.platform.sdk.v1.services.extobject.ExtendedObject
import com.axeda.platform.sdk.v1.services.extobject.ExtendedObjectSearchCriteria
import com.axeda.platform.sdk.v1.services.extobject.ExtendedObjectService
import com.axeda.platform.sdk.v1.services.extobject.ExtendedObjectType
import com.axeda.platform.sdk.v1.services.extobject.Property
import com.axeda.platform.sdk.v1.services.extobject.PropertyDataType
import com.axeda.platform.sdk.v1.services.extobject.PropertyType
import com.axeda.platform.sdk.v1.services.factories.SpringExtendedServiceFactory
import com.jcraft.jsch.Channel
import com.jcraft.jsch.ChannelSftp
import com.jcraft.jsch.JSch
import com.jcraft.jsch.Session
import javax.mail.internet.InternetAddress
import static com.axeda.sdk.v2.dsl.Bridges.*
 
/**
* OutboundSFTP.groovy
*
* Transfers file to SFTP server
*
* @param server        -   (REQ):Str server address.
* 
* @param port        -   (REQ):Str server port.
* @param user       -   (REQ):Str FTP username.
* @param pass       -   (REQ):Str FTP password.
* @param workingdir  -   (REQ):Str FTP working directory.
* @param fileId       -   (REQ):Str Id of the FileInfo.
*
* @author sara streeter <sstreeter@axeda.com>
 *
*/
 
/**
 * initialize our global variables
 * json = the contents of our response
 * infoString = a stringBuilder used to collect debug information during the script
 * contentType = the content type we will return
 * scriptname = The name of this Script, used in multiple places
*/
def json = new groovy.json.JsonBuilder()
def infoString = new StringBuilder()
def contentType = "application/json"
def scriptName = "OutboundSFTP.groovy"
def root = ["result":["items":[]]]
 
try {
    
    def server = Request.parameters.server
    // you could also use external credentials for these
    def username = Request.parameters.user
    def password = Request.parameters.pass
    // this is the folder to send to
    def workingdir = Request.parameters.workingdir
    def fileInfoId = Request.parameters.fileId
   int port = Integer.valueOf(Request.parameters['port'])
     logger.info(fileInfoId)
     InputStream inputStream = fileInfoBridge.getFileData(fileInfoId)
     logger.info(inputStream.available())
	def fileinfo = fileInfoBridge.findById(fileInfoId)	
 logger.info(fileinfo?.filesize)
  def (result, failureMessage) = sendFile(server, port, username, password, workingdir, inputStream, fileinfo.label);
 
  if (result){
    logger.info "Send successful."

  }
  else {
    logger.info "Send failed."
  }
}
catch (Exception e){
  logger.error e.getMessage()
}
 
public sendFile(String address, int port, String userName,
                String password, String workingdir, InputStream inputStream,
                String fileNameToStore) {
   int TENSECONDS  = 10*1000
   int THIRTYSECONDS = 30*1000
  Session session = null;
  Channel channel = null;
  ChannelSftp sftpChannel = null;
 
  boolean error = false;
  String failureMessage = null;
 
  try {
    JSch jsch = new JSch();
    session = jsch.getSession(userName, address, port);
    session.setPassword(password)
    session.setConfig("StrictHostKeyChecking", "no");
    session.setTimeout(THIRTYSECONDS)
    session.connect();
 
    channel = session.openChannel("sftp");
    channel.connect();
    sftpChannel = (ChannelSftp)channel;
 
    
      sftpChannel.cd(workingdir);
    
    if (!sftpChannel.cd(workingdir)){
      throw new Exception( "Directory $workingdir does not exist.")
    }
 
    // Store the file
    sftpChannel.put(inputStream, fileNameToStore);
  }
  catch (Exception e){
    error = true;
    failureMessage = e.getMessage();
    errorStr = e.getMessage();
    logger.error "Could not send file to SFTP: " + errorStr
  }
  finally{

    sftpChannel?.exit();
    channel?.disconnect();
    session?.disconnect();
  }
  return [!error, failureMessage] ;
}