root/src/map/vending.c

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

#include "../common/nullpo.h"
#include "../common/strlib.h"
#include "../common/utils.h"
#include "clif.h"
#include "itemdb.h"
#include "atcommand.h"
#include "map.h"
#include "path.h"
#include "chrif.h"
#include "vending.h"
#include "pc.h"
#include "skill.h"
#include "battle.h"
#include "log.h"

#include "irc.h"

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


/*==========================================
 * Close shop
 *------------------------------------------*/
void vending_closevending(struct map_session_data* sd)
{
        nullpo_retv(sd);

        sd->vender_id = 0;
        clif_closevendingboard(&sd->bl,0);

        if( use_irc && irc_announce_shop_flag )
                irc_announce_shop(sd,0);
}

/*==========================================
 * Request a shop's item list
 *------------------------------------------*/
void vending_vendinglistreq(struct map_session_data* sd, int id)
{
        struct map_session_data* vsd;
        nullpo_retv(sd);

        if( (vsd = map_id2sd(id)) == NULL )
                return;
        if( vsd->vender_id == 0 )
                return; // not vending

        if ( !pc_can_give_items(pc_isGM(sd)) || !pc_can_give_items(pc_isGM(vsd)) ) //check if both GMs are allowed to trade
        {       // GM is not allowed to trade
                clif_displaymessage(sd->fd, msg_txt(246));
                return;
        } 

        clif_vendinglist(sd, id, vsd->vending);
}

/*==========================================
 * Purchase item(s) from a shop
 *------------------------------------------*/
void vending_purchasereq(struct map_session_data* sd, int id, const uint8* data, int count)
{
        int i, j, cursor, w, new_ = 0, blank, vend_list[MAX_VENDING];
        double z;
        struct s_vending vending[MAX_VENDING]; // against duplicate packets
        struct map_session_data* vsd = map_id2sd(id);

        nullpo_retv(sd);

        if( vsd == NULL || vsd->vender_id == 0 || vsd->vender_id == sd->bl.id )
                return; // invalid shop
        if( sd->bl.m != vsd->bl.m || !check_distance_bl(&sd->bl, &vsd->bl, AREA_SIZE) )
                return; // shop too far away
        if( count < 1 || count > MAX_VENDING || count > vsd->vend_num )
                return; // invalid amount of purchased items

        blank = pc_inventoryblank(sd); //number of free cells in the buyer's inventory

        // duplicate item in vending to check hacker with multiple packets
        memcpy(&vending, &vsd->vending, sizeof(vsd->vending)); // copy vending list

        // some checks
        z = 0.; // zeny counter
        w = 0;  // weight counter
        for( i = 0; i < count; i++ )
        {
                short amount = *(uint16*)(data + 4*i + 0);
                short idx    = *(uint16*)(data + 4*i + 2);
                idx -= 2;

                if( amount <= 0 )
                        return;

                // check of item index in the cart
                if( idx < 0 || idx >= MAX_CART )
                        return;

                ARR_FIND( 0, vsd->vend_num, j, vsd->vending[j].index == idx );
                if( j == vsd->vend_num )
                        return; //picked non-existing item
                else
                        vend_list[i] = j;

                z += ((double)vsd->vending[j].value * (double)amount);
                if( z > (double)sd->status.zeny || z < 0. || z > (double)MAX_ZENY )
                {
                        clif_buyvending(sd, idx, amount, 1); // you don't have enough zeny
                        return;
                }
                if( z + (double)vsd->status.zeny > (double)MAX_ZENY && !battle_config.vending_over_max )
                {
                        clif_buyvending(sd, idx, vsd->vending[j].amount, 4); // too much zeny = overflow
                        return;

                }
                w += itemdb_weight(vsd->status.cart[idx].nameid) * amount;
                if( w + sd->weight > sd->max_weight )
                {
                        clif_buyvending(sd, idx, amount, 2); // you can not buy, because overweight
                        return;
                }
                
                //Check to see if cart/vend info is in sync.
                if( vending[j].amount > vsd->status.cart[idx].amount )
                        vending[j].amount = vsd->status.cart[idx].amount;
                
                // if they try to add packets (example: get twice or more 2 apples if marchand has only 3 apples).
                // here, we check cumulative amounts
                if( vending[j].amount < amount )
                {
                        // send more quantity is not a hack (an other player can have buy items just before)
                        clif_buyvending(sd, idx, vsd->vending[j].amount, 4); // not enough quantity
                        return;
                }
                
                vending[j].amount -= amount;

                switch( pc_checkadditem(sd, vsd->status.cart[idx].nameid, amount) ) {
                case ADDITEM_EXIST:
                        break;  //We'd add this item to the existing one (in buyers inventory)
                case ADDITEM_NEW:
                        new_++;
                        if (new_ > blank)
                                return; //Buyer has no space in his inventory
                        break;
                case ADDITEM_OVERAMOUNT:
                        return; //too many items
                }
        }

        //Logs (V)ending Zeny [Lupus]
        if( log_config.zeny > 0 )
                log_zeny(vsd, "V", sd, (int)z);

        pc_payzeny(sd, (int)z);
        if( battle_config.vending_tax )
                z -= z * (battle_config.vending_tax/10000.);
        pc_getzeny(vsd, (int)z);

        for( i = 0; i < count; i++ )
        {
                short amount = *(uint16*)(data + 4*i + 0);
                short idx    = *(uint16*)(data + 4*i + 2);
                idx -= 2;

                //Logs sold (V)ending items [Lupus]
                if(log_config.enable_logs&0x4) {
                        log_pick_pc(vsd, "V", vsd->status.cart[idx].nameid, -amount, &vsd->status.cart[idx]);
                        log_pick_pc( sd, "V", vsd->status.cart[idx].nameid,  amount, &vsd->status.cart[idx]);
                }

                // vending item
                pc_additem(sd, &vsd->status.cart[idx], amount);
                vsd->vending[vend_list[i]].amount -= amount;
                pc_cart_delitem(vsd, idx, amount, 0);
                clif_vendingreport(vsd, idx, amount);

                //print buyer's name
                if( battle_config.buyer_name )
                {
                        char temp[256];
                        sprintf(temp, msg_txt(265), sd->status.name);
                        clif_disp_onlyself(vsd,temp,strlen(temp));
                }
        }

        // compact the vending list
        for( i = 0, cursor = 0; i < vsd->vend_num; i++ )
        {
                if( vsd->vending[i].amount == 0 )
                        continue;
                
                if( cursor != i ) // speedup
                {
                        vsd->vending[cursor].index = vsd->vending[i].index;
                        vsd->vending[cursor].amount = vsd->vending[i].amount;
                        vsd->vending[cursor].value = vsd->vending[i].value;
                }

                cursor++;
        }
        vsd->vend_num = cursor;

        //Always save BOTH: buyer and customer
        if( save_settings&2 )
        {
                chrif_save(sd,0);
                chrif_save(vsd,0);
        }

        //check for @AUTOTRADE users [durf]
        if( vsd->state.autotrade )
        {
                //see if there is anything left in the shop
                ARR_FIND( 0, vsd->vend_num, i, vsd->vending[i].amount > 0 );
                if( i == vsd->vend_num )
                {
                        //Close Vending (this was automatically done by the client, we have to do it manually for autovenders) [Skotlex]
                        vending_closevending(vsd);
                        map_quit(vsd);  //They have no reason to stay around anymore, do they?
                }
        }
}

/*==========================================
 * Open shop
 * data := {<index>.w <amount>.w <value>.l}[count]
 *------------------------------------------*/
void vending_openvending(struct map_session_data* sd, const char* message, bool flag, const uint8* data, int count)
{
        int i, j;
        int vending_skill_lvl;
        nullpo_retv(sd);

        if( !flag ) // cancelled
                return; // nothing to do

        if (pc_istrading(sd))
                return; // can't have 2 shops at once

        vending_skill_lvl = pc_checkskill(sd, MC_VENDING);
        // skill level and cart check
        if( !vending_skill_lvl || !pc_iscarton(sd) )
        {
                clif_skill_fail(sd, MC_VENDING, 0, 0);
                return;
        }

        // check number of items in shop
        if( count < 1 || count > MAX_VENDING || count > 2 + vending_skill_lvl )
        {       // invalid item count
                clif_skill_fail(sd, MC_VENDING, 0, 0);
                return;
        }

        // filter out invalid items
        i = 0;
        for( j = 0; j < count; j++ )
        {
                short index        = *(uint16*)(data + 8*j + 0);
                short amount       = *(uint16*)(data + 8*j + 2);
                unsigned int value = *(uint32*)(data + 8*j + 4);

                index -= 2; // offset adjustment (client says that the first cart position is 2)

                if( index < 0 || index >= MAX_CART // invalid position
                ||  pc_cartitem_amount(sd, index, amount) < 0 // invalid item or insufficient quantity
                //NOTE: official server does not do any of the following checks!
                ||  !sd->status.cart[index].identify // unidentified item
                ||  sd->status.cart[index].attribute == 1 // broken item
                ||  !itemdb_cantrade(&sd->status.cart[index], pc_isGM(sd), pc_isGM(sd)) ) // untradeable item
                        continue;

                sd->vending[i].index = index;
                sd->vending[i].amount = amount;
                sd->vending[i].value = cap_value(value, 1, (unsigned int)battle_config.vending_max_value);

                i++; // item successfully added
        }

        if( i != j )
                clif_displaymessage (sd->fd, msg_txt(266)); //"Some of your items cannot be vended and were removed from the shop."

        if( i == 0 )
        {       // no valid item found
                clif_skill_fail(sd, MC_VENDING, 0, 0); // custom reply packet
                return;
        }

        sd->vender_id = sd->bl.id;
        sd->vend_num = i;
        safestrncpy(sd->message, message, MESSAGE_SIZE);

        pc_stop_walking(sd,1);
        clif_openvending(sd,sd->vender_id,sd->vending);
        clif_showvendingboard(&sd->bl,message,0);

        if( use_irc && irc_announce_shop_flag )
                irc_announce_shop(sd,1);
}