add peer-to-peer file sharing plugin ZSync

frontend/ui/message/messagequeue.lua

@@ -0,0 +1,85 @@
+local ffi = require("ffi")
+local util = require("ffi/util")
+local Event = require("ui/event")
+local DEBUG = require("dbg")
+
+local dummy = require("ffi/zeromq_h")
+local czmq = ffi.load("libs/libczmq.so.1")
+local zyre = ffi.load("libs/libzyre.so.1")
+
+local MessageQueue = {}
+
+function MessageQueue:new(o)
+    o = o or {}
+    setmetatable(o, self)
+    self.__index = self
+    if o.init then o:init() end
+    self.messages = {}
+    return o
+end
+
+function MessageQueue:init()
+end
+
+function MessageQueue:start()
+end
+
+function MessageQueue:stop()
+end
+
+function MessageQueue:waitEvent()
+end
+
+function MessageQueue:handleZMsgs(messages)
+    local function drop_message()
+        if czmq.zmsg_size(messages[1]) == 0 then
+            czmq.zmsg_destroy(ffi.new('zmsg_t *[1]', messages[1]))
+            table.remove(messages, 1)
+        end
+    end
+    local function pop_string()
+        local str_p = czmq.zmsg_popstr(messages[1])
+        local message_size = czmq.zmsg_size(messages[1])
+        local res = ffi.string(str_p)
+        czmq.zstr_free(ffi.new('char *[1]', str_p))
+        drop_message()
+        return res
+    end
+    local function pop_header()
+        local header = {}
+        local frame = czmq.zmsg_pop(messages[1])
+        if frame ~= nil then
+            local hash = czmq.zhash_unpack(frame)
+            czmq.zframe_destroy(ffi.new('zframe_t *[1]', frame))
+            if hash ~= nil then
+                local value, key = czmq.zhash_first(hash), czmq.zhash_cursor(hash)
+                while value ~= nil and key ~= nil do
+                    header[ffi.string(key)] = ffi.string(value)
+                    value, key = czmq.zhash_next(hash), czmq.zhash_cursor(hash)
+                end
+                czmq.zhash_destroy(ffi.new('zhash_t *[1]', hash))
+            end
+        end
+        drop_message()
+        return header
+    end
+    if #messages == 0 then return end
+    local message_size = czmq.zmsg_size(messages[1])
+    local command = pop_string()
+    DEBUG("ØMQ message", command)
+    if command == "ENTER" and #messages >= 4 then
+        local id = pop_string()
+        local name = pop_string()
+        local header = pop_header()
+        local endpoint = pop_string()
+        --DEBUG(id, name, header, endpoint)
+        return Event:new("ZyreEnter", id, name, header, endpoint)
+    elseif command == "DELIVER" then
+        local filename = pop_string()
+        local fullname = pop_string()
+        --DEBUG("received", filename)
+        return Event:new("FileDeliver", filename, fullname)
+    end
+end
+
+return MessageQueue