diff --git a/include/wrapping_dap_stream.h b/include/wrapping_dap_stream.h new file mode 100644 index 0000000000000000000000000000000000000000..c93b1d5a934f4b350469f432bfa308994af3b021 --- /dev/null +++ b/include/wrapping_dap_stream.h @@ -0,0 +1,63 @@ +#ifndef _WRAPPING_DAP_STREAM_ +#define _WRAPPING_DAP_STREAM_ + +#include <Python.h> +#include "dap_stream.h" +#include "dap_server_python.h" +#include "dap_http.h" +#include "dap_enc_http.h" + +typedef struct PyDapStream{ + PyObject_HEAD +}PyDapStreamObject; + +PyObject *dap_stream_add_proc_http_py(PyObject *self, PyObject *args); + +PyMethodDef DapStreamMethods[] = { + {"addProcHttp", dap_stream_add_proc_http_py, METH_VARARGS | METH_STATIC, ""}, + {NULL, NULL, 0, NULL} +}; + +static PyTypeObject DapStream_DapStreamType = { + PyVarObject_HEAD_INIT(NULL, 0) + "CellFrame.DapStream", /* tp_name */ + sizeof(PyDapStreamObject), /* tp_basicsize */ + 0, /* tp_itemsize */ + 0, /* tp_dealloc */ + 0, /* tp_print */ + 0, /* tp_getattr */ + 0, /* tp_setattr */ + 0, /* tp_reserved */ + 0, /* tp_repr */ + 0, /* tp_as_number */ + 0, /* tp_as_sequence */ + 0, /* tp_as_mapping */ + 0, /* tp_hash */ + 0, /* tp_call */ + 0, /* tp_str */ + 0, /* tp_getattro */ + 0, /* tp_setattro */ + 0, /* tp_as_buffer */ + Py_TPFLAGS_DEFAULT | + Py_TPFLAGS_BASETYPE, /* tp_flags */ + "Dap stream object", /* tp_doc */ + 0, /* tp_traverse */ + 0, /* tp_clear */ + 0, /* tp_richcompare */ + 0, /* tp_weaklistoffset */ + 0, /* tp_iter */ + 0, /* tp_iternext */ + DapStreamMethods, /* tp_methods */ + 0, /* tp_members */ + 0, /* tp_getset */ + 0, /* tp_base */ + 0, /* tp_dict */ + 0, /* tp_descr_get */ + 0, /* tp_descr_set */ + 0, /* tp_dictoffset */ + 0, /* tp_init */ + 0, /* tp_alloc */ + PyType_GenericNew, /* tp_new */ +}; + +#endif // _WRAPPING_DAP_STREAM_ diff --git a/src/wrapping_dap_stream.c b/src/wrapping_dap_stream.c new file mode 100644 index 0000000000000000000000000000000000000000..230e60a7b3301f27f3a9f7b182fbd3b9057d46ee --- /dev/null +++ b/src/wrapping_dap_stream.c @@ -0,0 +1,10 @@ +#include "wrapping_dap_stream.h" + +PyObject *dap_stream_add_proc_http_py(PyObject *self, PyObject *args){ + PyObject *obj_server; + const char *STREAM_URL; + if (!PyArg_ParseTuple(args, "O|s", &obj_server, &STREAM_URL)) + return NULL; + dap_stream_add_proc_http(DAP_HTTP(((PyDapServerObject*)obj_server)->t_server), STREAM_URL); + return PyLong_FromLong(0); +}