Compare commits
31
Commits
3770dd6d9b
...
v0.1.0
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
3b6da45b01 | ||
|
|
b7260b5199 | ||
|
|
1f29622914 | ||
|
|
eb882db0c8 | ||
|
|
9ba43e3f25 | ||
|
|
54e96ba4bb | ||
|
|
9027f36748 | ||
|
|
2ae9ef39f3 | ||
|
|
ee0db0307e | ||
|
|
44cbe6bbdc | ||
|
|
31728af351 | ||
|
|
4845d14ef5 | ||
|
|
aca4e732ed | ||
|
|
f475c9125f | ||
|
|
4fe7314389 | ||
|
|
1f366830bc | ||
|
|
15df7c8d96 | ||
|
|
b8dd1fd0f6 | ||
|
|
83c80bd4ab | ||
|
|
b13c07d3c4 | ||
|
|
b95747bfe0 | ||
|
|
01c5eceeb4 | ||
|
|
ee9c109ed9 | ||
|
|
7eed69725d | ||
|
|
e37035eed8 | ||
|
|
5312e5060e | ||
|
|
3c9db3ac53 | ||
|
|
2b5d19ecd5 | ||
|
|
53e862d126 | ||
|
|
b6baeef32f | ||
|
|
159da01d5c |
+119
-75
@@ -23,11 +23,6 @@ use ReflectionProperty;
|
|||||||
#[AllowDynamicProperties]
|
#[AllowDynamicProperties]
|
||||||
class Model
|
class Model
|
||||||
{
|
{
|
||||||
/**
|
|
||||||
* @var array Attributes that should be set to NULL on update.
|
|
||||||
*/
|
|
||||||
protected array $dbSetToNull = [];
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @var string The name of the primary key column.
|
* @var string The name of the primary key column.
|
||||||
*/
|
*/
|
||||||
@@ -36,7 +31,7 @@ class Model
|
|||||||
/**
|
/**
|
||||||
* @var array Attributes to ignore when saving to the database.
|
* @var array Attributes to ignore when saving to the database.
|
||||||
*/
|
*/
|
||||||
protected static array $dbIgnoreSave = ['id'];
|
protected static array $dbIgnoreSave = [];
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @var array Attributes that should be explicitly saved, even if private/protected.
|
* @var array Attributes that should be explicitly saved, even if private/protected.
|
||||||
@@ -161,7 +156,19 @@ class Model
|
|||||||
|
|
||||||
try {
|
try {
|
||||||
$prepared = $db->prepare($query);
|
$prepared = $db->prepare($query);
|
||||||
$prepared->execute(static::$dbQueryVariables);
|
foreach (static::$dbQueryVariables as $key => $value) {
|
||||||
|
// Detect data type to choose the PDO constant
|
||||||
|
$type = match (gettype($value)) {
|
||||||
|
'integer' => PDO::PARAM_INT,
|
||||||
|
'boolean' => PDO::PARAM_BOOL,
|
||||||
|
'NULL' => PDO::PARAM_NULL,
|
||||||
|
default => PDO::PARAM_STR,
|
||||||
|
};
|
||||||
|
|
||||||
|
$prepared->bindValue($key, $value, $type);
|
||||||
|
}
|
||||||
|
|
||||||
|
$prepared->execute();
|
||||||
} catch (PDOException $e) {
|
} catch (PDOException $e) {
|
||||||
if ($db->inTransaction()) {
|
if ($db->inTransaction()) {
|
||||||
$db->rollBack();
|
$db->rollBack();
|
||||||
@@ -169,6 +176,10 @@ class Model
|
|||||||
|
|
||||||
$vars = json_encode(static::$dbQueryVariables);
|
$vars = json_encode(static::$dbQueryVariables);
|
||||||
|
|
||||||
|
if ($resetQuery) {
|
||||||
|
static::resetQuery();
|
||||||
|
}
|
||||||
|
|
||||||
throw new Exception(
|
throw new Exception(
|
||||||
"\nError at query to database.\n" .
|
"\nError at query to database.\n" .
|
||||||
"Query: $query\n" .
|
"Query: $query\n" .
|
||||||
@@ -289,22 +300,20 @@ class Model
|
|||||||
*/
|
*/
|
||||||
protected static function getInstance(array $elem = []): static
|
protected static function getInstance(array $elem = []): static
|
||||||
{
|
{
|
||||||
$class = get_called_class();
|
$class = get_called_class();
|
||||||
$instance = new $class();
|
$instance = new $class();
|
||||||
$reflection = new ReflectionClass($instance);
|
$reflection = new ReflectionClass($instance);
|
||||||
$properties = $reflection->getProperties();
|
$properties = $reflection->getProperties();
|
||||||
$propertyNames = array_map(function ($property) {
|
|
||||||
return static::camelCaseToSnakeCase($property->name);
|
$map = [];
|
||||||
}, $properties);
|
foreach ($properties as $prop) {
|
||||||
|
$map[static::camelCaseToSnakeCase($prop->name)] = $prop;
|
||||||
|
}
|
||||||
|
|
||||||
foreach ($elem as $key => $value) {
|
foreach ($elem as $key => $value) {
|
||||||
$index = array_search($key, $propertyNames);
|
if (isset($map[$key])) {
|
||||||
if (is_numeric($index)) {
|
$property = $map[$key];
|
||||||
if (enum_exists($properties[$index]->getType()->getName())) {
|
$instance->{$property->name} = static::castValue($property, $value);
|
||||||
$instance->{$properties[$index]->name} = $properties[$index]->getType()->getName()::tryfrom($value);
|
|
||||||
} else {
|
|
||||||
$instance->{$properties[$index]->name} = $value;
|
|
||||||
}
|
|
||||||
} else {
|
} else {
|
||||||
$instance->{static::snakeCaseToCamelCase($key)} = $value;
|
$instance->{static::snakeCaseToCamelCase($key)} = $value;
|
||||||
}
|
}
|
||||||
@@ -315,6 +324,41 @@ class Model
|
|||||||
return $instance;
|
return $instance;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Handles type casting for properties
|
||||||
|
*
|
||||||
|
* @param ReflectionProperty $property
|
||||||
|
* @param mixed $value
|
||||||
|
*
|
||||||
|
* @return mixed
|
||||||
|
*/
|
||||||
|
protected static function castValue(ReflectionProperty $property, mixed $value): mixed
|
||||||
|
{
|
||||||
|
$type = $property->getType();
|
||||||
|
if (!$type) {
|
||||||
|
return $value;
|
||||||
|
}
|
||||||
|
|
||||||
|
$typeName = $type->getName();
|
||||||
|
|
||||||
|
// Enum cast
|
||||||
|
if (enum_exists($typeName)) {
|
||||||
|
if (method_exists($typeName, 'tryFrom')) {
|
||||||
|
return $typeName::tryFrom($value);
|
||||||
|
}
|
||||||
|
if (in_array($value, array_column($typeName::cases(), 'name'))) {
|
||||||
|
return $typeName::{$value};
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// DateTime cast
|
||||||
|
if (is_subclass_of($typeName, \DateTimeInterface::class)) {
|
||||||
|
return $value ? new $typeName($value) : null;
|
||||||
|
}
|
||||||
|
|
||||||
|
return $value;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Returns the attributes to be saved for the current class.
|
* Returns the attributes to be saved for the current class.
|
||||||
* Attributes will be those that are public and not excluded in static::$ignoreSave,
|
* Attributes will be those that are public and not excluded in static::$ignoreSave,
|
||||||
@@ -330,30 +374,43 @@ class Model
|
|||||||
$result = [];
|
$result = [];
|
||||||
|
|
||||||
foreach ($properties as $property) {
|
foreach ($properties as $property) {
|
||||||
|
// Avoid save unset variables
|
||||||
|
if ($property->getType() && !$property->isInitialized($this)) {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
if (!in_array($property->name, static::$dbIgnoreSave)) {
|
if (!in_array($property->name, static::$dbIgnoreSave)) {
|
||||||
$result[$this->camelCaseToSnakeCase($property->name)] = isset($this->{$property->name})
|
$name = $this->camelCaseToSnakeCase($property->name);
|
||||||
? $this->{$property->name} : null;
|
$result[$name] = $this->castToDbValue($this->{$property->name});
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
foreach (static::$dbForceSave as $value) {
|
foreach (static::$dbForceSave as $value) {
|
||||||
$result[$value] = isset($this->$value)
|
$result[$value] = $this->castToDbValue($this->$value);
|
||||||
? $this->$value : null;
|
|
||||||
}
|
|
||||||
|
|
||||||
foreach ($result as $i => $property) {
|
|
||||||
if (gettype($property) == 'boolean') {
|
|
||||||
$result[$i] = $property ? '1' : '0';
|
|
||||||
}
|
|
||||||
|
|
||||||
if ($property instanceof \UnitEnum) {
|
|
||||||
$result[$i] = $property->value ?? $property->name;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
return $result;
|
return $result;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Converts a PHP value to a database-compatible value.
|
||||||
|
*
|
||||||
|
* @param mixed $value
|
||||||
|
* @return mixed
|
||||||
|
*/
|
||||||
|
protected function castToDbValue(mixed $value): mixed
|
||||||
|
{
|
||||||
|
if ($value instanceof \UnitEnum) {
|
||||||
|
return $value->value ?? $value->name;
|
||||||
|
}
|
||||||
|
|
||||||
|
if ($value instanceof \DateTimeInterface) {
|
||||||
|
return $value->format('Y-m-d H:i:s');
|
||||||
|
}
|
||||||
|
|
||||||
|
return $value;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Returns the name of the current class, even if it's an extended class.
|
* Returns the name of the current class, even if it's an extended class.
|
||||||
*
|
*
|
||||||
@@ -423,26 +480,20 @@ class Model
|
|||||||
protected function update(): void
|
protected function update(): void
|
||||||
{
|
{
|
||||||
$atts = $this->getVars();
|
$atts = $this->getVars();
|
||||||
|
static::$dbQueryVariables = [];
|
||||||
|
|
||||||
|
$set = [];
|
||||||
foreach ($atts as $key => $value) {
|
foreach ($atts as $key => $value) {
|
||||||
if (isset($value)) {
|
$set[] = "$key=:$key";
|
||||||
if (in_array($key, $this->dbSetToNull)) {
|
static::$dbQueryVariables[':' . $key] = $value;
|
||||||
$set[] = "$key=NULL";
|
|
||||||
} else {
|
|
||||||
$set[] = "$key=:$key";
|
|
||||||
static::$dbQueryVariables[':' . $key] = $value;
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
if (in_array($key, $this->dbSetToNull)) {
|
|
||||||
$set[] = "$key=NULL";
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
$table = static::table();
|
$table = static::table();
|
||||||
$pk = static::$dbPrimaryKey;
|
$pk = static::$dbPrimaryKey;
|
||||||
$pkv = $this->$pk;
|
$pkv = $this->$pk;
|
||||||
$sql = "UPDATE $table SET " . join(', ', $set) . " WHERE $pk='$pkv'";
|
$sql = "UPDATE $table SET " . join(', ', $set) . " WHERE $pk=:$pk";
|
||||||
|
static::$dbQueryVariables[":$pk"] = $pkv;
|
||||||
|
|
||||||
static::query($sql);
|
static::query($sql);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -457,13 +508,12 @@ class Model
|
|||||||
$atts = $this->getVars();
|
$atts = $this->getVars();
|
||||||
$into = [];
|
$into = [];
|
||||||
$values = [];
|
$values = [];
|
||||||
|
static::$dbQueryVariables = [];
|
||||||
|
|
||||||
foreach ($atts as $key => $value) {
|
foreach ($atts as $key => $value) {
|
||||||
if (isset($value)) {
|
$into[] = "$key";
|
||||||
$into[] = "$key";
|
$values[] = ":$key";
|
||||||
$values[] = ":$key";
|
static::$dbQueryVariables[":$key"] = $value;
|
||||||
static::$dbQueryVariables[":$key"] = $value;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
$table = static::table();
|
$table = static::table();
|
||||||
@@ -471,7 +521,7 @@ class Model
|
|||||||
static::query($sql);
|
static::query($sql);
|
||||||
|
|
||||||
$pk = static::$dbPrimaryKey;
|
$pk = static::$dbPrimaryKey;
|
||||||
$this->$pk = $db->lastInsertId();
|
$this->$pk ??= $db->lastInsertId();
|
||||||
$this->markAsSaved();
|
$this->markAsSaved();
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -962,7 +1012,9 @@ class Model
|
|||||||
public static function orderBy(string $value, string $order = 'ASC'): static
|
public static function orderBy(string $value, string $order = 'ASC'): static
|
||||||
{
|
{
|
||||||
if ($value == "RAND") {
|
if ($value == "RAND") {
|
||||||
static::$dbQuery['orderBy'] = 'RAND()';
|
$random = static::db()->getAttribute(PDO::ATTR_DRIVER_NAME) == 'mysql' ? 'RAND()' : 'RANDOM()';
|
||||||
|
static::$dbQuery['orderBy'] = $random;
|
||||||
|
|
||||||
return new static();
|
return new static();
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -1052,8 +1104,18 @@ class Model
|
|||||||
public static function search(string $search, ?array $in = null): static
|
public static function search(string $search, ?array $in = null): static
|
||||||
{
|
{
|
||||||
if ($in == null) {
|
if ($in == null) {
|
||||||
$className = get_called_class();
|
$in = [];
|
||||||
$in = array_keys((new $className())->getVars());
|
$reflection = new \ReflectionClass(get_called_class());
|
||||||
|
|
||||||
|
foreach ($reflection->getProperties(\ReflectionProperty::IS_PUBLIC) as $property) {
|
||||||
|
if (!in_array($property->getName(), static::$dbIgnoreSave)) {
|
||||||
|
$in[] = static::camelCaseToSnakeCase($property->getName());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (empty($in)) {
|
||||||
|
return new static();
|
||||||
}
|
}
|
||||||
|
|
||||||
$search = static::bind($search);
|
$search = static::bind($search);
|
||||||
@@ -1136,22 +1198,4 @@ class Model
|
|||||||
|
|
||||||
return $instances;
|
return $instances;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* Allows defining an attribute's value as null.
|
|
||||||
* Only works for updating an element in the DB, not for inserting.
|
|
||||||
*
|
|
||||||
* @param array $attributes
|
|
||||||
* Attribute or array of attributes that will be set to null.
|
|
||||||
*
|
|
||||||
* @return void
|
|
||||||
*/
|
|
||||||
public function setNull(string ...$attributes): void
|
|
||||||
{
|
|
||||||
foreach ($attributes as $att) {
|
|
||||||
if (!in_array($att, $this->dbSetToNull)) {
|
|
||||||
$this->dbSetToNull[] = $att;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
+2
-2
@@ -50,9 +50,9 @@ class Neuron
|
|||||||
* It returns null instead of triggering an E_NOTICE.
|
* It returns null instead of triggering an E_NOTICE.
|
||||||
*
|
*
|
||||||
* @param string $index The name of the property being accessed.
|
* @param string $index The name of the property being accessed.
|
||||||
* @return null Always returns null for undefined properties.
|
* @return null Always returns null for undefined properties.
|
||||||
*/
|
*/
|
||||||
public function __get(string $index): null
|
public function __get(string $index)
|
||||||
{
|
{
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|||||||
+48
-17
@@ -2,6 +2,8 @@
|
|||||||
|
|
||||||
namespace Libs;
|
namespace Libs;
|
||||||
|
|
||||||
|
use Exception;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Request - DuckBrain
|
* Request - DuckBrain
|
||||||
*
|
*
|
||||||
@@ -59,39 +61,48 @@ class Request extends Neuron
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Run configured validations
|
// Run configured validations
|
||||||
if (!$this->validate()) {
|
$this->validate();
|
||||||
exit();
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Starts the configured validation.
|
* Starts the configured validation.
|
||||||
*
|
*
|
||||||
* @return bool
|
* On failure the single error message is built with Validator::message()
|
||||||
|
* and handed to onInvalid(), which throws by default: failures travel up
|
||||||
|
* as exceptions instead of answering HTTP here.
|
||||||
|
*
|
||||||
|
* @return void
|
||||||
|
* @throws Exception When a configured rule fails.
|
||||||
*/
|
*/
|
||||||
public function validate(): bool
|
public function validate(): void
|
||||||
{
|
{
|
||||||
$actual = match ($_SERVER['REQUEST_METHOD']) {
|
$actual = match ($_SERVER['REQUEST_METHOD']) {
|
||||||
'POST', 'PUT', 'PATCH', 'DELETE' => $this->{strtolower($_SERVER['REQUEST_METHOD'])},
|
'POST', 'PUT', 'PATCH', 'DELETE' => $this->{strtolower($_SERVER['REQUEST_METHOD'])},
|
||||||
default => $this->get
|
default => $this->get
|
||||||
};
|
};
|
||||||
|
|
||||||
|
// Merge uploaded files ($_FILES) into the body data set so the file rules
|
||||||
|
// (file/image/mimes and the routed min/max/required...) can validate
|
||||||
|
// uploads through a Request. $this->post is left untouched.
|
||||||
|
$body = empty($_FILES)
|
||||||
|
? $actual
|
||||||
|
: new Neuron(array_merge(get_object_vars($actual), $_FILES));
|
||||||
|
|
||||||
if (
|
if (
|
||||||
Validator::validateList(static::paramRules(), $this->params) &&
|
Validator::validateList(static::paramRules(), $this->params) &&
|
||||||
Validator::validateList(static::getRules(), $this->get) &&
|
Validator::validateList(static::getRules(), $this->get) &&
|
||||||
Validator::validateList(static::rules(), $actual)
|
Validator::validateList(static::rules(), $body)
|
||||||
) {
|
) {
|
||||||
return true;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (isset(static::messages()[Validator::$lastFailed])) {
|
$error = Validator::message(
|
||||||
$error = static::messages()[Validator::$lastFailed];
|
Validator::$lastFailed,
|
||||||
} else {
|
static::messages(),
|
||||||
$error = 'Error: validation failed of ' . preg_replace('/\./', ' as ', Validator::$lastFailed, 1);
|
static::attributes()
|
||||||
}
|
);
|
||||||
|
|
||||||
static::onInvalid($error);
|
static::onInvalid($error);
|
||||||
return false;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -134,16 +145,36 @@ class Request extends Neuron
|
|||||||
return [];
|
return [];
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Human-readable names for the fields.
|
||||||
|
*
|
||||||
|
* Forwarded to Validator::message() so the :attribute marker in the error
|
||||||
|
* text can be replaced with a friendlier name (e.g. "edad" => "la edad").
|
||||||
|
*
|
||||||
|
* @return array
|
||||||
|
*/
|
||||||
|
public function attributes(): array
|
||||||
|
{
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Function to execute when an invalid value has been detected.
|
* Function to execute when an invalid value has been detected.
|
||||||
*
|
*
|
||||||
|
* The default implementation always throws a generic \Exception carrying
|
||||||
|
* the single error message and HTTP 422 as its code; the framework's
|
||||||
|
* exception boundary (Router::apply) renders the response. Override it to
|
||||||
|
* throw a more specific exception type instead. The never return type is
|
||||||
|
* the contract: an override that returned would let the request continue
|
||||||
|
* with invalid data, so PHP rejects such an override at compile time.
|
||||||
|
*
|
||||||
* @param string $error
|
* @param string $error
|
||||||
*
|
*
|
||||||
* @return void
|
* @return never
|
||||||
|
* @throws Exception
|
||||||
*/
|
*/
|
||||||
public function onInvalid(string $error): void
|
public function onInvalid(string $error): never
|
||||||
{
|
{
|
||||||
http_response_code(422);
|
throw new Exception($error, 422);
|
||||||
print($error);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
+90
-33
@@ -50,7 +50,7 @@ class Router
|
|||||||
*
|
*
|
||||||
* @var callable $notFoundCallback
|
* @var callable $notFoundCallback
|
||||||
*/
|
*/
|
||||||
public static $notFoundCallback = 'Libs\Router::defaultNotFound';
|
public static $notFoundCallback = 'Libs\Router::defaultNotFound';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Default callback function for when
|
* Default callback function for when
|
||||||
@@ -64,6 +64,54 @@ class Router
|
|||||||
echo '<h2 style="text-align: center;margin: 25px 0px;">Error 404 - Page Not Found</h2>';
|
echo '<h2 style="text-align: center;margin: 25px 0px;">Error 404 - Page Not Found</h2>';
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* The callback function to be executed when the router's boundary
|
||||||
|
* catches an exception thrown anywhere in the matched route chain.
|
||||||
|
* It receives the exception as a named argument: the handler must
|
||||||
|
* declare its parameter as $exception (typeable as \Throwable).
|
||||||
|
*
|
||||||
|
* @var callable $exceptionCallback
|
||||||
|
*/
|
||||||
|
public static $exceptionCallback = 'Libs\Router::defaultException';
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Default callback function for exception responses.
|
||||||
|
*
|
||||||
|
* The HTTP status comes from the exception's code only when it is an
|
||||||
|
* integer in the 400-599 range; anything else (0, arbitrary codes, the
|
||||||
|
* SQLSTATE string carried by PDOException) answers 500. The body is
|
||||||
|
* negotiated from the request's Accept header: JSON when the client asks
|
||||||
|
* for application/json, plain text otherwise. The trace is serialized
|
||||||
|
* from getTraceAsString() because json_encode() of a Throwable yields an
|
||||||
|
* empty object: its properties are protected.
|
||||||
|
*
|
||||||
|
* @param \Throwable $exception
|
||||||
|
*
|
||||||
|
* @return void
|
||||||
|
*/
|
||||||
|
public static function defaultException(\Throwable $exception): void
|
||||||
|
{
|
||||||
|
$code = $exception->getCode();
|
||||||
|
http_response_code(is_int($code) && $code >= 400 && $code <= 599 ? $code : 500);
|
||||||
|
|
||||||
|
$accept = $_SERVER['HTTP_ACCEPT'] ?? '';
|
||||||
|
|
||||||
|
if (str_contains($accept, 'application/json')) {
|
||||||
|
header('Content-Type: application/json');
|
||||||
|
print(json_encode([
|
||||||
|
'error' => $exception->getMessage(),
|
||||||
|
'exception' => get_class($exception),
|
||||||
|
'file' => $exception->getFile(),
|
||||||
|
'line' => $exception->getLine(),
|
||||||
|
'trace' => explode(PHP_EOL, $exception->getTraceAsString()),
|
||||||
|
]));
|
||||||
|
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
print($exception->getMessage() . PHP_EOL . $exception->getTraceAsString());
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* __construct
|
* __construct
|
||||||
*/
|
*/
|
||||||
@@ -136,7 +184,6 @@ class Router
|
|||||||
public static function redirect(string $path): void
|
public static function redirect(string $path): void
|
||||||
{
|
{
|
||||||
header('Location: ' . static::basePath() . ltrim($path, '/'));
|
header('Location: ' . static::basePath() . ltrim($path, '/'));
|
||||||
exit;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -363,50 +410,60 @@ class Router
|
|||||||
/**
|
/**
|
||||||
* Applies the route configuration.
|
* Applies the route configuration.
|
||||||
*
|
*
|
||||||
|
* This method is the framework's error boundary: any \Throwable thrown
|
||||||
|
* while running the matched route's callback chain, while printing the
|
||||||
|
* returned data, or while resolving the not-found callback is caught
|
||||||
|
* here and rendered through $exceptionCallback. A failing handler is
|
||||||
|
* deliberately left uncaught (double failure falls back to PHP itself).
|
||||||
|
*
|
||||||
* @param string|null $path (optional) Path to use. If not defined, it detects the current path.
|
* @param string|null $path (optional) Path to use. If not defined, it detects the current path.
|
||||||
*
|
*
|
||||||
* @return void
|
* @return void
|
||||||
*/
|
*/
|
||||||
public static function apply(?string $path = null): void
|
public static function apply(?string $path = null): void
|
||||||
{
|
{
|
||||||
$path = $path ?? static::currentPath();
|
try {
|
||||||
$routers = match ($_SERVER['REQUEST_METHOD']) { // Selects an array of routers based on the method
|
$path = $path ?? static::currentPath();
|
||||||
'POST' => static::$post,
|
$routers = match ($_SERVER['REQUEST_METHOD']) { // Selects an array of routers based on the method
|
||||||
'PUT' => static::$put,
|
'POST' => static::$post,
|
||||||
'PATCH' => static::$patch,
|
'PUT' => static::$put,
|
||||||
'DELETE' => static::$delete,
|
'PATCH' => static::$patch,
|
||||||
default => static::$get
|
'DELETE' => static::$delete,
|
||||||
};
|
default => static::$get
|
||||||
|
};
|
||||||
|
|
||||||
foreach ($routers as $router) { // Checks all routers to see if they match the current path
|
foreach ($routers as $router) { // Checks all routers to see if they match the current path
|
||||||
if (preg_match_all('/^' . $router['path'] . '\/?$/si', $path, $matches, PREG_PATTERN_ORDER)) {
|
if (preg_match_all('/^' . $router['path'] . '\/?$/si', $path, $matches, PREG_PATTERN_ORDER)) {
|
||||||
unset($matches[0]);
|
unset($matches[0]);
|
||||||
|
|
||||||
// Checking and storing the variable parameters of the route
|
// Checking and storing the variable parameters of the route
|
||||||
if (isset($matches[1])) {
|
if (isset($matches[1])) {
|
||||||
static::$params = new Neuron();
|
static::$params = new Neuron();
|
||||||
foreach ($matches as $index => $match) {
|
foreach ($matches as $index => $match) {
|
||||||
$paramName = $router['paramNames'][$index - 1];
|
$paramName = $router['paramNames'][$index - 1];
|
||||||
static::$params->{$paramName} = urldecode($match[0]);
|
static::$params->{$paramName} = urldecode($match[0]);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
// Processes the callback queue
|
// Processes the callback queue
|
||||||
foreach (array_reverse($router['callback']) as $callback) {
|
foreach (array_reverse($router['callback']) as $callback) {
|
||||||
$data = Synapsis::resolve($callback);
|
$data = Synapsis::resolve($callback);
|
||||||
}
|
}
|
||||||
|
|
||||||
// By default, prints as JSON if something is returned
|
// By default, prints as JSON if something is returned
|
||||||
if (isset($data)) {
|
if (isset($data)) {
|
||||||
header('Content-Type: application/json');
|
header('Content-Type: application/json');
|
||||||
print(json_encode($data));
|
print(json_encode($data));
|
||||||
}
|
}
|
||||||
|
|
||||||
return;
|
return;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
// If no router matches, call $notFoundCallBack
|
// If no router matches, call $notFoundCallBack
|
||||||
Synapsis::resolve(static::$notFoundCallback);
|
Synapsis::resolve(static::$notFoundCallback);
|
||||||
|
} catch (\Throwable $exception) {
|
||||||
|
Synapsis::resolve(static::$exceptionCallback, ['exception' => $exception]);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
+22
-5
@@ -65,12 +65,14 @@ class Synapsis
|
|||||||
/**
|
/**
|
||||||
* Resolves and injects dependencies for a callable and returns its result.
|
* Resolves and injects dependencies for a callable and returns its result.
|
||||||
*
|
*
|
||||||
* @param callable $action
|
* @param callable $action
|
||||||
|
* @param array<string, mixed> $named Associative array of values injected into the callable's
|
||||||
|
* parameters by exact name match. Consumed in resolveParameterValues().
|
||||||
*
|
*
|
||||||
* @return mixed
|
* @return mixed
|
||||||
* @throws Exception If an unhandled callable type is provided.
|
* @throws Exception If an unhandled callable type is provided.
|
||||||
*/
|
*/
|
||||||
public static function resolve(callable $action): mixed
|
public static function resolve(callable $action, array $named = []): mixed
|
||||||
{
|
{
|
||||||
if ($action instanceof Closure) { // If it's an anonymous function
|
if ($action instanceof Closure) { // If it's an anonymous function
|
||||||
$reflectionCallback = new ReflectionFunction($action);
|
$reflectionCallback = new ReflectionFunction($action);
|
||||||
@@ -90,7 +92,7 @@ class Synapsis
|
|||||||
// Get the parameters
|
// Get the parameters
|
||||||
return call_user_func_array(
|
return call_user_func_array(
|
||||||
$action,
|
$action,
|
||||||
static::resolveParameterValues($reflectionCallback->getParameters())
|
static::resolveParameterValues($reflectionCallback->getParameters(), $named)
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -132,14 +134,27 @@ class Synapsis
|
|||||||
* Resolves parameter values by injecting dependencies.
|
* Resolves parameter values by injecting dependencies.
|
||||||
*
|
*
|
||||||
* @param array<ReflectionParameter> $parameters
|
* @param array<ReflectionParameter> $parameters
|
||||||
|
* @param array<string, mixed> $named
|
||||||
|
* Values injected into parameters whose name matches the key,
|
||||||
|
* taking precedence over optional defaults and DI resolution.
|
||||||
|
* Keys matching no parameter are ignored.
|
||||||
*
|
*
|
||||||
* @return array<mixed>
|
* @return array<mixed>
|
||||||
* @throws Exception If a primitive parameter does not have a default value.
|
* @throws Exception If a primitive parameter does not have a default value.
|
||||||
*/
|
*/
|
||||||
public static function resolveParameterValues(array $parameters): array
|
public static function resolveParameterValues(array $parameters, array $named = []): array
|
||||||
{
|
{
|
||||||
$values = [];
|
$values = [];
|
||||||
foreach ($parameters as $parameter) {
|
foreach ($parameters as $parameter) {
|
||||||
|
if ($parameter->isVariadic()) { // Skip variatic parameters
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (array_key_exists($parameter->getName(), $named)) { // Named values win over defaults and DI
|
||||||
|
$values[] = $named[$parameter->getName()];
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
if ($parameter->isOptional()) { // Always use the default value first
|
if ($parameter->isOptional()) { // Always use the default value first
|
||||||
$values[] = $parameter->getDefaultValue();
|
$values[] = $parameter->getDefaultValue();
|
||||||
continue;
|
continue;
|
||||||
@@ -148,7 +163,9 @@ class Synapsis
|
|||||||
$paramType = $parameter->getType();
|
$paramType = $parameter->getType();
|
||||||
if ($paramType === null) {
|
if ($paramType === null) {
|
||||||
// If no type is declared, and it's not optional, we cannot resolve it.
|
// If no type is declared, and it's not optional, we cannot resolve it.
|
||||||
throw new Exception('Untyped parameters expect at least a default value or must be optional.');
|
throw new Exception(
|
||||||
|
"Untyped parameter '{$parameter}' expect at least a default value or must be optional."
|
||||||
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
if ($paramType->isBuiltin()) {
|
if ($paramType->isBuiltin()) {
|
||||||
|
|||||||
+1075
-32
File diff suppressed because it is too large
Load Diff
Reference in New Issue
Block a user