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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
<?php
declare(strict_types=1);
namespace OpenTelemetry\Context\Propagation;
use function array_key_first;
use ArrayAccess;
use function get_class;
use function gettype;
use InvalidArgumentException;
use function is_array;
use function is_object;
use function is_string;
use function sprintf;
use function strcasecmp;
use Traversable;
/**
* @see https://github.com/open-telemetry/opentelemetry-specification/blob/v1.6.1/specification/context/api-propagators.md#textmap-propagator Getter and Setter.
*
* Default implementation of {@see PropagationGetterInterface} and {@see PropagationSetterInterface}.
* This type is used if no custom getter/setter is provided to {@see TextMapPropagatorInterface::inject()} or {@see TextMapPropagatorInterface::extract()}.
*/
final class ArrayAccessGetterSetter implements PropagationGetterInterface, PropagationSetterInterface
{
private static ?self $instance = null;
/**
* Returns a singleton instance of `self` to avoid, multiple runtime allocations.
*/
public static function getInstance(): self
{
if (null === self::$instance) {
self::$instance = new self();
}
return self::$instance;
}
/** {@inheritdoc} */
public function keys($carrier): array
{
if ($this->isSupportedCarrier($carrier)) {
$keys = [];
foreach ($carrier as $key => $_) {
$keys[] = (string) $key;
}
return $keys;
}
throw new InvalidArgumentException(
sprintf(
'Unsupported carrier type: %s.',
is_object($carrier) ? get_class($carrier) : gettype($carrier),
)
);
}
/** {@inheritdoc} */
public function get($carrier, string $key): ?string
{
if ($this->isSupportedCarrier($carrier)) {
$value = $carrier[$this->resolveKey($carrier, $key)] ?? null;
if (is_array($value) && $value) {
$value = $value[array_key_first($value)];
}
return is_string($value)
? $value
: null;
}
throw new InvalidArgumentException(
sprintf(
'Unsupported carrier type: %s. Unable to get value associated with key:%s',
is_object($carrier) ? get_class($carrier) : gettype($carrier),
$key
)
);
}
/** {@inheritdoc} */
public function set(&$carrier, string $key, string $value): void
{
if ($key === '') {
throw new InvalidArgumentException('Unable to set value with an empty key');
}
if ($this->isSupportedCarrier($carrier)) {
if (($r = $this->resolveKey($carrier, $key)) !== $key) {
unset($carrier[$r]);
}
$carrier[$key] = $value;
return;
}
throw new InvalidArgumentException(
sprintf(
'Unsupported carrier type: %s. Unable to set value associated with key:%s',
is_object($carrier) ? get_class($carrier) : gettype($carrier),
$key
)
);
}
private function isSupportedCarrier($carrier): bool
{
return is_array($carrier) || $carrier instanceof ArrayAccess && $carrier instanceof Traversable;
}
private function resolveKey($carrier, string $key): string
{
if (isset($carrier[$key])) {
return $key;
}
foreach ($carrier as $k => $_) {
$k = (string) $k;
if (strcasecmp($k, $key) === 0) {
return $k;
}
}
return $key;
}
}
|
