Trigger the cron job right after the first configuration

Flared · Nov 20, 2024 · e61c918 · e61c918
1 parent dafc78e
commit e61c918
Show file tree

Hide file tree

Showing 2 changed files with 35 additions and 10 deletions.
diff --git a/packages/flare/src/main/resources/splunk/default/inputs.conf b/packages/flare/src/main/resources/splunk/default/inputs.conf
@@ -1,5 +1,5 @@
 [script://$SPLUNK_HOME/etc/apps/flare/bin/cron_job_ingest_events.py]
-interval = * * * * *
+interval = 600
 python.version = python3
 index = flare
 source = flare

diff --git a/packages/react-components/src/utils/setupConfiguration.ts b/packages/react-components/src/utils/setupConfiguration.ts
@@ -114,8 +114,27 @@ async function saveConfiguration(
         `${isIngestingMetadataOnly}`
     );
     await saveIndexForIngestion(service, indexName);
+    const isFirstConfiguration = await fetchIsFirstConfiguration();
+    if (isFirstConfiguration) {
+        await updateEventIngestionCronJobInterval(service, 1);
+    }
     await completeSetup(service);
     await reloadApp(service);
+    if (isFirstConfiguration) {
+        await updateEventIngestionCronJobInterval(service, 600);
+        await reloadApp(service);
+    }
+}
+
+async function updateEventIngestionCronJobInterval(service: SplunkService, intervalInSeconds: number): Promise<void> {
+    await updateConfigurationFile(
+        service,
+        'inputs',
+        'script://$SPLUNK_HOME/etc/apps/flare/bin/cron_job_ingest_events.py',
+        {
+            interval: `${intervalInSeconds}`,
+        }
+    );
 }
 
 async function fetchCollectionItems(): Promise<SplunkCollectionItem[]> {
@@ -178,15 +197,8 @@ async function fetchIngestMetadataOnly(): Promise<boolean> {
 
 async function createFlareIndex(): Promise<void> {
     const service = createService();
-    const isConfigured =
-        (await getConfigurationStanzaValue(
-            service,
-            'app',
-            'install',
-            'is_configured',
-            'unknown'
-        )) === '1';
-    if (!isConfigured) {
+    const isFirstConfiguration = await fetchIsFirstConfiguration();
+    if (isFirstConfiguration) {
         const currentIndexNames = await fetchAvailableIndexNames();
         if (!currentIndexNames.find((indexName) => indexName === appName)) {
             await service.indexes().create(appName, {});
@@ -218,6 +230,19 @@ async function fetchAvailableIndexNames(): Promise<Array<string>> {
     return indexNames;
 }
 
+async function fetchIsFirstConfiguration(): Promise<boolean> {
+    const service = createService();
+    return (
+        (await getConfigurationStanzaValue(
+            service,
+            'app',
+            'install',
+            'is_configured',
+            'unknown'
+        )) !== '1'
+    );
+}
+
 async function fetchCurrentIndexName(): Promise<string> {
     const service = createService();
     return getConfigurationStanzaValue(