$value * @throws \Exception */ public function __construct(array $value = [], ?string $boundary = null) { $this->data = new ArrayBodyRepository; $this->boundary = is_null($boundary) ? StringHelpers::random(40) : $boundary; $this->set($value); } /** * Set a value inside the repository * * @param array<\Saloon\Data\MultipartValue> $value * @return $this */ public function set(mixed $value): static { if (! is_array($value)) { throw new InvalidArgumentException('The value must be an array'); } $this->data->set( $this->parseMultipartArray($value) ); return $this; } /** * Merge another array into the repository * * @param array<\Saloon\Data\MultipartValue> ...$arrays * @return $this */ public function merge(array ...$arrays): static { $this->data->merge(...array_map( $this->parseMultipartArray(...), $arrays, )); return $this; } /** * Add an element to the repository. * * @param \Psr\Http\Message\StreamInterface|resource|string $contents * @param array $headers * @return $this */ public function add(string $name, mixed $contents, ?string $filename = null, array $headers = []): static { $this->attach(new MultipartValue($name, $contents, $filename, $headers)); return $this; } /** * Attach a multipart file * * @return $this */ public function attach(MultipartValue $file): static { $this->data->add(null, $file); return $this; } /** * Get the raw data in the repository. * * @return array<\Saloon\Data\MultipartValue> */ public function all(): array { return $this->data->all(); } /** * Get a specific key of the array * * @param array-key $key * @return MultipartValue|array */ public function get(string|int $key, mixed $default = null): MultipartValue|array { $values = array_values(array_filter($this->all(), static function (MultipartValue $value) use ($key) { return $value->name === $key; })); if (count($values) === 0) { return $default; } if (count($values) === 1) { return $values[0]; } return $values; } /** * Remove an item from the repository. * * @return $this */ public function remove(string $key): static { $values = array_filter($this->all(), static function (MultipartValue $value) use ($key) { return $value->name !== $key; }); $this->set($values); return $this; } /** * Determine if the repository is empty */ public function isEmpty(): bool { return $this->data->isEmpty(); } /** * Determine if the repository is not empty */ public function isNotEmpty(): bool { return $this->data->isNotEmpty(); } /** * Parse a multipart array * * @param array $value * @return array<\Saloon\Data\MultipartValue> */ protected function parseMultipartArray(array $value): array { $multipartValues = array_filter($value, static fn (mixed $item): bool => $item instanceof MultipartValue); if (count($value) !== count($multipartValues)) { throw new InvalidArgumentException(sprintf('The value array must only contain %s objects.', MultipartValue::class)); } return array_values($value); } /** * Set the multipart body factory */ public function setMultipartBodyFactory(MultipartBodyFactory $multipartBodyFactory): MultipartBodyRepository { $this->multipartBodyFactory = $multipartBodyFactory; return $this; } /** * Get the boundary */ public function getBoundary(): string { return $this->boundary; } /** * Convert the body repository into a stream * * @throws BodyException */ public function toStream(StreamFactoryInterface $streamFactory): StreamInterface { if (! isset($this->multipartBodyFactory)) { throw new BodyException('Unable to create a multipart body stream because the multipart body factory was not set.'); } return $this->multipartBodyFactory->create($streamFactory, $this->all(), $this->getBoundary()); } }