egroupware/phpgwapi/inc/class.app_registry.inc.php

<?php
  /**************************************************************************\
  * phpGroupWare API - App(lication) Registry Manager Class                  *
  * This file written by Mark Peters <skeeter@phpgroupware.org>              *
  * Copyright (C) 2001 Mark Peters                                           *
  * -------------------------------------------------------------------------*
  * This library is part of the phpGroupWare API                             *
  * http://www.phpgroupware.org/api                                          * 
  * ------------------------------------------------------------------------ *
  * This library is free software; you can redistribute it and/or modify it  *
  * under the terms of the GNU Lesser General Public License as published by *
  * the Free Software Foundation; either version 2.1 of the License,         *
  * or any later version.                                                    *
  * This library is distributed in the hope that it will be useful, but      *
  * WITHOUT ANY WARRANTY; without even the implied warranty of               *
  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.                     *
  * See the GNU Lesser General Public License for more details.              *
  * You should have received a copy of the GNU Lesser General Public License *
  * along with this library; if not, write to the Free Software Foundation,  *
  * Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA            *
  \**************************************************************************/

  /* $Id$ */
	/*!
	@class app_registry
	@abstract functions for managing and installing apps via XML-RPC/SOAP
	@discussion Author: skeeter
	*/
	class app_registry
	{
		var $public_functions = array(
			'list_methods'          => True,
			'request_appbyid'       => True,
			'request_appbyname'     => True,
			'request_newer_applist' => True,
			'get_appbyid'           => True,
			'get_appbyname'         => True,
			'find_new_app'          => True
		);

		var $soap_functions = array();

		var $db;
		var $is;
		var $client;
		var $server;

//		var $target_page = '/cvsdemo/xmlrpc.php';
//		var $target_site = 'www.phpgroupware.org';
		var $target_page = '/phpgroupware/xmlrpc.php';
		var $target_site = 'devel';
		var $target_port = 80;
		
		function app_registry($param='')
		{
			$this->db = $GLOBALS['phpgw']->db;

			if(is_array($param))
			{
				// This is the interserver communicator
				$this->is = CreateObject('phpgwapi.interserver',$param['server']);
				$this->is->sessionid = $param['sessionid'];
				$this->is->kp3 = $param['kp3'];
			}
			else
			{
				// create the app_registry services client
				$this->client = CreateObject('phpgwapi.xmlrpc_client',$this->target_page,$this->target_site,$this->target_port);
				$this->client->debug = False;
			}
		}


		function list_methods($_type='xmlrpc')
		{
			/*
			  This handles introspection or discovery by the logged in client,
			  in which case the input might be an array.  The server always calls
			  this function to fill the server dispatch map using a string.
			*/
			if (is_array($_type))
			{
				$_type = $_type['type'];
			}
			switch($_type)
			{
				case 'xmlrpc':
					$xml_functions = Array(
						'list_methods' => Array(
							'function'  => 'list_methods',
							'signature' => Array(
								Array(
									xmlrpcStruct,
									xmlrpcString
								)
							),
							'docstring' => lang('Read this list of methods.')
 						),
						'get_appbyid' => Array(
							'function'  => 'get_appbyid',
							'signature' => Array(
								Array(
									xmlrpcStruct,
									xmlrpcString
								)
							),
							'docstring' => lang('Read a single app by id.')
						),
						'get_appbyname' => Array(
							'function'  => 'get_appbyname',
							'signature' => Array(
								Array(
									xmlrpcStruct,
									xmlrpcString
								)
							),
							'docstring' => lang('Read a single app by name.')
						),
						'find_new_app' => Array(
							'function'  => 'find_new_app',
							'signature' => Array(
								Array(
									xmlrpcStruct,
									xmlrpcStruct
								)
							),
							'docstring' => lang('compare an array of apps/versions against the repository and return new/updated list of apps.')
						)
					);
					return $xml_functions;
					break;
				case 'soap':
					return $this->soap_functions;
					break;
				default:
					return array();
					break;
			}
		}

		function request($method, $args)
		{
			$msg = CreateObject('phpgwapi.xmlrpcmsg',$method,$args);
			$resp = $this->client->send($msg);
			if (!$resp)
			{
				echo '<p>IO error: '.$this->client->errstr.'</p>';
				$GLOBALS['phpgw']->common->phpgw_exit();
			}
			if ($resp->faultCode())
			{
				echo '<p>There was an error: '.$resp->faultCode().' '.$resp->faultString().'</p>';
				$GLOBALS['phpgw']->common->phpgw_exit();
			}
			return xmlrpc_decode($resp->value());
		}

		function request_appbyid($appid)
		{
			if(is_object($this->is))
			{
				return $this->is->send('system.get_appbyid',$appid,$this->is->server['server_url']);
			}
			else
			{
				return $this->request('phpgwapi.app_registry.get_appbyid',$appid);
			}
		}


		function request_appbyname($app_name)
		{
			if(is_object($this->is))
			{
				return $this->is->send('system.get_appbyname',$app_name,$this->is->server['server_url']);
			}
			else
			{
				return $this->request('phpgwapi.app_registry.get_appbyname',$app_name);
			}
		}

		function request_newer_applist($dummy='')
		{
			$this->db->query('SELECT * FROM phpgw_applications',__LINE__,__FILE__);
			while($this->db->next_record())
			{
				$app_list[$this->db->f('app_id')] = Array(
					'id'      => $this->db->f('app_id'),
					'version' => $this->db->f('app_version')
				);
			}
		
			if(is_object($this->is))
			{
				return $this->is->send('system.find_new_app',$app_list,$this->is->server['server_url']);
			}
			else
			{
				return $this->request('phpgwapi.app_registry.find_new_app',$app_list);
			}
		}

		function get_result()
		{
			switch($this->db->num_rows())
			{
				case 0:
					$app[] = CreateObject('phpgwapi.xmlrpcval',CreateObject('phpgwapi.xmlrpcval',False,'boolean'),'boolean');
					break;
				case 1:
					$this->db->next_record();
					$app[] = CreateObject('phpgwapi.xmlrpcval',
						Array(
							'id'      => CreateObject('phpgwapi.xmlrpcval',$this->db->f('app_id'),'int'),
							'name'    => CreateObject('phpgwapi.xmlrpcval',$this->db->f('app_name'),'string'),
							'title'   => CreateObject('phpgwapi.xmlrpcval',$this->db->f('app_title'),'string'),
							'version' => CreateObject('phpgwapi.xmlrpcval',$this->db->f('app_version'),'string'),
							'tables'  => CreateObject('phpgwapi.xmlrpcval',$this->db->f('app_tables'),'string')
						),
						'struct'
					);
					break;
				default:
					while($this->db->next_record())
					{
						$app[] = CreateObject('phpgwapi.xmlrpcval',
								Array(
									'id'      => CreateObject('phpgwapi.xmlrpcval',$this->db->f('app_id'),'int'),
									'name'    => CreateObject('phpgwapi.xmlrpcval',$this->db->f('app_name'),'string'),
									'title'   => CreateObject('phpgwapi.xmlrpcval',$this->db->f('app_title'),'string'),
									'version' => CreateObject('phpgwapi.xmlrpcval',$this->db->f('app_version'),'string'),
									'tables'  => CreateObject('phpgwapi.xmlrpcval',$this->db->f('app_tables'),'string')
								),
								'struct'
						);
					}
					break;
			}
			return CreateObject('phpgwapi.xmlrpcresp',CreateObject('phpgwapi.xmlrpcval',$app, 'struct'));
		}

//		function get_result()
//		{
//			switch($this->db->num_rows())
//			{
//				case 0:
//					$app = False;
//					break;
//				case 1:
//					$this->db->next_record();
//					$app = Array(
//						'id'      => $this->db->f('app_id'),
//						'name'    => $this->db->f('app_name'),
//						'title'   => $this->db->f('app_title'),
//						'version' => $this->db->f('app_version'),
//						'tables'  => $this->db->f('app_tables')
//					);
//					break;
//				default:
//					while($this->db->next_record())
//					{
//						$app[] = Array(
//							'id'      => $this->db->f('app_id'),
//							'name'    => $this->db->f('app_name'),
//							'title'   => $this->db->f('app_title'),
//							'version' => $this->db->f('app_version'),
//							'tables'  => $this->db->f('app_tables')
//						);
//					}
//					break;
//			}
//			return $app;
//		}

		function get_appbyid($app_id)
		{
			$this->db->query('SELECT * FROM phpgw_applications WHERE app_id='.$app_id,__LINE__,__FILE__);
			return $this->get_result();
		}

		function get_appbyname($app_name)
		{
			$this->db->query("SELECT * FROM phpgw_applications WHERE app_name='".$app_name."'",__LINE__,__FILE__);
			return $this->get_result();
		}

		function get_allapps()
		{
			$this->db->query('SELECT * FROM phpgw_applications',__LINE__,__FILE__);
			return $this->get_result();
		}

		function find_new_app($apps)
		{
			$this->db->query('SELECT * FROM phpgw_applications',__LINE__,__FILE__);
			while($this->db->next_record())
			{
				$app[$this->db->f('app_id')] = Array(
					'id'      => $this->db->f('app_id'),
					'name'    => $this->db->f('app_name'),
					'title'   => $this->db->f('app_title'),
					'version' => $this->db->f('app_version'),
					'tables'  => $this->db->f('app_tables')
				);
			}
			@reset($apps);
			while($apps && list($id,$application) = each($apps))
			{
				if($app[$id])
				{
					if($app[$id]->version == $application->version)
					{
						unset($app[$id]);
					}
				}
			}
			@reset($app);
			while($app && list($id,$application) = each($app))
			{
				$updated_app[$id] = CreateObject('phpgwapi.xmlrpcval',
					Array(
						'id'      => CreateObject('phpgwapi.xmlrpcval',$id,'int'),
						'name'    => CreateObject('phpgwapi.xmlrpcval',$application->name,'string'),
						'title'   => CreateObject('phpgwapi.xmlrpcval',$application->title,'string'),
						'version' => CreateObject('phpgwapi.xmlrpcval',$application->version,'string'),
						'tables'  => CreateObject('phpgwapi.xmlrpcval',$application->tables,'string')
					),
					'struct'
				);
			}
			return CreateObject('phpgwapi.xmlrpcresp',CreateObject('phpgwapi.xmlrpcval',$updated_app, 'struct'));
		}
	}
?>