Merge branch 'master' into dps_sim_graph
This commit is contained in:
@@ -22,8 +22,10 @@ from math import exp, log, radians, sin, inf
|
||||
|
||||
from logbook import Logger
|
||||
|
||||
import eos.config
|
||||
from eos.const import FittingHardpoint, FittingModuleState
|
||||
from eos.graph import SmoothGraph
|
||||
from eos.utils.spoolSupport import SpoolType, SpoolOptions
|
||||
|
||||
|
||||
pyfalog = Logger(__name__)
|
||||
@@ -58,9 +60,10 @@ class FitDpsVsRangeGraph(SmoothGraph):
|
||||
tgtSpeed = self.penalizeModChain(tgtSpeed, tgtSpeedMods)
|
||||
tgtSigRad = self.penalizeModChain(tgtSigRad, tgtSigRadMods)
|
||||
attRad = fit.ship.getModifiedItemAttr('radius', 0)
|
||||
defaultSpoolValue = eos.config.settings['globalDefaultSpoolupPercentage']
|
||||
|
||||
for mod in fit.modules:
|
||||
dps = mod.getDps(targetResists=fit.targetResists).total
|
||||
dps = mod.getDps(targetResists=fit.targetResists, spoolOptions=SpoolOptions(SpoolType.SCALE, defaultSpoolValue, False)).total
|
||||
if mod.hardpoint == FittingHardpoint.TURRET:
|
||||
if mod.state >= FittingModuleState.ACTIVE:
|
||||
total += dps * self.calculateTurretMultiplier(fit, mod, distance, angle, tgtSpeed, tgtSigRad)
|
||||
|
||||
@@ -1167,6 +1167,10 @@ class Fit(object):
|
||||
|
||||
return self.__capRecharge
|
||||
|
||||
@property
|
||||
def capDelta(self):
|
||||
return (self.__capRecharge or 0) - (self.__capUsed or 0)
|
||||
|
||||
def calculateCapRecharge(self, percent=PEAK_RECHARGE):
|
||||
capacity = self.ship.getModifiedItemAttr("capacitorCapacity")
|
||||
rechargeRate = self.ship.getModifiedItemAttr("rechargeRate") / 1000.0
|
||||
|
||||
@@ -8,10 +8,12 @@ import gui.mainFrame
|
||||
import gui.utils.color as colorUtils
|
||||
import gui.utils.draw as drawUtils
|
||||
import gui.utils.fonts as fonts
|
||||
from .events import FitSelected, SearchSelected, ImportSelected, Stage1Selected, Stage2Selected, Stage3Selected
|
||||
from gui.bitmap_loader import BitmapLoader
|
||||
from service.fit import Fit
|
||||
from gui.utils.helpers_wxPython import HandleCtrlBackspace
|
||||
from service.fit import Fit
|
||||
from utils.cjk import isStringCjk
|
||||
from .events import FitSelected, SearchSelected, ImportSelected, Stage1Selected, Stage2Selected, Stage3Selected
|
||||
|
||||
|
||||
pyfalog = Logger(__name__)
|
||||
|
||||
@@ -86,7 +88,8 @@ class NavigationPanel(SFItem.SFBrowserItem):
|
||||
search = self.BrowserSearchBox.GetValue()
|
||||
# Make sure we do not count wildcard as search symbol
|
||||
realsearch = search.replace("*", "")
|
||||
if len(realsearch) >= 3:
|
||||
minChars = 1 if isStringCjk(realsearch) else 3
|
||||
if len(realsearch) >= minChars:
|
||||
self.lastSearch = search
|
||||
wx.PostEvent(self.shipBrowser, SearchSelected(text=search, back=False))
|
||||
|
||||
|
||||
@@ -85,46 +85,44 @@ class CapacitorViewFull(StatsView):
|
||||
|
||||
sizerCapacitor.Add(baseBox, 0, wx.ALIGN_CENTER_HORIZONTAL)
|
||||
|
||||
tooltip = wx.ToolTip("Capacitor throughput")
|
||||
tooltip = wx.ToolTip("Extra stats")
|
||||
bitmap = BitmapLoader.getStaticBitmap("capacitorRecharge_big", parent, "gui")
|
||||
bitmap.SetToolTip(tooltip)
|
||||
baseBox.Add(bitmap, 0, wx.ALIGN_CENTER)
|
||||
|
||||
# Recharge
|
||||
chargeSizer = wx.FlexGridSizer(2, 3, 0, 0)
|
||||
# Delta
|
||||
chargeSizer = wx.BoxSizer(wx.VERTICAL)
|
||||
baseBox.Add(chargeSizer, 0, wx.ALIGN_CENTER)
|
||||
|
||||
chargeSizer.Add(wx.StaticText(parent, wx.ID_ANY, "+ "), 0, wx.ALIGN_CENTER)
|
||||
lbl = wx.StaticText(parent, wx.ID_ANY, "0.0")
|
||||
setattr(self, "label%sCapacitorRecharge" % panel.capitalize(), lbl)
|
||||
lbl = wx.StaticText(parent, wx.ID_ANY, "0 GJ/s")
|
||||
setattr(self, "label%sCapacitorDelta" % panel.capitalize(), lbl)
|
||||
chargeSizer.Add(lbl, 0, wx.ALIGN_CENTER)
|
||||
chargeSizer.Add(wx.StaticText(parent, wx.ID_ANY, " GJ/s"), 0, wx.ALIGN_CENTER)
|
||||
|
||||
# Discharge
|
||||
chargeSizer.Add(wx.StaticText(parent, wx.ID_ANY, "- "), 0, wx.ALIGN_CENTER)
|
||||
lbl = wx.StaticText(parent, wx.ID_ANY, "0.0")
|
||||
setattr(self, "label%sCapacitorDischarge" % panel.capitalize(), lbl)
|
||||
# Resists
|
||||
lbl = wx.StaticText(parent, wx.ID_ANY, "0%")
|
||||
setattr(self, "label%sCapacitorResist" % panel.capitalize(), lbl)
|
||||
chargeSizer.Add(lbl, 0, wx.ALIGN_CENTER)
|
||||
chargeSizer.Add(wx.StaticText(parent, wx.ID_ANY, " GJ/s"), 0, wx.ALIGN_CENTER)
|
||||
|
||||
def refreshPanel(self, fit):
|
||||
# If we did anything intresting, we'd update our labels to reflect the new fit's stats here
|
||||
stats = (
|
||||
("label%sCapacitorCapacity", lambda: fit.ship.getModifiedItemAttr("capacitorCapacity"), 3, 0, 9),
|
||||
("label%sCapacitorRecharge", lambda: fit.capRecharge, 3, 0, 0),
|
||||
("label%sCapacitorDischarge", lambda: fit.capUsed, 3, 0, 0),
|
||||
("label%sCapacitorCapacity", lambda: fit.ship.getModifiedItemAttr("capacitorCapacity"), 3, 0, 9, False, ''),
|
||||
("label%sCapacitorDelta", lambda: fit.capDelta, 3, 0, 0, True, ' GJ/s'),
|
||||
("label%sCapacitorResist", lambda: (1 - fit.ship.getModifiedItemAttr("energyWarfareResistance", 1)) * 100, 3, 0, 0, False, '%'),
|
||||
)
|
||||
if fit is not None:
|
||||
neut_resist = fit.ship.getModifiedItemAttr("energyWarfareResistance", 0)
|
||||
cap_amount = fit.ship.getModifiedItemAttr("capacitorCapacity")
|
||||
cap_recharge = fit.capRecharge
|
||||
cap_use = fit.capUsed
|
||||
neut_res = fit.ship.getModifiedItemAttr("energyWarfareResistance", 1)
|
||||
else:
|
||||
neut_resist = 0
|
||||
cap_amount = 0
|
||||
cap_recharge = 0
|
||||
cap_use = 0
|
||||
neut_res = 1
|
||||
|
||||
panel = "Full"
|
||||
for labelName, value, prec, lowest, highest in stats:
|
||||
for labelName, value, prec, lowest, highest, forceSign, unit in stats:
|
||||
label = getattr(self, labelName % panel)
|
||||
value = value() if fit is not None else 0
|
||||
value = value if value is not None else 0
|
||||
@@ -132,15 +130,19 @@ class CapacitorViewFull(StatsView):
|
||||
label.SetLabel(value)
|
||||
label.SetToolTip(wx.ToolTip(value))
|
||||
else:
|
||||
label.SetLabel(formatAmount(value, prec, lowest, highest))
|
||||
label.SetLabel('{}{}'.format(formatAmount(value, prec, lowest, highest, forceSign=forceSign), unit))
|
||||
label.SetToolTip(wx.ToolTip("%.1f" % value))
|
||||
|
||||
if labelName in ("label%sCapacitorRecharge", "label%sCapacitorDischarge"):
|
||||
neut_resist_preformat = 100 - (neut_resist * 100) if neut_resist else neut_resist
|
||||
label_tooltip = "Capacitor delta: {}\nNeut resistance: {}%".format(
|
||||
formatAmount(cap_recharge - cap_use, 3, 0, 3, forceSign=True),
|
||||
formatAmount(neut_resist_preformat, 3, 0, 3))
|
||||
if labelName == 'label%sCapacitorDelta':
|
||||
label_tooltip = 'Capacitor delta:\n+{} GJ/s\n-{} GJ/s'.format(
|
||||
formatAmount(cap_recharge, 3, 0, 3),
|
||||
formatAmount(cap_use, 3, 0, 3))
|
||||
label.SetToolTip(wx.ToolTip(label_tooltip))
|
||||
if labelName == 'label%sCapacitorResist':
|
||||
texts = ['Neutralizer resistance']
|
||||
if cap_amount > 0 and neut_res < 1:
|
||||
texts.append('Effective capacity: {} GJ'.format(formatAmount(cap_amount / neut_res, 3, 0, 9)))
|
||||
label.SetToolTip(wx.ToolTip('\n'.join(texts)))
|
||||
|
||||
capState = fit.capState if fit is not None else 0
|
||||
capStable = fit.capStable if fit is not None else False
|
||||
|
||||
@@ -1 +1 @@
|
||||
__all__ = ['evemarketer', 'evemarketdata']
|
||||
__all__ = ['evemarketer', 'evemarketdata', 'evepraisal']
|
||||
|
||||
@@ -31,7 +31,7 @@ pyfalog = Logger(__name__)
|
||||
|
||||
class EveMarketData:
|
||||
|
||||
name = "eve-marketdata.com"
|
||||
name = 'eve-marketdata.com'
|
||||
|
||||
def __init__(self, priceMap, system, fetchTimeout):
|
||||
# Try selected system first
|
||||
@@ -42,24 +42,24 @@ class EveMarketData:
|
||||
|
||||
@staticmethod
|
||||
def fetchPrices(priceMap, fetchTimeout, system=None):
|
||||
params = {"type_ids": ','.join(str(typeID) for typeID in priceMap)}
|
||||
params = {'type_ids': ','.join(str(typeID) for typeID in priceMap)}
|
||||
if system is not None:
|
||||
params["system_id"] = system
|
||||
baseurl = "https://eve-marketdata.com/api/item_prices.xml"
|
||||
params['system_id'] = system
|
||||
baseurl = 'https://eve-marketdata.com/api/item_prices.xml'
|
||||
network = Network.getInstance()
|
||||
data = network.request(baseurl, network.PRICES, params=params, timeout=fetchTimeout)
|
||||
data = network.get(url=baseurl, type=network.PRICES, params=params, timeout=fetchTimeout)
|
||||
xml = minidom.parseString(data.text)
|
||||
types = xml.getElementsByTagName("eve").item(0).getElementsByTagName("price")
|
||||
types = xml.getElementsByTagName('eve').item(0).getElementsByTagName('price')
|
||||
|
||||
# Cycle through all types we've got from request
|
||||
for type_ in types:
|
||||
# Get data out of each typeID details tree
|
||||
typeID = int(type_.getAttribute("id"))
|
||||
typeID = int(type_.getAttribute('id'))
|
||||
|
||||
try:
|
||||
price = float(type_.firstChild.data)
|
||||
except (TypeError, ValueError):
|
||||
pyfalog.warning("Failed to get price for: {0}", type_)
|
||||
pyfalog.warning('Failed to get price for: {0}', type_)
|
||||
continue
|
||||
|
||||
# eve-marketdata returns 0 if price data doesn't even exist for the item
|
||||
|
||||
@@ -31,7 +31,7 @@ pyfalog = Logger(__name__)
|
||||
|
||||
class EveMarketer:
|
||||
|
||||
name = "evemarketer"
|
||||
name = 'evemarketer'
|
||||
|
||||
def __init__(self, priceMap, system, fetchTimeout):
|
||||
# Try selected system first
|
||||
@@ -42,24 +42,24 @@ class EveMarketer:
|
||||
|
||||
@staticmethod
|
||||
def fetchPrices(priceMap, fetchTimeout, system=None):
|
||||
params = {"typeid": {typeID for typeID in priceMap}}
|
||||
params = {'typeid': {typeID for typeID in priceMap}}
|
||||
if system is not None:
|
||||
params["usesystem"] = system
|
||||
baseurl = "https://api.evemarketer.com/ec/marketstat"
|
||||
params['usesystem'] = system
|
||||
baseurl = 'https://api.evemarketer.com/ec/marketstat'
|
||||
network = Network.getInstance()
|
||||
data = network.request(baseurl, network.PRICES, params=params, timeout=fetchTimeout)
|
||||
data = network.get(url=baseurl, type=network.PRICES, params=params, timeout=fetchTimeout)
|
||||
xml = minidom.parseString(data.text)
|
||||
types = xml.getElementsByTagName("marketstat").item(0).getElementsByTagName("type")
|
||||
types = xml.getElementsByTagName('marketstat').item(0).getElementsByTagName('type')
|
||||
# Cycle through all types we've got from request
|
||||
for type_ in types:
|
||||
# Get data out of each typeID details tree
|
||||
typeID = int(type_.getAttribute("id"))
|
||||
sell = type_.getElementsByTagName("sell").item(0)
|
||||
# If price data wasn't there, set price to zero
|
||||
typeID = int(type_.getAttribute('id'))
|
||||
sell = type_.getElementsByTagName('sell').item(0)
|
||||
# If price data wasn't there, skip the item
|
||||
try:
|
||||
percprice = float(sell.getElementsByTagName("percentile").item(0).firstChild.data)
|
||||
percprice = float(sell.getElementsByTagName('percentile').item(0).firstChild.data)
|
||||
except (TypeError, ValueError):
|
||||
pyfalog.warning("Failed to get price for: {0}", type_)
|
||||
pyfalog.warning('Failed to get price for: {0}', type_)
|
||||
continue
|
||||
|
||||
# Price is 0 if evemarketer has info on this item, but it is not available
|
||||
@@ -67,7 +67,6 @@ class EveMarketer:
|
||||
# such items to check globally, and do not skip if requested globally
|
||||
if percprice == 0 and system is not None:
|
||||
continue
|
||||
|
||||
priceMap[typeID].update(PriceStatus.fetchSuccess, percprice)
|
||||
del priceMap[typeID]
|
||||
|
||||
|
||||
78
service/marketSources/evepraisal.py
Normal file
78
service/marketSources/evepraisal.py
Normal file
@@ -0,0 +1,78 @@
|
||||
# =============================================================================
|
||||
# Copyright (C) 2010 Diego Duclos
|
||||
#
|
||||
# This file is part of pyfa.
|
||||
#
|
||||
# pyfa 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 3 of the License, or
|
||||
# (at your option) any later version.
|
||||
#
|
||||
# pyfa 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 pyfa. If not, see <http://www.gnu.org/licenses/>.
|
||||
# =============================================================================
|
||||
|
||||
|
||||
from logbook import Logger
|
||||
|
||||
from eos.saveddata.price import PriceStatus
|
||||
from service.network import Network
|
||||
from service.price import Price
|
||||
|
||||
pyfalog = Logger(__name__)
|
||||
|
||||
systemAliases = {
|
||||
None: 'universe',
|
||||
30000142: 'jita',
|
||||
30002187: 'amarr',
|
||||
30002659: 'dodixie',
|
||||
30002510: 'rens',
|
||||
30002053: 'hek'}
|
||||
|
||||
|
||||
class EvePraisal:
|
||||
|
||||
name = 'evepraisal'
|
||||
|
||||
def __init__(self, priceMap, system, fetchTimeout):
|
||||
# Try selected system first
|
||||
self.fetchPrices(priceMap, max(2 * fetchTimeout / 3, 2), system)
|
||||
# If price was not available - try globally
|
||||
if priceMap:
|
||||
self.fetchPrices(priceMap, max(fetchTimeout / 3, 2))
|
||||
|
||||
@staticmethod
|
||||
def fetchPrices(priceMap, fetchTimeout, system=None):
|
||||
if system not in systemAliases:
|
||||
return
|
||||
jsonData = {
|
||||
'market_name': systemAliases[system],
|
||||
'items': [{'type_id': typeID} for typeID in priceMap]}
|
||||
baseurl = 'https://evepraisal.com/appraisal/structured.json'
|
||||
network = Network.getInstance()
|
||||
resp = network.post(baseurl, network.PRICES, jsonData=jsonData, timeout=fetchTimeout)
|
||||
data = resp.json()
|
||||
try:
|
||||
itemsData = data['appraisal']['items']
|
||||
except (KeyError, TypeError):
|
||||
return
|
||||
# Cycle through all types we've got from request
|
||||
for itemData in itemsData:
|
||||
try:
|
||||
typeID = int(itemData['typeID'])
|
||||
price = itemData['prices']['sell']['min']
|
||||
except (KeyError, TypeError):
|
||||
continue
|
||||
# evepraisal returns 0 if price data doesn't even exist for the item
|
||||
if price == 0:
|
||||
continue
|
||||
priceMap[typeID].update(PriceStatus.fetchSuccess, price)
|
||||
del priceMap[typeID]
|
||||
|
||||
|
||||
Price.register(EvePraisal)
|
||||
@@ -70,36 +70,18 @@ class Network:
|
||||
|
||||
return cls._instance
|
||||
|
||||
def request(self, url, type, *args, **kwargs):
|
||||
def get(self, url, type, **kwargs):
|
||||
self.__networkAccessCheck(type)
|
||||
|
||||
# URL is required to be https as of right now
|
||||
# print "Starting request: %s\n\tType: %s\n\tPost Data: %s"%(url,type,data)
|
||||
|
||||
# Make sure request is enabled
|
||||
access = NetworkSettings.getInstance().getAccess()
|
||||
|
||||
if not self.ENABLED & access or not type & access:
|
||||
pyfalog.warning("Access not enabled - please enable in Preferences > Network")
|
||||
raise Error("Access not enabled - please enable in Preferences > Network")
|
||||
|
||||
# Set up some things for the request
|
||||
versionString = "{0}".format(config.version)
|
||||
headers = {"User-Agent": "pyfa {0} (python-requests {1})".format(versionString, requests.__version__)}
|
||||
# user-agent: pyfa 2.0.0b4 git -YC120.2 1.2 (python-requests 2.18.4)
|
||||
|
||||
# python-requests supports setting proxy for request as parameter to get() / post()
|
||||
# in a form like: proxies = { 'http': 'http://10.10.1.10:3128', 'https': 'http://10.10.1.10:1080' }
|
||||
# or with HTTP Basic auth support: proxies = {'http': 'http://user:pass@10.10.1.10:3128/'}
|
||||
# then you do: requests.get('http://example.org', proxies=proxies)
|
||||
|
||||
proxies = NetworkSettings.getInstance().getProxySettingsInRequestsFormat()
|
||||
headers = self.__getHeaders()
|
||||
proxies = self.__getProxies()
|
||||
|
||||
try:
|
||||
resp = requests.get(url, headers=headers, proxies=proxies, **kwargs)
|
||||
resp.raise_for_status()
|
||||
return resp
|
||||
except requests.exceptions.HTTPError as error:
|
||||
pyfalog.warning("HTTPError:")
|
||||
pyfalog.warning('HTTPError:')
|
||||
pyfalog.warning(error)
|
||||
if error.response.status_code == 404:
|
||||
raise RequestError()
|
||||
@@ -112,3 +94,46 @@ class Network:
|
||||
raise TimeoutError()
|
||||
except Exception as error:
|
||||
raise Error(error)
|
||||
|
||||
def post(self, url, type, jsonData, **kwargs):
|
||||
self.__networkAccessCheck(type)
|
||||
|
||||
headers = self.__getHeaders()
|
||||
proxies = self.__getProxies()
|
||||
|
||||
try:
|
||||
resp = requests.post(url, json=jsonData, headers=headers, proxies=proxies, **kwargs)
|
||||
resp.raise_for_status()
|
||||
return resp
|
||||
except requests.exceptions.HTTPError as error:
|
||||
pyfalog.warning('HTTPError:')
|
||||
pyfalog.warning(error)
|
||||
if error.response.status_code == 404:
|
||||
raise RequestError()
|
||||
elif error.response.status_code == 403:
|
||||
raise AuthenticationError()
|
||||
elif error.response.status_code >= 500:
|
||||
raise ServerError()
|
||||
raise Error(error)
|
||||
except requests.exceptions.Timeout:
|
||||
raise TimeoutError()
|
||||
except Exception as error:
|
||||
raise Error(error)
|
||||
|
||||
def __networkAccessCheck(self, type):
|
||||
# Make sure request is enabled
|
||||
access = NetworkSettings.getInstance().getAccess()
|
||||
if not self.ENABLED & access or not type & access:
|
||||
pyfalog.warning('Access not enabled - please enable in Preferences > Network')
|
||||
raise Error('Access not enabled - please enable in Preferences > Network')
|
||||
|
||||
def __getHeaders(self):
|
||||
versionString = '{0}'.format(config.version)
|
||||
return {'User-Agent': 'pyfa {0} (python-requests {1})'.format(versionString, requests.__version__)}
|
||||
|
||||
def __getProxies(self):
|
||||
# python-requests supports setting proxy for request as parameter to get() / post()
|
||||
# in a form like: proxies = { 'http': 'http://10.10.1.10:3128', 'https': 'http://10.10.1.10:1080' }
|
||||
# or with HTTP Basic auth support: proxies = {'http': 'http://user:pass@10.10.1.10:3128/'}
|
||||
# then you do: requests.get('http://example.org', proxies=proxies)
|
||||
return NetworkSettings.getInstance().getProxySettingsInRequestsFormat()
|
||||
|
||||
@@ -136,15 +136,13 @@ class EfsPort:
|
||||
CalcChangeModuleChargesCommand(
|
||||
fit.ID,
|
||||
projected=False,
|
||||
chargeMap={mod.position: None},
|
||||
commit=False).Do()
|
||||
chargeMap={mod.position: None}).Do()
|
||||
sFit.recalc(fit)
|
||||
stats["unloadedCapacitorNeed"] = mod.getModifiedItemAttr("capacitorNeed")
|
||||
CalcChangeModuleChargesCommand(
|
||||
fit.ID,
|
||||
projected=False,
|
||||
chargeMap={mod.position: c.typeID},
|
||||
commit=False).Do()
|
||||
chargeMap={mod.position: c.typeID}).Do()
|
||||
sFit.recalc(fit)
|
||||
elif mod.item.group.name == "Capacitor Booster":
|
||||
# The capacitorNeed is negative, which provides the boost.
|
||||
|
||||
@@ -20,6 +20,7 @@
|
||||
|
||||
import queue
|
||||
import threading
|
||||
import timeit
|
||||
from itertools import chain
|
||||
|
||||
import math
|
||||
@@ -112,15 +113,18 @@ class Price:
|
||||
if source == sourcePrimary:
|
||||
continue
|
||||
sources[source] = min(sources.values()) - 1
|
||||
timeoutWeightMult = fetchTimeout / sum(sources.values())
|
||||
|
||||
# Record timeouts as it will affect our final decision
|
||||
timedOutSources = {}
|
||||
|
||||
for source, timeoutWeight in sources.items():
|
||||
remainingTime = fetchTimeout
|
||||
|
||||
for source in sorted(sources, key=sources.get, reverse=True):
|
||||
timeBefore = timeit.default_timer()
|
||||
pyfalog.info('Trying {}'.format(source))
|
||||
timedOutSources[source] = False
|
||||
sourceFetchTimeout = timeoutWeight * timeoutWeightMult
|
||||
# Time we allocate for a source depends on source weight and remaining time
|
||||
sourceFetchTimeout = remainingTime * sources[source] / sum(sources.values())
|
||||
try:
|
||||
sourceCls = cls.sources.get(source)
|
||||
sourceCls(priceMap, cls.systemsList[sFit.serviceFittingOptions["priceSystem"]], sourceFetchTimeout)
|
||||
@@ -132,6 +136,16 @@ class Price:
|
||||
# Sources remove price map items as they fetch info, if none remain then we're done
|
||||
if not priceMap:
|
||||
break
|
||||
timeAfter = timeit.default_timer()
|
||||
# Remove source so it doesn't affect time weights of sources we're going to use next
|
||||
del sources[source]
|
||||
remainingTime -= timeAfter - timeBefore
|
||||
# No time remaining (should not happen) - mark remaining sources as timeout
|
||||
if remainingTime <= 0:
|
||||
for source in sources:
|
||||
timedOutSources[source] = True
|
||||
break
|
||||
|
||||
|
||||
# If we get to this point, then we've failed to get price with all our sources
|
||||
# If all sources failed due to timeouts, set one status
|
||||
@@ -247,4 +261,4 @@ class PriceWorkerThread(threading.Thread):
|
||||
|
||||
|
||||
# Import market sources only to initialize price source modules, they register on their own
|
||||
from service.marketSources import evemarketer, evemarketdata # noqa: E402
|
||||
from service.marketSources import evemarketer, evemarketdata, evepraisal # noqa: E402
|
||||
|
||||
@@ -47,10 +47,13 @@ class CheckUpdateThread(threading.Thread):
|
||||
|
||||
try:
|
||||
try:
|
||||
response = network.request('https://www.pyfa.io/update_check?pyfa_version={}&client_hash={}'.format(
|
||||
config.version, config.getClientSecret()), network.UPDATE)
|
||||
response = network.get(
|
||||
url='https://www.pyfa.io/update_check?pyfa_version={}&client_hash={}'.format(config.version, config.getClientSecret()),
|
||||
type=network.UPDATE)
|
||||
except Exception as e:
|
||||
response = network.request('https://api.github.com/repos/pyfa-org/Pyfa/releases', network.UPDATE)
|
||||
response = network.get(
|
||||
url='https://api.github.com/repos/pyfa-org/Pyfa/releases',
|
||||
type=network.UPDATE)
|
||||
|
||||
jsonResponse = response.json()
|
||||
jsonResponse.sort(
|
||||
|
||||
27
utils/cjk.py
Normal file
27
utils/cjk.py
Normal file
@@ -0,0 +1,27 @@
|
||||
def isCharCjk(char):
|
||||
# https://stackoverflow.com/questions/1366068/whats-the-complete-range-for-chinese-characters-in-unicode
|
||||
ranges = (
|
||||
('\u4e00', '\u9fff'),
|
||||
('\u3400', '\u4dbf'),
|
||||
('\u20000', '\u2a6df'),
|
||||
('\u2a700', '\u2b73f'),
|
||||
('\u2b740', '\u2b81f'),
|
||||
('\u2b820', '\u2ceaf'),
|
||||
('\uf900', '\ufaff'),
|
||||
('\u2f800', '\u2fa1f'),
|
||||
('\uac00', '\ud7af'))
|
||||
for low, high in ranges:
|
||||
if low <= char <= high:
|
||||
return True
|
||||
return False
|
||||
|
||||
|
||||
def isStringCjk(string):
|
||||
checked = set()
|
||||
for char in string:
|
||||
if char in checked:
|
||||
continue
|
||||
checked.add(char)
|
||||
if isCharCjk(char):
|
||||
return True
|
||||
return False
|
||||
Reference in New Issue
Block a user