Add SST api

Signed-off-by: Andrei Stepanov <[email protected]>

Author: Andrei-Stepanov

Dockerfile

@@ -12,9 +12,12 @@ RUN ["bash","-c", "--", "npm run build"]
 FROM registry.access.redhat.com/ubi8/nodejs-14
 ARG ADDPKGS=""
 ARG NPMLOCATION="open"
+ARG ANCHORS=""
 USER root
 RUN yum install -y "krb5-workstation" $ADDPKGS && \
     yum clean all -y
+COPY Dockerfile $ANCHORS "$HOME/"
+RUN if [ -n "${ANCHORS}" ]; then echo "Add anchors ${ANCHORS}"; trust anchor --store "${HOME}/${ANCHORS}"; fi
 USER 1001
 COPY "src" "$HOME/src/"
 COPY "assets" "$HOME/assets/"

assets/config-default.yaml

@@ -28,7 +28,8 @@ waiverdb:
 datagrepper:
   url: ~
 sst:
-  url: ~
+  url: 'https://sst.osci.redhat.com'
+  results: 'results/sstlist.json'
 db:
   # http://mongodb.github.io/node-mongodb-native/3.5/api/MongoClient.html
   url: ~
@@ -91,6 +92,7 @@ env_to_config_map:
     url: SRV_DATAGREPPER_URL
   sst:
     url: SRV_SST_URL
+    results: SRV_SST_RESULTS
   db:
     url: SRV_DB_URL
     limit_default: SRV_DB_LIMIT_DEFAULT

src/cfg.ts

@@ -205,6 +205,7 @@ export interface Cfg {
   };
   sst: {
     url: string;
+    results: string;
   };
   db: {
     /**

src/schema/root_query_type.ts

@@ -1,7 +1,7 @@
 /*
  * This file is part of ciboard-server
 
- * Copyright (c) 2021 Andrei Stepanov <[email protected]>
+ * Copyright (c) 2021, 2022 Andrei Stepanov <[email protected]>
  * 
  * This program is free software; you can redistribute it and/or
  * modify it under the terms of the GNU Lesser General Public
@@ -67,6 +67,8 @@ import {
   GreenwaveSubjectTypesType,
 } from './greenwave_types';
 
+import { SSTInfoType, SSTListType, SSTResultsType } from './sst_types';
+
 import { ArtifactsType } from './db_types';
 
 import {
@@ -158,6 +160,73 @@ const RootQuery = new GraphQLObjectType({
         return 'pong';
       },
     },
+    /**
+     *  Subsystem teams (SST)
+     */
+    sst_list: {
+      type: SSTListType,
+      resolve() {
+        const url = new URL(cfg.sst.results, cfg.sst.url);
+        return axios.get(url.toString()).then((response) =>
+          response.data.map((sst: SSTInfoType) => {
+            const releases = (sst.releases || []).map((rel) => rel.name);
+            const { name, display_name } = sst;
+            return { name, display_name, releases };
+          })
+        );
+      },
+    },
+    sst_results: {
+      type: SSTResultsType,
+      args: {
+        sst_name: { type: new GraphQLNonNull(GraphQLString) },
+        release: { type: new GraphQLNonNull(GraphQLString) },
+      },
+      resolve(_parentValue, { sst_name, release }) {
+        const results_json_url = new URL(
+          `/results/${sst_name}.${release}.json`,
+          cfg.sst.url
+        ).toString();
+        return axios.get(results_json_url).then((response) => {
+          const results = response.data.data;
+          const reply = _.map(results, (result) => {
+            const transformed: { [key: string]: any } = {
+              nvr: result.nvr,
+              assignee: result.assignee,
+              artifact: {
+                id: result.aid,
+                url: result.aid_link,
+              },
+              testcase: {
+                namespace: result.namespace,
+                type: result.type,
+                category: result.category,
+              },
+              tag: result.tag,
+              time: result.time,
+              status: result.status,
+              metadata_url: result.nvr_link,
+            };
+            if (result.rebuild_link && result.rebuild_link !== 'X')
+              transformed.rebuild_url = result.rebuild_link;
+            if (result.log_link && result.log_link !== 'X') {
+              if (Array.isArray(result.log_link))
+                transformed.log_urls = result.log_link;
+              else transformed.log_urls = [result.log_link];
+            }
+            if (result.el8_gating_bug && result.el8_gating_bug !== 'X')
+              transformed.gating_bug = {
+                text: result.el8_gating_bug,
+                url: result.el8_gating_bug_link,
+              };
+            if (result.yaml && result.yaml !== 'missing')
+              transformed.gating_yaml_url = result.yaml_link;
+            return transformed;
+          });
+          return reply as SSTResultsType;
+        });
+      },
+    },
     /**
      * WaiverDB
      */
@@ -656,7 +725,7 @@ const RootQuery = new GraphQLObjectType({
         };
       },
     },
-    sst_list: {
+    db_sst_list: {
       args: {
         product_id: {
           type: GraphQLInt,

src/services/db.ts

@@ -41,7 +41,45 @@ const options: MongoClientOptions = _.pickBy(
 
 log(' [i] mongo client options: %O', options);
 
-export const client_promise = new MongoClient(cfg.db.url, options).connect();
+async function attemptAsync<T>(
+  func: (...args: any[]) => Promise<T>,
+  ...args: any[]
+): Promise<Error | T> {
+  try {
+    return await func(...args);
+  } catch (e) {
+    if (_.isError(e)) {
+      return e;
+    }
+    throw e;
+  }
+}
+
+const mkClient = (): Promise<MongoClient> => {
+  var mongoClient;
+  try {
+    mongoClient = new MongoClient(cfg.db.url, options);
+  } catch (e) {
+    console.log('Failed to create mongo configuration. Check options.');
+    console.dir(e);
+    process.exit(1);
+  }
+  return mongoClient.connect();
+};
+
+const clientPromise: Promise<Error | MongoClient> =
+  attemptAsync<MongoClient>(mkClient);
+
+const getClient = async (
+  clientPromise: Promise<Error | MongoClient>
+): Promise<MongoClient> => {
+  const client = await clientPromise;
+  if (_.isError(client)) {
+    console.dir(clientPromise);
+    process.exit(1);
+  }
+  return client;
+};
 
 /** For reduced query */
 const project = {
@@ -78,7 +116,7 @@ const mk_filter = (
 };
 
 (async function test() {
-  const client = await client_promise;
+  const client = await getClient(clientPromise);
   const database = client.db('ci-messages');
   const collection = database.collection('artifacts');
   const cursor = collection.find().sort({ _id: -1 }).limit(1);
@@ -155,7 +193,11 @@ export const mk_cursor = async (args: QueryOptions) => {
     dbFieldValues3,
     dbFieldValuesComponentMapping1,
   } = args;
-  const client = await client_promise;
+  if (_.isError(clientPromise)) {
+    console.dir(clientPromise);
+    process.exit(1);
+  }
+  const client = await getClient(clientPromise);
   const database = client.db(cfg.db.db_name);
   const collection = database.collection(cfg.db.collection_name);
   /** look-up by name -> nvr, nsvc, ... */
@@ -254,7 +296,7 @@ export const mk_cursor = async (args: QueryOptions) => {
 };
 
 export const db_list_sst = async (product_id: number) => {
-  const client = await client_promise;
+  const client = await getClient(clientPromise);
   const database = client.db(cfg.db.db_name);
   const collection = database.collection(cfg.db.collection_name_components);
   log('List SST names');