backing up.

ealcantara22 · Jan 18, 2018 · db01aa9 · db01aa9
1 parent 6e378c6
commit db01aa9
Show file tree

Hide file tree

Showing 6 changed files with 8 additions and 6 deletions.
diff --git a/Controller/SyncController.php b/Controller/SyncController.php
@@ -98,7 +98,7 @@ public function pushAction(Request $request) {
 
             $syncClass = $mapping->getSyncService();
 
-            if(!class_exists($syncClass)) { continue; }
+            #if(!class_exists($syncClass)) { continue; }
 
             /** @var SyncServiceInterface $service */
             $service = $this->get($syncClass);

diff --git a/Entity/SyncDeleteState.php b/Entity/SyncDeleteState.php
@@ -108,4 +108,3 @@ public function setTimestamp($timestamp)
     }
 
 }
-
diff --git a/Entity/SyncMapping.php b/Entity/SyncMapping.php
@@ -108,4 +108,3 @@ public function setSyncService($syncService)
 
 
 }
-
diff --git a/Entity/SyncNewItemState.php b/Entity/SyncNewItemState.php
@@ -141,4 +141,4 @@ public function setTimestamp($timestamp)
         return $this;
     }
 
-}
+}
diff --git a/Entity/SyncState.php b/Entity/SyncState.php
@@ -83,4 +83,3 @@ public function setTimestamp($timestamp)
     }
 
 }
-
diff --git a/Service/SyncService.php b/Service/SyncService.php
@@ -27,7 +27,6 @@ class SyncService {
      */
     public function __construct(ContainerInterface $container) {
         $this->container = $container;
-
     }
 
     /**
@@ -61,6 +60,11 @@ public function getFromMappings($mappings) {
             $deletes = $this->em->getRepository('NTISyncBundle:SyncDeleteState')->findFromTimestamp($mappingName, $timestamp);
             $newItems = $this->em->getRepository('NTISyncBundle:SyncNewItemState')->findFromTimestampAndMapping($mappingName, $timestamp);
 
+            /**
+             * Failed Items Synchronization
+             */
+            $failedItems = $this->em->getRepository('NTISyncBundle:SyncFailedItemState')->findFromTimestampAndMapping($mappingName, $timestamp);
+
             /** @var SyncRepositoryInterface $repository */
             $repository = $this->em->getRepository($syncMapping->getClass());
             if(!($repository instanceof SyncRepositoryInterface)) {
@@ -74,6 +78,7 @@ public function getFromMappings($mappings) {
                 'changes' => $result["data"],
                 'deletes' => json_decode($this->container->get('jms_serializer')->serialize($deletes, 'json'), true),
                 'newItems' => json_decode($this->container->get('jms_serializer')->serialize($newItems, 'json'), true),
+                'failedItems' => json_decode($this->container->get('jms_serializer')->serialize($failedItems, 'json'), true),
                 SyncState::REAL_LAST_TIMESTAMP => $result[SyncState::REAL_LAST_TIMESTAMP],
             );
         }
Original file line number	Diff line number	Diff line change
Expand Up		@@ -108,4 +108,3 @@ public function setTimestamp($timestamp)
		}

		}
Original file line number	Diff line number	Diff line change
Expand Up		@@ -108,4 +108,3 @@ public function setSyncService($syncService)


		}
-Original file line number
+Diff line change
@@ Expand Up / @@ -141,4 +141,4 @@ public function setTimestamp($timestamp) @@
             return $this;
         }
-    }
+    }
Original file line number	Diff line number	Diff line change
Expand Up		@@ -83,4 +83,3 @@ public function setTimestamp($timestamp)
		}

		}