speatzle/nfsense
1
0
Fork 0
mirror of https://github.com/speatzle/nfsense.git synced 2025-05-11 19:08:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Use ConfigManager

Browse source
This commit is contained in:
Samuel Lorch 2023-04-02 02:11:15 +02:00
parent 75e981545a
commit 2716507c86
2 changed files with 30 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
internal/api/object/addresses.go
View file

@ -28,8 +28,11 @@ func (f *Object) CreateAddress(ctx context.Context, params CreateAddressParamete
return struct{}{}, fmt.Errorf("Address already Exists") return struct{}{}, fmt.Errorf("Address already Exists")
} }
f.ConfigManager.GetPendingConfig().Object.Addresses[params.Name] = params.Address t, conf := f.ConfigManager.StartTransaction()
return struct{}{}, nil defer t.Discard()
conf.Object.Addresses[params.Name] = params.Address
return struct{}{}, t.Commit()
} }
type UpdateAddressParameters struct { type UpdateAddressParameters struct {
@ -43,8 +46,11 @@ func (f *Object) UpdateAddress(ctx context.Context, params CreateAddressParamete
return struct{}{}, fmt.Errorf("Address does not Exist") return struct{}{}, fmt.Errorf("Address does not Exist")
} }
f.ConfigManager.GetPendingConfig().Object.Addresses[params.Name] = params.Address t, conf := f.ConfigManager.StartTransaction()
return struct{}{}, nil defer t.Discard()
conf.Object.Addresses[params.Name] = params.Address
return struct{}{}, t.Commit()
} }
type DeleteAddressParameters struct { type DeleteAddressParameters struct {
@ -57,6 +63,9 @@ func (f *Object) DeleteAddress(ctx context.Context, params DeleteAddressParamete
return struct{}{}, fmt.Errorf("Interface does not Exist") return struct{}{}, fmt.Errorf("Interface does not Exist")
} }
delete(f.ConfigManager.GetPendingConfig().Object.Addresses, params.Name) t, conf := f.ConfigManager.StartTransaction()
return struct{}{}, nil defer t.Discard()
delete(conf.Object.Addresses, params.Name)
return struct{}{}, t.Commit()
} }

21
internal/api/object/services.go
View file

@ -28,8 +28,11 @@ func (f *Object) CreateService(ctx context.Context, params CreateServiceParamete
return struct{}{}, fmt.Errorf("Service already Exists") return struct{}{}, fmt.Errorf("Service already Exists")
} }
f.ConfigManager.GetPendingConfig().Object.Services[params.Name] = params.Service t, conf := f.ConfigManager.StartTransaction()
return struct{}{}, nil defer t.Discard()
conf.Object.Services[params.Name] = params.Service
return struct{}{}, t.Commit()
} }
type UpdateServiceParameters struct { type UpdateServiceParameters struct {
@ -43,8 +46,11 @@ func (f *Object) UpdateService(ctx context.Context, params CreateServiceParamete
return struct{}{}, fmt.Errorf("Service does not Exist") return struct{}{}, fmt.Errorf("Service does not Exist")
} }
f.ConfigManager.GetPendingConfig().Object.Services[params.Name] = params.Service t, conf := f.ConfigManager.StartTransaction()
return struct{}{}, nil defer t.Discard()
conf.Object.Services[params.Name] = params.Service
return struct{}{}, t.Commit()
} }
type DeleteServiceParameters struct { type DeleteServiceParameters struct {
@ -57,6 +63,9 @@ func (f *Object) DeleteService(ctx context.Context, params DeleteServiceParamete
return struct{}{}, fmt.Errorf("Interface does not Exist") return struct{}{}, fmt.Errorf("Interface does not Exist")
} }
delete(f.ConfigManager.GetPendingConfig().Object.Services, params.Name) t, conf := f.ConfigManager.StartTransaction()
return struct{}{}, nil defer t.Discard()
delete(conf.Object.Services, params.Name)
return struct{}{}, t.Commit()
} }