#!/usr/bin/env python # -*- coding: utf-8 -*- # Copyright 2008-2010, Ray E. Barker # # This program is free software; you can redistribute it and/or modify # it under the terms of the GNU General Public License as published by # the Free Software Foundation; either version 2 of the License, or # (at your option) any later version. # # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU General Public License for more details. # # You should have received a copy of the GNU General Public License # along with this program; if not, write to the Free Software # Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA ######################################################################## """Hud_main.py Main for FreePokerTools HUD. """ # Standard Library modules import sys import os import traceback import thread import time import string # pyGTK modules import gtk import gobject # FreePokerTools modules import Configuration import Database import Hud import Options (options, argv) = Options.fpdb_options() # get the correct module for the current os if os.name == 'posix': import XTables as Tables elif os.name == 'nt': import WinTables as Tables import locale lang = locale.getdefaultlocale()[0][0:2] print "lang:", lang if lang == "en": def _(string): return string else: import gettext try: trans = gettext.translation("fpdb", localedir="locale", languages=[lang]) trans.install() except IOError: def _(string): return string # get config and set up logger c = Configuration.Config(file=options.config, dbname=options.dbname) log = Configuration.get_logger("logging.conf", "hud", log_dir=c.dir_log, log_file='HUD-log.txt') class HUD_main(object): """A main() object to own both the read_stdin thread and the gui.""" # This class mainly provides state for controlling the multiple HUDs. def __init__(self, db_name='fpdb'): self.db_name = db_name self.config = c log.info("HUD_main starting: using db name = %s" % (db_name)) try: if not options.errorsToConsole: fileName = os.path.join(self.config.dir_log, 'HUD-errors.txt') log.info("Note: error output is being diverted to:" + fileName) log.info("Any major error will be reported there _only_.") errorFile = open(fileName, 'w', 0) sys.stderr = errorFile sys.stderr.write("HUD_main: starting ...\n") self.hud_dict = {} self.hud_params = self.config.get_hud_ui_parameters() # a thread to read stdin gobject.threads_init() # this is required thread.start_new_thread(self.read_stdin, ()) # starts the thread # a main window self.main_window = gtk.Window() self.main_window.connect("client_moved", self.client_moved) self.main_window.connect("client_resized", self.client_resized) self.main_window.connect("client_destroyed", self.client_destroyed) self.main_window.connect("game_changed", self.game_changed) self.main_window.connect("table_changed", self.table_changed) self.main_window.connect("destroy", self.destroy) self.vb = gtk.VBox() self.label = gtk.Label('Closing this window will exit from the HUD.') self.vb.add(self.label) self.main_window.add(self.vb) self.main_window.set_title("HUD Main Window") cards = os.path.join(os.getcwd(), '..','gfx','fpdb-cards.png') if os.path.exists(cards): self.main_window.set_icon_from_file(cards) elif os.path.exists('/usr/share/pixmaps/fpdb-cards.png'): self.main_window.set_icon_from_file('/usr/share/pixmaps/fpdb-cards.png') else: self.main_window.set_icon_stock(gtk.STOCK_HOME) self.main_window.show_all() gobject.timeout_add(100, self.check_tables) except: log.exception("Error initializing main_window") gtk.main_quit() # we're hosed, just terminate def client_moved(self, widget, hud): hud.up_update_table_position() def client_resized(self, widget, hud): gobject.idle_add(idle_resize, hud) def client_destroyed(self, widget, hud): # call back for terminating the main eventloop self.kill_hud(None, hud.table.key) def game_changed(self, widget, hud): print "hud_main: Game changed." def table_changed(self, widget, hud): self.kill_hud(None, hud.table.key) def destroy(self, *args): # call back for terminating the main eventloop log.info("Terminating normally.") gtk.main_quit() def kill_hud(self, event, table): gobject.idle_add(idle_kill, self, table) def check_tables(self): for hud in self.hud_dict.keys(): self.hud_dict[hud].table.check_table(self.hud_dict[hud]) return True def create_HUD(self, new_hand_id, table, temp_key, max, poker_game, type, stat_dict, cards): """type is "ring" or "tour" used to set hud_params""" self.hud_dict[temp_key] = Hud.Hud(self, table, max, poker_game, self.config, self.db_connection) self.hud_dict[temp_key].table_name = temp_key self.hud_dict[temp_key].stat_dict = stat_dict self.hud_dict[temp_key].cards = cards table.hud = self.hud_dict[temp_key] # set agg_bb_mult so that aggregate_tour and aggregate_ring can be ignored, # agg_bb_mult == 1 means no aggregation after these if statements: if type == "tour" and self.hud_params['aggregate_tour'] == False: self.hud_dict[temp_key].hud_params['agg_bb_mult'] = 1 elif type == "ring" and self.hud_params['aggregate_ring'] == False: self.hud_dict[temp_key].hud_params['agg_bb_mult'] = 1 if type == "tour" and self.hud_params['h_aggregate_tour'] == False: self.hud_dict[temp_key].hud_params['h_agg_bb_mult'] = 1 elif type == "ring" and self.hud_params['h_aggregate_ring'] == False: self.hud_dict[temp_key].hud_params['h_agg_bb_mult'] = 1 # sqlcoder: I forget why these are set to true (aren't they ignored from now on?) # but I think it's needed: self.hud_params['aggregate_ring'] = True self.hud_params['h_aggregate_ring'] = True # so maybe the tour ones should be set as well? does this fix the bug I see mentioned? self.hud_params['aggregate_tour'] = True self.hud_params['h_aggregate_tour'] = True [aw.update_data(new_hand_id, self.db_connection) for aw in self.hud_dict[temp_key].aux_windows] gobject.idle_add(idle_create, self, new_hand_id, table, temp_key, max, poker_game, type, stat_dict, cards) def update_HUD(self, new_hand_id, table_name, config): """Update a HUD gui from inside the non-gui read_stdin thread.""" gobject.idle_add(idle_update, self, new_hand_id, table_name, config) def read_stdin(self): # This is the thread function """Do all the non-gui heavy lifting for the HUD program.""" # This db connection is for the read_stdin thread only. It should not # be passed to HUDs for use in the gui thread. HUD objects should not # need their own access to the database, but should open their own # if it is required. self.db_connection = Database.Database(self.config) # get hero's screen names and player ids self.hero, self.hero_ids = {}, {} found = False while 1: # wait for a new hand number on stdin new_hand_id = sys.stdin.readline() new_hand_id = string.rstrip(new_hand_id) log.debug("Received hand no %s" % new_hand_id) if new_hand_id == "": # blank line means quit self.destroy() break # this thread is not always killed immediately with gtk.main_quit() # This block cannot be hoisted outside the while loop, because it would # cause a problem when auto importing into an empty db. # FIXME: This doesn't work in the case of the player playing on 2 # sites at once (???) Eratosthenes if not found: for site in self.config.get_supported_sites(): result = self.db_connection.get_site_id(site) if result: site_id = result[0][0] self.hero[site_id] = self.config.supported_sites[site].screen_name self.hero_ids[site_id] = self.db_connection.get_player_id(self.config, site, self.hero[site_id]) if self.hero_ids[site_id] is not None: found = True else: self.hero_ids[site_id] = -1 # get basic info about the new hand from the db # if there is a db error, complain, skip hand, and proceed log.info("HUD_main.read_stdin: hand processing starting ...") try: (table_name, max, poker_game, type, site_id, site_name, num_seats, tour_number, tab_number) = \ self.db_connection.get_table_info(new_hand_id) except Exception: log.exception("db error: skipping %s" % new_hand_id) continue if type == "tour": # hand is from a tournament temp_key = "%s Table %s" % (tour_number, tab_number) else: temp_key = table_name # Update an existing HUD if temp_key in self.hud_dict: # get stats using hud's specific params and get cards self.db_connection.init_hud_stat_vars( self.hud_dict[temp_key].hud_params['hud_days'] , self.hud_dict[temp_key].hud_params['h_hud_days']) stat_dict = self.db_connection.get_stats_from_hand(new_hand_id, type, self.hud_dict[temp_key].hud_params, self.hero_ids[site_id], num_seats) try: self.hud_dict[temp_key].stat_dict = stat_dict except KeyError: # HUD instance has been killed off, key is stale log.error('hud_dict[%s] was not found\n' % temp_key) log.error('will not send hand\n') # Unlocks table, copied from end of function self.db_connection.connection.rollback() return self.hud_dict[temp_key].cards = self.get_cards(new_hand_id) [aw.update_data(new_hand_id, self.db_connection) for aw in self.hud_dict[temp_key].aux_windows] self.update_HUD(new_hand_id, temp_key, self.config) # Or create a new HUD else: # get stats using default params--also get cards self.db_connection.init_hud_stat_vars( self.hud_params['hud_days'], self.hud_params['h_hud_days'] ) stat_dict = self.db_connection.get_stats_from_hand(new_hand_id, type, self.hud_params, self.hero_ids[site_id], num_seats) cards = self.get_cards(new_hand_id) table_kwargs = dict(table_name=table_name, tournament=tour_number, table_number=tab_number) tablewindow = Tables.Table(self.config, site_name, **table_kwargs) if tablewindow is None: # If no client window is found on the screen, complain and continue if type == "tour": table_name = "%s %s" % (tour_number, tab_number) log.error("HUD create: table name %s not found, skipping." % table_name) else: tablewindow.key = temp_key tablewindow.max = max tablewindow.site = site_name # Test that the table window still exists if hasattr(tablewindow, 'number'): self.create_HUD(new_hand_id, tablewindow, temp_key, max, poker_game, type, stat_dict, cards) else: log.error('Table "%s" no longer exists\n' % table_name) if type == "tour": self.hud_dict[temp_key].table.check_table_no(self.hud_dict[temp_key]) def get_cards(self, new_hand_id): cards = self.db_connection.get_cards(new_hand_id) comm_cards = self.db_connection.get_common_cards(new_hand_id) if comm_cards != {}: # stud! cards['common'] = comm_cards['common'] return cards ###################################################################### # idle FUNCTIONS # # These are passed to the event loop by the non-gui thread to do # gui things in a thread-safe way. They are passed to the event # loop using the gobject.idle_add() function. # # A general rule for gtk is that only 1 thread should be messing # with the gui. def idle_resize(hud): gtk.gdk.threads_enter() try: [aw.update_card_positions() for aw in hud.aux_windows] hud.resize_windows() except: log.exception("Error resizing HUD for table: %s." % hud.table.title) finally: gtk.gdk.threads_leave() def idle_kill(hud_main, table): gtk.gdk.threads_enter() try: if table in hud_main.hud_dict: hud_main.hud_dict[table].kill() hud_main.vb.remove(hud_main.hud_dict[table].tablehudlabel) del(hud_main.hud_dict[table]) hud_main.main_window.resize(1, 1) except: log.exception("Error killing HUD for table: %s." % table.title) finally: gtk.gdk.threads_leave() def idle_create(hud_main, new_hand_id, table, temp_key, max, poker_game, type, stat_dict, cards): gtk.gdk.threads_enter() try: table.gdkhandle = gtk.gdk.window_foreign_new(table.number) newlabel = gtk.Label("%s - %s" % (table.site, temp_key)) hud_main.vb.add(newlabel) newlabel.show() hud_main.main_window.resize_children() hud_main.hud_dict[temp_key].tablehudlabel = newlabel hud_main.hud_dict[temp_key].create(new_hand_id, hud_main.config, stat_dict, cards) for m in hud_main.hud_dict[temp_key].aux_windows: m.create() m.update_gui(new_hand_id) hud_main.hud_dict[temp_key].update(new_hand_id, hud_main.config) hud_main.hud_dict[temp_key].reposition_windows() except: log.exception("Error creating HUD for hand %s." % new_hand_id) finally: gtk.gdk.threads_leave() return False def idle_update(hud_main, new_hand_id, table_name, config): gtk.gdk.threads_enter() try: hud_main.hud_dict[table_name].update(new_hand_id, config) [aw.update_gui(new_hand_id) for aw in hud_main.hud_dict[table_name].aux_windows] except: log.exception("Error updating HUD for hand %s." % new_hand_id) finally: gtk.gdk.threads_leave() return False if __name__== "__main__": # start the HUD_main object hm = HUD_main(db_name = options.dbname) # start the event loop gtk.main()