ServerRemotePlayer implements ServerActiveObject
[oweals/minetest.git] / src / content_sao.cpp
index 93073002b089429da2e0cd681541736ff446bf49..0abeb0ef047e30675d235f44c72ea96d16681d51 100644 (file)
@@ -21,6 +21,7 @@ with this program; if not, write to the Free Software Foundation, Inc.,
 #include "collision.h"
 #include "environment.h"
 #include "settings.h"
+#include "profiler.h"
 
 core::map<u16, ServerActiveObject::Factory> ServerActiveObject::m_types;
 
@@ -48,20 +49,20 @@ void accelerate_xz(v3f &speed, v3f target_speed, f32 max_increase)
 */
 
 // Prototype
-TestSAO proto_TestSAO(NULL, 0, v3f(0,0,0));
+TestSAO proto_TestSAO(NULL, v3f(0,0,0));
 
-TestSAO::TestSAO(ServerEnvironment *env, u16 id, v3f pos):
-       ServerActiveObject(env, id, pos),
+TestSAO::TestSAO(ServerEnvironment *env, v3f pos):
+       ServerActiveObject(env, pos),
        m_timer1(0),
        m_age(0)
 {
        ServerActiveObject::registerType(getType(), create);
 }
 
-ServerActiveObject* TestSAO::create(ServerEnvironment *env, u16 id, v3f pos,
+ServerActiveObject* TestSAO::create(ServerEnvironment *env, v3f pos,
                const std::string &data)
 {
-       return new TestSAO(env, id, pos);
+       return new TestSAO(env, pos);
 }
 
 void TestSAO::step(float dtime, bool send_recommended)
@@ -84,7 +85,6 @@ void TestSAO::step(float dtime, bool send_recommended)
        if(m_timer1 < 0.0)
        {
                m_timer1 += 0.125;
-               //infostream<<"TestSAO: id="<<getId()<<" sending data"<<std::endl;
 
                std::string data;
 
@@ -107,11 +107,11 @@ void TestSAO::step(float dtime, bool send_recommended)
 */
 
 // Prototype
-ItemSAO proto_ItemSAO(NULL, 0, v3f(0,0,0), "");
+ItemSAO proto_ItemSAO(NULL, v3f(0,0,0), "");
 
-ItemSAO::ItemSAO(ServerEnvironment *env, u16 id, v3f pos,
+ItemSAO::ItemSAO(ServerEnvironment *env, v3f pos,
                const std::string inventorystring):
-       ServerActiveObject(env, id, pos),
+       ServerActiveObject(env, pos),
        m_inventorystring(inventorystring),
        m_speed_f(0,0,0),
        m_last_sent_position(0,0,0)
@@ -119,7 +119,7 @@ ItemSAO::ItemSAO(ServerEnvironment *env, u16 id, v3f pos,
        ServerActiveObject::registerType(getType(), create);
 }
 
-ServerActiveObject* ItemSAO::create(ServerEnvironment *env, u16 id, v3f pos,
+ServerActiveObject* ItemSAO::create(ServerEnvironment *env, v3f pos,
                const std::string &data)
 {
        std::istringstream is(data, std::ios::binary);
@@ -133,11 +133,13 @@ ServerActiveObject* ItemSAO::create(ServerEnvironment *env, u16 id, v3f pos,
        std::string inventorystring = deSerializeString(is);
        infostream<<"ItemSAO::create(): Creating item \""
                        <<inventorystring<<"\""<<std::endl;
-       return new ItemSAO(env, id, pos, inventorystring);
+       return new ItemSAO(env, pos, inventorystring);
 }
 
 void ItemSAO::step(float dtime, bool send_recommended)
 {
+       ScopeProfiler sp2(g_profiler, "ItemSAO::step avg", SPT_AVG);
+
        assert(m_env);
 
        const float interval = 0.2;
@@ -258,10 +260,10 @@ void ItemSAO::rightClick(Player *player)
 */
 
 // Prototype
-RatSAO proto_RatSAO(NULL, 0, v3f(0,0,0));
+RatSAO proto_RatSAO(NULL, v3f(0,0,0));
 
-RatSAO::RatSAO(ServerEnvironment *env, u16 id, v3f pos):
-       ServerActiveObject(env, id, pos),
+RatSAO::RatSAO(ServerEnvironment *env, v3f pos):
+       ServerActiveObject(env, pos),
        m_is_active(false),
        m_speed_f(0,0,0)
 {
@@ -276,7 +278,7 @@ RatSAO::RatSAO(ServerEnvironment *env, u16 id, v3f pos):
        m_touching_ground = false;
 }
 
-ServerActiveObject* RatSAO::create(ServerEnvironment *env, u16 id, v3f pos,
+ServerActiveObject* RatSAO::create(ServerEnvironment *env, v3f pos,
                const std::string &data)
 {
        std::istringstream is(data, std::ios::binary);
@@ -287,11 +289,13 @@ ServerActiveObject* RatSAO::create(ServerEnvironment *env, u16 id, v3f pos,
        // check if version is supported
        if(version != 0)
                return NULL;
-       return new RatSAO(env, id, pos);
+       return new RatSAO(env, pos);
 }
 
 void RatSAO::step(float dtime, bool send_recommended)
 {
+       ScopeProfiler sp2(g_profiler, "RatSAO::step avg", SPT_AVG);
+
        assert(m_env);
 
        if(m_is_active == false)
@@ -443,10 +447,10 @@ InventoryItem* RatSAO::createPickedUpItem()
 */
 
 // Prototype
-Oerkki1SAO proto_Oerkki1SAO(NULL, 0, v3f(0,0,0));
+Oerkki1SAO proto_Oerkki1SAO(NULL, v3f(0,0,0));
 
-Oerkki1SAO::Oerkki1SAO(ServerEnvironment *env, u16 id, v3f pos):
-       ServerActiveObject(env, id, pos),
+Oerkki1SAO::Oerkki1SAO(ServerEnvironment *env, v3f pos):
+       ServerActiveObject(env, pos),
        m_is_active(false),
        m_speed_f(0,0,0)
 {
@@ -463,7 +467,7 @@ Oerkki1SAO::Oerkki1SAO(ServerEnvironment *env, u16 id, v3f pos):
        m_after_jump_timer = 0;
 }
 
-ServerActiveObject* Oerkki1SAO::create(ServerEnvironment *env, u16 id, v3f pos,
+ServerActiveObject* Oerkki1SAO::create(ServerEnvironment *env, v3f pos,
                const std::string &data)
 {
        std::istringstream is(data, std::ios::binary);
@@ -474,13 +478,15 @@ ServerActiveObject* Oerkki1SAO::create(ServerEnvironment *env, u16 id, v3f pos,
        // check if version is supported
        if(version != 0)
                return NULL;
-       Oerkki1SAO *o = new Oerkki1SAO(env, id, pos);
+       Oerkki1SAO *o = new Oerkki1SAO(env, pos);
        o->m_hp = hp;
        return o;
 }
 
 void Oerkki1SAO::step(float dtime, bool send_recommended)
 {
+       ScopeProfiler sp2(g_profiler, "Oerkki1SAO::step avg", SPT_AVG);
+
        assert(m_env);
 
        if(m_is_active == false)
@@ -678,11 +684,25 @@ std::string Oerkki1SAO::getStaticData()
        return os.str();
 }
 
-u16 Oerkki1SAO::punch(const std::string &toolname, v3f dir)
+u16 Oerkki1SAO::punch(const std::string &toolname, v3f dir,
+               const std::string &playername)
 {
        m_speed_f += dir*12*BS;
 
-       u16 amount = 20;
+       u16 amount = 5;
+       /* See tool names in inventory.h */
+       if(toolname == "WSword")
+               amount = 10;
+       if(toolname == "STSword")
+               amount = 12;
+       if(toolname == "SteelSword")
+               amount = 16;
+       if(toolname == "STAxe")
+               amount = 7;
+       if(toolname == "SteelAxe")
+               amount = 9;
+       if(toolname == "SteelPick")
+               amount = 7;
        doDamage(amount);
        return 65536/100;
 }
@@ -719,10 +739,10 @@ void Oerkki1SAO::doDamage(u16 d)
 */
 
 // Prototype
-FireflySAO proto_FireflySAO(NULL, 0, v3f(0,0,0));
+FireflySAO proto_FireflySAO(NULL, v3f(0,0,0));
 
-FireflySAO::FireflySAO(ServerEnvironment *env, u16 id, v3f pos):
-       ServerActiveObject(env, id, pos),
+FireflySAO::FireflySAO(ServerEnvironment *env, v3f pos):
+       ServerActiveObject(env, pos),
        m_is_active(false),
        m_speed_f(0,0,0)
 {
@@ -737,7 +757,7 @@ FireflySAO::FireflySAO(ServerEnvironment *env, u16 id, v3f pos):
        m_touching_ground = false;
 }
 
-ServerActiveObject* FireflySAO::create(ServerEnvironment *env, u16 id, v3f pos,
+ServerActiveObject* FireflySAO::create(ServerEnvironment *env, v3f pos,
                const std::string &data)
 {
        std::istringstream is(data, std::ios::binary);
@@ -748,11 +768,13 @@ ServerActiveObject* FireflySAO::create(ServerEnvironment *env, u16 id, v3f pos,
        // check if version is supported
        if(version != 0)
                return NULL;
-       return new FireflySAO(env, id, pos);
+       return new FireflySAO(env, pos);
 }
 
 void FireflySAO::step(float dtime, bool send_recommended)
 {
+       ScopeProfiler sp2(g_profiler, "FireflySAO::step avg", SPT_AVG);
+
        assert(m_env);
 
        if(m_is_active == false)
@@ -896,11 +918,11 @@ InventoryItem* FireflySAO::createPickedUpItem()
 */
 
 // Prototype
-MobV2SAO proto_MobV2SAO(NULL, 0, v3f(0,0,0), NULL);
+MobV2SAO proto_MobV2SAO(NULL, v3f(0,0,0), NULL);
 
-MobV2SAO::MobV2SAO(ServerEnvironment *env, u16 id, v3f pos,
+MobV2SAO::MobV2SAO(ServerEnvironment *env, v3f pos,
                Settings *init_properties):
-       ServerActiveObject(env, id, pos),
+       ServerActiveObject(env, pos),
        m_move_type("ground_nodes"),
        m_speed(0,0,0),
        m_last_sent_position(0,0,0),
@@ -939,13 +961,13 @@ MobV2SAO::~MobV2SAO()
        delete m_properties;
 }
 
-ServerActiveObject* MobV2SAO::create(ServerEnvironment *env, u16 id, v3f pos,
+ServerActiveObject* MobV2SAO::create(ServerEnvironment *env, v3f pos,
                const std::string &data)
 {
        std::istringstream is(data, std::ios::binary);
        Settings properties;
        properties.parseConfigLines(is, "MobArgsEnd");
-       MobV2SAO *o = new MobV2SAO(env, id, pos, &properties);
+       MobV2SAO *o = new MobV2SAO(env, pos, &properties);
        return o;
 }
 
@@ -1066,6 +1088,8 @@ static void explodeSquare(Map *map, v3s16 p0, v3s16 size)
 
 void MobV2SAO::step(float dtime, bool send_recommended)
 {
+       ScopeProfiler sp2(g_profiler, "MobV2SAO::step avg", SPT_AVG);
+
        assert(m_env);
        Map *map = &m_env->getMap();
 
@@ -1091,8 +1115,10 @@ void MobV2SAO::step(float dtime, bool send_recommended)
                        f32 dist = m_base_position.getDistanceFrom(playerpos);
                        if(dist < BS*16)
                        {
-                               if(myrand_range(0,2) == 0){
-                                       infostream<<"ACTION: id="<<m_id<<" got randomly disturbed by "
+                               if(myrand_range(0,3) == 0){
+                                       actionstream<<"Mob id="<<m_id<<" at "
+                                                       <<PP(m_base_position/BS)
+                                                       <<" got randomly disturbed by "
                                                        <<player->getName()<<std::endl;
                                        m_disturbing_player = player->getName();
                                        m_disturb_timer = 0;
@@ -1135,7 +1161,8 @@ void MobV2SAO::step(float dtime, bool send_recommended)
                                dir.normalize();
                                v3f speed = dir * BS * 10.0;
                                v3f pos = m_base_position + shoot_pos;
-                               infostream<<__FUNCTION_NAME<<": Shooting fireball from "<<PP(pos)
+                               infostream<<__FUNCTION_NAME<<": Mob id="<<m_id
+                                               <<" shooting fireball from "<<PP(pos)
                                                <<" at speed "<<PP(speed)<<std::endl;
                                Settings properties;
                                properties.set("looks", "fireball");
@@ -1147,12 +1174,13 @@ void MobV2SAO::step(float dtime, bool send_recommended)
                                properties.set("player_hit_damage", "9");
                                properties.set("player_hit_distance", "2");
                                properties.set("player_hit_interval", "1");
-                               ServerActiveObject *obj = new MobV2SAO(m_env, 0,
+                               ServerActiveObject *obj = new MobV2SAO(m_env,
                                                pos, &properties);
                                //m_env->addActiveObjectAsStatic(obj);
                                m_env->addActiveObject(obj);
                        } else {
-                               infostream<<__FUNCTION_NAME<<": Unknown shoot_type="<<shoot_type
+                               infostream<<__FUNCTION_NAME<<": Mob id="<<m_id
+                                               <<": Unknown shoot_type="<<shoot_type
                                                <<std::endl;
                        }
                }
@@ -1163,16 +1191,23 @@ void MobV2SAO::step(float dtime, bool send_recommended)
                if(m_disturb_timer <= 15.0)
                        reload_time = 3.0;
 
+               bool shoot_without_player = false;
+               if(m_properties->getBool("mindless_rage"))
+                       shoot_without_player = true;
+
                if(!m_shooting && m_shoot_reload_timer >= reload_time &&
-                               !m_next_pos_exists)
+                               !m_next_pos_exists &&
+                               (m_disturb_timer <= 60.0 || shoot_without_player))
                {
                        m_shoot_y = 0;
-                       if(m_disturb_timer < 30.0 && disturbing_player &&
+                       if(m_disturb_timer < 60.0 && disturbing_player &&
                                        disturbing_player_distance < 16*BS &&
                                        fabs(disturbing_player_norm.Y) < 0.8){
                                m_yaw = disturbing_player_dir;
                                sendPosition();
                                m_shoot_y += disturbing_player_norm.Y;
+                       } else {
+                               m_shoot_y = 0.01 * myrand_range(-30,10);
                        }
                        m_shoot_reload_timer = 0.0;
                        m_shooting = true;
@@ -1229,7 +1264,6 @@ void MobV2SAO::step(float dtime, bool send_recommended)
                        m_base_position = pos_f;
 
                        if((pos_f - next_pos_f).getLength() < 0.1 || arrived){
-                               //infostream<<"id="<<m_id<<": arrived to "<<PP(m_next_pos_i)<<std::endl;
                                m_next_pos_exists = false;
                        }
                }
@@ -1271,16 +1305,10 @@ void MobV2SAO::step(float dtime, bool send_recommended)
                                }
                                u32 order[3*3*3];
                                get_random_u32_array(order, num_dps);
-                               /*infostream<<"At pos "<<PP(pos_i)<<"; Random array: ";
-                               for(int i=0; i<num_dps; i++){
-                                       infostream<<order[i]<<" ";
-                               }
-                               infostream<<std::endl;*/
                                for(int i=0; i<num_dps; i++){
                                        v3s16 p = dps[order[i]] + pos_i;
                                        bool is_free = checkFreeAndWalkablePosition(map,
                                                        p + pos_size_off, size_blocks);
-                                       //infostream<<PP(p)<<" is_free="<<is_free<<std::endl;
                                        if(!is_free)
                                                continue;
                                        m_next_pos_i = p;
@@ -1310,7 +1338,7 @@ void MobV2SAO::step(float dtime, bool send_recommended)
        }
        else
        {
-               infostream<<"MobV2SAO::step(): id="<<m_id<<" unknown move_type=\""
+               errorstream<<"MobV2SAO::step(): id="<<m_id<<" unknown move_type=\""
                                <<m_move_type<<"\""<<std::endl;
        }
 
@@ -1329,7 +1357,7 @@ u16 MobV2SAO::punch(const std::string &toolname, v3f dir,
        assert(m_env);
        Map *map = &m_env->getMap();
        
-       infostream<<"ACTION: "<<playername<<" punches id="<<m_id
+       actionstream<<playername<<" punches mob id="<<m_id
                        <<" with a \""<<toolname<<"\" at "
                        <<PP(m_base_position/BS)<<std::endl;
 
@@ -1405,6 +1433,7 @@ void MobV2SAO::setPropertyDefaults()
        m_properties->setDefault("size", "(1,2)");
        m_properties->setDefault("shoot_type", "fireball");
        m_properties->setDefault("shoot_y", "0");
+       m_properties->setDefault("mindless_rage", "false");
 }
 void MobV2SAO::readProperties()
 {
@@ -1461,3 +1490,205 @@ void MobV2SAO::doDamage(u16 d)
 }
 
 
+/*
+       LuaEntitySAO
+*/
+
+#include "scriptapi.h"
+#include "luaentity_common.h"
+
+// Prototype
+LuaEntitySAO proto_LuaEntitySAO(NULL, v3f(0,0,0), "_prototype", "");
+
+LuaEntitySAO::LuaEntitySAO(ServerEnvironment *env, v3f pos,
+               const std::string &name, const std::string &state):
+       ServerActiveObject(env, pos),
+       m_init_name(name),
+       m_init_state(state),
+       m_registered(false),
+       m_prop(new LuaEntityProperties),
+       m_yaw(0),
+       m_last_sent_yaw(0),
+       m_last_sent_position(0,0,0),
+       m_last_sent_position_timer(0),
+       m_last_sent_move_precision(0)
+{
+       // Only register type if no environment supplied
+       if(env == NULL){
+               ServerActiveObject::registerType(getType(), create);
+               return;
+       }
+}
+
+LuaEntitySAO::~LuaEntitySAO()
+{
+       if(m_registered){
+               lua_State *L = m_env->getLua();
+               scriptapi_luaentity_rm(L, m_id);
+       }
+       delete m_prop;
+}
+
+void LuaEntitySAO::addedToEnvironment(u16 id)
+{
+       ServerActiveObject::addedToEnvironment(id);
+       
+       // Create entity from name and state
+       m_registered = true;
+       lua_State *L = m_env->getLua();
+       scriptapi_luaentity_add(L, id, m_init_name.c_str(), m_init_state.c_str());
+       
+       // Get properties
+       scriptapi_luaentity_get_properties(L, m_id, m_prop);
+}
+
+ServerActiveObject* LuaEntitySAO::create(ServerEnvironment *env, v3f pos,
+               const std::string &data)
+{
+       std::istringstream is(data, std::ios::binary);
+       // read version
+       u8 version = readU8(is);
+       // check if version is supported
+       if(version != 0)
+               return NULL;
+       // read name
+       std::string name = deSerializeString(is);
+       // read state
+       std::string state = deSerializeLongString(is);
+       // create object
+       infostream<<"LuaEntitySAO::create(name=\""<<name<<"\" state=\""
+                       <<state<<"\")"<<std::endl;
+       return new LuaEntitySAO(env, pos, name, state);
+}
+
+void LuaEntitySAO::step(float dtime, bool send_recommended)
+{
+       m_last_sent_position_timer += dtime;
+       
+       if(m_registered){
+               lua_State *L = m_env->getLua();
+               scriptapi_luaentity_step(L, m_id, dtime);
+       }
+
+       if(send_recommended == false)
+               return;
+       
+       float minchange = 0.2*BS;
+       if(m_last_sent_position_timer > 1.0){
+               minchange = 0.01*BS;
+       } else if(m_last_sent_position_timer > 0.2){
+               minchange = 0.05*BS;
+       }
+       float move_d = m_base_position.getDistanceFrom(m_last_sent_position);
+       move_d += m_last_sent_move_precision;
+       if(move_d > minchange || fabs(m_yaw - m_last_sent_yaw) > 1.0){
+               sendPosition(true, false);
+       }
+}
+
+std::string LuaEntitySAO::getClientInitializationData()
+{
+       std::ostringstream os(std::ios::binary);
+       // version
+       writeU8(os, 0);
+       // pos
+       writeV3F1000(os, m_base_position);
+       // yaw
+       writeF1000(os, m_yaw);
+       // properties
+       std::ostringstream prop_os(std::ios::binary);
+       m_prop->serialize(prop_os);
+       os<<serializeLongString(prop_os.str());
+       // return result
+       return os.str();
+}
+
+std::string LuaEntitySAO::getStaticData()
+{
+       infostream<<__FUNCTION_NAME<<std::endl;
+       std::ostringstream os(std::ios::binary);
+       // version
+       writeU8(os, 0);
+       // name
+       os<<serializeString(m_init_name);
+       // state
+       if(m_registered){
+               lua_State *L = m_env->getLua();
+               std::string state = scriptapi_luaentity_get_state(L, m_id);
+               os<<serializeLongString(state);
+       } else {
+               os<<serializeLongString(m_init_state);
+       }
+       return os.str();
+}
+
+InventoryItem* LuaEntitySAO::createPickedUpItem()
+{
+       std::istringstream is("CraftItem testobject1 1", std::ios_base::binary);
+       InventoryItem *item = InventoryItem::deSerialize(is);
+       return item;
+}
+
+u16 LuaEntitySAO::punch(const std::string &toolname, v3f dir,
+               const std::string &playername)
+{
+       return 0;
+}
+
+void LuaEntitySAO::rightClick(Player *player)
+{
+       if(!m_registered)
+               return;
+       lua_State *L = m_env->getLua();
+       scriptapi_luaentity_rightclick_player(L, m_id, player->getName());
+}
+
+void LuaEntitySAO::setPos(v3f pos)
+{
+       m_base_position = pos;
+       sendPosition(false, true);
+}
+
+void LuaEntitySAO::moveTo(v3f pos, bool continuous)
+{
+       m_base_position = pos;
+       if(!continuous)
+               sendPosition(true, true);
+}
+
+float LuaEntitySAO::getMinimumSavedMovement()
+{
+       return 0.1 * BS;
+}
+
+void LuaEntitySAO::sendPosition(bool do_interpolate, bool is_movement_end)
+{
+       m_last_sent_move_precision = m_base_position.getDistanceFrom(
+                       m_last_sent_position);
+       m_last_sent_position_timer = 0;
+       m_last_sent_yaw = m_yaw;
+       m_last_sent_position = m_base_position;
+
+       float update_interval = m_env->getSendRecommendedInterval();
+
+       std::ostringstream os(std::ios::binary);
+       // command (0 = update position)
+       writeU8(os, 0);
+
+       // do_interpolate
+       writeU8(os, do_interpolate);
+       // pos
+       writeV3F1000(os, m_base_position);
+       // yaw
+       writeF1000(os, m_yaw);
+       // is_end_position (for interpolation)
+       writeU8(os, is_movement_end);
+       // update_interval (for interpolation)
+       writeF1000(os, update_interval);
+
+       // create message and add to list
+       ActiveObjectMessage aom(getId(), false, os.str());
+       m_messages_out.push_back(aom);
+}
+
+