mirror of
https://github.com/OpenFusionProject/OpenFusion.git
synced 2025-10-22 21:20:08 +00:00
Compare commits
4 Commits
a87c8aadbd
...
landlock
Author | SHA1 | Date | |
---|---|---|---|
6a0d8ca436 | |||
0e32a8974f | |||
c196171034 | |||
8137921154 |
4
.github/workflows/check-builds.yaml
vendored
4
.github/workflows/check-builds.yaml
vendored
@@ -29,7 +29,7 @@ jobs:
|
|||||||
submodules: recursive
|
submodules: recursive
|
||||||
fetch-depth: 0
|
fetch-depth: 0
|
||||||
- name: Install dependencies
|
- name: Install dependencies
|
||||||
run: sudo apt install clang cmake snap libsqlite3-dev -y && sudo snap install powershell --classic
|
run: sudo apt install clang cmake snap -y && sudo snap install powershell --classic
|
||||||
- name: Check compilation
|
- name: Check compilation
|
||||||
run: |
|
run: |
|
||||||
$versions = "104", "728", "1013"
|
$versions = "104", "728", "1013"
|
||||||
@@ -113,7 +113,7 @@ jobs:
|
|||||||
|
|
||||||
copy-artifacts:
|
copy-artifacts:
|
||||||
if: github.event_name != 'pull_request' && github.ref == 'refs/heads/master'
|
if: github.event_name != 'pull_request' && github.ref == 'refs/heads/master'
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-22.04
|
||||||
needs: [windows-build, ubuntu-build]
|
needs: [windows-build, ubuntu-build]
|
||||||
env:
|
env:
|
||||||
BOT_SSH_KEY: ${{ secrets.BOT_SSH_KEY }}
|
BOT_SSH_KEY: ${{ secrets.BOT_SSH_KEY }}
|
||||||
|
11
.github/workflows/push-docker-image.yml
vendored
11
.github/workflows/push-docker-image.yml
vendored
@@ -11,6 +11,11 @@ jobs:
|
|||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
permissions:
|
permissions:
|
||||||
contents: read
|
contents: read
|
||||||
|
strategy:
|
||||||
|
matrix:
|
||||||
|
platforms:
|
||||||
|
- linux/amd64
|
||||||
|
- linux/arm64
|
||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v4
|
- uses: actions/checkout@v4
|
||||||
- name: Retrieve major version
|
- name: Retrieve major version
|
||||||
@@ -26,13 +31,11 @@ jobs:
|
|||||||
username: ${{ secrets.DOCKERHUB_USERNAME }}
|
username: ${{ secrets.DOCKERHUB_USERNAME }}
|
||||||
- name: Set up QEMU
|
- name: Set up QEMU
|
||||||
uses: docker/setup-qemu-action@v3
|
uses: docker/setup-qemu-action@v3
|
||||||
- name: Set up Docker Buildx
|
|
||||||
uses: docker/setup-buildx-action@v3
|
|
||||||
- name: Build and push the Docker image
|
- name: Build and push the Docker image
|
||||||
uses: docker/build-push-action@v6
|
uses: docker/build-push-action@v5
|
||||||
with:
|
with:
|
||||||
context: .
|
context: .
|
||||||
file: ./Dockerfile
|
file: ./Dockerfile
|
||||||
platforms: linux/amd64,linux/arm64
|
platforms: ${{ matrix.platforms }}
|
||||||
push: true
|
push: true
|
||||||
tags: ${{ secrets.DOCKERHUB_REPOSITORY }}:${{ github.ref_name }},${{ secrets.DOCKERHUB_REPOSITORY }}:${{ steps.split.outputs._0 }},${{ secrets.DOCKERHUB_REPOSITORY }}:latest
|
tags: ${{ secrets.DOCKERHUB_REPOSITORY }}:${{ github.ref_name }},${{ secrets.DOCKERHUB_REPOSITORY }}:${{ steps.split.outputs._0 }},${{ secrets.DOCKERHUB_REPOSITORY }}:latest
|
||||||
|
10
Dockerfile
10
Dockerfile
@@ -1,5 +1,5 @@
|
|||||||
# build
|
# build
|
||||||
FROM debian:stable-slim AS build
|
FROM debian:stable-slim as build
|
||||||
|
|
||||||
WORKDIR /usr/src/app
|
WORKDIR /usr/src/app
|
||||||
|
|
||||||
@@ -14,7 +14,7 @@ COPY vendor ./vendor
|
|||||||
COPY .git ./.git
|
COPY .git ./.git
|
||||||
COPY Makefile CMakeLists.txt version.h.in ./
|
COPY Makefile CMakeLists.txt version.h.in ./
|
||||||
|
|
||||||
RUN make nosandbox -j$(nproc)
|
RUN make -j8
|
||||||
|
|
||||||
# prod
|
# prod
|
||||||
FROM debian:stable-slim
|
FROM debian:stable-slim
|
||||||
@@ -29,8 +29,4 @@ COPY sql ./sql
|
|||||||
|
|
||||||
CMD ["/bin/fusion"]
|
CMD ["/bin/fusion"]
|
||||||
|
|
||||||
EXPOSE 23000/tcp
|
LABEL Name=openfusion Version=0.0.2
|
||||||
EXPOSE 23001/tcp
|
|
||||||
EXPOSE 8001/tcp
|
|
||||||
|
|
||||||
LABEL Name=openfusion Version=1.6.0
|
|
||||||
|
@@ -102,8 +102,5 @@ eventmode=0
|
|||||||
enabled=false
|
enabled=false
|
||||||
# the port to listen for connections on
|
# the port to listen for connections on
|
||||||
port=8003
|
port=8003
|
||||||
# The local IP to listen on.
|
|
||||||
# Do not change this unless you know what you're doing.
|
|
||||||
listenip=127.0.0.1
|
|
||||||
# how often the listeners should be updated (in milliseconds)
|
# how often the listeners should be updated (in milliseconds)
|
||||||
interval=5000
|
interval=5000
|
||||||
|
@@ -1,9 +1,11 @@
|
|||||||
|
version: '3.4'
|
||||||
|
|
||||||
services:
|
services:
|
||||||
openfusion:
|
openfusion:
|
||||||
|
image: openfusion
|
||||||
build:
|
build:
|
||||||
context: .
|
context: .
|
||||||
dockerfile: ./Dockerfile
|
dockerfile: ./Dockerfile
|
||||||
image: openfusion/openfusion:latest
|
|
||||||
volumes:
|
volumes:
|
||||||
- ./config.ini:/usr/src/app/config.ini
|
- ./config.ini:/usr/src/app/config.ini
|
||||||
- ./database.db:/usr/src/app/database.db
|
- ./database.db:/usr/src/app/database.db
|
||||||
|
168
src/Chunking.cpp
168
src/Chunking.cpp
@@ -1,6 +1,5 @@
|
|||||||
#include "Chunking.hpp"
|
#include "Chunking.hpp"
|
||||||
|
|
||||||
#include "Player.hpp"
|
|
||||||
#include "MobAI.hpp"
|
#include "MobAI.hpp"
|
||||||
#include "NPCManager.hpp"
|
#include "NPCManager.hpp"
|
||||||
|
|
||||||
@@ -12,11 +11,6 @@ using namespace Chunking;
|
|||||||
* The initial chunkPos value before a player is placed into the world.
|
* The initial chunkPos value before a player is placed into the world.
|
||||||
*/
|
*/
|
||||||
const ChunkPos Chunking::INVALID_CHUNK = {};
|
const ChunkPos Chunking::INVALID_CHUNK = {};
|
||||||
constexpr size_t MAX_PC_PER_AROUND = (CN_PACKET_BUFFER_SIZE - 4) / sizeof(sPCAppearanceData);
|
|
||||||
constexpr size_t MAX_NPC_PER_AROUND = (CN_PACKET_BUFFER_SIZE - 4) / sizeof(sNPCAppearanceData);
|
|
||||||
constexpr size_t MAX_SHINY_PER_AROUND = (CN_PACKET_BUFFER_SIZE - 4) / sizeof(sShinyAppearanceData);
|
|
||||||
constexpr size_t MAX_TRANSPORTATION_PER_AROUND = (CN_PACKET_BUFFER_SIZE - 4) / sizeof(sTransportationAppearanceData);
|
|
||||||
constexpr size_t MAX_IDS_PER_AROUND_DEL = (CN_PACKET_BUFFER_SIZE - 4) / sizeof(int32_t);
|
|
||||||
|
|
||||||
std::map<ChunkPos, Chunk*> Chunking::chunks;
|
std::map<ChunkPos, Chunk*> Chunking::chunks;
|
||||||
|
|
||||||
@@ -81,83 +75,11 @@ void Chunking::untrackEntity(ChunkPos chunkPos, const EntityRef ref) {
|
|||||||
deleteChunk(chunkPos);
|
deleteChunk(chunkPos);
|
||||||
}
|
}
|
||||||
|
|
||||||
template<class T>
|
|
||||||
static void sendAroundPacket(const EntityRef recipient, std::vector<std::vector<T>>& slices, size_t maxCnt, uint32_t packetId) {
|
|
||||||
assert(recipient.kind == EntityKind::PLAYER);
|
|
||||||
|
|
||||||
uint8_t pktBuf[CN_PACKET_BUFFER_SIZE];
|
|
||||||
for (const auto& slice : slices) {
|
|
||||||
memset(pktBuf, 0, CN_PACKET_BUFFER_SIZE);
|
|
||||||
int count = slice.size();
|
|
||||||
assert(count <= maxCnt);
|
|
||||||
*((int32_t*)pktBuf) = count;
|
|
||||||
T* data = (T*)(pktBuf + sizeof(int32_t));
|
|
||||||
for (size_t i = 0; i < count; i++) {
|
|
||||||
data[i] = slice[i];
|
|
||||||
}
|
|
||||||
recipient.sock->sendPacket(pktBuf, packetId, sizeof(int32_t) + (count * sizeof(T)));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
static void sendAroundDelPacket(const EntityRef recipient, std::vector<std::vector<int32_t>>& slices, bool isTransportation, uint32_t packetId) {
|
|
||||||
assert(recipient.kind == EntityKind::PLAYER);
|
|
||||||
|
|
||||||
size_t maxCnt = MAX_IDS_PER_AROUND_DEL;
|
|
||||||
if (isTransportation)
|
|
||||||
maxCnt -= 1; // account for eTT. sad.
|
|
||||||
|
|
||||||
uint8_t pktBuf[CN_PACKET_BUFFER_SIZE];
|
|
||||||
for (const auto& slice : slices) {
|
|
||||||
memset(pktBuf, 0, CN_PACKET_BUFFER_SIZE);
|
|
||||||
int count = slice.size();
|
|
||||||
assert(count <= maxCnt);
|
|
||||||
|
|
||||||
size_t baseSize;
|
|
||||||
if (isTransportation) {
|
|
||||||
sP_FE2CL_AROUND_DEL_TRANSPORTATION* pkt = (sP_FE2CL_AROUND_DEL_TRANSPORTATION*)pktBuf;
|
|
||||||
pkt->eTT = 3;
|
|
||||||
pkt->iCnt = count;
|
|
||||||
baseSize = sizeof(sP_FE2CL_AROUND_DEL_TRANSPORTATION);
|
|
||||||
} else {
|
|
||||||
*((int32_t*)pktBuf) = count;
|
|
||||||
baseSize = sizeof(int32_t);
|
|
||||||
}
|
|
||||||
int32_t* ids = (int32_t*)(pktBuf + baseSize);
|
|
||||||
|
|
||||||
for (size_t i = 0; i < count; i++) {
|
|
||||||
ids[i] = slice[i];
|
|
||||||
}
|
|
||||||
recipient.sock->sendPacket(pktBuf, packetId, baseSize + (count * sizeof(int32_t)));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
template<class T>
|
|
||||||
static void bufferAppearanceData(std::vector<std::vector<T>>& slices, const T& data, size_t maxCnt) {
|
|
||||||
if (slices.empty())
|
|
||||||
slices.push_back(std::vector<T>());
|
|
||||||
std::vector<T>& slice = slices[slices.size() - 1];
|
|
||||||
slice.push_back(data);
|
|
||||||
if (slice.size() == maxCnt)
|
|
||||||
slices.push_back(std::vector<T>());
|
|
||||||
}
|
|
||||||
|
|
||||||
static void bufferIdForDisappearance(std::vector<std::vector<int32_t>>& slices, int32_t id, size_t maxCnt) {
|
|
||||||
if (slices.empty())
|
|
||||||
slices.push_back(std::vector<int32_t>());
|
|
||||||
std::vector<int32_t>& slice = slices[slices.size() - 1];
|
|
||||||
slice.push_back(id);
|
|
||||||
if (slice.size() == maxCnt)
|
|
||||||
slices.push_back(std::vector<int32_t>());
|
|
||||||
}
|
|
||||||
|
|
||||||
void Chunking::addEntityToChunks(std::set<Chunk*> chnks, const EntityRef ref) {
|
void Chunking::addEntityToChunks(std::set<Chunk*> chnks, const EntityRef ref) {
|
||||||
Entity *ent = ref.getEntity();
|
Entity *ent = ref.getEntity();
|
||||||
bool alive = ent->isExtant();
|
bool alive = ent->isExtant();
|
||||||
|
|
||||||
std::vector<std::vector<sPCAppearanceData>> pcAppearances;
|
// TODO: maybe optimize this, potentially using AROUND packets?
|
||||||
std::vector<std::vector<sNPCAppearanceData>> npcAppearances;
|
|
||||||
std::vector<std::vector<sShinyAppearanceData>> shinyAppearances;
|
|
||||||
std::vector<std::vector<sTransportationAppearanceData>> transportationAppearances;
|
|
||||||
for (Chunk *chunk : chnks) {
|
for (Chunk *chunk : chnks) {
|
||||||
for (const EntityRef otherRef : chunk->entities) {
|
for (const EntityRef otherRef : chunk->entities) {
|
||||||
// skip oneself
|
// skip oneself
|
||||||
@@ -173,39 +95,7 @@ void Chunking::addEntityToChunks(std::set<Chunk*> chnks, const EntityRef ref) {
|
|||||||
|
|
||||||
// notify this *player* of the existence of all visible Entities
|
// notify this *player* of the existence of all visible Entities
|
||||||
if (ref.kind == EntityKind::PLAYER && other->isExtant()) {
|
if (ref.kind == EntityKind::PLAYER && other->isExtant()) {
|
||||||
sPCAppearanceData pcData;
|
other->enterIntoViewOf(ref.sock);
|
||||||
sNPCAppearanceData npcData;
|
|
||||||
sShinyAppearanceData eggData;
|
|
||||||
sTransportationAppearanceData busData;
|
|
||||||
switch(otherRef.kind)
|
|
||||||
{
|
|
||||||
case EntityKind::PLAYER:
|
|
||||||
pcData = dynamic_cast<Player*>(other)->getAppearanceData();
|
|
||||||
bufferAppearanceData(pcAppearances, pcData, MAX_PC_PER_AROUND);
|
|
||||||
break;
|
|
||||||
case EntityKind::SIMPLE_NPC:
|
|
||||||
npcData = dynamic_cast<BaseNPC*>(other)->getAppearanceData();
|
|
||||||
bufferAppearanceData(npcAppearances, npcData, MAX_NPC_PER_AROUND);
|
|
||||||
break;
|
|
||||||
case EntityKind::COMBAT_NPC:
|
|
||||||
npcData = dynamic_cast<CombatNPC*>(other)->getAppearanceData();
|
|
||||||
bufferAppearanceData(npcAppearances, npcData, MAX_NPC_PER_AROUND);
|
|
||||||
break;
|
|
||||||
case EntityKind::MOB:
|
|
||||||
npcData = dynamic_cast<Mob*>(other)->getAppearanceData();
|
|
||||||
bufferAppearanceData(npcAppearances, npcData, MAX_NPC_PER_AROUND);
|
|
||||||
break;
|
|
||||||
case EntityKind::EGG:
|
|
||||||
eggData = dynamic_cast<Egg*>(other)->getShinyAppearanceData();
|
|
||||||
bufferAppearanceData(shinyAppearances, eggData, MAX_SHINY_PER_AROUND);
|
|
||||||
break;
|
|
||||||
case EntityKind::BUS:
|
|
||||||
busData = dynamic_cast<Bus*>(other)->getTransportationAppearanceData();
|
|
||||||
bufferAppearanceData(transportationAppearances, busData, MAX_TRANSPORTATION_PER_AROUND);
|
|
||||||
break;
|
|
||||||
default:
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// for mobs, increment playersInView
|
// for mobs, increment playersInView
|
||||||
@@ -215,28 +105,13 @@ void Chunking::addEntityToChunks(std::set<Chunk*> chnks, const EntityRef ref) {
|
|||||||
((Mob*)other)->playersInView++;
|
((Mob*)other)->playersInView++;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if (ref.kind != EntityKind::PLAYER)
|
|
||||||
return; // nothing to send
|
|
||||||
|
|
||||||
if (!pcAppearances.empty())
|
|
||||||
sendAroundPacket(ref, pcAppearances, MAX_PC_PER_AROUND, P_FE2CL_PC_AROUND);
|
|
||||||
if (!npcAppearances.empty())
|
|
||||||
sendAroundPacket(ref, npcAppearances, MAX_NPC_PER_AROUND, P_FE2CL_NPC_AROUND);
|
|
||||||
if (!shinyAppearances.empty())
|
|
||||||
sendAroundPacket(ref, shinyAppearances, MAX_SHINY_PER_AROUND, P_FE2CL_SHINY_AROUND);
|
|
||||||
if (!transportationAppearances.empty())
|
|
||||||
sendAroundPacket(ref, transportationAppearances, MAX_TRANSPORTATION_PER_AROUND, P_FE2CL_TRANSPORTATION_AROUND);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
void Chunking::removeEntityFromChunks(std::set<Chunk*> chnks, const EntityRef ref) {
|
void Chunking::removeEntityFromChunks(std::set<Chunk*> chnks, const EntityRef ref) {
|
||||||
Entity *ent = ref.getEntity();
|
Entity *ent = ref.getEntity();
|
||||||
bool alive = ent->isExtant();
|
bool alive = ent->isExtant();
|
||||||
|
|
||||||
std::vector<std::vector<int32_t>> pcDisappearances;
|
// TODO: same as above
|
||||||
std::vector<std::vector<int32_t>> npcDisappearances;
|
|
||||||
std::vector<std::vector<int32_t>> shinyDisappearances;
|
|
||||||
std::vector<std::vector<int32_t>> transportationDisappearances;
|
|
||||||
for (Chunk *chunk : chnks) {
|
for (Chunk *chunk : chnks) {
|
||||||
for (const EntityRef otherRef : chunk->entities) {
|
for (const EntityRef otherRef : chunk->entities) {
|
||||||
// skip oneself
|
// skip oneself
|
||||||
@@ -252,30 +127,7 @@ void Chunking::removeEntityFromChunks(std::set<Chunk*> chnks, const EntityRef re
|
|||||||
|
|
||||||
// notify this *player* of the departure of all visible Entities
|
// notify this *player* of the departure of all visible Entities
|
||||||
if (ref.kind == EntityKind::PLAYER && other->isExtant()) {
|
if (ref.kind == EntityKind::PLAYER && other->isExtant()) {
|
||||||
int32_t id;
|
other->disappearFromViewOf(ref.sock);
|
||||||
switch(otherRef.kind)
|
|
||||||
{
|
|
||||||
case EntityKind::PLAYER:
|
|
||||||
id = dynamic_cast<Player*>(other)->iID;
|
|
||||||
bufferIdForDisappearance(pcDisappearances, id, MAX_IDS_PER_AROUND_DEL);
|
|
||||||
break;
|
|
||||||
case EntityKind::SIMPLE_NPC:
|
|
||||||
case EntityKind::COMBAT_NPC:
|
|
||||||
case EntityKind::MOB:
|
|
||||||
id = dynamic_cast<BaseNPC*>(other)->id;
|
|
||||||
bufferIdForDisappearance(npcDisappearances, id, MAX_IDS_PER_AROUND_DEL);
|
|
||||||
break;
|
|
||||||
case EntityKind::EGG:
|
|
||||||
id = dynamic_cast<Egg*>(other)->id;
|
|
||||||
bufferIdForDisappearance(shinyDisappearances, id, MAX_IDS_PER_AROUND_DEL);
|
|
||||||
break;
|
|
||||||
case EntityKind::BUS:
|
|
||||||
id = dynamic_cast<Bus*>(other)->id;
|
|
||||||
bufferIdForDisappearance(transportationDisappearances, id, MAX_IDS_PER_AROUND_DEL - 1);
|
|
||||||
break;
|
|
||||||
default:
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// for mobs, decrement playersInView
|
// for mobs, decrement playersInView
|
||||||
@@ -285,18 +137,6 @@ void Chunking::removeEntityFromChunks(std::set<Chunk*> chnks, const EntityRef re
|
|||||||
((Mob*)other)->playersInView--;
|
((Mob*)other)->playersInView--;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if (ref.kind != EntityKind::PLAYER)
|
|
||||||
return; // nothing to send
|
|
||||||
|
|
||||||
if (!pcDisappearances.empty())
|
|
||||||
sendAroundDelPacket(ref, pcDisappearances, false, P_FE2CL_AROUND_DEL_PC);
|
|
||||||
if (!npcDisappearances.empty())
|
|
||||||
sendAroundDelPacket(ref, npcDisappearances, false, P_FE2CL_AROUND_DEL_NPC);
|
|
||||||
if (!shinyDisappearances.empty())
|
|
||||||
sendAroundDelPacket(ref, shinyDisappearances, false, P_FE2CL_AROUND_DEL_SHINY);
|
|
||||||
if (!transportationDisappearances.empty())
|
|
||||||
sendAroundDelPacket(ref, transportationDisappearances, true, P_FE2CL_AROUND_DEL_TRANSPORTATION);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
static void emptyChunk(ChunkPos chunkPos) {
|
static void emptyChunk(ChunkPos chunkPos) {
|
||||||
|
@@ -126,6 +126,15 @@ static void eggStep(CNServer* serv, time_t currTime) {
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void Eggs::npcDataToEggData(int x, int y, int z, sNPCAppearanceData* npc, sShinyAppearanceData* egg) {
|
||||||
|
egg->iX = x;
|
||||||
|
egg->iY = y;
|
||||||
|
egg->iZ = z;
|
||||||
|
// client doesn't care about egg->iMapNum
|
||||||
|
egg->iShinyType = npc->iNPCType;
|
||||||
|
egg->iShiny_ID = npc->iNPC_ID;
|
||||||
|
}
|
||||||
|
|
||||||
static void eggPickup(CNSocket* sock, CNPacketData* data) {
|
static void eggPickup(CNSocket* sock, CNPacketData* data) {
|
||||||
auto pickup = (sP_CL2FE_REQ_SHINY_PICKUP*)data->buf;
|
auto pickup = (sP_CL2FE_REQ_SHINY_PICKUP*)data->buf;
|
||||||
Player* plr = PlayerManager::getPlayer(sock);
|
Player* plr = PlayerManager::getPlayer(sock);
|
||||||
|
@@ -15,4 +15,5 @@ namespace Eggs {
|
|||||||
void init();
|
void init();
|
||||||
|
|
||||||
void eggBuffPlayer(CNSocket* sock, int skillId, int eggId, int duration);
|
void eggBuffPlayer(CNSocket* sock, int skillId, int eggId, int duration);
|
||||||
|
void npcDataToEggData(int x, int y, int z, sNPCAppearanceData* npc, sShinyAppearanceData* egg);
|
||||||
}
|
}
|
||||||
|
@@ -70,7 +70,11 @@ void Bus::enterIntoViewOf(CNSocket *sock) {
|
|||||||
INITSTRUCT(sP_FE2CL_TRANSPORTATION_ENTER, pkt);
|
INITSTRUCT(sP_FE2CL_TRANSPORTATION_ENTER, pkt);
|
||||||
|
|
||||||
// TODO: Potentially decouple this from BaseNPC?
|
// TODO: Potentially decouple this from BaseNPC?
|
||||||
pkt.AppearanceData = getTransportationAppearanceData();
|
pkt.AppearanceData = {
|
||||||
|
3, id, type,
|
||||||
|
x, y, z
|
||||||
|
};
|
||||||
|
|
||||||
sock->sendPacket(pkt, P_FE2CL_TRANSPORTATION_ENTER);
|
sock->sendPacket(pkt, P_FE2CL_TRANSPORTATION_ENTER);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -78,22 +82,12 @@ void Egg::enterIntoViewOf(CNSocket *sock) {
|
|||||||
INITSTRUCT(sP_FE2CL_SHINY_ENTER, pkt);
|
INITSTRUCT(sP_FE2CL_SHINY_ENTER, pkt);
|
||||||
|
|
||||||
// TODO: Potentially decouple this from BaseNPC?
|
// TODO: Potentially decouple this from BaseNPC?
|
||||||
pkt.ShinyAppearanceData = getShinyAppearanceData();
|
pkt.ShinyAppearanceData = {
|
||||||
sock->sendPacket(pkt, P_FE2CL_SHINY_ENTER);
|
|
||||||
}
|
|
||||||
|
|
||||||
sTransportationAppearanceData Bus::getTransportationAppearanceData() {
|
|
||||||
return sTransportationAppearanceData {
|
|
||||||
3, id, type,
|
|
||||||
x, y, z
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
sShinyAppearanceData Egg::getShinyAppearanceData() {
|
|
||||||
return sShinyAppearanceData {
|
|
||||||
id, type, 0, // client doesn't care about map num
|
id, type, 0, // client doesn't care about map num
|
||||||
x, y, z
|
x, y, z
|
||||||
};
|
};
|
||||||
|
|
||||||
|
sock->sendPacket(pkt, P_FE2CL_SHINY_ENTER);
|
||||||
}
|
}
|
||||||
|
|
||||||
sNano* Player::getActiveNano() {
|
sNano* Player::getActiveNano() {
|
||||||
|
@@ -161,8 +161,6 @@ struct Egg : public BaseNPC {
|
|||||||
|
|
||||||
virtual void enterIntoViewOf(CNSocket *sock) override;
|
virtual void enterIntoViewOf(CNSocket *sock) override;
|
||||||
virtual void disappearFromViewOf(CNSocket *sock) override;
|
virtual void disappearFromViewOf(CNSocket *sock) override;
|
||||||
|
|
||||||
sShinyAppearanceData getShinyAppearanceData();
|
|
||||||
};
|
};
|
||||||
|
|
||||||
struct Bus : public BaseNPC {
|
struct Bus : public BaseNPC {
|
||||||
@@ -174,6 +172,4 @@ struct Bus : public BaseNPC {
|
|||||||
|
|
||||||
virtual void enterIntoViewOf(CNSocket *sock) override;
|
virtual void enterIntoViewOf(CNSocket *sock) override;
|
||||||
virtual void disappearFromViewOf(CNSocket *sock) override;
|
virtual void disappearFromViewOf(CNSocket *sock) override;
|
||||||
|
|
||||||
sTransportationAppearanceData getTransportationAppearanceData();
|
|
||||||
};
|
};
|
||||||
|
@@ -478,14 +478,6 @@ void MobAI::deadStep(CombatNPC* npc, time_t currTime) {
|
|||||||
if (self->groupLeader == self->id)
|
if (self->groupLeader == self->id)
|
||||||
roamingStep(self, currTime);
|
roamingStep(self, currTime);
|
||||||
|
|
||||||
/*
|
|
||||||
* If the mob hasn't fully despanwed yet, don't try to respawn it. This protects
|
|
||||||
* against the edge case where mobs with a very short regenTime would try to respawn
|
|
||||||
* before they've faded away; and would respawn even if they were meant to be removed.
|
|
||||||
*/
|
|
||||||
if (!self->despawned)
|
|
||||||
return;
|
|
||||||
|
|
||||||
if (self->killedTime != 0 && currTime - self->killedTime < self->regenTime * 100)
|
if (self->killedTime != 0 && currTime - self->killedTime < self->regenTime * 100)
|
||||||
return;
|
return;
|
||||||
|
|
||||||
|
@@ -388,21 +388,8 @@ NPCPath* Transport::findApplicablePath(int32_t id, int32_t type, int taskID) {
|
|||||||
|
|
||||||
void Transport::constructPathNPC(int32_t id, NPCPath* path) {
|
void Transport::constructPathNPC(int32_t id, NPCPath* path) {
|
||||||
BaseNPC* npc = NPCManager::NPCs[id];
|
BaseNPC* npc = NPCManager::NPCs[id];
|
||||||
|
if (npc->kind == EntityKind::MOB)
|
||||||
if (npc->kind == EntityKind::MOB) {
|
((Mob*)(npc))->staticPath = true;
|
||||||
auto mob = (Mob*)npc;
|
|
||||||
mob->staticPath = true;
|
|
||||||
|
|
||||||
Vec3 firstPoint = path->points.front();
|
|
||||||
|
|
||||||
// Ensure that the first point coincides with the mob's spawn point.
|
|
||||||
if (mob->spawnX != firstPoint.x || mob->spawnY != firstPoint.y) {
|
|
||||||
std::cout << "[FATAL] The first point of the route for mob " << mob->id << " (type " << mob->type
|
|
||||||
<< ") does not correspond with its spawn point." << std::endl;
|
|
||||||
exit(1);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
npc->loopingPath = path->isLoop;
|
npc->loopingPath = path->isLoop;
|
||||||
|
|
||||||
// Interpolate
|
// Interpolate
|
||||||
|
@@ -428,7 +428,7 @@ void CNServer::removePollFD(int fd) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
void CNServer::start() {
|
void CNServer::start() {
|
||||||
std::cout << "Starting " << serverType << " server at *:" << port << std::endl;
|
std::cout << "Starting server at *:" << port << std::endl;
|
||||||
while (active) {
|
while (active) {
|
||||||
// the timeout is to ensure shard timers are ticking
|
// the timeout is to ensure shard timers are ticking
|
||||||
int n = poll(fds.data(), fds.size(), 50);
|
int n = poll(fds.data(), fds.size(), 50);
|
||||||
|
@@ -1,8 +1,6 @@
|
|||||||
/* enum definitions from the client */
|
/* enum definitions from the client */
|
||||||
#pragma once
|
#pragma once
|
||||||
|
|
||||||
#include "core/CNStructs.hpp"
|
|
||||||
|
|
||||||
// floats
|
// floats
|
||||||
const float VALUE_BATTERY_EMPTY_PENALTY = 0.5f;
|
const float VALUE_BATTERY_EMPTY_PENALTY = 0.5f;
|
||||||
const float CN_EP_RANK_1 = 0.8f;
|
const float CN_EP_RANK_1 = 0.8f;
|
||||||
@@ -412,13 +410,7 @@ enum {
|
|||||||
SEND_ANYCAST_NEW = 3,
|
SEND_ANYCAST_NEW = 3,
|
||||||
SEND_BROADCAST = 4,
|
SEND_BROADCAST = 4,
|
||||||
|
|
||||||
#if PROTOCOL_VERSION == 728
|
|
||||||
CN_PACKET_BUFFER_SIZE = 8192,
|
|
||||||
#elif PROTOCOL_VERSION == 1013
|
|
||||||
CN_PACKET_BUFFER_SIZE = 8192,
|
|
||||||
#else
|
|
||||||
CN_PACKET_BUFFER_SIZE = 4096,
|
CN_PACKET_BUFFER_SIZE = 4096,
|
||||||
#endif
|
|
||||||
|
|
||||||
P_CL2LS_REQ_LOGIN = 0x12000001, // 301989889
|
P_CL2LS_REQ_LOGIN = 0x12000001, // 301989889
|
||||||
P_CL2LS_REQ_CHECK_CHAR_NAME = 0x12000002, // 301989890
|
P_CL2LS_REQ_CHECK_CHAR_NAME = 0x12000002, // 301989890
|
||||||
|
@@ -235,7 +235,7 @@ std::map<uint32_t, PacketDesc> Packets::packets = {
|
|||||||
PACKET(P_FE2CL_REP_PC_EXIT_FAIL),
|
PACKET(P_FE2CL_REP_PC_EXIT_FAIL),
|
||||||
PACKET(P_FE2CL_REP_PC_EXIT_SUCC),
|
PACKET(P_FE2CL_REP_PC_EXIT_SUCC),
|
||||||
PACKET(P_FE2CL_PC_EXIT),
|
PACKET(P_FE2CL_PC_EXIT),
|
||||||
VAR_PACKET(P_FE2CL_PC_AROUND, iPCCnt, sPCAppearanceData),
|
PACKET(P_FE2CL_PC_AROUND),
|
||||||
PACKET(P_FE2CL_PC_MOVE),
|
PACKET(P_FE2CL_PC_MOVE),
|
||||||
PACKET(P_FE2CL_PC_STOP),
|
PACKET(P_FE2CL_PC_STOP),
|
||||||
PACKET(P_FE2CL_PC_JUMP),
|
PACKET(P_FE2CL_PC_JUMP),
|
||||||
@@ -243,9 +243,9 @@ std::map<uint32_t, PacketDesc> Packets::packets = {
|
|||||||
PACKET(P_FE2CL_NPC_EXIT),
|
PACKET(P_FE2CL_NPC_EXIT),
|
||||||
PACKET(P_FE2CL_NPC_MOVE),
|
PACKET(P_FE2CL_NPC_MOVE),
|
||||||
PACKET(P_FE2CL_NPC_NEW),
|
PACKET(P_FE2CL_NPC_NEW),
|
||||||
VAR_PACKET(P_FE2CL_NPC_AROUND, iNPCCnt, sNPCAppearanceData),
|
PACKET(P_FE2CL_NPC_AROUND),
|
||||||
VAR_PACKET(P_FE2CL_AROUND_DEL_PC, iPCCnt, int32_t),
|
PACKET(P_FE2CL_AROUND_DEL_PC),
|
||||||
VAR_PACKET(P_FE2CL_AROUND_DEL_NPC, iNPCCnt, int32_t),
|
PACKET(P_FE2CL_AROUND_DEL_NPC),
|
||||||
PACKET(P_FE2CL_REP_SEND_FREECHAT_MESSAGE_SUCC),
|
PACKET(P_FE2CL_REP_SEND_FREECHAT_MESSAGE_SUCC),
|
||||||
PACKET(P_FE2CL_REP_SEND_FREECHAT_MESSAGE_FAIL),
|
PACKET(P_FE2CL_REP_SEND_FREECHAT_MESSAGE_FAIL),
|
||||||
VAR_PACKET(P_FE2CL_PC_ATTACK_NPCs_SUCC, iNPCCnt, sAttackResult),
|
VAR_PACKET(P_FE2CL_PC_ATTACK_NPCs_SUCC, iNPCCnt, sAttackResult),
|
||||||
@@ -387,8 +387,8 @@ std::map<uint32_t, PacketDesc> Packets::packets = {
|
|||||||
PACKET(P_FE2CL_TRANSPORTATION_EXIT),
|
PACKET(P_FE2CL_TRANSPORTATION_EXIT),
|
||||||
PACKET(P_FE2CL_TRANSPORTATION_MOVE),
|
PACKET(P_FE2CL_TRANSPORTATION_MOVE),
|
||||||
PACKET(P_FE2CL_TRANSPORTATION_NEW),
|
PACKET(P_FE2CL_TRANSPORTATION_NEW),
|
||||||
VAR_PACKET(P_FE2CL_TRANSPORTATION_AROUND, iCnt, sTransportationAppearanceData),
|
PACKET(P_FE2CL_TRANSPORTATION_AROUND),
|
||||||
VAR_PACKET(P_FE2CL_AROUND_DEL_TRANSPORTATION, iCnt, int32_t),
|
PACKET(P_FE2CL_AROUND_DEL_TRANSPORTATION),
|
||||||
PACKET(P_FE2CL_REP_EP_RANK_LIST),
|
PACKET(P_FE2CL_REP_EP_RANK_LIST),
|
||||||
PACKET(P_FE2CL_REP_EP_RANK_DETAIL),
|
PACKET(P_FE2CL_REP_EP_RANK_DETAIL),
|
||||||
PACKET(P_FE2CL_REP_EP_RANK_PC_INFO),
|
PACKET(P_FE2CL_REP_EP_RANK_PC_INFO),
|
||||||
@@ -404,8 +404,8 @@ std::map<uint32_t, PacketDesc> Packets::packets = {
|
|||||||
PACKET(P_FE2CL_SHINY_ENTER),
|
PACKET(P_FE2CL_SHINY_ENTER),
|
||||||
PACKET(P_FE2CL_SHINY_EXIT),
|
PACKET(P_FE2CL_SHINY_EXIT),
|
||||||
PACKET(P_FE2CL_SHINY_NEW),
|
PACKET(P_FE2CL_SHINY_NEW),
|
||||||
VAR_PACKET(P_FE2CL_SHINY_AROUND, iShinyCnt, sShinyAppearanceData),
|
PACKET(P_FE2CL_SHINY_AROUND),
|
||||||
VAR_PACKET(P_FE2CL_AROUND_DEL_SHINY, iShinyCnt, int32_t),
|
PACKET(P_FE2CL_AROUND_DEL_SHINY),
|
||||||
PACKET(P_FE2CL_REP_SHINY_PICKUP_FAIL),
|
PACKET(P_FE2CL_REP_SHINY_PICKUP_FAIL),
|
||||||
PACKET(P_FE2CL_REP_SHINY_PICKUP_SUCC),
|
PACKET(P_FE2CL_REP_SHINY_PICKUP_SUCC),
|
||||||
PACKET(P_FE2CL_PC_MOVETRANSPORTATION),
|
PACKET(P_FE2CL_PC_MOVETRANSPORTATION),
|
||||||
|
@@ -391,7 +391,7 @@ static bool landlock_detect() {
|
|||||||
exit(1);
|
exit(1);
|
||||||
}
|
}
|
||||||
|
|
||||||
std::cout << "[INFO] Detected Landlock ABI version: " << abi << std::endl;
|
std::cout << "[INFO] Landlock ABI version: " << abi << std::endl;
|
||||||
|
|
||||||
switch (abi) {
|
switch (abi) {
|
||||||
case 1:
|
case 1:
|
||||||
|
@@ -180,14 +180,9 @@ SOCKET Monitor::init() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
address.sin_family = AF_INET;
|
address.sin_family = AF_INET;
|
||||||
|
address.sin_addr.s_addr = INADDR_ANY;
|
||||||
address.sin_port = htons(settings::MONITORPORT);
|
address.sin_port = htons(settings::MONITORPORT);
|
||||||
|
|
||||||
if (!inet_pton(AF_INET, settings::MONITORLISTENIP.c_str(), &address.sin_addr)) {
|
|
||||||
std::cout << "Failed to set monitor listen address" << std::endl;
|
|
||||||
printSocketError("inet_pton");
|
|
||||||
exit(1);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (SOCKETERROR(bind(listener, (struct sockaddr*)&address, sizeof(address)))) {
|
if (SOCKETERROR(bind(listener, (struct sockaddr*)&address, sizeof(address)))) {
|
||||||
std::cout << "Failed to bind to monitor port" << std::endl;
|
std::cout << "Failed to bind to monitor port" << std::endl;
|
||||||
printSocketError("bind");
|
printSocketError("bind");
|
||||||
@@ -211,7 +206,7 @@ SOCKET Monitor::init() {
|
|||||||
exit(EXIT_FAILURE);
|
exit(EXIT_FAILURE);
|
||||||
}
|
}
|
||||||
|
|
||||||
std::cout << "Monitor listening on " << settings::MONITORLISTENIP << ":" << settings::MONITORPORT << std::endl;
|
std::cout << "Monitor listening on *:" << settings::MONITORPORT << std::endl;
|
||||||
|
|
||||||
REGISTER_SHARD_TIMER(tick, settings::MONITORINTERVAL);
|
REGISTER_SHARD_TIMER(tick, settings::MONITORINTERVAL);
|
||||||
|
|
||||||
|
@@ -64,7 +64,6 @@ bool settings::DISABLEFIRSTUSEFLAG = true;
|
|||||||
// monitor settings
|
// monitor settings
|
||||||
bool settings::MONITORENABLED = false;
|
bool settings::MONITORENABLED = false;
|
||||||
int settings::MONITORPORT = 8003;
|
int settings::MONITORPORT = 8003;
|
||||||
std::string settings::MONITORLISTENIP = "127.0.0.1";
|
|
||||||
int settings::MONITORINTERVAL = 5000;
|
int settings::MONITORINTERVAL = 5000;
|
||||||
|
|
||||||
// event mode settings
|
// event mode settings
|
||||||
@@ -122,6 +121,5 @@ void settings::init() {
|
|||||||
IZRACESCORECAPPED = reader.GetBoolean("shard", "izracescorecapped", IZRACESCORECAPPED);
|
IZRACESCORECAPPED = reader.GetBoolean("shard", "izracescorecapped", IZRACESCORECAPPED);
|
||||||
MONITORENABLED = reader.GetBoolean("monitor", "enabled", MONITORENABLED);
|
MONITORENABLED = reader.GetBoolean("monitor", "enabled", MONITORENABLED);
|
||||||
MONITORPORT = reader.GetInteger("monitor", "port", MONITORPORT);
|
MONITORPORT = reader.GetInteger("monitor", "port", MONITORPORT);
|
||||||
MONITORLISTENIP = reader.Get("monitor", "listenip", MONITORLISTENIP);
|
|
||||||
MONITORINTERVAL = reader.GetInteger("monitor", "interval", MONITORINTERVAL);
|
MONITORINTERVAL = reader.GetInteger("monitor", "interval", MONITORINTERVAL);
|
||||||
}
|
}
|
||||||
|
@@ -38,7 +38,6 @@ namespace settings {
|
|||||||
extern int EVENTMODE;
|
extern int EVENTMODE;
|
||||||
extern bool MONITORENABLED;
|
extern bool MONITORENABLED;
|
||||||
extern int MONITORPORT;
|
extern int MONITORPORT;
|
||||||
extern std::string MONITORLISTENIP;
|
|
||||||
extern int MONITORINTERVAL;
|
extern int MONITORINTERVAL;
|
||||||
extern bool DISABLEFIRSTUSEFLAG;
|
extern bool DISABLEFIRSTUSEFLAG;
|
||||||
extern bool IZRACESCORECAPPED;
|
extern bool IZRACESCORECAPPED;
|
||||||
|
Reference in New Issue
Block a user