Skip to content

Push msgpack implementation out of PHP userland #8

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 1 commit into from
Closed

Push msgpack implementation out of PHP userland #8

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
127 changes: 1 addition & 126 deletions Core/Sockets/MsgPack.php
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -11,135 +11,10 @@ class MsgPack

public function __construct($bigendian = null)
{
$this->bigendian = $bigendian !== null ? $bigendian : (pack('S', 1) == pack('n', 1));
}

public function pack($input)
{
// null
if (is_null($input)) {
return pack('C', 0xC0);
}

// booleans
if (is_bool($input)) {
return pack('C', $input ? 0xC3 : 0xC2);
}

// Integers
if (is_int($input)) {
// positive fixnum
if (($input | 0x7F) == 0x7F) {
return pack('C', $input & 0x7F);
}

// negative fixnum
if ($input < 0 && $input >= -32) {
return pack('c', $input);
}

// uint8
if ($input > 0 && $input <= 0xFF) {
return pack('CC', 0xCC, $input);
}

// uint16
if ($input > 0 && $input <= 0xFFFF) {
return pack('Cn', 0xCD, $input);
}

// uint32
if ($input > 0 && $input <= 0xFFFFFFFF) {
return pack('CN', 0xCE, $input);
}

// uint64
if ($input > 0 && $input <= 0xFFFFFFFFFFFFFFFF) {
// pack() does not support 64-bit ints, so pack into two 32-bits
$h = ($input & 0xFFFFFFFF00000000) >> 32;
$l = $input & 0xFFFFFFFF;
return $this->bigendian ? pack('CNN', 0xCF, $l, $h) : pack('CNN', 0xCF, $h, $l);
}
// int8
if ($input < 0 && $input >= -0x80) {
return pack('Cc', 0xD0, $input);
}
// int16
if ($input < 0 && $input >= -0x8000) {
$p = pack('s', $input);
return pack('Ca2', 0xD1, $this->bigendian ? $p : strrev($p));
}
// int32
if ($input < 0 && $input >= -0x80000000) {
$p = pack('l', $input);
return pack('Ca4', 0xD2, $this->bigendian ? $p : strrev($p));
}
// int64
if ($input < 0 && $input >= -0x8000000000000000) {
// pack() does not support 64-bit ints either so pack into two 32-bits
$p1 = pack('l', $input & 0xFFFFFFFF);
$p2 = pack('l', ($input >> 32) & 0xFFFFFFFF);
return $this->bigendian ? pack('Ca4a4', 0xD3, $p1, $p2) : pack('Ca4a4', 0xD3, strrev($p2), strrev($p1));
}

throw new \InvalidArgumentException('Invalid integer: ' . $input);
}

// Floats
if (is_float($input)) {
// Just pack into a double, don't take any chances with single precision
return pack('C', 0xCB) . ($this->bigendian ? pack('d', $input) : strrev(pack('d', $input)));
}

// Strings/Raw
if (is_string($input)) {
$len = strlen($input);
if ($len < 32) {
return pack('Ca*', 0xA0 | $len, $input);
} elseif ($len <= 0xFFFF) {
return pack('Cna*', 0xDA, $len, $input);
} elseif ($len <= 0xFFFFFFFF) {
return pack('CNa*', 0xDB, $len, $input);
} else {
throw new \InvalidArgumentException('Input overflows (2^32)-1 byte max');
}
}

// Arrays & Maps
if (is_array($input)) {
$keys = array_keys($input);
$len = count($input);

// Is this an associative array?
$isMap = false;
foreach ($keys as $key) {
if (!is_int($key)) {
$isMap = true;
break;
}
}

$buf = '';
if ($len < 16) {
$buf .= pack('C', ($isMap ? 0x80 : 0x90) | $len);
} elseif ($len <= 0xFFFF) {
$buf .= pack('Cn', ($isMap ? 0xDE : 0xDC), $len);
} elseif ($len <= 0xFFFFFFFF) {
$buf .= pack('CN', ($isMap ? 0xDF : 0xDD), $len);
} else {
throw new \InvalidArgumentException('Input overflows (2^32)-1 max elements');
}

foreach ($input as $key => $elm) {
if ($isMap) {
$buf .= $this->pack($key);
}

$buf .= $this->pack($elm);
}
return $buf;
}

throw new \InvalidArgumentException('Not able to pack/serialize input type: ' . gettype($input));
return msgpack_pack($input);
}
}