cosmetics

This commit is contained in:
nikk gitanes
2024-05-26 00:33:00 +03:00
parent cb0f0dd194
commit 6505d6e55d
4 changed files with 16 additions and 14 deletions

View File

@@ -41,7 +41,6 @@ func (v *JsonDB) CloseDB() {
func (v *JsonDB) Set(xPath, name string, value []byte) { func (v *JsonDB) Set(xPath, name string, value []byte) {
var err error = nil var err error = nil
jsonObj := map[string]interface{}{} jsonObj := map[string]interface{}{}
if err := json.Unmarshal(value, &jsonObj); err == nil { if err := json.Unmarshal(value, &jsonObj); err == nil {
if filename, err := v.xPathToFilename(xPath); err == nil { if filename, err := v.xPathToFilename(xPath); err == nil {
v.lock(filename) v.lock(filename)
@@ -101,10 +100,11 @@ func (v *JsonDB) Rem(xPath, name string) {
defer v.unlock(filename) defer v.unlock(filename)
if root, err := v.readJsonFileAsMap(filename); err == nil { if root, err := v.readJsonFileAsMap(filename); err == nil {
delete(root, name) delete(root, name)
v.writeMapAsJsonFile(filename, root) if err = v.writeMapAsJsonFile(filename, root); err == nil {
return return
} }
} }
}
v.log(fmt.Sprintf("Rem: error removing entry %s->%s", xPath, name), err) v.log(fmt.Sprintf("Rem: error removing entry %s->%s", xPath, name), err)
} }
@@ -135,7 +135,9 @@ func (v *JsonDB) readJsonFileAsMap(filename string) (map[string]interface{}, err
jsonData := map[string]interface{}{} jsonData := map[string]interface{}{}
path := filepath.Join(v.Path, filename) path := filepath.Join(v.Path, filename)
if fileData, err := os.ReadFile(path); err == nil { if fileData, err := os.ReadFile(path); err == nil {
err = json.Unmarshal(fileData, &jsonData) if err = json.Unmarshal(fileData, &jsonData); err != nil {
v.log(fmt.Sprintf("readJsonFileAsMap fileData: %s error", fileData), err)
}
} }
return jsonData, err return jsonData, err
} }
@@ -143,9 +145,10 @@ func (v *JsonDB) readJsonFileAsMap(filename string) (map[string]interface{}, err
func (v *JsonDB) writeMapAsJsonFile(filename string, o map[string]interface{}) error { func (v *JsonDB) writeMapAsJsonFile(filename string, o map[string]interface{}) error {
var err error = nil var err error = nil
path := filepath.Join(v.Path, filename) path := filepath.Join(v.Path, filename)
if fileData, err := json.MarshalIndent(o, "", " "); err == nil { if fileData, err := json.MarshalIndent(o, "", " "); err == nil {
err = os.WriteFile(path, fileData, v.fileMode) if err = os.WriteFile(path, fileData, v.fileMode); err != nil {
v.log(fmt.Sprintf("writeMapAsJsonFile path: %s, fileMode: %s, fileData: %s error", path, v.fileMode, fileData), err)
}
} }
return err return err
} }

View File

@@ -1,7 +1,6 @@
package settings package settings
import ( import (
"fmt"
"os" "os"
"path/filepath" "path/filepath"
@@ -49,7 +48,7 @@ func InitSets(readOnly, searchWA bool) {
// We migrate settings here, it must be done before loadBTSets() // We migrate settings here, it must be done before loadBTSets()
if err := Migrate2(bboltDB, jsonDB); err != nil { if err := Migrate2(bboltDB, jsonDB); err != nil {
log.TLogln(fmt.Sprintf("Migrate2 failed")) log.TLogln("Migrate2 failed")
os.Exit(1) os.Exit(1)
} }
loadBTSets() loadBTSets()

View File

@@ -93,8 +93,6 @@ func ListViewed(hash string) []*Viewed {
return ret return ret
} }
if err != nil {
log.TLogln("Error list viewed:", err) log.TLogln("Error list viewed:", err)
}
return []*Viewed{} return []*Viewed{}
} }

View File

@@ -43,7 +43,7 @@ var start = struct {
func SetupRoute(r gin.IRouter) { func SetupRoute(r gin.IRouter) {
authorized := r.Group("/", auth.CheckAuth()) authorized := r.Group("/", auth.CheckAuth())
//MSX: // MSX:
authorized.Any("/msx/*pth", func(c *gin.Context) { authorized.Any("/msx/*pth", func(c *gin.Context) {
switch p := strings.TrimPrefix(c.Param("pth"), "/"); p { switch p := strings.TrimPrefix(c.Param("pth"), "/"); p {
case "start.json": case "start.json":
@@ -64,7 +64,7 @@ func SetupRoute(r gin.IRouter) {
} }
} }
}) })
//files: // files:
authorized.GET("/files", func(c *gin.Context) { authorized.GET("/files", func(c *gin.Context) {
if l, e := os.Readlink(files); e == nil || os.IsNotExist(e) { if l, e := os.Readlink(files); e == nil || os.IsNotExist(e) {
c.JSON(200, l) c.JSON(200, l)
@@ -85,7 +85,7 @@ func SetupRoute(r gin.IRouter) {
} }
}) })
authorized.StaticFS("/files/", gin.Dir(files, true)) authorized.StaticFS("/files/", gin.Dir(files, true))
//IMDB: // IMDB:
authorized.GET("/imdb/:id", func(c *gin.Context) { authorized.GET("/imdb/:id", func(c *gin.Context) {
i, l, j := strings.TrimPrefix(c.Param("id"), "/"), "", false i, l, j := strings.TrimPrefix(c.Param("id"), "/"), "", false
if j = strings.HasSuffix(i, ".json"); !j { if j = strings.HasSuffix(i, ".json"); !j {
@@ -148,6 +148,7 @@ func trnGet(h string) (st, sc string) {
} }
return return
} }
func response(c *gin.Context, a any) { func response(c *gin.Context, a any) {
var r struct { var r struct {
R struct { R struct {
@@ -165,6 +166,7 @@ func response(c *gin.Context, a any) {
r.R.T = http.StatusText(r.R.S) r.R.T = http.StatusText(r.R.S)
c.JSON(200, &r) c.JSON(200, &r)
} }
func torrent(c *gin.Context) { func torrent(c *gin.Context) {
if c.Request.Method != "POST" { if c.Request.Method != "POST" {
r := false r := false