73 lines
1.7 KiB
C++
73 lines
1.7 KiB
C++
/* This file is part of mastodon-cpp.
|
|
* Streaming API example
|
|
*/
|
|
|
|
|
|
#include <iostream>
|
|
#include <string>
|
|
#include <cstdint>
|
|
#include <thread>
|
|
#include <chrono>
|
|
#include <memory>
|
|
#ifdef MASTODON_CPP
|
|
#include "mastodon-cpp.hpp"
|
|
#else
|
|
#include <mastodon-cpp/mastodon-cpp.hpp>
|
|
#endif
|
|
|
|
using Mastodon::API;
|
|
|
|
int main(int argc, char *argv[])
|
|
{
|
|
if (argc < 3)
|
|
{
|
|
std::cerr << "usage: " << argv[0] << " <instance> <access_token>\n";
|
|
return 1;
|
|
}
|
|
|
|
static std::string answer;
|
|
static std::unique_ptr<Mastodon::API::http> ptr;
|
|
|
|
std::cout << "Dumping public timeline...\n";
|
|
std::thread pub([=]
|
|
{
|
|
Mastodon::API masto(argv[1], argv[2]);
|
|
masto.set_useragent("mastodon-cpp-example/1.3.3.7");
|
|
masto.get_stream(API::v1::streaming_public, answer, ptr);
|
|
});
|
|
|
|
std::uint8_t counter = 0;
|
|
while (true)
|
|
{
|
|
++counter;
|
|
std::cout << answer;
|
|
answer.clear();
|
|
if (counter == 10)
|
|
{
|
|
std::cerr << "Aborting...\n";
|
|
ptr->abort_stream();
|
|
break;
|
|
}
|
|
std::this_thread::sleep_for(std::chrono::seconds(2));
|
|
}
|
|
pub.join();
|
|
std::cout << '\n';
|
|
|
|
std::cout << "Dumping the #np tag...\n";
|
|
answer = "";
|
|
std::thread tag([=]
|
|
{
|
|
Mastodon::API masto(argv[1], argv[2]);
|
|
masto.set_useragent("mastodon-cpp-example/1.3.3.7");
|
|
masto.get_stream(API::v1::streaming_hashtag, {{ "hashtag", {"np"} }},
|
|
answer, ptr);
|
|
});
|
|
std::this_thread::sleep_for(std::chrono::seconds(20));
|
|
ptr->abort_stream();
|
|
std::cout << answer;
|
|
std::cout << '\n';
|
|
tag.join();
|
|
|
|
return 0;
|
|
}
|