FileMaster

Edit File: PostSyncService.php

<?php

namespace SureCart\Sync;

use SureCart\Models\Concerns\Facade;

use SureCart\Models\VariantOptionValue;
use SureCart\Support\Currency;
use SureCart\Sync\Concerns\HasLockProcess;

/**
 * This class syncs product records to WordPress posts.
 */
class PostSyncService {
	use Facade;
	use HasLockProcess;

/**
	 * The product model.
	 *
	 * @var \SureCart\Models\Product
	 */
	protected $product;

/**
	 * The post.
	 *
	 * @var \WP_Post
	 */
	protected $post;

/**
	 * The post type.
	 *
	 * @var string
	 */
	protected $post_type = 'sc_product';

/**
	 * The excluded meta keys.
	 *
	 * @var array
	 */
	protected $excluded_meta_keys = [
		'gallery',
		'gallery_ids',
		'meta_description',
		'page_title',
		'wp_buy_link_coupon_field_disabled',
		'wp_buy_link_custom_thankyou_page',
		'wp_buy_link_custom_thankyou_page_url',
		'wp_buy_link_enabled',
		'wp_buy_link_logo_disabled',
		'wp_buy_link_product_description_disabled',
		'wp_buy_link_product_image_disabled',
		'wp_buy_link_success_page_enabled',
		'wp_buy_link_success_page_url',
		'wp_buy_link_terms_disabled',
		'wp_buy_link_test_mode_enabled',
		'wp_created_by',
		'wp_template_part_id',
		'wp_template_id',
	];

/**
	 * Find the post from the model.
	 *
	 * @param string $model_id The model id.
	 *
	 * @return \WP_Post|\WP_Error|null
	 */
	protected function findByModelId( $model_id ) {
		// if we don't have a model id, return null.
		if ( empty( $model_id ) ) {
			return null;
		}

// query the post.
		$query = new \WP_Query(
			array(
				'post_type'        => $this->post_type,
				'post_status'      => array( 'auto-draft', 'draft', 'publish', 'trash', 'sc_archived', 'future' ),
				'posts_per_page'   => 1,
				'no_found_rows'    => true,
				'suppress_filters' => true,
				'meta_query'       => array(
					array(
						'key'   => 'sc_id',
						'value' => $model_id, // query by model id.
					),
				),
			)
		);

// handle error.
		if ( is_wp_error( $query ) ) {
			return $query;
		}

// get the post.
		$post = $query->posts[0] ?? null;

// return the post.
		return apply_filters( "surecart_get_{$this->post_type}_post", $post, $model_id, $this );
	}

/**
	 * Sync the model with the post.
	 *
	 * @param \SureCart\Models\Model $model The model.
	 *
	 * @return \WP_Post|\WP_Error
	 */
	protected function sync( \SureCart\Models\Model $model ) {
		$this->post = $this->findByModelId( $model->id );

if ( is_wp_error( $this->post ) ) {
			return $this->post;
		}

return empty( $this->post->ID ) ? $this->create( $model ) : $this->update( $model );
	}

/**
	 * Delete the synced post.
	 *
	 * @param string $id The model id.
	 *
	 * @return \WP_Post|\WP_Error|false|null
	 */
	protected function delete( string $id ) {
		$this->post = $this->findByModelId( $id );

if ( is_wp_error( $this->post ) ) {
			return $this->post;
		}

// force delete post.
		$deleted = wp_delete_post( $this->post->ID, true );
		if ( is_wp_error( $deleted ) ) {
			return $deleted;
		}

// delete variant option values where post_id is the post id.
		$deleted_option = VariantOptionValue::where( 'product_id', $id )->delete();
		if ( is_wp_error( $deleted_option ) ) {
			return $deleted_option;
		}

return $deleted;
	}

/**
	 * Get the schema map.
	 *
	 * @param \SureCart\Models\Model $model The model.
	 *
	 * @return array
	 */
	protected function getSchemaMap( \SureCart\Models\Model $model ) {
		$base_amount = ! empty( $model->prices->data[0]->amount ) ? $model->prices->data[0]->amount : 0;

// Filter metadata using array_filter with a callback.
		$metadata = array_filter(
			(array) $model->metadata,
			function ( $key ) {
				$excluded = apply_filters( 'surecart_excluded_post_meta_keys', $this->excluded_meta_keys );
				return ! in_array( $key, $excluded, true );
			},
			ARRAY_FILTER_USE_KEY // pass just the key to the callback.
		);

return array(
			'post_title'        => $model->name,
			'post_type'         => $this->post_type,
			'post_name'         => $model->slug,
			'post_excerpt'      => $model->description ?? '',
			'post_date'         => ( new \DateTime() )->setTimestamp( $model->cataloged_at ?? $model->created_at ?? time() )->setTimezone( new \DateTimeZone( wp_timezone_string() ) )->format( 'Y-m-d H:i:s' ),
			'post_date_gmt'     => date_i18n( 'Y-m-d H:i:s', $model->cataloged_at ?? $model->created_at ?? time(), true ),
			'post_modified'     => ( new \DateTime() )->setTimestamp( $model->updated_at ?? $model->created_at ?? time() )->setTimezone( new \DateTimeZone( wp_timezone_string() ) )->format( 'Y-m-d H:i:s' ),
			'post_modified_gmt' => date_i18n( 'Y-m-d H:i:s', $model->updated_at ?? $model->created_at ?? time(), true ),
			'post_status'       => $this->getPostStatusFromModel( $model ),
			'meta_input'        => array_merge(
				$metadata,
				array(
					'sc_id'                        => $model->id,
					'product'                      => $model->toArray(),
					'min_price_amount'             => ! empty( $model->metrics->min_price_amount ) ? Currency::maybeConvertAmount( $model->metrics->min_price_amount ?? 0, $model->initial_price->currency ?? null ) : $base_amount,
					'max_price_amount'             => ! empty( $model->metrics->max_price_amount ) ? Currency::maybeConvertAmount( $model->metrics->max_price_amount ?? 0, $model->initial_price->currency ?? null ) : $base_amount,
					'available_stock'              => $model->available_stock,
					'stock_enabled'                => $model->stock_enabled,
					'allow_out_of_stock_purchases' => $model->allow_out_of_stock_purchases,
					'featured'                     => $model->featured,
					'recurring'                    => $model->recurring,
					'shipping_enabled'             => $model->shipping_enabled,
					'purchase_limit'               => $model->purchase_limit,
					'sku'                          => $model->sku,
					'weight'                       => $model->weight,
					'weight_unit'                  => $model->weight_unit,
					'display_amount'               => $model->display_amount,
					'scratch_display_amount'       => $model->scratch_display_amount,
					'range_display_amount'         => $model->range_display_amount,
					'is_on_sale'                   => $model->is_on_sale,
					'total_reviews'                => $model->total_reviews,
					'average_stars'                => $model->average_stars,
					'reviews_enabled'              => $model->reviews_enabled ?? false,
				)
			),
		);
	}

/**
	 * Convert the template id.
	 *
	 * This removes the template theme prefix since this is not needed.
	 *
	 * @param string $id The template id.
	 *
	 * @return string
	 */
	protected function convertTemplateId( $id ) {
		$parts = explode( '//', $id, 2 );

// not a FSE template.
		if ( count( $parts ) < 2 ) {
			return $id;
		}

return $parts[1] ?? null;
	}

/**
	 * Create the post.
	 *
	 * @param \SureCart\Models\Model $model The model.
	 *
	 * @return \WP_Post|\WP_Error
	 */
	protected function create( \SureCart\Models\Model $model ) {
		// Another process is already syncing this product.
		if ( $this->hasLock( $model ) ) {
			return $this->findByModelId( $model->id );
		}

try {
			// Acquire lock.
			$this->acquireLock( $model );

// don't do these actions as they can slow down the sync.
			foreach ( array( 'do_pings', 'transition_post_status', 'save_post', 'pre_post_update', 'add_attachment', 'edit_attachment', 'edit_post', 'post_updated', 'wp_insert_post', 'save_post_' . $this->post_type ) as $action ) {
				remove_all_actions( $action );
			}

// we are importing.
			if ( ! defined( 'WP_IMPORTING' ) ) {
				define( 'WP_IMPORTING', true );
			}

// insert post.
			$props   = $this->getSchemaMap( $model );
			$post_id = wp_insert_post( wp_slash( apply_filters( 'surecart/product/sync/created/props', $props, $model ) ), true, false );

// handle errors.
			if ( is_wp_error( $post_id ) ) {
				return $post_id;
			}

// If there is a page template, use that, otherwise use the default.
			update_post_meta( $post_id, '_wp_page_template', $this->convertTemplateId( $model->template_id ?? '' ) );
			update_post_meta( $post_id, '_wp_page_template_part', $this->convertTemplateId( $model->template_part_id ?? '' ) );

$this->syncCollections( $post_id, $model );

// we need to do this because tax_input checks permissions for some ungodly reason.
			wp_set_post_terms( $post_id, \SureCart::account()->id, 'sc_account' );

$values = $this->syncVariantValues( $model, $post_id );
			if ( is_wp_error( $values ) ) {
				return $values;
			}

// set the post on the model.
			$this->post = get_post( $post_id );

// fire action.
			do_action( 'surecart/product/sync/created', $this->post, $model );

return $this->post;
		} finally {
			// Always release the lock, if any error occurs.
			$this->releaseLock( $model );
		}
	}

/**
	 * Update the post.
	 *
	 * @param \SureCart\Models\Model $model The model.
	 *
	 * @return \WP_Post|\WP_Error
	 */
	protected function update( $model ) {
		// find the post.
		if ( empty( $this->post ) ) {
			$this->post = $this->findByModelId( $model->id );
		}

$props = $this->getSchemaMap( $model );

// if we already have a post template, don't sync. This is to prevent overwriting the template.
		if ( ! empty( $this->post->page_template ) ) {
			unset( $props['page_template'] );
		}

// update the post by id.
		$post_id = wp_update_post(
			apply_filters(
				'surecart/product/sync/updated/props',
				array_merge(
					$props,
					array(
						'ID' => $this->post->ID,
					)
				),
				$model
			),
		);

if ( is_wp_error( $post_id ) ) {
			return $post_id;
		}

// update page template.
		update_post_meta( $post_id, '_wp_page_template', $this->convertTemplateId( $model->template_id ?? '' ) );
		update_post_meta( $post_id, '_wp_page_template_part', $this->convertTemplateId( $model->template_part_id ?? '' ) );

// set the collection terms.
		$this->syncCollections( $post_id, $model );

// we need to do this because tax_input checks permissions for some ungodly reason.
		wp_set_post_terms( $post_id, \SureCart::account()->id, 'sc_account' );

$values = $this->syncVariantValues( $model, $post_id );
		if ( is_wp_error( $values ) ) {
			return $values;
		}

$this->post = get_post( $post_id );

// fire action.
		do_action( 'surecart/product/sync/updated', $this->post, $model );

return $this->post;
	}

/**
	 * Sync the variant values.
	 *
	 * @param int $model_id The model id.
	 * @param int $post_id  The post id.
	 *
	 * @return bool|\WP_Error
	 */
	protected function syncVariantValues( $model, $post_id ) {
		// delete existing.
		VariantOptionValue::where( 'product_id', $model->id )->delete();

// create new.
		foreach ( ( $model->variant_options->data ?? array() ) as $option ) {
			foreach ( $option->values as $value ) {
				$created = VariantOptionValue::create(
					array(
						'value'      => $value,
						'name'       => $option->name,
						'post_id'    => $post_id,
						'product_id' => $model->id,
					)
				);
				if ( is_wp_error( $created ) ) {
					return $created;
				}
			}
		}

return true;
	}

/**
	 * Sync the collections.
	 *
	 * @param int                    $post_id The post id.
	 * @param \SureCart\Models\Model $model   The model.
	 *
	 * @return void
	 */
	protected function syncCollections( $post_id, $model ) {
		// sanity check.
		if ( ! isset( $model->product_collections ) || ! isset( $model->product_collections->data ) || ! is_array( $model->product_collections->data ) ) {
			return;
		}

// store the terms for the post.
		$terms = array();

// Loop through the collections.
		foreach ( $model->product_collections->data as $collection ) {
			// sync the collection.
			$collection->sync();

// get term by sc_id.
			$term = $collection->term;

// error handling.
			if ( is_wp_error( $term ) ) {
				error_log( $term->get_error_message() );
				continue;
			}

// if we don't have a term id, skip.
			if ( ! isset( $term->term_id ) || empty( $term->term_id ) ) {
				error_log( 'Could not sync term for collection: ' . $collection->name );
				error_log( print_r( $term, true ) );
				continue;
			}

// add to terms array.
			$terms[] = (int) $term->term_id;
		}

// set the terms.
		wp_set_post_terms( $post_id, $terms, 'sc_collection' );
	}

/**
	 * Add archived to the post meta.
	 *
	 * @param \SureCart\Models\Model $model The model.
	 *
	 * @return string
	 */
	protected function getPostStatusFromModel( \SureCart\Models\Model $model ) {
		// if it's archived, use that.
		if ( $model->archived ) {
			return 'sc_archived';
		}

// if it's draft, use that.
		if ( 'draft' === ( $model->status ?? '' ) ) {
			return 'draft';
		}

// default to publish.
		return 'publish';
	}
}

Back