#include "../python/uwsgi_python.h"

//FIXME: [upstream:python] needs PyAPI_FUNC(void)
#ifdef PYTHREE
extern void Py_GetArgcArgv(int *, wchar_t ***);
#else
extern void Py_GetArgcArgv(int *, char ***);
#endif

extern struct uwsgi_server uwsgi;
extern struct uwsgi_python up;

extern char **environ;

static int new_argc = -1;
static int orig_argc = -1;
static char **new_argv = NULL;
static char **orig_argv = NULL;
static char *new_argv_buf = NULL;


PyObject *pyuwsgi_setup(PyObject * self, PyObject * args, PyObject * kwds) {

	if (new_argv) {
		PyErr_SetString(PyExc_RuntimeError, "uWSGI already setup");
		return NULL;
	}

	if (uwsgi.mywid) {
		PyErr_SetString(PyExc_RuntimeError, "uWSGI must be setup by master");
		return NULL;
	}

	PyObject *iterator;

	if (args == NULL || PyObject_Size(args) == 0) {
		PyObject *argv = PySys_GetObject("argv");
		if (argv == NULL)
			return NULL;

		// during site.py maybe
		if (argv == Py_None) {
			argv = PyTuple_New(0);
			iterator = PyObject_GetIter(argv);
			Py_DECREF(argv);
		}
		else {
			iterator = PyObject_GetIter(argv);
			if (PyObject_Size(argv) > 0) {
				// forward past argv0
				PyObject *item = PyIter_Next(iterator);
				Py_DECREF(item);
			}
		}
	}
	else if (PyObject_Size(args) == 1 && !PyString_Check(PyTuple_GetItem(args, 0))
		) {
		iterator = PyObject_GetIter(PyTuple_GetItem(args, 0));
	}
	else {
		iterator = PyObject_GetIter(args);
	}

	if (iterator == NULL) {
		return NULL;
	}

	size_t size = 1;
	//FIXME: ARGS prior to and including -c/-m are REQUIRED!
#ifdef PYTHREE
	PyObject *item = PyUnicode_FromString(orig_argv[0]);
#else
	PyObject *item = PyString_FromString(orig_argv[0]);
#endif
	PyObject *args_li = PyList_New(0);
	PyList_Append(args_li, item);
	size += strlen(orig_argv[0]) + 1;
	Py_DECREF(item);


	while ((item = PyIter_Next(iterator))) {
		PyObject *py_str = PyObject_Str(item);
		PyList_Append(args_li, py_str);
#ifdef PYTHREE
		const char *str = PyUnicode_AsUTF8(py_str);
		size += strlen(str) + 1;
#else
		size += PyObject_Length(item) + 1;
#endif
		Py_DECREF(item);
		Py_DECREF(py_str);
	}

	Py_DECREF(iterator);

	new_argc = PyObject_Length(args_li);
	new_argv = uwsgi_calloc(sizeof(char *) * (new_argc + 2));
	new_argv_buf = uwsgi_calloc(size);

	int i = 0;
	char *new_argv_ptr = new_argv_buf;
	for (i = 0; i < new_argc; i++) {
		PyObject *arg = PyList_GetItem(args_li, i);
#ifdef PYTHREE
		const char *arg_str = PyUnicode_AsUTF8(arg);
#else
		char *arg_str = PyString_AsString(arg);
#endif
		new_argv[i] = new_argv_ptr;
		strcpy(new_argv_ptr, arg_str);
		new_argv_ptr += strlen(arg_str) + 1;
	}

	PyObject *args_tup = PyList_AsTuple(args_li);
	PyObject_SetAttrString(self, "NEW_ARGV", args_tup);
	Py_DECREF(args_tup);
	Py_DECREF(args_li);


	// TODO: convention here is a goto methinks?
	if (PyErr_Occurred()) {
		free(new_argv_buf);
		free(new_argv);
		new_argv = 0;
		new_argc = 0;
		return NULL;
	}

	Py_INCREF(self);
	return self;
}


PyObject *pyuwsgi_init(PyObject * self, PyObject * args, PyObject * kwds) {
	if (pyuwsgi_setup(self, args, kwds) == NULL) {
		return NULL;
	}

	uwsgi_setup(orig_argc, orig_argv, environ);
	int rc = uwsgi_run();

	// never(?) here
	return Py_BuildValue("i", rc);
}


PyObject *pyuwsgi_run(PyObject * self, PyObject * args, PyObject * kwds) {
	// backcompat
	if (new_argv == NULL && pyuwsgi_setup(self, args, kwds) == NULL) {
		return NULL;
	}

	uwsgi_setup(orig_argc, orig_argv, environ);
	int rc = uwsgi_run();

	// never(?) here
	return Py_BuildValue("i", rc);
}


PyMethodDef methods[] = {
	{"run",
	 (PyCFunction) pyuwsgi_run,
	 METH_VARARGS | METH_KEYWORDS,
	 "run(...)" "\n>>> 0" "\n" "\n * Call setup(...) if not configured" "\n * Begin uWSGI mainloop" "\n   NOTE: will not return" "\n"}
	,
	{"init",
	 (PyCFunction) pyuwsgi_init,
	 METH_VARARGS | METH_KEYWORDS,
	 "init(...)" "\n>>> 0" "\n" "\n * Call setup(...)" "\n * Begin uWSGI mainloop" "\n   NOTE: will not return" "\n"}
	,
	{"setup",
	 (PyCFunction) pyuwsgi_setup,
	 METH_VARARGS | METH_KEYWORDS,
	 "setup('--master', ...)" "\n>>> <module 'uwsgi' from \"uwsgi.so\">" "\n" "\n * Initialize uWSGI core with (...)" "\n   MUST only call once          [RuntimeException]" "\n   MUST only call from master   [RuntimeException]" "\n"}
	,
	{NULL, NULL, 0, NULL}
};


static void pyuwsgi_set_orig_argv(PyObject * self) {

	//  ask python for the original argc/argv saved in Py_Main()
#ifdef PYTHREE
	wchar_t ** tmp_orig_argv = NULL;
	Py_GetArgcArgv(&orig_argc, &tmp_orig_argv);
	int j;
	orig_argv = uwsgi_calloc(sizeof(char *) * (orig_argc + 2));
	size_t size = 0;
	for (j=0;j<orig_argc;j++) {
		size += (wcslen(tmp_orig_argv[j]) + 1) * sizeof(wchar_t);
	}
	// add environment to size
	char **env = environ;
	while(*env) {
		size += strlen(*env) + 1;
		env++;
	}
	// this contguous memory will remain allocated for the whole process lifetime
	// TODO we need a trick for setproctitle() to get access to the original argv[0]
	// check https://github.com/dvarrazzo/py-setproctitle/blob/master/src/spt_setup.c#L151
	char *data = uwsgi_calloc(size);
	for (j=0;j<orig_argc;j++) {
		size_t strsize = (wcslen(tmp_orig_argv[j]) + 1) * sizeof(wchar_t);
		orig_argv[j] = data;
		wcstombs(orig_argv[j], tmp_orig_argv[j], strsize);
		data += strlen(orig_argv[j]) + 1;
	}

#else
	Py_GetArgcArgv(&orig_argc, &orig_argv);
#endif

	//  [re?]export to uwsgi.orig_argv
	PyObject *m_orig_argv;
	m_orig_argv = PyTuple_New(orig_argc);

	int i = 0;
	int i_cm = -1;

	for (i = 0; i < orig_argc; i++) {
		char *arg = orig_argv[i];
		//XXX: _PyOS_optarg != 0 also indicates python quit early...
		//FIXME: [upstream:python] orig_argv could be mangled; reset
		// rel: http://bugs.python.org/issue8202
		orig_argv[i + 1] = arg + strlen(arg) + 1;

		// look for -c or -m and record the offset
		if (i_cm < 0) {
			if (strcmp(arg, "-c") || strcmp(arg, "-m")) {
				// python's getopt would've failed had + 1 not exist
				i_cm = i + 1;
			}
			else if (!uwsgi_startswith(arg, "-c", 2) || !uwsgi_startswith(arg, "-m", 2)) {
				//FIXME: ARGS prior to and including -c/-m are REQUIRED,
				// but NOT a part of the uWSGI argv! Needed to make
				// exec*() self-referential: exec*(...) -> uwsgi
				//
				// want: uwsgi.binary_argv[:] + uwsgi.argv[:]!
				//       binary_argv = [binary_path] + args
				i_cm = i;
			}
		}

#ifdef PYTHREE
		PyTuple_SetItem(m_orig_argv, i, PyUnicode_FromString(arg));
#else
		PyTuple_SetItem(m_orig_argv, i, PyString_FromString(arg));
#endif
	}

	//TODO: howto properly detect uwsgi already running...
	// orig_argv == uwsgi.orig_argv (?)
	// ^^^ but if Py_Main not called, python/main.c:orig_argv unset
	// howto interact/detect things in general
	PyObject *m_new_argv = PyTuple_New(0);
	PyObject_SetAttrString(self, "NEW_ARGV", m_new_argv);
	PyObject_SetAttrString(self, "ORIG_ARGV", m_orig_argv);
	Py_DECREF(m_new_argv);
	Py_DECREF(m_orig_argv);
}


#ifdef PYTHREE
static struct PyModuleDef pyuwsgi_module = {
	PyModuleDef_HEAD_INIT,
	"pyuwsgi",		/* name of module */
	NULL,			/* module documentation, may be NULL */
	-1,			/* size of per-interpreter state of the
				 * module, or -1 if the module keeps state in
				 * global variables. */
	methods
};
#endif


#ifndef PYTHREE
static PyObject *pyuwsgi_init_as(char *mod_name) {

	PyObject *m;

	m = PyImport_GetModuleDict();
	if (m == NULL) {
		return NULL;
	}

	m = PyDict_GetItemString(m, mod_name);
	if (!m) {
		m = Py_InitModule(mod_name, NULL);
	}

	if (orig_argc < 0) {
		pyuwsgi_set_orig_argv(m);
	}

	int i;
	for (i = 0; methods[i].ml_name != NULL; i++) {
		PyObject *fun = PyObject_GetAttrString(m, methods[i].ml_name);
		if (fun != NULL) {
			// already exists
			Py_DECREF(fun);
			continue;
		}

		PyErr_Clear();

		//  rel: Python/modsupport.c:Py_InitModule4
		PyObject *name = PyString_FromString(methods[i].ml_name);
		//  fun(self, ...)
		fun = PyCFunction_NewEx(&methods[i], m, name);
		Py_DECREF(name);
		//  module.fun
		PyObject_SetAttrString(m, methods[i].ml_name, fun);
		Py_DECREF(fun);
	}

	return m;
}
#endif


#ifdef PYTHREE
PyMODINIT_FUNC PyInit_pyuwsgi() {
	PyObject *m = PyModule_Create(&pyuwsgi_module);
	if (orig_argc < 0) {
		pyuwsgi_set_orig_argv(m);
	}
	return m;
}
#else
PyMODINIT_FUNC initpyuwsgi() {
	(void) pyuwsgi_init_as("pyuwsgi");
}


// allow the module to be called `uwsgi`
PyMODINIT_FUNC inituwsgi() {
	(void) pyuwsgi_init_as("uwsgi");
}
#endif


void pyuwsgi_load() {
	if (new_argc > -1) {
		uwsgi.new_argc = new_argc;
		uwsgi.new_argv = new_argv;
	}
}


struct uwsgi_plugin pyuwsgi_plugin = {

	.name = "pyuwsgi",
	.on_load = pyuwsgi_load,
};