fprintf(stderr, "-%c: invalid option specified\n", optopt);

           return 1;

         }

       else if(curopt == 'h')

         {

           fprintf(stderr, "Usage: distrenslave [option] \nStarts a distren slave\n\t-u\tset username (run after fresh install)\n\t-t\tEnter test mode\n\t-h\tshow this help\n");

           return 2;

         }

       else if(curopt == 't')

         {

           slaveTest();

           return 0;

         }

       else if(curopt == 'u')

         username = strdup(optarg);

         fprintf(stderr, "Putting username \"%s\" in distrenslave.conf\n", username);

         conf_replace("distrenslave.conf", "!username", username);

         fprintf(stderr, "Please invoke distrenslave with no arguments to run with the username you just set\n");

         return 0;

     }

  /* Get conf data */

  options_init(argc, argv, &my_cfg, myopts, "slave", &commonopts);

  /* Notifies the user if there no username in .conf */

  if(checkUsername(username))

    return 1;

  fprintf(stderr, "Connecting to server...\n");

  if(remoteio_open(&comm_slave, commonopts->remoteio, server))

    {

      fprintf(stderr, "Error connecting to server; exiting\n");

      return 1;

    }

  // Variables needed for main loop

  int jobnum = 0;

  int framenum = 0;

  int slavekey = atoi(username); // @TODO: Make this more friendly

  char *urltoTar;      /* Full URL to the server-side location of job#.tgz */

  char *pathtoTar;     /* Full path to the location of the job#.tgz */

  char *urltoOutput;   /* Full URL where output is posted */

  char *pathtoOutput;  /* Full path to the output (rendered) file */

  char *pathtoJobfile; /* Full path to the job's main file */

  char *outputExt;     /* Output Extension (e.g., JPG) */

  int haveWork = 0;

  int quit = 0;

  // Main loop

  while(!quit)

    {

    // request work

    fprintf(stderr,"Requesting work...\n");

    sendSignal(comm_slave, DISTREN_REQUEST_GETWORK);

    /* If we got a frame */

    if(haveWork)

      {

        fprintf(stderr,"Got work from server...\n");

        /* @TODO: Add remotio hooks */

        // jobnum = remoteio_read(jobnum); /* Set jobnum from remoteio (we could use info from struct, but we need this info to download the xmlfile */

        // framenum = remoteio_read(jobnum); /* Set framenum from remoteio */

        fprintf(stderr, "Preparing to render frame %d in job %d\n", framenum, jobnum);

        if(downloadTar(urltoTar, pathtoTar))

          return 1;

        unpackJob(pathtoTar, jobnum);

        /* Prepares the path to the jobfile */

        _distren_asprintf(&pathtoOutput, "%s/job%d/output/job%d-frame%d.%s", datadir, jobnum, jobnum, framenum, outputExt );

        free(outputExt);

        /* Execute blender */

        if(exec_blender(pathtoJobfile, pathtoOutput, framenum))

          {

            fprintf(stderr,"Error running Blender. Check your installation and/or your PATH.\n");

            return 1;

          }

        free(pathtoJobfile);

        /* Post-execution */

        fprintf(stderr, "Finished frame %d in job %d, uploading...\n", framenum, jobnum);

        uploadOutput(pathtoOutput, urltoOutput, jobnum, framenum, slavekey); // @TODO: Handle return value

        free(urltoOutput);

        free(pathtoOutput);

        // Tell the server that rendering and upload are complete of "jobjum.framenum"

	char *jobFrame;

	_distren_asprintf(&jobFrame, "%s.%s", jobnum, framenum);

        sendExtSignal(comm_slave, DISTREN_REQUEST_DONEFRAME, jobFrame);

	free(jobFrame);

      }

    else

      fprintf(stderr,"Nothing to do. Idling...\n");

    // @TODO: If the server says that every frame for the last jobnum is finished, OR if the data is getting old

    if(1 == 0)

      {

        // Note: individual frames are already deleted after uploading,

        // except for ones that couldn't be uploaded

        delete_jobdata(jobnum, datadir);

      }

    sleep(5); // Poll 5 seconds. @TODO: Remove all polling

  }

  fprintf(stderr,"Closing connection to server...\n");

  remoteio_close(comm_slave);

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

  return 0;

}

  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;

  */

}

  // 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://distren.org/slaveUpload.php"); // Prepares the URL where output is posted

   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;

  int framenum = 0;

  int slavekey = 0;

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

  char tmpString1[100] = "";

  char tmpString2[100] = "";

  char *uploadURL = "http://distren.org/slaveUpload.php";

  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");

  This file is a part of DistRen.

  DistRen is free software: you can redistribute it and/or modify

  it under the terms of the GNU Affero General Public License as published by

  the Free Software Foundation, either version 3 of the License, or

  (at your option) any later version.

  DistRen 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 Affero General Public License for more details.

  You should have received a copy of the GNU Affero General Public License

  along with DistRen.  If not, see <http://www.gnu.org/licenses/>.

*/

#ifndef _DISTREN_SLAVEFUNCS_H

#define _DISTREN_SLAVEFUNCS_H

#include "distrenjob.h"

#include "common/remoteio.h"

#include <libxml/xpath.h>

#include <stdio.h>

struct msg;

int sendSignal(struct remoteio *rem, char signal);

int sendExtSignal(struct remoteio *rem, char signal, char *data);

xmlNodePtr xml_quickxpath(xmlXPathContextPtr xpathctxt, xmlChar *path);

int software_updatecheck();

int delete_jobdata(int jobnum, char *datadir);

size_t curl_writetodisk(void *ptr, size_t size, size_t nmemb, FILE *stream);

int curlget(char *url, char *out);

int curlpost(char *filename, char *url, int jobnum, int framenum, int slavekey);

int ssh_keygen();

int register_user(char *username, char *email);

int login_user(char *username);

int conf_replace(char *conffile, char *wordtoreplace, char *replacewith);

int exec_blender(char *input, char *output, int frame);

void xmlinit();

void xmlcleanup();

int distren_mkdir_recurse(char *dirname);

int job_build_path(char *filename, unsigned int jobnum);

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

int uploadOutput(char *pathtoOutput, char *urltoOutput, int jobnum, int framenum, int slavekey);

int unpackJob(char *pathtoTar, int jobnum);

int checkUsername(char *username);

void slaveTest();

#endif