source: Daodan/src/flatline/Flatline_PacketBuilder.c@ 888

#include "Flatline.h"
#include "../Oni_Symbols.h"
#include <assert.h>
#include "Flatline_Packet.h"

#define FLAG_AND_INCREMENT( FLAG )      PD->UpdateFlags |= (1 << FLAG ); DataPointer += FLpData_PartSize( FLAG );

void FLsPacketBuild( uint8_t p, PlayerData* PD, bool UpdateAll )
{
        Character* Player = PlayerList[p]->Chr;
        ActiveCharacter* APlayer = ONrGetActiveCharacter(Player);
        player_info * PI = PlayerList[p];
        uint8_t * DataPointer = PD->data;
        PD->ID = p;
        
        //if ( data has changed )
        //{
        //      copy it to the buffer
        //  copy it to the player info
        //  set the changed flag
        //  increment the buffer pointer
        //}

        /* 
        //Could probably send this every frame, but afk players can save a few bytes, eh?
        if( PI->Input.Actions1 != PI->InputFromClient.Actions1 ||
                PI->Input.Actions2 != PI->InputFromClient.Actions2 ||
                PI->Input.MouseDeltaX != PI->InputFromClient.MouseDeltaX ||
                PI->Input.MouseDeltaY != PI->InputFromClient.MouseDeltaY )
        {*/

        //Better in case of dropped packets to send input every frame
        if(1)
        {
                memcpy( DataPointer, &PI->InputFromClient, sizeof(PlayerInput));
                PI->Input = PI->InputFromClient;

                FLAG_AND_INCREMENT( PFlag_Input );
        }

        if( PI->Facings.Facing != Player->Facing ||
                PI->Facings.DesiredFacing != Player->DesiredFacing || UpdateAll )
        {
                PlayerFacing* ptr = (void*)DataPointer;
                ptr->Facing = Player->Facing;
                ptr->DesiredFacing = Player->DesiredFacing;

                PI->Facings = *ptr;

                FLAG_AND_INCREMENT( PFlag_Facing );
        }

        if(PI->Health.Health != Player->Health ||
                PI->Health.MaxHealth != Player->MaxHealth || UpdateAll )
        {
                PlayerHealth* ptr = (void*)DataPointer;
                ptr->Health = Player->Health;
                ptr->MaxHealth = Player->MaxHealth;

                PI->Health = *ptr;

                FLAG_AND_INCREMENT( PFlag_Health );
        }

        //Score
        //skipping for now

        //Frame and ping can be sent every frame, i guess. Improve this later,
        if( 1 )
        {
                PlayerFP* ptr = (void*)DataPointer;
                if(APlayer)
                {
                        ptr->Frame = APlayer->Frame;
                }
                else
                {
                        ptr->Frame = -1;
                }
                ptr->Ping = PI->Ping;

                PI->Frame = ptr->Frame;

                FLAG_AND_INCREMENT( PFlag_FramePing );
        }
        
        //Skipping inventory because we dont need it right now
        if( 0 )
        {
                //Do inventory
        }

        if( PI->Class != Player->ONCC || UpdateAll )
        {
                snprintf( DataPointer, 32, "%s", TMrInstance_GetInstanceName( Player->ONCC ) );
                snprintf( PI->ClassString, 32, "%s", DataPointer );
                PI->Class = Player->ONCC;

                FLAG_AND_INCREMENT( PFlag_Class );
        }

        if(APlayer)
        {
                if( (APlayer->PhyContext) && (memcmp(&PI->Position, &APlayer->PhyContext->Position, sizeof(Vector3)) || UpdateAll ))
                {
                        Vector3* ptr = (Vector3*)DataPointer;
                        *ptr = PI->Position = APlayer->PhyContext->Position;
                
                        FLAG_AND_INCREMENT( PFlag_Position );
                }

                if(APlayer->Animation != PI->Animation || !APlayer->Frame || UpdateAll )
                {
                        snprintf( DataPointer, 32, "%s", TMrInstance_GetInstanceName( APlayer->Animation ) );
                        snprintf( PI->AnimationString, 32, "%s", DataPointer );
                        PI->Animation = APlayer->Animation;

                        
                        FLAG_AND_INCREMENT( PFlag_Animation );
                }

                if(APlayer->targetThrow)
                {
                        if(!PI->HasAppliedThrow || UpdateAll )
                        {
                                PlayerThrowData* ptr = (void*)DataPointer;
                                ptr->throwing = Players[APlayer->throwing].list_slot;
                                memcpy(ptr->throwName, TMrInstance_GetInstanceName(APlayer->targetThrow), 31);
                                ptr->throwFrame = ONrGetActiveCharacter(APlayer->targetThrow)->Frame;

                                PI->ThrowData = *ptr;

                                PI->HasAppliedThrow = 1;

                                FLAG_AND_INCREMENT( PFlag_Throws );
                        }
                }
                else
                {
                        PI->HasAppliedThrow = 0;
                }
        }
        
        PD->Size = (uint32_t)DataPointer - (uint32_t)PD;

        PI->UpdateFlags = PD->UpdateFlags;      
        
}



void FLsSendPlayerData()
{
        PlayerData BuildData[32] = {0};
        uint8_t p = 0;
        uint32_t PacketSize = 0;
        flatline_packet OutputPacket = {0};
        uint8_t* OutputPointer = OutputPacket.data;
        //Most of the time we won't even hit this. Could probably be bumped up a few hundred bytes
        const uint32_t max_packet_size = 1000;

        //Prepare buffers
        OutputPacket.id = PK_PLAYER_DATA;
        memset( BuildData, 0, sizeof(PlayerData) * 32 );

        //Build data
        for(p = 0; p < MAX_PLAYERS; p++)
        {
                if(PlayerList[p] && PlayerList[p]->Chr)
                {
                        FLsPacketBuild(p, &BuildData[p], 0);
                        
                        assert( BuildData[p].Size < 255 );
                        
                        if( BuildData[p].Size > 0 )
                        {

                                //If we hit maximum size, send the packet and reset the buffer for a new one
                                if( BuildData[p].Size + PacketSize > max_packet_size )
                                {
                                        UDPServer_SendToAll(&OutputPacket, PacketSize + FLATLINE_HEADER);

                                        memset( OutputPacket.data, 0, PacketSize );
                                        OutputPointer = OutputPacket.data;
                                        PacketSize = 0;
                                }

                                //add to the packet
                                memcpy( OutputPointer, &BuildData[p], BuildData[p].Size );

                                OutputPointer += BuildData[p].Size;
                                PacketSize += BuildData[p].Size;
                        }
                }
        }
        //Send data
        if( PacketSize > 0 )
        {
                UDPServer_SendToAll(&OutputPacket, PacketSize + FLATLINE_HEADER);
        }
}