/* 

py/pyext - python external object for PD and Max/MSP

Copyright (c) 2002-2004 Thomas Grill (xovo@gmx.net)
For information on usage and redistribution, and for a DISCLAIMER OF ALL
WARRANTIES, see the file, "license.txt," in this distribution.  

*/

#include "main.h"


// function table for module
PyMethodDef py::func_tbl[] = 
{
	{ "_send", py::py_send, METH_VARARGS,"Send message to a named object" },
#ifdef FLEXT_THREADS
	{ "_priority", py::py_priority, METH_VARARGS,"Set priority of current thread" },
#endif

	{ "_samplerate", py::py_samplerate, 0,"Get system sample rate" },
	{ "_blocksize", py::py_blocksize, 0,"Get system block size" },
	{ "_inchannels", py::py_inchannels, 0,"Get number of audio in channels" },
	{ "_outchannels", py::py_outchannels, 0,"Get number of audio out channels" },

	{NULL, NULL, 0, NULL} // sentinel
};

const C *py::py_doc =
	"py/pyext - python external object for PD and Max/MSP, (C)2002-2004 Thomas Grill\n"
	"\n"
	"This is the pyext module. Available function:\n"
	"_send(args...): Send a message to a send symbol\n"
#ifdef FLEXT_THREADS
	"_priority(int): Raise/lower thread priority\n"
#endif
	"_samplerate(): Get system sample rate\n"
	"_blocksize(): Get current blocksize\n"
	"_inchannels(): Get number of audio in channels\n"
	"_outchannels(): Get number of audio out channels\n"
;



V py::tick(V *)
{
	Lock();

	if(!thrcount) {
		// all threads have stopped
		shouldexit = false;
		stoptick = 0;
	}
	else {
		// still active threads 
		if(!--stoptick) {
			post("%s - Threads couldn't be stopped entirely - %i remaining",thisName(),thrcount);
			shouldexit = false;
		}
		else
			// continue waiting
            stoptmr.Delay(PY_STOP_TICK/1000.);
	}

	Unlock();
}

V py::m_stop(int argc,const t_atom *argv)
{
	if(thrcount) {
		Lock();

		I wait = PY_STOP_WAIT;
		if(argc >= 1 && CanbeInt(argv[0])) wait = GetAInt(argv[0]);

		I ticks = wait/PY_STOP_TICK;
		if(stoptick) {
			// already stopping
			if(ticks < stoptick) stoptick = ticks;
		}
		else
			stoptick = ticks;
		shouldexit = true;
        stoptmr.Delay(PY_STOP_TICK/1000.);

		Unlock();
	}
		
}

PyObject *py::py_samplerate(PyObject *self,PyObject *args)
{
	return PyFloat_FromDouble(sys_getsr());
}

PyObject *py::py_blocksize(PyObject *self,PyObject *args)
{
	return PyLong_FromLong(sys_getblksize());
}

PyObject *py::py_inchannels(PyObject *self,PyObject *args)
{
#if FLEXT_SYS == FLEXT_SYS_PD
	I ch = sys_get_inchannels();
#elif FLEXT_SYS == FLEXT_SYS_MAX
	I ch = sys_getch(); // not functioning
#else
#pragma message("Not implemented!")
	ch = 0;
#endif
	return PyLong_FromLong(ch);
}

PyObject *py::py_outchannels(PyObject *self,PyObject *args)
{
#if FLEXT_SYS == FLEXT_SYS_PD
	I ch = sys_get_outchannels();
#elif FLEXT_SYS == FLEXT_SYS_MAX
	I ch = sys_getch(); // not functioning
#else
#pragma message("Not implemented!")
	ch = 0;
#endif
	return PyLong_FromLong(ch);
}

PyObject *py::py_send(PyObject *,PyObject *args)
{
    if(PySequence_Check(args)) {
		PyObject *name = PySequence_GetItem(args,0); // borrowed
		if(name && PyString_Check(name)) {
			const t_symbol *recv = MakeSymbol(PyString_AsString(name));
			I sz = PySequence_Size(args);
			PyObject *val;
			BL tp = sz == 2 && PySequence_Check(PySequence_GetItem(args,1));

			if(tp)
				val = PySequence_GetItem(args,1); // borrowed
			else
				val = PySequence_GetSlice(args,1,sz);  // new ref

			AtomList *lst = GetPyArgs(val);
			if(lst) {
                if(!Forward(recv,*lst))
#ifdef FLEXT_DEBUG
					post("py/pyext - Receiver doesn't exist");
#else
                    {}
#endif
			}
			else 
				post("py/pyext - No data to send");
			if(lst) delete lst;

			if(!tp) Py_DECREF(val);
		}
		else
			post("py/pyext - Send name is invalid");
	}

    Py_INCREF(Py_None);
    return Py_None;
}

#ifdef FLEXT_THREADS
PyObject *py::py_priority(PyObject *self,PyObject *args)
{
	int val;
    if(!PyArg_ParseTuple(args, "i:py_priority", &val)) {
		post("py/pyext - Syntax: _priority [int]");
    }
	else
		RelPriority(val);

    Py_INCREF(Py_None);
    return Py_None;
}
#endif