{plotEntriesA.length == 0 ? "No plots of this type in this collection" : ""}
- {plotEntriesB.length == 0 ? "No plots of this type in this collection" : ""}
+ {plotEntriesA.length == 0 || plotEntriesB.length == 0 ? (
+
+
+ ) : (
+ ""
+ )}
+ {plotEntriesA.length == 0
+ ? "No plots of this type in this collection"
+ : ""}
- : "" }
+
+ {plotEntriesB.length == 0
+ ? "No plots of this type in this collection"
+ : ""}
+
+
{getSlice(currentPage).map((indexedEntry, n) => (
diff --git a/app/_components/listPager.js b/app/_components/listPager.js
index 603ab4c..de2cedc 100644
--- a/app/_components/listPager.js
+++ b/app/_components/listPager.js
@@ -1,74 +1,104 @@
+"use client";
+import Link from "next/link";
+import React from "react";
+import { useState } from "react";
-'use client'
+export default function ListPager({
+ listEntries,
+ entriesPerPage = 10,
+ showRepo = true,
+}) {
+ const [currentPage, setCurrentPage] = useState(1);
-import Link from 'next/link'
-import React from 'react';
-import { useState } from 'react'
+ const totalPages = () => {
+ return Math.ceil(listEntries.length / entriesPerPage);
+ };
-export default function ListPager({listEntries, entriesPerPage = 10, showRepo = true}) {
-
- const [currentPage, setCurrentPage] = useState(1)
-
- const totalPages = () => {
- return Math.ceil(listEntries.length/entriesPerPage)
- }
-
- const previousPage = () => {
- if(currentPage > 1) {
- setCurrentPage(currentPage - 1)
- }
+ const previousPage = () => {
+ if (currentPage > 1) {
+ setCurrentPage(currentPage - 1);
}
+ };
- const nextPage = () => {
- if(currentPage < totalPages()) {
- setCurrentPage(currentPage + 1)
- }
+ const nextPage = () => {
+ if (currentPage < totalPages()) {
+ setCurrentPage(currentPage + 1);
}
+ };
- const getSlice = (currentPage) => {
+ const getSlice = (currentPage) => {
+ return listEntries.slice(
+ (currentPage - 1) * entriesPerPage,
+ currentPage * entriesPerPage,
+ );
+ };
+ const cellClassNames = "px-2 py-3";
- return listEntries.slice((currentPage - 1) * entriesPerPage, currentPage * entriesPerPage)
- }
- const cellClassNames = "px-2 py-3"
-
- return (
-
-
-
-
-
+ return (
+
+ );
}
diff --git a/app/_components/plotDisplay.js b/app/_components/plotDisplay.js
index 524d542..b4a2cd0 100644
--- a/app/_components/plotDisplay.js
+++ b/app/_components/plotDisplay.js
@@ -1,33 +1,51 @@
+import React from "react";
-import React from 'react';
+export default async function PlotDisplay({
+ plotEntry,
+ showDataId = true,
+ showDatasetType = false,
+ showPermalink = false,
+}) {
+ const { instrument, skymap, ...dataId } = JSON.parse(plotEntry.dataId);
+ const uuid = plotEntry.id;
+ const imgUrl = plotEntry.url;
+ const repo = plotEntry.repo;
+ const permalink = plotEntry.permalink ?? "";
+ const datasetType = plotEntry.datasetType ?? "";
-export default async function PlotDisplay({plotEntry, showDataId = true, showDatasetType = false, showPermalink = false}) {
+ const splitType = [...datasetType.matchAll(/[a-zA-Z0-9]*(_|$)/g)].map(
+ (x) => x[0],
+ );
+ const typeWithWbr = splitType.join("\u00ad");
- const {instrument, skymap, ...dataId} = JSON.parse(plotEntry.dataId)
- const uuid = plotEntry.id
- const imgUrl = plotEntry.url
- const repo = plotEntry.repo
- const permalink = plotEntry.permalink ?? ''
- const datasetType = plotEntry.datasetType ?? ''
+ const dataIdString = Object.entries(dataId)
+ .map(([k, v]) => `${k}: ${v}`)
+ .join(", ");
- const splitType = [...datasetType.matchAll(/[a-zA-Z0-9]*(_|$)/g)].map((x) => x[0])
- const typeWithWbr = splitType.join('\u00ad')
-
- const dataIdString = Object.entries(dataId).map(([k,v]) => `${k}: ${v}`).join(', ')
-
- return (
- | Collection | - { showRepo ? -Repo | - : ""} -Last Updated | -
| {summary.collection} | - { showRepo ? -{summary.repo} | - : "" } -{summary.lastModified.toDateString()} | -
+
+
+
+
+
-
- )
-
+ | Collection | + {showRepo ?Repo | : ""} +Last Updated | +
| + + {summary.collection} + + | + {showRepo ? ( +{summary.repo} | + ) : ( + "" + )} ++ {summary.lastModified.toDateString()} + | +
-
+
- { currentPage > 1 ? :
-
- Prev
}
- Page {currentPage}/{totalPages()}
-
- { currentPage < totalPages() ? :
-
- Next
}
-
+
-
+ {currentPage > 1 ? (
+
+ ) : (
+
+ Prev
+ )}
+
+ Page {currentPage}/{totalPages()}
+
+
+ {currentPage < totalPages() ? (
+
+ ) : (
+
Next
+ )}
+
- 
- :
-
- }
+ return (
+
- { showDataId ? dataIdString : "" }
- { showDatasetType ? typeWithWbr : "" }
-
- { showPermalink ? : "" }
- { uuid ?
-
+
+ ) : (
+
+ )}
+
+ );
}
diff --git a/app/_components/plotPager.js b/app/_components/plotPager.js
index 9d5c5f7..77e2396 100644
--- a/app/_components/plotPager.js
+++ b/app/_components/plotPager.js
@@ -1,143 +1,210 @@
-
-'use client'
-
-import React from 'react';
-import { useState, useEffect } from 'react'
-import BandSelector from './bandSelector.js'
-
-export default function PlotPager({plotEntries, plotsPerPage = 10}) {
-
- const [selectedBands, setSelectedBands] = useState({u: true, g: true, r: true, i: true, z: true, y: true})
-
- const [currentPage, setCurrentPage] = useState(1)
- const [inLightbox, setInLightbox] = useState(false)
- const [displayedEntry, setDisplayedEntry] = useState(0)
-
- const getFilteredEntries = () => {
-
- const indexedEntries = plotEntries.map((entry, n) => ({dataId: entry.dataId, plot: entry.plot, index: n}))
- return indexedEntries.filter(
- (indexedEntry) => selectedBands[indexedEntry.dataId.band] || !('band' in indexedEntry.dataId) )
+"use client";
+
+import React from "react";
+import { useState, useEffect } from "react";
+import BandSelector from "./bandSelector.js";
+
+export default function PlotPager({ plotEntries, plotsPerPage = 10 }) {
+ const [selectedBands, setSelectedBands] = useState({
+ u: true,
+ g: true,
+ r: true,
+ i: true,
+ z: true,
+ y: true,
+ });
+
+ const [currentPage, setCurrentPage] = useState(1);
+ const [inLightbox, setInLightbox] = useState(false);
+ const [displayedEntry, setDisplayedEntry] = useState(0);
+
+ const getFilteredEntries = () => {
+ return plotEntries
+ .filter(
+ (indexedEntry) =>
+ selectedBands[indexedEntry.dataId.band] ||
+ !("band" in indexedEntry.dataId),
+ )
+ .map((entry, n) => ({
+ dataId: entry.dataId,
+ plot: entry.plot,
+ index: n,
+ }));
+ };
+
+ const totalPages = () => {
+ return Math.ceil(getFilteredEntries().length / plotsPerPage);
+ };
+
+ const onBandUpdated = (band, value) => {
+ setSelectedBands({ ...selectedBands, [band]: event.target.checked });
+ };
+
+ useEffect(() => {
+ if (currentPage > totalPages()) {
+ setCurrentPage(totalPages());
}
-
- const totalPages = () => {
- return Math.ceil(getFilteredEntries().length/plotsPerPage)
+ if (currentPage == 0 && totalPages() > 0) {
+ setCurrentPage(1);
}
-
- const onBandUpdated = (band, value) => {
- setSelectedBands({...selectedBands, [band]: event.target.checked})
- }
-
- useEffect(() => {
- if(currentPage > totalPages()) {
- setCurrentPage(totalPages())
- }
- if(currentPage == 0 && totalPages() > 0) {
- setCurrentPage(1)
- }
- }, [selectedBands])
-
- const displayBandSelector = () => {
- const dimensions = new Set(plotEntries.map((entry) => Object.keys(entry.dataId)).flat())
- return (dimensions.has('band'))
+ }, [selectedBands]);
+
+ const displayBandSelector = () => {
+ const dimensions = new Set(
+ plotEntries.map((entry) => Object.keys(entry.dataId)).flat(),
+ );
+ return dimensions.has("band");
+ };
+
+ const previousPage = () => {
+ if (currentPage > 1) {
+ setCurrentPage(Number(currentPage) - 1);
}
+ };
- const previousPage = () => {
- if(currentPage > 1) {
- setCurrentPage(currentPage - 1)
- }
+ const nextPage = () => {
+ if (currentPage < totalPages()) {
+ setCurrentPage(Number(currentPage) + 1);
}
-
- const nextPage = () => {
- if(currentPage < totalPages()) {
- setCurrentPage(currentPage + 1)
- }
+ };
+
+ const showLightboxEntry = (entry) => {
+ setDisplayedEntry(entry);
+ setInLightbox(true);
+ };
+
+ const exitLightbox = () => {
+ setInLightbox(false);
+ };
+ const doNothing = (e) => {
+ e.stopPropagation();
+ };
+
+ const advanceLeft = (e) => {
+ e.stopPropagation();
+ if (displayedEntry > 0) {
+ setDisplayedEntry(displayedEntry - 1);
}
+ };
- const showLightboxEntry = (entry) => {
- setDisplayedEntry(entry)
- setInLightbox(true)
- }
-
- const exitLightbox = () => {
- setInLightbox(false)
- }
- const doNothing = (e) => {
- e.stopPropagation();
+ const advanceRight = (e) => {
+ e.stopPropagation();
+ if (displayedEntry < getFilteredEntries().length - 1) {
+ setDisplayedEntry(displayedEntry + 1);
}
-
- const advanceLeft = (e) => {
- e.stopPropagation();
- if(displayedEntry > 0) {
- setDisplayedEntry(displayedEntry - 1)
- }
- }
-
- const advanceRight = (e) => {
- e.stopPropagation();
- if(displayedEntry < (plotEntries.length - 1)) {
- setDisplayedEntry(displayedEntry + 1)
- }
- }
-
-
- const getSlice = (currentPage) => {
-
- return getFilteredEntries().slice((currentPage - 1) * plotsPerPage, currentPage * plotsPerPage)
- }
-
-
- return (
-
+ {showDataId ? dataIdString : ""}
+ {showDatasetType ? typeWithWbr : ""}
+
+ {showPermalink ? (
+
-
- )
+ ) : (
+ ""
+ )}
+ {uuid ? (
+
-
-
-
-
-
-
- { currentPage > 1 ? :
-
- Prev
}
- Page {currentPage}/{totalPages()}
-
- { currentPage < totalPages() ? :
-
- Next
}
-
- { displayBandSelector() ?
-
- {getSlice(currentPage).map((indexedEntry, n) =>
-
showLightboxEntry(indexedEntry.index)}>
- {indexedEntry.plot}
-
- )}
+ };
+
+ const getSlice = (currentPage) => {
+ return getFilteredEntries().slice(
+ (currentPage - 1) * plotsPerPage,
+ currentPage * plotsPerPage,
+ );
+ };
+
+ return (
+
+
+ );
}
diff --git a/app/_components/selectionDropdown.js b/app/_components/selectionDropdown.js
index b77350a..2a512d8 100644
--- a/app/_components/selectionDropdown.js
+++ b/app/_components/selectionDropdown.js
@@ -1,30 +1,25 @@
-'use client'
-
-
-import React from 'react'
-import {useState} from 'react'
-
-
-export default function SelectionDropdown({contents, title, initiallyOpen = false}) {
-
- const [showContents, setShowContents] = useState(initiallyOpen)
-
-
- const toggle = () => {
- setShowContents(!showContents)
- }
-
-
- return (
-
+
+
+
+
+
+ {currentPage > 1 ? (
+
+ ) : (
+
+ Prev
+ )}
+
+ Page
+ setCurrentPage(e.target.value)}
+ />
+ /{totalPages()}
+
+
+ {currentPage < totalPages() ? (
+
+ ) : (
+
+ Next
+ )}
+
+ {displayBandSelector() ? (
+
+
+ {currentPage >= 1 && currentPage <= totalPages()
+ ? ""
+ : "Invalid page number"}
+ {getSlice(currentPage).map((indexedEntry, n) => (
+
+ {inLightbox ? (
+ showLightboxEntry(indexedEntry.index)}
+ >
+ {indexedEntry.plot}
+
+ ))}
+
+
+
- )
-
+ ) : (
+ ""
+ )}
+
+ {displayedEntry > 0 ? (
+
+
+
+ ) : (
+ ""
+ )}
+ <<
+
+
+
+ {getFilteredEntries()[displayedEntry].plot}
- { inLightbox ?
-
-
-
- : ""}
+
- {displayedEntry > 0 ?
-
-
-
- : "" }
- <<
-
-
-
- {plotEntries[displayedEntry].plot}
-
-
- {displayedEntry < (plotEntries.length - 1) ?
-
-
-
- : "" }
- >>
-
+ {displayedEntry < plotEntries.length - 1 ? (
+
+
+ ) : (
+ ""
+ )}
+ >>
+
-
- )
-
+"use client";
+
+import React from "react";
+import { useState } from "react";
+
+export default function SelectionDropdown({
+ contents,
+ title,
+ initiallyOpen = false,
+}) {
+ const [showContents, setShowContents] = useState(initiallyOpen);
+
+ const toggle = () => {
+ setShowContents(!showContents);
+ };
+
+ return (
+
- {title}
-
- {showContents ?
- contents
- : ""}
-
+
+ );
}
-
diff --git a/app/_lib/dataIdFuncs.js b/app/_lib/dataIdFuncs.js
index 5f25101..49c1cb0 100644
--- a/app/_lib/dataIdFuncs.js
+++ b/app/_lib/dataIdFuncs.js
@@ -1,38 +1,39 @@
-
export default function DataIdSortFunc(dataIdA, dataIdB) {
+ const bandsOrder = ["u", "g", "r", "i", "z", "y"];
- const bandsOrder = ['u', 'g', 'r', 'i', 'z', 'y']
-
- if('tract' in dataIdA && 'tract' in dataIdB) {
- const tract_comparison = dataIdA.tract - dataIdB.tract
- if(tract_comparison != 0) {
- return tract_comparison
- }
+ if ("tract" in dataIdA && "tract" in dataIdB) {
+ const tract_comparison = dataIdA.tract - dataIdB.tract;
+ if (tract_comparison != 0) {
+ return tract_comparison;
}
+ }
- if('visit' in dataIdA && 'visit' in dataIdB) {
- const visit_comparison = dataIdA.visit - dataIdB.visit
- if(visit_comparison != 0) {
- return visit_comparison
- }
+ if ("visit" in dataIdA && "visit" in dataIdB) {
+ const visit_comparison = dataIdA.visit - dataIdB.visit;
+ if (visit_comparison != 0) {
+ return visit_comparison;
}
+ }
- if('band' in dataIdA && 'band' in dataIdB) {
- const band_comparison = bandsOrder.indexOf(dataIdA.band) - bandsOrder.indexOf(dataIdB.band)
- if(band_comparison != 0) {
- return band_comparison
- }
+ if ("band" in dataIdA && "band" in dataIdB) {
+ const band_comparison =
+ bandsOrder.indexOf(dataIdA.band) - bandsOrder.indexOf(dataIdB.band);
+ if (band_comparison != 0) {
+ return band_comparison;
}
-
- if('physical_filter' in dataIdA && 'physical_filter' in dataIdB) {
- const physical_filter_comparison = bandsOrder.indexOf(dataIdA.physical_filter[0]) - bandsOrder.indexOf(dataIdB.physical_filter[0])
- if(physical_filter_comparison != 0) {
- return physical_filter_comparison
- }
+ }
+
+ if ("physical_filter" in dataIdA && "physical_filter" in dataIdB) {
+ const physical_filter_comparison =
+ bandsOrder.indexOf(dataIdA.physical_filter[0]) -
+ bandsOrder.indexOf(dataIdB.physical_filter[0]);
+ if (physical_filter_comparison != 0) {
+ return physical_filter_comparison;
}
+ }
- /* if none of these dimensions are available */
- return 0
+ /* if none of these dimensions are available */
+ return 0;
}
-export { DataIdSortFunc }
+export { DataIdSortFunc };
diff --git a/app/_lib/summaries.js b/app/_lib/summaries.js
index 01e34a3..4502ba4 100644
--- a/app/_lib/summaries.js
+++ b/app/_lib/summaries.js
@@ -1,12 +1,13 @@
+import {
+ S3Client,
+ ListObjectsV2Command,
+ GetObjectCommand,
+} from "@aws-sdk/client-s3";
+const fs = require("fs");
+const zlib = require("zlib");
-import { S3Client, ListObjectsV2Command, GetObjectCommand} from "@aws-sdk/client-s3"
-
-const fs = require('fs');
-const zlib = require('zlib');
-
-const { readFile } = require("fs/promises")
-
+const { readFile } = require("fs/promises");
/*
* This function defines which repo names are "special" such that users should be sent to the "More
@@ -15,206 +16,212 @@ const { readFile } = require("fs/promises")
*
*/
function GetCollectionListURLFromRepo(repoName) {
+ const moreRepos = ["decasu"];
- const moreRepos = ['decasu']
-
- return moreRepos.includes(repoName) ? '/more' : ''
-
+ return moreRepos.includes(repoName) ? "/more" : "";
}
function GetButlerURL(repoName) {
+ const repoUrls = (() => {
+ try {
+ return JSON.parse(process.env.REPO_URLS);
+ } catch (err) {
+ console.error(`Could not parse REPO_URLS env var, ${err}`);
+ console.error(`REPO_URLS='${process.env.REPO_URLS}'`);
+ return {};
+ }
+ })();
- const repoUrls = (() => {
- try {
- return JSON.parse(process.env.REPO_URLS)
- } catch (err) {
- console.error(`Could not parse REPO_URLS env var, ${err}`)
- console.error(`REPO_URLS='${process.env.REPO_URLS}'`)
- return {}
- }
- })()
-
- return repoUrls[repoName]
-
+ return repoUrls[repoName];
}
function GetClient() {
-
- const client = new S3Client({
- endpoint: process.env.BUCKET_URL,
- region: "s3dfrgw",
- forcePathStyle: true,
- credentials: {
- accessKeyId: process.env.S3_KEY,
- secretAccessKey: process.env.S3_SECRET,
- },
- })
-
- return client
+ const client = new S3Client({
+ endpoint: process.env.BUCKET_URL,
+ region: "s3dfrgw",
+ forcePathStyle: true,
+ credentials: {
+ accessKeyId: process.env.S3_KEY,
+ secretAccessKey: process.env.S3_SECRET,
+ },
+ });
+
+ return client;
}
async function _GetSummaryS3(repoName, collectionName) {
-
- const client = GetClient()
- const command = new GetObjectCommand({
- Bucket: process.env.BUCKET_NAME,
- Key: `${encodeURIComponent(repoName)}/collection_${encodeURIComponent(collectionName)}.json.gz`
- })
-
- try {
- const response = await client.send(command)
- const gzData = await response.Body.transformToByteArray()
- const collectionData = JSON.parse(zlib.gunzipSync(gzData))
- return collectionData
-
- } catch (err) {
- console.error(err)
- return {}
- }
-
+ const client = GetClient();
+ const command = new GetObjectCommand({
+ Bucket: process.env.BUCKET_NAME,
+ Key: `${encodeURIComponent(repoName)}/collection_${encodeURIComponent(collectionName)}.json.gz`,
+ });
+
+ try {
+ const response = await client.send(command);
+ const gzData = await response.Body.transformToByteArray();
+ const collectionData = JSON.parse(zlib.gunzipSync(gzData));
+ return collectionData;
+ } catch (err) {
+ console.error(err);
+ return {};
+ }
}
async function GetSummary(repoName, collectionName) {
-
- if(!process.env.ENABLE_TEST_IMAGES) {
- return await _GetSummaryS3(repoName, collectionName)
-
- } else {
- const gzData = await readFile(`test_assets/summaries/${encodeURIComponent(repoName)}/collection_${encodeURIComponent(collectionName)}.json.gz`)
- const collectionData = JSON.parse(zlib.gunzipSync(gzData))
- return collectionData
- }
-
+ if (!process.env.ENABLE_TEST_IMAGES) {
+ return await _GetSummaryS3(repoName, collectionName);
+ } else {
+ const gzData = await readFile(
+ `test_assets/summaries/${encodeURIComponent(repoName)}/collection_${encodeURIComponent(collectionName)}.json.gz`,
+ );
+ const collectionData = JSON.parse(zlib.gunzipSync(gzData));
+ return collectionData;
+ }
}
async function _ListSummariesS3(repoName) {
-
- const client = GetClient()
- const command = new ListObjectsV2Command({
- Bucket: process.env.BUCKET_NAME,
- Prefix: `${encodeURIComponent(repoName)}/`,
- });
-
- try {
- let isTruncated = true;
-
- let filenameArrays = []
-
- while (isTruncated) {
- const { Contents, IsTruncated, NextContinuationToken } =
- await client.send(command)
- if(Contents) {
- filenameArrays.push(Contents)
- }
- isTruncated = IsTruncated
- command.input.ContinuationToken = NextContinuationToken
- }
- return filenameArrays.flat()
- } catch (err) {
- console.log(err)
- return []
+ const client = GetClient();
+ const command = new ListObjectsV2Command({
+ Bucket: process.env.BUCKET_NAME,
+ Prefix: `${encodeURIComponent(repoName)}/`,
+ });
+
+ try {
+ let isTruncated = true;
+
+ let filenameArrays = [];
+
+ while (isTruncated) {
+ const { Contents, IsTruncated, NextContinuationToken } =
+ await client.send(command);
+ if (Contents) {
+ filenameArrays.push(Contents);
+ }
+ isTruncated = IsTruncated;
+ command.input.ContinuationToken = NextContinuationToken;
}
-
+ return filenameArrays.flat();
+ } catch (err) {
+ console.log(err);
+ return [];
+ }
}
async function _ListSummariesFilesystem(repoName) {
- const repoDir = `test_assets/summaries/${encodeURIComponent(repoName)}`
- try {
- console.log(fs.readdirSync(repoDir))
- return fs.readdirSync(repoDir).filter(
- (filename) => filename.match("^collection_(.*).json.gz$"));
- } catch (error) {
- return []
- }
+ const repoDir = `test_assets/summaries/${encodeURIComponent(repoName)}`;
+ try {
+ return fs
+ .readdirSync(repoDir)
+ .filter((filename) => filename.match("^collection_(.*).json.gz$"));
+ } catch (error) {
+ return [];
+ }
}
async function ListSummaries(repo) {
+ const decodeFilename = (filename) => {
+ const uriEncodedCollection = filename.match("collection_(.*).json.gz")[1];
+ return decodeURIComponent(uriEncodedCollection);
+ };
- const decodeFilename = (filename) => {
- const uriEncodedCollection = filename.match("collection_(.*).json.gz")[1]
- return decodeURIComponent(uriEncodedCollection)
- }
-
- const repoUrls = (() => {
- try {
- return JSON.parse(process.env.REPO_URLS)
- } catch (err) {
- console.error(`Could not parse REPO_URLS env var, ${err}`)
- console.error(`REPO_URLS='${process.env.REPO_URLS}'`)
- return {}
- }
- })()
-
- const repos = repo ? [repo] : Object.keys(repoUrls)
-
- if(!process.env.ENABLE_TEST_IMAGES) {
- const res = await Promise.all(repos.map(repo =>
- {
- return _ListSummariesS3(repo).then((entries) => entries.map(entry => ({repo: repo, collection: decodeFilename(entry.Key), filename: entry.Key, lastModified: entry.LastModified})))
- }))
- return res.flat()
- } else {
- const res = await Promise.all(
- repos.map(repo => _ListSummariesFilesystem(repo)
- .then((filenames) => filenames.map(filename => ({repo: repo, collection: decodeFilename(filename), filename: filename,
- lastModified: new Date(2025, 2, 10, 2, 30)}))))
- )
- return res.flat()
+ const repoUrls = (() => {
+ try {
+ return JSON.parse(process.env.REPO_URLS);
+ } catch (err) {
+ console.error(`Could not parse REPO_URLS env var, ${err}`);
+ console.error(`REPO_URLS='${process.env.REPO_URLS}'`);
+ return {};
}
-
+ })();
+
+ const repos = repo ? [repo] : Object.keys(repoUrls);
+
+ if (!process.env.ENABLE_TEST_IMAGES) {
+ const res = await Promise.all(
+ repos.map((repo) => {
+ return _ListSummariesS3(repo).then((entries) =>
+ entries.map((entry) => ({
+ repo: repo,
+ collection: decodeFilename(entry.Key),
+ filename: entry.Key,
+ lastModified: entry.LastModified,
+ })),
+ );
+ }),
+ );
+ return res.flat();
+ } else {
+ const res = await Promise.all(
+ repos.map((repo) =>
+ _ListSummariesFilesystem(repo).then((filenames) =>
+ filenames.map((filename) => ({
+ repo: repo,
+ collection: decodeFilename(filename),
+ filename: filename,
+ lastModified: new Date(2025, 2, 10, 2, 30),
+ })),
+ ),
+ ),
+ );
+ return res.flat();
+ }
}
async function ListReports() {
- return []
+ return [];
- const client = GetClient()
+ const client = GetClient();
- const command = new ListObjectsV2Command({
- Bucket: process.env.BUCKET_NAME,
- Prefix: `reports/`
- });
+ const command = new ListObjectsV2Command({
+ Bucket: process.env.BUCKET_NAME,
+ Prefix: `reports/`,
+ });
- try {
- let isTruncated = true;
-
- let filenameArrays = []
-
- while (isTruncated) {
- const { Contents, IsTruncated, NextContinuationToken } =
- await client.send(command)
- if(Contents) {
- filenameArrays.push(Contents.map((entry) => entry.Key))
- }
- isTruncated = IsTruncated
- command.input.ContinuationToken = NextContinuationToken
- }
- return filenameArrays.flat()
- } catch (err) {
- console.log(err)
- return []
- }
-
-}
-
-async function GetReport(filename) {
+ try {
+ let isTruncated = true;
- const client = GetClient()
- const command = new GetObjectCommand({
- Bucket: process.env.BUCKET_NAME,
- Key: `reports/${filename}`
- })
+ let filenameArrays = [];
- try {
- const response = await client.send(command)
- const gzData = await response.Body.transformToByteArray()
- const collectionData = JSON.parse(zlib.gunzipSync(gzData))
- return collectionData
-
- } catch (err) {
- console.error(err)
- return {}
+ while (isTruncated) {
+ const { Contents, IsTruncated, NextContinuationToken } =
+ await client.send(command);
+ if (Contents) {
+ filenameArrays.push(Contents.map((entry) => entry.Key));
+ }
+ isTruncated = IsTruncated;
+ command.input.ContinuationToken = NextContinuationToken;
}
+ return filenameArrays.flat();
+ } catch (err) {
+ console.log(err);
+ return [];
+ }
+}
+async function GetReport(filename) {
+ const client = GetClient();
+ const command = new GetObjectCommand({
+ Bucket: process.env.BUCKET_NAME,
+ Key: `reports/${filename}`,
+ });
+
+ try {
+ const response = await client.send(command);
+ const gzData = await response.Body.transformToByteArray();
+ const collectionData = JSON.parse(zlib.gunzipSync(gzData));
+ return collectionData;
+ } catch (err) {
+ console.error(err);
+ return {};
+ }
}
-export {GetCollectionListURLFromRepo, ListSummaries, GetSummary, ListReports, GetReport, GetButlerURL, GetClient}
+export {
+ GetCollectionListURLFromRepo,
+ ListSummaries,
+ GetSummary,
+ ListReports,
+ GetReport,
+ GetButlerURL,
+ GetClient,
+};
+ {title}
+
+ {showContents ? contents : ""}
+