apogee/src/controller/outbox.c

#include "outbox.h"

#include "fs_list.h"

#include "model/crypto/keys.h"
#include "model/account.h"
#include "sha256/sha256.h"

#include "collections/array.h"

#include <stdlib.h>
#include <stdio.h>
#include <time.h>

static bool process_one( int id )
{
	bool result = false;
	struct crypto_keys* keys = crypto_keys_new();
	FILE* f = NULL;
	ARRAY_OF(char*) inboxes;
	memset( &inboxes, 0, sizeof(inboxes) );

	if( !crypto_keys_load_private( keys, "data/owner/private.pem" ) ) {
		printf( "Failed to load private key\n" );
		return false;
	}

	char buffer[512];
	snprintf( buffer, 512, "data/outbox/%d.json", id );
	f = fopen( buffer, "r" );
	if( !f ) {
		printf( "Unable to open file %s\n", buffer );
		goto discard;
	}

	char* toline = NULL;
	size_t n;
	if( -1 == getline( &toline, &n, f ) ) {
		printf( "no to line" );
		free(toline);
		goto failed;
	}

	if( strlen(toline) < 5 ) {
		printf( "too short.\n" );
		goto failed;
	}

	char* remainder = NULL;
	char* iter = strtok_r( &toline[4],",",&remainder);

	do
	{
		int id;
		if( sscanf( iter, "%d", &id ) ) {
			int compare( void* a, void* b ) { return strcmp( (char*)a, (char*)b ); }

			struct account* to_account = account_from_id( id );
			if( to_account ) {
				if( to_account->inbox ) {
					char* item_to_add = strdup(to_account->inbox);
					array_append_unique( &inboxes, sizeof(item_to_add), &item_to_add, compare );
				}
				account_free(to_account);
			}
		}
		iter = strtok_r( NULL,",",&remainder);
	} while( iter );
	free(toline);

	for( int i = 0; i < inboxes.count; ++i ) {
		const char* inbox = inboxes.items[i];
		printf( "item[%d] = %s\n", i, inbox );

		if( 0 != strncmp( "https://", inbox, 8 ) ) {
			printf( "Invalid inbox: %s\n", inbox );
			goto failed;
		}

		// Separate host and path from inbox
		char* path = index( &inbox[8], '/' );
		char* host = strndup( &inbox[8], path - &inbox[8] );

		// Build HTTP date
		time_t utc_time = time(NULL);
		struct tm gmtime_data;
		gmtime_r( &utc_time, &gmtime_data );
		static const char* day_of_week[] = { "Sun", "Mon", "Tue", "Wed", "Thu", "Fri", "Sat" };
		static const char* month_of_year[] = { "Jan", "Feb", "Mar", "Apr", "May", "Jun", "Jul", "Aug", "Sep", "Oct", "Nov", "Dec" };
		char date[32];
		snprintf( date, sizeof(date),
			"%s, %d %s %d %02d:%02d:%02d GMT",
			day_of_week[ gmtime_data.tm_wday ],
			gmtime_data.tm_mday,
			month_of_year[ gmtime_data.tm_mon ],
			gmtime_data.tm_year + 1900,
			gmtime_data.tm_hour,
			gmtime_data.tm_min,
			gmtime_data.tm_sec
		);

		// Build hash line
		char hash_line[512];
		snprintf( hash_line, 512, "(request-target): post %s\nhost: %s\ndate: %s", path, host, date );
		printf( "hash_line = %s\n", hash_line );

		// Hash and sign
		char hash[32];
		sha256_easy_hash( hash_line, strlen(hash_line), hash );
		char* signature = crypto_keys_sign( keys, hash, 32 );
		printf( "signature = %s\n", signature );
		free(signature);

		// TODO: HTTP POST request

		free(host);
	}

	// NOT FINISHED DEVELOPING
	goto failed;

discard:
	result = true;
cleanup:
	void release( void* item ) { free( *(char**)item ); }
	array_free( &inboxes, sizeof(char*), release );

	crypto_keys_free(keys);
	if( f ) { fclose(f); }

	return result;
failed:
	result = false;
	goto cleanup;
}

void process_outbox()
{
	int head = fs_list_get("data/outbox/HEAD");
	int tail = fs_list_get("data/outbox/TAIL");
	if( tail < head ) {
		printf( "Processing outbox/%d.json\n", tail );
		if( process_one(tail) ) {
			printf( "Done with outbox/%d.json\n", tail );
			fs_list_set( "data/outbox/TAIL", tail + 1 );
		}
	}

	exit(0);
}