gistfile1.txt

public function findMatching($threadId, $text = '', $lastMessageId = 0, $comparison = '<', $limit = 3)
    {
        if ($lastMessageId == 0) {
            $lastMessageId = $this->message->max('id') + 1;
        }

        $querySeri = [
            [
                'match' => [
                    'message' => $text,
                ],
            ],
        ];

        $filters = [
            ['term' => ['thread_id' => $threadId]],
        ];

        if ($comparison == '<') {
            $sorts = ['id' => ['order' => 'desc']];
        } else {
            $sorts = ['id' => ['order' => 'asc']];
        }


        $params = [
            'index' => 'message',
            'type' => 'message_search',
            'body' => [
                'query' => [
                    'bool' => [
                        'should' => $querySeri,
                        'filter' => $filters,
                        'minimum_should_match' => 1,
                    ],
                ],
                'sort' => $sorts,
                'search_after' => [$lastMessageId],
                'size' => $limit,
            ],
        ];

        $response = SearchService::init()->search($params);

        return $response;
    }