From dc108ddf68d97c626921516fbdd113ff15cba45a Mon Sep 17 00:00:00 2001
From: "mayur.popli" <mayur.popli@thewitslab.com>
Date: Thu, 3 Apr 2025 13:41:58 +0530
Subject: [PATCH] fix: added error from error module

---
 .../implementation/schemavalidator/schemavalidator.go      | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/pkg/plugin/implementation/schemavalidator/schemavalidator.go b/pkg/plugin/implementation/schemavalidator/schemavalidator.go
index 8b56e03..dd3d596 100644
--- a/pkg/plugin/implementation/schemavalidator/schemavalidator.go
+++ b/pkg/plugin/implementation/schemavalidator/schemavalidator.go
@@ -39,7 +39,7 @@ type Config struct {
 func New(ctx context.Context, config *Config) (*schemaValidator, func() error, error) {
 	// Check if config is nil
 	if config == nil {
-		return nil, nil, fmt.Errorf("config cannot be nil")
+		return nil, nil, model.NewBadReqErr(errors.New("config cannot be nil"))
 	}
 	v := &schemaValidator{
 		config:      config,
@@ -105,8 +105,7 @@ func (v *schemaValidator) Validate(ctx context.Context, url *url.URL, data []byt
 			// Return the array of schema validation errors
 			return &model.SchemaValidationErr{Errors: schemaErrors}
 		}
-		// Return a generic error for non-validation errors
-		return fmt.Errorf("validation failed: %v", err)
+		return model.NewBadReqErr(err)
 	}
 
 	// Return nil if validation succeeds
@@ -191,7 +190,7 @@ func (v *schemaValidator) initialise() error {
 
 	// Start processing from the root schema directory.
 	if err := processDir(schemaDir); err != nil {
-		return fmt.Errorf("failed to read schema directory: %v", err)
+		return model.NewNotFoundErr(err)
 	}
 
 	return nil