vendor/botman/botman/src/Middleware/MiddlewareManager.php line 126

Open in your IDE?
  1. <?php
  3. namespace BotMan\BotMan\Middleware;
  5. use BotMan\BotMan\BotMan;
  6. use BotMan\BotMan\Interfaces\Middleware\Captured;
  7. use BotMan\BotMan\Interfaces\Middleware\Heard;
  8. use BotMan\BotMan\Interfaces\Middleware\Matching;
  9. use BotMan\BotMan\Interfaces\Middleware\Received;
  10. use BotMan\BotMan\Interfaces\Middleware\Sending;
  11. use BotMan\BotMan\Interfaces\MiddlewareInterface;
  12. use Closure;
  13. use Mpociot\Pipeline\Pipeline;
  15. class MiddlewareManager
  16. {
  17. /** @var Received[] */
  18. protected $received = [];
  19. /** @var Captured[] */
  20. protected $captured = [];
  21. /** @var Matching[] */
  22. protected $matching = [];
  23. /** @var Heard[] */
  24. protected $heard = [];
  25. /** @var Sending[] */
  26. protected $sending = [];
  27. /** @var BotMan */
  28. protected $botman;
  30. public function __construct(BotMan $botman)
  31. {
  32. $this->botman = $botman;
  33. }
  35. /**
  36. * @param Received[] ...$middleware
  37. * @return Received[]|$this
  38. */
  39. public function received(Received ...$middleware)
  40. {
  41. if (empty($middleware)) {
  42. return $this->received;
  43. }
  44. $this->received = array_merge($this->received, $middleware);
  46. return $this;
  47. }
  49. /**
  50. * @param Captured[] ...$middleware
  51. * @return Captured[]|$this
  52. */
  53. public function captured(Captured ...$middleware)
  54. {
  55. if (empty($middleware)) {
  56. return $this->captured;
  57. }
  58. $this->captured = array_merge($this->captured, $middleware);
  60. return $this;
  61. }
  63. /**
  64. * @param Matching[] ...$middleware
  65. * @return Matching[]|$this
  66. */
  67. public function matching(Matching ...$middleware)
  68. {
  69. if (empty($middleware)) {
  70. return $this->matching;
  71. }
  72. $this->matching = array_merge($this->matching, $middleware);
  74. return $this;
  75. }
  77. /**
  78. * @param Heard[] $middleware
  79. * @return Heard[]|$this
  80. */
  81. public function heard(Heard ...$middleware)
  82. {
  83. if (empty($middleware)) {
  84. return $this->heard;
  85. }
  86. $this->heard = array_merge($this->heard, $middleware);
  88. return $this;
  89. }
  91. /**
  92. * @param Sending[] $middleware
  93. * @return Sending[]|$this
  94. */
  95. public function sending(Sending ...$middleware)
  96. {
  97. if (empty($middleware)) {
  98. return $this->sending;
  99. }
  100. $this->sending = array_merge($this->sending, $middleware);
  102. return $this;
  103. }
  105. /**
  106. * @param string $method
  107. * @param mixed $payload
  108. * @param MiddlewareInterface[] $additionalMiddleware
  109. * @param Closure|null $destination
  110. * @return mixed
  111. */
  112. public function applyMiddleware($method, $payload, array $additionalMiddleware = [], Closure $destination = null)
  113. {
  114. $destination = is_null($destination) ? function ($payload) {
  115. return $payload;
  116. }
  117. : $destination;
  119. $middleware = $this->$method + $additionalMiddleware;
  121. return (new Pipeline())
  122. ->via($method)
  123. ->send($payload)
  124. ->with($this->botman)
  125. ->through($middleware)
  126. ->then($destination);
  127. }
  128. }