AutomotiveInvestor/scm-platinum

ea3b858

Sep 9, 2018

khadlock Cleanup

2 contributors

Users who have contributed to this file

Raw Blame History

602 lines (533 sloc) 19.6 KB

	<?php
	if ( !defined( 'ABSPATH' ) ) {
	exit;
	}

	/**
	* Handle AJAX requests for Platinum results.
	*
	* This replicates the functionality originally embodied by
	* wp-content/themes/scm_responsive/platinum/result.php.
	*/
	function scm_platinum_ajax_result() {
	// This HTTP POST variable is used by admin-ajax.php for routing to
	// the proper action. At this point, we don't need it anymore, so we
	// can get rid of it before passing the "real" POST data along.
	unset( $_POST['action'] );

	parse_str( str_replace( ' ', '%20', @file_get_contents( 'php://input' ) ),
	$params );
	$query_args = array(
	'page' => isset( $_POST['pl-page'] ) ? $_POST['pl-page'] : 1,
	'page-size' => isset( $_POST['page-size'] ) ? $_POST['page-size'] : 12,
	'sort-by' => isset( $_POST['sort-by'] ) ? $_POST['sort-by'] : 'LATEST',
	);
	// Later arguments to array_merge() clobber earlier ones.
	$query_args = array_merge( $params, $query_args );

	// if search is set to return all
	if ( isset( $_REQUEST['all'] ) ) {
	// Later arguments to array_merge() clobber earlier ones.
	$query_args = array_merge( $query_args, array(
	'page-size' => 12,
	'sort-by' => 'LATEST',
	) );
	}

	$response = scm_platinum_query_api(
	scm_platinum_get_site_specific_endpoint( 'platinumsearch' ) . '/',
	$query_args
	);

	wp_send_json( $response );
	}
	add_action( 'wp_ajax_scm_platinum_result', 'scm_platinum_ajax_result' );
	add_action( 'wp_ajax_nopriv_scm_platinum_result', 'scm_platinum_ajax_result' );

	function scm_platinum_ajax_get_all_models() {
	// This HTTP POST variable is used by admin-ajax.php for routing to
	// the proper action. At this point, we don't need it anymore, so we
	// can get rid of it before passing the "real" POST data along.
	unset( $_POST['action'] );

	$response = scm_platinum_get_year_model_list();
	wp_send_json( $response );
	}
	add_action( 'wp_ajax_scm_platinum_get_all_models',
	'scm_platinum_ajax_get_all_models' );
	add_action( 'wp_ajax_nopriv_scm_platinum_get_all_models',
	'scm_platinum_ajax_get_all_models' );

	function scm_platinum_ajax_get_models_by_make() {
	// This HTTP POST variable is used by admin-ajax.php for routing to
	// the proper action. At this point, we don't need it anymore, so we
	// can get rid of it before passing the "real" POST data along.
	unset( $_POST['action'] );

	$response = scm_platinum_get_year_make_model_list( $_POST['make'] );
	wp_send_json( $response );
	}
	add_action( 'wp_ajax_scm_platinum_get_models_by_make',
	'scm_platinum_ajax_get_models_by_make' );
	add_action( 'wp_ajax_nopriv_scm_platinum_get_models_by_make',
	'scm_platinum_ajax_get_models_by_make' );

	/**
	* Handle AJAX requests for Platinum high bid requests.
	*
	* This is called by the edit page of a digitalissue when working with
	* the Auction fields. This replicates the functionality originally
	* embodied by wp-content/themes/scm_responsive/platinum/highbid.php.
	*/
	function scm_platinum_ajax_highbid() {
	// This HTTP POST variable is used by admin-ajax.php for routing to
	// the proper action. At this point, we don't need it anymore, so we
	// can get rid of it before passing the "real" POST data along.
	unset( $_POST['action'] );

	$api_response = scm_platinum_query_api(
	scm_platinum_get_site_specific_endpoint( 'highsaleforauction' ) . '/' .
	$_POST['id']
	);

	$listing = $api_response->Listings[0];

	// This is an array of arrays because the JavaScript that requests
	// this expects it that way. It's not functionally necessary, and
	// this should probably be refactored.
	$response = array( array(
	'title' => implode( ' ', array(
	$listing->VehicleListing->Year,
	$listing->VehicleListing->Make,
	$listing->VehicleListing->Model,
	) ),
	'price' => $listing->Price,
	'id' => $listing->ListingID,
	) );

	wp_send_json( $response );
	}
	add_action( 'wp_ajax_scm_platinum_highbid', 'scm_platinum_ajax_highbid' );

	function scm_platinum_ajax_graph() {
	// This HTTP POST variable is used by admin-ajax.php for routing to
	// the proper action. At this point, we don't need it anymore, so we
	// can get rid of it before passing the "real" POST data along.
	unset( $_POST['action'] );

	$is_var_usable = function( $var ) {
	if ( is_string( $var) && !empty( $var ) && 'undefined' !== $var ) {
	return true;
	}
	else {
	return false;
	}
	};

	parse_str( str_replace( ' ', '%20', @file_get_contents( 'php://input' ) ),
	$params );
	$query_args = array(
	'graphtype' =>
	$is_var_usable( $_POST['graphtype'] ) ?
	$_POST['graphtype'] :
	'apy',
	'yearStart' =>
	$is_var_usable( $_POST['yearStart'] ) ?
	$_POST['yearStart'] :
	'1800',
	'yearEnd' =>
	$is_var_usable( $_POST['yearEnd'] ) ?
	$_POST['yearEnd'] :
	current_time( 'Y' ),
	'sold' =>
	'true',
	);
	// Later arguments to array_merge() clobber earlier ones.
	$query_args = array_merge( $params, $query_args );

	switch ( $query_args['graphtype'] ) {
	case 'apy':
	$query_type = 'avgPriceByYear';
	break;
	case 'ts':
	$query_type = 'totalSales';
	break;
	case 'is':
	$query_type = 'individualSales';
	break;
	case 'apmy':
	$query_type = 'avgPriceByModelYear';
	break;
	}

	$year_range['start'] = $query_args['yearStart'];
	$year_range['end'] = $query_args['yearEnd'];

	// We don't want to pass some query arguments to the API. This
	// replicates the 'removeqsvar' functionality in the earlier
	// theme-entwined version of Platinum.
	unset( $query_args['yearStart'] );
	unset( $query_args['yearEnd'] );
	unset( $query_args['listingcompany'] );

	$api_response = scm_platinum_query_api(
	implode( '/', array(
	scm_platinum_get_site_specific_endpoint( $query_type ),
	$year_range['start'],
	$year_range['end'] ) ),
	$query_args );

	$year = array();
	$price = array();
	switch ( $query_type ) {
	case 'avgPriceByYear':
	foreach ( $api_response->List as $item ) {
	$price[] = array( $item->AvgPrice, $item->Year );
	$year[] = $item->Year;
	}
	break;

	case 'avgPriceByModelYear':
	foreach ( $api_response->List as $item ) {
	$price[] = array( $item->Price, $item->Year );
	$year[] = $item->Year;
	}
	break;

	case 'totalSales':
	foreach ( $api_response->List as $item ) {
	$price[] = array( $item->Total, $item->Year );
	$year[] = $item->Year;
	}
	break;
	}

	$ajax_response_data = '';
	switch ( $query_type ) {
	case 'individualSales':
	// This is currently disabled on the front end. Marc has been
	// reworking this.
	/*
	$max_results = 200;
	if ( sizeof( $api_response->List ) > $max_results ) {
	$api_response->List =
	array_slice(
	$api_response->List,
	round( ( sizeof( $api_response->List ) - $max_results ) / 2, 0 ),
	$max_results );

	$ajax_response_data = array(
	'cols' => array(
	array(
	'type' => 'date',
	'label' => 'Auction Date',
	),
	),
	);

	$year_array = array();
	foreach ( $api_response->List as $item ) {
	$year_array[] = $item->Year;
	}
	$year_array = array_unique( $year_array );

	foreach ( $year_array as $year ) {
	$ajax_response_data['cols'][] = array(
	'type' => 'number',
	'label' => "$year - ",
	);
	}
	}
	*/
	break;

	case 'avgPriceByYear':
	$ajax_response_data = array(
	'cols' => array(
	array(
	'label' => 'Auction Date',
	'type' => 'date',
	),
	array(
	'label' => 'Average Sales',
	'type' => 'number',
	),
	),
	'rows' => array(),
	);
	$ajax_response_data = scm_platinum_add_price_rows_to_response_data(
	$ajax_response_data, $price );
	break;

	case 'avgPriceByModelYear':
	$ajax_response_data = array(
	'cols' => array(
	array(
	'label' => 'Model Year',
	'type' => 'date',
	),
	array(
	'label' => 'Average Sales',
	'type' => 'number',
	),
	),
	'rows' => array(),
	);
	$ajax_response_data = scm_platinum_add_price_rows_to_response_data(
	$ajax_response_data, $price );
	break;

	case 'totalSales':
	$ajax_response_data = array(
	'cols' => array(
	array(
	'label' => 'Auction Year',
	'type' => 'date',
	),
	array(
	'label' => 'Total Sales',
	'type' => 'number',
	),
	),
	);
	$ajax_response_data = scm_platinum_add_price_rows_to_response_data(
	$ajax_response_data, $price );
	break;
	}

	wp_send_json( json_encode( $ajax_response_data ) );
	}
	add_action( 'wp_ajax_scm_platinum_graph', 'scm_platinum_ajax_graph' );
	add_action( 'wp_ajax_nopriv_scm_platinum_graph', 'scm_platinum_ajax_graph' );

	function scm_platinum_add_price_rows_to_response_data( $ajax_response_data,
	$price ) {
	$ajax_response_data['rows'] = array();

	foreach ( $price as $item ) {
	$ajax_response_data['rows'][] = array(
	'c' => array(
	array(
	'v' => 'Date( ' . $item[1] . ', 0, 01 )',
	),
	array(
	'v' => $item[0],
	),
	),
	);
	}

	return $ajax_response_data;
	}

	function scm_platinum_get_year_make_list( $year_from = 1800,
	$year_to = 2050 ) {
	$args = array(
	'page' => 1,
	'page-size' => 1000,
	);
	return scm_platinum_query_api(
	scm_platinum_get_site_specific_endpoint( 'yearmakelist' ) . '/' .
	$year_from . '/' . $year_to,
	$args
	);
	}

	function scm_platinum_get_year_model_list( $year_from = 1800,
	$year_to = 2050) {
	$args = array(
	'page' => 1,
	'page-size' => 5000,
	);
	return scm_platinum_query_api(
	scm_platinum_get_site_specific_endpoint( 'yearmodellist' ) . '/' .
	$year_from . '/' . $year_to,
	$args
	);
	}

	function scm_platinum_get_year_make_model_list( $make ) {
	$make = str_replace( ' ', '%20', $make );

	$args = array(
	'page' => 1,
	'page-size' => 1000,
	);
	return scm_platinum_query_api(
	scm_platinum_get_site_specific_endpoint( 'yearmakemodellist' ) . '/' .
	$make,
	$args
	);
	}

	function scm_platinum_get_auction_list() {
	return scm_platinum_query_api(
	scm_platinum_get_site_specific_endpoint( 'auctionlist' )
	);
	}

	function scm_platinum_get_listing_company_list() {
	return scm_platinum_query_api(
	scm_platinum_get_site_specific_endpoint( 'listingcompanylist' )
	);
	}

	function scm_platinum_get_platinum_search() {
	$args = array(
	'page' => 1,
	'page-size' => 12,
	'sort-by' => 'LATEST',
	);
	return scm_platinum_query_api(
	scm_platinum_get_site_specific_endpoint( 'platinumsearch' ) . '/',
	$args,
	5
	);
	}

	function scm_platinum_get_single_listing( $listing_id ) {
	$result = scm_platinum_query_api(
	scm_platinum_get_site_specific_endpoint( 'listingid' ) . '/' .
	$listing_id
	);

	if ( isset( $result ) ) {
	// TODO. Handle this exceptional case.
	//if ( isset( $result->Listings ) && count( $result->Listings ) != 1 ) {}

	if ( isset( $result->Listings[0] ) ) {
	$single_listing = $result->Listings[0];
	}
	else {
	$single_listing = NULL;
	}
	}
	else {
	$single_listing = NULL;
	}

	return $single_listing;
	}

	function scm_platinum_query_api( $resource, $args = NULL, $retry_max = 50 ) {
	$api_url = 'http://api.automotiveinvestor.com/VehicleService';
	$resource_url = $api_url . '/' . $resource;
	if ( $args ) {
	// $defaults = array();
	// $args = wp_parse_args( $args, $defaults );
	$resource_url .= '?' . http_build_query( $args );
	}

	preg_match( '/[\S]+.automotiveinvestor.com(.+)/', $resource_url,
	$matches );
	$resource_path = $matches[1];

	$retry_count = 0;
	do {
	// Separate the timestamp by the decimal point. Everything
	// before the decimal is the unix timestamp in seconds.
	$timestamp = explode( '.', microtime( true ) );

	// If the call to microtime() lands right on a second, there
	// will be nothing after the decimal point.
	if ( empty( $timestamp[1] ) ) {
	$timestamp[1] = '0';
	}

	// The miliseconds are the first three figures after the decimal
	// of the timestamp. Make sure we get a three digit number by
	// padding to the right with zeroes.
	$miliseconds = str_pad( substr( $timestamp[1], 0, 3 ), 3, '0' );
	// We only needed the $miliseconds all along, so forget the
	// $timestamp.
	unset( $timestamp );

	$date = current_time( "Y-m-d\TH:i:s.{$miliseconds}P", true );
	$header_auth_fields = array(
	'x-ai-nonce' => $date,
	'x-ai-timestamp' => $date,
	);

	// Create request header to be passed to CURL.
	$request_header[] = 'Accept: application/json';
	foreach ( $header_auth_fields as $key => $value ) {
	$request_header[] = $key . ': ' . $value;
	}
	$request_header[] = 'authorization: ' .
	scm_platinum_api_auth_token( $header_auth_fields, $resource_path );

	$ch = curl_init();
	curl_setopt( $ch, CURLOPT_URL, $resource_url );
	curl_setopt( $ch, CURLOPT_HTTPHEADER, $request_header );
	curl_setopt( $ch, CURLOPT_RETURNTRANSFER, true );
	curl_setopt( $ch, CURLOPT_ENCODING, 'gzip' );
	curl_setopt( $ch, CURLOPT_IPRESOLVE, CURL_IPRESOLVE_V4 );
	$curl_response = curl_exec( $ch );
	$curl_error = curl_error( $ch );
	curl_close( $ch );

	if ( $curl_error ) {
	throw new Exception( $curl_error );
	}

	$retry_count++;
	}
	while ( !$curl_response && $retry_count < $retry_max );

	if ( $curl_response ) {
	$response_json_decoded = json_decode( $curl_response );
	}
	else {
	throw new Exception( 'Maximum retries exhausted when querying API.' );
	}

	return $response_json_decoded;
	}

	function scm_platinum_api_auth_token( $header_fields, $resource_path ) {
	// Make a copy of $header_fields with all lower case fields to use
	// for authentication.
	$auth_header = array_change_key_case( $header_fields );
	// Encode auth header field values and prepend encoded values with
	// keys.
	array_walk( $auth_header, function ( &$value, $key ) {
	$value = $key . ':' . base64_encode( utf8_encode( $value ) );
	} );
	// Convert auth header array into newline separated string.
	$auth_header = implode( "\n", $auth_header );

	$shared_key = "You've been testing your units again, haven't you?";
	$signature = base64_encode( hash_hmac(
	'sha1', utf8_encode( $resource_path . "\n" . $auth_header ),
	utf8_encode( $shared_key ), true ) );

	return "AI SCM.UnitTest:" . $signature;
	}

	/**
	* Return the SCM/ACC-specific endpoint name.
	*
	* Depending on the WordPress site title, return the name of the proper
	* endpoint.
	*
	* @param string $canonical_endpoint canonical name of the endpoint,
	* which happens to be the same as the
	* name of the SCM-specific endpoint
	* @return string site-specific endpoint name, or the canonical name
	* provided as $canonical_endpoint if no site-specific
	* endpoint name is defined
	*/
	function scm_platinum_get_site_specific_endpoint( $canonical_endpoint ) {
	// Define the site-specific endpoint names. The array key for each
	// site's collection should be the return value of
	// get_bloginfo( 'name' )
	// Examples: 'Sports Car Market', 'American Car Collector'
	$endpoint_names['American Car Collector'] = array(
	'auctionlist' => 'accauctionlist',
	'platinumsearch' => 'accplatinumsearch',
	'yearmakelist' => 'accyearmakelist',
	'yearmodellist' => 'accyearmodellist',
	'yearmakemodellist' => 'accyearmakemodellist',
	// Graph endpoints
	'avgPriceByYear' => 'accAvgPriceByYear',
	'totalSales' => 'accTotalSales',
	'individualSales' => 'accIndividualSales',
	'avgPriceByModelYear' => 'accAvgPriceByModelYear',
	// These endpoints do not have site-specific equivalents because
	// they query single listings
	//'highsaleforauction' => '',
	//'listingcompanylist' => '',
	//'listingid' => '',
	);

	$site_name = get_bloginfo( 'name' );

	if ( isset( $endpoint_names[ $site_name ][ $canonical_endpoint ] ) ) {
	$site_specific_endpoint =
	$endpoint_names[ $site_name ][ $canonical_endpoint ];
	}
	// If there is no endpoint name defined, return the canonical name.
	// The canonical names were chosen to match the Sports Car Market
	// endpoint names exactly. As a result, the SCM names have been left
	// undefined and are caught by this condition.
	else {
	$site_specific_endpoint = $canonical_endpoint;
	}

	return $site_specific_endpoint;
	}

	/**
	* Return the Platinum listing ID corresponding to the given SCM number,
	* or false if no corresponding listing exists.
	*
	* @param integer $scm_number The internal SCM number of the Platinum
	* listing
	*
	* @return integer\|boolean The Platinum listing ID corresponding to the
	* given SCM number, or false if no
	* corresponding listing exists.
	*/
	function scm_platinum_get_listing_id_from_scm_number( $scm_number ) {
	$args = array(
	'page' => 1,
	'page-size' => 1,
	'sort-by' => 'LATEST',
	'scmnumber' => intval( $scm_number ),
	);
	$api_response = scm_platinum_query_api(
	scm_platinum_get_site_specific_endpoint( 'platinumsearch' ) . '/',
	$args
	);

	if ( $api_response ) {
	$api_response = json_decode( $api_response );

	if ( $api_response->count ) {
	if ( !empty( $api_response->rows[0]->ListingID ) ) {
	return $api_response->rows[0]->ListingID;
	}
	else {
	return false;
	}
	}
	else {
	return false;
	}
	}
	else {
	throw new Exception( 'Platinum API failed to respond' );
	}
	}

AutomotiveInvestor/scm-platinum Private

Users who have contributed to this file

1951 Ferrari 212 Export Berlinetta

Get the SCM Newsletter

Almost done! Confirm your subscription with the email in your inbox.