Stars: 115
Forks: 22
Pull Requests: 15
Issues: 9
Watchers: 26
Last Updated: 2020-09-04 17:12:33
Asynchronous Twitter client compatible with mpyw/co Generator-based flows.
License: MIT License
Languages: PHP, Hack
Asynchronous Twitter client compatible with mpyw/co Generator-based flows.
PHP | ❓ | Feature Restriction |
---|---|---|
7.0~ | 😄 | Full Support |
5.5~5.6 | 😧 | Generator is not so cool |
~5.4 | 💥 | Incompatible |
composer require mpyw/cowitter:^1.0
require __DIR__ . '/vendor/autoload.php';
use mpyw\Co\Co;
use mpyw\Co\CURLException;
use mpyw\Cowitter\Client;
use mpyw\Cowitter\HttpException;
$client = new Client(['CK', 'CS', 'AT', 'ATS']);
// Search tweets
$statuses = $client->get('search/tweets', ['q' => 'cowitter'])->statuses;
var_dump($statuses);
// Update tweet
$client->post('statuses/update', ['status' => 'Cowitter is the best twitter library for PHP!']);
// Send direct message with new API
$params = [
'event' => [
'type' => 'message_create',
'message_create' => [
'target' => [
'recipient_id' => 'RECIPIENT_USER_ID'
],
'message_data' => [
'text' => 'Hello World!',
]
]
]
];
// Post as json
$client->postJson('direct_messages/events/new ', $params);
// Update tweet with multiple images
$ids = [
$client->postMultipart('media/upload', ['media' => new \CURLFile('photo01.png')])->media_id_string,
$client->postMultipart('media/upload', ['media' => new \CURLFile('photo02.jpg')])->media_id_string,
];
$client->post('statuses/update', [
'status' => 'My photos',
'media_ids' => implode(',', $ids),
]);
// Listen user streaming
$client->streaming('user', function ($status) {
if (!isset($status->text)) return;
printf("%s(@%s) - %s\n",
$status->user->name,
$status->user->screen_name,
htmlspecialchars_decode($status->text, ENT_NOQUOTES)
);
});
// Search tweets
Co::wait(function () use ($client) {
$statuses = (yield $client->getAsync('search/tweets', ['q' => 'cowitter']))->statuses;
var_dump($statuses);
});
// Rapidly update tweets for 10 times
$tasks = [];
for ($i = 0; $i < 20; ++$i) {
$tasks[] = $client->postAsync('statuses/update', [
'status' => str_repeat('!', $i + 1),
]);
}
Co::wait($tasks);
// Rapidly update tweet with multiple images
Co::wait(function () use ($client) {
$info = yield [
$client->postMultipartAsync('media/upload', ['media' => new \CURLFile('photo01.png')]),
$client->postMultipartAsync('media/upload', ['media' => new \CURLFile('photo02.png')]),
];
yield $client->postAsync('statuses/update', [
'status' => 'My photos',
'media_ids' => implode(',', array_column($info, 'media_id_string')),
]);
});
// Listen filtered streaming to favorite/retweet at once each tweet
Co::wait($client->streamingAsync('statuses/filter', function ($status) use ($client) {
if (!isset($status->text)) return;
printf("%s(@s) - %s\n",
$status->user->name,
$status->user->screen_name,
htmlspecialchars_decode($status->text, ENT_NOQUOTES)
);
yield Co::SAFE => [ // ignore errors
$client->postAsync('favorites/create', ['id' => $status->id_str]),
$client->postAsync("statuses/retweet/{$status->id_str}"),
];
}, ['track' => 'PHP']));
// Rapidly update with MP4 video
Co::wait(function () use ($client) {
$file = new \SplFileObject('video.mp4', 'rb');
$on_uploading = function ($percent) {
echo "Uploading ... ({$percent}%)\n";
};
$on_processing = function ($percent) {
echo "Processing ... ({$percent}%)\n";
};
yield $client->postAsync('statuses/update', [
'status' => 'My video',
'media_ids' => (yield $client->uploadVideoAsync($file, 'tweet_video', $on_uploading, $on_processing))->media_id_string,
]);
echo "Done\n";
});
try {
// do stuff here
$client->get(...);
$client->post(...);
} catch (HttpException $e) {
// cURL communication successful but something went wrong with Twitter APIs.
$message = $e->getMessage(); // Message
$code = $e->getCode(); // Error code (-1 if not available)
$status = $e->getStatusCode(); // HTTP status code
} catch (CURLException $e) {
// cURL communication failed.
$message = $e->getMessage(); // Message (equivalent to curl_error())
$code = $e->getCode(); // Error code (equivalent to curl_errno())
}
or
try {
// do stuff here
$client->get(...);
$client->post(...);
} catch (\RuntimeException $e) {
// Something failed.
$message = $e->getMessage();
}
If you encountered SSL certificate problem
error...
cacert.pem
from official libcurl site.Specify the path as curl.cainfo
in your php.ini
.
curl.cainfo="C:\foo\bar\baz\cacert.pem"
DO NOT forget restarting Apache.
Specify the path as CURLOPT_CAINFO
. Using the magic constant __DIR__
is recommended.
$client = new Client(['CK', 'CS', 'AT', 'ATS'], [CURLOPT_CAINFO => __DIR__ . '/cacert.pem']);
or
$client = new Client(['CK', 'CS', 'AT', 'ATS']);
$client = $client->withOptions([CURLOPT_CAINFO => __DIR__ . '/cacert.pem']);
Read interfaces.