Skip to content

Commit f78dea5

Browse files
committed
Event can now handle both array and string data
1 parent 72be089 commit f78dea5

File tree

2 files changed

+16
-1
lines changed

2 files changed

+16
-1
lines changed

src/Event.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ public static function createFromMessage(array $message): self
3535
{
3636
return new self(
3737
$message['event'],
38-
json_decode($message['data'], true),
38+
is_array($message['data']) ? $message['data'] : json_decode($message['data'], true),
3939
isset($message['channel']) ? $message['channel'] : ''
4040
);
4141
}

tests/EventTest.php

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,21 @@ public function eventsProvider()
4545
$data,
4646
];
4747

48+
$data = [
49+
'time' => time(),
50+
'pid' => getmypid(),
51+
];
52+
yield [
53+
[
54+
'event' => 'event:name',
55+
'channel' => 'foo-bar',
56+
'data' => $data,
57+
],
58+
'event:name',
59+
'foo-bar',
60+
$data,
61+
];
62+
4863
}
4964

5065
/**

0 commit comments

Comments
 (0)