cache

var ErrCacheNotFound = errors.New("cache not found")

var NewCache = sync.OnceValues(func() (*ImageCache, error) {
	appCfg, err := config.LoadAppConfig()
	if err != nil {
		return nil, fmt.Errorf("load app config: %w", err)
	}
	c := &ImageCache{
		caches: make(map[string]ObjectCache),
	}
	switch appCfg.GetAppEnvironment() {
	case config.EnvProduction:
		bucketName := os.Getenv("IMAGEPROXY_BUCKET")
		imgCache, err := gcs.Connect(context.Background(), bucketName, "")
		if err != nil {
			return nil, fmt.Errorf("connect to gcs:%s %w", bucketName, err)
		}
		c.caches["imgproxy"] = imgCache
		avatarCache, err := gcs.Connect(context.Background(), bucketName, "avatars")
		if err != nil {
			return nil, fmt.Errorf("connect to gcs:%s/%s %w", bucketName, "avatars", err)
		}
		c.caches["avatars"] = avatarCache
		thumbnailCache, err := gcs.Connect(context.Background(), bucketName, "subscription_images")
		if err != nil {
			return nil, fmt.Errorf("connect to gcs:%s/%s %w", bucketName, "subscription_images", err)
		}
		c.caches["subscription_thumbnails"] = thumbnailCache
		screenshotCache, err := gcs.Connect(context.Background(), bucketName, "screenshots")
		if err != nil {
			return nil, fmt.Errorf("connect to gcs:%s/%s %w", bucketName, "screenshots", err)
		}
		c.caches["screenshots"] = screenshotCache
	default:
		var err error
		imgCache, err := newDirCache("imgproxy")
		if err != nil {
			return nil, fmt.Errorf("create dir cache: %s:  %w", "imgproxy", err)
		}
		c.caches["imgproxy"] = imgCache
		avatarCache, err := newDirCache("avatars")
		if err != nil {
			return nil, fmt.Errorf("create dir cache: %s:  %w", "avatars", err)
		}
		c.caches["avatars"] = avatarCache
		thumbnailCache, err := newDirCache("subscription_images")
		if err != nil {
			return nil, fmt.Errorf("create dir cache: %s: %w", "subscription_images", err)
		}
		c.caches["subscription_thumbnails"] = thumbnailCache
		screenshotsCache, err := newDirCache("screenshots")
		if err != nil {
			return nil, fmt.Errorf("create dir cache: %s: %w", "screenshots", err)
		}
		c.caches["screenshots"] = screenshotsCache
	}

	return c, nil
})

var NewItemsCache = sync.OnceValues(func() (ObjectCache, error) {
	appCfg, err := config.LoadAppConfig()
	if err != nil {
		return nil, fmt.Errorf("load app config: %w", err)
	}

	switch appCfg.GetAppEnvironment() {
	case config.EnvProduction:
		bucketName := os.Getenv("FORAGD_SERVER_BUCKET")
		var err error
		itemsCache, err := gcs.Connect(context.Background(), bucketName, "articles")
		if err != nil {
			return nil, fmt.Errorf("connect to gcs:%s: %w", "articles", err)
		}
		return itemsCache, nil
	default:
		var err error
		itemsCache, err := newDirCache("articles")
		if err != nil {
			return nil, fmt.Errorf("create items dir cache: %w", err)
		}
		return itemsCache, nil
	}
})