nopolabs / yabot-plugins

src/Sms/TextPlugin.php

<?php

namespace Nopolabs\Yabot\Plugins\Sms;

use React\Http\Request as HttpRequest;
use React\Http\Response as HttpResponse;
use Nopolabs\Yabot\Message\Message;
use Nopolabs\Yabot\Plugin\PluginInterface;
use Nopolabs\Yabot\Plugin\PluginTrait;
use Nopolabs\Yabot\Slack\Client;
use Nopolabs\Yabot\Helpers\SlackTrait;
use Nopolabs\Yabot\Http\HttpServer;
use Psr\Log\LoggerInterface;
use React\Stream\BufferedSink;

class TextPlugin implements PluginInterface
{
    use PluginTrait;
    use SlackTrait;

    /** @var TextClient */
    private $textClient;
    private $fromPhone;

    public function __construct(
        LoggerInterface $logger,
        Client $slack,
        HttpServer $http,
        TextClient $textClient,
        array $config)
    {
        $this->setLog($logger);
        $this->setSlack($slack);
        $http->addHandler([$this, 'request']);
        $this->textClient = $textClient;
        $this->fromPhone = $config['twilio']['phone'];

        $this->setConfig(array_merge(
            [
                'help' => '<prefix> text [number] [message]',
                'matchers' => [
                    'text' => [
                        'pattern' => "/^text (?'number'\\d{3}-?\\d{3}-?\\d{4})\\b(?'message'.*)$/",
                        'method' => 'text',
                    ],
                ],
            ],
            $config
        ));
    }

    public function text(Message $msg, array $matches)

The parameter $msg is not used and could be removed.

    {
        $to = '+1'.str_replace('-', '', $matches['number']);
        $message = $matches['message'];

        $this->textClient->send($to, $this->fromPhone, $message);
    }

    /**
     * Need to configure twilio phone number messaging URL: https://www.twilio.com/console/phone-numbers/incoming
     * For testing I use ngrok to tunnel local ports to public URLs and inspect traffic https://ngrok.com/
     *
     * @param HttpRequest $request
     * @param HttpResponse $response
     */
    public function request(HttpRequest $request, HttpResponse $response)
    {
        $headers = array('Content-Type' => 'text/plain');
        $response->writeHead(200, $headers);

        $sink = new BufferedSink();
        $request->pipe($sink);
        $sink->promise()->then(function ($data) use ($response) {
            if (mb_parse_str($data, $result)) {
                $from = $result['From'];
                $body = $result['Body'];
                $this->say("$from: $body", 'general');
            }
            $response->end();
        });
    }
}