invoiceninja/app/Ninja/Intents/BaseIntent.php

<?php namespace App\Ninja\Intents;

use stdClass;
use Exception;
use App\Libraries\CurlUtils;
use App\Libraries\Skype\SkypeResponse;

class BaseIntent
{
    protected $state;
    protected $parameters;
    protected $fieldMap = [];

    public function __construct($state, $data)
    {
        //if (true) {
        if ( ! $state || is_string($state)) {
            $state = new stdClass;
            foreach (['current', 'previous'] as $reference) {
                $state->$reference = new stdClass;
                $state->$reference->entityType = false;
                foreach ([ENTITY_INVOICE, ENTITY_CLIENT, ENTITY_INVOICE_ITEM] as $entityType) {
                    $state->$reference->$entityType = [];
                }
            }
        }

        $this->state = $state;
        $this->data = $data;

        //var_dump($state);
    }

    public static function createIntent($state, $data)
    {
        if ( ! count($data->intents)) {
            throw new Exception(trans('texts.intent_not_found'));
        }

        $intent = $data->intents[0]->intent;
        $entityType = false;

        foreach ($data->entities as $entity) {
            if ($entity->type === 'EntityType') {
                $entityType = $entity->entity;
                break;
            }
        }

        if ( ! $entityType) {
            $entityType = $state->current->entityType;
        }

        $entityType = ucwords(strtolower($entityType));
        $intent = str_replace('Entity', $entityType, $intent);
        $className = "App\\Ninja\\Intents\\{$intent}Intent";

        //echo "Intent: $intent<p>";

        if ( ! class_exists($className)) {
            throw new Exception(trans('texts.intent_not_supported'));
        }

        return (new $className($state, $data));
    }


    public function process()
    {
        throw new Exception(trans('texts.intent_not_supported'));
    }

    public function setStateEntities($entityType, $entities)
    {
        if ( ! is_array($entities)) {
            $entities = [$entities];
        }

        $state = $this->state;

        $state->previous->$entityType = $state->current->$entityType;
        $state->current->$entityType = $entities;
    }

    public function setStateEntityType($entityType)
    {
        $state = $this->state;

        if ($state->current->entityType == $entityType) {
            return;
        }

        $state->previous->entityType = $state->current->entityType;
        $state->current->entityType = $entityType;
    }

    public function stateEntities($entityType)
    {
        return $this->state->current->$entityType;
    }

    public function stateEntity($entityType)
    {
        $entities = $this->state->current->$entityType;

        return count($entities) ? $entities[0] : false;
    }

    public function previousStateEntities($entityType)
    {
        return $this->state->previous->$entityType;
    }

    public function stateEntityType()
    {
        return $this->state->current->entityType;
    }


    public function getState()
    {
        return $this->state;
    }

    protected function requestClient()
    {
        $clientRepo = app('App\Ninja\Repositories\ClientRepository');
        $client = false;

        foreach ($this->data->entities as $param) {
            if ($param->type == 'Name') {
                $client = $clientRepo->findPhonetically($param->entity);
            }
        }

        return $client;
    }

    protected function requestFields()
    {
        $data = [];

        if ( ! isset($this->data->compositeEntities)) {
            return [];
        }

        foreach ($this->data->compositeEntities as $compositeEntity) {
            if ($compositeEntity->parentType != 'FieldValuePair') {
                continue;
            }

            $field = false;
            $value = false;

            foreach ($compositeEntity->children as $child) {
                if ($child->type == 'Field') {
                    $field = $child->value;;
                } elseif ($child->type == 'Value') {
                    $value = $child->value;
                }
            }

            if ($field && $value) {
                $field = $this->processField($field);
                $value = $this->processValue($value);

                $data[$field] = $value;
            }
        }

        foreach ($this->fieldMap as $key => $value) {
            if (isset($data[$key])) {
                $data[$value] = $data[$key];
                unset($data[$key]);
            }
        }

        return $data;
    }

    protected function processField($field)
    {
        $field = str_replace(' ', '_', $field);

        if (strpos($field, 'date') !== false) {
            $field .= '_sql';
        }

        return $field;
    }

    protected function processValue($value)
    {
        // look for LUIS pre-built entity matches
        foreach ($this->data->entities as $entity) {
            if ($entity->entity === $value) {
                if ($entity->type == 'builtin.datetime.date') {
                    $value = $entity->resolution->date;
                    $value = str_replace('XXXX', date('Y'), $value);
                }
            }
        }

        return $value;
    }

    protected function createResponse($type, $content)
    {
        $response = new SkypeResponse($type);

        if (is_string($content)) {
            $response->setText($content);
        } else {
            if ($content instanceof \Illuminate\Database\Eloquent\Collection) {
                // do nothing
            } elseif ( ! is_array($content)) {
                $content = [$content];
            }

            foreach ($content as $item) {
                $response->addAttachment($item);
            }
        }

        return json_encode($response);
    }
}