Method put

drizzle-orm/src/cache/upstash/cache.ts:149–189

(
		key: string,
		response: any,
		tables: string[],
		isTag: boolean = false,
		config?: CacheConfig,
	)

	}

	override async put(
		key: string,
		response: any,
		tables: string[],
		isTag: boolean = false,
		config?: CacheConfig,
	): Promise<void> {
		const isAutoInvalidate = tables.length !== 0;

		const pipeline = this.redis.pipeline();
		const ttlSeconds = config && config.ex ? config.ex : this.internalConfig.seconds;
		const hexOptions = config && config.hexOptions ? config.hexOptions : this.internalConfig?.hexOptions;

		if (!isAutoInvalidate) {
			if (isTag) {
				pipeline.hset(UpstashCache.tagsMapKey, { [key]: UpstashCache.nonAutoInvalidateTablePrefix });
				pipeline.hexpire(UpstashCache.tagsMapKey, key, ttlSeconds, hexOptions);
			}

			pipeline.hset(UpstashCache.nonAutoInvalidateTablePrefix, { [key]: response });
			pipeline.hexpire(UpstashCache.nonAutoInvalidateTablePrefix, key, ttlSeconds, hexOptions);
			await pipeline.exec();
			return;
		}

		const compositeKey = this.getCompositeKey(tables);

		pipeline.hset(compositeKey, { [key]: response }); // Store the result with the tag under the composite key
		pipeline.hexpire(compositeKey, key, ttlSeconds, hexOptions); // Set expiration for the composite key

		if (isTag) {
			pipeline.hset(UpstashCache.tagsMapKey, { [key]: compositeKey }); // Store the tag and its composite key in the map
			pipeline.hexpire(UpstashCache.tagsMapKey, key, ttlSeconds, hexOptions); // Set expiration for the tag
		}

		for (const table of tables) {
			pipeline.sadd(this.addTablePrefix(table), compositeKey);
		}

		await pipeline.exec();
	}

	override async onMutate(params: MutationOption) {
		const tags = Array.isArray(params.tags) ? params.tags : params.tags ? [params.tags] : [];