jakevan/jvb.git

			@@ -3,6 +3,7 @@

			use JVBase\managers\queue\executors\IntegrationExecutor;
			use JVBase\managers\queue\mergers\DefaultMerger;
			use JVBase\managers\queue\Queue;
			use JVBase\managers\queue\TypeConfig;
			use JVBase\meta\Meta;
			use WP_Query;
			@@ -12,7 +13,7 @@
			}

			trait SyncHelpers {
			use _Base;
			use _Base, SyncDefaults;
			/**
			* Queue types
			* These types match with IntegrationExecutor
			@@ -23,12 +24,15 @@
			protected static string $syncCustomer;
			protected static string $import;

			protected static array $syncing = ['posts' => [], 'users' => [], 'terms' => []];


			protected function setQueueTypes():void
			{
			self::$syncTo = $this->service_name.'_sync_to';
			self::$deleteFrom = $this->service_name.'_delete_from';
			self::$syncFrom = $this->service_name.'_sync_from';
			self::$syncCustomer = $this->service_name.'_sync_customer';
			//TODO: What is the difference between sync_from and import?
			self::$import = $this->service_name.'import_from';
			}
			@@ -42,6 +46,17 @@
			default => ''
			};
			}
			public function setServiceItemID(int $itemID, string $id, string $type = 'post'):bool
			{

			$result = match($type) {
			'post' => Meta::forPost($itemID)->set("_{$this->service_name}_item_id", $id),
			'term','taxonomy' => Meta::forTerm($itemID)->set("_{$this->service_name}_item_id", $id),
			'user' => Meta::forUser($itemID)->set("_{$this->service_name}_item_id", $id),
			default => false
			};
			return $result !== false;
			}
			protected function updateItemStatus(int\|array $items, string $status = 'pending', string $type = 'post'):void
			{
			if (!is_array($items)) {
			@@ -151,7 +166,7 @@
			if (empty($this->syncTaxonomies) && empty($this->syncPostTypes)) {
			return;
			}
			$queue = JVB()->queue();
			$queue = Queue::getInstance();
			$executor = new IntegrationExecutor();

			$queue->registry()->register(self::$syncTo, new TypeConfig(