X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=runtime%2Forg.argeo.slc.support.simple%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fjsch%2FScpTo.java;h=2c984bc22c7973aa357fd396c973d31ac6218703;hb=5fcacdb600e4c9e765cb93b46132932662832c1b;hp=8d7e49b01e4d24c1930e76dac7bc7ca499466c64;hpb=82da8aeebe37e93f26158678590f94341f8ea325;p=gpl%2Fargeo-slc.git diff --git a/runtime/org.argeo.slc.support.simple/src/main/java/org/argeo/slc/jsch/ScpTo.java b/runtime/org.argeo.slc.support.simple/src/main/java/org/argeo/slc/jsch/ScpTo.java index 8d7e49b01..2c984bc22 100644 --- a/runtime/org.argeo.slc.support.simple/src/main/java/org/argeo/slc/jsch/ScpTo.java +++ b/runtime/org.argeo.slc.support.simple/src/main/java/org/argeo/slc/jsch/ScpTo.java @@ -1,3 +1,19 @@ +/* + * Copyright (C) 2010 Mathieu Baudier + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + package org.argeo.slc.jsch; import java.io.ByteArrayInputStream; @@ -57,7 +73,7 @@ public class ScpTo extends AbstractJschTask { } if (localResource != null) { - uploadResource(session, localResource, remoteDir); + uploadResource(session, localResource); } } @@ -109,18 +125,19 @@ public class ScpTo extends AbstractJschTask { protected void uploadFile(Session session, File file, String remoteFile) { try { - uploadFile(session, new FileInputStream(file), file.length(), file + upload(session, new FileInputStream(file), file.length(), file .getPath(), file.toString(), remoteFile); } catch (FileNotFoundException e) { throw new SlcException("Cannot upload " + file, e); } } - protected void uploadResource(Session session, Resource resource, - String remoteFile) { + protected void uploadResource(Session session, Resource resource) { + String targetPath = remotePath != null ? remotePath : remoteDir + '/' + + resource.getFilename(); try { File lFile = resource.getFile(); - uploadFile(session, lFile, remotePath); + uploadFile(session, lFile, targetPath); } catch (IOException e) { // no underlying file found // load the resource in memory before transferring it @@ -137,10 +154,12 @@ public class ScpTo extends AbstractJschTask { IOUtils.copy(in, out); arr = out.toByteArray(); path = resource.getURL().getPath(); + if (path.startsWith("/")) + path = path.substring(1); } ByteArrayInputStream content = new ByteArrayInputStream(arr); - uploadFile(session, content, arr.length, path, resource - .toString(), remotePath); + upload(session, content, arr.length, path, resource.toString(), + targetPath); arr = null; } catch (IOException e1) { throw new SlcException("Can not interpret resource " @@ -152,7 +171,7 @@ public class ScpTo extends AbstractJschTask { } } - protected void uploadFile(Session session, InputStream in, long size, + protected void upload(Session session, InputStream in, long size, String path, String sourceDesc, String remoteFile) { OutputStream channelOut; InputStream channelIn;