Skip to content

Commit

Permalink
cli/context/store: rename removeAllContextData(), removeAllEndpointDa…
Browse files Browse the repository at this point in the history
…ta()

The existing `remove()` was unused, and using that as name makes it more
consistent with the metadata-store. Also renaming `removeAllEndpointData`
to just `removeEndpoint`, as it's part of the TLS-store, which should already
make it clear it's about (TLS)data.

Signed-off-by: Sebastiaan van Stijn <[email protected]>
  • Loading branch information
thaJeztah committed Sep 29, 2022
1 parent f713d0c commit fc65436
Show file tree
Hide file tree
Showing 3 changed files with 12 additions and 24 deletions.
6 changes: 3 additions & 3 deletions cli/context/store/store.go
Original file line number Diff line number Diff line change
Expand Up @@ -142,7 +142,7 @@ func (s *ContextStore) Remove(name string) error {
if err := s.meta.remove(name); err != nil {
return errors.Wrapf(err, "failed to remove context %s", name)
}
if err := s.tls.removeAllContextData(name); err != nil {
if err := s.tls.remove(name); err != nil {
return errors.Wrapf(err, "failed to remove context %s", name)
}
return nil
Expand All @@ -157,7 +157,7 @@ func (s *ContextStore) GetMetadata(name string) (Metadata, error) {
// ResetTLSMaterial removes TLS data for all endpoints in the context and replaces
// it with the new data.
func (s *ContextStore) ResetTLSMaterial(name string, data *ContextTLSData) error {
if err := s.tls.removeAllContextData(name); err != nil {
if err := s.tls.remove(name); err != nil {
return err
}
if data == nil {
Expand All @@ -176,7 +176,7 @@ func (s *ContextStore) ResetTLSMaterial(name string, data *ContextTLSData) error
// ResetEndpointTLSMaterial removes TLS data for the given context and endpoint,
// and replaces it with the new data.
func (s *ContextStore) ResetEndpointTLSMaterial(contextName string, endpointName string, data *EndpointTLSData) error {
if err := s.tls.removeAllEndpointData(contextName, endpointName); err != nil {
if err := s.tls.removeEndpoint(contextName, endpointName); err != nil {
return err
}
if data == nil {
Expand Down
21 changes: 6 additions & 15 deletions cli/context/store/tlsstore.go
Original file line number Diff line number Diff line change
Expand Up @@ -41,30 +41,21 @@ func (s *tlsStore) getData(name, endpointName, filename string) ([]byte, error)
return data, nil
}

// remove removes a TLS data from an endpoint
// TODO(thaJeztah) tlsStore.remove() is not used anywhere outside of tests; should we use removeAllEndpointData() only?
func (s *tlsStore) remove(name, endpointName, filename string) error {
err := os.Remove(filepath.Join(s.contextDir(contextdirOf(name)), endpointName, filename))
if os.IsNotExist(err) {
return nil
// remove deletes all TLS data for the given context.
func (s *tlsStore) remove(name string) error {
if err := os.RemoveAll(s.contextDir(contextdirOf(name))); err != nil {
return errors.Wrapf(err, "failed to remove TLS data")
}
return err
return nil
}

func (s *tlsStore) removeAllEndpointData(name, endpointName string) error {
func (s *tlsStore) removeEndpoint(name, endpointName string) error {
if err := os.RemoveAll(filepath.Join(s.contextDir(contextdirOf(name)), endpointName)); err != nil {
return errors.Wrapf(err, "failed to remove TLS data for endpoint %s", endpointName)
}
return nil
}

func (s *tlsStore) removeAllContextData(name string) error {
if err := os.RemoveAll(s.contextDir(contextdirOf(name))); err != nil {
return errors.Wrapf(err, "failed to remove TLS data")
}
return nil
}

func (s *tlsStore) listContextData(name string) (map[string]EndpointFiles, error) {
contextDir := s.contextDir(contextdirOf(name))
epFSs, err := os.ReadDir(contextDir)
Expand Down
9 changes: 3 additions & 6 deletions cli/context/store/tlsstore_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -26,11 +26,8 @@ func TestTlsCreateUpdateGetRemove(t *testing.T) {
assert.NilError(t, err)
assert.Equal(t, string(data), "data2")

err = testee.remove(contextName, "test-ep", "test-data")
err = testee.removeEndpoint(contextName, "test-ep")
assert.NilError(t, err)
err = testee.remove(contextName, "test-ep", "test-data")
assert.NilError(t, err)

_, err = testee.getData(contextName, "test-ep", "test-data")
assert.ErrorType(t, err, errdefs.IsNotFound)
}
Expand Down Expand Up @@ -61,13 +58,13 @@ func TestTlsListAndBatchRemove(t *testing.T) {
assert.NilError(t, err)
assert.DeepEqual(t, resAll, all)

err = testee.removeAllEndpointData(contextName, "ep3")
err = testee.removeEndpoint(contextName, "ep3")
assert.NilError(t, err)
resEp1ep2, err := testee.listContextData(contextName)
assert.NilError(t, err)
assert.DeepEqual(t, resEp1ep2, ep1ep2)

err = testee.removeAllContextData(contextName)
err = testee.remove(contextName)
assert.NilError(t, err)
resEmpty, err := testee.listContextData(contextName)
assert.NilError(t, err)
Expand Down

0 comments on commit fc65436

Please sign in to comment.