Why Gemfury? Push, build, and install  RubyGems npm packages Python packages Maven artifacts PHP packages Go Modules Debian packages RPM packages NuGet packages

Repository URL to install this package:

Details    
mailoptin/connections / DripConnect / AbstractDripConnect.php
Size: Mime:
<?php

namespace MailOptin\DripConnect;

use DrewM\Drip\Drip;
use MailOptin\Core\Connections\AbstractConnect;
use MailOptin\Core\PluginSettings\Connections;
use MailOptin\Core\PluginSettings\Settings;
use MailOptin\Core\Repositories\OptinCampaignsRepository;

class AbstractDripConnect extends AbstractConnect
{
    /** @var \MailOptin\Core\PluginSettings\Settings */
    protected $plugin_settings;

    /** @var \MailOptin\Core\PluginSettings\Connections */
    protected $connections_settings;

    public function __construct()
    {
        $this->plugin_settings      = Settings::instance();
        $this->connections_settings = Connections::instance();

        parent::__construct();
    }

    /**
     * Is Drip successfully connected to?
     *
     * @return bool
     */
    public static function is_connected($return_error = false)
    {
        $db_options = $_POST['mailoptin_connections'] ?? get_option(MAILOPTIN_CONNECTIONS_DB_OPTION_NAME);
        $api_token  = $db_options['drip_api_token'] ?? '';
        $account_id = $db_options['drip_account_id'] ?? '';

        if (empty($api_token)) {
            delete_transient('_mo_drip_is_connected');

            return false;
        }

        if (isset($_POST['wp_csa_nonce'])) {
            delete_transient('_mo_drip_is_connected');
        }

        //Check for connection status from cache
        if ('true' == get_transient('_mo_drip_is_connected')) {
            return true;
        }

        try {

            $api    = new Drip($api_token, $account_id);
            $result = $api->get('forms');

            if (self::is_http_code_success($result->status)) {
                set_transient('_mo_drip_is_connected', 'true', WEEK_IN_SECONDS);

                return true;
            }

            return $return_error === true ? $result->message : false;

        } catch (\Exception $e) {

            return $return_error === true ? $e->getMessage() : false;
        }
    }

    public static function get_core_custom_fields()
    {
        return [
            'address1'        => 'Address 1',
            'address2'        => 'Address 2',
            'city'            => 'City',
            'state'           => 'State',
            'zip'             => 'Zip',
            'country'         => 'Country',
            'phone'           => 'Phone',
            'sms_number'      => 'SMS Number',
            'user_id'         => 'User ID',
            'time_zone'       => 'Time Zone',
            'lifetime_value'  => 'Lifetime Value',
            'base_lead_score' => 'Base Lead Score',
        ];
    }

    public function get_integration_data($data_key, $integration_data = [], $default = '')
    {
        if (empty($integration_data) && ! empty($_POST['optin_campaign_id'])) {
            $optin_campaign_id = absint($_POST['optin_campaign_id']);
            $index             = absint($_POST['integration_index']);
            $val               = json_decode(OptinCampaignsRepository::get_customizer_value($optin_campaign_id, 'integrations'), true);

            if (isset($val[$index])) {
                $integration_data = $val[$index];
            }
        }

        return parent::get_integration_data($data_key, $integration_data, $default);
    }

    /**
     * Returns instance of API class.
     *
     * @return Drip
     * @throws \Exception
     *
     */
    public function drip_instance()
    {
        $api_token  = $this->connections_settings->drip_api_token();
        $account_id = $this->connections_settings->drip_account_id();

        if (empty($api_token)) {
            throw new \Exception('Drip API Token not found.');
        }

        if (empty($account_id)) {
            throw new \Exception('Drip Account ID not found.');
        }

        return new Drip($api_token, $account_id);
    }
}