/**
* This file is part of Hercules.
* http://herc.ws - http://github.com/HerculesWS/Hercules
*
* Copyright (C) 2012-2018 Hercules Dev Team
* Copyright (C) Athena Dev Teams
*
* Hercules 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 3 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, see .
*/
#define HERCULES_CORE
#include "config/core.h" // GP_BOUND_ITEMS
#include "mapif.h"
#include "char/char.h"
#include "char/int_achievement.h"
#include "char/int_auction.h"
#include "char/int_clan.h"
#include "char/int_guild.h"
#include "char/int_homun.h"
#include "char/int_elemental.h"
#include "char/int_mail.h"
#include "char/int_mercenary.h"
#include "char/int_party.h"
#include "char/int_pet.h"
#include "char/int_quest.h"
#include "char/int_rodex.h"
#include "char/int_storage.h"
#include "char/inter.h"
#include "common/cbasetypes.h"
#include "common/memmgr.h"
#include "common/mmo.h"
#include "common/nullpo.h"
#include "common/random.h"
#include "common/showmsg.h"
#include "common/socket.h"
#include "common/sql.h"
#include "common/strlib.h"
#include
static struct mapif_interface mapif_s;
struct mapif_interface *mapif;
static void mapif_ban(int id, unsigned int flag, int status)
{
// send to all map-servers to disconnect the player
unsigned char buf[11];
WBUFW(buf,0) = 0x2b14;
WBUFL(buf,2) = id;
WBUFB(buf,6) = flag; // 0: change of status, 1: ban
WBUFL(buf,7) = status; // status or final date of a banishment
mapif->sendall(buf, 11);
}
/// Initializes a server structure.
static void mapif_server_init(int id)
{
//memset(&chr->server[id], 0, sizeof(server[id]));
chr->server[id].fd = -1;
}
/// Destroys a server structure.
static void mapif_server_destroy(int id)
{
if (chr->server[id].fd == -1) {
sockt->close(chr->server[id].fd);
chr->server[id].fd = -1;
}
}
/// Resets all the data related to a server.
static void mapif_server_reset(int id)
{
int i, j;
unsigned char buf[16384];
int fd = chr->server[id].fd;
//Notify other map servers that this one is gone. [Skotlex]
WBUFW(buf, 0) = 0x2b20;
WBUFL(buf, 4) = htonl(chr->server[id].ip);
WBUFW(buf, 8) = htons(chr->server[id].port);
j = 0;
for (i = 0; i < VECTOR_LENGTH(chr->server[id].maps); i++) {
uint16 m = VECTOR_INDEX(chr->server[id].maps, i);
if (m != 0)
WBUFW(buf, 10 + (j++) * 4) = m;
}
if (j > 0) {
WBUFW(buf, 2) = j * 4 + 10;
mapif->sendallwos(fd, buf, WBUFW(buf, 2));
}
if (SQL_ERROR == SQL->Query(inter->sql_handle, "DELETE FROM `%s` WHERE `index`='%d'", ragsrvinfo_db, chr->server[id].fd))
Sql_ShowDebug(inter->sql_handle);
chr->online_char_db->foreach(chr->online_char_db, chr->db_setoffline, id); //Tag relevant chars as 'in disconnected' server.
mapif->server_destroy(id);
mapif->server_init(id);
}
/// Called when the connection to a Map Server is disconnected.
static void mapif_on_disconnect(int id)
{
ShowStatus("Map-server #%d has disconnected.\n", id);
mapif->server_reset(id);
}
static void mapif_on_parse_accinfo(int account_id, int u_fd, int u_aid, int u_group, int map_fd)
{
Assert_retv(chr->login_fd > 0);
WFIFOHEAD(chr->login_fd, 22);
WFIFOW(chr->login_fd, 0) = 0x2740;
WFIFOL(chr->login_fd, 2) = account_id;
WFIFOL(chr->login_fd, 6) = u_fd;
WFIFOL(chr->login_fd, 10) = u_aid;
WFIFOL(chr->login_fd, 14) = u_group;
WFIFOL(chr->login_fd, 18) = map_fd;
WFIFOSET(chr->login_fd, 22);
}
static void mapif_char_ban(int char_id, time_t timestamp)
{
unsigned char buf[11];
WBUFW(buf, 0) = 0x2b14;
WBUFL(buf, 2) = char_id;
WBUFB(buf, 6) = 2;
WBUFL(buf, 7) = (unsigned int)timestamp;
mapif->sendall(buf, 11);
}
static int mapif_sendall(const unsigned char *buf, unsigned int len)
{
int i, c;
nullpo_ret(buf);
c = 0;
for (i = 0; i < ARRAYLENGTH(chr->server); i++) {
int fd;
if ((fd = chr->server[i].fd) > 0) {
WFIFOHEAD(fd, len);
memcpy(WFIFOP(fd, 0), buf, len);
WFIFOSET(fd, len);
c++;
}
}
return c;
}
static int mapif_sendallwos(int sfd, unsigned char *buf, unsigned int len)
{
int i, c;
nullpo_ret(buf);
c = 0;
for (i = 0; i < ARRAYLENGTH(chr->server); i++) {
int fd;
if ((fd = chr->server[i].fd) > 0 && fd != sfd) {
WFIFOHEAD(fd, len);
memcpy(WFIFOP(fd, 0), buf, len);
WFIFOSET(fd, len);
c++;
}
}
return c;
}
static int mapif_send(int fd, unsigned char *buf, unsigned int len)
{
nullpo_ret(buf);
if (fd >= 0) {
int i;
ARR_FIND (0, ARRAYLENGTH(chr->server), i, fd == chr->server[i].fd);
if (i < ARRAYLENGTH(chr->server)) {
WFIFOHEAD(fd, len);
memcpy(WFIFOP(fd, 0), buf, len);
WFIFOSET(fd, len);
return 1;
}
}
return 0;
}
static void mapif_send_users_count(int users)
{
uint8 buf[6];
// send number of players to all map-servers
WBUFW(buf, 0) = 0x2b00;
WBUFL(buf, 2) = users;
mapif->sendall(buf, 6);
}
static void mapif_auction_message(int char_id, unsigned char result)
{
unsigned char buf[74];
WBUFW(buf, 0) = 0x3854;
WBUFL(buf, 2) = char_id;
WBUFL(buf, 6) = result;
mapif->sendall(buf, 7);
}
static void mapif_auction_sendlist(int fd, int char_id, short count, short pages, unsigned char *buf)
{
int len = (sizeof(struct auction_data) * count) + 12;
nullpo_retv(buf);
WFIFOHEAD(fd, len);
WFIFOW(fd, 0) = 0x3850;
WFIFOW(fd, 2) = len;
WFIFOL(fd, 4) = char_id;
WFIFOW(fd, 8) = count;
WFIFOW(fd, 10) = pages;
memcpy(WFIFOP(fd, 12), buf, len - 12);
WFIFOSET(fd, len);
}
static void mapif_parse_auction_requestlist(int fd)
{
char searchtext[NAME_LENGTH];
int char_id = RFIFOL(fd, 4), len = sizeof(struct auction_data);
int price = RFIFOL(fd, 10);
short type = RFIFOW(fd, 8), page = max(1, RFIFOW(fd, 14));
unsigned char buf[5 * sizeof(struct auction_data)];
struct DBIterator *iter = db_iterator(inter_auction->db);
struct auction_data *auction;
short i = 0, j = 0, pages = 1;
memcpy(searchtext, RFIFOP(fd, 16), NAME_LENGTH);
for (auction = dbi_first(iter); dbi_exists(iter); auction = dbi_next(iter)) {
if ((type == 0 && auction->type != IT_ARMOR && auction->type != IT_PETARMOR)
|| (type == 1 && auction->type != IT_WEAPON)
|| (type == 2 && auction->type != IT_CARD)
|| (type == 3 && auction->type != IT_ETC)
|| (type == 4 && !strstr(auction->item_name, searchtext))
|| (type == 5 && auction->price > price)
|| (type == 6 && auction->seller_id != char_id)
|| (type == 7 && auction->buyer_id != char_id))
continue;
i++;
if (i > 5) {
// Counting Pages of Total Results (5 Results per Page)
pages++;
i = 1; // First Result of This Page
}
if (page != pages)
continue; // This is not the requested Page
memcpy(WBUFP(buf, j * len), auction, len);
j++; // Found Results
}
dbi_destroy(iter);
mapif->auction_sendlist(fd, char_id, j, pages, buf);
}
static void mapif_auction_register(int fd, struct auction_data *auction)
{
int len = sizeof(struct auction_data) + 4;
nullpo_retv(auction);
WFIFOHEAD(fd,len);
WFIFOW(fd, 0) = 0x3851;
WFIFOW(fd, 2) = len;
memcpy(WFIFOP(fd, 4), auction, sizeof(struct auction_data));
WFIFOSET(fd, len);
}
static void mapif_parse_auction_register(int fd)
{
struct auction_data auction;
if( RFIFOW(fd, 2) != sizeof(struct auction_data) + 4 )
return;
memcpy(&auction, RFIFOP(fd, 4), sizeof(struct auction_data));
if( inter_auction->count(auction.seller_id, false) < 5 )
auction.auction_id = inter_auction->create(&auction);
mapif->auction_register(fd, &auction);
}
static void mapif_auction_cancel(int fd, int char_id, unsigned char result)
{
WFIFOHEAD(fd, 7);
WFIFOW(fd, 0) = 0x3852;
WFIFOL(fd, 2) = char_id;
WFIFOB(fd, 6) = result;
WFIFOSET(fd, 7);
}
static void mapif_parse_auction_cancel(int fd)
{
int char_id = RFIFOL(fd, 2), auction_id = RFIFOL(fd, 6);
struct auction_data *auction;
if ((auction = (struct auction_data *)idb_get(inter_auction->db, auction_id)) == NULL) {
mapif->auction_cancel(fd, char_id, 1); // Bid Number is Incorrect
return;
}
if (auction->seller_id != char_id) {
mapif->auction_cancel(fd, char_id, 2); // You cannot end the auction
return;
}
if (auction->buyer_id > 0) {
mapif->auction_cancel(fd, char_id, 3); // An auction with at least one bidder cannot be canceled
return;
}
inter_mail->sendmail(0, "Auction Manager", auction->seller_id, auction->seller_name, "Auction", "Auction canceled.", 0, &auction->item);
inter_auction->delete_(auction);
mapif->auction_cancel(fd, char_id, 0); // The auction has been canceled
}
static void mapif_auction_close(int fd, int char_id, unsigned char result)
{
WFIFOHEAD(fd, 7);
WFIFOW(fd, 0) = 0x3853;
WFIFOL(fd, 2) = char_id;
WFIFOB(fd, 6) = result;
WFIFOSET(fd, 7);
}
static void mapif_parse_auction_close(int fd)
{
int char_id = RFIFOL(fd, 2), auction_id = RFIFOL(fd, 6);
struct auction_data *auction;
if ((auction = (struct auction_data *)idb_get(inter_auction->db, auction_id)) == NULL) {
mapif->auction_close(fd, char_id, 2); // Bid Number is Incorrect
return;
}
if (auction->seller_id != char_id) {
mapif->auction_close(fd, char_id, 1); // You cannot end the auction
return;
}
if (auction->buyer_id == 0) {
mapif->auction_close(fd, char_id, 1); // You cannot end the auction
return;
}
// Send Money to Seller
inter_mail->sendmail(0, "Auction Manager", auction->seller_id, auction->seller_name, "Auction", "Auction closed.", auction->price, NULL);
// Send Item to Buyer
inter_mail->sendmail(0, "Auction Manager", auction->buyer_id, auction->buyer_name, "Auction", "Auction winner.", 0, &auction->item);
mapif->auction_message(auction->buyer_id, 6); // You have won the auction
inter_auction->delete_(auction);
mapif->auction_close(fd, char_id, 0); // You have ended the auction
}
static void mapif_auction_bid(int fd, int char_id, int bid, unsigned char result)
{
WFIFOHEAD(fd, 11);
WFIFOW(fd, 0) = 0x3855;
WFIFOL(fd, 2) = char_id;
WFIFOL(fd, 6) = bid; // To Return Zeny
WFIFOB(fd, 10) = result;
WFIFOSET(fd, 11);
}
static void mapif_parse_auction_bid(int fd)
{
int char_id = RFIFOL(fd, 4), bid = RFIFOL(fd, 12);
unsigned int auction_id = RFIFOL(fd, 8);
struct auction_data *auction;
if ((auction = (struct auction_data *)idb_get(inter_auction->db, auction_id)) == NULL || auction->price >= bid || auction->seller_id == char_id) {
mapif->auction_bid(fd, char_id, bid, 0); // You have failed to bid in the auction
return;
}
if (inter_auction->count(char_id, true) > 4 && bid < auction->buynow && auction->buyer_id != char_id) {
mapif->auction_bid(fd, char_id, bid, 9); // You cannot place more than 5 bids at a time
return;
}
if (auction->buyer_id > 0) {
// Send Money back to the previous Buyer
if (auction->buyer_id != char_id) {
inter_mail->sendmail(0, "Auction Manager", auction->buyer_id, auction->buyer_name, "Auction", "Someone has placed a higher bid.", auction->price, NULL);
mapif->auction_message(auction->buyer_id, 7); // You have failed to win the auction
} else {
inter_mail->sendmail(0, "Auction Manager", auction->buyer_id, auction->buyer_name, "Auction", "You have placed a higher bid.", auction->price, NULL);
}
}
auction->buyer_id = char_id;
safestrncpy(auction->buyer_name, RFIFOP(fd, 16), NAME_LENGTH);
auction->price = bid;
if (bid >= auction->buynow) {
// Automatic won the auction
mapif->auction_bid(fd, char_id, bid - auction->buynow, 1); // You have successfully bid in the auction
inter_mail->sendmail(0, "Auction Manager", auction->buyer_id, auction->buyer_name, "Auction", "You have won the auction.", 0, &auction->item);
mapif->auction_message(char_id, 6); // You have won the auction
inter_mail->sendmail(0, "Auction Manager", auction->seller_id, auction->seller_name, "Auction", "Payment for your auction!.", auction->buynow, NULL);
inter_auction->delete_(auction);
return;
}
inter_auction->save(auction);
mapif->auction_bid(fd, char_id, 0, 1); // You have successfully bid in the auction
}
static void mapif_elemental_send(int fd, struct s_elemental *ele, unsigned char flag)
{
int size = sizeof(struct s_elemental) + 5;
nullpo_retv(ele);
WFIFOHEAD(fd, size);
WFIFOW(fd, 0) = 0x387c;
WFIFOW(fd, 2) = size;
WFIFOB(fd, 4) = flag;
memcpy(WFIFOP(fd, 5), ele, sizeof(struct s_elemental));
WFIFOSET(fd, size);
}
static void mapif_parse_elemental_create(int fd, const struct s_elemental *ele)
{
struct s_elemental ele_;
bool result;
memcpy(&ele_, ele, sizeof(ele_));
result = inter_elemental->create(&ele_);
mapif->elemental_send(fd, &ele_, result);
}
static void mapif_parse_elemental_load(int fd, int ele_id, int char_id)
{
struct s_elemental ele;
bool result = inter_elemental->load(ele_id, char_id, &ele);
mapif->elemental_send(fd, &ele, result);
}
static void mapif_elemental_deleted(int fd, unsigned char flag)
{
WFIFOHEAD(fd, 3);
WFIFOW(fd, 0) = 0x387d;
WFIFOB(fd, 2) = flag;
WFIFOSET(fd, 3);
}
static void mapif_parse_elemental_delete(int fd, int ele_id)
{
bool result = inter_elemental->delete(ele_id);
mapif->elemental_deleted(fd, result);
}
static void mapif_elemental_saved(int fd, unsigned char flag)
{
WFIFOHEAD(fd, 3);
WFIFOW(fd, 0) = 0x387e;
WFIFOB(fd, 2) = flag;
WFIFOSET(fd, 3);
}
static void mapif_parse_elemental_save(int fd, const struct s_elemental *ele)
{
bool result = inter_elemental->save(ele);
mapif->elemental_saved(fd, result);
}
static int mapif_guild_created(int fd, int account_id, struct guild *g)
{
WFIFOHEAD(fd, 10);
WFIFOW(fd, 0) = 0x3830;
WFIFOL(fd, 2) = account_id;
if (g != NULL) {
WFIFOL(fd, 6) = g->guild_id;
ShowInfo("int_guild: Guild created (%d - %s)\n", g->guild_id, g->name);
} else {
WFIFOL(fd, 6) = 0;
}
WFIFOSET(fd, 10);
return 0;
}
// Guild not found
static int mapif_guild_noinfo(int fd, int guild_id)
{
unsigned char buf[12];
WBUFW(buf, 0) = 0x3831;
WBUFW(buf, 2) = 8;
WBUFL(buf, 4) = guild_id;
ShowWarning("int_guild: info not found %d\n", guild_id);
if (fd < 0)
mapif->sendall(buf, 8);
else
mapif->send(fd,buf, 8);
return 0;
}
// Send guild info
static int mapif_guild_info(int fd, struct guild *g)
{
unsigned char buf[8 + sizeof(struct guild)];
nullpo_ret(g);
WBUFW(buf, 0) = 0x3831;
WBUFW(buf, 2) = 4 + sizeof(struct guild);
memcpy(buf + 4, g, sizeof(struct guild));
if (fd < 0)
mapif->sendall(buf, WBUFW(buf, 2));
else
mapif->send(fd, buf, WBUFW(buf, 2));
return 0;
}
// ACK member add
static int mapif_guild_memberadded(int fd, int guild_id, int account_id, int char_id, int flag)
{
WFIFOHEAD(fd, 15);
WFIFOW(fd, 0) = 0x3832;
WFIFOL(fd, 2) = guild_id;
WFIFOL(fd, 6) = account_id;
WFIFOL(fd, 10) = char_id;
WFIFOB(fd, 14) = flag;
WFIFOSET(fd, 15);
return 0;
}
// ACK member leave
static int mapif_guild_withdraw(int guild_id, int account_id, int char_id, int flag, const char *name, const char *mes)
{
unsigned char buf[55 + NAME_LENGTH];
nullpo_ret(name);
nullpo_ret(mes);
WBUFW(buf, 0) = 0x3834;
WBUFL(buf, 2) = guild_id;
WBUFL(buf, 6) = account_id;
WBUFL(buf, 10) = char_id;
WBUFB(buf, 14) = flag;
memcpy(WBUFP(buf, 15), mes, 40);
memcpy(WBUFP(buf, 55), name, NAME_LENGTH);
mapif->sendall(buf, 55 + NAME_LENGTH);
ShowInfo("int_guild: guild withdraw (%d - %d: %s - %s)\n", guild_id, account_id, name, mes);
return 0;
}
// Send short member's info
static int mapif_guild_memberinfoshort(struct guild *g, int idx)
{
unsigned char buf[23];
nullpo_ret(g);
Assert_ret(idx >= 0 && idx < MAX_GUILD);
WBUFW(buf, 0) = 0x3835;
WBUFL(buf, 2) = g->guild_id;
WBUFL(buf, 6) = g->member[idx].account_id;
WBUFL(buf, 10) = g->member[idx].char_id;
WBUFB(buf, 14) = (unsigned char)g->member[idx].online;
WBUFW(buf, 15) = g->member[idx].lv;
WBUFL(buf, 17) = g->member[idx].class;
WBUFL(buf, 21) = g->member[idx].last_login;
mapif->sendall(buf, 25);
return 0;
}
// Send guild broken
static int mapif_guild_broken(int guild_id, int flag)
{
unsigned char buf[7];
WBUFW(buf, 0) = 0x3836;
WBUFL(buf, 2) = guild_id;
WBUFB(buf, 6) = flag;
mapif->sendall(buf, 7);
ShowInfo("int_guild: Guild broken (%d)\n", guild_id);
return 0;
}
// Send guild message
static int mapif_guild_message(int guild_id, int account_id, const char *mes, int len, int sfd)
{
unsigned char buf[512];
nullpo_ret(mes);
if (len > 500)
len = 500;
WBUFW(buf, 0) = 0x3837;
WBUFW(buf, 2) = len + 12;
WBUFL(buf, 4) = guild_id;
WBUFL(buf, 8) = account_id;
memcpy(WBUFP(buf, 12), mes, len);
mapif->sendallwos(sfd, buf, len + 12);
return 0;
}
// Send basic info
static int mapif_guild_basicinfochanged(int guild_id, int type, const void *data, int len)
{
unsigned char buf[2048];
nullpo_ret(data);
if (len > 2038)
len = 2038;
WBUFW(buf, 0) = 0x3839;
WBUFW(buf, 2) = len + 10;
WBUFL(buf, 4) = guild_id;
WBUFW(buf, 8) = type;
memcpy(WBUFP(buf, 10), data, len);
mapif->sendall(buf, len + 10);
return 0;
}
// Send member info
static int mapif_guild_memberinfochanged(int guild_id, int account_id, int char_id, int type, const void *data, int len)
{
unsigned char buf[2048];
nullpo_ret(data);
if (len > 2030)
len = 2030;
WBUFW(buf, 0) = 0x383a;
WBUFW(buf, 2) = len + 18;
WBUFL(buf, 4) = guild_id;
WBUFL(buf, 8) = account_id;
WBUFL(buf, 12) = char_id;
WBUFW(buf, 16) = type;
memcpy(WBUFP(buf, 18), data, len);
mapif->sendall(buf, len + 18);
return 0;
}
// ACK guild skill up
static int mapif_guild_skillupack(int guild_id, uint16 skill_id, int account_id)
{
unsigned char buf[14];
WBUFW(buf, 0) = 0x383c;
WBUFL(buf, 2) = guild_id;
WBUFL(buf, 6) = skill_id;
WBUFL(buf,10) = account_id;
mapif->sendall(buf, 14);
return 0;
}
// ACK guild alliance
static int mapif_guild_alliance(int guild_id1, int guild_id2, int account_id1, int account_id2, int flag, const char *name1, const char *name2)
{
unsigned char buf[19 + 2 * NAME_LENGTH];
nullpo_ret(name1);
nullpo_ret(name2);
WBUFW(buf, 0) = 0x383d;
WBUFL(buf, 2) = guild_id1;
WBUFL(buf, 6) = guild_id2;
WBUFL(buf, 10) = account_id1;
WBUFL(buf, 14) = account_id2;
WBUFB(buf, 18) = flag;
memcpy(WBUFP(buf, 19), name1, NAME_LENGTH);
memcpy(WBUFP(buf, 19 + NAME_LENGTH), name2, NAME_LENGTH);
mapif->sendall(buf,19 + 2 * NAME_LENGTH);
return 0;
}
// Send a guild position desc
static int mapif_guild_position(struct guild *g, int idx)
{
unsigned char buf[12 + sizeof(struct guild_position)];
nullpo_ret(g);
Assert_ret(idx >= 0 && idx < MAX_GUILDPOSITION);
WBUFW(buf, 0) = 0x383b;
WBUFW(buf, 2) = sizeof(struct guild_position)+12;
WBUFL(buf, 4) = g->guild_id;
WBUFL(buf, 8) = idx;
memcpy(WBUFP(buf, 12), &g->position[idx], sizeof(struct guild_position));
mapif->sendall(buf, WBUFW(buf, 2));
return 0;
}
// Send the guild notice
static int mapif_guild_notice(struct guild *g)
{
unsigned char buf[256];
nullpo_ret(g);
WBUFW(buf, 0) = 0x383e;
WBUFL(buf, 2) = g->guild_id;
memcpy(WBUFP(buf, 6), g->mes1, MAX_GUILDMES1);
memcpy(WBUFP(buf, 66), g->mes2, MAX_GUILDMES2);
mapif->sendall(buf, 186);
return 0;
}
// Send emblem data
static int mapif_guild_emblem(struct guild *g)
{
unsigned char buf[12 + sizeof(g->emblem_data)];
nullpo_ret(g);
WBUFW(buf, 0) = 0x383f;
WBUFW(buf, 2) = g->emblem_len+12;
WBUFL(buf, 4) = g->guild_id;
WBUFL(buf, 8) = g->emblem_id;
memcpy(WBUFP(buf, 12), g->emblem_data, g->emblem_len);
mapif->sendall(buf, WBUFW(buf, 2));
return 0;
}
static int mapif_guild_master_changed(struct guild *g, int aid, int cid)
{
unsigned char buf[14];
nullpo_ret(g);
WBUFW(buf, 0) = 0x3843;
WBUFL(buf, 2) = g->guild_id;
WBUFL(buf, 6) = aid;
WBUFL(buf, 10) = cid;
mapif->sendall(buf, 14);
return 0;
}
static int mapif_guild_castle_dataload(int fd, int sz, const int *castle_ids)
{
struct guild_castle *gc = NULL;
int num = (sz - 4) / sizeof(int);
int len = 4 + num * sizeof(*gc);
int i;
nullpo_ret(castle_ids);
WFIFOHEAD(fd, len);
WFIFOW(fd, 0) = 0x3840;
WFIFOW(fd, 2) = len;
for (i = 0; i < num; i++) {
gc = inter_guild->castle_fromsql(*(castle_ids++));
memcpy(WFIFOP(fd, 4 + i * sizeof(*gc)), gc, sizeof(*gc));
}
WFIFOSET(fd, len);
return 0;
}
// Guild creation request
static int mapif_parse_CreateGuild(int fd, int account_id, const char *name, const struct guild_member *master)
{
struct guild *g;
nullpo_ret(name);
nullpo_ret(master);
g = inter_guild->create(name, master);
// Report to client
mapif->guild_created(fd,account_id,g);
if (g != NULL) {
mapif->guild_info(fd,g);
}
return 0;
}
// Return guild info to client
static int mapif_parse_GuildInfo(int fd, int guild_id)
{
struct guild * g = inter_guild->fromsql(guild_id); //We use this because on start-up the info of castle-owned guilds is required. [Skotlex]
if (g != NULL) {
if (!inter_guild->calcinfo(g))
mapif->guild_info(fd, g);
} else {
mapif->guild_noinfo(fd, guild_id); // Failed to load info
}
return 0;
}
// Add member to guild
static int mapif_parse_GuildAddMember(int fd, int guild_id, const struct guild_member *m)
{
nullpo_ret(m);
inter_guild->add_member(guild_id, m, fd);
return 0;
}
// Delete member from guild
static int mapif_parse_GuildLeave(int fd, int guild_id, int account_id, int char_id, int flag, const char *mes)
{
inter_guild->leave(guild_id, account_id, char_id, flag, mes, fd);
return 0;
}
// Change member info
static int mapif_parse_GuildChangeMemberInfoShort(int fd, int guild_id, int account_id, int char_id, int online, int lv, int class)
{
inter_guild->update_member_info_short(guild_id, account_id, char_id, online, lv, class);
return 0;
}
// BreakGuild
static int mapif_parse_BreakGuild(int fd, int guild_id)
{
inter_guild->disband(guild_id);
return 0;
}
// Forward Guild message to others map servers
static int mapif_parse_GuildMessage(int fd, int guild_id, int account_id, const char *mes, int len)
{
return mapif->guild_message(guild_id,account_id,mes,len, fd);
}
/**
* Changes basic guild information
* The types are available in mmo.h::guild_basic_info
**/
static int mapif_parse_GuildBasicInfoChange(int fd, int guild_id, int type, const void *data, int len)
{
inter_guild->update_basic_info(guild_id, type, data, len);
// Information is already sent in mapif->guild_info
//mapif->guild_basicinfochanged(guild_id,type,data,len);
return 0;
}
// Modification of the guild
static int mapif_parse_GuildMemberInfoChange(int fd, int guild_id, int account_id, int char_id, int type, const char *data, int len)
{
inter_guild->update_member_info(guild_id, account_id, char_id, type, data, len);
return 0;
}
// Change a position desc
static int mapif_parse_GuildPosition(int fd, int guild_id, int idx, const struct guild_position *p)
{
nullpo_ret(p);
inter_guild->update_position(guild_id, idx, p);
return 0;
}
// Guild Skill UP
static int mapif_parse_GuildSkillUp(int fd, int guild_id, uint16 skill_id, int account_id, int max)
{
inter_guild->use_skill_point(guild_id, skill_id, account_id, max);
return 0;
}
// Alliance modification
static int mapif_parse_GuildAlliance(int fd, int guild_id1, int guild_id2, int account_id1, int account_id2, int flag)
{
inter_guild->change_alliance(guild_id1, guild_id2, account_id1, account_id2, flag);
return 0;
}
// Change guild message
static int mapif_parse_GuildNotice(int fd, int guild_id, const char *mes1, const char *mes2)
{
inter_guild->update_notice(guild_id, mes1, mes2);
return 0;
}
static int mapif_parse_GuildEmblem(int fd, int len, int guild_id, int dummy, const char *data)
{
inter_guild->update_emblem(len, guild_id, data);
return 0;
}
static int mapif_parse_GuildCastleDataLoad(int fd, int len, const int *castle_ids)
{
return mapif->guild_castle_dataload(fd, len, castle_ids);
}
static int mapif_parse_GuildCastleDataSave(int fd, int castle_id, int index, int value)
{
inter_guild->update_castle_data(castle_id, index, value);
return 0;
}
static int mapif_parse_GuildMasterChange(int fd, int guild_id, const char* name, int len)
{
inter_guild->change_leader(guild_id, name, len);
return 0;
}
static void mapif_homunculus_created(int fd, int account_id, const struct s_homunculus *sh, unsigned char flag)
{
nullpo_retv(sh);
WFIFOHEAD(fd, sizeof(struct s_homunculus) + 9);
WFIFOW(fd, 0) = 0x3890;
WFIFOW(fd, 2) = sizeof(struct s_homunculus) + 9;
WFIFOL(fd, 4) = account_id;
WFIFOB(fd, 8) = flag;
memcpy(WFIFOP(fd, 9), sh, sizeof(struct s_homunculus));
WFIFOSET(fd, WFIFOW(fd, 2));
}
static void mapif_homunculus_deleted(int fd, int flag)
{
WFIFOHEAD(fd, 3);
WFIFOW(fd, 0) = 0x3893;
WFIFOB(fd,2) = flag; //Flag 1 = success
WFIFOSET(fd, 3);
}
static void mapif_homunculus_loaded(int fd, int account_id, struct s_homunculus *hd)
{
WFIFOHEAD(fd, sizeof(struct s_homunculus) + 9);
WFIFOW(fd, 0) = 0x3891;
WFIFOW(fd, 2) = sizeof(struct s_homunculus) + 9;
WFIFOL(fd, 4) = account_id;
if (hd != NULL) {
WFIFOB(fd, 8) = 1; // success
memcpy(WFIFOP(fd, 9), hd, sizeof(struct s_homunculus));
} else {
WFIFOB(fd, 8) = 0; // not found.
memset(WFIFOP(fd, 9), 0, sizeof(struct s_homunculus));
}
WFIFOSET(fd, sizeof(struct s_homunculus) + 9);
}
static void mapif_homunculus_saved(int fd, int account_id, bool flag)
{
WFIFOHEAD(fd, 7);
WFIFOW(fd, 0) = 0x3892;
WFIFOL(fd, 2) = account_id;
WFIFOB(fd, 6) = flag; // 1:success, 0:failure
WFIFOSET(fd, 7);
}
static void mapif_homunculus_renamed(int fd, int account_id, int char_id, unsigned char flag, const char *name)
{
nullpo_retv(name);
WFIFOHEAD(fd, NAME_LENGTH + 12);
WFIFOW(fd, 0) = 0x3894;
WFIFOL(fd, 2) = account_id;
WFIFOL(fd, 6) = char_id;
WFIFOB(fd, 10) = flag;
safestrncpy(WFIFOP(fd, 11), name, NAME_LENGTH);
WFIFOSET(fd, NAME_LENGTH + 12);
}
static void mapif_parse_homunculus_create(int fd, int len, int account_id, const struct s_homunculus *phd)
{
struct s_homunculus shd;
bool result;
memcpy(&shd, phd, sizeof(shd));
result = inter_homunculus->create(&shd);
mapif->homunculus_created(fd, account_id, &shd, result);
}
static void mapif_parse_homunculus_delete(int fd, int homun_id)
{
bool result = inter_homunculus->delete(homun_id);
mapif->homunculus_deleted(fd, result);
}
static void mapif_parse_homunculus_load(int fd, int account_id, int homun_id)
{
struct s_homunculus hd;
bool result = inter_homunculus->load(homun_id, &hd);
mapif->homunculus_loaded(fd, account_id, (result ? &hd : NULL));
}
static void mapif_parse_homunculus_save(int fd, int len, int account_id, const struct s_homunculus *phd)
{
bool result = inter_homunculus->save(phd);
mapif->homunculus_saved(fd, account_id, result);
}
static void mapif_parse_homunculus_rename(int fd, int account_id, int char_id, const char *name)
{
bool result = inter_homunculus->rename(name);
mapif->homunculus_renamed(fd, account_id, char_id, result, name);
}
static void mapif_mail_sendinbox(int fd, int char_id, unsigned char flag, struct mail_data *md)
{
nullpo_retv(md);
//FIXME: dumping the whole structure like this is unsafe [ultramage]
WFIFOHEAD(fd, sizeof(struct mail_data) + 9);
WFIFOW(fd, 0) = 0x3848;
WFIFOW(fd, 2) = sizeof(struct mail_data) + 9;
WFIFOL(fd, 4) = char_id;
WFIFOB(fd, 8) = flag;
memcpy(WFIFOP(fd, 9),md,sizeof(struct mail_data));
WFIFOSET(fd,WFIFOW(fd, 2));
}
/*==========================================
* Client Inbox Request
*------------------------------------------*/
static void mapif_parse_mail_requestinbox(int fd)
{
int char_id = RFIFOL(fd, 2);
unsigned char flag = RFIFOB(fd, 6);
struct mail_data md;
memset(&md, 0, sizeof(md));
inter_mail->fromsql(char_id, &md);
mapif->mail_sendinbox(fd, char_id, flag, &md);
}
/*==========================================
* Mark mail as 'Read'
*------------------------------------------*/
static void mapif_parse_mail_read(int fd)
{
int mail_id = RFIFOL(fd, 2);
inter_mail->mark_read(mail_id);
}
static void mapif_mail_sendattach(int fd, int char_id, struct mail_message *msg)
{
nullpo_retv(msg);
WFIFOHEAD(fd, sizeof(struct item) + 12);
WFIFOW(fd, 0) = 0x384a;
WFIFOW(fd, 2) = sizeof(struct item) + 12;
WFIFOL(fd, 4) = char_id;
WFIFOL(fd, 8) = (msg->zeny > 0) ? msg->zeny : 0;
memcpy(WFIFOP(fd, 12), &msg->item, sizeof(struct item));
WFIFOSET(fd,WFIFOW(fd, 2));
}
static void mapif_parse_mail_getattach(int fd)
{
struct mail_message msg = { 0 };
int char_id = RFIFOL(fd, 2);
int mail_id = RFIFOL(fd, 6);
if (!inter_mail->get_attachment(char_id, mail_id, &msg))
return;
mapif->mail_sendattach(fd, char_id, &msg);
}
/*==========================================
* Delete Mail
*------------------------------------------*/
static void mapif_mail_delete(int fd, int char_id, int mail_id, bool failed)
{
WFIFOHEAD(fd, 11);
WFIFOW(fd, 0) = 0x384b;
WFIFOL(fd, 2) = char_id;
WFIFOL(fd, 6) = mail_id;
WFIFOB(fd, 10) = failed;
WFIFOSET(fd, 11);
}
static void mapif_parse_mail_delete(int fd)
{
int char_id = RFIFOL(fd, 2);
int mail_id = RFIFOL(fd, 6);
bool failed = !inter_mail->delete(char_id, mail_id);
mapif->mail_delete(fd, char_id, mail_id, failed);
}
/*==========================================
* Report New Mail to Map Server
*------------------------------------------*/
static void mapif_mail_new(struct mail_message *msg)
{
unsigned char buf[74];
if (msg == NULL || msg->id == 0)
return;
WBUFW(buf, 0) = 0x3849;
WBUFL(buf, 2) = msg->dest_id;
WBUFL(buf, 6) = msg->id;
memcpy(WBUFP(buf, 10), msg->send_name, NAME_LENGTH);
memcpy(WBUFP(buf, 34), msg->title, MAIL_TITLE_LENGTH);
mapif->sendall(buf, 74);
}
/*==========================================
* Return Mail
*------------------------------------------*/
static void mapif_mail_return(int fd, int char_id, int mail_id, int new_mail)
{
WFIFOHEAD(fd, 11);
WFIFOW(fd, 0) = 0x384c;
WFIFOL(fd, 2) = char_id;
WFIFOL(fd, 6) = mail_id;
WFIFOB(fd, 10) = (new_mail == 0);
WFIFOSET(fd, 11);
}
static void mapif_parse_mail_return(int fd)
{
int char_id = RFIFOL(fd, 2);
int mail_id = RFIFOL(fd, 6);
int new_mail = 0;
if (!inter_mail->return_message(char_id, mail_id, &new_mail))
return;
mapif->mail_return(fd, char_id, mail_id, new_mail);
}
/*==========================================
* Send Mail
*------------------------------------------*/
static void mapif_mail_send(int fd, struct mail_message* msg)
{
int len = sizeof(struct mail_message) + 4;
nullpo_retv(msg);
WFIFOHEAD(fd, len);
WFIFOW(fd, 0) = 0x384d;
WFIFOW(fd, 2) = len;
memcpy(WFIFOP(fd, 4), msg, sizeof(struct mail_message));
WFIFOSET(fd,len);
}
static void mapif_parse_mail_send(int fd)
{
struct mail_message msg;
int account_id = 0;
if (RFIFOW(fd, 2) != 8 + sizeof(struct mail_message))
return;
account_id = RFIFOL(fd, 4);
memcpy(&msg, RFIFOP(fd, 8), sizeof(struct mail_message));
inter_mail->send(account_id, &msg);
mapif->mail_send(fd, &msg); // notify sender
mapif->mail_new(&msg); // notify recipient
}
static void mapif_mercenary_send(int fd, struct s_mercenary *merc, unsigned char flag)
{
int size = sizeof(struct s_mercenary) + 5;
nullpo_retv(merc);
WFIFOHEAD(fd, size);
WFIFOW(fd, 0) = 0x3870;
WFIFOW(fd, 2) = size;
WFIFOB(fd, 4) = flag;
memcpy(WFIFOP(fd, 5), merc, sizeof(struct s_mercenary));
WFIFOSET(fd,size);
}
static void mapif_parse_mercenary_create(int fd, const struct s_mercenary *merc)
{
struct s_mercenary merc_;
bool result;
memcpy(&merc_, merc, sizeof(merc_));
result = inter_mercenary->create(&merc_);
mapif->mercenary_send(fd, &merc_, result);
}
static void mapif_parse_mercenary_load(int fd, int merc_id, int char_id)
{
struct s_mercenary merc;
bool result = inter_mercenary->load(merc_id, char_id, &merc);
mapif->mercenary_send(fd, &merc, result);
}
static void mapif_mercenary_deleted(int fd, unsigned char flag)
{
WFIFOHEAD(fd, 3);
WFIFOW(fd, 0) = 0x3871;
WFIFOB(fd, 2) = flag;
WFIFOSET(fd, 3);
}
static void mapif_parse_mercenary_delete(int fd, int merc_id)
{
bool result = inter_mercenary->delete(merc_id);
mapif->mercenary_deleted(fd, result);
}
static void mapif_mercenary_saved(int fd, unsigned char flag)
{
WFIFOHEAD(fd, 3);
WFIFOW(fd, 0) = 0x3872;
WFIFOB(fd, 2) = flag;
WFIFOSET(fd, 3);
}
static void mapif_parse_mercenary_save(int fd, const struct s_mercenary *merc)
{
bool result = inter_mercenary->save(merc);
mapif->mercenary_saved(fd, result);
}
// Create a party whether or not
static int mapif_party_created(int fd, int account_id, int char_id, struct party *p)
{
WFIFOHEAD(fd, 39);
WFIFOW(fd, 0) = 0x3820;
WFIFOL(fd, 2) = account_id;
WFIFOL(fd, 6) = char_id;
if (p != NULL) {
WFIFOB(fd, 10) = 0;
WFIFOL(fd, 11) = p->party_id;
memcpy(WFIFOP(fd, 15), p->name, NAME_LENGTH);
ShowInfo("int_party: Party created (%d - %s)\n", p->party_id, p->name);
} else {
WFIFOB(fd, 10) = 1;
WFIFOL(fd, 11) = 0;
memset(WFIFOP(fd, 15), 0, NAME_LENGTH);
}
WFIFOSET(fd, 39);
return 0;
}
//Party information not found
static void mapif_party_noinfo(int fd, int party_id, int char_id)
{
WFIFOHEAD(fd, 12);
WFIFOW(fd, 0) = 0x3821;
WFIFOW(fd, 2) = 12;
WFIFOL(fd, 4) = char_id;
WFIFOL(fd, 8) = party_id;
WFIFOSET(fd, 12);
ShowWarning("int_party: info not found (party_id=%d char_id=%d)\n", party_id, char_id);
}
//Digest party information
static void mapif_party_info(int fd, struct party* p, int char_id)
{
unsigned char buf[8 + sizeof(struct party)];
nullpo_retv(p);
WBUFW(buf, 0) = 0x3821;
WBUFW(buf, 2) = 8 + sizeof(struct party);
WBUFL(buf, 4) = char_id;
memcpy(WBUFP(buf, 8), p, sizeof(struct party));
if (fd < 0)
mapif->sendall(buf, WBUFW(buf, 2));
else
mapif->send(fd, buf, WBUFW(buf, 2));
}
//Whether or not additional party members
static int mapif_party_memberadded(int fd, int party_id, int account_id, int char_id, int flag)
{
WFIFOHEAD(fd, 15);
WFIFOW(fd, 0) = 0x3822;
WFIFOL(fd, 2) = party_id;
WFIFOL(fd, 6) = account_id;
WFIFOL(fd, 10) = char_id;
WFIFOB(fd, 14) = flag;
WFIFOSET(fd, 15);
return 0;
}
// Party setting change notification
static int mapif_party_optionchanged(int fd, struct party *p, int account_id, int flag)
{
unsigned char buf[16];
nullpo_ret(p);
WBUFW(buf, 0) = 0x3823;
WBUFL(buf, 2) = p->party_id;
WBUFL(buf, 6) = account_id;
WBUFW(buf, 10) = p->exp;
WBUFW(buf, 12) = p->item;
WBUFB(buf, 14) = flag;
if (flag == 0)
mapif->sendall(buf, 15);
else
mapif->send(fd, buf, 15);
return 0;
}
//Withdrawal notification party
static int mapif_party_withdraw(int party_id, int account_id, int char_id)
{
unsigned char buf[16];
WBUFW(buf, 0) = 0x3824;
WBUFL(buf, 2) = party_id;
WBUFL(buf, 6) = account_id;
WBUFL(buf, 10) = char_id;
mapif->sendall(buf, 14);
return 0;
}
//Party map update notification
static int mapif_party_membermoved(struct party *p, int idx)
{
unsigned char buf[20];
nullpo_ret(p);
Assert_ret(idx >= 0 && idx < MAX_PARTY);
WBUFW(buf, 0) = 0x3825;
WBUFL(buf, 2) = p->party_id;
WBUFL(buf, 6) = p->member[idx].account_id;
WBUFL(buf, 10) = p->member[idx].char_id;
WBUFW(buf, 14) = p->member[idx].map;
WBUFB(buf, 16) = p->member[idx].online;
WBUFW(buf, 17) = p->member[idx].lv;
mapif->sendall(buf, 19);
return 0;
}
//Dissolution party notification
static int mapif_party_broken(int party_id, int flag)
{
unsigned char buf[16];
WBUFW(buf, 0) = 0x3826;
WBUFL(buf, 2) = party_id;
WBUFB(buf, 6) = flag;
mapif->sendall(buf, 7);
//printf("int_party: broken %d\n",party_id);
return 0;
}
//Remarks in the party
static int mapif_party_message(int party_id, int account_id, const char *mes, int len, int sfd)
{
unsigned char buf[512];
nullpo_ret(mes);
WBUFW(buf, 0) = 0x3827;
WBUFW(buf, 2) = len + 12;
WBUFL(buf, 4) = party_id;
WBUFL(buf, 8) = account_id;
memcpy(WBUFP(buf, 12), mes, len);
mapif->sendallwos(sfd, buf, len + 12);
return 0;
}
// Create Party
static int mapif_parse_CreateParty(int fd, const char *name, int item, int item2, const struct party_member *leader)
{
struct party_data *p;
nullpo_ret(name);
nullpo_ret(leader);
p = inter_party->create(name, item, item2, leader);
if (p == NULL) {
mapif->party_created(fd, leader->account_id, leader->char_id, NULL);
return 0;
}
mapif->party_info(fd, &p->party, 0);
mapif->party_created(fd, leader->account_id, leader->char_id, &p->party);
return 0;
}
// Party information request
static void mapif_parse_PartyInfo(int fd, int party_id, int char_id)
{
struct party_data *p;
p = inter_party->fromsql(party_id);
if (p != NULL)
mapif->party_info(fd, &p->party, char_id);
else
mapif->party_noinfo(fd, party_id, char_id);
}
// Add a player to party request
static int mapif_parse_PartyAddMember(int fd, int party_id, const struct party_member *member)
{
nullpo_ret(member);
if (!inter_party->add_member(party_id, member)) {
mapif->party_memberadded(fd, party_id, member->account_id, member->char_id, 1);
return 0;
}
mapif->party_memberadded(fd, party_id, member->account_id, member->char_id, 0);
return 0;
}
//Party setting change request
static int mapif_parse_PartyChangeOption(int fd, int party_id, int account_id, int exp, int item)
{
inter_party->change_option(party_id, account_id, exp, item, fd);
return 0;
}
//Request leave party
static int mapif_parse_PartyLeave(int fd, int party_id, int account_id, int char_id)
{
inter_party->leave(party_id, account_id, char_id);
return 0;
}
// When member goes to other map or levels up.
static int mapif_parse_PartyChangeMap(int fd, int party_id, int account_id, int char_id, unsigned short map, int online, unsigned int lv)
{
inter_party->change_map(party_id, account_id, char_id, map, online, lv);
return 0;
}
//Request party dissolution
static int mapif_parse_BreakParty(int fd, int party_id)
{
inter_party->disband(party_id);
return 0;
}
//Party sending the message
static int mapif_parse_PartyMessage(int fd, int party_id, int account_id, const char *mes, int len)
{
return mapif->party_message(party_id, account_id, mes, len, fd);
}
static int mapif_parse_PartyLeaderChange(int fd, int party_id, int account_id, int char_id)
{
if (!inter_party->change_leader(party_id, account_id, char_id))
return 0;
return 1;
}
static int mapif_pet_created(int fd, int account_id, struct s_pet *p)
{
WFIFOHEAD(fd, 12);
WFIFOW(fd, 0) = 0x3880;
WFIFOL(fd, 2) = account_id;
if (p != NULL){
WFIFOL(fd, 6) = p->class_;
WFIFOL(fd, 10) = p->pet_id;
ShowInfo("int_pet: created pet %d - %s\n", p->pet_id, p->name);
} else {
WFIFOL(fd, 6) = 0;
WFIFOL(fd, 10) = 0;
}
WFIFOSET(fd, 14);
return 0;
}
static int mapif_pet_info(int fd, int account_id, struct s_pet *p)
{
nullpo_ret(p);
WFIFOHEAD(fd, sizeof(struct s_pet) + 9);
WFIFOW(fd, 0) = 0x3881;
WFIFOW(fd, 2) = sizeof(struct s_pet) + 9;
WFIFOL(fd, 4) = account_id;
WFIFOB(fd, 8) = 0;
memcpy(WFIFOP(fd, 9), p, sizeof(struct s_pet));
WFIFOSET(fd, WFIFOW(fd, 2));
return 0;
}
static int mapif_pet_noinfo(int fd, int account_id)
{
WFIFOHEAD(fd, sizeof(struct s_pet) + 9);
WFIFOW(fd, 0) = 0x3881;
WFIFOW(fd, 2) = sizeof(struct s_pet) + 9;
WFIFOL(fd, 4) = account_id;
WFIFOB(fd, 8) = 1;
memset(WFIFOP(fd, 9), 0, sizeof(struct s_pet));
WFIFOSET(fd, WFIFOW(fd, 2));
return 0;
}
static int mapif_save_pet_ack(int fd, int account_id, int flag)
{
WFIFOHEAD(fd, 7);
WFIFOW(fd, 0) = 0x3882;
WFIFOL(fd, 2) = account_id;
WFIFOB(fd, 6) = flag;
WFIFOSET(fd, 7);
return 0;
}
static int mapif_delete_pet_ack(int fd, int flag)
{
WFIFOHEAD(fd, 3);
WFIFOW(fd, 0) = 0x3883;
WFIFOB(fd, 2) = flag;
WFIFOSET(fd, 3);
return 0;
}
static int mapif_save_pet(int fd, int account_id, const struct s_pet *data)
{
//here process pet save request.
int len;
nullpo_ret(data);
RFIFOHEAD(fd);
len = RFIFOW(fd, 2);
if (sizeof(struct s_pet) != len-8) {
ShowError("inter pet: data size mismatch: %d != %"PRIuS"\n", len-8, sizeof(struct s_pet));
return 0;
}
inter_pet->tosql(data);
mapif->save_pet_ack(fd, account_id, 0);
return 0;
}
static int mapif_delete_pet(int fd, int pet_id)
{
mapif->delete_pet_ack(fd, inter_pet->delete_(pet_id));
return 0;
}
static int mapif_parse_CreatePet(int fd)
{
int account_id;
struct s_pet *pet;
RFIFOHEAD(fd);
account_id = RFIFOL(fd, 2);
pet = inter_pet->create(account_id,
RFIFOL(fd, 6),
RFIFOL(fd, 10),
RFIFOL(fd, 14),
RFIFOL(fd, 18),
RFIFOL(fd, 22),
RFIFOW(fd, 26),
RFIFOW(fd, 28),
RFIFOB(fd, 30),
RFIFOB(fd, 31),
RFIFOP(fd, 32));
if (pet != NULL)
mapif->pet_created(fd, account_id, pet);
else
mapif->pet_created(fd, account_id, NULL);
return 0;
}
static int mapif_parse_LoadPet(int fd)
{
int account_id;
struct s_pet *pet;
RFIFOHEAD(fd);
account_id = RFIFOL(fd, 2);
pet = inter_pet->load(account_id, RFIFOL(fd, 6), RFIFOL(fd, 10));
if (pet != NULL)
mapif->pet_info(fd, account_id, pet);
else
mapif->pet_noinfo(fd, account_id);
return 0;
}
static int mapif_parse_SavePet(int fd)
{
RFIFOHEAD(fd);
mapif->save_pet(fd, RFIFOL(fd, 4), RFIFOP(fd, 8));
return 0;
}
static int mapif_parse_DeletePet(int fd)
{
RFIFOHEAD(fd);
mapif->delete_pet(fd, RFIFOL(fd, 2));
return 0;
}
static void mapif_quest_save_ack(int fd, int char_id, bool success)
{
WFIFOHEAD(fd, 7);
WFIFOW(fd, 0) = 0x3861;
WFIFOL(fd, 2) = char_id;
WFIFOB(fd, 6) = success ? 1 : 0;
WFIFOSET(fd, 7);
}
/**
* Handles the save request from mapserver for a character's questlog.
*
* Received quests are saved, and an ack is sent back to the map server.
*
* @see inter_parse_frommap
*/
static int mapif_parse_quest_save(int fd)
{
int num = (RFIFOW(fd, 2) - 8) / sizeof(struct quest);
int char_id = RFIFOL(fd, 4);
const struct quest *qd = NULL;
bool success;
if (num > 0)
qd = RFIFOP(fd,8);
success = inter_quest->save(char_id, qd, num);
// Send ack
mapif->quest_save_ack(fd, char_id, success);
return 0;
}
static void mapif_send_quests(int fd, int char_id, struct quest *tmp_questlog, int num_quests)
{
WFIFOHEAD(fd,num_quests*sizeof(struct quest) + 8);
WFIFOW(fd, 0) = 0x3860;
WFIFOW(fd, 2) = num_quests*sizeof(struct quest) + 8;
WFIFOL(fd, 4) = char_id;
if (num_quests > 0) {
nullpo_retv(tmp_questlog);
memcpy(WFIFOP(fd, 8), tmp_questlog, sizeof(struct quest) * num_quests);
}
WFIFOSET(fd, num_quests * sizeof(struct quest) + 8);
}
/**
* Sends questlog to the map server
*
* Note: Completed quests (state == Q_COMPLETE) are guaranteed to be sent last
* and the map server relies on this behavior (once the first Q_COMPLETE quest,
* all of them are considered to be Q_COMPLETE)
*
* @see inter_parse_frommap
*/
static int mapif_parse_quest_load(int fd)
{
int char_id = RFIFOL(fd,2);
struct quest *tmp_questlog = NULL;
int num_quests;
tmp_questlog = inter_quest->fromsql(char_id, &num_quests);
mapif->send_quests(fd, char_id, tmp_questlog, num_quests);
if (tmp_questlog != NULL)
aFree(tmp_questlog);
return 0;
}
/* RoDEX */
/*==========================================
* Inbox Request
*------------------------------------------*/
static void mapif_parse_rodex_requestinbox(int fd)
{
int count;
int char_id = RFIFOL(fd,2);
int account_id = RFIFOL(fd, 6);
int8 flag = RFIFOB(fd, 10);
int8 opentype = RFIFOB(fd, 11);
int64 mail_id = RFIFOQ(fd, 12);
struct rodex_maillist mails = { 0 };
VECTOR_INIT(mails);
if (flag == 0)
count = inter_rodex->fromsql(char_id, account_id, opentype, 0, &mails);
else
count = inter_rodex->fromsql(char_id, account_id, opentype, mail_id, &mails);
mapif->rodex_sendinbox(fd, char_id, opentype, flag, count, mail_id, &mails);
VECTOR_CLEAR(mails);
}
static void mapif_rodex_sendinbox(int fd, int char_id, int8 opentype, int8 flag, int count, int64 mail_id, struct rodex_maillist *mails)
{
int per_packet = (UINT16_MAX - 24) / sizeof(struct rodex_message);
int sent = 0;
bool is_first = true;
nullpo_retv(mails);
Assert_retv(char_id > 0);
Assert_retv(count >= 0);
Assert_retv(mail_id >= 0);
do {
int i = 24, j, size, limit;
int to_send = count - sent;
bool is_last = true;
if (to_send <= per_packet) {
size = to_send * sizeof(struct rodex_message) + 24;
limit = to_send;
is_last = true;
} else {
limit = min(to_send, per_packet);
if (limit != to_send) {
is_last = false;
}
size = limit * sizeof(struct rodex_message) + 24;
}
WFIFOHEAD(fd, size);
WFIFOW(fd, 0) = 0x3895;
WFIFOW(fd, 2) = size;
WFIFOL(fd, 4) = char_id;
WFIFOB(fd, 8) = opentype;
WFIFOB(fd, 9) = flag;
WFIFOB(fd, 10) = is_last;
WFIFOB(fd, 11) = is_first;
WFIFOL(fd, 12) = limit;
WFIFOQ(fd, 16) = mail_id;
for (j = 0; j < limit; ++j, ++sent, i += sizeof(struct rodex_message)) {
memcpy(WFIFOP(fd, i), &VECTOR_INDEX(*mails, sent), sizeof(struct rodex_message));
}
WFIFOSET(fd, size);
is_first = false;
} while (sent < count);
}
/*==========================================
* Checks if there are new mails
*------------------------------------------*/
static void mapif_parse_rodex_checkhasnew(int fd)
{
int char_id = RFIFOL(fd, 2);
int account_id = RFIFOL(fd, 6);
bool has_new;
Assert_retv(account_id >= START_ACCOUNT_NUM && account_id <= END_ACCOUNT_NUM);
Assert_retv(char_id >= START_CHAR_NUM);
has_new = inter_rodex->hasnew(char_id, account_id);
mapif->rodex_sendhasnew(fd, char_id, has_new);
}
static void mapif_rodex_sendhasnew(int fd, int char_id, bool has_new)
{
Assert_retv(char_id > 0);
WFIFOHEAD(fd, 7);
WFIFOW(fd, 0) = 0x3896;
WFIFOL(fd, 2) = char_id;
WFIFOB(fd, 6) = has_new;
WFIFOSET(fd, 7);
}
/*==========================================
* Update/Delete mail
*------------------------------------------*/
static void mapif_parse_rodex_updatemail(int fd)
{
int64 mail_id = RFIFOL(fd, 2);
int8 flag = RFIFOB(fd, 10);
inter_rodex->updatemail(mail_id, flag);
}
/*==========================================
* Send Mail
*------------------------------------------*/
static void mapif_parse_rodex_send(int fd)
{
struct rodex_message msg = { 0 };
if (RFIFOW(fd,2) != 4 + sizeof(struct rodex_message))
return;
memcpy(&msg, RFIFOP(fd,4), sizeof(struct rodex_message));
if (msg.receiver_id > 0 || msg.receiver_accountid > 0)
msg.id = inter_rodex->savemessage(&msg);
mapif->rodex_send(fd, msg.sender_id, msg.receiver_id, msg.receiver_accountid, msg.id > 0 ? true : false);
}
static void mapif_rodex_send(int fd, int sender_id, int receiver_id, int receiver_accountid, bool result)
{
Assert_retv(sender_id >= 0);
Assert_retv(receiver_id + receiver_accountid > 0);
WFIFOHEAD(fd,15);
WFIFOW(fd,0) = 0x3897;
WFIFOL(fd,2) = sender_id;
WFIFOL(fd,6) = receiver_id;
WFIFOL(fd,10) = receiver_accountid;
WFIFOB(fd,14) = result;
WFIFOSET(fd,15);
}
/*------------------------------------------
* Check Player
*------------------------------------------*/
static void mapif_parse_rodex_checkname(int fd)
{
int reqchar_id = RFIFOL(fd, 2);
char name[NAME_LENGTH];
int target_char_id, target_level;
int target_class;
safestrncpy(name, RFIFOP(fd, 6), NAME_LENGTH);
if (inter_rodex->checkname(name, &target_char_id, &target_class, &target_level) == true)
mapif->rodex_checkname(fd, reqchar_id, target_char_id, target_class, target_level, name);
else
mapif->rodex_checkname(fd, reqchar_id, 0, 0, 0, name);
}
static void mapif_rodex_checkname(int fd, int reqchar_id, int target_char_id, int target_class, int target_level, char *name)
{
nullpo_retv(name);
Assert_retv(reqchar_id > 0);
Assert_retv(target_char_id >= 0);
WFIFOHEAD(fd, 16 + NAME_LENGTH);
WFIFOW(fd, 0) = 0x3898;
WFIFOL(fd, 2) = reqchar_id;
WFIFOL(fd, 6) = target_char_id;
WFIFOL(fd, 10) = target_class;
WFIFOL(fd, 14) = target_level;
safestrncpy(WFIFOP(fd, 18), name, NAME_LENGTH);
WFIFOSET(fd, 18 + NAME_LENGTH);
}
static int mapif_load_guild_storage(int fd, int account_id, int guild_id, char flag)
{
if (SQL_ERROR == SQL->Query(inter->sql_handle, "SELECT `guild_id` FROM `%s` WHERE `guild_id`='%d'", guild_db, guild_id)) {
Sql_ShowDebug(inter->sql_handle);
} else if (SQL->NumRows(inter->sql_handle) > 0) {
// guild exists
WFIFOHEAD(fd, sizeof(struct guild_storage) + 13);
WFIFOW(fd, 0) = 0x3818;
WFIFOW(fd, 2) = sizeof(struct guild_storage)+13;
WFIFOL(fd, 4) = account_id;
WFIFOL(fd, 8) = guild_id;
WFIFOB(fd, 12) = flag; //1 open storage, 0 don't open
inter_storage->guild_storage_fromsql(guild_id, WFIFOP(fd, 13));
WFIFOSET(fd, WFIFOW(fd, 2));
return 0;
}
// guild does not exist
SQL->FreeResult(inter->sql_handle);
WFIFOHEAD(fd, 12);
WFIFOW(fd, 0) = 0x3818;
WFIFOW(fd, 2) = 12;
WFIFOL(fd, 4) = account_id;
WFIFOL(fd, 8) = 0;
WFIFOSET(fd, 12);
return 0;
}
static int mapif_save_guild_storage_ack(int fd, int account_id, int guild_id, int fail)
{
WFIFOHEAD(fd, 11);
WFIFOW(fd, 0) = 0x3819;
WFIFOL(fd, 2) = account_id;
WFIFOL(fd, 6) = guild_id;
WFIFOB(fd, 10) = fail;
WFIFOSET(fd, 11);
return 0;
}
/**
* Loads the account storage and send to the map server.
* @packet 0x3805 [out] .L .P
* @param fd [in] file/socket descriptor.
* @param account_id [in] account id of the session.
* @return 1 on success, 0 on failure.
*/
static int mapif_account_storage_load(int fd, int account_id)
{
struct storage_data stor = { 0 };
int count = 0, i = 0, len = 0;
Assert_ret(account_id > 0);
VECTOR_INIT(stor.item);
count = inter_storage->fromsql(account_id, &stor);
len = 8 + count * sizeof(struct item);
WFIFOHEAD(fd, len);
WFIFOW(fd, 0) = 0x3805;
WFIFOW(fd, 2) = (uint16) len;
WFIFOL(fd, 4) = account_id;
for (i = 0; i < count; i++)
memcpy(WFIFOP(fd, 8 + i * sizeof(struct item)), &VECTOR_INDEX(stor.item, i), sizeof(struct item));
WFIFOSET(fd, len);
VECTOR_CLEAR(stor.item);
return 1;
}
/**
* Parses account storage load request from map server.
* @packet 0x3010 [in] .L
* @param fd [in] file/socket descriptor
* @return 1 on success, 0 on failure.
*/
static int mapif_parse_AccountStorageLoad(int fd)
{
int account_id = RFIFOL(fd, 2);
Assert_ret(fd > 0);
Assert_ret(account_id > 0);
mapif->account_storage_load(fd, account_id);
return 1;
}
/**
* Parses an account storage save request from the map server.
* @packet 0x3011 [in] .W .L .P
* @param fd [in] file/socket descriptor.
* @return 1 on success, 0 on failure.
*/
static int mapif_parse_AccountStorageSave(int fd)
{
int payload_size = RFIFOW(fd, 2) - 8, account_id = RFIFOL(fd, 4);
int i = 0, count = 0;
struct storage_data p_stor = { 0 };
Assert_ret(fd > 0);
Assert_ret(account_id > 0);
count = payload_size/sizeof(struct item);
VECTOR_INIT(p_stor.item);
if (count > 0) {
VECTOR_ENSURE(p_stor.item, count, 1);
for (i = 0; i < count; i++) {
const struct item *it = RFIFOP(fd, 8 + i * sizeof(struct item));
VECTOR_PUSH(p_stor.item, *it);
}
p_stor.aggregate = count;
}
inter_storage->tosql(account_id, &p_stor);
VECTOR_CLEAR(p_stor.item);
mapif->sAccountStorageSaveAck(fd, account_id, true);
return 1;
}
/**
* Sends an acknowledgement for the save
* status of the account storage.
* @packet 0x3808 [out] .L .B
* @param fd [in] File/Socket Descriptor.
* @param account_id [in] Account ID of the storage in question.
* @param flag [in] Save flag, true for success and false for failure.
*/
static void mapif_send_AccountStorageSaveAck(int fd, int account_id, bool flag)
{
WFIFOHEAD(fd, 7);
WFIFOW(fd, 0) = 0x3808;
WFIFOL(fd, 2) = account_id;
WFIFOB(fd, 6) = flag ? 1 : 0;
WFIFOSET(fd, 7);
}
static int mapif_parse_LoadGuildStorage(int fd)
{
RFIFOHEAD(fd);
mapif->load_guild_storage(fd, RFIFOL(fd, 2), RFIFOL(fd, 6), 1);
return 0;
}
static int mapif_parse_SaveGuildStorage(int fd)
{
int guild_id;
int len;
RFIFOHEAD(fd);
guild_id = RFIFOL(fd, 8);
len = RFIFOW(fd, 2);
if (sizeof(struct guild_storage) != len - 12) {
ShowError("inter storage: data size mismatch: %d != %"PRIuS"\n", len - 12, sizeof(struct guild_storage));
} else if (inter_storage->guild_storage_tosql(guild_id, RFIFOP(fd, 12))) {
mapif->save_guild_storage_ack(fd, RFIFOL(fd, 4), guild_id, 0);
return 0;
}
mapif->save_guild_storage_ack(fd, RFIFOL(fd, 4), guild_id, 1);
return 0;
}
static int mapif_itembound_ack(int fd, int aid, int guild_id)
{
#ifdef GP_BOUND_ITEMS
WFIFOHEAD(fd, 8);
WFIFOW(fd, 0) = 0x3856;
WFIFOL(fd, 2) = aid;/* the value is not being used, drop? */
WFIFOW(fd, 6) = guild_id;
WFIFOSET(fd, 8);
#endif
return 0;
}
static void mapif_parse_ItemBoundRetrieve(int fd)
{
#ifdef GP_BOUND_ITEMS
int char_id = RFIFOL(fd, 2);
int account_id = RFIFOL(fd, 6);
int guild_id = RFIFOW(fd, 10);
inter_storage->retrieve_bound_items(char_id, account_id, guild_id);
//Finally reload storage and tell map we're done
mapif->load_guild_storage(fd, account_id, guild_id, 0);
// If character is logged in char, disconnect
chr->disconnect_player(account_id);
#endif // GP_BOUND_ITEMS
/* tell map server the operation is over and it can unlock the storage */
mapif->itembound_ack(fd, RFIFOL(fd, 6), RFIFOW(fd, 10));
}
static void mapif_parse_accinfo(int fd)
{
char query[NAME_LENGTH];
int u_fd = RFIFOL(fd, 2), aid = RFIFOL(fd, 6), castergroup = RFIFOL(fd, 10);
safestrncpy(query, RFIFOP(fd, 14), NAME_LENGTH);
inter->accinfo(u_fd, aid, castergroup, query, fd);
}
// broadcast sending
static int mapif_broadcast(const unsigned char *mes, int len, unsigned int fontColor, short fontType, short fontSize, short fontAlign, short fontY, int sfd)
{
unsigned char *buf = (unsigned char*)aMalloc((len)*sizeof(unsigned char));
nullpo_ret(mes);
Assert_ret(len >= 16);
WBUFW(buf, 0) = 0x3800;
WBUFW(buf, 2) = len;
WBUFL(buf, 4) = fontColor;
WBUFW(buf, 8) = fontType;
WBUFW(buf, 10) = fontSize;
WBUFW(buf, 12) = fontAlign;
WBUFW(buf, 14) = fontY;
memcpy(WBUFP(buf, 16), mes, len - 16);
mapif->sendallwos(sfd, buf, len);
aFree(buf);
return 0;
}
// Wis sending
static int mapif_wis_message(struct WisData *wd)
{
unsigned char buf[2048];
nullpo_ret(wd);
//if (wd->len > 2047-56) wd->len = 2047-56; //Force it to fit to avoid crashes. [Skotlex]
if (wd->len < 0)
wd->len = 0;
if (wd->len >= (int)sizeof(wd->msg) - 1)
wd->len = (int)sizeof(wd->msg) - 1;
WBUFW(buf, 0) = 0x3801;
WBUFW(buf, 2) = 56 + wd->len;
WBUFL(buf, 4) = wd->id;
memcpy(WBUFP(buf, 8), wd->src, NAME_LENGTH);
memcpy(WBUFP(buf, 32), wd->dst, NAME_LENGTH);
memcpy(WBUFP(buf, 56), wd->msg, wd->len);
wd->count = mapif->sendall(buf, WBUFW(buf, 2));
return 0;
}
static void mapif_wis_response(int fd, const unsigned char *src, int flag)
{
unsigned char buf[27];
nullpo_retv(src);
WBUFW(buf, 0) = 0x3802;
memcpy(WBUFP(buf, 2), src, 24);
WBUFB(buf, 26) = flag;
mapif->send(fd, buf, 27);
}
// Wis sending result
static int mapif_wis_end(struct WisData *wd, int flag)
{
nullpo_ret(wd);
mapif->wis_response(wd->fd, wd->src, flag);
return 0;
}
#if 0
// Account registry transfer to map-server
static void mapif_account_reg(int fd, unsigned char *src)
{
nullpo_retv(src);
WBUFW(src, 0) = 0x3804; //NOTE: writing to RFIFO
mapif->sendallwos(fd, src, WBUFW(src, 2));
}
#endif // 0
// Send the requested account_reg
static int mapif_account_reg_reply(int fd,int account_id,int char_id, int type)
{
inter->accreg_fromsql(account_id, char_id, fd, type);
return 0;
}
//Request to kick char from a certain map server. [Skotlex]
static int mapif_disconnectplayer(int fd, int account_id, int char_id, int reason)
{
if (fd < 0)
return -1;
WFIFOHEAD(fd, 7);
WFIFOW(fd, 0) = 0x2b1f;
WFIFOL(fd, 2) = account_id;
WFIFOB(fd, 6) = reason;
WFIFOSET(fd, 7);
return 0;
}
// broadcast sending
static int mapif_parse_broadcast(int fd)
{
mapif->broadcast(RFIFOP(fd, 16), RFIFOW(fd, 2), RFIFOL(fd, 4), RFIFOW(fd, 8), RFIFOW(fd, 10), RFIFOW(fd, 12), RFIFOW(fd, 14), fd);
return 0;
}
// Wisp/page request to send
static int mapif_parse_WisRequest(int fd)
{
struct WisData* wd;
char name[NAME_LENGTH];
char *data;
size_t len;
if (fd <= 0) // check if we have a valid fd
return 0;
if (RFIFOW(fd, 2) - 52 >= sizeof(wd->msg)) {
ShowWarning("inter: Wis message size too long.\n");
return 0;
} else if (RFIFOW(fd, 2) - 52 <= 0) { // normally, impossible, but who knows...
ShowError("inter: Wis message doesn't exist.\n");
return 0;
}
safestrncpy(name, RFIFOP(fd, 28), NAME_LENGTH); //Received name may be too large and not contain \0! [Skotlex]
// search if character exists before to ask all map-servers
if (!chr->name_exists(name, NULL)) {
mapif->wis_response(fd, RFIFOP(fd, 4), 1);
} else {
// Character exists. So, ask all map-servers
// to be sure of the correct name, rewrite it
SQL->GetData(inter->sql_handle, 0, &data, &len);
memset(name, 0, NAME_LENGTH);
memcpy(name, data, min(len, NAME_LENGTH));
// if source is destination, don't ask other servers.
if (strncmp(RFIFOP(fd, 4), name, NAME_LENGTH) == 0) {
mapif->wis_response(fd, RFIFOP(fd, 4), 1);
} else {
wd = inter->add_wisdata(fd, RFIFOP(fd, 4), RFIFOP(fd, 28), RFIFOP(fd, 52), RFIFOW(fd, 2) - 52);
mapif->wis_message(wd);
}
}
SQL->FreeResult(inter->sql_handle);
return 0;
}
// Wisp/page transmission result
static int mapif_parse_WisReply(int fd)
{
int id, flag;
struct WisData *wd;
id = RFIFOL(fd,2);
flag = RFIFOB(fd,6);
wd = inter->get_wisdata(id);
if (wd == NULL)
return 0; // This wisp was probably suppress before, because it was timeout of because of target was found on another map-server
if ((--wd->count) <= 0 || flag != 1) {
mapif->wis_end(wd, flag); // flag: 0: success to send whisper, 1: target character is not logged in?, 2: ignored by target
inter->remove_wisdata(id);
}
return 0;
}
// Received wisp message from map-server for ALL gm (just copy the message and resends it to ALL map-servers)
static int mapif_parse_WisToGM(int fd)
{
unsigned char buf[2048]; // 0x3003/0x3803 .w .24B .w .?B
memcpy(WBUFP(buf,0), RFIFOP(fd,0), RFIFOW(fd,2)); // Message contains the NUL terminator (see intif_wis_message_to_gm())
WBUFW(buf, 0) = 0x3803;
mapif->sendall(buf, RFIFOW(fd,2));
return 0;
}
// Save account_reg into sql (type=2)
static int mapif_parse_Registry(int fd)
{
int account_id = RFIFOL(fd, 4), char_id = RFIFOL(fd, 8), count = RFIFOW(fd, 12);
if (count != 0) {
int cursor = 14, i;
char key[SCRIPT_VARNAME_LENGTH+1], sval[254];
bool isLoginActive = sockt->session_is_active(chr->login_fd);
if (isLoginActive)
chr->global_accreg_to_login_start(account_id, char_id);
for (i = 0; i < count; i++) {
unsigned int index;
int len = RFIFOB(fd, cursor);
safestrncpy(key, RFIFOP(fd, cursor + 1), min((int)sizeof(key), len));
cursor += len + 1;
index = RFIFOL(fd, cursor);
cursor += 4;
switch (RFIFOB(fd, cursor++)) {
/* int */
case 0:
inter->savereg(account_id, char_id, key, index, RFIFOL(fd, cursor), false);
cursor += 4;
break;
case 1:
inter->savereg(account_id, char_id, key, index, 0, false);
break;
/* str */
case 2:
len = RFIFOB(fd, cursor);
safestrncpy(sval, RFIFOP(fd, cursor + 1), min((int)sizeof(sval), len));
cursor += len + 1;
inter->savereg(account_id, char_id, key, index, (intptr_t)sval, true);
break;
case 3:
inter->savereg(account_id, char_id, key, index, 0, true);
break;
default:
ShowError("mapif->parse_Registry: unknown type %d\n", RFIFOB(fd, cursor - 1));
return 1;
}
}
if (isLoginActive)
chr->global_accreg_to_login_send();
}
return 0;
}
// Request the value of all registries.
static int mapif_parse_RegistryRequest(int fd)
{
//Load Char Registry
if (RFIFOB(fd, 12))
mapif->account_reg_reply(fd, RFIFOL(fd, 2), RFIFOL(fd, 6), 3); // 3: char reg
//Load Account Registry
if (RFIFOB(fd, 11) != 0)
mapif->account_reg_reply(fd, RFIFOL(fd, 2), RFIFOL(fd, 6), 2); // 2: account reg
//Ask Login Server for Account2 values.
if (RFIFOB(fd, 10) != 0)
chr->request_accreg2(RFIFOL(fd, 2), RFIFOL(fd, 6));
return 1;
}
static void mapif_namechange_ack(int fd, int account_id, int char_id, int type, int flag, const char *const name)
{
nullpo_retv(name);
WFIFOHEAD(fd, NAME_LENGTH+13);
WFIFOW(fd, 0) = 0x3806;
WFIFOL(fd, 2) = account_id;
WFIFOL(fd, 6) = char_id;
WFIFOB(fd, 10) = type;
WFIFOB(fd, 11) = flag;
memcpy(WFIFOP(fd, 12), name, NAME_LENGTH);
WFIFOSET(fd, NAME_LENGTH + 13);
}
static int mapif_parse_NameChangeRequest(int fd)
{
int account_id, char_id, type;
const char *name;
int i;
account_id = RFIFOL(fd, 2);
char_id = RFIFOL(fd, 6);
type = RFIFOB(fd, 10);
name = RFIFOP(fd, 11);
// Check Authorized letters/symbols in the name
if (char_name_option == 1) { // only letters/symbols in char_name_letters are authorized
for (i = 0; i < NAME_LENGTH && name[i]; i++)
if (strchr(char_name_letters, name[i]) == NULL) {
mapif->namechange_ack(fd, account_id, char_id, type, 0, name);
return 0;
}
} else if (char_name_option == 2) { // letters/symbols in char_name_letters are forbidden
for (i = 0; i < NAME_LENGTH && name[i]; i++)
if (strchr(char_name_letters, name[i]) != NULL) {
mapif->namechange_ack(fd, account_id, char_id, type, 0, name);
return 0;
}
}
//TODO: type holds the type of object to rename.
//If it were a player, it needs to have the guild information and db information
//updated here, because changing it on the map won't make it be saved [Skotlex]
//name allowed.
mapif->namechange_ack(fd, account_id, char_id, type, 1, name);
return 0;
}
// Clan System
static int mapif_parse_ClanMemberKick(int fd, int clan_id, int kick_interval)
{
int count = 0;
if (inter_clan->kick_inactive_members(clan_id, kick_interval) == 1)
count = inter_clan->count_members(clan_id, kick_interval);
WFIFOHEAD(fd, 10);
WFIFOW(fd, 0) = 0x3858;
WFIFOL(fd, 2) = clan_id;
WFIFOL(fd, 6) = count;
WFIFOSET(fd, 10);
return 0;
}
static int mapif_parse_ClanMemberCount(int fd, int clan_id, int kick_interval)
{
WFIFOHEAD(fd, 10);
WFIFOW(fd, 0) = 0x3858;
WFIFOL(fd, 2) = clan_id;
WFIFOL(fd, 6) = inter_clan->count_members(clan_id, kick_interval);
WFIFOSET(fd, 10);
return 0;
}
// Achievement System
/**
* Parse achievement load request from the map server
* @param[in] fd socket descriptor.
*/
static void mapif_parse_load_achievements(int fd)
{
int char_id = 0;
/* Read received information from map-server. */
RFIFOHEAD(fd);
char_id = RFIFOL(fd, 2);
/* Load and send achievements to map */
mapif->achievement_load(fd, char_id);
}
/**
* Loads achievements and sends to the map server.
* @param[in] fd socket descriptor
* @param[in] char_id character Id.
*/
static void mapif_achievement_load(int fd, int char_id)
{
struct char_achievements *cp = NULL;
/* Ensure data exists */
cp = idb_ensure(inter_achievement->char_achievements, char_id, inter_achievement->ensure_char_achievements);
/* Load storage for char-server. */
inter_achievement->fromsql(char_id, cp);
/* Send Achievements to map server. */
mapif->sAchievementsToMap(fd, char_id, cp);
}
/**
* Sends achievement data of a character to the map server.
* @packet[out] 0x3810 .W .W .L .P
* @param[in] fd socket descriptor.
* @param[in] char_id Character ID.
* @param[in] cp Pointer to character's achievement data vector.
*/
static void mapif_send_achievements_to_map(int fd, int char_id, const struct char_achievements *cp)
{
int i = 0;
int data_size = 0;
nullpo_retv(cp);
data_size = sizeof(struct achievement) * VECTOR_LENGTH(*cp);
STATIC_ASSERT((sizeof(struct achievement) * MAX_ACHIEVEMENT_DB + 8 <= UINT16_MAX),
"The achievements data can potentially be larger than the maximum packet size. This may cause errors at run-time.");
/* Send to the map server. */
WFIFOHEAD(fd, (8 + data_size));
WFIFOW(fd, 0) = 0x3810;
WFIFOW(fd, 2) = (8 + data_size);
WFIFOL(fd, 4) = char_id;
for (i = 0; i < VECTOR_LENGTH(*cp); i++)
memcpy(WFIFOP(fd, 8 + i * sizeof(struct achievement)), &VECTOR_INDEX(*cp, i), sizeof(struct achievement));
WFIFOSET(fd, 8 + data_size);
}
/**
* Handles achievement request and saves data from map server.
* @packet[in] 0x3013 .W .L .P
* @param[in] fd session socket descriptor.
*/
static void mapif_parse_save_achievements(int fd)
{
int size = 0, char_id = 0, payload_count = 0, i = 0;
struct char_achievements p = { 0 };
RFIFOHEAD(fd);
size = RFIFOW(fd, 2);
char_id = RFIFOL(fd, 4);
payload_count = (size - 8) / sizeof(struct achievement);
VECTOR_INIT(p);
VECTOR_ENSURE(p, payload_count, 1);
for (i = 0; i < payload_count; i++) {
struct achievement ach = { 0 };
memcpy(&ach, RFIFOP(fd, 8 + i * sizeof(struct achievement)), sizeof(struct achievement));
VECTOR_PUSH(p, ach);
}
mapif->achievement_save(char_id, &p);
VECTOR_CLEAR(p);
}
/**
* Handles inter-server achievement db ensuring
* and saves current achievements to sql.
* @param[in] char_id character identifier.
* @param[out] p pointer to character achievements vector.
*/
static void mapif_achievement_save(int char_id, struct char_achievements *p)
{
struct char_achievements *cp = NULL;
nullpo_retv(p);
/* Get loaded achievements. */
cp = idb_ensure(inter_achievement->char_achievements, char_id, inter_achievement->ensure_char_achievements);
if (VECTOR_LENGTH(*p)) /* Save current achievements. */
inter_achievement->tosql(char_id, cp, p);
}
void mapif_defaults(void)
{
mapif = &mapif_s;
mapif->ban = mapif_ban;
mapif->server_init = mapif_server_init;
mapif->server_destroy = mapif_server_destroy;
mapif->server_reset = mapif_server_reset;
mapif->on_disconnect = mapif_on_disconnect;
mapif->on_parse_accinfo = mapif_on_parse_accinfo;
mapif->char_ban = mapif_char_ban;
mapif->sendall = mapif_sendall;
mapif->sendallwos = mapif_sendallwos;
mapif->send = mapif_send;
mapif->send_users_count = mapif_send_users_count;
mapif->pLoadAchievements = mapif_parse_load_achievements;
mapif->sAchievementsToMap = mapif_send_achievements_to_map;
mapif->pSaveAchievements = mapif_parse_save_achievements;
mapif->achievement_load = mapif_achievement_load;
mapif->achievement_save = mapif_achievement_save;
mapif->auction_message = mapif_auction_message;
mapif->auction_sendlist = mapif_auction_sendlist;
mapif->parse_auction_requestlist = mapif_parse_auction_requestlist;
mapif->auction_register = mapif_auction_register;
mapif->parse_auction_register = mapif_parse_auction_register;
mapif->auction_cancel = mapif_auction_cancel;
mapif->parse_auction_cancel = mapif_parse_auction_cancel;
mapif->auction_close = mapif_auction_close;
mapif->parse_auction_close = mapif_parse_auction_close;
mapif->auction_bid = mapif_auction_bid;
mapif->parse_auction_bid = mapif_parse_auction_bid;
mapif->elemental_send = mapif_elemental_send;
mapif->parse_elemental_create = mapif_parse_elemental_create;
mapif->parse_elemental_load = mapif_parse_elemental_load;
mapif->elemental_deleted = mapif_elemental_deleted;
mapif->parse_elemental_delete = mapif_parse_elemental_delete;
mapif->elemental_saved = mapif_elemental_saved;
mapif->parse_elemental_save = mapif_parse_elemental_save;
mapif->guild_created = mapif_guild_created;
mapif->guild_noinfo = mapif_guild_noinfo;
mapif->guild_info = mapif_guild_info;
mapif->guild_memberadded = mapif_guild_memberadded;
mapif->guild_withdraw = mapif_guild_withdraw;
mapif->guild_memberinfoshort = mapif_guild_memberinfoshort;
mapif->guild_broken = mapif_guild_broken;
mapif->guild_message = mapif_guild_message;
mapif->guild_basicinfochanged = mapif_guild_basicinfochanged;
mapif->guild_memberinfochanged = mapif_guild_memberinfochanged;
mapif->guild_skillupack = mapif_guild_skillupack;
mapif->guild_alliance = mapif_guild_alliance;
mapif->guild_position = mapif_guild_position;
mapif->guild_notice = mapif_guild_notice;
mapif->guild_emblem = mapif_guild_emblem;
mapif->guild_master_changed = mapif_guild_master_changed;
mapif->guild_castle_dataload = mapif_guild_castle_dataload;
mapif->parse_CreateGuild = mapif_parse_CreateGuild;
mapif->parse_GuildInfo = mapif_parse_GuildInfo;
mapif->parse_GuildAddMember = mapif_parse_GuildAddMember;
mapif->parse_GuildLeave = mapif_parse_GuildLeave;
mapif->parse_GuildChangeMemberInfoShort = mapif_parse_GuildChangeMemberInfoShort;
mapif->parse_BreakGuild = mapif_parse_BreakGuild;
mapif->parse_GuildMessage = mapif_parse_GuildMessage;
mapif->parse_GuildBasicInfoChange = mapif_parse_GuildBasicInfoChange;
mapif->parse_GuildMemberInfoChange = mapif_parse_GuildMemberInfoChange;
mapif->parse_GuildPosition = mapif_parse_GuildPosition;
mapif->parse_GuildSkillUp = mapif_parse_GuildSkillUp;
mapif->parse_GuildAlliance = mapif_parse_GuildAlliance;
mapif->parse_GuildNotice = mapif_parse_GuildNotice;
mapif->parse_GuildEmblem = mapif_parse_GuildEmblem;
mapif->parse_GuildCastleDataLoad = mapif_parse_GuildCastleDataLoad;
mapif->parse_GuildCastleDataSave = mapif_parse_GuildCastleDataSave;
mapif->parse_GuildMasterChange = mapif_parse_GuildMasterChange;
mapif->homunculus_created = mapif_homunculus_created;
mapif->homunculus_deleted = mapif_homunculus_deleted;
mapif->homunculus_loaded = mapif_homunculus_loaded;
mapif->homunculus_saved = mapif_homunculus_saved;
mapif->homunculus_renamed = mapif_homunculus_renamed;
mapif->parse_homunculus_create = mapif_parse_homunculus_create;
mapif->parse_homunculus_delete = mapif_parse_homunculus_delete;
mapif->parse_homunculus_load = mapif_parse_homunculus_load;
mapif->parse_homunculus_save = mapif_parse_homunculus_save;
mapif->parse_homunculus_rename = mapif_parse_homunculus_rename;
mapif->mail_sendinbox = mapif_mail_sendinbox;
mapif->parse_mail_requestinbox = mapif_parse_mail_requestinbox;
mapif->parse_mail_read = mapif_parse_mail_read;
mapif->mail_sendattach = mapif_mail_sendattach;
mapif->parse_mail_getattach = mapif_parse_mail_getattach;
mapif->mail_delete = mapif_mail_delete;
mapif->parse_mail_delete = mapif_parse_mail_delete;
mapif->mail_new = mapif_mail_new;
mapif->mail_return = mapif_mail_return;
mapif->parse_mail_return = mapif_parse_mail_return;
mapif->mail_send = mapif_mail_send;
mapif->parse_mail_send = mapif_parse_mail_send;
mapif->mercenary_send = mapif_mercenary_send;
mapif->parse_mercenary_create = mapif_parse_mercenary_create;
mapif->parse_mercenary_load = mapif_parse_mercenary_load;
mapif->mercenary_deleted = mapif_mercenary_deleted;
mapif->parse_mercenary_delete = mapif_parse_mercenary_delete;
mapif->mercenary_saved = mapif_mercenary_saved;
mapif->parse_mercenary_save = mapif_parse_mercenary_save;
mapif->party_created = mapif_party_created;
mapif->party_noinfo = mapif_party_noinfo;
mapif->party_info = mapif_party_info;
mapif->party_memberadded = mapif_party_memberadded;
mapif->party_optionchanged = mapif_party_optionchanged;
mapif->party_withdraw = mapif_party_withdraw;
mapif->party_membermoved = mapif_party_membermoved;
mapif->party_broken = mapif_party_broken;
mapif->party_message = mapif_party_message;
mapif->parse_CreateParty = mapif_parse_CreateParty;
mapif->parse_PartyInfo = mapif_parse_PartyInfo;
mapif->parse_PartyAddMember = mapif_parse_PartyAddMember;
mapif->parse_PartyChangeOption = mapif_parse_PartyChangeOption;
mapif->parse_PartyLeave = mapif_parse_PartyLeave;
mapif->parse_PartyChangeMap = mapif_parse_PartyChangeMap;
mapif->parse_BreakParty = mapif_parse_BreakParty;
mapif->parse_PartyMessage = mapif_parse_PartyMessage;
mapif->parse_PartyLeaderChange = mapif_parse_PartyLeaderChange;
mapif->pet_created = mapif_pet_created;
mapif->pet_info = mapif_pet_info;
mapif->pet_noinfo = mapif_pet_noinfo;
mapif->save_pet_ack = mapif_save_pet_ack;
mapif->delete_pet_ack = mapif_delete_pet_ack;
mapif->save_pet = mapif_save_pet;
mapif->delete_pet = mapif_delete_pet;
mapif->parse_CreatePet = mapif_parse_CreatePet;
mapif->parse_LoadPet = mapif_parse_LoadPet;
mapif->parse_SavePet = mapif_parse_SavePet;
mapif->parse_DeletePet = mapif_parse_DeletePet;
mapif->quest_save_ack = mapif_quest_save_ack;
mapif->parse_quest_save = mapif_parse_quest_save;
mapif->send_quests = mapif_send_quests;
mapif->parse_quest_load = mapif_parse_quest_load;
/* RoDEX */
mapif->parse_rodex_requestinbox = mapif_parse_rodex_requestinbox;
mapif->rodex_sendinbox = mapif_rodex_sendinbox;
mapif->parse_rodex_checkhasnew = mapif_parse_rodex_checkhasnew;
mapif->rodex_sendhasnew = mapif_rodex_sendhasnew;
mapif->parse_rodex_updatemail = mapif_parse_rodex_updatemail;
mapif->parse_rodex_send = mapif_parse_rodex_send;
mapif->rodex_send = mapif_rodex_send;
mapif->parse_rodex_checkname = mapif_parse_rodex_checkname;
mapif->rodex_checkname = mapif_rodex_checkname;
mapif->load_guild_storage = mapif_load_guild_storage;
mapif->save_guild_storage_ack = mapif_save_guild_storage_ack;
mapif->parse_LoadGuildStorage = mapif_parse_LoadGuildStorage;
mapif->parse_SaveGuildStorage = mapif_parse_SaveGuildStorage;
mapif->pAccountStorageLoad = mapif_parse_AccountStorageLoad;
mapif->pAccountStorageSave = mapif_parse_AccountStorageSave;
mapif->sAccountStorageSaveAck = mapif_send_AccountStorageSaveAck;
mapif->account_storage_load = mapif_account_storage_load;
mapif->itembound_ack = mapif_itembound_ack;
mapif->parse_ItemBoundRetrieve = mapif_parse_ItemBoundRetrieve;
mapif->parse_accinfo = mapif_parse_accinfo;
mapif->broadcast = mapif_broadcast;
mapif->wis_message = mapif_wis_message;
mapif->wis_response = mapif_wis_response;
mapif->wis_end = mapif_wis_end;
mapif->account_reg_reply = mapif_account_reg_reply;
mapif->disconnectplayer = mapif_disconnectplayer;
mapif->parse_broadcast = mapif_parse_broadcast;
mapif->parse_WisRequest = mapif_parse_WisRequest;
mapif->parse_WisReply = mapif_parse_WisReply;
mapif->parse_WisToGM = mapif_parse_WisToGM;
mapif->parse_Registry = mapif_parse_Registry;
mapif->parse_RegistryRequest = mapif_parse_RegistryRequest;
mapif->namechange_ack = mapif_namechange_ack;
mapif->parse_NameChangeRequest = mapif_parse_NameChangeRequest;
/* Clan System */
mapif->parse_ClanMemberKick = mapif_parse_ClanMemberKick;
mapif->parse_ClanMemberCount = mapif_parse_ClanMemberCount;
}