Add getColumns method and improve aggregation options

Introduces a getColumns method to Schema\Builder for retrieving column metadata from Elasticsearch index mappings. Also updates Query\Grammar to allow 'unmapped_type' in aggregation order options and to respect query limits when setting the 'size' parameter in aggregations.

Author: pdphilip

src/Query/Grammar.php

@@ -229,15 +229,13 @@ public function compileSelect($query): array
             }
 
             $dsl->setBody(['aggs'], $this->compileBucketAggregations($query, $sorts));
-            $dsl->setBody(['size'], 0);
-
-            //            return $dsl->getDsl();
+            $dsl->setBody(['size'], $query->getSetLimit() ?? 0);
         }
 
         // Else if we have metrics aggregations
         elseif ($query->metricsAggregations) {
             $dsl->setBody(['aggs'], $this->compileMetricAggregations($query));
-            $dsl->setBody(['size'], 0);
+            $dsl->setBody(['size'], $query->getSetLimit() ?? 0);
         }
 
         if (! $dsl->getBodyValue(['query'])) {
@@ -806,7 +804,7 @@ protected function compileOrders(Builder|BaseBuilder $builder, $orders = []): ar
                         'order' => $order['direction'] < 0 ? 'desc' : 'asc',
                     ];
 
-                    $allowedOptions = ['missing', 'mode', 'nested'];
+                    $allowedOptions = ['missing', 'mode', 'nested', 'unmapped_type'];
 
                     $options = isset($order['options']) ? array_intersect_key($order['options'], array_flip($allowedOptions)) : [];
 

src/Schema/Builder.php

@@ -11,6 +11,7 @@
 use Elastic\Elasticsearch\Exception\ServerResponseException;
 use Illuminate\Database\Schema\Builder as BaseBuilder;
 use Illuminate\Support\Arr;
+use Illuminate\Support\Str;
 use PDPhilip\Elasticsearch\Connection;
 use PDPhilip\Elasticsearch\Exceptions\LogicException;
 use PDPhilip\Elasticsearch\Laravel\Compatibility\Schema\BuilderCompatibility;
@@ -68,6 +69,46 @@ public function hasTable($table): bool
         return $this->connection->elastic()->indices()->exists($params)->asBool();
     }
 
+    public function getColumns($table): array
+    {
+        $index = $this->parseIndexName($table);
+        $params = ['index' => $index, 'fields' => ['*']];
+        $result = $this->connection->elastic()->indices()->getFieldMapping($params)->asArray();
+        $mappings = $result[$index]['mappings'] ?? [];
+        $columns[] = [
+            'name' => 'id',
+            'type_name' => 'text',
+            'type' => 'text',
+            'collation' => null,
+            'nullable' => false,
+            'default' => null,
+            'auto_increment' => false,
+            'comment' => null,
+            'generation' => null,
+        ];
+        foreach ($mappings as $field => $mapping) {
+
+            if (! Str::startsWith($field, '_')) {
+
+                $mapCollection = collect($mapping)->dot()->toArray();
+                $type = $mapCollection['mapping.'.$field.'.types'] ?? 'text';
+                $columns[] = [
+                    'name' => $field,
+                    'type_name' => $type,
+                    'type' => $type,
+                    'collation' => null,
+                    'nullable' => false,
+                    'default' => null,
+                    'auto_increment' => false,
+                    'comment' => null,
+                    'generation' => null,
+                ];
+            }
+        }
+
+        return $columns;
+    }
+
     public function hasColumn($table, $column): bool
     {
         $index = $this->parseIndexName($table);