Version: 0.0 2011-07-28

Author: Andy Gelme

.gitignore

@@ -0,0 +1 @@
+readme.html

images/aiko_gateway.jpg

@@ -0,0 +1,66 @@
+#!/usr/bin/lua
+-- ------------------------------------------------------------------------- --
+-- example_00.lua
+-- ~~~~~~~~~~~~~~
+-- Please do not remove the following notices.
+-- Copyright (c) 2011 by Geekscape Pty. Ltd.
+-- Documentation: http://http://geekscape.github.com/lua_mqtt_client
+-- License: GPLv3 http://geekscape.org/static/aiko_license.html
+-- Version: 0.0
+--
+-- Description
+-- ~~~~~~~~~~~
+-- Subscribe to a topic and publish all received messages on another topic.
+--
+-- ToDo
+-- ~~~~
+-- - On failure, automatically reconnect to MQTT server.
+-- ------------------------------------------------------------------------- --
+
+function callback(
+  topic,    -- string
+  message)  -- string
+
+  print("Topic: " .. topic .. ", message: '" .. message .. "'")
+
+  mqtt_client:publish(args.topic2, message)
+end
+
+-- ------------------------------------------------------------------------- --
+
+function is_openwrt()
+  return(os.getenv("USER") == "root")  -- Assume logged in as "root" on OpenWRT
+end
+
+-- ------------------------------------------------------------------------- --
+
+if (not is_openwrt()) then require("luarocks.require") end
+require("lapp")
+
+args = lapp [[
+  Subscribe to topic1 and publish all messages on topic2
+  -h,--host    (default localhost)   MQTT server hostname
+  -i,--id      (default example_00)  MQTT client identifier
+  -p,--port    (default 1883)        MQTT server port number
+  -s,--topic1  (default test/1)      Subscribe topic
+  -t,--topic2  (default test/2)      Publish topic
+]]
+
+local MQTT = require("mqtt_library")
+
+mqtt_client = MQTT.client.create(args.host, args.port, callback)
+
+mqtt_client:connect(args.id)
+
+mqtt_client:subscribe({ args.topic1 })
+
+while (true) do
+  mqtt_client:handler()
+  socket.sleep(1.0)  -- seconds
+end
+
+mqtt_client:unsubscribe({ args.topic1 })
+
+mqtt_client:destroy()
+
+-- ------------------------------------------------------------------------- --

images/lua_mqtt_overview.dia

@@ -0,0 +1,73 @@
+#!/usr/bin/lua
+-- ------------------------------------------------------------------------- --
+-- example_01.lua
+-- ~~~~~~~~~~~~~~
+-- Please do not remove the following notices.
+-- Copyright (c) 2011 by Geekscape Pty. Ltd.
+-- Documentation: http://http://geekscape.github.com/lua_mqtt_client
+-- License: GPLv3 http://geekscape.org/static/aiko_license.html
+-- Version: 0.0
+--
+-- Description
+-- ~~~~~~~~~~~
+-- Subscribe to a topic on one MQTT server and publish all received messages
+-- to a topic on another MQTT server.
+--
+-- ToDo
+-- ~~~~
+-- - On failure, automatically reconnect to MQTT server(s).
+-- ------------------------------------------------------------------------- --
+
+function callback(
+  topic,    -- string
+  message)  -- string
+
+  print("Topic: " .. topic .. ", message: '" .. message .. "'")
+
+  mqtt_client2:publish(args.topic2, message)
+end
+
+-- ------------------------------------------------------------------------- --
+
+function is_openwrt()
+  return(os.getenv("USER") == "root")  -- Assume logged in as "root" on OpenWRT
+end
+
+-- ------------------------------------------------------------------------- --
+
+if (not is_openwrt()) then require("luarocks.require") end
+require("lapp")
+
+args = lapp [[
+  Subscribe to topic1 and publish all messages on topic2
+  -g,--host1   (default localhost)   Subscribe MQTT server hostname
+  -h,--host2   (default localhost)   Publish MQTT server hostname
+  -i,--id      (default example_01)  MQTT client identifier
+  -p,--port1   (default 1883)        Subscribe MQTT server port number
+  -q,--port2   (default 1883)        Publish MQTT server port number
+  -s,--topic1  (default test/1)      Subscribe topic
+  -t,--topic2  (default test/2)      Publish topic
+]]
+
+local MQTT = require("mqtt_library")
+
+mqtt_client1 = MQTT.client.create(args.host1, args.port1, callback)
+mqtt_client2 = MQTT.client.create(args.host2, args.port2)
+
+mqtt_client1:connect(args.id .. "a")
+mqtt_client2:connect(args.id .. "b")
+
+mqtt_client1:subscribe({ args.topic1 })
+
+while (true) do
+  mqtt_client1:handler()
+  mqtt_client2:handler()
+  socket.sleep(1.0)  -- seconds
+end
+
+mqtt_client1:unsubscribe({ args.topic1 })
+
+mqtt_client1:destroy()
+mqtt_client2:destroy()
+
+-- ------------------------------------------------------------------------- --

images/lua_mqtt_overview.jpg

@@ -0,0 +1,61 @@
+#!/usr/bin/lua
+-- ------------------------------------------------------------------------- --
+-- example_02.lua
+-- ~~~~~~~~~~~~~~
+-- Please do not remove the following notices.
+-- Copyright (c) 2011 by Geekscape Pty. Ltd.
+-- Documentation: http://http://geekscape.github.com/lua_mqtt_client
+-- License: GPLv3 http://geekscape.org/static/aiko_license.html
+-- Version: 0.0
+--
+-- Description
+-- ~~~~~~~~~~~
+-- Publish a sequence of messages to a specified topic.
+-- Used to control some coloured RGB LEDs.
+--
+-- ToDo
+-- ~~~~
+-- - On failure, automatically reconnect to MQTT server.
+-- ------------------------------------------------------------------------- --
+
+function is_openwrt()
+  return(os.getenv("USER") == "root")  -- Assume logged in as "root" on OpenWRT
+end
+
+-- ------------------------------------------------------------------------- --
+
+if (not is_openwrt()) then require("luarocks.require") end
+require("lapp")
+
+local args = lapp [[
+  Subscribe to topic1 and publish all messages on topic2
+  -h,--host   (default localhost)   MQTT server hostname
+  -i,--id     (default example_02)  MQTT client identifier
+  -p,--port   (default 1883)        MQTT server port number
+  -s,--sleep  (default 5.0)         Sleep time between commands
+  -t,--topic  (default test/2)      Topic on which to publish
+]]
+
+local MQTT = require("mqtt_library")
+
+local mqtt_client = MQTT.client.create(args.host, args.port)
+
+mqtt_client:connect(args.id)
+
+local index = 1
+local messages = { "c010000", "c000100", "c000001" }
+
+while (true) do
+  mqtt_client:handler()
+  socket.sleep(0.1)  -- seconds
+
+  socket.sleep(args.sleep)  -- seconds
+  mqtt_client:publish(args.topic, messages[index]);
+
+  index = index + 1
+  if (index > #messages) then index = 1 end
+end
+
+mqtt_client:destroy()
+
+-- ------------------------------------------------------------------------- --