mirrors
/
kore
mirror of https://git.kore.io/kore.git
1
0
Fork 1
Code Issues Projects Releases Wiki Activity

implement kore_websockat_broadcast.

This commit is contained in:
Joris Vink 2017-01-30 20:30:42 +01:00
parent 5485967547
commit 7bc8bb42e2
2 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
examples/python/src/websockets.py
View File

@ -6,7 +6,6 @@ def onconnect(c):
kore.log(kore.LOG_INFO, "%s: py connected" % c)
def onmessage(c, op, data):
kore.log(kore.LOG_INFO, "%s: got message" % c)
kore.websocket_broadcast(c, op, data, kore.WEBSOCKET_BROADCAST_GLOBAL)
def ondisconnect(c):

13
src/python.c
View File

@ -742,7 +742,18 @@ pyhttp_websocket_handshake(struct pyhttp_request *pyreq, PyObject *args)
static PyObject *
python_websocket_broadcast(PyObject *self, PyObject *args)
{
printf("websocket_broadcast\n");
struct pyconnection *pyc;
Py_buffer data;
int op, broadcast;
if (!PyArg_ParseTuple(args, "O!iy*i",
&pyconnection_type, &pyc, &op, &data, &broadcast)) {
PyErr_SetString(PyExc_TypeError, "invalid parameters");
return (NULL);
}
kore_websocket_broadcast(pyc->c, op, data.buf, data.len, broadcast);
PyBuffer_Release(&data);
Py_RETURN_TRUE;
}