<?php

/**
 * Copyright 2019 Huawei Technologies Co.,Ltd.
 * Licensed under the Apache License, Version 2.0 (the "License"); you may not use
 * this file except in compliance with the License.  You may obtain a copy of the
 * License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software distributed
 * under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
 * CONDITIONS OF ANY KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations under the License.
 *
 */

/**
 * This sample demonstrates how to post object under specified bucket from
 * OBS using the OBS SDK for PHP.
 */
if (file_exists ( 'vendor/autoload.php' )) {
    require 'vendor/autoload.php';
} else {
    require '../vendor/autoload.php'; // sample env
}

if (file_exists ( 'obs-autoloader.php' )) {
    require 'obs-autoloader.php';
} else {
    require '../obs-autoloader.php'; // sample env
}

use Obs\ObsClient;
use GuzzleHttp\Client;
use GuzzleHttp\Exception\ClientException;

$ak = '*** Provide your Access Key ***';

$sk = '*** Provide your Secret Key ***';

$endpoint = 'https://your-endpoint:443';

$bucketName = 'my-obs-bucket-demo';

$objectKey = 'my-obs-object-key-demo';

$signature = 'obs';

/*
 * Constructs a obs client instance with your account for accessing OBS
 */
$obsClient = ObsClient::factory ( [
        'key' => $ak,
        'secret' => $sk,
        'endpoint' => $endpoint,
        'socket_timeout' => 30,
        'connect_timeout' => 10,
        'signature' => $signature
]);

/*
 * Create bucket
 */
printf("Create a new bucket for demo\n\n");
$obsClient -> createBucket(['Bucket' => $bucketName]);


/*
 * Create sample file
 */
$sampleFilePath = '/temp/text.txt';
createSampleFile($sampleFilePath);

/*
 * Claim a post object request
 */
$formParams = [];
if (strcasecmp($signature, 'obs') === 0) {
    $formParams['x-obs-acl'] = ObsClient::AclPublicRead;
} else {
    $formParams['acl'] = ObsClient::AclPublicRead;
}
$formParams['content-type'] = 'text/plain';

$res = $obsClient -> createPostSignature(['Bucket' => $bucketName, 'Key' => $objectKey, 'Expires' => 3600, 'FormParams' => $formParams]);

$formParams['key'] = $objectKey;
$formParams['policy'] = $res['Policy'];

if (strcasecmp($signature, 'obs') === 0) {
    $formParams['Accesskeyid'] = $ak;
} else {
    $formParams['AWSAccesskeyid'] = $ak;
}

$formParams['signature'] = $res['Signature'];


printf("Creating object in browser-based post way\n\n");
$boundary = '9431149156168';

$buffers = [];
$contentLength = 0;

/*
 * Construct form data
 */
$buffer = [];
$first = true;
foreach ($formParams as $key => $val){
    if(!$first){
        $buffer[] = "\r\n";
    }else{
        $first = false;
    }
    
    $buffer[] = "--";
    $buffer[] = $boundary;
    $buffer[] = "\r\n";
    $buffer[] = "Content-Disposition: form-data; name=\"";
    $buffer[] = strval($key);
    $buffer[] = "\"\r\n\r\n";
    $buffer[] = strval($val);
}

$buffer = implode('', $buffer);
$contentLength += strlen($buffer);
$buffers[] = $buffer;

/*
 * Construct file description
 */
$buffer = [];

$buffer[] = "\r\n";
$buffer[] = "--";
$buffer[] = $boundary;
$buffer[] = "\r\n";
$buffer[] = "Content-Disposition: form-data; name=\"file\"; filename=\"";
$buffer[] = "myfile";
$buffer[] = "\"\r\n";
$buffer[] = "Content-Type: text/plain";
$buffer[] = "\r\n\r\n";

$buffer = implode('', $buffer);
$contentLength += strlen($buffer);
$buffers[] = $buffer;

/*
 * Construct file data
 */
$buffer = [];

$fp = fopen($sampleFilePath, 'r');
if($fp){
    while(!feof($fp)){
        $buffer[] = fgetc($fp);
    }
    fclose($fp);
}

$buffer = implode('', $buffer);
$contentLength += strlen($buffer);
$buffers[] = $buffer;

/*
 * Contruct end data
 */
$buffer = [];
$buffer[] = "\r\n--";
$buffer[] = $boundary;
$buffer[] = "--\r\n";

$buffer = implode('', $buffer);
$contentLength += strlen($buffer);
$buffers[] = $buffer;


$httpClient = new Client(['verify' => false]);
$host = parse_url($endpoint)['host'];
$host = $bucketName . '.' . $host;
$url = 'https://' . $host . ':443';
$headers = ['Content-Length' => strval($contentLength), 'Content-Type' => 'multipart/form-data; boundary=' . $boundary];

try{
    $response = $httpClient -> request('POST', $url, ['body' => implode('', $buffers), 'headers'=> $headers]);
    
    printf('Post object successfully!');
    $response -> getBody()-> close();
}catch (ClientException $ex){
    printf('Exception message:%s', $ex ->getMessage());
}


if(file_exists($sampleFilePath)){
    unlink($sampleFilePath);
}

function createSampleFile($filePath)
{
    if(file_exists($filePath)){
        return;
    }
    $filePath = iconv('UTF-8', 'GBK', $filePath);
    if(is_string($filePath) && $filePath !== '')
    {
        $fp = null;
        $dir = dirname($filePath);
        try{
            if(!is_dir($dir))
            {
                mkdir($dir,0755,true);
            }
            
            if(($fp = fopen($filePath, 'w+')))
            {
                fwrite($fp, uniqid() . "\n");
                fwrite($fp, uniqid() . "\n");
            }
        }finally{
            if($fp){
                fclose($fp);
            }
        }
    }
}