X-Git-Url: http://git.roojs.org/?p=Pman.Core;a=blobdiff_plain;f=DataObjects%2FCore_setting.php;h=05816c4e578f50c9626c7678f136cd001943be19;hp=5e3b6a9ae226e80664331312d89c31e9377b243f;hb=5754135335377a4fc49d2295d9f8cb768c451df9;hpb=7289b72545305828882a1b69b8c1c01a75ae82a6 diff --git a/DataObjects/Core_setting.php b/DataObjects/Core_setting.php index 5e3b6a9a..05816c4e 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,43 +34,127 @@ 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; + 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; } - $val = $a['val']; - if(!isset($a['is_encrypt']) || $a['is_encrypt'] == 1) { - $val = encrypt($val); - } + $this->initKeys(); + + $c = $this->lookup($a['module'], $a['name']); + + $o = $c ? clone($c) : false; + + $c = $c ? $c : DB_DataObject::factory('core_setting'); + + $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 + )); - return; + $o ? $c->update($o) : $c->insert(); } - function encrypt($v) { + //one key for encrypting all the settings + function encrypt($v) + { + $key_dir = "{$this->getKeyDirectory()}/pub.key"; + + if(!file_exists($key_dir)) { + print_r("Cannot find {$key_dir}"); + exit; + } + $pub_key = file_get_contents($key_dir); + if(!$pub_key) { + return; + } + openssl_public_encrypt($v, $ciphertext, $pub_key); + return $ciphertext; } + function getDecryptVal() + { + $dir = $this->getKeyDirectory(); + + if(!$dir) { + return false; + } + + if(empty($this->val)) { + return false; + } + + if(empty($this->is_encrypt)) { + return $this->val; + } + + $key_dir = "{$dir}/pri.key"; + + if(!file_exists($key_dir)) { + return false; + } + + $pri_key = file_get_contents($key_dir); + + if(!$pri_key) { + return false; + } + + openssl_private_decrypt($this->val, $plaintext, $pri_key); + + return $plaintext; + } }