Update v1 elasticsearch when ranking mapset

Author: Swan

config.example.json

@@ -10,6 +10,10 @@
       "127.0.0.1"
     ]
   },
+  "api_v1": {
+    "url": "http://localhost:8082",
+    "secret_key": ""
+  },
   "steam": {
     "app_id": 980610,
     "publisher_key": "",

config/config.go

@@ -21,6 +21,11 @@ type Config struct {
 		RateLimitIpWhitelist []string `json:"rate_limit_ip_whitelist"`
 	} `json:"server"`
 
+	ApiV1 struct {
+		Url       string `json:"url"`
+		SecretKey string `json:"secret_key"`
+	} `json:"api_v1"`
+
 	Steam struct {
 		AppId                   int    `json:"app_id"`
 		PublisherKey            string `json:"publisher_key"`

handlers/ranking_actions.go

@@ -4,8 +4,10 @@ import (
 	"github.com/Quaver/api2/config"
 	"github.com/Quaver/api2/db"
 	"github.com/Quaver/api2/enums"
+	v1 "github.com/Quaver/api2/v1"
 	"github.com/Quaver/api2/webhooks"
 	"github.com/gin-gonic/gin"
+	"github.com/sirupsen/logrus"
 	"gorm.io/gorm"
 	"net/http"
 	"strconv"
@@ -155,6 +157,10 @@ func VoteForRankingQueueMapset(c *gin.Context) *APIError {
 			return APIErrorServerError("Error inserting ranked mapset notification", err)
 		}
 
+		if err := v1.UpdateElasticSearchMapset(data.QueueMapset.MapsetId); err != nil {
+			logrus.Warn("Error updating v1 elastic search for mapset: ", data.QueueMapset.MapsetId, err)
+		}
+
 		_ = webhooks.SendRankedWebhook(data.QueueMapset.Mapset, existingVotes)
 	}
 

v1/elastic.go

@@ -0,0 +1,27 @@
+package v1
+
+import (
+	"fmt"
+	"github.com/Quaver/api2/config"
+	"github.com/go-resty/resty/v2"
+)
+
+// UpdateElasticSearchMapset Makes an API call to v1 to update elastic search for a given mapset
+func UpdateElasticSearchMapset(id int) error {
+	resp, err := resty.New().R().
+		SetHeader("Accept", "application/json").
+		SetBody(map[string]interface{}{
+			"key": config.Instance.ApiV1.SecretKey,
+			"id":  id,
+		}).Post(fmt.Sprintf("%v/v1/mapsets/elastic", config.Instance.ApiV1.Url))
+
+	if err != nil {
+		return err
+	}
+
+	if resp.IsError() {
+		return fmt.Errorf("request to update elastic mapset (v1) failed: %v", resp.Error())
+	}
+
+	return nil
+}