org.netfrag.flib/Tracker/User.php

<?
/**
 * This file contains the Tracker::User module.
 *
 * @author Andreas Motl <andreas.motl@ilo.de>
 * @package org.netfrag.flib
 * @name Tracker::User
 *
 */


//    -----------------------------------------------------------------------------
//    $Id: User.php,v 1.12 2003/03/03 21:20:47 joko Exp $
//    -----------------------------------------------------------------------------
//    $Log: User.php,v $
//    Revision 1.12  2003/03/03 21:20:47  joko
//    mungled the namespaces
//
//    Revision 1.11  2003/02/14 14:22:06  joko
//    + always (re-)tries to connect
//
//    Revision 1.10  2003/02/13 21:58:39  joko
//    + caching mechanisms more configurable now
//
//    Revision 1.9  2003/02/09 17:46:26  joko
//    + now utilizing DesignPattern::RemoteProxy and Data::Deep
//
//    Revision 1.8  2002/12/28 01:16:42  jonen
//    + added clear of $this->state[autologout] at 'hadTimeout()'
//
//    Revision 1.7  2002/12/23 11:32:28  jonen
//    + added inserting of uservars on '_create' to frontend db(needed to login user after create!)
//      + added hard link to page 'pub/register', TODO: move this out here
//
//    Revision 1.6  2002/12/18 22:46:06  jonen
//    + added function 'getUserGuid()'
//       (returns user's 'guid' read from database at function 'login()'  (now))
//    + function '_loadData()' loads user remote now via 'getUserGuid()'
//
//    Revision 1.5  2002/12/12 21:34:32  joko
//    + fix in 'function update': invalidate data only if it's not for caching purposes
//
//    Revision 1.4  2002/12/06 04:10:28  joko
//    + replaced 'xyzCache' through 'xyzProxy'
//
//    Revision 1.3  2002/12/04 07:42:54  jonen
//    + changes according to backend schema change
//
//    Revision 1.2  2002/12/03 16:47:22  joko
//    - function preLogout()
//    + function preLogout($autologout = 0)
//    + function hadTimeout()
//
//    Revision 1.1  2002/11/12 05:42:31  joko
//    + initial checkin
//
//    Revision 1.7  2002/10/29 19:09:53  cvsjoko
//    + function getLastLogin
//    + function getUserId
//
//    Revision 1.6  2002/10/25 11:18:10  cvsmax
//    - removed old functions ('logout', 'create',...)
//    + add function preLogout()        # save user session and unset (session) state
//
//    Revision 1.5  2002/10/22 09:47:48  cvsmax
//    + add new
//      - function create()             # create & save new user-object in session
//      - function _create($attr)       # create & save new user-object in backend
//
//    - purged some very old functions
//
//    Revision 1.4  2002/10/17 03:12:17  cvsmax
//    -(+) cleaned code from old structure
//      + function getPostVar($fieldname)
//
//    Revision 1.3  2002/10/10 02:41:57  cvsjoko
//    + fixed typo
//
//    Revision 1.2  2002/10/10 02:34:33  cvsjoko
//    + new level of data-caching (session and persistant)
//        + function _save()
//        + function save()
//    + handling (storing/caching) of POSTed data
//        + function getPostVars()
//        + function setPostVars()
//    + handy utils
//        + function doDataReady()  cares for ready data to continue working
//        + function refresh()           clears underlying data container and makes data "unready"
//
//    Revision 1.1  2002/10/09 00:40:13  cvsjoko
//    + new
//
//
//    -----------------------------------------------------------------------------


/**
 * This is the User class.
 *
 * @author Andreas Motl <andreas.motl@ilo.de>
 * @package org.netfrag.flib
 * @name Tracker::User
 *
 */
class User {
  
  var $state;
  var $meta;
  
  var $pObject;
  var $data;
  
  
  function User() {

    // attention:
    // this code is only run when your session is _really_ fresh
    if (session_register_safe('userstate')) {
    }

    $this->_loadState();
    $this->meta[logontoken] = 'k&%g2';

    // print dumpVar($_SESSION);

  }

  function _loadState() {
    global $userstate;
    $this->state = $userstate;
  }
  function _saveState() {
    global $userstate;
    $userstate = $this->state;
  }


  function _loadData() {
    $this->meta[data_ready] = 1;
    //$this->pObject = new ProxyObject($this->getUserGuid(), array( remote => 1, classname => "NetPerson", guid => 1) );
    $rpcinfo = $this->site->configuration->get("rpcinfo");
    $this->pObject = mkObject('DesignPattern::RemoteProxy', $this->getUserGuid(), array( remote => 1, classname => "NetPerson", guid => 1, rpcinfo => $rpcinfo, cache => array( db => 1, session => 1 ), connect => 1 ) );
    if ($this->getUserGuid()) {
      $this->data = $this->pObject->getResult();
    }
  }

  function _saveData($newRawData) {

    foreach ($newRawData as $key => $val) {
      //print "$key => $val<br>";
      $this->set($key, $val);
    }

    $this->_save("cache");
    
    //$this->pObject->flushProxy();     // done in "pObject->save"
    
  }
  
  function _save($type = '') {
//print Dumper($this->data);
    $this->pObject->save($this->data, $type);
    // invalidate data only if it's not for caching purposes
    if ($type != 'cache') {
      $this->meta[data_ready] = 0;
    }
  }
  
  function save() {
    $this->_doDataReady();
    $this->_save("commit");
  }
  
  function create() {
   $this->_save();
   $attr = $this->pObject->getAttributes();
   //print DumpVar($attr);
   $this->_create($attr);
  }

  function _create($result) {
    //print "saving to backend: " . dumpVar($result) . "<br>";
    $response = $this->pObject->backend->send('createUser', array('data' => $result) );
    $objectId = $response[oid];
    if($objectId) {
        connectdb();
        $guid = $response[guid];
        $username = $this->get('userData.username');
        $password = $this->get('userData.password');
        $sql = "INSERT into td_users VALUES ( '$objectId', '$guid', '', '$username', '$password','' )";
            $res = send_sql($sql);
          }
          else {
            // TODO: handle this with a generic rpc-debug/pending function
      $site->session->set('register_error', 'rpc_error');
      $site->redirect( getlink('/pub/register/') );
          }
    //$this->_init($objectId);
  }

  function get($attr) {
    $this->_doDataReady();
    $deep = new Data_Deep($this->data);
    return $deep->get($attr);
  }
  function set($attr, $val) {
    $this->_doDataReady();
    $deep = new Data_Deep($this->data);
    $deep->set($attr, $val);
  }
  
  function isLoggedOn() {
    if ($this->state[id] && $this->state[status] == $this->meta[logontoken]) {
      return 1;
    }
  }
  

  //===== function userlogin =========================
  function login($user,$passwd) {
        connectdb();
        //$sql = "SELECT * FROM td_users WHERE uname='$user'";
        $sql = "SELECT user_oid, guid, uname, pass FROM td_users WHERE uname='$user'";
        if ($res=send_sql($sql)) {
                $row = mysql_fetch_array($res,MYSQL_ASSOC);
                if (!is_array($row)) { return 0; }
        }
        if ($row[pass] == $passwd) {
      //return $uservars_db;
      // store 1st priority user-data to state
        $this->state[id] = $row[user_oid];
        $this->state[guid] = $row[guid];
        $this->state[status] = $this->meta[logontoken];
        $this->_saveState();
      $this->site->log( get_class($this) . "->login ok", PEAR_LOG_NOTICE );
      return 1;
    } else { 
      return 0; 
    }
}

  function exists($string) {
        connectdb();
        $sql = "SELECT uname FROM td_users WHERE uname='$string'";
        if ($res=send_sql($sql)) {
                $row = mysql_fetch_array($res,MYSQL_ASSOC);

                if (is_array($row)) {
          return 1;
                }
        }

  }
  

  function update($vars) {
    $this->setPostVars($vars);
//print Dumper($vars);
    $data = $this->_transformInputData($vars);
    $this->_saveData($data);
  }
 
  function _transformInputData(&$uservars) {
    global $def_mapping;
    $mapping_uservars2data = array_flip($def_mapping[data2uservars]);
    foreach ($uservars as $key => $val) {
      $key_target = $mapping_uservars2data[$key];
      if($key_target != '') {
        //print "$key => $key_target: $val<br>";
        $target[$key_target] = $val;
      }
    }
    return $target;
  }

  function logout() {

    global $site;

    // get information about user from site
      $userid = $this->getUserId();

      $this->site->log( get_class($this) . "->logout: userid $userid", PEAR_LOG_NOTICE );
    
    // get information about session from php
      $session_id = session_id();
      $session_name = session_name();

    // session-sqldb related
      $date = date('Y-m-d H:i:s', time());
      $session_e = $site->session->exists($session_id);
      $sql = "UPDATE f_map_user_session SET date_logged_out='$date' WHERE session_uid='$session_e[session_uid]' AND user_uid='$userid'";
      $res = send_sql($sql);

    // destroy user's session at server-side
      $session_name = session_name();
      session_destroy();

    // overwrite session-variables - to be sure ;)
      $_SESSION = array();
      unset($_COOKIE[$session_name]);

  }

  function preLogout($autologout = 0) {
    global $site;
    $this->state[status] = '';
    $this->state[autologout] = $autologout;
    $this->_saveState();
  }

  function getAccountSum() {
    // store additional user-data to state
      if (!$this->state[accountSum]) {
        $this->state[accountSum] = $this->get("account.amount");
        $this->_saveState();
      }
      return $this->state[accountSum];
  }

  function getAccountCurrency() {
    // store additional user-data to state
      if (!$this->state[accountCurrency]) {
        $this->state[accountCurrency] = $this->get("account.currency");
        $this->_saveState();
      }
      //print "state: " . $this->get("financeInfo.currency") . "<br>";
      return $this->state[accountCurrency];
  }
  
  function refresh() {
    if ($this->pObject) {$this->pObject->flushState();}
    $this->meta[data_ready] = 0;
  }
  
  function _doDataReady() {
    if (!$this->meta[data_ready]) { $this->_loadData(); }
  }

  function getLastLogin() {
    $userid = $this->getUserId();
    connectdb();
    $sql = "SELECT * FROM f_map_user_session WHERE user_uid='$userid' AND last='1'";
    $res = send_sql($sql);
    while($row = mysql_fetch_array($res,MYSQL_BOTH)) {
      if($row[date_logged_out]=="0000-00-00 00:00:00") { 
        $date = $row[date_logged_in];
      } else { 
        $date = $row[date_logged_out];
      }
      $lastLogin = strftime("%d %b %Y - %H:%M",strtotime($date));
    }
    return $lastLogin;
  }
  
  function getUserId() {
    return $this->state[id];
  }

  function getUserGuid() {
    return $this->state[guid];
  }

  function getPostVars() {
    return $this->state[postvars];
  }

  function setPostVars($postvars) {
    $this->state[postvars] = $postvars;
    $this->_saveState();
  }

  function getPostVar($var) {
    return $this->state[postvars][$var];
  }
  
  function hadTimeout() {
    if ($this->state[autologout]) { $this->state[autologout] = ''; return 1; }
  }

}

?>
1	joko	1.1	<?
2	joko	1.13	/**
3			* This file contains the Tracker::User module.
4			*
5			* @author Andreas Motl <andreas.motl@ilo.de>
6			* @package org.netfrag.flib
7			* @name Tracker::User
8			*
9			*/
10
11
12	joko	1.1	// -----------------------------------------------------------------------------
13	joko	1.13	// $Id: User.php,v 1.12 2003/03/03 21:20:47 joko Exp $
14	joko	1.1	// -----------------------------------------------------------------------------
15	joko	1.2	// $Log: User.php,v $
16	joko	1.13	// Revision 1.12 2003/03/03 21:20:47 joko
17			// mungled the namespaces
18			//
19	joko	1.12	// Revision 1.11 2003/02/14 14:22:06 joko
20			// + always (re-)tries to connect
21			//
22	joko	1.11	// Revision 1.10 2003/02/13 21:58:39 joko
23			// + caching mechanisms more configurable now
24			//
25	joko	1.10	// Revision 1.9 2003/02/09 17:46:26 joko
26	joko	1.12	// + now utilizing DesignPattern::RemoteProxy and Data::Deep
27	joko	1.10	//
28	joko	1.9	// Revision 1.8 2002/12/28 01:16:42 jonen
29			// + added clear of $this->state[autologout] at 'hadTimeout()'
30			//
31	jonen	1.8	// Revision 1.7 2002/12/23 11:32:28 jonen
32			// + added inserting of uservars on '_create' to frontend db(needed to login user after create!)
33			// + added hard link to page 'pub/register', TODO: move this out here
34			//
35	jonen	1.7	// Revision 1.6 2002/12/18 22:46:06 jonen
36			// + added function 'getUserGuid()'
37			// (returns user's 'guid' read from database at function 'login()' (now))
38			// + function '_loadData()' loads user remote now via 'getUserGuid()'
39			//
40	jonen	1.6	// Revision 1.5 2002/12/12 21:34:32 joko
41			// + fix in 'function update': invalidate data only if it's not for caching purposes
42			//
43	joko	1.5	// Revision 1.4 2002/12/06 04:10:28 joko
44			// + replaced 'xyzCache' through 'xyzProxy'
45			//
46	joko	1.4	// Revision 1.3 2002/12/04 07:42:54 jonen
47			// + changes according to backend schema change
48			//
49	jonen	1.3	// Revision 1.2 2002/12/03 16:47:22 joko
50			// - function preLogout()
51			// + function preLogout($autologout = 0)
52			// + function hadTimeout()
53			//
54	joko	1.2	// Revision 1.1 2002/11/12 05:42:31 joko
55			// + initial checkin
56			//
57	joko	1.1	// Revision 1.7 2002/10/29 19:09:53 cvsjoko
58			// + function getLastLogin
59			// + function getUserId
60			//
61			// Revision 1.6 2002/10/25 11:18:10 cvsmax
62			// - removed old functions ('logout', 'create',...)
63			// + add function preLogout() # save user session and unset (session) state
64			//
65			// Revision 1.5 2002/10/22 09:47:48 cvsmax
66			// + add new
67			// - function create() # create & save new user-object in session
68			// - function _create($attr) # create & save new user-object in backend
69			//
70			// - purged some very old functions
71			//
72			// Revision 1.4 2002/10/17 03:12:17 cvsmax
73			// -(+) cleaned code from old structure
74			// + function getPostVar($fieldname)
75			//
76			// Revision 1.3 2002/10/10 02:41:57 cvsjoko
77			// + fixed typo
78			//
79			// Revision 1.2 2002/10/10 02:34:33 cvsjoko
80			// + new level of data-caching (session and persistant)
81			// + function _save()
82			// + function save()
83			// + handling (storing/caching) of POSTed data
84			// + function getPostVars()
85			// + function setPostVars()
86			// + handy utils
87			// + function doDataReady() cares for ready data to continue working
88			// + function refresh() clears underlying data container and makes data "unready"
89			//
90			// Revision 1.1 2002/10/09 00:40:13 cvsjoko
91			// + new
92			//
93			//
94			// -----------------------------------------------------------------------------
95
96	joko	1.13
97			/**
98			* This is the User class.
99			*
100			* @author Andreas Motl <andreas.motl@ilo.de>
101			* @package org.netfrag.flib
102			* @name Tracker::User
103			*
104			*/
105	joko	1.1	class User {
106
107			var $state;
108			var $meta;
109
110			var $pObject;
111			var $data;
112
113
114			function User() {
115
116			// attention:
117			// this code is only run when your session is _really_ fresh
118			if (session_register_safe('userstate')) {
119			}
120
121			$this->_loadState();
122			$this->meta[logontoken] = 'k&%g2';
123
124			// print dumpVar($_SESSION);
125
126			}
127
128			function _loadState() {
129			global $userstate;
130			$this->state = $userstate;
131			}
132			function _saveState() {
133			global $userstate;
134			$userstate = $this->state;
135			}
136
137
138			function _loadData() {
139	joko	1.9	$this->meta[data_ready] = 1;
140			//$this->pObject = new ProxyObject($this->getUserGuid(), array( remote => 1, classname => "NetPerson", guid => 1) );
141			$rpcinfo = $this->site->configuration->get("rpcinfo");
142	joko	1.12	$this->pObject = mkObject('DesignPattern::RemoteProxy', $this->getUserGuid(), array( remote => 1, classname => "NetPerson", guid => 1, rpcinfo => $rpcinfo, cache => array( db => 1, session => 1 ), connect => 1 ) );
143	jonen	1.6	if ($this->getUserGuid()) {
144	joko	1.13	$this->data = $this->pObject->getResult();
145	joko	1.1	}
146			}
147
148			function _saveData($newRawData) {
149
150			foreach ($newRawData as $key => $val) {
151			//print "$key => $val<br>";
152			$this->set($key, $val);
153			}
154
155			$this->_save("cache");
156
157	joko	1.4	//$this->pObject->flushProxy(); // done in "pObject->save"
158	joko	1.1
159			}
160
161			function _save($type = '') {
162	joko	1.5	//print Dumper($this->data);
163	joko	1.1	$this->pObject->save($this->data, $type);
164	joko	1.5	// invalidate data only if it's not for caching purposes
165			if ($type != 'cache') {
166			$this->meta[data_ready] = 0;
167			}
168	joko	1.1	}
169
170			function save() {
171			$this->_doDataReady();
172			$this->_save("commit");
173			}
174
175			function create() {
176			$this->_save();
177			$attr = $this->pObject->getAttributes();
178			//print DumpVar($attr);
179			$this->_create($attr);
180			}
181
182			function _create($result) {
183			//print "saving to backend: " . dumpVar($result) . "<br>";
184			$response = $this->pObject->backend->send('createUser', array('data' => $result) );
185			$objectId = $response[oid];
186	jonen	1.7	if($objectId) {
187			connectdb();
188			$guid = $response[guid];
189			$username = $this->get('userData.username');
190			$password = $this->get('userData.password');
191			$sql = "INSERT into td_users VALUES ( '$objectId', '$guid', '', '$username', '$password','' )";
192			$res = send_sql($sql);
193			}
194			else {
195			// TODO: handle this with a generic rpc-debug/pending function
196			$site->session->set('register_error', 'rpc_error');
197			$site->redirect( getlink('/pub/register/') );
198			}
199	joko	1.1	//$this->_init($objectId);
200			}
201
202			function get($attr) {
203			$this->_doDataReady();
204	joko	1.9	$deep = new Data_Deep($this->data);
205			return $deep->get($attr);
206	joko	1.1	}
207			function set($attr, $val) {
208			$this->_doDataReady();
209	joko	1.9	$deep = new Data_Deep($this->data);
210			$deep->set($attr, $val);
211	joko	1.1	}
212
213			function isLoggedOn() {
214			if ($this->state[id] && $this->state[status] == $this->meta[logontoken]) {
215			return 1;
216			}
217			}
218
219
220			//===== function userlogin =========================
221			function login($user,$passwd) {
222			connectdb();
223			//$sql = "SELECT * FROM td_users WHERE uname='$user'";
224	jonen	1.6	$sql = "SELECT user_oid, guid, uname, pass FROM td_users WHERE uname='$user'";
225	joko	1.1	if ($res=send_sql($sql)) {
226			$row = mysql_fetch_array($res,MYSQL_ASSOC);
227			if (!is_array($row)) { return 0; }
228			}
229			if ($row[pass] == $passwd) {
230			//return $uservars_db;
231			// store 1st priority user-data to state
232			$this->state[id] = $row[user_oid];
233	jonen	1.6	$this->state[guid] = $row[guid];
234	joko	1.1	$this->state[status] = $this->meta[logontoken];
235			$this->_saveState();
236	joko	1.9	$this->site->log( get_class($this) . "->login ok", PEAR_LOG_NOTICE );
237	joko	1.1	return 1;
238			} else {
239			return 0;
240			}
241			}
242
243			function exists($string) {
244			connectdb();
245			$sql = "SELECT uname FROM td_users WHERE uname='$string'";
246			if ($res=send_sql($sql)) {
247			$row = mysql_fetch_array($res,MYSQL_ASSOC);
248
249			if (is_array($row)) {
250			return 1;
251			}
252			}
253
254			}
255
256
257	joko	1.5	function update($vars) {
258			$this->setPostVars($vars);
259			//print Dumper($vars);
260			$data = $this->_transformInputData($vars);
261	joko	1.1	$this->_saveData($data);
262			}
263
264			function _transformInputData(&$uservars) {
265			global $def_mapping;
266			$mapping_uservars2data = array_flip($def_mapping[data2uservars]);
267			foreach ($uservars as $key => $val) {
268			$key_target = $mapping_uservars2data[$key];
269	jonen	1.7	if($key_target != '') {
270			//print "$key => $key_target: $val<br>";
271			$target[$key_target] = $val;
272			}
273	joko	1.1	}
274			return $target;
275			}
276
277			function logout() {
278
279			global $site;
280
281			// get information about user from site
282	jonen	1.6	$userid = $this->getUserId();
283	joko	1.1
284	joko	1.9	$this->site->log( get_class($this) . "->logout: userid $userid", PEAR_LOG_NOTICE );
285	joko	1.1
286			// get information about session from php
287			$session_id = session_id();
288			$session_name = session_name();
289
290			// session-sqldb related
291			$date = date('Y-m-d H:i:s', time());
292			$session_e = $site->session->exists($session_id);
293			$sql = "UPDATE f_map_user_session SET date_logged_out='$date' WHERE session_uid='$session_e[session_uid]' AND user_uid='$userid'";
294			$res = send_sql($sql);
295
296			// destroy user's session at server-side
297			$session_name = session_name();
298			session_destroy();
299
300			// overwrite session-variables - to be sure ;)
301			$_SESSION = array();
302			unset($_COOKIE[$session_name]);
303
304			}
305
306	joko	1.2	function preLogout($autologout = 0) {
307	joko	1.1	global $site;
308			$this->state[status] = '';
309	joko	1.2	$this->state[autologout] = $autologout;
310	joko	1.1	$this->_saveState();
311			}
312
313			function getAccountSum() {
314			// store additional user-data to state
315			if (!$this->state[accountSum]) {
316	jonen	1.3	$this->state[accountSum] = $this->get("account.amount");
317	joko	1.1	$this->_saveState();
318			}
319			return $this->state[accountSum];
320			}
321
322			function getAccountCurrency() {
323			// store additional user-data to state
324			if (!$this->state[accountCurrency]) {
325	jonen	1.3	$this->state[accountCurrency] = $this->get("account.currency");
326	joko	1.1	$this->_saveState();
327			}
328			//print "state: " . $this->get("financeInfo.currency") . "<br>";
329			return $this->state[accountCurrency];
330			}
331
332			function refresh() {
333			if ($this->pObject) {$this->pObject->flushState();}
334			$this->meta[data_ready] = 0;
335			}
336
337			function _doDataReady() {
338			if (!$this->meta[data_ready]) { $this->_loadData(); }
339			}
340
341			function getLastLogin() {
342			$userid = $this->getUserId();
343			connectdb();
344			$sql = "SELECT * FROM f_map_user_session WHERE user_uid='$userid' AND last='1'";
345			$res = send_sql($sql);
346			while($row = mysql_fetch_array($res,MYSQL_BOTH)) {
347			if($row[date_logged_out]=="0000-00-00 00:00:00") {
348			$date = $row[date_logged_in];
349			} else {
350			$date = $row[date_logged_out];
351			}
352			$lastLogin = strftime("%d %b %Y - %H:%M",strtotime($date));
353			}
354			return $lastLogin;
355			}
356
357			function getUserId() {
358			return $this->state[id];
359			}
360
361	jonen	1.6	function getUserGuid() {
362			return $this->state[guid];
363			}
364	joko	1.1
365			function getPostVars() {
366			return $this->state[postvars];
367			}
368
369			function setPostVars($postvars) {
370			$this->state[postvars] = $postvars;
371			$this->_saveState();
372			}
373
374			function getPostVar($var) {
375			return $this->state[postvars][$var];
376			}
377
378	joko	1.2	function hadTimeout() {
379	jonen	1.8	if ($this->state[autologout]) { $this->state[autologout] = ''; return 1; }
380	joko	1.2	}
381	joko	1.1
382			}
383
384			?>
MailToCvsAdmin">MailToCvsAdmin	ViewVC Help
Powered by ViewVC 1.1.26