SensorNode-client application for IOTA.
Either data is being pushed to Tangle or send as Masked Authenticated Message, or both.
(Image by Wyn Tiedmers)
Clone this repository:
git clone https://github.com/rckey/SensorNode
Install node_modules:
cd SensorNode/
npm install
Install mam.node.js:
cd node_modules/
git clone https://github.com/rckey/mam.node.js
You can create streamobjects with the following parameters:
| Parameter | Function | Default |
|---|---|---|
| host | (Remote-) node we're connecting to. | 0.0.0.0 |
| port | Iota-api port on the node. | 14265 |
| id | Identifies the streamobject. | "SensorNode" |
| location | Nodes location, eg. 'lat': 52.26 'lng': 13.42. | {'lat': 40.65, 'lng': -73.91} |
| seed | Seed for creating transactions/MAM-messages. | [generated] |
| rec | Receiving address (tanglestream only). | "GPB9PBNCJTPGF..." |
| tag | Tag for Transactions (tanglestream only). | "SENSORNODEROCKS" |
| depth | Depth for tip-selection (tanglestream only). | 3 |
| wait | Discards packets till the current packet has been send. | true |
| fetch | Enable continuous fetching from MAM-root when multiple nodes stream from the same seed (mamstream only). | false |
streams.push(new STREAM ({
'host': 'http://[remote node / localhost]',
'port': [port]
[OPTIONAL PARAMETERS]
}))
streams.push(new MAM_STREAM ({
'host': 'http://[remote node / localhost]',
'port': [port]
[OPTIONAL PARAMETERS]
}))
Data sources are (async) functions which return the data you want to stream, eg:
async function functionFoo () {
return await sensorA.read();
}
async function functionBar () {
return await sensorB.read();
}
streams[0].addSource(functionFoo);
streams[1].addSource(functionBar);
Run with npm start [delay] where delay specifies a timeout between each push (default 60 seconds).
Thats it. Have fun providing data over the iota protocol. ;)
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent