Skip to content

Commit

Permalink
fix: update setting and mapping api
Browse files Browse the repository at this point in the history
  • Loading branch information
hengfeiyang committed Jun 3, 2022
1 parent 36bbf9c commit 4a155c2
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 13 deletions.
8 changes: 4 additions & 4 deletions pkg/handlers/index/mapping.go
Original file line number Diff line number Diff line change
Expand Up @@ -49,13 +49,13 @@ func SetMapping(c *gin.Context) {
return
}

var newIndex meta.IndexSimple
if err := c.BindJSON(&newIndex); err != nil {
var mappingRequest map[string]interface{}
if err := c.BindJSON(&mappingRequest); err != nil {
c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
return
}

mappings, err := mappings.Request(nil, newIndex.Mappings)
mappings, err := mappings.Request(nil, mappingRequest)
if err != nil {
c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
return
Expand All @@ -79,7 +79,7 @@ func SetMapping(c *gin.Context) {
mappings = index.Mappings
} else {
// create index
index, err = core.NewIndex(indexName, newIndex.StorageType, nil)
index, err = core.NewIndex(indexName, "", nil)
if err != nil {
c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
return
Expand Down
18 changes: 9 additions & 9 deletions pkg/handlers/index/settings.go
Original file line number Diff line number Diff line change
Expand Up @@ -49,18 +49,18 @@ func SetSettings(c *gin.Context) {
return
}

var newIndex core.Index
if err := c.BindJSON(&newIndex); err != nil {
var settings *meta.IndexSettings
if err := c.BindJSON(&settings); err != nil {
c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
return
}

if newIndex.Settings == nil {
if settings == nil {
c.JSON(http.StatusOK, gin.H{"message": "ok"})
return
}

analyzers, err := zincanalysis.RequestAnalyzer(newIndex.Settings.Analysis)
analyzers, err := zincanalysis.RequestAnalyzer(settings.Analysis)
if err != nil {
c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
return
Expand All @@ -69,10 +69,10 @@ func SetSettings(c *gin.Context) {
index, exists := core.GetIndex(indexName)
if exists {
// it can only change settings.NumberOfReplicas when index exists
if newIndex.Settings.NumberOfReplicas > 0 {
index.Settings.NumberOfReplicas = newIndex.Settings.NumberOfReplicas
if settings.NumberOfReplicas > 0 {
index.Settings.NumberOfReplicas = settings.NumberOfReplicas
}
if newIndex.Settings.Analysis != nil && len(newIndex.Settings.Analysis.Analyzer) > 0 {
if settings.Analysis != nil && len(settings.Analysis.Analyzer) > 0 {
c.JSON(http.StatusBadRequest, gin.H{"error": "can't update analyzer for existing index"})
return
}
Expand All @@ -90,14 +90,14 @@ func SetSettings(c *gin.Context) {
if analyzers != nil {
defaultSearchAnalyzer = analyzers["default"]
}
index, err = core.NewIndex(indexName, newIndex.StorageType, defaultSearchAnalyzer)
index, err = core.NewIndex(indexName, "", defaultSearchAnalyzer)
if err != nil {
c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
return
}

// update settings
_ = index.SetSettings(newIndex.Settings)
_ = index.SetSettings(settings)

// update analyzers
_ = index.SetAnalyzers(analyzers)
Expand Down

0 comments on commit 4a155c2

Please sign in to comment.