root/src/map/party.c @ 1

// Copyright (c) Athena Dev Teams - Licensed under GNU GPL
// For more information, see LICENCE in the main folder

#include "../common/cbasetypes.h"
#include "../common/timer.h"
#include "../common/socket.h" // last_tick
#include "../common/nullpo.h"
#include "../common/malloc.h"
#include "../common/showmsg.h"
#include "../common/utils.h"
#include "../common/strlib.h"

#include "party.h"
#include "atcommand.h"  //msg_txt()
#include "pc.h"
#include "map.h"
#include "battle.h"
#include "intif.h"
#include "clif.h"
#include "log.h"
#include "skill.h"
#include "status.h"
#include "itemdb.h"

#include <stdio.h>
#include <stdlib.h>
#include <string.h>


static DBMap* party_db; // int party_id -> struct party_data*
int party_share_level = 10;
int party_send_xy_timer(int tid, unsigned int tick, int id, intptr data);

/*==========================================
 * Fills the given party_member structure according to the sd provided. 
 * Used when creating/adding people to a party. [Skotlex]
 *------------------------------------------*/
static void party_fill_member(struct party_member *member, struct map_session_data *sd)
{
        member->account_id = sd->status.account_id;
        member->char_id    = sd->status.char_id;
        memcpy(member->name, sd->status.name, NAME_LENGTH);
        member->class_     = sd->status.class_;
        member->map        = sd->mapindex;
        member->lv         = sd->status.base_level;
        member->online     = 1;
        member->leader     = 0;
}

/*==========================================
 * Retrieves and validates the sd pointer for this party member [Skotlex]
 *------------------------------------------*/

static TBL_PC* party_sd_check(int party_id, int account_id, int char_id)
{
        TBL_PC* sd = map_id2sd(account_id);

        if (!(sd && sd->status.char_id == char_id))
                return NULL;

        if (sd->status.party_id != party_id)
        {       //If player belongs to a different party, kick him out.
                intif_party_leave(party_id,account_id,char_id);
                return NULL;
        }

        return sd;
}

/*==========================================
 * I—¹
 *------------------------------------------*/
void do_final_party(void)
{
        party_db->destroy(party_db,NULL);
}
// ‰Šú‰»
void do_init_party(void)
{
        party_db = idb_alloc(DB_OPT_RELEASE_DATA);
        add_timer_func_list(party_send_xy_timer, "party_send_xy_timer");
        add_timer_interval(gettick()+battle_config.party_update_interval, party_send_xy_timer, 0, 0, battle_config.party_update_interval);
}

/// Party data lookup using party id.
struct party_data* party_search(int party_id)
{
        if(!party_id)
                return NULL;
        return (struct party_data*)idb_get(party_db,party_id);
}

/// Party data lookup using party name.
struct party_data* party_searchname(const char* str)
{
        struct party_data* p;

        DBIterator* iter = party_db->iterator(party_db);
        for( p = (struct party_data*)iter->first(iter,NULL); iter->exists(iter); p = (struct party_data*)iter->next(iter,NULL) )
        {
                if( strncmpi(p->party.name,str,NAME_LENGTH) == 0 )
                        break;
        }
        iter->destroy(iter);

        return p;
}

int party_create(struct map_session_data *sd,char *name,int item,int item2)
{
        struct party_member leader;
        char tname[NAME_LENGTH];

        safestrncpy(tname, name, NAME_LENGTH);
        if( strlen(trim(tname)) == 0 )
        {// empty name
                return 0;
        }

        if( sd->status.party_id > 0 || sd->party_joining || sd->party_creating )
        {// already associated with a party
                clif_party_created(sd,2);
                return 0;
        }

        sd->party_creating = true;

        party_fill_member(&leader, sd);
        leader.leader = 1;

        intif_create_party(&leader,name,item,item2);
        return 0;
}


void party_created(int account_id,int char_id,int fail,int party_id,char *name)
{
        struct map_session_data *sd;
        sd=map_id2sd(account_id);

        if (!sd || sd->status.char_id != char_id || !sd->party_creating )
        {       //Character logged off before creation ack?
                if (!fail) //break up party since player could not be added to it.
                        intif_party_leave(party_id,account_id,char_id);
                return;
        }

        sd->party_creating = false;

        if( !fail ) {
                sd->status.party_id = party_id;
                clif_party_created(sd,0); //Success message
                //We don't do any further work here because the char-server sends a party info packet right after creating the party.
        } else {
                clif_party_created(sd,1); // "party name already exists"
        }

}

int party_request_info(int party_id)
{
        return intif_request_partyinfo(party_id);
}

/// Checks if each char having a party actually belongs to that party.
/// If check fails, the char gets marked as 'not in a party'.
int party_check_member(struct party *p)
{
        int i;
        struct map_session_data *sd;
        struct s_mapiterator* iter;

        nullpo_retr(0, p);

        iter = mapit_getallusers();
        for( sd = (TBL_PC*)mapit_first(iter); mapit_exists(iter); sd = (TBL_PC*)mapit_next(iter) )
        {
                if( sd->status.party_id != p->party_id )
                        continue;

                ARR_FIND( 0, MAX_PARTY, i, p->member[i].account_id == sd->status.account_id && p->member[i].char_id == sd->status.char_id );
                if( i == MAX_PARTY )
                {
                        ShowWarning("party_check_member: '%s' (acc:%d) is not member of party '%s' (id:%d)\n",sd->status.name,sd->status.account_id,p->name,p->party_id);
                        sd->status.party_id = 0;
                }
        }
        mapit_free(iter);

        return 0;
}

/// Marks all chars belonging to this party as 'not in a party'.
int party_recv_noinfo(int party_id)
{
        struct map_session_data *sd;
        struct s_mapiterator* iter;

        iter = mapit_getallusers();
        for( sd = (TBL_PC*)mapit_first(iter); mapit_exists(iter); sd = (TBL_PC*)mapit_next(iter) )
        {
                if( sd->status.party_id == party_id )
                        sd->status.party_id = 0; // erase party
        }
        mapit_free(iter);

        return 0;
}

static void* create_party(DBKey key, va_list args)
{
        struct party_data *p;
        p=(struct party_data *)aCalloc(1,sizeof(struct party_data));
        return p;
}

static void party_check_state(struct party_data *p)
{
        int i;
        memset(&p->state, 0, sizeof(p->state));
        for (i = 0; i < MAX_PARTY; i ++)
        {
                if (!p->party.member[i].online) continue; //Those not online shouldn't aport to skill usage and all that.
                switch (p->party.member[i].class_) {
                case JOB_MONK:
                case JOB_BABY_MONK:
                case JOB_CHAMPION:
                        p->state.monk = 1;
                break;
                case JOB_STAR_GLADIATOR:
                        p->state.sg = 1;
                break;
                case JOB_SUPER_NOVICE:
                case JOB_SUPER_BABY:
                        p->state.snovice = 1;
                break;
                case JOB_TAEKWON:
                        p->state.tk = 1;
                break;
                }
        }
}

int party_recv_info(struct party *sp)
{
        struct party_data *p;
        int i;
        bool party_new = false;
        
        nullpo_retr(0, sp);

        p = (struct party_data*)idb_ensure(party_db, sp->party_id, create_party);
        if (!p->party.party_id) //party just received.
        {
                party_new = true;
                party_check_member(sp);
        }
        memcpy(&p->party,sp,sizeof(struct party));
        memset(&p->state, 0, sizeof(p->state));
        memset(&p->data, 0, sizeof(p->data));
        for(i=0;i<MAX_PARTY;i++){
                if (!p->party.member[i].account_id)
                        continue;
                p->data[i].sd = party_sd_check(p->party.party_id, p->party.member[i].account_id, p->party.member[i].char_id);
        }
        party_check_state(p);
        if (party_new) {
                //Send party data to all players.
                struct map_session_data *sd;
                for(i=0;i<MAX_PARTY;i++){
                        sd = p->data[i].sd;
                        if(!sd) continue;
                        clif_charnameupdate(sd); //Update other people's display. [Skotlex]
                        clif_party_member_info(p,sd);
                        clif_party_option(p,sd,0x100);
                        clif_party_info(p,NULL);
                }
        }
        
        return 0;
}

int party_invite(struct map_session_data *sd,struct map_session_data *tsd)
{
        struct party_data *p=party_search(sd->status.party_id);
        int i,flag=0;
        
        nullpo_retr(0, sd);
        if (p==NULL)
                return 0;

        if(tsd==NULL) { //TODO: Find the correct reply packet.
                clif_displaymessage(sd->fd, msg_txt(3));
                return 0;
        }
        //Only leader can invite.
        ARR_FIND(0, MAX_PARTY, i, p->data[i].sd == sd);
        if (i == MAX_PARTY || !p->party.member[i].leader)
        {       //TODO: Find the correct reply packet.
                clif_displaymessage(sd->fd, msg_txt(282));
                return 0;
        }

        if(!battle_config.invite_request_check) {
                if (tsd->guild_invite>0 || tsd->trade_partner || tsd->adopt_invite) {
                        clif_party_inviteack(sd,tsd->status.name,0);
                        return 0;
                }
        }

        if (!tsd->fd) { //You can't invite someone who has already disconnected.
                clif_party_inviteack(sd,tsd->status.name,1);
                return 0;
        }

        if( tsd->status.party_id > 0 || tsd->party_invite > 0 )
        {// already associated with a party
                clif_party_inviteack(sd,tsd->status.name,0);
                return 0;
        }
        for(i=0;i<MAX_PARTY;i++){
                if(p->party.member[i].account_id == 0) //Room for a new member.
                        flag = 1;
        /* By default Aegis BLOCKS more than one char from the same account on a party.
         * But eA does support it... so this check is left commented.
                if(p->party.member[i].account_id==tsd->status.account_id)
                {
                        clif_party_inviteack(sd,tsd->status.name,4);
                        return 0;
                }
        */
        }
        if (!flag) { //Full party.
                clif_party_inviteack(sd,tsd->status.name,3);
                return 0;
        }
                
        tsd->party_invite=sd->status.party_id;
        tsd->party_invite_account=sd->status.account_id;

        clif_party_invite(sd,tsd);
        return 1;
}

void party_reply_invite(struct map_session_data *sd,int account_id,int flag)
{
        struct map_session_data *tsd= map_id2sd(account_id);
        struct party_member member;

        if( flag == 1 && !sd->party_creating && !sd->party_joining )
        {// accepted and allowed
                sd->party_joining = true;
                party_fill_member(&member, sd);
                intif_party_addmember(sd->party_invite, &member);
        }
        else
        {// rejected or failure
                sd->party_invite = 0;
                sd->party_invite_account = 0;
                if( tsd != NULL )
                        clif_party_inviteack(tsd,sd->status.name,1);
        }
}

//Invoked when a player joins:
//- Loads up party data if not in server
//- Sets up the pointer to him
//- Player must be authed/active and belong to a party before calling this method
void party_member_joined(struct map_session_data *sd)
{
        struct party_data* p = party_search(sd->status.party_id);
        int i;
        if (!p)
        {
                party_request_info(sd->status.party_id);
                return;
        }
        ARR_FIND( 0, MAX_PARTY, i, p->party.member[i].account_id == sd->status.account_id && p->party.member[i].char_id == sd->status.char_id );
        if (i < MAX_PARTY)
                p->data[i].sd = sd;
        else
                sd->status.party_id = 0; //He does not belongs to the party really?
}

/// Invoked (from char-server) when a new member is added to the party.
/// flag: 0-success, 1-failure
int party_member_added(int party_id,int account_id,int char_id, int flag)
{
        struct map_session_data *sd = map_id2sd(account_id),*sd2;
        struct party_data *p = party_search(party_id);
        int i;

        if(sd == NULL || sd->status.char_id != char_id || !sd->party_joining ) {
                if (!flag) //Char logged off before being accepted into party.
                        intif_party_leave(party_id,account_id,char_id);
                return 0;
        }

        sd2 = map_id2sd(sd->party_invite_account);

        sd->party_joining = false;
        sd->party_invite = 0;
        sd->party_invite_account = 0;

        if (!p) {
                ShowError("party_member_added: party %d not found.\n",party_id);
                intif_party_leave(party_id,account_id,char_id);
                return 0;
        }

        if( flag )
        {// failed
                if( sd2 != NULL )
                        clif_party_inviteack(sd2,sd->status.name,3);
                return 0;
        }

        sd->status.party_id = party_id;

        ARR_FIND( 0, MAX_PARTY, i, p->party.member[i].account_id == 0 );
        if (i < MAX_PARTY) {
                //TODO: This is a hack to allow the following clif calls to send the data to the new player.
                //The correct player data is set when party_recv_info arrives soon afterwards.
                party_fill_member(&p->party.member[i], sd);
                p->data[i].sd = sd;
        }

        party_check_conflict(sd); //FIXME: is this neccessary?
        clif_party_member_info(p,sd);
        clif_party_option(p,sd,0x100);
        clif_party_info(p,sd);

        if( sd2 != NULL )
                clif_party_inviteack(sd2,sd->status.name,2);

        for( i = 0; i < ARRAYLENGTH(p->data); ++i )
        {// hp of the other party members
                sd2 = p->data[i].sd;
                if( sd2 && sd2->status.account_id != account_id && sd2->status.char_id != char_id )
                        clif_hpmeter_single(sd->fd, sd2->bl.id, sd2->battle_status.hp, sd2->battle_status.max_hp);
        }
        clif_party_hp(sd);
        clif_party_xy(sd);
        clif_charnameupdate(sd); //Update char name's display [Skotlex]

        return 0;
}

/// Party member 'sd' requesting kick of member with <account_id, name>.
int party_removemember(struct map_session_data* sd, int account_id, char* name)
{
        struct party_data *p;
        int i;

        p = party_search(sd->status.party_id);
        if( p == NULL )
                return 0;

        // check the requesting char's party membership
        ARR_FIND( 0, MAX_PARTY, i, p->party.member[i].account_id == sd->status.account_id && p->party.member[i].char_id == sd->status.char_id );
        if( i == MAX_PARTY )
                return 0; // request from someone not in party? o.O
        if( !p->party.member[i].leader )
                return 0; // only party leader may remove members

        ARR_FIND( 0, MAX_PARTY, i, p->party.member[i].account_id == account_id && strncmp(p->party.member[i].name,name,NAME_LENGTH) == 0 );
        if( i == MAX_PARTY )
                return 0; // no such char in party

        intif_party_leave(p->party.party_id,account_id,p->party.member[i].char_id);
        return 1;
}

/// Party member 'sd' requesting exit from party.
int party_leave(struct map_session_data *sd)
{
        struct party_data *p;
        int i;

        p = party_search(sd->status.party_id);
        if( p == NULL )
                return 0;

        ARR_FIND( 0, MAX_PARTY, i, p->party.member[i].account_id == sd->status.account_id && p->party.member[i].char_id == sd->status.char_id );
        if( i == MAX_PARTY )
                return 0;

        intif_party_leave(p->party.party_id,sd->status.account_id,sd->status.char_id);
        return 1;
}

/// Invoked (from char-server) when a party member leaves the party.
int party_member_leaved(int party_id, int account_id, int char_id)
{
        struct map_session_data* sd = map_id2sd(account_id);
        struct party_data* p = party_search(party_id);
        int i;

        if( p )
        {
                ARR_FIND( 0, MAX_PARTY, i, p->party.member[i].account_id == account_id && p->party.member[i].char_id == char_id );
                if( i < MAX_PARTY )
                {
                        clif_party_leaved(p,sd,account_id,p->party.member[i].name,0x00);
                        memset(&p->party.member[i], 0, sizeof(p->party.member[0]));
                        memset(&p->data[i], 0, sizeof(p->data[0]));
                        p->party.count--;
                        party_check_state(p);
                }
        }

        if( sd && sd->status.party_id == party_id && sd->status.char_id == char_id )
        {
                sd->status.party_id = 0;
                clif_charnameupdate(sd); //Update name display [Skotlex]
                //TODO: hp bars should be cleared too
        }
        return 0;
}

/// Invoked (from char-server) when a party is disbanded.
int party_broken(int party_id)
{
        struct party_data* p;
        int i;

        p = party_search(party_id);
        if( p == NULL )
                return 0;

        for(i=0;i<MAX_PARTY;i++){
                if(p->data[i].sd!=NULL){
                        clif_party_leaved(p,p->data[i].sd,p->party.member[i].account_id,p->party.member[i].name,0x10);
                        p->data[i].sd->status.party_id=0;
                }
        }
        idb_remove(party_db,party_id);
        return 0;
}

int party_changeoption(struct map_session_data *sd,int exp,int item)
{
        nullpo_retr(0, sd);

        if( sd->status.party_id==0)
                return 0;
        intif_party_changeoption(sd->status.party_id,sd->status.account_id,exp,item);
        return 0;
}

int party_optionchanged(int party_id,int account_id,int exp,int item,int flag)
{
        struct party_data *p;
        struct map_session_data *sd=map_id2sd(account_id);
        if( (p=party_search(party_id))==NULL)
                return 0;

        if(!(flag&0x01) && p->party.exp != exp) {
                p->party.exp=exp;
                clif_party_option(p,sd,flag); //This packet doesn't updates item info anymore...
        }
        if(!(flag&0x10) && p->party.item != item) {
                p->party.item=item;
                clif_party_member_info(p,sd);
        }
        if(flag&0x01) //Send denied message
                clif_party_option(p,sd,flag);
        return 0;
}

/// Invoked (from char-server) when a party member
/// - changes maps
/// - logs in or out
/// - gains a level (disabled)
int party_recv_movemap(int party_id,int account_id,int char_id, unsigned short map,int online,int lv)
{
        struct party_member* m;
        struct party_data* p;
        int i;

        p = party_search(party_id);
        if( p == NULL )
                return 0;

        ARR_FIND( 0, MAX_PARTY, i, p->party.member[i].account_id == account_id && p->party.member[i].char_id == char_id );
        if( i == MAX_PARTY )
        {
                ShowError("party_recv_movemap: char %d/%d not found in party %s (id:%d)",account_id,char_id,p->party.name,party_id);
                return 0;
        }

        m = &p->party.member[i];
        m->map = map;
        m->online = online;
        m->lv = lv;
        //Check if they still exist on this map server
        p->data[i].sd = party_sd_check(party_id, account_id, char_id);
        
        clif_party_info(p,NULL);
        return 0;
}

void party_send_movemap(struct map_session_data *sd)
{
        int i;
        struct party_data *p;

        if( sd->status.party_id==0 )
                return;

        intif_party_changemap(sd,1);

        p=party_search(sd->status.party_id);
        if (!p) return;

        if(sd->state.connect_new) {
                //Note that this works because this function is invoked before connect_new is cleared.
                clif_party_option(p,sd,0x100);
                clif_party_info(p,sd);
                clif_party_member_info(p,sd);
        }

        if (sd->fd) { // synchronize minimap positions with the rest of the party
                for(i=0; i < MAX_PARTY; i++) {
                        if (p->data[i].sd && 
                                p->data[i].sd != sd &&
                                p->data[i].sd->bl.m == sd->bl.m)
                        {
                                clif_party_xy_single(sd->fd, p->data[i].sd);
                                clif_party_xy_single(p->data[i].sd->fd, sd);
                        }
                }
        }
        return;
}

void party_send_levelup(struct map_session_data *sd)
{
        intif_party_changemap(sd,1);
}

int party_send_logout(struct map_session_data *sd)
{
        struct party_data *p;
        int i;

        if(!sd->status.party_id)
                return 0;
        
        intif_party_changemap(sd,0);
        p=party_search(sd->status.party_id);
        if(!p) return 0;

        ARR_FIND( 0, MAX_PARTY, i, p->data[i].sd == sd );
        if( i < MAX_PARTY )
                memset(&p->data[i], 0, sizeof(p->data[0]));
        else
                ShowError("party_send_logout: Failed to locate member %d:%d in party %d!\n", sd->status.account_id, sd->status.char_id, p->party.party_id);
        
        return 1;
}

int party_send_message(struct map_session_data *sd,const char *mes,int len)
{
        if(sd->status.party_id==0)
                return 0;
        intif_party_message(sd->status.party_id,sd->status.account_id,mes,len);
        party_recv_message(sd->status.party_id,sd->status.account_id,mes,len);

        // Chat logging type 'P' / Party Chat
        if( log_config.chat&1 || (log_config.chat&8 && !(agit_flag && log_config.chat&64)) )
                log_chat("P", sd->status.party_id, sd->status.char_id, sd->status.account_id, mapindex_id2name(sd->mapindex), sd->bl.x, sd->bl.y, NULL, mes);

        return 0;
}

int party_recv_message(int party_id,int account_id,const char *mes,int len)
{
        struct party_data *p;
        if( (p=party_search(party_id))==NULL)
                return 0;
        clif_party_message(p,account_id,mes,len);
        return 0;
}

int party_check_conflict(struct map_session_data *sd)
{
        nullpo_retr(0, sd);

        intif_party_checkconflict(sd->status.party_id,sd->status.account_id,sd->status.char_id);
        return 0;
}

int party_skill_check(struct map_session_data *sd, int party_id, int skillid, int skilllv)
{
        struct party_data *p;
        struct map_session_data *p_sd;
        int i;

        if(!party_id || (p=party_search(party_id))==NULL)
                return 0;
        switch(skillid) {
                case TK_COUNTER: //Increase Triple Attack rate of Monks.
                        if (!p->state.monk) return 0;
                        break;
                case MO_COMBOFINISH: //Increase Counter rate of Star Gladiators
                        if (!p->state.sg) return 0;
                        break;
                case AM_TWILIGHT2: //Twilight Pharmacy, requires Super Novice
                        return p->state.snovice;
                case AM_TWILIGHT3: //Twilight Pharmacy, Requires Taekwon
                        return p->state.tk;
                default:
                        return 0; //Unknown case?
        }
        
        for(i=0;i<MAX_PARTY;i++){
                if ((p_sd = p->data[i].sd) == NULL)
                        continue;
                if (sd->bl.m != p_sd->bl.m)
                        continue;
                switch(skillid) {
                        case TK_COUNTER: //Increase Triple Attack rate of Monks.
                                if((p_sd->class_&MAPID_UPPERMASK) == MAPID_MONK
                                        && pc_checkskill(p_sd,MO_TRIPLEATTACK)) {
                                        sc_start4(&p_sd->bl,SC_SKILLRATE_UP,100,MO_TRIPLEATTACK,
                                                50+50*skilllv, //+100/150/200% rate
                                                0,0,skill_get_time(SG_FRIEND, 1));
                                }
                                break;
                        case MO_COMBOFINISH: //Increase Counter rate of Star Gladiators
                                if((p_sd->class_&MAPID_UPPERMASK) == MAPID_STAR_GLADIATOR
                                        && sd->sc.data[SC_READYCOUNTER]
                                        && pc_checkskill(p_sd,SG_FRIEND)) {
                                        sc_start4(&p_sd->bl,SC_SKILLRATE_UP,100,TK_COUNTER,
                                                50+50*pc_checkskill(p_sd,SG_FRIEND), //+100/150/200% rate
                                                0,0,skill_get_time(SG_FRIEND, 1));
                                }
                                break;
                }
        }
        return 0;
}

int party_send_xy_timer(int tid, unsigned int tick, int id, intptr data)
{
        struct party_data* p;

        DBIterator* iter = party_db->iterator(party_db);
        // for each existing party,
        for( p = (struct party_data*)iter->first(iter,NULL); iter->exists(iter); p = (struct party_data*)iter->next(iter,NULL) )
        {
                int i;
                // for each member of this party,
                for( i = 0; i < MAX_PARTY; i++ )
                {
                        struct map_session_data* sd = p->data[i].sd;
                        if( !sd ) continue;

                        if( p->data[i].x != sd->bl.x || p->data[i].y != sd->bl.y )
                        {// perform position update
                                clif_party_xy(sd);
                                p->data[i].x = sd->bl.x;
                                p->data[i].y = sd->bl.y;
                        }
                        if (battle_config.party_hp_mode && p->data[i].hp != sd->battle_status.hp)
                        {// perform hp update
                                clif_party_hp(sd);
                                p->data[i].hp = sd->battle_status.hp;
                        }
                }
        }
        iter->destroy(iter);

        return 0;
}

int party_send_xy_clear(struct party_data *p)
{
        int i;

        nullpo_retr(0, p);

        for(i=0;i<MAX_PARTY;i++){
                if(!p->data[i].sd) continue;
                p->data[i].hp = 0;
                p->data[i].x = 0;
                p->data[i].y = 0;
        }
        return 0;
}

// exp share and added zeny share [Valaris]
int party_exp_share(struct party_data* p, struct block_list* src, unsigned int base_exp, unsigned int job_exp, int zeny)
{
        struct map_session_data* sd[MAX_PARTY];
        unsigned int i, c;

        nullpo_retr(0, p);

        // count the number of players eligible for exp sharing
        for (i = c = 0; i < MAX_PARTY; i++) {
                if( (sd[c] = p->data[i].sd) == NULL || sd[c]->bl.m != src->m || pc_isdead(sd[c]) || (battle_config.idle_no_share && pc_isidle(sd[c])) )
                        continue;
                c++;
        }
        if (c < 1)
                return 0;

        base_exp/=c;    
        job_exp/=c;
        zeny/=c;

        if (battle_config.party_even_share_bonus && c > 1)
        {
                double bonus = 100 + battle_config.party_even_share_bonus*(c-1);
                if (base_exp)
                        base_exp = (unsigned int) cap_value(base_exp * bonus/100, 0, UINT_MAX);
                if (job_exp)
                        job_exp = (unsigned int) cap_value(job_exp * bonus/100, 0, UINT_MAX);
                if (zeny)
                        zeny = (unsigned int) cap_value(zeny * bonus/100, INT_MIN, INT_MAX);
        }

        for (i = 0; i < c; i++)
        {
                pc_gainexp(sd[i], src, base_exp, job_exp);
                if (zeny) // zeny from mobs [Valaris]
                        pc_getzeny(sd[i],zeny);
        }
        return 0;
}

//Does party loot. first_charid holds the charid of the player who has time priority to take the item.
int party_share_loot(struct party_data* p, struct map_session_data* sd, struct item* item_data, int first_charid)
{
        TBL_PC* target = NULL;
        int i;
        if (p && p->party.item&2 && (first_charid || !(battle_config.party_share_type&1)))
        {
                //item distribution to party members.
                if (battle_config.party_share_type&2)
                {       //Round Robin
                        TBL_PC* psd;
                        i = p->itemc;
                        do {
                                i++;
                                if (i >= MAX_PARTY)
                                        i = 0;  // reset counter to 1st person in party so it'll stop when it reaches "itemc"

                                if( (psd = p->data[i].sd) == NULL || sd->bl.m != psd->bl.m || pc_isdead(psd) || (battle_config.idle_no_share && pc_isidle(psd)) )
                                        continue;
                                
                                if (pc_additem(psd,item_data,item_data->amount))
                                        continue; //Chosen char can't pick up loot.

                                //Successful pick.
                                p->itemc = i;
                                target = psd;
                                break;
                        } while (i != p->itemc);
                }
                else
                {       //Random pick
                        TBL_PC* psd[MAX_PARTY];
                        int count = 0;
                        //Collect pick candidates
                        for (i = 0; i < MAX_PARTY; i++) {
                                if( (psd[count] = p->data[i].sd) == NULL || psd[count]->bl.m != sd->bl.m || pc_isdead(psd[count]) || (battle_config.idle_no_share && pc_isidle(psd[count])) )
                                        continue;

                                count++;
                        }
                        while (count > 0) { //Pick a random member.
                                i = rand()%count;
                                if (pc_additem(psd[i],item_data,item_data->amount))
                                {       //Discard this receiver.
                                        psd[i] = psd[count-1];
                                        count--;
                                } else { //Successful pick.
                                        target = psd[i];
                                        break;
                                }
                        }
                }
        }

        if (!target) { 
                target = sd; //Give it to the char that picked it up
                if ((i=pc_additem(sd,item_data,item_data->amount)))
                        return i;
        }

        if(log_config.enable_logs&0x8) //Logs items, taken by (P)layers [Lupus]
                log_pick_pc(target, "P", item_data->nameid, item_data->amount, item_data);
        
        if(battle_config.party_show_share_picker && target != sd) {
                char output[80];
                sprintf(output, "%s acquired %s.",target->status.name, itemdb_jname(item_data->nameid));
                clif_disp_onlyself(sd,output,strlen(output));
        }
        return 0;
}

int party_send_dot_remove(struct map_session_data *sd)
{
        if (sd->status.party_id)
                clif_party_xy_remove(sd);
        return 0;
}

// To use for Taekwon's "Fighting Chant"
// int c = 0;
// party_foreachsamemap(party_sub_count, sd, 0, &c);
int party_sub_count(struct block_list *bl, va_list ap)
{
        struct map_session_data *sd = (TBL_PC *)bl;

        if (sd->state.autotrade)
                return 0;
        
        if (battle_config.idle_no_share && pc_isidle(sd))
                return 0;

        return 1;
}

/// Executes 'func' for each party member on the same map and in range (0:whole map)
int party_foreachsamemap(int (*func)(struct block_list*,va_list),struct map_session_data *sd,int range,...)
{
        struct party_data *p;
        va_list ap;
        int i;
        int x0,y0,x1,y1;
        struct block_list *list[MAX_PARTY];
        int blockcount=0;
        int total = 0; //Return value.
        
        nullpo_retr(0,sd);
        
        if((p=party_search(sd->status.party_id))==NULL)
                return 0;

        x0=sd->bl.x-range;
        y0=sd->bl.y-range;
        x1=sd->bl.x+range;
        y1=sd->bl.y+range;

        va_start(ap,range);
        
        for(i=0;i<MAX_PARTY;i++)
        {
                struct map_session_data *psd = p->data[i].sd;
                if(!psd) continue;
                if(psd->bl.m!=sd->bl.m || !psd->bl.prev)
                        continue;
                if(range &&
                        (psd->bl.x<x0 || psd->bl.y<y0 ||
                         psd->bl.x>x1 || psd->bl.y>y1 ) )
                        continue;
                list[blockcount++]=&psd->bl; 
        }

        map_freeblock_lock();
        
        for(i=0;i<blockcount;i++)
                total += func(list[i],ap);

        map_freeblock_unlock();

        va_end(ap);
        return total;
}