return 0;

}

/**

 @TODO: Use for constructing path to job data locally and/or on data.distren.org

 */

int job_build_path(char *filename, unsigned int jobnum)

{

  return 0;

}

int downloadTar(char *url, char *destinationPath){

  // Prepare to download the job tar if it isn't  present

  struct stat buffer;

  int fstatus = stat(destinationPath, &buffer);

  if(fstatus == -1)

    {

      // Download the Tar

      if( curlget(url, destinationPath) == 0){

        fprintf(stderr, "Job data retrieved successfully\n");

        // free(url); @FIXME: causes doublefree! Curl must free the url?

        return 0;

      }

      else {

        fprintf(stderr, "Downloading job data from %s failed. Check your network connection.\n",url);

        free(url);

        return 1; // Eventually make a retry loop

      }

    }

  else{

    fprintf(stderr, "Tar already exists! Download cancelled.\n");

    return 2;

  }

}

int uploadOutput(char *pathtoOutput, char *urltoOutput){

  if( !curlpost(pathtoOutput, urltoOutput)) // Uploads output

    {

      fprintf(stderr,"Upload successful, removing old output...\n");

      remove(pathtoOutput); // Delete the file after its uploaded

      return 0;

    }

  else

    {

      fprintf(stderr,"Upload failed. Check your network connection. Retrying upload...\n");

      int tries=1;

      while(tries<=10 && curlpost(pathtoOutput, urltoOutput))

        {

          fprintf(stderr, "Upload failed. Trying again in 10 seconds... (attempt %d of 10)\n", tries);

          tries++;

          sleep(10);

        }

      return 1; // Upload failed after multiple tries

      // @FUTURE: Keep track of files that we were unable to upload, and upload them later

    }

}

int unpackJob(char *pathtoTar, int jobnum){

  int ret;

  int buffsize = 8192;

  char *buff = "";

  size_t size;

  struct archive_entry *ae = archive_entry_new();

  struct archive *a = archive_read_new();

  archive_read_support_compression_all(a);

  archive_read_support_format_raw(a);

  ret = archive_read_open_filename(a, pathtoTar, 16384);

  if (ret != ARCHIVE_OK) {

    return 1;

  }

  ret = archive_read_next_header(a, &ae);

  if (ret != ARCHIVE_OK) {

    return 1;

  }

   for (;;) {

    size = archive_read_data(a, buff, buffsize);

    if (size < 0) {

      return 1;

    }

    if (size == 0)

      break;

    write(1, buff, size);

  }

  archive_read_finish(a);

  archive_entry_free(ae);

  return 0;

/*

  char *tarcmd;        // Command to run for tar. Migrate to libtar sometime

  char *outdir;        // Output Directory for tar

  _distren_asprintf(&outdir, "/tmp/distren/job%d", jobnum);

  mkdir("/tmp/distren", 0750); // @FIXME: Change to tmpdir once it exists

  mkdir(outdir, 0750);

  _distren_asprintf(&tarcmd, "tar -xvf \"%s\" -C \"%s\"", pathtoTar, outdir); // @FIXME:Use a lib here!

  system(tarcmd);

  free(tarcmd);

  free(pathtoTar);

  free(outdir);

  return 0;

  */

}

void prepareJobPaths(int jobnum,char *datadir, char **urltoTar,char **pathtoTar,char **pathtoJobfile,char **urltoOutput,char **pathtoXml){

  // Variable Preparation

  char *jobdatapath;

   _distren_asprintf(&jobdatapath, "job%d", jobnum);

   _distren_asprintf(urltoTar, "http://data.distren.org/job%d/job%d.tar.gz", jobnum); // Prepares URL to download from

   _distren_asprintf(pathtoTar, "%s/stor/jobdata/job%d.tar.gz", datadir, jobnum); // Prepares destination to save to

   _distren_asprintf(pathtoJobfile, "%s/%s/job.blend", datadir, jobdatapath ); // Prepares the path to the jobfile

   _distren_asprintf(urltoOutput, "http://data.distren.org/tmp/", jobdatapath ); // Prepares the URL where output is posted

   _distren_asprintf(pathtoXml, "%s/job%d/job%d.xml", datadir, jobnum ); // Prepares the path to the job's XML file

   free(jobdatapath);

}

int checkUsername(char *username){

  if(username == NULL || strcmp(username, "!username") == 0 ) {

     fprintf(stderr, "\nPlease ensure that your username is present in distrenslave.conf\n");

     return 0;

   }

   else

     if( username != NULL || strcmp(username, "!username") != 0 )

       {

         // Log in the user

         if(login_user(username) == 1){

           fprintf(stderr, "You should now be logged into distren.\n");

           return 0;

         }

         else

           {

             fprintf(stderr, "Login failed, please check your username. If you have not registered, please do so on the DistRen website.\n");

             return 1;

           }

       }

     else

       {

         fprintf(stderr, "Please check your distrenslave.conf, it appears to be incorrectly formatted.\n");

         return 1;

       }

}

void slaveTest(){

  int command;

  int test = 1;

  int jobnum = 0;

  fprintf(stderr,"Hello!\n");

  char tmpString1[100] = "";

  char tmpString2[100] = "";

  while(test == 1)

   {

     fprintf(stderr, "Welcome to DistRenSlave Alpha Interactive Test Mode\n\n");

     fprintf(stderr, "\t1 \tTest posting (uploading) data\n");

     fprintf(stderr, "\t2 \tTest getting frame from server\n");

     fprintf(stderr, "\t3 \tTest data downloading\n");

     fprintf(stderr, "\t4 \tTest archive decompression\n");

     fprintf(stderr, "\t5 \tQuit\n");

     scanf("%d", &command);

     switch(command)

     {

     case 1:

       fprintf(stderr,"Path to file to upload: ");

       scanf("%99s", tmpString1);

       fprintf(stderr,"URL to upload to: ");

       scanf("%99s", tmpString2);

       uploadOutput(tmpString1, tmpString2);

       break;

     case 2:

       fprintf(stderr,"Remotio not implemented yet!\n");

       break;

     case 3:

       fprintf(stderr,"URL to file: ");

       scanf("%s", tmpString1);

       fprintf(stderr,"Local save path (including filename): ");

       scanf("%s", tmpString2);

       if(downloadTar(tmpString1, tmpString2))

         fprintf(stderr,"Error downloading!\n");

       else

         fprintf(stderr,"Success!\n");

       break;

     case 4:

       fprintf(stderr,"Jobnum to decompress: ");

       fprintf(stderr,"Path to compressed data: ");

       unpackJob(tmpString1, jobnum);

       break;

     case 5:

       test = 0;

       break;

     default:

       fprintf(stderr, "Invalid input, please try again.\n");

       break;

     }

   }

}