mxoemu/Reality/Source/SequencedPacket.cpp

// ***************************************************************************
//
// Reality - The Matrix Online Server Emulator
// Copyright (C) 2006-2010 Rajko Stojadinovic
// http://mxoemu.info
//
// ---------------------------------------------------------------------------
//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU Affero 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 Affero General Public License for more details.
//
// You should have received a copy of the GNU Affero General Public License
// along with this program.  If not, see <http://www.gnu.org/licenses/>.
//
// ---------------------------------------------------------------------------
//
// ***************************************************************************

#include "SequencedPacket.h"

void SequencedPacket::Construct(ByteBuffer withHeader)
{
	uint32 packedSeqs; //FL CC CS SS

	withHeader.rpos(0);
	withHeader >> packedSeqs;

	uint32 packed = swap32(packedSeqs);
	localSeq = packed&0xFFF;
	remoteSeq = (packed>>12)&0xFFF;
	ackBits = (packed>>24)&0xFF;

	vector<byte> restOfPacket;
	restOfPacket.resize(withHeader.size() - withHeader.rpos());
	withHeader.read(&restOfPacket[0],restOfPacket.size());

	this->clear();
	this->append(&restOfPacket[0],restOfPacket.size());
}

SequencedPacket::SequencedPacket( ByteBuffer withHeader )
{
	Construct(withHeader);
}

SequencedPacket::SequencedPacket( const string &withHeader )
{
	ByteBuffer simulation;
	simulation.append((const byte*)withHeader.data(),withHeader.size());

	Construct(simulation);
}

ByteBuffer SequencedPacket::getDataWithHeader() const
{
	uint32 packedSeqs = swap32((ackBits << 24) | ((remoteSeq & 0xFFF) << 12) | (localSeq & 0xFFF)); // FL CC CS SS

	ByteBuffer returnMe;
	returnMe << packedSeqs;
	returnMe.append(this->contents(),this->count());

	return returnMe;
}