New Badges components: destination, public, status, teams + container/status

apps/ui/src/lib/container/status.ts

@@ -0,0 +1,73 @@
+//
+// Maps Container ID x Operation Status
+//
+// Example response of $status => {'123asdf': 'degraded', '124asdf': 'running'}
+
+import { writable, get as getStore } from 'svelte/store';
+import { get } from '$lib/api';
+
+export let containerStatus = writable({});
+
+let PERMITED_STATUS = ['loading', 'running', 'healthy', 'building', 'degraded', 'stopped', 'error'];
+
+// refreshStatus([{id}])
+export async function refreshStatus(list:Array<any>) {
+  for (const item of list) {
+    setStatus(item.id, 'loading');
+    getStatus(item, true);
+  }
+}
+
+export async function getStatus(resource: any, force: boolean = false) {
+  const { id, buildPack, dualCerts, engine } = resource;
+  let newStatus = 'stopped';
+
+  // Already set and we're not forcing
+  if (getStore(containerStatus)[id] && !force) return getStore(containerStatus)[id];
+
+  try {
+    if (buildPack) { // Application
+      const response = await get(`/applications/${id}/status`);
+      newStatus = parseApplicationsResponse(response);
+    } else if (typeof dualCerts !== 'undefined') { // Service
+      const response = await get(`/services/${id}/status`);
+      newStatus = parseServiceResponse(response);
+    } else if (typeof engine !== 'undefined'){ // Destination/Server
+      const response = await get(`/destinations/${id}/status`);
+      newStatus = response.isRunning ? 'running' : 'stopped';
+    } else { // Database
+      const response = await get(`/databases/${id}/status`);
+      newStatus = response.isRunning ? 'running' : 'stopped';
+    }
+  } catch (error) {
+    newStatus = 'error';
+  }
+
+  setStatus(id, newStatus);
+  // console.log("GOT:", id, newStatus)
+  return newStatus
+}
+
+const setStatus = (thingId, newStatus) => {
+  if(!PERMITED_STATUS.includes(newStatus))
+    throw(`Change to ${newStatus} is not permitted. Try: ${PERMITED_STATUS.join(', ')}`);
+  containerStatus.update(n => Object.assign(n, {thingId: newStatus}));
+};
+
+// -- Response Parsing
+
+function parseApplicationsResponse(list:Array<any>){
+  if (list.length === 0) return 'stopped';
+  if (list.length === 1) return list[0].status.isRunning ? 'running' : 'stopped';
+  return allWorking(list.map( (el:any) => el.status.isRunning ))
+}
+
+function parseServiceResponse(response:any){
+  if (Object.keys(response).length === 0) return 'stopped';
+  let list = Object.keys(response).map((el) => el.status.isRunning)
+  return allWorking(list) ? 'running' : 'degraded'
+}
+
+function allWorking(list:Array<any>){
+  return list.reduce((acum:boolean,res:boolean) => acum && res) ? 'running' : 'degraded';
+}