ACLOCAL_AMFLAGS = -I m4

AM_CPPFLAGS = -DSYSCONFDIR='"$(sysconfdir)"' \

	-DLOCALSTATEDIR='"$(localstatedir)"' \

	-I$(top_srcdir)/src

AM_CFLAGS = $(DISTLIBS_CFLAGS)

LIBS = $(DISTLIBS_LDADD) $(DISTLIBS_LDFLAGS)

LDADD = libdistrencommon.la

bin_PROGRAMS = 

if ENABLE_SERVER

endif

pkglib_LTLIBRARIES = libdistrencommon.la

# libdistrencommon.la:

libdistrencommon_la_SOURCES = src/common/asprintf.c src/common/asprintf.h \

	src/common/execio.c src/common/execio.h \

	src/common/misc.c src/common/misc.h \

	src/common/options.c src/common/options.h \

	src/common/protocol.h \

	src/common/remoteio.h \

	src/common/remoteio.c src/common/libremoteio.h

#see http://sources.redhat.com/autobook/autobook/autobook_91.html

# either increase the revision number or the interface number each release!

libdistrencommon_la_LDFLAGS = $(AM_LDFLAGS) -version-info 0:0:0

# shared server sources:

SERVER_SOURCES = src/server/slavefuncs.c \

	src/server/slavefuncs.h \

	src/server/distrenjob.c \

	src/server/distrenjob.h

# distrend:

distrend_CFLAGS = $(AM_CFLAGS) $(MYSQL_CFLAGS)

distrend_LDFLAGS = $(AM_LDFLAGS) $(MYSQL_LDFLAGS)

distrend_SOURCES = $(SERVER_SOURCES) \

	src/server/distrend.c \

	src/server/distrend.h \

	src/server/user_mgr.c \

	src/server/user_mgr.h \

	src/server/listen.h \

	src/server/listen.c \

	src/server/mysql.h \

	src/server/mysql.c

distrend_LDADD = libdistrencommon.la

# distrenslave:

distrenslave_SOURCES = $(SERVER_SOURCES) \

distrenslave_LDADD = libdistrencommon.la

# configuration files:

dist_sysconf_DATA = etc/distrencommon.conf

nodist_sysconf_DATA = etc/distrendaemon.conf \

	etc/distrenslave.conf

EXTRA_DIST = etc/distrendaemon.conf.in \

	etc/distrenslave.conf.in

# tests

TESTS=test/check_execio test/check_asprintf

check_PROGRAMS=$(TESTS)

#check_execio_LIBS = $(CHECK_LIBS)

#check_asprintf_LIBS = $(CHECK_LIBS)

test_check_execio_LDADD = $(CHECK_LIBS) libdistrencommon.la

test_check_asprintf_LDADD = $(CHECK_LIBS) libdistrencommon.la

test_check_execio_CFLAGS = $(AM_CFLAGS) $(CHECK_CFLAGS)

test_check_asprintf_CFLAGS = $(AM_CFLAGS) $(CHECK_CFLAGS)

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

     scanf("%d", &command);

     switch(command)

     {

     case 1:

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

       scanf("%99s", tmpString1);

       fprintf(stderr,"Framenum that is being uploaded: ");

       scanf("%d", &framenum);

       fprintf(stderr,"Jobnum that frame belongs to: ");

       scanf("%d", &jobnum);

       fprintf(stderr,"Slavekey that rendered this output: ");

       scanf("%d", &slavekey);

       uploadOutput(tmpString1, uploadURL, jobnum, framenum, slavekey);

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

       scanf("%d", &jobnum);

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

       scanf("%s", tmpString2);

       unpackJob(tmpString1, jobnum);

       break;

     case 5:

       test = 0;

       break;

     default:

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

       break;

     }

   }

}

/* simpleSlave functions */

/** Memory struct for curl */

struct _web_memorystruct {

  char *memory;

  size_t size;

};

static void *_web_myrealloc(void *ptr, size_t size);

static void *_web_myrealloc(void *ptr, size_t size)

{

  /* There might be a realloc() out there that doesn't like reallocing

     NULL pointers, so we take care of it here */

  if(ptr)

    return realloc(ptr, size);

  else

    return malloc(size);

}

static size_t _web_writememorycallback(void *ptr, size_t size, size_t nmemb, void *data)

{

  size_t realsize = size * nmemb;

  struct _web_memorystruct *mem = (struct _web_memorystruct *)data;

  mem->memory = _web_myrealloc(mem->memory, mem->size + realsize + 1);

  if (mem->memory) {

    memcpy(&(mem->memory[mem->size]), ptr, realsize);

    mem->size += realsize;

    mem->memory[mem->size] = 0;

  }

  return realsize;

}

struct _web_memorystruct _web_getrequest(char *url){

  CURL *curl;

  CURLcode res;

  struct _web_memorystruct chunk;

  chunk.memory=NULL; /* we expect realloc(NULL, size) to work */

  chunk.size = 0;    /* no data at this point */

  curl = curl_easy_init();

  if(curl) {

    curl_easy_setopt(curl, CURLOPT_URL, url);

    curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, _web_writememorycallback);

    curl_easy_setopt(curl, CURLOPT_WRITEDATA, (void *)&chunk);

    curl_easy_setopt(curl, CURLOPT_USERAGENT, "libcurl-agent/1.0");

    res = curl_easy_perform(curl);

    curl_easy_cleanup(curl);

  }

  /* we're done with libcurl, so clean it up */

  curl_global_cleanup();

  return chunk; // 0 is OK, 1 is 404 or other error

}

void _web_finishframe(int slavekey, char *slavepass, int jobnum, int framenum){

  char *url;

  _distren_asprintf(&url,"http://dev.distren.org/slave/act.php?mode=finishframe&slavekey=%d&slavepass=%s&jobnum=%d&framenum=%d", slavekey, slavepass, jobnum, framenum);

  struct _web_memorystruct data = _web_getrequest(url);

  if(data.memory)

    free(data.memory);

}

void _web_startframe(int slavekey, char *slavepass, int jobnum, int framenum){

}

}

void _web_setrenderpower(int slavekey, char *slavepass, int jobnum, int framenum){

}

/*

  Copyright 2009 Nathan Phillip Brink, Ethan Zonca, Matthew Orlando

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

void prepareJobPaths(int jobnum, int framenum, char *outputExt, char *datadir, char **urltoTar,char **pathtoTar,char **pathtoJobfile,char **urltoOutput,char **pathtoOutput);

int checkUsername(char *username);

void slaveTest();

/* Simple slave */

struct _web_memorystruct;

static void *_web_myrealloc(void *ptr, size_t size);

static size_t _web_writememorycallback(void *ptr, size_t size, size_t nmemb, void *data);

struct _web_memorystruct _web_getrequest(char *url);

void _web_finishframe(int slavekey, char *slavepass, int jobnum, int framenum);

void _web_startframe(int slavekey, char *slavepass, int jobnum, int framenum);

void _web_setrenderpower(int slavekey, char *slavepass, int jobnum, int framenum);

#endif