remove rss_reader from examples
This commit is contained in:
Arvid Norberg
parent
f168849f51
commit
7cb2f79377
|
|
@ -23,7 +23,6 @@ exe stats_counters : stats_counters.cpp ;
|
||||||
exe dump_torrent : dump_torrent.cpp ;
|
exe dump_torrent : dump_torrent.cpp ;
|
||||||
exe make_torrent : make_torrent.cpp ;
|
exe make_torrent : make_torrent.cpp ;
|
||||||
exe connection_tester : connection_tester.cpp ;
|
exe connection_tester : connection_tester.cpp ;
|
||||||
exe rss_reader : rss_reader.cpp ;
|
|
||||||
exe upnp_test : upnp_test.cpp ;
|
exe upnp_test : upnp_test.cpp ;
|
||||||
|
|
||||||
explicit stage_client_test ;
|
explicit stage_client_test ;
|
||||||
|
|
|
||||||
|
|
@ -4,7 +4,6 @@ example_programs = \
|
||||||
dump_torrent \
|
dump_torrent \
|
||||||
make_torrent \
|
make_torrent \
|
||||||
simple_client \
|
simple_client \
|
||||||
rss_reader \
|
|
||||||
upnp_test \
|
upnp_test \
|
||||||
connection_tester
|
connection_tester
|
||||||
|
|
||||||
|
|
@ -33,9 +32,6 @@ simple_client_SOURCES = simple_client.cpp
|
||||||
connection_tester_SOURCES = connection_tester.cpp
|
connection_tester_SOURCES = connection_tester.cpp
|
||||||
#connection_tester_LDADD = $(top_builddir)/src/libtorrent-rasterbar.la
|
#connection_tester_LDADD = $(top_builddir)/src/libtorrent-rasterbar.la
|
||||||
|
|
||||||
rss_reader_SOURCES = rss_reader.cpp
|
|
||||||
#rss_reader_LDADD = $(top_builddir)/src/libtorrent-rasterbar.la
|
|
||||||
|
|
||||||
upnp_test_SOURCES = upnp_test.cpp
|
upnp_test_SOURCES = upnp_test.cpp
|
||||||
#upnp_test_LDADD = $(top_builddir)/src/libtorrent-rasterbar.la
|
#upnp_test_LDADD = $(top_builddir)/src/libtorrent-rasterbar.la
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -39,7 +39,7 @@ POSSIBILITY OF SUCH DAMAGE.
|
||||||
#include "libtorrent/create_torrent.hpp"
|
#include "libtorrent/create_torrent.hpp"
|
||||||
#include "libtorrent/file.hpp"
|
#include "libtorrent/file.hpp"
|
||||||
#include "libtorrent/file_pool.hpp"
|
#include "libtorrent/file_pool.hpp"
|
||||||
#include "libtorrent/escape_string.hpp" // for from_hex
|
#include "libtorrent/hex.hpp" // for from_hex
|
||||||
|
|
||||||
#include <boost/bind.hpp>
|
#include <boost/bind.hpp>
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -1,283 +0,0 @@
|
||||||
/*
|
|
||||||
|
|
||||||
Copyright (c) 2012, Arvid Norberg
|
|
||||||
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.
|
|
||||||
* Neither the name of the author nor the names of its
|
|
||||||
contributors may be used to endorse or promote products derived
|
|
||||||
from this software without specific prior written permission.
|
|
||||||
|
|
||||||
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.
|
|
||||||
|
|
||||||
*/
|
|
||||||
|
|
||||||
|
|
||||||
#include "libtorrent/rss.hpp"
|
|
||||||
#include "libtorrent/session.hpp"
|
|
||||||
#include "libtorrent/bencode.hpp"
|
|
||||||
#include <signal.h>
|
|
||||||
#include <stdio.h>
|
|
||||||
|
|
||||||
using namespace libtorrent;
|
|
||||||
namespace lt = libtorrent;
|
|
||||||
|
|
||||||
void sleep_ms(int milliseconds)
|
|
||||||
{
|
|
||||||
#if defined TORRENT_WINDOWS || defined TORRENT_CYGWIN
|
|
||||||
Sleep(milliseconds);
|
|
||||||
#elif defined TORRENT_BEOS
|
|
||||||
snooze_until(system_time() + boost::int64_t(milliseconds) * 1000, B_SYSTEM_TIMEBASE);
|
|
||||||
#else
|
|
||||||
usleep(milliseconds * 1000);
|
|
||||||
#endif
|
|
||||||
}
|
|
||||||
|
|
||||||
int load_file(std::string const& filename, std::vector<char>& v, libtorrent::error_code& ec, int limit = 8000000)
|
|
||||||
{
|
|
||||||
ec.clear();
|
|
||||||
FILE* f = fopen(filename.c_str(), "rb");
|
|
||||||
if (f == NULL)
|
|
||||||
{
|
|
||||||
ec.assign(errno, boost::system::generic_category());
|
|
||||||
return -1;
|
|
||||||
}
|
|
||||||
|
|
||||||
int r = fseek(f, 0, SEEK_END);
|
|
||||||
if (r != 0)
|
|
||||||
{
|
|
||||||
ec.assign(errno, boost::system::generic_category());
|
|
||||||
fclose(f);
|
|
||||||
return -1;
|
|
||||||
}
|
|
||||||
long s = ftell(f);
|
|
||||||
if (s < 0)
|
|
||||||
{
|
|
||||||
ec.assign(errno, boost::system::generic_category());
|
|
||||||
fclose(f);
|
|
||||||
return -1;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (s > limit)
|
|
||||||
{
|
|
||||||
fclose(f);
|
|
||||||
return -2;
|
|
||||||
}
|
|
||||||
|
|
||||||
r = fseek(f, 0, SEEK_SET);
|
|
||||||
if (r != 0)
|
|
||||||
{
|
|
||||||
ec.assign(errno, boost::system::generic_category());
|
|
||||||
fclose(f);
|
|
||||||
return -1;
|
|
||||||
}
|
|
||||||
|
|
||||||
v.resize(s);
|
|
||||||
if (s == 0)
|
|
||||||
{
|
|
||||||
fclose(f);
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
r = fread(&v[0], 1, v.size(), f);
|
|
||||||
if (r < 0)
|
|
||||||
{
|
|
||||||
ec.assign(errno, boost::system::generic_category());
|
|
||||||
fclose(f);
|
|
||||||
return -1;
|
|
||||||
}
|
|
||||||
|
|
||||||
fclose(f);
|
|
||||||
|
|
||||||
if (r != s) return -3;
|
|
||||||
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
void print_feed(feed_status const& f)
|
|
||||||
{
|
|
||||||
printf("FEED: %s\n",f.url.c_str());
|
|
||||||
if (f.error)
|
|
||||||
printf("ERROR: %s\n", f.error.message().c_str());
|
|
||||||
|
|
||||||
printf(" %s\n %s\n", f.title.c_str(), f.description.c_str());
|
|
||||||
printf(" ttl: %d minutes\n", f.ttl);
|
|
||||||
|
|
||||||
for (std::vector<feed_item>::const_iterator i = f.items.begin()
|
|
||||||
, end(f.items.end()); i != end; ++i)
|
|
||||||
{
|
|
||||||
printf("\033[32m%s\033[0m\n------------------------------------------------------\n"
|
|
||||||
" url: %s\n size: %" PRId64 "\n info-hash: %s\n uuid: %s\n description: %s\n"
|
|
||||||
" comment: %s\n category: %s\n"
|
|
||||||
, i->title.c_str(), i->url.c_str(), i->size
|
|
||||||
, i->info_hash.is_all_zeros() ? "" : to_hex(i->info_hash.to_string()).c_str()
|
|
||||||
, i->uuid.c_str(), i->description.c_str(), i->comment.c_str(), i->category.c_str());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
std::string const& progress_bar(int progress, int width)
|
|
||||||
{
|
|
||||||
static std::string bar;
|
|
||||||
bar.clear();
|
|
||||||
bar.reserve(width + 10);
|
|
||||||
|
|
||||||
int progress_chars = (progress * width + 500) / 1000;
|
|
||||||
std::fill_n(std::back_inserter(bar), progress_chars, '#');
|
|
||||||
std::fill_n(std::back_inserter(bar), width - progress_chars, '-');
|
|
||||||
return bar;
|
|
||||||
}
|
|
||||||
|
|
||||||
int save_file(std::string const& filename, std::vector<char>& v)
|
|
||||||
{
|
|
||||||
FILE* f = fopen(filename.c_str(), "wb");
|
|
||||||
if (f == NULL)
|
|
||||||
return -1;
|
|
||||||
|
|
||||||
int w = fwrite(&v[0], 1, v.size(), f);
|
|
||||||
if (w < 0)
|
|
||||||
{
|
|
||||||
fclose(f);
|
|
||||||
return -1;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (w != int(v.size())) return -3;
|
|
||||||
fclose(f);
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
volatile bool quit = false;
|
|
||||||
|
|
||||||
void sig(int num)
|
|
||||||
{
|
|
||||||
quit = true;
|
|
||||||
}
|
|
||||||
|
|
||||||
int main(int argc, char* argv[])
|
|
||||||
{
|
|
||||||
if ((argc == 2 && strcmp(argv[1], "--help") == 0) || argc > 2)
|
|
||||||
{
|
|
||||||
fprintf(stderr, "usage: rss_reader [rss-url]\n");
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
lt::session ses;
|
|
||||||
|
|
||||||
settings_pack pack;
|
|
||||||
pack.set_int(settings_pack::active_downloads, 2);
|
|
||||||
pack.set_int(settings_pack::active_seeds, 1);
|
|
||||||
pack.set_int(settings_pack::active_limit, 3);
|
|
||||||
ses.apply_settings(pack);
|
|
||||||
|
|
||||||
std::vector<char> in;
|
|
||||||
error_code ec;
|
|
||||||
if (load_file(".ses_state", in, ec) == 0)
|
|
||||||
{
|
|
||||||
bdecode_node e;
|
|
||||||
if (bdecode(&in[0], &in[0] + in.size(), e, ec) == 0)
|
|
||||||
ses.load_state(e);
|
|
||||||
}
|
|
||||||
|
|
||||||
feed_handle fh;
|
|
||||||
if (argc == 2)
|
|
||||||
{
|
|
||||||
feed_settings feed;
|
|
||||||
feed.url = argv[1];
|
|
||||||
feed.add_args.save_path = ".";
|
|
||||||
fh = ses.add_feed(feed);
|
|
||||||
fh.update_feed();
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
std::vector<feed_handle> handles;
|
|
||||||
ses.get_feeds(handles);
|
|
||||||
if (handles.empty())
|
|
||||||
{
|
|
||||||
printf("usage: rss_reader rss-url\n");
|
|
||||||
return 1;
|
|
||||||
}
|
|
||||||
fh = handles[0];
|
|
||||||
}
|
|
||||||
feed_status fs = fh.get_feed_status();
|
|
||||||
int i = 0;
|
|
||||||
char spinner[] = {'|', '/', '-', '\\'};
|
|
||||||
fprintf(stderr, "fetching feed ... %c", spinner[i]);
|
|
||||||
while (fs.updating)
|
|
||||||
{
|
|
||||||
sleep_ms(100);
|
|
||||||
i = (i + 1) % 4;
|
|
||||||
fprintf(stderr, "\b%c", spinner[i]);
|
|
||||||
fs = fh.get_feed_status();
|
|
||||||
}
|
|
||||||
fprintf(stderr, "\bDONE\n");
|
|
||||||
|
|
||||||
print_feed(fs);
|
|
||||||
|
|
||||||
signal(SIGTERM, &sig);
|
|
||||||
signal(SIGINT, &sig);
|
|
||||||
|
|
||||||
while (!quit)
|
|
||||||
{
|
|
||||||
std::vector<torrent_handle> t = ses.get_torrents();
|
|
||||||
for (std::vector<torrent_handle>::iterator i = t.begin()
|
|
||||||
, end(t.end()); i != end; ++i)
|
|
||||||
{
|
|
||||||
torrent_status st = i->status();
|
|
||||||
std::string const& progress = progress_bar(st.progress_ppm / 1000, 40);
|
|
||||||
std::string name = st.name;
|
|
||||||
if (name.size() > 70) name.resize(70);
|
|
||||||
std::string error = st.error;
|
|
||||||
if (error.size() > 40) error.resize(40);
|
|
||||||
|
|
||||||
static char const* state_str[] =
|
|
||||||
{"checking (q)", "checking", "dl metadata"
|
|
||||||
, "downloading", "finished", "seeding", "allocating", "checking (r)"};
|
|
||||||
std::string status = st.paused ? "queued" : state_str[st.state];
|
|
||||||
|
|
||||||
int attribute = 0;
|
|
||||||
if (st.paused) attribute = 33;
|
|
||||||
else if (st.state == torrent_status::downloading) attribute = 1;
|
|
||||||
|
|
||||||
printf("\033[%dm%2d %-70s d:%-4d u:%-4d %-40s %4d(%4d) %-12s\033[0m\n"
|
|
||||||
, attribute, st.queue_position
|
|
||||||
, name.c_str(), st.download_rate / 1000
|
|
||||||
, st.upload_rate / 1000, !error.empty() ? error.c_str() : progress.c_str()
|
|
||||||
, st.num_peers, st.num_seeds, status.c_str());
|
|
||||||
}
|
|
||||||
|
|
||||||
sleep_ms(500);
|
|
||||||
if (quit) break;
|
|
||||||
printf("\033[%dA", int(t.size()));
|
|
||||||
}
|
|
||||||
|
|
||||||
printf("saving session state\n");
|
|
||||||
{
|
|
||||||
entry session_state;
|
|
||||||
ses.save_state(session_state);
|
|
||||||
|
|
||||||
std::vector<char> out;
|
|
||||||
bencode(std::back_inserter(out), session_state);
|
|
||||||
save_file(".ses_state", out);
|
|
||||||
}
|
|
||||||
|
|
||||||
printf("closing session");
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
Loading…
Reference in New Issue