Update installer to use new update-sent endpoint

Author: Kbayero

installer/config/const.go

@@ -5,14 +5,24 @@ import (
 	"time"
 )
 
-const INSTALLER_VERSION = ""
-const REPLACE = ""
-const PUBLIC_KEY = ``
+const INSTALLER_VERSION = "v11.0.0-alpha.1"
+const REPLACE = "0aXq879sPfvy2Zrc"
+const PUBLIC_KEY = `-----BEGIN PUBLIC KEY-----
+MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAxoZ5m/bsj4NOlSblXPg3
+eGbx2nCg5jMoVsCevxX64+MkOpwHBNiA0VPCZfOrdv2atWbOnJ7KfmZJWWZFSlTf
+tJ6VA0jaODnSlQeoTn/XIMKkfyzxKgLN+miG89M4ysidZgHPYlwz8+R1gIPouxYa
+BUQ8mUgRrkW3JCpYoGvf6k0Od9k8NXdR52rFf0Ryl6oGwedOWh/tiYE0he0pWkB7
+zPAveFqvxJnte4aN1Xjv2Qp1OmQVvc37RMZsh8oNpfYTMxrGFWZpBmF61NLXOYjn
+YtvKtxUQPR/TOf9p55H9cFeRf2LzSAM4L3NQ3Xdss6eWndjywL5Giqd2gtrD/1Tt
++wIDAQAB
+-----END PUBLIC KEY-----
+`
 
 const (
 	RegisterInstanceEndpoint   = "/api/v1/instances/register"
 	GetInstanceDetailsEndpoint = "/api/v1/instances"
 	GetUpdatesInfoEndpoint     = "/api/v1/updates"
+	SetUpdateSentEndpoint      = "/api/v1/updates/sent"
 	GetLicenseEndpoint         = "/api/v1/licenses"
 	HealthEndpoint             = "/api/v1/health"
 	LogCollectorEndpoint       = "/api/v1/logcollectors/upload"

installer/updater/client.go

@@ -99,6 +99,7 @@ func (c *UpdaterClient) CheckUpdate() error {
 			newUpdate["version"] = update.Version.Version
 			newUpdate["edition"] = update.Instance.Edition
 			newUpdate["changelog"] = update.Version.Changelog
+			newUpdate["id"] = update.ID
 			updates = append(updates, newUpdate)
 		}
 	} else {
@@ -110,6 +111,7 @@ func (c *UpdaterClient) CheckUpdate() error {
 		newUpdate["version"] = v
 		newUpdate["edition"] = "enterprise"
 		newUpdate["changelog"] = "No changelog available for offline version"
+		newUpdate["id"] = "offline"
 		updates = append(updates, newUpdate)
 	}
 
@@ -124,6 +126,12 @@ func (c *UpdaterClient) CheckUpdate() error {
 			if err != nil {
 				return fmt.Errorf("error updating to new version: %v", err)
 			}
+			if update["id"] != "offline" {
+				err = c.MarkUpdateSent(update["id"])
+				if err != nil {
+					return fmt.Errorf("error marking update as sent: %v", err)
+				}
+			}
 		}
 	}
 
@@ -155,6 +163,21 @@ func (c *UpdaterClient) UpdateToNewVersion(version, edition, changelog string) e
 	return nil
 }
 
+func (c *UpdaterClient) MarkUpdateSent(updateId string) error {
+	url := fmt.Sprintf("%s%s?id=%s", c.Config.Server, config.SetUpdateSentEndpoint, updateId)
+	_, status, err := utils.DoReq[any](
+		url,
+		nil,
+		http.MethodPost,
+		map[string]string{"id": c.Config.InstanceID, "key": c.Config.InstanceKey},
+		nil,
+	)
+	if err != nil || status != http.StatusOK {
+		return fmt.Errorf("error marking update as sent: status: %d, error: %v", status, err)
+	}
+	return nil
+}
+
 func (c *UpdaterClient) UploadLogs(ctx context.Context, path string) error {
 	url := fmt.Sprintf("%s%s", c.Config.Server, config.LogCollectorEndpoint)