@@ -657,47 +657,39 @@ func (c *APIClient) ReplaceAllObjects(indexName string, objects []map[string]any
657657 return nil, err
658658 }
659659
660+ defer func() {
661+ _, _ = c.DeleteIndex(c.NewApiDeleteIndexRequest(tmpIndexName))
662+ } ()
663+
660664 opts = append(opts, WithWaitForTasks(true))
661665
662666 batchResp, err := c.ChunkedBatch(tmpIndexName, objects, ACTION_ADD_OBJECT, opts...)
663667 if err != nil {
664- _, _ = c.DeleteIndex(c.NewApiDeleteIndexRequest(tmpIndexName))
665-
666668 return nil, err
667669 }
668670
669671 _, err = c.WaitForTask(tmpIndexName, copyResp.TaskID, toIterableOptions(opts)...)
670672 if err != nil {
671- _, _ = c.DeleteIndex(c.NewApiDeleteIndexRequest(tmpIndexName))
672-
673673 return nil, err
674674 }
675675
676676 copyResp, err = c.OperationIndex(c.NewApiOperationIndexRequest(indexName, NewOperationIndexParams(OPERATION_TYPE_COPY, tmpIndexName, WithOperationIndexParamsScope([]ScopeType{ SCOPE_TYPE_SETTINGS, SCOPE_TYPE_RULES, SCOPE_TYPE_SYNONYMS} ))), toRequestOptions(opts)...)
677677 if err != nil {
678- _, _ = c.DeleteIndex(c.NewApiDeleteIndexRequest(tmpIndexName))
679-
680678 return nil, err
681679 }
682680
683681 _, err = c.WaitForTask(tmpIndexName, copyResp.TaskID, toIterableOptions(opts)...)
684682 if err != nil {
685- _, _ = c.DeleteIndex(c.NewApiDeleteIndexRequest(tmpIndexName))
686-
687683 return nil, err
688684 }
689685
690686 moveResp, err := c.OperationIndex(c.NewApiOperationIndexRequest(tmpIndexName, NewOperationIndexParams(OPERATION_TYPE_MOVE, indexName)), toRequestOptions(opts)...)
691687 if err != nil {
692- _, _ = c.DeleteIndex(c.NewApiDeleteIndexRequest(tmpIndexName))
693-
694688 return nil, err
695689 }
696690
697691 _, err = c.WaitForTask(tmpIndexName, moveResp.TaskID, toIterableOptions(opts)...)
698692 if err != nil {
699- _, _ = c.DeleteIndex(c.NewApiDeleteIndexRequest(tmpIndexName))
700-
701693 return nil, err
702694 }
703695
0 commit comments