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: 

<?php

namespace SAREhub\Client\Event;

use SAREhub\Client\DataFormat\DataFormat;
use SAREhub\Client\Message\Exchange;
use SAREhub\Client\User\User;

class RawEventDataFormat implements DataFormat
{

    /**
     * @param Exchange $exchange
     * @return array
     */
    public function marshal(Exchange $exchange)
    {
        $event = EventHelper::extract($exchange->getIn());
        $eventData = [
            'type' => $event->getType(),
            'time' => $event->getTime()
        ];

        if ($event->hasUser()) {
            $eventData['user'] = $event->getUser()->getKeys();
        }

        EventLegacyHelper::copyFromEventToEventData($event, $eventData);
        $eventData['params'] = $event->getProperties();

        return $eventData;
    }

    /**
     * @param Exchange $exchange
     * @return Event
     */
    public function unmarshal(Exchange $exchange)
    {
        $eventData = $exchange->getIn()->getBody();
        $event = BasicEvent::newInstanceOf($eventData['type'])
            ->withTime($eventData['time'])
            ->withProperties($eventData['params']);

        if (isset($eventData['user'])) {
            $event->withUser(new User($eventData['user']));
        }

        EventLegacyHelper::copyFromDataToEvent($eventData, $event);
        return $event;
    }

    public function __toString()
    {
        return 'DataFormat[RawEvent]';
    }
}