diff options
Diffstat (limited to 'pkg/opasdk')
| -rw-r--r-- | pkg/opasdk/opasdk.go | 19 | ||||
| -rw-r--r-- | pkg/opasdk/opasdk_test.go | 8 |
2 files changed, 14 insertions, 13 deletions
diff --git a/pkg/opasdk/opasdk.go b/pkg/opasdk/opasdk.go index 50edba4..8fd1708 100644 --- a/pkg/opasdk/opasdk.go +++ b/pkg/opasdk/opasdk.go @@ -44,16 +44,16 @@ import ( // Define the structs var ( - opaInstance *sdk.OPA //A singleton instance of the OPA object - once sync.Once //A sync.Once variable used to ensure that the OPA instance is initialized only once, - memStore storage.Store + opaInstance *sdk.OPA //A singleton instance of the OPA object + once sync.Once //A sync.Once variable used to ensure that the OPA instance is initialized only once, + memStore storage.Store UpsertPolicyVar UpsertPolicyFunc = UpsertPolicy - WriteDataVar WriteDataFunc = WriteData + WriteDataVar WriteDataFunc = WriteData ) type ( - UpsertPolicyFunc func(ctx context.Context, policyID string, policyContent []byte) error - WriteDataFunc func(ctx context.Context, dataPath string, data interface{}) error + UpsertPolicyFunc func(ctx context.Context, policyID string, policyContent []byte) error + WriteDataFunc func(ctx context.Context, dataPath string, data interface{}) error ) type PatchImpl struct { @@ -81,6 +81,7 @@ func getJSONReader(filePath string, openFunc func(string) (*os.File, error), } type NewSDKFunc func(ctx context.Context, options sdk.Options) (*sdk.OPA, error) + var NewSDK NewSDKFunc = sdk.New // Returns a singleton instance of the OPA object. The initialization of the instance is @@ -88,9 +89,9 @@ var NewSDK NewSDKFunc = sdk.New func GetOPASingletonInstance() (*sdk.OPA, error) { var err error once.Do(func() { - var opaErr error + var opaErr error memStore = inmem.New() - opaInstance, opaErr = NewSDK(context.Background(), sdk.Options{ + opaInstance, opaErr = NewSDK(context.Background(), sdk.Options{ // Configure your OPA instance here V1Compatible: true, Store: memStore, @@ -113,7 +114,7 @@ func GetOPASingletonInstance() (*sdk.OPA, error) { Config: jsonReader, }) if err != nil { - log.Warnf("Failed to configure OPA: %v", err) + log.Warnf("Failed to configure OPA: %v", err) } } }) diff --git a/pkg/opasdk/opasdk_test.go b/pkg/opasdk/opasdk_test.go index 3ed4be1..48ed65e 100644 --- a/pkg/opasdk/opasdk_test.go +++ b/pkg/opasdk/opasdk_test.go @@ -29,12 +29,12 @@ import ( "github.com/stretchr/testify/assert" "github.com/stretchr/testify/mock" "io" + "net/http" "net/http/httptest" "os" "policy-opa-pdp/consts" "sync" "testing" - "net/http" ) // Mock for os.Open @@ -560,8 +560,8 @@ func TestListPolicies_GetPolicySuccess(t *testing.T) { res := httptest.NewRecorder() ListPolicies(res, req) -// assert.Nil(t, err) -// assert.NoError(t, err) + // assert.Nil(t, err) + // assert.NoError(t, err) mockMemStore.AssertExpectations(t) } @@ -579,7 +579,7 @@ func TestListPolicies_Success(t *testing.T) { res := httptest.NewRecorder() ListPolicies(res, req) -// assert.NoError(t, err) + // assert.NoError(t, err) mockMemStore.AssertExpectations(t) } |