summaryrefslogtreecommitdiff
path: root/python/ovs/db/parser.py
blob: 07ce8e2b0f550827265667877a43282558e71137 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
# Copyright (c) 2010 Nicira Networks
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at:
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

import re

from ovs.db import error

class Parser(object):
    def __init__(self, json, name):
        self.name = name
        self.json = json
        if type(json) != dict:
            self.__raise_error("Object expected.")
        self.used = set()

    def __get(self, name, types, optional, default=None):
        if name in self.json:
            self.used.add(name)
            member = float_to_int(self.json[name])
            if is_identifier(member) and "id" in types:
                return member
            if len(types) and type(member) not in types:
                self.__raise_error("Type mismatch for member '%s'." % name)
            return member
        else:
            if not optional:        
                self.__raise_error("Required '%s' member is missing." % name)
            return default

    def get(self, name, types):
        return self.__get(name, types, False)

    def get_optional(self, name, types, default=None):
        return self.__get(name, types, True, default)

    def __raise_error(self, message):
        raise error.Error("Parsing %s failed: %s" % (self.name, message),
                          self.json)

    def finish(self):
        missing = set(self.json) - set(self.used)
        if missing:
            name = missing.pop()
            if len(missing) > 1:
                self.__raise_error("Member '%s' and %d other members "
                                   "are present but not allowed here"
                                   % (name, len(missing)))
            elif missing:
                self.__raise_error("Member '%s' and 1 other member "
                                   "are present but not allowed here" % name)
            else:
                self.__raise_error("Member '%s' is present but not "
                                   "allowed here" % name)
    
def float_to_int(x):
    # XXX still needed?
    if type(x) == float:
        integer = int(x)
        if integer == x and integer >= -2**53 and integer < 2**53:
            return integer
    return x

id_re = re.compile("[_a-zA-Z][_a-zA-Z0-9]*$")
def is_identifier(s):
    return type(s) in [str, unicode] and id_re.match(s)

def json_type_to_string(type):
    if type == None:
        return "null"
    elif type == bool:
        return "boolean"
    elif type == dict:
        return "object"
    elif type == list:
        return "array"
    elif type in [int, long, float]:
        return "number"
    elif type in [str, unicode]:
        return "string"
    else:
        return "<invalid>"

def unwrap_json(json, name, need_type):
    if (type(json) != list or len(json) != 2 or json[0] != name or
        type(json[1]) != need_type):
        raise error.Error("expected [\"%s\", <%s>]"
                          % (name, json_type_to_string(need_type)), json)
    return json[1]

def parse_json_pair(json):
    if type(json) != list or len(json) != 2:
        raise error.Error("expected 2-element array", json)
    return json