1
0
Fork 0
mirror of https://github.com/archtechx/tenancy.git synced 2026-02-04 21:24:04 +00:00

finish writing storage driver

This commit is contained in:
Samuel Štancl 2019-08-09 23:03:18 +02:00
parent fd0712e037
commit fc76da38cb
2 changed files with 54 additions and 17 deletions

View file

@ -53,27 +53,12 @@ class DatabaseStorageDriver implements StorageDriver
public function get(string $uuid, string $key) public function get(string $uuid, string $key)
{ {
$tenant = Tenant::find($uuid); return Tenant::find($uuid)->get($key);
return $tenant->$key ?? json_decode($tenant->data)[$key] ?? null;
} }
public function getMany(string $uuid, array $keys): array public function getMany(string $uuid, array $keys): array
{ {
// todo move this logic to the model? return Tenant::getMany($keys);
$tenant = Tenant::find($uuid);
$tenant_data = null; // cache - json_decode() can be expensive
$get_from_tenant_data = function ($key) use ($tenant, &$tenant_data) {
$tenant_data = $tenant_data ?? json_decode($tenant->data);
return $tenant_data[$key] ?? null;
};
return array_reduce($keys, function ($keys, $key) use ($tenant, $get_from_tenant_data) {
$keys[$key] = $tenant->$key ?? $get_from_tenant_data($key) ?? null;
return $keys;
}, []);
} }
public function put(string $uuid, string $key, $value) public function put(string $uuid, string $key, $value)

View file

@ -10,6 +10,58 @@ class Tenant extends Model
protected $specialColumns = []; protected $specialColumns = [];
protected $guarded = []; protected $guarded = [];
/**
* Decoded data from the data column.
*
* @var object
*/
private $dataObject;
/**
* Get data from the data column.
*
* @param string $key
* @return mixed
*/
public function getFromData(string $key)
{
$this->dataObject = $this->dataObject ?? json_decode($this->{$this->dataColumn});
return $this->dataObject->$key;
}
/**
* Get data from tenant storage.
*
* @param string $key
* @return mixed
*/
public function get(string $key)
{
return $this->$key ?? $this->getFromData($key) ?? null;
}
/**
* Get multiple values from tenant storage.
*
* @param array $keys
* @return array
*/
public function getMany(array $keys): array
{
return array_reduce($keys, function ($keys, $key) {
$keys[$key] = $this->get($key);
return $keys;
}, []);
}
/**
* Put data into tenant storage.
*
* @param string $key
* @param mixed $value
* @return mixed
*/
public function put(string $key, $value) public function put(string $key, $value)
{ {
if (array_key_exists($key, $this->specialColumns)) { if (array_key_exists($key, $this->specialColumns)) {