fix: cache is now properly invalidated when packs are modified

platforms/api/src/app.ts

@@ -13,6 +13,8 @@ import { HTTPResponses } from "data-types"
 import abCache from "abstract-cache"
 import IORedis from "ioredis"
 import { Client } from "typesense"
+import { resolve } from "path"
+import { rejects } from "assert"
 
 export let TYPESENSE_APP: Client
 
@@ -64,7 +66,7 @@ export let REDIS: IORedis | undefined = undefined
 
 async function registerCacheRedis() {
 	const redis = new IORedis({
-		host: process.env.DOCKER ? "redis" : "127.0.0.1",
+		host: process.env.DOCKER === "true" ? "redis" : "127.0.0.1",
 	})
 	REDIS = redis
 
@@ -124,6 +126,8 @@ export async function setupApp() {
 		methods: ["GET", "PUT", "POST", "PATCH", "DELETE"],
 	})
 
+	console.log(API_APP.cache)
+
 	// API_APP.addHook('preHandler', (request, reply, done) => {
 	//     reply.header("Access-Control-Allow-Origin", "*");
 	//     reply.header("Access-Control-Allow-Methods", "POST, GET, PUT, PATCH, OPTIONS, DELETE");
@@ -166,3 +170,13 @@ export async function set(
 		})
 	})
 }
+
+export async function invalidate(pattern: string): Promise<void> {
+	if (REDIS === undefined)
+		return
+
+	const matches = await REDIS.keys(pattern)
+	if (matches.length === 0)
+		return 
+	const deleted = await REDIS.del(matches)
+}

platforms/api/src/routes/packs/id/index.ts

@@ -1,5 +1,5 @@
 import { Static, Type } from "@sinclair/typebox"
-import { API_APP, get, sendError, set } from "../../../app.js"
+import { API_APP, get, invalidate, sendError, set } from "../../../app.js"
 import { getStorage } from "firebase-admin/storage"
 import {
 	HTTPResponses,
@@ -306,8 +306,7 @@ const setPack = async (request: any, reply: any) => {
 		)
 	}
 
-	const requestIdentifier = "GET-PACK::" + packId
-	await set(requestIdentifier, undefined, 1)
+	invalidateCachedData(packData.id, doc.id)
 
 	request.log.info(packData)
 	await doc.ref.set({ data: packData }, { merge: true })
@@ -731,3 +730,10 @@ API_APP.route({
 		)
 	},
 })
+
+export function invalidateCachedData(id: string | undefined, docId: string) {
+	if (id !== undefined)
+		invalidate("**" + id + "**")
+	invalidate("**" + docId + "**")
+}
+

platforms/api/src/routes/packs/id/versions.ts

@@ -9,6 +9,7 @@ import {
 } from "data-types"
 import { coerce, compare } from "semver"
 import { getPackDoc, validateToken } from "database"
+import { invalidateCachedData } from "./index.js"
 
 /*
  * @route GET /packs/:id/versions
@@ -140,6 +141,8 @@ API_APP.route({
 		versionData.name = versionId
 		versions.push(versionData)
 
+		invalidateCachedData(await doc.get("data.id"), doc.id)
+
 		await doc.ref.set(
 			{
 				data: {
@@ -256,6 +259,8 @@ API_APP.route({
 			{ merge: true }
 		)
 
+		invalidateCachedData(await doc.get("data.id"), doc.id)
+
 		return reply
 			.status(HTTPResponses.CREATED)
 			.send(`Version ${versionId} successfully updated`)
@@ -345,6 +350,8 @@ API_APP.route({
 			{ merge: true }
 		)
 
+		invalidateCachedData(await doc.get("data.id"), doc.id)
+
 		return reply
 			.status(HTTPResponses.CREATED)
 			.send(`Version ${versionId} successfully deleted`)