Merge pull request #54 from Flared/mahinse/run_cron_job_post_configur…

…ation Trigger the cron job right after the first configuration
Flared · Nov 20, 2024 · 9524b14 · 9524b14
2 parents 2621d6c + af22b0a
commit 9524b14
Show file tree

Hide file tree

Showing 2 changed files with 38 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 = 0 0 1 1 *
 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
@@ -117,13 +117,35 @@ async function saveConfiguration(
         `${isIngestingMetadataOnly}`
     );
     await saveIndexForIngestion(service, indexName);
+    const isFirstConfiguration = await fetchIsFirstConfiguration();
+    if (isFirstConfiguration) {
+        await updateEventIngestionCronJobInterval(service, '1');
+    }
     await updateSavedSearchQuery(
         service,
         flareSavedSearchName,
         `source=${appName} index=${indexName}`
     );
     await completeSetup(service);
     await reloadApp(service);
+    if (isFirstConfiguration) {
+        await updateEventIngestionCronJobInterval(service, '* * * * *');
+        await reloadApp(service);
+    }
+}
+
+async function updateEventIngestionCronJobInterval(
+    service: SplunkService,
+    interval: string
+): Promise<void> {
+    await updateConfigurationFile(
+        service,
+        'inputs',
+        'script://$SPLUNK_HOME/etc/apps/flare/bin/cron_job_ingest_events.py',
+        {
+            interval: `${interval}`,
+        }
+    );
 }
 
 async function updateSavedSearchQuery(
@@ -200,15 +222,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, {});
@@ -240,6 +255,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(