Blame src/EditJob.cc

Packit Service a2489d
/*
Packit Service a2489d
 * lftp - file transfer program
Packit Service a2489d
 *
Packit Service a2489d
 * Copyright (c) 1996-2015 by Alexander V. Lukyanov (lav@yars.free.net)
Packit Service a2489d
 *
Packit Service a2489d
 * This program is free software; you can redistribute it and/or modify
Packit Service a2489d
 * it under the terms of the GNU General Public License as published by
Packit Service a2489d
 * the Free Software Foundation; either version 3 of the License, or
Packit Service a2489d
 * (at your option) any later version.
Packit Service a2489d
 *
Packit Service a2489d
 * This program is distributed in the hope that it will be useful,
Packit Service a2489d
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
Packit Service a2489d
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
Packit Service a2489d
 * GNU General Public License for more details.
Packit Service a2489d
 *
Packit Service a2489d
 * You should have received a copy of the GNU General Public License
Packit Service a2489d
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
Packit Service a2489d
 */
Packit Service a2489d
Packit Service a2489d
#include <config.h>
Packit Service a2489d
#include <sys/types.h>
Packit Service a2489d
#include <sys/stat.h>
Packit Service a2489d
Packit Service a2489d
#include "EditJob.h"
Packit Service a2489d
#include "GetJob.h"
Packit Service a2489d
#include "SysCmdJob.h"
Packit Service a2489d
Packit Service a2489d
void EditJob::Finish(int e)
Packit Service a2489d
{
Packit Service a2489d
   exit_code=e;
Packit Service a2489d
   done=true;
Packit Service a2489d
   if(!keep)
Packit Service a2489d
      unlink(temp_file);
Packit Service a2489d
}
Packit Service a2489d
Packit Service a2489d
int EditJob::HandleJob(JobRef<Job>& j,bool fail)
Packit Service a2489d
{
Packit Service a2489d
   if(!j->Done())
Packit Service a2489d
      return STALL;
Packit Service a2489d
   if(j->ExitCode() && fail)
Packit Service a2489d
      Finish(1);
Packit Service a2489d
   RemoveWaiting(j);
Packit Service a2489d
   return MOVED;
Packit Service a2489d
}
Packit Service a2489d
Packit Service a2489d
int EditJob::Do()
Packit Service a2489d
{
Packit Service a2489d
   int m=STALL;
Packit Service a2489d
   if(Done())
Packit Service a2489d
      return m;
Packit Service a2489d
   if(put) {
Packit Service a2489d
      if(!HandleJob(put))
Packit Service a2489d
	 return m;
Packit Service a2489d
      if(done)
Packit Service a2489d
	 return MOVED;
Packit Service a2489d
      Finish(0);
Packit Service a2489d
      return MOVED;
Packit Service a2489d
   }
Packit Service a2489d
   if(editor) {
Packit Service a2489d
      if(!HandleJob(editor))
Packit Service a2489d
	 return m;
Packit Service a2489d
      if(done)
Packit Service a2489d
	 return MOVED;
Packit Service a2489d
      struct stat st;
Packit Service a2489d
      int res=stat(temp_file,&st);
Packit Service a2489d
      if(res<0) {
Packit Service a2489d
	 perror(temp_file);
Packit Service a2489d
	 Finish(1);
Packit Service a2489d
	 return MOVED;
Packit Service a2489d
      }
Packit Service a2489d
      if(st.st_mtime!=mtime) {
Packit Service a2489d
	 ArgV *args=new ArgV("put");
Packit Service a2489d
	 args->Append(temp_file);
Packit Service a2489d
	 args->Append(file);
Packit Service a2489d
	 GetJob *j=new GetJob(session->Clone(),args,false);
Packit Service a2489d
	 j->Reverse();
Packit Service a2489d
	 put=j;
Packit Service a2489d
	 AddWaiting(put);
Packit Service a2489d
	 return MOVED;
Packit Service a2489d
      }
Packit Service a2489d
      Finish(0);
Packit Service a2489d
      return MOVED;
Packit Service a2489d
   }
Packit Service a2489d
   if(get) {
Packit Service a2489d
      if(!HandleJob(get,false))
Packit Service a2489d
	 return m;
Packit Service a2489d
      if(done)
Packit Service a2489d
	 return MOVED;
Packit Service a2489d
      struct stat st;
Packit Service a2489d
      int res=stat(temp_file,&st);
Packit Service a2489d
      mtime=(res>=0?st.st_mtime:NO_DATE);
Packit Service a2489d
      xstring cmd("${EDITOR:-vi} ");
Packit Service a2489d
      cmd.append(shell_encode(temp_file));
Packit Service a2489d
      editor=new SysCmdJob(cmd);
Packit Service a2489d
      AddWaiting(editor);
Packit Service a2489d
      return MOVED;
Packit Service a2489d
   }
Packit Service a2489d
   else {
Packit Service a2489d
      ArgV *args=new ArgV("get");
Packit Service a2489d
      args->Append(file);
Packit Service a2489d
      args->Append(temp_file);
Packit Service a2489d
      get=new GetJob(session->Clone(),args,false);
Packit Service a2489d
      AddWaiting(get);
Packit Service a2489d
      return MOVED;
Packit Service a2489d
   }
Packit Service a2489d
   return m;
Packit Service a2489d
}