Method LoadSubscription

backend/enterprise/license.go:201–234

LoadSubscription will load subscription. If there is no license, we will return a free plan subscription without expiration time. If there is expired license, we will return a free plan subscription with the expiration time of the expired license.

(ctx context.Context, workspaceID string)

// If there is no license, we will return a free plan subscription without expiration time.
// If there is expired license, we will return a free plan subscription with the expiration time of the expired license.
func (s *LicenseService) LoadSubscription(ctx context.Context, workspaceID string) *v1pb.Subscription {
	if workspaceID == "" {
		return defaultFreeSubscription
	}
	key := licenseCacheKey(workspaceID)

	// Fast path: cache hit (TTL handled automatically by expirable.LRU)
	if sub, ok := s.cache.Get(key); ok {
		return sub
	}

	// Slow path: load from DB with singleflight to prevent thundering herd
	v, _, _ := s.sfGroup.Do(key, func() (any, error) {
		// Double check after entering singleflight
		if sub, ok := s.cache.Get(key); ok {
			return sub, nil
		}

		subscription := s.loadSubscriptionFromDB(ctx, workspaceID)

		// Only cache non-free subscriptions. Free plan may be a transient failure
		// (e.g. DB not ready during startup), and caching it would mask the real
		// license for the TTL duration.
		if subscription.Plan != v1pb.PlanType_FREE {
			s.cache.Add(key, subscription)
		}
		return subscription, nil
	})

	if sub, ok := v.(*v1pb.Subscription); ok {
		return sub
	}
	return defaultFreeSubscription
}

func (s *LicenseService) loadSubscriptionFromDB(ctx context.Context, workspaceID string) *v1pb.Subscription {
	setting, err := s.store.GetSystemSetting(ctx, workspaceID)