132 lines
4.4 KiB
Python
132 lines
4.4 KiB
Python
from .utils import *
|
|
|
|
|
|
class Model(object):
|
|
|
|
accessible_fields = ['id']
|
|
updatable_fields = ['id']
|
|
initializable_fields = ['id']
|
|
base_url = None
|
|
default_retrieve_params = {}
|
|
|
|
DEFAULT_ACTIONS_WITH_ID = ['get', 'put', 'delete']
|
|
DEFAULT_ACTIONS_WITHOUT_ID = ['get_all', 'post']
|
|
DEFAULT_ACTIONS = DEFAULT_ACTIONS_WITH_ID + DEFAULT_ACTIONS_WITHOUT_ID
|
|
|
|
def __init__(self, *args, **kwargs):
|
|
self.attributes = extract(kwargs, self.accessible_fields)
|
|
self.retrieved = False
|
|
|
|
def __getattr__(self, name):
|
|
if name == 'id':
|
|
return self.attributes.get('id', None)
|
|
try:
|
|
return self.attributes[name]
|
|
except KeyError:
|
|
if self.retrieved or self.id is None:
|
|
raise AttributeError("Field {0} does not exist".format(name))
|
|
self.retrieve()
|
|
return self.__getattr__(name)
|
|
|
|
def __setattr__(self, name, value):
|
|
if name == 'attributes' or name not in self.accessible_fields:
|
|
super(Model, self).__setattr__(name, value)
|
|
else:
|
|
self.attributes[name] = value
|
|
|
|
def __getitem__(self, key):
|
|
if key not in self.accessible_fields:
|
|
raise KeyError("Field {0} does not exist".format(key))
|
|
return self.attributes.get(key)
|
|
|
|
def __setitem__(self, key, value):
|
|
if key not in self.accessible_fields:
|
|
raise KeyError("Field {0} does not exist".format(key))
|
|
self.attributes.__setitem__(key, value)
|
|
|
|
def items(self, *args, **kwargs):
|
|
return self.attributes.items(*args, **kwargs)
|
|
|
|
def get(self, *args, **kwargs):
|
|
return self.attributes.get(*args, **kwargs)
|
|
|
|
def to_dict(self):
|
|
self.retrieve()
|
|
return self.attributes
|
|
|
|
def retrieve(self, *args, **kwargs):
|
|
if not self.retrieved:
|
|
self._retrieve(*args, **kwargs)
|
|
self.retrieved = True
|
|
return self
|
|
|
|
def _retrieve(self, *args, **kwargs):
|
|
url = self.url(action='get', params=self.attributes)
|
|
response = perform_request('get', url, self.default_retrieve_params)
|
|
self.update_attributes(**response)
|
|
|
|
@classmethod
|
|
def find(cls, id):
|
|
return cls(id=id)
|
|
|
|
def update_attributes(self, *args, **kwargs):
|
|
for k, v in kwargs.items():
|
|
if k in self.accessible_fields:
|
|
self.__setattr__(k, v)
|
|
else:
|
|
raise AttributeError("Field {0} does not exist".format(k))
|
|
|
|
def updatable_attributes(self):
|
|
return extract(self.attributes, self.updatable_fields)
|
|
|
|
def initializable_attributes(self):
|
|
return extract(self.attributes, self.initializable_fields)
|
|
|
|
@classmethod
|
|
def before_save(cls, instance):
|
|
pass
|
|
|
|
@classmethod
|
|
def after_save(cls, instance):
|
|
pass
|
|
|
|
def save(self):
|
|
self.__class__.before_save(self)
|
|
if self.id: # if we have id already, treat this as an update
|
|
url = self.url(action='put', params=self.attributes)
|
|
response = perform_request('put', url, self.updatable_attributes())
|
|
else: # otherwise, treat this as an insert
|
|
url = self.url(action='post', params=self.attributes)
|
|
response = perform_request('post', url, self.initializable_attributes())
|
|
self.retrieved = True
|
|
self.update_attributes(**response)
|
|
self.__class__.after_save(self)
|
|
|
|
def delete(self):
|
|
url = self.url(action='delete', params=self.attributes)
|
|
response = perform_request('delete', url)
|
|
self.retrieved = True
|
|
self.update_attributes(**response)
|
|
|
|
@classmethod
|
|
def url_with_id(cls, params={}):
|
|
return cls.base_url + '/' + str(params['id'])
|
|
|
|
@classmethod
|
|
def url_without_id(cls, params={}):
|
|
return cls.base_url
|
|
|
|
@classmethod
|
|
def url(cls, action, params={}):
|
|
if cls.base_url is None:
|
|
raise CommentClientError("Must provide base_url when using default url function")
|
|
if action not in cls.DEFAULT_ACTIONS:
|
|
raise ValueError("Invalid action {0}. The supported action must be in {1}".format(action, str(cls.DEFAULT_ACTIONS)))
|
|
elif action in cls.DEFAULT_ACTIONS_WITH_ID:
|
|
try:
|
|
return cls.url_with_id(params)
|
|
except KeyError:
|
|
raise CommentClientError("Cannot perform action {0} without id".format(action))
|
|
else: # action must be in DEFAULT_ACTIONS_WITHOUT_ID now
|
|
return cls.url_without_id()
|