Sistem Pemantauan Sampah dan Kualitas Udara Dalam Ruangan

Kode

• sensor.js
• mam_sensor.js
• mam_receive.js
• mam_sensorArduino.js
• mam_receiveArduino.js

sensor.jsJavaScript

const sensor =require('node-dht-sensor');const TIMEINTERVAL =10; // SECONDSconst SENSORTYPE =11; // 11=DHT11, 22=DHT22konst GPIOPIN =4; // PIN GPIO RASPBERRY DARI SENSOR DHT11fungsi readSensor(){ sensor.read(SENSORTYPE, GPIOPIN, function(err, temperatur, kelembaban) { if (!err) { console.log('temp:' + temperature.toFixed(1 ) + 'C, ' + 'humidity:' + moisture.toFixed(1) + '%'); } else { console.log(err); } });}readSensor();// OTOMATIS UPDATE SENSOR NILAI SETIAP 10 SECONDSsetInterval(readSensor, TIMEINTERVAL*1000);

mam_sensor.jsJavaScript

const sensor =require('node-dht-sensor');const Mam =require('./lib/mam.client.js');const IOTA =membutuhkan('iota.lib.js');const momen =membutuhkan('moment');//const iota =new IOTA({ penyedia:'https://nodes.testnet.iota.org:443 ' });const iota =new IOTA({ provider:'https://potato.iotasalad.org:14265' });//const iota =new IOTA({ provider:'https://peanut.iotasalad.org :14265' });const MODE ='dibatasi'; // PUBLIK, SWASTA ATAU TERBATASconst SIDEKEY ='rahasiaku'; // DIGUNAKAN HANYA DALAM MODE TERBATAS, TINGKAT KEAMANAN =3; const INTERVAL WAKTU =30; // SECONDSconst SENSORTYPE =11; // 11=DHT11, 22=DHT22konst GPIOPIN =14; // PIN GPIO RASPBERRY DARI SENSOR DHT11// INITIALIZE MAM STATElet mamState =Mam.init(iota, undefined, SECURITYLEVEL);// CHANNEL MODEif (MODE =='restricted') { const key =iota.utils.toTrytes(SIDEKEY); mamState =Mam.changeMode(mamState, MODE, key);} else { mamState =Mam.changeMode(mamState, MODE);}// PUBLISH TO TANGLEconst publish =async function(packet) { // CREATE MAM PAYLOAD const trytes =sedikit .utils.toTrytes(JSON.stringify(paket)); const pesan =Mam.create(mamState, trytes); // SIMPAN MAMSTATE BARU mamState =message.state; console.log('Akar:', pesan.root); console.log('Alamat:', pesan.alamat); // Lampirkan PAYLOAD menunggu Mam.attach(message.payload, message.address); return message.root;}function readSensor(){ sensor.read(SENSORTYPE, GPIOPIN, async function(err, temperature, moisture) { if (!err) { const city =('MEKSIKO'); const building =('65 '); const dateTime =momen().utc().format('YYYY/MM/DD jj:mm:ss'); const data =`{Suhu:${temperature.toFixed(1)}°C ($ {(temperature.toFixed(1)*1.8)+32}°F), Kelembaban:${humidity.toFixed(1)}%}`; const json ={"data":data, "dateTime":dateTime, " building":building, "city":city}; const root =menunggu publish(json); console.log(`City:${json.city}, Building:${json.building}, Time:${json. dateTime} UTC, Data:${json.data}, root:${root}`); } else { console.log(err); } });}// MULAI ITreadSensor();// AUTOMATICALLY UPDATE SENSOR NILAI SETIAP 30 DETIKsetInterval(readSensor, TIMEINTERVAL*1000);

mam_receive.jsJavaScript

const Mam =require('./lib/mam.client.js');const IOTA =require('iota.lib.js');//const iota =new IOTA( { penyedia:'https://nodes.testnet.iota.org:443' });const iota =new IOTA({ penyedia:'https://potato.iotasalad.org:14265' });//const iota =new IOTA({ provider:'https://peanut.iotasalad.org:14265' });const MODE ='restricted'; // PUBLIK, SWASTA ATAU TERBATASconst SIDEKEY ='rahasiaku'; // HANYA DIGUNAKAN DALAM MODE TERBATAS root;let key;// PERIKSA ARGUMENTSconst args =process.argv;if(args.length !=3) { console.log('Missing root as argument:node mam_receive.js  '); process.exit();} else if(!iota.valid.isAddress(args[2])){ console.log('Anda telah memasukkan root yang tidak valid:'+ args[2]); process.exit();} else { root =args[2];}// INITIALISE MAM STATElet mamState =Mam.init(iota);// SET CHANNEL MODEif (MODE =='restricted') { key =iota.utils .toTrytes(SIDEKEY); mamState =Mam.changeMode(mamState, MODE, key);} else { mamState =Mam.changeMode(mamState, MODE);}// MENERIMA DATA DARI TANGLEconst executionDataRetrieval =async function(rootVal, keyVal) { let resp =menunggu Mam .fetch(rootVal, MODE, keyVal, function(data) { biarkan json =JSON.parse(iota.utils.fromTrytes(data)); console.log(`City:${json.city}, Building:${json .building}, Waktu:${json.dateTime} UTC, Data:${json.data}`); }); }executeDataRetrieval(root, kunci);

mam_sensorArduino.jsJavaScript

const SerialPort =require('serialport');const moment =require('moment');const IOTA =memerlukan ('iota.lib.js');const Mam =require('./lib/mam.client.js');//const iota =new IOTA({ provider:'https://nodes.testnet.iota. org:443' });const iota =new IOTA({ provider:'https://potato.iotasalad.org:14265' });const MODE ='restricted'; // PUBLIC, PRIVATE, RESTRICTEDconst SIDEKEY ='rahasiaku'; // HANYA ASCII CHARACTERSconst SECURITYLEVEL =3; // 1, 2, 3const PORTNAME ='/dev/ttyACM1'; // ENTER VALID PORT const port =new SerialPort(PORTNAME, { baudRate:9600, autoOpen:true});const Readline =SerialPort.parsers.Readline;const parser =port.pipe(new Readline({ pembatas:'\r\ n' }));// INITIALIZE MAM STATElet mamState =Mam.init(iota, undefined, SECURITYLEVEL);// SET CHANNEL MODEif (MODE =='restricted') { const key =iota.utils.toTrytes(SIDEKEY); mamState =Mam.changeMode(mamState, MODE, key);} else { mamState =Mam.changeMode(mamState, MODE);}// PUBLISH TO TANGLEconst publish =async function(packet) { // CREATE MAM PAYLOAD const trytes =sedikit .utils.toTrytes(JSON.stringify(paket)); const pesan =Mam.create(mamState, trytes); // SIMPAN MAMSTATE BARU mamState =message.state; console.log('Akar:', pesan.root); console.log('Alamat:', pesan.alamat); // Lampirkan PAYLOAD menunggu Mam.attach(message.payload, message.address); return message.root;}// SERIAL PORT LIBRARY EVENTSport.on('open', showPortOpen);parser.on('data', readSerialData);port.on('close', showPortClose);port.on('error ', showError);// CALLBACK FUNCTIONSfunction showPortOpen() { console.log('Serial port open. Data rate:' + port.baudRate);}fungsi async readSerialData(data){ let json ={}; const waktu =momen().utc().format('YYYY/MM/DD jj:mm:dd'); const kota =('NY'); bangunan const =('13'); json['waktu'] =waktu; json['kota'] =`${kota}`; json['bangunan'] =`${bangunan}`; json['data'] =`{${data}}`; console.log('json =',json); const root =await publish(json);}function showPortClose() { console.log('Serial port closed.');}function showError(error) { console.log('Serial port error:' + error);}

mam_receiveArduino.jsJavaScript

const Mam =require('./lib/mam.client.js');const IOTA =require('iota.lib.js');//const iota =new IOTA({ provider:'https://nodes.testnet.iota.org:443' });const iota =new IOTA({ provider:'https://potato.iotasalad.org:14265' });const MODE ='restricted'; // PUBLIC, PRIVATE OR RESTRICTEDconst SIDEKEY ='mysecret'; // ENTER ONLY ASCII CHARACTERSlet root;let key;// CHECK THE ARGUMENTSconst args =process.argv;if(args.length !=3) { console.log('Missing root as argument:node mam_receive.js '); process.exit();} else if(!iota.valid.isAddress(args[2])){ console.log('You have entered an invalid root:'+ args[2]); process.exit();} else { root =args[2];}// INITIALIZE MAM STATElet mamState =Mam.init(iota);// SET CHANNEL MODEif (MODE =='restricted') { key =iota.utils.toTrytes(SIDEKEY); mamState =Mam.changeMode(mamState, MODE, key);} else { mamState =Mam.changeMode(mamState, MODE);}// RECEIVE DATA FROM THE TANGLEconst executeDataRetrieval =async function(rootVal, keyVal) { let resp =await Mam.fetch(rootVal, MODE, keyVal, function(data) { let json =JSON.parse(iota.utils.fromTrytes(data)); console.log(`City:${json.city}, Building:${json.building}, Time:${json.time} UTC, Data:${json.data}`); }); executeDataRetrieval(resp.nextRoot, keyVal);}executeDataRetrieval(root, key);

Skema

Schematic diagram Schematic diagram Schematic diagram