Context Navigation

source: trunk/prototype/services/ImapServiceAdapter.php @ 5959

Revision 5959, 23.4 KB checked in by adriano, 12 years ago (diff)
Ticket #2633 - alteracoes de backend e interceptadores para a funcionalidade de sinalizadores

Line
1	<?php
2
3	include_once ROOTPATH."/../expressoMail1_2/inc/class.imap_functions.inc.php";
4
5	class ImapServiceAdapter extends imap_functions/* implements Service*/
6	{
7	public function open( $config )
8	{
9	$this->init();
10	}
11
12	// public function connect( $config )
13	// {
14	// $this->init();
15	// }
16
17	public function find( $URI, $justthese = false, $criteria = false )
18	{
19	$context = $justthese['context'];
20	$URI = $URI['concept'];
21
22	switch( $URI )
23	{
24	case 'folder':
25	{
26	$result = $this->to_utf8($this->get_folders_list());
27
28	foreach ($result as $res) {
29
30	$response[] = array(
31	'id' => $res['folder_id'],
32	'commonName' => $res['folder_name'],
33	'parentFolder' => $res['folder_parent'],
34	'messageCount' => array('unseen' => isset($res['folder_unseen']) ? $res['folder_unseen'] : null, 'total' => null)
35	);
36	}
37
38	return $response;
39	}
40	case 'message':
41	{
42	//begin: for grid
43	$page = $criteria['page']; //{1} get the requested page
44	$limit = $criteria['rows']; //{10} get how many rows we want to have into the grid
45	$sidx = $criteria['sidx']; //{id} get index row - i.e. user click to sort
46	$sord = $criteria['sord']; //{desc} get the direction
47
48	$filter = $criteria['filter'];
49
50	if( !$sidx ) $sidx = 1;
51
52	$folder_name = str_replace( '.', $this->imap_delimiter, $context['folder'] );
53
54	$count = imap_num_msg( $this->open_mbox( $folder_name ) );
55
56	$total_pages = $count > 0 ? ceil( $count/$limit ) : 0;
57
58	if( $page > $total_pages )
59	$page = $total_pages;
60
61	$start = $limit * $page - $limit;
62	// do not put $limit*($page - 1)
63	//end: for grid
64
65
66	/**
67	* Trata o caso específico de retorno do atributo messageId
68	*
69	* TODO - refazer todo a operação find do conceito message, uma vez que esta
70	* foi desenvolvida quando a nova API ainda era muito imatura e se encontra
71	* muito acoplada à estrutura de retorno esperada pelo plugin jqGrid
72	*/
73	if ( $justthese )
74	{
75	if ($justthese[0] == 'messageId') {
76	$map = array(
77	'folderName' => array(),
78	'messageNumber' => array()
79	);
80
81	self::parseFilter($criteria["filter"], &$map);
82
83	if (count($map['folderName']) == 0) {
84	$folders = $this->get_folders_list();
85	foreach ($folders as $folder)
86	if (isset($folder['folder_id']))
87	$map['folderName'][] = $folder['folder_id'];
88	}
89
90	$result = array();
91	foreach ($map['folderName'] as $folder) {
92	$this->mbox = $this->open_mbox($folder);
93
94	/**
95	* Se não foi passado messageNumber no filtro,
96	* busca todas as mensagens de cada pasta
97	*/
98	$messages = empty($map['messageNumber']) ? '1:*' : implode(',', $map['messageNumber']);
99	$sequenceType = empty($map['messageNumber']) ? 0 : FT_UID;
100
101	$headers = imap_fetch_overview($this->mbox, $messages, $sequenceType);
102	foreach ($headers as $h) {
103	$result[] = array ( 'messageId' => $h->message_id );
104	}
105
106	imap_close($this->mbox);
107	$this->mbox = false;
108	}
109	return $result;
110	}
111	}
112
113	if( $filter )
114	{
115	if( $filter[0] !== 'msgNumber' )
116	{
117	for( $i = 0; $i < count($filter); $i++ )
118	{
119	if( count( $filter[$i] ) === 4 )
120	$criteria['isExact'] = ( array_shift( $filter[$i] ) === 'AND' );
121
122	$criteria[ $filter[$i][0] ] = array( 'criteria' => $filter[$i][2], 'filter' => $filter[$i][1] );
123	}
124
125	return $this->searchSieveRule($criteria);
126	}
127
128	$msgNumber = array();
129
130	for( $i = $start; $i < $start + $limit && isset( $filter[2][$i] ); $i++ )
131	$msgNumber[] = $filter[2][$i];
132
133	if( empty( $msgNumber ) )
134	return( false );
135
136	$result = $this->get_info_msgs( array( 'folder' => $folder_name,
137	'msgs_number' => implode( ',', $msgNumber ) ) );
138
139	foreach( $result as $i => $val )
140	$result[$i] = unserialize( $val );
141
142	}
143	else
144	{
145	$result = $this->get_range_msgs2(
146	array(
147	'folder' => $folder_name, //INBOX
148	'msg_range_begin' => $start + 1, //??
149	'msg_range_end' => $start + $limit, //$limit = $_GET['rows']; // get how many rows we want to have into the grid
150	'sort_box_type' => 'SORTARRIVAL',
151	'search_box_type' => 'ALL',
152	'sort_box_reverse' => 1
153	)
154	);
155	}
156	//return var_export($result);
157
158	$response = array( "page" => $page, "total" => $total_pages, "records" => $count );
159
160	for ($i=0; $i<count($result); $i++)
161	{
162	$flags_enum = array('Recent', 'Unseen', 'Answered', 'Draft', 'Deleted', 'Flagged');
163
164	foreach ($flags_enum as $key => $flag)
165	{
166	if ( !isset($result[$i][$flag]) \|\| !trim($result[$i][$flag]) \|\| trim($result[$i][$flag]) == '')
167	unset($flags_enum[$key]);
168
169	unset($result[$i][$flag]);
170	}
171
172	if (array_key_exists($i, $result))
173	{
174	$response["rows"][$i] = $result[$i];
175	$response["rows"][$i]['timestamp'] = ( ( $result[$i]['udate'] + $this->functions->CalculateDateOffset() ) * 1000 );
176	$response["rows"][$i]['flags'] = implode(',', $flags_enum);
177	$response["rows"][$i]['size'] = $response["rows"][$i]['Size'];
178	//$response["rows"][$i]['udate'] = ( $result[$i]['udate'] + $this->functions->CalculateDateOffset() * 1000 );
179	unset($response["rows"][$i]['Size']);
180	}
181	}
182
183	return $this->to_utf8($response);
184	}
185
186	/**
187	* Filtros suportados:
188	* - ['=', 'folderName', $X]
189	* - [
190	* 'AND',
191	* [
192	* 'AND',
193	* ['=', 'folderName', $X],
194	* ['IN', 'messageNumber', $Ys]
195	* ],
196	* ['IN', 'labelId', $Zs]
197	* ]
198	* - ['=', 'labelId', $X]
199	* - [
200	* 'AND',
201	* ['=', 'folderName', $X],
202	* ['=', 'labelId', $Y]
203	* ]
204	* - ['IN', 'labelId', $Ys]
205	* - [
206	* 'AND',
207	* ['=', 'folderName', $X],
208	* ['IN', 'labelId', $Ys]
209	* ]
210	*/
211	case 'labeled':
212	{
213	$result = array ( );
214	if (isset($criteria["filter"]) && is_array($criteria['filter'])) {
215	//TODO - melhorar o tratamento do filter com a lista de todos os labelIds dado pelo interceptor
216	$map = array(
217	'id' => array(),
218	'folderName' => array(),
219	'messageNumber' => array(),
220	'labelId' => array()
221	);
222
223	self::parseFilter($criteria["filter"], &$map);
224
225	if (count($map['folderName']) == 0) {
226	$folders = $this->get_folders_list();
227	foreach ($folders as $folder)
228	if (isset($folder['folder_id']))
229	$map['folderName'][] = $folder['folder_id'];
230	}
231
232	foreach ($map['folderName'] as $folder) {
233	$this->mbox = $this->open_mbox($folder);
234
235	foreach ($map['labelId'] as $label) {
236	$messagesLabeleds = imap_search($this->mbox, 'UNDELETED KEYWORD "$Label'.$label.'"', SE_UID);
237
238	foreach ($messagesLabeleds as $messageLabeled) {
239	if (count($map['messageNumber']) > 0 && !in_array($messageLabeled, $map['messageNumber']))
240	continue;
241
242	$result[] = array (
243	'id' => $folder . '/' . $messageLabeled . '#' . $label,
244	'folderName' => $folder,
245	'messageNumber' => $messageLabeled,
246	'labelId' => $label
247	);
248	}
249	}
250
251	imap_close($this->mbox);
252	$this->mbox = false;
253	}
254	}
255
256	return $result;
257	}
258
259	case 'followupflagged':
260	{
261	$result = array ( );
262
263	$map = array(
264	//'id' => array(),
265	'folderName' => array(),
266	'messageNumber' => array(),
267	'messageId' => array()
268	);
269
270	self::parseFilter($criteria["filter"], &$map);
271
272	if (empty($map['folderName'])) {
273	$folders = $this->get_folders_list();
274	foreach ($folders as $folder)
275	if (isset($folder['folder_id']))
276	$map['folderName'][] = $folder['folder_id'];
277	}
278
279	$messagesIds = $map['messageId'];
280
281	foreach ($map['folderName'] as $folder) {
282	$messages = array();
283
284	$this->mbox = $this->open_mbox($folder);
285
286	/**
287	* Se é uma busca por messageId
288	*/
289	if (!empty($map['messageId'])) {
290
291	foreach ($messagesIds as $k => $v) {
292	$r = imap_search($this->mbox, 'UNDELETED KEYWORD "$Followupflagged" TEXT "'.$v.'"', SE_UID);
293
294	if ($r) {
295	$messages = $messages + $r;
296	unset($messagesIds[$k]);
297	}
298	}
299
300	/**
301	* Se é uma busca por messageNumber.
302	* Lembrando que, neste caso, só deve ser suportada uma única pasta no filtro.
303	*/
304	} else {
305	$messages = imap_search($this->mbox, 'UNDELETED KEYWORD "$Followupflagged"', SE_UID);
306	}
307
308	/**
309	* Se é uma busca por messageId, deve ser comparado com os messageNumbers
310	* passados no filtro, se houverem.
311	*/
312	if (!empty($map['messageNumber'])) {
313	foreach ($messages as $k => $m)
314	if (!in_array($m, $map['messageNumber']))
315	unset($messages[$k]);
316	}
317
318	/**
319	* Adicionar demais atributos às mensagens para retorno
320	*/
321	foreach ($messages as $k => $m) {
322	$headers = imap_fetch_overview($this->mbox, $m, FT_UID);
323
324	$result[] = array (
325	'messageId' => $headers[0]->message_id,
326	'messageNumber' => $m,
327	'folderName' => $folder
328	);
329	}
330
331	imap_close($this->mbox);
332	$this->mbox = false;
333
334	/**
335	* Se é uma busca por messageId e todos os messageIds foram econstrados:
336	* Stop searching in all folders
337	*/
338	if (!empty($map['messageId']) && empty($messagesIds))
339	break;
340	}
341
342	if ($this->mbox) {
343	imap_close($this->mbox);
344	$this->mbox = false;
345	}
346
347	return $result;
348
349	} //CASE 'followupflag'
350	}
351	}
352
353	public function read( $URI, $justthese = false )
354	{
355
356	switch( $URI['concept'] )
357	{
358	case 'message':
359	{
360	return $this->to_utf8(
361	$this->get_info_msg( array('msg_number'=>$URI['id'],
362	'msg_folder'=>str_replace( '.', $this->imap_delimiter, $justthese['context']['folder'] )) )
363	);
364	}
365	case 'labeled':
366	{
367	/**
368	* id looks like 'folder/subfolder/subsubfolder/65#13', meaning messageId#labelId
369	*/
370	list($messageId, $labelId) = explode('#', $URI['id']);
371	$folderName = basename($messageId);
372	$messageNumber = dirname($messageId);
373
374	$result = array();
375
376	if ($folderName && $messageNumber && $labelId) {
377	$this->mbox = $this->open_mbox($folderName);
378	$messagesLabeleds = imap_search($this->mbox, 'UNDELETED KEYWORD "$Label'.$labelId.'"', SE_UID);
379
380	if (in_array($messageNumber, $messagesLabeleds)) {
381	$result = array (
382	'id' => $URI['id'],
383	'folderName' => $folderName,
384	'messageNumber' => $messageNumber,
385	'labelId' => $labelId
386	);
387	}
388	imap_close($this->mbox);
389	$this->mbox = false;
390	}
391
392	return $result;
393	}
394
395	case 'followupflagged':
396	{
397
398	/**
399	* identifica se o formato de ID é "folder/subfolder/subsubfolder/<messageNumber>" ou "<message-id>"
400	*/
401	$folderName = $messageNumber = false;
402	if(!($messageHasId = preg_match('/<.*>/', $URI['id']))) {
403	$folderName = dirname($URI['id']);
404	$messageNumber = basename($URI['id']);
405	}
406
407	$result = array();
408	if ($folderName && $messageNumber) {
409
410	$this->mbox = $this->open_mbox($folderName);
411	$r = imap_search($this->mbox, 'UNDELETED KEYWORD "$Followupflagged"', SE_UID);
412
413	if (in_array($messageNumber, $r)) {
414	$headers = imap_fetch_overview($this->mbox, $messageNumber, FT_UID);
415
416	$result = array (
417	'messageId' => $headers[0]->message_id,
418	'messageNumber' => $messageNumber,
419	'folderName' => $folderName
420	);
421	}
422
423	imap_close($this->mbox);
424	$this->mbox = false;
425
426	} else {
427	/**
428	* Busca pela mensagem com o messageId dado. Se uma pasta foi passada, busca nela,
429	* senão busca em todas.
430	*/
431
432	$folders = array ();
433	if ($folderName) {
434	$folders = array ($folderName);
435	} else {
436	$folder_list = $this->get_folders_list();
437	foreach ($folder_list as $folder)
438	if (isset($folder['folder_id']))
439	$folders[] = $folder['folder_id'];
440	}
441
442	foreach ($folders as $folder) {
443
444	$this->mbox = $this->open_mbox($folder);
445
446	if ($messages = imap_search($this->mbox, 'UNDELETED KEYWORD "$Followupflagged" TEXT "'.$URI['id'].'"', SE_UID)) {
447
448	$result = array (
449	'messageId' => $URI['id'],
450	'messageNumber' => $messages[0],
451	'folderName' => $folder
452	);
453
454	/**
455	* Stop searching in all folders
456	*/
457	break;
458	}
459
460	imap_close($this->mbox);
461	$this->mbox = false;
462	}
463	}
464
465	if ($this->mbox) {
466	imap_close($this->mbox);
467	$this->mbox = false;
468	}
469
470	return $result;
471	}
472	}
473	}
474
475	public function create($URI, &$data)
476	{
477	switch( $URI['concept'] )
478	{
479	case 'labeled':
480	{
481	if (isset($data['folderName']) && isset($data['messageNumber']) && isset($data['labelId'])) {
482	$this->mbox = $this->open_mbox($data['folderName']);
483	imap_setflag_full($this->mbox, $data['messageNumber'], '$Label' . $data['labelId'], ST_UID);
484
485	imap_close($this->mbox);
486	$this->mbox = false;
487
488	return array ('id' => $data['folderName'].'/'.$data['messageNumber'].'#'.$data['labelId']);
489	}
490	return array ();
491	}
492	case 'followupflagged':
493	{
494	//deve ser gravado primeiro no imap, obtido o message-id e, depois gravado no banco
495
496	if (isset($data['folderName']) && isset($data['messageNumber'])) {
497
498	$this->mbox = $this->open_mbox($data['folderName']);
499	$s = imap_setflag_full($this->mbox, $data['messageNumber'], '$Followupflagged', ST_UID);
500
501	$headers = imap_fetch_overview($this->mbox, $data['messageNumber'], FT_UID);
502
503	$data['messageId'] = $headers[0]->message_id;
504
505	imap_close($this->mbox);
506	$this->mbox = false;
507
508	return ($s) ? $data : array();
509
510	} else if (isset($data['messageId'])) {
511	/**
512	* Busca pela mensagem com o messageId dado. Se uma pasta foi passada, busca nela,
513	* senão busca em todas.
514	*/
515	$folders = array ();
516	if (isset($data['folderName'])) {
517	$folders = array ($data['folderName']);
518	} else {
519	$folder_list = $this->get_folders_list();
520	foreach ($folder_list as $folder)
521	if (isset($folder['folder_id']))
522	$folders[] = $folder['folder_id'];
523	}
524
525	foreach ($folders as $folder) {
526
527	$this->mbox = $this->open_mbox($folder);
528	if ($messages = imap_search($this->mbox, 'TEXT "'.$data['messageId'].'"', SE_UID)) {
529
530	$s = imap_setflag_full($this->mbox, $messages[0], '$Followupflagged', ST_UID);
531
532	imap_close($this->mbox);
533	$this->mbox = false;
534
535	/**
536	* Stop searching in all folders
537	*/
538	return $data;
539	}
540
541	imap_close($this->mbox);
542	$this->mbox = false;
543	}
544	}
545	return array ();
546	}
547
548	case 'message':
549	{
550	require_once ROOTPATH.'/library/uuid/class.uuid.php';
551
552	$GLOBALS['phpgw_info']['flags'] = array( 'noheader' => true, 'nonavbar' => true,'currentapp' => 'expressoMail1_2','enable_nextmatchs_class' => True );
553	$return = array();
554
555	require_once dirname(__FILE__) . '/../../services/class.servicelocator.php';
556	$mailService = ServiceLocator::getService('mail');
557
558	$msg_uid = $data['msg_id'];
559	$body = $data['body'];
560	$body = str_replace("%nbsp;"," ",$body);
561	$body = preg_replace("/\n/"," ",$body);
562	$body = preg_replace("/\r/","" ,$body);
563	$body = html_entity_decode ( $body, ENT_QUOTES , 'ISO-8859-1' );
564
565	$folder = mb_convert_encoding($data['folder'], "UTF7-IMAP","ISO-8859-1, UTF-8");
566	$folder = @eregi_replace("INBOX[/.]", "INBOX".$this->imap_delimiter, $folder);
567
568	/**
569	* Gera e preenche o field Message-Id do header
570	*/
571	$mailService->addHeaderField('Message-Id', UUID::generate( UUID::UUID_RANDOM, UUID::FMT_STRING ) . '@Draft');
572
573	$mailService->addTo($data['input_to']);
574	$mailService->addCc( $data['input_cc']);
575	$mailService->addBcc($data['input_cco']);
576	$mailService->setSubject($data['input_subject']);
577	if(isset($data['input_important_message']))
578	$mailService->addHeaderField('Importance','High');
579
580	if(isset($data['input_return_receipt']))
581	$mailService->addHeaderField('Disposition-Notification-To', Config::me('mail'));
582
583	$isHTML = ( ( array_key_exists( 'type', $data ) && in_array( strtolower( $data[ 'type' ] ), array( 'html', 'plain' ) ) ) ? strtolower( $data[ 'type' ] ) != 'plain' : true );
584
585	if (!$body) $body = ' ';
586
587
588	$mbox_stream = $this->open_mbox($folder);
589
590	$attachment = json_decode($data['attachments'],TRUE);
591
592
593	foreach ($attachment as &$value)
594	{
595	if((int)$value > 0) //BD attachment
596	{
597	$att = Controller::read(array('id'=> $value , 'concept' => 'mailAttachment'));
598
599	if($att['disposition'] == 'embedded')
600	{
601	$body = str_replace('"../prototype/getArchive.php?mailAttachment='.$att['id'].'"', $att['name'], $body);
602	$mailService->addStringImage(base64_decode($att['source']), $att['type'], $att['name']);
603	}
604	else
605	$mailService->addStringAttachment(base64_decode($att['source']), $att['name'], $att['type'], 'base64', isset($att['disposition']) ? $att['disposition'] :'attachment' );
606
607	unset($att);
608	}
609	else
610	{
611	$value = json_decode($value, true);
612
613	switch ($value['type']) {
614	case 'imapPart':
615	$att = $this->getForwardingAttachment($value['folder'],$value['uid'], $value['part']);
616	if(strstr($body,'<img src="./inc/get_archive.php?msgFolder='.$value['folder'].'&msgNumber='.$value['uid'].'&indexPart='.$value['part'].'" />') !== false)//Embeded IMG
617	{
618	$body = str_ireplace('<img src="./inc/get_archive.php?msgFolder='.$value['folder'].'&msgNumber='.$value['uid'].'&indexPart='.$value['part'].'" />' , '<img src="'.$att['name'].'" />', $body);
619	$mailService->addStringImage($att['source'], $att['type'], $att['name']);
620	}
621	else
622	$mailService->addStringAttachment($att['source'], $att['name'], $att['type'], 'base64', isset($att['disposition']) ? $att['disposition'] :'attachment' );
623	unset($att);
624	break;
625	case 'imapMSG':
626	$sub = $value['name'] ? $value['name'].'.eml' :'no title.eml';
627	$mbox_stream = $this->open_mbox($value['folder']);
628	$rawmsg = $this->getRawHeader($value['uid']) . "\r\n\r\n" . $this->getRawBody($value['uid']);
629	$mailService->addStringAttachment($rawmsg, $sub, 'message/rfc822', '7bit', 'attachment' );
630	unset($rawmsg);
631	break;
632
633	default:
634	break;
635	}
636	}
637
638	}
639
640	if($isHTML) $mailService->setBodyHtml($body); else $mailService->setBodyText($body);
641
642	if(imap_append($mbox_stream, "{".$this->imap_server.":".$this->imap_port."}".$folder, $mailService->getMessage(), "\\Seen \\Draft"))
643	{
644	$status = imap_status($mbox_stream, "{".$this->imap_server.":".$this->imap_port."}".$folder, SA_UIDNEXT);
645	$return['id'] = $status->uidnext - 1;
646
647	if($data['uidsSave'] )
648	$this->delete_msgs(array('folder'=> $folder , 'msgs_number' => $data['uidsSave']));
649	}
650
651	if($mbox_stream) imap_close($mbox_stream);
652
653	return $return;
654	}
655	}
656	}
657
658	public function delete( $URI, $justthese = false, $criteria = false )
659	{
660	switch( $URI['concept'] )
661	{
662	case 'labeled':
663	{
664	list($messageId, $labelId) = explode('#', $URI['id']);
665	$folderName = dirname($messageId);
666	$messageNumber = basename($messageId);
667
668	if ($folderName && $messageNumber && $labelId) {
669	$this->mbox = $this->open_mbox($folderName);
670	imap_clearflag_full($this->mbox, $messageNumber, '$Label' . $labelId, ST_UID);
671
672	imap_close($this->mbox);
673	$this->mbox = false;
674	}
675	}
676	case 'followupflagged':
677	{
678
679	/**
680	* identifica se o formato de ID é "folder/subfolder/subsubfolder/<messageNumber>" ou "<message-id>"
681	*/
682	$folderName = $messageNumber = false;
683	if(!($messageHasId = preg_match('/<.*>/', $URI['id']))) {
684	$folderName = dirname($URI['id']);
685	$messageNumber = basename($URI['id']);
686	}
687
688	/**
689	* TODO - efetuar o parsing do $criteria e obter a pasta passada
690	*/
691	$map = array(
692	'folderName' => array(),
693	'messageNumber' => array(),
694	'messageId' => array()
695	);
696
697	if ($folderName && $messageNumber) {
698
699	$this->mbox = $this->open_mbox($folderName);
700	$s = imap_clearflag_full($this->mbox, $messageNumber, '$Followupflagged', ST_UID);
701
702	imap_close($this->mbox, CL_EXPUNGE);
703	$this->mbox = false;
704
705	return $s;
706	} else {
707	/**
708	* Busca pela mensagem com o messageId dado. Se uma pasta foi passada, busca nela,
709	* senão busca em todas.
710	*/
711
712	$folders = array ();
713	if (isset($map['folderName'])) {
714	$folders = $map['folderName'];
715	} else {
716	$folder_list = $this->get_folders_list();
717	foreach ($folder_list as $folder)
718	if (isset($folder['folder_id']))
719	$folders[] = $folder['folder_id'];
720	}
721
722	foreach ($folders as $folder) {
723
724	$this->mbox = $this->open_mbox($folder);
725	if ($messages = imap_search($this->mbox, 'TEXT "'.$URI['id'].'"', SE_UID)) {
726
727	$s = imap_clearflag_full($this->mbox, $messages[0], '$Followupflagged', ST_UID);
728
729	imap_close($this->mbox, CL_EXPUNGE);
730	$this->mbox = false;
731
732	/**
733	* Stop searching in all folders
734	*/
735	return $s;
736	}
737
738	imap_close($this->mbox);
739	$this->mbox = false;
740	}
741	}
742
743	return false;
744	}
745	}
746
747	//TODO - return
748	}
749
750	public function deleteAll( $URI, $justthese = false, $criteria = false ) // avaliar
751	{}
752
753	public function update( $URI, $data, $criteria = false )
754	{
755	/**
756	* Os únicos atributos da sinalização presentes no IMAP são folderName, messageNumber e messageId,
757	* porém a operação de update desses atributos não faz sentido para o usuário da DataLayer,
758	* pois na prática elas são executadas através das operações de CREATE e DELETE.
759	* Assim, para os conceitos "labeled" e "followupflagged", só faz sentido o update de
760	* atributos gravados no banco de dados e nunca no IMAP.
761	*/
762	}
763
764	// public function retrieve( $concept, $id, $parents, $justthese = false, $criteria = false )
765	// {
766	// return $this->read( array( 'id' => $id,
767	// 'concept' => $concept,
768	// 'context' => $parents ), $justthese );
769	// }
770
771	public function replace( $URI, $data, $criteria = false )
772	{}
773
774	public function close()
775	{}
776
777	public function setup()
778	{}
779
780	public function commit( $uri )
781	{ return( true ); }
782
783	public function rollback( $uri )
784	{}
785
786	public function begin( $uri )
787	{}
788
789
790	public function teardown()
791	{}
792
793	function to_utf8($in)
794	{
795	if (is_array($in)) {
796	foreach ($in as $key => $value) {
797	$out[$this->to_utf8($key)] = $this->to_utf8($value);
798	}
799	} elseif(is_string($in)) {
800	return mb_convert_encoding( $in , 'UTF-8' , 'UTF-8 , ISO-8859-1' );
801	} else {
802	return $in;
803	}
804	return $out;
805	}
806
807
808	private static function parseFilter($filter ,&$map){
809
810	if( !is_array( $filter ) \|\| count($filter) <= 0) return null;
811
812	$op = array_shift( $filter );
813	switch(strtolower($op))
814	{
815	case 'and': {
816	foreach ($filter as $term)
817	self::parseFilter($term ,&$map);
818	return;
819	}
820	case 'in': {
821	if(is_array($map[$filter[0]]) && is_array($filter[1]))
822	$map[$filter[0]] = array_unique(array_merge($map[$filter[0]], $filter[1]));
823	return;
824	}
825	case '=': {
826	$map[$filter[0]][] = $filter[1];
827	}
828	}
829	}
830
831	}

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

Download in other formats: