requests by request ID */ private array $requests = []; /** * @param RequestInformation[]|BatchRequestItem[] $requests Converts $requests to BatchRequestItems with auto-generated incrementing IDs starting from "0". * Use getRequests() to fetch created BatchRequestItem objects. * @throws \JsonException */ public function __construct(array $requests = []) { $this->setRequests( array_map(fn ($request) => is_a($request, BatchRequestItem::class) ? $request : new BatchRequestItem($request), $requests)); } /** * @return array */ public function getRequests(): array { return array_values($this->requests); } /** * @param BatchRequestItem[] $requests */ public function setRequests(array $requests): void { if (count($requests) > self::MAX_REQUESTS) { throw new \InvalidArgumentException("Maximum number of requests is ".self::MAX_REQUESTS); } array_map(fn ($request) => $this->addRequest($request), $requests); } /** * @param BatchRequestItem $request Assigns unique request Id if none is provided */ public function addRequest(BatchRequestItem $request): void { if (count($this->requests) >= self::MAX_REQUESTS) { throw new \RuntimeException("Maximum number of requests is ".self::MAX_REQUESTS); } if (!$request->getId()) { $request->setId(Uuid::uuid4()); } $this->requests[$request->getId()] = $request; } /** * @param RequestInformation $request * @throws \JsonException */ public function addRequestInformation(RequestInformation $request): void { $this->addRequest(new BatchRequestItem($request)); } /** * @param RequestInterface $request * @throws \JsonException */ public function addPsrRequest(RequestInterface $request): void { $this->addRequest(BatchRequestItem::createWithPsrRequest($request)); } /** * Remove request from batch * * @param string $requestId */ public function remove(string $requestId): void { unset($this->requests[$requestId]); } /** * Remove request from batch * * @param BatchRequestItem $item */ public function removeBatchRequestItem(BatchRequestItem $item): void { $this->remove($item->getId()); } public function getFieldDeserializers(): array { return []; } public function serialize(SerializationWriter $writer): void { $writer->writeCollectionOfObjectValues("requests", $this->requests); } }