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.ftp.core.command.service;
21  
22  import org.waarp.common.command.exception.CommandAbstractException;
23  import org.waarp.common.command.exception.Reply450Exception;
24  import org.waarp.common.command.exception.Reply501Exception;
25  import org.waarp.common.command.exception.Reply550Exception;
26  import org.waarp.common.logging.WaarpLogger;
27  import org.waarp.common.logging.WaarpLoggerFactory;
28  import org.waarp.ftp.core.command.AbstractCommand;
29  import org.waarp.ftp.core.file.FtpFile;
30  
31  /**
32   * RETR command
33   */
34  public class RETR extends AbstractCommand {
35    private static final WaarpLogger logger =
36        WaarpLoggerFactory.getInstance(RETR.class);
37  
38    @Override
39    public final void exec() throws CommandAbstractException {
40      if (!hasArg()) {
41        invalidCurrentCommand();
42        throw new Reply501Exception("Need a pathname as argument");
43      }
44      final String filename = getArg();
45      final FtpFile file = getSession().getDir().setFile(filename, false);
46      if (file != null) {
47        if (file.retrieve()) {
48          getSession().openDataConnection();
49          getSession().getDataConn().getFtpTransferControl()
50                      .setNewFtpTransfer(getCode(), file);
51          return;
52        }
53        logger.info("File not accessible: {}", file);
54        // FtpFile does not exist
55        throw new Reply450Exception("Retrieve operation not allowed");
56      }
57      logger.info("Filename not allowed: {}", filename);
58      // FtpFile name not allowed
59      throw new Reply550Exception("Filename not allowed");
60    }
61  
62  }