api_key = $api_key; $this->api_secret = $api_secret; $this->debug = $debug; $this->log = new ConvertKit_Log(); } /** * Gets account information from the API. * * @since 1.9.6 * * @return mixed WP_Error | array */ public function account() { $this->log( 'API: account()' ); return $this->get( 'account', array( 'api_secret' => $this->api_secret, ) ); } /** * Gets all subscription forms from the API. * * @since 1.9.6 * * @return mixed WP_Error | array */ public function get_subscription_forms() { $this->log( 'API: get_subscription_forms()' ); // Send request. return $this->get( 'subscription_forms', array( 'api_key' => $this->api_key, ) ); } /** * Gets all forms from the API. * * @since 1.9.6 * * @return mixed WP_Error | array */ public function get_forms() { $this->log( 'API: get_forms()' ); // Get all forms and landing pages from the API. $forms = $this->get_forms_landing_pages(); // Bail if an error occured. if ( is_wp_error( $forms ) ) { $this->log( 'API: get_forms(): Error: ' . $forms->get_error_message() ); return $forms; } return $forms['forms']; } /** * Subscribes an email address to a form. * * @since 1.9.6 * * @param string $form_id Form ID. * @param string $email Email Address. * @param string $first_name First Name. * @return mixed WP_Error | array */ public function form_subscribe( $form_id, $email, $first_name ) { // Backward compat. if $email is an array comprising of email and name keys. if ( is_array( $email ) ) { _deprecated_function( __FUNCTION__, '1.9.6', 'form_subscribe( $form_id, $email, $first_name )' ); $first_name = $email['name']; $email = $email['email']; } $this->log( 'API: form_subscribe(): [ form_id: ' . $form_id . ', email: ' . $email . ', first_name: ' . $first_name . ' ]' ); $response = $this->post( 'forms/' . $form_id . '/subscribe', array( 'api_secret' => $this->api_secret, 'email' => $email, 'first_name' => $first_name, ) ); if ( is_wp_error( $response ) ) { $this->log( 'API: form_subscribe(): Error: ' . $response->get_error_message() ); } /** * Runs actions immediately after the email address was successfully subscribed to the form. * * @since 1.9.6 * * @param array $response API Response * @param string $form_id Form ID * @param string $email Email Address * @param string $first_name First Name */ do_action( 'convertkit_api_form_subscribe_success', $response, $form_id, $email, $first_name ); return $response; } /** * Gets all landing pages from the API. * * @since 1.9.6 * * @return mixed WP_Error | array */ public function get_landing_pages() { $this->log( 'API: get_landing_pages()' ); // Get all forms and landing pages from the API. $forms = $this->get_forms_landing_pages(); // Bail if an error occured. if ( is_wp_error( $forms ) ) { $this->log( 'API: get_landing_pages(): Error: ' . $forms->get_error_message() ); return $forms; } return $forms['landing_pages']; } /** * Fetches all tags from the API. * * @since 1.9.6 * * @return mixed WP_Error | array */ public function get_tags() { $this->log( 'API: get_tags()' ); $tags = array(); // Send request. $response = $this->get( 'tags', array( 'api_key' => $this->api_key, ) ); // If an error occured, return WP_Error. if ( is_wp_error( $response ) ) { $this->log( 'API: get_tags(): Error: ' . $response->get_error_message() ); return $response; } // If no tags exist, return WP_Error. if ( ! isset( $response['tags'] ) ) { $this->log( 'API: get_tags(): Error: No tags exist in ConvertKit.', 'convertkit' ); return new WP_Error( 'convertkit_api_error', __( 'No tags exist in ConvertKit. Visit your ConvertKit account and create your first tag.', 'convertkit' ) ); } if ( ! count( $response['tags'] ) ) { $this->log( 'API: get_tags(): Error: No tags exist in ConvertKit.', 'convertkit' ); return new WP_Error( 'convertkit_api_error', __( 'No tags exist in ConvertKit. Visit your ConvertKit account and create your first tag.', 'convertkit' ) ); } foreach ( $response['tags'] as $tag ) { $tags[] = $tag; } return $tags; } /** * Subscribes an email address to a tag. * * @since 1.9.6 * * @param string $tag_id Tag ID. * @param string $email Email Address. * @return mixed WP_Error | array */ public function tag_subscribe( $tag_id, $email ) { $this->log( 'API: tag_subscribe(): [ tag_id: ' . $tag_id . ', email: ' . $email . ']' ); $response = $this->post( 'tags/' . $tag_id . '/subscribe', array( 'api_key' => $this->api_key, 'email' => $email, ) ); if ( is_wp_error( $response ) ) { $this->log( 'API: tag_subscribe(): Error: ' . $response->get_error_message() ); } /** * Runs actions immediately after the email address was successfully subscribed to the tag. * * @since 1.9.6 * * @param array $response API Response * @param string $tag_id Tag ID * @param string $email Email Address */ do_action( 'convertkit_api_tag_subscribe_success', $response, $tag_id, $email ); return $response; } /** * Gets a subscriber by their email address. * * @since 1.9.6 * * @param string $email Email Address. * @return mixed WP_Error | array */ public function get_subscriber_by_email( $email ) { $this->log( 'API: get_subscriber_by_email(): [ email: ' . $email . ']' ); // Send request. $response = $this->get( 'subscribers', array( 'api_secret' => $this->api_secret, 'email_address' => $email, ) ); // If an error occured, return WP_Error. if ( is_wp_error( $response ) ) { $this->log( 'API: tag_subscriber(): Error: ' . $response->get_error_message() ); return $response; } // If no subscribers exist, return WP_Error. if ( ! absint( $response['total_subscribers'] ) ) { $error = new WP_Error( 'convertkit_api_error', sprintf( /* translators: Email Address */ __( 'No subscriber(s) exist in ConvertKit matching the email address %s.', 'convertkit' ), $email ) ); $this->log( 'API: get_subscriber_by_email(): Error: ' . $error->get_error_message() ); return $error; } return $response['subscribers'][0]; } /** * Gets a subscriber by their ConvertKit subscriber ID. * * @since 1.9.6 * * @param int $subscriber_id Subscriber ID. * @return mixed WP_Error | array */ public function get_subscriber_by_id( $subscriber_id ) { $this->log( 'API: get_subscriber_by_id(): [ subscriber_id: ' . $subscriber_id . ']' ); // Send request. $response = $this->get( 'subscribers/' . $subscriber_id, array( 'api_secret' => $this->api_secret, ) ); // If an error occured, eturn WP_Error. if ( is_wp_error( $response ) ) { $this->log( 'API: get_subscriber_by_id(): Error: ' . $response->get_error_message() ); return $response; } // If no subscriber exists, return WP_Error. if ( ! isset( $response['subscriber'] ) ) { $error = new WP_Error( 'convertkit_api_error', sprintf( /* translators: Subscriber ID */ __( 'No subscriber exist in ConvertKit matching the subscriber ID %s.', 'convertkit' ), $subscriber_id ) ); $this->log( 'API: get_subscriber_by_id(): Error: ' . $error->get_error_message() ); return $error; } return $response['subscriber']; } /** * Gets a list of tags for the given ConvertKit subscriber ID. * * @since 1.9.6 * * @param int $subscriber_id Subscriber ID. * @return mixed WP_Error | array */ public function get_subscriber_tags( $subscriber_id ) { $this->log( 'API: get_subscriber_tags(): [ subscriber_id: ' . $subscriber_id . ']' ); // Send request. $response = $this->get( 'subscribers/' . $subscriber_id . '/tags', array( 'api_key' => $this->api_key, ) ); // If an error occured, return WP_Error. if ( is_wp_error( $response ) ) { $this->log( 'API: get_subscriber_tags(): Error: ' . $response->get_error_message() ); return $response; } // If no tags exists, return WP_Error. if ( ! isset( $response['tags'] ) ) { $error = new WP_Error( 'convertkit_api_error', sprintf( /* translators: Subscriber ID */ __( 'No tags exist in ConvertKit for the subscriber ID %s.', 'convertkit' ), $subscriber_id ) ); $this->log( 'API: get_subscriber_tags(): Error: ' . $error->get_error_message() ); return $error; } return $response['tags']; } /** * Returns the subscriber's ID by their email address. * * @since 1.9.6 * * @param string $email_address Email Address. * @return mixed WP_Error | int */ public function get_subscriber_id( $email_address ) { // Get subscriber. $subscriber = $this->get_subscriber_by_email( $email_address ); // Bail if an error occured. if ( is_wp_error( $subscriber ) ) { return $subscriber; } // Return ID. return $subscriber->id; } /** * Unsubscribes an email address. * * @since 1.9.6 * * @param string $email Email Address. * @return mixed WP_Error | array */ public function unsubscribe( $email ) { $this->log( 'API: unsubscribe(): [ email: ' . $email . ']' ); $response = $this->post( 'unsubscribe', array( 'api_secret' => $this->api_secret, 'email' => $email, ) ); if ( is_wp_error( $response ) ) { $this->log( 'API: unsubscribe(): Error: ' . $response->get_error_message() ); } /** * Runs actions immediately after the email address was successfully unsubscribed. * * @since 1.9.6 * * @param array $response API Response * @param string $email Email Address */ do_action( 'convertkit_api_form_unsubscribe_success', $response, $email ); return $response; } /** * Get HTMl from ConvertKit for the given Legacy Form ID. * * This isn't specifically an API function, but for now it's best suited here. * * @param int $id Form ID. * @return string HTML */ public function get_form_html( $id ) { // Define Legacy Form URL. $url = add_query_arg( array( 'api_key' => $this->api_key, 'v' => 6, ), 'https://forms.convertkit.com/' . $id . '.html' ); // Get HTML. $body = $this->get_html( $url ); return $body; } /** * Get HTML from ConvertKit for the given Landing Page URL. * * This isn't specifically an API function, but for now it's best suited here. * * @param string $url URL of Landing Page. * @return string HTML */ public function get_landing_page_html( $url ) { // Get HTML. $body = $this->get_html( $url ); // Inject JS for subscriber forms to work. $scripts = new WP_Scripts(); $script = ""; // phpcs:ignore $script .= ""; // phpcs:ignore $script .= "'; // phpcs:ignore $body = str_replace( '', '' . $script, $body ); return $body; } /** * Backward compat. function for updating Forms, Landing Pages and Tags in WordPress options table. * * @since 1.0.0 * * @param string $api_key API Key. * @param string $api_secret API Secret. */ public function update_resources( $api_key, $api_secret ) { // phpcs:ignore // Warn the developer that they shouldn't use this function. _deprecated_function( __FUNCTION__, '1.9.6', 'refresh() in ConvertKit_Resource_Forms, ConvertKit_Resource_Landing_Pages and ConvertKit_Resource_Tags classes.' ); // Initialize resource classes. $forms = new ConvertKit_Resource_Forms(); $landing_pages = new ConvertKit_Resource_Landing_Pages(); $tags = new ConvertKit_Resource_Tags(); // Refresh resources by calling the API and storing the results. $forms->refresh(); $landing_pages->refresh(); $tags->refresh(); } /** * Backward compat. function for getting a ConvertKit subscriber by their ID. * * @since 1.9.6 * * @param int $id Subscriber ID. * @return mixed WP_Error | array */ public function get_subscriber( $id ) { // Warn the developer that they shouldn't use this function. _deprecated_function( __FUNCTION__, '1.9.6', 'get_subscriber_by_id()' ); // Pass request to new function. return $this->get_subscriber_by_id( $id ); } /** * Backward compat. function for subscribing a ConvertKit subscriber to the given Tag. * * @since 1.9.6 * * @param int $tag Tag ID. * @param array $args Arguments. * @return mixed WP_Error | array */ public function add_tag( $tag, $args ) { // Warn the developer that they shouldn't use this function. _deprecated_function( __FUNCTION__, '1.9.6', 'tag_subscribe( $tag_id, $email_address )' ); // Pass request to new function. return $this->tag_subscribe( $tag, $args['email'] ); } /** * Backward compat. function for fetching Legacy Form or Landing Page markup for the given URL. * * @since 1.9.6 * * @param string $url URL. * @return mixed WP_Error | string */ public function get_resource( $url ) { // Warn the developer that they shouldn't use this function. _deprecated_function( __FUNCTION__, '1.9.6', 'get_form_html( $form_id ) or get_landing_page_html( $url )' ); // Pass request to new function. return $this->get_landing_page_html( $url ); } /** * Backward compat. function for fetching Legacy Form or Landing Page markup for the given URL. * * @since 1.9.6 * * @param array $args Arguments (single email key). * @return mixed WP_Error | array */ public function form_unsubscribe( $args ) { // Warn the developer that they shouldn't use this function. _deprecated_function( __FUNCTION__, '1.9.6', 'unsubscribe( $email_address )' ); // Pass request to new function. return $this->unsubscribe( $args['email'] ); } /** * Get HTML for the given URL. * * This isn't specifically an API function, but for now it's best suited here. * * @param string $url URL of Form or Landing Page. * @return string HTML */ private function get_html( $url ) { // Get HTML from URL. $result = wp_remote_get( $url, array( 'Accept-Encoding' => 'gzip', 'timeout' => $this->get_timeout(), 'user-agent' => $this->get_user_agent(), ) ); // If an error occured, return it now. if ( is_wp_error( $result ) ) { return $result; } // Fetch HTTP response code and body. $http_response_code = wp_remote_retrieve_response_code( $result ); $body = wp_remote_retrieve_body( $result ); // Get just the scheme and host from the URL. $url_scheme = wp_parse_url( $url ); $url_scheme_host_only = $url_scheme['scheme'] . '://' . $url_scheme['host']; // Load the landing page HTML into a DOMDocument. libxml_use_internal_errors( true ); $html = new DOMDocument(); $html->loadHTML( $body ); // Convert any relative URLs to absolute URLs in the HTML DOM. $this->convert_relative_to_absolute_urls( $html->getElementsByTagName( 'a' ), 'href', $url_scheme_host_only ); $this->convert_relative_to_absolute_urls( $html->getElementsByTagName( 'link' ), 'href', $url_scheme_host_only ); $this->convert_relative_to_absolute_urls( $html->getElementsByTagName( 'img' ), 'src', $url_scheme_host_only ); $this->convert_relative_to_absolute_urls( $html->getElementsByTagName( 'script' ), 'src', $url_scheme_host_only ); $this->convert_relative_to_absolute_urls( $html->getElementsByTagName( 'form' ), 'action', $url_scheme_host_only ); // Fetch the edited HTML. return $html->saveHTML(); } /** * Converts any relative URls to absolute, fully qualified HTTP(s) URLs for the given * DOM Elements. * * @since 1.9.6 * * @param array $elements Elements. * @param string $attribute HTML Attribute. * @param string $url Absolute URL to prepend to relative URLs. */ private function convert_relative_to_absolute_urls( $elements, $attribute, $url ) { // Anchor hrefs. foreach ( $elements as $element ) { // Skip if the attribute's value is empty. if ( empty( $element->getAttribute( $attribute ) ) ) { continue; } // Skip if the attribute's value is a fully qualified URL. if ( filter_var( $element->getAttribute( $attribute ), FILTER_VALIDATE_URL ) ) { continue; } // If here, the attribute's value is a relative URL, missing the http(s) and domain. // Prepend the URL to the attribute's value. $element->setAttribute( $attribute, $url . $element->getAttribute( $attribute ) ); } } /** * Gets all forms and landing pages from the API. * * @since 1.9.6 * * @return mixed WP_Error | array */ private function get_forms_landing_pages() { // Send request. $response = $this->get( 'forms', array( 'api_key' => $this->api_key, ) ); // If an error occured, return WP_Error. if ( is_wp_error( $response ) ) { return $response; } // If no forms exist. if ( ! isset( $response['forms'] ) ) { return new WP_Error( 'convertkit_api_error', __( 'No forms exist in ConvertKit. Visit your ConvertKit account and create your first form.', 'convertkit' ) ); } // Iterate through forms, determining if each form is a form or landing page. $forms = array(); $landing_pages = array(); foreach ( $response['forms'] as $form ) { // Skip archived forms. if ( isset( $form['archived'] ) && $form['archived'] ) { continue; } switch ( $form['type'] ) { case 'hosted': $landing_pages[ $form['id'] ] = $form; break; default: $forms[ $form['id'] ] = $form; break; } } return array( 'forms' => $forms, 'landing_pages' => $landing_pages, ); } /** * Performs a GET request. * * @since 1.9.6 * * @param string $endpoint API Endpoint. * @param array $params Params. * @return mixed WP_Error | object */ private function get( $endpoint, $params ) { return $this->request( $endpoint, 'get', $params ); } /** * Performs a POST request. * * @since 1.9.6 * * @param string $endpoint API Endpoint. * @param array $params Params. * @return mixed WP_Error | object */ private function post( $endpoint, $params ) { return $this->request( $endpoint, 'post', $params ); } /** * Main function which handles sending requests to the API using WordPress functions. * * @since 1.9.6 * * @param string $endpoint API Endpoint (required). * @param string $method HTTP Method (optional). * @param mixed $params Params (array|boolean|string). * @return mixed WP_Error | object */ private function request( $endpoint, $method = 'get', $params = array() ) { // Send request. switch ( $method ) { case 'get': $result = wp_remote_get( $this->add_api_credentials_to_url( $this->get_api_url( $endpoint ), $params ), array( 'Accept-Encoding' => 'gzip', 'timeout' => $this->get_timeout(), 'user-agent' => $this->get_user_agent(), ) ); break; case 'post': $result = wp_remote_post( $this->get_api_url( $endpoint ), array( 'Accept-Encoding' => 'gzip', 'headers' => array( 'Content-Type' => 'application/json; charset=utf-8', ), 'body' => wp_json_encode( $params ), 'timeout' => $this->get_timeout(), 'user-agent' => $this->get_user_agent(), ) ); break; } // If an error occured, return it now. if ( is_wp_error( $result ) ) { $this->log( 'API: Error: ' . $result->get_error_message() ); return $result; } // Fetch HTTP response code and body. $http_response_code = wp_remote_retrieve_response_code( $result ); $body = wp_remote_retrieve_body( $result ); $response = json_decode( $body, true ); // If an error message or code exists in the response, return a WP_Error. if ( isset( $response['error'] ) ) { $this->log( 'API: Error: ' . $response['error'] . ': ' . $response['message'] ); return new WP_Error( 'convertkit_api_error', $response['error'] . ': ' . $response['message'] ); } return $response; } /** * Returns the maximum amount of time to wait for * a response to the request before exiting. * * @since 1.9.6 * * @return int Timeout, in seconds. */ private function get_timeout() { $timeout = 10; /** * Defines the maximum time to allow the API request to run. * * @since 2.2.9 * * @param int $timeout Timeout, in seconds. */ $timeout = apply_filters( 'convertkit_api_get_timeout', $timeout ); return $timeout; } /** * Gets a customized version of the WordPress default user agent; includes WP Version, PHP version, and ConvertKit plugin version. * * @since 1.9.6 * * @return string User Agent */ private function get_user_agent() { // Include an unmodified $wp_version. require ABSPATH . WPINC . '/version.php'; return sprintf( 'WordPress/%1$s;PHP/%2$s;ConvertKit/%3$s;%4$s', $wp_version, phpversion(), CONVERTKIT_PLUGIN_VERSION, home_url( '/' ) ); } /** * Returns the full API URL for the given endpoint. * * @since 1.9.6 * * @param string $endpoint Endpoint. * @return string API URL */ private function get_api_url( $endpoint ) { return path_join( $this->api_url_base . $this->api_version, $endpoint ); } /** * Adds either the API Key or API Secret to the URL, depending on whether * the API Key or API Secret is in the array of parameters. * * @since 1.9.6 * * @param string $url URL. * @param array $params Parameters for request. * @return string URL with API Key or API Secret */ private function add_api_credentials_to_url( $url, $params ) { if ( isset( $params['api_key'] ) ) { return add_query_arg( array( 'api_key' => $params['api_key'], ), $url ); } if ( isset( $params['api_secret'] ) ) { return add_query_arg( array( 'api_secret' => $params['api_secret'], ), $url ); } return $url; } /** * Adds the given entry to the log file, if debugging is enabled. * * @since 1.9.6 * * @param string $entry Log Entry. */ private function log( $entry ) { // Don't log this entry if debugging is disabled. if ( ! $this->debug ) { return; } // Pass the request to the log class. $this->log->add( $entry ); } }