Method cryptoKey

coderd/cryptokeys/cache.go:232–276

(ctx context.Context, sequence int32)

}

func (c *cache) cryptoKey(ctx context.Context, sequence int32) (string, []byte, error) {
	c.logger.Debug(ctx, "request for key", slog.F("sequence", sequence))
	c.mu.Lock()
	defer c.mu.Unlock()

	if c.closed {
		return "", nil, ErrClosed
	}

	var key codersdk.CryptoKey
	var ok bool
	for key, ok = c.key(sequence); !ok && c.fetching && !c.closed; {
		c.cond.Wait()
	}

	if c.closed {
		return "", nil, ErrClosed
	}

	if ok {
		return checkKey(key, sequence, c.clock.Now())
	}

	c.fetching = true

	c.mu.Unlock()
	keys, err := c.cryptoKeys(ctx)
	c.mu.Lock()
	if err != nil {
		return "", nil, xerrors.Errorf("get keys: %w", err)
	}

	c.lastFetch = c.clock.Now()
	c.refresher.Reset(refreshInterval)
	c.keys = keys
	c.fetching = false
	c.cond.Broadcast()

	key, ok = c.key(sequence)
	if !ok {
		return "", nil, ErrKeyNotFound
	}

	return checkKey(key, sequence, c.clock.Now())
}

func (c *cache) key(sequence int32) (codersdk.CryptoKey, bool) {
	if sequence == latestSequence {