/home/techb158/primomovers.ca/wp-content/plugins/optinmonster/OMAPI
Edit: /home/techb158/primomovers.ca/wp-content/plugins/optinmonster/OMAPI/Api.php (14508B)
get_api_credentials();
if ( ! empty( $creds ) ) {
// Check if we have the new API and if so only use it.
$creds = ! empty( $creds['apikey'] )
? array( 'apikey' => $creds['apikey'] )
: array(
'user' => ! empty( $creds['user'] ) ? $creds['user'] : '',
'key' => ! empty( $creds['key'] ) ? $creds['key'] : '',
);
}
}
return new self( $route, $creds, $method, $version );
}
/**
* Primary class constructor.
*
* @since 1.0.0
*
* @param string $route The API route to target.
* @param array $creds Array of API credentials.
* @param string $method The API method.
* @param string $version The version number of our API.
*/
public function __construct( $route, $creds, $method = 'POST', $version = 'v1' ) {
// Set class properties.
$this->route = $route;
$this->version = $version;
$this->method = $method;
$this->user = ! empty( $creds['user'] ) ? $creds['user'] : '';
$this->key = ! empty( $creds['key'] ) ? $creds['key'] : '';
$this->apikey = ! empty( $creds['apikey'] ) ? $creds['apikey'] : '';
$this->plugin = OMAPI::get_instance()->plugin_slug;
self::$instance = $this;
}
/**
* Processes the API request.
*
* @since 1.0.0
*
* @param array $args Request args.
*
* @return mixed $value The response to the API call.
*/
public function request( $args = array() ) {
// Build the body of the request.
$body = array(
'omapi-user' => $this->user,
'omapi-key' => $this->key,
);
$body = array_filter( $body );
// If a plugin API request, add the data.
if ( 'info' === $this->route || 'update' === $this->route ) {
$body['omapi-plugin'] = $this->plugin;
}
// Add in additional data if needed.
if ( ! empty( $this->additional_data ) ) {
$body['omapi-data'] = maybe_serialize( $this->additional_data );
}
$body = wp_parse_args( $args, $body );
$url = in_array( $this->method, array( 'GET', 'DELETE' ), true )
? add_query_arg( array_map( 'urlencode', $body ), $this->get_url() )
: $this->get_url();
$url = esc_url_raw( $url );
$plugins = new OMAPI_Plugins();
// Build the headers of the request.
$headers = array(
'Content-Type' => 'application/x-www-form-urlencoded',
'Cache-Control' => 'no-store, no-cache, must-revalidate, max-age=0, post-check=0, pre-check=0',
'Pragma' => 'no-cache',
'Expires' => 0,
'Origin' => site_url(),
'OMAPI-Referer' => site_url(),
'OMAPI-Sender' => 'WordPress',
'OMAPI-Site' => esc_attr( get_option( 'blogname' ) ),
'OMAPI-Version' => esc_attr( OMAPI::get_instance()->version ),
'OMAPI-Plugins' => $plugins->get_active_plugins_header_value(),
);
if ( $this->apikey ) {
$headers['X-OptinMonster-ApiKey'] = $this->apikey;
}
// If the onboarding key is set, let's use that as the API key.
if ( ! empty( $args['onboardingApiKey'] ) ) {
$headers['X-OptinMonster-ApiKey'] = $args['onboardingApiKey'];
}
// Setup data to be sent to the API.
$data = array(
'headers' => $headers,
'body' => $body,
'timeout' => 3000,
'sslverify' => false,
'method' => $this->method,
);
// Perform the query and retrieve the response.
$this->handle_response( wp_remote_request( $url, $data ) );
// Bail out early if there are any errors.
if ( is_wp_error( $this->response ) ) {
return $this->response;
}
// If we used the legacy api-creds, we'll get back a new api key.
if (
empty( $this->apikey )
&& ! empty( $this->response['headers']['x-optinmonster-apikey'] )
) {
$this->apikey = sanitize_text_field( $this->response['headers']['x-optinmonster-apikey'] );
}
$error = $this->check_response_error();
// Bail out early if there are any errors.
if ( is_wp_error( $error ) ) {
return $error;
}
// Return the json decoded content.
return $this->response_body;
}
/**
* Handle setting up the object properties from the response.
*
* @since 2.6.6
*
* @param object $response The response object from wp_remote_request.
*
* @return void
*/
public function handle_response( $response ) {
$this->response = $response;
// Get the response code and response body.
$this->response_code = wp_remote_retrieve_response_code( $response );
$this->response_body = json_decode( wp_remote_retrieve_body( $response ) );
$this->decode_error = json_last_error();
}
/**
* Check for an error response, and return an applicable WP_Error instance.
*
* @since 2.6.6
*
* @return boolean|WP_Error False if no errors, and WP_Error object if found.
*/
public function check_response_error() {
$code = (int) $this->response_code;
if ( $code < 400 ) {
return false;
}
// If not successful status header, send back error.
$type = ! empty( $this->response_body->type ) ? $this->response_body->type : 'api-error';
$message = ! empty( $this->response_body->message ) ? stripslashes( $this->response_body->message ) : '';
if ( empty( $message ) ) {
$message = ! empty( $this->response_body->status_message ) ? stripslashes( $this->response_body->status_message ) : '';
}
if ( empty( $message ) ) {
$message = ! empty( $this->response_body->error ) ? stripslashes( $this->response_body->error ) : 'unknown';
}
$message = sprintf(
/* translators: %1$s - API response code, %2$s - returned error from API. */
__( 'The API returned a
%1$s response with this message:
%2$s', 'optin-monster-api' ),
$this->response_code,
$message
);
return new WP_Error( $type, $message, $this->response_code );
}
/**
* The gets the URL based on our base, endpoint and version
*
* @since 1.8.0
*
* @return string The API url.
*/
public function get_url() {
return $this->base . '/' . $this->version . '/' . $this->route;
}
/**
* Sets a class property.
*
* @since 1.0.0
*
* @param string $key The property to set.
* @param string $val The value to set for the property.
* @return mixed $value The response to the API call.
*/
public function set( $key, $val ) {
$this->{$key} = $val;
}
/**
* Allow additional data to be passed in the request
*
* @since 1.0.0
*
* @param array $data The data to set.
*
* @return void
*/
public function set_additional_data( array $data ) {
$this->additional_data = array_merge( $this->additional_data, $data );
}
/**
* Clear additional data
*
* @since 1.9.0
*
* return void
*/
public function clear_additional_data() {
$this->additional_data = null;
return $this;
}
/**
* Get the request credentials for this API object.
*
* @since 2.3.0
*
* @return array Array containing API credentials.
*/
public function get_creds() {
return ! empty( $this->apikey )
? array( 'apikey' => $this->apikey )
: array(
'user' => $this->user,
'key' => $this->key,
);
}
/**
* Returns the last instantiated instance of this class.
*
* @since 1.9.10
*
* @return OMAPI_Api A single instance of this class.
*/
public static function instance() {
return self::$instance;
}
/**
* Fetch from the OM /me route, and cache results if no error..
*
* @since 2.6.6
*
* @param bool $refresh Whether to refresh the cache.
* @param array $creds Existing credentials array.
*
* @return array Requested /me data.
*/
public static function fetch_me_cached( $refresh = false, $creds = array() ) {
$api = self::build( 'v2', 'me?includeOnboarding=true', 'GET', $creds );
$creds = array( $api->user, $api->key, $api->apikey );
$creds = array_filter( $creds );
$creds = array_values( $creds );
$cache_key = 'omapp_me_cached' . md5( implode( ':', $creds ) );
$result = get_transient( $cache_key );
if ( empty( $result ) || $refresh ) {
$result = $api->request();
if ( ! is_wp_error( $result ) ) {
set_transient( $cache_key, $result, DAY_IN_SECONDS );
// Force the option to be updated when we gather new data from the API.
self::return_option_from_fetch( $result, array(), $creds, true );
}
}
return $result;
}
/**
* Fetch from the OM /me route to complete the plugin connection after onboarding.
*
* This differs from `OMAPI_Api::fetch_me_cached` in that there is no results
* caching. Fresh results are pulled every time this method is called.
*
* @since 2.16.6
*
* @param array $creds Existing credentials array.
*
* @return array Requested /me data.
*/
public static function fetch_me_onboarding( $creds = array() ) {
$api = self::build( 'v2', 'me?includeOnboarding=true', 'GET', $creds );
$result = $api->request( array( 'onboardingApiKey' => $creds['onboardingApiKey'] ) );
if ( ! is_wp_error( $result ) ) {
// Force the option to be updated when we gather new data from the API.
self::return_option_from_fetch( $result, array(), $creds, true );
OMAPI_ApiKey::init_connection( $api->apikey );
}
return $result;
}
/**
* Fetch from the OM /me route, and store data to our options.
*
* @since 2.0.0
*
* @param array $option Existing options array.
* @param array $creds Existing credentials array.
*
* @return array Updated options array.
*/
public static function fetch_me( $option = array(), $creds = array() ) {
if ( ! empty( $creds['onboardingApiKey'] ) ) {
$option = array();
$result = self::fetch_me_onboarding( $creds );
} else {
$result = self::fetch_me_cached( true, $creds );
}
if ( is_wp_error( $result ) ) {
return $result;
}
return self::return_option_from_fetch( $result, $option, $creds, empty( $option ) );
}
/**
* Return the option after fetching data from the /me route, potentially
* updating it in the database as well.
*
* @since 2.6.13
*
* @param stdClass $result The /me route result.
* @param array $option Possible option to be passed.
* @param array $creds Possible creds to be passed.
* @param bool $should_update Flag to update the option in the database or not.
*
* @return array Updated options array.
*/
public static function return_option_from_fetch( $result, $option = array(), $creds = array(), $should_update = false ) {
$api = self::instance();
if ( $should_update ) {
$option = OMAPI::get_instance()->get_option();
}
// Make sure to set the new api key, if we have it.
if ( empty( $option['api']['apikey'] ) && ! empty( $api->apikey ) ) {
$option['api'] = array( 'apikey' => $api->apikey );
if ( $api->user && $api->key ) {
// Notify user of credentials replacement.
OMAPI::get_instance()->notifications->add_event(
array(
'type' => 'success',
'title' => 'Your API Access Credentials have been updated',
'content' => 'We have automatically replaced your deprecated user/key OptinMonster connection credentials with a new API key.',
'btns' => array(
'main' => array(
'text' => 'Manage API Keys',
'url' => esc_url_raw( OPTINMONSTER_APP_URL . '/account/api/' ),
),
),
)
);
}
}
if ( isset( $result->id ) ) {
/*
* The user id connecting the plugin. It could be the owner or any sub-account.
* This key should not be used to embed codes or other API usage.
* In those cases, the owner's id (accountUserId) would be the one to use.
*/
$option['userId'] = $result->id;
}
$to_store = array( 'accountId', 'accountUserId', 'currentLevel', 'plan', 'revenueAttribution' );
foreach ( $to_store as $key ) {
if ( isset( $result->{$key} ) ) {
$option[ $key ] = is_object( $result->{$key} ) ? (array) $result->{$key} : $result->{$key};
}
}
if ( $should_update ) {
OMAPI::get_instance()->save->update_option( $option, $creds );
}
return $option;
}
/**
* Get the home/rest/admin url args.
*
* @since 2.13.0
*
* @return array
*/
public static function get_url_args() {
return array(
'homeUrl' => esc_url_raw( home_url() ),
'restUrl' => esc_url_raw( get_rest_url() ),
'adminUrl' => esc_url_raw( get_admin_url() ),
);
}
}