gerrit.akraino Code Review - camunda_workflow.git/blob

   1 /*
   2  * Copyright (c) 2018 AT&T Intellectual Property. All rights reserved.
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  *        http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16
  17 package com.akraino.bpm.delegate;
  18
  19 import org.camunda.bpm.engine.delegate.DelegateExecution;
  20 import org.camunda.bpm.engine.delegate.JavaDelegate;
  21 import org.slf4j.Logger;
  22 import org.slf4j.LoggerFactory;
  23 import org.springframework.beans.factory.annotation.Autowired;
  24 import org.springframework.stereotype.Component;
  25
  26 import com.akraino.bpm.service.DeployResponseSenderService;
  27 import com.akraino.bpm.service.RemoteScriptExecutionService;
  28
  29
  30
  31 @Component
  32 public class MultiNodeDeployRemoteScript1ExecutorTaskDelegate implements JavaDelegate {
  33
  34
  35         private static Logger logger = LoggerFactory.getLogger(MultiNodeDeployRemoteScript1ExecutorTaskDelegate.class);
  36
  37         @Autowired
  38         RemoteScriptExecutionService remoteScriptExecutionService;
  39
  40         @Autowired
  41         DeployResponseSenderService deployResponseSenderService;
  42
  43
  44         public void execute(DelegateExecution ctx) throws Exception {
  45
  46
  47                 String  remotserver=(String)ctx.getVariable("remotserver");
  48                 int  portnumner=(Integer)ctx.getVariable("port");
  49                 String  username=(String)ctx.getVariable("username");
  50                 String  password=(String)ctx.getVariable("password");
  51                 String  filename=(String)ctx.getVariable("remotefile1");
  52                 String fileparams=(String)ctx.getVariable("remotefile1params");
  53                 String destdir=(String)ctx.getVariable("destdir1");
  54
  55                 logger.debug("task execution started remotserver {} , portnumner {},username {}, password {},filename : {} ,fileparams={},dest dir={}",
  56                                 remotserver,portnumner,username,password,filename,fileparams,destdir);
  57                 String command="cd   "+destdir+ ";" +" bash  "+filename+"  "+ (fileparams!=null?fileparams:" ") ;
  58                 logger.debug("Execution command {}",command);
  59                 remoteScriptExecutionService.executeRemoteScript(remotserver,username,password,portnumner,filename,fileparams,null,destdir,command);
  60         }
  61
  62 }