core/go-process
8
0
Fork 0
Code Issues 4 Pull requests Projects Releases Packages Wiki Activity Actions

fix(process): AX-6 banned-import purge in registry.go (#300)

Browse source 
Removed encoding/json + strings imports. Replaced JSON marshal/unmarshal
with core.JSONMarshal / core.JSONUnmarshalString and strings.ReplaceAll
with core.Replace + core.Concat for path sanitisation.

Closes tasks.lthn.sh/view.php?id=300

Co-authored-by: Codex <noreply@openai.com>
This commit is contained in:
Snider 2026-04-25 09:08:21 +01:00
parent 0968d540b4
commit 708d5a660a
1 changed files with 8 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
registry.go
View file

@ -1,14 +1,13 @@
package process
import (
"encoding/json"
"os"
"path/filepath"
"sort"
"strings"
"syscall"
"time"
"dappco.re/go/core"
coreio "dappco.re/go/io"
coreerr "dappco.re/go/log"
)
@ -71,11 +70,13 @@ func (r *Registry) Register(entry DaemonEntry) error {
return coreerr.E("Registry.Register", "failed to create registry directory", err)
}
data, err := json.MarshalIndent(entry, "", " ")
if err != nil {
jsonResult := core.JSONMarshal(entry)
if !jsonResult.OK {
err, _ := jsonResult.Value.(error)
return coreerr.E("Registry.Register", "failed to marshal entry", err)
}
data := jsonResult.Value.([]byte)
if err := coreio.Local.Write(r.entryPath(entry.Code, entry.Daemon), string(data)); err != nil {
return coreerr.E("Registry.Register", "failed to write entry file", err)
}
@ -113,7 +114,7 @@ func (r *Registry) Get(code, daemon string) (*DaemonEntry, bool) {
}
var entry DaemonEntry
if err := json.Unmarshal([]byte(data), &entry); err != nil {
if result := core.JSONUnmarshalString(data, &entry); !result.OK {
_ = coreio.Local.Delete(path)
return nil, false
}
@ -145,7 +146,7 @@ func (r *Registry) List() ([]DaemonEntry, error) {
}
var entry DaemonEntry
if err := json.Unmarshal([]byte(data), &entry); err != nil {
if result := core.JSONUnmarshalString(data, &entry); !result.OK {
_ = coreio.Local.Delete(path)
continue
}
@ -173,7 +174,7 @@ func (r *Registry) List() ([]DaemonEntry, error) {
// entryPath returns the filesystem path for a daemon entry.
func (r *Registry) entryPath(code, daemon string) string {
name := strings.ReplaceAll(code, "/", "-") + "-" + strings.ReplaceAll(daemon, "/", "-") + ".json"
name := core.Concat(core.Replace(code, "/", "-"), "-", core.Replace(daemon, "/", "-"), ".json")
return filepath.Join(r.dir, name)
}