#include <errno.h>

#include <main/php.h>
#include <main/SAPI.h>
#include <main/php_main.h>

#include "engine.h"
#include "context.h"
#include "_cgo_export.h"

engine_context *context_new(php_engine *engine, void *parent) {
	engine_context *context;

	#ifdef ZTS
		void ***tsrm_ls = engine->tsrm_ls;
	#endif

	// Initialize context.
	context = (engine_context *) malloc((sizeof(engine_context)));
	if (context == NULL) {
		return_multi(NULL, 1);
	}

	context->engine = engine;
	context->parent = parent;

	SG(server_context) = (void *) context;

	// Initialize request lifecycle.
	if (php_request_startup(TSRMLS_C) == FAILURE) {
		SG(server_context) = NULL;
		free(context);

		return_multi(NULL, 1);
	}

	return_multi(context, 0);
}

void context_exec(engine_context *context, char *filename) {
	#ifdef ZTS
		void ***tsrm_ls = context->engine->tsrm_ls;
	#endif

	// Attempt to execute script file.
	zend_first_try {
		zend_file_handle script;

		script.type = ZEND_HANDLE_FILENAME;
		script.filename = filename;
		script.opened_path = NULL;
		script.free_filename = 0;

		php_execute_script(&script TSRMLS_CC);
	} zend_end_try();

	return_multi(NULL, 0);
}

void context_bind(engine_context *context, char *name, void *zvalptr) {
	zval *value = (zval *) zvalptr;

	#ifdef ZTS
		void ***tsrm_ls = context->engine->tsrm_ls;
	#endif

	ZEND_SET_SYMBOL(EG(active_symbol_table), name, value);
	return_multi(NULL, 0);
}

int context_write(engine_context *context, const char *message, unsigned int length) {
	int written = contextWrite(context->parent, (void *) message, length);
	if (written != length) {
		php_handle_aborted_connection();
	}

	return written;
}

void context_destroy(engine_context *context) {
	php_request_shutdown((void *) 0);

	SG(server_context) = NULL;
	free(context);
}