From 1021915845305934121935e88aed2c75e7913c73 Mon Sep 17 00:00:00 2001 From: pvm1922 <155550868+pvm1922@users.noreply.github.com> Date: Thu, 14 Mar 2024 00:25:05 +0530 Subject: [PATCH] add args to push and pull methods --- src/Calendar.php | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/src/Calendar.php b/src/Calendar.php index 84fe0a7..f636c66 100644 --- a/src/Calendar.php +++ b/src/Calendar.php @@ -112,7 +112,8 @@ public function pull(CalendarViewParamsInterface $params, ?Closure $deltaLinkSto $events, $requestAdapter, $requestConfiguration, - $deltaLinkStore + $deltaLinkStore, + $args ); $this->logger?->info('All events received...', [ @@ -236,7 +237,7 @@ public function getInstancesCollection(string $id, ?InstancesRequestBuilderGetQu */ public function push(array $params = [], array $args = []): void { - $eventsToWrite = $this->getLocalEvents(); + $eventsToWrite = $this->getLocalEvents($params); $this->batchPush($eventsToWrite, $params, $args); } @@ -469,7 +470,7 @@ protected function prepareUpsertAsync(Event $event, EventsRequestBuilderPostRequ /** * @throws \Exception */ - protected function iterateThrough(DeltaGetResponse $events, RequestAdapter $requestAdapter, DeltaRequestBuilderGetRequestConfiguration $requestConfiguration, ?Closure $deltaLinkStore = null): void + protected function iterateThrough(DeltaGetResponse $events, RequestAdapter $requestAdapter, DeltaRequestBuilderGetRequestConfiguration $requestConfiguration, ?Closure $deltaLinkStore = null, array $args = []): void { $iterator = new PageIterator( $events, @@ -478,7 +479,7 @@ protected function iterateThrough(DeltaGetResponse $events, RequestAdapter $requ $iterator->setHeaders($requestConfiguration->headers); - $iterator->iterate(function (?GraphEvent $event) { + $iterator->iterate(function (?GraphEvent $event) use ($args) { if (null === $event) { return true; } @@ -497,7 +498,7 @@ protected function iterateThrough(DeltaGetResponse $events, RequestAdapter $requ return true; } - $this->saveEventLocal($this->getEntity($event)); + $this->saveEventLocal($this->getEntity($event), $args); $this->logger?->info('Completed event processing', [ 'event_id' => $event->getId(),