Add blockchain audit endpoints

Author: AmirAbrams

https/rest/audit.go

@@ -0,0 +1,72 @@
+package rest
+
+import (
+	"dyn-https/blockchain/dynamic"
+	"dyn-https/models"
+	"encoding/json"
+	"fmt"
+	"io/ioutil"
+	"net/http"
+
+	"github.com/gin-gonic/gin"
+)
+
+func (w *WebProxy) addaudit(c *gin.Context) {
+	body, err := ioutil.ReadAll(c.Request.Body)
+	if err != nil {
+		strErrMsg := fmt.Sprintf("Request body read all error %v", err)
+		c.JSON(http.StatusBadRequest, gin.H{"error": strErrMsg})
+		return
+	}
+	if len(body) == 0 {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "Request body is empty"})
+		return
+	}
+	req := models.AuditAddRequest{}
+	err = json.Unmarshal(body, &req)
+	if err != nil {
+		strErrMsg := fmt.Sprintf("Request body JSON unmarshal error %v", err)
+		c.JSON(http.StatusBadRequest, gin.H{"error": strErrMsg})
+		return
+	}
+	//audit add "hash_array" ( "account" ) ( "description" ) ( "algorithm" )
+	cmd, _ := dynamic.NewRequest(`dynamic-cli audit add "` + req.HashArray + `" "` + req.Account +
+		`"` + `" "` + req.Description + `"` + `" "` + req.Algorithm + `"`)
+	response, _ := <-w.dynamicd.ExecCmdRequest(cmd)
+	var result interface{}
+	err = json.Unmarshal([]byte(response), &result)
+	if err != nil {
+		strErrMsg := fmt.Sprintf("Results JSON unmarshal error %v", err)
+		c.JSON(http.StatusBadRequest, gin.H{"error": strErrMsg})
+		return
+	}
+	c.JSON(http.StatusOK, result)
+}
+
+func (w *WebProxy) getaudit(c *gin.Context) {
+	Id := c.Param("UserID")
+	cmd, _ := dynamic.NewRequest(`dynamic-cli audit get "` + Id + `"`)
+	response, _ := <-w.dynamicd.ExecCmdRequest(cmd)
+	var result interface{}
+	err := json.Unmarshal([]byte(response), &result)
+	if err != nil {
+		strErrMsg := fmt.Sprintf("Results JSON unmarshal error %v", err)
+		c.JSON(http.StatusBadRequest, gin.H{"error": strErrMsg})
+		return
+	}
+	c.JSON(http.StatusOK, result)
+}
+
+func (w *WebProxy) verifyaudit(c *gin.Context) {
+	hash := c.Param("Hash")
+	cmd, _ := dynamic.NewRequest(`dynamic-cli audit verify "` + hash + `"`)
+	response, _ := <-w.dynamicd.ExecCmdRequest(cmd)
+	var result interface{}
+	err := json.Unmarshal([]byte(response), &result)
+	if err != nil {
+		strErrMsg := fmt.Sprintf("Results JSON unmarshal error %v", err)
+		c.JSON(http.StatusBadRequest, gin.H{"error": strErrMsg})
+		return
+	}
+	c.JSON(http.StatusOK, result)
+}

https/rest/router.go

@@ -191,6 +191,9 @@ func setupBlockchainRoutes(currentVersion *gin.RouterGroup) {
 	blockchain.GET("/users/:UserID", runner.user)
 	blockchain.GET("/groups", runner.groups)
 	blockchain.GET("/groups/:GroupID", runner.group)
+	blockchain.POST("/audit", runner.addaudit)
+	blockchain.GET("/audit/:Id", runner.getaudit)
+	blockchain.GET("/audit/verify/:Hash", runner.verifyaudit)
 }
 
 // TODO: follow https://rest.bitcoin.com for rest endpoints

models/audit.go

@@ -0,0 +1,12 @@
+package models
+
+type AuditAddRequest struct {
+	HashArray   string `json:"hash_array"`
+	Account     string `json:"account"`
+	Description string `json:"description"`
+	Algorithm   string `json:"algorithm"`
+}
+
+type AuditVerifyRequest struct {
+	Hash string `json:"audit_hash"`
+}