Pylons

from elixir.statements     import Statement
from sqlalchemy.orm.mapper import MapperExtension

import types

class MapperExtensionProxy(MapperExtension):

	def after_delete(self, mapper, connection, instance):
		if hasattr(instance, '__after_delete__') : instance.__after_delete__()

	def after_insert(self, mapper, connection, instance):
		if hasattr(instance, '__after_insert__') : instance.__after_insert__()

	def after_update(self, mapper, connection, instance):
		if hasattr(instance, '__after_update__') : instance.__after_update__()
	
	def before_delete(self, mapper, connection, instance):
		if hasattr(instance, '__before_delete__') : instance.__before_delete__()

	def before_insert(self, mapper, connection, instance):
		if hasattr(instance, '__before_insert__') : instance.__before_insert__()

	def before_update(self, mapper, connection, instance):
		if hasattr(instance, '__before_update__') : instance.__before_update__()

	
ext_proxy = MapperExtensionProxy()

def add_mapper_extension_proxy_method(entity, name, callbacks):
	def proxy_method(self):
		for callback in callbacks:
			getattr(self, callback)()
	setattr(entity, '__%s__' %name, proxy_method)
	extensions = entity._descriptor.mapper_options.get('extension', [])
	if type(extensions) is not types.ListType: 
		extensions = [extensions]
	if ext_proxy not in extensions:
		extensions.append(ext_proxy)
		entity._descriptor.mapper_options['extension'] = extensions

class BeforeDelete(object):
	def __init__(self, entity, *callbacks):
		add_mapper_extension_proxy_method(entity, 'before_delete', callbacks)

class BeforeInsert(object):
	def __init__(self, entity, *callbacks):
		add_mapper_extension_proxy_method(entity, 'before_insert', callbacks)

class BeforeUpdate(object):
	def __init__(self, entity, *callbacks):
		add_mapper_extension_proxy_method(entity, 'before_update', callbacks)

class BeforeDelete(object):
	def __init__(self, entity, *callbacks):
		add_mapper_extension_proxy_method(entity, 'before_delete', callbacks)
	
class BeforeInsert(object):
	def __init__(self, entity, *callbacks):
		add_mapper_extension_proxy_method(entity, 'before_insert', callbacks)

class BeforeUpdate(object):
	def __init__(self, entity, *callbacks):
		add_mapper_extension_proxy_method(entity, 'before_update', callbacks)

after_delete = Statement(AfterDelete)			
after_insert = Statement(AfterInsert)			
after_update = Statement(AfterUpdate)			
before_delete = Statement(BeforeDelete)			
before_insert = Statement(BeforeInsert)			
before_delete = Statement(BeforeDelete)