MiscMirror/gossa
1
0
Fork 0
mirror of https://github.com/pldubouilh/gossa.git synced 2026-09-05 16:47:39 -04:00
Code Issues Packages Projects Releases Wiki Activity

small refactor

Browse Source
This commit is contained in:
Pierre Dubouilh
2019-10-15 19:39:42 +02:00
parent d913176daa
commit 0b586c5df9
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/gossa.go
+5 -4
View File
@@ -159,9 +159,10 @@ func rpc(w http.ResponseWriter, r *http.Request) {
bodyBytes, _ := ioutil.ReadAll(r.Body) bodyBytes, _ := ioutil.ReadAll(r.Body)
json.Unmarshal(bodyBytes, &rpc) json.Unmarshal(bodyBytes, &rpc)
defer exitPath(w, "rpc", rpc) defer exitPath(w, "rpc", rpc)
ret := "ok"
stateLock.Lock() stateLock.Lock()
defer stateLock.Unlock() defer stateLock.Unlock()
ret := "ok"
key := hash(r.Header.Get("Authorization") + rpc.Args[0])
if rpc.Call == "mkdirp" { if rpc.Call == "mkdirp" {
err = os.MkdirAll(checkPath(rpc.Args[0]), os.ModePerm) err = os.MkdirAll(checkPath(rpc.Args[0]), os.ModePerm)
@@ -171,14 +172,14 @@ func rpc(w http.ResponseWriter, r *http.Request) {
err = os.RemoveAll(checkPath(rpc.Args[0])) err = os.RemoveAll(checkPath(rpc.Args[0]))
} else if rpc.Call == "historySet" && *history { } else if rpc.Call == "historySet" && *history {
if rpc.Args[2] == "hash" { if rpc.Args[2] == "hash" {
state[hash(r.Header.Get("Authorization")+rpc.Args[0])] = hash(rpc.Args[1]) state[key] = hash(rpc.Args[1])
} else { } else {
state[hash(r.Header.Get("Authorization")+rpc.Args[0])] = rpc.Args[1] state[key] = rpc.Args[1]
} }
f, _ := json.MarshalIndent(state, "", " ") f, _ := json.MarshalIndent(state, "", " ")
ioutil.WriteFile(historyPath, f, 0644) ioutil.WriteFile(historyPath, f, 0644)
} else if rpc.Call == "historyGet" && *history { } else if rpc.Call == "historyGet" && *history {
ret = state[hash(r.Header.Get("Authorization")+rpc.Args[0])] ret = state[key]
} }
check(err) check(err)