aprs.py
  1. # -*- coding: UTF-8 -*-
  2. # Copyright (C) 2008, Jack Zielke <jack@linuxcoffee.com>
  3. # Copyright (C) 2008, One Laptop Per Child
  4. #
  5. # This program is free software; you can redistribute it and/or modify
  6. # it under the terms of the GNU General Public License as published by
  7. # the Free Software Foundation; either version 2 of the License, or
  8. # (at your option) any later version.
  9. #
  10. # This program is distributed in the hope that it will be useful,
  11. # but WITHOUT ANY WARRANTY; without even the implied warranty of
  12. # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13. # GNU General Public License for more details.
  14. #
  15. # You should have received a copy of the GNU General Public License
  16. # along with this program; if not, write to the Free Software
  17. # Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
  18.  
  19. import gtk
  20. import pango
  21. import time
  22. import socket
  23. import random
  24. import gobject
  25. import json
  26.  
  27. from gettext import gettext as _
  28.  
  29. from sugar import profile
  30. from sugar.activity import activity
  31. from sugar.bundle.activitybundle import ActivityBundle
  32. from sugar.graphics.menuitem import MenuItem
  33. from sugar.graphics.toolbutton import ToolButton
  34.  
  35. HOST = 'rotate.aprs2.net'
  36. #HOST = '192.168.50.6'
  37. PORT = 14580
  38. RECV_BUFFER = 4096
  39.  
  40. MAXLINES = 50
  41. MAXRETRIES = 15
  42. MAX_MSG_QUEUE = 25
  43. MAX_PER_CALL_QUEUE = 2
  44.  
  45. FILTER = "m/300"
  46.  
  47. bundle = ActivityBundle(activity.get_bundle_path())
  48. VERSION = bundle.get_activity_version()
  49. del bundle
  50.  
  51. class APRSActivity(activity.Activity):
  52.     def __init__(self, handle):
  53.         activity.Activity.__init__(self, handle)
  54.         self.set_title(_('APRS-XO Activity'))
  55.  
  56.         self.sock = None
  57.         self.location = "home"
  58.         self.sent_acks = {}
  59.         self.recv_acks = {}
  60.         self.timers = []
  61.         self.bulletins = ["AIR", "DGPS", "QST", "TEL", "ALL", "DRILL", "QTH", "TEST", "AP", "DX", "RTCM", "TLM", "BEACON", "ID", "SKY", "WX", "CQ", "JAVA", "SPACE", "ZIP", "GPS", "MAIL", "SPC", "DF", "MICE", "SYM", "BLN", "NWS", "NTS"]
  62.         self.validating = False
  63.         self.help = True
  64.         self.messagebox = False
  65.         self.sequence = random.randrange(0, 7000)
  66.         self.queue_list = {}
  67.         self.message_list = {}
  68.         self.seen_bulletins = {}
  69.         self.message_marks = {}
  70.         self.input_watch = []
  71.         self.output_watch = []
  72.         self.cq_watch = []
  73.         self.current_message = {}
  74.  
  75.         titlefont = pango.FontDescription('Sans bold 8')
  76.         mediumfont = pango.FontDescription('Sans 6.5')
  77.         smallfont = pango.FontDescription('Sans 6')
  78.         verysmallfont = pango.FontDescription('Sans 4')
  79.  
  80.         firstName = profile.get_nick_name().split(None, 1)[0].capitalize()
  81.  
  82.         toolbox = activity.ActivityToolbox(self)
  83.         self.set_toolbox(toolbox)
  84.  
  85.         activity_toolbar = toolbox.get_activity_toolbar()
  86.         activity_toolbar.share.props.visible = False
  87.  
  88.         toolbox.show()
  89.  
  90.         win = gtk.HBox(False, 10)
  91.  
  92.         leftwin = gtk.VBox(False, 10)
  93.  
  94.         # Top 'about' box
  95.         aboutbox = gtk.VBox(False, 11)
  96.         aboutbox.set_border_width(10)
  97.  
  98.         topaboutbox = gtk.VBox(False, 0)
  99.  
  100.         titlebox = gtk.HBox(False, 0)
  101.         titlelabel = gtk.Label("APRS-XO:")
  102.         titlelabel.set_alignment(0, 0)
  103.         titlelabel.modify_font(titlefont)
  104.         titlebox.pack_start(titlelabel, False, False, 0)
  105.         titlelabel.show()
  106.         aboutlabel1 = gtk.Label("This amateur radio program will update your")
  107.         aboutlabel1.set_alignment(0, 0.8)
  108. #        aboutlabel1.modify_font(mediumfont)
  109.         titlebox.pack_start(aboutlabel1, False, False, 0)
  110.         aboutlabel1.show()
  111.         topaboutbox.pack_start(titlebox, False, False, 0)
  112.         titlebox.show()
  113.         aboutlabel2 = gtk.Label("positon & status on all of the global APRS web pages once\nevery 10 minutes.")
  114.         aboutlabel2.set_alignment(0, 0)
  115. #        aboutlabel2.modify_font(mediumfont)
  116.         topaboutbox.pack_start(aboutlabel2, False, False, 0)
  117.         aboutlabel2.show()
  118.         aboutbox.pack_start(topaboutbox, False, False, 0)
  119.         topaboutbox.show()
  120.  
  121.         sitebox = gtk.HBox(False, 10)
  122.         sitelabel = gtk.Label("Select an APRS site:")
  123.         sitelabel.set_alignment(0, 0.4)
  124.         sitebox.pack_start(sitelabel, False, False, 0)
  125.         sitelabel.show()
  126.  
  127.         findubutton = gtk.Button()
  128.         findubutton.set_label("FINDU.COM")
  129.         findubutton.connect("clicked", self.open_url_button, "http://www.findu.com/cgi-bin/symbol.cgi?icon=XA&limit=200")
  130.         sitebox.pack_start(findubutton, False, False, 0)
  131.         findubutton.show()
  132.  
  133.         aprsworldbutton = gtk.Button()
  134.         aprsworldbutton.set_label("APRSworld")
  135.         aprsworldbutton.connect("clicked", self.open_url_button, "http://aprsworld.net/")
  136.         sitebox.pack_start(aprsworldbutton, False, False, 0)
  137.         aprsworldbutton.show()
  138.  
  139.         otherbutton = gtk.Button()
  140.         otherbutton.set_label("About")
  141.         otherbutton.connect("clicked", self.open_url_button, "http://aprs.org/")
  142.         sitebox.pack_start(otherbutton, False, False, 0)
  143.         otherbutton.show()
  144.  
  145.         aboutbox.pack_start(sitebox, False, False, 0)
  146.         sitebox.show()
  147.  
  148.         leftwin.pack_start(aboutbox, False, False, 0)
  149.         aboutbox.show()
  150.  
  151.         separator = gtk.HSeparator()
  152.         leftwin.pack_start(separator, False, False, 0)
  153.         separator.show()
  154.  
  155.         # identifiers box
  156.         identbox = gtk.VBox(False, 4)
  157.         identbox.set_border_width(10)
  158.  
  159.         identlabel = gtk.Label("Identifiers")
  160.         identlabel.set_alignment(0, 0)
  161.         identlabel.modify_font(titlefont)
  162.         identbox.pack_start(identlabel, False, False, 0)
  163.         identlabel.show()
  164.  
  165.         bottomidentbox = gtk.HBox(False, 5)
  166.  
  167.         calllabel1 = gtk.Label("Callsign: ")
  168.         calllabel1.set_alignment(1, 0.5)
  169.         bottomidentbox.pack_start(calllabel1, False, False, 0)
  170.         calllabel1.show()
  171.  
  172.         self.calltext = gtk.Entry()
  173.         self.calltext.set_max_length(9)
  174.         self.calltext.set_width_chars(9)
  175.         self.calltext.set_text(self.metadata.get('callsign', ""))
  176.         self.calltext.connect("changed", self.disable_beacon)
  177.         bottomidentbox.pack_start(self.calltext, False, False, 0)
  178.         self.calltext.show()
  179.  
  180.         passlabel1 = gtk.Label("Password: ")
  181.         passlabel1.set_alignment(1, 0.5)
  182.         bottomidentbox.pack_start(passlabel1, False, False, 0)
  183.         passlabel1.show()
  184.  
  185.         self.passtext = gtk.Entry()
  186.         self.passtext.set_max_length(5)
  187.         self.passtext.set_width_chars(5)
  188.         self.passtext.set_invisible_char("x")
  189.         self.passtext.set_visibility(False)
  190.         bottomidentbox.pack_start(self.passtext, False, False, 0)
  191.         self.passtext.show()
  192.  
  193.         self.passbutton = gtk.CheckButton()
  194.         self.passbutton.set_active(True)
  195.         self.passbutton.connect("toggled", self.hide_password, "password")
  196.         bottomidentbox.pack_start(self.passbutton, False, False, 0)
  197.         self.passbutton.show()
  198.  
  199.         passbuttonbox = gtk.VBox(False, 0)
  200.  
  201.         passlabel3 = gtk.Label("Hide")
  202.         passlabel3.set_alignment(0.5, 0.5)
  203.         passlabel3.modify_font(smallfont)
  204.         passbuttonbox.pack_start(passlabel3, False, False, 0)
  205.         passlabel3.show()
  206.  
  207.         passlabel4 = gtk.Label("Password")
  208.         passlabel4.set_alignment(0, 0.5)
  209.         passlabel4.modify_font(smallfont)
  210.         passbuttonbox.pack_start(passlabel4, False, False, 0)
  211.         passlabel4.show()
  212.  
  213.         bottomidentbox.pack_start(passbuttonbox, False, False, 0)
  214.         passbuttonbox.show()
  215.  
  216.         identbox.pack_start(bottomidentbox, False, False, 0)
  217.         bottomidentbox.show()
  218.  
  219.         passlabel2 = gtk.Label("optional")
  220.         passlabel2.set_alignment(0.71, 0)
  221.         passlabel2.modify_font(smallfont)
  222.         identbox.pack_start(passlabel2, False, False, 0)
  223.         passlabel2.show()
  224.  
  225.         leftwin.pack_start(identbox, False, False, 0)
  226.         identbox.show()
  227.  
  228.         separator = gtk.HSeparator()
  229.         leftwin.pack_start(separator, False, False, 0)
  230.         separator.show()
  231.  
  232.         # station box
  233.         stationbox = gtk.VBox(False, 11)
  234.         stationbox.set_border_width(10)
  235.  
  236.         stationlabel = gtk.Label("Station Comment")
  237.         stationlabel.set_alignment(0, 0)
  238.         stationlabel.modify_font(titlefont)
  239.         stationbox.pack_start(stationlabel, False, False, 0)
  240.         stationlabel.show()
  241.  
  242.         # so the text box does not fill all horizontal space
  243.         stationtextbox = gtk.HBox()
  244.  
  245.         self.stationtext = gtk.Entry()
  246.         self.stationtext.set_max_length(43)
  247.         self.stationtext.set_width_chars(43)
  248.         self.stationtext.set_text("%s's XO at home." % firstName)
  249.         self.stationtext.connect("changed", self.disable_beacon)
  250.         stationtextbox.pack_start(self.stationtext, False, False, 0)
  251.         self.stationtext.show()
  252.         stationbox.pack_start(stationtextbox, False, False, 0)
  253.         stationtextbox.show()
  254.  
  255.         stationhelp = gtk.Label("Optional description of current position, status,\nor destination.  Enter up to 43 characters, most\nimportant first since some displays can only see\nthe first 20 or 28.")
  256.         stationhelp.set_alignment(0, 0)
  257. #        stationhelp.modify_font(mediumfont)
  258.         stationbox.pack_start(stationhelp, False, False, 0)
  259.         stationhelp.show()
  260.  
  261.         leftwin.pack_start(stationbox, False, False, 0)
  262.         stationbox.show()
  263.  
  264.         separator = gtk.HSeparator()
  265.         leftwin.pack_start(separator, False, False, 0)
  266.         separator.show()
  267.  
  268.         # position box
  269.         positbox = gtk.VBox(False, 11)
  270.         positbox.set_border_width(10)
  271.  
  272.         toppositbox = gtk.HBox(False, 0)
  273.  
  274.         topleftpositbox = gtk.VBox(False, 4)
  275.  
  276.         positlabel1 = gtk.Label("Position Data")
  277.         positlabel1.set_alignment(0, 0)
  278.         positlabel1.modify_font(titlefont)
  279.         topleftpositbox.pack_start(positlabel1, False, False, 0)
  280.         positlabel1.show()
  281.  
  282.         latpositbox = gtk.HBox(False, 4)
  283.         latlabel1 = gtk.Label("Latitude:    ")
  284.         latlabel1.set_alignment(0, 0.5)
  285.         latpositbox.pack_start(latlabel1, False, False, 0)
  286.         latlabel1.show()
  287.  
  288.         self.latDDtext = gtk.Entry()
  289.         self.latDDtext.set_max_length(2)
  290.         self.latDDtext.set_width_chars(4)
  291.         self.latDDtext.set_text("DD")
  292.         self.latDDtext.connect("changed", self.disable_beacon)
  293.         latpositbox.pack_start(self.latDDtext, False, False, 0)
  294.         self.latDDtext.show()
  295.  
  296.         self.latMMtext = gtk.Entry()
  297.         self.latMMtext.set_max_length(2)
  298.         self.latMMtext.set_width_chars(3)
  299.         self.latMMtext.set_text("MM")
  300.         self.latMMtext.connect("changed", self.disable_beacon)
  301.         latpositbox.pack_start(self.latMMtext, False, False, 0)
  302.         self.latMMtext.show()
  303.  
  304.         latlabel2 = gtk.Label(".")
  305.         latlabel2.set_alignment(0, 1)
  306.         latpositbox.pack_start(latlabel2, False, False, 0)
  307.         latlabel2.show()
  308.  
  309.         self.latmmtext = gtk.Entry()
  310.         self.latmmtext.set_max_length(2)
  311.         self.latmmtext.set_width_chars(3)
  312.         self.latmmtext.set_text("mm")
  313.         self.latmmtext.connect("changed", self.disable_beacon)
  314.         latpositbox.pack_start(self.latmmtext, False, False, 0)
  315.         self.latmmtext.show()
  316.  
  317.         self.latcombo = gtk.combo_box_new_text()
  318.         self.latcombo.append_text("N")
  319.         self.latcombo.append_text("S")
  320.         self.latcombo.set_active(0)
  321.         latpositbox.pack_start(self.latcombo, False, False, 0)
  322.         self.latcombo.show()
  323.  
  324.         topleftpositbox.pack_start(latpositbox, False, False, 0)
  325.         latpositbox.show()
  326.  
  327.         lonpositbox = gtk.HBox(False, 4)
  328.         lonlabel1 = gtk.Label("Longitude: ")
  329.         lonlabel1.set_alignment(0, 0.5)
  330.         lonpositbox.pack_start(lonlabel1, False, False, 0)
  331.         lonlabel1.show()
  332.  
  333.         self.lonDDDtext = gtk.Entry()
  334.         self.lonDDDtext.set_max_length(3)
  335.         self.lonDDDtext.set_width_chars(4)
  336.         self.lonDDDtext.set_text("DDD")
  337.         self.lonDDDtext.connect("changed", self.disable_beacon)
  338.         lonpositbox.pack_start(self.lonDDDtext, False, False, 0)
  339.         self.lonDDDtext.show()
  340.  
  341.         self.lonMMtext = gtk.Entry()
  342.         self.lonMMtext.set_max_length(2)
  343.         self.lonMMtext.set_width_chars(3)
  344.         self.lonMMtext.set_text("MM")
  345.         self.lonMMtext.connect("changed", self.disable_beacon)
  346.         lonpositbox.pack_start(self.lonMMtext, False, False, 0)
  347.         self.lonMMtext.show()
  348.  
  349.         lonlabel2 = gtk.Label(".")
  350.         lonlabel2.set_alignment(0, 1)
  351.         lonpositbox.pack_start(lonlabel2, False, False, 0)
  352.         lonlabel2.show()
  353.  
  354.         self.lonmmtext = gtk.Entry()
  355.         self.lonmmtext.set_max_length(2)
  356.         self.lonmmtext.set_width_chars(3)
  357.         self.lonmmtext.set_text("mm")
  358.         self.lonmmtext.connect("changed", self.disable_beacon)
  359.         lonpositbox.pack_start(self.lonmmtext, False, False, 0)
  360.         self.lonmmtext.show()
  361.  
  362.         self.loncombo = gtk.combo_box_new_text()
  363.         self.loncombo.append_text("W")
  364.         self.loncombo.append_text("E")
  365.         self.loncombo.set_active(0)
  366.         lonpositbox.pack_start(self.loncombo, False, False, 0)
  367.         self.loncombo.show()
  368.  
  369.         topleftpositbox.pack_start(lonpositbox, False, False, 0)
  370.         lonpositbox.show()
  371.  
  372.         toppositbox.pack_start(topleftpositbox, False, False, 0)
  373.         topleftpositbox.show()
  374.  
  375.         toprightpositbox = gtk.VBox(False, 4)
  376.         toprightpositbox.set_border_width(10)
  377.  
  378.         loclabel = gtk.Label("-OR- Zip Code:")
  379.         loclabel.set_alignment(0.3, 0)
  380.         toprightpositbox.pack_start(loclabel, False, False, 0)
  381.         loclabel.show()
  382.  
  383.         self.ziptext = gtk.Entry()
  384.         self.ziptext.set_max_length(5)
  385.         self.ziptext.set_width_chars(5)
  386.         self.ziptext.connect("changed", self.disable_beacon)
  387.         toprightpositbox.pack_start(self.ziptext, False, False, 0)
  388.         self.ziptext.show()
  389.  
  390.         toppositbox.pack_start(toprightpositbox, False, False, 0)
  391.         toprightpositbox.show()
  392.  
  393.         positbox.pack_start(toppositbox, False, False, 0)
  394.         toppositbox.show()
  395.  
  396.         positlabel2 = gtk.Label("If you do not know your LAT/LONG then your zip code will\nbe used to place you on the map.")
  397.         positlabel2.set_alignment(0, 0)
  398. #        positlabel2.modify_font(mediumfont)
  399.         positbox.pack_start(positlabel2, False, False, 0)
  400.         positlabel2.show()
  401.  
  402.         leftwin.pack_start(positbox, False, False, 0)
  403.         positbox.show()
  404.  
  405.         separator = gtk.HSeparator()
  406.         leftwin.pack_start(separator, False, False, 0)
  407.         separator.show()
  408.  
  409.         # defined here so clear and connect buttons have access
  410.         self.statusview = gtk.TextView()
  411.         self.statusbuffer = self.statusview.get_buffer()
  412.         self.messageview = gtk.TextView()
  413.         self.messagebuffer = self.messageview.get_buffer()
  414.  
  415.         self.connectbutton = gtk.Button()
  416.         self.connectbutton.set_label("Connect")
  417.         self.connectbutton.modify_bg(gtk.STATE_NORMAL, gtk.gdk.color_parse("#00b20d"))
  418.         self.connectbutton.connect("clicked", self.connect_aprs)
  419.         leftwin.pack_start(self.connectbutton, False, False, 12)
  420.         self.connectbutton.show()
  421.  
  422.         win.pack_start(leftwin, False, False, 0)
  423.         leftwin.show()
  424.  
  425.         rightwin = gtk.VBox(False, 4)
  426.         rightwin.set_border_width(4)
  427.  
  428.         rightwintopbox = gtk.HBox(False, 4)
  429.  
  430.         clearbutton = gtk.Button()
  431. #        clearbutton.set_label(" Cancel Messages ")
  432. #        clearbutton.connect("clicked", self.clear_msg_queue)
  433.         clearbutton.set_label(" Clear/Cancel ")
  434.         clearbutton.connect("clicked", self.clear_message_button)
  435.         rightwintopbox.pack_start(clearbutton, False, False, 5)
  436.         clearbutton.show()
  437.  
  438.         self.cqbutton = gtk.CheckButton("CQ")
  439.         self.cqbutton.set_active(False)
  440.         self.cqbutton.connect("toggled", self.enable_cq, "cq")
  441.         rightwintopbox.pack_start(self.cqbutton, False, False, 5)
  442.         self.cqbutton.show()
  443.  
  444.         self.beaconbutton = gtk.CheckButton("Beacon every 10 minutes")
  445.         self.beaconbutton.set_active(True)
  446.         self.beaconbutton.connect("toggled", self.enable_beacon, "beacon")
  447.         rightwintopbox.pack_start(self.beaconbutton, False, False, 5)
  448.         self.beaconbutton.show()
  449.  
  450.         rightwin.pack_start(rightwintopbox, False, False, 0)
  451.         rightwintopbox.show()
  452.  
  453.         self.messageview.set_editable(False)
  454.         self.messageview.set_cursor_visible(True)
  455.         self.messageview.set_wrap_mode(gtk.WRAP_CHAR)
  456.         self.messageview.set_justification(gtk.JUSTIFY_LEFT)
  457.         self.messageview.modify_font(smallfont)
  458.  
  459.         self.messagebuffer.set_text("Welcome to APRS-XO.\n\nThis program sends your position information to a server that\nwill display your location on a webpage.  This program requires an active Internet connection to work.\n\nSelect an APRS Site\nSelecting a button will copy the URI to the journal.\n\nIndentifiers\nEnter your callsign.  If you leave the password blank it will be\nautomatically generated.\n\nStation Comment\nData in the Station Comment field will appear after your\nlocation information on the website.")
  460.  
  461.         # tags for easier reading of messages
  462.         self.messagebold = self.messagebuffer.create_tag("bold", weight=pango.WEIGHT_BOLD)
  463.  
  464.         self.messagewindow = gtk.ScrolledWindow()
  465.         self.messagewindow.set_policy(gtk.POLICY_AUTOMATIC, gtk.POLICY_ALWAYS)
  466.         self.messagewindow.add(self.messageview)
  467.         self.messageview.show()
  468.         rightwin.pack_start(self.messagewindow, True, True, 0)
  469.         self.messagewindow.show()
  470.  
  471.         messagebox = gtk.HBox(False, 4)
  472.  
  473.         self.messagecombo = gtk.combo_box_entry_new_text()
  474.         self.messagecombo.append_text("ALL")
  475.         self.messagecombo.append_text("BEACON")
  476.         self.messagecombo.append_text("CQ")
  477.         self.messagecombo.append_text("QST")
  478.         self.messagecombo.append_text("CQSRVR")
  479.         self.messagecombo.set_active(-1)
  480.         self.messagedest = self.messagecombo.get_child()
  481.         self.messagedest.set_max_length(9)
  482.         self.messagedest.set_width_chars(5)
  483.         self.messagedest.modify_font(smallfont)
  484.         messagebox.pack_start(self.messagecombo, False, False, 0)
  485.         self.messagecombo.show()
  486.  
  487.         self.messagetext = gtk.Entry()
  488.         self.messagetext.set_max_length(67)
  489.         self.messagetext.set_width_chars(31)
  490.         self.messagetext.modify_font(smallfont)
  491.         self.messagetext.connect("activate", self.send_message, self.messagetext)
  492.         messagebox.pack_start(self.messagetext, False, False, 0)
  493.         self.messagetext.show()
  494.  
  495.         messagebutton = gtk.Button()
  496.         messagebutton.set_label("Send")
  497.         messagebutton.connect("clicked", self.send_message, "message")
  498.         messagebox.pack_start(messagebutton, False, False, 0)
  499.         messagebutton.show()
  500.  
  501.         rightwin.pack_start(messagebox, False, False, 0)
  502.         messagebox.show()
  503.  
  504.         self.statusview.set_editable(False)
  505.         self.statusview.set_cursor_visible(True)
  506.         self.statusview.set_wrap_mode(gtk.WRAP_CHAR)
  507.         self.statusview.set_justification(gtk.JUSTIFY_LEFT)
  508.         self.statusview.modify_font(smallfont)
  509.  
  510.         self.statusbuffer.set_text("Position\nEnter your lat/long.  You may leave the decimal minutes (mm)\nblank for position ambiguity.  If you do not know your lat/long,\nenter your 5 digit zip code instead.\n\nBeacon\nWhen selected, sends location data every 10 minutes.  The\nbeacon will automatically stop when you edit personal\ninformation.  Must be manually reselected after edit\ncompletion.\n\nThis message will self destruct when you press Connect.\n\nAPRS Copyright (c) Bob Bruninga WB4APR\n\n")
  511.  
  512.         self.statuswindow = gtk.ScrolledWindow()
  513.         self.statuswindow.set_policy(gtk.POLICY_AUTOMATIC, gtk.POLICY_ALWAYS)
  514.         self.statuswindow.add(self.statusview)
  515.         self.statusview.show()
  516.         rightwin.pack_start(self.statuswindow, True, True, 0)
  517.         self.statuswindow.show()
  518.  
  519.         self.rawbox = gtk.HBox(False, 6)
  520.  
  521.         self.rawtext = gtk.Entry()
  522.         self.rawtext.set_max_length(128)
  523.         self.rawtext.set_width_chars(42)
  524.         self.rawtext.modify_font(smallfont)
  525.         self.rawtext.connect("activate", self.raw_send)
  526.         self.rawbox.pack_start(self.rawtext, False, False, 0)
  527.         self.rawtext.show()
  528.  
  529.         rawbutton = gtk.Button()
  530.         rawbutton.set_label("Send")
  531.         rawbutton.connect("clicked", self.raw_send)
  532.         self.rawbox.pack_start(rawbutton, False, False, 0)
  533.         rawbutton.show()
  534.  
  535.         rightwin.pack_start(self.rawbox, False, False, 0)
  536.         self.rawbox.show()
  537.  
  538.         win.pack_start(rightwin, False, False, 0)
  539.         rightwin.show()
  540.  
  541.         self.set_canvas(win)
  542.         win.show()
  543.         self.calltext.grab_focus()
  544.  
  545.         # Fix window not updating until activity after alt-tab
  546.         self.statusbuffer.create_mark("end", self.statusbuffer.get_end_iter(), False)
  547.         # Do the same for message window, without auto delete it did not have the problem
  548.         self.messagebuffer.create_mark("end", self.messagebuffer.get_end_iter(), False)
  549.  
  550.     def clear_status(self, button=None):
  551.         self.statusbuffer.set_text("")
  552.  
  553.     def clear_message(self, button=None):
  554.         self.messagebuffer.set_text("")
  555.  
  556.     def clear_message_button(self, button=None):
  557.         # cancel all outgoing messages, for now
  558.         self.clear_msg_queue()
  559.         # clear bulletin list
  560.         self.seen_bulletins = {}
  561.         # clear message screen
  562.         self.clear_message()
  563.        # TODO re-add outgoing messages (reset text iters)
  564.        # TODO re-add queued messages
  565.  
  566.     def connect_aprs(self, button):
  567.         if (self.sock == None):
  568.  
  569.             if (self.help):
  570.                 self.clear_status()
  571.                 self.messagebuffer.set_text("Message Window")
  572.                 self.messagebox = True
  573.                 self.help = False
  574.  
  575.             if (self.validate_data() == False):
  576.                 return False
  577.             self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  578.             self.status_write("Connecting ")
  579.             try:
  580.                 iplist = socket.gethostbyname_ex(HOST)[2]
  581.             except socket.error, msg:
  582.                 self.status_write("\n%s\n" % msg[1])
  583.                 self.sock = None
  584.                 return False
  585.             server = random.choice(iplist)
  586.             self.status_write("to %s\n" % server)
  587.             try:
  588.                 self.sock.connect((server, PORT))
  589.             except socket.error, msg:
  590.                 self.status_write("%s\n" % msg[1])
  591.                 self.sock = None
  592.                 return False
  593.  
  594.             self.status_write("Connected\n")
  595.             button.set_label("Disconnect")
  596.             button.modify_bg(gtk.STATE_NORMAL, gtk.gdk.color_parse("#e6000a"))
  597.        
  598.             response = self.sock.recv(RECV_BUFFER)
  599.             self.status_write("%s" % response)
  600.             if (response.find("javAPRSSrvr") == -1):
  601.                 self.status_write("invalid response.\n")
  602.                 self.disconnect_aprs(button)
  603.                 return False
  604.  
  605.             if (response.find("Port Full") != -1):
  606.                 self.status_write("Port Full.\n")
  607.                 self.disconnect_aprs(button)
  608.                 return False
  609.  
  610.             if (self.calltext.get_text() != "" and self.passtext.get_text() != ""):
  611.                 sendme = "user %s pass %s vers aprs_xo %d filter %s\n" % (self.calltext.get_text(), self.passtext.get_text(), VERSION, FILTER)
  612.             else:
  613.                 sendme = "user %s vers aprs_xo %d\n" % (self.calltext.get_text(), VERSION)
  614.             self.sock.sendall(sendme)
  615.             self.status_write("%s" % sendme)
  616.  
  617.             response = self.sock.recv(RECV_BUFFER)
  618.             self.status_write("%s" % response)
  619.             if (response.find("# logresp") == -1):
  620.                 self.status_write("invalid response.\n")
  621.                 self.disconnect_aprs(button)
  622.                 return False
  623.  
  624.             if (response.find("unverified") != -1):
  625.                 sendme = "# filter %s\n" % FILTER
  626.                 self.sock.sendall(sendme)
  627.                 self.status_write("%s\n" % sendme)
  628.  
  629.             self.status_write("\n")
  630.  
  631.             self.input_watch.append(gobject.io_add_watch(self.sock, gobject.IO_IN, self.recv_data))
  632.  
  633.             # send banner
  634.             sendme = "%s>APRS-XO v%s\n" % (self.calltext.get_text(), VERSION)
  635.             self.sock.sendall(sendme)
  636.             self.status_write("%s>\n" % self.calltext.get_text())
  637.             self.status_write("APRS-XO v%s\n\n" % VERSION)
  638.  
  639.             self.send_beacon()
  640.             self.output_watch.append(gobject.timeout_add(10 * 60 * 1000, self.send_beacon))
  641.  
  642.             # Start CQ if checked
  643.             if (self.cqbutton.get_active()):
  644.                 self.send_cq()
  645.                 self.cq_watch.append(gobject.timeout_add(32 * 60 * 1000, self.send_cq))
  646.  
  647.         else:
  648.             self.disconnect_aprs(button)
  649.  
  650.     def disconnect(self):
  651.         if (self.sock != None):
  652.             # stop cq
  653.             self.stop_cq()
  654.  
  655.             # for test server only
  656.             if(HOST == "192.168.50.6"):
  657.                 self.sock.sendall("q")
  658.  
  659.             self.sock.close()
  660.             self.sock = None
  661.  
  662.     def disconnect_aprs(self, button):
  663.         self.disconnect()
  664.         self.clear_msg_queue()
  665.  
  666.         self.status_write("Disconnected\n")
  667.  
  668.         # stop input watcher - just in case
  669.         for source in self.input_watch:
  670.             try:
  671.                 gobject.source_remove(source)
  672.             except:
  673.                 pass
  674.  
  675.         # stop beacon
  676.         for source in self.output_watch:
  677.             try:
  678.                 gobject.source_remove(source)
  679.             except:
  680.                 pass
  681.  
  682.         self.input_watch = []
  683.         self.output_watch = []
  684.  
  685.         button.set_label("Connect")
  686.         button.modify_bg(gtk.STATE_NORMAL, gtk.gdk.color_parse("#00b20d"))
  687.  
  688.     def recv_data(self, sock, condition):
  689.         if (self.sock == None):
  690.             return False
  691.         while 1:
  692.             try:
  693.                 recv_data = sock.recv(RECV_BUFFER)
  694.             except:
  695.                 self.status_write("Server closed connection.\n")
  696.                 self.sock = None
  697.                 self.disconnect_aprs(self.connectbutton)
  698.                 return False
  699.             if not recv_data:
  700.                 self.status_write("Server closed connection.\n")
  701.                 self.sock = None
  702.                 self.disconnect_aprs(self.connectbutton)
  703.                 return False
  704.             else:
  705.                 # sometimes more than one packet comes in
  706.                 for packet in recv_data.split("\n"):
  707.                     if (len(packet) < 2):
  708.                         break
  709.                     # find uri's http or www
  710.                     webaddy = packet.lower().find("http")
  711.                     if (webaddy != -1):
  712.                         packet = ("%s\n%s" % (packet[:webaddy], packet[webaddy:]))
  713.                     else:
  714.                         webaddy = packet.lower().find("www")
  715.                         if (webaddy != -1):
  716.                             packet = ("%s\n%s" % (packet[:webaddy], packet[webaddy:]))
  717.                     if (packet[0] == "#"):
  718.                         self.status_write("%s\n\n" % packet)
  719.                     else:
  720.                         cuthere = packet.find(":")
  721.                         self.status_write("%s\n" % packet[:cuthere+1])
  722.                         self.status_write("%s\n\n" % packet[cuthere+1:])
  723.                         self.msg_check(packet)
  724.                 return True
  725.  
  726.     def send_beacon(self):
  727.         if (self.sock == None):
  728.             return False
  729.         if (self.beaconbutton.get_active()):
  730.             beacon = "=%s%s.%s%sX%s%s.%s%sA%s" % (self.latDDtext.get_text(), self.latMMtext.get_text(), self.latmmtext.get_text(), self.latcombo.get_active_text(), self.lonDDDtext.get_text(), self.lonMMtext.get_text(), self.lonmmtext.get_text(), self.loncombo.get_active_text(), self.stationtext.get_text())
  731.             if (self.send_data(beacon)):
  732.                 return True
  733.             else:
  734.                 self.status_write("\nProblem sending beacon - STOPPED")
  735.                 return False
  736.  
  737.     def send_data(self, msg):
  738.         if (self.sock == None):
  739.             return False
  740.         path = "%s>APOLPC:" % self.calltext.get_text()
  741.         try:
  742.             self.sock.sendall("%s%s\n" % (path, msg))
  743.         except:
  744.             self.status_write("Problem sending packet\n")
  745.             self.sock = None
  746.             self.disconnect_aprs(self.connectbutton)
  747.             return False
  748.         self.status_write("%s\n" % path)
  749.         self.status_write("%s\n\n" % msg)
  750.         return True
  751.  
  752.     def send_ack(self, tocall, sequence):
  753.         # should check for duplicate messages in the next 30 seconds and drop them
  754.         # aprsd does this for us - but should do it here as well
  755.         if (tocall in self.sent_acks):
  756.             currentack = self.sent_acks[tocall]
  757.             if (currentack == sequence):
  758.                 ackmessage = ":%s:ack%s" % (tocall.ljust(9), sequence)
  759.                 self.send_data(ackmessage)
  760.         return False
  761.  
  762.     def status_write(self, text):
  763.         self.statusbuffer.insert(self.statusbuffer.get_end_iter(), text)
  764.         statuslines = self.statusbuffer.get_line_count()
  765.         if (statuslines > MAXLINES):
  766.             deletehere = self.statusbuffer.get_iter_at_line(statuslines - MAXLINES)
  767.             self.statusbuffer.delete(self.statusbuffer.get_start_iter(), deletehere)
  768.         if (not self.statusview.is_focus()):
  769.             self.statusbuffer.move_mark_by_name("end", self.statusbuffer.get_end_iter())
  770.             self.statusview.scroll_mark_onscreen(self.statusbuffer.get_mark("end"))
  771.  
  772.     def message_write(self, text, bold=None):
  773.         if (self.messagebox):
  774.             self.clear_message()
  775.             self.messagebox = False
  776.         iter = self.messagebuffer.get_end_iter()
  777.         self.messagebuffer.insert(iter, text)
  778.         if (bold):
  779.             bold_end = iter.copy()
  780.             bold_end.forward_to_line_end()
  781.             bold_start = bold_end.copy()
  782.             bold_start.backward_chars(len(text))
  783.             bold_start = bold_start.forward_search(">", gtk.TEXT_SEARCH_TEXT_ONLY)
  784.             self.messagebuffer.apply_tag(self.messagebold, bold_start[1], bold_end)
  785.  
  786.         if (not self.messageview.is_focus()):
  787.             self.messagebuffer.move_mark_by_name("end", self.messagebuffer.get_end_iter())
  788.             self.messageview.scroll_mark_onscreen(self.messagebuffer.get_mark("end"))
  789.  
  790.     def validate_data(self):
  791.         stop_here = False
  792.         self.validating = True
  793.         beaconchecked = self.beaconbutton.get_active()
  794.  
  795.         if (self.calltext.get_text() == "" and self.ziptext.get_text() == ""):
  796.             self.status_write("A callsign or zip code must be provided.\n")
  797.             return False
  798.  
  799.         # convert zip to position
  800.         if (self.ziptext.get_text() != ""):
  801.             self.status_write("Attempting to set location from zip code\n")
  802.             self.ziptext.set_text(self.ziptext.get_text().zfill(5))
  803.             try:
  804.                 zipsock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  805.             except socket.error, msg:
  806.                 self.status_write("[ERROR] %s\n" % msg[1])
  807.                 self.validating = False
  808.                 return False
  809.             try:
  810.                 zipsock.connect(('geocoder.us', 80))
  811.             except socket.error, msg:
  812.                 self.status_write("[ERROR] %s\n" % msg[1])
  813.                 self.validating = False
  814.                 return False
  815.             try:
  816.                 zipsock.sendall("GET /service/csv/geocode?zip=%s\n" % self.ziptext.get_text())
  817.             except socket.error, msg:
  818.                 self.status_write("[ERROR] %s\n" % msg[1])
  819.                 self.validating = False
  820.                 return False
  821.             zipsock.shutdown(1)
  822.             try:
  823.                 response = zipsock.recv(RECV_BUFFER)
  824.             except socket.error, msg:
  825.                 self.status_write("[ERROR] %s\n" % msg[1])
  826.                 self.validating = False
  827.                 return False
  828.             A = random.randrange(0, 9)
  829.             O = random.randrange(0, 9)
  830.             if (self.calltext.get_text() == ""):
  831.                 self.calltext.set_text("X%s-%d%d" % (self.ziptext.get_text(), A, O))
  832.                 self.passtext.set_text("-1")
  833.             try:
  834.                 (lat, lon, junk) = response.split(',', 2)
  835.             except:
  836.                 self.status_write("%s\n" % response)
  837.                 lat = "0"
  838.                 lon = "0"
  839.             lat = float(lat.strip())
  840.             lon = float(lon.strip())
  841.             if (lat < 0):
  842.                 self.latcombo.set_active(1)     # S
  843.             else:
  844.                 self.latcombo.set_active(0)     # N
  845.             lat = abs(lat)
  846.             if (lon < 0):
  847.                 self.loncombo.set_active(0)     # W
  848.             else:
  849.                 self.loncombo.set_active(1)     # E
  850.             lon = abs(lon)
  851.             self.latDDtext.set_text("%02d" % int(lat))
  852.             self.latMMtext.set_text("%02d" % int((lat - int(lat)) * 60 + 0.5))
  853.             self.latmmtext.set_text("%d " % A)
  854.             self.lonDDDtext.set_text("%03d" % int(lon))
  855.             self.lonMMtext.set_text("%02d" % int((lon - int(lon)) * 60 + 0.5))
  856.             self.lonmmtext.set_text("%d " % O)
  857.             self.ziptext.set_text("")
  858.         # end set loc by zip code
  859.  
  860.         if (self.latDDtext.get_text() == "DD" or self.latDDtext.get_text() == ""):
  861.             self.status_write("Latitude Degrees are required.\n")
  862.             stop_here = True
  863.         if (self.latMMtext.get_text() == "MM" or self.latMMtext.get_text() == ""):
  864.             self.status_write("Latitude Minutes are required.\n")
  865.             stop_here = True
  866.         if (self.lonDDDtext.get_text() == "DDD" or self.lonDDDtext.get_text() == ""):
  867.             self.status_write("Longitude Degrees are required.\n")
  868.             stop_here = True
  869.         if (self.lonMMtext.get_text() == "MM" or self.lonMMtext.get_text() == ""):
  870.             self.status_write("Longitude Minutes are required.\n")
  871.             stop_here = True
  872.  
  873.         if (stop_here):
  874.             self.status_write("Latitude and Longitude must be complete.\nFor position ambiguity omit decimal Minutes (mm).\nIf you do not know your lat/long, leave the letters\n(DD, MM, etc) and provide your zip code.\n")
  875.             self.validating = False
  876.             return False
  877.  
  878.         if (not self.latDDtext.get_text().isdigit()):
  879.             self.status_write("Latitude Degrees must be a number.\n")
  880.             stop_here = True
  881.         if (not self.latMMtext.get_text().isdigit()):
  882.             self.status_write("Latitude Minutes must be a number.\n")
  883.             stop_here = True
  884.         if (not self.lonDDDtext.get_text().isdigit()):
  885.             self.status_write("Longitude Degrees must be a number.\n")
  886.             stop_here = True
  887.         if (not self.lonMMtext.get_text().isdigit()):
  888.             self.status_write("Longitude Minutes must be a number.\n")
  889.             stop_here = True
  890.  
  891.         if (stop_here):
  892.             self.status_write("Invalid Position.\n")
  893.             self.validating = False
  894.             return False
  895.  
  896.         if (int(self.latDDtext.get_text()) < 0  or int(self.latDDtext.get_text()) > 90):
  897.             self.status_write("Latitude Degrees must be between 0 and 90.\n")
  898.             stop_here = True
  899.         if (int(self.latMMtext.get_text()) < 0  or int(self.latMMtext.get_text()) > 60):
  900.             self.status_write("Latitude Minutes must be between 0 and 60.\n")
  901.             stop_here = True
  902.         if (int(self.lonDDDtext.get_text()) < 0  or int(self.lonDDDtext.get_text()) > 180):
  903.             self.status_write("Longitude Degrees must be between 0 and 180.\n")
  904.             stop_here = True
  905.         if (int(self.lonMMtext.get_text()) < 0  or int(self.lonMMtext.get_text()) > 60):
  906.             self.status_write("Longitude Minutes must be between 0 and 60.\n")
  907.             stop_here = True
  908.  
  909.         if (stop_here):
  910.             self.status_write("Invalid Position.\n")
  911.             self.validating = False
  912.             return False
  913.  
  914.         # clean up entries
  915.         self.latDDtext.set_text(self.latDDtext.get_text().zfill(2))
  916.         self.latMMtext.set_text(self.latMMtext.get_text().zfill(2))
  917.         self.lonDDDtext.set_text(self.lonDDDtext.get_text().zfill(3))
  918.         self.lonMMtext.set_text(self.lonMMtext.get_text().zfill(2))
  919.         self.latmmtext.set_text(self.latmmtext.get_text().ljust(2))
  920.         self.lonmmtext.set_text(self.lonmmtext.get_text().ljust(2))
  921.         if (self.latmmtext.get_text() == "mm"):
  922.             self.latmmtext.set_text("  ")
  923.         if (self.lonmmtext.get_text() == "mm"):
  924.             self.lonmmtext.set_text("  ")
  925.         self.calltext.set_text(self.calltext.get_text().upper())
  926.         if (self.passtext.get_text() == ""):
  927.             self.passtext.set_text(self.aprspass(self.calltext.get_text()))
  928.         self.beaconbutton.set_active(beaconchecked)
  929.         self.validating = False
  930.  
  931.     def can_close( self ):
  932.         self.hide()
  933.         if (self.sock != None):
  934.             self.disconnect()
  935.         return True
  936.  
  937.     def write_file(self, file_path):
  938.         try:
  939.             JournalData = {}
  940.             JournalData['callsign'] = self.calltext.get_text()
  941.             JournalData['password'] = self.passtext.get_text()
  942.             JournalData['latDD'] = self.latDDtext.get_text()
  943.             JournalData['latMM'] = self.latMMtext.get_text()
  944.             JournalData['latmm'] = self.latmmtext.get_text()
  945.             JournalData['lat'] = self.latcombo.get_active_text()
  946.             JournalData['lonDDD'] = self.lonDDDtext.get_text()
  947.             JournalData['lonMM'] = self.lonMMtext.get_text()
  948.             JournalData['lonmm'] = self.lonmmtext.get_text()
  949.             JournalData['lon'] = self.loncombo.get_active_text()
  950.             JournalData['stationtext'] = self.stationtext.get_text()
  951.             if (self.beaconbutton.get_active()):
  952.                 JournalData['beacon'] = 'True'
  953.             else:
  954.                 JournalData['beacon'] = 'False'
  955.             if (self.passbutton.get_active()):
  956.                 JournalData['hidepass'] = 'True'
  957.             else:
  958.                 JournalData['hidepass'] = 'False'
  959.             if (self.cqbutton.get_active()):
  960.                 JournalData['cq'] = 'True'
  961.             else:
  962.                 JournalData['cq'] = 'False'
  963.  
  964.             callsignlist = []
  965.             model = self.messagecombo.get_model()
  966.             iter = model.get_iter_first()
  967.             while iter:
  968.                 callsignlist.append(model.get(iter, 0)[0])
  969.                 iter = model.iter_next(iter)
  970.  
  971.             JournalData['callsignlist'] = callsignlist
  972.             if (self.help):
  973.                 JournalData['messages'] = "Message Window"
  974.             else:
  975.                 JournalData['messages'] = self.messagebuffer.get_text(self.messagebuffer.get_start_iter(), self.messagebuffer.get_end_iter())
  976.             data = json.write(JournalData)
  977.  
  978.             f = open(file_path, 'w')
  979.             try:
  980.                 f.write(data)
  981.             finally:
  982.                 f.close()
  983.  
  984.         except Exception, e:
  985.             self.status_write("write_file(): %s\n" % e)
  986.  
  987.     def read_file(self, file_path):
  988.         self.statusbuffer.set_text("Status Window\n\n")
  989.         JournalData = {}
  990.         callsignlist = []
  991.         messages = "Message Window"
  992.         callsign = ""
  993.         password = ""
  994.         latDD = "DD"
  995.         latMM = "MM"
  996.         latmm = "mm"
  997.         lat = "N"
  998.         lonDDD = "DDD"
  999.         lonMM = "MM"
  1000.         lonmm = "mm"
  1001.         lon = "W"
  1002.         stationtext = ""
  1003.         beacon = "True"
  1004.         hidepass = "True"
  1005.         cq = "False"
  1006.         try:
  1007.             f = open(file_path, 'r')
  1008.             JournalData = json.read(f.read())
  1009.             if JournalData.has_key('callsignlist'):
  1010.                 callsignlist = JournalData['callsignlist']
  1011.             if JournalData.has_key('messages'):
  1012.                 messages = JournalData['messages']
  1013.             if JournalData.has_key('callsign'):
  1014.                 callsign = JournalData['callsign']
  1015.             if JournalData.has_key('password'):
  1016.                 password = JournalData['password']
  1017.             if JournalData.has_key('latDD'):
  1018.                 latDD = JournalData['latDD']
  1019.             if JournalData.has_key('latMM'):
  1020.                 latMM = JournalData['latMM']
  1021.             if JournalData.has_key('latmm'):
  1022.                 latmm = JournalData['latmm']
  1023.             if JournalData.has_key('lat'):
  1024.                 lat = JournalData['lat']
  1025.             if JournalData.has_key('lonDDD'):
  1026.                 lonDDD = JournalData['lonDDD']
  1027.             if JournalData.has_key('lonMM'):
  1028.                 lonMM = JournalData['lonMM']
  1029.             if JournalData.has_key('lonmm'):
  1030.                 lonmm = JournalData['lonmm']
  1031.             if JournalData.has_key('lon'):
  1032.                 lon = JournalData['lon']
  1033.             if JournalData.has_key('stationtext'):
  1034.                 stationtext = JournalData['stationtext']
  1035.             if JournalData.has_key('beacon'):
  1036.                 beacon = JournalData['beacon']
  1037.             if JournalData.has_key('hidepass'):
  1038.                 hidepass = JournalData['hidepass']
  1039.             if JournalData.has_key('cq'):
  1040.                 cq = JournalData['cq']
  1041.         except:
  1042.             pass
  1043.         finally:
  1044.             f.close()
  1045. #        self.messagebuffer.set_text(messages)
  1046.         self.bold_messages(messages)
  1047.         self.help = False
  1048.         if (messages == "Message Window"):
  1049.             self.messagebox = True
  1050.         else:
  1051.             self.messagebox = False
  1052.         for currentcall in callsignlist:
  1053.             self.add_callsign(currentcall, False)
  1054.         self.calltext.set_text(callsign)
  1055.         self.passtext.set_text(password)
  1056.         self.latDDtext.set_text(latDD)
  1057.         self.latMMtext.set_text(latMM)
  1058.         self.latmmtext.set_text(latmm)
  1059.         if (lat == "N"):
  1060.             self.latcombo.set_active(0)
  1061.         else:
  1062.             self.latcombo.set_active(1)
  1063.         self.lonDDDtext.set_text(lonDDD)
  1064.         self.lonMMtext.set_text(lonMM)
  1065.         self.lonmmtext.set_text(lonmm)
  1066.         if (lon == "W"):
  1067.             self.loncombo.set_active(0)
  1068.         else:
  1069.             self.loncombo.set_active(1)
  1070.         if (stationtext == ""):
  1071.             firstName = profile.get_nick_name().split(None, 1)[0].capitalize()
  1072.             self.stationtext.set_text("%s's XO at home." % firstName)
  1073.         else:
  1074.             self.stationtext.set_text(stationtext)
  1075.         if (beacon == "True"):
  1076.             self.beaconbutton.set_active(True)
  1077.         else:
  1078.             self.beaconbutton.set_active(False)
  1079.         if (hidepass == "True"):
  1080.             self.passbutton.set_active(True)
  1081.         else:
  1082.             self.passbutton.set_active(False)
  1083.         if (cq == "True"):
  1084.             self.cqbutton.set_active(True)
  1085.         else:
  1086.             self.cqbutton.set_active(False)
  1087.  
  1088.     def msg_check(self, data):
  1089.         mycall = self.calltext.get_text().upper()
  1090.         firstcheck = data.find("::")
  1091.         secondcheck = data[firstcheck+11:firstcheck+12]
  1092.         thirdcheck = data.find("{")
  1093.         if (firstcheck != -1 and secondcheck == ":"):
  1094.             tocall = data[firstcheck+2:firstcheck+11].upper()
  1095.             strippedtocall = tocall.strip()
  1096.             fromcall = data[:data.find(">")].upper()
  1097.             isbulletin = self.bulletin_check(strippedtocall)
  1098.             # 'mycall' check allows people with bulletin looking calls to ack messages
  1099.             # this check does not fix the problem of sending messages to bulletin looking calls
  1100.             if (isbulletin and strippedtocall != mycall):
  1101.                 message = data[firstcheck+12:]
  1102.                 self.add_callsign(fromcall, False)
  1103.                 bln_id = "%s-%s" % (fromcall, strippedtocall)
  1104.                 # show bulletin if have never seen it or has been at least 1 day since last viewing
  1105.                 if (not bln_id in self.seen_bulletins or time.time() - self.seen_bulletins[bln_id] > 86400):
  1106.                     self.seen_bulletins[bln_id] = time.time()
  1107.                     self.message_write("%s %s:%s> %s\n" % (time.strftime("%m/%d %H:%M", time.localtime()), fromcall, strippedtocall, message), True)
  1108.             else:
  1109.                 if (strippedtocall == mycall):
  1110.                     self.add_callsign(fromcall, False)
  1111.                     if (thirdcheck != -1):
  1112.                         sequence_end = data.find("}")
  1113.                         if (sequence_end == -1):
  1114.                             sequence = data[thirdcheck + 1:]
  1115.                         else:
  1116.                             sequence = data[thirdcheck + 1:sequence_end]
  1117.                             replyack = data[sequence_end + 1:]
  1118.                             if (len(replyack) > 1):
  1119.                                 ackid = "%s-%s" % (fromcall, replyack)
  1120.                                 if (ackid in self.recv_acks):
  1121.                                     if (self.recv_acks[ackid] == 0):
  1122.  
  1123.                                         count_start = self.messagebuffer.get_iter_at_mark(self.message_marks[ackid])
  1124.                                         count_end = count_start.forward_search(">", gtk.TEXT_SEARCH_TEXT_ONLY)
  1125.                                         self.messagebuffer.delete(count_start, count_end[0])
  1126.  
  1127.                                         line_end = self.messagebuffer.get_iter_at_mark(self.message_marks[ackid])
  1128.                                         queue_start = self.messagebuffer.get_iter_at_mark(self.message_marks[ackid])
  1129.                                         line_end.forward_to_line_end()
  1130.                                         queue_start.forward_to_line_end()
  1131.                                         queue_start.backward_chars(12)
  1132.                                         self.messagebuffer.delete(queue_start, line_end)
  1133.  
  1134.                                         line_end = self.messagebuffer.get_iter_at_mark(self.message_marks[ackid])
  1135.                                         line_end.forward_to_line_end()
  1136.                                         self.messagebuffer.insert(line_end, " <*ACKED*>")
  1137.  
  1138.                                         self.send_msg_queue(fromcall)
  1139.                                     self.recv_acks[ackid] = 1
  1140.                         message = data[firstcheck+12:thirdcheck]
  1141.                         ackmessage = ":%s:ack%s" % (fromcall.ljust(9), data[thirdcheck + 1:])
  1142.                         self.send_data(ackmessage)
  1143.                         id = "%s-%s" % (fromcall, sequence)
  1144.                         if (id in self.sent_acks):
  1145.                             self.timers.append(gobject.timeout_add(30 * 1000, self.send_ack, tocall, sequence))
  1146.                             self.timers.append(gobject.timeout_add(60 * 1000, self.send_ack, tocall, sequence))
  1147.                             self.timers.append(gobject.timeout_add(120 * 1000, self.send_ack, tocall, sequence))
  1148.                         else:
  1149.                             # TODO beep?
  1150.                             self.message_write("%s %s> %s\n" % (time.strftime("%m/%d %H:%M", time.localtime()), fromcall, message), True)
  1151.                         self.sent_acks[id] = time.time() # to help a cleanup thread later
  1152.                         self.sent_acks[fromcall] = sequence # to help with reply acks later
  1153.                     else:
  1154.                         message = data[firstcheck+12:]
  1155.                         if (message[0:3] == "ack"):
  1156.                             sequence_end = message.find("}")
  1157.                             if (sequence_end == -1):
  1158.                                 sequence = message[3:]
  1159.                             else:
  1160.                                 sequence = message[3:sequence_end]
  1161.                             ackid = "%s-%s" % (fromcall, sequence)
  1162.                             if (ackid in self.recv_acks):
  1163.                                 if (self.recv_acks[ackid] == 0):
  1164.  
  1165.                                     count_start = self.messagebuffer.get_iter_at_mark(self.message_marks[ackid])
  1166.                                     count_end = count_start.forward_search(">", gtk.TEXT_SEARCH_TEXT_ONLY)
  1167.                                     self.messagebuffer.delete(count_start, count_end[0])
  1168.  
  1169.                                     line_end = self.messagebuffer.get_iter_at_mark(self.message_marks[ackid])
  1170.                                     queue_start = self.messagebuffer.get_iter_at_mark(self.message_marks[ackid])
  1171.                                     line_end.forward_to_line_end()
  1172.                                     queue_start.forward_to_line_end()
  1173.                                     queue_start.backward_chars(12)
  1174.                                     self.messagebuffer.delete(queue_start, line_end)
  1175.  
  1176.                                     line_end = self.messagebuffer.get_iter_at_mark(self.message_marks[ackid])
  1177.                                     line_end.forward_to_line_end()
  1178.                                     self.messagebuffer.insert(line_end, " <*ACKED*>")
  1179.  
  1180.                                     self.send_msg_queue(fromcall)
  1181.                             self.recv_acks[ackid] = 1
  1182.                         else:
  1183.                             # TODO beep?
  1184.                             self.message_write("%s %s> %s\n" % (time.strftime("%m/%d %H:%M", time.localtime()), fromcall, message), True)
  1185.  
  1186.                             # TODO query check
  1187.                             if (message[0] == "?" and message[-1] == "?"):
  1188.                                 pass
  1189.  
  1190.  
  1191.     def disable_beacon(self, widget, data=None):
  1192.         if (self.sock != None):
  1193.             self.beaconbutton.set_active(False)
  1194.  
  1195.     def enable_beacon(self, widget, data=None):
  1196.         if (not self.validating and widget.get_active()):
  1197.             self.validate_data()
  1198.  
  1199.     def raw_send(self, widget, data=None):
  1200.         msg = "%s\n" % self.rawtext.get_text()
  1201.         try:
  1202.             self.sock.sendall(msg)
  1203.         except:
  1204.             self.status_write("Problem sending message\n")
  1205.             self.sock = None
  1206.             self.disconnect_aprs(self.connectbutton)
  1207.             return False
  1208.         self.status_write("%s\n" % msg)
  1209.         self.rawtext.set_text("")
  1210.         return True
  1211.  
  1212.     def send_message(self, widget, data=None, tocall=None, message=None):
  1213.         sendnow = False
  1214.  
  1215.         if (tocall == None and message == None):
  1216.             tocall = self.messagedest.get_text().upper()
  1217.             message = self.messagetext.get_text()
  1218.  
  1219.         if (message == ""):
  1220.             return False
  1221.  
  1222.         isbulletin = self.bulletin_check(tocall)
  1223.  
  1224.         # check for illegal characters before clearing message
  1225.         if (isbulletin):
  1226.             if (message.find("|") != -1 or message.find("~") != -1):
  1227.                 self.message_write("Bulletins can not contain the following characters: | ~")
  1228.                 return False
  1229.         else:
  1230.             if (message.find("|") != -1 or message.find("~") != -1 or message.find("{") != -1):
  1231.                 self.message_write("Messages can not contain the following characters: | ~ {")
  1232.                 return False
  1233.  
  1234.         # add callsign to list if just entered
  1235.         if (self.messagecombo.get_active() == -1):
  1236.             self.add_callsign(tocall, True)
  1237.  
  1238.         # get a sequence number
  1239.         if (isbulletin):
  1240.             # don't waste a number on a bulletin
  1241.             sequence = ""
  1242.         else:
  1243.             sequence = "%s" % self.b90()
  1244.  
  1245.         # TODO
  1246.         # cancel message option - menu popup
  1247.  
  1248.         # is there a queue for this callsign?
  1249.         if (tocall not in self.queue_list):
  1250.             sendnow = True
  1251.  
  1252.         # add the message to the queue
  1253.         if (not self.msg_queue(tocall, sequence, message)):
  1254.             if (self.sequence > 0):
  1255.                 self.sequence -= 1
  1256.             return False
  1257.  
  1258.         # clear the message text box
  1259.         self.messagetext.set_text("")
  1260.  
  1261.         if (sendnow):
  1262.             self.send_msg_queue(tocall)
  1263.  
  1264.     def b90(self):
  1265.         if (self.sequence > 8099):
  1266.             self.sequence = 0
  1267.         first = ((self.sequence / 90) % 90) + 33
  1268.         second = (self.sequence % 90) + 33
  1269.         output = "%c%c" % (first, second)
  1270.         self.sequence += 1
  1271.         return output
  1272.  
  1273.     def msg_timer(self, tocall, message, sequence, count, delay):
  1274.         id = "%s-%s" % (tocall, sequence)
  1275.         if (self.recv_acks[id] == 1):
  1276.             return False
  1277.         else:
  1278.             replyack = self.replyack(tocall)
  1279.             self.send_data(":%s:%s{%s}%s" % (tocall.ljust(9), message, sequence, replyack))
  1280.  
  1281.             count_start = self.messagebuffer.get_iter_at_mark(self.message_marks[id])
  1282.             count_end = self.messagebuffer.get_iter_at_mark(self.message_marks[id])
  1283.             count_end.forward_chars(len(str(count - 1)) + 1)
  1284.             self.messagebuffer.delete(count_start, count_end)
  1285.             iter = self.messagebuffer.get_iter_at_mark(self.message_marks[id])
  1286.             self.messagebuffer.insert(iter, " %i" % count)
  1287.  
  1288.             # start the next timer
  1289.             count += 1
  1290.             if (count > MAXRETRIES):
  1291.                 self.recv_acks[id] = 1
  1292.  
  1293.                 count_start = self.messagebuffer.get_iter_at_mark(self.message_marks[id])
  1294.                 count_end = self.messagebuffer.get_iter_at_mark(self.message_marks[id])
  1295.                 count_end.forward_chars(len(str(count - 1)) + len(str(MAXRETRIES)) + 2)
  1296.                 self.messagebuffer.delete(count_start, count_end)
  1297.  
  1298.                 line_end = self.messagebuffer.get_iter_at_mark(self.message_marks[id])
  1299.                 queue_start = self.messagebuffer.get_iter_at_mark(self.message_marks[id])
  1300.                 line_end.forward_to_line_end()
  1301.                 queue_start.forward_to_line_end()
  1302.                 queue_start.backward_chars(12)
  1303.                 self.messagebuffer.delete(queue_start, line_end)
  1304.  
  1305.                 line_end = self.messagebuffer.get_iter_at_mark(self.message_marks[id])
  1306.                 line_end.forward_to_line_end()
  1307.                 self.messagebuffer.insert(line_end, " <-timeout->")
  1308.  
  1309.                 self.send_msg_queue(tocall)
  1310.                 return False
  1311.             delay *=  2
  1312.             if (delay > 600):
  1313.                 delay = 600
  1314.             gobject.timeout_add(delay * 1000, self.msg_timer, tocall, message, sequence, count, delay)
  1315.  
  1316.             # and stop this timer
  1317.             return False
  1318.  
  1319.     def add_callsign(self, callsign, activate):
  1320.         model = self.messagecombo.get_model()
  1321.         notfound = True
  1322.         iter = model.get_iter_first()
  1323.         while iter:
  1324.             currentcall = model.get(iter, 0)[0]
  1325.             if (currentcall == callsign):
  1326.                 notfound = False
  1327.                 break
  1328.             iter = model.iter_next(iter)
  1329.         if (notfound):
  1330.             self.messagecombo.prepend_text(callsign)
  1331.             if (activate):
  1332.                 self.messagecombo.set_active(0)
  1333.  
  1334.     def bulletin_check(self, callsign):
  1335.         # hard code CQSRVR
  1336.         if (callsign == "CQSRVR"):
  1337.             return False
  1338.         for currentcall in self.bulletins:
  1339.             length = len(currentcall)
  1340.             if (currentcall == callsign[:length]):
  1341.                 return True
  1342.         return False
  1343.  
  1344.     def replyack(self, tocall):
  1345.         replyack = ""
  1346.         if (tocall in self.sent_acks):
  1347.             id = "%s-%s" % (tocall, self.sent_acks[tocall])
  1348.             if (time.time() - self.sent_acks[id] < 5400):
  1349.                 # less than 90 minutes ago
  1350.                 replyack = self.sent_acks[tocall]
  1351.         return replyack
  1352.  
  1353.     def msg_queue(self, call, sequence, message):
  1354.         if (len(self.message_list) >= MAX_MSG_QUEUE):
  1355.             self.message_write("Too many messages in queue.\n")
  1356.             return False
  1357.         id = "%s-%s" % (call, sequence)
  1358.         if (call in self.queue_list):
  1359.             if (len(self.queue_list[call]) >= MAX_PER_CALL_QUEUE):
  1360.                 self.message_write("Too many messages to %s in queue.\n" % call)
  1361.                 return False
  1362.             self.queue_list[call].append(sequence)
  1363.             self.message_list[id] = message
  1364.         else:
  1365.             self.queue_list[call] = []
  1366.             self.queue_list[call].append(sequence)
  1367.             self.message_list[id] = message
  1368.         self.message_write("%s To:%s> %s <-queued->\n" % (time.strftime("%m/%d %H:%M", time.localtime()), call, message))
  1369.         # if a message is received before the next lines are run there will be problems...
  1370.         iter = self.messagebuffer.get_iter_at_line(self.messagebuffer.get_line_count() - 2)
  1371.         iter.forward_chars(15 + len(call))
  1372.         self.message_marks[id] = self.messagebuffer.create_mark(None, iter, True)
  1373. #        self.message_marks[id].set_visible(True)
  1374.  
  1375.         bold_end = iter.copy()
  1376.         bold_start = iter.copy()
  1377.         bold_end.forward_to_line_end()
  1378.         bold_end = bold_end.backward_search("<", gtk.TEXT_SEARCH_TEXT_ONLY)
  1379.         bold_start.forward_chars(2)
  1380.         self.messagebuffer.apply_tag(self.messagebold, bold_start, bold_end[0])
  1381.  
  1382.         return True
  1383.  
  1384.     def send_msg_queue(self, call):
  1385.         if (call in self.queue_list):
  1386.             if (self.queue_list[call] == []):
  1387.                 del self.queue_list[call]
  1388.                 return False
  1389.  
  1390.             sequence = self.queue_list[call].pop(0)
  1391.             id = "%s-%s" % (call, sequence)
  1392.             message = self.message_list[id]
  1393.             del self.message_list[id]
  1394.  
  1395.             # record this so cancel can work on current messages
  1396.             self.current_message[call] = sequence
  1397.  
  1398.             # send message
  1399.             isbulletin = self.bulletin_check(call)
  1400.             if (isbulletin):
  1401.                 self.send_data(":%s:%s" % (call.ljust(9), message))
  1402.                 gobject.timeout_add(600 * 1000, self.msg_timer, call, message, "", 2, 600)
  1403.             else:
  1404.                 replyack = self.replyack(call)
  1405.                 self.send_data(":%s:%s{%s}%s" % (call.ljust(9), message, sequence, replyack))
  1406.                 self.recv_acks["%s-%s" % (call, sequence)] = 0
  1407.                 gobject.timeout_add(7 * 1000, self.msg_timer, call, message, sequence, 2, 7)
  1408.  
  1409.             # reset the timestamp
  1410.             line_start = self.messagebuffer.get_iter_at_mark(self.message_marks[id])
  1411.             date_end = self.messagebuffer.get_iter_at_mark(self.message_marks[id])
  1412.             length = line_start.get_line_offset()
  1413.             line_start.backward_chars(length)
  1414.             date_end.backward_chars(length)
  1415.             date_end.forward_chars(11)
  1416.             self.messagebuffer.delete(line_start, date_end)
  1417.  
  1418.             line_start = self.messagebuffer.get_iter_at_mark(self.message_marks[id])
  1419.             length = line_start.get_line_offset()
  1420.             line_start.backward_chars(length)
  1421.             self.messagebuffer.insert(line_start, time.strftime("%m/%d %H:%M", time.localtime()))
  1422.  
  1423.             # clear "<-queued->"
  1424.             line_end = self.messagebuffer.get_iter_at_mark(self.message_marks[id])
  1425.             queue_start = self.messagebuffer.get_iter_at_mark(self.message_marks[id])
  1426.             line_end.forward_to_line_end()
  1427.             queue_start.forward_to_line_end()
  1428.             queue_start.backward_chars(11)
  1429.             self.messagebuffer.delete(queue_start, line_end)
  1430.  
  1431.             # add <-sending->
  1432.             line_end = self.messagebuffer.get_iter_at_mark(self.message_marks[id])
  1433.             line_end.forward_to_line_end()
  1434.             self.messagebuffer.insert(line_end, " <-sending->")
  1435.  
  1436.             # add the counter
  1437.             iter = self.messagebuffer.get_iter_at_mark(self.message_marks[id])
  1438.             self.messagebuffer.insert(iter, " 1/%s" % MAXRETRIES)
  1439.  
  1440.     def cancel_message(self, id):
  1441.         if (self.recv_acks[id] == 1):
  1442.             return
  1443.  
  1444.         self.recv_acks[id] = 1
  1445.  
  1446.         # remove status
  1447.         line_end = self.messagebuffer.get_iter_at_mark(self.message_marks[id])
  1448.         line_end.forward_to_line_end()
  1449.         status_start = line_end.backward_search("<", gtk.TEXT_SEARCH_TEXT_ONLY)
  1450.         self.messagebuffer.delete(status_start[0], line_end)
  1451.  
  1452.         # add <-cancelled->
  1453.         line_end = self.messagebuffer.get_iter_at_mark(self.message_marks[id])
  1454.         line_end.forward_to_line_end()
  1455.         self.messagebuffer.insert(line_end, " <-cancelled->")
  1456.  
  1457.         # leave counter and timestamp alone
  1458.  
  1459.     def clear_msg_queue(self, button=None):
  1460.         if (self.queue_list != {}):
  1461.             for call in self.queue_list:
  1462.                 for sequence in self.queue_list[call]:
  1463.                     id = "%s-%s" % (call, sequence)
  1464.                     del self.message_list[id]
  1465.                     self.cancel_message(id)
  1466.             self.queue_list = {}
  1467.  
  1468.         if (self.current_message != {}):
  1469.             for call in self.current_message:
  1470.                 sequence = self.current_message[call]
  1471.                 id = "%s-%s" % (call, sequence)
  1472.                 self.cancel_message(id)
  1473.             self.current_message = {}
  1474.  
  1475.     def bold_messages(self, messages):
  1476.         self.messagebuffer.set_text("")
  1477.         for line in messages.splitlines():
  1478.             if (line[2:3] == "/" and line[5:6] == " " and line[8:9] == ":" and line[11:12] == " "):
  1479.                 if (line[12:15] == "To:"):
  1480.                     self.message_write("%s\n" % line)
  1481.                     iter = self.messagebuffer.get_iter_at_line(self.messagebuffer.get_line_count() - 2)
  1482.                     bold_end = iter.copy()
  1483.                     bold_end.forward_to_line_end()
  1484.                     bold_start = bold_end.copy()
  1485.                     bold_start.backward_chars(len(line))
  1486.                     bold_start = bold_start.forward_search(">", gtk.TEXT_SEARCH_TEXT_ONLY)
  1487.                     bold_end = bold_end.backward_search("<", gtk.TEXT_SEARCH_TEXT_ONLY)
  1488.                     self.messagebuffer.apply_tag(self.messagebold, bold_start[1], bold_end[0])
  1489.                 else:
  1490.                     self.message_write("%s\n" % line, True)
  1491.             else:
  1492.                 self.message_write("%s\n" % line)
  1493.  
  1494.     def aprspass(self, callsign):
  1495.         # Note: The doHash(char*) function is Copyright Steve Dimse 1998
  1496.         # As of April 11 2000 Steve Dimse has released this code to the open source aprs community
  1497.  
  1498.         # remove SSID, trim callsign, convert to upper case
  1499.         cuthere = callsign.find("-")
  1500.         if (cuthere != -1):
  1501.             callsign = callsign[:cuthere]
  1502.         realcall = callsign[:10].upper()
  1503.  
  1504.         if (realcall == "NOCALL"):
  1505.             return "-1"
  1506.  
  1507.         # initialize hash
  1508.         hash = 0x73e2
  1509.         i = 0
  1510.         length = len(realcall)
  1511.  
  1512.         # hash callsign two bytes at a time
  1513.         while (i < length):
  1514.             hash ^= ord(realcall[i])<<8
  1515.             if (i+1 < length):
  1516.                 hash ^= ord(realcall[i+1])
  1517.             i += 2
  1518.  
  1519.         # convert to string and mask off the high bit so number is always positive
  1520.         return str(hash & 0x7fff)
  1521.  
  1522.     def hide_password(self, widget, data=None):
  1523.         if (widget.get_active()):
  1524.             self.passtext.set_visibility(False)
  1525.         else:
  1526.             self.passtext.set_visibility(True)
  1527.  
  1528.     def open_url_button(self, widget, data):
  1529.         self._show_via_journal(data)
  1530.  
  1531.     # (mostly) from Chat.Activity
  1532.     def _show_via_journal(self, url):
  1533.         """Ask the journal to display a URL"""
  1534.         import os
  1535.         import time
  1536.         from sugar import profile
  1537.         from sugar.activity.activity import show_object_in_journal
  1538.         from sugar.datastore import datastore
  1539.         jobject = datastore.create()
  1540.         metadata = {
  1541.             'title': url,
  1542.             'title_set_by_user': '1',
  1543.             'icon-color': profile.get_color().to_string(),
  1544.             'activity': 'org.laptop.WebActivity',
  1545.             'mime_type': 'text/plain',
  1546.             }
  1547.         for k,v in metadata.items():
  1548.             jobject.metadata[k] = v
  1549.         file_path = os.path.join(self.get_activity_root(), 'instance',
  1550.                                  '%i_' % time.time())
  1551.         open(file_path, 'w').write('{"deleted":[],"shared_links":[],"history":[{"url":"' + url + '","title":"' + url + '"}]}')
  1552.         os.chmod(file_path, 0755)
  1553.         jobject.set_file_path(file_path)
  1554.         datastore.write(jobject)
  1555.         show_object_in_journal(jobject.object_id)
  1556.         jobject.destroy()
  1557.         os.unlink(file_path)
  1558.  
  1559.     def stop_cq(self):
  1560.         for source in self.cq_watch:
  1561.             try:
  1562.                 gobject.source_remove(source)
  1563.             except:
  1564.                 pass
  1565.         self.cq_watch = []
  1566.         if (self.cqbutton.get_active()):
  1567.             # send_message fails because disconnect happens too fast.
  1568. #            self.send_message(None, None, "CQSRVR", "U CQ")
  1569.             message = ":CQSRVR   :U CQ{%s" % self.b90()
  1570.             self.send_data(message)
  1571.  
  1572.     def enable_cq(self, widget, data=None):
  1573.         if (self.sock != None):
  1574.             if (self.cqbutton.get_active()):
  1575.                 self.send_cq()
  1576.                 self.cq_watch.append(gobject.timeout_add(32 * 60 * 1000, self.send_cq))
  1577.             else:
  1578.                 self.stop_cq()
  1579.                 self.send_message(None, None, "CQSRVR", "U CQ")
  1580.  
  1581.     def send_cq(self):
  1582.         if (self.sock == None):
  1583.             return False
  1584.         if (self.cqbutton.get_active()):
  1585.             self.send_message(None, None, "CQSRVR", "CQ CQ CQ From %s" % self.stationtext.get_text())
  1586.  
  1587.