/[projects]/smsdaemon/SmsToolTransceiver.cpp
ViewVC logotype

Diff of /smsdaemon/SmsToolTransceiver.cpp

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 151 by torben, Mon Dec 8 10:42:04 2008 UTC revision 210 by torben, Sun Dec 21 21:14:40 2008 UTC
# Line 1  Line 1 
1  #include "SmsToolTransceiver.h"  #include "SmsToolTransceiver.h"
2    
3  #include "common.h"  #include "Logger.h"
4  #include "util.h"  #include "Util.h"
5    #include "Common.h"
6    #include "ConfigFile.h"
7    
8  #include <stdexcept>  #include <stdexcept>
9  #include <iostream>  #include <iostream>
# Line 18  Line 20 
20    
21  using namespace std;  using namespace std;
22    
23    string appendSlash(string& str)
24    {
25            if (str.at(str.length()-1) != '/');
26            str += "/";
27            return str;
28    }
29    
30    SmsToolTransceiver::SmsToolTransceiver()
31    {
32            Common* cmn = Common::instance();
33    
34            try
35            {
36                    inboxdir = cmn->GetConfigfile()->GetValue("smstools","inboxdir").StringValue();
37            }
38            catch (...)
39            {
40                    Logger::logMessage("Config error> smstools::inboxdir not specified");
41                    exit(1);
42            }
43            try
44            {
45                    outgoingdir = cmn->GetConfigfile()->GetValue("smstools","outgoingdir").StringValue();
46            }
47            catch (...)
48            {
49                    Logger::logMessage("Config error> smstools::outgoingdir not specified");
50                    exit(1);
51            }
52    
53            inboxdir = appendSlash(inboxdir);
54            outgoingdir = appendSlash(outgoingdir);
55    
56    }
57    
58    
59  void SmsToolTransceiver::SendSms(std::string to, std::string message, bool allowMultipart)  void SmsToolTransceiver::SendSms(std::string to, std::string message, bool allowMultipart)
60  {  {
61            if (allowMultipart == false && message.size() > 160)
62                    message = message.substr(0,160);
63            
64    
65          std::string filename = CreateFilename();          std::string filename = CreateFilename();
66          Common::instance()->logMessage( std::string("Sending sms to: ") + to);          Logger::logMessage( std::string("Sending sms to: ") + to);
67    
68          string tempfile = "/var/spool/sms/";          string tempfile = outgoingdir + filename + ".LOCK";
         tempfile += filename;  
69    
70          string destfile = "/var/spool/sms/outgoing/";          string destfile = outgoingdir + filename;
         destfile += filename;  
71    
72          ofstream out( tempfile.c_str() );          ofstream out( tempfile.c_str() );
73          if (!out )          if (!out )
74          {          {
75                  Common::instance()->logMessage("SmsToolTransceiver:: could not create temp file");                  Logger::logMessage("SmsToolTransceiver:: could not create temp file");
76                  return;                  return;
77          }          }
78          out << "To: " << to << "\n\n" << message ;          out << "To: " << to << "\n\n" << message ;
79          out.close();          out.close();
80            
81            Common::instance()->smsCounter.outgoing++;
82    
83          int result = rename(tempfile.c_str(), destfile.c_str());          int result = rename(tempfile.c_str(), destfile.c_str());
84    
85          if (result)          if (result)
86                  Common::instance()->logMessage( string("SmsToolTransceiver could not spool file: ") + strerror(errno) );                  Logger::logMessage( string("SmsToolTransceiver could not spool file: ") + strerror(errno) );
87  }  }
88    
89  std::string SmsToolTransceiver::CreateFilename()  std::string SmsToolTransceiver::CreateFilename()
# Line 56  std::string SmsToolTransceiver::CreateFi Line 98  std::string SmsToolTransceiver::CreateFi
98    
99  std::vector<SMS> SmsToolTransceiver::ReadSms(bool readAll)  std::vector<SMS> SmsToolTransceiver::ReadSms(bool readAll)
100  {  {
         const std::string incoming = "/var/spool/sms/incoming/";  
101          std::vector<SMS> vec;          std::vector<SMS> vec;
102          DIR* dir = opendir( incoming.c_str() );          DIR* dir = opendir( inboxdir.c_str() );
103    
104          if (dir != 0)          if (dir != 0)
105          {          {
106                  dirent* entry;                  dirent* entry;
107                  while ( (entry = readdir(dir)) != 0)                  while ( (entry = readdir(dir)) != 0)
108                  {                  {
109                          if (entry->d_name[0] == '.')                          if (entry->d_name[0] == '.')
110                                  continue;                                  continue;
111                                                    Logger::logMessage( string("SmsTool::ReadSms >") +entry->d_name);
112    
113                          try                          try
114                          {                          {
115                                  SMS sms = ParseFile( incoming + entry->d_name);                                  SMS sms = ParseFile( inboxdir + entry->d_name);
116                                  vec.push_back(sms);                                  vec.push_back(sms);
117                          }                          }
118                          catch (std::exception& e)                          catch (std::exception& e)
119                          {                          {
120                                  Common::instance()->logMessage(e.what());                                  Logger::logMessage(e.what());
121                          }                          }
122    
123                          if (!readAll)                          if (!readAll)
# Line 84  std::vector<SMS> SmsToolTransceiver::Rea Line 126  std::vector<SMS> SmsToolTransceiver::Rea
126          }          }
127          else          else
128          {          {
129                  Common::instance()->logMessage( string("SmsToolTransceiver could open incoming dir ") + strerror(errno) );                  Logger::logMessage( string("SmsToolTransceiver could open inbox dir ") + strerror(errno) );
130          }          }
131            closedir(dir);
132    
133          return vec;          return vec;
134  }  }
135    
 void SmsToolTransceiver::DeleteSms(std::string smsIndex)  
 {  
 }  
136    
137  SMS SmsToolTransceiver::ParseFile(std::string path)  SMS SmsToolTransceiver::ParseFile(std::string path)
138  {  {
139          SMS sms;          SMS sms;
140            
141          string file = Util::readfile(path);          string file = Util::readfile(path);
142          int result = ::unlink(path.c_str());          int result = ::unlink(path.c_str());
143          if (result)          if (result)
144          {          {
145                  string message = "SmsTool> unlink ";                  string message = "SmsTool> unlink ";
146                  message += path;                  message += path;
147                  message += " failed: ";                  message += " failed: ";
148                  message += strerror(errno);                  message += strerror(errno);
149                  throw std::runtime_error( message );                  throw std::runtime_error( message );
# Line 112  SMS SmsToolTransceiver::ParseFile(std::s Line 152  SMS SmsToolTransceiver::ParseFile(std::s
152    
153          unsigned int pos = file.find("\n\n");          unsigned int pos = file.find("\n\n");
154    
155          if (pos != string::npos) {          if (pos != string::npos)
156            {
157                  string header = file.substr(0,pos);                  string header = file.substr(0,pos);
158                  string body = file.substr(pos+2,1024);                  string body = file.substr(pos+2,1024);
159    
# Line 121  SMS SmsToolTransceiver::ParseFile(std::s Line 162  SMS SmsToolTransceiver::ParseFile(std::s
162    
163                  ParseHeaders(header, sms);                  ParseHeaders(header, sms);
164    
165          } else {          }
166            else
167            {
168                  throw std::runtime_error("SmsTool: invalid incomming file");                  throw std::runtime_error("SmsTool: invalid incomming file");
169          }          }
170    
# Line 132  void SmsToolTransceiver::ParseHeaders(st Line 175  void SmsToolTransceiver::ParseHeaders(st
175  {  {
176          std::vector<std::string> headers = Util::str_split(headerstring, "\n");          std::vector<std::string> headers = Util::str_split(headerstring, "\n");
177    
178          for (unsigned int i=0; i<headers.size(); i++)          for (unsigned int i=0; i<headers.size(); i++)
179          {          {
180                  int pos = headers[i].find(":");                  unsigned int  pos = headers[i].find(":");
181                  string key = Util::str_trim( headers[i].substr(0,pos) );                  if (pos != string::npos)
182                  string val = Util::str_trim( headers[i].substr(pos+1) );                  {
183                            string key = Util::str_trim( headers[i].substr(0,pos) );
184                            string val = Util::str_trim( headers[i].substr(pos+1) );
185    
186                  if (key == "From")                          if (key == "From")
187                          sms.SetSender(val);                                  sms.SetSender(val);
188    
189                  if (key == "Received")                          if (key == "Received")
190                          sms.SetTimestamp(val);                                  sms.SetTimestamp(val);
191                    }
192                    else
193                    {
194                            Logger::logMessage(string("SmsTool: Invalid sms file header> ") + headers[i]);
195                    }
196          }          }
197    
198  }  }
199    
 int SmsToolTransceiver::DeleteAllSms()  
 {  
         return 0;  
 }  
200    
201    
Legend:
Removed from v.151  
changed lines
  Added in v.210
  ViewVC Help
Powered by ViewVC 1.1.20