Управление сайтом

Файловый менеджер

Имя файла	realtimeHttp.php
Содержимое	<?php /* * IMPORTANT! * You need https://github.com/reactphp/http to run this example: * $ composer require react/http "^0.7" * * Also, https://github.com/Seldaek/monolog is required: * $ composer require monolog/monolog * * Lastly, if you have a 32-bit PHP build, you have to enable the GMP extension: * http://php.net/manual/en/book.gmp.php * * Usage: * # mark item 456 in thread 123 as seen * $ curl -i 'http://127.0.0.1:1307/seen?threadId=123&threadItemId=456' * # send typing notification to thread 123 * $ curl -i 'http://127.0.0.1:1307/activity?threadId=123&flag=1' * # send some message to thread 123 * $ curl -i 'http://127.0.0.1:1307/message?threadId=123&text=Hi!' * # share post 456_789 to thread 123 * $ curl -i 'http://127.0.0.1:1307/post?threadId=123&mediaId=456_789&text=This+is+a+really+good+post!' * # share story 456_789 to thread 123 * $ curl -i 'http://127.0.0.1:1307/story?threadId=123&storyId=456_789&text=This+is+a+really+good+story!' * # share profile 456789 to thread 123 * $ curl -i 'http://127.0.0.1:1307/profile?threadId=123&userId=456789&text=Take+a+look+at+their+posts!' * # send location 456789 to thread 123 * $ curl -i 'http://127.0.0.1:1307/location?threadId=123&locationId=456789&text=I+want+to+go+there!' * # send hashtag #somehashtag to thread 123 * $ curl -i 'http://127.0.0.1:1307/hashtag?threadId=123&hashtag=somehashtag&text=It+went+viral!' * # like item 456 from thread 123 * $ curl -i 'http://127.0.0.1:1307/likeItem?threadId=123&threadItemId=456' * # unlike item 456 from thread 123 * $ curl -i 'http://127.0.0.1:1307/unlikeItem?threadId=123&threadItemId=456' * # send like to thread 123 * $ curl -i 'http://127.0.0.1:1307/like?threadId=123' * # remove typing notification from thread 123 * $ curl -i 'http://127.0.0.1:1307/activity?threadId=123&flag=0' * # ping realtime http server * $ curl -i 'http://127.0.0.1:1307/ping' * # stop realtime http server * $ curl -i 'http://127.0.0.1:1307/stop' / set_time_limit(0); date_default_timezone_set('UTC'); require __DIR__.'/../vendor/autoload.php'; /////// CONFIG /////// $username = ''; $password = ''; $debug = true; $truncatedDebug = false; ////////////////////// $ig = new \InstagramAPI\Instagram($debug, $truncatedDebug); try { $ig->login($username, $password); } catch (\Exception $e) { echo 'Something went wrong: '.$e->getMessage()."\n"; exit(0); } // Create main event loop. $loop = \React\EventLoop\Factory::create(); if ($debug) { $logger = new \Monolog\Logger('rtc'); $logger->pushHandler(new \Monolog\Handler\StreamHandler('php://stdout', \Monolog\Logger::INFO)); } else { $logger = null; } // Create HTTP server along with Realtime client. $httpServer = new RealtimeHttpServer($loop, $ig, $logger); // Run main loop. $loop->run(); class RealtimeHttpServer { const HOST = '127.0.0.1'; const PORT = 1307; const TIMEOUT = 5; /* @var \React\Promise\Deferred[] / protected $_contexts; /* @var \React\EventLoop\LoopInterface / protected $_loop; /* @var \InstagramAPI\Instagram / protected $_instagram; /* @var \InstagramAPI\Realtime / protected $_rtc; /* @var \React\Http\Server / protected $_server; /* @var \Psr\Log\LoggerInterface / protected $_logger; /* * Constructor. * * @param \React\EventLoop\LoopInterface $loop * @param \InstagramAPI\Instagram $instagram * @param \Psr\Log\LoggerInterface\|null $logger / public function __construct( \React\EventLoop\LoopInterface $loop, \InstagramAPI\Instagram $instagram, \Psr\Log\LoggerInterface $logger = null) { $this->_loop = $loop; $this->_instagram = $instagram; if ($logger === null) { $logger = new \Psr\Log\NullLogger(); } $this->_logger = $logger; $this->_contexts = []; $this->_rtc = new \InstagramAPI\Realtime($this->_instagram, $this->_loop, $this->_logger); $this->_rtc->on('client-context-ack', [$this, 'onClientContextAck']); $this->_rtc->on('error', [$this, 'onRealtimeFail']); $this->_rtc->start(); $this->_startHttpServer(); } /* * Gracefully stop everything. / protected function _stop() { // Initiate shutdown sequence. $this->_rtc->stop(); // Wait 2 seconds for Realtime to shutdown. $this->_loop->addTimer(2, function () { // Stop main loop. $this->_loop->stop(); }); } /* * Called when fatal error has been received from Realtime. * * @param \Exception $e / public function onRealtimeFail( \Exception $e) { $this->_logger->error((string) $e); $this->_stop(); } /* * Called when ACK has been received. * * @param \InstagramAPI\Realtime\Payload\Action\AckAction $ack / public function onClientContextAck( \InstagramAPI\Realtime\Payload\Action\AckAction $ack) { $context = $ack->getPayload()->getClientContext(); $this->_logger->info(sprintf('Received ACK for %s with status %s', $context, $ack->getStatus())); // Check if we have deferred object for this client_context. if (!isset($this->_contexts[$context])) { return; } // Resolve deferred object with $ack. $deferred = $this->_contexts[$context]; $deferred->resolve($ack); // Clean up. unset($this->_contexts[$context]); } /* * @param string\|bool $context * * @return \React\Http\Response\|\React\Promise\PromiseInterface / protected function _handleClientContext( $context) { // Reply with 503 Service Unavailable. if ($context === false) { return new \React\Http\Response(503); } // Set up deferred object. $deferred = new \React\Promise\Deferred(); $this->_contexts[$context] = $deferred; // Reject deferred after given timeout. $timeout = $this->_loop->addTimer(self::TIMEOUT, function () use ($deferred, $context) { $deferred->reject(); unset($this->_contexts[$context]); }); // Set up promise. return $deferred->promise() ->then(function (\InstagramAPI\Realtime\Payload\Action\AckAction $ack) use ($timeout) { // Cancel reject timer. $timeout->cancel(); // Reply with info from $ack. return new \React\Http\Response($ack->getStatusCode(), ['Content-Type' => 'text/json'], $ack->getPayload()->asJson()); }) ->otherwise(function () { // Called by reject timer. Reply with 504 Gateway Time-out. return new \React\Http\Response(504); }); } /* * Handler for incoming HTTP requests. * * @param \Psr\Http\Message\ServerRequestInterface $request * * @return \React\Http\Response\|\React\Promise\PromiseInterface / public function onHttpRequest( \Psr\Http\Message\ServerRequestInterface $request) { // Treat request path as command. $command = $request->getUri()->getPath(); // Params validation is up to you. $params = $request->getQueryParams(); // Log command with its params. $this->_logger->info(sprintf('Received command %s', $command), $params); switch ($command) { case '/ping': return new \React\Http\Response(200, [], 'pong'); case '/stop': $this->_stop(); return new \React\Http\Response(200); case '/seen': $context = $this->_rtc->markDirectItemSeen($params['threadId'], $params['threadItemId']); return new \React\Http\Response($context !== false ? 200 : 503); case '/activity': return $this->_handleClientContext($this->_rtc->indicateActivityInDirectThread($params['threadId'], (bool) $params['flag'])); case '/message': return $this->_handleClientContext($this->_rtc->sendTextToDirect($params['threadId'], $params['text'])); case '/post': return $this->_handleClientContext($this->_rtc->sendPostToDirect($params['threadId'], $params['mediaId'], [ 'text' => isset($params['text']) ? $params['text'] : null, ])); case '/story': return $this->_handleClientContext($this->_rtc->sendStoryToDirect($params['threadId'], $params['storyId'], [ 'text' => isset($params['text']) ? $params['text'] : null, ])); case '/profile': return $this->_handleClientContext($this->_rtc->sendProfileToDirect($params['threadId'], $params['userId'], [ 'text' => isset($params['text']) ? $params['text'] : null, ])); case '/location': return $this->_handleClientContext($this->_rtc->sendLocationToDirect($params['threadId'], $params['locationId'], [ 'text' => isset($params['text']) ? $params['text'] : null, ])); case '/hashtag': return $this->_handleClientContext($this->_rtc->sendHashtagToDirect($params['threadId'], $params['hashtag'], [ 'text' => isset($params['text']) ? $params['text'] : null, ])); case '/like': return $this->_handleClientContext($this->_rtc->sendLikeToDirect($params['threadId'])); case '/likeItem': return $this->_handleClientContext($this->_rtc->sendReactionToDirect($params['threadId'], $params['threadItemId'], 'like')); case '/unlikeItem': return $this->_handleClientContext($this->_rtc->deleteReactionFromDirect($params['threadId'], $params['threadItemId'], 'like')); default: $this->_logger->warning(sprintf('Unknown command %s', $command), $params); // If command is unknown, reply with 404 Not Found. return new \React\Http\Response(404); } } /* * Init and start HTTP server. */ protected function _startHttpServer() { // Create server socket. $socket = new \React\Socket\Server(self::HOST.':'.self::PORT, $this->_loop); $this->_logger->info(sprintf('Listening on http://%s', $socket->getAddress())); // Bind HTTP server on server socket. $this->_server = new \React\Http\Server([$this, 'onHttpRequest']); $this->_server->listen($socket); } }

/cron/instagram/vendor/mgp25/instagram-php/examples/

Имя	Дата	Размер
..	2019-01-15
assets	2019-01-15
README.md	2019-01-15	773 байт
accessingValues.php	2019-01-15	3 кб.
customSettings.php	2019-01-15	7 кб.
exceptionDetailsExample.php	2019-01-15	3 кб.
liveBroadcast.php	2019-01-15	4 кб.
paginateWithExclusion.php	2019-01-15	2 кб.
paginationExample.php	2019-01-15	2 кб.
pushReceiver.php	2019-01-15	2 кб.
rankTokenUsage.php	2019-01-15	2 кб.
realtimeClient.php	2019-01-15	5 кб.
realtimeHttp.php	2019-01-15	11 кб.
sharePhotoToStoryFeed.php	2019-01-15	2 кб.
shortcodeConverter.php	2019-01-15	819 байт
twoFactorLogin.php	2019-01-15	960 байт
uploadAlbum.php	2019-01-15	3 кб.
uploadPhoto.php	2019-01-15	2 кб.
uploadStory.php	2019-01-15	4 кб.
uploadStoryPoll.php	2019-01-15	3 кб.
uploadVideo.php	2019-01-15	2 кб.

/cron/instagram/vendor/mgp25/instagram-php/examples