Don't retry in go by default, increase batch sizing for DB

src/alerting.ts

@@ -91,7 +91,7 @@ const dbWriterLoop = async () => {
 
   dbWriterInitialised = true;
 
-  dbWriterInterval = setInterval(writeRecords, 5_000);
+  dbWriterInterval = setInterval(writeRecords, 10_000);
 
   if (process.env.DEBUG_DB_WRITER) {
     setInterval(() => {

src/fetch-beacon-data.ts

@@ -43,7 +43,9 @@ export const fetchBeaconDataInLoop = async (beaconId: string) => {
   const { config } = getState();
   const { fetchInterval } = config.beacons[beaconId];
 
-  setInterval(() => fetchBeaconData(beaconId), fetchInterval * 1_000);
+  const fetchBeaconDataCallback = () => fetchBeaconData(beaconId);
+  setInterval(fetchBeaconDataCallback, fetchInterval * 1_000);
+  fetchBeaconDataCallback();
 };
 
 export const fetchBeaconData = async (beaconId: string) => {
@@ -76,7 +78,7 @@ export const fetchBeaconData = async (beaconId: string) => {
   }
 
   const goRes = await go(fetchFn, {
-    retries: 2,
+    retries: 0,
     delay: { type: 'random', minDelayMs: RANDOM_BACKOFF_MIN_MS, maxDelayMs: RANDOM_BACKOFF_MAX_MS },
     onAttemptError,
   });

src/update-data-feeds.ts

@@ -86,10 +86,11 @@ export const initiateDataFeedUpdates = () => {
 export const updateDataFeedsInLoop = async (providerSponsorDataFeeds: ProviderSponsorDataFeeds) => {
   const { updateInterval } = providerSponsorDataFeeds;
 
-  setInterval(
-    () => Promise.allSettled([updateBeacons(providerSponsorDataFeeds), updateBeaconSets(providerSponsorDataFeeds)]),
-    updateInterval * 1_000
-  );
+  const intervalCallback = () =>
+    Promise.allSettled([updateBeacons(providerSponsorDataFeeds), updateBeaconSets(providerSponsorDataFeeds)]);
+
+  setInterval(intervalCallback, updateInterval * 1_000);
+  intervalCallback();
 };
 
 // We pass return value from `prepareGoOptions` (with calculated timeout) to every `go` call in the function to enforce the update cycle.

src/utils.ts

@@ -9,4 +9,5 @@ export const calculateTimeout = (startTime: number, totalTimeout: number) => tot
 
 export const prepareGoOptions = (): GoAsyncOptions => ({
   delay: { type: 'random' as const, minDelayMs: RANDOM_BACKOFF_MIN_MS, maxDelayMs: RANDOM_BACKOFF_MAX_MS },
+  retries: 0,
 });