chore(fdr): setup semantic caching (#1536)

servers/fdr/scripts/run.sh

@@ -1,3 +1,4 @@
-#!/bin/sh
+#!/bin/bash
+set -e
 prisma migrate deploy --schema /app/servers/fdr/prisma/schema.prisma
 node --experimental-specifier-resolution=node /app/servers/fdr/dist/server.js

servers/fdr/src/__test__/ete/ete.test.ts

@@ -1,10 +1,24 @@
+/* eslint-disable vitest/expect-expect */
+
 const PORT = 8080;
 
 it("check health", async () => {
     // register empty definition
-    await sleep(5000);
-    const response = await fetch(`http://localhost:${PORT}/health`);
-    expect(response.status).toEqual(200);
+
+    for (let i = 0; i < 10; ++i) {
+        await sleep(20_000);
+        try {
+            const response = await fetch(`http://localhost:${PORT}/health`);
+            if (response.status === 200) {
+                return;
+            } else {
+                console.log(`Received status ${response.status}`);
+            }
+        } catch (err) {
+            console.log(err);
+        }
+    }
+    throw new Error("Failed to make successfull request");
 }, 100_000);
 
 function sleep(ms: number): Promise<void> {

servers/fdr/src/services/docs-cache/DocsDefinitionCache.ts

@@ -45,13 +45,19 @@ export interface DocsDefinitionCache {
     invalidateCache(url: URL): Promise<void>;
 }
 
+/**
+ * The semantic version that the current version of FDR expects.
+ * Please bump this version if you would like to "clear" the cache.
+ */
+const SEMANTIC_VERSION = "v2";
+
 /**
  * All modifications to this type must be forward compatible.
  * In other words, only add optional properties.
  */
 export interface CachedDocsResponse {
     /** Adding a version to the cached response to allow for breaks in the future. */
-    version: "v2";
+    version: typeof SEMANTIC_VERSION;
     updatedTime: Date;
     response: DocsV2Read.LoadDocsForUrlResponse;
     dbFiles: Record<DocsV1Read.FileId, DocsV1Db.DbFileInfoV2>;
@@ -248,10 +254,16 @@ export class DocsDefinitionCacheImpl implements DocsDefinitionCache {
     }
 
     private async getDocsForUrlFromCache({ url }: { url: URL }): Promise<CachedDocsResponse | null> {
+        let record: CachedDocsResponse | null = null;
         if (this.redisDocsCache) {
-            return await this.redisDocsCache.get({ url });
+            record = await this.redisDocsCache.get({ url });
+        } else {
+            record = this.localDocsCache.get({ url }) ?? null;
+        }
+        if (record != null && record.version !== SEMANTIC_VERSION) {
+            return null;
         }
-        return this.localDocsCache.get({ url }) ?? null;
+        return record;
     }
 
     private async getDocsForUrlFromDatabase({ url }: { url: URL }): Promise<CachedDocsResponse> {