Replication fixed

Author: krystian-panek-vmltech

.gitignore

@@ -223,3 +223,16 @@ $RECYCLE.BIN/
 dist/
 **/aem/home/
 !pkg/instance/resource
+
+
+# VSCode
+.vscode/*
+!.vscode/settings.json
+!.vscode/tasks.json
+!.vscode/launch.json
+!.vscode/extensions.json
+!.vscode/*.code-snippets
+!*.code-workspace
+
+# Built Visual Studio Code Extensions
+*.vsix

.vscode/launch.json

@@ -0,0 +1,28 @@
+{
+    // Use IntelliSense to learn about possible attributes.
+    // Hover to view descriptions of existing attributes.
+    // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+    "version": "0.2.0",
+    "configurations": [
+        {
+            "name": "Print help",
+            "type": "go",
+            "request": "launch",
+            "mode": "auto",
+            "program": "${workspaceFolder}/cmd/aem",
+            "args": ["--help"],
+            "env": {},
+            "cwd": "${workspaceFolder}"
+        },
+        {
+            "name": "Replicate node",
+            "type": "go",
+            "request": "launch",
+            "mode": "auto",
+            "program": "${workspaceFolder}/cmd/aem",
+            "args": ["repl", "activate", "-A", "--path", "/content/projects/jcr:content"],
+            "env": {},
+            "cwd": "${workspaceFolder}"
+        }
+    ]
+}

pkg/repl.go

@@ -2,11 +2,12 @@ package pkg
 
 import (
 	"fmt"
+	"io"
+
 	log "github.com/sirupsen/logrus"
 	"github.com/spf13/cast"
 	"github.com/wttech/aemc/pkg/replication"
 	"github.com/wttech/aemc/pkg/sling"
-	"io"
 )
 
 type Replication struct {
@@ -63,16 +64,16 @@ func (r Replication) replicate(cmd string, path string) error {
 	} else if response.IsError() {
 		return fmt.Errorf("%s > cannot do replication command '%s' for path '%s': %s", r.instance.IDColor(), cmd, path, response.Status())
 	}
-	htmlBytes, err := io.ReadAll(response.RawBody())
+	jsonBytes, err := io.ReadAll(response.RawBody())
 	if err != nil {
 		return fmt.Errorf("%s > cannot read replication command '%s' response for path '%s': %w", r.instance.IDColor(), cmd, path, err)
 	}
-	htmlData, err := sling.HtmlData(string(htmlBytes))
+	jsonData, err := sling.JsonData(string(jsonBytes))
 	if err != nil {
-		return fmt.Errorf("%s > cannot parse replication command '%s' response for path '%s': %w", r.instance.IDColor(), cmd, path, err)
+		return fmt.Errorf("%s > cannot parse replication command '%s' JSON response for path '%s': %w", r.instance.IDColor(), cmd, path, err)
 	}
-	if htmlData.IsError() {
-		return fmt.Errorf("%s > cannot do replication command '%s' for path '%s': %s", r.instance.IDColor(), cmd, path, htmlData.Message)
+	if jsonData.IsError() {
+		return fmt.Errorf("%s > replication command '%s' failed for path '%s': %s", r.instance.IDColor(), cmd, path, jsonData.Message)
 	}
 	return nil
 }

pkg/sling/html_response.go

@@ -1,9 +1,10 @@
 package sling
 
 import (
+	"strings"
+
 	"github.com/PuerkitoBio/goquery"
 	"github.com/spf13/cast"
-	"strings"
 )
 
 type HTMLData struct {

pkg/sling/json_response.go

@@ -0,0 +1,34 @@
+package sling
+
+import (
+	"encoding/json"
+
+	"github.com/spf13/cast"
+)
+
+type JSONData struct {
+	Status        int
+	Message       string
+	Path          []string
+	StatusMessage string
+	StatusCode    int
+}
+
+func JsonData(jsonStr string) (data JSONData, err error) {
+	var rawData map[string]any
+	if err := json.Unmarshal([]byte(jsonStr), &rawData); err != nil {
+		return data, err
+	}
+
+	data.Path = cast.ToStringSlice(rawData["path"])
+	data.StatusMessage = cast.ToString(rawData["status.message"])
+	data.Message = data.StatusMessage
+	data.StatusCode = cast.ToInt(rawData["status.code"])
+	data.Status = data.StatusCode
+
+	return data, nil
+}
+
+func (d JSONData) IsError() bool {
+	return d.Status <= 0 || d.Status > 399
+}