<?php
    include("include/mysqlFunc.php");

    $TWITCH_URL = 'https://api.twitch.tv/helix/';
    $CLIENT_ID = '92zjrp6otv221cqzt0kod4yxydc5sx';
    $CLIENT_SECRET = 'rt1xh4izl6s9kk4xg1yn3gf996fa8i';

    $header = array('Client-ID: '.$CLIENT_ID);

    $codice = $_GET['code'];

    $query = 'https://id.twitch.tv/oauth2/token?client_id='.$CLIENT_ID.'&client_secret='.$CLIENT_SECRET.'&code='.$codice.'&grant_type=authorization_code&redirect_uri=http://51.68.138.15/richiesta.php';

// Create a stream
    $opts = array(
      'http'=>array(
        'method'=>"POST",
        'header'=>"Client-ID: ". $CLIENT_ID
      )
    );

    $context = stream_context_create($opts);

    $curl_handle=curl_init();
    curl_setopt($curl_handle, CURLOPT_URL,$query);
    curl_setopt($curl_handle, CURLOPT_CONNECTTIMEOUT, 2);
    curl_setopt($curl_handle, CURLOPT_RETURNTRANSFER, 1);
    curl_setopt($curl_handle, CURLOPT_USERAGENT, 'Your application name');
    $result = curl_exec($curl_handle);
    curl_close($curl_handle);

    $result = json_decode($result, true);

    $access_token = $result['access_token'];
    $refresh_token = $result['refresh_token'];

    $opts = array(
      'http'=>array(
        'method'=>"GET",
        'header'=>array(
            "Client-ID: ". $CLIENT_ID,
            "Authorization: Bearer ".$access_token
        )
      )
    );

    $context = stream_context_create($opts);

    $query = 'https://api.twitch.tv/helix/users';

    $curl_handle=curl_init();
    curl_setopt($curl_handle, CURLOPT_URL,$query);
    curl_setopt($curl_handle, CURLOPT_CONNECTTIMEOUT, 2);
    curl_setopt($curl_handle, CURLOPT_RETURNTRANSFER, 1);
    curl_setopt($curl_handle, CURLOPT_USERAGENT, 'Your application name');
    $result = curl_exec($curl_handle);
    curl_close($curl_handle);

    echo $result;

    $result = json_decode($result, true);

    echo $result["data"][0]["id"].' '.$result["data"][0]["login"];

    setcookie('id', $result["data"][0]["id"], strtotime("+175200 hours"));

    $id_abbonato = $result['data'][0]['id'];

    $queryResult = $database->dbQuery("SELECT * FROM abbonati WHERE ID='$id_abbonato'");

    if (!mysqli_num_rows($queryResult)){
        $queryResult = $database->dbQuery("INSERT INTO abbonati (ID, login, display_name, profile_image_url, sub, access_token, refresh_token) VALUES ('$id_abbonato', '".$result['data'][0]['login']."', '".$result['data'][0]['display_name']."', '".$result['data'][0]['profile_image_url']."', 0, '$access_token', '$refresh_token')");

    } else {
        $queryResult = $database->dbQuery("UPDATE abbonati SET refresh_token='$refresh_token', access_token='$access_token' WHERE ID='$id_abbonato'");

    }

    echo "pre redirect";

    header("location: /checksub.php");


?>