<?php

class DLM_WordPress_Log_Item_Repository implements DLM_Log_Item_Repository {

	/**
	 * Prep where statement for WP DB SQL queries
	 *
	 * @param $filters
	 *
	 * @return string
	 */
	private function prep_where_statement( $filters ) {
		global $wpdb;

		// setup where statements
		$where = array( 'WHERE 1=1' );

		foreach ( $filters as $filter ) {
			$operator = ( ! empty( $filter['operator'] ) ) ? esc_sql( $filter['operator'] ) : '=';

			if ( 'IN' == $operator && is_array( $filter['value'] ) ) {
				array_walk( $filter['value'], 'esc_sql' );
				$value_str = implode( "','", $filter['value'] );
				$where[]   = 'AND `' . esc_sql( $filter['key'] ) . '` ' . $operator . " ('" . $value_str . "')";
			} else {
				$where[] = $wpdb->prepare( 'AND `' . esc_sql( $filter['key'] ) . '` ' . $operator . " '%s'", $filter['value'] );
			}
		}

		$where_str = '';
		if ( count( $where ) > 1 ) {
			$where_str = implode( ' ', $where );
		}

		return $where_str;
	}

	/**
	 * Returns number of rows for given filters
	 *
	 * @param array $filters
	 *
	 * @return int
	 */
	public function num_rows( $filters = array() ) {
		global $wpdb;

		return $wpdb->get_var( "SELECT COUNT(`ID`) FROM {$wpdb->download_log} " . $this->prep_where_statement( $filters ) . ';' );
	}

	/**
	 * Retrieve single item
	 *
	 * @param int $id
	 *
	 * @return DLM_Log_Item
	 * @throws Exception
	 */
	public function retrieve_single( $id ) {
		$logs = $this->retrieve( array( array( 'key' => 'ID', 'value' => absint( $id ) ) ) );

		if ( count( $logs ) != 1 ) {
			throw new Exception( "Log Item not found" );
		}

		return array_shift( $logs );
	}

	/**
	 * @param int $limit
	 * @param int $offset
	 * @param string $order_by
	 * @param string $order
	 *
	 * @return array
	 */
	public function retrieve( $filters = array(), $limit = 0, $offset = 0, $order_by = 'download_date', $order = 'DESC' ) {
		global $wpdb;

		$items = array();

		// prep where statement
		$where_str = $this->prep_where_statement( $filters );

		// setup limit & offset.
		$limit_str = '';
		$limit     = absint( $limit );
		$offset    = absint( $offset );
		if ( $limit > 0 ) {
			$limit_str = "LIMIT {$offset},{$limit}";
		}

		// escape order_by
		$order_by = esc_sql( $order_by );

		// order can only be ASC or DESC
		$order = ( 'ASC' === strtoupper( $order ) ) ? 'ASC' : 'DESC';
		// query
		$data = $wpdb->get_results(
			"SELECT * FROM {$wpdb->download_log} {$where_str} ORDER BY `{$order_by}` {$order} {$limit_str};"
		);

		if ( count( $data ) > 0 ) {
			foreach ( $data as $row ) {
				$log_item = new DLM_Log_Item();
				$log_item->set_id( $row->ID );
				$log_item->set_user_id( $row->user_id );
				$log_item->set_user_ip( $row->user_ip );
				$log_item->set_user_uuid( $row->user_ip );
				$log_item->set_user_agent( $row->user_agent );
				$log_item->set_download_id( $row->download_id );
				$log_item->set_version_id( $row->version_id );
				$log_item->set_version( $row->version );
				$log_item->set_download_date( new DateTime( $row->download_date ) );
				$log_item->set_download_status( $row->download_status );
				$log_item->set_download_status_message( $row->download_status_message );
				$log_item->set_meta_data( ( null !== $row->meta_data ? json_decode( $row->meta_data ) : '' ) );
				$items[] = apply_filters( 'dlm_retreive_log_item', $log_item, $row, $data );
			}
		}

		return $items;
	}


	/**
	 * Download logging
	 *
	 * @param DLM_Log_Item $log_item
	 *
	 * @throws Exception
	 *
	 * @return bool
	 */
	public function persist( $log_item ) {
		// Don't log if admin hit does not need to be logged
		if ( DLM_Logging::ignore_admin_log() ) {
			return;
		}

		$logging = DLM_Logging::get_instance();
		global $wpdb;
		$download_id = $log_item->get_download_id();
		$version_id  = $log_item->get_version_id();
		$url         = $log_item->get_current_url();
		// Don't count if only unique IPs are counted and the IP has already downloaded the version.
		if ( $logging->is_count_unique_ips_only() && true === $logging->has_uuid_downloaded_version( absint( $version_id ) ) ) {
			return;
		}
		// Don't count if in the admin area.
		if ( false !== strpos( $url, admin_url() ) ) {
			return;
		}

		// allow filtering of log item.
		$log_item = apply_filters( 'dlm_log_item', $log_item, $download_id, $version_id );

		// hide wpdb errors to prevent errors in download request.
		$wpdb->hide_errors();

		// Set the log date. Should be current date, as logs will be separated by dates.
		$log_date = current_time( 'Y-m-d', false );

		//Check first if logging is enabled and the table exists, db upgrade process might have failed.
		if ( DLM_Logging::is_logging_enabled() && DLM_Utils::table_checker( $wpdb->dlm_reports ) ) {

			$today = $wpdb->get_results( $wpdb->prepare( "SELECT  * FROM {$wpdb->dlm_reports} WHERE date = %s;", $log_date ), ARRAY_A );

			// check if entry exists.
			if ( null !== $today && ! empty( $today ) ) {

				$downloads = json_decode( $today[0]['download_ids'], ARRAY_A );

				if ( isset( $downloads[ $download_id ] ) ) {
					$downloads[ $download_id ]['downloads'] = $downloads[ $download_id ]['downloads'] + 1;
				} else {
					$downloads[ $download_id ] = array(
						'downloads' => 1,
						'title'     => get_the_title( $download_id ),
					);
				}

				$result = $wpdb->update(
					"{$wpdb->dlm_reports}",
					array(
						'download_ids' => wp_json_encode( $downloads ),
					),
					array(
						'date' => $log_date,
					)
				);

				if ( false === $result ) {
					throw new Exception( 'Unable to insert log item in WordPress database' );
				}
			} else {

				// insert row.
				$result = $wpdb->insert(
					"{$wpdb->dlm_reports}",
					array(
						'date'         => $log_date,
						'download_ids' => wp_json_encode(
							array(
								$download_id => array(
									'downloads' => 1,
									'title'     => get_the_title( $download_id ),
								),
							)
						),
					)
				);

				if ( false === $result ) {
					throw new Exception( 'Unable to insert log item in WordPress database' );
				}
			}
		}

		$log_item->increase_download_count();
		// trigger action when new log item was added for a download request.
		do_action( 'dlm_downloading_log_item_added', $log_item, $download_id, $version_id );

		return true;
	}

	/**
	 * Update Download and Version download counts
	 *
	 * @param [int] $download_id The ID of the Download.
	 * @param [int] $version_id The ID of the Version corresponding to the Download.
	 * @return void
	 * @since 4.5.0
	 */
	public function update_detailed_download_count( $download_id, $version_id ) {

		$download_info = $this->retrieve_single_download( $download_id );

		if ( false === $download_info ) {
			return;
		}

	}

	/**
	 * Retrieve download info from custom table
	 *
	 * @param  mixed $download_id The ID of the Download.
	 * @return mixed
	 * @since 4.5.0
	 */
	public function retrieve_single_log( $download_id ) {

		global $wpdb;

		// Let's get the results that contain all the info we need from both tables.
		$result = $wpdb->get_results( $wpdb->prepare( "SELECT * FROM {$wpdb->dlm_single_download} dlm_download INNER JOIN {$wpdb->posts} dlm_post ON dlm_download.download_id = dlm_post.ID WHERE dlm_download.download_id = %s", $download_id ), ARRAY_A );

		if ( null === $result || empty( $result ) ) {
			return false;
		}

		return $result;

	}

	/**
	 * Retrieve download info from custom table
	 *
	 * @param  mixed $date The date for the desired report.
	 * @return mixed
	 * @since 4.5.0
	 */
	public function retrieve_single_day( $date ) {

		global $wpdb;

		// Let's get the results that contain all the info we need from both tables.
		$result = $wpdb->get_results( $wpdb->prepare( "SELECT * FROM {$wpdb->dlm_reports} dlm_download WHERE dlm_download.date = %s", $date ), ARRAY_A );

		if ( null === $result || empty( $result ) ) {
			return false;
		}

		return $result;

	}
}