moved stuff to helper

internal/graphqlTypes.go

@@ -140,11 +140,7 @@ func graphqlTypes() {
 						return nil, fmt.Errorf("Failed to parse Source for parent resolve")
 					}
 
-					basename := filepath.Dir(source.ID)
+					basename := getPathFromId(source.ID)
-
-					if basename == "." {
-						basename = "/"
-					}
 
 					return Directory{
 						ID: basename,
@@ -213,6 +209,10 @@ func loadFile(p graphql.ResolveParams) (*File, error) {
 	thunk := loader["getFile"].Load(p.Context, dataloader.StringKey(source.ID))
 	result, err := thunk()
 
+	if err != nil {
+		return nil, err
+	}
+
 	file, ok := result.(*File)
 
 	if !ok {

internal/helper.go

@@ -0,0 +1,32 @@
+package s3browser
+
+import (
+	"context"
+	"fmt"
+	"path/filepath"
+
+	"github.com/graph-gophers/dataloader"
+)
+
+func invalidateCache(ctx context.Context, id string) error {
+	loader, ok := ctx.Value("loader").(map[string]*dataloader.Loader)
+	if !ok {
+		return fmt.Errorf("Failed to get loader from context")
+	}
+
+	loader["getFile"].Clear(ctx, dataloader.StringKey(id))
+	loader["listObjects"].Clear(ctx, dataloader.StringKey(id))
+	loader["getFiles"].Clear(ctx, dataloader.StringKey(getPathFromId(id)))
+
+	return nil
+}
+
+func getPathFromId(id string) string {
+	dir := filepath.Dir(id)
+
+	if dir == "." {
+		return "/"
+	}
+
+	return dir + "/"
+}

internal/httpServer.go

@@ -8,7 +8,6 @@ import (
 	"net/http"
 	"path/filepath"
 
-	"github.com/graph-gophers/dataloader"
 	"github.com/graphql-go/graphql"
 	"github.com/graphql-go/graphql/gqlerrors"
 	"github.com/graphql-go/handler"
@@ -95,7 +94,6 @@ func httpGetFile(ctx context.Context, rw http.ResponseWriter, r *http.Request) {
 
 func httpPostFile(ctx context.Context, rw http.ResponseWriter, r *http.Request) {
 	s3Client := ctx.Value("s3Client").(*minio.Client)
-	loader := ctx.Value("loader").(map[string]*dataloader.Loader)
 
 	id := r.URL.Query().Get("id")
 
@@ -115,9 +113,7 @@ func httpPostFile(ctx context.Context, rw http.ResponseWriter, r *http.Request)
 	}
 
 	// Invalidate cache
-	loader["getFile"].Clear(ctx, dataloader.StringKey(info.Key))
+	invalidateCache(ctx, info.Key)
-	loader["listObjects"].Clear(ctx, dataloader.StringKey(info.Key))
-	loader["getFiles"].Clear(ctx, dataloader.StringKey(filepath.Dir(info.Key)))
 
 	rw.WriteHeader(http.StatusCreated)
 }

internal/mutations.go

@@ -3,9 +3,7 @@ package s3browser
 import (
 	"context"
 	"fmt"
-	"path/filepath"
 
-	"github.com/graph-gophers/dataloader"
 	"github.com/minio/minio-go/v7"
 )
 
@@ -25,16 +23,7 @@ func deleteMutation(ctx context.Context, id string) error {
 	}
 
 	// Invalidate cache
-	loader, ok := ctx.Value("loader").(map[string]*dataloader.Loader)
+	return invalidateCache(ctx, id)
-	if !ok {
-		return fmt.Errorf("Failed to get loader from context")
-	}
-
-	loader["getFile"].Clear(ctx, dataloader.StringKey(id))
-	loader["listObjects"].Clear(ctx, dataloader.StringKey(id))
-	loader["getFiles"].Clear(ctx, dataloader.StringKey(filepath.Dir(id)))
-
-	return nil
 }
 
 func copyMutation(ctx context.Context, src, dest string) (*File, error) {
@@ -57,16 +46,8 @@ func copyMutation(ctx context.Context, src, dest string) (*File, error) {
 	}
 
 	// Invalidate cache
-
+	// TODO: check error
-	loader, ok := ctx.Value("loader").(map[string]*dataloader.Loader)
+	invalidateCache(ctx, info.Key)
-
-	// TODO: Do we want to error when the operation
-	// has succeeded but the cache invalidation has failed ?
-	if ok {
-		loader["getFile"].Clear(ctx, dataloader.StringKey(info.Key))
-		loader["listObjects"].Clear(ctx, dataloader.StringKey(info.Key))
-		loader["getFiles"].Clear(ctx, dataloader.StringKey(filepath.Dir(info.Key)))
-	}
 
 	return &File{
 		ID: info.Key,