NexmoWebHookHandler.php
3.19 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
<?php
namespace NexmoBundle\WebHook;
use AppBundle\Service\ConsoleInvoker;
use CobrandBundle\CobrandInstance;
use CobrandBundle\Service\CobrandFactory;
use JMS\DiExtraBundle\Annotation\Inject;
use JMS\DiExtraBundle\Annotation\InjectParams;
use JMS\DiExtraBundle\Annotation\Service;
use Monolog\Logger;
use NexmoBundle\Manager\NexmoCallManager;
use Sentry\SentryBundle\SentrySymfonyClient;
use Symfony\Component\HttpFoundation\JsonResponse;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\HttpKernel\Exception\BadRequestHttpException;
/**
* Class NexmoWebHookHandler
* @Service("nexmo.webhooks.base", abstract=true, autowire=true, public=true)
*/
abstract class NexmoWebHookHandler
{
/**
* @var Request
*/
protected $request;
protected $logger;
protected $responseData = [];
/**
* @var SentrySymfonyClient
*/
protected $sentry;
/**
* @var CobrandInstance
*/
protected $currentCobrand;
/**
* @var ConsoleInvoker
*/
protected $consoleInvoker;
/**
* @param Logger $logger
* @InjectParams({
* "logger" = @Inject("logger", required=false)
* })
*/
public function injectLogger(Logger $logger)
{
$this->logger = $logger;
}
/**
* @param CobrandFactory $factory
* @InjectParams({
* "factory" = @Inject("cobrand.factory", required=false)
* })
*/
public function injectCurrentCobrand(CobrandFactory $factory)
{
$this->currentCobrand = $factory->current();
}
/**
* @param SentrySymfonyClient $client
* @InjectParams({
* "client" = @Inject("sentry.client", required=false)
* })
*/
public function injectSentryClient(SentrySymfonyClient $client)
{
$this->sentry = $client;
}
/**
* @param ConsoleInvoker $invoker
* @InjectParams({
* "invoker" = @Inject("spoke.console_invoker", required=false)
* })
*/
public function injectConsoleInvoker(ConsoleInvoker $invoker)
{
$this->consoleInvoker = $invoker;
}
/**
* @param Request $request
* @return JsonResponse
*/
final public function handle(Request $request)
{
$this->responseData = [];
$this->request = $request;
try {
$this->processRequest();
return new JsonResponse($this->responseData, Response::HTTP_OK);
} catch (\Exception $exception) {
// Important: Nexmo webhooks needs 200 response code, even for error.
$this->sentry->captureException($exception);
return new JsonResponse(["error" => $exception->getMessage()], Response::HTTP_OK);
}
}
protected function getRequestParam($key, $required = true)
{
$val = $this->request->get($key, null);
if ($required && is_null($val)) {
throw new BadRequestHttpException(sprintf('Missing required parameter for nexmo webhook: %s', $key));
}
return $val;
}
protected function logInfo($string)
{
$this->logger->info("[NEXMO_WEBHOOK]: {$string}");
}
abstract protected function processRequest();
}