style: Deactivate future-use code blocks and annotate server.go for c…

…larity

nimbus-kubearmor/processor/network_policy.go

@@ -1,8 +1,9 @@
 // SPDX-License-Identifier: Apache-2.0
 // Copyright 2023 Authors of Nimbus
 
-package policy
+package processor
 
+/*
 import (
 	"context"
 
@@ -61,3 +62,4 @@ func (npc *NetworkPolicyController) DeletePolicy(ctx context.Context, bindingInf
 	log.Info("Deleted Network Policy", "PolicyName", bindingInfo.Binding.Name)
 	return nil
 }
+*/

nimbus-kubearmor/processor/system_policy.go

@@ -1,8 +1,9 @@
 // SPDX-License-Identifier: Apache-2.0
 // Copyright 2023 Authors of Nimbus
 
-package policy
+package processor
 
+/*
 import (
 	"context"
 
@@ -60,3 +61,4 @@ func (spc *SystemPolicyController) DeletePolicy(ctx context.Context, bindingInfo
 	log.Info("Deleted System Policy", "PolicyName", bindingInfo.Binding.Name)
 	return nil
 }
+*/

nimbus-kubearmor/processor/utils/utils_policy.go

@@ -3,6 +3,7 @@
 
 package utils
 
+/*
 import (
 	"context"
 	"fmt"
@@ -423,3 +424,4 @@ func DeletePolicy(ctx context.Context, c client.Client, policyType, name, namesp
 	}
 	return nil
 }
+*/

nimbus-kubearmor/receiver/server/server.go

@@ -10,42 +10,46 @@ import (
 )
 
 var (
-	// 저장된 Nimbus Policy를 저장하는 메모리 저장소
+	// Memory store for saved Nimbus Policies
 	nimbusPolicies []interface{}
 	lock           sync.Mutex
 )
 
 func main() {
+	// Handler for exporting Nimbus Policies
 	http.HandleFunc("/api/v1/nimbus/export", func(w http.ResponseWriter, r *http.Request) {
 		if r.Method != "POST" {
 			http.Error(w, "Only POST method is accepted", http.StatusMethodNotAllowed)
 			return
 		}
 
+		// Read the request body
 		body, err := ioutil.ReadAll(r.Body)
 		if err != nil {
 			http.Error(w, "Error reading request body", http.StatusInternalServerError)
 			return
 		}
 		defer r.Body.Close()
 
+		// Unmarshal the JSON data from the request
 		var data interface{}
 		err = json.Unmarshal(body, &data)
 		if err != nil {
 			http.Error(w, "Error unmarshalling request body", http.StatusBadRequest)
 			return
 		}
 
-		// 수신된 Nimbus Policy 저장
+		// Store the received Nimbus Policy
 		lock.Lock()
 		nimbusPolicies = append(nimbusPolicies, data)
 		lock.Unlock()
 
+		// Log the received policy
 		fmt.Printf("Received Nimbus Policy: %+v\n", data)
 		w.WriteHeader(http.StatusOK)
 	})
 
-	// 저장된 Nimbus Policies를 조회하는 API
+	// Handler for retrieving stored Nimbus Policies
 	http.HandleFunc("/api/v1/nimbus/policies", func(w http.ResponseWriter, r *http.Request) {
 		if r.Method != "GET" {
 			http.Error(w, "Only GET method is accepted", http.StatusMethodNotAllowed)
@@ -54,11 +58,13 @@ func main() {
 
 		lock.Lock()
 		defer lock.Unlock()
+		// Encode and respond with the stored policies
 		if err := json.NewEncoder(w).Encode(nimbusPolicies); err != nil {
 			http.Error(w, "Error encoding response", http.StatusInternalServerError)
 		}
 	})
 
+	// Start the server on port 13000
 	log.Println("Server starting on port 13000...")
 	log.Fatal(http.ListenAndServe(":13000", nil))
 }