// Cyphesis Online RPG Server and AI Engine // Copyright (C) 2000 Alistair Riddoch // // 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. // // 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., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA #include "Py_MemMap.h" #include "Py_Location.h" #include "Py_Thing.h" #include "Py_Operation.h" #include "Py_RootEntity.h" #include "Py_Message.h" #include "Py_Filter.h" #include "MemEntity.h" #include "MemMap.h" #include "Script.h" using Atlas::Objects::Root; using Atlas::Objects::Factories; using Atlas::Objects::Entity::RootEntity; static PyObject * MemMap_find_by_location(PyMemMap* self, PyObject* args) { #ifndef NDEBUG if (self->m_map == nullptr) { PyErr_SetString(PyExc_AssertionError, "nullptr MemMap in MemMap.find_by_location"); return nullptr; } #endif // NDEBUG PyObject * where_obj; double radius; char * type; if (!PyArg_ParseTuple(args, "Ods", &where_obj, &radius, &type)) { return nullptr; } if (!PyLocation_Check(where_obj)) { PyErr_SetString(PyExc_TypeError, "Argument must be a location"); return nullptr; } PyLocation * where = (PyLocation *)where_obj; if (!where->location->isValid()) { PyErr_SetString(PyExc_RuntimeError, "Location is incomplete"); return nullptr; } EntityVector res = self->m_map->findByLocation(*where->location, radius, type); PyObject * list = PyList_New(res.size()); if (list == nullptr) { return nullptr; } EntityVector::const_iterator Iend = res.end(); int i = 0; for (EntityVector::const_iterator I = res.begin(); I != Iend; ++I, ++i) { PyObject * thing = wrapEntity(*I); if (thing == nullptr) { Py_DECREF(list); return nullptr; } PyList_SetItem(list, i, thing); } return list; } static PyObject * MemMap_find_by_type(PyMemMap* self, PyObject* py_what) { #ifndef NDEBUG if (self->m_map == nullptr) { PyErr_SetString(PyExc_AssertionError, "nullptr MemMap in MemMap.find_by_type"); return nullptr; } #endif // NDEBUG if (!PyUnicode_CheckExact(py_what)) { PyErr_SetString(PyExc_TypeError, "MemMap.find_by_type must be string"); return nullptr; } char * what = PyUnicode_AsUTF8(py_what); EntityVector res = self->m_map->findByType(std::string(what)); PyObject * list = PyList_New(res.size()); if (list == nullptr) { return nullptr; } EntityVector::const_iterator Iend = res.end(); int i = 0; for (EntityVector::const_iterator I = res.begin(); I != Iend; ++I, ++i) { PyObject * thing = wrapEntity(*I); if (thing == nullptr) { Py_DECREF(list); return nullptr; } PyList_SetItem(list, i, thing); } return list; } static PyObject * MemMap_updateAdd(PyMemMap* self, PyObject* args) { #ifndef NDEBUG if (self->m_map == nullptr) { PyErr_SetString(PyExc_AssertionError, "nullptr MemMap in MemMap.updateAdd"); return nullptr; } #endif // NDEBUG PyObject * arg; double time; if (!PyArg_ParseTuple(args, "Od", &arg, &time)) { return nullptr; } if (PyMessage_Check(arg)) { PyMessage * me = (PyMessage*)arg; if (!me->m_obj->isMap()) { PyErr_SetString(PyExc_TypeError, "arg is a Message that is not a map"); return nullptr; } Root obj(0); try { obj = Factories::instance()->createObject(me->m_obj->Map()); } catch (Atlas::Message::WrongTypeException&) { PyErr_SetString(PyExc_TypeError, "arg is a Message that contains malformed attributes"); return nullptr; } RootEntity ent = Atlas::Objects::smart_dynamic_cast(obj); if (!ent.isValid()) { PyErr_SetString(PyExc_TypeError, "arg is a Message that does not represent an entity"); return nullptr; } MemEntity * ret = self->m_map->updateAdd(ent, time); if (ret == nullptr) { PyErr_SetString(PyExc_TypeError, "arg is a Message that does not have an ID"); return nullptr; } PyObject * thing = wrapEntity(ret); return thing; } else if (PyRootEntity_Check(arg)) { PyRootEntity * ent = (PyRootEntity*)arg; MemEntity * ret = self->m_map->updateAdd(ent->entity, time); PyObject * thing = wrapEntity(ret); return thing; } else { PyErr_SetString(PyExc_TypeError, "arg is not an Atlas Entity or Message"); return nullptr; } } static PyObject * MemMap_delete(PyMemMap* self, PyObject* py_id) { #ifndef NDEBUG if (self->m_map == nullptr) { PyErr_SetString(PyExc_AssertionError, "nullptr MemMap in MemMap.delete"); return nullptr; } #endif // NDEBUG if (!PyUnicode_CheckExact(py_id)) { PyErr_SetString(PyExc_TypeError, "MemMap.delete must be string"); return nullptr; } char * id = PyUnicode_AsUTF8(py_id); self->m_map->del(id); Py_INCREF(Py_None); return Py_None; } static PyObject * MemMap_get(PyMemMap* self, PyObject* py_id) { #ifndef NDEBUG if (self->m_map == nullptr) { PyErr_SetString(PyExc_AssertionError, "nullptr MemMap in MemMap.get"); return nullptr; } #endif // NDEBUG if (!PyUnicode_CheckExact(py_id)) { PyErr_SetString(PyExc_TypeError, "MemMap.get must be string"); return nullptr; } char * id = PyUnicode_AsUTF8(py_id); MemEntity * ret = self->m_map->get(id); if (ret == nullptr) { Py_INCREF(Py_None); return Py_None; } PyObject * thing = wrapEntity(ret); return thing; } static PyObject * MemMap_get_add(PyMemMap* self, PyObject* py_id) { #ifndef NDEBUG if (self->m_map == nullptr) { PyErr_SetString(PyExc_AssertionError, "nullptr MemMap in MemMap.get_add"); return nullptr; } #endif // NDEBUG if (!PyUnicode_CheckExact(py_id)) { PyErr_SetString(PyExc_TypeError, "MemMap.get_add must be string"); return nullptr; } char * id = PyUnicode_AsUTF8(py_id); MemEntity * ret = self->m_map->getAdd(id); assert(ret != 0); PyObject * thing = wrapEntity(ret); return thing; } static PyObject * MemMap_add_hooks_append(PyMemMap* self, PyObject* py_method) { #ifndef NDEBUG if (self->m_map == nullptr) { PyErr_SetString(PyExc_AssertionError, "nullptr MemMap in MemMap.add_hooks_append"); return nullptr; } #endif // NDEBUG if (!PyUnicode_CheckExact(py_method)) { PyErr_SetString(PyExc_TypeError, "MemMap.add_hooks_append must be string"); return nullptr; } char * method = PyUnicode_AsUTF8(py_method); self->m_map->getAddHooks().push_back(std::string(method)); Py_INCREF(Py_None); return Py_None; } static PyObject * MemMap_update_hooks_append(PyMemMap* self, PyObject* py_method) { #ifndef NDEBUG if (self->m_map == nullptr) { PyErr_SetString(PyExc_AssertionError, "nullptr MemMap in MemMap.update_hooks_append"); return nullptr; } #endif // NDEBUG if (!PyUnicode_CheckExact(py_method)) { PyErr_SetString(PyExc_TypeError, "MemMap.update_hooks_append must be string"); return nullptr; } char * method = PyUnicode_AsUTF8(py_method); self->m_map->getUpdateHooks().push_back(std::string(method)); Py_INCREF(Py_None); return Py_None; } static PyObject * MemMap_delete_hooks_append(PyMemMap* self, PyObject* py_method) { #ifndef NDEBUG if (self->m_map == nullptr) { PyErr_SetString(PyExc_AssertionError, "nullptr MemMap in MemMap.delete_hooks_append"); return nullptr; } #endif // NDEBUG if (!PyUnicode_CheckExact(py_method)) { PyErr_SetString(PyExc_TypeError, "MemMap.delete_hooks_append must be string"); return nullptr; } char * method = PyUnicode_AsUTF8(py_method); self->m_map->getDeleteHooks().push_back(std::string(method)); Py_INCREF(Py_None); return Py_None; } ///\brief Return Python list of entities that match a given Filter static PyObject * MemMap_find_by_filter(PyMemMap* self, PyObject* filter){ #ifndef NDEBUG if (self->m_map == nullptr) { PyErr_SetString(PyExc_AssertionError, "nullptr MemMap in MemMap.find_by_filter"); return nullptr; } #endif // NDEBUG EntityVector res; if(!PyFilter_Check(filter)){ return nullptr; } PyFilter* f = (PyFilter*)filter; auto iter_begin = self->m_map->getEntities().begin(); auto iter_end = self->m_map->getEntities().end(); for (; iter_begin != iter_end; ++iter_begin){ if (f->m_filter->match(*iter_begin->second)){ res.push_back(iter_begin->second); } } PyObject * list = PyList_New(res.size()); if (list == nullptr) { return nullptr; } EntityVector::const_iterator Iend = res.end(); int i = 0; for (EntityVector::const_iterator I = res.begin(); I != Iend; ++I, ++i) { PyObject * thing = wrapEntity(*I); if (thing == nullptr) { Py_DECREF(list); return nullptr; } PyList_SetItem(list, i, thing); } return list; } ///\brief find entities using a query in a specified location static PyObject * MemMap_find_by_location_query(PyMemMap* self, PyObject* args){ #ifndef NDEBUG if (self->m_map == nullptr) { PyErr_SetString(PyExc_AssertionError, "nullptr MemMap in MemMap.find_by_location_query"); return nullptr; } #endif // NDEBUG PyObject * where_obj; double radius; PyObject* filter; if (!PyArg_ParseTuple(args, "OdO", &where_obj, &radius, &filter)) { return nullptr; } if (!PyFilter_Check(filter)) { return nullptr; } PyFilter* f = (PyFilter*)filter; if (!PyLocation_Check(where_obj)) { PyErr_SetString(PyExc_TypeError, "Argument must be a location"); return nullptr; } PyLocation * where = (PyLocation *)where_obj; if (!where->location->isValid()) { PyErr_SetString(PyExc_RuntimeError, "Location is incomplete"); return nullptr; } //Create a vector and fill it with entities that match the given filter and are in range float square_range = radius * radius; EntityVector res; LocatedEntity* place = where->location->m_loc; if (place != 0) { auto iter = place->m_contains->begin(); auto iter_end = place->m_contains->end(); for (; iter != iter_end; ++iter) { LocatedEntity* item = *iter; if (item == 0) { continue; } if (!item->isVisible() || !f->m_filter->match(*item)) { continue; } if (squareDistance(where->location->pos(), item->m_location.pos()) < square_range) { res.push_back(item); } } } //Create a python list an fill it with the entities we got PyObject * list = PyList_New(res.size()); if (list == nullptr) { return nullptr; } EntityVector::const_iterator Iend = res.end(); int i = 0; for (EntityVector::const_iterator I = res.begin(); I != Iend; ++I, ++i) { PyObject * thing = wrapEntity(*I); if (thing == nullptr) { Py_DECREF(list); return nullptr; } PyList_SetItem(list, i, thing); } return list; } PyObject* MemMap_add_entity_memory(PyMemMap* self, PyObject* args){ #ifndef NDEBUG if (self->m_map == nullptr) { PyErr_SetString(PyExc_AssertionError, "nullptr MemMap in MemMap.add_entity_memory"); return nullptr; } #endif // NDEBUG char *id, *memory_name; PyObject *val; if (!PyArg_ParseTuple(args, "ssO", &id, &memory_name, &val)) { return nullptr; } Atlas::Message::Element element_val; PyObject_asMessageElement(val, element_val, false); self->m_map->addEntityMemory(id, memory_name, element_val); return Py_None; } PyObject* MemMap_recall_entity_memory(PyMemMap* self, PyObject* args){ #ifndef NDEBUG if (self->m_map == nullptr) { PyErr_SetString(PyExc_AssertionError, "nullptr MemMap in MemMap.recall_entity_memory"); return nullptr; } #endif // NDEBUG char *id, *memory_name; if (!PyArg_ParseTuple(args, "ss", &id, &memory_name)) { return nullptr; } Atlas::Message::Element element_val; self->m_map->recallEntityMemory(std::string(id), std::string(memory_name), element_val); PyObject* ret = MessageElement_asPyObject(element_val); if (ret) { return ret; } else { return nullptr; } } static PyMethodDef MemMap_methods[] = { {"find_by_location", (PyCFunction)MemMap_find_by_location, METH_VARARGS}, {"find_by_type", (PyCFunction)MemMap_find_by_type, METH_O}, {"find_by_filter", (PyCFunction)MemMap_find_by_filter, METH_O}, {"find_by_location_query",(PyCFunction)MemMap_find_by_location_query, METH_VARARGS}, {"add_entity_memory", (PyCFunction)MemMap_add_entity_memory, METH_VARARGS}, {"recall_entity_memory",(PyCFunction)MemMap_recall_entity_memory,METH_VARARGS}, {"add", (PyCFunction)MemMap_updateAdd, METH_VARARGS}, {"delete", (PyCFunction)MemMap_delete, METH_O}, {"get", (PyCFunction)MemMap_get, METH_O}, {"get_add", (PyCFunction)MemMap_get_add, METH_O}, {"update", (PyCFunction)MemMap_updateAdd, METH_VARARGS}, {"add_hooks_append", (PyCFunction)MemMap_add_hooks_append, METH_O}, {"update_hooks_append", (PyCFunction)MemMap_update_hooks_append, METH_O}, {"delete_hooks_append", (PyCFunction)MemMap_delete_hooks_append, METH_O}, {nullptr, nullptr} // sentinel }; static int MemMap_init(PyMemMap* self, PyObject* args, PyObject* kwds) { Script ** s = new Script*; *s = 0; self->m_map = new MemMap(*s); return 0; } PyTypeObject PyMemMap_Type = { PyVarObject_HEAD_INIT(&PyType_Type, 0) "MemMap", // tp_name sizeof(PyMemMap), // tp_basicsize 0, // tp_itemsize // methods 0, // tp_dealloc 0, // tp_print 0, // tp_getattr 0, // tp_setattr 0, // tp_compare 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, // tp_flags "MemMap objects", // tp_doc 0, // tp_travers 0, // tp_clear 0, // tp_richcompare 0, // tp_weaklistoffset 0, // tp_iter 0, // tp_iternext MemMap_methods, // 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 (initproc)MemMap_init, // tp_init PyType_GenericAlloc, // tp_alloc 0, // tp_new }; PyMemMap * newPyMemMap() { return (PyMemMap *)PyMemMap_Type.tp_new(&PyMemMap_Type, 0, 0); }