Skip to content

gprs library #41

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open

gprs library #41

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
360 changes: 360 additions & 0 deletions modules/@amperka/gprs.js
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,360 @@
/*
Serial3.setup(9600, { rx: P0, tx : P1 });

console.log("Connecting to SIM900R module");
var gprs = require('@amperka/gprs').connect(Serial3, P5, function(err) {
if (err) throw err;
gprs.connect('internet.beeline.ru', 'beeline', 'beeline', function(err) {
if (err) throw err;
gprs.getIP(function(err, ip) {
if (err) throw err;
console.log('IP:' + ip);
require("http").get("http://www.pur3.co.uk/hello.txt", function(res) {
console.log("Response: ",res);
res.on('data', function(d) {
console.log("--->"+d);
});
});
});
});
});
*/

// APN:
// internet.beeline.ru
// beeline
// beeline

var at;
var socks = [];
var sockData = ["","","","",""];
var MAXSOCKETS = 5;
var _powerPin;
var _statusPin;
var _serial;
var busy = false;

function unregisterSocketCallbacks(sckt) {
at.unregister('>');
at.unregisterLine(sckt + ', SEND OK');
at.unregisterLine(sckt + ', SEND FAIL');
}

var netCallbacks = {
create: function(host, port) {
/* Create a socket and return its index, host is a string, port is an integer.
If host isn't defined, create a server socket */
if (host===undefined) {
sckt = MAXSOCKETS;
socks[sckt] = "Wait";
sockData[sckt] = "";
at.cmd("AT+CIPSERVER=1,"+port+"\r\n", 10000, function(d) {
if (d=="OK") {
socks[sckt] = true;
} else {
socks[sckt] = undefined;
throw new Error("CIPSERVER failed");
}
});
return MAXSOCKETS;
} else {
var sckt = 0;
while (socks[sckt]!==undefined) sckt++; // find free socket
if (sckt>=MAXSOCKETS) throw new Error('No free sockets.');
socks[sckt] = "Wait";
sockData[sckt] = "";
at.cmd('AT+CIPSTART='+sckt+',"TCP",'+JSON.stringify(host)+','+port+'\r\n',10000, function(d) {
if (d=="OK") {
at.registerLine(sckt + ', CONNECT OK', function() {
at.unregisterLine(sckt + ', CONNECT OK');
at.unregisterLine(sckt + ', CONNECT FAIL');
socks[sckt] = true;
return "";
});
at.registerLine(sckt + ', CONNECT FAIL', function() {
at.unregisterLine(sckt + ', CONNECT FAIL');
at.unregisterLine(sckt + ', CONNECT OK');
at.unregisterLine(sckt + ', CLOSED');
socks[sckt] = undefined;
return "";
});
at.registerLine(sckt + ', CLOSED', function() {
at.unregisterLine(sckt + ', CLOSED');
unregisterSocketCallbacks(sckt);
socks[sckt] = undefined;
busy = false;
return "";
});
} else {
socks[sckt] = undefined;
return "";
}
});
}
return sckt; // jshint ignore:line
},
/* Close the socket. returns nothing */
close: function(sckt) {
if (socks[sckt]) {
// ,1 = 'fast' close
at.cmd('AT+CIPCLOSE='+sckt+",1\r\n",1000, function(/*d*/) {
socks[sckt] = undefined;
});

}
},
/* Accept the connection on the server socket. Returns socket number or -1 if no connection */
accept: function(sckt) {
// console.log("Accept",sckt);
for (var i=0;i<MAXSOCKETS;i++)
if (sockData[i] && socks[i]===undefined) {
//console.log("Socket accept "+i,JSON.stringify(sockData[i]),socks[i]);
socks[i] = true;
return i;
}
return -1;
},
/* Receive data. Returns a string (even if empty).
If non-string returned, socket is then closed */
recv: function(sckt, maxLen) {
if (at.isBusy() || socks[sckt]=="Wait") return "";
if (sockData[sckt]) {
var r;
if (sockData[sckt].length > maxLen) {
r = sockData[sckt].substr(0,maxLen);
sockData[sckt] = sockData[sckt].substr(maxLen);
} else {
r = sockData[sckt];
sockData[sckt] = "";
}
return r;
}
if (!socks[sckt]) return -1; // close it
return "";
},
/* Send data. Returns the number of bytes sent - 0 is ok.
Less than 0 */
/* Send data. Returns the number of bytes sent - 0 is ok.
Less than 0 */
send: function(sckt, data) {
if (busy || at.isBusy() || socks[sckt]=="Wait") return 0;
if (!socks[sckt]) return -1; // error - close it
busy = true;
at.register('>', function() {
at.unregister('>');
at.write(data);
return "";
});
at.registerLine(sckt + ', SEND OK', function() {
at.unregisterLine(sckt + ', SEND OK');
at.unregisterLine(sckt + ', SEND FAIL');
busy = false;
return "";
});
at.registerLine(sckt + ', SEND FAIL', function() {
at.unregisterLine(sckt + ', SEND OK');
at.unregisterLine(sckt + ', SEND FAIL');
busy = false;
return -1;
});
at.write('AT+CIPSEND='+sckt+','+data.length+'\r\n');
return data.length;
}
};

// Handle +RECEIVE input data from SIM900A
function receiveHandler(line) {
var colon = line.indexOf(":\r\n");
if (colon<0) {
return line; // not enough data here at the moment
}
var parms = line.substring(9,colon).split(",");
parms[1] = 0|parms[1];
var len = line.length-(colon+3);
if (len>=parms[1]) {
// we have everything
sockData[parms[0]] += line.substr(colon+3,parms[1]);
return line.substr(colon+parms[1]+3); // return anything else
} else {
// still some to get
sockData[parms[0]] += line.substr(colon+3,len);
return "+D,"+parms[0]+","+(parms[1]-len)+":"; // return +D so receiveHandler2 gets called next time
}
}
function receiveHandler2(line) {
var colon = line.indexOf(":");
if (colon<0) return line; // not enough data here at the moment
var parms = line.substring(3,colon).split(",");
parms[1] = 0|parms[1];
var len = line.length-(colon+1);
if (len>=parms[1]) {
// we have everything
sockData[parms[0]] += line.substr(colon+1,parms[1]);
return line.substr(colon+parms[1]+1); // return anything else
} else {
// still some to get
sockData[parms[0]] += line.substr(colon+1,len);
return "+D,"+parms[0]+","+(parms[1]-len)+":"; // return +D so receiveHandler2 gets called next time
}
}
var gprsFuncs = {
receiveHandler: receiveHandler,
"debug" : function() {
return {
socks: socks,
sockData: sockData
};
},
// initialise the SIM900A
"init": function(callback) {
var s = 0;
var cb = function(r) {
switch (s) {
case 0:
if (r === 'IIIIATE0' || r === 'IIII' + String.fromCharCode(255) + 'ATE0' || r === 'ATE0') {
return cb;
} else if (r === 'OK') {
s = 1;
at.cmd('AT+CPIN?\r\n', 500, cb);
} else if (r) {
callback('Error in ATE0: ' + r);
}
break;
case 1:
if (r === '+CPIN: READY') {
return cb;
} else if (r === 'OK') {
s = 2;
// check if we're on network
at.cmd('AT+CGATT=1\r\n', 500, cb);
} else if (r) {
callback('Error in CPIN: ' + r);
}
break;
case 2:
if (r === 'OK') {
s = 3;
at.cmd('AT+CIPSHUT\r\n', 500, cb);
} else if (r) {
callback('Error in CGATT: ' + r);
}
break;
case 3:
if (r === 'SHUT OK') {
s = 4;
at.cmd('AT+CIPSTATUS\r\n', 500, cb);
} else if (r) {
callback('Error in CIPSHUT: ' + r);
}
break;
case 4:
if (r === 'OK') {
return cb;
} else if (r === 'STATE: IP INITIAL') {
s = 5;
at.cmd('AT+CIPMUX=1\r\n', 500, cb);
} else if (r) {
callback('Error in CIPSTATUS: ' + r);
}
break;
case 5:
if (r&&r.substr(0,3) == "C: ") {
return cb;
} else if (r === 'OK') {
s = 6;
at.cmd('AT+CIPHEAD=1\r\n', 500, cb);
} else if (r) {
callback('Error in CIPMUX: ' + r);
}
break;
case 6:
if (r === 'OK') {
return cb;
} else if (r) {
callback('Error in CIPHEAD: ' + r);
} else {
callback(null);
}
break;
}
};
at.cmd("ATE0\r\n",1000,cb);
},
"powerOn": function(callback) {
if (!digitalRead(_statusPin)) {
digitalPulse(_powerPin, 1, 1000);
setTimeout(function() {
print('gprsFuncs.init(callback);');
gprsFuncs.init(callback);
}, 2000);
} else {
gprsFuncs.init(callback);
}
},
"powerOff": function(callback) {
if (!!digitalRead(_statusPin)) {
digitalPulse(_powerPin, 1, 1000);
}
},
"getVersion": function(callback) {
at.cmd("AT+GMR\r\n", 1000, function(d) {
callback(null,d);
});
},
"connect": function(apn, username, password, callback) {
var s = 0;
var cb = function(r) {
switch (s) {
case 0:
if (r === 'OK') {
s = 1;
at.cmd('AT+CIICR\r\n', 2000, cb);
} else if (r) {
callback('Error in ' + s + ': ' + r);
}
break;
case 1:
if (r === 'OK') {
return cb;
} else if (r) {
callback('Error in ' + s + ': ' + r);
} else {
callback(null);
}
break;
}
};
at.cmd('AT+CSTT="' + apn + '", "' + username + '", "' + password + '"\r\n', 1000, cb);
},
"getIP": function(callback) {
var ip;
var cb = function(r) {
if (r && r != 'ERROR' && r != 'OK') {
ip = r;
return cb;
} else if (r === 'ERROR') {
callback('CIFSR Error');
} else if (!r) {
callback(null, ip);
}
};
at.cmd('AT+CIFSR\r\n', 2000, cb);
}
};
exports.connect = function(options, connectedCallback) {

options = options || {};

_powerPin = options.powerPin || P2;
_statusPin = options.statusPin || P3;
_serial = options.port || Serial3;
_serial.setup(options.serialSpeed || 9600);

gprsFuncs.at = at = require('AT').connect(_serial);

require("NetworkJS").create(netCallbacks);
at.register("+RECEIVE", receiveHandler);
at.register("+D", receiveHandler2);
// gprsFuncs.reset(connectedCallback);
return gprsFuncs;
};