Context Navigation

source: trunk/prototype/api/controller.php @ 5437

Revision 5437, 18.9 KB checked in by cristiano, 12 years ago (diff)
Ticket #2434 - Atualização modulo agenda e API

Rev	Line
[5136]	1	<?php
	2
[5341]	3	if( !defined( 'ROOTPATH' ) )
	4	define( 'ROOTPATH', dirname(__FILE__).'/..' );
[5136]	5
[5399]	6	require_once(ROOTPATH.'/api/config.php');
[5341]	7
	8	/**
	9	TODO list:
	10
	11	* definir de forma centralizada os caminhos e as constantes necessÃ¡rias;
	12	* criar um User Agent detect e um OS server detect para customizaÃ§Ãµes espeÃ§Ãficas de cada browser / servidor;
	13	* criar um registrador para fallback handlers;
	14	* criar um dependency manager na configuraÃ§Ã£o dos serviÃ§os, para poder gerenciar os imports corretamente
	15	* criar um login e a recuperaÃ§Ã£o da sessÃ£o;
	16
	17	*/
	18
[5136]	19	class Controller {
	20
[5341]	21	static $cache;
	22	static $services = array();
	23	static $interceptors = array();
	24	static $config = array();
	25	static $includes = array();
	26	static $tx = array();
	27	static $txID = 0;
	28	static $wallet;
[5136]	29
[5341]	30	public function __destruct()
[5136]	31	{
[5341]	32	// if( $this->service )
	33	// $this->service->close();
	34	// else
	35	self::closeAll();
[5136]	36	}
	37
[5341]	38	public static function closeAll()
[5136]	39	{
[5341]	40	if( self::$services )
	41	foreach( self::$services as $serviceName => $service )
	42	if( self::$config[ $serviceName ]['type'] === 'service' )
	43	$service->close();
	44	}
[5136]	45
[5341]	46	public static function clearAll()
[5136]	47	{
[5341]	48	return self::$cache->clearAll();
[5136]	49	}
	50
[5341]	51	public static function clear( $id )
	52	{
	53	return self::$cache->clear( $id );
	54	}
[5136]	55
[5341]	56	public static function check( $id )
	57	{
	58	return self::$cache->get( $id );
	59	}
[5136]	60
[5341]	61	public static function store( $id, $data, $expires, $compressed )
	62	{
	63	return self::$cache->put( $id, $data, $expires, $compressed );
	64	}
[5136]	65
[5341]	66	public static function find( $URI, $params = false, $criteria = false )
	67	{
	68	if( isset($URI['id']) && $URI['id'] )
	69	return self::read( $URI, $params, $criteria );
[5136]	70
[5341]	71	return self::call( 'find', $URI, $params, $criteria );
	72	}
[5136]	73
[5341]	74	public static function read( $URI, $params = false, $criteria = false )
	75	{
	76	if( !isset($URI['id']) \|\| !$URI['id'] )
	77	return self::find( $URI, $params, $criteria );
[5136]	78
[5341]	79	return self::call( 'read', $URI, $params, $criteria );
[5136]	80	}
	81
[5341]	82	public static function deleteAll( $URI, $params = false, $criteria = false )
[5136]	83	{
[5341]	84	if( isset($URI['id']) && $URI['id'] )
	85	return self::delete( $URI, $params, $criteria );
	86
	87	return self::call( 'deleteAll', $URI, $params, $criteria );
[5136]	88	}
	89
[5341]	90	public static function delete( $URI, $params = false, $criteria = false )
[5136]	91	{
[5341]	92	if( !isset($URI['id']) \|\| !$URI['id'] )
	93	return self::deleteAll( $URI, $params, $criteria );
	94
	95	return self::call( 'delete', $URI, $params, $criteria );
[5136]	96	}
	97
[5341]	98	public static function replace( $URI, $params, $criteria = false )
[5136]	99	{
[5341]	100	if( isset($URI['id']) && $URI['id'] )
	101	return self::update( $URI, $params, $criteria );
	102
	103	return self::call( 'replace', $URI, $params, $criteria );
[5136]	104	}
	105
[5341]	106	public static function update( $URI, $params, $criteria = false )
[5136]	107	{
[5341]	108	if( !isset($URI['id']) \|\| !$URI['id'] )
	109	return self::replace( $URI, $params, $criteria );
	110
	111	return self::call( 'update', $URI, $params, $criteria );
[5136]	112	}
	113
[5341]	114	public static function create( $URI, $params, $criteria = false )
[5136]	115	{
[5341]	116	return self::call( 'create', $URI, $params, $criteria );
	117	}
[5136]	118
[5341]	119	public static function begin( $URI, $params = false, $criteria = false )
	120	{
	121	return self::call( 'begin', $URI, $params, $criteria );
	122	}
[5136]	123
[5341]	124	public static function commit( $URI, $criteria = false )
[5136]	125	{
[5341]	126	return self::call( 'commit', $URI, false, $criteria );
	127	}
[5136]	128
[5341]	129	public static function rollback( $URI, $criteria = false )
	130	{
	131	return self::call( 'rollback', $URI, false, $criteria );
	132	}
[5136]	133
[5341]	134	public static function format( $URI, $params, $criteria = false )
	135	{
	136	return self::call( 'format', $URI, $params, $criteria );
	137	}
[5136]	138
[5341]	139	public static function parse( $URI, $data, $criteria = false )
	140	{
	141	return self::call( 'parse', $URI, $data, $criteria );
[5136]	142	}
	143
[5341]	144	public static function URI( $className, $id = false, $service = false )
	145	{
	146	return array( 'concept' => $className,
	147	'service' => $service ? $service : false,
	148	'id' => $id ? $id : '' );
[5136]	149	}
	150
[5399]	151	//TODO: Compatibilizar as configs relativas aos modulos, adicionando os mesmo nos parametros passados
	152	public static function links( $concept = false )
[5136]	153	{
[5341]	154	if( !isset(self::$config[ $concept ]) )
	155	self::$config[ $concept ] = self::loadConfig( $concept );
[5136]	156
[5341]	157	return( isset(self::$config[ $concept ]['links']) ?
	158	self::$config[ $concept ]['links'] : array() );
	159	}
[5136]	160
[5341]	161	public static function isConcept( $concept )
[5399]	162	{
[5341]	163	if( isset( self::$config[ $concept ] ) &&
	164	self::$config[ $concept ] )
	165	return( true );
[5136]	166	else
[5341]	167	return file_exists( ROOTPATH."/config/$concept.ini" );
	168	}
[5136]	169
[5399]	170	public static function getConcept( $concept, $moduleName = false )
[5341]	171	{
	172	if( isset( self::$config[ $concept ] ) )
	173	return( self::$config[ $concept ] );
	174
[5399]	175	return( self::$config[ $concept ] = self::loadConfig( $concept, $moduleName ) );
	176	}
[5136]	177
[5341]	178	public static function loadCache( $cacheType = 'Memory' )
	179	{
	180	include_once( "cache/MemoryCache.php" );
	181	return new MemoryCache();
	182	}
[5136]	183
[5399]	184	//TODO: Compatibilizar as configs relativas aos modulos, adicionando os mesmo nos parametros passados
	185	public static function loadConfig( $className, $isService = false)
[5341]	186	{
	187	$fileName = $className.'.'.($isService ? 'srv' : 'ini');
[5136]	188
[5341]	189	$config = self::$cache->get( $fileName );
[5399]	190
[5341]	191	if( !$config )
	192	{
[5399]	193	$config = parse_ini_file( ROOTPATH.'/config/'.$fileName, true );
[5341]	194
	195	self::$cache->put( $fileName, $config );
	196	}
	197
	198	return( $config );
[5136]	199	}
	200
[5341]	201	public static function import( $path, $ext = ".php" )
	202	{
	203	if( !isset(self::$includes[$path]) )
[5136]	204	{
[5341]	205	require_once( ROOTPATH.'/'.$path.$ext );
	206	self::$includes[$path] = false;
	207	}
[5136]	208
[5341]	209	return( self::$includes[$path] );
	210	}
[5136]	211
[5341]	212	public static function load( $path, $class = false )
[5136]	213	{
[5341]	214	if( $return = self::import( $path, "" ) )
	215	return( $return );
[5136]	216
[5341]	217	if( !$class ){
	218	preg_match( '/^\/?.*\/([^\/]+).php$/', $path, $class );
	219	$class = $class[1];
[5136]	220	}
	221
[5341]	222	$object = self::$cache->get( $class );
[5136]	223
[5341]	224	if( !$object )
	225	{
	226	$object = new $class();
	227	self::$cache->put( $class, $object );
	228	}
[5136]	229
[5341]	230	self::$includes[$path] = $object;
	231
	232	return( $object );
[5136]	233	}
	234
[5341]	235	public static function wallet( $serviceName )
[5136]	236	{
[5341]	237	if( !isset( self::$wallet ) )
	238	{
	239	//// Hack //// TODO: passar o init da sessÃ£o no login do expresso
	240	Config::init();
	241
	242	if(isset($_SESSION['wallet']))
	243	self::$wallet = $_SESSION['wallet'];
	244	/////////////
	245	}
	246
	247	return isset( self::$wallet[ $serviceName ] )? self::$wallet[ $serviceName ] : false;
	248	}
[5136]	249
[5341]	250	public static function connect( $service, $config )
[5136]	251	{
[5341]	252	$result = $service->open( $config );
[5136]	253
[5341]	254	if( is_string( $result ) )
	255	throw new Exception( $result );
	256
	257	return( true );
	258	}
	259
	260	public static function configure( $config, $newConfig )
	261	{
	262	foreach( $newConfig as $key => $value )
	263	$config[$key] = $value;
	264
	265	return( $config );
[5136]	266	}
	267
[5341]	268	public static function dispatch( $dispatcher, $data, $optionsMap = false )
	269	{
	270	// if( $mappedTo )
	271	// $data = array( $mappedTo => $data );
	272	//
	273	// foreach( $data as $method => $params )
	274	// {
	275	// // foreach( $data[ $method ] as $name => $value )
	276	// }
	277	//
	278	// self::import( "$dispatcher.php" );
	279	}
	280
[5399]	281	//TODO: Compatibilizar as configs relativas aos modulos, adicionando os mesmo nos parametros passados
[5341]	282	public static function service( $serviceName, $concept = false )
	283	{
	284	if( isset( self::$services[ $serviceName ] ) )
	285	return self::$services[ $serviceName ];
	286
	287	if( !isset(self::$config[ $serviceName ]) )
	288	self::$config[ $serviceName ] = self::loadConfig( $serviceName, true );
	289
	290	if( !isset(self::$config[ $serviceName ]) )
[5136]	291	return( false );
	292
[5341]	293	if( !isset(self::$config[ $serviceName ]['type']) )
	294	self::$config[ $serviceName ]['type'] = 'service';
[5136]	295
[5399]	296	self::import( 'api/'.self::$config[ $serviceName ]['type'] ); //TODO: Item 4
[5341]	297
	298	$service = self::load( self::$config[ $serviceName ]['path'],
	299	self::$config[ $serviceName ]['class'] );
	300
	301	$srvConfig = array();
	302
	303	if( isset(self::$config[ $serviceName ][ 'config' ]) )
	304	$srvConfig = self::configure( $srvConfig, self::$config[ $serviceName ][ 'config' ] );
	305	if( $wallet = self::wallet( $serviceName ) )
	306	$srvConfig = self::configure( $srvConfig, $wallet );
	307	if( $concept && isset(self::$config[ $concept ]['service.config']) )
	308	$srvConfig = self::configure( $srvConfig, self::$config[ $concept ]['service.config'] );
	309
	310	if( empty( $srvConfig ) )
	311	$srvConfig = false;
	312
	313	if( $service && self::$config[ $serviceName ]['type'] === 'service' )
	314	self::connect( $service, $srvConfig );
	315
	316	return( self::$services[ $serviceName ] = $service );
	317	}
	318
[5399]	319	//TODO: Compatibilizar as configs relativas aos modulos, adicionando os mesmo nos parametros passados
[5341]	320	public static function interceptor( $method, $concept = false, $serviceName = false, $isService = false )
	321	{
	322	if( $concept && !isset(self::$config[ $concept ]) )
	323	self::$config[ $concept ] = self::loadConfig( $concept );
	324
	325	if( !$concept ) $concept = 'global';
	326	if( !$isService \|\| !$serviceName ) $serviceName = 'global';
	327
	328	if( !isset( self::$interceptors[ $concept ] ) )
	329	self::$interceptors[ $concept ] = array();
	330
	331	if( !isset( self::$interceptors[ $concept ][ $serviceName ] ) )
	332	self::$interceptors[ $concept ][ $serviceName ] = array();
	333
	334	if( !isset( self::$interceptors[ $concept ][ $serviceName ][ $method ] ) )
	335	{
	336	$events = array( 'before', 'after' );
	337	$interceptors = array();
	338
	339	$prefix = ( $isService )? "$serviceName." : "";
	340
	341	foreach( $events as $i => $event )
	342	{
	343	$interceptors[$event] = array();
	344
	345	if( !isset(self::$config[$concept]["$prefix$event.$method"]) )
	346	continue;
	347
	348	foreach( self::$config[$concept]["$prefix$event.$method"] as $intercept => $interceptor )
	349	$interceptors[$event][$intercept] = self::load( $interceptor );
	350	}
	351
	352	self::$interceptors[ $concept ][ $serviceName ][ $method ] = $interceptors;
	353	}
	354
	355	return( self::$interceptors[ $concept ][ $serviceName ][ $method ] );
	356	}
	357
	358	public static function interceptorCommit( $eventType, $commitList, $isService = false )
	359	{
	360	$result = array( $eventType => array() );
	361
[5437]	362	if( is_array( $commitList ) )
[5341]	363	foreach( $commitList as $i => $tx )
	364	{
	365	$interceptors = self::interceptor( 'commit', $tx['concept'], $tx['service'], $isService );
	366
	367	$result[$eventType] = array_merge( $result[$eventType], $interceptors[$eventType] );
	368	}
	369
[5136]	370	return( $result );
	371	}
	372
[5341]	373	public static function fire( $eventType, $method, &$params, $original, $isService = false )
[5136]	374	{
[5341]	375	if( $method === 'commit' )
	376	$interceptors = self::interceptorCommit( $eventType, $params['criteria'], $isService );
	377
	378	else
	379	$interceptors = self::interceptor( $method,
	380	isset($original['URI']['concept']) ? $original['URI']['concept'] : false,
	381	isset($params['URI']['service']) ? $params['URI']['service'] : false, $isService );
	382
	383	if( $interceptors && isset($interceptors[ $eventType ]) )
	384	foreach( $interceptors[ $eventType ] as $intercept => $interceptor )
	385	{
	386	$return = $interceptor->$intercept( $params['URI'], $params['properties'], $params['criteria'], $original/, $params['service']/ );
	387
	388	if( $return === false )
[5136]	389	return( false );
	390
[5341]	391	if( isset($return) )
	392	$params['properties'] = $return;
	393	}
	394
	395	return( $params );
	396	}
	397
	398	/*
	399	* ex: array
	400	* (
	401	* [0] array( 'OR', array( array( '=', 'campo', 'valor' ),
	402	array( 'OR', array( array( '=', 'campo', 'valor' ) ) ) )
	403	* [1] array( '=', 'campo' , 'valor' )
	404	* [2] array( 'OR' , array( array( '=' , campo', 'valor' ) ) )
	405	* [3] array( 'IN', 'campo', array( '1' , '2' , '3' ) )
	406	* )
	407	* OR
	408	* array( '=' , 'campo' , 'valor' )
	409	*/
[5399]	410
	411	//TODO: Compatibilizar as configs relativas aos modulos, adicionando os mesmo nos parametros passados
[5341]	412	public static function serviceName( $URI, $original = false )
	413	{
	414	$concept = "";
	415
	416	if( $original && isset($original['concept']) && $original['concept'] )
	417	$concept = $original['concept'];
	418	elseif( isset($URI['concept']) && $URI['concept'] )
	419	$concept = $URI['concept'];
	420
	421	if( ( !isset($URI['service']) \|\| !$URI['service'] ) && $concept )
	422	{
	423	if( !isset(self::$config[ $concept ]) )
	424	self::$config[ $concept ] = self::loadConfig( $concept );
	425
	426	$URI['service'] = self::$config[ $concept ][ 'service' ];
	427	}
	428
	429	if( !isset($URI['service']) )
	430	throw new Exception( "CONFIGURATION ERROR: service name from concept '$concept' not found" );
	431
	432	return( $URI );
	433	}
	434
[5399]	435	//TODO: Compatibilizar as configs relativas aos modulos, adicionando os mesmos nas options passadas
[5437]	436	public static function call( $method, $URI, $properties = false, $options = false, $service = false )
[5341]	437	{
	438	try
	439	{
	440	if( !isset($URI['concept']) ) $URI['concept'] = false;
	441
	442	$original = $params = array( 'properties' => $properties,
	443	'criteria' => $options,
	444	'URI' => $URI,
	445	'service' => $service );
	446
	447	if( isset($params['URI']['concept']) && !self::fire( 'before', $method, $params, $original ) )
	448	return( empty($params['properties']) ? false : $params['properties'] );
	449
[5437]	450
	451
[5341]	452	if( $params && !$params['service'] )
	453	{
	454	$params['URI'] = self::serviceName( $params['URI'], $original['URI'] );
	455
	456	$params['service'] = self::service( $params['URI']['service'], $params['URI']['concept'] );
	457	}
	458
	459	if( isset($params['URI']['service']) )
	460	{
[5437]	461	if( $method === 'create' \|\| $method === 'update' \|\| $method === 'delete' )
[5341]	462	{
[5437]	463	if( $commit = !isset(self::$tx[ $params['URI']['service'] ]) )
	464	{
	465	self::call( 'begin', $params['URI'] );
	466	}
	467
	468	$TX = array();
[5341]	469	}
	470
	471	if( !self::fire( 'before', $method, $params, $original, true ) )
	472	return( empty($params['properties']) ? false : $params['properties'] );
	473	}
	474
	475	if( $params['service'] )
	476	switch( $method )
[5437]	477	{
[5341]	478	case 'find': $return = $params['service']->find( $params['URI'], $params['properties'], $params['criteria'] ); break;
[5136]	479
[5341]	480	case 'read': $return = $params['service']->read( $params['URI'], $params['properties']/, $criteria/ ); break;
	481
	482	case 'create': $return = $params['service']->create( $params['URI'], $params['properties']/, $criteria/ ); break;
	483
	484	case 'delete': $return = $params['service']->delete( $params['URI'], $params['properties']/, $criteria/ ); break;
	485
	486	case 'deleteAll': $return = $params['service']->deleteAll( $params['URI'], $params['properties'], $params['criteria'] ); break;
	487
	488	case 'update': $return = $params['service']->update( $params['URI'], $params['properties']/, $criteria/ ); break;
	489
	490	case 'replace': $return = $params['service']->replace( $params['URI'], $params['properties'], $params['criteria'] ); break;
	491
	492	case 'begin': $return = $params['service']->begin( $params['URI'] ); break;
	493
	494	case 'commit': $return = $params['service']->commit( $params['URI'], $params['criteria'] ); break;
	495
	496	case 'rollback': $return = $params['service']->rollback( $params['URI'], $params['criteria'] ); break;
	497
	498	case 'parse': $return = $params['service']->parse( $params['properties'], $params['criteria'] ); break;
	499
[5437]	500	case 'analize': $return = $params['service']->analize( $params['properties'], $params['criteria'] ); break;
	501
[5341]	502	case 'format': $return = $params['service']->format( $params['properties'], $params['criteria'] ); break;
[5136]	503
[5437]	504	default : $return = $params['service']->$method( $params['properties'], $params['criteria'] );
	505	}
	506
[5341]	507	if( isset($return) && $return !== false )
	508	$params['properties'] = $return;
	509
	510	if( isset($params['URI']['service']) )
	511	if( !self::fire( 'after', $method, $params, $original, true ) )
	512	return( empty($params['properties']) ? false : $params['properties'] );
	513
[5437]	514	if( isset($URI['concept']) )
	515	self::fire( 'after', $method, $params, $original );
	516
	517	if( empty($params['properties']) )
	518	$params['properties'] = false;
	519
	520	if( isset( $TX ) )
	521	{
	522	$TX['rollback'] = !!!$params['properties'];
	523
	524	if( $params['properties'] && isset($params['properties']['id']) )
	525	$TX['id'] = $params['properties']['id'];
	526
	527	self::$tx[ $params['URI']['service'] ][] = array_merge( $TX, $original['URI'], array( 'service' => $params['URI']['service'], 'method' => $method ) );
	528
	529	if( isset($commit) && $commit )
[5341]	530	{
	531	if( !self::call( 'commit', $params['URI'], false, self::$tx[ $params['URI']['service'] ] ) )
	532	self::call( 'rollback', $params['URI'] , false, self::$tx[ $params['URI']['service'] ] );
	533
	534	unset( self::$tx[ $params['URI']['service'] ] );
	535	}
	536	}
	537	}
	538	catch( Exception $e )
	539	{
	540	if( !self::fallback( $e ) )
	541	self::closeAll();
	542
[5136]	543	return( false );
[5341]	544	}
[5136]	545
[5437]	546	return( $params['properties'] );
[5341]	547	}
[5136]	548
[5341]	549	public static function fallback( $exception )
	550	{
	551	error_log( $exception->getMessage() );
	552	return( true );
[5136]	553	}
[5437]	554
	555	public static function put( $URI, $data, $txIds = false )
	556	{
	557	try
	558	{
	559	$URI = self::serviceName( $URI );
	560
	561	if( $commit = !$txIds )
	562	$txIds = array();
	563
	564	if( !isset( self::$tx[ $URI['service'] ] ) )
	565	{
	566	self::call( 'begin', $URI );
	567	self::$tx[ $txIds[] = $URI['service'] ] = array();
	568	}
	569
	570	$method = $data ? isset( $data['id'] ) ?
	571	'update' : 'create' : 'delete';
	572
	573	$links = self::links( $URI['concept'] );
	574
	575	$order = self::$txID++;
	576
	577	$postpone = array();
	578
	579	if( $data )
	580	{
	581	$URI['id'] = isset( $data['id'] ) ? $data['id'] : false;
	582
	583	foreach( $links as $linkName => $linkTarget )
	584	{
	585	if( isset( $data[$linkName] ) && is_array( $data[$linkName] ) )
	586	{
	587	if( self::isConcept( $linkName ) )
	588	$data[$linkName] = self::put( array( 'concept' => $linkTarget ), $data[$linkName], &$txIds );
	589	else
	590	$postpone[$linkTarget] = $data[$linkName];
	591	}
	592	}
	593	}
	594	else
	595	$URI['id'] = isset( $data['id'] ) ? $data['id'] : $URI['id'];
	596
	597	$result = Controller::call( $method, $URI, $data, false, false, true );
	598
	599	if( !is_bool( $result ) && !is_string( $result ) && isset( $result['id'] ) )
	600	$URI['id'] = $result['id'];
	601
	602	self::$tx[ $URI['service'] ][ count(self::$tx[ $URI['service'] ]) - 1 ]['order'] = $order;
	603	self::$tx[ $URI['service'] ][ count(self::$tx[ $URI['service'] ]) - 1 ]['id'] = $URI['id'];
	604
	605	foreach( $postpone as $linkTarget => $dt )
	606	foreach( $dt as $ii => $value )
	607	{
	608	if( !is_array( $value ) )
	609	$value = array( 'id' => $value );
	610
	611	$value[ $URI['concept'] ] = $URI['id'];
	612
	613	self::put( array( 'concept' => $linkTarget ), $value, &$txIds );
	614	}
	615
	616	if( $commit )
	617	{
	618	$result = array();
	619
	620	for( $i = count( $txIds ) - 1; $i >= 0; $i-- )
	621	{
	622	$currentTx = self::$tx[ $txIds[$i] ];
	623	unset( self::$tx[ $txIds[$i] ] );
	624
	625	if( !self::commit( array( 'service' => $txIds[$i] ), $currentTx ) )
	626	{
	627	self::rollback( array( 'service' => $txIds[$i] ), $currentTx );
	628
	629	foreach( $currentTx as $i => $st )
	630	$currentTx[$i][ 'rollback' ] = true;
	631	}
	632
	633	$result = array_merge( $result, $currentTx );
	634	}
	635
	636	self::$txID = 0;
	637
	638	return( $result );
	639	}
	640
	641	}
	642	catch( Exception $e )
	643	{
	644	if( !self::fallback( $e ) )
	645	self::closeAll();
	646
	647	return( false );
	648	}
	649
	650	return( $URI['id'] );
	651	}
	652
	653	public static function get()
	654	{
	655
	656	}
[5136]	657	}
[5341]	658
	659	Controller::$cache = Controller::loadCache();
[5136]	660	?>

Note: See TracBrowser for help on using the repository browser.

Download in other formats: