Adds support to run ssh commands on local server

connectors/migrations/0032_alter_connector_connector_type_and_more.py

@@ -0,0 +1,33 @@
+# Generated by Django 4.1.13 on 2024-11-28 08:10
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('connectors', '0031_alter_connector_connector_type_and_more'),
+    ]
+
+    operations = [
+        migrations.AlterField(
+            model_name='connector',
+            name='connector_type',
+            field=models.IntegerField(blank=True, choices=[(0, 'UNKNOWN'), (1, 'SENTRY'), (2, 'SEGMENT'), (3, 'ELASTIC_SEARCH'), (4, 'AMPLITUDE'), (5, 'AWS_KINESIS'), (6, 'CLOUDWATCH'), (7, 'CLEVERTAP'), (8, 'RUDDERSTACK'), (9, 'MOENGAGE'), (10, 'CRIBL'), (11, 'KAFKA'), (12, 'DATADOG'), (13, 'FILEBEAT'), (14, 'LOGSTASH'), (15, 'FLUENTD'), (16, 'FLUENTBIT'), (17, 'PAGER_DUTY'), (18, 'NEW_RELIC'), (19, 'SLACK'), (20, 'HONEYBADGER'), (21, 'GOOGLE_CHAT'), (22, 'DATADOG_OAUTH'), (23, 'GCM'), (24, 'PROMETHEUS'), (25, 'ELASTIC_APM'), (26, 'VICTORIA_METRICS'), (27, 'SLACK_CONNECT'), (28, 'GRAFANA'), (29, 'CLICKHOUSE'), (30, 'DOCUMENTATION'), (31, 'POSTGRES'), (32, 'OPS_GENIE'), (33, 'EKS'), (34, 'AGENT_PROXY'), (35, 'GRAFANA_VPC'), (36, 'GITHUB'), (37, 'SQL_DATABASE_CONNECTION'), (38, 'OPEN_AI'), (39, 'REMOTE_SERVER'), (40, 'API'), (41, 'BASH'), (42, 'AZURE'), (43, 'GRAFANA_MIMIR'), (44, 'GKE'), (45, 'MS_TEAMS'), (46, 'GRAFANA_LOKI'), (47, 'KUBERNETES'), (48, 'SMTP'), (49, 'BIG_QUERY'), (50, 'ZENDUTY'), (51, 'ROOTLY'), (52, 'JIRA_CLOUD'), (53, 'ASANA'), (54, 'CONFLUENCE_CLOUD'), (55, 'CONFLUENCE_SELF_HOSTED'), (56, 'GOOGLE_DRIVE'), (57, 'NOTION'), (58, 'DRD_PROXY_AGENT'), (59, 'MONGODB'), (60, 'OPEN_SEARCH'), (61, 'LINEAR'), (62, 'JENKINS'), (63, 'GITHUB_ACTIONS')], default=0, null=True),
+        ),
+        migrations.AlterField(
+            model_name='connectorkey',
+            name='key_type',
+            field=models.IntegerField(blank=True, choices=[(0, 'UNKNOWN_SKT'), (1, 'SENTRY_API_KEY'), (6, 'SENTRY_ORG_SLUG'), (2, 'DATADOG_APP_KEY'), (3, 'DATADOG_API_KEY'), (15, 'DATADOG_AUTH_TOKEN'), (18, 'DATADOG_API_DOMAIN'), (4, 'NEWRELIC_API_KEY'), (5, 'NEWRELIC_APP_ID'), (7, 'NEWRELIC_QUERY_KEY'), (19, 'NEWRELIC_API_DOMAIN'), (8, 'SLACK_BOT_AUTH_TOKEN'), (9, 'SLACK_CHANNEL_ID'), (46, 'SLACK_APP_ID'), (10, 'HONEYBADGER_USERNAME'), (11, 'HONEYBADGER_PASSWORD'), (12, 'HONEYBADGER_PROJECT_ID'), (13, 'AWS_ACCESS_KEY'), (14, 'AWS_SECRET_KEY'), (20, 'AWS_REGION'), (23, 'AWS_ASSUMED_ROLE_ARN'), (40, 'EKS_ROLE_ARN'), (93, 'AWS_DRD_CLOUD_ROLE_ARN'), (16, 'GOOGLE_CHAT_BOT_OAUTH_TOKEN'), (17, 'GOOGLE_CHAT_BOT_SPACES'), (21, 'GRAFANA_HOST'), (22, 'GRAFANA_API_KEY'), (24, 'CLICKHOUSE_INTERFACE'), (25, 'CLICKHOUSE_HOST'), (26, 'CLICKHOUSE_PORT'), (27, 'CLICKHOUSE_USER'), (28, 'CLICKHOUSE_PASSWORD'), (29, 'GCM_PROJECT_ID'), (30, 'GCM_PRIVATE_KEY'), (31, 'GCM_CLIENT_EMAIL'), (32, 'GCM_TOKEN_URI'), (33, 'POSTGRES_HOST'), (34, 'POSTGRES_USER'), (35, 'POSTGRES_PASSWORD'), (36, 'POSTGRES_PORT'), (37, 'POSTGRES_DATABASE'), (38, 'POSTGRES_OPTIONS'), (39, 'SQL_DATABASE_CONNECTION_STRING_URI'), (41, 'PAGER_DUTY_API_KEY'), (63, 'PAGER_DUTY_CONFIGURED_EMAIL'), (42, 'OPS_GENIE_API_KEY'), (43, 'AGENT_PROXY_HOST'), (44, 'AGENT_PROXY_API_KEY'), (45, 'GITHUB_TOKEN'), (47, 'OPEN_AI_API_KEY'), (49, 'REMOTE_SERVER_PEM'), (50, 'REMOTE_SERVER_USER'), (51, 'REMOTE_SERVER_HOST'), (52, 'REMOTE_SERVER_PASSWORD'), (53, 'MIMIR_HOST'), (54, 'X_SCOPE_ORG_ID'), (55, 'SSL_VERIFY'), (56, 'AZURE_SUBSCRIPTION_ID'), (57, 'AZURE_TENANT_ID'), (58, 'AZURE_CLIENT_ID'), (59, 'AZURE_CLIENT_SECRET'), (60, 'GKE_PROJECT_ID'), (61, 'GKE_SERVICE_ACCOUNT_JSON'), (62, 'MS_TEAMS_CONNECTOR_WEBHOOK_URL'), (64, 'ELASTIC_SEARCH_PROTOCOL'), (65, 'ELASTIC_SEARCH_HOST'), (66, 'ELASTIC_SEARCH_PORT'), (67, 'ELASTIC_SEARCH_API_KEY_ID'), (68, 'ELASTIC_SEARCH_API_KEY'), (69, 'GRAFANA_LOKI_PROTOCOL'), (70, 'GRAFANA_LOKI_HOST'), (71, 'GRAFANA_LOKI_PORT'), (72, 'KUBERNETES_CLUSTER_NAME'), (73, 'KUBERNETES_CLUSTER_API_SERVER'), (74, 'KUBERNETES_CLUSTER_TOKEN'), (75, 'KUBERNETES_CLUSTER_CERTIFICATE_AUTHORITY_DATA'), (76, 'KUBERNETES_CLUSTER_CERTIFICATE_AUTHORITY_PATH'), (77, 'SMTP_HOST'), (78, 'SMTP_PORT'), (79, 'SMTP_USER'), (80, 'SMTP_PASSWORD'), (81, 'BIG_QUERY_PROJECT_ID'), (82, 'BIG_QUERY_SERVICE_ACCOUNT_JSON'), (83, 'ZENDUTY_API_KEY'), (84, 'ROOTLY_API_KEY'), (85, 'JIRA_CLOUD_API_KEY'), (86, 'ASANA_ACCESS_TOKEN'), (87, 'CONFLUENCE_CLOUD_API_KEY'), (88, 'NOTION_API_KEY'), (89, 'DRD_PROXY_AGENT_HOST'), (90, 'DRD_PROXY_AGENT_API_TOKEN'), (91, 'DRD_PROXY_AGENT_API_KEY'), (92, 'MONGODB_CONNECTION_STRING'), (94, 'OPEN_SEARCH_PROTOCOL'), (95, 'OPEN_SEARCH_HOST'), (96, 'OPEN_SEARCH_PORT'), (97, 'OPEN_SEARCH_USERNAME'), (98, 'OPEN_SEARCH_PASSWORD'), (99, 'LINEAR_API_KEY'), (100, 'JENKINS_URL'), (101, 'JENKINS_USERNAME'), (102, 'JENKINS_API_TOKEN'), (103, 'GITHUB_ACTIONS_TOKEN')], default=0, null=True),
+        ),
+        migrations.AlterField(
+            model_name='connectormetadatamodelstore',
+            name='connector_type',
+            field=models.IntegerField(choices=[(0, 'UNKNOWN'), (1, 'SENTRY'), (2, 'SEGMENT'), (3, 'ELASTIC_SEARCH'), (4, 'AMPLITUDE'), (5, 'AWS_KINESIS'), (6, 'CLOUDWATCH'), (7, 'CLEVERTAP'), (8, 'RUDDERSTACK'), (9, 'MOENGAGE'), (10, 'CRIBL'), (11, 'KAFKA'), (12, 'DATADOG'), (13, 'FILEBEAT'), (14, 'LOGSTASH'), (15, 'FLUENTD'), (16, 'FLUENTBIT'), (17, 'PAGER_DUTY'), (18, 'NEW_RELIC'), (19, 'SLACK'), (20, 'HONEYBADGER'), (21, 'GOOGLE_CHAT'), (22, 'DATADOG_OAUTH'), (23, 'GCM'), (24, 'PROMETHEUS'), (25, 'ELASTIC_APM'), (26, 'VICTORIA_METRICS'), (27, 'SLACK_CONNECT'), (28, 'GRAFANA'), (29, 'CLICKHOUSE'), (30, 'DOCUMENTATION'), (31, 'POSTGRES'), (32, 'OPS_GENIE'), (33, 'EKS'), (34, 'AGENT_PROXY'), (35, 'GRAFANA_VPC'), (36, 'GITHUB'), (37, 'SQL_DATABASE_CONNECTION'), (38, 'OPEN_AI'), (39, 'REMOTE_SERVER'), (40, 'API'), (41, 'BASH'), (42, 'AZURE'), (43, 'GRAFANA_MIMIR'), (44, 'GKE'), (45, 'MS_TEAMS'), (46, 'GRAFANA_LOKI'), (47, 'KUBERNETES'), (48, 'SMTP'), (49, 'BIG_QUERY'), (50, 'ZENDUTY'), (51, 'ROOTLY'), (52, 'JIRA_CLOUD'), (53, 'ASANA'), (54, 'CONFLUENCE_CLOUD'), (55, 'CONFLUENCE_SELF_HOSTED'), (56, 'GOOGLE_DRIVE'), (57, 'NOTION'), (58, 'DRD_PROXY_AGENT'), (59, 'MONGODB'), (60, 'OPEN_SEARCH'), (61, 'LINEAR'), (62, 'JENKINS'), (63, 'GITHUB_ACTIONS')], db_index=True, default=0),
+        ),
+        migrations.AlterField(
+            model_name='connectormetadatamodelstore',
+            name='model_type',
+            field=models.IntegerField(choices=[(0, 'UNKNOWN_MT'), (1, 'NEW_RELIC_POLICY'), (2, 'NEW_RELIC_CONDITION'), (3, 'NEW_RELIC_ENTITY'), (4, 'NEW_RELIC_ENTITY_DASHBOARD'), (5, 'NEW_RELIC_ENTITY_APPLICATION'), (6, 'NEW_RELIC_NRQL'), (101, 'DATADOG_MONITOR'), (102, 'DATADOG_DASHBOARD'), (103, 'DATADOG_LIVE_INTEGRATION_AWS'), (104, 'DATADOG_LIVE_INTEGRATION_AWS_LOG'), (105, 'DATADOG_LIVE_INTEGRATION_AZURE'), (106, 'DATADOG_LIVE_INTEGRATION_CLOUDFLARE'), (107, 'DATADOG_LIVE_INTEGRATION_FASTLY'), (108, 'DATADOG_LIVE_INTEGRATION_GCP'), (109, 'DATADOG_LIVE_INTEGRATION_CONFLUENT'), (110, 'DATADOG_SERVICE'), (111, 'DATADOG_METRIC'), (112, 'DATADOG_QUERY'), (201, 'CLOUDWATCH_METRIC'), (202, 'CLOUDWATCH_LOG_GROUP'), (203, 'CLOUDWATCH_LOG_GROUP_QUERY'), (204, 'CLOUDWATCH_ALARMS'), (205, 'RDS_INSTANCES'), (301, 'GRAFANA_DATASOURCE'), (302, 'GRAFANA_DASHBOARD'), (303, 'GRAFANA_TARGET_METRIC_PROMQL'), (304, 'GRAFANA_PROMETHEUS_DATASOURCE'), (305, 'GRAFANA_ALERT_RULE'), (401, 'CLICKHOUSE_DATABASE'), (501, 'SLACK_CHANNEL'), (601, 'MARKDOWN'), (602, 'IFRAME'), (701, 'POSTGRES_QUERY'), (801, 'EKS_CLUSTER'), (901, 'SQL_DATABASE_CONNECTION_RAW_QUERY'), (1001, 'AZURE_WORKSPACE'), (1100, 'SSH_SERVER'), (1201, 'GRAFANA_MIMIR_PROMQL'), (1301, 'GKE_CLUSTER'), (1401, 'MS_TEAMS_CHANNEL'), (1501, 'PAGERDUTY_INCIDENT'), (1601, 'ELASTIC_SEARCH_INDEX'), (1701, 'GCM_METRIC'), (1801, 'ZENDUTY_INCIDENT'), (1901, 'ROOTLY_INCIDENT'), (2001, 'OPS_GENIE_ESCALATION'), (2002, 'OPS_GENIE_TEAM'), (2101, 'GOOGLE_CHAT_SPACE'), (2201, 'MONGODB_DATABASE'), (2202, 'MONGODB_COLLECTION'), (2301, 'OPEN_SEARCH_INDEX'), (2401, 'ASANA_PROJECT')], db_index=True, default=0),
+        ),
+    ]

connectors/models.py

@@ -309,7 +309,7 @@
     Source.GCM: [
         [
             SourceKeyType.GCM_PROJECT_ID,
-            SourceKeyType.GCM_SERVICE_ACCOUNT_JSON,
+            SourceKeyType.GCM_PRIVATE_KEY,
         ]
     ],
     Source.SMTP: [
@@ -349,7 +349,7 @@
     SourceKeyType.AWS_SECRET_KEY: 'AWS Secret Key',
     SourceKeyType.AWS_REGION: 'AWS Region',
     SourceKeyType.GCM_PROJECT_ID: 'Project ID',
-    SourceKeyType.GCM_SERVICE_ACCOUNT_JSON: 'Service Account JSON',
+    SourceKeyType.GCM_PRIVATE_KEY: 'Service Account JSON',
     SourceKeyType.GCM_CLIENT_EMAIL: 'Client Email',
     SourceKeyType.GCM_TOKEN_URI: 'Token URI',
     SourceKeyType.CLICKHOUSE_INTERFACE: 'Interface',
@@ -531,7 +531,7 @@ def proto(self):
                              SourceKeyType.AGENT_PROXY_HOST,
                              SourceKeyType.AWS_ASSUMED_ROLE_ARN,
                              SourceKeyType.CLICKHOUSE_USER, SourceKeyType.CLICKHOUSE_PASSWORD,
-                             SourceKeyType.GCM_PROJECT_ID, SourceKeyType.GCM_SERVICE_ACCOUNT_JSON,
+                             SourceKeyType.GCM_PROJECT_ID, SourceKeyType.GCM_PRIVATE_KEY,
                              SourceKeyType.GCM_CLIENT_EMAIL, SourceKeyType.PAGER_DUTY_API_KEY,
                              SourceKeyType.POSTGRES_PASSWORD, SourceKeyType.POSTGRES_USER,
                              SourceKeyType.OPS_GENIE_API_KEY,

executor/source_managers/bash_source_manager.py

@@ -29,7 +29,8 @@ def __init__(self):
                               display_name=StringValue(value="Remote Server"),
                               description=StringValue(value='Select Remote Server'),
                               data_type=LiteralType.STRING,
-                              form_field_type=FormFieldType.TYPING_DROPDOWN_FT),
+                              form_field_type=FormFieldType.TYPING_DROPDOWN_FT,
+                              is_optional=True),
                     FormField(key_name=StringValue(value="command"),
                               display_name=StringValue(value="Command"),
                               data_type=LiteralType.STRING,

executor/source_processors/bash_processor.py

@@ -13,11 +13,13 @@ class BashProcessor(Processor):
     client = None
 
     def __init__(self, remote_host=None, remote_password=None, remote_pem=None):
+        self.remote_host = None
+        self.remote_user = None
         if remote_host:
             self.remote_user = remote_host.split("@")[0]
             self.remote_host = remote_host.split("@")[1]
         self.remote_password = remote_password
-        self.remote_pem = remote_pem.strip()
+        self.remote_pem = remote_pem.strip() if remote_pem else None
 
     def get_connection(self):
         try:

executor/tests/source_managers/test_cloudwatch_source_manager.py

@@ -4,7 +4,6 @@
 from unittest.mock import MagicMock
 from datetime import datetime
 
-
 django.setup()
 
 from executor.source_managers.cloudwatch_source_manager import CloudwatchSourceManager

protos/base.proto

@@ -149,7 +149,7 @@ enum Source {
   EKS = 33;
   AGENT_PROXY = 34;
   GRAFANA_VPC = 35;
-  GITHUB_ACTIONS = 36;
+  GITHUB = 36;
   SQL_DATABASE_CONNECTION = 37;
   OPEN_AI = 38;
   REMOTE_SERVER = 39;
@@ -171,13 +171,16 @@ enum Source {
   CONFLUENCE_SELF_HOSTED = 55;
   GOOGLE_DRIVE = 56;
   NOTION = 57;
-
   DRD_PROXY_AGENT = 58;
+  MONGODB = 59;
+  OPEN_SEARCH = 60;
+  LINEAR = 61;
+  JENKINS = 62;
+  GITHUB_ACTIONS = 63;
 }
 
 enum SourceKeyType {
   UNKNOWN_SKT = 0;
-
   SENTRY_API_KEY = 1;
   SENTRY_ORG_SLUG = 6;
 
@@ -204,6 +207,7 @@ enum SourceKeyType {
   AWS_REGION = 20;
   AWS_ASSUMED_ROLE_ARN = 23;
   EKS_ROLE_ARN = 40;
+  AWS_DRD_CLOUD_ROLE_ARN = 93;
 
   GOOGLE_CHAT_BOT_OAUTH_TOKEN = 16;
   GOOGLE_CHAT_BOT_SPACES = 17;
@@ -218,7 +222,7 @@ enum SourceKeyType {
   CLICKHOUSE_PASSWORD = 28;
 
   GCM_PROJECT_ID = 29;
-  GCM_SERVICE_ACCOUNT_JSON = 30;
+  GCM_PRIVATE_KEY = 30;
   GCM_CLIENT_EMAIL = 31;
   GCM_TOKEN_URI = 32;
 
@@ -239,7 +243,7 @@ enum SourceKeyType {
   AGENT_PROXY_HOST = 43;
   AGENT_PROXY_API_KEY = 44;
 
-  GITHUB_ACTIONS_TOKEN = 45;
+  GITHUB_TOKEN = 45;
 
   OPEN_AI_API_KEY = 47;
 
@@ -302,11 +306,27 @@ enum SourceKeyType {
   DRD_PROXY_AGENT_HOST = 89;
   DRD_PROXY_AGENT_API_TOKEN = 90;
   DRD_PROXY_AGENT_API_KEY = 91;
+
+  MONGODB_CONNECTION_STRING = 92;
+
+  OPEN_SEARCH_PROTOCOL = 94;
+  OPEN_SEARCH_HOST = 95;
+  OPEN_SEARCH_PORT = 96;
+  OPEN_SEARCH_USERNAME = 97;
+  OPEN_SEARCH_PASSWORD = 98;
+
+  LINEAR_API_KEY = 99;
+
+  JENKINS_URL = 100;
+  JENKINS_USERNAME = 101;
+  JENKINS_API_TOKEN = 102;
+
+  GITHUB_ACTIONS_TOKEN = 103;
 }
 
 enum SourceModelType {
   UNKNOWN_MT = 0;
-  // New Relic Models
+  //New Relic Models
   NEW_RELIC_POLICY = 1;
   NEW_RELIC_CONDITION = 2;
   NEW_RELIC_ENTITY = 3;
@@ -328,17 +348,19 @@ enum SourceModelType {
   DATADOG_METRIC = 111;
   DATADOG_QUERY = 112;
 
-
   //Cloudwatch Models
   CLOUDWATCH_METRIC = 201;
   CLOUDWATCH_LOG_GROUP = 202;
-
+  CLOUDWATCH_LOG_GROUP_QUERY = 203;
+  CLOUDWATCH_ALARMS = 204;
+  RDS_INSTANCES = 205;
 
   //Grafana Models
   GRAFANA_DATASOURCE = 301;
   GRAFANA_DASHBOARD = 302;
   GRAFANA_TARGET_METRIC_PROMQL = 303;
   GRAFANA_PROMETHEUS_DATASOURCE = 304;
+  GRAFANA_ALERT_RULE = 305;
 
   //Clickhouse Models
   CLICKHOUSE_DATABASE = 401;
@@ -365,28 +387,28 @@ enum SourceModelType {
   //Remote Server Models
   SSH_SERVER = 1100;
 
-  // Mimir Server Models
+  //Mimir Server Models
   GRAFANA_MIMIR_PROMQL = 1201;
 
-  // GKE Models
+  //GKE Models
   GKE_CLUSTER = 1301;
 
-  // MS TEAMS Models
+  //MS TEAMS Models
   MS_TEAMS_CHANNEL = 1401;
 
-  // Pagerduty Models
+  //Pagerduty Models
   PAGERDUTY_INCIDENT = 1501;
 
-  // Elastic Search Models
+  //Elastic Search Models
   ELASTIC_SEARCH_INDEX = 1601;
 
-  // GCM Models
+  //GCM Models
   GCM_METRIC = 1701;
 
-  // Zenduty Models
+  //Zen Duty Models
   ZENDUTY_INCIDENT = 1801;
 
-  // Rootly Models
+  //ROOTLY Models
   ROOTLY_INCIDENT = 1901;
 
   //OPS GENIE Models
@@ -395,4 +417,14 @@ enum SourceModelType {
 
   //Google Chat Models
   GOOGLE_CHAT_SPACE = 2101;
+
+  // MongoDB Models
+  MONGODB_DATABASE = 2201;
+  MONGODB_COLLECTION = 2202;
+
+  //Open Search Models
+  OPEN_SEARCH_INDEX = 2301;
+
+  // Asana Models
+  ASANA_PROJECT = 2401;
 }