Changeset 43f521291669f483d361949fa6c886c0fbd94daf for http/threads.cc

Timestamp:

08/26/10 20:21:08 (21 months ago)

Author:

Antti-Juhani Kaijanaho <antti-juhani@…>

Children:

6c86e7ccc32f1c99d204262844a52b1b06359145

Parents:

7ccc366e52cc1e51e123b39fccaf56267361ca58

git-committer:

Antti-Juhani Kaijanaho <antti-juhani@…> (08/26/10 20:21:08)

Message:

Add support for paginating thread and article lists.

Signed-off-by: Antti-Juhani Kaijanaho <antti-juhani@…>

Files:

• http/threads.cc (modified) (2 diffs)

http/threads.cc

@@ -94 +94 @@
                 else
                 {
+                        std::string f = req->get_form_field("s");
+                        size_t start = util::is_number(f)
+                                ? util::parse_nonnegative_integer<size_t>(f)
+                                : 0;
+                        f = req->get_form_field("n");
+                        size_t length = util::is_number(f)
+                                ? util::parse_nonnegative_integer<size_t>(f)
+                                : 10;
+
                         tlate::list_value::ptr tl(new tlate::list_value);
                         std::list<db::thread_node::ptr> thrs 
@@ -100 +109 @@
                         thrs.sort(db::thread_node::cmp_latest_date_rev);
 
+                        size_t cur = 0;
+                        bool more = false;
                         for (std::list<db::thread_node::ptr>::const_iterator
                                      it = thrs.begin();
                              it != thrs.end(); it++)
                         {
-                                tl->push_back(tlate::msg_value::mk(*it, u));
+                                cur++;
+                                if (cur >= start + length)
+                                {
+                                        more = true;
+                                        break;
+                                }
+                                if (cur > start)
+                                        tl->push_back
+                                                (tlate::msg_value::mk(*it, u));
                         }
                         am->insert("threads", tl);
+
+                        tlate::data_model::ptr pg(new tlate::data_model);
+                        pg->insert("first", start);
+                        pg->insert("last", cur - 1);
+                        pg->insert("size", cur - start);
+                        pg->insert("max_size", length);
+
+                        if (more)
+                        {
+                                ::uri u = req->get_uri();
+                                u.replace_query_param("s", start + length);
+                                u.replace_query_param("n", length);
+                                pg->insert("next", u.to_string());
+                        }
+                        
+                        if (start > 0)
+                        {
+                                ::uri u = req->get_uri();
+                                u.replace_query_param("s",
+                                                      start > length
+                                                      ? start - length
+                                                      : 0);
+                                u.replace_query_param("n", length);
+                                pg->insert("prev", u.to_string());
+                        }
+                        am->insert("page", pg);
                 }
         }