ige.ospace.IGalaxy.IGalaxy.processBATTLEPhase() - Code Metrics - Inspection of "Renegade refresh" - ospaceteam/outerspace - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Pull Request — master (#225)

by Marek

created 2018-07-07 11:36 UTC

ige.ospace.IGalaxy.IGalaxy.processBATTLEPhase() A

↳ Parent: ige.ospace.IGalaxy

Complexity

Conditions

Size

Total Lines	5
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	2
eloc	5
nop	4
dl	0
loc	5
rs	10
c	0
b	0
f	0

#
#  Copyright 2001 - 2016 Ludek Smid [http://www.ospace.net/]
#
#  This file is part of Outer Space.
#
#  Outer Space 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.
#
#  Outer Space 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 Outer Space; if not, write to the Free Software
#  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
#

import os.path
import time
import copy
import random

from xml.dom.minidom import Node, parse

import ige
import IPlayer
import IAIPlayer
import IAIEDENPlayer
import IAIMutantPlayer
import IAIPiratePlayer
import IAIRenegadePlayer
import Const
import Rules
import Scanner
import Utils

from ige import log
from ige.IObject import IObject
from ige.IDataHolder import IDataHolder
from ige.IObject import public
from ISystem import ISystem
from Rules import Tech


class IGalaxy(IObject):

    typeID = Const.T_GALAXY
    forums = {"PUBLIC": 112, "NEWS": 112}

    def init(self, obj):
        IObject.init(self, obj)
        #
        obj.name = ""
        obj.owner = Const.OID_NONE
        obj.x = 0.0
        obj.y = 0.0
        obj.radius = 0.0
        obj.centerWeight = 250.0
        obj.systems = []
        obj.startingPos = []
        obj.numOfStartPos = 0
        obj.timeEnabled = None # none instead of False, to know when first enablement is happening
        obj.timePaused = False # this is only used for player-initiated pause, prevents autoenablement
        obj.creationTurn = 0
        obj.imperator = Const.OID_NONE
        obj.description = ""
        obj.scenario = Const.SCENARIO_NONE
        obj.scenarioData = IDataHolder()
        # electromagnetic radiation
        obj.emrLevel = 1.0
        obj.emrTrend = 1.0
        obj.emrTime = 0
        # galaxy keeps track of it's own time as well (because of pauses)
        obj.galaxyTurn = 0

    def update(self, tran, obj):
        # check existence of all systems
        if 0:
            for systemID in obj.systems:
                if not tran.db.has_key(systemID):
                    log.debug("CONSISTENCY - system %d from galaxy %d does not exists" % (systemID, obj.oid))
                elif tran.db[systemID].type not in (Const.T_SYSTEM, Const.T_WORMHOLE):
                    log.debug("CONSISTENCY - system %d from galaxy %d is not a Const.T_SYSTEM or Const.T_WORMHOLE" % (systemID, obj.oid))
        # validate starting positions
        for planetID in obj.startingPos[:]:
            if not tran.db.has_key(planetID):
                log.debug("REMOVING nonexistent obj from start pos", planetID)
                obj.startingPos.remove(planetID)
                continue
            planet = tran.db[planetID]
            if planet.type != Const.T_PLANET:
                log.debug("REMOVING ??? from start pos", planetID)
                obj.startingPos.remove(planetID)
        # check compOf
        if not tran.db.has_key(obj.compOf) or tran.db[obj.compOf].type != Const.T_UNIVERSE:
            log.debug("CONSISTENCY invalid compOf for galaxy", obj.oid, obj.compOf)
        # TODO: remove after 0.5.73
        if not hasattr(obj, 'galaxyTurn'):
            obj.galaxyTurn = 0
        obj.timeEnabled = bool(obj.timeEnabled)


    update.public = 0

    def getReferences(self, tran, obj):
        return obj.systems

    getReferences.public = 0

    @staticmethod
    def getFreeStartingPosition(db, obj):
        while 1:
            planetID = random.choice(obj.startingPos)
            obj.startingPos.remove(planetID)
            log.debug('Starting point', planetID)
            log.debug('Starting point - owner', db[planetID].owner)
            if db[planetID].owner == Const.OID_NONE:
                return planetID
            if not obj.startingPos:
                raise ige.GameException('No free starting point in the galaxy.')

    @public(Const.AL_ADMIN)
    def processINITPhase(self, tran, obj, data):
        if not obj.timeEnabled:
            return
        # compute emr level
        turn = tran.db[Const.OID_UNIVERSE].turn
        # galaxy keeps track of it's own time (because of pauses)
        obj.galaxyTurn += 1
        obj.emrTime -= 1
        if obj.emrTime <= 0:
            modulo = turn % Rules.emrPeriod
            for season in Rules.emrSeasons:
                if modulo >= season.startTime and modulo <= season.endTime:
                    log.debug("EMR - season", season.name)
                    obj.emrTrend = Utils.rand(int(season.emrLevelMin * 100), int(season.emrLevelMax * 100) + 1) / 100.0
                    obj.emrTime = Utils.rand(Rules.emrMinDuration, Rules.emrMaxDuration)
                    log.debug("EMR - trend, time", obj.emrTrend, obj.emrTime)
                    message = {
                        "sender": "GNC",
                        "senderID": obj.oid,
                        "forum": "NEWS",
                        "data": (obj.oid, Const.MSG_GNC_EMR_FORECAST, obj.oid, turn, (obj.emrTrend, obj.emrTime)),
                        "topic": "EVENT",
                    }
                    self.cmd(obj).sendMsg(tran, obj, message)
                    break
        elif obj.emrLevel >= obj.emrTrend:
            obj.emrLevel -= Utils.rand(1, 6) / 100.0
        elif obj.emrLevel <= obj.emrTrend:
            obj.emrLevel += Utils.rand(1, 6) / 100.0
        # remove old messages
        self.cmd(obj).deleteOldMsgs(tran, obj)
        return obj.systems

    @public(Const.AL_ADMIN)
    def processPRODPhase(self, tran, obj, data):
        if not obj.timeEnabled:
            return
        return obj.systems

    @public(Const.AL_ADMIN)
    def processACTIONPhase(self, tran, obj, data):
        if not obj.timeEnabled:
            return
        return obj.systems

    @public(Const.AL_ADMIN)
    def processSCAN2Phase(self, tran, obj, data):
        # data == True means forced scan (first after generating the galaxy)
        if not obj.timeEnabled and not data:
            return
        # compute scanner for all objects on the map
        playerMap = Scanner.computeMap(self, tran, obj)
        # distribute map
        for playerID, map in playerMap.iteritems():
            player = tran.db[playerID]
            self.cmd(player).mergeScannerMap(tran, player, map)
        return

    @public(Const.AL_ADMIN)
    def processBATTLEPhase(self, tran, obj, data):
        if not obj.timeEnabled:
            return
        return obj.systems

    @public(Const.AL_ADMIN)
    def processFINALPhase(self, tran, obj, data):
        if not obj.timeEnabled:
            return
        # validate starting positions
        remove = []
        for planetID in obj.startingPos:
            planet = tran.db[planetID]
            if planet.owner != Const.OID_NONE:
                remove.append(planetID)
        for planetID in remove:
            obj.startingPos.remove(planetID)
        return obj.systems

    @public(Const.AL_ADMIN)
    def processFINAL2Phase(self, tran, obj, data):
        if not obj.timeEnabled:
            return
        # save history file
        turn = tran.db[Const.OID_UNIVERSE].turn
        # TODO: reneable history when it's optimized
        if turn % 6 == 0 and False:
            log.debug("Saving history for galaxy", obj.oid, obj.name)
            fh = open(os.path.join(tran.config.configDir,"history/galaxy%d-%06d.xml" % (obj.oid, turn), "w+"))
            print >>fh, '<?xml version="1.0" encoding="UTF-8"?>'
            print >>fh, '<history turn="%d" galaxy="%d" name="%s">' % (turn, obj.oid, obj.name)
            # save systems and owners
            players = {}
            print >>fh, '  <systems>'
            for systemID in obj.systems:
                system = tran.db[systemID]
                owners = {}
                for planetID in system.planets:
                    ownerID = tran.db[planetID].owner
                    if ownerID != Const.OID_NONE:
                        owners[ownerID] = tran.db[ownerID].name
                        players[ownerID] = None
                print >>fh, '    <sys x="%.2f" y="%.2f" name="%s" owners="%s"/>' % (
                    system.x,
                    system.y,
                    system.name,
                    ",".join(owners.values())
                )
            print >>fh, '  </systems>'
            # stats
            print >>fh, '  <stats>'
            for playerID in players:
                player = tran.db[playerID]
                print >>fh, '    <pl name="%s" pop="%d" planets="%d" stucts="%d" cp="%d" mp="%d" rp="%d"/>'% (
                    player.name,
                    player.stats.storPop,
                    player.stats.planets,
                    player.stats.structs,
                    player.stats.prodProd,
                    player.stats.fleetPwr,
                    player.stats.prodSci,
                )
            print >>fh, '  </stats>'
            print >>fh, '</history>'


    @public(Const.AL_ADMIN)
    def loadFromXML(self, tran, obj, file, galaxyType, x, y, name):
        log.message('IGalaxy', 'Parsing XML file...')
        dom = parse(os.path.join('data', file))
        log.message('IGalaxy', 'XML file parsed.')
        assert dom.documentElement.tagName == 'universe'
        for node in dom.documentElement.childNodes:
            if node.nodeType == Node.ELEMENT_NODE and node.tagName == 'galaxy':
                if node.getAttribute('galaxyType') == galaxyType:
                    self.loadDOMNode(tran, obj, node, x, y, name)
                    self.connectWormHoles(tran, obj)
                    return Const.SUCC
        raise ige.GameException('No such id %s in resource' % galaxyType)

    def loadDOMNode(self, tran, obj, node, x, y, name):
        obj.name = name
        obj.x = float(x)
        obj.y = float(y)
        xoff = x - float(node.getAttribute('x'))
        yoff = y - float(node.getAttribute('y'))
        obj.creationTurn = tran.db[Const.OID_UNIVERSE].turn
        for elem in node.childNodes:
            if elem.nodeType == Node.ELEMENT_NODE:
                name = elem.tagName
                if name == 'properties':
                    self.loadDOMAttrs(obj, elem)
                elif name == 'system':
                    system = tran.db[self.createSystem(tran, obj)]
                    self.cmd(system).loadDOMNode(tran, system, xoff, yoff, elem)
                elif name == 'hole':
                    wormHole = tran.db[self.createWormHole(tran, obj)]
                    self.cmd(wormHole).loadDOMNode(tran, wormHole, xoff, yoff, elem)
                else:
                    raise ige.GameException('Unknown element %s' % name)
        return Const.SUCC

    def connectWormHoles(self, tran, obj):
        wormHoles = {}
        for holeID in obj.systems:
            wormHole = tran.db[holeID]
            if wormHole.type == Const.T_WORMHOLE:
                wormHoles[wormHole.name] = holeID

        for holeID in obj.systems:
            wormHole = tran.db[holeID]
            if wormHole.type != Const.T_WORMHOLE:
                continue
            if len(wormHole.destination) == 0:
                raise ige.GameException('Wrong WormHole(%d) definition' % holeID)
            if wormHole.destination == wormHole.name:
                raise ige.GameException('Same destination as position for WormHole(%d)' % holeID)
            destinationOid = wormHoles[wormHole.destination]
            if destinationOid == Const.OID_NONE:
                raise ige.GameException('WormHole(%d) has wrong destination ''%s''' % (holeID, wormHole.destination))
            wormHole.destinationOid = destinationOid

    def createSystem(self, tran, obj):
        system = self.new(Const.T_SYSTEM)
        system.compOf = obj.oid
        oid = tran.db.create(system)
        obj.systems.append(oid)
        return oid

    def createWormHole(self, tran, galaxy):
        hole = self.new(Const.T_WORMHOLE)
        hole.compOf = galaxy.oid
        oid = tran.db.create(hole)
        galaxy.systems.append(oid)
        return oid

    @public(Const.AL_OWNER)
    def toggleTime(self, tran, obj):
        player = tran.db[obj.owner]
        obj.timeEnabled = not obj.timeEnabled
        obj.timePaused = not obj.timeEnabled
        self._trickleTimeToPlayers(tran, obj)
        return obj.timeEnabled

    def _trickleTimeToPlayers(self, tran, obj):
        # enable time for players
        playerIDs = set()
        for systemID in obj.systems:
            system = tran.db[systemID]
            for planetID in system.planets:
                planet = tran.db[planetID]
                playerIDs.add(planet.owner)
        playerIDs.discard(Const.OID_NONE)
        for playerID in playerIDs:
            player = tran.db[playerID]
            if player.timeEnabled != obj.timeEnabled:
                player.timeEnabled = obj.timeEnabled
                player.lastLogin = time.time()
                if player.timeEnabled:
                    Utils.sendMessage(tran, player, Const.MSG_ENABLED_TIME, player.oid, None)
                else:
                    Utils.sendMessage(tran, player, Const.MSG_DISABLED_TIME, player.oid, None)

    def _isEligibleEnableTime(self, tran, obj):
        if obj.timeEnabled or obj.timePaused:
            # explicitly paused galaxy needs to be explicitly unpaused
            return False
        # We have to give players some time to prepare
        # (as they might be waiting for very long time for this galaxy to be created).
        currentTurn = tran.db[Const.OID_UNIVERSE].turn
        if obj.creationTurn + Rules.galaxyStartDelay <= currentTurn:
            log.debug("Time to prepare has passed", obj.creationTurn, currentTurn)
            return True
        elif obj.scenario == Const.SCENARIO_SINGLE:
            return True
        return False

    def _firstEnableTime(self, tran, obj):
        # spawn rebel player on all vacant starting positions
        for positionID in copy.copy(obj.startingPos):
            obj.startingPos.remove(positionID)
            # create new player
            log.debug("Creating new Rebel player", Const.T_AIPLAYER)
            player = self.new(Const.T_AIPLAYER)
            self.cmd(player).register(tran, player, obj.oid)
            player.galaxy = obj.oid
            playerID = player.oid
            # TODO tweak more planet's attrs
            planet = tran.db[positionID]
            self.cmd(planet).changeOwner(tran, planet, playerID, 1)
            IAIPlayer.IAIPlayer.setStartingTechnologies(player)
            # fleet
            # add basic ships designs
            # add small fleet
            system = tran.db[planet.compOf]
            IAIPlayer.IAIPlayer.setStartingShipDesigns(player)
            IAIPlayer.IAIPlayer.setStartingPlanet(tran, playerID, planet)
            IAIPlayer.IAIPlayer.setStartingFleet(tran, playerID, system)
            system.scannerPwrs[playerID] = Rules.startingScannerPwr
        # do scanner evaluation because of all new players
        self.cmd(obj).processSCAN2Phase(tran, obj, None)

    @public(Const.AL_ADMIN)
    def enableTime(self, tran, obj, force = False):
        log.debug('IGalaxy', 'Checking for time...')
        if not force and not self._isEligibleEnableTime(tran, obj):
            return
        if obj.timeEnabled is None:
            self._firstEnableTime(tran, obj)
        # ok, enable time
        log.message('IGalaxy', 'Enabling time for', obj.oid)
        obj.timeEnabled = True
        self._trickleTimeToPlayers(tran, obj)

    @public(Const.AL_OWNER)
    def deleteSingle(self, tran, obj):
        if obj.scenario != Const.SCENARIO_SINGLE:
            raise ige.GameException('Only Single Player galaxies can be deleted this way')
        log.debug(obj.oid, "GALAXY - singleplayer delete")
        self.delete(tran, obj)

    @public(Const.AL_ADMIN)
    def delete(self, tran, obj):
        log.debug(obj.oid, "GALAXY - delete")
        universe = tran.db[Const.OID_UNIVERSE]
        # delete systems and planets
        for systemID in obj.systems:
            log.debug("Deleting system", systemID)
            system = tran.db[systemID]
            log.debug("-- planets", system.planets)
            log.debug("-- fleets", system.fleets, system.closeFleets)
            for planetID in system.planets[:]:
                planet = tran.db[planetID]
                self.cmd(planet).changeOwner(tran, planet, Const.OID_NONE, force = 1)
                del tran.db[planetID]
            for fleetID in system.closeFleets[:]:
                fleet = tran.db[fleetID]
                # this will modify system fleet and closeFleets attrs
                self.cmd(fleet).disbandFleet(tran, fleet)
            del tran.db[systemID]
        # delete all remaining fleets
        for playerID in universe.players[:]:
            player = tran.db[playerID]
            if obj.oid != player.galaxy:
                continue
            if player.fleets:
                log.debug("Player %d has still fleets" % playerID, player.name, player.fleets)
                for fleetID in player.fleets:
                    fleet = tran.db[fleetID]
                    log.debug("Fleet NOT DELETED:", fleet)
            if player.planets:
                log.debug("Player %d has still planets" % playerID, player.name, player.planets)
            self.cmd(player).delete(tran, player)
        # remove this galaxy from the list of the galaxies
        tran.db[Const.OID_UNIVERSE].galaxies.remove(obj.oid)
        del tran.db[obj.oid]
        return 1

    @public(Const.AL_NONE)
    def getPublicInfo(self, tran, obj):
        result = IDataHolder()
        result.oid = obj.oid
        result.x = obj.x
        result.y = obj.y
        result.radius = obj.radius
        result.type = obj.type
        result.name = obj.name
        result.emrLevel = obj.emrLevel
        result.scenario = obj.scenario
        result.scenarioData = obj.scenarioData
        result.timeEnabled = obj.timeEnabled
        return result

    @public(Const.AL_NONE)
    def getDescription(self,obj):
        return obj.description

    def _environmentGetVacantPlanets(self, tran, obj):
        vacantPlanets = {}
        for systemID in obj.systems:
            system = tran.db[systemID]
            for planetID in system.planets:
                planet = tran.db[planetID]
                if planet.owner != Const.OID_NONE:
                    continue
                if planet.plStratRes in (Const.SR_TL1A, Const.SR_TL1B):
                    playerType = Const.T_AIRENPLAYER
                elif planet.plStratRes in (Const.SR_TL3A, Const.SR_TL3B, Const.SR_TL3C):
                    playerType = Const.T_AIPIRPLAYER
                elif planet.plStratRes in (Const.SR_TL5A, Const.SR_TL5B, Const.SR_TL5C):
                    playerType = Const.T_AIEDENPLAYER
                elif planet.plDisease != 0:
                    playerType = Const.T_AIMUTPLAYER
                else:
                    continue
                try:
                    vacantPlanets[playerType].append(planetID)
                except KeyError:
                    vacantPlanets[playerType] = [planetID]
        return vacantPlanets

    def _searchForPlayer(self, tran, obj, playerType):
        universe = tran.db[Const.OID_UNIVERSE]
        for playerID in universe.players:
            player = tran.db[playerID]
            if obj.oid == player.galaxy and player.type == playerType:
                return player
        # create new player
        log.debug("Creating new player", playerType)
        player = self.new(playerType)
        self.cmd(player).register(tran, player, obj.oid)
        player.galaxy = obj.oid
        return player

    def _setupEnvironmentRenegade(self, tran, obj, vacantPlanets):
        renType = Const.T_AIRENPLAYER
        planets = vacantPlanets.pop(renType)
        for planetID in planets:
            planet = tran.db[planetID]
            log.debug("Creating new Renegade")
            player = self.new(renType)
            self.cmd(player).register(tran, player, obj.oid)
            player.galaxy = obj.oid
            self.cmd(planet).changeOwner(tran, planet, player.oid, 1)
            IAIRenegadePlayer.IAIRenegadePlayer.setStartingPlanet(tran, planet)

    @public(Const.AL_ADMIN)
    def setupEnvironment(self, tran, obj):
        vacantPlanets = self._environmentGetVacantPlanets(tran, obj)
        self._setupEnvironmentRenegade(tran, obj, vacantPlanets)
        # iterate over types, create players if needed (it should be) and fill in vacant planets
        for playerType in vacantPlanets:
            player = self._searchForPlayer(tran, obj, playerType)
            # now we have a player, let's iterate over vacant planets and set them up
            for planetID in vacantPlanets[playerType]:
                planet = tran.db[planetID]
                self.cmd(planet).changeOwner(tran, planet, player.oid, 1)
                if playerType == Const.T_AIPIRPLAYER:
                    IAIPiratePlayer.IAIPiratePlayer.setStartingPlanet(tran, planet)
                elif playerType == Const.T_AIEDENPLAYER:
                    IAIEDENPlayer.IAIEDENPlayer.setStartingPlanet(tran, planet)
                elif playerType == Const.T_AIMUTPLAYER:
                    IAIMutantPlayer.IAIMutantPlayer.setStartingPlanet(tran, planet)

    ## messaging
    def canGetMsgs(self, tran, obj, oid):
        return 1

    canGetMsgs.public = 0

    def canSendMsg(self, tran, obj, oid, forum):
        if forum == "PUBLIC":
            return 1
        elif forum == "NEWS":
            return 1
        return 0

    canSendMsg.public = 0


1			#
2			# Copyright 2001 - 2016 Ludek Smid [http://www.ospace.net/]
3			#
4			# This file is part of Outer Space.
5			#
6			# Outer Space is free software; you can redistribute it and/or modify
7			# it under the terms of the GNU General Public License as published by
8			# the Free Software Foundation; either version 2 of the License, or
9			# (at your option) any later version.
10			#
11			# Outer Space is distributed in the hope that it will be useful,
12			# but WITHOUT ANY WARRANTY; without even the implied warranty of
13			# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14			# GNU General Public License for more details.
15			#
16			# You should have received a copy of the GNU General Public License
17			# along with Outer Space; if not, write to the Free Software
18			# Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
19			#
20
21			import os.path
22			import time
23			import copy
24			import random
25
26			from xml.dom.minidom import Node, parse
27
28			import ige
29			import IPlayer
30			import IAIPlayer
31			import IAIEDENPlayer
32			import IAIMutantPlayer
33			import IAIPiratePlayer
34			import IAIRenegadePlayer
35			import Const
36			import Rules
37			import Scanner
38			import Utils
39
40			from ige import log
41			from ige.IObject import IObject
42			from ige.IDataHolder import IDataHolder
43			from ige.IObject import public
44			from ISystem import ISystem
45			from Rules import Tech
46
47
48			class IGalaxy(IObject):
49
50			typeID = Const.T_GALAXY
51			forums = {"PUBLIC": 112, "NEWS": 112}
52
53			def init(self, obj):
54			IObject.init(self, obj)
55			#
56			obj.name = ""
57			obj.owner = Const.OID_NONE
58			obj.x = 0.0
59			obj.y = 0.0
60			obj.radius = 0.0
61			obj.centerWeight = 250.0
62			obj.systems = []
63			obj.startingPos = []
64			obj.numOfStartPos = 0
65			obj.timeEnabled = None # none instead of False, to know when first enablement is happening
66			obj.timePaused = False # this is only used for player-initiated pause, prevents autoenablement
67			obj.creationTurn = 0
68			obj.imperator = Const.OID_NONE
69			obj.description = ""
70			obj.scenario = Const.SCENARIO_NONE
71			obj.scenarioData = IDataHolder()
72			# electromagnetic radiation
73			obj.emrLevel = 1.0
74			obj.emrTrend = 1.0
75			obj.emrTime = 0
76			# galaxy keeps track of it's own time as well (because of pauses)
77			obj.galaxyTurn = 0
78
79			def update(self, tran, obj):
80			# check existence of all systems
81			if 0:
82			for systemID in obj.systems:
83			if not tran.db.has_key(systemID):
84			log.debug("CONSISTENCY - system %d from galaxy %d does not exists" % (systemID, obj.oid))
85			elif tran.db[systemID].type not in (Const.T_SYSTEM, Const.T_WORMHOLE):
86			log.debug("CONSISTENCY - system %d from galaxy %d is not a Const.T_SYSTEM or Const.T_WORMHOLE" % (systemID, obj.oid))
87			# validate starting positions
88			for planetID in obj.startingPos[:]:
89			if not tran.db.has_key(planetID):
90			log.debug("REMOVING nonexistent obj from start pos", planetID)
91			obj.startingPos.remove(planetID)
92			continue
93			planet = tran.db[planetID]
94			if planet.type != Const.T_PLANET:
95			log.debug("REMOVING ??? from start pos", planetID)
96			obj.startingPos.remove(planetID)
97			# check compOf
98			if not tran.db.has_key(obj.compOf) or tran.db[obj.compOf].type != Const.T_UNIVERSE:
99			log.debug("CONSISTENCY invalid compOf for galaxy", obj.oid, obj.compOf)
100			# TODO: remove after 0.5.73
101			if not hasattr(obj, 'galaxyTurn'):
102			obj.galaxyTurn = 0
103			obj.timeEnabled = bool(obj.timeEnabled)
104
105
106			update.public = 0
107
108			def getReferences(self, tran, obj):
109			return obj.systems
110
111			getReferences.public = 0
112
113			@staticmethod
114			def getFreeStartingPosition(db, obj):
115			while 1:
116			planetID = random.choice(obj.startingPos)
117			obj.startingPos.remove(planetID)
118			log.debug('Starting point', planetID)
119			log.debug('Starting point - owner', db[planetID].owner)
120			if db[planetID].owner == Const.OID_NONE:
121			return planetID
122			if not obj.startingPos:
123			raise ige.GameException('No free starting point in the galaxy.')
124
125			@public(Const.AL_ADMIN)
126			def processINITPhase(self, tran, obj, data):
127			if not obj.timeEnabled:
128			return
129			# compute emr level
130			turn = tran.db[Const.OID_UNIVERSE].turn
131			# galaxy keeps track of it's own time (because of pauses)
132			obj.galaxyTurn += 1
133			obj.emrTime -= 1
134			if obj.emrTime <= 0:
135			modulo = turn % Rules.emrPeriod
136			for season in Rules.emrSeasons:
137			if modulo >= season.startTime and modulo <= season.endTime:
138			log.debug("EMR - season", season.name)
139			obj.emrTrend = Utils.rand(int(season.emrLevelMin * 100), int(season.emrLevelMax * 100) + 1) / 100.0
140			obj.emrTime = Utils.rand(Rules.emrMinDuration, Rules.emrMaxDuration)
141			log.debug("EMR - trend, time", obj.emrTrend, obj.emrTime)
142			message = {
143			"sender": "GNC",
144			"senderID": obj.oid,
145			"forum": "NEWS",
146			"data": (obj.oid, Const.MSG_GNC_EMR_FORECAST, obj.oid, turn, (obj.emrTrend, obj.emrTime)),
147			"topic": "EVENT",
148			}
149			self.cmd(obj).sendMsg(tran, obj, message)
150			break
151			elif obj.emrLevel >= obj.emrTrend:
152			obj.emrLevel -= Utils.rand(1, 6) / 100.0
153			elif obj.emrLevel <= obj.emrTrend:
154			obj.emrLevel += Utils.rand(1, 6) / 100.0
155			# remove old messages
156			self.cmd(obj).deleteOldMsgs(tran, obj)
157			return obj.systems
158
159			@public(Const.AL_ADMIN)
160			def processPRODPhase(self, tran, obj, data):
161			if not obj.timeEnabled:
162			return
163			return obj.systems
164
165			@public(Const.AL_ADMIN)
166			def processACTIONPhase(self, tran, obj, data):
167			if not obj.timeEnabled:
168			return
169			return obj.systems
170
171			@public(Const.AL_ADMIN)
172			def processSCAN2Phase(self, tran, obj, data):
173			# data == True means forced scan (first after generating the galaxy)
174			if not obj.timeEnabled and not data:
175			return
176			# compute scanner for all objects on the map
177			playerMap = Scanner.computeMap(self, tran, obj)
178			# distribute map
179			for playerID, map in playerMap.iteritems():
180			player = tran.db[playerID]
181			self.cmd(player).mergeScannerMap(tran, player, map)
182			return
183
184			@public(Const.AL_ADMIN)
185			def processBATTLEPhase(self, tran, obj, data):
186			if not obj.timeEnabled:
187			return
188			return obj.systems
189
190			@public(Const.AL_ADMIN)
191			def processFINALPhase(self, tran, obj, data):
192			if not obj.timeEnabled:
193			return
194			# validate starting positions
195			remove = []
196			for planetID in obj.startingPos:
197			planet = tran.db[planetID]
198			if planet.owner != Const.OID_NONE:
199			remove.append(planetID)
200			for planetID in remove:
201			obj.startingPos.remove(planetID)
202			return obj.systems
203
204			@public(Const.AL_ADMIN)
205			def processFINAL2Phase(self, tran, obj, data):
206			if not obj.timeEnabled:
207			return
208			# save history file
209			turn = tran.db[Const.OID_UNIVERSE].turn
210			# TODO: reneable history when it's optimized
211			if turn % 6 == 0 and False:
212			log.debug("Saving history for galaxy", obj.oid, obj.name)
213			fh = open(os.path.join(tran.config.configDir,"history/galaxy%d-%06d.xml" % (obj.oid, turn), "w+"))
214			print >>fh, '<?xml version="1.0" encoding="UTF-8"?>'
215			print >>fh, '<history turn="%d" galaxy="%d" name="%s">' % (turn, obj.oid, obj.name)
216			# save systems and owners
217			players = {}
218			print >>fh, ' <systems>'
219			for systemID in obj.systems:
220			system = tran.db[systemID]
221			owners = {}
222			for planetID in system.planets:
223			ownerID = tran.db[planetID].owner
224			if ownerID != Const.OID_NONE:
225			owners[ownerID] = tran.db[ownerID].name
226			players[ownerID] = None
227			print >>fh, ' <sys x="%.2f" y="%.2f" name="%s" owners="%s"/>' % (
228			system.x,
229			system.y,
230			system.name,
231			",".join(owners.values())
232			)
233			print >>fh, ' </systems>'
234			# stats
235			print >>fh, ' <stats>'
236			for playerID in players:
237			player = tran.db[playerID]
238			print >>fh, ' <pl name="%s" pop="%d" planets="%d" stucts="%d" cp="%d" mp="%d" rp="%d"/>'% (
239			player.name,
240			player.stats.storPop,
241			player.stats.planets,
242			player.stats.structs,
243			player.stats.prodProd,
244			player.stats.fleetPwr,
245			player.stats.prodSci,
246			)
247			print >>fh, ' </stats>'
248			print >>fh, '</history>'
249
250
251			@public(Const.AL_ADMIN)
252			def loadFromXML(self, tran, obj, file, galaxyType, x, y, name):
253			log.message('IGalaxy', 'Parsing XML file...')
254			dom = parse(os.path.join('data', file))
255			log.message('IGalaxy', 'XML file parsed.')
256			assert dom.documentElement.tagName == 'universe'
257			for node in dom.documentElement.childNodes:
258			if node.nodeType == Node.ELEMENT_NODE and node.tagName == 'galaxy':
259			if node.getAttribute('galaxyType') == galaxyType:
260			self.loadDOMNode(tran, obj, node, x, y, name)
261			self.connectWormHoles(tran, obj)
262			return Const.SUCC
263			raise ige.GameException('No such id %s in resource' % galaxyType)
264
265			def loadDOMNode(self, tran, obj, node, x, y, name):
266			obj.name = name
267			obj.x = float(x)
268			obj.y = float(y)
269			xoff = x - float(node.getAttribute('x'))
270			yoff = y - float(node.getAttribute('y'))
271			obj.creationTurn = tran.db[Const.OID_UNIVERSE].turn
272			for elem in node.childNodes:
273			if elem.nodeType == Node.ELEMENT_NODE:
274			name = elem.tagName
275			if name == 'properties':
276			self.loadDOMAttrs(obj, elem)
277			elif name == 'system':
278			system = tran.db[self.createSystem(tran, obj)]
279			self.cmd(system).loadDOMNode(tran, system, xoff, yoff, elem)
280			elif name == 'hole':
281			wormHole = tran.db[self.createWormHole(tran, obj)]
282			self.cmd(wormHole).loadDOMNode(tran, wormHole, xoff, yoff, elem)
283			else:
284			raise ige.GameException('Unknown element %s' % name)
285			return Const.SUCC
286
287			def connectWormHoles(self, tran, obj):
288			wormHoles = {}
289			for holeID in obj.systems:
290			wormHole = tran.db[holeID]
291			if wormHole.type == Const.T_WORMHOLE:
292			wormHoles[wormHole.name] = holeID
293
294			for holeID in obj.systems:
295			wormHole = tran.db[holeID]
296			if wormHole.type != Const.T_WORMHOLE:
297			continue
298			if len(wormHole.destination) == 0:
299			raise ige.GameException('Wrong WormHole(%d) definition' % holeID)
300			if wormHole.destination == wormHole.name:
301			raise ige.GameException('Same destination as position for WormHole(%d)' % holeID)
302			destinationOid = wormHoles[wormHole.destination]
303			if destinationOid == Const.OID_NONE:
304			raise ige.GameException('WormHole(%d) has wrong destination ''%s''' % (holeID, wormHole.destination))
305			wormHole.destinationOid = destinationOid
306
307			def createSystem(self, tran, obj):
308			system = self.new(Const.T_SYSTEM)
309			system.compOf = obj.oid
310			oid = tran.db.create(system)
311			obj.systems.append(oid)
312			return oid
313
314			def createWormHole(self, tran, galaxy):
315			hole = self.new(Const.T_WORMHOLE)
316			hole.compOf = galaxy.oid
317			oid = tran.db.create(hole)
318			galaxy.systems.append(oid)
319			return oid
320
321			@public(Const.AL_OWNER)
322			def toggleTime(self, tran, obj):
323			player = tran.db[obj.owner]
324			obj.timeEnabled = not obj.timeEnabled
325			obj.timePaused = not obj.timeEnabled
326			self._trickleTimeToPlayers(tran, obj)
327			return obj.timeEnabled
328
329			def _trickleTimeToPlayers(self, tran, obj):
330			# enable time for players
331			playerIDs = set()
332			for systemID in obj.systems:
333			system = tran.db[systemID]
334			for planetID in system.planets:
335			planet = tran.db[planetID]
336			playerIDs.add(planet.owner)
337			playerIDs.discard(Const.OID_NONE)
338			for playerID in playerIDs:
339			player = tran.db[playerID]
340			if player.timeEnabled != obj.timeEnabled:
341			player.timeEnabled = obj.timeEnabled
342			player.lastLogin = time.time()
343			if player.timeEnabled:
344			Utils.sendMessage(tran, player, Const.MSG_ENABLED_TIME, player.oid, None)
345			else:
346			Utils.sendMessage(tran, player, Const.MSG_DISABLED_TIME, player.oid, None)
347
348			def _isEligibleEnableTime(self, tran, obj):
349			if obj.timeEnabled or obj.timePaused:
350			# explicitly paused galaxy needs to be explicitly unpaused
351			return False
352			# We have to give players some time to prepare
353			# (as they might be waiting for very long time for this galaxy to be created).
354			currentTurn = tran.db[Const.OID_UNIVERSE].turn
355			if obj.creationTurn + Rules.galaxyStartDelay <= currentTurn:
356			log.debug("Time to prepare has passed", obj.creationTurn, currentTurn)
357			return True
358			elif obj.scenario == Const.SCENARIO_SINGLE:
359			return True
360			return False
361
362			def _firstEnableTime(self, tran, obj):
363			# spawn rebel player on all vacant starting positions
364			for positionID in copy.copy(obj.startingPos):
365			obj.startingPos.remove(positionID)
366			# create new player
367			log.debug("Creating new Rebel player", Const.T_AIPLAYER)
368			player = self.new(Const.T_AIPLAYER)
369			self.cmd(player).register(tran, player, obj.oid)
370			player.galaxy = obj.oid
371			playerID = player.oid
372			# TODO tweak more planet's attrs
373			planet = tran.db[positionID]
374			self.cmd(planet).changeOwner(tran, planet, playerID, 1)
375			IAIPlayer.IAIPlayer.setStartingTechnologies(player)
376			# fleet
377			# add basic ships designs
378			# add small fleet
379			system = tran.db[planet.compOf]
380			IAIPlayer.IAIPlayer.setStartingShipDesigns(player)
381			IAIPlayer.IAIPlayer.setStartingPlanet(tran, playerID, planet)
382			IAIPlayer.IAIPlayer.setStartingFleet(tran, playerID, system)
383			system.scannerPwrs[playerID] = Rules.startingScannerPwr
384			# do scanner evaluation because of all new players
385			self.cmd(obj).processSCAN2Phase(tran, obj, None)
386
387			@public(Const.AL_ADMIN)
388			def enableTime(self, tran, obj, force = False):
389			log.debug('IGalaxy', 'Checking for time...')
390			if not force and not self._isEligibleEnableTime(tran, obj):
391			return
392			if obj.timeEnabled is None:
393			self._firstEnableTime(tran, obj)
394			# ok, enable time
395			log.message('IGalaxy', 'Enabling time for', obj.oid)
396			obj.timeEnabled = True
397			self._trickleTimeToPlayers(tran, obj)
398
399			@public(Const.AL_OWNER)
400			def deleteSingle(self, tran, obj):
401			if obj.scenario != Const.SCENARIO_SINGLE:
402			raise ige.GameException('Only Single Player galaxies can be deleted this way')
403			log.debug(obj.oid, "GALAXY - singleplayer delete")
404			self.delete(tran, obj)
405
406			@public(Const.AL_ADMIN)
407			def delete(self, tran, obj):
408			log.debug(obj.oid, "GALAXY - delete")
409			universe = tran.db[Const.OID_UNIVERSE]
410			# delete systems and planets
411			for systemID in obj.systems:
412			log.debug("Deleting system", systemID)
413			system = tran.db[systemID]
414			log.debug("-- planets", system.planets)
415			log.debug("-- fleets", system.fleets, system.closeFleets)
416			for planetID in system.planets[:]:
417			planet = tran.db[planetID]
418			self.cmd(planet).changeOwner(tran, planet, Const.OID_NONE, force = 1)
419			del tran.db[planetID]
420			for fleetID in system.closeFleets[:]:
421			fleet = tran.db[fleetID]
422			# this will modify system fleet and closeFleets attrs
423			self.cmd(fleet).disbandFleet(tran, fleet)
424			del tran.db[systemID]
425			# delete all remaining fleets
426			for playerID in universe.players[:]:
427			player = tran.db[playerID]
428			if obj.oid != player.galaxy:
429			continue
430			if player.fleets:
431			log.debug("Player %d has still fleets" % playerID, player.name, player.fleets)
432			for fleetID in player.fleets:
433			fleet = tran.db[fleetID]
434			log.debug("Fleet NOT DELETED:", fleet)
435			if player.planets:
436			log.debug("Player %d has still planets" % playerID, player.name, player.planets)
437			self.cmd(player).delete(tran, player)
438			# remove this galaxy from the list of the galaxies
439			tran.db[Const.OID_UNIVERSE].galaxies.remove(obj.oid)
440			del tran.db[obj.oid]
441			return 1
442
443			@public(Const.AL_NONE)
444			def getPublicInfo(self, tran, obj):
445			result = IDataHolder()
446			result.oid = obj.oid
447			result.x = obj.x
448			result.y = obj.y
449			result.radius = obj.radius
450			result.type = obj.type
451			result.name = obj.name
452			result.emrLevel = obj.emrLevel
453			result.scenario = obj.scenario
454			result.scenarioData = obj.scenarioData
455			result.timeEnabled = obj.timeEnabled
456			return result
457
458			@public(Const.AL_NONE)
459			def getDescription(self,obj):
460			return obj.description
461
462			def _environmentGetVacantPlanets(self, tran, obj):
463			vacantPlanets = {}
464			for systemID in obj.systems:
465			system = tran.db[systemID]
466			for planetID in system.planets:
467			planet = tran.db[planetID]
468			if planet.owner != Const.OID_NONE:
469			continue
470			if planet.plStratRes in (Const.SR_TL1A, Const.SR_TL1B):
471			playerType = Const.T_AIRENPLAYER
472			elif planet.plStratRes in (Const.SR_TL3A, Const.SR_TL3B, Const.SR_TL3C):
473			playerType = Const.T_AIPIRPLAYER
474			elif planet.plStratRes in (Const.SR_TL5A, Const.SR_TL5B, Const.SR_TL5C):
475			playerType = Const.T_AIEDENPLAYER
476			elif planet.plDisease != 0:
477			playerType = Const.T_AIMUTPLAYER
478			else:
479			continue
480			try:
481			vacantPlanets[playerType].append(planetID)
482			except KeyError:
483			vacantPlanets[playerType] = [planetID]
484			return vacantPlanets
485
486			def _searchForPlayer(self, tran, obj, playerType):
487			universe = tran.db[Const.OID_UNIVERSE]
488			for playerID in universe.players:
489			player = tran.db[playerID]
490			if obj.oid == player.galaxy and player.type == playerType:
491			return player
492			# create new player
493			log.debug("Creating new player", playerType)
494			player = self.new(playerType)
495			self.cmd(player).register(tran, player, obj.oid)
496			player.galaxy = obj.oid
497			return player
498
499			def _setupEnvironmentRenegade(self, tran, obj, vacantPlanets):
500			renType = Const.T_AIRENPLAYER
501			planets = vacantPlanets.pop(renType)
502			for planetID in planets:
503			planet = tran.db[planetID]
504			log.debug("Creating new Renegade")
505			player = self.new(renType)
506			self.cmd(player).register(tran, player, obj.oid)
507			player.galaxy = obj.oid
508			self.cmd(planet).changeOwner(tran, planet, player.oid, 1)
509			IAIRenegadePlayer.IAIRenegadePlayer.setStartingPlanet(tran, planet)
510
511			@public(Const.AL_ADMIN)
512			def setupEnvironment(self, tran, obj):
513			vacantPlanets = self._environmentGetVacantPlanets(tran, obj)
514			self._setupEnvironmentRenegade(tran, obj, vacantPlanets)
515			# iterate over types, create players if needed (it should be) and fill in vacant planets
516			for playerType in vacantPlanets:
517			player = self._searchForPlayer(tran, obj, playerType)
518			# now we have a player, let's iterate over vacant planets and set them up
519			for planetID in vacantPlanets[playerType]:
520			planet = tran.db[planetID]
521			self.cmd(planet).changeOwner(tran, planet, player.oid, 1)
522			if playerType == Const.T_AIPIRPLAYER:
523			IAIPiratePlayer.IAIPiratePlayer.setStartingPlanet(tran, planet)
524			elif playerType == Const.T_AIEDENPLAYER:
525			IAIEDENPlayer.IAIEDENPlayer.setStartingPlanet(tran, planet)
526			elif playerType == Const.T_AIMUTPLAYER:
527			IAIMutantPlayer.IAIMutantPlayer.setStartingPlanet(tran, planet)
528
529			## messaging
530			def canGetMsgs(self, tran, obj, oid):
531			return 1
532
533			canGetMsgs.public = 0
534
535			def canSendMsg(self, tran, obj, oid, forum):
536			if forum == "PUBLIC":
537			return 1
538			elif forum == "NEWS":
539			return 1
540			return 0
541
542			canSendMsg.public = 0
543

ospaceteam / outerspace

Pull Request — master (#225)

ige.ospace.IGalaxy.IGalaxy.processBATTLEPhase() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like