test/test-gsm-receive.vala

   1 /*
   2  * test-gsm-receive - Play with receiving GSM data
   3  *
   4  * Copyright (C) 2010  Enrico Zini <enrico@enricozini.org>
   5  *
   6  * This program is free software; you can redistribute it and/or modify
   7  * it under the terms of the GNU General Public License as published by
   8  * the Free Software Foundation; either version 2 of the License, or
   9  * (at your option) any later version.
  10  *
  11  * This program is distributed in the hope that it will be useful,
  12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14  * GNU General Public License for more details.
  15  *
  16  * You should have received a copy of the GNU General Public License
  17  * along with this program; if not, write to the Free Software
  18  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  19  */
  20
  21 using GLib;
  22
  23 public DBus.Connection sbus;
  24
  25 //string VERSION = "0.1";
  26
  27 public class GSMReceive: Object //, zavai.Resource
  28 {
  29     public dynamic DBus.Object device;
  30     public dynamic DBus.Object network;
  31     public dynamic DBus.Object sim;
  32     public dynamic DBus.Object call;
  33
  34     public GSMReceive()
  35     {
  36         //zavai.gsm.gsm.request("GSMReceive");
  37
  38         device = sbus.get_object(
  39                     "org.freesmartphone.ogsmd",
  40                     "/org/freesmartphone/GSM/Device",
  41                     "org.freesmartphone.GSM.Device");
  42
  43         network = sbus.get_object(
  44             "org.freesmartphone.ogsmd",
  45             "/org/freesmartphone/GSM/Device",
  46             "org.freesmartphone.GSM.Network");
  47         sim = sbus.get_object(
  48             "org.freesmartphone.ogsmd",
  49             "/org/freesmartphone/GSM/Device",
  50             "org.freesmartphone.GSM.SIM");
  51
  52         call = sbus.get_object(
  53                 "org.freesmartphone.ogsmd",
  54                 "/org/freesmartphone/GSM/Device",
  55                 "org.freesmartphone.GSM.Call");
  56
  57         stderr.printf("Antenna is %s\n", device.GetAntennaPower() ? "on" : "off");
  58         stderr.printf("Signal strength: %d\n", network.GetSignalStrength());
  59         stderr.printf("Calling identification: %s\n", network.GetCallingIdentification());
  60         GLib.HashTable<string, GLib.Value?> status = network.GetStatus();
  61         stderr.printf("Network status:\n");
  62         dump_table(status);
  63
  64         network.Status += on_network_Status;
  65         network.SignalStrength += on_network_SignalStrength;
  66         call.CallStatus += on_call_Status;
  67         sim.IncomingStoredMessage += on_sim_IncomingStoredMessage;
  68     }
  69
  70     public void shutdown()
  71     {
  72         //zavai.gsm.gsm.release("GSMReceive");
  73     }
  74
  75     protected void dump_table(HashTable<string, Value?> vals)
  76     {
  77         vals.for_each((pk, pv) => {
  78                 string k = (string)pk;
  79                 Value? v = (Value?)pv;
  80                 stderr.printf("K: %s V: %s\n", k, v == null ? "(null)" : v.strdup_contents());
  81         });
  82     }
  83
  84     public void on_sim_IncomingStoredMessage(DBus.Object sender, int index)
  85     {
  86         stderr.printf("INCOMING STORED MESSAGE %d\n", index);
  87         dump_message(index);
  88     }
  89
  90     public void dump_message(int index)
  91     {
  92         string state, sender, msg;
  93         GLib.HashTable<string, GLib.Value?> info;
  94         sim.RetrieveMessage(index, out state, out sender, out msg, out info);
  95         stderr.printf("state: %s\n", state);
  96         stderr.printf("sender: %s\n", sender);
  97         stderr.printf("msg: %s\n", msg);
  98         dump_table(info);
  99     }
 100
 101     public void on_network_SignalStrength(DBus.Object sender, int strength)
 102     {
 103         stderr.printf("SIGNAL STRENGTH %d\n", strength);
 104     }
 105
 106     public void on_network_Status(DBus.Object sender, HashTable<string, Value?> status)
 107     {
 108         stderr.printf("NETWORK STATUS\n");
 109         dump_table(status);
 110
 111         // dbg("cbNetworkStatus %s" % formatDict(status))
 112     }
 113
 114     public void on_call_Status(DBus.Object sender, int index, string status, HashTable<string, Value?> properties)
 115     {
 116         stderr.printf("CALL STATUS %d %s\n", index, status);
 117         dump_table(properties);
 118         /*
 119         dbg("cbCallStatus %d, %s, %s" % (id, status, formatDict(properties)))
 120         self.status = status
 121         if status == "incoming":
 122             if "peer" in properties and properties["peer"] == "+358942832031":
 123                 self.gsm_call_iface.ReleaseAll()
 124                 os.system("kapula-debug-call-handler &")
 125             else:
 126                 os.system("alsactl restore -f /etc/alsa-scenarios/stereoout-maxvolume.state")
 127                 os.system("vibrator-start")
 128                 os.system("ringtone-start")
 129                 os.system("ledctrl --on-time 400 --off-time 200 gta02-aux:red");
 130         if status == "release":
 131             os.system("ringtone-stop")
 132             os.system("vibrator-stop")
 133             os.system("ledctrl --off gta02-aux:red");
 134         */
 135     }
 136
 137
 138 /*
 139         def onIncomingUssd( self, mode, message ):
 140                 logger.info( "USSD Message: %s" % message )
 141                         self.main.groups["alert"].activate( "<title>Operator Message</title>%s" % message, [("OK")] )
 142     def onCallStatus( self, id, status, properties ):
 143         self.call = id
 144         self.update_status(status)
 145         if not status in ["release"]:
 146             if "peer" in properties:
 147                 self.part_text_set( "label", self.main.groups["contacts"].tryNumberToName( properties[ "peer" ] ) )
 148                 self.part_text_set( "sublabel", properties[ "peer" ] )
 149             else:
 150                 self.part_text_set( "label", _("unknown number") )
 151                 self.part_text_set( "sublabel", "" )
 152
 153     @edje.decorators.signal_callback( "mouse,clicked,1", "button_*" )
 154     def on_edje_signal_dialer_button_pressed(self, emission, source):
 155         key = source.split("_", 1)[1]
 156         if key in ("0", "1", "2", "3", "4", "5", "6", "7", "8", "9"):
 157             dbus_object.gsm_call_iface.SendDtmf( key )
 158             self.text.append(key)
 159         elif key in "star":
 160             dbus_object.gsm_call_iface.SendDtmf( "*" )
 161             self.text.append("*")
 162         elif key in "hash":
 163             dbus_object.gsm_call_iface.SendDtmf( "#" )
 164             self.text += "#"
 165         # The trailing whitespace is a workaround for the one char invisible
 166         # bug due to some problems with scaling of text parts.
 167         self.part_text_set("label", "".join(self.text)+" ")
 168
 169     @edje.decorators.signal_callback("call_button_pressed", "button_right")
 170     def on_edje_signal_call_button_right_pressed(self, emission, source):
 171         self.main.transition_to("call")
 172
 173     def sendMessage( self, index ):
 174         logger.info( "trying to send message w/ index %d..." % index )
 175         dbus_object.gsm_sim_iface.SendStoredMessage( index, reply_handler=self.cbSendReply, error_handler=self.cbSendError )
 176
 177     def cbSendReply( self, reference, timestamp ):
 178         logger.info( "sent message successfully w/ reference number %d (timestamp: %s)" % ( reference, timestamp ) )
 179
 180     def cbSendError( self, e ):
 181         logger.error( "could not send message. leaving in outgoing. error was: %s" % e )
 182
 183     def cbStoreReply( self, result ):
 184         logger.info( "stored message lives at SIM position %d" % result )
 185         self.sendMessage( result )
 186         if not self.busy:
 187             dbus_object.gsm_sim_iface.RetrieveMessagebook(
 188                 "all",
 189                 reply_handler=self.cbMessagebookReply,
 190                 error_handler=self.cbMessagebookError
 191             )
 192             self.busy = True
 193
 194     def cbStoreError( self, e ):
 195         logger.warning( "error while storing message - %s" % e.get_dbus_name() )
 196         if e.get_dbus_name() == "org.freesmartphone.GSM.SIM.MemoryFull":
 197             self.main.groups["alert"].activate( "<title>Failed to send message</title>SIM Memory Full", [("OK")] )
 198
 199     def cbSend1( self, selected, cb_data ):
 200         self.main.groups["text_edit"].setup(
 201             "sms",
 202             "", # text
 203             selected[0], # title
 204             selected[1], # reference
 205             self.cbSend2
 206         )
 207
 208     def cbSend2( self, text, number ):
 209         if dbus_object.gsm_device_obj:
 210             dbus_object.gsm_sim_iface.StoreMessage(
 211                 number, text, {},
 212                 reply_handler=self.cbStoreReply,
 213                 error_handler=self.cbStoreError
 214             )
 215
 216     def cbDelete( self, result, reference ):
 217         if result == "abort":
 218             return
 219         if dbus_object.gsm_device_obj:
 220             dbus_object.gsm_sim_iface.DeleteMessage(
 221                 reference
 222             )
 223         for i in range( len( self.messagebook ) ):
 224             if self.messagebook[i][0] == reference:
 225                 del self.messagebook[i]
 226                 break
 227         self.updateList()
 228
 229     def cbForward( self, selected, text ):
 230         if dbus_object.gsm_device_obj:
 231             dbus_object.gsm_sim_iface.StoreMessage(
 232                 selected[1], text, {},
 233                 reply_handler=self.cbStoreReply,
 234                 error_handler=self.cbStoreError
 235             )
 236
 237     def cbReply( self, text, number):
 238         if dbus_object.gsm_device_obj:
 239             dbus_object.gsm_sim_iface.StoreMessage(
 240                 number, text, {},
 241                 reply_handler=self.cbStoreReply,
 242                 error_handler=self.cbStoreError
 243             )
 244
 245     def cbMenu( self, result ):
 246         if result == _("send"):
 247             self.main.groups["contacts"].prepare()
 248             if self.main.groups["contacts"].ready:
 249                 self.main.groups["list_choose"].setup(
 250                     "sms",
 251                     [ (x[1], x[2]) for x in  self.main.groups["contacts"].phonebook],
 252                     None,
 253                     self.cbSend1
 254                 )
 255         elif result == _("delete"):
 256             self.main.groups["alert"].activate(
 257                 _("delete?"),
 258                 (_("abort"), _("delete")),
 259                 self.current[self.selected][0], # reference
 260                 self.cbDelete
 261             )
 262         elif result == _("forward"):
 263             self.main.groups["contacts"].prepare()
 264             if self.main.groups["contacts"].ready:
 265                 self.main.groups["list_choose"].setup(
 266                     "sms",
 267                     [ (x[1], x[2] ) for x in  self.main.groups["contacts"].phonebook],
 268                     self.current[self.selected][3],
 269                     self.cbForward
 270                 )
 271         elif result == _("reply"):
 272             self.main.groups["text_edit"].setup(
 273                 "sms",
 274                 "", # text
 275                 self.current[self.selected][2], # title = number
 276                 self.current[self.selected][2], # reference = number
 277                 self.cbReply
 278             )
 279
 280     def cbMessagebookReply( self, result ):
 281         logger.info( "retrieved messagebook: %s" % result )
 282         self.busy = False
 283         self.messagebook = result
 284         self.ready = True
 285         self.updateList()
 286         self.main.groups["main"].targets["sms"] = True
 287         self.main.groups["main"].update()
 288         if not self.newindex is None:
 289             message = [x for x in self.messagebook if x[0] == self.newindex]
 290             self.newindex = None
 291             if message and self.main.current_group == self.main.groups["main"]:
 292                 message = message[0]
 293                 if "read" in message[1]:
 294                     from_to = _("From")
 295                     timestamp = message[4]["timestamp"]
 296                 else:
 297                     from_to = _("To")
 298                     timestamp = _("Unknown")
 299                 from_text = self.main.groups["contacts"].tryNumberToName( message[2] )
 300                 self.main.groups["text_show"].setup(
 301                     "sms",
 302                     _("%s: %s<br>Date: %s<p>%s") % (
 303                         from_to,
 304                         from_text,
 305                         timestamp,
 306                         textblock_escape( message[3] ).replace( '\n', '<br>' )
 307                     )
 308                 )
 309             if dbus_object.gsm_device_obj:
 310                 messagebookInfo = dbus_object.gsm_sim_iface.GetMessagebookInfo()
 311                 if messagebookInfo["used"] == messagebookInfo["last"]:
 312                     self.main.groups["alert"].activate( "<title>Warning</title>SIM Memory Full", [("OK")] )
 313
 314     def cbMessagebookError( self, e ):
 315         logger.warning( "error while retrieving messagebook" )
 316         self.busy = False
 317
 318     def onIncomingMessage( self, index ):
 319         logger.info( "new message! Retrieving messagebook..." )
 320         self.newindex = index
 321         if not self.busy:
 322             dbus_object.gsm_sim_iface.RetrieveMessagebook(
 323                 "all",
 324                 reply_handler=self.cbMessagebookReply,
 325                 error_handler=self.cbMessagebookError
 326             )
 327             self.busy = True
 328
 329     def prepare( self ):
 330         if not self.ready and not self.busy:
 331             if dbus_object.gsm_device_obj:
 332                 logger.info( "retrieving messagebook..." )
 333                 dbus_object.gsm_sim_iface.RetrieveMessagebook(
 334                     "all",
 335                     reply_handler=self.cbMessagebookReply,
 336                     error_handler=self.cbMessagebookError
 337                 )
 338                 self.busy = True
 339             else:
 340                 # Fake messagebook...
 341                 self.cbMessagebookReply( [
 342                     (0, "read", "+4544555", "Hello World!"),
 343                     (1, "read", "+456663443", "Zhone!"),
 344                     (2, "read", "+456663443", "Hi Guy\nGuess what, I now "+
 345                         "know to write multi-line SMSs.\nIsn't that "+
 346                         "nice?\n\nSome Buddy"),
 347                     (3, "read", "Flash SMS", "An SMS without digits. Strange, isn't it?"),
 348                 ] )
 349
 350     def onReadyStatus( self, status ):
 351         logger.debug( "SIM is ready: %s" % status )
 352         if status:
 353             # Force update
 354             self.ready = False
 355             self.prepare()
 356
 357     def onShow( self ):
 358         self.prepare()
 359         self.updateList()
 360
 361     def updateList( self):
 362         self.main.groups["contacts"].prepare()
 363         self.pages = max( ( len( self.messagebook ) - 1 ) / 6 + 1, 1 )
 364         if self.page >= self.pages:
 365             self.page = self.pages - 1
 366         if self.page < 0:
 367             self.page = 0
 368         self.current = self.messagebook[self.page*6:(self.page+1)*6]
 369         text = u"".join( [u"□"]*self.page+[u"▣"]+[u"□"]*(self.pages-self.page-1) )
 370         self.part_text_set( "pager", text )
 371         for i in range( 0, len( self.current ) ):
 372             main_text = self.main.groups["contacts"].tryNumberToName( self.current[i][2] )
 373             self.part_text_set( "label_main_list_%i" % i, main_text )
 374             sub_text = " ".join(self.current[i][3].splitlines())
 375             self.part_text_set( "label_sub_list_%i" % i, u"(%s) %s" % ( self.current[i][1], sub_text ) )
 376         for i in range( len( self.current ), 6):
 377             self.part_text_set( "label_main_list_%i" % i, u"" )
 378             self.part_text_set( "label_sub_list_%i" % i, u"" )
 379         self.selected = None
 380         for i in range( 6 ):
 381             self.signal_emit( "deactivate_target_list_%i" % i, "" )
 382
 383
 384     @edje.decorators.signal_callback( "mouse,clicked,1", "target_list_*" )
 385     def on_edje_signal_button_list_pressed( self, emission, source ):
 386         id = int( source.split( "_" )[-1] )
 387         if self.selected == id:
 388             return
 389         if self.selected is not None:
 390             self.signal_emit( "deactivate_target_list_%i" % self.selected, "" )
 391         self.signal_emit( "activate_target_list_%i" % id, "" )
 392         self.selected = id
 393
 394     @edje.decorators.signal_callback( "mouse,clicked,1", "button_action_left" )
 395     def on_edje_signal_button_action_left_pressed( self, emission, source ):
 396         self.page -= 1
 397         self.updateList()
 398
 399     @edje.decorators.signal_callback( "mouse,clicked,1", "button_action_right" )
 400     def on_edje_signal_button_action_right_pressed( self, emission, source ):
 401         self.page += 1
 402         self.updateList()
 403
 404     @edje.decorators.signal_callback( "mouse,clicked,1", "button_action_open" )
 405     def on_edje_signal_button_action_open_pressed( self, emission, source ):
 406         if self.selected is not None:
 407             if "read" in self.current[self.selected][1]:
 408                 from_to = _("From")
 409                 timestamp = self.current[self.selected][4]["timestamp"]
 410             else:
 411                 from_to = _("To")
 412                 timestamp = _("Unknown")
 413             from_text = self.main.groups["contacts"].tryNumberToName( self.current[self.selected][2] )
 414             self.main.groups["text_show"].setup(
 415                 "sms",
 416                 _("%s: %s<br>Date: %s<p>%s") % (
 417                     from_to,
 418                     from_text,
 419                     timestamp,
 420                     textblock_escape( self.current[self.selected][3] ).replace( '\n', '<br>' )
 421                 )
 422             )
 423
 424     @edje.decorators.signal_callback( "mouse,clicked,1", "button_bottom_middle" )
 425     def on_edje_signal_button_bottom_middle_pressed( self, emission, source ):
 426         self.main.groups["menu"].activate( ( _("send"), _("delete"), _("forward"), _("reply") ), self.cbMenu )
 427         self.main.groups["menu"].part_text_set( "target_label_cancel", _("cancel") )
 428 */
 429 }
 430
 431 static int main (string[] args) {
 432         Gtk.init (ref args);
 433     // Gst.init (ref args);
 434
 435         // Set up zavai
 436         sbus = DBus.Bus.get(DBus.BusType.SYSTEM);
 437
 438     // Core infrastructure
 439 //      zavai.config = new zavai.Config();
 440 //      zavai.config.argv0 = args[0];
 441 //      zavai.registry = new zavai.Registry();
 442
 443     // Additional infrastructure
 444         //zavai.gsm.init();
 445         //zavai.log.init();
 446
 447     // PLAY here
 448     var gr = new GSMReceive();
 449
 450         if (args.length > 1)
 451                 gr.dump_message(args[1].to_int());
 452
 453         Gtk.main();
 454
 455         // zavai.info("Shutting down")
 456         // zavai.registry.shutdown();
 457
 458         return 0;
 459 }