sendnrw/netbird
2
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2026-04-17 15:56:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix sonar issue

Browse Source
This commit is contained in:
aliamerj
2025-08-29 10:50:55 +03:00
parent 373f978baa
commit 2db19c27f2
1 changed files with 16 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
management/server/types/job.go
View File

@@ -104,15 +104,8 @@ func (j *Job) BuildWorkloadResponse() (*api.WorkloadResponse, error) {
switch j.Workload.Type {
case JobTypeBundle:
if j.Workload.BundleParameters == nil {
return nil, status.Errorf(status.InvalidArgument, "missing bundle parameters")
}
if err := wl.FromBundleWorkloadResponse(api.BundleWorkloadResponse{
Type: api.WorkloadTypeBundle,
Parameters: *j.Workload.BundleParameters,
Result: *j.Workload.BundleResult,
}); err != nil {
return nil, status.Errorf(status.InvalidArgument, "unknown job parameters: %v", err)
if err := j.buildBundleResponse(&wl); err != nil {
return nil, status.Errorf(status.InvalidArgument, err.Error())
}
return &wl, nil
@@ -121,6 +114,20 @@ func (j *Job) BuildWorkloadResponse() (*api.WorkloadResponse, error) {
}
}
func (j *Job) buildBundleResponse(wl *api.WorkloadResponse) error {
if j.Workload.BundleParameters == nil {
return fmt.Errorf("missing bundle parameters")
}
if err := wl.FromBundleWorkloadResponse(api.BundleWorkloadResponse{
Type: api.WorkloadTypeBundle,
Parameters: *j.Workload.BundleParameters,
Result: *j.Workload.BundleResult,
}); err != nil {
return fmt.Errorf("unknown job parameters: %v", err)
}
return nil
}
func validateBundleParams(req api.WorkloadRequest, workload *Workload) error {
bundle, err := req.AsBundleWorkloadRequest()
if err != nil {