Keyword sanitize on aggs & base migration

Author: pdphilip

src/DSL/Bridge.php

@@ -844,9 +844,15 @@ private function processBuckets($columns, $keys, $response, $index, $includeDocC
         if (!empty($response[$keys[$index]]['buckets'])) {
             foreach ($response[$keys[$index]]['buckets'] as $res) {
                 $datum = $currentData;
-                $datum[$columns[$index]] = $res['key'];
+                //clear keyword from column name
+                $col = $columns[$index];
+                if (str_contains($col, '.keyword')) {
+                    $col = str_replace('.keyword', '', $col);
+                }
+                
+                $datum[$col] = $res['key'];
                 if ($includeDocCount) {
-                    $datum[$columns[$index].'_count'] = $res['doc_count'];
+                    $datum[$col.'_count'] = $res['doc_count'];
                 }
 
                 if (isset($columns[$index + 1])) {

src/Schema/Builder.php

@@ -269,6 +269,15 @@ private function _sanitizeFlatFields($flatFields)
         return $fields;
     }
 
+    //----------------------------------------------------------------------
+    // Internal Laravel init migration catchers
+    // *Case for when ES is the only datasource
+    //----------------------------------------------------------------------
+    public function hasTable($table)
+    {
+        return $this->getIndex($table);
+    }
+    
 
     //----------------------------------------------------------------------
     // Builders

src/Schema/IndexBlueprint.php

@@ -165,6 +165,21 @@ public function buildIndexModify(Connection $connection)
         }
     }
 
+    //----------------------------------------------------------------------
+    // Internal Laravel init migration catchers
+    // *Case for when ES is the only datasource
+    //----------------------------------------------------------------------
+    
+    public function increments($column)
+    {
+        return $this->addField('keyword', $column);
+    }
+    
+    public function string($column)
+    {
+        return $this->addField('keyword', $column);
+    }
+    
     //----------------------------------------------------------------------
     // Helpers
     //----------------------------------------------------------------------