add args to push and pull methods

Symplicity · Mar 13, 2024 · 1021915 · 1021915
1 parent f157b49
commit 1021915
Showing 1 changed file with 6 additions and 5 deletions.
diff --git 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(),