/*
    * This file is part of Waarp Project (named also Waarp or GG).
    *
    *  Copyright (c) 2019, Waarp SAS, and individual contributors by the @author
    *  tags. See the COPYRIGHT.txt in the distribution for a full listing of
    * individual contributors.
    *
    *  All Waarp Project is free software: you can redistribute it and/or
    * modify it under the terms of the GNU General Public License as published by
   * the Free Software Foundation, either version 3 of the License, or (at your
   * option) any later version.
   *
   * Waarp is distributed in the hope that it will be useful, but WITHOUT ANY
   * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
   * A PARTICULAR PURPOSE. See the GNU General Public License for more details.
   *
   *  You should have received a copy of the GNU General Public License along with
   * Waarp . If not, see <http://www.gnu.org/licenses/>.
   */
  package org.waarp.ftp.filesystembased;
  
  import org.waarp.common.command.exception.CommandAbstractException;
  import org.waarp.common.command.exception.Reply502Exception;
  import org.waarp.common.file.filesystembased.FilesystemBasedRestartImpl;
  import org.waarp.ftp.core.command.FtpArgumentCode.TransferMode;
  import org.waarp.ftp.core.command.FtpArgumentCode.TransferStructure;
  import org.waarp.ftp.core.command.FtpArgumentCode.TransferType;
  import org.waarp.ftp.core.data.FtpDataAsyncConn;
  import org.waarp.ftp.core.session.FtpSession;
  
  /**
   * Filesystem implementation of a Restart.<br>
   * Only FILE+STREAM is supported (byte position in file).
   */
  public class FilesystemBasedFtpRestart extends FilesystemBasedRestartImpl {
    /**
     * @param session
     */
    public FilesystemBasedFtpRestart(final FtpSession session) {
      super(session);
    }
  
    @Override
    public final boolean restartMarker(final String marker)
        throws CommandAbstractException {
      final FtpDataAsyncConn dataConn = ((FtpSession) getSession()).getDataConn();
      if (dataConn.getStructure() == TransferStructure.FILE &&
          dataConn.getMode() == TransferMode.STREAM &&
          dataConn.getType() != TransferType.LENGTH) {
        final long newposition;
        final String[] args = marker.split(" ");
        try {
          newposition = Long.parseLong(args[0]);
          if (args.length > 1) {
            limit = Integer.parseInt(args[1]);
          }
        } catch (final NumberFormatException e) {
          throw new Reply502Exception(
              "Marker must be length in byte as a position");
        }
        position = newposition;
        setSet(true);
        return true;
      }
      throw new Reply502Exception(
          "Marker not implemented for such Mode, Type and Structure");
    }
  }