Guest User

Untitled

a guest
Nov 22nd, 2017
105
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 5.11 KB | None | 0 0
  1. var Client = require("ibmiotf");
  2. var moment = require("moment");
  3. var net = require('net');
  4. var deviceConfig = new require("./kashyap.json");
  5. var deviceClient = new Client.IotfGateway(deviceConfig);
  6. var msg = "$HTSTEST1,HTS0001,A47C4365,A1FD4365,A0D04365,AAA54365,00000000,00000000,00000000,#";
  7. var client = new net.Socket();
  8. client.connect(9000, '10.175.174.224', function() {
  9. console.log('Connected');
  10. client.write('REQDATArn');});
  11.  
  12. client.on('data', function(data) {
  13. if(data[data.length -1] == '35')
  14. {
  15. console.log('Received: ' + data);
  16. msg = data;
  17. client.destroy(); // kill client after server's response
  18. });
  19.  
  20. client.on('close', function() {
  21. console.log('Connection closed');
  22. });
  23. var chordIndex=0;
  24. var getTemp = function() {
  25. var cel=temp.value();
  26. console.log("current Temp is " + cel);
  27. return cel.toFixed(4);
  28. };
  29. var getTimestamp = function() {
  30. console.log("Time",moment().valueOf());
  31. return moment().valueOf();
  32. }
  33.  
  34. var getTemperature = function(msg1){
  35. msg1 = msg1.toString();
  36. console.log("1111111111 : ",msg1);
  37. var res = msg1.split(',',3);
  38. console.log("Temperature : ",res[1]);
  39. return res[1];
  40. };
  41.  
  42. var getVoltage = function(msg1){
  43. msg1 = msg1.toString();
  44. var res = msg1.split(',',10);
  45. var Data = res[2].substring(4,8)+res[2].substring(0,4);
  46. var buf = new Buffer(Data, "hex");
  47. var number = buf.readFloatBE(0);
  48. console.log("Voltage : ",number);
  49. return number;
  50. };
  51.  
  52. var getCurrent = function(msg1){
  53. msg1 = msg1.toString();
  54. var res = msg1.split(',',10);
  55. var Data = res[3].substring(4,8)+res[3].substring(0,4);
  56. var buf = new Buffer(Data, "hex");
  57. var number = buf.readFloatBE(0);
  58. console.log("Current : ",number);
  59. return number;
  60. };
  61.  
  62. var getFrequency = function(msg1){
  63. msg1 = msg1.toString();
  64. var res = msg1.split(',',10);
  65. var Data = res[4].substring(4,8)+res[4].substring(0,4);
  66. var buf = new Buffer(Data, "hex");
  67. var number = buf.readFloatBE(0);
  68. console.log("Frequency : ",number);
  69. return number;
  70. };
  71.  
  72. var getPowerFactor = function(msg1){
  73. msg1 = msg1.toString();
  74. var res = msg1.split(',',10);
  75. var Data = res[5].substring(4,8)+res[5].substring(0,4);
  76. var buf = new Buffer(Data, "hex");
  77. var number = buf.readFloatBE(0);
  78. console.log("Power Factor : ",number);
  79. return number;
  80. };
  81.  
  82. var getKwh = function(msg1){
  83. msg1 = msg1.toString();
  84. var res = msg1.split(',',10);
  85. var Data = res[6].substring(4,8)+res[6].substring(0,4);
  86. var buf = new Buffer(Data, "hex");
  87. var number = buf.readFloatBE(0);
  88. console.log("Kwh : ",number);
  89. return number;
  90. };
  91.  
  92. deviceClient.connect();
  93. //deviceClient.log.setLevel('debug');
  94. deviceClient.on("connect", function() {
  95. console.log("successfully connected to IoTF");
  96.  
  97. setInterval(function() {
  98. client.connect(9000, '10.175.174.224',
  99. function(){
  100. console.log('Connected');
  101. client.write('REQDATArn');
  102. });
  103. deviceClient.publishGatewayEvent("Status Frequency":'+getFrequency(msg)+'Power_factor":'+getPowerFactor(msg)+',"Kwh":'+getKwh(msg)+',"Time":'+getTimestamp()+'}}');},3000);});
  104.  
  105. /root/kash/node_modules/ibmiotf/node_modules/mqtt/node_modules/websocket-
  106. stream/server.js:6
  107. class Server extends WebSocketServer{
  108. ^^^^^
  109. SyntaxError: Unexpected reserved word
  110. at Module._compile (module.js:439:25)
  111. at Object.Module._extensions..js (module.js:474:10)
  112. at Module.load (module.js:356:32)
  113. at Function.Module._load (module.js:312:12)
  114. at Module.require (module.js:364:17)
  115. at require (module.js:380:17)
  116. at Object.<anonymous>
  117. (/root/kash/node_modules/ibmiotf/node_modules/mqtt/node_modules/websocket-
  118. stream/index.js:2:14)
  119. at Module._compile (module.js:456:26)
  120. at Object.Module._extensions..js (module.js:474:10)
  121. at Module.load (module.js:356:32)
  122. at Function.Module._load (module.js:312:12)
  123. at Module.require (module.js:364:17)
  124. at require (module.js:380:17)
  125. at Object.<anonymous>
  126. (/root/kash/node_modules/ibmiotf/node_modules/mqtt/lib/connect/ws.js:3:17)
  127. at Module._compile (module.js:456:26)
  128. at Object.Module._extensions..js (module.js:474:10)
  129. root@WR-IntelligentDevice:~/kash#
Add Comment
Please, Sign In to add comment