Added error enrichment

cmd/kessel-relations/main.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	"flag"
+	"fmt"
 	"os"
 	"strings"
 
@@ -63,12 +64,12 @@ func main() {
 	defer c.Close()
 
 	if err := c.Load(); err != nil {
-		panic(err)
+		panic(fmt.Errorf("error loading configuration: %w", err))
 	}
 
 	var bc conf.Bootstrap
 	if err := c.Scan(&bc); err != nil {
-		panic(err)
+		panic(fmt.Errorf("error reading bootstrap config from configuration: %w", err))
 	}
 
 	//preshared, err := c.Value("PRESHARED").String()
@@ -81,13 +82,13 @@ func main() {
 
 	app, cleanup, err := wireApp(bc.Server, bc.Data, createLogger(bc.Server))
 	if err != nil {
-		panic(err)
+		panic(fmt.Errorf("error initializing application (via wire): %w", err))
 	}
 	defer cleanup()
 
 	// start and wait for stop signal
 	if err := app.Run(); err != nil {
-		panic(err)
+		panic(fmt.Errorf("fatal error during application execution: %w", err))
 	}
 }
 

internal/data/spicedb.go

@@ -44,7 +44,7 @@ func NewSpiceDbRepository(c *conf.Data, logger log.Logger) (*SpiceDbRepository,
 		token, err = readToken(c.SpiceDb.TokenFile)
 		if err != nil {
 			log.NewHelper(logger).Error(err)
-			return nil, nil, err
+			return nil, nil, fmt.Errorf("error creating spicedb client: error loading token file: %w", err)
 		}
 	}
 	if token == "" {
@@ -442,19 +442,10 @@ func createSpiceDbRelationship(relationship *apiV1beta1.Relationship) *v1.Relati
 }
 
 func readToken(file string) (string, error) {
-	isFileExist := checkFileExists(file)
-	if !isFileExist {
-		return file, errors.New("file doesn't exist")
-	}
 	bytes, err := os.ReadFile(file)
 	if err != nil {
 		return "", err
 	}
 
 	return string(bytes), nil
 }
-
-func checkFileExists(filePath string) bool {
-	_, err := os.Stat(filePath)
-	return !errors.Is(err, os.ErrNotExist)
-}

internal/service/lookup.go

@@ -84,20 +84,20 @@ func (s *LookupService) LookupResources(req *pb.LookupResourcesRequest, conn pb.
 	res, errs, err := s.resourcesUsecase.Get(ctx, req)
 
 	if err != nil {
-		return err
+		return fmt.Errorf("failed to retrieve resources: %w", err)
 	}
 	for re := range res {
 		err = conn.Send(&pb.LookupResourcesResponse{
 			Resource:   re.Resource,
 			Pagination: &pb.ResponsePagination{ContinuationToken: string(re.Continuation)},
 		})
 		if err != nil {
-			return err
+			return fmt.Errorf("error sending retrieved resource to the client: %w", err)
 		}
 	}
 	err, ok := <-errs
 	if ok {
-		return err
+		return fmt.Errorf("error received while streaming subjects from Zanzibar backend: %w", err)
 	}
 
 	return nil