123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920 |
- """
- @package datacatalog::tree
- @brief Data catalog tree classes
- Classes:
- - datacatalog::NameEntryDialog
- - datacatalog::DataCatalogNode
- - datacatalog::DataCatalogTree
- (C) 2014-2018 by Tereza Fiedlerova, and the GRASS Development Team
- This program is free software under the GNU General Public
- License (>=v2). Read the file COPYING that comes with GRASS
- for details.
- @author Tereza Fiedlerova
- @author Anna Petrasova (kratochanna gmail com)
- @author Linda Kladivova (l.kladivova@seznam.cz)
- """
- import os
- import re
- import copy
- from multiprocessing import Process, Queue, cpu_count
- watchdog_used = True
- try:
- from watchdog.observers import Observer
- from watchdog.events import PatternMatchingEventHandler
- except ImportError:
- watchdog_used = False
- import wx
- from wx.lib.newevent import NewEvent
- from core.gcmd import RunCommand, GError, GMessage, GWarning
- from core.utils import GetListOfLocations
- from core.debug import Debug
- from core.gthread import gThread
- from gui_core.dialogs import TextEntryDialog
- from core.giface import StandaloneGrassInterface
- from core.treemodel import TreeModel, DictNode
- from gui_core.treeview import TreeView
- from gui_core.wrap import Menu
- from datacatalog.dialogs import CatalogReprojectionDialog
- from icons.icon import MetaIcon
- from core.settings import UserSettings
- from startup.guiutils import (
- create_mapset_interactively,
- create_location_interactively,
- rename_mapset_interactively,
- rename_location_interactively,
- delete_mapsets_interactively,
- delete_locations_interactively,
- download_location_interactively,
- delete_grassdb_interactively,
- can_switch_mapset_interactive,
- switch_mapset_interactively,
- get_reason_mapset_not_removable,
- get_reasons_location_not_removable,
- get_mapset_name_invalid_reason,
- get_location_name_invalid_reason
- )
- from grass.grassdb.manage import (
- rename_mapset,
- rename_location
- )
- from grass.pydispatch.signal import Signal
- import grass.script as gscript
- from grass.script import gisenv
- from grass.grassdb.data import map_exists
- from grass.grassdb.checks import (get_mapset_owner, is_mapset_locked,
- is_different_mapset_owner)
- from grass.exceptions import CalledModuleError
- updateMapset, EVT_UPDATE_MAPSET = NewEvent()
- def filterModel(model, element=None, name=None):
- """Filter tree model based on type or name of map using regular expressions.
- Copies tree and remove nodes which don't match."""
- fmodel = copy.deepcopy(model)
- nodesToRemove = []
- if name:
- try:
- regex = re.compile(name)
- except:
- return fmodel
- for gisdbase in fmodel.root.children:
- for location in gisdbase.children:
- for mapset in location.children:
- for layer in mapset.children:
- if element and layer.data['type'] != element:
- nodesToRemove.append(layer)
- continue
- if name and regex.search(layer.data['name']) is None:
- nodesToRemove.append(layer)
- for node in reversed(nodesToRemove):
- fmodel.RemoveNode(node)
- cleanUpTree(fmodel)
- return fmodel
- def cleanUpTree(model):
- """Removes empty element/mapsets/locations nodes.
- It first removes empty elements, then mapsets, then locations"""
- # removes empty mapsets
- nodesToRemove = []
- for gisdbase in model.root.children:
- for location in gisdbase.children:
- for mapset in location.children:
- if not mapset.children:
- nodesToRemove.append(mapset)
- for node in reversed(nodesToRemove):
- model.RemoveNode(node)
- # removes empty locations
- nodesToRemove = []
- for gisdbase in model.root.children:
- for location in gisdbase.children:
- if not location.children:
- nodesToRemove.append(location)
- for node in reversed(nodesToRemove):
- model.RemoveNode(node)
- def getLocationTree(gisdbase, location, queue, mapsets=None):
- """Creates dictionary with mapsets, elements, layers for given location.
- Returns tuple with the dictionary and error (or None)"""
- tmp_gisrc_file, env = gscript.create_environment(gisdbase, location, 'PERMANENT')
- env['GRASS_SKIP_MAPSET_OWNER_CHECK'] = '1'
- maps_dict = {}
- elements = ['raster', 'raster_3d', 'vector']
- try:
- if not mapsets:
- mapsets = gscript.read_command(
- 'g.mapsets',
- flags='l',
- separator='comma',
- quiet=True,
- env=env).strip()
- except CalledModuleError:
- queue.put(
- (maps_dict,
- _("Failed to read mapsets from location <{l}>.").format(
- l=location)))
- gscript.try_remove(tmp_gisrc_file)
- return
- else:
- mapsets = mapsets.split(',')
- Debug.msg(
- 4, "Location <{0}>: {1} mapsets found".format(
- location, len(mapsets)))
- for each in mapsets:
- maps_dict[each] = []
- try:
- maplist = gscript.read_command(
- 'g.list', flags='mt', type=elements,
- mapset=','.join(mapsets),
- quiet=True, env=env).strip()
- except CalledModuleError:
- queue.put(
- (maps_dict,
- _("Failed to read maps from location <{l}>.").format(
- l=location)))
- gscript.try_remove(tmp_gisrc_file)
- return
- else:
- # fill dictionary
- listOfMaps = maplist.splitlines()
- Debug.msg(
- 4, "Location <{0}>: {1} maps found".format(
- location, len(listOfMaps)))
- for each in listOfMaps:
- ltype, wholename = each.split('/')
- name, mapset = wholename.split('@', maxsplit=1)
- maps_dict[mapset].append({'name': name, 'type': ltype})
- queue.put((maps_dict, None))
- gscript.try_remove(tmp_gisrc_file)
- class MapWatch(PatternMatchingEventHandler):
- """Monitors file events (create, delete, move files) using watchdog
- to inform about changes in current mapset. One instance monitors
- only one element (raster, vector, raster_3d).
- Patterns are not used/needed in this case, use just '*' for matching
- everything. When file/directory change is detected, wx event is dispatched
- to event handler (can't use Signals because this is different thread),
- containing info about the change."""
- def __init__(self, patterns, element, event_handler):
- PatternMatchingEventHandler.__init__(self, patterns=patterns)
- self.element = element
- self.event_handler = event_handler
-
- def on_created(self, event):
- if (self.element == 'vector' or self.element == 'raster_3d') and not event.is_directory:
- return
- evt = updateMapset(src_path=event.src_path, event_type=event.event_type,
- is_directory=event.is_directory, dest_path=None)
- wx.PostEvent(self.event_handler, evt)
- def on_deleted(self, event):
- if (self.element == 'vector' or self.element == 'raster_3d') and not event.is_directory:
- return
- evt = updateMapset(src_path=event.src_path, event_type=event.event_type,
- is_directory=event.is_directory, dest_path=None)
- wx.PostEvent(self.event_handler, evt)
- def on_moved(self, event):
- if (self.element == 'vector' or self.element == 'raster_3d') and not event.is_directory:
- return
- evt = updateMapset(src_path=event.src_path, event_type=event.event_type,
- is_directory=event.is_directory, dest_path=event.dest_path)
- wx.PostEvent(self.event_handler, evt)
- class NameEntryDialog(TextEntryDialog):
- def __init__(self, element, mapset, env, **kwargs):
- TextEntryDialog.__init__(self, **kwargs)
- self._element = element
- self._mapset = mapset
- self._env = env
- id_OK = self.GetAffirmativeId()
- self.Bind(wx.EVT_BUTTON, self.OnOK, self.FindWindowById(id_OK))
- def OnOK(self, event):
- new = self.GetValue()
- if not new:
- return
- if map_exists(new, self._element, env=self._env, mapset=self._mapset):
- dlg = wx.MessageDialog(
- self,
- message=_(
- "Map of type {elem} <{name}> already exists in mapset <{mapset}>. "
- "Do you want to overwrite it?").format(
- elem=self._element,
- name=new,
- mapset=self._mapset),
- caption=_("Overwrite?"),
- style=wx.YES_NO)
- if dlg.ShowModal() == wx.ID_YES:
- dlg.Destroy()
- self._env['GRASS_OVERWRITE'] = '1'
- self.EndModal(wx.ID_OK)
- else:
- dlg.Destroy()
- return
- else:
- self.EndModal(wx.ID_OK)
- class DataCatalogNode(DictNode):
- """Node representing item in datacatalog."""
- def __init__(self, data=None):
- super(DataCatalogNode, self).__init__(data=data)
- @property
- def label(self):
- data = self.data
- if data['type'] == 'mapset':
- owner = data['owner'] if data['owner'] else _("name unknown")
- if data['current']:
- return _("{name} (current)").format(**data)
- elif data['is_different_owner'] and data['lock']:
- return _("{name} (in use, owner: {owner})").format(
- name=data["name"], owner=owner
- )
- elif data['lock']:
- return _("{name} (in use)").format(**data)
- elif data['is_different_owner']:
- return _("{name} (owner: {owner})").format(name=data["name"],
- owner=owner)
- return _("{name}").format(**data)
- def match(self, **kwargs):
- """Method used for searching according to given parameters.
- :param value: dictionary value to be matched
- :param key: data dictionary key
- """
- if not kwargs:
- return False
- for key in kwargs:
- if not (key in self.data and self.data[key] == kwargs[key]):
- return False
- return True
- class DataCatalogTree(TreeView):
- """Tree structure visualizing and managing grass database.
- Uses virtual tree and model defined in core/treemodel.py.
- When changes to data are initiated from inside, the model
- and the tree are not changed directly, rather a grassdbChanged
- signal needs to be emitted and the handler of the signal
- takes care of the refresh. At the same time, watchdog (if installed)
- monitors changes in current mapset and refreshes the tree.
- """
- def __init__(
- self, parent, model=None, giface=None,
- style=wx.TR_HIDE_ROOT | wx.TR_EDIT_LABELS |
- wx.TR_LINES_AT_ROOT | wx.TR_HAS_BUTTONS |
- wx.TR_FULL_ROW_HIGHLIGHT | wx.TR_MULTIPLE):
- """Location Map Tree constructor."""
- self._model = TreeModel(DataCatalogNode)
- self._orig_model = self._model
- super(
- DataCatalogTree,
- self).__init__(
- parent=parent,
- model=self._model,
- id=wx.ID_ANY,
- style=style)
- self._giface = giface
- self._restricted = True
- self.showNotification = Signal('Tree.showNotification')
- self.parent = parent
- self.contextMenu.connect(self.OnRightClick)
- self.itemActivated.connect(self.OnDoubleClick)
- self._giface.currentMapsetChanged.connect(self._updateAfterMapsetChanged)
- self._giface.grassdbChanged.connect(self._updateAfterGrassdbChanged)
- self._iconTypes = ['grassdb', 'location', 'mapset', 'raster',
- 'vector', 'raster_3d']
- self._initImages()
- self.thread = gThread()
- self._resetSelectVariables()
- self._resetCopyVariables()
- self.current_grassdb_node = None
- self.current_location_node = None
- self.current_mapset_node = None
- self.UpdateCurrentDbLocationMapsetNode()
- # Get databases from settings
- # add current to settings if it's not included
- self.grassdatabases = self._getValidSavedGrassDBs()
- currentDB = gisenv()['GISDBASE']
- if currentDB not in self.grassdatabases:
- self.grassdatabases.append(currentDB)
- self._saveGrassDBs()
- self.beginDrag = Signal('DataCatalogTree.beginDrag')
- self.endDrag = Signal('DataCatalogTree.endDrag')
- self.startEdit = Signal('DataCatalogTree.startEdit')
- self.endEdit = Signal('DataCatalogTree.endEdit')
- self.Bind(wx.EVT_TREE_BEGIN_DRAG, lambda evt:
- self._emitSignal(evt.GetItem(), self.beginDrag, event=evt))
- self.Bind(wx.EVT_TREE_END_DRAG, lambda evt:
- self._emitSignal(evt.GetItem(), self.endDrag, event=evt))
- self.beginDrag.connect(self.OnBeginDrag)
- self.endDrag.connect(self.OnEndDrag)
- self.Bind(wx.EVT_TREE_BEGIN_LABEL_EDIT, lambda evt:
- self._emitSignal(evt.GetItem(), self.startEdit, event=evt))
- self.Bind(wx.EVT_TREE_END_LABEL_EDIT, lambda evt:
- self._emitSignal(evt.GetItem(), self.endEdit, event=evt))
- self.startEdit.connect(self.OnStartEditLabel)
- self.endEdit.connect(self.OnEditLabel)
- self.Bind(EVT_UPDATE_MAPSET, self.OnWatchdogMapsetReload)
-
- self.observer = None
- def _resetSelectVariables(self):
- """Reset variables related to item selection."""
- self.selected_grassdb = []
- self.selected_layer = []
- self.selected_mapset = []
- self.selected_location = []
- self.mixed = False
- def _resetCopyVariables(self):
- """Reset copy related variables."""
- self.copy_mode = False
- self.copy_layer = None
- self.copy_mapset = None
- self.copy_location = None
- self.copy_grassdb = None
- def _getValidSavedGrassDBs(self):
- """Returns list of GRASS databases from settings.
- Returns only existing directories."""
- dbs = UserSettings.Get(group='datacatalog',
- key='grassdbs',
- subkey='listAsString')
- dbs = [db for db in dbs.split(',') if os.path.isdir(db)]
- return dbs
- def _saveGrassDBs(self):
- """Save current grass dbs in tree to settings"""
- UserSettings.Set(group='datacatalog',
- key='grassdbs',
- subkey='listAsString',
- value=",".join(self.grassdatabases))
- grassdbSettings = {}
- UserSettings.ReadSettingsFile(settings=grassdbSettings)
- if 'datacatalog' not in grassdbSettings:
- grassdbSettings['datacatalog'] = UserSettings.Get(group='datacatalog')
- # update only dbs
- grassdbSettings['datacatalog']['grassdbs'] = UserSettings.Get(group='datacatalog', key='grassdbs')
- UserSettings.SaveToFile(grassdbSettings)
- def _reloadMapsetNode(self, mapset_node):
- """Recursively reload the model of a specific mapset node"""
- if mapset_node.children:
- del mapset_node.children[:]
- q = Queue()
- p = Process(
- target=getLocationTree,
- args=(
- mapset_node.parent.parent.data['name'],
- mapset_node.parent.data['name'],
- q,
- mapset_node.data['name']))
- p.start()
- maps, error = q.get()
- self._populateMapsetItem(mapset_node,
- maps[mapset_node.data['name']])
- self._orig_model = copy.deepcopy(self._model)
- return error
- def _reloadLocationNode(self, location_node):
- """Recursively reload the model of a specific location node"""
- if location_node.children:
- del location_node.children[:]
- q = Queue()
- p = Process(
- target=getLocationTree,
- args=(
- location_node.parent.data['name'],
- location_node.data['name'],
- q,
- None))
- p.start()
- maps, error = q.get()
- for mapset in maps:
- mapset_path = os.path.join(location_node.parent.data['name'],
- location_node.data['name'],
- mapset)
- mapset_node = self._model.AppendNode(
- parent=location_node,
- data=dict(type='mapset',
- name=mapset,
- current=False,
- lock=is_mapset_locked(mapset_path),
- is_different_owner=is_different_mapset_owner(mapset_path),
- owner=get_mapset_owner(mapset_path)))
- self._populateMapsetItem(mapset_node,
- maps[mapset])
- self._model.SortChildren(location_node)
- self._orig_model = copy.deepcopy(self._model)
- return error
- def _reloadGrassDBNode(self, grassdb_node):
- """Recursively reload the model of a specific grassdb node.
- Runs reloading locations in parallel."""
- if grassdb_node.children:
- del grassdb_node.children[:]
- locations = GetListOfLocations(grassdb_node.data['name'])
- loc_count = proc_count = 0
- queue_list = []
- proc_list = []
- loc_list = []
- try:
- nprocs = cpu_count()
- except NotImplementedError:
- nprocs = 4
- results = dict()
- errors = []
- location_nodes = []
- all_location_nodes = []
- nlocations = len(locations)
- for location in locations:
- results[location] = dict()
- varloc = self._model.AppendNode(parent=grassdb_node,
- data=dict(type='location',
- name=location))
- location_nodes.append(varloc)
- all_location_nodes.append(varloc)
- loc_count += 1
- Debug.msg(
- 3, "Scanning location <{0}> ({1}/{2})".format(location, loc_count, nlocations))
- q = Queue()
- p = Process(target=getLocationTree,
- args=(grassdb_node.data['name'], location, q))
- p.start()
- queue_list.append(q)
- proc_list.append(p)
- loc_list.append(location)
- proc_count += 1
- # Wait for all running processes
- if proc_count == nprocs or loc_count == nlocations:
- Debug.msg(4, "Process subresults")
- for i in range(len(loc_list)):
- maps, error = queue_list[i].get()
- proc_list[i].join()
- if error:
- errors.append(error)
- for key in sorted(maps.keys()):
- mapset_path = os.path.join(location_nodes[i].parent.data['name'],
- location_nodes[i].data['name'],
- key)
- mapset_node = self._model.AppendNode(
- parent=location_nodes[i],
- data=dict(type='mapset',
- name=key,
- lock=is_mapset_locked(mapset_path),
- current=False,
- is_different_owner=is_different_mapset_owner(mapset_path),
- owner=get_mapset_owner(mapset_path)))
- self._populateMapsetItem(mapset_node, maps[key])
- proc_count = 0
- proc_list = []
- queue_list = []
- loc_list = []
- location_nodes = []
- for node in all_location_nodes:
- self._model.SortChildren(node)
- self._model.SortChildren(grassdb_node)
- self._orig_model = copy.deepcopy(self._model)
- return errors
- def _reloadTreeItems(self):
- """Updates grass databases, locations, mapsets and layers in the tree.
- It runs in thread, so it should not directly interact with GUI.
- In case of any errors it returns the errors as a list of strings, otherwise None.
- """
- errors = []
- for grassdatabase in self.grassdatabases:
- grassdb_nodes = self._model.SearchNodes(name=grassdatabase,
- type='grassdb')
- if not grassdb_nodes:
- grassdb_node = self._model.AppendNode(parent=self._model.root,
- data=dict(type='grassdb',
- name=grassdatabase))
- else:
- grassdb_node = grassdb_nodes[0]
- error = self._reloadGrassDBNode(grassdb_node)
- if error:
- errors += error
- if errors:
- return errors
- return None
- def ScheduleWatchCurrentMapset(self):
- """Using watchdog library, sets up watching of current mapset folder
- to detect changes not captured by other means (e.g. from command line).
- Schedules 3 watches (raster, vector, 3D raster).
- If watchdog observers are active, it restarts the observers in current mapset.
- """
- global watchdog_used
- if not watchdog_used:
- return
- if self.observer and self.observer.is_alive():
- self.observer.stop()
- self.observer.join()
- self.observer.unschedule_all()
- self.observer = Observer()
- gisenv = gscript.gisenv()
- for element, directory in (('raster', 'cell'), ('vector', 'vector'), ('raster_3d', 'grid3')):
- path = os.path.join(gisenv['GISDBASE'], gisenv['LOCATION_NAME'],
- gisenv['MAPSET'], directory)
- if not os.path.exists(path):
- try:
- os.mkdir(path)
- except OSError:
- pass
- if os.path.exists(path):
- self.observer.schedule(MapWatch("*", element, self), path=path, recursive=False)
- try:
- self.observer.start()
- except OSError:
- # in case inotify on linux exceeds limits
- watchdog_used = False
- return
- def OnWatchdogMapsetReload(self, event):
- """Reload mapset node associated with watchdog event"""
- mapset_path = os.path.dirname(os.path.dirname(os.path.abspath(event.src_path)))
- location_path = os.path.dirname(os.path.abspath(mapset_path))
- db = os.path.dirname(os.path.abspath(location_path))
- node = self.GetDbNode(grassdb=db, location=os.path.basename(location_path),
- mapset=os.path.basename(mapset_path))
- if node:
- self._reloadMapsetNode(node)
- self.RefreshNode(node, recursive=True)
- def GetDbNode(self, grassdb, location=None, mapset=None, map=None, map_type=None):
- """Returns node representing db/location/mapset/map or None if not found."""
- grassdb_nodes = self._model.SearchNodes(name=grassdb, type='grassdb')
- if grassdb_nodes:
- if not location:
- return grassdb_nodes[0]
- location_nodes = self._model.SearchNodes(parent=grassdb_nodes[0],
- name=location, type='location')
- if location_nodes:
- if not mapset:
- return location_nodes[0]
- mapset_nodes = self._model.SearchNodes(parent=location_nodes[0],
- name=mapset, type='mapset')
- if mapset_nodes:
- if not map:
- return mapset_nodes[0]
- map_nodes = self._model.SearchNodes(parent=mapset_nodes[0],
- name=map, type=map_type)
- if map_nodes:
- return map_nodes[0]
- return None
- def _renameNode(self, node, name):
- """Rename node (map, mapset, location), sort and refresh.
- Should be called after actual renaming of a map, mapset, location."""
- node.data['name'] = name
- self._model.SortChildren(node.parent)
- self.RefreshNode(node.parent, recursive=True)
- def UpdateCurrentDbLocationMapsetNode(self):
- """Update variables storing current mapset/location/grassdb node.
- Updates associated mapset node data ('lock' and 'current').
- """
- def is_current_mapset_node_locked():
- mapset_path = os.path.join(self.current_grassdb_node.data['name'],
- self.current_location_node.data['name'],
- self.current_mapset_node.data["name"])
- return is_mapset_locked(mapset_path)
- if self.current_mapset_node:
- self.current_mapset_node.data["current"] = False
- self.current_mapset_node.data["lock"] = is_current_mapset_node_locked()
- self.current_grassdb_node, self.current_location_node, self.current_mapset_node = \
- self.GetCurrentDbLocationMapsetNode()
- if self.current_mapset_node:
- self.current_mapset_node.data["current"] = True
- self.current_mapset_node.data["lock"] = is_current_mapset_node_locked()
- def ReloadTreeItems(self):
- """Reload dbs, locations, mapsets and layers in the tree."""
- self.busy = wx.BusyCursor()
- self._quickLoading()
- self.thread.Run(callable=self._reloadTreeItems,
- ondone=self._loadItemsDone)
- def _quickLoading(self):
- """Quick loading of locations to show
- something when loading for the first time"""
- if self._model.root.children:
- return
- gisenv = gscript.gisenv()
- for grassdatabase in self.grassdatabases:
- grassdb_node = self._model.AppendNode(parent=self._model.root,
- data=dict(type='grassdb',
- name=grassdatabase))
- for location in GetListOfLocations(grassdatabase):
- self._model.AppendNode(parent=grassdb_node,
- data=dict(type='location',
- name=location))
- self.RefreshItems()
- if grassdatabase == gisenv['GISDBASE']:
- self.ExpandNode(grassdb_node, recursive=False)
- def _loadItemsDone(self, event):
- Debug.msg(1, "Tree filled")
- del self.busy
- if event.ret is not None:
- self._giface.WriteWarning('\n'.join(event.ret))
- self.UpdateCurrentDbLocationMapsetNode()
- self.ScheduleWatchCurrentMapset()
- self.RefreshItems()
- self.ExpandCurrentMapset()
- def ReloadCurrentMapset(self):
- """Reload current mapset tree only."""
- self.UpdateCurrentDbLocationMapsetNode()
- if not self.current_grassdb_node or not self.current_location_node or not self.current_mapset_node:
- return
- self._reloadMapsetNode(self.current_mapset_node)
- self.RefreshNode(self.current_mapset_node, recursive=True)
- def _populateMapsetItem(self, mapset_node, data):
- for item in data:
- self._model.AppendNode(parent=mapset_node,
- data=dict(**item))
- self._model.SortChildren(mapset_node)
- def _initImages(self):
- bmpsize = (16, 16)
- icons = {
- 'grassdb': MetaIcon(img='grassdb').GetBitmap(bmpsize),
- 'location': MetaIcon(img='location').GetBitmap(bmpsize),
- 'mapset': MetaIcon(img='mapset').GetBitmap(bmpsize),
- 'raster': MetaIcon(img='raster').GetBitmap(bmpsize),
- 'vector': MetaIcon(img='vector').GetBitmap(bmpsize),
- 'raster_3d': MetaIcon(img='raster3d').GetBitmap(bmpsize)
- }
- il = wx.ImageList(bmpsize[0], bmpsize[1], mask=False)
- for each in self._iconTypes:
- il.Add(icons[each])
- self.AssignImageList(il)
- def GetControl(self):
- """Returns control itself."""
- return self
- def DefineItems(self, selected):
- """Set selected items."""
- self._resetSelectVariables()
- mixed = []
- for item in selected:
- type = item.data['type']
- if type in ('raster', 'raster_3d', 'vector'):
- self.selected_layer.append(item)
- self.selected_mapset.append(item.parent)
- self.selected_location.append(item.parent.parent)
- self.selected_grassdb.append(item.parent.parent.parent)
- mixed.append('layer')
- elif type == 'mapset':
- self.selected_layer.append(None)
- self.selected_mapset.append(item)
- self.selected_location.append(item.parent)
- self.selected_grassdb.append(item.parent.parent)
- mixed.append('mapset')
- elif type == 'location':
- self.selected_layer.append(None)
- self.selected_mapset.append(None)
- self.selected_location.append(item)
- self.selected_grassdb.append(item.parent)
- mixed.append('location')
- elif type == 'grassdb':
- self.selected_layer.append(None)
- self.selected_mapset.append(None)
- self.selected_location.append(None)
- self.selected_grassdb.append(item)
- mixed.append('grassdb')
- self.mixed = False
- if len(set(mixed)) > 1:
- self.mixed = True
- def OnSelChanged(self, event):
- self.selected_layer = None
- def OnRightClick(self, node):
- """Display popup menu."""
- self.DefineItems(self.GetSelected())
- if self.mixed:
- self._popupMenuEmpty()
- return
- if not self.selected_layer:
- self._popupMenuEmpty()
- elif self.selected_layer[0]:
- self._popupMenuLayer()
- elif self.selected_mapset[0] and len(self.selected_mapset) == 1:
- self._popupMenuMapset()
- elif self.selected_location[0] and not self.selected_mapset[0] and len(self.selected_location) == 1:
- self._popupMenuLocation()
- elif self.selected_grassdb[0] and not self.selected_location[0] and len(self.selected_grassdb) == 1:
- self._popupMenuGrassDb()
- elif len(self.selected_grassdb) > 1 and not self.selected_location[0]:
- self._popupMenuEmpty()
- elif len(self.selected_location) > 1 and not self.selected_mapset[0]:
- self._popupMenuMultipleLocations()
- elif len(self.selected_mapset) > 1:
- self._popupMenuMultipleMapsets()
- else:
- self._popupMenuEmpty()
- def OnDoubleClick(self, node):
- """Double click on item/node.
- Display selected layer if node is a map layer otherwise
- expand/collapse node.
- """
- if not isinstance(self._giface, StandaloneGrassInterface):
- self.DefineItems([node])
- selected_layer = self.selected_layer[0]
- selected_mapset = self.selected_mapset[0]
- selected_loc = self.selected_location[0]
- if selected_layer is not None:
- genv = gisenv()
- # Check if the layer is in different location
- if selected_loc.data['name'] != genv['LOCATION_NAME']:
- dlg = wx.MessageDialog(
- parent=self,
- message=_(
- "Map <{0}@{1}> is not in the current location"
- " and therefore cannot be displayed."
- "\n\n"
- "To display this map switch to mapset <{1}> first."
- ).format(selected_layer.data['name'],
- selected_mapset.data['name']),
- caption=_("Unable to display the map"),
- style=wx.OK | wx.ICON_WARNING
- )
- dlg.ShowModal()
- dlg.Destroy()
- else:
- self.DisplayLayer()
- return
- # expand/collapse location/mapset...
- if self.IsNodeExpanded(node):
- self.CollapseNode(node, recursive=False)
- else:
- self.ExpandNode(node, recursive=False)
- def ExpandCurrentLocation(self):
- """Expand current location"""
- location = gscript.gisenv()['LOCATION_NAME']
- item = self._model.SearchNodes(name=location, type='location')
- if item:
- self.Select(item[0], select=True)
- self.ExpandNode(item[0], recursive=False)
- else:
- Debug.msg(1, "Location <%s> not found" % location)
- def GetCurrentDbLocationMapsetNode(self):
- """Get current mapset node"""
- genv = gisenv()
- gisdbase = genv['GISDBASE']
- location = genv['LOCATION_NAME']
- mapset = genv['MAPSET']
- grassdbItem = self._model.SearchNodes(
- name=gisdbase, type='grassdb')
- if not grassdbItem:
- return None, None, None
- locationItem = self._model.SearchNodes(
- parent=grassdbItem[0],
- name=location, type='location')
- if not locationItem:
- return grassdbItem[0], None, None
- mapsetItem = self._model.SearchNodes(
- parent=locationItem[0],
- name=mapset,
- type='mapset')
- if not mapsetItem:
- return grassdbItem[0], locationItem[0], None
- return grassdbItem[0], locationItem[0], mapsetItem[0]
- def OnGetItemImage(self, index, which=wx.TreeItemIcon_Normal, column=0):
- """Overriden method to return image for each item."""
- node = self._model.GetNodeByIndex(index)
- try:
- return self._iconTypes.index(node.data['type'])
- except ValueError:
- return 0
- def OnGetItemTextColour(self, index):
- """Overriden method to return colour for each item.
- Used to distinquish lock and ownership on mapsets."""
- node = self._model.GetNodeByIndex(index)
- if node.data['type'] == 'mapset':
- if node.data['current']:
- return wx.SystemSettings.GetColour(wx.SYS_COLOUR_WINDOWTEXT)
- elif node.data['lock'] or node.data['is_different_owner']:
- return wx.SystemSettings.GetColour(wx.SYS_COLOUR_GRAYTEXT)
- return wx.SystemSettings.GetColour(wx.SYS_COLOUR_WINDOWTEXT)
- def OnGetItemFont(self, index):
- """Overriden method to return font for each item.
- Used to highlight current db/loc/mapset."""
- node = self._model.GetNodeByIndex(index)
- font = self.GetFont()
- if node.data['type'] in ('grassdb', 'location', 'mapset'):
- if node in (self.current_grassdb_node, self.current_location_node, self.current_mapset_node):
- font.SetWeight(wx.FONTWEIGHT_BOLD)
- else:
- font.SetWeight(wx.FONTWEIGHT_NORMAL)
- return font
- def ExpandCurrentMapset(self):
- """Expand current mapset"""
- if self.current_mapset_node:
- self.Select(self.current_mapset_node, select=True)
- self.ExpandNode(self.current_mapset_node, recursive=True)
- def SetRestriction(self, restrict):
- self._restricted = restrict
- def _runCommand(self, prog, **kwargs):
- cmdString = ' '.join(gscript.make_command(prog, **kwargs))
- ret = RunCommand(prog, parent=self, **kwargs)
- return ret, cmdString
- def OnMoveMap(self, event):
- """Move layer or mapset (just save it temporarily, copying is done by paste)"""
- self.copy_mode = False
- self.copy_layer = self.selected_layer[:]
- self.copy_mapset = self.selected_mapset[:]
- self.copy_location = self.selected_location[:]
- self.copy_grassdb = self.selected_grassdb[:]
- if len(self.copy_layer) > 1:
- label = _("{c} maps marked for moving.").format(c=len(self.selected_layer))
- else:
- label = _("Map <{layer}> marked for moving.").format(layer=self.copy_layer[0].data['name'])
- self.showNotification.emit(message=label)
- def OnCopyMap(self, event):
- """Copy layer or mapset (just save it temporarily, copying is done by paste)"""
- self.copy_mode = True
- self.copy_layer = self.selected_layer[:]
- self.copy_mapset = self.selected_mapset[:]
- self.copy_location = self.selected_location[:]
- self.copy_grassdb = self.selected_grassdb[:]
- if len(self.copy_layer) > 1:
- label = _("{c} maps marked for copying.").format(c=len(self.selected_layer))
- else:
- label = _("Map <{layer}> marked for copying.").format(layer=self.copy_layer[0].data['name'])
- self.showNotification.emit(message=label)
- def OnRenameMap(self, event):
- """Rename layer with dialog"""
- old_name = self.selected_layer[0].data['name']
- gisrc, env = gscript.create_environment(
- self.selected_grassdb[0].data['name'],
- self.selected_location[0].data['name'],
- self.selected_mapset[0].data['name'])
- new_name = self._getNewMapName(
- _('New name'),
- _('Rename map'),
- old_name,
- env=env,
- mapset=self.selected_mapset[0].data['name'],
- element=self.selected_layer[0].data['type'])
- if new_name:
- self.Rename(old_name, new_name)
- def CreateMapset(self, grassdb_node, location_node):
- """Creates new mapset interactively and adds it to the tree."""
- mapset = create_mapset_interactively(self, grassdb_node.data['name'],
- location_node.data['name'])
- if mapset:
- self._giface.grassdbChanged.emit(grassdb=grassdb_node.data['name'],
- location=location_node.data['name'],
- mapset=mapset,
- element='mapset',
- action='new')
- def OnCreateMapset(self, event):
- """Create new mapset"""
- self.CreateMapset(self.selected_grassdb[0], self.selected_location[0])
- def CreateLocation(self, grassdb_node):
- """
- Creates new location interactively and adds it to the tree.
- """
- grassdatabase, location, mapset = (
- create_location_interactively(self, grassdb_node.data['name'])
- )
- if location:
- self._giface.grassdbChanged.emit(grassdb=grassdatabase,
- location=location,
- element='location',
- action='new')
- def OnCreateLocation(self, event):
- """Create new location"""
- self.CreateLocation(self.selected_grassdb[0])
- def OnRenameMapset(self, event):
- """
- Rename selected mapset
- """
- newmapset = rename_mapset_interactively(
- self,
- self.selected_grassdb[0].data['name'],
- self.selected_location[0].data['name'],
- self.selected_mapset[0].data['name'])
- if newmapset:
- self._giface.grassdbChanged.emit(grassdb=self.selected_grassdb[0].data['name'],
- location=self.selected_location[0].data['name'],
- mapset=self.selected_mapset[0].data['name'],
- element='mapset',
- action='rename',
- newname=newmapset)
- def OnRenameLocation(self, event):
- """
- Rename selected location
- """
- newlocation = rename_location_interactively(
- self,
- self.selected_grassdb[0].data['name'],
- self.selected_location[0].data['name'])
- if newlocation:
- self._giface.grassdbChanged.emit(grassdb=self.selected_grassdb[0].data['name'],
- location=self.selected_location[0].data['name'],
- element='location',
- action='rename',
- newname=newlocation)
- def OnStartEditLabel(self, node, event):
- """Start label editing"""
- self.DefineItems([node])
- # Not allowed for grassdb node
- if node.data['type'] == 'grassdb':
- event.Veto()
- # Check selected mapset
- elif node.data['type'] == 'mapset':
- if (
- self._restricted
- or get_reason_mapset_not_removable(self.selected_grassdb[0].data['name'],
- self.selected_location[0].data['name'],
- self.selected_mapset[0].data['name'],
- check_permanent=True)
- ):
- event.Veto()
- # Check selected location
- elif node.data['type'] == 'location':
- if (
- self._restricted
- or get_reasons_location_not_removable(self.selected_grassdb[0].data['name'],
- self.selected_location[0].data['name'])
- ):
- event.Veto()
- elif node.data['type'] in ('raster', 'raster_3d', 'vector'):
- currentGrassDb, currentLocation, currentMapset = self._isCurrent(gisenv())
- if not currentMapset:
- event.Veto()
- def OnEditLabel(self, node, event):
- """End label editing"""
- if event.IsEditCancelled():
- return
- old_name = node.data['name']
- Debug.msg(1, "End label edit {name}".format(name=old_name))
- new_name = event.GetLabel()
- if node.data['type'] in ('raster', 'raster_3d', 'vector'):
- self.Rename(old_name, new_name)
- elif node.data['type'] == 'mapset':
- message = get_mapset_name_invalid_reason(
- self.selected_grassdb[0].data['name'],
- self.selected_location[0].data['name'],
- new_name)
- if message:
- GError(parent=self, message=message,
- caption=_("Cannot rename mapset"),
- showTraceback=False)
- event.Veto()
- return
- rename_mapset(self.selected_grassdb[0].data['name'],
- self.selected_location[0].data['name'],
- self.selected_mapset[0].data['name'],
- new_name)
- self._renameNode(self.selected_mapset[0], new_name)
- label = _(
- "Renaming mapset <{oldmapset}> to <{newmapset}> completed").format(
- oldmapset=old_name, newmapset=new_name)
- self.showNotification.emit(message=label)
- elif node.data['type'] == 'location':
- message = get_location_name_invalid_reason(
- self.selected_grassdb[0].data['name'],
- new_name)
- if message:
- GError(parent=self, message=message,
- caption=_("Cannot rename location"),
- showTraceback=False)
- event.Veto()
- return
- rename_location(self.selected_grassdb[0].data['name'],
- self.selected_location[0].data['name'],
- new_name)
- self._renameNode(self.selected_location[0], new_name)
- label = _(
- "Renaming location <{oldlocation}> to <{newlocation}> completed").format(
- oldlocation=old_name, newlocation=new_name)
- self.showNotification.emit(message=label)
- def Rename(self, old, new):
- """Rename layer"""
- string = old + ',' + new
- gisrc, env = gscript.create_environment(
- self.selected_grassdb[0].data['name'],
- self.selected_location[0].data['name'],
- self.selected_mapset[0].data['name'])
- label = _("Renaming map <{name}>...").format(name=string)
- self.showNotification.emit(message=label)
- if self.selected_layer[0].data['type'] == 'vector':
- renamed, cmd = self._runCommand('g.rename', vector=string, env=env)
- elif self.selected_layer[0].data['type'] == 'raster':
- renamed, cmd = self._runCommand('g.rename', raster=string, env=env)
- else:
- renamed, cmd = self._runCommand(
- 'g.rename', raster3d=string, env=env)
- gscript.try_remove(gisrc)
- if renamed == 0:
- self.showNotification.emit(
- message=_("{cmd} -- completed").format(cmd=cmd))
- Debug.msg(1, "LAYER RENAMED TO: " + new)
- self._giface.grassdbChanged.emit(grassdb=self.selected_grassdb[0].data['name'],
- location=self.selected_location[0].data['name'],
- mapset=self.selected_mapset[0].data['name'],
- map=old,
- element=self.selected_layer[0].data['type'],
- newname=new,
- action='rename')
- def OnPasteMap(self, event):
- # copying between mapsets of one location
- if not self.copy_layer:
- if self.copy_mode:
- GMessage(_("No map selected for copying."), parent=self)
- else:
- GMessage(_("No map selected for moving."), parent=self)
- return
- for i in range(len(self.copy_layer)):
- gisrc, env = gscript.create_environment(self.selected_grassdb[0].data['name'],
- self.selected_location[0].data['name'],
- self.selected_mapset[0].data['name'])
- gisrc2, env2 = gscript.create_environment(self.copy_grassdb[i].data['name'],
- self.copy_location[i].data['name'],
- self.copy_mapset[i].data['name'])
- new_name = self.copy_layer[i].data['name']
- if self.selected_location[0] == self.copy_location[i]:
- # within one mapset
- if self.selected_mapset[0] == self.copy_mapset[i]:
- # ignore when just moves map
- if self.copy_mode is False:
- return
- new_name = self._getNewMapName(_('New name for <{n}>').format(n=self.copy_layer[i].data['name']),
- _('Select new name'),
- self.copy_layer[i].data['name'], env=env,
- mapset=self.selected_mapset[0].data['name'],
- element=self.copy_layer[i].data['type'])
- if not new_name:
- return
- # within one location, different mapsets
- else:
- if map_exists(new_name, element=self.copy_layer[i].data['type'], env=env,
- mapset=self.selected_mapset[0].data['name']):
- new_name = self._getNewMapName(_('New name for <{n}>').format(n=self.copy_layer[i].data['name']),
- _('Select new name'),
- self.copy_layer[i].data['name'], env=env,
- mapset=self.selected_mapset[0].data['name'],
- element=self.copy_layer[i].data['type'])
- if not new_name:
- return
- string = self.copy_layer[i].data['name'] + '@' + self.copy_mapset[i].data['name'] + ',' + new_name
- pasted = 0
- if self.copy_mode:
- label = _("Copying <{name}>...").format(name=string)
- else:
- label = _("Moving <{name}>...").format(name=string)
- self.showNotification.emit(message=label)
- if self.copy_layer[i].data['type'] == 'vector':
- pasted, cmd = self._runCommand('g.copy', vector=string, env=env)
- node = 'vector'
- elif self.copy_layer[i].data['type'] == 'raster':
- pasted, cmd = self._runCommand('g.copy', raster=string, env=env)
- node = 'raster'
- else:
- pasted, cmd = self._runCommand('g.copy', raster_3d=string, env=env)
- node = 'raster_3d'
- if pasted == 0:
- Debug.msg(1, "COPIED TO: " + new_name)
- if self.copy_mode:
- self.showNotification.emit(message=_("g.copy completed"))
- else:
- self.showNotification.emit(message=_("g.copy completed"))
- self._giface.grassdbChanged.emit(grassdb=self.selected_grassdb[0].data['name'],
- location=self.selected_location[0].data['name'],
- mapset=self.selected_mapset[0].data['name'],
- map=new_name,
- element=node,
- action='new')
- # remove old
- if not self.copy_mode:
- self._removeMapAfterCopy(self.copy_layer[i], self.copy_mapset[i], env2)
- gscript.try_remove(gisrc)
- gscript.try_remove(gisrc2)
- # expand selected mapset
- else:
- if self.copy_layer[i].data['type'] == 'raster_3d':
- GError(_("Reprojection is not implemented for 3D rasters"), parent=self)
- return
- if map_exists(new_name, element=self.copy_layer[i].data['type'], env=env,
- mapset=self.selected_mapset[0].data['name']):
- new_name = self._getNewMapName(_('New name'), _('Select new name'),
- self.copy_layer[i].data['name'], env=env,
- mapset=self.selected_mapset[0].data['name'],
- element=self.copy_layer[i].data['type'])
- if not new_name:
- continue
- callback = lambda gisrc2=gisrc2, gisrc=gisrc, cLayer=self.copy_layer[i], \
- cMapset=self.copy_mapset[i], cMode=self.copy_mode, \
- sMapset=self.selected_mapset[0], name=new_name: \
- self._onDoneReprojection(env2, gisrc2, gisrc, cLayer, cMapset, cMode, sMapset, name)
- dlg = CatalogReprojectionDialog(self, self._giface,
- self.copy_grassdb[i].data['name'],
- self.copy_location[i].data['name'],
- self.copy_mapset[i].data['name'],
- self.copy_layer[i].data['name'],
- env2,
- self.selected_grassdb[0].data['name'],
- self.selected_location[0].data['name'],
- self.selected_mapset[0].data['name'],
- new_name,
- self.copy_layer[i].data['type'],
- env, callback)
- if dlg.ShowModal() == wx.ID_CANCEL:
- return
- self.ExpandNode(self.selected_mapset[0], recursive=True)
- self._resetCopyVariables()
- def _onDoneReprojection(self, iEnv, iGisrc, oGisrc, cLayer, cMapset, cMode, sMapset, name):
- self._giface.grassdbChanged.emit(grassdb=sMapset.parent.parent.data['name'],
- location=sMapset.parent.data['name'],
- mapset=sMapset.data['name'],
- element=cLayer.data['type'],
- map=name,
- action='new')
- if not cMode:
- self._removeMapAfterCopy(cLayer, cMapset, iEnv)
- gscript.try_remove(iGisrc)
- gscript.try_remove(oGisrc)
- self.ExpandNode(sMapset, recursive=True)
- def _removeMapAfterCopy(self, cLayer, cMapset, env):
- removed, cmd = self._runCommand('g.remove', type=cLayer.data['type'],
- name=cLayer.data['name'], flags='f', env=env)
- if removed == 0:
- Debug.msg(1, "LAYER " + cLayer.data['name'] + " DELETED")
- self.showNotification.emit(message=_("g.remove completed"))
- self._giface.grassdbChanged.emit(grassdb=cMapset.parent.parent.data['name'],
- location=cMapset.parent.data['name'],
- mapset=cMapset.data['name'],
- map=cLayer.data['name'],
- element=cLayer.data['type'],
- action='delete')
- def InsertLayer(self, name, mapset_node, element_name):
- """Insert layer into model and refresh tree"""
- self._model.AppendNode(parent=mapset_node,
- data=dict(type=element_name, name=name))
- self._model.SortChildren(mapset_node)
- self.RefreshNode(mapset_node, recursive=True)
- def InsertMapset(self, name, location_node):
- """Insert new mapset into model and refresh tree.
- Assumes mapset is empty."""
- mapset_path = os.path.join(location_node.parent.data['name'],
- location_node.data['name'],
- name)
- mapset_node = self._model.AppendNode(parent=location_node,
- data=dict(type='mapset',
- name=name,
- current=False,
- lock=is_mapset_locked(mapset_path),
- is_different_owner=is_different_mapset_owner(mapset_path),
- owner=get_mapset_owner(mapset_path)))
- self._model.SortChildren(location_node)
- self.RefreshNode(location_node, recursive=True)
- return mapset_node
- def InsertLocation(self, name, grassdb_node):
- """Insert new location into model and refresh tree"""
- location_node = self._model.AppendNode(parent=grassdb_node,
- data=dict(type='location', name=name))
- # reload new location since it has a mapset
- self._reloadLocationNode(location_node)
- self._model.SortChildren(grassdb_node)
- self.RefreshNode(grassdb_node, recursive=True)
- return location_node
- def InsertGrassDb(self, name):
- """
- Insert new grass db into model, update user setting and refresh tree.
- Check if not already added.
- """
- grassdb_node = self._model.SearchNodes(name=name,
- type='grassdb')
- if not grassdb_node:
- grassdb_node = self._model.AppendNode(parent=self._model.root,
- data=dict(type="grassdb", name=name))
- self._reloadGrassDBNode(grassdb_node)
- self.RefreshItems()
- # Update user's settings
- self.grassdatabases.append(name)
- self._saveGrassDBs()
- return grassdb_node
- def OnDeleteMap(self, event):
- """Delete layer or mapset"""
- names = [self.selected_layer[i].data['name'] + '@' + self.selected_mapset[i].data['name']
- for i in range(len(self.selected_layer))]
- if len(names) < 10:
- question = _("Do you really want to delete map(s) <{m}>?").format(m=', '.join(names))
- else:
- question = _("Do you really want to delete {n} maps?").format(n=len(names))
- if self._confirmDialog(question, title=_('Delete map')) == wx.ID_YES:
- label = _("Deleting {name}...").format(name=names)
- self.showNotification.emit(message=label)
- for i in range(len(self.selected_layer)):
- gisrc, env = gscript.create_environment(
- self.selected_grassdb[i].data['name'],
- self.selected_location[i].data['name'],
- self.selected_mapset[i].data['name'])
- removed, cmd = self._runCommand(
- 'g.remove', flags='f', type=self.selected_layer[i].data['type'],
- name=self.selected_layer[i].data['name'], env=env)
- gscript.try_remove(gisrc)
- if removed == 0:
- self._giface.grassdbChanged.emit(grassdb=self.selected_grassdb[i].data['name'],
- location=self.selected_location[i].data['name'],
- mapset=self.selected_mapset[i].data['name'],
- element=self.selected_layer[i].data['type'],
- map=self.selected_layer[i].data['name'],
- action='delete')
- Debug.msg(1, "LAYER " + self.selected_layer[i].data['name'] + " DELETED")
- self.UnselectAll()
- self.showNotification.emit(message=_("g.remove completed"))
- def OnDeleteMapset(self, event):
- """
- Delete selected mapset or mapsets
- """
- mapsets = []
- changes = []
- for i in range(len(self.selected_mapset)):
- # Append to the list of tuples
- mapsets.append((
- self.selected_grassdb[i].data['name'],
- self.selected_location[i].data['name'],
- self.selected_mapset[i].data['name']
- ))
- changes.append(dict(grassdb=self.selected_grassdb[i].data['name'],
- location=self.selected_location[i].data['name'],
- mapset=self.selected_mapset[i].data['name'],
- action='delete',
- element='mapset'))
- if delete_mapsets_interactively(self, mapsets):
- for change in changes:
- self._giface.grassdbChanged.emit(**change)
- def OnDeleteLocation(self, event):
- """
- Delete selected location or locations
- """
- locations = []
- changes = []
- for i in range(len(self.selected_location)):
- # Append to the list of tuples
- locations.append((
- self.selected_grassdb[i].data['name'],
- self.selected_location[i].data['name']
- ))
- changes.append(dict(grassdb=self.selected_grassdb[i].data['name'],
- location=self.selected_location[i].data['name'],
- action='delete',
- element='location'))
- if delete_locations_interactively(self, locations):
- for change in changes:
- self._giface.grassdbChanged.emit(**change)
- def DownloadLocation(self, grassdb_node):
- """
- Download new location interactively.
- """
- grassdatabase, location, mapset = (
- download_location_interactively(self, grassdb_node.data['name'])
- )
- if location:
- self._reloadGrassDBNode(grassdb_node)
- self.UpdateCurrentDbLocationMapsetNode()
- self.RefreshItems()
- def OnDownloadLocation(self, event):
- """
- Download location online
- """
- self.DownloadLocation(self.selected_grassdb[0])
- def DeleteGrassDb(self, grassdb_node):
- """
- Delete grassdb from disk.
- """
- grassdb = grassdb_node.data['name']
- if (delete_grassdb_interactively(self, grassdb)):
- self.RemoveGrassDB(grassdb_node)
- def OnDeleteGrassDb(self, event):
- """
- Delete grassdb from disk.
- """
- self.DeleteGrassDb(self.selected_grassdb[0])
- def OnRemoveGrassDb(self, event):
- """
- Remove grassdb node from data catalogue.
- """
- self.RemoveGrassDB(self.selected_grassdb[0])
- def RemoveGrassDB(self, grassdb_node):
- """
- Remove grassdb node from tree
- and updates settings. Doesn't check if it's current db.
- """
- self.grassdatabases.remove(grassdb_node.data['name'])
- self._model.RemoveNode(grassdb_node)
- self.RefreshItems()
- # Update user's settings
- self._saveGrassDBs()
- def OnDisplayLayer(self, event):
- """
- Display layer in current graphics view
- """
- self.DisplayLayer()
- def DisplayLayer(self):
- """Display selected layer in current graphics view"""
- all_names = []
- names = {'raster': [], 'vector': [], 'raster_3d': []}
- for i in range(len(self.selected_layer)):
- name = self.selected_layer[i].data['name'] + '@' + self.selected_mapset[i].data['name']
- names[self.selected_layer[i].data['type']].append(name)
- all_names.append(name)
- #if self.selected_location[0].data['name'] == gisenv()['LOCATION_NAME'] and self.selected_mapset[0]:
- for ltype in names:
- if names[ltype]:
- self._giface.lmgr.AddMaps(list(reversed(names[ltype])), ltype, True)
- if len(self._giface.GetLayerList()) == 1:
- # zoom to map if there is only one map layer
- self._giface.GetMapWindow().ZoomToMap()
- Debug.msg(1, "Displayed layer(s): " + str(all_names))
- def OnBeginDrag(self, node, event):
- """Just copy necessary data"""
- self.DefineItems(self.GetSelected())
- if self.selected_location and None in self.selected_mapset and \
- None in self.selected_layer:
- GMessage(_("Move or copy location isn't allowed"))
- event.Veto()
- return
- elif self.selected_location and self.selected_mapset and \
- None in self.selected_layer:
- GMessage(_("Move or copy mapset isn't allowed"))
- event.Veto()
- return
- if self.selected_layer and not (self._restricted and gisenv()[
- 'LOCATION_NAME'] != self.selected_location[0].data['name']):
- event.Allow()
- self.OnCopyMap(event)
- Debug.msg(1, "DRAG")
- else:
- event.Veto()
- def OnEndDrag(self, node, event):
- """Copy layer into target"""
- self.copy_mode = wx.GetMouseState().ControlDown()
- if node:
- self.DefineItems([node])
- if None not in self.selected_mapset:
- if self._restricted and gisenv()['MAPSET'] != self.selected_mapset[0].data['name']:
- GMessage(_("To move or copy maps to other mapsets, unlock editing of other mapsets"),
- parent=self)
- event.Veto()
- return
- event.Allow()
- Debug.msg(1, "DROP DONE")
- self.OnPasteMap(event)
- else:
- GMessage(_("To move or copy maps to other location, "
- "please drag them to a mapset in the "
- "destination location"),
- parent=self)
- event.Veto()
- return
- def OnSwitchMapset(self, event):
- """Switch to location and mapset"""
- genv = gisenv()
- grassdb = self.selected_grassdb[0].data['name']
- location = self.selected_location[0].data['name']
- mapset = self.selected_mapset[0].data['name']
- if can_switch_mapset_interactive(self, grassdb, location, mapset):
- # Switch to mapset in the same location
- if (grassdb == genv['GISDBASE'] and location == genv['LOCATION_NAME']):
- switch_mapset_interactively(self, self._giface, None, None, mapset)
- # Switch to mapset in the same grassdb
- elif grassdb == genv['GISDBASE']:
- switch_mapset_interactively(self, self._giface, None, location, mapset)
- # Switch to mapset in a different grassdb
- else:
- switch_mapset_interactively(self, self._giface, grassdb, location, mapset)
- def _updateAfterGrassdbChanged(self, action, element, grassdb, location, mapset=None,
- map=None, newname=None):
- """Update tree after grassdata changed"""
- if element == 'mapset':
- if action == 'new':
- node = self.GetDbNode(grassdb=grassdb,
- location=location)
- if node:
- self.InsertMapset(name=mapset, location_node=node)
- elif action == 'delete':
- node = self.GetDbNode(grassdb=grassdb,
- location=location)
- if node:
- self._reloadLocationNode(node)
- self.UpdateCurrentDbLocationMapsetNode()
- self.RefreshNode(node, recursive=True)
- elif action == 'rename':
- node = self.GetDbNode(grassdb=grassdb,
- location=location,
- mapset=mapset)
- if node:
- self._renameNode(node, newname)
- elif element == 'location':
- if action == 'new':
- node = self.GetDbNode(grassdb=grassdb)
- if not node:
- node = self.InsertGrassDb(name=grassdb)
- if node:
- self.InsertLocation(location, node)
- elif action == 'delete':
- node = self.GetDbNode(grassdb=grassdb)
- if node:
- self._reloadGrassDBNode(node)
- self.RefreshNode(node, recursive=True)
- elif action == 'rename':
- node = self.GetDbNode(grassdb=grassdb,
- location=location)
- if node:
- self._renameNode(node, newname)
- elif element in ('raster', 'vector', 'raster_3d'):
- # when watchdog is used, it watches current mapset,
- # so we don't process any signals here,
- # instead the watchdog handler takes care of refreshing tree
- if (watchdog_used and grassdb == self.current_grassdb_node.data['name']
- and location == self.current_location_node.data['name']
- and mapset == self.current_mapset_node.data['name']):
- return
- if action == 'new':
- node = self.GetDbNode(grassdb=grassdb,
- location=location,
- mapset=mapset)
- if node:
- if map:
- # check if map already exists
- if not self._model.SearchNodes(parent=node, name=newname, type=element):
- self.InsertLayer(name=newname, mapset_node=node,
- element_name=element)
- else:
- # we know some maps created
- self._reloadMapsetNode(node)
- self.RefreshNode(node)
- elif action == 'delete':
- node = self.GetDbNode(grassdb=grassdb,
- location=location,
- mapset=mapset,
- map=map,
- map_type=element)
- if node:
- self._model.RemoveNode(node)
- self.RefreshNode(node.parent, recursive=True)
- elif action == 'rename':
- node = self.GetDbNode(grassdb=grassdb,
- location=location,
- mapset=mapset,
- map=map,
- map_type=element)
- if node:
- self._renameNode(node, newname)
- def _updateAfterMapsetChanged(self):
- """Update tree after current mapset has changed"""
- self.UpdateCurrentDbLocationMapsetNode()
- self.ExpandCurrentMapset()
- self.RefreshItems()
- self.ScheduleWatchCurrentMapset()
- def OnMetadata(self, event):
- """Show metadata of any raster/vector/3draster"""
- def done(event):
- gscript.try_remove(event.userData)
- for i in range(len(self.selected_layer)):
- if self.selected_layer[i].data['type'] == 'raster':
- cmd = ['r.info']
- elif self.selected_layer[i].data['type'] == 'vector':
- cmd = ['v.info']
- elif self.selected_layer[i].data['type'] == 'raster_3d':
- cmd = ['r3.info']
- cmd.append('map=%s@%s' % (self.selected_layer[i].data['name'], self.selected_mapset[i].data['name']))
- gisrc, env = gscript.create_environment(
- self.selected_grassdb[i].data['name'],
- self.selected_location[i].data['name'],
- self.selected_mapset[i].data['name'])
- # print output to command log area
- # temp gisrc file must be deleted onDone
- self._giface.RunCmd(cmd, env=env, onDone=done, userData=gisrc)
- def OnCopyName(self, event):
- """Copy layer name to clipboard"""
- if wx.TheClipboard.Open():
- do = wx.TextDataObject()
- text = []
- for i in range(len(self.selected_layer)):
- text.append('%s@%s' % (self.selected_layer[i].data['name'], self.selected_mapset[i].data['name']))
- do.SetText(','.join(text))
- wx.TheClipboard.SetData(do)
- wx.TheClipboard.Close()
- def Filter(self, text):
- """Filter tree based on name and type."""
- text = text.strip()
- if len(text.split(':')) > 1:
- name = text.split(':')[1].strip()
- elem = text.split(':')[0].strip()
- if 'r' == elem:
- element = 'raster'
- elif 'r3' == elem:
- element = 'raster_3d'
- elif 'v' == elem:
- element = 'vector'
- else:
- element = None
- else:
- element = None
- name = text.strip()
- self._model = filterModel(self._orig_model, name=name, element=element)
- self.UpdateCurrentDbLocationMapsetNode()
- self.RefreshItems()
- self.ExpandCurrentMapset()
- def _getNewMapName(self, message, title, value, element, mapset, env):
- """Dialog for simple text entry"""
- dlg = NameEntryDialog(parent=self, message=message, caption=title,
- element=element, env=env, mapset=mapset)
- dlg.SetValue(value)
- if dlg.ShowModal() == wx.ID_OK:
- name = dlg.GetValue()
- else:
- name = None
- dlg.Destroy()
- return name
- def _confirmDialog(self, question, title):
- """Confirm dialog"""
- dlg = wx.MessageDialog(self, question, title, wx.YES_NO)
- res = dlg.ShowModal()
- dlg.Destroy()
- return res
- def _isCurrent(self, genv):
- if self._restricted:
- currentMapset = currentLocation = currentGrassDb = True
- for i in range(len(self.selected_grassdb)):
- if self.selected_grassdb[i].data['name'] != genv['GISDBASE']:
- currentGrassDb = False
- currentLocation = False
- currentMapset = False
- break
- if currentLocation and self.selected_location[0]:
- for i in range(len(self.selected_location)):
- if self.selected_location[i].data['name'] != genv['LOCATION_NAME']:
- currentLocation = False
- currentMapset = False
- break
- if currentMapset and self.selected_mapset[0]:
- for i in range(len(self.selected_mapset)):
- if self.selected_mapset[i].data['name'] != genv['MAPSET']:
- currentMapset = False
- break
- return currentGrassDb, currentLocation, currentMapset
- else:
- return True, True, True
- def _popupMenuLayer(self):
- """Create popup menu for layers"""
- menu = Menu()
- genv = gisenv()
- currentGrassDb, currentLocation, currentMapset = self._isCurrent(genv)
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Cut"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnMoveMap, item)
- if not currentMapset:
- item.Enable(False)
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Copy"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnCopyMap, item)
- item = wx.MenuItem(menu, wx.ID_ANY, _("Copy &name"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnCopyName, item)
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Paste"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnPasteMap, item)
- if not(currentMapset and self.copy_layer):
- item.Enable(False)
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Delete"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnDeleteMap, item)
- item.Enable(currentMapset)
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Rename"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnRenameMap, item)
- item.Enable(currentMapset and len(self.selected_layer) == 1)
- menu.AppendSeparator()
- if not isinstance(self._giface, StandaloneGrassInterface):
- if all([each.data['name'] == genv['LOCATION_NAME'] for each in self.selected_location]):
- if len(self.selected_layer) > 1:
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Display layers"))
- else:
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Display layer"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnDisplayLayer, item)
- item = wx.MenuItem(menu, wx.ID_ANY, _("Show &metadata"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnMetadata, item)
- self.PopupMenu(menu)
- menu.Destroy()
- def _popupMenuMapset(self):
- """Create popup menu for mapsets"""
- menu = Menu()
- genv = gisenv()
- currentGrassDb, currentLocation, currentMapset = self._isCurrent(genv)
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Paste"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnPasteMap, item)
- if not(currentMapset and self.copy_layer):
- item.Enable(False)
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Switch mapset"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnSwitchMapset, item)
- if (
- self.selected_grassdb[0].data['name'] == genv['GISDBASE']
- and self.selected_location[0].data['name'] == genv['LOCATION_NAME']
- and self.selected_mapset[0].data['name'] == genv['MAPSET']
- ):
- item.Enable(False)
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Delete mapset"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnDeleteMapset, item)
- if self._restricted:
- item.Enable(False)
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Rename mapset"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnRenameMapset, item)
- if self._restricted:
- item.Enable(False)
- self.PopupMenu(menu)
- menu.Destroy()
- def _popupMenuLocation(self):
- """Create popup menu for locations"""
- menu = Menu()
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Create mapset"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnCreateMapset, item)
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Delete location"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnDeleteLocation, item)
- if self._restricted:
- item.Enable(False)
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Rename location"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnRenameLocation, item)
- if self._restricted:
- item.Enable(False)
- self.PopupMenu(menu)
- menu.Destroy()
- def _popupMenuGrassDb(self):
- """Create popup menu for grass db"""
- menu = Menu()
- genv = gisenv()
- currentGrassDb, currentLocation, currentMapset = self._isCurrent(genv)
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Create new location"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnCreateLocation, item)
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Download sample location"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnDownloadLocation, item)
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Remove GRASS database from data catalog"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnRemoveGrassDb, item)
- if self.selected_grassdb[0].data['name'] == genv['GISDBASE']:
- item.Enable(False)
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Delete GRASS database from disk"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnDeleteGrassDb, item)
- if self._restricted:
- item.Enable(False)
- self.PopupMenu(menu)
- menu.Destroy()
- def _popupMenuElement(self):
- """Create popup menu for elements"""
- menu = Menu()
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Paste"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnPasteMap, item)
- genv = gisenv()
- currentGrassDb, currentLocation, currentMapset = self._isCurrent(genv)
- if not(currentMapset and self.copy_layer):
- item.Enable(False)
- self.PopupMenu(menu)
- menu.Destroy()
- def _popupMenuMultipleLocations(self):
- """Create popup menu for multiple selected locations"""
- menu = Menu()
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Delete locations"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnDeleteLocation, item)
- if self._restricted:
- item.Enable(False)
- self.PopupMenu(menu)
- menu.Destroy()
- def _popupMenuMultipleMapsets(self):
- """Create popup menu for multiple selected mapsets"""
- menu = Menu()
- item = wx.MenuItem(menu, wx.ID_ANY, _("&Delete mapsets"))
- menu.AppendItem(item)
- self.Bind(wx.EVT_MENU, self.OnDeleteMapset, item)
- if self._restricted:
- item.Enable(False)
- self.PopupMenu(menu)
- menu.Destroy()
- def _popupMenuEmpty(self):
- """Create empty popup when multiple different types of items are selected"""
- menu = Menu()
- item = wx.MenuItem(menu, wx.ID_ANY, _("No available options"))
- menu.AppendItem(item)
- item.Enable(False)
- self.PopupMenu(menu)
- menu.Destroy()
|