Added an RSS feed example.

glynos · glynos · commit 56048ec0f0bd · 2011-12-11T11:36:06.000+01:00
diff --git a/libs/network/example/CMakeLists.txt b/libs/network/example/CMakeLists.txt
@@ -11,6 +11,7 @@ endif (OPENSSL_FOUND)
 add_executable(http_client http_client.cpp)
 add_executable(simple_wget simple_wget.cpp)
 add_executable(atom_reader atom/atom.cpp atom/main.cpp)
+add_executable(rss_reader rss/rss.cpp rss/main.cpp)
 add_executable(hello_world_server http/hello_world_server.cpp)
 if (UNIX)
   add_executable(fileserver http/fileserver.cpp)
@@ -19,6 +20,7 @@ add_executable(uri uri.cpp)
 add_dependencies(http_client cppnetlib-uri cppnetlib-client-connections)
 add_dependencies(simple_wget cppnetlib-uri cppnetlib-client-connections)
 add_dependencies(atom_reader cppnetlib-uri cppnetlib-client-connections)
+add_dependencies(rss_reader cppnetlib-uri cppnetlib-client-connections)
 add_dependencies(uri cppnetlib-uri)
 set(BOOST_CLIENT_LIBS
     ${Boost_PROGRAM_OPTIONS_LIBRARY}
@@ -51,6 +53,12 @@ target_link_libraries(atom_reader
     cppnetlib-uri
     cppnetlib-client-connections)
 
+target_link_libraries(rss_reader
+    ${BOOST_CLIENT_LIBS}
+    ${CMAKE_THREAD_LIBS_INIT}
+    cppnetlib-uri
+    cppnetlib-client-connections)
+
 target_link_libraries(hello_world_server
     ${BOOST_SERVER_LIBS}
     ${CMAKE_THREAD_LIBS_INIT})
@@ -59,6 +67,7 @@ if (OPENSSL_FOUND)
   target_link_libraries(http_client ${OPENSSL_LIBRARIES})
   target_link_libraries(simple_wget ${OPENSSL_LIBRARIES})
   target_link_libraries(atom_reader ${OPENSSL_LIBRARIES})
+  target_link_libraries(rss_reader ${OPENSSL_LIBRARIES})
   target_link_libraries(hello_world_server ${OPENSSL_LIBRARIES})
 endif (OPENSSL_FOUND)
 
@@ -74,6 +83,7 @@ target_link_libraries(uri cppnetlib-uri)
 set_target_properties(http_client PROPERTIES RUNTIME_OUTPUT_DIRECTORY ${CPP-NETLIB_BINARY_DIR}/example)
 set_target_properties(simple_wget PROPERTIES RUNTIME_OUTPUT_DIRECTORY ${CPP-NETLIB_BINARY_DIR}/example)
 set_target_properties(atom_reader PROPERTIES RUNTIME_OUTPUT_DIRECTORY ${CPP-NETLIB_BINARY_DIR}/example)
+set_target_properties(rss_reader PROPERTIES RUNTIME_OUTPUT_DIRECTORY ${CPP-NETLIB_BINARY_DIR}/example)
 set_target_properties(hello_world_server PROPERTIES RUNTIME_OUTPUT_DIRECTORY ${CPP-NETLIB_BINARY_DIR}/example)
 if (UNIX)
   set_target_properties(fileserver PROPERTIES RUNTIME_OUTPUT_DIRECTORY ${CPP-NETLIB_BINARY_DIR}/example)
diff --git a/libs/network/example/rss/main.cpp b/libs/network/example/rss/main.cpp
@@ -0,0 +1,36 @@
+//            Copyright (c) Glyn Matthews 2011.
+// Distributed under the Boost Software License, Version 1.0.
+//    (See accompanying file LICENSE_1_0.txt or copy at
+//          http://www.boost.org/LICENSE_1_0.txt)
+
+
+#include "rss.hpp"
+#include <boost/network/protocol/http/client.hpp>
+#include <iostream>
+
+int main(int argc, char * argv[]) {
+    using namespace boost::network;
+
+    if (argc != 2) {
+        std::cout << "Usage: " << argv[0] << " <url>" << std::endl;
+        return 1;
+    }
+
+    try {
+        http::client client;
+        http::client::request request(argv[1]);
+        request << header("Connection", "close");
+        http::client::response response = client.get(request);
+        rss::channel channel(response);
+
+        std::cout << "Channel: " << channel.title() << " (" << channel.description() << ")" << std::endl;
+        BOOST_FOREACH(const rss::item &item, channel) {
+            std::cout << item.title() << " (" << item.author() << ")" << std::endl;
+        }
+    }
+    catch (std::exception &e) {
+        std::cerr << e.what() << std::endl;
+    }
+
+    return 0;
+}
diff --git a/libs/network/example/rss/rss.cpp b/libs/network/example/rss/rss.cpp
@@ -0,0 +1,75 @@
+//            Copyright (c) Glyn Matthews 2011.
+// Distributed under the Boost Software License, Version 1.0.
+//    (See accompanying file LICENSE_1_0.txt or copy at
+//          http://www.boost.org/LICENSE_1_0.txt)
+
+
+#include "rss.hpp"
+#include "../rapidxml/rapidxml.hpp"
+#include <stdexcept>
+#include <cassert>
+
+
+namespace boost {
+namespace network {
+namespace rss {
+channel::channel(const http::client::response &response) {
+	std::string response_body = body(response);
+    rapidxml::xml_document<> doc;
+	doc.parse<0>(const_cast<char *>(response_body.c_str()));
+
+    rapidxml::xml_node<> *rss = doc.first_node("rss");
+    if (!rss) {
+        throw std::runtime_error("Invalid RSS feed.");
+    }
+
+    rapidxml::xml_node<> *channel = rss->first_node("channel");
+    if (!channel) {
+        throw std::runtime_error("Invalid RSS channel.");
+    }
+
+    rapidxml::xml_node<> *title = channel->first_node("title");
+    if (title) {
+        title_ = title->first_node()->value();
+    }
+
+    rapidxml::xml_node<> *description = channel->first_node("description");
+    if (description) {
+        description_ = description->first_node()->value();
+    }
+
+    rapidxml::xml_node<> *link = channel->first_node("link");
+    if (link) {
+        link_ = link->first_node()->value();
+    }
+
+    rapidxml::xml_node<> *author = channel->first_node("author");
+    if (author) {
+        author_ = author->first_node()->value();
+    }
+
+    rapidxml::xml_node<> *item = channel->first_node("item");
+    while (item) {
+        items_.push_back(rss::item());
+
+        rapidxml::xml_node<> *title = item->first_node("title");
+        if (title) {
+            items_.back().set_title(title->first_node()->value());
+        }
+
+        rapidxml::xml_node<> *author = item->first_node("author");
+        if (author) {
+            items_.back().set_author(author->first_node()->value());
+        }
+
+        rapidxml::xml_node<> *description = item->first_node("description");
+        if (description) {
+            items_.back().set_description(description->first_node()->value());
+        }
+
+		item = item->next_sibling();
+    }
+}
+} // namespace rss
+} // namespace network
+} // namespace boost
diff --git a/libs/network/example/rss/rss.hpp b/libs/network/example/rss/rss.hpp
@@ -0,0 +1,112 @@
+//            Copyright (c) Glyn Matthews 2011.
+// Distributed under the Boost Software License, Version 1.0.
+//    (See accompanying file LICENSE_1_0.txt or copy at
+//          http://www.boost.org/LICENSE_1_0.txt)
+
+#ifndef ___RSS_INC__
+# define ___RSS_INC__
+
+
+# include <string>
+# include <vector>
+# include <boost/network/protocol/http.hpp>
+
+
+namespace boost {
+namespace network {
+namespace rss {
+class item {
+
+public:
+
+    void set_title(const std::string &title) {
+        title_ = title;
+    }
+
+    std::string title() const {
+        return title_;
+    }
+
+    void set_author(const std::string &author) {
+        author_ = author;
+    }
+
+    std::string author() const {
+        return author_;
+    }
+
+    void set_description(const std::string &description) {
+        description_ = description;
+    }
+
+    std::string description() const {
+        return description_;
+    }
+
+private:
+
+    std::string title_;
+    std::string author_;
+    std::string description_;
+
+};
+
+class channel {
+
+public:
+    typedef item value_type;
+    typedef std::vector<item>::iterator iterator;
+    typedef std::vector<item>::const_iterator const_iterator;
+
+    channel(const http::client::response &response);
+
+    std::string title() const {
+        return title_;
+    }
+
+    std::string description() const {
+        return description_;
+    }
+
+    std::string link() const {
+        return link_;
+    }
+
+    std::string author() const {
+        return author_;
+    }
+
+    unsigned int item_count() const {
+        return items_.size();
+    }
+
+    iterator begin() {
+        return items_.begin();
+    }
+
+    iterator end() {
+        return items_.end();
+    }
+
+    const_iterator begin() const {
+        return items_.begin();
+    }
+
+    const_iterator end() const {
+        return items_.end();
+    }
+
+private:
+
+    std::string title_;
+    std::string description_;
+    std::string link_;
+    std::string author_;
+    std::vector<item> items_;
+
+};
+} // namespace rss
+} // namespace network
+} // namespace boost
+
+#endif // ___RSS_INC__
