diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..ee14794 --- /dev/null +++ b/.gitignore @@ -0,0 +1,2 @@ +server/node_modules +server/db diff --git a/init.lua b/init.lua index 21e9478..97c6ebc 100644 --- a/init.lua +++ b/init.lua @@ -8,9 +8,9 @@ minetest.register_node("connected:iotswitch", { groups = {snappy=1,choppy=2,oddly_breakable_by_hand=2,flammable=3}, on_rightclick = function (pos, node) print("punch") - minetest.after(5, function() + minetest.after(1, function() http_api.fetch({ - url = "http://localhost:3000/resources/feedsonoff", + url = "http://localhost:8088/punch", timeout = 1 }, function (res) diff --git a/server/package.json b/server/package.json new file mode 100644 index 0000000..36e2664 --- /dev/null +++ b/server/package.json @@ -0,0 +1,9 @@ +{ + "name": "connectedJS", + "version": "0.1.0", + "dependencies": { + "express": "^4.14.0", + "mqtt": "^2.0.1", + "ponte": "~0.0.16" + } +} diff --git a/server/server.js b/server/server.js new file mode 100644 index 0000000..e05ebf0 --- /dev/null +++ b/server/server.js @@ -0,0 +1,38 @@ +var mosca = require('mosca') + +var moscaSettings = { + port: 1883 +}; + +var server = new mosca.Server(moscaSettings); +server.on('ready', setup); + +server.on('clientConnected', function(client) { + console.log('client connected', client.id); +}); + +// fired when a message is received +server.on('published', function(packet, client) { + console.log('Published', packet.payload); +}); + +// fired when the mqtt server is ready +function setup() { + console.log('Mosca server is up and running') +} + +var mqtt = require('mqtt') +//var client = mqtt.connect() +var client = mqtt.connect({ port: 1883, host: '127.0.0.1', keepalive: 10000}); + +var express = require('express'); +var app = express(); + +app.get('/punch', function (req, res) { + res.send('Punch!!!'); + client.publish('punch', 'message root punch') +}); + +app.listen(8088, function () { + console.log('Example app listening on port 8088!'); +});