new components

Author: michelle0927

components/splunk/actions/get-search-job-status/get-search-job-status.mjs

@@ -14,10 +14,10 @@ export default {
         "selfSigned",
       ],
     },
-    searchId: {
+    jobId: {
       propDefinition: [
         splunk,
-        "searchId",
+        "jobId",
         (c) => ({
           selfSigned: c.selfSigned,
         }),
@@ -28,9 +28,9 @@ export default {
     const response = await this.splunk.getSearchJobStatus({
       $,
       selfSigned: this.selfSigned,
-      searchId: this.searchId,
+      jobId: this.jobId,
     });
-    $.export("$summary", `Successfully retrieved status for job ID ${this.searchId}`);
+    $.export("$summary", `Successfully retrieved status for job ID ${this.jobId}`);
     return response;
   },
 };

components/splunk/actions/run-search/run-search.mjs

@@ -15,9 +15,10 @@ export default {
       ],
     },
     query: {
-      type: "string",
-      label: "Search Query",
-      description: "The Splunk search query. Example: `search *`. [See the documentation](https://docs.splunk.com/Documentation/Splunk/9.4.1/SearchReference/Search) for more information about search command sytax.",
+      propDefinition: [
+        splunk,
+        "query",
+      ],
     },
     earliestTime: {
       type: "string",

components/splunk/sources/common/base.mjs

@@ -0,0 +1,36 @@
+import splunk from "../../splunk.app.mjs";
+import { DEFAULT_POLLING_SOURCE_TIMER_INTERVAL } from "@pipedream/platform";
+
+export default {
+  props: {
+    splunk,
+    timer: {
+      type: "$.interface.timer",
+      default: {
+        intervalSeconds: DEFAULT_POLLING_SOURCE_TIMER_INTERVAL,
+      },
+    },
+    db: "$.service.db",
+    selfSigned: {
+      propDefinition: [
+        splunk,
+        "selfSigned",
+      ],
+    },
+  },
+  methods: {
+    async getRecentJobIds() {
+      const results = this.splunk.paginate({
+        resourceFn: this.splunk.listJobs,
+        args: {
+          selfSigned: this.selfSigned,
+        },
+      });
+      const jobIds = [];
+      for await (const job of results) {
+        jobIds.push(job.content.sid);
+      }
+      return jobIds;
+    },
+  },
+};

components/splunk/sources/new-alert-fired/new-alert-fired.mjs

@@ -0,0 +1,39 @@
+import common from "../common/base.mjs";
+
+export default {
+  ...common,
+  key: "splunk-new-alert-fired",
+  name: "New Alert Fired",
+  description: "Emit new event when a new alert is triggered in Splunk. [See the documentation](https://docs.splunk.com/Documentation/Splunk/9.4.1/RESTREF/RESTsearch#alerts.2Ffired_alerts)",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  methods: {
+    ...common.methods,
+    generateMeta(alert) {
+      return {
+        id: alert.id,
+        summary: `New Alert Fired: ${alert.name}`,
+        ts: Date.now(),
+      };
+    },
+  },
+  async run() {
+    const results = this.splunk.paginate({
+      resourceFn: this.splunk.listFiredAlerts,
+      args: {
+        selfSigned: this.selfSigned,
+      },
+    });
+
+    const alerts = [];
+    for await (const item of results) {
+      alerts.push(item);
+    }
+
+    alerts.forEach((alert) => {
+      const meta = this.generateMeta(alert);
+      this.$emit(alert, meta);
+    });
+  },
+};