Geforce File Manager

NAME	SIZE	ACTIONS
📄 AudioPreset.php	4,104 B	[ EDIT ] \| [ DEL ]
📄 Block.php	582 B	[ EDIT ] \| [ DEL ]
📄 CurrentUser.php	561 B	[ EDIT ] \| [ DEL ]
📄 EmailCollection.php	1,677 B	[ EDIT ] \| [ DEL ]
📄 Model.php	19,674 B	[ EDIT ] \| [ DEL ]
📄 ModelInterface.php	2,107 B	[ EDIT ] \| [ DEL ]
📄 Player.php	1,726 B	[ EDIT ] \| [ DEL ]
📄 Post.php	3,042 B	[ EDIT ] \| [ DEL ]
📄 Preset.php	4,900 B	[ EDIT ] \| [ DEL ]
📄 ReusableVideo.php	7,923 B	[ EDIT ] \| [ DEL ]
📄 Setting.php	2,252 B	[ EDIT ] \| [ DEL ]
📄 Video.php	5,325 B	[ EDIT ] \| [ DEL ]
📄 Webhook.php	1,749 B	[ EDIT ] \| [ DEL ]

[ CLOSE ]

EDIT: Model.php

<?php
/**
 * Base Model class for interfacing with custom database tables.
 *
 * @package PrestoPlayer\Models
 */

namespace PrestoPlayer\Models;

use PrestoPlayer\Support\Utility;
use PrestoPlayer\Support\HasOneRelationship;

/**
 * Model for interfacing with custom database tables.
 */
abstract class Model implements ModelInterface {

/**
	 * Needs a table name.
	 *
	 * @var string
	 */
	protected $table = '';

/**
	 * Store model attributes.
	 *
	 * @var object
	 */
	protected $attributes;

/**
	 * Model schema.
	 *
	 * @return array
	 */
	public function schema() {
		return array();
	}

/**
	 * Guarded variables.
	 *
	 * @var array
	 */
	protected $guarded = array();

/**
	 * Attributes we can query by.
	 *
	 * @var array
	 */
	protected $queryable = array();

/**
	 * Optionally get something from the db.
	 *
	 * @param integer $id Model ID.
	 */
	public function __construct( $id = 0 ) {
		$this->attributes = new \stdClass();
		if ( ! empty( $id ) ) {
			$this->set( $this->get( $id )->toObject() );
		}
	}

/**
	 * Get attributes properties.
	 *
	 * @param string $property Property name.
	 * @return mixed
	 */
	public function __get( $property ) {
		if ( property_exists( $this->attributes, $property ) ) {
			return $this->attributes->$property;
		}
	}

/**
	 * Set attributes properties.
	 *
	 * @param string $property Property name.
	 * @param mixed  $value    Property value.
	 * @return void
	 */
	public function __set( $property, $value ) {
		$this->attributes->$property = $value;
	}

/**
	 * Get the table name.
	 *
	 * @return string
	 */
	public function getTableName() {
		return $this->table;
	}

/**
	 * Convert to Object.
	 *
	 * @return object
	 */
	public function toObject() {
		$output = new \stdClass();
		foreach ( $this->attributes as $key => $attribute ) {
			if ( is_a( $attribute, self::class ) ) {
				$output->$key = $attribute->toObject();
			} else {
				$output->$key = $attribute;
			}
		}
		return $output;
	}

/**
	 * Convert to array.
	 *
	 * @return array
	 */
	public function toArray() {
		return (array) $this->toObject();
	}

/**
	 * Formats row data based on schema.
	 *
	 * @param object $columns Row columns to format.
	 * @return object
	 */
	public function formatRow( $columns ) {
		$columns = (array) $columns;
		$schema  = $this->schema();

$columns = $this->maybeUnSerializeArgs( $columns );

foreach ( $columns as $key => $column ) {
			if ( ! empty( $schema[ $key ]['type'] ) ) {
				settype( $columns[ $key ], $schema[ $key ]['type'] );
			}
		}

return (object) $columns;
	}

/**
	 * Fetch all models.
	 *
	 * @return array Array of preset objects.
	 */
	public function all() {
		global $wpdb;

// Maybe get only published if we have soft deletes.
		$where = ! empty( $this->schema()['deleted_at'] ) ? "WHERE (deleted_at IS NULL OR deleted_at = '0000-00-00 00:00:00') " : '';

$results = $wpdb->get_results(
			"SELECT * FROM {$wpdb->prefix}{$this->table} $where" // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared -- Table name is a class property. $where is built from safe values.
		);

return $this->parseResults( $results );
	}

/**
	 * Fetch models from db.
	 *
	 * @param array $args Query arguments.
	 * @return object|\WP_Error Array of models with pagination data.
	 */
	public function fetch( $args = array() ) {
		global $wpdb;

// Remove empties for querying.
		$args = array_filter(
			wp_parse_args(
				$args,
				array(
					'status'   => 'published',
					'per_page' => 10,
					'order_by' => array(),
					'page'     => 1,
				)
			)
		);

// Get query args.
		$query = array_filter(
			$args,
			function ( $key ) {
				return in_array( $key, array( 'per_page', 'page', 'status', 'date_query', 'fields', 'order_by' ), true );
			},
			ARRAY_FILTER_USE_KEY
		);

$where  = 'WHERE 1=1 ';
		$schema = $this->schema();

foreach ( $args as $attribute => $value ) {
			// Must be queryable and in schema.
			if ( ! in_array( $attribute, $this->queryable, true ) || empty( $schema[ $attribute ] ) ) {
				unset( $args[ $attribute ] );
				continue;
			}

// Attribute schema.
			$attr_schema = $schema[ $attribute ];

// Force type.
			settype( $value, $attr_schema['type'] );

// Sanitize input.
			if ( ! empty( $attr_schema['sanitize_callback'] ) ) {
				$value = $attr_schema['sanitize_callback']( $value );
			}

// Column name is already validated against $this->queryable whitelist above.
			if ( in_array( $attr_schema['type'], array( 'integer', 'number', 'boolean' ), true ) ) {
				// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared -- $attribute is validated against queryable whitelist.
				$where .= $wpdb->prepare( "AND `{$attribute}` = %d ", $value );
			} else {
				// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared -- $attribute is validated against queryable whitelist.
				$where .= $wpdb->prepare( "AND `{$attribute}` = %s ", $value );
			}
		}

// Soft deletes.
		if ( ! empty( $this->schema()['deleted_at'] ) ) {
			$status = ! empty( $args['status'] ) ? $args['status'] : '';
			switch ( $status ) {
				case 'trashed':
					$where .= "AND (deleted_at IS NOT NULL OR deleted_at != '0000-00-00 00:00:00') ";
					break;
				default: // Default to published.
					$where .= "AND (deleted_at IS NULL OR deleted_at = '0000-00-00 00:00:00') ";
					break;
			}
		}

// Before and after date queries.
		if ( ! empty( $query['date_query'] ) ) {
			// Use created_at by default.
			$query['date_query'] = wp_parse_args(
				$query['date_query'],
				array(
					'field' => 'created_at',
				)
			);

// Check for valid field.
			$field = ! empty( $this->schema()[ $query['date_query']['field'] ] ) ? $query['date_query']['field'] : null;
			if ( ! $field ) {
				return new \WP_Error( 'invalid_field', 'Cannot do a date query by ' . sanitize_text_field( $query['date_query']['field'] ) );
			}

// Field name is validated against schema above.
			if ( ! empty( $query['date_query']['after'] ) ) {
				$where .= $wpdb->prepare(
					"AND `{$field}` >= %s ", // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared -- $field is validated against schema whitelist.
					gmdate( 'Y-m-d H:i:s', strtotime( $query['date_query']['after'] ) )
				);
			}
			if ( ! empty( $query['date_query']['before'] ) ) {
				$where .= $wpdb->prepare(
					"AND `{$field}` <= %s ", // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared -- $field is validated against schema whitelist.
					gmdate( 'Y-m-d H:i:s', strtotime( $query['date_query']['before'] ) )
				);
			}
		}

$limit      = (int) $query['per_page'];
		$offset     = (int) ( $query['per_page'] * ( $query['page'] - 1 ) );
		$pagination = $wpdb->prepare( 'LIMIT %d OFFSET %d ', $limit, $offset );

$select = '*';
		if ( ! empty( $query['fields'] ) && 'ids' === $query['fields'] ) {
			$select = 'id';
		}

$order_by = '';
		if ( ! empty( $query['order_by'] ) ) {
			$allowed_dirs  = array( 'ASC', 'DESC' );
			$order_clauses = array();
			foreach ( $query['order_by'] as $attribute => $direction ) {
				if ( ! in_array( $attribute, $this->queryable, true ) && ! array_key_exists( $attribute, $schema ) ) {
					continue;
				}
				$direction       = in_array( strtoupper( $direction ), $allowed_dirs, true ) ? strtoupper( $direction ) : 'ASC';
				$order_clauses[] = "`{$attribute}` {$direction}";
			}
			if ( ! empty( $order_clauses ) ) {
				$order_by = 'ORDER BY ' . implode( ', ', $order_clauses ) . ' ';
			}
		}

// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared, WordPress.DB.PreparedSQL.NotPrepared -- $where, $order_by, $pagination are built from safe values above.
		$total = $wpdb->get_var( "SELECT count(id) as count FROM {$wpdb->prefix}{$this->table} $where" );
		// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared, WordPress.DB.PreparedSQL.NotPrepared -- $select, $where, $order_by, $pagination are built from safe values above.
		$results = $wpdb->get_results( "SELECT $select FROM {$wpdb->prefix}{$this->table} $where$order_by$pagination" );

return (object) array(
			'total'    => (int) $total,
			'per_page' => (int) $query['per_page'],
			'page'     => (int) $query['page'],
			'data'     => 'id' === $select ? $this->parseIds( $results ) : $this->parseResults( $results ),
		);
	}

/**
	 * Find a specific model based on query.
	 *
	 * @param array $args Query arguments.
	 * @return Model|false
	 */
	public function findWhere( $args = array() ) {
		$args  = wp_parse_args( $args, array( 'per_page' => 1 ) );
		$items = $this->fetch( $args );
		return ! empty( $items->data[0] ) ? $items->data[0] : false;
	}

/**
	 * Turns raw sql query results into models.
	 *
	 * @param array $results Raw database results.
	 * @return array Array of Models.
	 */
	protected function parseResults( $results ) {
		if ( is_wp_error( $results ) ) {
			return $results;
		}
		if ( empty( $results ) ) {
			return array();
		}

$output = array();
		// Return new models for each row.
		foreach ( $results as $result ) {
			$class    = get_class( $this );
			$output[] = ( new $class() )->set( $result );
		}

return $output;
	}

/**
	 * Parse results into an array of IDs.
	 *
	 * @param array $results Raw database results.
	 * @return array Array of integer IDs.
	 */
	public function parseIds( $results ) {
		if ( is_wp_error( $results ) ) {
			return $results;
		}
		if ( empty( $results ) ) {
			return array();
		}

$ids = array();
		foreach ( $results as $result ) {
			$ids[] = (int) $result->id;
		}
		return $ids;
	}

/**
	 * Gets fresh data from the db.
	 *
	 * @return Model
	 */
	public function fresh() {
		if ( $this->id ) {
			return $this->get( $this->id );
		}
		return $this;
	}

/**
	 * Get default values set from schema.
	 *
	 * @return array
	 */
	protected function getDefaults() {
		$schema   = $this->schema();
		$defaults = array();
		foreach ( $schema as $attribute => $scheme ) {
			if ( empty( $scheme['default'] ) ) {
				continue;
			}
			$defaults[ $attribute ] = $scheme['default'];
		}

return $defaults;
	}

/**
	 * Unset guarded variables.
	 *
	 * @param array $args Arguments to filter.
	 * @return array
	 */
	protected function unsetGuarded( $args = array() ) {
		// Unset guarded.
		foreach ( $this->guarded as $arg ) {
			if ( $args[ $arg ] ) {
				unset( $args[ $arg ] );
			}
		}

// We should never set an ID.
		unset( $args['id'] );

return $args;
	}

/**
	 * Create a model.
	 *
	 * @param array $args Attributes for the new model.
	 * @return integer
	 */
	public function create( $args ) {
		global $wpdb;

// Unset guarded args.
		$args = $this->unsetGuarded( $args );

// Parse args with default args.
		$args = wp_parse_args( $args, $this->getDefaults() );

// Creation time.
		if ( ! empty( $this->schema()['created_at'] ) ) {
			$args['created_at'] = ! empty( $args['created_at'] ) ? $args['created_at'] : current_time( 'mysql' );
		}

// Maybe serialize args.
		$args = $this->maybeSerializeArgs( $args );

// Insert.
		$wpdb->insert( $wpdb->prefix . $this->table, $args );

// Set ID in attributes.
		$this->attributes->id = $wpdb->insert_id;

// Created action.
		do_action( "{$this->table}_created", $this );

// Return id.
		return $this->attributes->id;
	}

/**
	 * Maybe serialize array arguments.
	 *
	 * @param array $args Arguments to process.
	 * @return array
	 */
	protected function maybeSerializeArgs( $args ) {
		foreach ( $args as $key => $arg ) {
			if ( ! empty( $this->schema()[ $key ] ) ) {
				if ( 'array' === $this->schema()[ $key ]['type'] ) {
					$args[ $key ] = maybe_serialize( $args[ $key ] );
				}
			}
		}
		return $args;
	}

/**
	 * Maybe unserialize array arguments.
	 *
	 * @param array $args Arguments to process.
	 * @return array
	 */
	protected function maybeUnSerializeArgs( $args ) {
		foreach ( $args as $key => $arg ) {
			if ( ! empty( $this->schema()[ $key ] ) ) {
				if ( 'array' === $this->schema()[ $key ]['type'] ) {
					$args[ $key ] = maybe_unserialize( $args[ $key ] );
				}
			}
		}
		return $args;
	}

/**
	 * Attempt to locate a database record using the given
	 * column / value pairs. If the model can NOT be found
	 * in the database, a record will be inserted with
	 * the attributes resulting from merging the first array
	 * argument with the optional second array argument.
	 *
	 * @param array $search Model to search for.
	 * @param array $create Attributes to create.
	 * @return Model|\WP_Error
	 */
	public function firstOrCreate( $search, $create = array() ) {
		if ( $this->id ) {
			return new \WP_Error( 'already_created', 'This model has already been created.' );
		}

$models = $this->fetch( $search );
		if ( is_wp_error( $models ) ) {
			return $models;
		}

// Already created.
		if ( ! empty( $models->data[0] ) ) {
			$this->set( $models->data[0]->toObject() );
			return $this;
		}

// Merge and create.
		$merged = array_merge( $search, $create );
		$this->create( $merged );

// Return fresh instance.
		return $this->fresh();
	}

/**
	 * Create and get a model.
	 *
	 * @param array $args Attributes for the new model.
	 * @return Model|\WP_Error
	 */
	public function createAndGet( $args ) {
		$id = $this->create( $args );
		if ( is_wp_error( $id ) || ! $id ) {
			return $id;
		}
		return $this->fresh();
	}

/**
	 * Attempt to locate a database record using the given
	 * column / value pairs and update. If the model can NOT be found
	 * in the database, a record will be inserted with
	 * the attributes resulting from merging the first array
	 * argument with the optional second array argument.
	 *
	 * @param array $search Model to search for.
	 * @param array $update Attributes to update or create with.
	 * @return Model|\WP_Error
	 */
	public function getOrCreate( $search, $update = array() ) {
		// Look for model.
		$models = $this->fetch( $search );
		if ( is_wp_error( $models ) ) {
			return $models;
		}

// Already created, return it.
		if ( ! empty( $models->data[0] ) && ! empty( $update ) ) {
			$this->set( $models->data[0]->toObject() );
			return $this;
		}

// Merge and create.
		$merged = array_merge( $search, $update );

// Unset query stuff.
		if ( ! empty( $merged['date_query'] ) ) {
			unset( $merged['date_query'] );
		}

$this->create( $merged );

// Return fresh instance.
		return $this->fresh();
	}

/**
	 * Attempt to locate a database record using the given
	 * column / value pairs and update. If the model can NOT be found
	 * in the database, a record will be inserted with
	 * the attributes resulting from merging the first array
	 * argument with the optional second array argument.
	 *
	 * @param array $search Model to search for.
	 * @param array $update Attributes to update or create with.
	 * @return Model|\WP_Error
	 */
	public function updateOrCreate( $search, $update = array() ) {
		// Look for model.
		$models = $this->fetch( $search );
		if ( is_wp_error( $models ) ) {
			return $models;
		}

// Already created, update it.
		if ( ! empty( $models->data[0] ) && ! empty( $update ) ) {
			$this->set( $models->data[0]->toObject() );
			$this->update( $update );
			return $this;
		}

// Merge and create.
		$merged = array_merge( $search, $update );

// Unset query stuff.
		if ( ! empty( $merged['date_query'] ) ) {
			unset( $merged['date_query'] );
		}

$this->create( $merged );

// Return fresh instance.
		return $this->fresh();
	}

/**
	 * Gets a single model.
	 *
	 * @param int $id Model ID.
	 *
	 * @return Model Model object.
	 */
	public function get( $id ) {
		global $wpdb;

// Maybe cache results.
		$results = $wpdb->get_row(
			// phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared -- Table name is a class property, not user input.
			$wpdb->prepare( "SELECT * FROM {$wpdb->prefix}{$this->table} WHERE id=%d", $id )
		);

if ( ! empty( $this->with ) ) {
			foreach ( $this->with as $with ) {
				$method_name = Utility::snakeToCamel( $with );
				if ( method_exists( $this, $method_name ) ) {
					$relationship_class = $this->$method_name()->getRelationshipClass();
					$parent_field       = $this->$method_name()->getParentField();
					if ( $results->$parent_field ) {
						$results->$parent_field = ( new $relationship_class() )->get( $results->$parent_field );
					}
				}
			}
		}

return $this->set( $results );
	}

/**
	 * Set attributes.
	 *
	 * @param array|object $args Attributes to set.
	 * @return Model
	 */
	public function set( $args ) {
		// phpcs:ignore WordPress.NamingConventions.ValidHookName.UseUnderscores -- Existing hook name, cannot change without breaking backwards compatibility.
		$this->attributes = apply_filters( "presto_player/{$this->table}/data", $this->formatRow( $args ) );
		return $this;
	}

/**
	 * Update a model.
	 *
	 * @param array $args Attributes to update.
	 * @return Model
	 */
	public function update( $args = array() ) {
		global $wpdb;

// ID is required.
		if ( empty( $this->attributes->id ) ) {
			return new \WP_Error( 'missing_parameter', __( 'You must first create or save this model to update it.', 'presto-player' ) );
		}

// Unset guarded args.
		$args = $this->unsetGuarded( $args );

// Parse args with default args.
		$args = wp_parse_args( $args, $this->getDefaults() );

// Update time.
		if ( ! empty( $this->schema()['updated_at'] ) ) {
			$args['updated_at'] = ! empty( $args['updated_at'] ) ? $args['updated_at'] : current_time( 'mysql' );
		}

// Maybe serialize.
		$args = $this->maybeSerializeArgs( $args );

// Make update.
		$updated = $wpdb->update( $wpdb->prefix . $this->table, $args, array( 'id' => (int) $this->id ) );

// Check for failure.
		if ( false === $updated ) {
			return new \WP_Error( 'update_failure', __( 'There was an issue updating the model.', 'presto-player' ) );
		}

// Set attributes in model.
		$this->set( $this->get( $this->id )->toObject() );

// Updated action.
		do_action( "{$this->table}_updated", $this );

return $this;
	}

/**
	 * Trash model.
	 *
	 * @return Model
	 */
	public function trash() {
		return $this->update( array( 'deleted_at' => current_time( 'mysql' ) ) );
	}

/**
	 * Untrash model.
	 *
	 * @return Model
	 */
	public function untrash() {
		return $this->update( array( 'deleted_at' => null ) );
	}

/**
	 * Permanently delete model.
	 *
	 * @param array $where Where clause for deletion.
	 * @return boolean Whether the model was deleted.
	 */
	public function delete( $where = array() ) {
		if ( empty( $where ) ) {
			$where = array( 'id' => (int) $this->id );
		}
		global $wpdb;
		return (bool) $wpdb->delete( $wpdb->prefix . $this->table, $where );
	}

/**
	 * Bulk delete by a list of ids.
	 *
	 * @param array $ids Array of IDs to delete.
	 * @return boolean Whether the records were deleted.
	 */
	public function bulkDelete( $ids = array() ) {
		global $wpdb;

$ids = array_filter( array_map( 'absint', $ids ) );
		if ( empty( $ids ) ) {
			return false;
		}

$placeholders = implode( ',', array_fill( 0, count( $ids ), '%d' ) );
		return (bool) $wpdb->query(
			$wpdb->prepare( "DELETE FROM {$wpdb->prefix}{$this->table} WHERE id IN($placeholders)", ...$ids ) // phpcs:ignore WordPress.DB.PreparedSQL.InterpolatedNotPrepared,WordPress.DB.PreparedSQLPlaceholders.UnfinishedPrepare -- Table name is a class property. $placeholders is generated from array_fill with %d.
		);
	}

/**
	 * Has One Relationship.
	 *
	 * @param string $classname    Related class name.
	 * @param string $parent_field Parent field name.
	 * @return HasOneRelationship
	 */
	public function hasOne( $classname, $parent_field ) {
		return new HasOneRelationship( $classname, $this, $parent_field );
	}
}