widgets.py 38 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169
  1. """
  2. @package web_services.widgets
  3. @brief Widgets for web services (WMS, WMTS, NasaOnEarh)
  4. List of classes:
  5. - widgets::WSPanel
  6. - widgets::LayersList
  7. (C) 2012-2013 by the GRASS Development Team
  8. This program is free software under the GNU General Public License
  9. (>=v2). Read the file COPYING that comes with GRASS for details.
  10. @author Martin Landa <landa.martin gmail.com>
  11. @author Stepan Turek <stepan.turek seznam.cz>
  12. """
  13. import os
  14. import sys
  15. import six
  16. import shutil
  17. from copy import deepcopy
  18. from core import globalvar
  19. try:
  20. from xml.etree.ElementTree import ParseError
  21. except ImportError: # < Python 2.7
  22. from xml.parsers.expat import ExpatError as ParseError
  23. import wx
  24. if globalvar.wxPythonPhoenix:
  25. try:
  26. import agw.flatnotebook as FN
  27. except ImportError: # if it's not there locally, try the wxPython lib.
  28. import wx.lib.agw.flatnotebook as FN
  29. else:
  30. import wx.lib.flatnotebook as FN
  31. import wx.lib.colourselect as csel
  32. from core.debug import Debug
  33. from core.gcmd import GWarning, GMessage
  34. from core.gconsole import CmdThread, GStderr, EVT_CMD_DONE, EVT_CMD_OUTPUT
  35. from web_services.cap_interface import WMSCapabilities, WMTSCapabilities, OnEarthCapabilities
  36. from gui_core.widgets import GNotebook
  37. from gui_core.widgets import ManageSettingsWidget
  38. from gui_core.wrap import Button, ScrolledPanel, SpinCtrl, StaticBox, \
  39. StaticText, TextCtrl, TreeCtrl
  40. import grass.script as grass
  41. rinwms_path = os.path.join(os.getenv("GISBASE"), "etc", "r.in.wms")
  42. if rinwms_path not in sys.path:
  43. sys.path.append(rinwms_path)
  44. from wms_base import WMSDriversInfo
  45. from srs import Srs
  46. from grass.pydispatch.signal import Signal
  47. class WSPanel(wx.Panel):
  48. def __init__(self, parent, web_service, **kwargs):
  49. """Show data from capabilities file.
  50. Signal: capParsed - this signal is emitted when capabilities file is downloaded
  51. (after ConnectToServer method was called)
  52. :param parent: parent widget
  53. :param web_service: web service to be panel generated for
  54. """
  55. wx.Panel.__init__(self, parent=parent, id=wx.ID_ANY)
  56. self.parent = parent
  57. self.ws = web_service
  58. self.capParsed = Signal('WSPanel.capParsed')
  59. # stores widgets, which represents parameters/flags of d.wms
  60. self.params = {}
  61. self.flags = {}
  62. self.o_layer_name = ''
  63. # stores err output from r.in.wms during getting capabilities
  64. self.cmd_err_str = ''
  65. # stores selected layer from layer list
  66. self.sel_layers = []
  67. # downloaded and parsed data from server successfully?
  68. self.is_connected = False
  69. # common part of command for r.in.wms -c and d.wms
  70. self.ws_cmdl = None
  71. # provides information about driver parameters
  72. self.drv_info = WMSDriversInfo()
  73. self.drv_props = self.drv_info.GetDrvProperties(self.ws)
  74. self.ws_drvs = {
  75. 'WMS_1.1.1': {
  76. 'cmd': [
  77. 'wms_version=1.1.1',
  78. 'driver=WMS_GRASS'],
  79. 'cap_parser': lambda temp_file: WMSCapabilities(
  80. temp_file,
  81. '1.1.1'),
  82. },
  83. 'WMS_1.3.0': {
  84. 'cmd': [
  85. 'wms_version=1.3.0',
  86. 'driver=WMS_GRASS'],
  87. 'cap_parser': lambda temp_file: WMSCapabilities(
  88. temp_file,
  89. '1.3.0'),
  90. },
  91. 'WMTS': {
  92. 'cmd': ['driver=WMTS_GRASS'],
  93. 'cap_parser': WMTSCapabilities,
  94. },
  95. 'OnEarth': {
  96. 'cmd': ['driver=OnEarth_GRASS'],
  97. 'cap_parser': OnEarthCapabilities,
  98. }}
  99. self.cmdStdErr = GStderr(self)
  100. self.cmd_thread = CmdThread(self)
  101. self.cap_file = grass.tempfile()
  102. reqDataBox = StaticBox(
  103. parent=self, label=_(" Requested data settings "))
  104. self._nb_sizer = wx.StaticBoxSizer(reqDataBox, wx.VERTICAL)
  105. self.notebook = GNotebook(parent=self,
  106. style=FN.FNB_FANCY_TABS | FN.FNB_NO_X_BUTTON)
  107. self._requestPage()
  108. self._advancedSettsPage()
  109. self._layout()
  110. self.layerSelected = self.list.layerSelected
  111. self.Bind(EVT_CMD_DONE, self.OnCapDownloadDone)
  112. self.Bind(EVT_CMD_OUTPUT, self.OnCmdOutput)
  113. self.SetMinSize((-1, 300))
  114. def __del__(self):
  115. self.cmd_thread.abort(abortall=True)
  116. grass.try_remove(self.cap_file)
  117. def _layout(self):
  118. self._nb_sizer.Add(self.notebook, proportion=1, flag=wx.EXPAND)
  119. self.SetSizer(self._nb_sizer)
  120. def _requestPage(self):
  121. """Create request page"""
  122. self.req_page_panel = wx.Panel(parent=self, id=wx.ID_ANY)
  123. self.notebook.AddPage(page=self.req_page_panel,
  124. text=_('Request'),
  125. name='request')
  126. # list of layers
  127. self.layersBox = StaticBox(parent=self.req_page_panel, id=wx.ID_ANY,
  128. label=_("List of layers "))
  129. style = wx.TR_DEFAULT_STYLE | wx.TR_HAS_BUTTONS | wx.TR_FULL_ROW_HIGHLIGHT
  130. if self.drv_props['req_multiple_layers']:
  131. style = style | wx.TR_MULTIPLE
  132. if 'WMS' not in self.ws:
  133. style = style | wx.TR_HIDE_ROOT
  134. self.list = LayersList(parent=self.req_page_panel,
  135. web_service=self.ws,
  136. style=style)
  137. self.params['format'] = None
  138. self.params['srs'] = None
  139. if 'srs' not in self.drv_props['ignored_params']:
  140. projText = StaticText(
  141. parent=self.req_page_panel, id=wx.ID_ANY,
  142. label=_("Source projection:"))
  143. self.params['srs'] = wx.Choice(
  144. parent=self.req_page_panel, id=wx.ID_ANY)
  145. self.list.Bind(wx.EVT_TREE_SEL_CHANGED, self.OnListSelChanged)
  146. # layout
  147. self.req_page_sizer = wx.BoxSizer(wx.VERTICAL)
  148. layersSizer = wx.StaticBoxSizer(self.layersBox, wx.HORIZONTAL)
  149. layersSizer.Add(
  150. self.list,
  151. proportion=1,
  152. flag=wx.LEFT | wx.RIGHT | wx.BOTTOM | wx.EXPAND,
  153. border=5)
  154. self.req_page_sizer.Add(
  155. layersSizer,
  156. proportion=1,
  157. flag=wx.LEFT | wx.RIGHT | wx.BOTTOM | wx.EXPAND,
  158. border=5)
  159. self.source_sizer = wx.BoxSizer(wx.HORIZONTAL)
  160. if self.params['format'] is not None:
  161. self.source_sizer.Add(
  162. self.params['format'],
  163. flag=wx.LEFT | wx.RIGHT | wx.BOTTOM,
  164. border=5)
  165. if self.params['srs'] is not None:
  166. self.source_sizer.Add(
  167. projText,
  168. flag=wx.ALIGN_CENTER_VERTICAL | wx.ALL,
  169. border=5)
  170. self.source_sizer.Add(
  171. self.params['srs'],
  172. flag=wx.ALIGN_CENTER_VERTICAL | wx.RIGHT | wx.TOP | wx.BOTTOM,
  173. border=5)
  174. self.req_page_sizer.Add(
  175. self.source_sizer,
  176. flag=wx.LEFT | wx.RIGHT | wx.BOTTOM | wx.EXPAND,
  177. border=5)
  178. self.req_page_panel.SetSizer(self.req_page_sizer)
  179. def enableButtons(self, enable=True):
  180. """Enable/disable up, down, buttons
  181. """
  182. self.btnUp.Enable(enable)
  183. self.btnDown.Enable(enable)
  184. def _advancedSettsPage(self):
  185. """Create advanced settings page
  186. """
  187. # TODO parse maxcol, maxrow, settings from d.wms module?
  188. # TODO OnEarth driver - add selection of time
  189. adv_setts_panel = ScrolledPanel(parent=self, id=wx.ID_ANY,
  190. style=wx.TAB_TRAVERSAL | wx.SUNKEN_BORDER)
  191. self.notebook.AddPage(page=adv_setts_panel,
  192. text=_('Advanced request settings'),
  193. name='adv_req_setts')
  194. labels = {}
  195. self.l_odrder_list = None
  196. if 'WMS' in self.ws:
  197. labels['l_order'] = StaticBox(
  198. parent=adv_setts_panel, id=wx.ID_ANY,
  199. label=_("Order of layers in raster"))
  200. self.l_odrder_list = wx.ListBox(
  201. adv_setts_panel, id=wx.ID_ANY, choices=[],
  202. style=wx.LB_SINGLE | wx.LB_NEEDED_SB)
  203. self.btnUp = Button(
  204. adv_setts_panel, id=wx.ID_ANY, label=_("Up"))
  205. self.btnDown = Button(
  206. adv_setts_panel, id=wx.ID_ANY, label=_("Down"))
  207. self.btnUp.Bind(wx.EVT_BUTTON, self.OnUp)
  208. self.btnDown.Bind(wx.EVT_BUTTON, self.OnDown)
  209. labels['method'] = StaticText(parent=adv_setts_panel, id=wx.ID_ANY,
  210. label=_("Reprojection method:"))
  211. self.reproj_methods = ['nearest', 'linear', 'cubic', 'cubicspline']
  212. self.params['method'] = wx.Choice(
  213. parent=adv_setts_panel,
  214. id=wx.ID_ANY,
  215. choices=[
  216. _('Nearest neighbor'),
  217. _('Linear interpolation'),
  218. _('Cubic interpolation'),
  219. _('Cubic spline interpolation')])
  220. labels['maxcols'] = StaticText(
  221. parent=adv_setts_panel, id=wx.ID_ANY,
  222. label=_("Maximum columns to request from server at time:"))
  223. self.params['maxcols'] = SpinCtrl(
  224. parent=adv_setts_panel, id=wx.ID_ANY, size=(100, -1))
  225. labels['maxrows'] = StaticText(
  226. parent=adv_setts_panel, id=wx.ID_ANY,
  227. label=_("Maximum rows to request from server at time:"))
  228. self.params['maxrows'] = SpinCtrl(
  229. parent=adv_setts_panel, id=wx.ID_ANY, size=(100, -1))
  230. min = 100
  231. max = 10000
  232. self.params['maxcols'].SetRange(min, max)
  233. self.params['maxrows'].SetRange(min, max)
  234. val = 500
  235. self.params['maxcols'].SetValue(val)
  236. self.params['maxrows'].SetValue(val)
  237. self.flags['o'] = self.params['bgcolor'] = None
  238. if 'o' not in self.drv_props['ignored_flags']:
  239. self.flags['o'] = wx.CheckBox(
  240. parent=adv_setts_panel, id=wx.ID_ANY,
  241. label=_("Do not request transparent data"))
  242. self.flags['o'].Bind(wx.EVT_CHECKBOX, self.OnTransparent)
  243. labels['bgcolor'] = StaticText(
  244. parent=adv_setts_panel, id=wx.ID_ANY,
  245. label=_("Background color:"))
  246. self.params['bgcolor'] = csel.ColourSelect(
  247. parent=adv_setts_panel, id=wx.ID_ANY, colour=(
  248. 255, 255, 255), size=globalvar.DIALOG_COLOR_SIZE)
  249. self.params['bgcolor'].Enable(False)
  250. self.params['urlparams'] = None
  251. if self.params['urlparams'] not in self.drv_props['ignored_params']:
  252. labels['urlparams'] = StaticText(
  253. parent=adv_setts_panel, id=wx.ID_ANY,
  254. label=_("Additional query parameters for server:"))
  255. self.params['urlparams'] = TextCtrl(
  256. parent=adv_setts_panel, id=wx.ID_ANY)
  257. # layout
  258. border = wx.BoxSizer(wx.VERTICAL)
  259. if 'WMS' in self.ws:
  260. boxSizer = wx.StaticBoxSizer(labels['l_order'], wx.VERTICAL)
  261. gridSizer = wx.GridBagSizer(hgap=3, vgap=3)
  262. gridSizer.Add(self.l_odrder_list,
  263. pos=(0, 0),
  264. span=(4, 1),
  265. flag=wx.ALIGN_CENTER_VERTICAL | wx.EXPAND,
  266. border=0)
  267. gridSizer.Add(self.btnUp,
  268. pos=(0, 1),
  269. flag=wx.ALIGN_CENTER_VERTICAL,
  270. border=0)
  271. gridSizer.Add(self.btnDown,
  272. pos=(1, 1),
  273. flag=wx.ALIGN_CENTER_VERTICAL,
  274. border=0)
  275. gridSizer.AddGrowableCol(0)
  276. boxSizer.Add(gridSizer,
  277. flag=wx.EXPAND | wx.ALL,
  278. border=5)
  279. border.Add(boxSizer,
  280. flag=wx.LEFT | wx.RIGHT | wx.UP | wx.EXPAND,
  281. border=5)
  282. gridSizer = wx.GridBagSizer(hgap=3, vgap=3)
  283. row = 0
  284. for k in ['method', 'maxcols', 'maxrows', 'o', 'bgcolor']:
  285. if k in self.params:
  286. param = self.params[k]
  287. elif k in self.flags:
  288. param = self.flags[k]
  289. if param is None:
  290. continue
  291. if k in labels or k == 'o':
  292. if k != 'o':
  293. label = labels[k]
  294. else:
  295. label = param
  296. gridSizer.Add(label,
  297. flag=wx.ALIGN_LEFT |
  298. wx.ALIGN_CENTER_VERTICAL,
  299. pos=(row, 0))
  300. if k != 'o':
  301. gridSizer.Add(param,
  302. flag=wx.ALIGN_RIGHT |
  303. wx.ALIGN_CENTER_VERTICAL,
  304. pos=(row, 1))
  305. row += 1
  306. gridSizer.AddGrowableCol(0)
  307. border.Add(gridSizer,
  308. flag=wx.LEFT | wx.RIGHT | wx.TOP | wx.EXPAND,
  309. border=5)
  310. if self.params['urlparams']:
  311. gridSizer = wx.GridBagSizer(hgap=3, vgap=3)
  312. row = 0
  313. gridSizer.Add(labels['urlparams'],
  314. flag=wx.ALIGN_LEFT |
  315. wx.ALIGN_CENTER_VERTICAL,
  316. pos=(row, 0))
  317. gridSizer.Add(self.params['urlparams'],
  318. flag=wx.ALIGN_RIGHT |
  319. wx.ALIGN_CENTER_VERTICAL | wx.EXPAND,
  320. pos=(row, 1))
  321. gridSizer.AddGrowableCol(1)
  322. border.Add(gridSizer,
  323. flag=wx.LEFT | wx.RIGHT | wx.TOP | wx.EXPAND,
  324. border=5)
  325. adv_setts_panel.SetSizer(border)
  326. adv_setts_panel.SetAutoLayout(True)
  327. adv_setts_panel.SetupScrolling()
  328. def OnUp(self, event):
  329. """Move selected layer up
  330. """
  331. if self.l_odrder_list.GetSelections():
  332. pos = self.l_odrder_list.GetSelection()
  333. if pos:
  334. self.sel_layers.insert(pos - 1, self.sel_layers.pop(pos))
  335. if pos > 0:
  336. self._updateLayerOrderList(selected=(pos - 1))
  337. else:
  338. self._updateLayerOrderList(selected=0)
  339. def OnDown(self, event):
  340. """Move selected to down
  341. """
  342. if self.l_odrder_list.GetSelections():
  343. pos = self.l_odrder_list.GetSelection()
  344. if pos != len(self.sel_layers) - 1:
  345. self.sel_layers.insert(pos + 1, self.sel_layers.pop(pos))
  346. if pos < len(self.sel_layers) - 1:
  347. self._updateLayerOrderList(selected=(pos + 1))
  348. else:
  349. self._updateLayerOrderList(selected=len(self.sel_layers) - 1)
  350. def _updateLayerOrderList(self, selected=None):
  351. """Update order in list.
  352. """
  353. def getlayercaption(l):
  354. if l['title']:
  355. cap = (l['title'])
  356. else:
  357. cap = (l['name'])
  358. if l['style']:
  359. if l['style']['title']:
  360. cap += ' / ' + l['style']['title']
  361. else:
  362. cap += ' / ' + l['style']['name']
  363. return cap
  364. layer_capts = [getlayercaption(l) for l in self.sel_layers]
  365. self.l_odrder_list.Set(layer_capts)
  366. if self.l_odrder_list.IsEmpty():
  367. self.enableButtons(False)
  368. else:
  369. self.enableButtons(True)
  370. if selected is not None:
  371. self.l_odrder_list.SetSelection(selected)
  372. self.l_odrder_list.EnsureVisible(selected)
  373. def OnTransparent(self, event):
  374. checked = event.IsChecked()
  375. if checked:
  376. self.params['bgcolor'].Enable(True)
  377. else:
  378. self.params['bgcolor'].Enable(False)
  379. def ConnectToServer(self, url, username, password):
  380. """Download and parse data from capabilities file.
  381. :param url: server url
  382. :type url: str
  383. :param username: username for connection
  384. :type username: str
  385. :param password: password for connection
  386. :type password: str
  387. """
  388. self._prepareForNewConn(url, username, password)
  389. cap_cmd = [
  390. 'r.in.wms',
  391. '-c',
  392. ('capfile_output=%s' % self.cap_file),
  393. '--overwrite'] + self.ws_cmdl
  394. self.currentPid = self.cmd_thread.GetId()
  395. self.cmd_thread.RunCmd(cap_cmd, stderr=self.cmdStdErr)
  396. def OnCmdOutput(self, event):
  397. """Manage cmd output.
  398. """
  399. if Debug.GetLevel() != 0:
  400. Debug.msg(1, event.text)
  401. elif event.type != 'message' and event.type != 'warning':
  402. self.cmd_err_str += event.text + os.linesep
  403. def _prepareForNewConn(self, url, username, password):
  404. """Prepare panel for new connection
  405. """
  406. self.is_connected = False
  407. self.sel_layers = []
  408. self.formats_list = []
  409. self.projs_list = []
  410. self.conn = {
  411. 'url': url,
  412. 'password': password,
  413. 'username': username
  414. }
  415. conn_cmd = []
  416. for k, v in six.iteritems(self.conn):
  417. if v:
  418. conn_cmd.append("%s=%s" % (k, v))
  419. self.ws_cmdl = self.ws_drvs[self.ws]['cmd'] + conn_cmd
  420. def OnCapDownloadDone(self, event):
  421. """Process donwloaded capabilities file and emits capParsed
  422. signal (see class constructor).
  423. """
  424. if event.pid != self.currentPid:
  425. return
  426. if event.returncode != 0:
  427. if self.cmd_err_str:
  428. self.cmd_err_str = _(
  429. "Unable to download %s capabilities file\nfrom <%s>:\n" %
  430. (self.ws.replace('_', ' '),
  431. self.conn['url'])) + self.cmd_err_str
  432. self._postCapParsedEvt(error_msg=self.cmd_err_str)
  433. self.cmd_err_str = ''
  434. return
  435. self._parseCapFile(self.cap_file)
  436. def _parseCapFile(self, cap_file):
  437. """Parse capabilities data and emits capParsed signal
  438. (see class constructor).
  439. """
  440. try:
  441. self.cap = self.ws_drvs[self.ws]['cap_parser'](cap_file)
  442. except (IOError, ParseError) as error:
  443. error_msg = _(
  444. "%s web service was not found in fetched capabilities file from <%s>:\n%s\n" %
  445. (self.ws, self.conn['url'], str(error)))
  446. if Debug.GetLevel() != 0:
  447. Debug.msg(1, error_msg)
  448. self._postCapParsedEvt(None)
  449. else:
  450. self._postCapParsedEvt(error_msg=error_msg)
  451. return
  452. self.is_connected = True
  453. # WMS standard has formats defined for all layers
  454. if 'WMS' in self.ws:
  455. self.formats_list = sorted(self._getFormats())
  456. self._updateFormatRadioBox(self.formats_list)
  457. self._setDefaultFormatVal()
  458. self.list.LoadData(self.cap)
  459. self.OnListSelChanged(event=None)
  460. self._postCapParsedEvt(None)
  461. def ParseCapFile(self, url, username, password, cap_file=None,):
  462. """Parse capabilities data and emits capParsed signal
  463. (see class constructor).
  464. """
  465. self._prepareForNewConn(url, username, password)
  466. if cap_file is None or not url:
  467. self._postCapParsedEvt(None)
  468. return
  469. shutil.copyfile(cap_file, self.cap_file)
  470. self._parseCapFile(self.cap_file)
  471. def UpdateWidgetsByCmd(self, cmd):
  472. """Update panel widgets accordnig to passed cmd tuple
  473. :param cmd: cmd in tuple
  474. """
  475. dcmd = cmd[1]
  476. layers = []
  477. if 'layers' in dcmd:
  478. layers = dcmd['layers']
  479. styles = []
  480. if 'styles' in dcmd:
  481. styles = dcmd['styles']
  482. if 'WMS' in self.ws:
  483. layers = layers.split(',')
  484. styles = styles.split(',')
  485. else:
  486. layers = [layers]
  487. styles = [styles]
  488. if len(layers) != len(styles):
  489. styles = [''] * len(layers)
  490. l_st_list = []
  491. for i in range(len(layers)):
  492. l_st_list.append({'style': styles[i],
  493. 'layer': layers[i]})
  494. # WMS standard - first layer in params is most bottom...
  495. # therefore layers order need to be reversed
  496. l_st_list = [l for l in reversed(l_st_list)]
  497. self.list.SelectLayers(l_st_list)
  498. params = {}
  499. if 'format' in dcmd:
  500. params['format'] = dcmd['format']
  501. if 'srs' in dcmd:
  502. params['srs'] = 'EPSG:' + dcmd['srs']
  503. if 'method' in dcmd:
  504. params['method'] = dcmd['method']
  505. for p, v in six.iteritems(params):
  506. if self.params[p]:
  507. self.params[p].SetStringSelection(v)
  508. for p, conv_f in [
  509. ('urlparams', None),
  510. ('maxcols', int),
  511. ('maxrows', int)]:
  512. if p in dcmd:
  513. v = dcmd[p]
  514. if conv_f:
  515. v = conv_f(v)
  516. self.params[p].SetValue(v)
  517. if 'flags' in dcmd and \
  518. 'o' in dcmd['flags']:
  519. self.flags['o'].SetValue(1)
  520. self.params['bgcolor'].Enable(True)
  521. if 'bgcolor' in dcmd and \
  522. self.params['bgcolor']:
  523. bgcolor = dcmd['bgcolor'].strip().lower()
  524. if len(bgcolor) == 8 and \
  525. '0x' == bgcolor[:2]:
  526. colour = '#' + bgcolor[2:]
  527. self.params['bgcolor'].SetColour(colour)
  528. def IsConnected(self):
  529. """Was successful in downloading and parsing capabilities data?
  530. """
  531. return self.is_connected
  532. def _postCapParsedEvt(self, error_msg):
  533. """Helper function
  534. """
  535. self.capParsed.emit(error_msg=error_msg)
  536. def CreateCmd(self):
  537. """Create d.wms cmd from values of panels widgets
  538. :return: cmd list
  539. :return: None if required widgets do not have selected/filled values.
  540. """
  541. # check required widgets
  542. if not self._checkImportValues():
  543. return None
  544. # create d.wms command
  545. lcmd = self.ws_cmdl
  546. lcmd = ['d.wms'] + lcmd
  547. layers = "layers="
  548. styles = 'styles='
  549. first = True
  550. # WMS standard - first layer in params is most bottom...
  551. # therefore layers order need to be reversed
  552. for layer in reversed(self.sel_layers):
  553. if not first:
  554. layers += ','
  555. styles += ','
  556. first = False
  557. layers += layer['name']
  558. if layer['style'] is not None:
  559. styles += layer['style']['name']
  560. lcmd.append(layers)
  561. lcmd.append(styles)
  562. if 'format' not in self.drv_props['ignored_params']:
  563. i_format = self.params['format'].GetSelection()
  564. lcmd.append("format=%s" % self.formats_list[i_format])
  565. if 'srs' not in self.drv_props['ignored_params']:
  566. i_srs = self.params['srs'].GetSelection()
  567. epsg_num = int(self.projs_list[i_srs].split(':')[-1])
  568. lcmd.append("srs=%s" % epsg_num)
  569. for k in ['maxcols', 'maxrows', 'urlparams']:
  570. lcmd.append(k + '=' + str(self.params[k].GetValue()))
  571. i_method = self.params['method'].GetSelection()
  572. lcmd.append('method=' + self.reproj_methods[i_method])
  573. if 'o' not in self.drv_props['ignored_flags'] and \
  574. self.flags['o'].IsChecked():
  575. lcmd.append('-o')
  576. c = self.params['bgcolor'].GetColour()
  577. hex_color = wx.Colour(
  578. c[0],
  579. c[1],
  580. c[2]).GetAsString(
  581. wx.C2S_HTML_SYNTAX)
  582. lcmd.append("bgcolor=" + '0x' + hex_color[1:])
  583. lcmd.append("map=" + self.o_layer_name)
  584. return lcmd
  585. def OnListSelChanged(self, event):
  586. """Update widgets according to selected layer in list.
  587. """
  588. curr_sel_ls = self.list.GetSelectedLayers()
  589. # update self.sel_layers (selected layer list)
  590. if 'WMS' in self.ws:
  591. for sel_l in self.sel_layers[:]:
  592. if sel_l not in curr_sel_ls:
  593. self.sel_layers.remove(sel_l)
  594. for l in curr_sel_ls:
  595. if l not in self.sel_layers:
  596. self.sel_layers.append(l)
  597. self._updateLayerOrderList()
  598. else:
  599. self.sel_layers = curr_sel_ls
  600. # update projection
  601. self.projs_list = []
  602. projs_list = []
  603. intersect_proj = []
  604. first = True
  605. for l in curr_sel_ls:
  606. layer_projs = l['cap_intf_l'].GetLayerData('srs')
  607. if first:
  608. projs_list = layer_projs
  609. first = False
  610. continue
  611. projs_list = set(projs_list).intersection(layer_projs)
  612. if 'srs' not in self.drv_props['ignored_params']:
  613. for proj in projs_list:
  614. proj_code = Srs(proj.strip()).getcode()
  615. proj_spl = proj_code.split(':')
  616. if proj_spl[0].strip().lower() in self.drv_info.GetSrs():
  617. try:
  618. int(proj_spl[1])
  619. self.projs_list.append(proj_code)
  620. except ValueError as IndexError:
  621. continue
  622. cur_sel = self.params['srs'].GetStringSelection()
  623. self.projs_list = sorted(self.projs_list)
  624. self.params['srs'].SetItems(self.projs_list)
  625. if cur_sel:
  626. self.params['srs'].SetStringSelection(cur_sel)
  627. else:
  628. try:
  629. i = self.projs_list.index('EPSG:4326')
  630. self.params['srs'].SetSelection(i)
  631. except ValueError:
  632. if len(self.projs_list) > 0:
  633. self.params['srs'].SetSelection(0)
  634. # update format
  635. if 'WMS' not in self.ws and \
  636. 'format' not in self.drv_props['ignored_params']:
  637. self.formats_list = []
  638. cur_sel = None
  639. if self.params['format'] is not None:
  640. cur_sel = self.params['format'].GetStringSelection()
  641. if len(curr_sel_ls) > 0:
  642. self.formats_list = sorted(
  643. self._getFormats(
  644. curr_sel_ls[0]['cap_intf_l']))
  645. self._updateFormatRadioBox(self.formats_list)
  646. if cur_sel:
  647. self.params['format'].SetStringSelection(cur_sel)
  648. else:
  649. self._setDefaultFormatVal()
  650. self.Layout()
  651. def _setDefaultFormatVal(self):
  652. """Set default format value.
  653. """
  654. try:
  655. i = self.formats_list.index('png')
  656. self.params['format'].SetSelection(i)
  657. except ValueError:
  658. pass
  659. def _updateFormatRadioBox(self, formats_list):
  660. """Helper function
  661. """
  662. if self.params['format'] is not None:
  663. self.req_page_sizer.Detach(self.params['format'])
  664. self.params['format'].Destroy()
  665. if len(self.formats_list) > 0:
  666. self.params['format'] = wx.RadioBox(
  667. parent=self.req_page_panel,
  668. id=wx.ID_ANY,
  669. label=_("Source image format"),
  670. pos=wx.DefaultPosition,
  671. choices=formats_list,
  672. majorDimension=4,
  673. style=wx.RA_SPECIFY_COLS)
  674. self.source_sizer.Insert(2, window=self.params['format'],
  675. flag=wx.LEFT | wx.RIGHT | wx.BOTTOM,
  676. border=5)
  677. def _getFormats(self, layer=None):
  678. """Get formats
  679. WMS has formats defined generally for whole cap.
  680. In WMTS and NASA OnEarh formats are defined for layer.
  681. """
  682. formats_label = []
  683. if layer is None:
  684. formats_list = self.cap.GetFormats()
  685. else:
  686. formats_list = layer.GetLayerData('format')
  687. for frmt in formats_list:
  688. frmt = frmt.strip()
  689. label = self.drv_info.GetFormatLabel(frmt)
  690. if label:
  691. formats_label.append(label)
  692. return formats_label
  693. def _checkImportValues(self,):
  694. """Check if required widgets are selected/filled
  695. """
  696. warning_str = ""
  697. show_war = False
  698. if not self.list or not self.list.GetSelectedLayers():
  699. warning_str += _("Select layer in layer list.\n")
  700. show_war = True
  701. if self.params['format'] is not None and \
  702. self.params['format'].GetSelection() == -1:
  703. warning_str += _("Select source image format.\n")
  704. show_war = True
  705. if self.params['srs'] is not None and \
  706. self.params['srs'].GetSelection() == -1:
  707. warning_str += _("Select source projection.\n")
  708. show_war = True
  709. if not self.o_layer_name:
  710. warning_str += _("Choose output layer name.\n")
  711. show_war = True
  712. if show_war:
  713. GMessage(parent=self.parent, message=warning_str)
  714. return False
  715. return True
  716. def SetOutputLayerName(self, name):
  717. """Set name of layer to be added to layer tree
  718. """
  719. self.o_layer_name = name
  720. def GetOutputLayerName(self):
  721. return self.o_layer_name
  722. def GetCapFile(self):
  723. """Get path to file where capabilities are saved
  724. """
  725. return self.cap_file
  726. def GetWebService(self):
  727. """Get web service
  728. """
  729. return self.ws
  730. class LayersList(TreeCtrl):
  731. def __init__(self, parent, web_service, style, pos=wx.DefaultPosition):
  732. """List of layers and styles available in capabilities file
  733. """
  734. self.parent = parent
  735. self.ws = web_service
  736. TreeCtrl.__init__(self, parent=parent, id=wx.ID_ANY, style=style)
  737. self.root = None
  738. self.Bind(wx.EVT_TREE_SEL_CHANGING, self.OnListSelChanging)
  739. self.layerSelected = Signal('LayersList.layerSelected')
  740. def LoadData(self, cap=None):
  741. """Load data into list
  742. """
  743. # detete first all items
  744. self.DeleteAllItems()
  745. if not cap:
  746. return
  747. def AddLayerChildrenToTree(parent_layer, parent_item):
  748. """Recursive function which adds all capabilities
  749. layers/styles to the LayersList.
  750. """
  751. def gettitle(layer):
  752. """Helper function"""
  753. if layer.GetLayerData('title') is not None:
  754. layer_title = layer.GetLayerData('title')
  755. elif layer.GetLayerData('name') is not None:
  756. layer_title = layer.GetLayerData('name')
  757. else:
  758. layer_title = str(layer.GetId())
  759. return layer_title
  760. def addlayer(layer, item):
  761. styles = layer.GetLayerData('styles')
  762. def_st = None
  763. for st in styles:
  764. if st['name']:
  765. style_name = st['name']
  766. else:
  767. continue
  768. if st['title']:
  769. style_name = st['title']
  770. if st['isDefault']:
  771. def_st = st
  772. style_item = self.AppendItem(item, style_name)
  773. self.SetItemData(style_item, {'type': 'style',
  774. 'layer': layer, # it is parent layer of style
  775. 'style': st})
  776. self.SetItemData(item, {'type': 'layer', # is it layer or style?
  777. 'layer': layer, # Layer instance from web_services.cap_interface
  778. 'style': def_st}) # layer can have assigned default style
  779. if parent_layer is None:
  780. parent_layer = cap.GetRootLayer()
  781. layer_title = gettitle(parent_layer)
  782. parent_item = self.AddRoot(layer_title)
  783. addlayer(parent_layer, parent_item)
  784. for layer in parent_layer.GetChildren():
  785. item = self.AppendItem(parent_item, gettitle(layer))
  786. addlayer(layer, item)
  787. AddLayerChildrenToTree(layer, item)
  788. AddLayerChildrenToTree(None, None)
  789. # self.ExpandAll(self.GetRootItem())
  790. def GetSelectedLayers(self):
  791. """Get selected layers/styles in LayersList
  792. :return: dict with these items:
  793. * 'name' : layer name used for request
  794. if it is style, it is name of parent layer
  795. * 'title' : layer title
  796. * 'style' : {'name' : 'style name', title : 'style title'}
  797. * 'cap_intf_l' : \*Layer instance from web_services.cap_interface
  798. """
  799. sel_layers = self.GetSelections()
  800. sel_layers_dict = []
  801. for s in sel_layers:
  802. try:
  803. layer = self.GetItemData(s)['layer']
  804. except ValueError:
  805. continue
  806. sel_layers_dict.append({
  807. 'name': layer.GetLayerData('name'),
  808. 'title': layer.GetLayerData('title'),
  809. 'style': self.GetItemData(s)['style'],
  810. 'cap_intf_l': layer
  811. })
  812. return sel_layers_dict
  813. def OnListSelChanging(self, event):
  814. """Do not allow selecting items, which cannot be requested from server.
  815. """
  816. def _emitSelected(layer):
  817. title = layer.GetLayerData('title')
  818. self.layerSelected.emit(title=title)
  819. def _selectRequestableChildren(item, list_to_check, items_to_sel):
  820. self.Expand(item)
  821. child_item, cookie = self.GetFirstChild(item)
  822. while child_item and child_item.IsOk():
  823. if self.GetItemData(child_item)['layer'].IsRequestable() \
  824. and not self.IsSelected(child_item):
  825. items_to_sel.append(child_item)
  826. elif not self.GetItemData(child_item)['layer'].IsRequestable():
  827. list_to_check.append(child_item)
  828. child_item, cookie = self.GetNextChild(item, cookie)
  829. cur_item = event.GetItem()
  830. if not self.GetItemData(cur_item)['layer'].IsRequestable():
  831. event.Veto()
  832. if not self.HasFlag(wx.TR_MULTIPLE):
  833. return
  834. _emitSelected(self.GetItemData(cur_item)['layer'])
  835. items_to_chck = []
  836. items_to_sel = []
  837. chck_item = cur_item
  838. while True:
  839. _selectRequestableChildren(
  840. chck_item, items_to_chck, items_to_sel)
  841. if items_to_chck:
  842. chck_item = items_to_chck.pop()
  843. else:
  844. break
  845. while items_to_sel:
  846. self.SelectItem(items_to_sel.pop(), select=True)
  847. else:
  848. _emitSelected(self.GetItemData(cur_item)['layer'])
  849. def GetItemCount(self):
  850. """Required for listmix.ListCtrlAutoWidthMixin
  851. """
  852. return 0
  853. def GetCountPerPage(self):
  854. """Required for listmix.ListCtrlAutoWidthMixin
  855. """
  856. return 0
  857. def SelectLayers(self, l_st_list):
  858. """Select layers/styles in LayersList
  859. :param l_st_list: [{style : 'style_name', layer : 'layer_name'}, ...]
  860. :return: items from l_st_list which were not found
  861. """
  862. def checknext(item, l_st_list, items_to_sel):
  863. def compare(item, l_name, st_name):
  864. it_l_name = self.GetItemData(item)['layer'].GetLayerData('name')
  865. it_st = self.GetItemData(item)['style']
  866. it_type = self.GetItemData(item)['type']
  867. if it_l_name == l_name and ((not it_st and not st_name) or (
  868. it_st and it_st['name'] == st_name and it_type == 'style')):
  869. return True
  870. return False
  871. for i, l_st in enumerate(l_st_list):
  872. l_name = l_st['layer']
  873. st_name = l_st['style']
  874. if compare(item, l_name, st_name):
  875. items_to_sel[i] = [item, l_st]
  876. break
  877. if len(items_to_sel) == len(l_st_list):
  878. item = self.GetNextVisible(item)
  879. if not item.IsOk():
  880. return
  881. checknext(item, l_st_list, items_to_sel)
  882. self.UnselectAll()
  883. l_st_list = deepcopy(l_st_list)
  884. root_item = self.GetRootItem()
  885. items_to_sel = [None] * len(l_st_list)
  886. checknext(root_item, l_st_list, items_to_sel)
  887. # items are selected according to position in l_st_list
  888. # to be added to Layers order list in right order
  889. for i in items_to_sel:
  890. if not i:
  891. continue
  892. item, l_st = i
  893. keep = False
  894. if self.HasFlag(wx.TR_MULTIPLE):
  895. keep = True
  896. self.SelectItem(item, select=keep)
  897. l_st_list.remove(l_st)
  898. return l_st_list
  899. class WSManageSettingsWidget(ManageSettingsWidget):
  900. def __init__(self, parent, settingsFile, default_servers):
  901. ManageSettingsWidget.__init__(self, parent, settingsFile)
  902. self.default_servers = default_servers
  903. def _layout(self):
  904. self.btnAddDefaultServers = Button(parent=self, id=wx.ID_ANY,
  905. label=_("Add default"))
  906. self.btnAddDefaultServers.Bind(wx.EVT_BUTTON, self.OnAddDefaultServers)
  907. ManageSettingsWidget._layout(self)
  908. self.settingsSizer.Add(self.btnAddDefaultServers,
  909. flag=wx.RIGHT,
  910. border=5)
  911. def OnAddDefaultServers(self, event):
  912. setts = self.GetSettings()
  913. self.servers_to_add = {}
  914. for k, v in six.iteritems(self.default_servers):
  915. if k not in six.iterkeys(setts):
  916. self.servers_to_add[k] = v
  917. elif v != setts[k]:
  918. GMessage(parent=self,
  919. message=_("User defined server with same name "
  920. "as default server <%s> already exists.\n"
  921. "Keeping user defined server") % (k))
  922. if self.servers_to_add:
  923. self.AddSettings(self.servers_to_add)