X-Git-Url: http://git.roojs.org/?p=Pman.Core;a=blobdiff_plain;f=DataObjects%2FCore_setting.php;h=97ec8bd3742a1f88bc0646132f2a02af0931bb29;hp=9721062f7b211725cf5178a9cc62c5d47bdf3326;hb=HEAD;hpb=6f2cb5aea1e600c1d3c3ca00a036aa28aed43bad diff --git a/DataObjects/Core_setting.php b/DataObjects/Core_setting.php index 9721062f..e1eea761 100644 --- a/DataObjects/Core_setting.php +++ b/DataObjects/Core_setting.php @@ -6,15 +6,20 @@ class Pman_Core_DataObjects_Core_setting extends DB_DataObject { public $__table = 'core_setting'; - function initKeys($dir) + function initKeys() { - //reject when keys exist + // return false when fail + $dir = $this->getKeyDirectory(); + + if(!$dir) { + return false; // only fail case? + } + if( - !file_exists($dir) || file_exists("{$dir}/pub.key") || file_exists("{$dir}/pri.key") ){ - return; + return true; } $ssl = openssl_pkey_new(array( @@ -29,51 +34,130 @@ class Pman_Core_DataObjects_Core_setting extends DB_DataObject file_put_contents("{$dir}/pub.key",$pub_key); file_put_contents("{$dir}/pri.key",$pri_key); + + return true; } - function getSetting($m,$n) + function lookup($m,$n) { $s = DB_DataObject::factory('core_setting'); $s->setFrom(array( - 'module' => $q['module'], - 'name' => $q['name'] + 'module' => $m, + 'name' => $n )); + if($s->find(true)) { return $s; } + return false; } function beforeInsert($q, $roo) { - return; + if (isset($q['is_encrypt'])) { + $roo->jerr("no direct access for setting encrypted data at present?"); + } + // we store column data in here now - so it has to be insertable. + //exit; } + function getKeyDirectory() + { + $client_dir = HTML_FlexyFramework::get()->Pman['storedir']; + + $key_dir = $client_dir.'/keys'; + + if(file_exists($key_dir)) { + return $key_dir; + } + + if(!is_writable($key_dir)) { + return false; + } + + mkdir($key_dir, 0755, true); + + return $key_dir; + } + + // FIXME - this needs to go in beforeInsert/beforeUpdate + // should not be sending this the values.. function initSetting($a) { if(empty($a)) { return; } - //check setting exist - $c = $this->getSetting($a['module'], $a['name']); - if($c) { - return; - } + $this->initKeys(); + + $c = $this->lookup($a['module'], $a['name']); + $o = $c ? clone($c) : false; + $c = $c ? $c : DB_DataObject::factory('core_setting'); - $val = $a['val']; - if(!isset($a['is_encrypt']) || $a['is_encrypt'] == 1) { - $val = encrypt($val); + $c->setFrom(array( + 'module' => $a['module'], + 'name' => $a['name'], + 'description' => $a['description'], + 'val' => (!isset($a['is_encrypt']) || $a['is_encrypt'] == 1) ? + $this->encrypt($a['val']) : $a['val'], + 'is_encrypt' => isset($a['is_encrypt']) ? $a['is_encrypt'] : 1, + 'is_valid' => 1 + )); + + $o ? $c->update($o) : $c->insert(); + } + + //one key for encrypting all the settings + function encrypt($v) + { + $key_dir = "{$this->getKeyDirectory()}/pub.key"; + + if(!file_exists($key_dir)) { + return false; } - return; + $pub_key = file_get_contents($key_dir); + if(!$pub_key) { + return false; + } + openssl_public_encrypt($v, $ciphertext, $pub_key); + return $ciphertext; } - function encrypt($v) { + function decrypt($v) + { + $key_dir = "{$this->getKeyDirectory()}/pri.key"; + + if(!file_exists($key_dir)) { + return false; + } + + $pri_key = file_get_contents($key_dir); + if(!$pri_key) { + return false; + } + + openssl_private_decrypt($v, $plaintext, $pri_key); + + return $plaintext; } + function getDecryptVal() + { + + if(empty($this->val)) { + return false; + } + + if(empty($this->is_encrypt)) { + return $this->val; + } + + return $this->decrypt($this->val); + } }