--- smsdaemon/GsmModem.cpp 2008/06/11 10:21:47 49 +++ smsdaemon/ModemTransceiver.cpp 2008/12/22 22:22:42 214 @@ -2,36 +2,36 @@ */ #include - #include -#include #include -#include #include -#include "SerialPort.h" +#include "serialport/SerialPort.h" -#include "GsmModem.h" +#include "ModemTransceiver.h" -#include "util.h" -#include "common.h" +#include "Util.h" +#include "Common.h" +#include "Logger.h" +#include "ConfigFile.h" +#include "SmsPdu.h" +#include "Exceptions.h" using namespace std; -GsmModem::GsmModem(SerialPort& serialport) -: m_port(serialport) +ModemTransceiver::ModemTransceiver(SerialPort& serialport) + : m_port(serialport) { - Init(); } -string GsmModem::GetResponse() +string ModemTransceiver::GetResponse() { SerialPort::DataBuffer buf; @@ -45,10 +45,11 @@ } -string GsmModem::Command(string command, string term) +string ModemTransceiver::Command(string command, string term) { time_t start,now; start = time(0); + _timeout = false; if (term != "> ") command.append("\r"); //Dont append CarriageReturn if sending SMS @@ -70,31 +71,34 @@ response += GetResponse(); Util::Sleep(1); - now = time(0); - if ( (now-start) > 10 ) - { - Common::instance()->logMessage( string("GsmModem::Command time out --") + command); - break; - } + now = time(0); + if ( (now-start) > 10 ) + { + Logger::logMessage( string("ModemTransceiver::Command time out --") + command); + Logger::logMessage( string("Modem responded: ") + Util::str_trim(response) ); + _timeout = true; + break; + } } Util::Sleep(5); -// cout << response.length() << ":" << response << endl; -// DumpString(response); return response; } -vector GsmModem::ReadSms(bool readAll) +vector ModemTransceiver::ReadSms(bool readAll) { + + Command( "AT+CMGF=0" ); //Set SMS format to PDU + const string search = "+CMGL: "; std::string cmd = "AT+CMGL"; if (readAll) - cmd.append("=ALL"); + cmd.append("=4"); string result = Command(cmd); - + vector retval; if (result.find(search) == string::npos) return retval; @@ -106,74 +110,203 @@ { unsigned int endpos = result.find(search,5); - + string sms_entry = result.substr(0,endpos); - retval.push_back( SMS::FromRawString(sms_entry) );; + + try + { + SMS sms = FromPduString(sms_entry); + + retval.push_back( sms ); + } + catch (smsnotfoundexception& e) //do nothing + { + } if (endpos == string::npos) break; - + result = result.substr(endpos, result.length() - endpos); } return retval; } -void GsmModem::SendSms(string to, string message) + +void ModemTransceiver::SendSmsPdu(std::string pdu, int len) //pdu inclussive leading "00" { - Common::instance()->logMessage( string("SMS send to ") + to); + Logger::logMessage( string("SMS pdu send") ); - Command("AT+CMGF=1");///Allways telling the format makes the application more stable + Command("AT+CMGF=0"); Util::Sleep(2); string line1 = "AT+CMGS="; - line1.append(to); + line1.append( Util::str_formatint(len) ); line1.append("\r"); + Command(line1,"> "); + pdu.append("\032"); // \032 == Ctrl+Z + Command( pdu ); + Util::Sleep( 50 ); + Common::instance()->smsCounter.outgoing++; +} - message.append("\032"); // \032 == Ctrl+Z +void ModemTransceiver::SendSms(string to, string message, bool allowMultipart) +{ + Logger::logMessage( string("SMS send to ") + to); - Command( message.substr(0,160) ); //In textmode limit to 160 bytes + if (to.at(0) == '+') + to.erase(0,0); + vector pdu_vec = SmsPdu::CreateSmsPdu(to, Util::str_latin2gsm(message), allowMultipart); + + for (unsigned i=0; ismsCounter.outgoing++; } -void GsmModem::DeleteSms(std::string smsIndex) +void ModemTransceiver::DeleteSms(std::string smsIndex) { string cmd = "AT+CMGD="; cmd.append(smsIndex); Command(cmd); } -int GsmModem::DeleteAllSms() + +void ModemTransceiver::WaitForSimcard() { - vector sms = ReadSms(true); + int start = time(0); + string result; + - for (unsigned int i= 0; i 10) + throw std::runtime_error("Sim card timed out:"); + Util::Sleep(100); } - return sms.size(); + } +void ModemTransceiver::HandlePincode() +{ + string pin = Common::instance()->GetConfigfile()->GetValue("gsmmodem","pin",""); + string result = Command("AT+CPIN?"); + result = Util::str_trim(result); + result.erase(result.length() -2, 2); //remove trailing ok + result = Util::str_trim(result); + if (result != "+CPIN: READY") + { + if (result == "+CPIN: SIM PIN") + { + Command("AT^SSET=1"); + result = Command( string("AT+CPIN=")+pin ); + if ( result.substr(result.length()-4, 4) != "OK\r\n") + throw std::runtime_error(string("Illegal pincode: ") + result); + + WaitForSimcard(); + } + else + { + throw std::runtime_error(string("AT+CPIN? returned unhandled code: ") + result); + } + + } +} -void GsmModem::Init() +void ModemTransceiver::Init() { + Command( "AT" ); + if (_timeout) + throw std::runtime_error("Modem did not respond!"); + Command( "ATZ" ); //Reset any previous setup + Command( "AT\\Q3" ); //Hardware flow control Command( "ATE0" ); //Disable echo - Command( "AT+CMGF=1" ); //Set SMS format to text - Command ("AT^SM20=0,0" ); //No SM20 compability - //Set RealTimeClock ?? - - //Enter pin code ?? + //Command("AT+CGATT=1"); //GPRS Attach + + //Command("AT+CGSMS=2"); //SMS over GPRS preferred + + HandlePincode(); +} + + +SMS ModemTransceiver::FromRawString(const std::string& input) +{ + std::string smsline = input.substr(7, input.length() -7); //strip "+CMGL: " + + std::vector lines = Util::str_split(smsline, "\r\n"); + std::vector fields = Util::str_split(lines[0],","); + + std::string body; + for (unsigned i=1; i 0) + body += "\r\n"; + body += body_line; + } + } + + body = Util::str_trim(body); + + SMS sms; + + sms.SetIndex( fields[0] ); + + + std::string sender = fields[2]; + sender = Util::str_replace(sender, "\""); + sms.SetSender(sender); + + std::string timestamp = fields[4] + std::string(",") + fields[5]; + timestamp = Util::str_replace(timestamp, "\""); + sms.SetTimestamp(timestamp); + + sms.SetMessage( Util::str_gsm2latin(body) ); + + return sms; } + +SMS ModemTransceiver::FromPduString(const std::string& input) +{ + std::string smsline = input.substr(7, input.length() -7); //strip "+CMGL: " + + std::vector lines = Util::str_split(smsline, "\r\n"); + std::vector fields = Util::str_split(lines[0],","); + + std::string index = fields[0]; + DeleteSms(index); + + SMS sms = SmsPdu::ParseSmsPdu(lines[1]); + + sms.SetIndex(index); + + sms.SetMessage( Util::str_gsm2latin(sms.GetMessage()) ) ; + + return sms; +} + + + +