""" Bidding data for JFR Pary result pages. Utility to insert HTML tables with bidding data into traveller files generated by JFR Pary. """ import sys import glob import re import pypyodbc import logging as log from os import path, remove from bs4 import BeautifulSoup as bs4 __version__ = '1.0.1' def parse_lineup_data(sitting_data): """ Convert BWS lineup to dictionary structure. Structure: {round}.{sector}_{table}.{pair numbers} """ round_lineups = {} for sitting in sitting_data: log.getLogger('lineup').debug(sitting) round_no = sitting[2] if sitting[2] is not None else 0 table_no = str(sitting[0]) + '_' + str(sitting[1]) lineup = sorted([sitting[3], sitting[4]]) if round_no not in round_lineups: round_lineups[round_no] = {} round_lineups[round_no][table_no] = lineup log.getLogger('lineup').debug('round %d, table %s: %s', round_no, table_no, lineup) return round_lineups def parse_bidding_data(bidding_data): """ Convert BWS bidding to dictionary structure. Keys: {board}_{round}_{sector}_{table}.{sector}_{table}.{round} Values: {bidding}[] Applies call erasures. """ bids = {} for bid in bidding_data: log.getLogger('bidding').debug(bid) round_no = bid[3] table_no = str(bid[1]) + '_' + str(bid[2]) board_no = str(bid[4]) + '_' + str(round_no) + '_' + table_no bid_counter = bid[5] bid_erased = bid[10] if board_no not in bids: bids[board_no] = {} if table_no not in bids[board_no]: bids[board_no][table_no] = {} if round_no not in bids[board_no][table_no]: bids[board_no][table_no][round_no] = {} if bid_erased == 1: if bid_counter in bids[board_no][table_no][round_no]: if bids[board_no][table_no][round_no][bid_counter][ 'direction'] == bid[6]: bids[board_no][table_no][round_no].pop( bid_counter, None) log.getLogger('bidding').debug( 'erased bid %d from board %s, ' + 'round %s, table %s-%s', bid_counter, *board_no.split('_')) if len(bids[board_no][table_no][round_no]) == 0: bids[board_no][table_no].pop(round_no, None) log.getLogger('bidding').debug( 'bidding on board %s, round %s, ' + 'table %s-%s empty, removing', *board_no.split('_')) else: log.getLogger('bidding').debug( 'bid does not match, not removing') else: bids[board_no][table_no][round_no][bid_counter] = { 'direction': bid[6], 'bid': bid[7]} log.getLogger('bidding').debug( 'board %s, round %s, table %s-%s, bid %d: %s by %s', *(board_no.split('_') + [bid_counter, bid[7], bid[6]])) return bids def get_dealer(bidding): """Return first player to call in a bidding.""" return bidding[min(bidding.keys())]['direction'] def get_last_bidder(bidding): """Return last player to call in a bidding.""" return bidding[max(bidding.keys())]['direction'] class JFRBidding(object): """Bidding data converter (from BWS data to JFR HTML pages).""" # alignment of the bidding table __directions = ['W', 'N', 'E', 'S'] def __format_bidding(self, bidding): """Convert bidding data to properly formatted HTML table.""" log.getLogger('b_format').debug('formatting bidding: %s', bidding) bid_match = re.compile(r'(\d)([SHDCN])') html_output = bs4('', 'lxml') header_row = html_output.new_tag('tr') html_output.table.append(header_row) for direction in self.__directions: header_cell = html_output.new_tag('th') header_cell.string = direction header_row.append(header_cell) for bid_round in bidding: bidding_row = html_output.new_tag('tr') html_output.table.append(bidding_row) for bid in bid_round: bid_cell = html_output.new_tag('td') call_match = re.match(bid_match, bid) if call_match: bid_cell.append(call_match.group(1)) bid_icon = html_output.new_tag( 'img', src='images/' + call_match.group(2) + '.gif') bid_cell.append(bid_icon) else: bid_cell.append(bid) bidding_row.append(bid_cell) log.getLogger('b_format').debug('%5s' * 4, *bid_round) return html_output.table.prettify() def __get_bidding_file_output_path(self, board_no, round_no=None, table_no=None, pair_numbers=None): """ Compile file path for bidding data (HTML file with bidding). Path format: {prefix}_bidding_{jfr_board_number}_{pair_numbers}.txt """ if pair_numbers is None: # read numbers from lineup pair_numbers = self.__round_lineups[round_no][table_no] return u'{0}_bidding_{1:03}_{2}.txt'.format( self.__tournament_prefix, board_no, '_'.join([str(num) for num in pair_numbers])) def __map_board_numbers(self): """ Map BWS board numbers to JFR board numbers. Filters boards to these present in both sets of data. """ self.__tournament_files = [ f for f in glob.glob(self.__tournament_prefix + '*.html') if re.search(self.__tournament_files_match, f)] log.getLogger('b_map').debug('found %d possible board files to map', len(self.__tournament_files)) for round_data in self.__lineup_data: log.getLogger('b_map').debug('round data: %s', round_data) # 13th column has JFR number for the first board if len(round_data) > 12: jfr_number = round_data[12] round_no = round_data[2] sector_no = round_data[0] table_no = round_data[1] if jfr_number and round_no: # 5th and 6th - actual board number for board_number in range(int(round_data[5]), int(round_data[6])+1): board_string = '_'.join([ str(board_number), str(round_no), str(sector_no), str(table_no)]) board_no = jfr_number + board_number - round_data[5] self.__board_number_mapping[ board_string ] = board_no log.getLogger('b_map').debug('mapping %s -> %d', board_string, board_no) # only include these board numbers from mapping # which actually exist in JFR output custom_files = [] for b_number, jfr_number in self.__board_number_mapping.iteritems(): board_files = [ f for f in self.__tournament_files if f.endswith('{0:03}.html'.format(jfr_number))] if len(board_files): custom_files = custom_files + board_files else: self.__board_number_mapping[b_number] = None log.getLogger('b_map').debug( 'board %s -> %d not in board files, ignoring', b_number, jfr_number) self.__tournament_files = list(set(custom_files)) def __compile_bidding(self, bidding): """Compile two-dimensional bidding table from a list of calls.""" bidding_table = [[], [], [], []] # compile bidding player-by-player for bid_index in sorted(bidding): bid = bidding[bid_index] bidding_table[ self.__directions.index( bid['direction']) ].append(bid['bid']) return bidding_table def __form_bidding(self, bidding_table, dealer, last_bidder): """Format bidding table in equally sized, full rows.""" # fill skipped calls for players before dealer # in the first round of bidding for pos in range( 0, self.__directions.index(dealer)): bidding_table[pos].insert(0, '') # fill skipped calls for players after pass out # (so that bidding table is a proper matrix) for pos in range( self.__directions.index(last_bidder), len(self.__directions)): bidding_table[pos].append('') # transpose the bidding table # aligning it row-by-row (bid round-by-round) return [list(row) for row in zip(*bidding_table)] def __write_bidding_file(self, board_text_path, file_number): """Alter traveller file to include links to bidding tables.""" with file(board_text_path, 'r+') as board_text: board_text_content = bs4( board_text, 'lxml') used_files = [] for row in board_text_content.select('tr'): cells = row.select('td') debug_string = ' '.join([ ''.join([ cc for cc in c.contents if isinstance(cc, basestring)]).strip() for c in cells]) log.getLogger('links').debug('row: %s', debug_string) # traveller table rows for specific score entries # should have 11 cells if len(cells) == 11: try: pair_numbers = sorted([ int(cells[1].contents[0]), int(cells[2].contents[0])]) log.getLogger('links').debug( 'pairs: %s', pair_numbers) except ValueError: log.getLogger('links').debug( 'invalid pair numbers, skipping') continue bidding_link = board_text_content.new_tag( 'a', href='#', **{'class': 'biddingLink'}) bidding_link.string = ' ' bidding_path = self.__get_bidding_file_output_path( int(file_number, 10), pair_numbers=pair_numbers) bidding_link['data-bidding-link'] = path.basename( bidding_path) # only append link if we've got bidding data if path.isfile(path.join( path.dirname(self.__tournament_prefix), bidding_link['data-bidding-link'])): if bidding_path in self.__bidding_files: used_files.append(bidding_path) log.getLogger('links').info( 'linking: %s', bidding_link['data-bidding-link']) # fourth cell is the contract for link in cells[3].select('a.biddingLink'): log.getLogger('links').debug( 'removing existing link') link.extract() cells[3].append(bidding_link) else: log.getLogger('links').warning( 'bidding for file path %s not found', bidding_link['data-bidding-link']) else: log.getLogger('links').debug('skipping row') board_text.seek(0) board_text.write(board_text_content.table.prettify( 'utf-8', formatter='html')) board_text.truncate() return used_files # sitting read from BWS __round_lineups = {} # bidding read from BWS __bids = {} # full path + JFR prefix __tournament_prefix = '' # RegEx matching board HTML files __tournament_files_match = None # matched files, including board number mapping boundaries __tournament_files = [] # BWS number -> JFR number mapping __board_number_mapping = {} # all generated bidding table files, for cleanup purposes __bidding_files = [] def __init__(self, bws_file, file_prefix): """Construct parser object.""" log.getLogger('init').debug('reading BWS file: %s', bws_file) with pypyodbc.win_connect_mdb(bws_file) as connection: cursor = connection.cursor() self.__lineup_data = cursor.execute( 'SELECT * FROM RoundData').fetchall() bid_data = cursor.execute('SELECT * FROM BiddingData').fetchall() log.getLogger('init').debug('parsing lineup data (%d entries)', len(self.__lineup_data)) self.__round_lineups = parse_lineup_data(self.__lineup_data) log.getLogger('init').debug('parsing bidding data (%d entries)', len(bid_data)) self.__bids = parse_bidding_data(bid_data) log.getLogger('init').debug('parsing prefix, filename = %s', file_prefix) self.__tournament_prefix = path.splitext( path.realpath(file_prefix))[0] log.getLogger('init').debug('prefix = %s', self.__tournament_prefix) self.__tournament_files_match = re.compile( re.escape(self.__tournament_prefix) + r'([0-9]{3})\.html') log.getLogger('init').debug('tournament files pattern: %s', self.__tournament_files_match.pattern) self.__map_board_numbers() def write_bidding_tables(self): """Iterate over bidding and writes tables to HTML files.""" for board_no, board_data in self.__bids.items(): if board_no in self.__board_number_mapping: for table_no, table_data in board_data.items(): for round_no, round_data in table_data.items(): if round_no in self.__round_lineups: if table_no in self.__round_lineups[round_no]: dealer = get_dealer(round_data) log.getLogger('tables').debug( 'board %s: %d bids, dealer %s', board_no, len(round_data), dealer) last_bidder = get_last_bidder(round_data) bidding_table = self.__compile_bidding( round_data) bidding_table = self.__form_bidding( bidding_table, dealer, last_bidder) log.getLogger('tables').debug( 'compiled into %d rounds of bidding', len(bidding_table)) bidding_fpath = \ self.__get_bidding_file_output_path( self.__board_number_mapping[board_no], round_no, table_no) self.__bidding_files.append(bidding_fpath) with file(bidding_fpath, 'w') as bidding_file: bidding_file.write( self.__format_bidding(bidding_table)) log.getLogger('tables').info( 'written bidding table to %s', bidding_fpath) else: log.getLogger('tables').info( 'lineup for table %s, round %s not found', table_no, round_no) print self.__round_lineups[round_no] else: log.getLogger('tables').info( 'lineup for round %s not found', round_no) else: log.getLogger('tables').info('mapping for board %s not found', board_no) def write_bidding_scripts(self): """Alter traveller files to include necessary JavaScript.""" for tournament_file in self.__tournament_files: log.getLogger('scripts').info('writing scripts into: %s', tournament_file) with file(tournament_file, 'r+') as board_html: board_content = bs4(board_html, 'lxml', from_encoding='utf-8') header_scripts = board_content.select('head script') # check for jQuery, append if necessary jquery_scripts = [script for script in header_scripts if script['src'] == 'javas/jquery.js'] if not len(jquery_scripts): jquery = board_content.new_tag( 'script', src='javas/jquery.js', type='text/javascript') jquery_scripts.append(jquery) board_content.head.append(jquery) log.getLogger('scripts').debug('jQuery not found, adding') # check for bidding.js bidding_scripts = [ script for script in header_scripts if script['src'] == 'javas/bidding.js'] log.getLogger('scripts').debug('found %d bidding.js scripts', len(bidding_scripts)) # and make sure bidding.js is appended after jQuery for script in bidding_scripts: script.extract() bidding_script = board_content.new_tag( 'script', src='javas/bidding.js', type='text/javascript') jquery_scripts[0].insert_after(bidding_script) board_html.seek(0) board_html.write(board_content.prettify( 'utf-8', formatter='html')) board_html.truncate() def write_bidding_links(self): """ Iterate over traveller files to include links to bidding tables. Cleans up bidding table files, which are not used. """ used_bidding_tables = [] for tournament_file in self.__tournament_files: file_number = re.match( self.__tournament_files_match, tournament_file).group(1) board_text_path = path.splitext(tournament_file)[0] + '.txt' log.getLogger('links').info('writing traveller for board %s: %s', file_number, board_text_path) used_bidding_tables = self.__write_bidding_file( board_text_path, file_number) + used_bidding_tables log.getLogger('links').info('used board files: %s', ', '.join(used_bidding_tables)) for unused_file in [unused for unused in self.__bidding_files if unused not in used_bidding_tables]: log.getLogger('links').warning( 'bidding file %s not used, deleting', unused_file) remove(unused_file) def main(): """Program entry point, invoked when __name__ is __main__.""" import argparse argument_parser = argparse.ArgumentParser( description='Display bidding data from BWS files on JFR Pary pages') def file_path(filepath): """Sanitize and validate file paths from input parameters.""" filepath = unicode(filepath, sys.getfilesystemencoding()) if path.isfile(filepath): return filepath else: argument_parser.error('File %s does not exist' % filepath) argument_parser.add_argument('-V', '--version', action='version', version='%(prog)s {version}'.format( version=__version__)) argument_parser.add_argument('bws_file', metavar='BWS_FILE', help='path to BWS file', type=file_path) argument_parser.add_argument('path', metavar='PATH', help='tournament path (to PREFIX.html)', type=file_path) console_output_args = argument_parser.add_mutually_exclusive_group() console_output_args.add_argument('-q', '--quiet', action='store_true', help='suppress warning on STDERR') console_output_args.add_argument('-v', '--verbose', action='store_true', help='be verbose on STDERR') argument_parser.add_argument('-l', '--log-level', metavar='LEVEL', help='file logging verbosity level', default='INFO', choices=['DEBUG', 'INFO', 'WARNING', 'ERROR', 'CRITICAL']) argument_parser.add_argument('-f', '--log-file', metavar='LOGFILE', help='log file path', default='bidding_data.log') arguments = argument_parser.parse_args() # primary logging facility - virtual_table.log file log.basicConfig( level=getattr(log, arguments.log_level), format='%(asctime)s %(levelname)-8s %(name)-8s %(message)s', datefmt='%Y-%m-%d %H:%M:%S', filename=arguments.log_file) # secondary logging facility - standard error output console_log = log.StreamHandler() console_log.setLevel(log.INFO if arguments.verbose else ( log.ERROR if arguments.quiet else log.WARNING)) console_log.setFormatter(log.Formatter( '%(levelname)-8s %(name)-8s: %(message)s')) log.getLogger().addHandler(console_log) log.info('-------- program started --------') log.debug('parsed arguments: %s', arguments) try: bidding_parser = JFRBidding( bws_file=arguments.bws_file, file_prefix=arguments.path, ) bidding_parser.write_bidding_tables() bidding_parser.write_bidding_scripts() bidding_parser.write_bidding_links() except Exception as ex: log.getLogger('root').error(ex.strerror) raise log.info('--------- program ended ---------') if __name__ == '__main__': main()