AWS SDK php 2 in codeigniter application

I got a change to work on a interesting project where we needed to integrate AWS services like cloudfront and s3 to our application. we started out with using a class from tpyo @ https://github.com/tpyo/amazon-s3-php-class/ but soon found limitations so I decided to use latest AWS SDK for php from amazon available at http://aws.amazon.com/sdkforphp/. I got to try out composer aswell, it is dependency management tool for php and aws sdk was available on it. So today I will be writing up a short tutorial on how to make use of aws sdk on your codeigniter application using composer and will also provide a wrapper library for some methods for services like cloudfront and s3.
You can find this instructions here as well

1. First we need to prepare a composer.json file which will contain aws sdk as dependency in our project root path.
composer.json

{
  "require": {
      "aws/aws-sdk-php": "*"
  }
}

2. Then download and install composer
In terminal do following

curl -s "http://getcomposer.org/installer" | php

php composer.phar install

Above codes will download required files and libraries to vendor directory in our project.

Now we will create a new library called Myaws that will act as wrapper for our methods we will be using exclusively in our app.

<?php 

if (!defined('BASEPATH'))
    exit('No direct script access allowed');
//composer auto load
include_once FCPATH.'/vendor/autoload.php';
use Aws\Common\Aws;
use Aws\Common\Enum\Region;
use Aws\S3\Enum\CannedAcl;
use Aws\S3\Exception\S3Exception;
use Aws\CloudFront\Enum\OriginProtocolPolicy;
use Aws\CloudFront\Enum\ViewerProtocolPolicy;
use Aws\CloudFront\Exception\CloudFrontException;
class Myaws {	
	private $aws;
	private $s3Client;
	private $cfClient;
	private $cfIdentity;
	public $debug=false;
	function __construct(){
		$CI =& get_instance();
		$this->aws = Aws::factory(array(
		  'key'    => $CI->config->item('s3_access_key_id'),
		  'secret' => $CI->config->item('s3_secret_key')
		));
		$this->cfIdentity = $CI->config->item('cf_identity');
		$this->s3Client = $this->aws->get('s3');
		$this->cfClient = $this->aws->get('cloudfront');
	}
	
	function isValidBucketName($bucket_name){
		try {
			if($this->s3Client->isValidBucketName($bucket_name)){
				return true;
			}
			return false;
		} catch (S3Exception $e) {
			if($this->debug){
				return $e->getMessage();
			}
			else{
				return false;
			}
		}	
	}
	
	function doesBucketExist($bucket_name){
		try {
			if($this->s3Client->doesBucketExist($bucket_name)){
				return true;
			}
			return false;
		} catch (S3Exception $e) {
			if($this->debug){
				return $e->getMessage();
			}
			else{
				return false;
			}
		}
	}
	
	function createBucket($bucket_name){
		if($this->isValidBucketName($bucket_name)){
			if($this->doesBucketExist($bucket_name)){
				return false;
			}
			else{
				try{
					$this->s3Client->createBucket(
					array(
						'Bucket'=>$bucket_name,
						'ACL'	=> CannedAcl::PUBLIC_READ
						//add more items if required here
					));
					return true;
				} catch(S3Exception $e){
					if($this->debug){
						return $e->getMessage();
					}
					else{
						return false;
					}
				}	
			}
		}
		else{
			if($this->debug){
				return $e->getMessage();
			}
			else{
				return false;
			}
		}
	}
	
	function _return_bucket_policy($bucket_name = ''){
		return '{
			"Version": "2008-10-17",
			"Id": "PolicyForCloudFrontPrivateContent",
			"Statement": [
				{
					"Sid": "1",
					"Effect": "Allow",
					"Principal": {
						"AWS": "arn:aws:iam::cloudfront:user/CloudFront Origin Access Identity '.$this->cfIdentity.'"
					},
					"Action": "s3:GetObject",
					"Resource": "arn:aws:s3:::'.$bucket_name.'/*"
				}
			]
		}';
	}
	
	function putBucketPolicy($bucket_name){
		if($this->doesBucketExist($bucket_name)){
			try{
				$this->s3Client->putBucketPolicy(
				array(
					'Bucket'=>$bucket_name, 
					'Policy'=>$this->_return_bucket_policy($bucket_name)
				));
				return true;
			} catch(S3Exception $e){
				if($this->debug){
					return $e->getMessage();
				}
				else{
					return false;
				}
			}
		}
		else{
			return false;
		}
	}
	
	function deleteBucket($bucket_name){
		try {
			$this->s3Client->clearBucket($bucket_name);
			$this->s3Client->deleteBucket(array(
				'Bucket' => $bucket_name
			));
			return true;
		} catch (S3Exception $e) {
			if($this->debug){
				return $e->getMessage();
			}
			else{
				return false;
			}
		}
	}
	
	function doesObjectExist($bucket_name, $key){
		try {
			if($this->s3Client->doesObjectExist($bucket_name, $key)){
				return true;	
			}
			return false;
		} catch(S3Exception $e){
			if($this->debug){
				return $e->getMessage();
			}
			else{
				return false;
			}
		}	
	}
	
	function putObject($bucket_name, $key, $body){
		try {
			$this->s3Client->putObject(array(
				'Bucket'=> $bucket_name,
				'Key'	=> $key,
				'Body' 	=> $body,
				'ACL'	=> CannedAcl::PUBLIC_READ
			));
			return true;
		} catch(S3Exception $e){
			if($this->debug){
				return $e->getMessage();
			}
			else{
				return false;
			}
		}
	}
	
	function deleteObject($bucket_name, $objects){
		try {
			$this->s3Client->deleteObject(array(
				'Bucket'  =>$bucket_name,
				'Objects' =>$objects
			));
			return true;
		} catch (S3Exception $e) {
			if($this->debug){
				return $e->getMessage();
			}
			else{
				return false;
			}
		}
	}
	
	// $objects should be array(array('Key'=>$key), array('Key'=>$key2)); testing needed here before implementation
	function deleteObjects($bucket_name, $keys){
		try {
			$this->s3Client->deleteObjects(array(
				'Bucket' => $bucket_name,
				'Key'=> $keys
			));
			return true;
		} catch (S3Exception $e) {
			if($this->debug){
				return $e->getMessage();
			}
			else{
				return false;
			}
		}	
	}
	
	function createDistribution($bucket_name, $domain_name){
		try{
			$return = $this->cfClient->createDistribution($this->_return_distribution_config_array($bucket_name, $domain_name, true));
			return $return->toArray();
		} catch(CloudFrontException $e){
			if($this->debug){
				return $e->getMessage();
			}
			else{
				return false;
			}
		}
	}
	
	function _return_distribution_config_array($bucket_name= '', $domain_name = '', $enabled = true){
		$origin_id = 'S3-'.$bucket_name;
		return array(
			'CallerReference' => md5(time()),
			'Aliases' => array(
				'Quantity'=>1, 
				'Items'=> array($domain_name)
			),
			'DefaultRootObject' => 'index.html',
			'Origins' => array(
				'Quantity' => 1, 
				'Items' => array(
					array(
						'Id' => $origin_id,
						'DomainName' => strtolower($bucket_name.'.s3.amazonaws.com'),
						'S3OriginConfig' => array(
							'OriginAccessIdentity' => 'origin-access-identity/cloudfront/'.$this->cfIdentity
						)
					)
				)
			),
			'DefaultCacheBehavior' => array(
				'TargetOriginId' => $origin_id,
				'ForwardedValues' => array(
					'QueryString' => false
				),
				'TrustedSigners' => array(
	            	'Enabled'  => false,
					'Quantity' => 0,
					'Items' => array()
	             ),
				'ViewerProtocolPolicy' => ViewerProtocolPolicy::ALLOW_ALL,
				'MinTTL' => 0
			),
			'CacheBehaviors' => array('Quantity' => 0, 'Items' => array()),
			'Comment' => 'Distribution for '.$bucket_name,
			'Logging' => array(
                'Enabled' => false,
                'Bucket' => '',
                'Prefix' => ''
            ),
			'Enabled' => $enabled
		);
	}
	
	function disableDistribution($cfID){
		try{
			$getConfig = $this->cfClient->getDistributionConfig(array('Id' => $cfID));
			$got_config_array = $getConfig->toArray();
			try{
				$config_array = $got_config_array;
				$config_array['Enabled'] = false;
				$config_array['Id'] = $cfID;
				$config_array['IfMatch'] = $got_config_array['ETag'];
				$config_array['Logging'] = array(
	                'Enabled' => false,
	                'Bucket' => '',
	                'Prefix' => ''
	            );
				unset($config_array['ETag']);
				unset($config_array['RequestId']);
				$this->cfClient->updateDistribution($config_array);
			} catch(CloudFrontException $e){
				if($this->debug){
					return $e->getMessage();
				}
				else{
					return false;
				}
			}
		} catch(CloudFrontException $e){
			if($this->debug){
				return $e->getMessage();
			}
			else{
				return false;
			}
		}
	}
	
	function deleteDistribution($cfID){
		try{
			$getDistribution = $this->cfClient->getDistribution(array('Id' => $cfID));
			$got_distribution_array = $getDistribution->toArray();
			if($got_distribution_array['Status'] == 'Deployed' and $got_distribution_array['DistributionConfig']['Enabled'] == false){
				try{
					$this->cfClient->deleteDistribution(array('Id' => $cfID, 'IfMatch' => $got_distribution_array['ETag']));
					return true;
				} catch(CloudFrontException $e){
					if($this->debug){
						return $e->getMessage();
					}
					else{
						return false;
					}
				}
			}
			else{
				if($this->debug){
					return $e->getMessage();
				}
				else{
					return false;
				}
			}	
		} catch(CloudFrontException $e){
			if($this->debug){
				return $e->getMessage();
			}
			else{
				return false;
			}
		}
	}
	
	
}

This library includes the vendor auto load file from composer and uses required namespaces for the library. The methods in this library are itself self explanatory. I have set some config items in constructer. You can add them in your codeigniter config file as follows:

$config['aws_access_key_id'] = '';
$config['aws_secret_key'] = '';
$config['cf_identity'] = '';

You can get these values from your aws management panel.

Now to use this library simply load the library and call the required methods in your controller:

<?php

if (!defined('BASEPATH'))
    exit('No direct script access allowed');

class Testaws extends MY_Controller 
{
    function __construct() {
        parent::__construct();
		$this->load->library('myaws');
    }

    function index() {
		$this->myaws->createBucket('bucketname');
		$this->myaws->putBucketPolicy('bucketname', 'Bucket Policy in Json format here');
		$this->myaws->putObject('bucketname', 'keyname.txt', 'body content');
		$this->myaws->createDistribution('bucketname', 'domain');
		$this->myaws->disableDistribution('distribution ID');
		$this->myaws->deleteDistribution('distribution ID');
		
    }

That’s it you can add more methods as required. You can find detailed API documentation here. If you need any help regarding the use of sdk and api let me know in comments I will try to help you out.