I am even stupider than I thought

container-registry · Feb 22, 2022 · dfc8fa9 · dfc8fa9
1 parent d4411e3
commit dfc8fa9
Show file tree

Hide file tree

Showing 3 changed files with 25 additions and 40 deletions.
diff --git a/src/service/router.ts b/src/service/router.ts
@@ -37,7 +37,7 @@ export async function createRouter(
   const baseUrl = options.config.getString("harbor.baseUrl");
   const username = options.config.getString("harbor.username");
   const password = options.config.getString("harbor.password");
-  const redisConfig = options.config.getConfig("redis");
+  const redisConfig = options.config.getOptionalConfig("redis");
 
   const router = Router();
   router.use(express.json());

diff --git a/src/service/search.ts b/src/service/search.ts
@@ -9,15 +9,19 @@ export async function repoSearch(
   password: string,
   body: string,
   team: string,
-  redisConfig: Config
+  redisConfig: Config | undefined
 ) {
   const repos: Repositories[] = JSON.parse(JSON.stringify(body));
-  const redisHost = redisConfig.getString("host");
-  const redisPort = redisConfig.getNumber("port");
+  let client = redis.createClient({});
+  if (redisConfig !== undefined) {
+    const redisHost = redisConfig.getString("host");
+    const redisPort = redisConfig.getNumber("port");
+
+    client = redis.createClient({
+      url: `redis://${redisHost}:${redisPort}`,
+    });
+  }
 
-  const client = redis.createClient({
-    url: `redis://${redisHost}:${redisPort}`,
-  });
   await client.connect();
 
   const HarborRepos = await client.json.get(team, { path: "." });

diff --git a/src/service/teamArtifacts.ts b/src/service/teamArtifacts.ts
@@ -5,56 +5,37 @@ import { Config } from "@backstage/config";
 export async function getTeamArtifacts(
   RepoInformation: RepoInformation[],
   team: string,
-  redisConfig: Config
+  redisConfig: Config | undefined
 ) {
-  const redisHost = redisConfig.getString("host");
-  const redisPort = redisConfig.getNumber("port");
+  let client = redis.createClient({});
+  if (redisConfig !== undefined) {
+    const redisHost = redisConfig.getString("host");
+    const redisPort = redisConfig.getNumber("port");
+
+    client = redis.createClient({
+      url: `redis://${redisHost}:${redisPort}`,
+    });
+  }
 
-  const client = redis.createClient({
-    url: `redis://${redisHost}:${redisPort}`,
-  });
   await client.connect();
 
   const HarborArtifacts = await client.json.get(`${team}Artifacts`, {
     path: ".",
   });
   if (HarborArtifacts) {
-    const Artifacts = await teamArtifacts(RepoInformation);
-    setRedisCache(
-      redisHost,
-      redisPort,
-      `${team}Artifacts`,
-      60,
-      JSON.parse(JSON.stringify(Artifacts))
-    );
     return HarborArtifacts;
   }
   const Artifacts = await teamArtifacts(RepoInformation);
-  setRedisCache(
-    redisHost,
-    redisPort,
+
+  await client.json.set(
     `${team}Artifacts`,
-    60,
+    ".",
     JSON.parse(JSON.stringify(Artifacts))
   );
+  client.expire(`${team}Artifacts`, 3600);
   return Artifacts;
 }
 
-async function setRedisCache(
-  redisHost: string,
-  redisPort: number,
-  identifier: string,
-  ttl: number = 3600,
-  jsonData: string
-) {
-  const client = redis.createClient({
-    url: `redis://${redisHost}:${redisPort}`,
-  });
-  await client.connect();
-  await client.json.set(identifier, ".", jsonData);
-  client.expire(identifier, ttl);
-}
-
 async function teamArtifacts(RepoInformation: RepoInformation[]) {
   const repoArtifacts: Artifact[] = [];
   const errorMsgs: HarborErrors[] = [];