EGroupware\Api\Etemplate\Widget\Nextmatch::ajax_get_rows()

Complexity

Conditions	54
Paths	> 20000

Size

Total Lines	263
Code Lines	99

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
	static public function ajax_get_rows($exec_id, array $queriedRange, array $filters = array(), $form_name='nm',
		array $knownUids=null, $lastModified=null)
	{
		self::$request = Etemplate\Request::read($exec_id);

It seems like EGroupware\Api\Etemplate\Request::read($exec_id) can also be of type EGroupware\Api\Etemplate\Request. However, the property $request is declared as type EGroupware\Api\Etemplate\etemplate_request. Maybe add an additional type check?

		// fix for somehow empty etemplate request content
		if (!is_array(self::$request->content))
		{
			self::$request->content = array($form_name => array());
		}
		self::$response = Api\Json\Response::get();

		$value = self::get_array(self::$request->content, $form_name, true);
		if(!is_array($value))
		{
			$value = ($value) ? array($value) : array();
		}

		// Validate filters
		if (($template = Template::instance(self::$request->template['name'], self::$request->template['template_set'],
			self::$request->template['version'], self::$request->template['load_via'])))
		{
			$template = $template->getElementById($form_name, strpos($form_name, 'history') === 0 ? 'historylog' : 'nextmatch');
			$expand = array(
				'cont' => array($form_name => $filters),
			);
			$valid_filters = array();

			if($template)
			{
				$template->run('validate', array('', $expand, $expand['cont'], &$valid_filters), false);	// $respect_disabled=false: as client may disable things, here we validate everything and leave it to the get_rows to interpret
				$filters = $valid_filters[$form_name];
			}
			// Avoid empty arrays, they cause problems with db filtering
			foreach((array)$filters['col_filter'] as $col => $val)
			{
				if(is_array($val) && count($val) == 0)
				{
					unset($filters['col_filter'][$col]);
				}
			}
			//error_log($this . " Valid filters: " . array2string($filters));
		}
		else
		{
			$template = null;	// get_rows method requires null, not false
		}

		if (true) $value = $value_in = array_merge($value, $filters);

		//error_log(__METHOD__."('".substr($exec_id,0,10)."...', range=".array2string($queriedRange).', filters='.array2string($filters).", '$form_name', knownUids=".array2string($knownUids).", lastModified=$lastModified) parent_id=$value[parent_id], is_parent=$value[is_parent]");

		$result = array();

		// Parse sort into something that get_rows functions are expecting: db_field in order, ASC/DESC in sort
		if(is_array($value['sort']))
		{
			$value['order'] = $value['sort']['id'];
			$value['sort'] = $value['sort']['asc'] ? 'ASC' : 'DESC';
		}

		$value['start'] = (int)$queriedRange['start'];
		$value['num_rows'] = (int)$queriedRange['num_rows'];
		if($value['num_rows'] == 0) $value['num_rows'] = self::INITIAL_ROWS;
		// if app supports parent_id / hierarchy ($value['parent_id'] not empty), set parent_id as filter
		if (($parent_id = $value['parent_id']))
		{
			// Infolog at least wants 'parent_id' instead of $parent_id
			$value['col_filter'][$parent_id] = $queriedRange['parent_id'];
			if ($queriedRange['parent_id']) $value['csv_export'] = 'children';
		}

		// Set current app for get_rows
		list($app) = explode('.',self::$request->method);
		if(!$app) list($app) = explode('::',self::$request->method);
		if($app)
		{
			$GLOBALS['egw_info']['flags']['currentapp'] = $app;
			Api\Translation::add_app($app);
		}
		// If specific data requested, just do that
		if (($row_id = $value['row_id']) && $queriedRange['refresh'])
		{
			$value['col_filter'][$row_id] = $queriedRange['refresh'];
			$value['csv_export'] = 'refresh';
		}
		$rows = $result['data'] = $result['order'] = array();
		$result['total'] = self::call_get_rows($value, $rows, $result['readonlys'], null, null, $template);
		$result['lastModification'] = Api\DateTime::to('now', 'ts')-1;

		if (isset($GLOBALS['egw_info']['flags']['app_header']) && self::$request->app_header != $GLOBALS['egw_info']['flags']['app_header'])
		{
			self::$request->app_header = $GLOBALS['egw_info']['flags']['app_header'];
			Api\Json\Response::get()->apply('egw_app_header', array($GLOBALS['egw_info']['flags']['app_header']));
		}

		$GLOBALS['egw']->session->commit_session();

		$row_id = isset($value['row_id']) ? $value['row_id'] : 'id';
		$row_modified = $value['row_modified'];

		foreach($rows as $n => $row)
		{
			$kUkey = false;
			if (is_int($n) && $row)
			{
				if (!isset($row[$row_id])) unset($row_id);	// unset default row_id of 'id', if not used
				if (!isset($row[$row_modified])) unset($row_modified);

				$id = $row_id ? $row[$row_id] : $n;
				$result['order'][] = $id;

				$modified = $row[$row_modified];
				if (isset($modified) && !(is_int($modified) || is_string($modified) && is_numeric($modified)))
				{
					$modified = Api\DateTime::to(str_replace('Z', '', $modified), 'ts');
				}

				// check if we need to send the data
				//error_log("$id Known: " . (array_search($id, $knownUids) !== false ? 'Yes' : 'No') . ' Modified: ' . Api\DateTime::to($row[$row_modified]) . ' > ' . Api\DateTime::to($lastModified).'? ' . ($row[$row_modified] > $lastModified ? 'Yes' : 'No'));
				if (!$row_id || !$knownUids || ($kUkey = array_search($id, $knownUids)) === false ||
					!$lastModified || !isset($modified) || $modified > $lastModified ||
					$queriedRange['refresh'] && $id == $queriedRange['refresh']
				)
				{
					$result['data'][$id] = $row;
				}

				if ($kUkey !== false) unset($knownUids[$kUkey]);
			}
			else	// non-row data set by get_rows method
			{
				// Encode all select options and re-index to avoid Firefox's problem with
				// '' => 'All'
				if($n == 'sel_options')
				{
					foreach($row as &$options)
					{
						Select::fix_encoded_options($options,true);
					}
				}
				$result['rows'][$n] = $row;
			}
		}
		// check knowUids outside of range for modification - includes deleted
		/*
		if ($knownUids)
		{
			// row_id not set for nextmatch --> just skip them, we can't identify the rows
			if (!$row_id)
			{
				foreach($knownUids as $uid)
				{
					// Just don't send it back for now
					unset($result['data'][$uid]);
					//$result['data'][$uid] = null;
				}
			}
			else
			{
				error_log(__METHOD__."() knowUids left to check ".array2string($knownUids));
				// check if they are up to date: we create a query similar to csv-export without any filters
				$uid_query = $value;
				$uid_query['csv_export'] = 'knownUids';	// do not store $value in session
				$uid_query['filter'] = $uid_query['filter2'] = $uid_query['cat_id'] = $uid_query['search'] = '';
				$uid_query['col_filter'] = array($row_id => $knownUids);
				// if we know name of modification column and have a last-modified date
				if ($row_modified && $lastModified)	// --> set filter to return only modified entries
				{
					$uid_query['col_filter'][] = $row_modified.' > '.(int)$lastModified;
				}
				$uid_query['start'] = 0;
				$uid_query['num_rows'] = count($knownUids);
				$rows = array();
				try
				{
					if (self::call_get_rows($uid_query, $rows))
					{
						foreach($rows as $n => $row)
						{
							if (!is_int($n)) continue;	// ignore non-row data set by get_rows method

							if (!$row_modified || !isset($row[$row_modified]) ||
								!isset($lastModified) || $row[$row_modified] > $lastModified)
							{
								$result['data'][$row[$row_id]] = $row;
								$kUkey = array_search($id, $knownUids);
								if ($kUkey !== false) unset($knownUids[$kUkey]);
							}
						}
					}
				}
				catch (Exception $e)
				{
					unset($value['row_modified']);
					error_log("Error trying to find changed rows with {$value['get_rows']}, falling back to all rows. ");
					error_log($e);
				}

				// Remove any remaining knownUIDs from the grid
				foreach($knownUids as $uid)
				{
					$result['data'][$uid] = null;
				}
			}
		}
		 */

		// Check for anything changed in the query
		// Tell the client about the changes
		$request_value =& self::get_array(self::$request->content, $form_name,true);
		$changes = $no_rows = false;

The assignment to $no_rows is dead and can be removed.

		foreach(array_keys($value_in) + array_keys($value) as $key)
		{
			// These keys are ignored
			if(in_array($key, array('col_filter','start','num_rows','total','order','sort')))
			{
				continue;
			}
			if($value_in[$key] == $value[$key]) continue;

			// These keys we don't send row data back, as they cause a partial reload
			if(in_array($key, array('template'))) $no_rows = true;

			// Actions still need extra handling
			if($key == 'actions' && !isset($value['actions'][0]))
			{
				$value['action_links'] = array();
				$template_name = isset($value['template']) ? $value['template'] : '';
				if (!is_array($value['action_links'])) $value['action_links'] = array();
				$value['actions'] = self::egw_actions($value['actions'], $template_name, '', $value['action_links']);
			}

			$changes = true;
			$request_value[$key] = $value[$key];

			Api\Json\Response::get()->generic('assign', array(
				'etemplate_exec_id' => $exec_id,
				'id' => $form_name,
				'key' => $key,
				'value' => $value[$key],
			));
		}
		// Request doesn't handle changing by reference, so force it
		if($changes)
		{
			$content = self::$request->content;
			self::$request->content = array();
			self::$request->content = $content;
		}

		// Send back data
		//foreach($result as $name => $value) if ($name != 'readonlys') error_log(__METHOD__."() result['$name']=".array2string($name == 'data' ? array_keys($value) : $value));
		Api\Json\Response::get()->data($result);

		// If etemplate_exec_id has changed, update the client side
		if (($new_id = self::$request->id()) != $exec_id)
		{
			Api\Json\Response::get()->generic('assign', array(
				'etemplate_exec_id' => $exec_id,
				'id' => '',
				'key' => 'etemplate_exec_id',
				'value' => $new_id,
			));