deploys actual services when applied.
This commit is contained in:
parent
49df5fa285
commit
3bab9a5d34
4 changed files with 11 additions and 9 deletions
|
|
@ -621,6 +621,6 @@ class App
|
||||||
|
|
||||||
$this->router->cache();
|
$this->router->cache();
|
||||||
|
|
||||||
$this->logger->info('ROUTE_CACHE miss.');
|
//$this->logger->info('ROUTE_CACHE miss.');
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -166,7 +166,7 @@ class Router
|
||||||
|
|
||||||
try {
|
try {
|
||||||
$this->cachePoolChain->save($routeItem);
|
$this->cachePoolChain->save($routeItem);
|
||||||
$this->logger->info('Cached router to cache pool');
|
//$this->logger->info('Cached router to cache pool');
|
||||||
} catch (CachePoolException $cachePoolException) {
|
} catch (CachePoolException $cachePoolException) {
|
||||||
$this->logger->critical('Cache Pool Exception: '.$cachePoolException->getMessage());
|
$this->logger->critical('Cache Pool Exception: '.$cachePoolException->getMessage());
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -35,12 +35,6 @@ abstract class WaitForEmitWorker extends AbstractWorker
|
||||||
return $this;
|
return $this;
|
||||||
}
|
}
|
||||||
|
|
||||||
public function run(): void
|
|
||||||
{
|
|
||||||
$this->logger->debug('Running Emit Worker');
|
|
||||||
$this->redis->listen([$this, 'recv']);
|
|
||||||
}
|
|
||||||
|
|
||||||
public function recv($redis, $pattern, $chan, $msg): void
|
public function recv($redis, $pattern, $chan, $msg): void
|
||||||
{
|
{
|
||||||
$json = json_decode($msg, true);
|
$json = json_decode($msg, true);
|
||||||
|
|
@ -51,5 +45,7 @@ abstract class WaitForEmitWorker extends AbstractWorker
|
||||||
|
|
||||||
public function iterate(): bool
|
public function iterate(): bool
|
||||||
{
|
{
|
||||||
|
$this->logger->debug('Running Emit Worker');
|
||||||
|
$this->redis->listen([$this, 'recv']);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -3,7 +3,10 @@
|
||||||
namespace Benzine\Tests;
|
namespace Benzine\Tests;
|
||||||
|
|
||||||
use Benzine\Tests\Traits\AppTestTrait;
|
use Benzine\Tests\Traits\AppTestTrait;
|
||||||
|
use GuzzleHttp\Psr7\Utils;
|
||||||
|
use Middlewares\Utils\Factory as MiddlewareFactory;
|
||||||
use Psr\Http\Message\ResponseInterface;
|
use Psr\Http\Message\ResponseInterface;
|
||||||
|
use Slim\Psr7\Request;
|
||||||
|
|
||||||
abstract class AbstractRoutesTestCase extends AbstractBaseTestCase
|
abstract class AbstractRoutesTestCase extends AbstractBaseTestCase
|
||||||
{
|
{
|
||||||
|
|
@ -31,6 +34,7 @@ abstract class AbstractRoutesTestCase extends AbstractBaseTestCase
|
||||||
bool $isJsonRequest = true,
|
bool $isJsonRequest = true,
|
||||||
array $extraHeaders = []
|
array $extraHeaders = []
|
||||||
): ResponseInterface {
|
): ResponseInterface {
|
||||||
|
/** @var Request $request */
|
||||||
$request = $this->createRequest($method, $path);
|
$request = $this->createRequest($method, $path);
|
||||||
|
|
||||||
if ($isJsonRequest) {
|
if ($isJsonRequest) {
|
||||||
|
|
@ -38,8 +42,10 @@ abstract class AbstractRoutesTestCase extends AbstractBaseTestCase
|
||||||
$dataOrPost = json_decode(json_encode($dataOrPost), true);
|
$dataOrPost = json_decode(json_encode($dataOrPost), true);
|
||||||
$request = $request->withParsedBody($dataOrPost);
|
$request = $request->withParsedBody($dataOrPost);
|
||||||
}
|
}
|
||||||
|
|
||||||
$request = $request->withHeader('Content-Type', 'application/json');
|
$request = $request->withHeader('Content-Type', 'application/json');
|
||||||
|
}else{
|
||||||
|
$request->getBody()->write($dataOrPost);
|
||||||
|
$request->getBody()->rewind();
|
||||||
}
|
}
|
||||||
|
|
||||||
foreach($extraHeaders as $key => $value){
|
foreach($extraHeaders as $key => $value){
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue