code.grnet.gr Git - ganeti-local/blob - lib/rapi/connector.py

   1 #
   2 #
   3
   4 # Copyright (C) 2006, 2007, 2008 Google Inc.
   5 #
   6 # This program is free software; you can redistribute it and/or modify
   7 # it under the terms of the GNU General Public License as published by
   8 # the Free Software Foundation; either version 2 of the License, or
   9 # (at your option) any later version.
  10 #
  11 # This program is distributed in the hope that it will be useful, but
  12 # WITHOUT ANY WARRANTY; without even the implied warranty of
  13 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  14 # General Public License for more details.
  15 #
  16 # You should have received a copy of the GNU General Public License
  17 # along with this program; if not, write to the Free Software
  18 # Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
  19 # 02110-1301, USA.
  20
  21 """Remote API connection map.
  22
  23 """
  24
  25 # pylint: disable=C0103
  26
  27 # C0103: Invalid name, since the R_* names are not conforming
  28
  29 import cgi
  30 import re
  31
  32 from ganeti import constants
  33 from ganeti import http
  34 from ganeti import utils
  35
  36 from ganeti.rapi import rlib2
  37
  38
  39 _NAME_PATTERN = r"[\w\._-]+"
  40 _DISK_PATTERN = r"\d+"
  41
  42 # the connection map is created at the end of this file
  43 CONNECTOR = {}
  44
  45
  46 class Mapper:
  47   """Map resource to method.
  48
  49   """
  50   def __init__(self, connector=None):
  51     """Resource mapper constructor.
  52
  53     @param connector: a dictionary, mapping method name with URL path regexp
  54
  55     """
  56     if connector is None:
  57       connector = CONNECTOR
  58     self._connector = connector
  59
  60   def getController(self, uri):
  61     """Find method for a given URI.
  62
  63     @param uri: string with URI
  64
  65     @return: None if no method is found or a tuple containing
  66         the following fields:
  67             - method: name of method mapped to URI
  68             - items: a list of variable intems in the path
  69             - args: a dictionary with additional parameters from URL
  70
  71     """
  72     if "?" in uri:
  73       (path, query) = uri.split("?", 1)
  74       args = cgi.parse_qs(query)
  75     else:
  76       path = uri
  77       query = None
  78       args = {}
  79
  80     # Try to find handler for request path
  81     result = utils.FindMatch(self._connector, path)
  82
  83     if result is None:
  84       raise http.HttpNotFound()
  85
  86     (handler, groups) = result
  87
  88     return (handler, groups, args)
  89
  90
  91 def GetHandlers(node_name_pattern, instance_name_pattern,
  92                 group_name_pattern, network_name_pattern,
  93                 job_id_pattern, disk_pattern,
  94                 query_res_pattern):
  95   """Returns all supported resources and their handlers.
  96
  97   """
  98   # Important note: New resources should always be added under /2. During a
  99   # discussion in July 2010 it was decided that having per-resource versions
 100   # is more flexible and future-compatible than versioning the whole remote
 101   # API.
 102   return {
 103     "/": rlib2.R_root,
 104     "/2": rlib2.R_2,
 105
 106     "/version": rlib2.R_version,
 107
 108     "/2/nodes": rlib2.R_2_nodes,
 109     re.compile(r"^/2/nodes/(%s)$" % node_name_pattern):
 110       rlib2.R_2_nodes_name,
 111     re.compile(r"^/2/nodes/(%s)/powercycle$" % node_name_pattern):
 112       rlib2.R_2_nodes_name_powercycle,
 113     re.compile(r"^/2/nodes/(%s)/tags$" % node_name_pattern):
 114       rlib2.R_2_nodes_name_tags,
 115     re.compile(r"^/2/nodes/(%s)/role$" % node_name_pattern):
 116       rlib2.R_2_nodes_name_role,
 117     re.compile(r"^/2/nodes/(%s)/evacuate$" % node_name_pattern):
 118       rlib2.R_2_nodes_name_evacuate,
 119     re.compile(r"^/2/nodes/(%s)/migrate$" % node_name_pattern):
 120       rlib2.R_2_nodes_name_migrate,
 121     re.compile(r"^/2/nodes/(%s)/modify$" % node_name_pattern):
 122       rlib2.R_2_nodes_name_modify,
 123     re.compile(r"^/2/nodes/(%s)/storage$" % node_name_pattern):
 124       rlib2.R_2_nodes_name_storage,
 125     re.compile(r"^/2/nodes/(%s)/storage/modify$" % node_name_pattern):
 126       rlib2.R_2_nodes_name_storage_modify,
 127     re.compile(r"^/2/nodes/(%s)/storage/repair$" % node_name_pattern):
 128       rlib2.R_2_nodes_name_storage_repair,
 129
 130     "/2/instances": rlib2.R_2_instances,
 131     re.compile(r"^/2/instances/(%s)$" % instance_name_pattern):
 132       rlib2.R_2_instances_name,
 133     re.compile(r"^/2/instances/(%s)/info$" % instance_name_pattern):
 134       rlib2.R_2_instances_name_info,
 135     re.compile(r"^/2/instances/(%s)/tags$" % instance_name_pattern):
 136       rlib2.R_2_instances_name_tags,
 137     re.compile(r"^/2/instances/(%s)/reboot$" % instance_name_pattern):
 138       rlib2.R_2_instances_name_reboot,
 139     re.compile(r"^/2/instances/(%s)/reinstall$" % instance_name_pattern):
 140       rlib2.R_2_instances_name_reinstall,
 141     re.compile(r"^/2/instances/(%s)/replace-disks$" % instance_name_pattern):
 142       rlib2.R_2_instances_name_replace_disks,
 143     re.compile(r"^/2/instances/(%s)/shutdown$" % instance_name_pattern):
 144       rlib2.R_2_instances_name_shutdown,
 145     re.compile(r"^/2/instances/(%s)/startup$" % instance_name_pattern):
 146       rlib2.R_2_instances_name_startup,
 147     re.compile(r"^/2/instances/(%s)/activate-disks$" % instance_name_pattern):
 148       rlib2.R_2_instances_name_activate_disks,
 149     re.compile(r"^/2/instances/(%s)/deactivate-disks$" % instance_name_pattern):
 150       rlib2.R_2_instances_name_deactivate_disks,
 151     re.compile(r"^/2/instances/(%s)/recreate-disks$" % instance_name_pattern):
 152       rlib2.R_2_instances_name_recreate_disks,
 153     re.compile(r"^/2/instances/(%s)/prepare-export$" % instance_name_pattern):
 154       rlib2.R_2_instances_name_prepare_export,
 155     re.compile(r"^/2/instances/(%s)/export$" % instance_name_pattern):
 156       rlib2.R_2_instances_name_export,
 157     re.compile(r"^/2/instances/(%s)/migrate$" % instance_name_pattern):
 158       rlib2.R_2_instances_name_migrate,
 159     re.compile(r"^/2/instances/(%s)/failover$" % instance_name_pattern):
 160       rlib2.R_2_instances_name_failover,
 161     re.compile(r"^/2/instances/(%s)/rename$" % instance_name_pattern):
 162       rlib2.R_2_instances_name_rename,
 163     re.compile(r"^/2/instances/(%s)/modify$" % instance_name_pattern):
 164       rlib2.R_2_instances_name_modify,
 165     re.compile(r"^/2/instances/(%s)/disk/(%s)/grow$" %
 166                (instance_name_pattern, disk_pattern)):
 167       rlib2.R_2_instances_name_disk_grow,
 168     re.compile(r"^/2/instances/(%s)/console$" % instance_name_pattern):
 169       rlib2.R_2_instances_name_console,
 170
 171     "/2/networks": rlib2.R_2_networks,
 172     re.compile(r"^/2/networks/(%s)$" % network_name_pattern):
 173       rlib2.R_2_networks_name,
 174     re.compile(r"^/2/networks/(%s)/connect$" % network_name_pattern):
 175       rlib2.R_2_networks_name_connect,
 176     re.compile(r"^/2/networks/(%s)/disconnect$" % network_name_pattern):
 177       rlib2.R_2_networks_name_disconnect,
 178     re.compile(r"^/2/networks/(%s)/modify$" % network_name_pattern):
 179       rlib2.R_2_networks_name_modify,
 180     re.compile(r"^/2/networks/(%s)/tags$" % network_name_pattern):
 181       rlib2.R_2_networks_name_tags,
 182
 183     "/2/groups": rlib2.R_2_groups,
 184     re.compile(r"^/2/groups/(%s)$" % group_name_pattern):
 185       rlib2.R_2_groups_name,
 186     re.compile(r"^/2/groups/(%s)/modify$" % group_name_pattern):
 187       rlib2.R_2_groups_name_modify,
 188     re.compile(r"^/2/groups/(%s)/rename$" % group_name_pattern):
 189       rlib2.R_2_groups_name_rename,
 190     re.compile(r"^/2/groups/(%s)/assign-nodes$" % group_name_pattern):
 191       rlib2.R_2_groups_name_assign_nodes,
 192     re.compile(r"^/2/groups/(%s)/tags$" % group_name_pattern):
 193       rlib2.R_2_groups_name_tags,
 194
 195     "/2/jobs": rlib2.R_2_jobs,
 196     re.compile(r"^/2/jobs/(%s)$" % job_id_pattern):
 197       rlib2.R_2_jobs_id,
 198     re.compile(r"^/2/jobs/(%s)/wait$" % job_id_pattern):
 199       rlib2.R_2_jobs_id_wait,
 200
 201     "/2/instances-multi-alloc": rlib2.R_2_instances_multi_alloc,
 202     "/2/tags": rlib2.R_2_tags,
 203     "/2/info": rlib2.R_2_info,
 204     "/2/os": rlib2.R_2_os,
 205     "/2/redistribute-config": rlib2.R_2_redist_config,
 206     "/2/features": rlib2.R_2_features,
 207     "/2/modify": rlib2.R_2_cluster_modify,
 208     re.compile(r"^/2/query/(%s)$" % query_res_pattern): rlib2.R_2_query,
 209     re.compile(r"^/2/query/(%s)/fields$" % query_res_pattern):
 210       rlib2.R_2_query_fields,
 211     }
 212
 213
 214 CONNECTOR.update(GetHandlers(_NAME_PATTERN, _NAME_PATTERN,
 215                              _NAME_PATTERN, _NAME_PATTERN,
 216                              constants.JOB_ID_TEMPLATE, _DISK_PATTERN,
 217                              _NAME_PATTERN))