diff options
Diffstat (limited to 'source/gameengine/Ketsji/KXNetwork/KX_NetworkMessageSensor.cpp')
| -rw-r--r-- | source/gameengine/Ketsji/KXNetwork/KX_NetworkMessageSensor.cpp | 258 |
1 files changed, 258 insertions, 0 deletions
diff --git a/source/gameengine/Ketsji/KXNetwork/KX_NetworkMessageSensor.cpp b/source/gameengine/Ketsji/KXNetwork/KX_NetworkMessageSensor.cpp new file mode 100644 index 00000000000..1eeceb55469 --- /dev/null +++ b/source/gameengine/Ketsji/KXNetwork/KX_NetworkMessageSensor.cpp @@ -0,0 +1,258 @@ +/** + * $Id$ + * + * ***** BEGIN GPL/BL DUAL LICENSE BLOCK ***** + * + * This program is free software; you can redistribute it and/or + * modify it under the terms of the GNU General Public License + * as published by the Free Software Foundation; either version 2 + * of the License, or (at your option) any later version. The Blender + * Foundation also sells licenses for use in proprietary software under + * the Blender License. See http://www.blender.org/BL/ for information + * about this. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software Foundation, + * Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. + * + * The Original Code is Copyright (C) 2001-2002 by NaN Holding BV. + * All rights reserved. + * + * The Original Code is: all of this file. + * + * Contributor(s): none yet. + * + * ***** END GPL/BL DUAL LICENSE BLOCK ***** + * Ketsji Logic Extenstion: Network Message Sensor generic implementation + */ + +#include "KX_NetworkMessageSensor.h" +#include "KX_NetworkEventManager.h" +#include "NG_NetworkMessage.h" +#include "NG_NetworkScene.h" +#include "NG_NetworkObject.h" +#include "SCA_IObject.h" +#include "InputParser.h" +#include "ListValue.h" +#include "StringValue.h" + +#ifdef NAN_NET_DEBUG + #include <iostream> +#endif + +KX_NetworkMessageSensor::KX_NetworkMessageSensor( + class KX_NetworkEventManager* eventmgr, // our eventmanager + class NG_NetworkScene *NetworkScene, // our scene + SCA_IObject* gameobj, // the sensor controlling object + const STR_String &subject, + PyTypeObject* T +) : + SCA_ISensor(gameobj,eventmgr,T), + m_Networkeventmgr(eventmgr), + m_NetworkScene(NetworkScene), + m_subject(subject), + m_frame_message_count (0), + m_IsUp(false), + m_BodyList(NULL) +{ +} + +KX_NetworkMessageSensor::~KX_NetworkMessageSensor() +{ +} + +CValue* KX_NetworkMessageSensor::GetReplica() { + // This is the standard sensor implementation of GetReplica + // There may be more network message sensor specific stuff to do here. + CValue* replica = new KX_NetworkMessageSensor(*this); + + if (replica == NULL) return NULL; + + // this will copy properties and so on... + CValue::AddDataToReplica(replica); + + return replica; +} + +// Return true only for flank (UP and DOWN) +bool KX_NetworkMessageSensor::Evaluate(CValue* event) +{ + bool result = false; + bool WasUp = m_IsUp; + + m_IsUp = false; + if (m_BodyList) { + m_BodyList->Release(); + m_BodyList = NULL; + } + + STR_String toname=GetParent()->GetName(); + STR_String subject = this->m_subject; + + vector<NG_NetworkMessage*> messages = + m_NetworkScene->FindMessages(toname,"",subject,true); + + m_frame_message_count = messages.size(); + + if (!messages.empty()) { +#ifdef NAN_NET_DEBUG + printf("KX_NetworkMessageSensor found one or more messages\n"); +#endif + m_IsUp = true; + m_BodyList = new CListValue(); + } + + vector<NG_NetworkMessage*>::iterator mesit; + for (mesit=messages.begin();mesit!=messages.end();mesit++) + { + // save the body + STR_String body = (*mesit)->GetMessageText(); +#ifdef NAN_NET_DEBUG + if (body) { + cout << "body [" << body << "]\n"; + } +#endif + m_BodyList->Add(new CStringValue(body,"body")); + + // free the message + (*mesit)->Release(); + } + messages.clear(); + + result = (WasUp != m_IsUp); + + // Return true if the message received state has changed. + return result; +} + +// return true for being up (no flank needed) +bool KX_NetworkMessageSensor::IsPositiveTrigger() +{ +// printf("KX_NetworkMessageSensor IsPositiveTrigger\n"); + return m_IsUp; +} + +/* --------------------------------------------------------------------- */ +/* Python interface ---------------------------------------------------- */ +/* --------------------------------------------------------------------- */ + +/* Integration hooks --------------------------------------------------- */ +PyTypeObject KX_NetworkMessageSensor::Type = { + PyObject_HEAD_INIT(&PyType_Type) + 0, + "KX_NetworkMessageSensor", + sizeof(KX_NetworkMessageSensor), + 0, + PyDestructor, + 0, + __getattr, + __setattr, + 0, //&MyPyCompare, + __repr, + 0, //&cvalue_as_number, + 0, + 0, + 0, + 0 +}; + +PyParentObject KX_NetworkMessageSensor::Parents[] = { + &KX_NetworkMessageSensor::Type, + &SCA_ISensor::Type, + &SCA_ILogicBrick::Type, + &CValue::Type, + NULL +}; + +PyMethodDef KX_NetworkMessageSensor::Methods[] = { + {"setSubjectFilterText", (PyCFunction) + KX_NetworkMessageSensor::sPySetSubjectFilterText, METH_VARARGS, + SetSubjectFilterText_doc}, + {"getFrameMessageCount", (PyCFunction) + KX_NetworkMessageSensor::sPyGetFrameMessageCount, METH_VARARGS, + GetFrameMessageCount_doc}, + {"getBodies", (PyCFunction) + KX_NetworkMessageSensor::sPyGetBodies, METH_VARARGS, + GetBodies_doc}, + {"getSubject", (PyCFunction) + KX_NetworkMessageSensor::sPyGetSubject, METH_VARARGS, + GetSubject_doc}, + {NULL,NULL} //Sentinel +}; + +PyObject* KX_NetworkMessageSensor::_getattr(char* attr) { + _getattr_up(SCA_ISensor); // implicit return! +} + +// 1. Set the message subject that this sensor listens for +char KX_NetworkMessageSensor::SetSubjectFilterText_doc[] = +"\tsetSubjectFilterText(value)\n" +"\tChange the message subject text that this sensor is listening to.\n"; + +PyObject* KX_NetworkMessageSensor::PySetSubjectFilterText( + PyObject* self, + PyObject* args, + PyObject* kwds) +{ + char* Subject; + + if (PyArg_ParseTuple(args, "s", &Subject)) + { + m_subject = Subject; + } + + Py_Return; +} + +// 2. Get the number of messages received since the last frame +char KX_NetworkMessageSensor::GetFrameMessageCount_doc[] = +"\tgetFrameMessageCount()\n" +"\tGet the number of messages received since the last frame.\n"; + +PyObject* KX_NetworkMessageSensor::PyGetFrameMessageCount( + PyObject* self, + PyObject* args, + PyObject* kwds) +{ + return PyInt_FromLong(long(m_frame_message_count)); +} + +// 3. Get the message bodies +char KX_NetworkMessageSensor::GetBodies_doc[] = +"\tgetBodies()\n" +"\tGet the list of message bodies.\n"; + +PyObject* KX_NetworkMessageSensor::PyGetBodies( + PyObject* self, + PyObject* args, + PyObject* kwds) +{ + if (m_BodyList) { + return ((PyObject*) m_BodyList->AddRef()); + } + + Py_Return; +} + +// 4. Get the message subject +char KX_NetworkMessageSensor::GetSubject_doc[] = +"\tgetSubject()\n" +"\tGet the subject of the message.\n"; + +PyObject* KX_NetworkMessageSensor::PyGetSubject( + PyObject* self, + PyObject* args, + PyObject* kwds) +{ + if (m_subject) { + return PyString_FromString(m_subject); + } + + Py_Return; +} + |