Skip to content

Commit a5932cc

Browse files
committed
Use JSONRPC struct for post audit
1 parent d4d3375 commit a5932cc

File tree

1 file changed

+32
-7
lines changed

1 file changed

+32
-7
lines changed

https/rest/audit.go

Lines changed: 32 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@ package rest
33
import (
44
"dyn-https/blockchain/dynamic"
55
"dyn-https/models"
6+
"dyn-https/util"
67
"encoding/json"
78
"fmt"
89
"io/ioutil"
@@ -29,9 +30,19 @@ func (w *WebProxy) addaudit(c *gin.Context) {
2930
c.JSON(http.StatusBadRequest, gin.H{"error": strErrMsg})
3031
return
3132
}
33+
34+
jsonRPC := models.JSONRPC{}
35+
jsonRPC.ID, _ = util.RandomHashString(9)
36+
jsonRPC.Method = "audit"
37+
jsonRPC.JSONRPC = "1.0"
38+
jsonRPC.Params = make([]interface{}, 5)
3239
//audit add "hash_array" ( "account" ) ( "description" ) ( "algorithm" )
33-
cmd, _ := dynamic.NewRequest(`dynamic-cli audit add "` + req.HashArray + `" "` + req.Account +
34-
`"` + `" "` + req.Description + `"` + `" "` + req.Algorithm + `"`)
40+
jsonRPC.Params[0] = "add"
41+
jsonRPC.Params[1] = req.HashArray
42+
jsonRPC.Params[2] = req.Account
43+
jsonRPC.Params[3] = req.Description
44+
jsonRPC.Params[4] = req.Algorithm
45+
cmd, err := dynamic.GetNewRequest(jsonRPC)
3546
response, _ := <-w.dynamicd.ExecCmdRequest(cmd)
3647
var result interface{}
3748
err = json.Unmarshal([]byte(response), &result)
@@ -44,11 +55,18 @@ func (w *WebProxy) addaudit(c *gin.Context) {
4455
}
4556

4657
func (w *WebProxy) getaudit(c *gin.Context) {
47-
Id := c.Param("UserID")
48-
cmd, _ := dynamic.NewRequest(`dynamic-cli audit get "` + Id + `"`)
58+
Id := c.Param("Id")
59+
jsonRPC := models.JSONRPC{}
60+
jsonRPC.ID, _ = util.RandomHashString(9)
61+
jsonRPC.Method = "audit"
62+
jsonRPC.JSONRPC = "1.0"
63+
jsonRPC.Params = make([]interface{}, 2)
64+
jsonRPC.Params[0] = "get"
65+
jsonRPC.Params[1] = Id
66+
cmd, err := dynamic.GetNewRequest(jsonRPC)
4967
response, _ := <-w.dynamicd.ExecCmdRequest(cmd)
5068
var result interface{}
51-
err := json.Unmarshal([]byte(response), &result)
69+
err = json.Unmarshal([]byte(response), &result)
5270
if err != nil {
5371
strErrMsg := fmt.Sprintf("Results JSON unmarshal error %v", err)
5472
c.JSON(http.StatusBadRequest, gin.H{"error": strErrMsg})
@@ -59,10 +77,17 @@ func (w *WebProxy) getaudit(c *gin.Context) {
5977

6078
func (w *WebProxy) verifyaudit(c *gin.Context) {
6179
hash := c.Param("Hash")
62-
cmd, _ := dynamic.NewRequest(`dynamic-cli audit verify "` + hash + `"`)
80+
jsonRPC := models.JSONRPC{}
81+
jsonRPC.ID, _ = util.RandomHashString(9)
82+
jsonRPC.Method = "audit"
83+
jsonRPC.JSONRPC = "1.0"
84+
jsonRPC.Params = make([]interface{}, 2)
85+
jsonRPC.Params[0] = "verify"
86+
jsonRPC.Params[1] = hash
87+
cmd, err := dynamic.GetNewRequest(jsonRPC)
6388
response, _ := <-w.dynamicd.ExecCmdRequest(cmd)
6489
var result interface{}
65-
err := json.Unmarshal([]byte(response), &result)
90+
err = json.Unmarshal([]byte(response), &result)
6691
if err != nil {
6792
strErrMsg := fmt.Sprintf("Results JSON unmarshal error %v", err)
6893
c.JSON(http.StatusBadRequest, gin.H{"error": strErrMsg})

0 commit comments

Comments
 (0)