\nUsage: mqtt-scripts [options]\n\nOptions:\n  --version                Show version number                         [boolean]\n  -c, --config             Path to JSON config file\n  -d, --dir                directory to scan for .js and .coffee files. can be\n                           used multiple times.\n  -h, --help               Show help                                   [boolean]\n  -s, --variable-prefix    topic prefix for $ substitution (shorthand for\n                           variables, see docs)                 [default: \"var\"]\n  -t, --disable-variables  disable variable feedback (see docs) [default: false]\n  -n, --name               instance name. used as mqtt client id and as prefix\n                           for connected topic                [default: \"logic\"]\n  -u, --url                mqtt broker url. See\n                           https://github.com/mqttjs/MQTT.js#connect-using-a-url\n                                                   [default: \"mqtt://127.0.0.1\"]\n  -v, --verbosity          possible values: \"error\", \"warn\", \"info\", \"debug\"\n                                                               [default: \"info\"]\n  -w, --disable-watch      disable file watching (don't exit process on file\n                           changes)                             [default: false]\n  --disable-lwt            disable last-will-and-testament (usefull if the\n                           remote broker is read-only)          [default: false]\n  -l, --latitude                                              [default: 48.7408]\n  -m, --longitude                                              [default: 9.1778]                                            \n

\n\nIf you're running multiple instances of mqtt-scripts you have to decide which one should handle variables and disable \nthe variables on all other instances with the --disable-variable option.\n\n\n# Script Examples\n\n#### Use hm2mqtt and hue2mqtt to control a hue lamp with a homematic remote control\n\n```javascript\nlink('hm//RC4:1/PRESS_CONT', 'hue//lights/Hobbyraum/bri_inc', -16);\n\nsubscribe('hm//RC4:2/PRESS_CONT', function () {\n if (!getValue('hue//lights/Hobbyraum')) {\n setValue('hue//lights/Hobbyraum', 1);\n } else {\n setValue('hue//lights/Hobbyraum/bri_inc', 16);\n }\n});\n\nlink('hm//RC4:1/PRESS_SHORT', 'hue//lights/Hobbyraum', 0);\nlink('hm//RC4:2/PRESS_SHORT', 'hue//lights/Hobbyraum', 254);\nlink('hm//RC4:3/PRESS_CONT', 'hue//lights/Hobbyraum/ct_inc', -16);\nlink('hm//RC4:4/PRESS_CONT', 'hue//lights/Hobbyraum/ct_inc', 16);\nlink('hm//RC4:3/PRESS_SHORT', 'hue//lights/Hobbyraum/ct', 153);\nlink('hm//RC4:4/PRESS_SHORT', 'hue//lights/Hobbyraum/ct', 500);\n```\n\n#### retrieve fuel prices from tankerkoenig\n\n```javascript\nvar request = require('request');\nvar cred = require('./lib/credentials.js');\n\nvar url = 'https://creativecommons.tankerkoenig.de/json/detail.php';\n\nvar tankstellen = {\n 'OMV': 'cb1f0588-d517-40f0-8ce3-3edadebea40d',\n 'Shell': '4267c196-eea1-47be-96b7-d790b2fbd17a'\n};\n\nschedule('0/12 * * * *', function () {\n for (var topic in tankstellen) {\n getData(topic, tankstellen[topic]);\n }\n});\n\nfunction getData(topic, id) {\n request.get(url + '?id=' + id + '&apikey=' + cred.tankerkoenig.apikey, function (err, res) {\n if (err) {\n log.error(err);\n return;\n }\n var data = JSON.parse(res.body).station;\n setValue('$Tankstelle/' + topic + '/Diesel', data.diesel);\n setValue('$Tankstelle/' + topic + '/E5', data.e5);\n setValue('$Tankstelle/' + topic + '/Offen', data.isOpen);\n });\n}\n```\n\n#### Send a variables state changes to Pushover\n\n```Javascript\nvar cred = require('./lib/credentials.js');\n\nvar pushoverNotifications = require('pushover-notifications');\n\nvar push = new pushoverNotifications( {\n user: cred.pushover.user,\n token: cred.pushover.token,\n onerror: function (error) {\n log.error(error);\n }\n});\n\nfunction pushover(msg) {\n if (typeof msg !== 'object' || typeof msg.message !== 'string') msg = {message: '' + msg};\n msg.title = msg.title || \"Smart Home\";\n msg.priority = msg.priority || 0;\n msg.device = msg.device || 'iphone5';\n push.send(msg, function(err, result) {\n if (err) {\n log.error(err);\n }\n });\n}\n\nsubscribe('$Anwesenheit', {change: true}, function () {\n pushover({\n title:'Anwesenheit',\n message: getProp($Anwesenheit, 'logic_textual'),\n priority: -1\n });\n});\n```\n\n# API\n\n## Classes\n\n

log: Log to stdout/stderr. Messages are prefixed with a timestamp and the calling scripts path.
\n

\n\n## Functions\n\n

subscribe(topic, [options], callback): Subscribe to MQTT topic(s)
\n
schedule(pattern, [options], callback): Schedule recurring and one-shot events
\n
sunSchedule(pattern, [options], callback): Schedule a recurring event based on sun position
\n
publish(topic, payload, [options]): Publish a MQTT message
\n
setValue(topic, val): Set a value on one or more topics
\n
getValue(topic) ⇒ mixed
getProp(topic, [...property]) ⇒ mixed: Get a specific property of a topic
\n
now() ⇒ number
age(topic) ⇒ number
link(source, target, [value]): Link topic(s) to other topic(s)
\n
combineBool(srcs, targets): Combine topics through boolean or
\n
combineMax(srcs, targets): Publish maximum of combined topics
\n
timer(src, target, time): Publishes 1 on target for specific time after src changed to true
\n

\n\n## Typedefs\n\n

subscribeCallback : function

\n\n\n\n## log\nLog to stdout/stderr. Messages are prefixed with a timestamp and the calling scripts path.\n\n**Kind**: global class \n\n* [log](#log)\n * [.debug()](#log.debug)\n * [.info()](#log.info)\n * [.warn()](#log.warn)\n * [.error()](#log.error)\n\n\n\n### log.debug()\nLog a debug message\n\n**Kind**: static method of [log](#log) \n\n| Type |\n| --- |\n| \\* | \n\n\n\n### log.info()\nLog an info message\n\n**Kind**: static method of [log](#log) \n\n| Type |\n| --- |\n| \\* | \n\n\n\n### log.warn()\nLog a warning message\n\n**Kind**: static method of [log](#log) \n\n| Type |\n| --- |\n| \\* | \n\n\n\n### log.error()\nLog an error message\n\n**Kind**: static method of [log](#log) \n\n| Type |\n| --- |\n| \\* | \n\n\n\n## subscribe(topic, [options], callback)\nSubscribe to MQTT topic(s)\n\n**Kind**: global function \n\n| Param | Type | Description |\n| --- | --- | --- |\n| topic | string \\| Array.<string> | topic or array of topics to subscribe |\n| [options] | Object \\| string \\| function | Options object or as shorthand to options.condition a function or string |\n| [options.shift] | number | delay execution in seconds. Has to be positive |\n| [options.random] | number | random delay execution in seconds. Has to be positive |\n| [options.change] | boolean | if set to true callback is only called if val changed |\n| [options.retain] | boolean | if set to true callback is also called on retained messages |\n| [options.condition] | string \\| function | conditional function or condition string |\n| callback | [subscribeCallback](#subscribeCallback) | |\n\n\n\n## schedule(pattern, [options], callback)\nSchedule recurring and one-shot events\n\n**Kind**: global function \n**See**: [sunSchedule](#sunSchedule) for scheduling based on sun position. \n\n| Param | Type | Description |\n| --- | --- | --- |\n| pattern | string \\| Date \\| Object \\| Array.<mixed> | pattern or array of patterns. May be cron style string, Date object or node-schedule object literal. See [https://github.com/tejasmanohar/node-schedule/wiki](https://github.com/tejasmanohar/node-schedule/wiki) |\n| [options] | Object | |\n| [options.random] | number | random delay execution in seconds. Has to be positive |\n| callback | function | is called with no arguments |\n\n**Example** \n```js\n// every full Hour.\nschedule('0 * * * *', callback);\n\n// Monday till friday, random between 7:30am an 8:00am\nschedule('30 7 * * 1-5', {random: 30 * 60}, callback);\n\n// once on 21. December 2018 at 5:30am\nschedule(new Date(2018, 12, 21, 5, 30, 0), callback);\n\n// every Sunday at 2:30pm\nschedule({hour: 14, minute: 30, dayOfWeek: 0}, callback);\n```\n\n\n## sunSchedule(pattern, [options], callback)\nSchedule a recurring event based on sun position\n\n**Kind**: global function \n**See**: [schedule](#schedule) for time based scheduling. \n\n| Param | Type | Description |\n| --- | --- | --- |\n| pattern | string \\| Array.<string> | a suncalc event or an array of suncalc events. See [https://github.com/mourner/suncalc](https://github.com/mourner/suncalc) |\n| [options] | Object | |\n| [options.shift] | number | delay execution in seconds. Allowed Range: -86400...86400 (+/- 24h) |\n| [options.random] | number | random delay execution in seconds. |\n| callback | function | is called with no arguments |\n\n**Example** \n```js\n// Call callback 15 minutes before sunrise\nsunSchedule('sunrise', {shift: -900}, callback);\n\n// Call callback random 0-15 minutes after sunset\nsunSchedule('sunset', {random: 900}, callback);\n```\n\n\n## publish(topic, payload, [options])\nPublish a MQTT message\n\n**Kind**: global function \n\n| Param | Type | Default | Description |\n| --- | --- | --- | --- |\n| topic | string \\| Array.<string> | | topic or array of topics to publish to |\n| payload | string \\| Object | | the payload string. If an object is given it will be JSON.stringified |\n| [options] | Object | | the options to publish with |\n| [options.qos] | number | 0 | QoS Level |\n| [options.retain] | boolean | false | retain flag |\n\n\n\n## setValue(topic, val)\nSet a value on one or more topics\n\n**Kind**: global function \n\n| Param | Type | Description |\n| --- | --- | --- |\n| topic | string \\| Array.<string> | topic or array of topics to set value on |\n| val | mixed | |\n\n\n\n## getValue(topic) ⇒ mixed\n**Kind**: global function \n**Returns**: mixed - the topics value \n\n| Param | Type |\n| --- | --- |\n| topic | string | \n\n\n\n## getProp(topic, [...property]) ⇒ mixed\nGet a specific property of a topic\n\n**Kind**: global function \n**Returns**: mixed - the topics properties value \n\n| Param | Type | Description |\n| --- | --- | --- |\n| topic | string | |\n| [...property] | string | the property to retrieve. May be repeated for nested properties. If omitted the whole topic object is returned. |\n\n**Example** \n```js\n// returns the timestamp of a given topic\ngetProp('hm//Bewegungsmelder Keller/MOTION', 'ts');\n```\n\n\n## now() ⇒ number\n**Kind**: global function \n**Returns**: number - ms since epoch \n\n\n## age(topic) ⇒ number\n**Kind**: global function \n**Returns**: number - seconds since last change \n\n| Param | Type |\n| --- | --- |\n| topic | string | \n\n\n\n## link(source, target, [value])\nLink topic(s) to other topic(s)\n\n**Kind**: global function \n\n| Param | Type | Description |\n| --- | --- | --- |\n| source | string \\| Array.<string> | topic or array of topics to subscribe |\n| target | string \\| Array.<string> | topic or array of topics to publish |\n| [value] | mixed | value to publish. If omitted the sources value is published. A function can be used to transform the value. |\n\n\n\n## combineBool(srcs, targets)\nCombine topics through boolean or\n\n**Kind**: global function \n\n| Param | Type | Description |\n| --- | --- | --- |\n| srcs | Array.<string> | array of topics to subscribe |\n| targets | string | topic to publish |\n\n\n\n## combineMax(srcs, targets)\nPublish maximum of combined topics\n\n**Kind**: global function \n\n| Param | Type | Description |\n| --- | --- | --- |\n| srcs | Array.<string> | array of topics to subscribe |\n| targets | string | topic to publish |\n\n\n\n## timer(src, target, time)\nPublishes 1 on target for specific time after src changed to true\n\n**Kind**: global function \n\n| Param | Type | Description |\n| --- | --- | --- |\n| src | string \\| Array.<string> | topic or array of topics to subscribe |\n| target | string | topic to publish |\n| time | number | timeout in milliseconds |\n\n\n\n## subscribeCallback : function\n**Kind**: global typedef \n\n| Param | Type | Description |\n| --- | --- | --- |\n| topic | string | the topic that triggered this callback. +/status/# will be replaced by +//# |\n| val | mixed | the val property of the new state |\n| obj | object | new state - the whole state object (e.g. {\"val\": true, \"ts\": 12346345, \"lc\": 12346345} ) |\n| objPrev | object | previous state - the whole state object |\n| msg | object | the mqtt message as received from MQTT.js |\n\n\n# License\n\n\nMIT © [Sebastian Raff](https://github.com/hobbyquaker)\n\n[mit-badge]: https://img.shields.io/badge/License-MIT-blue.svg?style=flat\n[mit-url]: LICENSE\n","has_starred","hub_user","immutable_tags_settings",{"_70":11,"_71":72},"enabled","rules",[73],".*","is_automated","permissions",{"_77":17,"_78":11,"_79":11},"read","write","admin","user","storage_size",79798143,"orgData","recentTags",[86],{"_87":39,"_88":89,"_90":91,"_92":93,"_94":95,"_45":112,"_113":89,"_114":28,"_115":51,"_52":116,"_117":118,"_119":103,"_120":112,"_121":61,"_122":17},"content_type","creator",2496156,"full_size",79788811,"id",141376392,"images",[96],{"_97":98,"_99":100,"_101":43,"_102":103,"_104":105,"_106":107,"_108":43,"_109":-5,"_110":91,"_58":61,"_111":-5},"architecture","amd64","digest","sha256:28751f39e8581bf45bd6db1d6e34f99ce57eba391b9f54eb62f5afeb4ffe8ef1","features","last_pulled","2026-09-14T04:01:44.512342674Z","last_pushed","2021-03-14T09:09:43Z","os","linux","os_features","os_version","size","variant","2021-03-14T09:09:42.128791Z","last_updater","last_updater_username","media_type","latest","repository",11780897,"tag_last_pulled","tag_last_pushed","tag_status","v2","sbxKitMetadata","isPotentialSpam","isHubSbxKitsEnabled","displaySecurityMetadata","tagAttestations","tagsHaveAttestations",[],"routes/_layout.r.$namespace.$reponame.tags",{"_33":132,"_139":140,"_128":149,"_150":11},{"_35":133,"_37":134,"_40":41,"_42":43,"_44":11,"_45":46,"_47":48,"_49":135,"_52":30,"_27":28,"_53":54,"_55":39,"_56":57,"_58":59,"_60":61,"_62":-5,"_63":57,"_64":65,"_66":11,"_67":28,"_68":136,"_74":11,"_75":138,"_80":28,"_81":82},[],[39],[51],{"_70":11,"_71":137},[73],{"_77":17,"_78":11,"_79":11},"tags",{"_141":59,"_142":-5,"_143":-5,"_144":145},"count","next","previous","results",[146],{"_87":39,"_88":89,"_90":91,"_92":93,"_94":147,"_45":112,"_113":89,"_114":28,"_115":51,"_52":116,"_117":118,"_119":103,"_120":112,"_121":61,"_122":17},[148],{"_97":98,"_99":100,"_101":43,"_102":103,"_104":105,"_106":107,"_108":43,"_109":-5,"_110":91,"_58":61,"_111":-5},[],"canDeleteTags","actionData","errors"]

micwy/mqtt-scripts

Tags for micwy/mqtt-scripts