ChanViewer: Start working on a simple read-only 4Chan viewer

Since they are nice enough to provide a JSON API over HTTP, this makes
for a perfect way to exercise our networking code a bit. :^)

4 files changed, 174 insertions, 0 deletions

diff --git a/Applications/ChanViewer/Makefile b/Applications/ChanViewer/Makefile
new file mode 100755
index 0000000000..65d01b6065
--- /dev/null
+++ b/Applications/ChanViewer/Makefile
@@ -0,0 +1,9 @@
+include ../../Makefile.common
+
+OBJS = \
+    ThreadCatalogModel.o \
+    main.o
+
+APP = ChanViewer
+
+include ../Makefile.common
diff --git a/Applications/ChanViewer/ThreadCatalogModel.cpp b/Applications/ChanViewer/ThreadCatalogModel.cpp
new file mode 100644
index 0000000000..5d3334507b
--- /dev/null
+++ b/Applications/ChanViewer/ThreadCatalogModel.cpp
@@ -0,0 +1,110 @@
+#include "ThreadCatalogModel.h"
+#include <AK/JsonArray.h>
+#include <AK/JsonObject.h>
+#include <AK/JsonValue.h>
+#include <LibCore/CHttpRequest.h>
+#include <LibCore/CNetworkJob.h>
+#include <LibCore/CNetworkResponse.h>
+#include <stdio.h>
+
+ThreadCatalogModel::ThreadCatalogModel()
+{
+    update();
+}
+
+ThreadCatalogModel::~ThreadCatalogModel()
+{
+}
+
+void ThreadCatalogModel::update()
+{
+    CHttpRequest request;
+    request.set_hostname("a.4cdn.org");
+    request.set_path("/g/catalog.json");
+
+    auto* job = request.schedule();
+
+    job->on_finish = [job, this](bool success) {
+        auto* response = job->response();
+        dbg() << "job finished! success=" << success << ", response=" << response;
+        dbg() << "payload size: " << response->payload().size();
+
+        auto json = JsonValue::from_string(response->payload());
+
+        if (json.is_array()) {
+            JsonArray new_catalog;
+
+            for (auto& page : json.as_array().values()) {
+                if (!page.is_object())
+                    continue;
+                auto threads_value = page.as_object().get("threads");
+                if (!threads_value.is_array())
+                    continue;
+                for (auto& thread : threads_value.as_array().values()) {
+                    new_catalog.append(thread);
+                }
+            }
+
+            m_catalog = move(new_catalog);
+        }
+
+        did_update();
+    };
+}
+
+int ThreadCatalogModel::row_count(const GModelIndex&) const
+{
+    return m_catalog.size();
+}
+
+String ThreadCatalogModel::column_name(int column) const
+{
+    switch (column) {
+    case Column::ThreadNumber:
+        return "#";
+    case Column::Text:
+        return "Text";
+    case Column::ReplyCount:
+        return "Replies";
+    case Column::ImageCount:
+        return "Images";
+    default:
+        ASSERT_NOT_REACHED();
+    }
+}
+
+GModel::ColumnMetadata ThreadCatalogModel::column_metadata(int column) const
+{
+    switch (column) {
+    case Column::ThreadNumber:
+        return { 70, TextAlignment::CenterRight };
+    case Column::Text:
+        return { 200, TextAlignment::CenterLeft };
+    case Column::ReplyCount:
+        return { 45, TextAlignment::CenterRight };
+    case Column::ImageCount:
+        return { 40, TextAlignment::CenterRight };
+    default:
+        ASSERT_NOT_REACHED();
+    }
+}
+
+GVariant ThreadCatalogModel::data(const GModelIndex& index, Role role) const
+{
+    auto& thread = m_catalog.at(index.row()).as_object();
+    if (role == Role::Display) {
+        switch (index.column()) {
+        case Column::ThreadNumber:
+            return thread.get("no").to_u32();
+        case Column::Text:
+            return thread.get("com").to_string();
+        case Column::ReplyCount:
+            return thread.get("replies").to_u32();
+        case Column::ImageCount:
+            return thread.get("images").to_u32();
+        default:
+            ASSERT_NOT_REACHED();
+        }
+    }
+    return {};
+}
diff --git a/Applications/ChanViewer/ThreadCatalogModel.h b/Applications/ChanViewer/ThreadCatalogModel.h
new file mode 100644
index 0000000000..ce1e30fbeb
--- /dev/null
+++ b/Applications/ChanViewer/ThreadCatalogModel.h
@@ -0,0 +1,30 @@
+#pragma once
+
+#include <AK/JsonArray.h>
+#include <LibGUI/GModel.h>
+
+class ThreadCatalogModel final : public GModel {
+public:
+    enum Column {
+        ThreadNumber,
+        Text,
+        ReplyCount,
+        ImageCount,
+        __Count,
+    };
+
+    static NonnullRefPtr<ThreadCatalogModel> create() { return adopt(*new ThreadCatalogModel); }
+    virtual ~ThreadCatalogModel() override;
+
+    virtual int row_count(const GModelIndex& = GModelIndex()) const override;
+    virtual int column_count(const GModelIndex& = GModelIndex()) const override { return Column::__Count; }
+    virtual String column_name(int) const override;
+    virtual ColumnMetadata column_metadata(int) const override;
+    virtual GVariant data(const GModelIndex&, Role = Role::Display) const override;
+    virtual void update() override;
+
+private:
+    ThreadCatalogModel();
+
+    JsonArray m_catalog;
+};
diff --git a/Applications/ChanViewer/main.cpp b/Applications/ChanViewer/main.cpp
new file mode 100644
index 0000000000..917df59be0
--- /dev/null
+++ b/Applications/ChanViewer/main.cpp
@@ -0,0 +1,25 @@
+#include "ThreadCatalogModel.h"
+#include <LibGUI/GApplication.h>
+#include <LibGUI/GBoxLayout.h>
+#include <LibGUI/GTableView.h>
+#include <LibGUI/GWindow.h>
+
+int main(int argc, char** argv)
+{
+    GApplication app(argc, argv);
+
+    auto* window = new GWindow;
+    window->set_title("ChanViewer");
+    window->set_rect(100, 100, 640, 480);
+
+    auto* widget = new GWidget;
+    window->set_main_widget(widget);
+    widget->set_layout(make<GBoxLayout>(Orientation::Vertical));
+
+    auto* catalog_view = new GTableView(widget);
+    catalog_view->set_model(ThreadCatalogModel::create());
+
+    window->show();
+
+    return app.exec();
+}