pycasbin / sqlobject-adapter / 1

pending completion

Build # 1

Build Type

Pull #1

travis-ci

Committed by

web-flow

Commit Message

<a href="https://github.com/pycasbin/sqlobject-adapter/commit/<a class=hub.com/pycasbin/sqlobject-adapter/commit/<a class="double-link" href="https://git"><a class=hub.com/pycasbin/sqlobject-adapter/commit/<a class="double-link" href="https://git"><a class=hub.com/pycasbin/sqlobject-adapter/commit/<a class="double-link" href="https://git"><a class=hub.com/pycasbin/sqlobject-adapter/commit/d4cac9e6adbb5b17e9efc4dce62eb0a2df3ce6a7">d4cac9e6a">&lt;a href=&quot;https://github.com/pycasbin/sqlobject-adapter/commit/</a><a class="double-link" href="https://github.com/pycasbin/sqlobject-adapter/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/pycasbin/sqlobject-adapter/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/pycasbin/sqlobject-adapter/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/pycasbin/sqlobject-adapter/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/pycasbin/sqlobject-adapter/commit/d4cac9e6adbb5b17e9efc4dce62eb0a2df3ce6a7">d4cac9e6a</a><a href="https://github.com/pycasbin/sqlobject-adapter/commit/d4cac9e6adbb5b17e9efc4dce62eb0a2df3ce6a7">&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/pycasbin/sqlobject-adapter/commit/&lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/pycasbin/sqlobject-adapter/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/pycasbin/sqlobject-adapter/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/pycasbin/sqlobject-adapter/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/pycasbin/sqlobject-adapter/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/pycasbin/sqlobject-adapter/commit/d4cac9e6adbb5b17e9efc4dce62eb0a2df3ce6a7&quot;&gt;d4cac9e6a&lt;/a&gt;&lt;a href=&quot;https://github.com/pycasbin/sqlobject-adapter/commit/d4cac9e6adbb5b17e9efc4dce62eb0a2df3ce6a7&quot;&gt;&amp;quot;&amp;gt;&amp;amp;lt;a href=&amp;amp;quot;https://github.com/pycasbin/sqlobject-adapter/co... (continued)

Pull Request Pull Request #1: first commit

Run Details

49 of 49 new or added lines in 2 files covered. (100.0%)

46 of 49 relevant lines covered (93.88%)

4.69 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

93.75

/casbin_sqlobject_adapter/adapter.py

from casbin import persist
from sqlobject import SQLObject, StringCol, sqlhub, connectionForURI


class CasbinRule(SQLObject):
    class sqlmeta:

        table = "casbin_rule"

    ptype = StringCol(length=255)
    v0 = StringCol(length=255, default=None)
    v1 = StringCol(length=255, default=None)
    v2 = StringCol(length=255, default=None)
    v3 = StringCol(length=255, default=None)
    v4 = StringCol(length=255, default=None)
    v5 = StringCol(length=255, default=None)

    def __str__(self):
        arr = [self.ptype]
        for v in (self.v0, self.v1, self.v2, self.v3, self.v4, self.v5):
            if v is None:
                break
            arr.append(v)
        return ", ".join(arr)

    def __repr__(self):
        return '<CasbinRule {}: "{}">'.format(self.id, str(self))


class Adapter(persist.Adapter):
    """the interface for Casbin adapters."""

    def __init__(self, connection_string):
        self._conhandler = connectionForURI(connection_string)
        sqlhub.processConnection = self._conhandler

    def load_policy(self, model):
        """loads all policy rules from the storage."""
        count = CasbinRule.select().count()
        for i in range(1, 1 + count):
            line = CasbinRule.get(i)
            persist.load_policy_line(str(line), model)

    def _save_policy_line(self, ptype, rule):
        line = CasbinRule.selectBy(ptype=ptype)
        for i, v in enumerate(rule):
            setattr(line, "v{}".format(i), v)

    def save_policy(self, model):
        """saves all policy rules to the storage."""
        for sec in ["p", "g"]:
            if sec not in model.model.keys():
                continue
            for ptype, ast in model.model[sec].items():
                for rule in ast.policy:
                    self._save_policy_line(ptype, rule)

        return True

    def add_policy(self, sec, ptype, rule):
        """adds a policy rule to the storage."""
        self._save_policy_line(ptype, rule)

    def remove_policy(self, sec, ptype, rule):
        """removes a policy rule from the storage."""
        pass

    def remove_filtered_policy(self, sec, ptype, field_index, *field_values):
        """removes policy rules that match the filter from the storage.
        This is part of the Auto-Save feature.
        """
        pass

1	from casbin import persist	5✔
2	from sqlobject import SQLObject, StringCol, sqlhub, connectionForURI	5✔
3
4
5	class CasbinRule(SQLObject):	5✔
6	class sqlmeta:	5✔
7
8	table = "casbin_rule"	5✔
9
10	ptype = StringCol(length=255)	5✔
11	v0 = StringCol(length=255, default=None)	5✔
12	v1 = StringCol(length=255, default=None)	5✔
13	v2 = StringCol(length=255, default=None)	5✔
14	v3 = StringCol(length=255, default=None)	5✔
15	v4 = StringCol(length=255, default=None)	5✔
16	v5 = StringCol(length=255, default=None)	5✔
17
18	def __str__(self):	5✔
19	arr = [self.ptype]	5✔
20	for v in (self.v0, self.v1, self.v2, self.v3, self.v4, self.v5):	5✔
21	if v is None:	5✔
22	break	5✔
23	arr.append(v)	5✔
24	return ", ".join(arr)	5✔
25
26	def __repr__(self):	5✔
27	return '<CasbinRule {}: "{}">'.format(self.id, str(self))	5✔
28
29
30	class Adapter(persist.Adapter):	5✔
31	"""the interface for Casbin adapters."""
32
33	def __init__(self, connection_string):	5✔
34	self._conhandler = connectionForURI(connection_string)	5✔
35	sqlhub.processConnection = self._conhandler	5✔
36
37	def load_policy(self, model):	5✔
38	"""loads all policy rules from the storage."""
39	count = CasbinRule.select().count()	5✔
40	for i in range(1, 1 + count):	5✔
41	line = CasbinRule.get(i)	5✔
42	persist.load_policy_line(str(line), model)	5✔
43
44	def _save_policy_line(self, ptype, rule):	5✔
45	line = CasbinRule.selectBy(ptype=ptype)	5✔
46	for i, v in enumerate(rule):	5✔
47	setattr(line, "v{}".format(i), v)	5✔
48
49	def save_policy(self, model):	5✔
50	"""saves all policy rules to the storage."""
51	for sec in ["p", "g"]:	5✔
52	if sec not in model.model.keys():	5✔
53	continue	×
54	for ptype, ast in model.model[sec].items():	5✔
55	for rule in ast.policy:	5✔
56	self._save_policy_line(ptype, rule)	5✔
57
58	return True	5✔
59
60	def add_policy(self, sec, ptype, rule):	5✔
61	"""adds a policy rule to the storage."""
62	self._save_policy_line(ptype, rule)	5✔
63
64	def remove_policy(self, sec, ptype, rule):	5✔
65	"""removes a policy rule from the storage."""
66	pass	×
67
68	def remove_filtered_policy(self, sec, ptype, field_index, *field_values):	5✔
69	"""removes policy rules that match the filter from the storage.
70	This is part of the Auto-Save feature.
71	"""
72	pass	×

pycasbin / sqlobject-adapter / 1

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous