sendnrw/netbird
2
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2026-07-18 20:49:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix lint

Browse Source
This commit is contained in:
aliamerj
2025-08-26 13:09:54 +03:00
parent 667dfdfcc3
commit d1aec58108
1 changed files with 25 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
management/server/http/handlers/peers/peers_handler.go
View File

@@ -72,7 +72,13 @@ func (h *Handler) CreateJob(w http.ResponseWriter, r *http.Request) {
return
}
util.WriteJSONObject(ctx, w, toSingleJobResponse(job))
resp, err := toSingleJobResponse(job)
if err != nil {
util.WriteError(ctx, err, w)
return
}
util.WriteJSONObject(ctx, w, resp)
}
func (h *Handler) ListJobs(w http.ResponseWriter, r *http.Request) {
@@ -94,7 +100,12 @@ func (h *Handler) ListJobs(w http.ResponseWriter, r *http.Request) {
respBody := make([]*api.Job, 0, len(jobs))
for _, job := range jobs {
respBody = append(respBody, toSingleJobResponse(job))
resp, err := toSingleJobResponse(job)
if err != nil {
util.WriteError(ctx, err, w)
return
}
respBody = append(respBody, resp)
}
util.WriteJSONObject(ctx, w, respBody)
@@ -118,7 +129,13 @@ func (h *Handler) GetJob(w http.ResponseWriter, r *http.Request) {
return
}
util.WriteJSONObject(ctx, w, toSingleJobResponse(job))
resp, err := toSingleJobResponse(job)
if err != nil {
util.WriteError(ctx, err, w)
return
}
util.WriteJSONObject(ctx, w, resp)
}
func (h *Handler) checkPeerStatus(peer *nbpeer.Peer) (*nbpeer.Peer, error) {
@@ -501,10 +518,11 @@ func toPeerListItemResponse(peer *nbpeer.Peer, groupsInfo []api.GroupMinimum, dn
}
}
func toSingleJobResponse(job *types.Job) *api.Job {
func toSingleJobResponse(job *types.Job) (*api.Job, error) {
var parameters map[string]any
job.DecodeParameters(&parameters)
if err := job.DecodeParameters(&parameters); err != nil {
return nil, err
}
return &api.Job{
Id: job.ID,
Status: (*api.JobStatus)(&job.Status),
@@ -521,7 +539,7 @@ func toSingleJobResponse(job *types.Job) *api.Job {
Parameters: &parameters,
Result: &job.Result,
},
}
}, nil
}
func fqdn(peer *nbpeer.Peer, dnsDomain string) string {