Ключ к вашему рациону 2025 года – персонализация. Забудьте о шаблонных диетах. В следующем году мы увидим расцвет технологий, способных анализировать ваш уникальный метаболизм и генетические особенности, предлагая блюда, идеально подходящие именно вам.
Представьте: ваш смартфон анализирует данные с биометрического браслета и мгновенно генерирует рецепт ужина, обогащенного нужными витаминами и микроэлементами, учитывая ваши вкусовые предпочтения и даже уровень стресса.
Инновации в приготовлении пищи. 3D-принтеры для еды станут более доступными, позволяя создавать сложные и питательные блюда с невероятной точностью. Вместо обычных ингредиентов, мы будем использовать специализированные пищевые пасты, разработанные для обеспечения полного спектра питательных веществ.
Будущее не за экзотикой, а за разумным подходом к тому, что уже доступно, преображенное наукой.
Как искусственное мясо изменит ваше ежедневное меню: Практическое руководство
Начните с замены части привычного мяса на растительные аналоги. Пробуйте котлеты из горохового белка для бургеров или фарш из сои для лазаньи. Это простой шаг, чтобы ощутить разницу во вкусе и текстуре.
Изучите рецепты, где искусственное мясо выступает не заменой, а основным ингредиентом. Например, блюда в азиатском стиле с “курицей” из сейтана или вегетарианские “колбаски” в пасте.
Обратите внимание на разнообразие продуктов. Сегодня доступен не только фарш, но и целые куски “стейков”, “куриных грудок” и “рыбы”, которые позволяют готовить привычные блюда с новым подходом.
Экспериментируйте с маринадами и специями. Искусственное мясо хорошо впитывает ароматы, поэтому смело добавляйте любимые травы, чеснок и соусы, чтобы усилить вкус.
Включайте в рацион блюда, где искусственное мясо сочетается с овощами и злаками. Это могут быть рагу, запеканки или сытные салаты, где “мясной” компонент дополняет остальные ингредиенты.
Оцените удобство приготовления. Многие продукты из искусственного мяса уже готовы к употреблению или требуют минимальной термической обработки, что экономит время на кухне.
Персонализированное питание: Как технологии предскажут ваши идеальные блюда
Представьте: ваш смартфон анализирует ваше самочувствие после тренировки и предлагает рецепт с повышенным содержанием белка, а затем автоматически добавляет нужные ингредиенты в список покупок. Это не фантастика, а реальность, которая становится доступнее с каждым днем.
Ваши пищевые предпочтения и потребности больше не будут загадкой. Специальные приложения, используя данные о вашем образе жизни, генетической предрасположенности и даже микробиоме, смогут с высокой точностью определить, какие продукты принесут максимальную пользу именно вам.
Умные кухонные приборы станут вашими личными шеф-поварами. Они будут не просто готовить по рецепту, а адаптировать процесс под ваши текущие нужды. Например, если вы чувствуете усталость, прибор предложит блюдо, способствующее быстрому восстановлению энергии, с учетом ваших вкусовых предпочтений.
Технологии помогут избежать пищевых ошибок. Аллергии, непереносимости, дефицит витаминов – все это будет учтено. Система сможет предупредить вас о потенциально вредных сочетаниях продуктов или предложить альтернативы, которые не навредят вашему здоровью.
Будущее за питанием, которое знает вас лучше, чем вы сами. Это не просто еда, это индивидуально подобранный источник здоровья и энергии, созданный с помощью науки и технологий.
Съедобная упаковка и zero-waste кухня: Инструкция по снижению пищевых отходов
Начните с выбора продуктов с минимальным количеством упаковки или упаковкой, которую можно съесть.
Упаковочные материалы будущего изготавливаются из натуральных ингредиентов, таких как водоросли, крахмал или фруктовые пектины. Эти материалы не только защищают продукт, но и добавляют ему вкус и питательные вещества. Представьте себе йогурт в стаканчике из прессованных ягод, который вы можете съесть вместе с йогуртом, или пакет для орехов, сделанный из рисовой бумаги, который становится частью снека.
Практические шаги для дома:
Покупайте на развес: Используйте собственные многоразовые контейнеры для круп, орехов, сухофруктов и специй.
Откажитесь от одноразового: Замените пластиковые пакеты для овощей и фруктов на тканевые мешочки.
Используйте все части продукта: Стебли зелени можно добавить в супы или соусы, а кожуру овощей – для приготовления овощного бульона.
Храните правильно: Изучите оптимальные способы хранения разных продуктов, чтобы продлить их свежесть. Например, зелень лучше хранить в стакане с водой, а корнеплоды – в прохладном темном месте.
Компостируйте: Органические остатки, которые нельзя использовать, превратите в ценное удобрение для растений.
Zero-waste кухня – это не только про экологию, но и про разумное потребление и новые кулинарные возможности.
Новые суперфуды из лаборатории: Откройте для себя белок будущего
Представляем вам культивируемый белок – решение для устойчивого и питательного рациона.
Лабораторный белок производится из клеток животных, выращенных в контролируемой среде, что исключает необходимость животноводства.
Этот метод снижает потребление воды и земли, а также уменьшает выбросы парниковых газов.
Культивируемое мясо по составу аминокислот и питательным свойствам не уступает традиционному.
Выбирайте продукты с маркировкой “культивируемый белок” для будущего вашего здоровья и планеты.
<?php
// @codingStandardsIgnoreStart
// This is a compatibility library, using Amazon's official PHP SDK (PHP 5.3.3+), but providing the methods of Donovan Schönknecht's S3.php library (which we used to always use) - but we've only cared about making code-paths in UpdraftPlus work, so be careful if re-deploying this in another project. And, we have a few bits of UpdraftPlus-specific code below, for logging.
/**
*
* Copyright (c) 2012-22, David Anderson (https://www.simbahosting.co.uk). All rights reserved.
* Portions copyright (c) 2011, Donovan Schönknecht. All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are met:
*
* - Redistributions of source code must retain the above copyright notice,
* this list of conditions and the following disclaimer.
* - Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
*
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
* ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
* LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
* POSSIBILITY OF SUCH DAMAGE.
*
* Amazon S3 is a trademark of Amazon.com, Inc. or its affiliates.
*/
// @codingStandardsIgnoreEnd
// SDK requires PHP 5.5+
use Aws\Common\RulesEndpointProvider;
use Aws\Credentials\Credentials;
use Aws\S3\Exception\NoSuchBucketException;
use Aws\S3\S3MultiRegionClient;
global $updraftplus;
$updraftplus->potentially_remove_composer_autoloaders(array('GuzzleHttp\\', 'Aws\\'));
updraft_try_include_file('vendor/autoload.php', 'include');
$updraftplus->mitigate_guzzle_autoloader_conflicts();
/**
* Amazon S3 PHP class
* http://undesigned.org.za/2007/10/22/amazon-s3-php-cla
*
* @version Release: 0.5.0-dev
*/
class UpdraftPlus_S3_Compat {
// ACL flags
const ACL_PRIVATE = 'private';
const ACL_PUBLIC_READ = 'public-read';
const ACL_PUBLIC_READ_WRITE = 'public-read-write';
const ACL_AUTHENTICATED_READ = 'authenticated-read';
const STORAGE_CLASS_STANDARD = 'STANDARD';
// AWS S3 client
private $client;
private $config;
private $__access_key = null; // AWS Access key
private $__secret_key = null; // AWS Secret key
private $__session_token = null;
private $__ssl_key = null;
public $endpoint = 's3.amazonaws.com';
public $proxy = null;
private $region = 'us-east-1';
// Added to cope with a particular situation where the user had no pernmission to check the bucket location, which necessitated using DNS-based endpoints.
public $use_dns_bucket_name = false;
public $use_ssl = false;
public $use_ssl_validation = true;
public $useExceptions = false;
private $_serverSideEncryption = null;
// SSL CURL SSL options - only needed if you are experiencing problems with your OpenSSL configuration
public $ssl_key = null;
public $ssl_cert = null;
public $ssl_ca_cert = null;
public $iam = null;
// Added at request of a user using a non-default port.
public static $port = false;
/**
* Constructor - if you're not using the class statically
*
* @param string $access_key Access key
* @param string $secret_key Secret key
* @param boolean $use_ssl Enable SSL
* @param string|boolean $ssl_ca_cert Certificate authority (true = bundled Guzzle version; false = no verify, 'system' = system version; otherwise, path)
* @param Null|String $endpoint Endpoint (if omitted, it will be set by the SDK using the region)
* @param Null|String $session_token The session token returned by AWS for temporary credentials access
* @param Null|String $region Region. Currently unused, but harmonised with UpdraftPlus_S3 class
* @return void
*/
public function __construct($access_key = null, $secret_key = null, $use_ssl = true, $ssl_ca_cert = true, $endpoint = null, $session_token = null, $region = null) {// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable -- $region is unused
do_action('updraftplus_load_aws_sdk');
global $updraftplus;
$updraftplus->mitigate_guzzle_autoloader_conflicts();
if (null !== $access_key && null !== $secret_key)
$this->setAuth($access_key, $secret_key, $session_token);
$this->use_ssl = $use_ssl;
$this->ssl_ca_cert = $ssl_ca_cert;
if ($session_token) {
$credentials = new Credentials($access_key, $secret_key, $session_token);
} else {
$credentials = new Credentials($access_key, $secret_key);
}
global $updraftplus;
// AWS SDK V3 requires we specify a version. String 'latest' can be used but not recommended, a full list of versions for each API found here: https://docs.aws.amazon.com/aws-sdk-php/v3/api/index.html
// latest S3Client version as of 16/09/21 is version 2006-03-01
$this->config = array(
'credentials' => $credentials,
'version' => '2006-03-01',
'scheme' => ($use_ssl) ? 'https' : 'http',
'ua_append' => 'UpdraftPlus/'.$updraftplus->version,
// Using signature v4 requires a region (but see the note below)
// 'signature_version' => 'v4',
// 'region' => $this->region
// 'endpoint' => 'somethingorother.s3.amazonaws.com'
);
if ($endpoint) {
// Can't specify signature v4, as that requires stating the region - which we don't necessarily yet know.
// Later comment: however, it looks to me like in current UD (Sep 2017), $endpoint is never used for Amazon S3/Vault, and there may be cases (e.g. DigitalOcean Spaces) where we might prefer v4 (DO support v2 too, currently) without knowing a region.
$this->endpoint = $endpoint;
$this->config['endpoint'] = $endpoint;
} else {
// Using signature v4 requires a region. Also, some regions (EU Central 1, China) require signature v4 - and all support it, so we may as well use it if we can.
$this->config['signature_version'] = 'v4';
$this->config['region'] = $this->region;
}
if ($use_ssl) $this->config['http']['verify'] = $ssl_ca_cert;
$this->client = new S3MultiRegionClient($this->config);
}
/**
* Set AWS access key and secret key
*
* @param string $access_key Access key
* @param string $secret_key Secret key
* @param null|string $session_token The session token returned by AWS for temporary credentials access
* @return void
*/
public function setAuth($access_key, $secret_key, $session_token = null) {
$this->__access_key = $access_key;
$this->__secret_key = $secret_key;
$this->__session_token = $session_token;
}
/**
* Example value: 'AES256'. See: https://docs.aws.amazon.com/AmazonS3/latest/dev/SSEUsingPHPSDK.html
* Or, false to turn off.
*
* @param boolean $value Set if Value
*/
public function setServerSideEncryption($value) {
$this->_serverSideEncryption = $value;
}
/**
* Set the service region
*
* @param string $region Region
* @return void
*/
public function setRegion($region) {
$this->region = $region;
if ('eu-central-1' == $region || 'cn-north-1' == $region) {
// $this->config['signature'] = new Aws\S3\S3SignatureV4('s3');
// $this->client->setConfig($this->config);
}
}
/**
* Set the service endpoint
*
* @param string $host Hostname
* @param string $region Region
* @return void
*/
public function setEndpoint($host, $region) {
$this->endpoint = $host;
$this->region = $region;
$this->config['endpoint_provider'] = $this->return_provider();
$this->client->setConfig($this->config);
}
/**
* Set the service port
*
* @param Integer $port Port number
*/
public function setPort($port) {
// Not used with AWS (which is the only thing using this class)
self::$port = $port;
}
public function return_provider() {
$our_endpoints = array(
'endpoint' => $this->endpoint
);
if ('eu-central-1' == $this->region || 'cn-north-1' == $this->region) $our_endpoints['signatureVersion'] = 'v4';
$endpoints = array(
'version' => 2,
'endpoints' => array(
"*/s3" => $our_endpoints
)
);
return new RulesEndpointProvider($endpoints);
}
/**
* Set SSL on or off
* This code relies upon the particular pattern of SSL options-setting in s3.php in UpdraftPlus
*
* @param boolean $enabled SSL enabled
* @param boolean $validate SSL certificate validation
* @return void
*/
public function setSSL($enabled, $validate = true) {
$this->use_ssl = $enabled;
$this->use_ssl_validation = $validate;
$scheme = ($enabled) ? 'https' : 'http';
// The AWS SDK V3 client doesn't have the 'setConfig' method, so we must recreate the client instance to update the configs. However, we only do it when the '$config' variable is changed.
if ($this->config['scheme'] != $scheme) {
$this->config['scheme'] = $scheme;
$this->client = new S3MultiRegionClient($this->config);
}
}
public function getuseSSL() {
return $this->use_ssl;
}
/**
* Get SSL validation value.
*
* @return bool
*/
public function getUseSSLValidation() {
return $this->use_ssl_validation;
}
/**
* Set SSL client certificates (experimental)
*
* @param string $ssl_cert SSL client certificate
* @param string $ssl_key SSL client key
* @param string $ssl_ca_cert SSL CA cert (only required if you are having problems with your system CA cert)
* @return void
*/
public function setSSLAuth($ssl_cert = null, $ssl_key = null, $ssl_ca_cert = null) {// phpcs:ignore Generic.CodeAnalysis.UnusedFunctionParameter.Found -- Unused parameters are for future use.
if (!$this->use_ssl) return;
if (!$this->use_ssl_validation || !$ssl_ca_cert) {
$verify = false;
} else {
$verify = ('system' === $ssl_ca_cert) ? true : realpath($ssl_ca_cert);
}
// The AWS SDK V3 client doesn't have the 'setConfig' method, so we must recreate the client instance to update the configs. However, we only do it when the '$config' variable is changed.
if ($this->config['http']['verify'] != $verify) {
$this->config['http']['verify'] = $verify;
$this->client = new S3MultiRegionClient($this->config);
}
}
/**
* Set proxy information
*
* @param string $host Proxy hostname and port (localhost:1234)
* @param string $user Proxy username
* @param string $pass Proxy password
* @param constant $type CURL proxy type
* @param integer $port Port number
* @return void
*/
public function setProxy($host, $user = null, $pass = null, $type = CURLPROXY_SOCKS5, $port = null) {
$this->proxy = array('host' => $host, 'type' => $type, 'user' => $user, 'pass' => $pass, 'port' => $port);
if (!$host) return;
$wp_proxy = new WP_HTTP_Proxy();
if ($wp_proxy->send_through_proxy('https://s3.amazonaws.com')) {
global $updraftplus;
$updraftplus->log("setProxy: host=$host, user=$user, port=$port");
// N.B. Currently (02-Feb-15), only support for HTTP proxies has ever been requested for S3 in UpdraftPlus
$proxy_url = 'http://';
if ($user) {
$proxy_url .= $user;
if ($pass) $proxy_url .= ":$pass";
$proxy_url .= "@";
}
$proxy_url .= $host;
if ($port) $proxy_url .= ":$port";
$this->client->setDefaultOption('proxy', $proxy_url);
}
}
/**
* Set the error mode to exceptions
*
* @param boolean $enabled Enable exceptions
* @return void
*/
public function setExceptions($enabled = true) {
$this->useExceptions = $enabled;
}
/**
* A no-op in this compatibility layer (for now - not yet found a use)...
*
* @param boolean $use Bucket use
* @param string $bucket Bucket name
* @return boolean
*/
public function useDNSBucketName($use = true, $bucket = '') {
$this->use_dns_bucket_name = $use;
if ($use && $bucket) {
$this->setEndpoint($bucket.'.s3.amazonaws.com', $this->region);
}
return true;
}
/**
* Get contents for a bucket
* If max_keys is null this method will loop through truncated result sets
* N.B. UpdraftPlus does not use the $delimiter or $return_common_prefixes parameters (nor set $prefix or $marker to anything other than null)
* $return_common_prefixes is not implemented below
*
* @param string $bucket Bucket name
* @param string $prefix Prefix
* @param string $marker Marker (last file listed)
* @param string $max_keys Max keys (maximum number of keys to return)
* @param string $delimiter Delimiter
* @param boolean $return_common_prefixes Set to true to return CommonPrefixes
* @return array
*/
public function getBucket($bucket, $prefix = null, $marker = null, $max_keys = null, $delimiter = null, $return_common_prefixes = false) {// phpcs:ignore VariableAnalysis.CodeAnalysis.VariableAnalysis.UnusedVariable -- $return_common_prefixes is unused (commented out) so kept in just incase it is reused again
try {
if (0 == $max_keys) $max_keys = null;
$vars = array(
'Bucket' => $bucket,
'@region' => $this->region
);
if (null !== $prefix && '' !== $prefix) $vars['Prefix'] = $prefix;
if (null !== $marker && '' !== $marker) $vars['Marker'] = $marker;
if (null !== $max_keys && '' !== $max_keys) $vars['MaxKeys'] = $max_keys;
if (null !== $delimiter && '' !== $delimiter) $vars['Delimiter'] = $delimiter;
$result = $this->client->listObjects($vars);
if (!is_a($result, 'Aws\Result')) {
return false;
}
$results = array();
$next_marker = null;
// http://docs.aws.amazon.com/AmazonS3/latest/dev/ListingObjectKeysUsingPHP.html
// UpdraftPlus does not use the 'hash' result
if (empty($result['Contents'])) $result['Contents'] = array();
foreach ($result['Contents'] as $c) {
$results[(string) $c['Key']] = array(
'name' => (string) $c['Key'],
'time' => strtotime((string) $c['LastModified']),
'size' => (int) $c['Size'],
// 'hash' => trim((string)$c['ETag'])
// 'hash' => substr((string)$c['ETag'], 1, -1)
);
$next_marker = (string) $c['Key'];
}
if (isset($result['IsTruncated']) && empty($result['IsTruncated'])) return $results;
if (isset($result['NextMarker'])) $next_marker = (string) $result['NextMarker'];
// Loop through truncated results if max_keys isn't specified
if (null == $max_keys && null !== $next_marker && !empty($result['IsTruncated']))
do {
$vars['Marker'] = $next_marker;
$result = $this->client->listObjects($vars);
if (!is_a($result, 'Aws\Result') || empty($result['Contents'])) break;
foreach ($result['Contents'] as $c) {
$results[(string) $c['Key']] = array(
'name' => (string) $c['Key'],
'time' => strtotime((string) $c['LastModified']),
'size' => (int) $c['Size'],
// 'hash' => trim((string)$c['ETag'])
// 'hash' => substr((string)$c['ETag'], 1, -1)
);
$next_marker = (string) $c['Key'];
}
// if ($return_common_prefixes && isset($response->body, $response->body->CommonPrefixes))
// foreach ($response->body->CommonPrefixes as $c)
// $results[(string)$c->Prefix] = array('prefix' => (string)$c->Prefix);
if (isset($result['NextMarker']))
$next_marker = (string) $result['NextMarker'];
} while (is_a($result, 'Aws\Result') && !empty($result['Contents']) && !empty($result['IsTruncated']));
return $results;
} catch (Exception $e) {
if ($this->useExceptions) {
throw $e;
} else {
return $this->trigger_from_exception($e);
}
}
}
/**
* This is crude - nothing is returned
*
* @param string $bucket Name of the Bucket
* @return array Returns an array of results if bucket exists
*/
public function waitForBucket($bucket) {
try {
$this->client->waitUntil('BucketExists', array(
'Bucket' => $bucket,
'@region' => $this->region
));
} catch (Exception $e) {
if ($this->useExceptions) {
throw $e;
} else {
return $this->trigger_from_exception($e);
}
}
}
/**
* Put a bucket
*
* @param string $bucket Bucket name
* @param constant $acl ACL flag
* @param string $location Set as "EU" to create buckets hosted in Europe
* @return boolean Returns true or false; or may throw an exception
*/
public function putBucket($bucket, $acl = self::ACL_PRIVATE, $location = false) {
if (!$location) {
$location = $this->region;
} else {
$this->setRegion($location);
}
$bucket_vars = array(
'Bucket' => $bucket,
'ACL' => $acl,
'@region' => $this->region
);
// http://docs.aws.amazon.com/aws-sdk-php/latest/class-Aws.S3.S3Client.html#_createBucket
$location_constraint = apply_filters('updraftplus_s3_putbucket_defaultlocation', $location);
if ('us-east-1' != $location_constraint) $bucket_vars['LocationConstraint'] = $location_constraint;
try {
$result = $this->client->createBucket($bucket_vars);
if (is_object($result) && method_exists($result, 'get')) {
$metadata = $result->get('@metadata');
if (!empty($metadata) && in_array($metadata['statusCode'], array(200, 204))) {
$this->client->waitUntil('BucketExists', array(
'Bucket' => $bucket,
'@region' => $this->region
));
return true;
}
}
} catch (Exception $e) {
if ($this->useExceptions) {
throw $e;
} else {
return $this->trigger_from_exception($e);
}
}
return false;
}
/**
* Initiate a multi-part upload (http://docs.amazonwebservices.com/AmazonS3/latest/API/mpUploadInitiate.html)
*
* @param string $bucket Bucket name
* @param string $uri Object URI
* @param constant $acl ACL constant
* @param array $meta_headers Array of x-amz-meta-* headers
* @param array $request_headers Array of request headers or content type as a string
* @param constant $storage_class Storage class constant
* @return string | false
*/
public function initiateMultipartUpload($bucket, $uri, $acl = self::ACL_PRIVATE, $meta_headers = array(), $request_headers = array(), $storage_class = self::STORAGE_CLASS_STANDARD) {// phpcs:ignore Generic.CodeAnalysis.UnusedFunctionParameter.Found -- Unused parameter is present because the caller from UpdraftPlus_BackupModule_s3 class uses 6 arguments.
$vars = array(
'ACL' => $acl,
'Bucket' => $bucket,
'Key' => $uri,
'Metadata' => $meta_headers,
'StorageClass' => $storage_class,
'@region' => $this->region
);
$vars['ContentType'] = ('.gz' == strtolower(substr($uri, -3, 3))) ? 'application/octet-stream' : 'application/zip';
if (!empty($this->_serverSideEncryption)) $vars['ServerSideEncryption'] = $this->_serverSideEncryption;
try {
$result = $this->client->createMultipartUpload($vars);
if (is_object($result) && method_exists($result, 'get') && '' != $result->get('UploadId')) return $result->get('UploadId');
} catch (Exception $e) {
if ($this->useExceptions) {
throw $e;
} else {
return $this->trigger_from_exception($e);
}
}
return false;
}
/**
* Upload a part of a multi-part set (http://docs.amazonwebservices.com/AmazonS3/latest/API/mpUploadUploadPart.html)
* The chunk is read into memory, so make sure that you have enough (or patch this function to work another way!)
*
* @param string $bucket Bucket name
* @param string $uri Object URI
* @param string $upload_id upload_id returned previously from initiateMultipartUpload
* @param string $file_path file to upload content from
* @param integer $part_number sequential part number to upload
* @param integer $part_size number of bytes in each part (though final part may have fewer) - pass the same value each time (for this particular upload) - default 5Mb (which is Amazon's minimum)
* @return string (ETag) | false]
*/
public function uploadPart($bucket, $uri, $upload_id, $file_path, $part_number, $part_size = 5242880) {
$vars = array(
'Bucket' => $bucket,
'Key' => $uri,
'PartNumber' => $part_number,
'UploadId' => $upload_id,
'@region' => $this->region
);
// Where to begin
$file_offset = ($part_number - 1) * $part_size;
// Download the smallest of the remaining bytes and the part size
$file_bytes = min(filesize($file_path) - $file_offset, $part_size);
if ($file_bytes < 0) $file_bytes = 0;
// $rest->setHeader('Content-Type', 'application/octet-stream');
$data = "";
if ($handle = fopen($file_path, "rb")) {
if ($file_offset > 0) fseek($handle, $file_offset);
// $bytes_read = 0;
while ($file_bytes > 0 && $read = fread($handle, max($file_bytes, 131072))) {
$file_bytes = $file_bytes - strlen($read);
// $bytes_read += strlen($read);
$data .= $read;
}
fclose($handle);
} else {
return false;
}
$vars['Body'] = $data;
try {
$result = $this->client->uploadPart($vars);
if (is_object($result) && method_exists($result, 'get') && '' != $result->get('ETag')) return $result->get('ETag');
} catch (Exception $e) {
if ($this->useExceptions) {
throw $e;
} else {
return $this->trigger_from_exception($e);
}
}
return false;
}
/**
* Complete a multi-part upload (http://docs.amazonwebservices.com/AmazonS3/latest/API/mpUploadComplete.html)
*
* @param string $bucket Bucket name
* @param string $uri Object URI
* @param string $upload_id upload_id returned previously from initiateMultipartUpload
* @param array $parts an ordered list of eTags of previously uploaded parts from uploadPart
* @return boolean Returns either true of false
*/
public function completeMultipartUpload($bucket, $uri, $upload_id, $parts) {
$vars = array(
'Bucket' => $bucket,
'Key' => $uri,
'UploadId' => $upload_id,
'@region' => $this->region
);
$partno = 1;
$send_parts = array();
foreach ($parts as $etag) {
$send_parts[] = array('ETag' => $etag, 'PartNumber' => $partno);
$partno++;
}
$vars['MultipartUpload'] = array('Parts' => $send_parts);
try {
$result = $this->client->completeMultipartUpload($vars);
if (is_object($result) && method_exists($result, 'get') && '' != $result->get('ETag')) return true;
} catch (Exception $e) {
if ($this->useExceptions) {
throw $e;
} else {
return $this->trigger_from_exception($e);
}
}
return false;
}
/**
* Put an object from a file (legacy function)
*
* @param string $file Input file path
* @param string $bucket Bucket name
* @param string $uri Object URI
* @param constant $acl ACL constant
* @param array $meta_headers Array of x-amz-meta-* headers
* @param string $content_type Content type
* @param string $storage_class STORAGE_CLASS_STANDARD constant
* @return boolean returns either true of false
*/
public function putObjectFile($file, $bucket, $uri, $acl = self::ACL_PRIVATE, $meta_headers = array(), $content_type = null, $storage_class = self::STORAGE_CLASS_STANDARD) {
try {
$options = array(
'Bucket' => $bucket,
'Key' => $uri,
'SourceFile' => $file,
'StorageClass' => $storage_class,
'ACL' => $acl,
'@region' => $this->region
);
if ($content_type) $options['ContentType'] = $content_type;
if (!empty($this->_serverSideEncryption)) $options['ServerSideEncryption'] = $this->_serverSideEncryption;
if (!empty($meta_headers)) $options['Metadata'] = $meta_headers;
$result = $this->client->putObject($options);
if (is_object($result) && method_exists($result, 'get')) {
$metadata = $result->get('@metadata');
if (!empty($metadata) && in_array($metadata['statusCode'], array(200, 204))) return true;
}
} catch (Exception $e) {
if ($this->useExceptions) {
throw $e;
} else {
return $this->trigger_from_exception($e);
}
}
return false;
}
/**
* Put an object from a string (legacy function)
* Only the first 3 parameters vary in UpdraftPlus
*
* @param string $string Input data
* @param string $bucket Bucket name
* @param string $uri Object URI
* @param constant $acl ACL constant
* @param array $meta_headers Array of x-amz-meta-* headers
* @param string $content_type Content type
* @return boolean returns either true of false
*/
public function putObjectString($string, $bucket, $uri, $acl = self::ACL_PRIVATE, $meta_headers = array(), $content_type = 'text/plain') { // phpcs:ignore Generic.CodeAnalysis.UnusedFunctionParameter.Found -- legacy function
try {
$result = $this->client->putObject(array(
'Bucket' => $bucket,
'Key' => $uri,
'Body' => $string,
'ContentType' => $content_type,
'@region' => $this->region
));
if (is_object($result) && method_exists($result, 'get')) {
$metadata = $result->get('@metadata');
if (!empty($metadata) && in_array($metadata['statusCode'], array(200, 204))) return true;
}
} catch (Exception $e) {
if ($this->useExceptions) {
throw $e;
} else {
return $this->trigger_from_exception($e);
}
}
return false;
}
/**
* Get an object
*
* @param string $bucket Bucket name
* @param string $uri Object URI
* @param mixed $save_to Filename or resource to write to
* @param mixed $resume - if $save_to is a resource, then this is either false or the value for a Range: header; otherwise, a boolean, indicating whether to resume if possible.
* @return mixed
*/
public function getObject($bucket, $uri, $save_to = false, $resume = false) {
try {
// SaveAs: "Specify where the contents of the object should be downloaded. Can be the path to a file, a resource returned by fopen, or a Guzzle\Http\EntityBodyInterface object." - http://docs.aws.amazon.com/aws-sdk-php/latest/class-Aws.S3.S3Client.html#_getObject
$range_header = false;
if (is_resource($save_to)) {
$fp = $save_to;
if (!is_bool($resume)) $range_header = $resume;
} elseif (file_exists($save_to)) {
if ($resume && ($fp = @fopen($save_to, 'ab')) !== false) {// phpcs:ignore Generic.PHP.NoSilencedErrors.Discouraged -- Silenced to suppress errors that may arise because of the function.
$range_header = "bytes=".filesize($save_to).'-';
} else {
throw new Exception('Unable to open save file for writing: '.$save_to);
}
} else {
if (($fp = @fopen($save_to, 'wb')) !== false) {// phpcs:ignore Generic.PHP.NoSilencedErrors.Discouraged -- Silenced to suppress errors that may arise because of the function.
$range_header = false;
} else {
throw new Exception('Unable to open save file for writing: '.$save_to);
}
}
$vars = array(
'Bucket' => $bucket,
'Key' => $uri,
'SaveAs' => $fp,
'@region' => $this->region
);
if (!empty($range_header)) $vars['Range'] = $range_header;
$result = $this->client->getObject($vars);
if (is_object($result) && method_exists($result, 'get')) {
$metadata = $result->get('@metadata');
if (!empty($metadata) && in_array($metadata['statusCode'], array(200, 204, 206))) return true;
}
} catch (Exception $e) {
if ($this->useExceptions) {
throw $e;
} else {
return $this->trigger_from_exception($e);
}
}
return false;
}
/**
* Get a bucket's location
*
* @param string $bucket Bucket name
*
* @return String | Boolean - A boolean result will be false, indicating failure.
*/
public function getBucketLocation($bucket) {
try {
$result = $this->client->getBucketLocation(array(
'Bucket' => $bucket,
'@region' => $this->region
));
$location = $result->get('LocationConstraint');
if ($location) return $location;
} catch (NoSuchBucketException $e) {
return false;
} catch (Exception $e) {
if ($this->useExceptions) {
throw $e;
} else {
return $this->trigger_from_exception($e);
}
}
}
private function trigger_from_exception($e) {
trigger_error(esc_html($e->getMessage().' ('.get_class($e).') (line: '.$e->getLine().', file: '.$e->getFile().')'), E_USER_WARNING);
return false;
}
/**
* Delete an object
*
* @param string $bucket Bucket name
* @param string $uri Object URI
* @return boolean
*/
public function deleteObject($bucket, $uri) {
try {
$result = $this->client->deleteObject(array(
'Bucket' => $bucket,
'Key' => $uri,
'@region' => $this->region
));
if (is_object($result) && method_exists($result, 'get')) {
$metadata = $result->get('@metadata');
if (!empty($metadata) && in_array($metadata['statusCode'], array(200, 204))) return true;
}
} catch (Exception $e) {
if ($this->useExceptions) {
throw $e;
} else {
return $this->trigger_from_exception($e);
}
}
return false;
}
public function setCORS($policy) {
try {
$cors = $this->client->putBucketCors($policy);
if (is_object($cors) && method_exists($cors, 'get')) {
$metadata = $cors->get('@metadata');
if (!empty($metadata) && in_array($metadata['statusCode'], array(200, 204))) return true;
}
} catch (Exception $e) {
if ($this->useExceptions) {
throw $e;
} else {
return $this->trigger_from_exception($e);
}
}
return false;
}
/**
* Get or create IAM instance
*
* @return object $this->iam
*/
private function getIAM() {
if (!$this->iam) {
$opts = array(
'credentials' => array(
'key' => $this->__access_key,
'secret' => $this->__secret_key
),
'version' => '2010-05-08',
'region' => $this->region
);
$this->iam = new Aws\Iam\IamClient($opts);
}
return $this->iam;
}
/**
* Create IAM user
*
* @param array $options
*
* @return array $response
*/
public function createUser($options) {
$iam = $this->getIAM();
try {
$response = $iam->createUser(array(
'Path' => $options['Path'],
'UserName' => $options['UserName']
));
} catch (Guzzle\Http\Exception\ClientErrorResponseException $e) {
$response = $e->getResponse();
$code = $response->getStatusCode();
return array(
'code' => $code,
'error' => $e->getMessage()
);
}
return $response;
}
/**
* Create access key for IAM user
*
* @param string $username
*
* @return array $response
*/
public function createAccessKey($username) {
$iam = $this->getIAM();
try {
$response = $iam->createAccessKey(array('UserName' => $username));
} catch (Guzzle\Http\Exception\ClientErrorResponseException $e) {
return array(
'error' => $e->getMessage()
);
}
return $response;
}
/**
* Put user policy IAM user
*
* @param array $options
*
* @return array $response
*/
public function putUserPolicy($options) {
$iam = $this->getIAM();
try {
$response = $iam->putUserPolicy(array(
'UserName' => $options['UserName'],
'PolicyName' => $options['PolicyName'],
'PolicyDocument' => $options['PolicyDocument']
));
} catch (Guzzle\Http\Exception\ClientErrorResponseException $e) {
return array(
'error' => $e->getMessage()
);
}
return $response;
}
}
