func loadCursor()

in storage/cursor.go [30:54]

• 21 lines of code
• 4 McCabe index (conditional complexity)

func loadCursor(ctx context.Context, logger *zap.Logger, storageClient *storage.Client, bucketName, rootStoragePath string) (*cursor, error) {
	span, ctx := apm.StartSpan(ctx, "LoadCursor", "app")
	defer span.End()

	logger.Debug("load cursor file")

	rootedCursorStoragePath := joinObjectPaths(rootStoragePath, cursorStoragePath)
	objectReader, err := storageClient.Bucket(bucketName).Object(rootedCursorStoragePath).NewReader(ctx)
	if err == storage.ErrObjectNotExist {
		return nil, fmt.Errorf("cursor file doesn't exist, most likely a first run (bucketName: %s, path: %s): %w", bucketName, rootedCursorStoragePath, err)
	}
	if err != nil {
		return nil, fmt.Errorf("can't read the cursor file (path: %s): %w", rootedCursorStoragePath, err)
	}
	defer objectReader.Close()

	var c cursor
	err = json.NewDecoder(objectReader).Decode(&c)
	if err != nil {
		return nil, fmt.Errorf("can't decode the cursor file: %w", err)
	}

	logger.Debug("loaded cursor file", zap.String("cursor", c.String()))
	return &c, nil
}