equal
deleted
inserted
replaced
72 * @return int (1 if sucess, 0 if error) |
72 * @return int (1 if sucess, 0 if error) |
73 */ |
73 */ |
74 private function resetIndex() |
74 private function resetIndex() |
75 { |
75 { |
76 $indexParams = [ |
76 $indexParams = [ |
77 'index' => env('ELASTICSEARCH_INDEX') |
77 'index' => config('elasticsearch.index') |
78 ]; |
78 ]; |
79 if(Es::indices()->exists($indexParams)){ |
79 if(Es::indices()->exists($indexParams)){ |
80 $response = Es::indices()->delete($indexParams); |
80 $response = Es::indices()->delete($indexParams); |
81 if($response['acknowledged']!=1){ |
81 if($response['acknowledged']!=1){ |
82 return 0; |
82 return 0; |
598 $success = $this->resetIndex(); |
598 $success = $this->resetIndex(); |
599 if($success==1){ |
599 if($success==1){ |
600 $this->comment('Index reset!'); |
600 $this->comment('Index reset!'); |
601 } |
601 } |
602 else{ |
602 else{ |
603 $this->error('Error resetting index ' . env('ELASTICSEARCH_INDEX')); |
603 $this->error('Error resetting index ' . config('elasticsearch.index')); |
604 } |
604 } |
605 |
605 |
606 $this->info('Indexing documents...'); |
606 $this->info('Indexing documents...'); |
607 |
607 |
608 $limit = (int)$limit; |
608 $limit = (int)$limit; |