support the new list feature

Author: mjarkk

go.mod

@@ -8,6 +8,6 @@ require (
 	github.com/andybalholm/brotli v1.0.4 // indirect
 	github.com/klauspost/compress v1.15.0 // indirect
 	github.com/valyala/bytebufferpool v1.0.0 // indirect
-	golang.org/x/crypto v0.0.0-20220817201139-bc19a97f63c8 // indirect
+	golang.org/x/crypto v0.0.0-20220817201139-bc19a97f63c8
 	golang.org/x/sys v0.0.0-20220227234510-4e6760a101f9 // indirect
 )

helpers.go

@@ -0,0 +1,17 @@
+package main
+
+import "errors"
+
+func checkIfCVHasReferenceNr(cv map[string]interface{}) (referenceNr string, err error) {
+	referenceNrInterf, ok := cv["referenceNumber"]
+	if !ok {
+		return "", errors.New("referenceNumber field does not exists")
+	}
+
+	referenceNr, ok = referenceNrInterf.(string)
+	if !ok {
+		return "", errors.New("referenceNumber must be a string")
+	}
+
+	return referenceNr, nil
+}

webserver.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	"encoding/json"
+	"fmt"
 	"log"
 	"net"
 	"strconv"
@@ -29,15 +30,9 @@ func startWebserver(env Env, api *API, loginUsers []EnvUser) string {
 				return
 			}
 
-			referenceNrInterf, ok := cvContent["referenceNumber"]
-			if !ok {
-				errorResp(ctx, 400, "referenceNumber field does not exists")
-				return
-			}
-
-			referenceNr, ok := referenceNrInterf.(string)
-			if !ok {
-				errorResp(ctx, 400, "referenceNumber must be a string")
+			referenceNr, err := checkIfCVHasReferenceNr(cvContent)
+			if err != nil {
+				errorResp(ctx, 400, err.Error())
 				return
 			}
 
@@ -76,6 +71,34 @@ func startWebserver(env Env, api *API, loginUsers []EnvUser) string {
 				}
 			}
 
+			ctx.Response.AppendBodyString("true")
+		case "/cvs_list":
+			cvsContent := []map[string]interface{}{}
+			err := json.Unmarshal(body, &cvsContent)
+			if err != nil {
+				errorResp(ctx, 400, "invalid CV")
+				return
+			}
+
+			for idx, cv := range cvsContent {
+				_, err := checkIfCVHasReferenceNr(cv)
+				if err != nil {
+					errorResp(ctx, 400, fmt.Sprintf("error in cv with index %d, error: %s", idx, err.Error()))
+					return
+				}
+			}
+
+			if !api.MockMode {
+				body := append(append([]byte(`{"cvs":`), body...), '}')
+				for _, conn := range api.connections {
+					err = conn.Post("/api/v1/scraper/allCVs", json.RawMessage(body), nil)
+					if err != nil {
+						errorResp(ctx, 500, err.Error())
+						return
+					}
+				}
+			}
+
 			ctx.Response.AppendBodyString("true")
 		case "/users":
 			ctx.Response.AppendBody(loginUsersJSON)