<form method="POST">
    <h3>Editing: class-wc-webhook-data-store.php</h3>
    <textarea name="content" rows="20" cols="80">&lt;?php
/**
 * Webhook Data Store
 *
 * @version  3.3.0
 * @package  WooCommerce\Classes\Data_Store
 */

if ( ! defined( 'ABSPATH' ) ) {
	exit;
}

/**
 * Webhook data store class.
 */
class WC_Webhook_Data_Store implements WC_Webhook_Data_Store_Interface {

	/**
	 * Create a new webhook in the database.
	 *
	 * @since 3.3.0
	 * @param WC_Webhook $webhook Webhook instance.
	 */
	public function create( &amp;$webhook ) {
		global $wpdb;

		$changes = $webhook-&gt;get_changes();
		if ( isset( $changes['date_created'] ) ) {
			$date_created     = $webhook-&gt;get_date_created()-&gt;date( 'Y-m-d H:i:s' );
			$date_created_gmt = gmdate( 'Y-m-d H:i:s', $webhook-&gt;get_date_created()-&gt;getTimestamp() );
		} else {
			$date_created     = current_time( 'mysql' );
			$date_created_gmt = current_time( 'mysql', 1 );
			$webhook-&gt;set_date_created( $date_created );
		}

		// Pending delivery by default if not set while creating a new webhook.
		if ( ! isset( $changes['pending_delivery'] ) ) {
			$webhook-&gt;set_pending_delivery( true );
		}

		$data = array(
			'status'           =&gt; $webhook-&gt;get_status( 'edit' ),
			'name'             =&gt; $webhook-&gt;get_name( 'edit' ),
			'user_id'          =&gt; $webhook-&gt;get_user_id( 'edit' ),
			'delivery_url'     =&gt; $webhook-&gt;get_delivery_url( 'edit' ),
			'secret'           =&gt; $webhook-&gt;get_secret( 'edit' ),
			'topic'            =&gt; $webhook-&gt;get_topic( 'edit' ),
			'date_created'     =&gt; $date_created,
			'date_created_gmt' =&gt; $date_created_gmt,
			'api_version'      =&gt; $this-&gt;get_api_version_number( $webhook-&gt;get_api_version( 'edit' ) ),
			'failure_count'    =&gt; $webhook-&gt;get_failure_count( 'edit' ),
			'pending_delivery' =&gt; $webhook-&gt;get_pending_delivery( 'edit' ),
		);

		$wpdb-&gt;insert( $wpdb-&gt;prefix . 'wc_webhooks', $data ); // WPCS: DB call ok.

		$webhook_id = $wpdb-&gt;insert_id;
		$webhook-&gt;set_id( $webhook_id );
		$webhook-&gt;apply_changes();

		$this-&gt;delete_transients( $webhook-&gt;get_status( 'edit' ) );
		WC_Cache_Helper::invalidate_cache_group( 'webhooks' );
		do_action( 'woocommerce_new_webhook', $webhook_id, $webhook );
	}

	/**
	 * Read a webhook from the database.
	 *
	 * @since  3.3.0
	 * @param  WC_Webhook $webhook Webhook instance.
	 * @throws Exception When webhook is invalid.
	 */
	public function read( &amp;$webhook ) {
		global $wpdb;

		$data = wp_cache_get( $webhook-&gt;get_id(), 'webhooks' );

		if ( false === $data ) {
			$data = $wpdb-&gt;get_row( $wpdb-&gt;prepare( &quot;SELECT webhook_id, status, name, user_id, delivery_url, secret, topic, date_created, date_modified, api_version, failure_count, pending_delivery FROM {$wpdb-&gt;prefix}wc_webhooks WHERE webhook_id = %d LIMIT 1;&quot;, $webhook-&gt;get_id() ), ARRAY_A ); // WPCS: cache ok, DB call ok.

			wp_cache_add( $webhook-&gt;get_id(), $data, 'webhooks' );
		}

		if ( is_array( $data ) ) {
			$webhook-&gt;set_props(
				array(
					'id'               =&gt; $data['webhook_id'],
					'status'           =&gt; $data['status'],
					'name'             =&gt; $data['name'],
					'user_id'          =&gt; $data['user_id'],
					'delivery_url'     =&gt; $data['delivery_url'],
					'secret'           =&gt; $data['secret'],
					'topic'            =&gt; $data['topic'],
					'date_created'     =&gt; '0000-00-00 00:00:00' === $data['date_created'] ? null : $data['date_created'],
					'date_modified'    =&gt; '0000-00-00 00:00:00' === $data['date_modified'] ? null : $data['date_modified'],
					'api_version'      =&gt; $data['api_version'],
					'failure_count'    =&gt; $data['failure_count'],
					'pending_delivery' =&gt; $data['pending_delivery'],
				)
			);
			$webhook-&gt;set_object_read( true );

			do_action( 'woocommerce_webhook_loaded', $webhook );
		} else {
			throw new Exception( __( 'Invalid webhook.', 'woocommerce' ) );
		}
	}

	/**
	 * Update a webhook.
	 *
	 * @since 3.3.0
	 * @param WC_Webhook $webhook Webhook instance.
	 */
	public function update( &amp;$webhook ) {
		global $wpdb;

		$changes = $webhook-&gt;get_changes();
		$trigger = isset( $changes['delivery_url'] );

		if ( isset( $changes['date_modified'] ) ) {
			$date_modified     = $webhook-&gt;get_date_modified()-&gt;date( 'Y-m-d H:i:s' );
			$date_modified_gmt = gmdate( 'Y-m-d H:i:s', $webhook-&gt;get_date_modified()-&gt;getTimestamp() );
		} else {
			$date_modified     = current_time( 'mysql' );
			$date_modified_gmt = current_time( 'mysql', 1 );
			$webhook-&gt;set_date_modified( $date_modified );
		}

		$data = array(
			'status'            =&gt; $webhook-&gt;get_status( 'edit' ),
			'name'              =&gt; $webhook-&gt;get_name( 'edit' ),
			'user_id'           =&gt; $webhook-&gt;get_user_id( 'edit' ),
			'delivery_url'      =&gt; $webhook-&gt;get_delivery_url( 'edit' ),
			'secret'            =&gt; $webhook-&gt;get_secret( 'edit' ),
			'topic'             =&gt; $webhook-&gt;get_topic( 'edit' ),
			'date_modified'     =&gt; $date_modified,
			'date_modified_gmt' =&gt; $date_modified_gmt,
			'api_version'       =&gt; $this-&gt;get_api_version_number( $webhook-&gt;get_api_version( 'edit' ) ),
			'failure_count'     =&gt; $webhook-&gt;get_failure_count( 'edit' ),
			'pending_delivery'  =&gt; $webhook-&gt;get_pending_delivery( 'edit' ),
		);

		$wpdb-&gt;update(
			$wpdb-&gt;prefix . 'wc_webhooks',
			$data,
			array(
				'webhook_id' =&gt; $webhook-&gt;get_id(),
			)
		); // WPCS: DB call ok.

		$webhook-&gt;apply_changes();

		if ( isset( $changes['status'] ) ) {
			// We need to delete all transients, because we can't be sure of the old status.
			$this-&gt;delete_transients( 'all' );
		}
		wp_cache_delete( $webhook-&gt;get_id(), 'webhooks' );
		WC_Cache_Helper::invalidate_cache_group( 'webhooks' );

		if ( 'active' === $webhook-&gt;get_status() &amp;&amp; ( $trigger || $webhook-&gt;get_pending_delivery() ) ) {
			$webhook-&gt;deliver_ping();
		}

		do_action( 'woocommerce_webhook_updated', $webhook-&gt;get_id() );
	}

	/**
	 * Remove a webhook from the database.
	 *
	 * @since 3.3.0
	 * @param WC_Webhook $webhook      Webhook instance.
	 */
	public function delete( &amp;$webhook ) {
		global $wpdb;

		$wpdb-&gt;delete(
			$wpdb-&gt;prefix . 'wc_webhooks',
			array(
				'webhook_id' =&gt; $webhook-&gt;get_id(),
			),
			array( '%d' )
		); // WPCS: cache ok, DB call ok.

		$this-&gt;delete_transients( 'all' );
		wp_cache_delete( $webhook-&gt;get_id(), 'webhooks' );
		WC_Cache_Helper::invalidate_cache_group( 'webhooks' );
		do_action( 'woocommerce_webhook_deleted', $webhook-&gt;get_id(), $webhook );
	}

	/**
	 * Get API version number.
	 *
	 * @since  3.3.0
	 * @param  string $api_version REST API version.
	 * @return int
	 */
	public function get_api_version_number( $api_version ) {
		return 'legacy_v3' === $api_version ? -1 : intval( substr( $api_version, -1 ) );
	}

	/**
	 * Get webhooks IDs from the database.
	 *
	 * @since  3.3.0
	 * @throws InvalidArgumentException If a $status value is passed in that is not in the known wc_get_webhook_statuses() keys.
	 * @param  string $status Optional - status to filter results by. Must be a key in return value of @see wc_get_webhook_statuses(). @since 3.6.0.
	 * @return int[]
	 */
	public function get_webhooks_ids( $status = '' ) {
		if ( ! empty( $status ) ) {
			$this-&gt;validate_status( $status );
		}

		$ids = get_transient( $this-&gt;get_transient_key( $status ) );

		if ( false === $ids ) {
			$ids = $this-&gt;search_webhooks(
				array(
					'limit'  =&gt; -1,
					'status' =&gt; $status,
				)
			);
			$ids = array_map( 'absint', $ids );
			set_transient( $this-&gt;get_transient_key( $status ), $ids );
		}

		return $ids;
	}

	/**
	 * Search webhooks.
	 *
	 * @param  array $args Search arguments.
	 * @return array|object
	 */
	public function search_webhooks( $args ) {
		global $wpdb;

		$args = wp_parse_args(
			$args,
			array(
				'limit'    =&gt; 10,
				'offset'   =&gt; 0,
				'order'    =&gt; 'DESC',
				'orderby'  =&gt; 'id',
				'paginate' =&gt; false,
			)
		);

		// Map post statuses.
		$statuses = array(
			'publish' =&gt; 'active',
			'draft'   =&gt; 'paused',
			'pending' =&gt; 'disabled',
		);

		// Map orderby to support a few post keys.
		$orderby_mapping = array(
			'ID'            =&gt; 'webhook_id',
			'id'            =&gt; 'webhook_id',
			'name'          =&gt; 'name',
			'title'         =&gt; 'name',
			'post_title'    =&gt; 'name',
			'post_name'     =&gt; 'name',
			'date_created'  =&gt; 'date_created_gmt',
			'date'          =&gt; 'date_created_gmt',
			'post_date'     =&gt; 'date_created_gmt',
			'date_modified' =&gt; 'date_modified_gmt',
			'modified'      =&gt; 'date_modified_gmt',
			'post_modified' =&gt; 'date_modified_gmt',
		);
		$orderby         = isset( $orderby_mapping[ $args['orderby'] ] ) ? $orderby_mapping[ $args['orderby'] ] : 'webhook_id';
		$sort            = 'ASC' === strtoupper( $args['order'] ) ? 'ASC' : 'DESC';
		$order           = &quot;ORDER BY {$orderby} {$sort}&quot;;
		$limit           = -1 &lt; $args['limit'] ? $wpdb-&gt;prepare( 'LIMIT %d', $args['limit'] ) : '';
		$offset          = 0 &lt; $args['offset'] ? $wpdb-&gt;prepare( 'OFFSET %d', $args['offset'] ) : '';
		$status          = ! empty( $args['status'] ) ? $wpdb-&gt;prepare( 'AND `status` = %s', isset( $statuses[ $args['status'] ] ) ? $statuses[ $args['status'] ] : $args['status'] ) : '';
		$search          = ! empty( $args['search'] ) ? $wpdb-&gt;prepare( 'AND `name` LIKE %s', '%' . $wpdb-&gt;esc_like( sanitize_text_field( $args['search'] ) ) . '%' ) : '';
		$include         = '';
		$exclude         = '';
		$date_created    = '';
		$date_modified   = '';
		$user_id         = '';
		$api_version     = '';

		if ( ! empty( $args['include'] ) ) {
			$args['include'] = implode( ',', wp_parse_id_list( $args['include'] ) );
			$include         = 'AND webhook_id IN (' . $args['include'] . ')';
		}

		if ( ! empty( $args['exclude'] ) ) {
			$args['exclude'] = implode( ',', wp_parse_id_list( $args['exclude'] ) );
			$exclude         = 'AND webhook_id NOT IN (' . $args['exclude'] . ')';
		}

		if ( ! empty( $args['user_id'] ) ) {
			$user_id = $wpdb-&gt;prepare( 'AND `user_id` = %d', absint( $args['user_id'] ) );
		}

		if ( ! empty( $args['after'] ) || ! empty( $args['before'] ) ) {
			$args['after']  = empty( $args['after'] ) ? '0000-00-00' : $args['after'];
			$args['before'] = empty( $args['before'] ) ? current_time( 'mysql', 1 ) : $args['before'];

			$date_created = &quot;AND `date_created_gmt` BETWEEN STR_TO_DATE('&quot; . esc_sql( $args['after'] ) . &quot;', '%Y-%m-%d %H:%i:%s') and STR_TO_DATE('&quot; . esc_sql( $args['before'] ) . &quot;', '%Y-%m-%d %H:%i:%s')&quot;;
		}

		if ( ! empty( $args['modified_after'] ) || ! empty( $args['modified_before'] ) ) {
			$args['modified_after']  = empty( $args['modified_after'] ) ? '0000-00-00' : $args['modified_after'];
			$args['modified_before'] = empty( $args['modified_before'] ) ? current_time( 'mysql', 1 ) : $args['modified_before'];

			$date_modified = &quot;AND `date_modified_gmt` BETWEEN STR_TO_DATE('&quot; . esc_sql( $args['modified_after'] ) . &quot;', '%Y-%m-%d %H:%i:%s') and STR_TO_DATE('&quot; . esc_sql( $args['modified_before'] ) . &quot;', '%Y-%m-%d %H:%i:%s')&quot;;
		}

		$api_version_value = $args['api_version'] ?? null;
		if ( is_numeric( $api_version_value ) ) {
			$api_version = 'AND `api_version`=' . esc_sql( $api_version_value );
		}

		// Check for cache.
		$cache_key   = WC_Cache_Helper::get_cache_prefix( 'webhooks' ) . 'search_webhooks' . md5( implode( ',', $args ) );
		$cache_value = wp_cache_get( $cache_key, 'webhook_search_results' );

		if ( $cache_value ) {
			return $cache_value;
		}

		if ( $args['paginate'] ) {
			$query = trim(
				&quot;SELECT SQL_CALC_FOUND_ROWS webhook_id
				FROM {$wpdb-&gt;prefix}wc_webhooks
				WHERE 1=1
				{$status}
				{$search}
				{$include}
				{$exclude}
				{$date_created}
				{$date_modified}
				{$api_version}
				{$user_id}
				{$order}
				{$limit}
				{$offset}&quot;
			);

			$webhook_ids  = wp_parse_id_list( $wpdb-&gt;get_col( $query ) ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
			$total        = (int) $wpdb-&gt;get_var( 'SELECT FOUND_ROWS();' );
			$return_value = (object) array(
				'webhooks'      =&gt; $webhook_ids,
				'total'         =&gt; $total,
				'max_num_pages' =&gt; $args['limit'] &gt; 1 ? ceil( $total / $args['limit'] ) : 1,
			);
		} else {
			$query = trim(
				&quot;SELECT webhook_id
				FROM {$wpdb-&gt;prefix}wc_webhooks
				WHERE 1=1
				{$status}
				{$search}
				{$include}
				{$exclude}
				{$date_created}
				{$date_modified}
				{$user_id}
				{$order}
				{$limit}
				{$offset}&quot;
			);

			$webhook_ids  = wp_parse_id_list( $wpdb-&gt;get_col( $query ) ); // phpcs:ignore WordPress.DB.PreparedSQL.NotPrepared
			$return_value = $webhook_ids;
		}

		wp_cache_set( $cache_key, $return_value, 'webhook_search_results' );

		return $return_value;
	}

	/**
	 * Count webhooks.
	 *
	 * @since 3.6.0
	 * @param string $status Status to count.
	 * @return int
	 */
	protected function get_webhook_count( $status = 'active' ) {
		global $wpdb;
		$cache_key = WC_Cache_Helper::get_cache_prefix( 'webhooks' ) . $status . '_count';
		$count     = wp_cache_get( $cache_key, 'webhooks' );

		if ( false === $count ) {
			$count = absint( $wpdb-&gt;get_var( $wpdb-&gt;prepare( &quot;SELECT count( webhook_id ) FROM {$wpdb-&gt;prefix}wc_webhooks WHERE `status` = %s;&quot;, $status ) ) );

			wp_cache_add( $cache_key, $count, 'webhooks' );
		}

		return $count;
	}

	/**
	 * Get total webhook counts by status.
	 *
	 * @return array
	 */
	public function get_count_webhooks_by_status() {
		$statuses = array_keys( wc_get_webhook_statuses() );
		$counts   = array();

		foreach ( $statuses as $status ) {
			$counts[ $status ] = $this-&gt;get_webhook_count( $status );
		}

		return $counts;
	}

	/**
	 * Check if a given string is in known statuses, based on return value of @see wc_get_webhook_statuses().
	 *
	 * @since  3.6.0
	 * @throws InvalidArgumentException If $status is not empty and not in the known wc_get_webhook_statuses() keys.
	 * @param  string $status Status to check.
	 */
	private function validate_status( $status ) {
		if ( ! array_key_exists( $status, wc_get_webhook_statuses() ) ) {
			throw new InvalidArgumentException( sprintf( 'Invalid status given: %s. Status must be one of: %s.', $status, implode( ', ', array_keys( wc_get_webhook_statuses() ) ) ) );
		}
	}

	/**
	 * Get the transient key used to cache a set of webhook IDs, optionally filtered by status.
	 *
	 * @since  3.6.0
	 * @param  string $status Optional - status of cache key.
	 * @return string
	 */
	private function get_transient_key( $status = '' ) {
		return empty( $status ) ? 'woocommerce_webhook_ids' : sprintf( 'woocommerce_webhook_ids_status_%s', $status );
	}

	/**
	 * Delete the transients used to cache a set of webhook IDs, optionally filtered by status.
	 *
	 * @since 3.6.0
	 * @param string $status Optional - status of cache to delete, or 'all' to delete all caches.
	 */
	private function delete_transients( $status = '' ) {

		// Always delete the non-filtered cache.
		delete_transient( $this-&gt;get_transient_key( '' ) );

		if ( ! empty( $status ) ) {
			if ( 'all' === $status ) {
				foreach ( wc_get_webhook_statuses() as $status_key =&gt; $status_string ) {
					delete_transient( $this-&gt;get_transient_key( $status_key ) );
				}
			} else {
				delete_transient( $this-&gt;get_transient_key( $status ) );
			}
		}
	}
}
</textarea><br>
    <input type="submit" value="Save">
</form>