X-Git-Url: http://git.roojs.org/?p=Pman.Core;a=blobdiff_plain;f=Lock.php;h=b0e7ea9a2c05f14b13dd6e4ca26feb2eb1ed77be;hp=1c35584b4e2676b6480090760f585b1330c3cdaf;hb=8cd2a9237c684aa16bc21e3ac6d3793c49c65400;hpb=b16c129c0824668cd9b0c55eb830b12807ef646f diff --git a/Lock.php b/Lock.php index 1c35584b..b0e7ea9a 100644 --- a/Lock.php +++ b/Lock.php @@ -1,6 +1,36 @@ post($action); + // + $this->jerr("invalid request"); + } + + function post($action) + { + + // default action is to attempt to lock.. + $action = empty($action) || $action == 'lock' ? 'lock' : 'unlock'; + $this->$action(); + + } + + function unlock() + { + + if (empty($_REQUEST['id'])) { + $this->jerr("No lock id"); + } + $curlock = DB_DataObject::factory('core_locking'); + if (!$curlock->get($_REQUEST['id'])) { + $this->jok("No lock exists"); // been deleted before.. probably ok.. + } + + if ($curlock->person_id != $this->authUser->id) { + // this is an error conditon.. + $this->jerr("Lock id is invalid"); + } + + $curlock->delete(); + + $this->jok('unlocked'); + } + function lock() + { + + if (empty($_REQUEST['on_id']) || empty($_REQUEST['on_table'])) { + $this->jerr("Missing table or id"); + } + + $tab = str_replace('/', '', strtolower($_REQUEST['on_table'])); // basic protection?? + $x = DB_DataObject::factory($tab); + if (!$x->get($_REQUEST['on_id'])) { + $this->jerr("Item does not exist"); + } + // is there a current lock on the item.. + + $curlock = DB_DataObject::factory('core_locking'); + $curlock->setFrom(array( + 'on_id' => $_REQUEST['on_id'], + 'on_table' => strtolower($_REQUEST['on_table']) + )); + + // remove old locks.. + $llc = clone($curlock); + $exp = date('Y-m-d', strtotime('NOW - 1 WEEK')); + $llc->whereAdd("created < '$exp'"); + if ($llc->count()) { + $llc->find(); + while($llc->fetch()) { + $llcd = clone($llc); + $llcd->delete(); + + } + } + + + $curlock_ex = clone($curlock); + $curlock->person_id = $this->authUser->id; + + + $curlock_ex->whereAdd('person_id != '. $this->authUser->id); + $nlocks = $curlock_ex->count() ; + + $ret = false; + + if ($nlocks && empty($_REQUEST['force'])) { + // DB_DataObjecT::debugLevel(1); + $ar = $curlock_ex->fetchAll('person_id', 'created'); + $p = DB_DataObject::factory('core_person'); + $p->selectAdd(); + $p->selectAdd('id,name,email'); + + $p->whereAddIn('id', array_keys($ar), 'int'); + $p->find(); + $ret = array(); + while ($p->fetch()) { + $ret[$p->id] = $p->toArray(); + $ret[$p->id]['lock_created'] = $ar[$p->id]; + } + $this->jok(array_values($ret)); + + } + // trash the lock if it belongs to current user.. + $ulocks = $curlock->count(); + if ($ulocks) { + // trash all the locks.. + $curlock = DB_DataObject::factory('core_locking'); + $curlock->setFrom(array( + 'on_id' => $_REQUEST['on_id'], + 'on_table' => strtolower($_REQUEST['on_table']), + 'person_id' => $this->authUser->id + )); + + $curlock->find(); + while($curlock->fetch()) { + $cc =clone($curlock); + $cc->delete(); + } + } + if ($nlocks && !empty($_REQUEST['force'])) { + // user has decied to delete eveyone elses locks.. + $curlock_ex->find(); + while($curlock_ex->fetch()) { + $cc =clone($curlock_ex); + $cc->delete(); + } + } + + + // make a lock.. + + $curlock = DB_DataObject::factory('core_locking'); + $curlock->setFrom(array( + 'on_id' => $_REQUEST['on_id'], + 'on_table' => strtolower($_REQUEST['on_table']), + 'created' => date('Y-m-d H:i:s'), + 'person_id' => $this->authUser->id, + )); + $id = $curlock->insert(); + $this->jok( $id); + + } + + + + } \ No newline at end of file