Method GetFileDescriptorSet

backend/pkg/bsr/client.go:142–166

GetFileDescriptorSet fetches the complete file descriptor set from BSR. This is used for the protojson resolver when marshaling to JSON. Returns linker.Files which has an AsResolver() method for protojson.

(ctx context.Context, messageName, commit string)

// This is used for the protojson resolver when marshaling to JSON.
// Returns linker.Files which has an AsResolver() method for protojson.
func (c *Client) GetFileDescriptorSet(ctx context.Context, messageName, commit string) (linker.Files, error) {
	if messageName == "" {
		return nil, errors.New("message name is empty")
	}
	if commit == "" {
		return nil, errors.New("commit is empty")
	}

	key := cacheKey{messageName: messageName, commit: commit}

	// Use cache.Get which handles cache lookup and only calls the function on cache miss
	entry, err, _ := c.cache.Get(key.String(), func() (*bsrCacheEntry, error) {
		// This function is only called on cache miss
		files, desc, fetchErr := c.fetchFromBSR(ctx, messageName, commit)
		if fetchErr != nil {
			return nil, fetchErr
		}
		return &bsrCacheEntry{files: files, messageDesc: desc}, nil
	})

	if err != nil {
		return nil, err
	}
	return entry.files, nil
}

// fetchFromBSR fetches the file descriptor set from BSR via the Connect API.
func (c *Client) fetchFromBSR(ctx context.Context, messageName, commit string) (linker.Files, protoreflect.MessageDescriptor, error) {