ref: 5ec6b8b626f241c6a4b55f98f0f06c45d1d12e8c
converter/server/vendor/rybakit/msgpack/examples/MessagePack/PackedMapTransformer.php
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 |
<?php /* * This file is part of the rybakit/msgpack.php package. * * (c) Eugene Leonovich <gen.work@gmail.com> * * For the full copyright and license information, please view the LICENSE * file that was distributed with this source code. */ namespace App\MessagePack; use MessagePack\BufferUnpacker; use MessagePack\Packer; use MessagePack\TypeTransformer\Packable; use MessagePack\TypeTransformer\Unpackable; class PackedMapTransformer implements Packable, Unpackable { private $type; public function __construct($type) { $this->type = $type; } public function getType() : int { return $this->type; } public function pack(Packer $packer, $value) : ?string { if (!$value instanceof PackedMap) { return null; } $data = ''; $size = 0; foreach ($value->map as $item) { foreach ($value->schema as $key => $type) { $data .= $packer->{'pack'.$type}($item[$key]); } ++$size; } return $packer->packExt($this->type, $packer->packMap($value->schema). $packer->packArrayHeader($size). $data ); } public function unpack(BufferUnpacker $unpacker, int $extLength) { $schema = $unpacker->unpackMap(); $size = $unpacker->unpackArrayHeader(); $items = []; for ($i = 0; $i < $size; ++$i) { foreach ($schema as $key => $type) { $items[$i][$key] = $unpacker->{'unpack'.$type}(); } } return $items; } } |