libresapi: added channels/create_post

group creation acknowledge not implemented yet

usage:
$ curl --data "{\"group_id\":\"<group_id>\",\"subject\":\"just a test\",\"message\":\"test message\"}" http://<host:port>/api/v2/channels/create_post

parameter object:
{
    group_id: required string,
    subject: required string,
    message: required string,
    thumbnail_base64_png: optional string,
    files: optional array of
        {
            name: required string,
            hash: required string,
            size: required number
        }
}

libresapi/src/api/ApiServer.cpp

@@ -14,6 +14,7 @@
 #include "StateTokenServer.h" // for the state token serialisers
 
 #include "ApiPluginHandler.h"
+#include "ChannelsHandler.h"
 
 /*
 data types in json       http://json.org/
@@ -232,7 +233,8 @@ public:
         mFileSearchHandler(sts, ifaces.mNotify, ifaces.mTurtle, ifaces.mFiles),
         mTransfersHandler(sts, ifaces.mFiles),
         mChatHandler(sts, ifaces.mNotify, ifaces.mMsgs, ifaces.mPeers, ifaces.mIdentity, &mPeersHandler),
-        mApiPluginHandler(sts, ifaces)
+        mApiPluginHandler(sts, ifaces),
+        mChannelsHandler(ifaces.mGxsChannels)
     {
         // the dynamic cast is to not confuse the addResourceHandler template like this:
         // addResourceHandler(derived class, parent class)
@@ -254,6 +256,8 @@ public:
                                   &ChatHandler::handleRequest);
         router.addResourceHandler("apiplugin", dynamic_cast<ResourceRouter*>(&mApiPluginHandler),
                                   &ChatHandler::handleRequest);
+        router.addResourceHandler("channels", dynamic_cast<ResourceRouter*>(&mChannelsHandler),
+                                  &ChannelsHandler::handleRequest);
     }
 
     PeersHandler mPeersHandler;
@@ -264,6 +268,7 @@ public:
     TransfersHandler mTransfersHandler;
     ChatHandler mChatHandler;
     ApiPluginHandler mApiPluginHandler;
+    ChannelsHandler mChannelsHandler;
 };
 
 ApiServer::ApiServer():

libresapi/src/api/ChannelsHandler.cpp

@@ -0,0 +1,112 @@
+#include "ChannelsHandler.h"
+
+#include <retroshare/rsgxschannels.h>
+#include <util/radix64.h>
+#include <algorithm>
+#include "Operators.h"
+
+namespace resource_api
+{
+
+StreamBase& operator << (StreamBase& left, RsGxsFile& file)
+{
+    left << makeKeyValueReference("name", file.mName)
+         << makeKeyValueReference("hash", file.mHash);
+    if(left.serialise())
+    {
+        double size = file.mSize;
+        left << makeKeyValueReference("size", size);
+    }
+    else
+    {
+        double size = 0;
+        left << makeKeyValueReference("size", size);
+        file.mSize = size;
+    }
+    return left;
+}
+
+ChannelsHandler::ChannelsHandler(RsGxsChannels *channels):
+    mChannels(channels)
+{
+    addResourceHandler("create_post", this, &ChannelsHandler::handleCreatePost);
+}
+
+ResponseTask* ChannelsHandler::handleCreatePost(Request &req, Response &resp)
+{
+    RsGxsChannelPost post;
+
+    req.mStream << makeKeyValueReference("group_id", post.mMeta.mGroupId);
+    req.mStream << makeKeyValueReference("subject", post.mMeta.mMsgName);
+    req.mStream << makeKeyValueReference("message", post.mMsg);
+
+    StreamBase& file_array = req.mStream.getStreamToMember("files");
+    while(file_array.hasMore())
+    {
+        RsGxsFile file;
+        file_array.getStreamToMember() << file;
+        post.mFiles.push_back(file);
+    }
+
+    std::string thumbnail_base64;
+    req.mStream << makeKeyValueReference("thumbnail_base64_png", thumbnail_base64);
+
+    if(post.mMeta.mGroupId.isNull())
+    {
+        resp.setFail("groupd_id is null");
+        return 0;
+    }
+    if(post.mMeta.mMsgName.empty())
+    {
+        resp.setFail("subject is empty");
+        return 0;
+    }
+    if(post.mMsg.empty())
+    {
+        resp.setFail("msg text is empty");
+        return 0;
+    }
+    // empty file list is ok, but files have to be valid
+    for(std::list<RsGxsFile>::iterator lit = post.mFiles.begin(); lit != post.mFiles.end(); ++lit)
+    {
+        if(lit->mHash.isNull())
+        {
+            resp.setFail("at least one file hash is empty");
+            return 0;
+        }
+        if(lit->mName.empty())
+        {
+            resp.setFail("at leats one file name is empty");
+            return 0;
+        }
+        if(lit->mSize == 0)
+        {
+            resp.setFail("at least one file size is empty");
+            return 0;
+        }
+    }
+
+    std::vector<uint8_t> png_data = Radix64::decode(thumbnail_base64);
+    if(!png_data.empty())
+    {
+        if(png_data.size() < 8)
+        {
+            resp.setFail("Decoded thumbnail_base64_png is smaller than 8 byte. This can't be a valid png file!");
+            return 0;
+        }
+        uint8_t png_magic_number[] = {0x89, 0x50, 0x4e, 0x47, 0x0d, 0x0a, 0x1a, 0x0a};
+        if(!std::equal(&png_magic_number[0],&png_magic_number[8],png_data.begin()))
+        {
+            resp.setFail("Decoded thumbnail_base64_png does not seem to be a png file. (Header is missing magic number)");
+            return 0;
+        }
+        post.mThumbnail.copy(png_data.data(), png_data.size());
+    }
+
+    uint32_t token;
+    mChannels->createPost(token, post);
+    // TODO: grp creation acknowledge
+    return 0;
+}
+
+} // namespace resource_api

libresapi/src/api/ChannelsHandler.h

@@ -0,0 +1,21 @@
+#pragma once
+
+#include "ResourceRouter.h"
+
+class RsGxsChannels;
+
+namespace resource_api
+{
+
+class ChannelsHandler : public ResourceRouter
+{
+public:
+    ChannelsHandler(RsGxsChannels* channels);
+
+private:
+    ResponseTask* handleCreatePost(Request& req, Response& resp);
+
+    RsGxsChannels* mChannels;
+};
+
+} // namespace resource_api

libresapi/src/libresapi.pro

@@ -66,7 +66,8 @@ SOURCES += \
     api/LivereloadHandler.cpp \
     api/TmpBlobStore.cpp \
     util/ContentTypes.cpp \
-    api/ApiPluginHandler.cpp
+    api/ApiPluginHandler.cpp \
+    api/ChannelsHandler.cpp
 
 HEADERS += \
 	api/ApiServer.h \
@@ -91,4 +92,5 @@ HEADERS += \
     api/LivereloadHandler.h \
     api/TmpBlobStore.h \
     util/ContentTypes.h \
-    api/ApiPluginHandler.h
+    api/ApiPluginHandler.h \
+    api/ChannelsHandler.h