f1921bebde
Doesn't actually do much cleanup. Intend on moving all db functions into Database.py and fpdb_db.py and providing and API, the functionality of fpdb_simple et all to shift into the HHC
189 lines
9.5 KiB
Python
189 lines
9.5 KiB
Python
#!/usr/bin/python
|
|
|
|
#Copyright 2008 Steffen Jobbagy-Felso
|
|
#This program is free software: you can redistribute it and/or modify
|
|
#it under the terms of the GNU Affero General Public License as published by
|
|
#the Free Software Foundation, version 3 of the License.
|
|
#
|
|
#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 Affero General Public License
|
|
#along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
#In the "official" distribution you can find the license in
|
|
#agpl-3.0.txt in the docs folder of the package.
|
|
|
|
#methods that are specific to holdem but not trivial
|
|
|
|
import fpdb_simple
|
|
import Database
|
|
|
|
#parses a holdem hand
|
|
def mainParser(settings, fdb, siteID, category, hand, config):
|
|
backend = settings['db-backend']
|
|
#This is redundant - hopefully fdb will be a Database object in an interation soon
|
|
db = Database.Database(config, 'fpdb', '')
|
|
category = fpdb_simple.recogniseCategory(hand[0])
|
|
|
|
base = "hold" if category == "holdem" or category == "omahahi" or category == "omahahilo" else "stud"
|
|
|
|
#part 0: create the empty arrays
|
|
lineTypes = [] #char, valid values: header, name, cards, action, win, rake, ignore
|
|
lineStreets = [] #char, valid values: (predeal, preflop, flop, turn, river)
|
|
|
|
cardValues, cardSuits, boardValues, boardSuits, antes, actionTypes, allIns, actionAmounts, actionNos, actionTypeByNo, seatLines, winnings, rakes=[],[],[],[],[],[],[],[],[],[],[],[],[]
|
|
|
|
#part 1: read hand no and check for duplicate
|
|
siteHandNo = fpdb_simple.parseSiteHandNo(hand[0])
|
|
#print "siteHandNo =", siteHandNo
|
|
handStartTime = fpdb_simple.parseHandStartTime(hand[0])
|
|
|
|
isTourney = fpdb_simple.isTourney(hand[0])
|
|
smallBlindLine = 0
|
|
for i, line in enumerate(hand):
|
|
if 'posts small blind' in line or 'posts the small blind' in line:
|
|
if line[-2:] == "$0": continue
|
|
smallBlindLine = i
|
|
break
|
|
#print "small blind line:",smallBlindLine
|
|
|
|
gametypeID = fpdb_simple.recogniseGametypeID(backend, fdb.db, fdb.cursor, hand[0], hand[smallBlindLine], siteID, category, isTourney)
|
|
if isTourney:
|
|
siteTourneyNo = fpdb_simple.parseTourneyNo(hand[0])
|
|
buyin = fpdb_simple.parseBuyin(hand[0])
|
|
fee = fpdb_simple.parseFee(hand[0])
|
|
entries = -1 #todo: parse this
|
|
prizepool = -1 #todo: parse this
|
|
knockout = 0
|
|
tourneyStartTime= handStartTime #todo: read tourney start time
|
|
rebuyOrAddon = fpdb_simple.isRebuyOrAddon(hand[0])
|
|
|
|
tourneyTypeId = fpdb_simple.recogniseTourneyTypeId(fdb.cursor, siteID, buyin, fee, knockout, rebuyOrAddon)
|
|
|
|
fpdb_simple.isAlreadyInDB(fdb.cursor, gametypeID, siteHandNo)
|
|
|
|
hand = fpdb_simple.filterCrap(hand, isTourney)
|
|
|
|
#part 2: classify lines by type (e.g. cards, action, win, sectionchange) and street
|
|
fpdb_simple.classifyLines(hand, category, lineTypes, lineStreets)
|
|
|
|
#part 3: read basic player info
|
|
#3a read player names, startcashes
|
|
for i, line in enumerate(hand):
|
|
if lineTypes[i] == "name":
|
|
seatLines.append(line)
|
|
|
|
names = fpdb_simple.parseNames(seatLines)
|
|
playerIDs = fpdb_simple.recognisePlayerIDs(fdb.cursor, names, siteID)
|
|
tmp = fpdb_simple.parseCashesAndSeatNos(seatLines)
|
|
startCashes = tmp['startCashes']
|
|
seatNos = tmp['seatNos']
|
|
|
|
fpdb_simple.createArrays(category, len(names), cardValues, cardSuits, antes, winnings, rakes, actionTypes, allIns, actionAmounts, actionNos, actionTypeByNo)
|
|
|
|
#3b read positions
|
|
if base == "hold":
|
|
positions = fpdb_simple.parsePositions(hand, names)
|
|
|
|
#part 4: take appropriate action for each line based on linetype
|
|
for i, line in enumerate(hand):
|
|
if lineTypes[i] == "cards":
|
|
fpdb_simple.parseCardLine(category, lineStreets[i], line, names, cardValues, cardSuits, boardValues, boardSuits)
|
|
#if category=="studhilo":
|
|
# print "hand[i]:", hand[i]
|
|
# print "cardValues:", cardValues
|
|
# print "cardSuits:", cardSuits
|
|
elif lineTypes[i] == "action":
|
|
fpdb_simple.parseActionLine(base, isTourney, line, lineStreets[i], playerIDs, names, actionTypes, allIns, actionAmounts, actionNos, actionTypeByNo)
|
|
elif lineTypes[i] == "win":
|
|
fpdb_simple.parseWinLine(line, names, winnings, isTourney)
|
|
elif lineTypes[i] == "rake":
|
|
totalRake = 0 if isTourney else fpdb_simple.parseRake(line)
|
|
fpdb_simple.splitRake(winnings, rakes, totalRake)
|
|
elif lineTypes[i]=="header" or lineTypes[i]=="rake" or lineTypes[i]=="name" or lineTypes[i]=="ignore":
|
|
pass
|
|
elif lineTypes[i]=="ante":
|
|
fpdb_simple.parseAnteLine(line, isTourney, names, antes)
|
|
elif lineTypes[i]=="table":
|
|
tableResult=fpdb_simple.parseTableLine(base, line)
|
|
else:
|
|
raise fpdb_simple.FpdbError("unrecognised lineType:"+lineTypes[i])
|
|
|
|
maxSeats = tableResult['maxSeats']
|
|
tableName = tableResult['tableName']
|
|
#print "before part5, antes:", antes
|
|
|
|
#part 5: final preparations, then call Database.* with
|
|
# the arrays as they are - that file will fill them.
|
|
fpdb_simple.convertCardValues(cardValues)
|
|
if base == "hold":
|
|
fpdb_simple.convertCardValuesBoard(boardValues)
|
|
fpdb_simple.convertBlindBet(actionTypes, actionAmounts)
|
|
fpdb_simple.checkPositions(positions)
|
|
|
|
fdb.cursor.execute("SELECT limitType FROM Gametypes WHERE id=%s",(gametypeID, ))
|
|
limit_type = fdb.cursor.fetchone()[0]
|
|
fpdb_simple.convert3B4B(category, limit_type, actionTypes, actionAmounts)
|
|
|
|
totalWinnings = sum(winnings)
|
|
|
|
# if hold'em, use positions and not antes, if stud do not use positions, use antes
|
|
# this is used for handsplayers inserts, so still needed even if hudcache update is being skipped
|
|
if base == "hold":
|
|
hudImportData = fpdb_simple.generateHudCacheData(playerIDs, base, category, actionTypes
|
|
, allIns, actionTypeByNo, winnings, totalWinnings, positions
|
|
, actionTypes, actionAmounts, None)
|
|
else:
|
|
hudImportData = fpdb_simple.generateHudCacheData(playerIDs, base, category, actionTypes
|
|
, allIns, actionTypeByNo, winnings, totalWinnings, None
|
|
, actionTypes, actionAmounts, antes)
|
|
|
|
if isTourney:
|
|
ranks = map(lambda x: 0, names) # create an array of 0's equal to the length of names
|
|
payin_amounts = fpdb_simple.calcPayin(len(names), buyin, fee)
|
|
|
|
if base == "hold":
|
|
result = db.tourney_holdem_omaha(
|
|
config, settings, fdb.db, fdb.cursor, base, category, siteTourneyNo, buyin
|
|
, fee, knockout, entries, prizepool, tourneyStartTime
|
|
, payin_amounts, ranks, tourneyTypeId, siteID, siteHandNo
|
|
, gametypeID, handStartTime, names, playerIDs, startCashes
|
|
, positions, cardValues, cardSuits, boardValues, boardSuits
|
|
, winnings, rakes, actionTypes, allIns, actionAmounts
|
|
, actionNos, hudImportData, maxSeats, tableName, seatNos)
|
|
elif base == "stud":
|
|
result = db.tourney_stud(
|
|
config, settings, fdb.db, fdb.cursor, base, category, siteTourneyNo
|
|
, buyin, fee, knockout, entries, prizepool, tourneyStartTime
|
|
, payin_amounts, ranks, tourneyTypeId, siteID, siteHandNo
|
|
, gametypeID, handStartTime, names, playerIDs, startCashes
|
|
, antes, cardValues, cardSuits, winnings, rakes, actionTypes
|
|
, allIns, actionAmounts, actionNos, hudImportData, maxSeats
|
|
, tableName, seatNos)
|
|
else:
|
|
raise fpdb_simple.FpdbError("unrecognised category")
|
|
else:
|
|
if base == "hold":
|
|
result = db.ring_holdem_omaha(
|
|
config, settings, fdb.db, fdb.cursor, base, category, siteHandNo
|
|
, gametypeID, handStartTime, names, playerIDs
|
|
, startCashes, positions, cardValues, cardSuits
|
|
, boardValues, boardSuits, winnings, rakes
|
|
, actionTypes, allIns, actionAmounts, actionNos
|
|
, hudImportData, maxSeats, tableName, seatNos)
|
|
elif base == "stud":
|
|
result = db.ring_stud(
|
|
config, settings, fdb.db, fdb.cursor, base, category, siteHandNo, gametypeID
|
|
, handStartTime, names, playerIDs, startCashes, antes
|
|
, cardValues, cardSuits, winnings, rakes, actionTypes, allIns
|
|
, actionAmounts, actionNos, hudImportData, maxSeats, tableName
|
|
, seatNos)
|
|
else:
|
|
raise fpdb_simple.FpdbError ("unrecognised category")
|
|
fdb.db.commit()
|
|
return result
|
|
#end def mainParser
|
|
|