forked from bartvdbraak/blender
80485c2926
Message using a python function of the MessageSensor. Thats a nice thing if you want complex message handling in one python script. Just get all messages, check the subject and do what you want. In the current situation you end up with several MessageSensors connected to the python script, instead of one Sensor and a smart script. Some developer (cant remember who) did implement that function, but however not the way I wanted (maybe I was not clear enough) ;-) So the getSubject() function will return whats entered in the "Subject:" filter field of the MessageSensor. Quite useless IMHO. So I added a new function getSubjects() which is similar to getBodies(), in fact I stole the code from there ;-) I left the getSubject() alone, because of backward compatibility (never saw someone using that function, but...) The future: In conjunction with a wildcard subject: filter field the getSubjects() function will be even more usefull. i.e. Player* will filter for PlayerScore, PlayerKill etc. -- Carsten Wartmann
293 lines
7.3 KiB
C++
293 lines
7.3 KiB
C++
/**
|
|
* $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 HAVE_CONFIG_H
|
|
#include <config.h>
|
|
#endif
|
|
|
|
#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),
|
|
m_SubjectList(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;
|
|
}
|
|
|
|
if (m_SubjectList) {
|
|
m_SubjectList->Release();
|
|
m_SubjectList = 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();
|
|
m_SubjectList = new CListValue();
|
|
}
|
|
|
|
vector<NG_NetworkMessage*>::iterator mesit;
|
|
for (mesit=messages.begin();mesit!=messages.end();mesit++)
|
|
{
|
|
// save the body
|
|
STR_String body = (*mesit)->GetMessageText();
|
|
// save the subject
|
|
STR_String messub = (*mesit)->GetSubject();
|
|
#ifdef NAN_NET_DEBUG
|
|
if (body) {
|
|
cout << "body [" << body << "]\n";
|
|
}
|
|
#endif
|
|
m_BodyList->Add(new CStringValue(body,"body"));
|
|
// Store Subject
|
|
m_SubjectList->Add(new CStringValue(messub,"subject"));
|
|
|
|
// 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},
|
|
{"getSubjects", (PyCFunction)
|
|
KX_NetworkMessageSensor::sPyGetSubjects, METH_VARARGS,
|
|
GetSubjects_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: field of the message sensor
|
|
char KX_NetworkMessageSensor::GetSubject_doc[] =
|
|
"\tgetSubject()\n"
|
|
"\tGet the subject: field of the message sensor.\n";
|
|
|
|
PyObject* KX_NetworkMessageSensor::PyGetSubject(
|
|
PyObject* self,
|
|
PyObject* args,
|
|
PyObject* kwds)
|
|
{
|
|
if (m_subject) {
|
|
return PyString_FromString(m_subject);
|
|
}
|
|
|
|
Py_Return;
|
|
}
|
|
|
|
// 5. Get the message subjects
|
|
char KX_NetworkMessageSensor::GetSubjects_doc[] =
|
|
"\tgetSubjects()\n"
|
|
"\tGet list of message subjects.\n";
|
|
|
|
PyObject* KX_NetworkMessageSensor::PyGetSubjects(
|
|
PyObject* self,
|
|
PyObject* args,
|
|
PyObject* kwds)
|
|
{
|
|
if (m_SubjectList) {
|
|
return ((PyObject*) m_SubjectList->AddRef());
|
|
}
|
|
|
|
Py_Return;
|
|
}
|