sepa_producer.c

/*
 * sepa_producer.c
 * 
 * Copyright 2017 Francesco Antoniazzi <francesco.antoniazzi@unibo.it>
 * 
 *  This program 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.
 *
 *  This program 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 this program.  If not, see <http://www.gnu.org/licenses/>.
 * 
 * 
 */
 
#include <stdlib.h>
#include <string.h>
#include <curl/curl.h>
#include "sepa_producer.h"

#define G_LOG_DOMAIN "SepaProducer"
#include <glib.h>

long kpProduce(const char * update_string,const char * http_server,sClient * jwt) {
	CURL *curl;
	CURLcode result;
	struct curl_slist *list = NULL;
	long response_code;
	FILE *nullFile;
	int protocol_used = KPI_PRODUCE_FAIL;
	char *request;
	
	if ((update_string==NULL) || (http_server==NULL)) {
		g_critical("NullPointerException in kpProduce.");
		return KPI_PRODUCE_FAIL;
	}
	
	if (strstr(http_server,"http:")!=NULL) protocol_used = HTTP;
	else {
		if (strstr(http_server,"https:")!=NULL) {
			protocol_used = HTTPS;
			if (jwt==NULL) {
				g_critical("NullPointerException in JWT with https query request");
				return KPI_PRODUCE_FAIL;
			}
		}
		else {
			g_critical("%s protocol error in kpProduce: only http and https are accepted.",http_server);
			return KPI_PRODUCE_FAIL; 
		}
	}

	if (http_client_init()==EXIT_FAILURE) return KPI_PRODUCE_FAIL;
	curl = curl_easy_init();
	if (curl) {
		curl_easy_setopt(curl, CURLOPT_URL, http_server);
		curl_easy_setopt(curl, CURLOPT_POSTFIELDS, update_string);

		if (protocol_used==HTTPS) {
			curl_easy_setopt(curl, CURLOPT_SSL_VERIFYPEER, 0); // TODO this is not good
			curl_easy_setopt(curl, CURLOPT_SSL_VERIFYHOST, 0); // TODO this is not good as well
			
			request = (char *) malloc((HTTP_TOKEN_HEADER_SIZE+strlen(jwt->JWT))*sizeof(char));
			if (request==NULL) {
				g_critical("malloc error in kpQuery. (2)");
				curl_easy_cleanup(curl);
				http_client_free();
				return KPI_PRODUCE_FAIL;
			}
			sprintf(request,"Authorization: Bearer %s",jwt->JWT);
			list = curl_slist_append(list, request);
		}
		
		list = curl_slist_append(list, "Content-Type: application/sparql-update");
		curl_easy_setopt(curl, CURLOPT_HTTPHEADER, list);
		
		nullFile = fopen("/dev/null","w");
		if (nullFile==NULL)	{
			g_warning("Error opening /dev/null.");
			response_code = KPI_PRODUCE_FAIL;
		}
		else {
			curl_easy_setopt(curl, CURLOPT_WRITEDATA, nullFile);
			result = curl_easy_perform(curl);
			if (result!=CURLE_OK) {
				g_critical("curl_easy_perform() failed: %s",curl_easy_strerror(result));
				response_code = KPI_PRODUCE_FAIL;
			}
			else curl_easy_getinfo(curl,CURLINFO_RESPONSE_CODE,&response_code);
			fclose(nullFile);
		}
		curl_easy_cleanup(curl);
		if (protocol_used==HTTPS) free(request);
	}
	else {
		g_critical("curl_easy_init() failed.\n");
		response_code = KPI_PRODUCE_FAIL;
	}
	http_client_free();
	return response_code;
}