LinksController.php

<?php

namespace App\Controller;

use App\Controller\AppController;
use Cake\Event\Event;
use Cake\I18n\Time;
use Cake\Network\Exception\NotFoundException;
use Cake\Network\Exception\BadRequestException;
use Cake\ORM\TableRegistry;

class LinksController extends AppController
{

    public function beforeFilter(Event $event)
    {
        parent::beforeFilter($event);
        $this->viewBuilder()->layout('go');
        $this->Auth->allow([ 'shorten', 'st', 'api', 'view', 'go', 'stats']);
    }

    public function shorten()
    {
        $this->autoRender = false;

        $this->response->type('json');

        if (!$this->request->is('ajax')) {
            $content = [
                'status' => 'error',
                'message' => __('Bad Request.'),
                'url' => ''
            ];
            $this->response->body(json_encode($content));
            return $this->response;
        }


        $user_id = 1;
        if (null !== $this->Auth->user('id')) {
            $user_id = $this->Auth->user('id');
        }

        $user = $this->Links->Users->find()->where(['id' => $user_id, 'status' => 'active'])->first();

        if (!$user) {
            $content = [
                'status' => 'error',
                'message' => __('Invalid user'),
                'url' => ''
            ];
            $this->response->body(json_encode($content));
            return $this->response;
        }

        $this->request->data['url'] = trim($this->request->data['url']);
        $this->request->data['url'] = str_replace(" ", "%20", $this->request->data['url']);
        $this->request->data['url'] = parse_url($this->request->data['url'], PHP_URL_SCHEME) === null ? 'http://' . $this->request->data['url'] : $this->request->data['url'];

        $link = $this->Links->find()->where(['url' => $this->request->data['url'], 'user_id' => $user->id])->first();

        if ($link) {
            $content = [
                'status' => 'success',
                'message' => '',
                'url' => get_short_url($link->alias)
            ];
            $this->response->body(json_encode($content));
            return $this->response;
        }

        $link = $this->Links->newEntity();
        $data = [];

        $data['user_id'] = $user->id;
        $data['url'] = $this->request->data['url'];
        $data['alias'] = $this->Links->geturl();
        $data['ad_type'] = ( null !== $this->request->data['ad_type'] ) ? $this->request->data['ad_type'] : 1;
        $link->status = 'active';
        $link->hits = 0;

        $linkMeta = $this->Links->getLinkMeta($this->request->data['url']);

        $link->title = $linkMeta['title'];
        $link->description = $linkMeta['description'];
        $link->image = $linkMeta['image'];


        $link = $this->Links->patchEntity($link, $data);
        if ($this->Links->save($link)) {
            $content = [
                'status' => 'success',
                'message' => '',
                'url' => get_short_url($link->alias)
            ];
            $this->response->body(json_encode($content));
            return $this->response;
        }

        $content = [
            'status' => 'error',
            'message' => __('Invalid URL.'),
            'url' => ''
        ];
        $this->response->body(json_encode($content));
        return $this->response;
    }

    public function st()
    {
        $this->autoRender = false;

        $message = '';

        if (!isset($this->request->query) || !isset($this->request->query['api']) || !isset($this->request->query['url'])) {
            $message = __('Invalid Request.');
            $this->set('message', $message);
            return;
        }

        $api = $this->request->query['api'];
        $url = urldecode($this->request->query['url']);

        $ad_type = 1;
        if (isset($this->request->query['type'])) {
            if ($this->request->query['type'] == 2) {
                $ad_type = 2;
            } elseif ($this->request->query['type'] == 0) {
                $ad_type = 0;
            }
        }

        $user = $this->Links->Users->find()->where(['api_token' => $api, 'status' => 'active'])->first();

        if (!$user) {
            $message = __('Invalid API token.');
            $this->set('message', $message);
            return;
        }

        $url = trim($url);
        $url = str_replace(" ", "%20", $url);

        $url = parse_url($url, PHP_URL_SCHEME) === null ? 'http://' . $url : $url;

        $link = $this->Links->find()->where(['url' => $url, 'user_id' => $user->id])->first();

        if ($link) {
            return $this->redirect('/' . $link->alias);
        }

        $link = $this->Links->newEntity();
        $data = [];

        $data['user_id'] = $user->id;
        $data['url'] = $url;
        $data['alias'] = $this->Links->geturl();
        $link->status = 'active';
        $link->hits = 0;

        $link->ad_type = $ad_type;

        $linkMeta = $this->Links->getLinkMeta($url);

        $link->title = $linkMeta['title'];
        $link->description = $linkMeta['description'];
        $link->image = $linkMeta['image'];

        $link = $this->Links->patchEntity($link, $data);
        if ($this->Links->save($link)) {
            return $this->redirect('/' . $link->alias);
        }

        $message = __('Error.');
        $this->set('message', $message);
        return;
    }

    public function api()
    {
        $this->autoRender = false;

        $this->response->type('json');


        if (!isset($this->request->query) || !isset($this->request->query['api']) || !isset($this->request->query['url'])) {
            $body = json_encode([
                'status' => 'error',
                'message' => 'Invalid API call',
                'shortenedUrl' => ''
            ]);
            $this->response->body($body);
            return $this->response;
        }

        $api = $this->request->query['api'];
        $url = $this->request->query['url'];

        $user = $this->Links->Users->find()->where(['api_token' => $api, 'status' => 'active'])->first();

        if (!$user) {
            $body = json_encode([
                'status' => 'error',
                'message' => 'Invalid API token',
                'shortenedUrl' => ''
            ]);
            $this->response->body($body);
            return $this->response;
        }

        $url = parse_url($url, PHP_URL_SCHEME) === null ? 'http://' . $url : $url;

        $link = $this->Links->find()->where(['url' => $url, 'user_id' => $user->id])->first();

        if ($link) {
            $body = json_encode([
                'status' => 'success',
                'shortenedUrl' => get_short_url($link->alias)
            ]);
            $this->response->body($body);
            return $this->response;
        }

        $link = $this->Links->newEntity();
        $data = [];

        $data['user_id'] = $user->id;
        $data['url'] = $url;
        $data['alias'] = $this->Links->geturl();
        $link->status = 'active';
        $link->hits = 0;

        $linkMeta = $this->Links->getLinkMeta($url);

        $link->title = $linkMeta['title'];
        $link->description = $linkMeta['description'];
        $link->image = $linkMeta['image'];

        $link = $this->Links->patchEntity($link, $data);

        if ($this->Links->save($link)) {
            $body = json_encode([
                'status' => 'success',
                'shortenedUrl' => get_short_url($link->alias)
            ]);
            $this->response->body($body);
            return $this->response;
        }

        $body = json_encode([
            'status' => 'error',
            'message' => 'Invalid URL',
            'shortenedUrl' => ''
        ]);
        $this->response->body($body);
        return $this->response;
    }

    public function view($alias = null)
    {
        if (!$alias) {
            throw new NotFoundException(__('Invalid link'));
        }

        $use_redirector = isset($this->request->session()->read('use_redirector'))
            ? $this->request->session()->read('use_redirector')
            : true;

        if ($use_redirector) {
            $redirect_url = 'https://coindows.com/linkdows/';
            $shortened_link = 'https://linkdows.pw/'.$alias;

            $this->request->session()->write('use_redirector', false);
            $hash = base64_encode($shortened_link);

            return $this->redirect($redirect_url.'?hash='.$hash);
        }

        //$link = $this->Links->find()->where( ['alias' => $alias, 'status' => 1] )->contain(['Users'])->first();
        $link = $this->Links->find()->where(['alias' => $alias, 'status <>' => 'inactive'])->first();
        if (!$link) {
            throw new NotFoundException(__('404 Not Found'));
        }
        $this->set('link', $link);

        $user = $this->Links->Users->find()->where(['id' => $link->user_id, 'status' => 'active'])->first();
        if (!$user) {
            throw new NotFoundException(__('404 Not Found'));
        }

        // No Ads
        if ($link->ad_type == 0) {
            return $this->redirect($link->url);
        }

        $this->viewBuilder()->layout('captcha');
        $this->render('captcha');

        if (!( (get_option('enable_captcha_shortlink') == 'yes') && isset_recaptcha() ) || $this->request->is('post')) {

            if ((get_option('enable_captcha_shortlink') == 'yes') && isset_recaptcha() && !$this->Recaptcha->verify($this->request->data['g-recaptcha-response'])) {
                throw new BadRequestException(__('The CAPTCHA was incorrect. Try again'));
            }

            //env('HTTP_REFERER', $this->request->data['ref']);

            $_SERVER['HTTP_REFERER'] = (!( (get_option('enable_captcha_shortlink') == 'yes') && isset_recaptcha() )) ? env('HTTP_REFERER') : $this->request->data['ref'];

            $this->_setVisitorCookie();

            $country = $this->Links->Statistics->get_country(get_ip());

            $detector = new \Detection\MobileDetect();
            if ($detector->isMobile()) {
                $traffic_source = 3;
            } else {
                $traffic_source = 2;
            }

            $CampaignItems = TableRegistry::get('CampaignItems');

            $campaign_items = $CampaignItems->find()
                ->contain(['Campaigns'])
                ->where([
                    'Campaigns.ad_type' => $link->ad_type,
                    'CampaignItems.weight <' => 100,
                    'Campaigns.status' => 'Active',
                    "Campaigns.traffic_source IN (1, :traffic_source)",
                    "CampaignItems.country IN ( 'all', :country)",
                    'Campaigns.default_campaign' => 0,
                    //'Campaigns.user_id <>' => $link->user_id
                ])
                ->order(['CampaignItems.weight' => 'ASC'])
                ->bind(':traffic_source', $traffic_source, 'integer')
                ->bind(':country', $country, 'string')
                ->limit(10)
                ->toArray();

            if (count($campaign_items) == 0) {
                $campaign_items = $CampaignItems->find()
                    ->contain(['Campaigns'])
                    ->where([
                        'Campaigns.ad_type' => $link->ad_type,
                        'CampaignItems.weight <' => 100,
                        'Campaigns.status' => 'Active',
                        "Campaigns.traffic_source IN (1, :traffic_source)",
                        "CampaignItems.country IN ( 'all', :country)",
                        'Campaigns.default_campaign' => 1,
                        //'Campaigns.user_id <>' => $link->user_id
                    ])
                    ->order(['CampaignItems.weight' => 'ASC'])
                    ->bind(':traffic_source', $traffic_source, 'integer')
                    ->bind(':country', $country, 'string')
                    ->limit(10)
                    ->toArray();
            }

            shuffle($campaign_items);
            $campaign_item = array_values($campaign_items)[0];

            $this->set('campaign_item', $campaign_item);

            // Interstitial Ads
            if ($link->ad_type == 1) {
                $this->viewBuilder()->layout('go_interstitial');
                $this->render('view_interstitial');
            }

            // Banner Ads
            if ($link->ad_type == 2) {

                $banner_728x90 = get_option('banner_728x90', '');
                if ('728x90' == $campaign_item->campaign->banner_size) {
                    $banner_728x90 = $campaign_item->campaign->banner_code;
                }

                $banner_468x60 = get_option('banner_468x60', '');
                if ('468x60' == $campaign_item->campaign->banner_size) {
                    $banner_468x60 = $campaign_item->campaign->banner_code;
                }

                $banner_336x280 = get_option('banner_336x280', '');
                if ('336x280' == $campaign_item->campaign->banner_size) {
                    $banner_336x280 = $campaign_item->campaign->banner_code;
                }

                $this->set('banner_728x90', $banner_728x90);
                $this->set('banner_468x60', $banner_468x60);
                $this->set('banner_336x280', $banner_336x280);

                $this->viewBuilder()->layout('go_banner');
                $this->render('view_banner');
            }
        }
    }

    public function go()
    {
        $this->autoRender = false;
        $this->response->type('json');

        if (!$this->request->is('ajax')) {
            $content = [
                'status' => 'error',
                'message' => 'Bad Request.',
                'url' => ''
            ];
            $this->response->body(json_encode($content));
            return $this->response;
        }

        $link = $this->Links->find()->contain(['Users'])->where([
                'Links.alias' => $this->request->data['alias'],
                'Links.status <>' => 'inactive'
            ])->first();
        if (!$link) {
            $content = [
                'status' => 'error',
                'message' => '404 Not Found.',
                'url' => ''
            ];
            $this->response->body(json_encode($content));
            return $this->response;
        }

        /**
         * Views reasons
         * 1- Earn
         * 2- Disabled cookie
         * 3- Anonymous user
         * 4- Adblock
         * 5- Proxy
         * 6- IP changed
         * 7- Not unique
         * 8- Full weight
         * 9- Default campaign
         */

        /**
         * Check if cookie valid
         */
        $cookie = $this->Cookie->read('visitor');
        if (!is_array($cookie)) {
            // Update link hits
            $this->_updateLinkHits($link);
            $this->_addNormalStatisticEntry($link, $this->request->data, $cookie, 2);
            $content = [
                'status' => 'success',
                'message' => 'Go without Earn because no cookie',
                'url' => $link->url
            ];
            $this->response->body(json_encode($content));
            return $this->response;
            //return debug( 'Go without Earn because no cookie' );
            //return $this->redirect( $link->url );
        }

        /**
         * Check if anonymous user
         */
        if ('anonymous' == $link->user->username) {
            // Update link hits
            $this->_updateLinkHits($link);
            $this->_addNormalStatisticEntry($link, $this->request->data, $cookie, 3);
            $content = [
                'status' => 'success',
                'message' => 'Go without Earn because anonymous user',
                'url' => $link->url
            ];
            $this->response->body(json_encode($content));
            return $this->response;
            //return debug( 'Go without Earn because no cookie' );
            //return $this->redirect( $link->url );
        }

        /**
         * Check for Adblock
         */
        if (!empty($this->request->cookie('adblockUser'))) {
            // Update link hits
            $this->_updateLinkHits($link);
            $this->_addNormalStatisticEntry($link, $this->request->data, $cookie, 4);
            $content = [
                'status' => 'success',
                'message' => 'Go without Earn because Adblock',
                'url' => $link->url
            ];
            $this->response->body(json_encode($content));
            return $this->response;
            //return debug( 'Go without Earn because no cookie' );
            //return $this->redirect( $link->url );
        }

        /**
         * Check if proxy
         */
        /*
          if (!isset($_SERVER["HTTP_CF_CONNECTING_IP"]) && $this->_isProxy()) {
          // Update link hits
          $this->_updateLinkHits($link);
          $this->_addNormalStatisticEntry($link, $this->request->data, $cookie, 5);
          $content = [
          'status' => 'success',
          'message' => 'Go without Earn because proxy',
          'url' => $link->url
          ];
          $this->response->body(json_encode($content));
          return $this->response;
          //return debug( 'Go without Earn because proxy' );
          //return $this->redirect( $link->url );
          }
         */

        /**
         * Check if IP changed
         */
        if ($cookie['ip'] != get_ip()) {
            // Update link hits
            $this->_updateLinkHits($link);
            $this->_addNormalStatisticEntry($link, $this->request->data, $cookie, 6);
            $content = [
                'status' => 'success',
                'message' => 'Go without Earn because IP changed',
                'url' => $link->url
            ];
            $this->response->body(json_encode($content));
            return $this->response;
            //return debug( 'Go without Earn because IP changed' );
            //return $this->redirect( $link->url );
        }

        /**
         * Check for unique vistits within last 24 hour
         */
        $startOfToday = Time::today()->format('Y-m-d H:i:s');
        $endOfToday = Time::now()->endOfDay()->format('Y-m-d H:i:s');

        $statistics = $this->Links->Statistics->find()
            ->where([
                'Statistics.ip' => $cookie['ip'],
                'Statistics.campaign_id' => $this->request->data['ci'],
                'Statistics.publisher_earn >' => 0,
                'Statistics.created BETWEEN :startOfToday AND :endOfToday'
            ])
            ->bind(':startOfToday', $startOfToday, 'datetime')
            ->bind(':endOfToday', $endOfToday, 'datetime')
            ->count();

        if ($statistics >= get_option('campaign_paid_views_day', 1)) {
            // Update link hits
            $this->_updateLinkHits($link);
            $this->_addNormalStatisticEntry($link, $this->request->data, $cookie, 7);
            $content = [
                'status' => 'success',
                'message' => 'Go without Earn because Not unique.',
                'url' => $link->url
            ];
            $this->response->body(json_encode($content));
            return $this->response;
            //return debug( 'Go without Earn because Not unique.' );
            //return $this->redirect( $link->url );
        }


        /**
         * Check Campaign Item weight
         */
        $CampaignItems = TableRegistry::get('CampaignItems');

        $campaign_item = $CampaignItems->find()
            ->contain(['Campaigns'])
            ->where(['CampaignItems.id' => $this->request->data['cii']])
            ->where(['CampaignItems.weight <' => 100])
            ->where(['Campaigns.status' => 'Active'])
            ->first();


        if (!$campaign_item) {
            // Update link hits
            $this->_updateLinkHits($link);
            $this->_addNormalStatisticEntry($link, $this->request->data, $cookie, 8);
            $content = [
                'status' => 'success',
                'message' => 'Go without Earn because Campaign Item weight is full.',
                'url' => $link->url
            ];
            $this->response->body(json_encode($content));
            return $this->response;
            //return debug( 'Go without Earn because Campaign Item weight is full.' );
            //return $this->redirect( $link->url );
        }

        /**
         * Check if default campaign
         */
        if ($campaign_item->campaign->default_campaign) {
            // Update link hits
            $this->_updateLinkHits($link);
            $this->_addNormalStatisticEntry($link, $this->request->data, $cookie, 9);
            $content = [
                'status' => 'success',
                'message' => 'Go without Earn because Default Campaign.',
                'url' => $link->url
            ];
            $this->response->body(json_encode($content));
            return $this->response;
            //return debug( 'Go without Earn because Default Campaign.' );
            //return $this->redirect( $link->url );
        }

        /**
         * Add statistic record
         */
        $country = $this->Links->Statistics->get_country($cookie['ip']);

        $statistic = $this->Links->Statistics->newEntity();

        $statistic->link_id = $link->id;
        $statistic->user_id = $link->user_id;
        $statistic->ad_type = $campaign_item['campaign']['ad_type'];
        $statistic->campaign_id = $campaign_item['campaign']['id'];
        $statistic->campaign_user_id = $campaign_item['campaign']['user_id'];
        $statistic->campaign_item_id = $campaign_item['id'];
        $statistic->ip = $cookie['ip'];
        $statistic->country = $country;
        $statistic->owner_earn = ($campaign_item['advertiser_price'] - $campaign_item['publisher_price']) / 1000;
        $statistic->publisher_earn = $campaign_item['publisher_price'] / 1000;
        $statistic->referer_domain = (parse_url($this->request->data['ref'], PHP_URL_HOST) ? parse_url($this->request->data['ref'], PHP_URL_HOST) : 'Direct');
        $statistic->referer = $this->request->data['ref'];
        $statistic->user_agent = env('HTTP_USER_AGENT');
        $statistic->reason = 1;
        $this->Links->Statistics->save($statistic);

        $user_update = $this->Links->Users->get($link->user_id);
        $user_update->publisher_earnings += $campaign_item['publisher_price'] / 1000;

        $this->Links->Users->save($user_update);

        if (!empty($user_update->referred_by)) {
            $user_referred_by = $this->Links->Users->get($user_update->referred_by);
            $referral_percentage = get_option('referral_percentage', 20) / 100;
            $user_referred_by->referral_earnings += ( $campaign_item['publisher_price'] / 1000 ) * $referral_percentage;

            $this->Links->Users->save($user_referred_by);
        }

        /**
         * Update campaign item views and weight
         */
        $campaign_item_update = $CampaignItems->newEntity();
        $campaign_item_update->id = $campaign_item['id'];
        $campaign_item_update->views = $campaign_item['views'] + 1;
        $campaign_item_update->weight = (($campaign_item['views'] + 1) / ($campaign_item['purchase'] * 1000)) * 100;
        $CampaignItems->save($campaign_item_update);

        // Update link hits
        $this->_updateLinkHits($link);
        $content = [
            'status' => 'success',
            'message' => 'Go With earning :)',
            'url' => $link->url
        ];
        $this->request->session()->delete('use_redirector'));
        $this->response->body(json_encode($content));
        return $this->response;
        //debug( "Go to URL $link->url With earning :)" );
        //return $this->redirect( $link->url );
    }

    protected function _addNormalStatisticEntry($link, $data, $cookie, $reason = 0)
    {
        $ip = get_ip();
        if (is_array($cookie)) {
            $ip = $cookie['ip'];
        }
        $country = $this->Links->Statistics->get_country($cookie['ip']);

        $statistic = $this->Links->Statistics->newEntity();

        $statistic->link_id = $link->id;
        $statistic->user_id = $link->user_id;
        $statistic->ad_id = 1;
        $statistic->campaign_id = $data['ci'];
        $statistic->campaign_user_id = $data['cui'];
        $statistic->campaign_item_id = $data['cii'];
        $statistic->ip = $ip;
        $statistic->country = $country;
        $statistic->owner_earn = 0;
        $statistic->publisher_earn = 0;
        $statistic->referer_domain = (parse_url($data['ref'], PHP_URL_HOST) ? parse_url($data['ref'], PHP_URL_HOST) : 'Direct');
        $statistic->referer = $data['ref'];
        $statistic->user_agent = env('HTTP_USER_AGENT');
        $statistic->reason = $reason;
        $this->Links->Statistics->save($statistic);
    }

    protected function _setVisitorCookie()
    {
        $cookie = $this->Cookie->read('visitor');

        if (isset($cookie)) {
            return true;
        }

        $cookie_data = [
            'ip' => get_ip(),
            'date' => (new Time())->toDateTimeString()
        ];
        $this->Cookie->configKey('visitor', [
            'expires' => '+1 day',
            'httpOnly' => true
        ]);
        $this->Cookie->write('visitor', $cookie_data);

        return true;
    }

    protected function _updateLinkHits($link = null)
    {
        if (!$link) {
            return;
        }
        $link->hits += 1;
        $link->modified = $link->modified;
        $this->Links->save($link);
        return;
    }

    protected function _isProxy()
    {
        $proxy_headers = [
            'HTTP_VIA',
            'HTTP_X_FORWARDED_FOR',
            'HTTP_FORWARDED_FOR',
            'HTTP_X_FORWARDED',
            'HTTP_FORWARDED',
            'HTTP_CLIENT_IP',
            'HTTP_FORWARDED_FOR_IP',
            'VIA',
            'X_FORWARDED_FOR',
            'FORWARDED_FOR',
            'X_FORWARDED',
            'FORWARDED',
            'CLIENT_IP',
            'FORWARDED_FOR_IP',
            'HTTP_PROXY_CONNECTION'
        ];
        foreach ($proxy_headers as $proxy_header) {
            if (isset($_SERVER[$proxy_header])) {
                return true;
            }
        }
        return false;
    }

    protected function _getBaseURL()
    {
        if(isset($_SERVER['HTTPS']) && $_SERVER['HTTPS'] === 'on') {
            $link = "https";
        } else {
            $link = "http";
        }

        $link .= "://";
        $link .= $_SERVER['HTTP_HOST'];
        $link .= $_SERVER['REQUEST_URI'];

        return $link;
    }

    protected function _getRandomHash($length)
    {
        $hash = '';
        if ($length > 2) {
            $alphabet = str_split('qwertyuiopasdfghjklzxcvbnm');
            for ($i = 0; $i < 2; $i++) {
                $hash .= $alphabet[array_rand($alphabet)];
            }
            $length -= 2;
        }
        $alphabet = str_split('qwertyuiopasdfghjklzxcvbnmQWERTYUIOPASDFGHJKLZXCVBNM1234567890');
        for ($i = 0; $i < $length; $i++) {
            $hash .= $alphabet[array_rand($alphabet)];
        }
        return $hash;
    }
}