View Javadoc
1   /*
2    * This file is part of Waarp Project (named also Waarp or GG).
3    *
4    *  Copyright (c) 2019, Waarp SAS, and individual contributors by the @author
5    *  tags. See the COPYRIGHT.txt in the distribution for a full listing of
6    * individual contributors.
7    *
8    *  All Waarp Project is free software: you can redistribute it and/or
9    * modify it under the terms of the GNU General Public License as published by
10   * the Free Software Foundation, either version 3 of the License, or (at your
11   * option) any later version.
12   *
13   * Waarp is distributed in the hope that it will be useful, but WITHOUT ANY
14   * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
15   * A PARTICULAR PURPOSE. See the GNU General Public License for more details.
16   *
17   *  You should have received a copy of the GNU General Public License along with
18   * Waarp . If not, see <http://www.gnu.org/licenses/>.
19   */
20  package org.waarp.openr66.context.task;
21  
22  import org.waarp.common.command.exception.Reply550Exception;
23  import org.waarp.common.file.DirInterface;
24  import org.waarp.common.file.FileUtils;
25  import org.waarp.common.logging.WaarpLogger;
26  import org.waarp.common.logging.WaarpLoggerFactory;
27  import org.waarp.openr66.context.R66Session;
28  
29  import java.io.File;
30  
31  /**
32   * Move the file (without renaming it)
33   */
34  public class MoveTask extends AbstractTask {
35    /**
36     * Internal Logger
37     */
38    private static final WaarpLogger logger =
39        WaarpLoggerFactory.getLogger(MoveTask.class);
40  
41    /**
42     * @param argRule
43     * @param delay
44     * @param argTransfer
45     * @param session
46     */
47    public MoveTask(final String argRule, final int delay,
48                    final String argTransfer, final R66Session session) {
49      super(TaskType.MOVE, delay, argRule, argTransfer, session);
50    }
51  
52    @Override
53    public final void run() {
54      logger.info("Move with " + argRule + ':' + argTransfer + " and {}",
55                  session);
56      String directory = argRule;
57      directory = getReplacedValue(directory, BLANK.split(argTransfer)).trim()
58                                                                       .replace(
59                                                                           '\\',
60                                                                           '/');
61      final String finalname =
62          directory + DirInterface.SEPARATOR + session.getFile().getBasename();
63      final File from = session.getFile().getTrueFile();
64      final File to = new File(finalname);
65      try {
66        FileUtils.copy(from, to, true, false);
67      } catch (final Reply550Exception e) {
68        logger.error(
69            "Move with " + argRule + ':' + argTransfer + " to " + finalname +
70            " and " + session + ": {}", e.getMessage());
71        futureCompletion.setFailure(e);
72        return;
73      }
74      session.getRunner().setFileMoved(finalname, true);
75      futureCompletion.setSuccess();
76  
77    }
78  
79  }