Changed way to connect to api

This commit is contained in:
2022-11-30 10:40:36 -03:00
parent f8500e061c
commit a5d97729dc
12 changed files with 129 additions and 43 deletions

View File

@ -83,16 +83,25 @@ class Mailboxes
$body = $request->getBody(); $body = $request->getBody();
$json = \Safe\json_decode($body->getContents()); $json = \Safe\json_decode($body->getContents());
if (!isset($json->mailboxes)) { if (!isset($json->mailboxes)) {
throw new MissingArgument('mailboxes', 'array', 'mailboxes names'); throw new MissingArgument('mailboxes', 'array', 'mailboxes ids');
} }
$output = [ $output = [
'mailboxes' => $json->mailboxes, 'mailboxes' => $json->mailboxes,
'total' => count($json->mailboxes), 'total' => count($json->mailboxes),
'unregistered' => 0 'unregistered' => [
'total' => 0,
'mailboxes' => []
]
]; ];
foreach ($json->mailboxes as $mailbox_name) { foreach ($json->mailboxes as $mailbox_id) {
if ($service->unregister($mailbox_name)) { $mailbox = $service->getRepository()->fetchById($mailbox_id);
$output['unregistered'] ++; if ($service->unregister($mailbox->getName())) {
$output['unregistered']['total'] ++;
$output['unregistered']['mailboxes'] []= [
'id' => $mailbox->getId(),
'name' => $mailbox->getName(),
'unregistered' => true
];
} }
} }
return $this->withJson($response, $output); return $this->withJson($response, $output);

View File

@ -118,6 +118,7 @@ class Mailboxes extends Base
try { try {
$mailbox = $this->getRepository()->fetchByName($mailbox_name); $mailbox = $this->getRepository()->fetchByName($mailbox_name);
} catch (BlankResult $e) { } catch (BlankResult $e) {
$this->getLogger()->error($e);
// It's already unregistered // It's already unregistered
return true; return true;
} }

View File

@ -146,7 +146,7 @@ class Message implements Model
public function doesHaveAttachments(): Message public function doesHaveAttachments(): Message
{ {
if (!isset($this->getState()['has_attachments'])) { if (!isset($this->getStates()['has_attachments'])) {
$this->newState('has_attachments'); $this->newState('has_attachments');
} }
$this->getState('has_attachments')->setValue(true); $this->getState('has_attachments')->setValue(true);

View File

@ -0,0 +1,17 @@
<?php
namespace ProVM\Common\Controller;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use ProVM\Common\Service\Api as Service;
class Api
{
public function __invoke(ServerRequestInterface $request, ResponseInterface $response, Service $service): ResponseInterface
{
$body = $request->getBody();
$json = \Safe\json_decode($body->getContents(), JSON_OBJECT_AS_ARRAY);
return $service->sendRequest($json);
}
}

47
ui/common/Service/Api.php Normal file
View File

@ -0,0 +1,47 @@
<?php
namespace ProVM\Common\Service;
use Psr\Http\Client\ClientInterface;
use Psr\Http\Message\RequestFactoryInterface;
use Psr\Http\Message\ResponseInterface;
class Api
{
public function __construct(ClientInterface $client, RequestFactoryInterface $factory)
{
$this->setClient($client)
->setFactory($factory);
}
protected ClientInterface $client;
protected RequestFactoryInterface $factory;
public function getClient(): ClientInterface
{
return $this->client;
}
public function getFactory(): RequestFactoryInterface
{
return $this->factory;
}
public function setClient(ClientInterface $client): Api
{
$this->client = $client;
return $this;
}
public function setFactory(RequestFactoryInterface $factory): Api
{
$this->factory = $factory;
return $this;
}
public function sendRequest(array $request_data): ResponseInterface
{
$request = $this->getFactory()->createRequest(strtoupper($request_data['method']) ?? 'GET', $request_data['uri']);
if (strtolower($request_data['method']) !== 'get') {
$request->getBody()->write(\Safe\json_encode($request_data['data']));
$request->withHeader('Content-Type', 'application/json');
}
return $this->getClient()->sendRequest($request);
}
}

View File

@ -0,0 +1,4 @@
<?php
use ProVM\Common\Controller\Api;
$app->post('/api', Api::class);

View File

@ -33,8 +33,8 @@
).append( ).append(
$('<button></button>').addClass('ui mini circular red icon button').append( $('<button></button>').addClass('ui mini circular red icon button').append(
$('<i></i>').addClass('remove icon') $('<i></i>').addClass('remove icon')
).click(() => { ).click(e => {
this.unregister() this.unregister($(e.currentTarget))
}) })
) )
} else { } else {
@ -42,7 +42,7 @@
register.append( register.append(
$('<button></button>').addClass('ui mini circular icon button').append( $('<button></button>').addClass('ui mini circular icon button').append(
$('<i></i>').addClass('save icon') $('<i></i>').addClass('save icon')
).click((e) => { ).click(e => {
this.register($(e.currentTarget)) this.register($(e.currentTarget))
}) })
) )
@ -72,20 +72,25 @@
}) })
}) })
} }
unregister() { unregister(button) {
const uri = '/mailboxes/unregister' const uri = '/mailboxes/unregister'
const data = { const data = {
mailboxes: [this.id] mailboxes: [this.id]
} }
button.html('').append(
$('<i></i>').addClass('redo loading icon')
)
return Send.delete({ return Send.delete({
uri, uri,
data data
}).then(response => { }).then(response => {
response.mailboxes.forEach(mb => { response.unregistered.mailboxes.forEach(mb => {
if (mb.id === this.id && mb.removed) { if (mb.id === this.id && mb.unregistered) {
this.id = null this.id = null
this.registered = false this.registered = false
mailboxes.draw().table() const tr = button.parent().parent()
tr.html('')
this.draw(tr)
} }
}) })
}) })

View File

@ -1,38 +1,33 @@
<script type="text/javascript"> <script type="text/javascript">
const Send = { const Send = {
base_url: '{{$urls->api}}', base_url: '{{$urls->api}}',
base: function({method, uri, data = null, dataType = 'json', contentType = 'application/json'}) { base: function({method, uri, data = null}) {
const url = this.base_url + '/' + uri.replace(/^\//g, '') const request = {
uri: uri.replace(/^\//g, ''),
method
}
const options = { const options = {
method, url: this.base_url,
url, method: 'post',
crossDomain: true, contentType: 'application/json'
headers: {
'Authorization': [
'Bearer {{$api_key}}'
]
},
dataType
} }
if (method.toLowerCase() !== 'get' && data !== null) { if (method.toLowerCase() !== 'get' && data !== null) {
if (!(typeof data === 'string' || data instanceof String)) { request['data'] = data
options['data'] = JSON.stringify(data)
}
options['contentType'] = contentType
} }
options['data'] = JSON.stringify(request)
return $.ajax(options) return $.ajax(options)
}, },
get: function(uri, dataType = 'json') { get: function(uri) {
return this.base({method: 'get', uri, dataType}) return this.base({method: 'get', uri})
}, },
post: function({uri, data, dataType = 'json', contentType = 'application/json'}) { post: function({uri, data}) {
return this.base({method: 'post', uri, data, dataType, contentType}) return this.base({method: 'post', uri, data})
}, },
put: function({uri, data, dataType = 'json', contentType = 'application/json'}) { put: function({uri, data}) {
return this.base({method: 'put', uri, data, dataType, contentType}) return this.base({method: 'put', uri, data})
}, },
delete: function({uri, data, dataType = 'json', contentType = 'application/json'}) { delete: function({uri, data}) {
return this.base({method: 'delete', uri, data, dataType, contentType}) return this.base({method: 'delete', uri, data})
} }
} }
const _urls = JSON.parse('{!! Safe\json_encode($urls) !!}') const _urls = JSON.parse('{!! Safe\json_encode($urls) !!}')

View File

@ -2,7 +2,12 @@
return [ return [
'urls' => function() { 'urls' => function() {
$arr = ['base' => $_SERVER['REQUEST_SCHEME'] . '://' . $_SERVER['HTTP_HOST']]; $arr = ['base' => $_SERVER['REQUEST_SCHEME'] . '://' . $_SERVER['HTTP_HOST']];
$arr['api'] = 'http://localhost:8080'; $arr['api'] = $_ENV['API_URI'];
return (object) $arr; return (object) $arr;
} },
'view_urls' => function() {
$arr = ['base' => $_SERVER['REQUEST_SCHEME'] . '://' . $_SERVER['HTTP_HOST']];
$arr['api'] = implode('/', [$arr['base'], 'api']);
return (object) $arr;
},
]; ];

View File

@ -11,5 +11,8 @@ return [
] ]
] ]
]); ]);
} },
Psr\Http\Message\RequestFactoryInterface::class => function(ContainerInterface $container) {
return $container->get(Nyholm\Psr7\Factory\Psr17Factory::class);
},
]; ];

View File

@ -2,13 +2,13 @@
use Psr\Container\ContainerInterface; use Psr\Container\ContainerInterface;
return [ return [
\Slim\Views\Blade::class => function(ContainerInterface $container) { Slim\Views\Blade::class => function(ContainerInterface $container) {
return new \Slim\Views\Blade( return new Slim\Views\Blade(
$container->get('folders')->views, $container->get('folders')->views,
$container->get('folders')->cache, $container->get('folders')->cache,
null, null,
[ [
'urls' => $container->get('urls'), 'urls' => $container->get('view_urls'),
'api_key' => $container->get('api_key') 'api_key' => $container->get('api_key')
] ]
); );