Changeset 2744975

crowdaa-sync/tags/1.2.0/CHANGELOG

-                      r2722017
+                      r2744975
 ## [Unreleased]
+## [1.2.0] - 2022-06-14
+### Added
+- Permissions/badges synchronization
+- Synchronization database reset
+### Changed
+- Separated categories synchronization from post synchronization
 ## [1.1.0] - 2022-05-11

crowdaa-sync/tags/1.2.0/README.txt

r2722534	r2744975
6	6	Requires PHP: 7.3
7	7	Tested up to: 5.9
8		Stable tag: 1.~~1.1~~
	8	Stable tag: 1.2.0
9	9	License: GPLv2 or later
10	10	License URI: http://www.gnu.org/licenses/gpl-2.0.html

crowdaa-sync/tags/1.2.0/admin/class-crowdaa-sync-add-info-api.php

-                      r2722017
+                      r2744975
    */
   public function get_opqueue_ajax() {
+    $categories_opqueue = $this->get_categories_opqueue();
+    $badges_opqueue = $this->get_badges_opqueue();
     $articles_opqueue = $this->get_articles_opqueue();
     wp_send_json([
       'articles' => $articles_opqueue,
+      'badges' => $badges_opqueue,
+      'categories' => $categories_opqueue,
     ]);
+  }
+  public static function hash_badge(&$badge) {
+    $data = [
+      'name' => $badge->name,
+      'description' => $badge->description,
+      'access' => $badge->access,
+      'management' => $badge->management,
+      'createdAt' => $badge->createdAt,
+    ];
+    if (isset($badge->updatedAt)) {
+      $data['updatedAt'] = $badge->updatedAt;
+    }
+    return (hash('sha256', serialize($data)));
+  }
+  public static function hash_pmpro_membership(&$membership) {
+    $data = [
+      'name'          => ''.   $membership->name,
+      'description'   => ''.   $membership->description,
+      'allow_signups' => (int) $membership->allow_signups,
+    ];
+    return (hash('sha256', serialize($data)));
+  }
+  public static function hash_term(&$term) {
+    $data = [
+      'id'          => $term->term_id,
+      'name'        => $term->name,
+      'slug'        => $term->slug,
+      'parent'      => $term->parent,
+    ];
+    if (isset($term->rootParentId)) {
+      $data['rootParentId'] = $term->rootParentId;
+    }
+    if (Crowdaa_Sync_Utils::have_plugin('paid-memberships-pro')) {
+      global $wpdb;
+      $memberships = Crowdaa_Sync_Utils::quick_select($wpdb->pmpro_memberships_categories, [
+        'category_id' => $term->term_id,
+      ], ['membership_id']);
+      $data['memberships'] = $memberships;
+    }
+    return (hash('sha256', serialize($data)));
+  }
+  public static function hash_category(&$category) {
+    $data = [
+      'id'       => $category->_id,
+      'name'     => $category->name,
+      'pathName' => $category->pathName,
+      'parentId' => $category->parentId,
+    ];
+    if (Crowdaa_Sync_Utils::have_plugin('paid-memberships-pro')) {
+      $data['badges'] = $category->badges;
+    }
+    return (hash('sha256', serialize($data)));
+  }
+  /**
+   * Get badges pending sync operations queue
+   *
+   * @since    1.0.0
+   * @return array, object
+   */
+  public function get_badges_opqueue() {
+    Crowdaa_Sync_Logs::log('Syncing, Badges OpQueue fetching');
+    $crowdaa_sync_articles_wp_to_api_enabled = (get_option('crowdaa_sync_articles_wp_to_api_enabled', 'yes') === 'yes');
+    $crowdaa_sync_articles_api_to_wp_enabled = (get_option('crowdaa_sync_articles_api_to_wp_enabled', 'yes') === 'yes');
+    $api_data_class = new Crowdaa_Sync_API();
+    $sync_db = new Crowdaa_Sync_Syncdb('user_badges');
+    if(!get_option('crowdaa_auth_token')) {
+      $result = [
+        'error' => __('User is not connected', CROWDAA_SYNC_PLUGIN_NAME),
+      ];
+      return ($result);
+    }
+    $result = [
+      'api_to_wp'  => [],
+      'wp_to_api'  => [],
+      'only_api'   => [],
+      'only_wp'    => [],
+      'remove_api' => [],
+      'remove_wp'  => [],
+    ];
+    if (!Crowdaa_Sync_Utils::have_plugin('paid-memberships-pro')) {
+      return ($result);
+    }
+    if (!$crowdaa_sync_articles_api_to_wp_enabled && !$crowdaa_sync_articles_wp_to_api_enabled) {
+      return ($result);
+    }
+    global $wpdb;
+    $badges = $api_data_class->get_badges();
+    $synced = $sync_db->get_synced_entries();
+    $memberships = Crowdaa_Sync_Utils::quick_select($wpdb->pmpro_membership_levels);
+    if (isset($badges->message)) {
+      $result = [
+        'error' => __('API query error : ', CROWDAA_SYNC_PLUGIN_NAME).$badges->message,
+      ];
+      return ($result);
+    }
+    Crowdaa_Sync_Logs::log('OpQueue building...', count($badges).' api badges and '.count($memberships).' wp permissions');
+    $badges_by_id = [];
+    foreach ($badges as $badge) {
+      $badge->hash = self::hash_badge($badge);
+      $badges_by_id[$badge->_id] = $badge;
+    }
+    $synced_by_api_id = [];
+    $synced_by_wp_id = [];
+    foreach ($synced as $item) {
+      $item->badge_hash = $item->sync_data['badge_hash'];
+      $item->membership_hash = $item->sync_data['membership_hash'];
+      $synced_by_wp_id[$item->wp_id] = $item;
+      $synced_by_api_id[$item->api_id] = $item;
+    }
+    $memberships_by_id = [];
+    foreach ($memberships as $membership) {
+      $membership->hash = self::hash_pmpro_membership($membership);
+      $memberships_by_id[$membership->id] = $membership;
+    }
+    if ($crowdaa_sync_articles_wp_to_api_enabled) {
+      foreach ($memberships_by_id as $id => $membership) {
+        if (!array_key_exists($id, $synced_by_wp_id)) {
+          $result['only_wp'][] = [
+            'api_id' => null,
+            'wp_id' => $membership->id,
+            'name' => $membership->name,
+            'description' => $membership->description,
+            'public' => !!$membership->allow_signups,
+            'hash' => $membership->hash,
+          ];
+        } else if ($synced_by_wp_id[$id]->membership_hash !== $membership->hash) {
+          $result['wp_to_api'][] = [
+            'api_id' => $synced_by_wp_id[$id]->api_id,
+            'wp_id' => $membership->id,
+            'name' => $membership->name,
+            'description' => $membership->description,
+            'public' => !!$membership->allow_signups,
+            'hash' => $membership->hash,
+          ];
+        }
+      }
+      foreach ($synced_by_wp_id as $wp_id => $synced_item) {
+        if (!array_key_exists($wp_id, $memberships_by_id)) {
+          $result['remove_api'][] = [
+            'wp_id' => null,
+            'api_id' => $synced_item->api_id,
+          ];
+        }
+      }
+    }
+    if ($crowdaa_sync_articles_api_to_wp_enabled) {
+      foreach ($badges_by_id as $id => $badge) {
+        if (!array_key_exists($id, $synced_by_api_id)) {
+          $result['only_api'][] = [
+            'api_id' => $badge->_id,
+            'wp_id' => null,
+            'name' => $badge->name,
+            'description' => $badge->description,
+            'public' => (array_search($badge->management, ['request', 'public']) !== false),
+            'hash' => $badge->hash,
+          ];
+        } else if ($synced_by_api_id[$id]->badge_hash !== $badge->hash) {
+          $result['api_to_wp'][] = [
+            'api_id' => $badge->_id,
+            'wp_id' => $synced_by_api_id[$id]->wp_id,
+            'name' => $badge->name,
+            'description' => $badge->description,
+            'public' => (array_search($badge->management, ['request', 'public']) !== false),
+            'hash' => $badge->hash,
+          ];
+        }
+      }
+      foreach ($synced_by_api_id as $api_id => $synced_item) {
+        if (!array_key_exists($api_id, $badges_by_id)) {
+          $result['remove_wp'][] = [
+            'wp_id' => $synced_item->wp_id,
+            'api_id' => null,
+          ];
+        }
+      }
+    }
+    return ($result);
+  }
+  public function get_categories_opqueue() {
+    Crowdaa_Sync_Logs::log('Syncing, Categories OpQueue fetching');
+    $crowdaa_sync_articles_wp_to_api_enabled = (get_option('crowdaa_sync_articles_wp_to_api_enabled', 'yes') === 'yes');
+    $crowdaa_sync_articles_api_to_wp_enabled = (get_option('crowdaa_sync_articles_api_to_wp_enabled', 'yes') === 'yes');
+    $result = [
+      'api_to_wp'  => [],
+      'wp_to_api'  => [],
+      'only_api'   => [],
+      'only_wp'    => [],
+      'remove_api' => [],
+      'remove_wp'  => [],
+    ];
+    if (!$crowdaa_sync_articles_api_to_wp_enabled && !$crowdaa_sync_articles_wp_to_api_enabled) {
+      return ($result);
+    }
+    /// Fetching all categories and indexing by ID and updated field names
+    $categories_by_id = [];
+    $sync_api         = new Crowdaa_Sync_API();
+    $sync_db          = new Crowdaa_Sync_Syncdb('categories');
+    $synced           = $sync_db->get_synced_entries();
+    $all_categories   = $sync_api->get_categories();
+    if (isset($all_categories->message)) {
+      return ([
+        'error' => __('API query error : ', CROWDAA_SYNC_PLUGIN_NAME).$all_categories->message,
+      ]);
+    }
+    if ($all_categories->categories) {
+      foreach ($all_categories->categories as $category) {
+        if ($category->parentId) {
+          $category->rootParentId = $category->parentId;
+        }
+        $category->hash = self::hash_category($category);
+        $categories_by_id[$category->_id] = $category;
+      }
+    }
+    $args = array(
+      'hide_empty' => false,
+      'taxonomy'   => 'category',
+    );
+    $all_terms = get_terms($args);
+    $terms_by_id = [];
+    if(!empty($all_terms)) {
+      foreach ($all_terms as $term) {
+        $term->perms = [];
+        if (Crowdaa_Sync_Utils::have_plugin('paid-memberships-pro')) {
+          global $wpdb;
+          $perms = Crowdaa_Sync_Utils::quick_select($wpdb->pmpro_memberships_categories, [
+            'category_id' => $term->term_id,
+          ], ['membership_id']);
+          $perms_array = [];
+          foreach ($perms as $perm) {
+            $perms_array[] = $perm->membership_id;
+          }
+          $term->perms = $perms_array;
+        }
+        $terms_by_id[$term->term_id] = $term;
+      }
+    }
+    /// Fetching filtering modes
+    $sync_categories_mode = get_option('crowdaa_sync_categories_mode', 'blacklist');
+    $sync_categories_list = get_option('crowdaa_sync_categories_list', '');
+    if ($sync_categories_list === '') {
+      $sync_categories_list = [];
+    } else {
+      $sync_categories_list = explode(',', $sync_categories_list);
+    }
+    /// Getting list of categories names
+    $sync_categories_names = [];
+    foreach ($sync_categories_list as $id) {
+      if (isset($terms_by_id[$id])) {
+        $sync_categories_names = $terms_by_id[$id]->name;
+      }
+    }
+    /// Filtering allowed parents from the WP terms
+    foreach ($terms_by_id as $term) {
+      $root_term = $term;
+      while ($root_term->parent) {
+        $root_term = $terms_by_id[$root_term->parent];
+      }
+      if ($sync_categories_mode === 'whitelist' && !in_array($root_term->term_id, $sync_categories_list)) {
+        $term->rootParentId = null;
+      } else if ($sync_categories_mode === 'blacklist' && in_array($root_term->term_id, $sync_categories_list)) {
+        $term->rootParentId = null;
+      } else if ($root_term->term_id !== $term->term_id) {
+        $term->rootParentId = $root_term->term_id;
+      } else {
+        $term->rootParentId = null;
+      }
+      $term->hash = self::hash_term($term);
+    }
+    /// Filtering allowed terms
+    foreach ($terms_by_id as $id => $term) {
+      if ($sync_categories_mode === 'whitelist' && !in_array($term->term_id, $sync_categories_list)) {
+        unset($terms_by_id[$id]);
+      } else if ($sync_categories_mode === 'blacklist' && in_array($term->term_id, $sync_categories_list)) {
+        unset($terms_by_id[$id]);
+      }
+    }
+    /// Filtering allowed categories
+    foreach ($categories_by_id as $id => $category) {
+      if ($sync_categories_mode === 'whitelist' && !in_array($category->name, $sync_categories_names)) {
+        unset($categories_by_id[$id]);
+      } else if ($sync_categories_mode === 'blacklist' && in_array($category->name, $sync_categories_names)) {
+        unset($categories_by_id[$id]);
+      }
+    }
+    /// Specific code to handle migration from previous sync mechanism
+    if (count($synced) === 0) {
+      $created = 0;
+      foreach ($terms_by_id as $term) {
+        $api_id = get_term_meta($term->term_id, 'api_term_id', true);
+        if ($api_id && isset($categories_by_id[$api_id])) {
+          $sync_db->create_entry($term->term_id, $api_id, [
+            'category_hash' => $categories_by_id[$api_id]->hash,
+            'term_hash' => $term->hash,
+          ]);
+          $created++;
+        }
+      }
+      if ($created > 0) {
+        $synced = $sync_db->get_synced_entries();
+      }
+    }
+    /// Storing synced
+    $synced_by_api_id = [];
+    $synced_by_wp_id = [];
+    foreach ($synced as $item) {
+      $item->category_hash = $item->sync_data['category_hash'];
+      $item->term_hash = $item->sync_data['term_hash'];
+      if ($sync_categories_mode === 'whitelist' && !in_array($item->wp_id, $sync_categories_list)) {
+        $sync_db->delete_entry(['id' => $item->id]);
+      } else if ($sync_categories_mode === 'blacklist' && in_array($item->wp_id, $sync_categories_list)) {
+        $sync_db->delete_entry(['id' => $item->id]);
+      } else {
+        $synced_by_wp_id[$item->wp_id] = $item;
+        $synced_by_api_id[$item->api_id] = $item;
+      }
+    }
+    Crowdaa_Sync_Logs::log('OpQueue building...', count($all_categories->categories).' api categories and '.count($all_terms).' wp categories');
+    /// Comparing states and storing oplist
+    if ($crowdaa_sync_articles_wp_to_api_enabled) {
+      foreach ([false, true] as $hasParent) {
+        foreach ($terms_by_id as $id => $term) {
+          if ((!!$term->rootParentId) === $hasParent) {
+            if (!array_key_exists($id, $synced_by_wp_id)) {
+              $result['only_wp'][] = [
+                'api_id' => null,
+                'wp_id' => $term->term_id,
+                'name' => $term->name,
+                'slug' => $term->slug,
+                'parentId' => $term->rootParentId,
+                'perms' => $term->perms,
+                'hash' => $term->hash,
+              ];
+            } else if ($synced_by_wp_id[$id]->term_hash !== $term->hash) {
+              $result['wp_to_api'][] = [
+                'api_id' => $synced_by_wp_id[$id]->api_id,
+                'wp_id' => $term->term_id,
+                'name' => $term->name,
+                'slug' => $term->slug,
+                'parentId' => $term->rootParentId,
+                'perms' => $term->perms,
+                'hash' => $term->hash,
+              ];
+            }
+          }
+        }
+      }
+      foreach ($synced_by_wp_id as $wp_id => $synced_item) {
+        if (!array_key_exists($wp_id, $terms_by_id)) {
+          $result['remove_api'][] = [
+            'api_id' => $synced_item->api_id,
+            'wp_id' => null,
+          ];
+        }
+      }
+    }
+    if ($crowdaa_sync_articles_api_to_wp_enabled) {
+      foreach ([false, true] as $hasParent) {
+        foreach ($categories_by_id as $id => $category) {
+          if ((!!$category->parentId) === $hasParent) {
+            if (!array_key_exists($id, $synced_by_api_id)) {
+              $result['only_api'][] = [
+                'api_id' => $category->_id,
+                'wp_id' => null,
+                'name' => $category->name,
+                'slug' => $category->pathName,
+                'parentId' => $category->parentId,
+                'badges' => $category->badges,
+                'hash' => $category->hash,
+              ];
+            } else if ($synced_by_api_id[$id]->category_hash !== $category->hash) {
+              $result['api_to_wp'][] = [
+                'api_id' => $category->_id,
+                'wp_id' => $synced_by_api_id[$id]->wp_id,
+                'name' => $category->name,
+                'slug' => $category->pathName,
+                'parentId' => $category->parentId,
+                'badges' => $category->badges,
+                'hash' => $category->hash,
+              ];
+            }
+          }
+        }
+      }
+      foreach ($synced_by_api_id as $api_id => $synced_item) {
+        if (!array_key_exists($api_id, $categories_by_id)) {
+          $result['remove_wp'][] = [
+            'wp_id' => $synced_item->wp_id,
+            'api_id' => null,
+          ];
+        }
+      }
+    }
+    return ($result);
+  }
 …
+    }
-    // Compare posts API and WP
     $result = [
       'api_to_wp' => [],
 …
       $info_wp = new Crowdaa_Sync_Add_Info_WP();
+      $badges_opqueue = $this->get_badges_opqueue();
+      $categories_opqueue = $this->get_categories_opqueue();
       $articles_opqueue = $this->get_articles_opqueue();
+      if (isset($badges_opqueue['error']) && $badges_opqueue['error']) {
+        $result['error'] = $badges_opqueue['error'];
+        Crowdaa_Sync_Logs::log('Queue', 'error', $badges_opqueue['error']);
+        return ($result);
+      }
+      if (isset($categories_opqueue['error']) && $categories_opqueue['error']) {
+        $result['error'] = $categories_opqueue['error'];
+        Crowdaa_Sync_Logs::log('Queue', 'error', $categories_opqueue['error']);
+        return ($result);
+      }
       if (isset($articles_opqueue['error']) && $articles_opqueue['error']) {
 …
       $result['opqueue'] = [
+        'articles' => $articles_opqueue,
+        'articles'   => $articles_opqueue,
+        'badges'     => $badges_opqueue,
+        'categories' => $categories_opqueue,
       ];
+      self::log_opqueue($badges_opqueue, 'badges', 'api_to_wp');
+      self::log_opqueue($badges_opqueue, 'badges', 'wp_to_api');
+      self::log_opqueue($badges_opqueue, 'badges', 'only_api');
+      self::log_opqueue($badges_opqueue, 'badges', 'only_wp');
+      self::log_opqueue($badges_opqueue, 'badges', 'remove_api');
+      self::log_opqueue($badges_opqueue, 'badges', 'remove_wp');
+      self::log_opqueue($categories_opqueue, 'categories', 'api_to_wp');
+      self::log_opqueue($categories_opqueue, 'categories', 'wp_to_api');
+      self::log_opqueue($categories_opqueue, 'categories', 'only_api');
+      self::log_opqueue($categories_opqueue, 'categories', 'only_wp');
+      self::log_opqueue($categories_opqueue, 'categories', 'remove_api');
+      self::log_opqueue($categories_opqueue, 'categories', 'remove_wp');
       self::log_opqueue($articles_opqueue, 'articles', 'api_to_wp');
       self::log_opqueue($articles_opqueue, 'articles', 'wp_to_api');
 …
       do_action('crowdaa_sync_articles_synchronization_start');
+      // Sync WP => API
+      if (
+        count($badges_opqueue['wp_to_api']) > 0 ||
+        count($badges_opqueue['only_wp']) > 0 ||
+        count($badges_opqueue['remove_api']) > 0
+      ) {
+        /** @TODO Continue me, write this function */
+        $api_errors = $this->sync_badges_api(
+          $badges_opqueue['wp_to_api'],
+          $badges_opqueue['only_wp'],
+          $badges_opqueue['remove_api']
+        );
+      }
+      // Sync API => WP
+      if (
+        count($badges_opqueue['api_to_wp']) > 0 ||
+        count($badges_opqueue['only_api']) > 0 ||
+        count($badges_opqueue['remove_wp']) > 0
+      ) {
+        /** @TODO Continue me, write this function */
+        $wp_errors = $info_wp->sync_badges_wp(
+          $badges_opqueue['api_to_wp'],
+          $badges_opqueue['only_api'],
+          $badges_opqueue['remove_wp']
+        );
+      }
+      // Sync WP => API
+      if (
+        count($categories_opqueue['wp_to_api']) > 0 ||
+        count($categories_opqueue['only_wp']) > 0 ||
+        count($categories_opqueue['remove_api']) > 0
+      ) {
+        /** @TODO Continue me, write this function */
+        $api_errors = $this->sync_categories_api(
+          $categories_opqueue['wp_to_api'],
+          $categories_opqueue['only_wp'],
+          $categories_opqueue['remove_api']
+        );
+      }
+      // Sync API => WP
+      if (
+        count($categories_opqueue['api_to_wp']) > 0 ||
+        count($categories_opqueue['only_api']) > 0 ||
+        count($categories_opqueue['remove_wp']) > 0
+      ) {
+        /** @TODO Continue me, write this function */
+        $wp_errors = $info_wp->sync_categories_wp(
+          $categories_opqueue['api_to_wp'],
+          $categories_opqueue['only_api'],
+          $categories_opqueue['remove_wp']
+        );
+      }
       // Sync WP => API
       if (is_array($articles_opqueue['wp_to_api']) && is_array($articles_opqueue['only_wp'])) {
 …
     } catch (Crowdaa_Sync_Post_Error $e) {
       $result['error'] = __('Uncaught Post synchronization error : ', CROWDAA_SYNC_PLUGIN_NAME).$e->getMessage();
+    } catch (Crowdaa_Sync_Category_Error $e) {
+      $result['error'] = __('Category synchronization error : ', CROWDAA_SYNC_PLUGIN_NAME).$e->getMessage();
+    } catch (Crowdaa_Sync_Badge_Error $e) {
+      $result['error'] = __('Badge synchronization error : ', CROWDAA_SYNC_PLUGIN_NAME).$e->getMessage();
     } catch (Crowdaa_Sync_Error $e) {
       $result['error'] = __('Fatal synchronization error : ', CROWDAA_SYNC_PLUGIN_NAME).$e->getMessage();
 …
+  }
+  public function sync_badges_api(
+    &$wp_to_api,
+    &$only_wp,
+    &$remove_api
+  ) {
+    $elements_to_process = array_merge($wp_to_api, $only_wp, $remove_api);
+    if (!$elements_to_process) {
+      return (false);
+    }
+    $sync_api = new Crowdaa_Sync_API();
+    $sync_db  = new Crowdaa_Sync_Syncdb('user_badges');
+    $errors   = [];
+    foreach ($elements_to_process as $curPermId => $curPerm) {
+      Crowdaa_Sync_Timer::check();
+      Crowdaa_Sync_Logs::log('Syncing WP>API Badge', $curPermId, wp_json_encode($curPerm));
+      try {
+        if (in_array($curPerm, $only_wp, true)) {
+          $badge = $sync_api->create_badge($curPerm['name'], $curPerm['description'], $curPerm['public']);
+          $sync_db->create_entry($curPerm['wp_id'], $badge->_id, [
+            'badge_hash' => self::hash_badge($badge),
+            'membership_hash' => $curPerm['hash'],
+          ]);
+        } else if (in_array($curPerm, $wp_to_api, true)) {
+          $badge = $sync_api->update_badge($curPerm['api_id'], $curPerm['name'], $curPerm['description'], $curPerm['public']);
+          $sync_db->update_entry(['api_id' => $curPerm['api_id']], [
+            'sync_data' => [
+              'badge_hash' => self::hash_badge($badge),
+              'membership_hash' => $curPerm['hash'],
+            ],
+          ]);
+        } else if (in_array($curPerm, $remove_api, true)) {
+          $sync_api->remove_badge($curPerm['api_id']);
+          $sync_db->delete_entry(['api_id' => $curPerm['api_id']]);
+        }
+      } catch (Crowdaa_Sync_Post_Skip_Error $e) {
+        Crowdaa_Sync_Logs::log($e->getMessage());
+        continue;
+      } catch (Crowdaa_Sync_Post_Error $e) {
+        Crowdaa_Sync_Logs::log('Badge sync error', $e->getMessage());
+        $errors[] = $e->getMessage();
+        continue;
+      }
+    }
+    if (count($elements_to_process) > 0) {
+      foreach ($errors as $error) {
+        Crowdaa_Sync_Logs::log('Created/updated/removed API badges errors', $error);
+      }
+      Crowdaa_Sync_Logs::log(
+        'Created/updated API badges',
+        count($only_wp).' badges created, '.
+        count($wp_to_api).' badges updated and '.
+        count($remove_api).' badges removed with '.count($errors).' errors'
+      );
+    }
+    return ($errors);
+  }
+  private static function term_perms_to_badges($perms) {
+    $perm_sync_db = new Crowdaa_Sync_Syncdb('user_badges');
+    $badges = [];
+    foreach ($perms as $perm_id) {
+      $entry = $perm_sync_db->get_entry_with_wp_id($perm_id, 'api_id');
+      $badges[] = $entry->api_id;
+    }
+    return ($badges);
+  }
+  public function sync_categories_api(
+    &$wp_to_api,
+    &$only_wp,
+    &$remove_api
+  ) {
+    $elements_to_process = array_merge($wp_to_api, $only_wp, $remove_api);
+    if (!$elements_to_process) {
+      return (false);
+    }
+    $sync_api     = new Crowdaa_Sync_API();
+    $sync_db      = new Crowdaa_Sync_Syncdb('categories');
+    $errors       = [];
+    foreach ($elements_to_process as $curTermId => $curTerm) {
+      Crowdaa_Sync_Timer::check();
+      Crowdaa_Sync_Logs::log('Syncing WP>API Category', $curTermId, wp_json_encode($curTerm));
+      try {
+        if (in_array($curTerm, $only_wp, true)) {
+          $parentId = null;
+          if ($curTerm['parentId']) {
+            $parentId = $sync_db->get_entry_with_wp_id($curTerm['parentId'], 'api_id');
+            $parentId = $parentId->api_id;
+          }
+          $badges = null;
+          if (Crowdaa_Sync_Utils::have_plugin('paid-memberships-pro')) {
+            $badges = self::term_perms_to_badges($curTerm['perms']);
+          }
+          $category = $sync_api->create_category($curTerm['name'], $curTerm['slug'], $parentId, $badges);
+          $sync_db->create_entry($curTerm['wp_id'], $category->_id, [
+            'category_hash' => self::hash_category($category),
+            'term_hash' => $curTerm['hash'],
+          ]);
+        } else if (in_array($curTerm, $wp_to_api, true)) {
+          $parentId = null;
+          if ($curTerm['parentId']) {
+            $parentId = $sync_db->get_entry_with_wp_id($curTerm['parentId'], 'api_id');
+            $parentId = $parentId->api_id;
+          }
+          $badges = null;
+          if (Crowdaa_Sync_Utils::have_plugin('paid-memberships-pro')) {
+            $badges = self::term_perms_to_badges($curTerm['perms']);
+          }
+          $category = $sync_api->update_category($curTerm['api_id'], $curTerm['name'], $curTerm['slug'], $parentId, $badges);
+          $sync_db->update_entry(['api_id' => $curTerm['api_id']], [
+            'sync_data' => [
+              'category_hash' => self::hash_category($category),
+              'term_hash' => $curTerm['hash'],
+            ],
+          ]);
+        } else if (in_array($curTerm, $remove_api, true)) {
+          $sync_api->delete_category($curTerm['api_id']);
+          $sync_db->delete_entry(['api_id' => $curTerm['api_id']]);
+        }
+      } catch (Crowdaa_Sync_Post_Skip_Error $e) {
+        Crowdaa_Sync_Logs::log($e->getMessage());
+        continue;
+      } catch (Crowdaa_Sync_Post_Error $e) {
+        Crowdaa_Sync_Logs::log('Badge sync error', $e->getMessage());
+        $errors[] = $e->getMessage();
+        continue;
+      }
+    }
+    if (count($elements_to_process) > 0) {
+      foreach ($errors as $error) {
+        Crowdaa_Sync_Logs::log('Created/updated/removed API categories errors', $error);
+      }
+      Crowdaa_Sync_Logs::log(
+        'Created/updated API categories',
+        count($only_wp).' categories created, '.
+        count($wp_to_api).' categories updated and '.
+        count($remove_api).' categories removed with '.count($errors).' errors'
+      );
+    }
+    return ($errors);
+  }
   public function sync_info_api(&$wp_to_api, &$only_wp) {
     $posts_add_to_api = array_merge($wp_to_api, $only_wp);
 …
+    }
+    $cat_array        = [];
+    $errors           = [];
+    $sync_api         = new Crowdaa_Sync_API();
+    $all_categories   = $sync_api->get_categories();
+    if (isset($all_categories->message)) {
+      throw new Crowdaa_Sync_Error(__('Categories fetch error : ', CROWDAA_SYNC_PLUGIN_NAME).$all_categories->message);
+    }
+    if ($all_categories->categories) {
+      foreach ($all_categories->categories as $category) {
+        $cat_array[$category->_id] = strtolower(trim($category->pathName));
+      }
+    }
+    $args = array(
+      'hide_empty' => false,
+      'taxonomy'   => 'category',
+    );
+    $all_terms = get_terms($args);
+    $terms_hash = [];
+    if(!empty($all_terms)) {
+      foreach ($all_terms as $term) {
+        $terms_hash[$term->term_id] = $term;
+      }
+    $errors             = [];
+    $sync_api           = new Crowdaa_Sync_API();
+    $cat_sync_db        = new Crowdaa_Sync_Syncdb('categories');
+    $cat_synced_entries = $cat_sync_db->get_synced_entries();
+    $cat_wp_to_api_id = [];
+    foreach ($cat_synced_entries as $item) {
+      $cat_wp_to_api_id[$item->wp_id] = $item->api_id;
+    }
 …
+    }
-    foreach ($terms_hash as $term) {
-      $root_term = $term;
-      while ($root_term->parent) {
-        $root_term = $terms_hash[$root_term->parent];
+      }
-      if ($sync_categories_mode === 'whitelist' && !in_array($root_term->term_id, $sync_categories_list)) {
-        $term->root_term_id = null;
-        continue;
-      } else if ($sync_categories_mode === 'blacklist' && in_array($root_term->term_id, $sync_categories_list)) {
-        $term->root_term_id = null;
-        continue;
+      }
-      if ($root_term->term_id !== $term->term_id) {
-        $term->root_term_id = $root_term->term_id;
-      } else {
-        $term->root_term_id = $term->parent;
+      }
+    }
     foreach ($posts_add_to_api as $postArrayId => $post) {
       Crowdaa_Sync_Timer::check();
 …
       $blacklisted = false;
       foreach ($post_terms as $term) {
-        $blacklisted_term = false;
         if (in_array($term->term_id, $sync_categories_list)) {
           if ($sync_categories_mode === 'blacklist') {
 …
             $whitelisted = $term->term_id;
             if (!$post_term) {
-              $child_term = true; // Lie here to avoid losing this term.
               $post_term  = [
+                'id'   => $term->term_id,
+                'slug' => $term->slug,
+                'name' => $term->name,
+                'id'    => $term->term_id,
+                'child' => in_array($term->term_id, $child_terms),
+              ];
+            } else if (!$post_term['child'] && in_array($term->term_id, $child_terms)) {
+              $post_term  = [
+                'id'    => $term->term_id,
+                'child' => true,
               ];
+            }
 …
         } else if (
           $sync_categories_mode !== 'whitelist' &&
+          !$blacklisted &&
+          !$post_term &&
+          in_array($term->term_id, $child_terms)
+          !$blacklisted
         ) {
+          $child_term = true;
+          $post_term  = [
+            'id'   => $term->term_id,
+            'slug' => $term->slug,
+            'name' => $term->name,
+          ];
+          if (!$post_term) {
+            $post_term  = [
+              'id'    => $term->term_id,
+              'child' => in_array($term->term_id, $child_terms),
+            ];
+          } else if (!$post_term['child'] && in_array($term->term_id, $child_terms)) {
+            $post_term  = [
+              'id'    => $term->term_id,
+              'child' => true,
+            ];
+          }
+        }
+      }
 …
         continue;
+      }
-      if ($child_term == false) {
-        $post_term  = [
-          'id'   => $post_terms[0]->term_id,
-          'slug' => $post_terms[0]->slug,
-          'name' => $post_terms[0]->name,
-        ];
+      }
-      $term = $terms_hash[$post_term['id']];
-      if ($term->root_term_id) {
-        $term = $terms_hash[$term->root_term_id];
-        $post_term['parent'] = [
-          'id'   => $term->term_id,
-          'slug' => $term->slug,
-          'name' => $term->name,
-        ];
+      }
 …
+        }
+        // Create or update parent category, if needed
+        $parent_api_term_id = false;
+        if (array_key_exists('parent', $post_term)) {
+          $api_term_id = get_term_meta($post_term['parent']['id'], 'api_term_id', true);
+          $api_term_need_update = get_term_meta($post_term['parent']['id'], 'crowdaa_need_sync', true);
+          $sync_version = get_term_meta($post_term['parent']['id'], 'crowdaa_version', true);
+          if (!$api_term_id || !array_key_exists($api_term_id, $cat_array)) {
+            $api_term_id = array_search(strtolower(trim($post_term['parent']['slug'])), $cat_array);
+            if ($api_term_id !== false) {
+              update_term_meta($post_term['parent']['id'], 'api_term_id', $api_term_id);
+            }
+          }
+          $plain_term_name = html_entity_decode($post_term['parent']['name'], ENT_QUOTES);
+          if(!$api_term_id || !array_key_exists($api_term_id, $cat_array)) {
+            $api_term_id = $sync_api->create_category_api($post_term['parent']['id'], $plain_term_name, $post_term['parent']['slug'], '');
+            $cat_array[$api_term_id] = $post_term['parent']['slug'];
+          } elseif($api_term_need_update !== 'no' || $sync_version !== Crowdaa_Sync_Versions::get_version()) {
+            $sync_api->update_category_api($api_term_id, $post_term['parent']['id'], $plain_term_name, $post_term['parent']['slug'], '');
+          }
+          $parent_api_term_id = $api_term_id;
+        }
+        $api_term_id = get_term_meta($post_term['id'], 'api_term_id', true);
+        $api_term_need_update = get_term_meta($post_term['id'], 'crowdaa_need_sync', true);
+        $sync_version = get_term_meta($post_term['id'], 'crowdaa_version', true);
+        if (!$api_term_id || !array_key_exists($api_term_id, $cat_array)) {
+          $api_term_id = array_search(strtolower(trim($post_term['slug'])), $cat_array);
+          if ($api_term_id !== false) {
+            update_term_meta($post_term['id'], 'api_term_id', $api_term_id);
+          }
+        }
+        $plain_term_name = html_entity_decode($post_term['name'], ENT_QUOTES);
+        if(!$api_term_id || !array_key_exists($api_term_id, $cat_array)) {
+          $api_term_id = $sync_api->create_category_api($post_term['id'], $plain_term_name, $post_term['slug'], $parent_api_term_id ?: '');
+          $cat_array[$api_term_id] = $post_term['slug'];
+        } elseif($api_term_need_update !== 'no' || $sync_version !== Crowdaa_Sync_Versions::get_version()) {
+          $sync_api->update_category_api($api_term_id, $post_term['id'], $plain_term_name, $post_term['slug'], $parent_api_term_id ?: '');
+        // Get category API ID
+        $api_term_id = $cat_wp_to_api_id[$post_term['id']];
+        if (!$api_term_id) {
+          throw new Crowdaa_Sync_Post_Error('Could not find synced category for term '.$post_term['id'].'. This should not happen, aborting sync.');
+          continue;
+        }

crowdaa-sync/tags/1.2.0/admin/class-crowdaa-sync-add-info-wp.php

-                      r2620193
+                      r2744975
+  }
+  /**
+   * Create term
+   *
+   * @since    1.0.0
+   * @param $cat_id
+   * @param $cat_name
+   * @return int
+   */
+  /** @TODO That whole function was rewritten to handle more edge-cases and was not tested, test it! */
+  public function get_or_create_term($cat_id, $cat_name) {
+    $cat_name = esc_html($cat_name);
+    $post_type_taxonomy = 'category';
+    $terms = get_terms([
+      'hide_empty' => false,
+      'taxonomy' => $post_type_taxonomy,
+      'meta_query' => [
+        [
+           'key'       => 'api_term_id',
+           'value'     => $cat_id,
+           'compare'   => '=',
+        ],
+      ],
+  private function create_permission($name, $description, $public) {
+    global $wpdb;
+    $fields = [
+      'name' => $name,
+      'description' => $description,
+      'allow_signups' => $public ? 1 : 0,
+      'initial_payment' => 0.0,
+      'billing_amount' => 0.0,
+    ];
+    $insCount = $wpdb->insert(
+      $wpdb->pmpro_membership_levels,
+      $fields,
+      Crowdaa_Sync_Utils::wpdb_formats_for($fields)
+    );
+    if (!$insCount) {
+      throw new Crowdaa_Sync_Badge_Error('Could not insert permission named "'.$name.'" in SQL database');
+    }
+    $fields['id'] = $wpdb->insert_id;
+    return ((object) $fields);
+  }
+  private function update_permission($wp_id, $name, $description, $public) {
+    global $wpdb;
+    $fields = [
+      'name' => $name,
+      'description' => $description,
+      'allow_signups' => $public ? 1 : 0,
+    ];
+    $where = ['id' => $wp_id];
+    $updCount = $wpdb->update(
+      $wpdb->pmpro_membership_levels,
+      $fields,
+      $where,
+      Crowdaa_Sync_Utils::wpdb_formats_for($fields),
+      Crowdaa_Sync_Utils::wpdb_formats_for($where)
+    );
+    if (!$updCount) {
+      throw new Crowdaa_Sync_Badge_Error('Could not update permission named "'.$name.'" in SQL database');
+    }
+    $fields['id'] = $wp_id;
+    return ((object) $fields);
+  }
+  private function remove_permission($wp_id) {
+    global $wpdb;
+    $where = ['id' => $wp_id];
+    $where2 = ['membership_id' => $wp_id];
+    $formats2 = Crowdaa_Sync_Utils::wpdb_formats_for($where2);
+    $wpdb->delete(
+      $wpdb->pmpro_membership_levels,
+      $where,
+      Crowdaa_Sync_Utils::wpdb_formats_for($where)
+    );
+    $wpdb->delete($wpdb->pmpro_membership_orders,      $where2, $formats2);
+    $wpdb->delete($wpdb->pmpro_memberships_categories, $where2, $formats2);
+    $wpdb->delete($wpdb->pmpro_memberships_pages,      $where2, $formats2);
+    $wpdb->delete($wpdb->pmpro_memberships_users,      $where2, $formats2);
+    $where3 = ['pmpro_membership_level_id' => $wp_id];
+    $formats3 = Crowdaa_Sync_Utils::wpdb_formats_for($where3);
+    $wpdb->delete($wpdb->pmpro_membership_levelmeta,   $where3, $formats3);
+  }
+  private function create_term($name, $slug, $parentId, $badges) {
+    $term_data = wp_insert_term(esc_html($name), 'category', [
+      'parent' => $parentId ?: 0,
+      'slug'   => $slug ?: '',
     ]);
+    if (is_wp_error($terms) || !is_array($terms) || count($terms) === 0) {
+      $terms = get_terms([
+        'hide_empty' => false,
+        'taxonomy' => $post_type_taxonomy,
+        'name' => $cat_name,
+      ]);
+    }
+    if (!is_wp_error($terms) && is_array($terms) && count($terms) > 0) {
+      $term_by_name = null;
+      foreach ($terms as $term) {
+        $key = get_term_meta($term->term_id, 'api_term_id', false);
+        if ($key === $cat_id) {
+          if ($term->name !== $cat_name) {
+            wp_update_term($term->term_id, $post_type_taxonomy, [
+              'name' => $cat_name,
+              'parent' => $term->parent,
+              'slug' => $term->slug,
+              'description' => $term->description,
+            ]);
+            update_term_meta($term->term_id, 'crowdaa_need_sync', 'no');
+            update_term_meta($term->term_id, 'crowdaa_version', Crowdaa_Sync_Versions::get_version());
+    $term = get_term($term_data['term_id'], 'category');
+    if (Crowdaa_Sync_Utils::have_plugin('paid-memberships-pro') && $badges) {
+      global $wpdb;
+      if (isset($badges->list) && count($badges->list) > 0) {
+        $sync_db = new Crowdaa_Sync_Syncdb('user_badges');
+        foreach ($badges->list as $item) {
+          $sync_obj = $sync_db->get_entry_with_api_id($item->id, 'wp_id');
+          Crowdaa_Sync_Utils::quick_insert(
+            $wpdb->pmpro_memberships_categories,
+            [
+              'membership_id' => $sync_obj->wp_id,
+              'category_id' => $term->term_id,
+            ]
+          );
+        }
+      }
+    }
+    return ($term);
+  }
+  private function update_term($term_id, $name, $slug, $parentId, $badges) {
+    wp_update_term($term_id, 'category', [
+      'name'   => esc_html($name),
+      'parent' => $parentId ?: 0,
+      'slug'   => $slug ?: '',
+    ]);
+    if (Crowdaa_Sync_Utils::have_plugin('paid-memberships-pro') && $badges) {
+      global $wpdb;
+      if (isset($badges->list) && is_array($badges->list)) {
+        $sync_db = new Crowdaa_Sync_Syncdb('user_badges');
+        $current_memberships = Crowdaa_Sync_Utils::quick_select($wpdb->pmpro_memberships_categories, [
+          'category_id' => $term_id,
+        ], ['membership_id']);
+        $membership_hash = [];
+        foreach ($current_memberships as $membership) {
+          $membership_hash[$membership->membership_id] = true;
+        }
+        foreach ($badges->list as $item) {
+          $sync_obj = $sync_db->get_entry_with_api_id($item->id, 'wp_id');
+          if (!isset($membership_hash[$sync_obj->wp_id])) {
+            Crowdaa_Sync_Utils::quick_insert(
+              $wpdb->pmpro_memberships_categories,
+              [
+                'membership_id' => $sync_obj->wp_id,
+                'category_id' => $term_id,
+              ]
+            );
+          } else {
+            unset($membership_hash[$sync_obj->wp_id]);
+          }
+          return $term->term_id;
+        } else if (!$term_by_name && $key === false && $term->name === $cat_name) {
+          $term_by_name = $term;
+        }
+      }
+      if ($term_by_name) {
+        update_term_meta($term_by_name->term_id, 'crowdaa_need_sync', 'no');
+        update_term_meta($term_by_name->term_id, 'crowdaa_version', Crowdaa_Sync_Versions::get_version());
+        return ($term_by_name->term_id);
+      }
+    }
+    $term_id         = '';
+    $data = [
+      'description' => '',
+      'parent'      => 0,
+      'slug'        => '',
+    ];
+    $term = wp_insert_term($cat_name, $post_type_taxonomy, $data);
+    if(!is_wp_error($term)) {
+      $term_id = $term['term_id'];
+      update_term_meta($term_id, 'api_term_id', $cat_id);
+      update_term_meta($term_id, 'crowdaa_need_sync', 'no');
+      update_term_meta($term_id, 'crowdaa_version', Crowdaa_Sync_Versions::get_version());
+    }
+    return $term_id;
+        }
+        foreach ($membership_hash as $membership_id => $true) {
+          Crowdaa_Sync_Utils::quick_delete($wpdb->pmpro_memberships_categories, [
+            'category_id' => $term_id,
+            'membership_id' => $membership_id,
+          ]);
+        }
+      }
+    }
+    $term = get_term($term_id, 'category');
+    return ($term);
+  }
+  private function delete_term($term_id) {
+    wp_delete_term($term_id, 'category');
+  }
+  public function sync_badges_wp(
+    &$api_to_wp,
+    &$only_api,
+    &$remove_wp
+  ) {
+    $errors            = [];
+    $sync_db           = new Crowdaa_Sync_Syncdb('user_badges');
+    $badges_sync_to_wp = array_merge($api_to_wp, $only_api, $remove_wp);
+    foreach($badges_sync_to_wp as $curBadgeId => $curBadge) {
+      Crowdaa_Sync_Timer::check();
+      Crowdaa_Sync_Logs::log('Syncing API>WP Badge', $curBadgeId, wp_json_encode($curBadge));
+      if (in_array($curBadge, $only_api, true)) {
+        $permission = $this->create_permission($curBadge['name'], $curBadge['description'], $curBadge['public']);
+        $sync_db->create_entry($permission->id, $curBadge['api_id'], [
+          'badge_hash' => $curBadge['hash'],
+          'membership_hash' => Crowdaa_Sync_Add_Info_API::hash_pmpro_membership($permission),
+        ]);
+      } else if (in_array($curBadge, $api_to_wp, true)) {
+        $permission = $this->update_permission($curBadge['wp_id'], $curBadge['name'], $curBadge['description'], $curBadge['public']);
+        $sync_db->update_entry(['wp_id' => $curBadge['wp_id']], [
+          'sync_data' => [
+            'badge_hash' => $curBadge['hash'],
+            'membership_hash' => Crowdaa_Sync_Add_Info_API::hash_pmpro_membership($permission),
+          ],
+        ]);
+      } else if (in_array($curBadge, $remove_wp, true)) {
+        $this->remove_permission($curBadge['wp_id']);
+        $sync_db->delete_entry(['wp_id' => $curBadge['wp_id']]);
+      }
+    }
+    if (count($badges_sync_to_wp) > 0) {
+      Crowdaa_Sync_Logs::log(
+        'Created/updated WP permissions',
+        count($only_api).' permissions created, '.
+        count($api_to_wp).' permissions updated and '.
+        count($remove_wp).' permissions removed with '.
+        count($errors).' errors'
+      );
+    }
+    return ($errors);
+  }
+  public function sync_categories_wp(
+    &$api_to_wp,
+    &$only_api,
+    &$remove_wp
+  ) {
+    $errors                = [];
+    $sync_db               = new Crowdaa_Sync_Syncdb('categories');
+    $categories_sync_to_wp = array_merge($api_to_wp, $only_api, $remove_wp);
+    foreach($categories_sync_to_wp as $curCategoryId => $curCategory) {
+      Crowdaa_Sync_Timer::check();
+      Crowdaa_Sync_Logs::log('Syncing API>WP Category', $curCategoryId, wp_json_encode($curCategory));
+      if (in_array($curCategory, $only_api, true)) {
+        $parentId = null;
+        if ($curCategory['parentId']) {
+          $parentId = $sync_db->get_entry_with_api_id($curCategory['parentId'], 'wp_id');
+          $parentId = $parentId->wp_id;
+        }
+        $term = $this->create_term($curCategory['name'], $curCategory['slug'], $parentId, $curCategory['badges']);
+        $term->rootParentId = $parentId;
+        $sync_db->create_entry($term->term_id, $curCategory['api_id'], [
+          'category_hash' => $curCategory['hash'],
+          'term_hash' => Crowdaa_Sync_Add_Info_API::hash_term($term),
+        ]);
+      } else if (in_array($curCategory, $api_to_wp, true)) {
+        $parentId = null;
+        if ($curCategory['parentId']) {
+          $parentId = $sync_db->get_entry_with_api_id($curCategory['parentId'], 'wp_id');
+          $parentId = $parentId->wp_id;
+        }
+        $term = $this->update_term($curCategory['wp_id'], $curCategory['name'], $curCategory['slug'], $parentId, $curCategory['badges']);
+        $term->rootParentId = $parentId;
+        $sync_db->update_entry(['wp_id' => $curCategory['wp_id']], [
+          'sync_data' => [
+            'category_hash' => $curCategory['hash'],
+            'term_hash' => Crowdaa_Sync_Add_Info_API::hash_term($term),
+          ],
+        ]);
+      } else if (in_array($curCategory, $remove_wp, true)) {
+        $this->delete_term($curCategory['wp_id']);
+        $sync_db->delete_entry(['wp_id' => $curCategory['wp_id']]);
+      }
+    }
+    if (count($categories_sync_to_wp) > 0) {
+      Crowdaa_Sync_Logs::log(
+        'Created/updated WP categories',
+        count($only_api).' categories created, '.
+        count($api_to_wp).' categories updated and '.
+        count($remove_wp).' categories removed with '.
+        count($errors).' errors'
+      );
+    }
+    return ($errors);
+  }
 …
   private function create_wp_post_from_api($api_data) {
     $created_posts  = [];
+    $categories = $this->get_or_create_term($api_data->category->_id, $api_data->category->name);
+    $cat_sync_db    = new Crowdaa_Sync_Syncdb('categories');
+    $term = $cat_sync_db->get_entry_with_api_id($api_data->category->_id, 'wp_id');
+    $term = get_term($term->wp_id, 'category');
     $post_data = [
 …
     $post_type_taxonomy = 'category';
     wp_set_post_terms($wp_post_id, [$categories], $post_type_taxonomy);
+    wp_set_post_terms($wp_post_id, [$term], $post_type_taxonomy);
     $sync_errors = $this->post_sync_api_medias($api_data, $wp_post_id);
 …
     $created_posts  = [];
+    $categories = $this->get_or_create_term($api_data->category->_id, $api_data->category->name);
+    $term = $cat_sync_db->get_entry_with_api_id($api_data->category->_id, 'wp_id');
+    $term = get_term($term->wp_id, 'category');
     $data = [
 …
     $post_type_taxonomy = 'category';
     wp_set_post_terms($wp_post_id, [$categories], $post_type_taxonomy);
+    wp_set_post_terms($wp_post_id, [$term], $post_type_taxonomy);
     wp_update_post($data);
     update_post_meta($wp_post_id, 'api_post_id', $api_data->_id);
 …
    */
   private function get_uploads($img_url, $img_name) {
+    $wp_upload_dir = wp_upload_dir();
+    $file_path     = $wp_upload_dir['basedir'].'/'.'catalogue_images/'.$img_name;
     Crowdaa_Sync_Logs::log('Downloading media to Wordpress',
       'img_url='.$img_url,
       'img_name='.$img_name,
+      'img_path='.$file_path,
     );
 …
         'timeout'         => 45,
         'stream'          => true,
         'filename'        => $upload_fname,
+        'filename'        => $file_path,
         'sslcertificates' => CROWDAA_SYNC_CACERT_PATH,
       ]);

crowdaa-sync/tags/1.2.0/admin/class-crowdaa-sync-admin-display.php

-                      r2722017
+                      r2744975
    * @since    1.0.0
    */
+  public function database_reset() {
+    if(empty($_POST) || !wp_verify_nonce($_POST['crowdaa_reset'], 'crowdaa_reset_data')) {
+      return;
+    }
+    Crowdaa_Sync_Logs::log('Running database reset');
+    update_option('crowdaa_cron_sync_enabled', 'no');
+    if (Crowdaa_Sync_Utils::have_plugin('paid-memberships-pro')) {
+      $sync_db = new Crowdaa_Sync_Syncdb('user_badges');
+      $sync_db->reset();
+    }
+    $sync_db = new Crowdaa_Sync_Syncdb('categories');
+    $sync_db->reset();
+    $table = Crowdaa_Sync_Utils::db_prefix().'postmeta';
+    Crowdaa_Sync_Utils::quick_query("DELETE FROM `$table` WHERE meta_key = %s", ['api_picture_id']);
+    Crowdaa_Sync_Utils::quick_query("DELETE FROM `$table` WHERE meta_key = %s", ['api_videos_id']);
+    Crowdaa_Sync_Utils::quick_query("DELETE FROM `$table` WHERE meta_key = %s", ['api_feedpicture_id']);
+    Crowdaa_Sync_Utils::quick_query("DELETE FROM `$table` WHERE meta_key = %s", ['api_media_map']);
+    Crowdaa_Sync_Utils::quick_query("DELETE FROM `$table` WHERE meta_key = %s", ['api_post_id']);
+    Crowdaa_Sync_Utils::quick_query("DELETE FROM `$table` WHERE meta_key LIKE 'crowdaa_%'");
+    $table = Crowdaa_Sync_Utils::db_prefix().'termmeta';
+    Crowdaa_Sync_Utils::quick_query("DELETE FROM `$table` WHERE meta_key = %s", ['api_term_id']);
+    Crowdaa_Sync_Utils::quick_query("DELETE FROM `$table` WHERE meta_key LIKE 'crowdaa_%'");
+    Crowdaa_Sync_Versions::bump_version();
+    Crowdaa_Sync_Logs::log('Database reset done');
+  }
   public function enable_sync() {
     if(!isset($_POST['crowdaa_cron_sync_enabled']) || !wp_verify_nonce($_POST['crowdaa_cron_sync_enabled'], 'crowdaa_cron_sync_enabled_data')) {
 …
     } else {
       update_option('crowdaa_sync_wpapi_register_enabled', 'no');
+    }
+    if(isset($_POST['sync_perm_plugin'])) {
+      update_option('crowdaa_sync_perm_plugin', $_POST['sync_perm_plugin']);
+    }
 …
       'WP-API register' => get_option('crowdaa_sync_wpapi_register_enabled') === 'yes',
       'duration' => get_option('crowdaa_sync_max_duration', 60),
+      'perm_plugin' => get_option('crowdaa_sync_perm_plugin', '-'),
     ];
     $sync_logs = apply_filters('crowdaa_sync_configure_levers_log', $sync_logs);

crowdaa-sync/tags/1.2.0/admin/class-crowdaa-sync-api.php

-                      r2722017
+                      r2744975
+  }
+  public function get_badges() {
+    $url = '/userBadges';
+    $response = $this->http_request('GET', $url);
+    $err = is_wp_error($response) ? $response->get_error_message() : null;
+    if (!$err) {
+      $body = wp_remote_retrieve_body($response);
+      $json = json_decode($body);
+    }
+    if ($err) {
+      Crowdaa_Sync_Logs::log('Get badges query error', $err);
+      return ((object) [
+        'message' => $err,
+      ]);
+    }
+    if (isset($json->message)) {
+      Crowdaa_Sync_Logs::log('Get badges error', $json->message);
+    }
+    foreach ($json->userBadges as &$v) {
+      if (!isset($v->management)) {
+        $v->management = 'private-internal';
+      }
+      if (!isset($v->access)) {
+        $v->access = 'hidden';
+      }
+    }
+    return ($json->userBadges);
+  }
   /**
 …
         $gallery_ids = array_diff($gallery_ids, $bad_ids);
         if (count($gallery_ids) === 0 && !$thumbnail_id) {
           throw new Crowdaa_Sync_Post_Error(__('No picture could be synchronized for post ').$wp_post_id);
+          throw new Crowdaa_Sync_Post_Error(__('No picture could be synchronized for post ', CROWDAA_SYNC_PLUGIN_NAME).$wp_post_id);
+        }
+      }
 …
+  }
+  public function create_badge($name, $description, $public) {
+    $data = [
+      'name'          => $name,
+      'description'   => $description,
+      'management'    => $public ? 'public' : 'private-internal',
+      'access'        => 'teaser',
+      'isDefault'     => false,
+      'validationUrl' => '',
+    ];
+    $data = apply_filters('crowdaa_sync_api_create_badge_payload', $data);
+    $response = $this->http_request('POST', '/userBadges', $data);
+    $err      = is_wp_error($response) ? $response->get_error_message() : null;
+    if (!$err) {
+      $body = wp_remote_retrieve_body($response);
+      $json = json_decode($body);
+    }
+    if ($err) {
+      Crowdaa_Sync_Logs::log('Create badge query error', $name, $err);
+      throw new Crowdaa_Sync_Post_Error(__('Query error during badge creation : ', CROWDAA_SYNC_PLUGIN_NAME).$err);
+    } else {
+      if (isset($json->message)) {
+        Crowdaa_Sync_Logs::log('Create badge error', $name, $json->message);
+        throw new Crowdaa_Sync_Post_Error(__('API error during badge creation : ', CROWDAA_SYNC_PLUGIN_NAME).$json->message);
+      }
+      Crowdaa_Sync_Logs::log('Created badge', wp_json_encode($json->userBadge));
+      return ($json->userBadge);
+    }
+  }
+  public function update_badge($badge_id, $name, $description, $public) {
+    $data = [
+      'name'          => $name,
+      'description'   => $description,
+      'management'    => $public ? 'public' : 'private-internal',
+      'access'        => 'teaser',
+      'isDefault'     => false,
+      'validationUrl' => '',
+    ];
+    $data = apply_filters('crowdaa_sync_api_update_badge_payload', $data);
+    $response = $this->http_request('PUT', "/userBadges/$badge_id", $data);
+    $err      = is_wp_error($response) ? $response->get_error_message() : null;
+    if (!$err) {
+      $body = wp_remote_retrieve_body($response);
+      $json = json_decode($body);
+    }
+    if ($err) {
+      Crowdaa_Sync_Logs::log('Update badge query error', $name, $err);
+      throw new Crowdaa_Sync_Post_Error(__('Query error during badge update : ', CROWDAA_SYNC_PLUGIN_NAME).$err);
+    } else {
+      if (isset($json->message)) {
+        Crowdaa_Sync_Logs::log('Update badge error', $name, $json->message);
+        throw new Crowdaa_Sync_Post_Error(__('API error during badge update : ', CROWDAA_SYNC_PLUGIN_NAME).$json->message);
+      }
+      Crowdaa_Sync_Logs::log('Updated badge', wp_json_encode($json->userBadge));
+      return ($json->userBadge);
+    }
+  }
+  public function remove_badge($badge_id) {
+    $response = $this->http_request('DELETE', "/userBadges/$badge_id");
+    $err      = is_wp_error($response) ? $response->get_error_message() : null;
+    if (!$err) {
+      $body = wp_remote_retrieve_body($response);
+      $json = json_decode($body);
+    }
+    if ($err) {
+      Crowdaa_Sync_Logs::log('Delete badge query error', $name, $err);
+      throw new Crowdaa_Sync_Post_Error(__('Query error during badge delete : ', CROWDAA_SYNC_PLUGIN_NAME).$err);
+    } else {
+      if (isset($json->message)) {
+        Crowdaa_Sync_Logs::log('Delete badge error', $name, $json->message);
+        throw new Crowdaa_Sync_Post_Error(__('API error during badge delete : ', CROWDAA_SYNC_PLUGIN_NAME).$json->message);
+      }
+      Crowdaa_Sync_Logs::log('Deleted badge', $badge_id);
+    }
+    return (true);
+  }
   /**
    * Create category on the API
 …
    * @return boolean
    */
   public function create_category_api($term_id, $cat_name, $cat_slug, $parent_category_id = '') {
+  public function create_category($cat_name, $cat_slug, $parent_category_id, $badges) {
     $data = [
       'name'     => $cat_name,
 …
       'action'   => '',
     ];
+    if (is_array($badges)) {
+      $data['badges'] = $badges;
+      $data['badgesAllow'] = 'all';
+    }
     $data = apply_filters('crowdaa_sync_api_create_category_payload', $data);
 …
     if ($err) {
       Crowdaa_Sync_Logs::log('Create category query error', $cat_name, $err);
       throw new Crowdaa_Sync_Post_Error(__('Query error during category creation : ', CROWDAA_SYNC_PLUGIN_NAME).$err);
+      throw new Crowdaa_Sync_Category_Error(__('Query error during category creation : ', CROWDAA_SYNC_PLUGIN_NAME).$err);
     } else {
       if (isset($json->message)) {
         Crowdaa_Sync_Logs::log('Create category error', $cat_name, $json->message);
+        throw new Crowdaa_Sync_Post_Error(__('API error during category creation : ', CROWDAA_SYNC_PLUGIN_NAME).$json->message);
+      }
+      if ($term_id) {
+        update_term_meta($term_id, 'api_term_id', $json->_id);
+        update_term_meta($term_id, 'crowdaa_version', Crowdaa_Sync_Versions::get_version());
+        update_term_meta($term_id, 'crowdaa_need_sync', 'no');
+        throw new Crowdaa_Sync_Category_Error(__('API error during category creation : ', CROWDAA_SYNC_PLUGIN_NAME).$json->message);
+      }
       Crowdaa_Sync_Logs::log('Created category', $cat_name, $json->_id);
+      return ($json->_id);
+      return ($json);
+    }
+  }
 …
    * @return boolean
    */
   public function update_category_api($cat_id, $term_id, $cat_name, $cat_slug, $parent_category_id = '') {
+  public function update_category($cat_id, $cat_name, $cat_slug, $parent_category_id, $badges) {
     $data = [
       'name'     => $cat_name,
 …
       // 'order'    => null,
     ];
+    if (is_array($badges)) {
+      $data['badges'] = $badges;
+      $data['badgesAllow'] = 'all';
+    }
     $data = apply_filters('crowdaa_sync_api_update_category_payload', $data);
 …
     if ($err) {
       Crowdaa_Sync_Logs::log('Updated category query error', $cat_name, $err);
       throw new Crowdaa_Sync_Post_Error(__('Query error during category update : ', CROWDAA_SYNC_PLUGIN_NAME).$err);
+      throw new Crowdaa_Sync_Category_Error(__('Query error during category update : ', CROWDAA_SYNC_PLUGIN_NAME).$err);
     } else {
       if (isset($json->message)) {
         Crowdaa_Sync_Logs::log('Updated category error', $json->message);
+        throw new Crowdaa_Sync_Post_Error(__('API error during category update : ', CROWDAA_SYNC_PLUGIN_NAME).$json->message);
+      }
+      update_term_meta($term_id, 'api_term_id', $cat_id);
+      update_term_meta($term_id, 'crowdaa_version', Crowdaa_Sync_Versions::get_version());
+      update_term_meta($term_id, 'crowdaa_need_sync', 'no');
+        throw new Crowdaa_Sync_Category_Error(__('API error during category update : ', CROWDAA_SYNC_PLUGIN_NAME).$json->message);
+      }
       Crowdaa_Sync_Logs::log('Updated category', $cat_name);
+      /** API just returns 'true', so we must rebuild the object as it would have been returned... */
+      $ret = (object) $data;
+      $ret->_id = $cat_id;
+      if (is_array($badges)) {
+        $ret_badges = [];
+        foreach ($badges as $badge_id) {
+          $ret_badges[] = (object) ['id' => $badge_id];
+        }
+        $ret->badges = (object) [
+          'list' => $ret_badges,
+          'allow' => $data['badgesAllow'],
+        ];
+      }
+      return ($ret);
+    }
+  }
+  public function delete_category($cat_id) {
+    $response = $this->http_request('DELETE', '/press/categories/'.$cat_id);
+    $err    = is_wp_error($response) ? $response->get_error_message() : null;
+    if (!$err) {
+      $body = wp_remote_retrieve_body($response);
+      $json = json_decode($body);
+    }
+    if ($err) {
+      Crowdaa_Sync_Logs::log('Deleted category query error', $cat_name, $err);
+      throw new Crowdaa_Sync_Category_Error(__('Query error during category delete : ', CROWDAA_SYNC_PLUGIN_NAME).$err);
+    } else {
+      if (isset($json->message)) {
+        Crowdaa_Sync_Logs::log('Deleted category error', $json->message);
+        throw new Crowdaa_Sync_Category_Error(__('API error during category delete : ', CROWDAA_SYNC_PLUGIN_NAME).$json->message);
+      }
+      Crowdaa_Sync_Logs::log('Deleted category', $cat_name);
+    }
+  }

crowdaa-sync/tags/1.2.0/admin/class-crowdaa-sync-ext-hooks.php

-                      r2722017
+                      r2744975
+    }
+    if (Crowdaa_Sync_Utils::have_plugin('paid-memberships-pro')) {
+      global $wpdb;
+      $user_memberships = Crowdaa_Sync_Utils::quick_select($wpdb->pmpro_memberships_users, [
+        'user_id' => $user->data->ID,
+        'status' => 'active',
+      ], 'id');
+      if (count($user_memberships) > 0) {
+        $sync_db = new Crowdaa_Sync_Syncdb('user_badges');
+        $wp_ids = Crowdaa_Sync_Utils::object_array_extract_field('id', $user_memberships);
+        $synced = $sync_db->get_entry_with_wp_id($wp_ids, 'api_id');
+        $api_ids = Crowdaa_Sync_Utils::object_array_extract_field('api_id', $synced);
+        $data['user_badges'] = $api_ids;
+      }
+    }
+    /**
+     * @TODO Use that in the API.
+     */
     return ($data);
+  }

crowdaa-sync/tags/1.2.0/admin/class-crowdaa-sync-wp-hooks.php

-                      r2620193
+                      r2744975
     add_action('save_post', [$this, 'save_post_without_cat_notice']);
     add_action('save_post', [$this, 'set_need_to_sync_for_post']);
-    add_action('saved_category', [$this, 'set_need_to_sync_for_category']);
     add_action('admin_notices', [$this, 'sync_admin_notice']);
     add_action('before_delete_post', [$this, 'sync_delete_post']);
 …
   /**
-   * Set need sync option for category synchronization
+   *
-   * @since    1.0.0
-   * @param $post_id
-   * @return void
-   */
-  public function set_need_to_sync_for_category($term_id) {
-    update_term_meta($term_id, 'crowdaa_need_sync', 'yes');
+  }
-  /**
    * Hide deleted post from WP to API
+   *

crowdaa-sync/tags/1.2.0/admin/css/crowdaa-sync-admin.css

-                      r2722017
+                      r2744975
   margin-bottom: 10px;
+}
+#crowdaa-reset-form {
+  display: none;
+  position: fixed;
+  top: 0;
+  left: 0;
+  right: 0;
+  bottom: 0;
+  background-color: rgba(88, 88, 88, 0.88);
+  text-align: center;
+  padding: 50px 0;
+  z-index: 100000;
+}
+#crowdaa-reset-form > div {
+  background-color: white;
+  padding: 20px 40px 40px;
+  display: inline-block;
+  text-align: left;
+}
+#crowdaa-reset-form ul {
+  padding-left: 20px;
+}
+#crowdaa-reset-form li {
+  list-style: initial;
+}
+.crowdaa-reset-danger {
+  background-color: rgb(255, 0, 0);
+  color: white;
+  font-weight: bold;
+  border: none;
+  border-radius: 10px;
+  padding: 8px 14px;
+}
+.crowdaa-reset-danger:hover {
+  background-color: rgb(206, 0, 0);
+  cursor: pointer;
+}
+.crowdaa-reset-form-buttons {
+  display: flex;
+  justify-content: space-between;
+  padding-top: 30px;
+}
+#crowdaa-reset-dismiss {
+  background-color: rgb(73, 189, 58);
+  color: white;
+  font-weight: bold;
+  border: none;
+  border-radius: 10px;
+  padding: 8px 14px;
+}
+#crowdaa-reset-dismiss:hover {
+  background-color: rgb(54, 143, 43);
+  cursor: pointer;
+}

crowdaa-sync/tags/1.2.0/admin/js/crowdaa-sync-admin.js

-                      r2722017
+                      r2744975
+    }
     function renderOpQueueFor(data, field) {
+    function renderOpQueueForArticle(data, field) {
       const list = data[field];
       if (!list) {
         return('<ul><li>No posts</li></ul>');
+        return(false);
+      }
       if (list === 'disabled') {
 …
+      }
       if (list.length === 0) {
         return('<ul><li>No posts</li></ul>');
+        return(false);
+      }
       const render = list.reduce(function(acc, item) {
         acc += '<li class="' + field + '"><i>' +
           'Post title: <strong>' + item.post_name + '</strong> ' +
           'Post CMS ID: <strong>' + (item.api_id ? item.api_id : 'New post') + '</strong>' +
+          'Post title: <strong>' + escapeHtml(item.post_name) + '</strong> ' +
+          'Post CMS ID: <strong>' + escapeHtml(item.api_id ? item.api_id : 'New post') + '</strong>' +
           '</i></li>';
         return(acc);
 …
+    }
+    function renderOpQueue(data) {
+    function renderOpQueueForCategory(data, field) {
+      const list = data[field];
+      if (!list) {
+        return(false);
+      }
+      if (list === 'disabled') {
+        return('<ul><li>Synchronization disabled</li></ul>');
+      }
+      if (list.length === 0) {
+        return(false);
+      }
+      const render = list.reduce(function(acc, item) {
+        acc += '<li class="' + field + '"><i title="' + escapeHtml(item.slug || '') + '">';
+        if (item.name) {
+          acc += 'Category : <strong>' + escapeHtml(item.name) + '</strong>';
+        } else if (item.wp_id) {
+          acc += 'WP Category ID : <strong>' + escapeHtml(item.wp_id) + '</strong>';
+        } else if (item.api_id) {
+          acc += 'API Category ID : <strong>' + escapeHtml(item.api_id) + '</strong>';
+        }
+        acc += '</i></li>';
+        return(acc);
+      }, '');
+      return ('<ul>' + render + '</ul>');
+    }
+    function renderOpQueueForBadge(data, field) {
+      const list = data[field];
+      if (!list) {
+        return(false);
+      }
+      if (list === 'disabled') {
+        return('<ul><li>Synchronization disabled</li></ul>');
+      }
+      if (list.length === 0) {
+        return(false);
+      }
+      const render = list.reduce(function(acc, item) {
+        acc += '<li class="' + field + '"><i title="' + escapeHtml(item.description || '') + '">';
+        if (item.name) {
+          acc += 'Permission : <strong>' + escapeHtml(item.name) + '</strong>';
+        } else if (item.wp_id) {
+          acc += 'WP Permission ID : <strong>' + escapeHtml(item.wp_id) + '</strong>';
+        } else if (item.api_id) {
+          acc += 'API Permission ID : <strong>' + escapeHtml(item.api_id) + '</strong>';
+        }
+        acc += '</i></li>';
+        return(acc);
+      }, '');
+      return ('<ul>' + render + '</ul>');
+    }
+    function renderOpQueue(data, showDates, renderCb) {
       let html = '';
+      html += '<h2>Synchronize elements from Crowdaa CMS to WordPress</h2>';
+      html += renderOpQueueFor(data, 'api_to_wp');
+      html += '<h2>Synchronize elements from WordPress to Crowdaa CMS</h2>';
+      html += renderOpQueueFor(data, 'wp_to_api');
+      html += '<h2>Synchronize new elements from Crowdaa CMS</h2>';
+      html += renderOpQueueFor(data, 'only_api');
+      html += '<h2>Synchronize new elements from WordPress</h2>';
+      html += renderOpQueueFor(data, 'only_wp');
+      let renderedCount = 0;
+      if (data.error) {
+        return ('<h3>' + escapeHtml(data.error) + '</h3>');
+      }
+      function renderThis(title, key) {
+        const result = renderCb(data, key);
+        if (result) {
+          html += title;
+          html += result;
+          renderedCount++;
+        }
+      }
+      renderThis('<h2>Synchronize elements from Crowdaa CMS to WordPress</h2>', 'api_to_wp');
+      renderThis('<h2>Synchronize elements from WordPress to Crowdaa CMS</h2>', 'wp_to_api');
+      renderThis('<h2>Synchronize new elements from Crowdaa CMS</h2>', 'only_api');
+      renderThis('<h2>Synchronize new elements from WordPress</h2>', 'only_wp');
+      if (data['remove_api']) renderThis('<h2>Elements to remove from Crowdaa CMS</h2>', 'remove_api');
+      if (data['remove_wp']) renderThis('<h2>Elements to remove from Wordpress</h2>', 'remove_wp');
+      if (renderedCount === 0) {
+        html += '<i>Nothing to do</i>';
+      }
       html += '<br />';
 …
+      }
+      renderSyncFrom('wp_to_api', 'WordPress to API');
+      renderSyncFrom('api_to_wp', 'API to WordPress');
+      if (showDates) {
+        renderSyncFrom('wp_to_api', 'WordPress to API');
+        renderSyncFrom('api_to_wp', 'API to WordPress');
+      }
       return(html);
 …
     $('#crowdaa-sync-categories-mode-whitelist-checkbox').on('change', updateSyncCategoriesSelect);
     updateSyncCategoriesSelect();
+    $('#crowdaa-reset-request').click(function(e) {
+      e.preventDefault();
+      $('#crowdaa-reset-form').show();
+    });
+    $('#crowdaa-reset-dismiss').click(function(e) {
+      e.preventDefault();
+      $('#crowdaa-reset-form').hide();
+    });
     /**
 …
+            }
+            if (data.opqueue.categories) {
+              if (data.error) {
+                output += '<p>Here are the categories operations that were attempted :</p>';
+              } else {
+                output += '<p>Here are the categories operations that were done :</p>';
+              }
+              output += renderOpQueue(data.opqueue.categories, false, renderOpQueueForCategory);
+            }
+            if (data.opqueue.badges) {
+              if (data.error) {
+                output += '<p>Here are the permission operations that were attempted :</p>';
+              } else {
+                output += '<p>Here are the permission operations that were done :</p>';
+              }
+              output += renderOpQueue(data.opqueue.badges, false, renderOpQueueForBadge);
+            }
             if (data.opqueue.articles) {
               if (data.error) {
                 output += '<p>Here are the articles operations that were attempted :</p>';
+                output += '<p>Here are the article operations that were attempted :</p>';
               } else {
                 output += '<p>Here are the articles operations that were done :</p>';
+                output += '<p>Here are the article operations that were done :</p>';
+              }
               output += renderOpQueue(data.opqueue.articles);
+              output += renderOpQueue(data.opqueue.articles, true, renderOpQueueForArticle);
+            }
 …
           } else {
             $opqueue.html(
+              '<p>Here are the category operations that should/will be done :</p>' +
+              renderOpQueue(data.categories, false, renderOpQueueForCategory) +
+              '<p>Here are the permission operations that should/will be done :</p>' +
+              renderOpQueue(data.badges, false, renderOpQueueForBadge) +
               '<p>Here are the article operations that should/will be done :</p>' +
               renderOpQueue(data.articles)
+              renderOpQueue(data.articles, true, renderOpQueueForArticle)
             );
+          }

crowdaa-sync/tags/1.2.0/admin/partials/crowdaa-sync-admin-display.php

-                      r2722017
+                      r2744975
   </form>
+  <form id="crowdaa-reset-form" method="post" action="<?php $admin_utils->database_reset(); ?>">
+    <?php wp_nonce_field('crowdaa_reset_data', 'crowdaa_reset'); ?>
+    <div>
+      <h3><?php esc_html_e('DO YOU REALLY WANT TO RESET THE DATABASE?', CROWDAA_SYNC_PLUGIN_NAME); ?></h3>
+      <?php esc_html_e('This action will erase all synchronization data. If you want to run a synchronization again after this step, you will either have to :', CROWDAA_SYNC_PLUGIN_NAME); ?>
+      <ul>
+        <li><?php esc_html_e('Change the targeted Crowdaa application', CROWDAA_SYNC_PLUGIN_NAME); ?></li>
+        <li><?php esc_html_e('Erase the Crowdaa app content (categories, badges and articles)', CROWDAA_SYNC_PLUGIN_NAME); ?></li>
+        <li><?php esc_html_e('Erase the Wordpress content (categories, permissions and articles)', CROWDAA_SYNC_PLUGIN_NAME); ?></li>
+      </ul>
+      <?php esc_html_e('This will also disable automatic synchronization.', CROWDAA_SYNC_PLUGIN_NAME); ?>
+      <div class="crowdaa-reset-form-buttons">
+        <button type="button" id="crowdaa-reset-dismiss">
+          <?php esc_html_e('Cancel', CROWDAA_SYNC_PLUGIN_NAME); ?>
+        </button>
+        <button type="submit" class="crowdaa-reset-danger">
+          <?php esc_html_e('RESET SYNC DATABASE', CROWDAA_SYNC_PLUGIN_NAME); ?>
+        </button>
+      </div>
+    </div>
+  </form>
+  <button type="button" class="crowdaa-reset-danger" id="crowdaa-reset-request">
+    <?php esc_html_e('RESET SYNC DATABASE', CROWDAA_SYNC_PLUGIN_NAME); ?>
+  </button>
   <?php
 …
         $sync_wpapi_register_enabled = (get_option('crowdaa_sync_wpapi_register_enabled', 'yes') === 'yes');
         $sync_max_duration           = get_option('crowdaa_sync_max_duration', 60);
+        ?>
+        <label class="sync-form-checkbox-label">
+          <span class="sync-form-label"><?php esc_html_e('Periodic synchronization enabled'); ?></span> &nbsp;
+        $sync_perm_plugin            = get_option('crowdaa_sync_perm_plugin', Crowdaa_Sync_Permissions::all_plugins_list()[0]);
+        ?>
+        <label class="sync-form-checkbox-label">
+          <span class="sync-form-label"><?php esc_html_e('Periodic synchronization enabled', CROWDAA_SYNC_PLUGIN_NAME); ?></span> &nbsp;
           <input type="checkbox" name="cron_sync_enable" class="sync-enable-checkbox"
             <?php echo ($sync_cron_enabled ? 'checked="checked"' : ''); ?>
 …
         <br />
         <label class="sync-form-checkbox-label">
           <span class="sync-form-label"><?php esc_html_e('Synchronize WordPress content to API'); ?></span> &nbsp;
+          <span class="sync-form-label"><?php esc_html_e('Synchronize WordPress content to API', CROWDAA_SYNC_PLUGIN_NAME); ?></span> &nbsp;
           <input type="checkbox" name="sync_wp_to_api_enable" class="sync-enable-checkbox"
             <?php echo ($sync_wp_to_api_enabled ? 'checked="checked"' : ''); ?>
 …
         <br />
         <label class="sync-form-checkbox-label">
           <span class="sync-form-label"><?php esc_html_e('Synchronize API content to WordPress'); ?></span> &nbsp;
+          <span class="sync-form-label"><?php esc_html_e('Synchronize API content to WordPress', CROWDAA_SYNC_PLUGIN_NAME); ?></span> &nbsp;
           <input type="checkbox" name="sync_api_to_wp_enable" class="sync-enable-checkbox"
             <?php echo ($sync_api_to_wp_enabled ? 'checked="checked"' : ''); ?>
 …
         <br />
         <label class="sync-form-checkbox-label">
           <span class="sync-form-label"><?php esc_html_e('Enable WP register from app'); ?></span> &nbsp;
+          <span class="sync-form-label"><?php esc_html_e('Enable WP register from app', CROWDAA_SYNC_PLUGIN_NAME); ?></span> &nbsp;
           <input type="checkbox" name="sync_wpapi_register_enable" class="sync-enable-checkbox"
             <?php echo ($sync_wpapi_register_enabled ? 'checked="checked"' : ''); ?>
 …
         <?php do_action('crowdaa_sync_configuration_levers'); ?>
         <label class="sync-form-checkbox-label">
           <span class="sync-form-label"><?php esc_html_e('Maximum synchronization duration (minutes)'); ?></span> &nbsp;
+          <span class="sync-form-label"><?php esc_html_e('Maximum synchronization duration (minutes)', CROWDAA_SYNC_PLUGIN_NAME); ?></span> &nbsp;
           <input type="number" name="sync_max_duration" min="2" id="sync-duration-field"
             value="<?php echo esc_attr($sync_max_duration); ?>"
           />
+        </label>
+        <br />
+        <label class="sync-form-checkbox-label">
+          <span class="sync-form-label"><?php esc_html_e('Permissions plugin', CROWDAA_SYNC_PLUGIN_NAME); ?></span> &nbsp;
+          <select class="sync-permissions-plugin-select" name="sync_perm_plugin[]">
+            <?php
+            $perm_plugins_list = Crowdaa_Sync_Permissions::plugins_list();
+            foreach ($perm_plugins_list as $plugin) { ?>
+              <option
+                value="<?php echo esc_attr($plugin); ?>"
+                <?php echo ($plugin === $sync_perm_plugin ? 'selected="selected"' : ''); ?>
+              >
+                <?php esc_html_e($plugin, CROWDAA_SYNC_PLUGIN_NAME); ?>
+              </option>
+            <?php } ?>
+          </select>
         </label>
         <br />

crowdaa-sync/tags/1.2.0/crowdaa-sync.php

-                      r2722534
+                      r2744975
  * Plugin URI:
  * Description:       Plugin for synchronizing WordPress site and Crowdaa CMS
  * Version:           1.1.1
+ * Version:           1.2.0
  * Requires at least: 5.5
  * Requires PHP:      7.2
 …
  * Uses SemVer - https://semver.org
  */
 define('CROWDAA_SYNC_VERSION', '1.1.1');
+define('CROWDAA_SYNC_VERSION', '1.2.0');
 define('CROWDAA_SYNC_PLUGIN_DIR', __DIR__);
 define('CROWDAA_SYNC_PLUGIN_NAME', 'crowdaa-sync');

crowdaa-sync/tags/1.2.0/includes/class-crowdaa-sync-exception.php

-                      r2620193
+                      r2744975
  */
 class Crowdaa_Sync_Error extends Exception {}
+/**
+ * An exception to handle errors on a single badge synchronzation, requesting to abort.
+ *
+ * @since      1.0.0
+ * @package    Crowdaa-Sync
+ * @subpackage Crowdaa-Sync/includes
+ * @author     Crowdaa <contact@crowdaa.com>
+ */
+class Crowdaa_Sync_Badge_Error extends Exception {}
+/**
+ * An exception to handle errors on a single category synchronzation, requesting to abort.
+ *
+ * @since      1.0.0
+ * @package    Crowdaa-Sync
+ * @subpackage Crowdaa-Sync/includes
+ * @author     Crowdaa <contact@crowdaa.com>
+ */
+class Crowdaa_Sync_Category_Error extends Exception {}
 /**

crowdaa-sync/tags/1.2.0/includes/class-crowdaa-sync.php

-                      r2722017
+                      r2744975
     /**
+     * The class responsible for general utils used accross the plugin.
+     */
+    require_once CROWDAA_SYNC_PLUGIN_DIR.'/includes/class-crowdaa-sync-utils.php';
+    /**
      * The class responsible logging & logs management.
      */
 …
     /**
+     * The class responsible for permissions plugins management for the plugin.
+     */
+    require_once CROWDAA_SYNC_PLUGIN_DIR.'/includes/class-crowdaa-sync-permissions.php';
+    /**
      * The class responsible for checking the execution time of this plugin.
      */
     require_once CROWDAA_SYNC_PLUGIN_DIR.'/includes/class-crowdaa-sync-timer.php';
+    /**
+     * The class responsible for handling custom synchronizations.
+     */
+    require_once CROWDAA_SYNC_PLUGIN_DIR.'/includes/class-crowdaa-sync-syncdb.php';
     /**

crowdaa-sync/trunk/CHANGELOG

-                      r2722017
+                      r2744975
 ## [Unreleased]
+## [1.2.0] - 2022-06-14
+### Added
+- Permissions/badges synchronization
+- Synchronization database reset
+### Changed
+- Separated categories synchronization from post synchronization
 ## [1.1.0] - 2022-05-11

crowdaa-sync/trunk/README.txt

r2722534	r2744975
6	6	Requires PHP: 7.3
7	7	Tested up to: 5.9
8		Stable tag: 1.~~1.1~~
	8	Stable tag: 1.2.0
9	9	License: GPLv2 or later
10	10	License URI: http://www.gnu.org/licenses/gpl-2.0.html

crowdaa-sync/trunk/admin/class-crowdaa-sync-add-info-api.php

-                      r2722017
+                      r2744975
    */
   public function get_opqueue_ajax() {
+    $categories_opqueue = $this->get_categories_opqueue();
+    $badges_opqueue = $this->get_badges_opqueue();
     $articles_opqueue = $this->get_articles_opqueue();
     wp_send_json([
       'articles' => $articles_opqueue,
+      'badges' => $badges_opqueue,
+      'categories' => $categories_opqueue,
     ]);
+  }
+  public static function hash_badge(&$badge) {
+    $data = [
+      'name' => $badge->name,
+      'description' => $badge->description,
+      'access' => $badge->access,
+      'management' => $badge->management,
+      'createdAt' => $badge->createdAt,
+    ];
+    if (isset($badge->updatedAt)) {
+      $data['updatedAt'] = $badge->updatedAt;
+    }
+    return (hash('sha256', serialize($data)));
+  }
+  public static function hash_pmpro_membership(&$membership) {
+    $data = [
+      'name'          => ''.   $membership->name,
+      'description'   => ''.   $membership->description,
+      'allow_signups' => (int) $membership->allow_signups,
+    ];
+    return (hash('sha256', serialize($data)));
+  }
+  public static function hash_term(&$term) {
+    $data = [
+      'id'          => $term->term_id,
+      'name'        => $term->name,
+      'slug'        => $term->slug,
+      'parent'      => $term->parent,
+    ];
+    if (isset($term->rootParentId)) {
+      $data['rootParentId'] = $term->rootParentId;
+    }
+    if (Crowdaa_Sync_Utils::have_plugin('paid-memberships-pro')) {
+      global $wpdb;
+      $memberships = Crowdaa_Sync_Utils::quick_select($wpdb->pmpro_memberships_categories, [
+        'category_id' => $term->term_id,
+      ], ['membership_id']);
+      $data['memberships'] = $memberships;
+    }
+    return (hash('sha256', serialize($data)));
+  }
+  public static function hash_category(&$category) {
+    $data = [
+      'id'       => $category->_id,
+      'name'     => $category->name,
+      'pathName' => $category->pathName,
+      'parentId' => $category->parentId,
+    ];
+    if (Crowdaa_Sync_Utils::have_plugin('paid-memberships-pro')) {
+      $data['badges'] = $category->badges;
+    }
+    return (hash('sha256', serialize($data)));
+  }
+  /**
+   * Get badges pending sync operations queue
+   *
+   * @since    1.0.0
+   * @return array, object
+   */
+  public function get_badges_opqueue() {
+    Crowdaa_Sync_Logs::log('Syncing, Badges OpQueue fetching');
+    $crowdaa_sync_articles_wp_to_api_enabled = (get_option('crowdaa_sync_articles_wp_to_api_enabled', 'yes') === 'yes');
+    $crowdaa_sync_articles_api_to_wp_enabled = (get_option('crowdaa_sync_articles_api_to_wp_enabled', 'yes') === 'yes');
+    $api_data_class = new Crowdaa_Sync_API();
+    $sync_db = new Crowdaa_Sync_Syncdb('user_badges');
+    if(!get_option('crowdaa_auth_token')) {
+      $result = [
+        'error' => __('User is not connected', CROWDAA_SYNC_PLUGIN_NAME),
+      ];
+      return ($result);
+    }
+    $result = [
+      'api_to_wp'  => [],
+      'wp_to_api'  => [],
+      'only_api'   => [],
+      'only_wp'    => [],
+      'remove_api' => [],
+      'remove_wp'  => [],
+    ];
+    if (!Crowdaa_Sync_Utils::have_plugin('paid-memberships-pro')) {
+      return ($result);
+    }
+    if (!$crowdaa_sync_articles_api_to_wp_enabled && !$crowdaa_sync_articles_wp_to_api_enabled) {
+      return ($result);
+    }
+    global $wpdb;
+    $badges = $api_data_class->get_badges();
+    $synced = $sync_db->get_synced_entries();
+    $memberships = Crowdaa_Sync_Utils::quick_select($wpdb->pmpro_membership_levels);
+    if (isset($badges->message)) {
+      $result = [
+        'error' => __('API query error : ', CROWDAA_SYNC_PLUGIN_NAME).$badges->message,
+      ];
+      return ($result);
+    }
+    Crowdaa_Sync_Logs::log('OpQueue building...', count($badges).' api badges and '.count($memberships).' wp permissions');
+    $badges_by_id = [];
+    foreach ($badges as $badge) {
+      $badge->hash = self::hash_badge($badge);
+      $badges_by_id[$badge->_id] = $badge;
+    }
+    $synced_by_api_id = [];
+    $synced_by_wp_id = [];
+    foreach ($synced as $item) {
+      $item->badge_hash = $item->sync_data['badge_hash'];
+      $item->membership_hash = $item->sync_data['membership_hash'];
+      $synced_by_wp_id[$item->wp_id] = $item;
+      $synced_by_api_id[$item->api_id] = $item;
+    }
+    $memberships_by_id = [];
+    foreach ($memberships as $membership) {
+      $membership->hash = self::hash_pmpro_membership($membership);
+      $memberships_by_id[$membership->id] = $membership;
+    }
+    if ($crowdaa_sync_articles_wp_to_api_enabled) {
+      foreach ($memberships_by_id as $id => $membership) {
+        if (!array_key_exists($id, $synced_by_wp_id)) {
+          $result['only_wp'][] = [
+            'api_id' => null,
+            'wp_id' => $membership->id,
+            'name' => $membership->name,
+            'description' => $membership->description,
+            'public' => !!$membership->allow_signups,
+            'hash' => $membership->hash,
+          ];
+        } else if ($synced_by_wp_id[$id]->membership_hash !== $membership->hash) {
+          $result['wp_to_api'][] = [
+            'api_id' => $synced_by_wp_id[$id]->api_id,
+            'wp_id' => $membership->id,
+            'name' => $membership->name,
+            'description' => $membership->description,
+            'public' => !!$membership->allow_signups,
+            'hash' => $membership->hash,
+          ];
+        }
+      }
+      foreach ($synced_by_wp_id as $wp_id => $synced_item) {
+        if (!array_key_exists($wp_id, $memberships_by_id)) {
+          $result['remove_api'][] = [
+            'wp_id' => null,
+            'api_id' => $synced_item->api_id,
+          ];
+        }
+      }
+    }
+    if ($crowdaa_sync_articles_api_to_wp_enabled) {
+      foreach ($badges_by_id as $id => $badge) {
+        if (!array_key_exists($id, $synced_by_api_id)) {
+          $result['only_api'][] = [
+            'api_id' => $badge->_id,
+            'wp_id' => null,
+            'name' => $badge->name,
+            'description' => $badge->description,
+            'public' => (array_search($badge->management, ['request', 'public']) !== false),
+            'hash' => $badge->hash,
+          ];
+        } else if ($synced_by_api_id[$id]->badge_hash !== $badge->hash) {
+          $result['api_to_wp'][] = [
+            'api_id' => $badge->_id,
+            'wp_id' => $synced_by_api_id[$id]->wp_id,
+            'name' => $badge->name,
+            'description' => $badge->description,
+            'public' => (array_search($badge->management, ['request', 'public']) !== false),
+            'hash' => $badge->hash,
+          ];
+        }
+      }
+      foreach ($synced_by_api_id as $api_id => $synced_item) {
+        if (!array_key_exists($api_id, $badges_by_id)) {
+          $result['remove_wp'][] = [
+            'wp_id' => $synced_item->wp_id,
+            'api_id' => null,
+          ];
+        }
+      }
+    }
+    return ($result);
+  }
+  public function get_categories_opqueue() {
+    Crowdaa_Sync_Logs::log('Syncing, Categories OpQueue fetching');
+    $crowdaa_sync_articles_wp_to_api_enabled = (get_option('crowdaa_sync_articles_wp_to_api_enabled', 'yes') === 'yes');
+    $crowdaa_sync_articles_api_to_wp_enabled = (get_option('crowdaa_sync_articles_api_to_wp_enabled', 'yes') === 'yes');
+    $result = [
+      'api_to_wp'  => [],
+      'wp_to_api'  => [],
+      'only_api'   => [],
+      'only_wp'    => [],
+      'remove_api' => [],
+      'remove_wp'  => [],
+    ];
+    if (!$crowdaa_sync_articles_api_to_wp_enabled && !$crowdaa_sync_articles_wp_to_api_enabled) {
+      return ($result);
+    }
+    /// Fetching all categories and indexing by ID and updated field names
+    $categories_by_id = [];
+    $sync_api         = new Crowdaa_Sync_API();
+    $sync_db          = new Crowdaa_Sync_Syncdb('categories');
+    $synced           = $sync_db->get_synced_entries();
+    $all_categories   = $sync_api->get_categories();
+    if (isset($all_categories->message)) {
+      return ([
+        'error' => __('API query error : ', CROWDAA_SYNC_PLUGIN_NAME).$all_categories->message,
+      ]);
+    }
+    if ($all_categories->categories) {
+      foreach ($all_categories->categories as $category) {
+        if ($category->parentId) {
+          $category->rootParentId = $category->parentId;
+        }
+        $category->hash = self::hash_category($category);
+        $categories_by_id[$category->_id] = $category;
+      }
+    }
+    $args = array(
+      'hide_empty' => false,
+      'taxonomy'   => 'category',
+    );
+    $all_terms = get_terms($args);
+    $terms_by_id = [];
+    if(!empty($all_terms)) {
+      foreach ($all_terms as $term) {
+        $term->perms = [];
+        if (Crowdaa_Sync_Utils::have_plugin('paid-memberships-pro')) {
+          global $wpdb;
+          $perms = Crowdaa_Sync_Utils::quick_select($wpdb->pmpro_memberships_categories, [
+            'category_id' => $term->term_id,
+          ], ['membership_id']);
+          $perms_array = [];
+          foreach ($perms as $perm) {
+            $perms_array[] = $perm->membership_id;
+          }
+          $term->perms = $perms_array;
+        }
+        $terms_by_id[$term->term_id] = $term;
+      }
+    }
+    /// Fetching filtering modes
+    $sync_categories_mode = get_option('crowdaa_sync_categories_mode', 'blacklist');
+    $sync_categories_list = get_option('crowdaa_sync_categories_list', '');
+    if ($sync_categories_list === '') {
+      $sync_categories_list = [];
+    } else {
+      $sync_categories_list = explode(',', $sync_categories_list);
+    }
+    /// Getting list of categories names
+    $sync_categories_names = [];
+    foreach ($sync_categories_list as $id) {
+      if (isset($terms_by_id[$id])) {
+        $sync_categories_names = $terms_by_id[$id]->name;
+      }
+    }
+    /// Filtering allowed parents from the WP terms
+    foreach ($terms_by_id as $term) {
+      $root_term = $term;
+      while ($root_term->parent) {
+        $root_term = $terms_by_id[$root_term->parent];
+      }
+      if ($sync_categories_mode === 'whitelist' && !in_array($root_term->term_id, $sync_categories_list)) {
+        $term->rootParentId = null;
+      } else if ($sync_categories_mode === 'blacklist' && in_array($root_term->term_id, $sync_categories_list)) {
+        $term->rootParentId = null;
+      } else if ($root_term->term_id !== $term->term_id) {
+        $term->rootParentId = $root_term->term_id;
+      } else {
+        $term->rootParentId = null;
+      }
+      $term->hash = self::hash_term($term);
+    }
+    /// Filtering allowed terms
+    foreach ($terms_by_id as $id => $term) {
+      if ($sync_categories_mode === 'whitelist' && !in_array($term->term_id, $sync_categories_list)) {
+        unset($terms_by_id[$id]);
+      } else if ($sync_categories_mode === 'blacklist' && in_array($term->term_id, $sync_categories_list)) {
+        unset($terms_by_id[$id]);
+      }
+    }
+    /// Filtering allowed categories
+    foreach ($categories_by_id as $id => $category) {
+      if ($sync_categories_mode === 'whitelist' && !in_array($category->name, $sync_categories_names)) {
+        unset($categories_by_id[$id]);
+      } else if ($sync_categories_mode === 'blacklist' && in_array($category->name, $sync_categories_names)) {
+        unset($categories_by_id[$id]);
+      }
+    }
+    /// Specific code to handle migration from previous sync mechanism
+    if (count($synced) === 0) {
+      $created = 0;
+      foreach ($terms_by_id as $term) {
+        $api_id = get_term_meta($term->term_id, 'api_term_id', true);
+        if ($api_id && isset($categories_by_id[$api_id])) {
+          $sync_db->create_entry($term->term_id, $api_id, [
+            'category_hash' => $categories_by_id[$api_id]->hash,
+            'term_hash' => $term->hash,
+          ]);
+          $created++;
+        }
+      }
+      if ($created > 0) {
+        $synced = $sync_db->get_synced_entries();
+      }
+    }
+    /// Storing synced
+    $synced_by_api_id = [];
+    $synced_by_wp_id = [];
+    foreach ($synced as $item) {
+      $item->category_hash = $item->sync_data['category_hash'];
+      $item->term_hash = $item->sync_data['term_hash'];
+      if ($sync_categories_mode === 'whitelist' && !in_array($item->wp_id, $sync_categories_list)) {
+        $sync_db->delete_entry(['id' => $item->id]);
+      } else if ($sync_categories_mode === 'blacklist' && in_array($item->wp_id, $sync_categories_list)) {
+        $sync_db->delete_entry(['id' => $item->id]);
+      } else {
+        $synced_by_wp_id[$item->wp_id] = $item;
+        $synced_by_api_id[$item->api_id] = $item;
+      }
+    }
+    Crowdaa_Sync_Logs::log('OpQueue building...', count($all_categories->categories).' api categories and '.count($all_terms).' wp categories');
+    /// Comparing states and storing oplist
+    if ($crowdaa_sync_articles_wp_to_api_enabled) {
+      foreach ([false, true] as $hasParent) {
+        foreach ($terms_by_id as $id => $term) {
+          if ((!!$term->rootParentId) === $hasParent) {
+            if (!array_key_exists($id, $synced_by_wp_id)) {
+              $result['only_wp'][] = [
+                'api_id' => null,
+                'wp_id' => $term->term_id,
+                'name' => $term->name,
+                'slug' => $term->slug,
+                'parentId' => $term->rootParentId,
+                'perms' => $term->perms,
+                'hash' => $term->hash,
+              ];
+            } else if ($synced_by_wp_id[$id]->term_hash !== $term->hash) {
+              $result['wp_to_api'][] = [
+                'api_id' => $synced_by_wp_id[$id]->api_id,
+                'wp_id' => $term->term_id,
+                'name' => $term->name,
+                'slug' => $term->slug,
+                'parentId' => $term->rootParentId,
+                'perms' => $term->perms,
+                'hash' => $term->hash,
+              ];
+            }
+          }
+        }
+      }
+      foreach ($synced_by_wp_id as $wp_id => $synced_item) {
+        if (!array_key_exists($wp_id, $terms_by_id)) {
+          $result['remove_api'][] = [
+            'api_id' => $synced_item->api_id,
+            'wp_id' => null,
+          ];
+        }
+      }
+    }
+    if ($crowdaa_sync_articles_api_to_wp_enabled) {
+      foreach ([false, true] as $hasParent) {
+        foreach ($categories_by_id as $id => $category) {
+          if ((!!$category->parentId) === $hasParent) {
+            if (!array_key_exists($id, $synced_by_api_id)) {
+              $result['only_api'][] = [
+                'api_id' => $category->_id,
+                'wp_id' => null,
+                'name' => $category->name,
+                'slug' => $category->pathName,
+                'parentId' => $category->parentId,
+                'badges' => $category->badges,
+                'hash' => $category->hash,
+              ];
+            } else if ($synced_by_api_id[$id]->category_hash !== $category->hash) {
+              $result['api_to_wp'][] = [
+                'api_id' => $category->_id,
+                'wp_id' => $synced_by_api_id[$id]->wp_id,
+                'name' => $category->name,
+                'slug' => $category->pathName,
+                'parentId' => $category->parentId,
+                'badges' => $category->badges,
+                'hash' => $category->hash,
+              ];
+            }
+          }
+        }
+      }
+      foreach ($synced_by_api_id as $api_id => $synced_item) {
+        if (!array_key_exists($api_id, $categories_by_id)) {
+          $result['remove_wp'][] = [
+            'wp_id' => $synced_item->wp_id,
+            'api_id' => null,
+          ];
+        }
+      }
+    }
+    return ($result);
+  }
 …
+    }
-    // Compare posts API and WP
     $result = [
       'api_to_wp' => [],
 …
       $info_wp = new Crowdaa_Sync_Add_Info_WP();
+      $badges_opqueue = $this->get_badges_opqueue();
+      $categories_opqueue = $this->get_categories_opqueue();
       $articles_opqueue = $this->get_articles_opqueue();
+      if (isset($badges_opqueue['error']) && $badges_opqueue['error']) {
+        $result['error'] = $badges_opqueue['error'];
+        Crowdaa_Sync_Logs::log('Queue', 'error', $badges_opqueue['error']);
+        return ($result);
+      }
+      if (isset($categories_opqueue['error']) && $categories_opqueue['error']) {
+        $result['error'] = $categories_opqueue['error'];
+        Crowdaa_Sync_Logs::log('Queue', 'error', $categories_opqueue['error']);
+        return ($result);
+      }
       if (isset($articles_opqueue['error']) && $articles_opqueue['error']) {
 …
       $result['opqueue'] = [
+        'articles' => $articles_opqueue,
+        'articles'   => $articles_opqueue,
+        'badges'     => $badges_opqueue,
+        'categories' => $categories_opqueue,
       ];
+      self::log_opqueue($badges_opqueue, 'badges', 'api_to_wp');
+      self::log_opqueue($badges_opqueue, 'badges', 'wp_to_api');
+      self::log_opqueue($badges_opqueue, 'badges', 'only_api');
+      self::log_opqueue($badges_opqueue, 'badges', 'only_wp');
+      self::log_opqueue($badges_opqueue, 'badges', 'remove_api');
+      self::log_opqueue($badges_opqueue, 'badges', 'remove_wp');
+      self::log_opqueue($categories_opqueue, 'categories', 'api_to_wp');
+      self::log_opqueue($categories_opqueue, 'categories', 'wp_to_api');
+      self::log_opqueue($categories_opqueue, 'categories', 'only_api');
+      self::log_opqueue($categories_opqueue, 'categories', 'only_wp');
+      self::log_opqueue($categories_opqueue, 'categories', 'remove_api');
+      self::log_opqueue($categories_opqueue, 'categories', 'remove_wp');
       self::log_opqueue($articles_opqueue, 'articles', 'api_to_wp');
       self::log_opqueue($articles_opqueue, 'articles', 'wp_to_api');
 …
       do_action('crowdaa_sync_articles_synchronization_start');
+      // Sync WP => API
+      if (
+        count($badges_opqueue['wp_to_api']) > 0 ||
+        count($badges_opqueue['only_wp']) > 0 ||
+        count($badges_opqueue['remove_api']) > 0
+      ) {
+        /** @TODO Continue me, write this function */
+        $api_errors = $this->sync_badges_api(
+          $badges_opqueue['wp_to_api'],
+          $badges_opqueue['only_wp'],
+          $badges_opqueue['remove_api']
+        );
+      }
+      // Sync API => WP
+      if (
+        count($badges_opqueue['api_to_wp']) > 0 ||
+        count($badges_opqueue['only_api']) > 0 ||
+        count($badges_opqueue['remove_wp']) > 0
+      ) {
+        /** @TODO Continue me, write this function */
+        $wp_errors = $info_wp->sync_badges_wp(
+          $badges_opqueue['api_to_wp'],
+          $badges_opqueue['only_api'],
+          $badges_opqueue['remove_wp']
+        );
+      }
+      // Sync WP => API
+      if (
+        count($categories_opqueue['wp_to_api']) > 0 ||
+        count($categories_opqueue['only_wp']) > 0 ||
+        count($categories_opqueue['remove_api']) > 0
+      ) {
+        /** @TODO Continue me, write this function */
+        $api_errors = $this->sync_categories_api(
+          $categories_opqueue['wp_to_api'],
+          $categories_opqueue['only_wp'],
+          $categories_opqueue['remove_api']
+        );
+      }
+      // Sync API => WP
+      if (
+        count($categories_opqueue['api_to_wp']) > 0 ||
+        count($categories_opqueue['only_api']) > 0 ||
+        count($categories_opqueue['remove_wp']) > 0
+      ) {
+        /** @TODO Continue me, write this function */
+        $wp_errors = $info_wp->sync_categories_wp(
+          $categories_opqueue['api_to_wp'],
+          $categories_opqueue['only_api'],
+          $categories_opqueue['remove_wp']
+        );
+      }
       // Sync WP => API
       if (is_array($articles_opqueue['wp_to_api']) && is_array($articles_opqueue['only_wp'])) {
 …
     } catch (Crowdaa_Sync_Post_Error $e) {
       $result['error'] = __('Uncaught Post synchronization error : ', CROWDAA_SYNC_PLUGIN_NAME).$e->getMessage();
+    } catch (Crowdaa_Sync_Category_Error $e) {
+      $result['error'] = __('Category synchronization error : ', CROWDAA_SYNC_PLUGIN_NAME).$e->getMessage();
+    } catch (Crowdaa_Sync_Badge_Error $e) {
+      $result['error'] = __('Badge synchronization error : ', CROWDAA_SYNC_PLUGIN_NAME).$e->getMessage();
     } catch (Crowdaa_Sync_Error $e) {
       $result['error'] = __('Fatal synchronization error : ', CROWDAA_SYNC_PLUGIN_NAME).$e->getMessage();
 …
+  }
+  public function sync_badges_api(
+    &$wp_to_api,
+    &$only_wp,
+    &$remove_api
+  ) {
+    $elements_to_process = array_merge($wp_to_api, $only_wp, $remove_api);
+    if (!$elements_to_process) {
+      return (false);
+    }
+    $sync_api = new Crowdaa_Sync_API();
+    $sync_db  = new Crowdaa_Sync_Syncdb('user_badges');
+    $errors   = [];
+    foreach ($elements_to_process as $curPermId => $curPerm) {
+      Crowdaa_Sync_Timer::check();
+      Crowdaa_Sync_Logs::log('Syncing WP>API Badge', $curPermId, wp_json_encode($curPerm));
+      try {
+        if (in_array($curPerm, $only_wp, true)) {
+          $badge = $sync_api->create_badge($curPerm['name'], $curPerm['description'], $curPerm['public']);
+          $sync_db->create_entry($curPerm['wp_id'], $badge->_id, [
+            'badge_hash' => self::hash_badge($badge),
+            'membership_hash' => $curPerm['hash'],
+          ]);
+        } else if (in_array($curPerm, $wp_to_api, true)) {
+          $badge = $sync_api->update_badge($curPerm['api_id'], $curPerm['name'], $curPerm['description'], $curPerm['public']);
+          $sync_db->update_entry(['api_id' => $curPerm['api_id']], [
+            'sync_data' => [
+              'badge_hash' => self::hash_badge($badge),
+              'membership_hash' => $curPerm['hash'],
+            ],
+          ]);
+        } else if (in_array($curPerm, $remove_api, true)) {
+          $sync_api->remove_badge($curPerm['api_id']);
+          $sync_db->delete_entry(['api_id' => $curPerm['api_id']]);
+        }
+      } catch (Crowdaa_Sync_Post_Skip_Error $e) {
+        Crowdaa_Sync_Logs::log($e->getMessage());
+        continue;
+      } catch (Crowdaa_Sync_Post_Error $e) {
+        Crowdaa_Sync_Logs::log('Badge sync error', $e->getMessage());
+        $errors[] = $e->getMessage();
+        continue;
+      }
+    }
+    if (count($elements_to_process) > 0) {
+      foreach ($errors as $error) {
+        Crowdaa_Sync_Logs::log('Created/updated/removed API badges errors', $error);
+      }
+      Crowdaa_Sync_Logs::log(
+        'Created/updated API badges',
+        count($only_wp).' badges created, '.
+        count($wp_to_api).' badges updated and '.
+        count($remove_api).' badges removed with '.count($errors).' errors'
+      );
+    }
+    return ($errors);
+  }
+  private static function term_perms_to_badges($perms) {
+    $perm_sync_db = new Crowdaa_Sync_Syncdb('user_badges');
+    $badges = [];
+    foreach ($perms as $perm_id) {
+      $entry = $perm_sync_db->get_entry_with_wp_id($perm_id, 'api_id');
+      $badges[] = $entry->api_id;
+    }
+    return ($badges);
+  }
+  public function sync_categories_api(
+    &$wp_to_api,
+    &$only_wp,
+    &$remove_api
+  ) {
+    $elements_to_process = array_merge($wp_to_api, $only_wp, $remove_api);
+    if (!$elements_to_process) {
+      return (false);
+    }
+    $sync_api     = new Crowdaa_Sync_API();
+    $sync_db      = new Crowdaa_Sync_Syncdb('categories');
+    $errors       = [];
+    foreach ($elements_to_process as $curTermId => $curTerm) {
+      Crowdaa_Sync_Timer::check();
+      Crowdaa_Sync_Logs::log('Syncing WP>API Category', $curTermId, wp_json_encode($curTerm));
+      try {
+        if (in_array($curTerm, $only_wp, true)) {
+          $parentId = null;
+          if ($curTerm['parentId']) {
+            $parentId = $sync_db->get_entry_with_wp_id($curTerm['parentId'], 'api_id');
+            $parentId = $parentId->api_id;
+          }
+          $badges = null;
+          if (Crowdaa_Sync_Utils::have_plugin('paid-memberships-pro')) {
+            $badges = self::term_perms_to_badges($curTerm['perms']);
+          }
+          $category = $sync_api->create_category($curTerm['name'], $curTerm['slug'], $parentId, $badges);
+          $sync_db->create_entry($curTerm['wp_id'], $category->_id, [
+            'category_hash' => self::hash_category($category),
+            'term_hash' => $curTerm['hash'],
+          ]);
+        } else if (in_array($curTerm, $wp_to_api, true)) {
+          $parentId = null;
+          if ($curTerm['parentId']) {
+            $parentId = $sync_db->get_entry_with_wp_id($curTerm['parentId'], 'api_id');
+            $parentId = $parentId->api_id;
+          }
+          $badges = null;
+          if (Crowdaa_Sync_Utils::have_plugin('paid-memberships-pro')) {
+            $badges = self::term_perms_to_badges($curTerm['perms']);
+          }
+          $category = $sync_api->update_category($curTerm['api_id'], $curTerm['name'], $curTerm['slug'], $parentId, $badges);
+          $sync_db->update_entry(['api_id' => $curTerm['api_id']], [
+            'sync_data' => [
+              'category_hash' => self::hash_category($category),
+              'term_hash' => $curTerm['hash'],
+            ],
+          ]);
+        } else if (in_array($curTerm, $remove_api, true)) {
+          $sync_api->delete_category($curTerm['api_id']);
+          $sync_db->delete_entry(['api_id' => $curTerm['api_id']]);
+        }
+      } catch (Crowdaa_Sync_Post_Skip_Error $e) {
+        Crowdaa_Sync_Logs::log($e->getMessage());
+        continue;
+      } catch (Crowdaa_Sync_Post_Error $e) {
+        Crowdaa_Sync_Logs::log('Badge sync error', $e->getMessage());
+        $errors[] = $e->getMessage();
+        continue;
+      }
+    }
+    if (count($elements_to_process) > 0) {
+      foreach ($errors as $error) {
+        Crowdaa_Sync_Logs::log('Created/updated/removed API categories errors', $error);
+      }
+      Crowdaa_Sync_Logs::log(
+        'Created/updated API categories',
+        count($only_wp).' categories created, '.
+        count($wp_to_api).' categories updated and '.
+        count($remove_api).' categories removed with '.count($errors).' errors'
+      );
+    }
+    return ($errors);
+  }
   public function sync_info_api(&$wp_to_api, &$only_wp) {
     $posts_add_to_api = array_merge($wp_to_api, $only_wp);
 …
+    }
+    $cat_array        = [];
+    $errors           = [];
+    $sync_api         = new Crowdaa_Sync_API();
+    $all_categories   = $sync_api->get_categories();
+    if (isset($all_categories->message)) {
+      throw new Crowdaa_Sync_Error(__('Categories fetch error : ', CROWDAA_SYNC_PLUGIN_NAME).$all_categories->message);
+    }
+    if ($all_categories->categories) {
+      foreach ($all_categories->categories as $category) {
+        $cat_array[$category->_id] = strtolower(trim($category->pathName));
+      }
+    }
+    $args = array(
+      'hide_empty' => false,
+      'taxonomy'   => 'category',
+    );
+    $all_terms = get_terms($args);
+    $terms_hash = [];
+    if(!empty($all_terms)) {
+      foreach ($all_terms as $term) {
+        $terms_hash[$term->term_id] = $term;
+      }
+    $errors             = [];
+    $sync_api           = new Crowdaa_Sync_API();
+    $cat_sync_db        = new Crowdaa_Sync_Syncdb('categories');
+    $cat_synced_entries = $cat_sync_db->get_synced_entries();
+    $cat_wp_to_api_id = [];
+    foreach ($cat_synced_entries as $item) {
+      $cat_wp_to_api_id[$item->wp_id] = $item->api_id;
+    }
 …
+    }
-    foreach ($terms_hash as $term) {
-      $root_term = $term;
-      while ($root_term->parent) {
-        $root_term = $terms_hash[$root_term->parent];
+      }
-      if ($sync_categories_mode === 'whitelist' && !in_array($root_term->term_id, $sync_categories_list)) {
-        $term->root_term_id = null;
-        continue;
-      } else if ($sync_categories_mode === 'blacklist' && in_array($root_term->term_id, $sync_categories_list)) {
-        $term->root_term_id = null;
-        continue;
+      }
-      if ($root_term->term_id !== $term->term_id) {
-        $term->root_term_id = $root_term->term_id;
-      } else {
-        $term->root_term_id = $term->parent;
+      }
+    }
     foreach ($posts_add_to_api as $postArrayId => $post) {
       Crowdaa_Sync_Timer::check();
 …
       $blacklisted = false;
       foreach ($post_terms as $term) {
-        $blacklisted_term = false;
         if (in_array($term->term_id, $sync_categories_list)) {
           if ($sync_categories_mode === 'blacklist') {
 …
             $whitelisted = $term->term_id;
             if (!$post_term) {
-              $child_term = true; // Lie here to avoid losing this term.
               $post_term  = [
+                'id'   => $term->term_id,
+                'slug' => $term->slug,
+                'name' => $term->name,
+                'id'    => $term->term_id,
+                'child' => in_array($term->term_id, $child_terms),
+              ];
+            } else if (!$post_term['child'] && in_array($term->term_id, $child_terms)) {
+              $post_term  = [
+                'id'    => $term->term_id,
+                'child' => true,
               ];
+            }
 …
         } else if (
           $sync_categories_mode !== 'whitelist' &&
+          !$blacklisted &&
+          !$post_term &&
+          in_array($term->term_id, $child_terms)
+          !$blacklisted
         ) {
+          $child_term = true;
+          $post_term  = [
+            'id'   => $term->term_id,
+            'slug' => $term->slug,
+            'name' => $term->name,
+          ];
+          if (!$post_term) {
+            $post_term  = [
+              'id'    => $term->term_id,
+              'child' => in_array($term->term_id, $child_terms),
+            ];
+          } else if (!$post_term['child'] && in_array($term->term_id, $child_terms)) {
+            $post_term  = [
+              'id'    => $term->term_id,
+              'child' => true,
+            ];
+          }
+        }
+      }
 …
         continue;
+      }
-      if ($child_term == false) {
-        $post_term  = [
-          'id'   => $post_terms[0]->term_id,
-          'slug' => $post_terms[0]->slug,
-          'name' => $post_terms[0]->name,
-        ];
+      }
-      $term = $terms_hash[$post_term['id']];
-      if ($term->root_term_id) {
-        $term = $terms_hash[$term->root_term_id];
-        $post_term['parent'] = [
-          'id'   => $term->term_id,
-          'slug' => $term->slug,
-          'name' => $term->name,
-        ];
+      }
 …
+        }
+        // Create or update parent category, if needed
+        $parent_api_term_id = false;
+        if (array_key_exists('parent', $post_term)) {
+          $api_term_id = get_term_meta($post_term['parent']['id'], 'api_term_id', true);
+          $api_term_need_update = get_term_meta($post_term['parent']['id'], 'crowdaa_need_sync', true);
+          $sync_version = get_term_meta($post_term['parent']['id'], 'crowdaa_version', true);
+          if (!$api_term_id || !array_key_exists($api_term_id, $cat_array)) {
+            $api_term_id = array_search(strtolower(trim($post_term['parent']['slug'])), $cat_array);
+            if ($api_term_id !== false) {
+              update_term_meta($post_term['parent']['id'], 'api_term_id', $api_term_id);
+            }
+          }
+          $plain_term_name = html_entity_decode($post_term['parent']['name'], ENT_QUOTES);
+          if(!$api_term_id || !array_key_exists($api_term_id, $cat_array)) {
+            $api_term_id = $sync_api->create_category_api($post_term['parent']['id'], $plain_term_name, $post_term['parent']['slug'], '');
+            $cat_array[$api_term_id] = $post_term['parent']['slug'];
+          } elseif($api_term_need_update !== 'no' || $sync_version !== Crowdaa_Sync_Versions::get_version()) {
+            $sync_api->update_category_api($api_term_id, $post_term['parent']['id'], $plain_term_name, $post_term['parent']['slug'], '');
+          }
+          $parent_api_term_id = $api_term_id;
+        }
+        $api_term_id = get_term_meta($post_term['id'], 'api_term_id', true);
+        $api_term_need_update = get_term_meta($post_term['id'], 'crowdaa_need_sync', true);
+        $sync_version = get_term_meta($post_term['id'], 'crowdaa_version', true);
+        if (!$api_term_id || !array_key_exists($api_term_id, $cat_array)) {
+          $api_term_id = array_search(strtolower(trim($post_term['slug'])), $cat_array);
+          if ($api_term_id !== false) {
+            update_term_meta($post_term['id'], 'api_term_id', $api_term_id);
+          }
+        }
+        $plain_term_name = html_entity_decode($post_term['name'], ENT_QUOTES);
+        if(!$api_term_id || !array_key_exists($api_term_id, $cat_array)) {
+          $api_term_id = $sync_api->create_category_api($post_term['id'], $plain_term_name, $post_term['slug'], $parent_api_term_id ?: '');
+          $cat_array[$api_term_id] = $post_term['slug'];
+        } elseif($api_term_need_update !== 'no' || $sync_version !== Crowdaa_Sync_Versions::get_version()) {
+          $sync_api->update_category_api($api_term_id, $post_term['id'], $plain_term_name, $post_term['slug'], $parent_api_term_id ?: '');
+        // Get category API ID
+        $api_term_id = $cat_wp_to_api_id[$post_term['id']];
+        if (!$api_term_id) {
+          throw new Crowdaa_Sync_Post_Error('Could not find synced category for term '.$post_term['id'].'. This should not happen, aborting sync.');
+          continue;
+        }

crowdaa-sync/trunk/admin/class-crowdaa-sync-add-info-wp.php

-                      r2620193
+                      r2744975
+  }
+  /**
+   * Create term
+   *
+   * @since    1.0.0
+   * @param $cat_id
+   * @param $cat_name
+   * @return int
+   */
+  /** @TODO That whole function was rewritten to handle more edge-cases and was not tested, test it! */
+  public function get_or_create_term($cat_id, $cat_name) {
+    $cat_name = esc_html($cat_name);
+    $post_type_taxonomy = 'category';
+    $terms = get_terms([
+      'hide_empty' => false,
+      'taxonomy' => $post_type_taxonomy,
+      'meta_query' => [
+        [
+           'key'       => 'api_term_id',
+           'value'     => $cat_id,
+           'compare'   => '=',
+        ],
+      ],
+  private function create_permission($name, $description, $public) {
+    global $wpdb;
+    $fields = [
+      'name' => $name,
+      'description' => $description,
+      'allow_signups' => $public ? 1 : 0,
+      'initial_payment' => 0.0,
+      'billing_amount' => 0.0,
+    ];
+    $insCount = $wpdb->insert(
+      $wpdb->pmpro_membership_levels,
+      $fields,
+      Crowdaa_Sync_Utils::wpdb_formats_for($fields)
+    );
+    if (!$insCount) {
+      throw new Crowdaa_Sync_Badge_Error('Could not insert permission named "'.$name.'" in SQL database');
+    }
+    $fields['id'] = $wpdb->insert_id;
+    return ((object) $fields);
+  }
+  private function update_permission($wp_id, $name, $description, $public) {
+    global $wpdb;
+    $fields = [
+      'name' => $name,
+      'description' => $description,
+      'allow_signups' => $public ? 1 : 0,
+    ];
+    $where = ['id' => $wp_id];
+    $updCount = $wpdb->update(
+      $wpdb->pmpro_membership_levels,
+      $fields,
+      $where,
+      Crowdaa_Sync_Utils::wpdb_formats_for($fields),
+      Crowdaa_Sync_Utils::wpdb_formats_for($where)
+    );
+    if (!$updCount) {
+      throw new Crowdaa_Sync_Badge_Error('Could not update permission named "'.$name.'" in SQL database');
+    }
+    $fields['id'] = $wp_id;
+    return ((object) $fields);
+  }
+  private function remove_permission($wp_id) {
+    global $wpdb;
+    $where = ['id' => $wp_id];
+    $where2 = ['membership_id' => $wp_id];
+    $formats2 = Crowdaa_Sync_Utils::wpdb_formats_for($where2);
+    $wpdb->delete(
+      $wpdb->pmpro_membership_levels,
+      $where,
+      Crowdaa_Sync_Utils::wpdb_formats_for($where)
+    );
+    $wpdb->delete($wpdb->pmpro_membership_orders,      $where2, $formats2);
+    $wpdb->delete($wpdb->pmpro_memberships_categories, $where2, $formats2);
+    $wpdb->delete($wpdb->pmpro_memberships_pages,      $where2, $formats2);
+    $wpdb->delete($wpdb->pmpro_memberships_users,      $where2, $formats2);
+    $where3 = ['pmpro_membership_level_id' => $wp_id];
+    $formats3 = Crowdaa_Sync_Utils::wpdb_formats_for($where3);
+    $wpdb->delete($wpdb->pmpro_membership_levelmeta,   $where3, $formats3);
+  }
+  private function create_term($name, $slug, $parentId, $badges) {
+    $term_data = wp_insert_term(esc_html($name), 'category', [
+      'parent' => $parentId ?: 0,
+      'slug'   => $slug ?: '',
     ]);
+    if (is_wp_error($terms) || !is_array($terms) || count($terms) === 0) {
+      $terms = get_terms([
+        'hide_empty' => false,
+        'taxonomy' => $post_type_taxonomy,
+        'name' => $cat_name,
+      ]);
+    }
+    if (!is_wp_error($terms) && is_array($terms) && count($terms) > 0) {
+      $term_by_name = null;
+      foreach ($terms as $term) {
+        $key = get_term_meta($term->term_id, 'api_term_id', false);
+        if ($key === $cat_id) {
+          if ($term->name !== $cat_name) {
+            wp_update_term($term->term_id, $post_type_taxonomy, [
+              'name' => $cat_name,
+              'parent' => $term->parent,
+              'slug' => $term->slug,
+              'description' => $term->description,
+            ]);
+            update_term_meta($term->term_id, 'crowdaa_need_sync', 'no');
+            update_term_meta($term->term_id, 'crowdaa_version', Crowdaa_Sync_Versions::get_version());
+    $term = get_term($term_data['term_id'], 'category');
+    if (Crowdaa_Sync_Utils::have_plugin('paid-memberships-pro') && $badges) {
+      global $wpdb;
+      if (isset($badges->list) && count($badges->list) > 0) {
+        $sync_db = new Crowdaa_Sync_Syncdb('user_badges');
+        foreach ($badges->list as $item) {
+          $sync_obj = $sync_db->get_entry_with_api_id($item->id, 'wp_id');
+          Crowdaa_Sync_Utils::quick_insert(
+            $wpdb->pmpro_memberships_categories,
+            [
+              'membership_id' => $sync_obj->wp_id,
+              'category_id' => $term->term_id,
+            ]
+          );
+        }
+      }
+    }
+    return ($term);
+  }
+  private function update_term($term_id, $name, $slug, $parentId, $badges) {
+    wp_update_term($term_id, 'category', [
+      'name'   => esc_html($name),
+      'parent' => $parentId ?: 0,
+      'slug'   => $slug ?: '',
+    ]);
+    if (Crowdaa_Sync_Utils::have_plugin('paid-memberships-pro') && $badges) {
+      global $wpdb;
+      if (isset($badges->list) && is_array($badges->list)) {
+        $sync_db = new Crowdaa_Sync_Syncdb('user_badges');
+        $current_memberships = Crowdaa_Sync_Utils::quick_select($wpdb->pmpro_memberships_categories, [
+          'category_id' => $term_id,
+        ], ['membership_id']);
+        $membership_hash = [];
+        foreach ($current_memberships as $membership) {
+          $membership_hash[$membership->membership_id] = true;
+        }
+        foreach ($badges->list as $item) {
+          $sync_obj = $sync_db->get_entry_with_api_id($item->id, 'wp_id');
+          if (!isset($membership_hash[$sync_obj->wp_id])) {
+            Crowdaa_Sync_Utils::quick_insert(
+              $wpdb->pmpro_memberships_categories,
+              [
+                'membership_id' => $sync_obj->wp_id,
+                'category_id' => $term_id,
+              ]
+            );
+          } else {
+            unset($membership_hash[$sync_obj->wp_id]);
+          }
+          return $term->term_id;
+        } else if (!$term_by_name && $key === false && $term->name === $cat_name) {
+          $term_by_name = $term;
+        }
+      }
+      if ($term_by_name) {
+        update_term_meta($term_by_name->term_id, 'crowdaa_need_sync', 'no');
+        update_term_meta($term_by_name->term_id, 'crowdaa_version', Crowdaa_Sync_Versions::get_version());
+        return ($term_by_name->term_id);
+      }
+    }
+    $term_id         = '';
+    $data = [
+      'description' => '',
+      'parent'      => 0,
+      'slug'        => '',
+    ];
+    $term = wp_insert_term($cat_name, $post_type_taxonomy, $data);
+    if(!is_wp_error($term)) {
+      $term_id = $term['term_id'];
+      update_term_meta($term_id, 'api_term_id', $cat_id);
+      update_term_meta($term_id, 'crowdaa_need_sync', 'no');
+      update_term_meta($term_id, 'crowdaa_version', Crowdaa_Sync_Versions::get_version());
+    }
+    return $term_id;
+        }
+        foreach ($membership_hash as $membership_id => $true) {
+          Crowdaa_Sync_Utils::quick_delete($wpdb->pmpro_memberships_categories, [
+            'category_id' => $term_id,
+            'membership_id' => $membership_id,
+          ]);
+        }
+      }
+    }
+    $term = get_term($term_id, 'category');
+    return ($term);
+  }
+  private function delete_term($term_id) {
+    wp_delete_term($term_id, 'category');
+  }
+  public function sync_badges_wp(
+    &$api_to_wp,
+    &$only_api,
+    &$remove_wp
+  ) {
+    $errors            = [];
+    $sync_db           = new Crowdaa_Sync_Syncdb('user_badges');
+    $badges_sync_to_wp = array_merge($api_to_wp, $only_api, $remove_wp);
+    foreach($badges_sync_to_wp as $curBadgeId => $curBadge) {
+      Crowdaa_Sync_Timer::check();
+      Crowdaa_Sync_Logs::log('Syncing API>WP Badge', $curBadgeId, wp_json_encode($curBadge));
+      if (in_array($curBadge, $only_api, true)) {
+        $permission = $this->create_permission($curBadge['name'], $curBadge['description'], $curBadge['public']);
+        $sync_db->create_entry($permission->id, $curBadge['api_id'], [
+          'badge_hash' => $curBadge['hash'],
+          'membership_hash' => Crowdaa_Sync_Add_Info_API::hash_pmpro_membership($permission),
+        ]);
+      } else if (in_array($curBadge, $api_to_wp, true)) {
+        $permission = $this->update_permission($curBadge['wp_id'], $curBadge['name'], $curBadge['description'], $curBadge['public']);
+        $sync_db->update_entry(['wp_id' => $curBadge['wp_id']], [
+          'sync_data' => [
+            'badge_hash' => $curBadge['hash'],
+            'membership_hash' => Crowdaa_Sync_Add_Info_API::hash_pmpro_membership($permission),
+          ],
+        ]);
+      } else if (in_array($curBadge, $remove_wp, true)) {
+        $this->remove_permission($curBadge['wp_id']);
+        $sync_db->delete_entry(['wp_id' => $curBadge['wp_id']]);
+      }
+    }
+    if (count($badges_sync_to_wp) > 0) {
+      Crowdaa_Sync_Logs::log(
+        'Created/updated WP permissions',
+        count($only_api).' permissions created, '.
+        count($api_to_wp).' permissions updated and '.
+        count($remove_wp).' permissions removed with '.
+        count($errors).' errors'
+      );
+    }
+    return ($errors);
+  }
+  public function sync_categories_wp(
+    &$api_to_wp,
+    &$only_api,
+    &$remove_wp
+  ) {
+    $errors                = [];
+    $sync_db               = new Crowdaa_Sync_Syncdb('categories');
+    $categories_sync_to_wp = array_merge($api_to_wp, $only_api, $remove_wp);
+    foreach($categories_sync_to_wp as $curCategoryId => $curCategory) {
+      Crowdaa_Sync_Timer::check();
+      Crowdaa_Sync_Logs::log('Syncing API>WP Category', $curCategoryId, wp_json_encode($curCategory));
+      if (in_array($curCategory, $only_api, true)) {
+        $parentId = null;
+        if ($curCategory['parentId']) {
+          $parentId = $sync_db->get_entry_with_api_id($curCategory['parentId'], 'wp_id');
+          $parentId = $parentId->wp_id;
+        }
+        $term = $this->create_term($curCategory['name'], $curCategory['slug'], $parentId, $curCategory['badges']);
+        $term->rootParentId = $parentId;
+        $sync_db->create_entry($term->term_id, $curCategory['api_id'], [
+          'category_hash' => $curCategory['hash'],
+          'term_hash' => Crowdaa_Sync_Add_Info_API::hash_term($term),
+        ]);
+      } else if (in_array($curCategory, $api_to_wp, true)) {
+        $parentId = null;
+        if ($curCategory['parentId']) {
+          $parentId = $sync_db->get_entry_with_api_id($curCategory['parentId'], 'wp_id');
+          $parentId = $parentId->wp_id;
+        }
+        $term = $this->update_term($curCategory['wp_id'], $curCategory['name'], $curCategory['slug'], $parentId, $curCategory['badges']);
+        $term->rootParentId = $parentId;
+        $sync_db->update_entry(['wp_id' => $curCategory['wp_id']], [
+          'sync_data' => [
+            'category_hash' => $curCategory['hash'],
+            'term_hash' => Crowdaa_Sync_Add_Info_API::hash_term($term),
+          ],
+        ]);
+      } else if (in_array($curCategory, $remove_wp, true)) {
+        $this->delete_term($curCategory['wp_id']);
+        $sync_db->delete_entry(['wp_id' => $curCategory['wp_id']]);
+      }
+    }
+    if (count($categories_sync_to_wp) > 0) {
+      Crowdaa_Sync_Logs::log(
+        'Created/updated WP categories',
+        count($only_api).' categories created, '.
+        count($api_to_wp).' categories updated and '.
+        count($remove_wp).' categories removed with '.
+        count($errors).' errors'
+      );
+    }
+    return ($errors);
+  }
 …
   private function create_wp_post_from_api($api_data) {
     $created_posts  = [];
+    $categories = $this->get_or_create_term($api_data->category->_id, $api_data->category->name);
+    $cat_sync_db    = new Crowdaa_Sync_Syncdb('categories');
+    $term = $cat_sync_db->get_entry_with_api_id($api_data->category->_id, 'wp_id');
+    $term = get_term($term->wp_id, 'category');
     $post_data = [
 …
     $post_type_taxonomy = 'category';
     wp_set_post_terms($wp_post_id, [$categories], $post_type_taxonomy);
+    wp_set_post_terms($wp_post_id, [$term], $post_type_taxonomy);
     $sync_errors = $this->post_sync_api_medias($api_data, $wp_post_id);
 …
     $created_posts  = [];
+    $categories = $this->get_or_create_term($api_data->category->_id, $api_data->category->name);
+    $term = $cat_sync_db->get_entry_with_api_id($api_data->category->_id, 'wp_id');
+    $term = get_term($term->wp_id, 'category');
     $data = [
 …
     $post_type_taxonomy = 'category';
     wp_set_post_terms($wp_post_id, [$categories], $post_type_taxonomy);
+    wp_set_post_terms($wp_post_id, [$term], $post_type_taxonomy);
     wp_update_post($data);
     update_post_meta($wp_post_id, 'api_post_id', $api_data->_id);
 …
    */
   private function get_uploads($img_url, $img_name) {
+    $wp_upload_dir = wp_upload_dir();
+    $file_path     = $wp_upload_dir['basedir'].'/'.'catalogue_images/'.$img_name;
     Crowdaa_Sync_Logs::log('Downloading media to Wordpress',
       'img_url='.$img_url,
       'img_name='.$img_name,
+      'img_path='.$file_path,
     );
 …
         'timeout'         => 45,
         'stream'          => true,
         'filename'        => $upload_fname,
+        'filename'        => $file_path,
         'sslcertificates' => CROWDAA_SYNC_CACERT_PATH,
       ]);

crowdaa-sync/trunk/admin/class-crowdaa-sync-admin-display.php

-                      r2722017
+                      r2744975
    * @since    1.0.0
    */
+  public function database_reset() {
+    if(empty($_POST) || !wp_verify_nonce($_POST['crowdaa_reset'], 'crowdaa_reset_data')) {
+      return;
+    }
+    Crowdaa_Sync_Logs::log('Running database reset');
+    update_option('crowdaa_cron_sync_enabled', 'no');
+    if (Crowdaa_Sync_Utils::have_plugin('paid-memberships-pro')) {
+      $sync_db = new Crowdaa_Sync_Syncdb('user_badges');
+      $sync_db->reset();
+    }
+    $sync_db = new Crowdaa_Sync_Syncdb('categories');
+    $sync_db->reset();
+    $table = Crowdaa_Sync_Utils::db_prefix().'postmeta';
+    Crowdaa_Sync_Utils::quick_query("DELETE FROM `$table` WHERE meta_key = %s", ['api_picture_id']);
+    Crowdaa_Sync_Utils::quick_query("DELETE FROM `$table` WHERE meta_key = %s", ['api_videos_id']);
+    Crowdaa_Sync_Utils::quick_query("DELETE FROM `$table` WHERE meta_key = %s", ['api_feedpicture_id']);
+    Crowdaa_Sync_Utils::quick_query("DELETE FROM `$table` WHERE meta_key = %s", ['api_media_map']);
+    Crowdaa_Sync_Utils::quick_query("DELETE FROM `$table` WHERE meta_key = %s", ['api_post_id']);
+    Crowdaa_Sync_Utils::quick_query("DELETE FROM `$table` WHERE meta_key LIKE 'crowdaa_%'");
+    $table = Crowdaa_Sync_Utils::db_prefix().'termmeta';
+    Crowdaa_Sync_Utils::quick_query("DELETE FROM `$table` WHERE meta_key = %s", ['api_term_id']);
+    Crowdaa_Sync_Utils::quick_query("DELETE FROM `$table` WHERE meta_key LIKE 'crowdaa_%'");
+    Crowdaa_Sync_Versions::bump_version();
+    Crowdaa_Sync_Logs::log('Database reset done');
+  }
   public function enable_sync() {
     if(!isset($_POST['crowdaa_cron_sync_enabled']) || !wp_verify_nonce($_POST['crowdaa_cron_sync_enabled'], 'crowdaa_cron_sync_enabled_data')) {
 …
     } else {
       update_option('crowdaa_sync_wpapi_register_enabled', 'no');
+    }
+    if(isset($_POST['sync_perm_plugin'])) {
+      update_option('crowdaa_sync_perm_plugin', $_POST['sync_perm_plugin']);
+    }
 …
       'WP-API register' => get_option('crowdaa_sync_wpapi_register_enabled') === 'yes',
       'duration' => get_option('crowdaa_sync_max_duration', 60),
+      'perm_plugin' => get_option('crowdaa_sync_perm_plugin', '-'),
     ];
     $sync_logs = apply_filters('crowdaa_sync_configure_levers_log', $sync_logs);

crowdaa-sync/trunk/admin/class-crowdaa-sync-api.php

-                      r2722017
+                      r2744975
+  }
+  public function get_badges() {
+    $url = '/userBadges';
+    $response = $this->http_request('GET', $url);
+    $err = is_wp_error($response) ? $response->get_error_message() : null;
+    if (!$err) {
+      $body = wp_remote_retrieve_body($response);
+      $json = json_decode($body);
+    }
+    if ($err) {
+      Crowdaa_Sync_Logs::log('Get badges query error', $err);
+      return ((object) [
+        'message' => $err,
+      ]);
+    }
+    if (isset($json->message)) {
+      Crowdaa_Sync_Logs::log('Get badges error', $json->message);
+    }
+    foreach ($json->userBadges as &$v) {
+      if (!isset($v->management)) {
+        $v->management = 'private-internal';
+      }
+      if (!isset($v->access)) {
+        $v->access = 'hidden';
+      }
+    }
+    return ($json->userBadges);
+  }
   /**
 …
         $gallery_ids = array_diff($gallery_ids, $bad_ids);
         if (count($gallery_ids) === 0 && !$thumbnail_id) {
           throw new Crowdaa_Sync_Post_Error(__('No picture could be synchronized for post ').$wp_post_id);
+          throw new Crowdaa_Sync_Post_Error(__('No picture could be synchronized for post ', CROWDAA_SYNC_PLUGIN_NAME).$wp_post_id);
+        }
+      }
 …
+  }
+  public function create_badge($name, $description, $public) {
+    $data = [
+      'name'          => $name,
+      'description'   => $description,
+      'management'    => $public ? 'public' : 'private-internal',
+      'access'        => 'teaser',
+      'isDefault'     => false,
+      'validationUrl' => '',
+    ];
+    $data = apply_filters('crowdaa_sync_api_create_badge_payload', $data);
+    $response = $this->http_request('POST', '/userBadges', $data);
+    $err      = is_wp_error($response) ? $response->get_error_message() : null;
+    if (!$err) {
+      $body = wp_remote_retrieve_body($response);
+      $json = json_decode($body);
+    }
+    if ($err) {
+      Crowdaa_Sync_Logs::log('Create badge query error', $name, $err);
+      throw new Crowdaa_Sync_Post_Error(__('Query error during badge creation : ', CROWDAA_SYNC_PLUGIN_NAME).$err);
+    } else {
+      if (isset($json->message)) {
+        Crowdaa_Sync_Logs::log('Create badge error', $name, $json->message);
+        throw new Crowdaa_Sync_Post_Error(__('API error during badge creation : ', CROWDAA_SYNC_PLUGIN_NAME).$json->message);
+      }
+      Crowdaa_Sync_Logs::log('Created badge', wp_json_encode($json->userBadge));
+      return ($json->userBadge);
+    }
+  }
+  public function update_badge($badge_id, $name, $description, $public) {
+    $data = [
+      'name'          => $name,
+      'description'   => $description,
+      'management'    => $public ? 'public' : 'private-internal',
+      'access'        => 'teaser',
+      'isDefault'     => false,
+      'validationUrl' => '',
+    ];
+    $data = apply_filters('crowdaa_sync_api_update_badge_payload', $data);
+    $response = $this->http_request('PUT', "/userBadges/$badge_id", $data);
+    $err      = is_wp_error($response) ? $response->get_error_message() : null;
+    if (!$err) {
+      $body = wp_remote_retrieve_body($response);
+      $json = json_decode($body);
+    }
+    if ($err) {
+      Crowdaa_Sync_Logs::log('Update badge query error', $name, $err);
+      throw new Crowdaa_Sync_Post_Error(__('Query error during badge update : ', CROWDAA_SYNC_PLUGIN_NAME).$err);
+    } else {
+      if (isset($json->message)) {
+        Crowdaa_Sync_Logs::log('Update badge error', $name, $json->message);
+        throw new Crowdaa_Sync_Post_Error(__('API error during badge update : ', CROWDAA_SYNC_PLUGIN_NAME).$json->message);
+      }
+      Crowdaa_Sync_Logs::log('Updated badge', wp_json_encode($json->userBadge));
+      return ($json->userBadge);
+    }
+  }
+  public function remove_badge($badge_id) {
+    $response = $this->http_request('DELETE', "/userBadges/$badge_id");
+    $err      = is_wp_error($response) ? $response->get_error_message() : null;
+    if (!$err) {
+      $body = wp_remote_retrieve_body($response);
+      $json = json_decode($body);
+    }
+    if ($err) {
+      Crowdaa_Sync_Logs::log('Delete badge query error', $name, $err);
+      throw new Crowdaa_Sync_Post_Error(__('Query error during badge delete : ', CROWDAA_SYNC_PLUGIN_NAME).$err);
+    } else {
+      if (isset($json->message)) {
+        Crowdaa_Sync_Logs::log('Delete badge error', $name, $json->message);
+        throw new Crowdaa_Sync_Post_Error(__('API error during badge delete : ', CROWDAA_SYNC_PLUGIN_NAME).$json->message);
+      }
+      Crowdaa_Sync_Logs::log('Deleted badge', $badge_id);
+    }
+    return (true);
+  }
   /**
    * Create category on the API
 …
    * @return boolean
    */
   public function create_category_api($term_id, $cat_name, $cat_slug, $parent_category_id = '') {
+  public function create_category($cat_name, $cat_slug, $parent_category_id, $badges) {
     $data = [
       'name'     => $cat_name,
 …
       'action'   => '',
     ];
+    if (is_array($badges)) {
+      $data['badges'] = $badges;
+      $data['badgesAllow'] = 'all';
+    }
     $data = apply_filters('crowdaa_sync_api_create_category_payload', $data);
 …
     if ($err) {
       Crowdaa_Sync_Logs::log('Create category query error', $cat_name, $err);
       throw new Crowdaa_Sync_Post_Error(__('Query error during category creation : ', CROWDAA_SYNC_PLUGIN_NAME).$err);
+      throw new Crowdaa_Sync_Category_Error(__('Query error during category creation : ', CROWDAA_SYNC_PLUGIN_NAME).$err);
     } else {
       if (isset($json->message)) {
         Crowdaa_Sync_Logs::log('Create category error', $cat_name, $json->message);
+        throw new Crowdaa_Sync_Post_Error(__('API error during category creation : ', CROWDAA_SYNC_PLUGIN_NAME).$json->message);
+      }
+      if ($term_id) {
+        update_term_meta($term_id, 'api_term_id', $json->_id);
+        update_term_meta($term_id, 'crowdaa_version', Crowdaa_Sync_Versions::get_version());
+        update_term_meta($term_id, 'crowdaa_need_sync', 'no');
+        throw new Crowdaa_Sync_Category_Error(__('API error during category creation : ', CROWDAA_SYNC_PLUGIN_NAME).$json->message);
+      }
       Crowdaa_Sync_Logs::log('Created category', $cat_name, $json->_id);
+      return ($json->_id);
+      return ($json);
+    }
+  }
 …
    * @return boolean
    */
   public function update_category_api($cat_id, $term_id, $cat_name, $cat_slug, $parent_category_id = '') {
+  public function update_category($cat_id, $cat_name, $cat_slug, $parent_category_id, $badges) {
     $data = [
       'name'     => $cat_name,
 …
       // 'order'    => null,
     ];
+    if (is_array($badges)) {
+      $data['badges'] = $badges;
+      $data['badgesAllow'] = 'all';
+    }
     $data = apply_filters('crowdaa_sync_api_update_category_payload', $data);
 …
     if ($err) {
       Crowdaa_Sync_Logs::log('Updated category query error', $cat_name, $err);
       throw new Crowdaa_Sync_Post_Error(__('Query error during category update : ', CROWDAA_SYNC_PLUGIN_NAME).$err);
+      throw new Crowdaa_Sync_Category_Error(__('Query error during category update : ', CROWDAA_SYNC_PLUGIN_NAME).$err);
     } else {
       if (isset($json->message)) {
         Crowdaa_Sync_Logs::log('Updated category error', $json->message);
+        throw new Crowdaa_Sync_Post_Error(__('API error during category update : ', CROWDAA_SYNC_PLUGIN_NAME).$json->message);
+      }
+      update_term_meta($term_id, 'api_term_id', $cat_id);
+      update_term_meta($term_id, 'crowdaa_version', Crowdaa_Sync_Versions::get_version());
+      update_term_meta($term_id, 'crowdaa_need_sync', 'no');
+        throw new Crowdaa_Sync_Category_Error(__('API error during category update : ', CROWDAA_SYNC_PLUGIN_NAME).$json->message);
+      }
       Crowdaa_Sync_Logs::log('Updated category', $cat_name);
+      /** API just returns 'true', so we must rebuild the object as it would have been returned... */
+      $ret = (object) $data;
+      $ret->_id = $cat_id;
+      if (is_array($badges)) {
+        $ret_badges = [];
+        foreach ($badges as $badge_id) {
+          $ret_badges[] = (object) ['id' => $badge_id];
+        }
+        $ret->badges = (object) [
+          'list' => $ret_badges,
+          'allow' => $data['badgesAllow'],
+        ];
+      }
+      return ($ret);
+    }
+  }
+  public function delete_category($cat_id) {
+    $response = $this->http_request('DELETE', '/press/categories/'.$cat_id);
+    $err    = is_wp_error($response) ? $response->get_error_message() : null;
+    if (!$err) {
+      $body = wp_remote_retrieve_body($response);
+      $json = json_decode($body);
+    }
+    if ($err) {
+      Crowdaa_Sync_Logs::log('Deleted category query error', $cat_name, $err);
+      throw new Crowdaa_Sync_Category_Error(__('Query error during category delete : ', CROWDAA_SYNC_PLUGIN_NAME).$err);
+    } else {
+      if (isset($json->message)) {
+        Crowdaa_Sync_Logs::log('Deleted category error', $json->message);
+        throw new Crowdaa_Sync_Category_Error(__('API error during category delete : ', CROWDAA_SYNC_PLUGIN_NAME).$json->message);
+      }
+      Crowdaa_Sync_Logs::log('Deleted category', $cat_name);
+    }
+  }

crowdaa-sync/trunk/admin/class-crowdaa-sync-ext-hooks.php

-                      r2722017
+                      r2744975
+    }
+    if (Crowdaa_Sync_Utils::have_plugin('paid-memberships-pro')) {
+      global $wpdb;
+      $user_memberships = Crowdaa_Sync_Utils::quick_select($wpdb->pmpro_memberships_users, [
+        'user_id' => $user->data->ID,
+        'status' => 'active',
+      ], 'id');
+      if (count($user_memberships) > 0) {
+        $sync_db = new Crowdaa_Sync_Syncdb('user_badges');
+        $wp_ids = Crowdaa_Sync_Utils::object_array_extract_field('id', $user_memberships);
+        $synced = $sync_db->get_entry_with_wp_id($wp_ids, 'api_id');
+        $api_ids = Crowdaa_Sync_Utils::object_array_extract_field('api_id', $synced);
+        $data['user_badges'] = $api_ids;
+      }
+    }
+    /**
+     * @TODO Use that in the API.
+     */
     return ($data);
+  }

crowdaa-sync/trunk/admin/class-crowdaa-sync-wp-hooks.php

-                      r2620193
+                      r2744975
     add_action('save_post', [$this, 'save_post_without_cat_notice']);
     add_action('save_post', [$this, 'set_need_to_sync_for_post']);
-    add_action('saved_category', [$this, 'set_need_to_sync_for_category']);
     add_action('admin_notices', [$this, 'sync_admin_notice']);
     add_action('before_delete_post', [$this, 'sync_delete_post']);
 …
   /**
-   * Set need sync option for category synchronization
+   *
-   * @since    1.0.0
-   * @param $post_id
-   * @return void
-   */
-  public function set_need_to_sync_for_category($term_id) {
-    update_term_meta($term_id, 'crowdaa_need_sync', 'yes');
+  }
-  /**
    * Hide deleted post from WP to API
+   *

crowdaa-sync/trunk/admin/css/crowdaa-sync-admin.css

-                      r2722017
+                      r2744975
   margin-bottom: 10px;
+}
+#crowdaa-reset-form {
+  display: none;
+  position: fixed;
+  top: 0;
+  left: 0;
+  right: 0;
+  bottom: 0;
+  background-color: rgba(88, 88, 88, 0.88);
+  text-align: center;
+  padding: 50px 0;
+  z-index: 100000;
+}
+#crowdaa-reset-form > div {
+  background-color: white;
+  padding: 20px 40px 40px;
+  display: inline-block;
+  text-align: left;
+}
+#crowdaa-reset-form ul {
+  padding-left: 20px;
+}
+#crowdaa-reset-form li {
+  list-style: initial;
+}
+.crowdaa-reset-danger {
+  background-color: rgb(255, 0, 0);
+  color: white;
+  font-weight: bold;
+  border: none;
+  border-radius: 10px;
+  padding: 8px 14px;
+}
+.crowdaa-reset-danger:hover {
+  background-color: rgb(206, 0, 0);
+  cursor: pointer;
+}
+.crowdaa-reset-form-buttons {
+  display: flex;
+  justify-content: space-between;
+  padding-top: 30px;
+}
+#crowdaa-reset-dismiss {
+  background-color: rgb(73, 189, 58);
+  color: white;
+  font-weight: bold;
+  border: none;
+  border-radius: 10px;
+  padding: 8px 14px;
+}
+#crowdaa-reset-dismiss:hover {
+  background-color: rgb(54, 143, 43);
+  cursor: pointer;
+}

crowdaa-sync/trunk/admin/js/crowdaa-sync-admin.js

-                      r2722017
+                      r2744975
+    }
     function renderOpQueueFor(data, field) {
+    function renderOpQueueForArticle(data, field) {
       const list = data[field];
       if (!list) {
         return('<ul><li>No posts</li></ul>');
+        return(false);
+      }
       if (list === 'disabled') {
 …
+      }
       if (list.length === 0) {
         return('<ul><li>No posts</li></ul>');
+        return(false);
+      }
       const render = list.reduce(function(acc, item) {
         acc += '<li class="' + field + '"><i>' +
           'Post title: <strong>' + item.post_name + '</strong> ' +
           'Post CMS ID: <strong>' + (item.api_id ? item.api_id : 'New post') + '</strong>' +
+          'Post title: <strong>' + escapeHtml(item.post_name) + '</strong> ' +
+          'Post CMS ID: <strong>' + escapeHtml(item.api_id ? item.api_id : 'New post') + '</strong>' +
           '</i></li>';
         return(acc);
 …
+    }
+    function renderOpQueue(data) {
+    function renderOpQueueForCategory(data, field) {
+      const list = data[field];
+      if (!list) {
+        return(false);
+      }
+      if (list === 'disabled') {
+        return('<ul><li>Synchronization disabled</li></ul>');
+      }
+      if (list.length === 0) {
+        return(false);
+      }
+      const render = list.reduce(function(acc, item) {
+        acc += '<li class="' + field + '"><i title="' + escapeHtml(item.slug || '') + '">';
+        if (item.name) {
+          acc += 'Category : <strong>' + escapeHtml(item.name) + '</strong>';
+        } else if (item.wp_id) {
+          acc += 'WP Category ID : <strong>' + escapeHtml(item.wp_id) + '</strong>';
+        } else if (item.api_id) {
+          acc += 'API Category ID : <strong>' + escapeHtml(item.api_id) + '</strong>';
+        }
+        acc += '</i></li>';
+        return(acc);
+      }, '');
+      return ('<ul>' + render + '</ul>');
+    }
+    function renderOpQueueForBadge(data, field) {
+      const list = data[field];
+      if (!list) {
+        return(false);
+      }
+      if (list === 'disabled') {
+        return('<ul><li>Synchronization disabled</li></ul>');
+      }
+      if (list.length === 0) {
+        return(false);
+      }
+      const render = list.reduce(function(acc, item) {
+        acc += '<li class="' + field + '"><i title="' + escapeHtml(item.description || '') + '">';
+        if (item.name) {
+          acc += 'Permission : <strong>' + escapeHtml(item.name) + '</strong>';
+        } else if (item.wp_id) {
+          acc += 'WP Permission ID : <strong>' + escapeHtml(item.wp_id) + '</strong>';
+        } else if (item.api_id) {
+          acc += 'API Permission ID : <strong>' + escapeHtml(item.api_id) + '</strong>';
+        }
+        acc += '</i></li>';
+        return(acc);
+      }, '');
+      return ('<ul>' + render + '</ul>');
+    }
+    function renderOpQueue(data, showDates, renderCb) {
       let html = '';
+      html += '<h2>Synchronize elements from Crowdaa CMS to WordPress</h2>';
+      html += renderOpQueueFor(data, 'api_to_wp');
+      html += '<h2>Synchronize elements from WordPress to Crowdaa CMS</h2>';
+      html += renderOpQueueFor(data, 'wp_to_api');
+      html += '<h2>Synchronize new elements from Crowdaa CMS</h2>';
+      html += renderOpQueueFor(data, 'only_api');
+      html += '<h2>Synchronize new elements from WordPress</h2>';
+      html += renderOpQueueFor(data, 'only_wp');
+      let renderedCount = 0;
+      if (data.error) {
+        return ('<h3>' + escapeHtml(data.error) + '</h3>');
+      }
+      function renderThis(title, key) {
+        const result = renderCb(data, key);
+        if (result) {
+          html += title;
+          html += result;
+          renderedCount++;
+        }
+      }
+      renderThis('<h2>Synchronize elements from Crowdaa CMS to WordPress</h2>', 'api_to_wp');
+      renderThis('<h2>Synchronize elements from WordPress to Crowdaa CMS</h2>', 'wp_to_api');
+      renderThis('<h2>Synchronize new elements from Crowdaa CMS</h2>', 'only_api');
+      renderThis('<h2>Synchronize new elements from WordPress</h2>', 'only_wp');
+      if (data['remove_api']) renderThis('<h2>Elements to remove from Crowdaa CMS</h2>', 'remove_api');
+      if (data['remove_wp']) renderThis('<h2>Elements to remove from Wordpress</h2>', 'remove_wp');
+      if (renderedCount === 0) {
+        html += '<i>Nothing to do</i>';
+      }
       html += '<br />';
 …
+      }
+      renderSyncFrom('wp_to_api', 'WordPress to API');
+      renderSyncFrom('api_to_wp', 'API to WordPress');
+      if (showDates) {
+        renderSyncFrom('wp_to_api', 'WordPress to API');
+        renderSyncFrom('api_to_wp', 'API to WordPress');
+      }
       return(html);
 …
     $('#crowdaa-sync-categories-mode-whitelist-checkbox').on('change', updateSyncCategoriesSelect);
     updateSyncCategoriesSelect();
+    $('#crowdaa-reset-request').click(function(e) {
+      e.preventDefault();
+      $('#crowdaa-reset-form').show();
+    });
+    $('#crowdaa-reset-dismiss').click(function(e) {
+      e.preventDefault();
+      $('#crowdaa-reset-form').hide();
+    });
     /**
 …
+            }
+            if (data.opqueue.categories) {
+              if (data.error) {
+                output += '<p>Here are the categories operations that were attempted :</p>';
+              } else {
+                output += '<p>Here are the categories operations that were done :</p>';
+              }
+              output += renderOpQueue(data.opqueue.categories, false, renderOpQueueForCategory);
+            }
+            if (data.opqueue.badges) {
+              if (data.error) {
+                output += '<p>Here are the permission operations that were attempted :</p>';
+              } else {
+                output += '<p>Here are the permission operations that were done :</p>';
+              }
+              output += renderOpQueue(data.opqueue.badges, false, renderOpQueueForBadge);
+            }
             if (data.opqueue.articles) {
               if (data.error) {
                 output += '<p>Here are the articles operations that were attempted :</p>';
+                output += '<p>Here are the article operations that were attempted :</p>';
               } else {
                 output += '<p>Here are the articles operations that were done :</p>';
+                output += '<p>Here are the article operations that were done :</p>';
+              }
               output += renderOpQueue(data.opqueue.articles);
+              output += renderOpQueue(data.opqueue.articles, true, renderOpQueueForArticle);
+            }
 …
           } else {
             $opqueue.html(
+              '<p>Here are the category operations that should/will be done :</p>' +
+              renderOpQueue(data.categories, false, renderOpQueueForCategory) +
+              '<p>Here are the permission operations that should/will be done :</p>' +
+              renderOpQueue(data.badges, false, renderOpQueueForBadge) +
               '<p>Here are the article operations that should/will be done :</p>' +
               renderOpQueue(data.articles)
+              renderOpQueue(data.articles, true, renderOpQueueForArticle)
             );
+          }

crowdaa-sync/trunk/admin/partials/crowdaa-sync-admin-display.php

-                      r2722017
+                      r2744975
   </form>
+  <form id="crowdaa-reset-form" method="post" action="<?php $admin_utils->database_reset(); ?>">
+    <?php wp_nonce_field('crowdaa_reset_data', 'crowdaa_reset'); ?>
+    <div>
+      <h3><?php esc_html_e('DO YOU REALLY WANT TO RESET THE DATABASE?', CROWDAA_SYNC_PLUGIN_NAME); ?></h3>
+      <?php esc_html_e('This action will erase all synchronization data. If you want to run a synchronization again after this step, you will either have to :', CROWDAA_SYNC_PLUGIN_NAME); ?>
+      <ul>
+        <li><?php esc_html_e('Change the targeted Crowdaa application', CROWDAA_SYNC_PLUGIN_NAME); ?></li>
+        <li><?php esc_html_e('Erase the Crowdaa app content (categories, badges and articles)', CROWDAA_SYNC_PLUGIN_NAME); ?></li>
+        <li><?php esc_html_e('Erase the Wordpress content (categories, permissions and articles)', CROWDAA_SYNC_PLUGIN_NAME); ?></li>
+      </ul>
+      <?php esc_html_e('This will also disable automatic synchronization.', CROWDAA_SYNC_PLUGIN_NAME); ?>
+      <div class="crowdaa-reset-form-buttons">
+        <button type="button" id="crowdaa-reset-dismiss">
+          <?php esc_html_e('Cancel', CROWDAA_SYNC_PLUGIN_NAME); ?>
+        </button>
+        <button type="submit" class="crowdaa-reset-danger">
+          <?php esc_html_e('RESET SYNC DATABASE', CROWDAA_SYNC_PLUGIN_NAME); ?>
+        </button>
+      </div>
+    </div>
+  </form>
+  <button type="button" class="crowdaa-reset-danger" id="crowdaa-reset-request">
+    <?php esc_html_e('RESET SYNC DATABASE', CROWDAA_SYNC_PLUGIN_NAME); ?>
+  </button>
   <?php
 …
         $sync_wpapi_register_enabled = (get_option('crowdaa_sync_wpapi_register_enabled', 'yes') === 'yes');
         $sync_max_duration           = get_option('crowdaa_sync_max_duration', 60);
+        ?>
+        <label class="sync-form-checkbox-label">
+          <span class="sync-form-label"><?php esc_html_e('Periodic synchronization enabled'); ?></span> &nbsp;
+        $sync_perm_plugin            = get_option('crowdaa_sync_perm_plugin', Crowdaa_Sync_Permissions::all_plugins_list()[0]);
+        ?>
+        <label class="sync-form-checkbox-label">
+          <span class="sync-form-label"><?php esc_html_e('Periodic synchronization enabled', CROWDAA_SYNC_PLUGIN_NAME); ?></span> &nbsp;
           <input type="checkbox" name="cron_sync_enable" class="sync-enable-checkbox"
             <?php echo ($sync_cron_enabled ? 'checked="checked"' : ''); ?>
 …
         <br />
         <label class="sync-form-checkbox-label">
           <span class="sync-form-label"><?php esc_html_e('Synchronize WordPress content to API'); ?></span> &nbsp;
+          <span class="sync-form-label"><?php esc_html_e('Synchronize WordPress content to API', CROWDAA_SYNC_PLUGIN_NAME); ?></span> &nbsp;
           <input type="checkbox" name="sync_wp_to_api_enable" class="sync-enable-checkbox"
             <?php echo ($sync_wp_to_api_enabled ? 'checked="checked"' : ''); ?>
 …
         <br />
         <label class="sync-form-checkbox-label">
           <span class="sync-form-label"><?php esc_html_e('Synchronize API content to WordPress'); ?></span> &nbsp;
+          <span class="sync-form-label"><?php esc_html_e('Synchronize API content to WordPress', CROWDAA_SYNC_PLUGIN_NAME); ?></span> &nbsp;
           <input type="checkbox" name="sync_api_to_wp_enable" class="sync-enable-checkbox"
             <?php echo ($sync_api_to_wp_enabled ? 'checked="checked"' : ''); ?>
 …
         <br />
         <label class="sync-form-checkbox-label">
           <span class="sync-form-label"><?php esc_html_e('Enable WP register from app'); ?></span> &nbsp;
+          <span class="sync-form-label"><?php esc_html_e('Enable WP register from app', CROWDAA_SYNC_PLUGIN_NAME); ?></span> &nbsp;
           <input type="checkbox" name="sync_wpapi_register_enable" class="sync-enable-checkbox"
             <?php echo ($sync_wpapi_register_enabled ? 'checked="checked"' : ''); ?>
 …
         <?php do_action('crowdaa_sync_configuration_levers'); ?>
         <label class="sync-form-checkbox-label">
           <span class="sync-form-label"><?php esc_html_e('Maximum synchronization duration (minutes)'); ?></span> &nbsp;
+          <span class="sync-form-label"><?php esc_html_e('Maximum synchronization duration (minutes)', CROWDAA_SYNC_PLUGIN_NAME); ?></span> &nbsp;
           <input type="number" name="sync_max_duration" min="2" id="sync-duration-field"
             value="<?php echo esc_attr($sync_max_duration); ?>"
           />
+        </label>
+        <br />
+        <label class="sync-form-checkbox-label">
+          <span class="sync-form-label"><?php esc_html_e('Permissions plugin', CROWDAA_SYNC_PLUGIN_NAME); ?></span> &nbsp;
+          <select class="sync-permissions-plugin-select" name="sync_perm_plugin[]">
+            <?php
+            $perm_plugins_list = Crowdaa_Sync_Permissions::plugins_list();
+            foreach ($perm_plugins_list as $plugin) { ?>
+              <option
+                value="<?php echo esc_attr($plugin); ?>"
+                <?php echo ($plugin === $sync_perm_plugin ? 'selected="selected"' : ''); ?>
+              >
+                <?php esc_html_e($plugin, CROWDAA_SYNC_PLUGIN_NAME); ?>
+              </option>
+            <?php } ?>
+          </select>
         </label>
         <br />

crowdaa-sync/trunk/crowdaa-sync.php

-                      r2722534
+                      r2744975
  * Plugin URI:
  * Description:       Plugin for synchronizing WordPress site and Crowdaa CMS
  * Version:           1.1.1
+ * Version:           1.2.0
  * Requires at least: 5.5
  * Requires PHP:      7.2
 …
  * Uses SemVer - https://semver.org
  */
 define('CROWDAA_SYNC_VERSION', '1.1.1');
+define('CROWDAA_SYNC_VERSION', '1.2.0');
 define('CROWDAA_SYNC_PLUGIN_DIR', __DIR__);
 define('CROWDAA_SYNC_PLUGIN_NAME', 'crowdaa-sync');

crowdaa-sync/trunk/includes/class-crowdaa-sync-exception.php

-                      r2620193
+                      r2744975
  */
 class Crowdaa_Sync_Error extends Exception {}
+/**
+ * An exception to handle errors on a single badge synchronzation, requesting to abort.
+ *
+ * @since      1.0.0
+ * @package    Crowdaa-Sync
+ * @subpackage Crowdaa-Sync/includes
+ * @author     Crowdaa <contact@crowdaa.com>
+ */
+class Crowdaa_Sync_Badge_Error extends Exception {}
+/**
+ * An exception to handle errors on a single category synchronzation, requesting to abort.
+ *
+ * @since      1.0.0
+ * @package    Crowdaa-Sync
+ * @subpackage Crowdaa-Sync/includes
+ * @author     Crowdaa <contact@crowdaa.com>
+ */
+class Crowdaa_Sync_Category_Error extends Exception {}
 /**

crowdaa-sync/trunk/includes/class-crowdaa-sync.php

-                      r2722017
+                      r2744975
     /**
+     * The class responsible for general utils used accross the plugin.
+     */
+    require_once CROWDAA_SYNC_PLUGIN_DIR.'/includes/class-crowdaa-sync-utils.php';
+    /**
      * The class responsible logging & logs management.
      */
 …
     /**
+     * The class responsible for permissions plugins management for the plugin.
+     */
+    require_once CROWDAA_SYNC_PLUGIN_DIR.'/includes/class-crowdaa-sync-permissions.php';
+    /**
      * The class responsible for checking the execution time of this plugin.
      */
     require_once CROWDAA_SYNC_PLUGIN_DIR.'/includes/class-crowdaa-sync-timer.php';
+    /**
+     * The class responsible for handling custom synchronizations.
+     */
+    require_once CROWDAA_SYNC_PLUGIN_DIR.'/includes/class-crowdaa-sync-syncdb.php';
     /**

Plugin Directory

Context Navigation

Legend:

crowdaa-sync/tags/1.2.0/CHANGELOG

crowdaa-sync/tags/1.2.0/README.txt

crowdaa-sync/tags/1.2.0/admin/class-crowdaa-sync-add-info-api.php

crowdaa-sync/tags/1.2.0/admin/class-crowdaa-sync-add-info-wp.php

crowdaa-sync/tags/1.2.0/admin/class-crowdaa-sync-admin-display.php

crowdaa-sync/tags/1.2.0/admin/class-crowdaa-sync-api.php

crowdaa-sync/tags/1.2.0/admin/class-crowdaa-sync-ext-hooks.php

crowdaa-sync/tags/1.2.0/admin/class-crowdaa-sync-wp-hooks.php

crowdaa-sync/tags/1.2.0/admin/css/crowdaa-sync-admin.css

crowdaa-sync/tags/1.2.0/admin/js/crowdaa-sync-admin.js

crowdaa-sync/tags/1.2.0/admin/partials/crowdaa-sync-admin-display.php

crowdaa-sync/tags/1.2.0/crowdaa-sync.php

crowdaa-sync/tags/1.2.0/includes/class-crowdaa-sync-exception.php

crowdaa-sync/tags/1.2.0/includes/class-crowdaa-sync.php

crowdaa-sync/trunk/CHANGELOG

crowdaa-sync/trunk/README.txt

crowdaa-sync/trunk/admin/class-crowdaa-sync-add-info-api.php

crowdaa-sync/trunk/admin/class-crowdaa-sync-add-info-wp.php

crowdaa-sync/trunk/admin/class-crowdaa-sync-admin-display.php

crowdaa-sync/trunk/admin/class-crowdaa-sync-api.php

crowdaa-sync/trunk/admin/class-crowdaa-sync-ext-hooks.php

crowdaa-sync/trunk/admin/class-crowdaa-sync-wp-hooks.php

crowdaa-sync/trunk/admin/css/crowdaa-sync-admin.css

crowdaa-sync/trunk/admin/js/crowdaa-sync-admin.js

crowdaa-sync/trunk/admin/partials/crowdaa-sync-admin-display.php

crowdaa-sync/trunk/crowdaa-sync.php

crowdaa-sync/trunk/includes/class-crowdaa-sync-exception.php

crowdaa-sync/trunk/includes/class-crowdaa-sync.php

Download in other formats: