diff --git a/.gitignore b/.gitignore
index f7404b06..ec9632de 100644
--- a/.gitignore
+++ b/.gitignore
@@ -20,8 +20,9 @@ deployment.yaml
# Held by make proof and the daemon updater while either has the stack down.
.dfe-stack.lock
*.log
-# The demo replays these sample events as syslog
+# The demo and its packs replay these sample events
!resources/demo/events/**/*.log
+!resources/demo-*/events/**/*.log
dist/
dist-bin/
bin/
diff --git a/Makefile b/Makefile
index a6636da4..28ac691a 100644
--- a/Makefile
+++ b/Makefile
@@ -629,8 +629,8 @@ print-ruff-version:
.PHONY: check-python
check-python: ## Lint the helper scripts (config in ruff.toml)
- $(RUFF) check scripts/ ops/ resources/demo/
- $(RUFF) format --check scripts/ ops/ resources/demo/
+ $(RUFF) check scripts/ ops/ resources/demo/ resources/demo-*/
+ $(RUFF) format --check scripts/ ops/ resources/demo/ resources/demo-*/
# Pinned for the same reason RUFF is, and installed the same way in CI
# (PYTEST=pytest). Unit tests over the helper scripts: they
diff --git a/resources/demo-cyber/console/dashboards/demo-cyber-denied.json b/resources/demo-cyber/console/dashboards/demo-cyber-denied.json
new file mode 100644
index 00000000..7984be8c
--- /dev/null
+++ b/resources/demo-cyber/console/dashboards/demo-cyber-denied.json
@@ -0,0 +1,64 @@
+{
+ "name": "demo-cyber-denied",
+ "tags": [
+ "demo"
+ ],
+ "tiles": [
+ {
+ "config": {
+ "configType": "sql",
+ "displayType": "stacked_bar",
+ "name": "Denied connections per minute, by firewall",
+ "source": "cisco-asa",
+ "sqlTemplate": "SELECT $__timeInterval(t) AS ts,\n firewall,\n count() * 60 / $__interval_s AS \"denied/min\"\nFROM (SELECT _timestamp_load AS t, 'Cisco ASA' AS firewall, replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', '') AS src, if(coalesce(cisco_asa_rule_name, '') = '', concat('ASA ', coalesce(event_code, '')), cisco_asa_rule_name) AS rule\n FROM dfe.`cisco-asa`\n WHERE $__timeFilter(_timestamp_load) AND event_outcome = 'failure' AND event_action != 'logon-failed'\n UNION ALL\n SELECT _timestamp_load AS t, 'FortiGate' AS firewall, replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', '') AS src, concat('policy ', toString(rule_id)) AS rule\n FROM dfe.fortinet\n WHERE $__timeFilter(_timestamp_load) AND event_action = 'deny')\nGROUP BY ts, firewall\nORDER BY ts"
+ },
+ "h": 6,
+ "id": "rate",
+ "w": 16,
+ "x": 0,
+ "y": 0
+ },
+ {
+ "config": {
+ "configType": "sql",
+ "displayType": "number",
+ "name": "Denied connections in the time range",
+ "source": "cisco-asa",
+ "sqlTemplate": "SELECT count() AS \"denied\"\nFROM (SELECT _timestamp_load AS t, 'Cisco ASA' AS firewall, replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', '') AS src, if(coalesce(cisco_asa_rule_name, '') = '', concat('ASA ', coalesce(event_code, '')), cisco_asa_rule_name) AS rule\n FROM dfe.`cisco-asa`\n WHERE $__timeFilter(_timestamp_load) AND event_outcome = 'failure' AND event_action != 'logon-failed'\n UNION ALL\n SELECT _timestamp_load AS t, 'FortiGate' AS firewall, replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', '') AS src, concat('policy ', toString(rule_id)) AS rule\n FROM dfe.fortinet\n WHERE $__timeFilter(_timestamp_load) AND event_action = 'deny')"
+ },
+ "h": 6,
+ "id": "total",
+ "w": 8,
+ "x": 16,
+ "y": 0
+ },
+ {
+ "config": {
+ "configType": "sql",
+ "displayType": "table",
+ "name": "Top denied sources",
+ "source": "cisco-asa",
+ "sqlTemplate": "SELECT firewall AS \"Firewall\",\n src AS \"Source\",\n rule AS \"Rule\",\n count() AS \"Denied\"\nFROM (SELECT _timestamp_load AS t, 'Cisco ASA' AS firewall, replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', '') AS src, if(coalesce(cisco_asa_rule_name, '') = '', concat('ASA ', coalesce(event_code, '')), cisco_asa_rule_name) AS rule\n FROM dfe.`cisco-asa`\n WHERE $__timeFilter(_timestamp_load) AND event_outcome = 'failure' AND event_action != 'logon-failed'\n UNION ALL\n SELECT _timestamp_load AS t, 'FortiGate' AS firewall, replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', '') AS src, concat('policy ', toString(rule_id)) AS rule\n FROM dfe.fortinet\n WHERE $__timeFilter(_timestamp_load) AND event_action = 'deny')\nGROUP BY 1, 2, 3\nORDER BY 4 DESC\nLIMIT 12"
+ },
+ "h": 9,
+ "id": "sources",
+ "w": 14,
+ "x": 0,
+ "y": 6
+ },
+ {
+ "config": {
+ "configType": "sql",
+ "displayType": "table",
+ "name": "Denied by rule",
+ "source": "cisco-asa",
+ "sqlTemplate": "SELECT firewall AS \"Firewall\",\n rule AS \"Rule\",\n count() AS \"Denied\",\n uniqExact(src) AS \"Sources\"\nFROM (SELECT _timestamp_load AS t, 'Cisco ASA' AS firewall, replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', '') AS src, if(coalesce(cisco_asa_rule_name, '') = '', concat('ASA ', coalesce(event_code, '')), cisco_asa_rule_name) AS rule\n FROM dfe.`cisco-asa`\n WHERE $__timeFilter(_timestamp_load) AND event_outcome = 'failure' AND event_action != 'logon-failed'\n UNION ALL\n SELECT _timestamp_load AS t, 'FortiGate' AS firewall, replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', '') AS src, concat('policy ', toString(rule_id)) AS rule\n FROM dfe.fortinet\n WHERE $__timeFilter(_timestamp_load) AND event_action = 'deny')\nGROUP BY 1, 2\nORDER BY 3 DESC\nLIMIT 12"
+ },
+ "h": 9,
+ "id": "rules",
+ "w": 10,
+ "x": 14,
+ "y": 6
+ }
+ ]
+}
diff --git a/resources/demo-cyber/console/dashboards/demo-cyber-drop.json b/resources/demo-cyber/console/dashboards/demo-cyber-drop.json
new file mode 100644
index 00000000..d70135ac
--- /dev/null
+++ b/resources/demo-cyber/console/dashboards/demo-cyber-drop.json
@@ -0,0 +1,64 @@
+{
+ "name": "demo-cyber-drop",
+ "tags": [
+ "demo"
+ ],
+ "tiles": [
+ {
+ "config": {
+ "configType": "sql",
+ "displayType": "stacked_bar",
+ "name": "Connections to or from DROP-listed networks per minute, allowed and denied",
+ "source": "cisco-asa",
+ "sqlTemplate": "WITH ['42.128.0.0/12', '42.160.0.0/12', '42.208.0.0/12', '147.16.0.0/14', '196.16.0.0/14', '101.134.0.0/15', '112.142.0.0/15', '168.80.0.0/15'] AS drop_list\nSELECT $__timeInterval(t) AS ts,\n verdict,\n count() * 60 / $__interval_s AS \"connections/min\"\nFROM (SELECT t, firewall, verdict, if(arrayExists(n -> isIPAddressInRange(src, n), drop_list), src, dst) AS address\n FROM (\n SELECT _timestamp_load AS t, 'Cisco ASA' AS firewall, if(event_outcome = 'failure' AND event_action != 'logon-failed', 'denied', 'allowed') AS verdict, replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', '') AS src, replaceOne(IPv6NumToString(assumeNotNull(destination_ip)), '::ffff:', '') AS dst\n FROM dfe.`cisco-asa`\n WHERE $__timeFilter(_timestamp_load)\n UNION ALL\n SELECT _timestamp_load AS t, 'FortiGate' AS firewall, if(event_action = 'deny', 'denied', 'allowed') AS verdict, replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', '') AS src, replaceOne(IPv6NumToString(assumeNotNull(destination_ip)), '::ffff:', '') AS dst\n FROM dfe.fortinet\n WHERE $__timeFilter(_timestamp_load)\n )\n WHERE arrayExists(n -> isIPAddressInRange(src, n) OR isIPAddressInRange(dst, n), drop_list))\nGROUP BY ts, verdict\nORDER BY ts"
+ },
+ "h": 6,
+ "id": "rate",
+ "w": 16,
+ "x": 0,
+ "y": 0
+ },
+ {
+ "config": {
+ "configType": "sql",
+ "displayType": "number",
+ "name": "DROP-listed connections the firewalls allowed",
+ "source": "cisco-asa",
+ "sqlTemplate": "WITH ['42.128.0.0/12', '42.160.0.0/12', '42.208.0.0/12', '147.16.0.0/14', '196.16.0.0/14', '101.134.0.0/15', '112.142.0.0/15', '168.80.0.0/15'] AS drop_list\nSELECT countIf(verdict = 'allowed') AS \"allowed\"\nFROM (SELECT t, firewall, verdict, if(arrayExists(n -> isIPAddressInRange(src, n), drop_list), src, dst) AS address\n FROM (\n SELECT _timestamp_load AS t, 'Cisco ASA' AS firewall, if(event_outcome = 'failure' AND event_action != 'logon-failed', 'denied', 'allowed') AS verdict, replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', '') AS src, replaceOne(IPv6NumToString(assumeNotNull(destination_ip)), '::ffff:', '') AS dst\n FROM dfe.`cisco-asa`\n WHERE $__timeFilter(_timestamp_load)\n UNION ALL\n SELECT _timestamp_load AS t, 'FortiGate' AS firewall, if(event_action = 'deny', 'denied', 'allowed') AS verdict, replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', '') AS src, replaceOne(IPv6NumToString(assumeNotNull(destination_ip)), '::ffff:', '') AS dst\n FROM dfe.fortinet\n WHERE $__timeFilter(_timestamp_load)\n )\n WHERE arrayExists(n -> isIPAddressInRange(src, n) OR isIPAddressInRange(dst, n), drop_list))"
+ },
+ "h": 6,
+ "id": "allowed",
+ "w": 8,
+ "x": 16,
+ "y": 0
+ },
+ {
+ "config": {
+ "configType": "sql",
+ "displayType": "table",
+ "name": "Top DROP-listed networks",
+ "source": "cisco-asa",
+ "sqlTemplate": "WITH ['42.128.0.0/12', '42.160.0.0/12', '42.208.0.0/12', '147.16.0.0/14', '196.16.0.0/14', '101.134.0.0/15', '112.142.0.0/15', '168.80.0.0/15'] AS drop_list\nSELECT arrayFirst(n -> isIPAddressInRange(address, n), drop_list) AS \"Network\",\n countIf(verdict = 'allowed') AS \"Allowed\",\n countIf(verdict = 'denied') AS \"Denied\",\n uniqExact(address) AS \"Addresses\"\nFROM (SELECT t, firewall, verdict, if(arrayExists(n -> isIPAddressInRange(src, n), drop_list), src, dst) AS address\n FROM (\n SELECT _timestamp_load AS t, 'Cisco ASA' AS firewall, if(event_outcome = 'failure' AND event_action != 'logon-failed', 'denied', 'allowed') AS verdict, replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', '') AS src, replaceOne(IPv6NumToString(assumeNotNull(destination_ip)), '::ffff:', '') AS dst\n FROM dfe.`cisco-asa`\n WHERE $__timeFilter(_timestamp_load)\n UNION ALL\n SELECT _timestamp_load AS t, 'FortiGate' AS firewall, if(event_action = 'deny', 'denied', 'allowed') AS verdict, replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', '') AS src, replaceOne(IPv6NumToString(assumeNotNull(destination_ip)), '::ffff:', '') AS dst\n FROM dfe.fortinet\n WHERE $__timeFilter(_timestamp_load)\n )\n WHERE arrayExists(n -> isIPAddressInRange(src, n) OR isIPAddressInRange(dst, n), drop_list))\nGROUP BY 1\nORDER BY 2 DESC, 3 DESC\nLIMIT 10"
+ },
+ "h": 9,
+ "id": "networks",
+ "w": 12,
+ "x": 0,
+ "y": 6
+ },
+ {
+ "config": {
+ "configType": "sql",
+ "displayType": "table",
+ "name": "DROP-listed addresses seen",
+ "source": "cisco-asa",
+ "sqlTemplate": "WITH ['42.128.0.0/12', '42.160.0.0/12', '42.208.0.0/12', '147.16.0.0/14', '196.16.0.0/14', '101.134.0.0/15', '112.142.0.0/15', '168.80.0.0/15'] AS drop_list\nSELECT address AS \"Address\",\n firewall AS \"Firewall\",\n countIf(verdict = 'allowed') AS \"Allowed\",\n countIf(verdict = 'denied') AS \"Denied\"\nFROM (SELECT t, firewall, verdict, if(arrayExists(n -> isIPAddressInRange(src, n), drop_list), src, dst) AS address\n FROM (\n SELECT _timestamp_load AS t, 'Cisco ASA' AS firewall, if(event_outcome = 'failure' AND event_action != 'logon-failed', 'denied', 'allowed') AS verdict, replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', '') AS src, replaceOne(IPv6NumToString(assumeNotNull(destination_ip)), '::ffff:', '') AS dst\n FROM dfe.`cisco-asa`\n WHERE $__timeFilter(_timestamp_load)\n UNION ALL\n SELECT _timestamp_load AS t, 'FortiGate' AS firewall, if(event_action = 'deny', 'denied', 'allowed') AS verdict, replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', '') AS src, replaceOne(IPv6NumToString(assumeNotNull(destination_ip)), '::ffff:', '') AS dst\n FROM dfe.fortinet\n WHERE $__timeFilter(_timestamp_load)\n )\n WHERE arrayExists(n -> isIPAddressInRange(src, n) OR isIPAddressInRange(dst, n), drop_list))\nGROUP BY 1, 2\nORDER BY 3 DESC, 4 DESC\nLIMIT 16"
+ },
+ "h": 9,
+ "id": "addresses",
+ "w": 12,
+ "x": 12,
+ "y": 6
+ }
+ ]
+}
diff --git a/resources/demo-cyber/console/dashboards/demo-cyber-edr.json b/resources/demo-cyber/console/dashboards/demo-cyber-edr.json
new file mode 100644
index 00000000..b57fd57f
--- /dev/null
+++ b/resources/demo-cyber/console/dashboards/demo-cyber-edr.json
@@ -0,0 +1,64 @@
+{
+ "name": "demo-cyber-edr",
+ "tags": [
+ "demo"
+ ],
+ "tiles": [
+ {
+ "config": {
+ "configType": "sql",
+ "displayType": "stacked_bar",
+ "name": "CrowdStrike detections per minute, by severity",
+ "source": "crowdstrike",
+ "sqlTemplate": "SELECT $__timeInterval(_timestamp) AS ts,\n multiIf(event_severity >= 99, 'critical', event_severity >= 73, 'high', event_severity >= 47, 'medium', 'low') AS severity,\n count() * 60 / $__interval_s AS \"detections/min\"\nFROM dfe.crowdstrike\nWHERE $__timeFilter(_timestamp) AND event_kind = 'alert'\nGROUP BY ts, severity\nORDER BY ts"
+ },
+ "h": 6,
+ "id": "rate",
+ "w": 16,
+ "x": 0,
+ "y": 0
+ },
+ {
+ "config": {
+ "configType": "sql",
+ "displayType": "number",
+ "name": "Critical and high detections in the time range",
+ "source": "crowdstrike",
+ "sqlTemplate": "SELECT count() AS \"critical and high\"\nFROM dfe.crowdstrike\nWHERE $__timeFilter(_timestamp) AND event_kind = 'alert' AND event_severity >= 73"
+ },
+ "h": 6,
+ "id": "critical",
+ "w": 8,
+ "x": 16,
+ "y": 0
+ },
+ {
+ "config": {
+ "configType": "sql",
+ "displayType": "table",
+ "name": "Detections by host and severity",
+ "source": "crowdstrike",
+ "sqlTemplate": "SELECT host_name AS \"Host\",\n countIf(event_severity >= 99) AS \"Critical\",\n countIf(event_severity >= 73 AND event_severity < 99) AS \"High\",\n countIf(event_severity >= 47 AND event_severity < 73) AS \"Medium\",\n count() AS \"Total\"\nFROM dfe.crowdstrike\nWHERE $__timeFilter(_timestamp) AND event_kind = 'alert'\nGROUP BY 1\nORDER BY 2 DESC, 3 DESC, 5 DESC\nLIMIT 14"
+ },
+ "h": 9,
+ "id": "hosts",
+ "w": 13,
+ "x": 0,
+ "y": 6
+ },
+ {
+ "config": {
+ "configType": "sql",
+ "displayType": "table",
+ "name": "Detections by rule and tactic",
+ "source": "crowdstrike",
+ "sqlTemplate": "SELECT rule_name AS \"Detection\",\n arrayStringConcat(threat_tactic_name, ', ') AS \"Tactic\",\n count() AS \"Detections\"\nFROM dfe.crowdstrike\nWHERE $__timeFilter(_timestamp) AND event_kind = 'alert'\nGROUP BY 1, 2\nORDER BY 3 DESC"
+ },
+ "h": 9,
+ "id": "rules",
+ "w": 11,
+ "x": 13,
+ "y": 6
+ }
+ ]
+}
diff --git a/resources/demo-cyber/console/dashboards/demo-cyber-o365-admin.json b/resources/demo-cyber/console/dashboards/demo-cyber-o365-admin.json
new file mode 100644
index 00000000..883104b2
--- /dev/null
+++ b/resources/demo-cyber/console/dashboards/demo-cyber-o365-admin.json
@@ -0,0 +1,64 @@
+{
+ "name": "demo-cyber-o365-admin",
+ "tags": [
+ "demo"
+ ],
+ "tiles": [
+ {
+ "config": {
+ "configType": "sql",
+ "displayType": "stacked_bar",
+ "name": "Microsoft 365 admin actions per minute, by actor",
+ "source": "o365",
+ "sqlTemplate": "SELECT $__timeInterval(_timestamp) AS ts,\n user_id AS actor,\n count() * 60 / $__interval_s AS \"actions/min\"\nFROM dfe.o365\nWHERE $__timeFilter(_timestamp) AND (event_code = 'ExchangeAdmin' OR event_action IN ('SiteCollectionAdminAdded', 'SiteCollectionAdminRemoved'))\nGROUP BY ts, actor\nORDER BY ts"
+ },
+ "h": 6,
+ "id": "rate",
+ "w": 16,
+ "x": 0,
+ "y": 0
+ },
+ {
+ "config": {
+ "configType": "sql",
+ "displayType": "number",
+ "name": "Admin actions in the time range",
+ "source": "o365",
+ "sqlTemplate": "SELECT count() AS \"admin actions\"\nFROM dfe.o365\nWHERE $__timeFilter(_timestamp) AND (event_code = 'ExchangeAdmin' OR event_action IN ('SiteCollectionAdminAdded', 'SiteCollectionAdminRemoved'))"
+ },
+ "h": 6,
+ "id": "total",
+ "w": 8,
+ "x": 16,
+ "y": 0
+ },
+ {
+ "config": {
+ "configType": "sql",
+ "displayType": "table",
+ "name": "Admin actions by actor",
+ "source": "o365",
+ "sqlTemplate": "SELECT user_id AS \"Actor\",\n count() AS \"Actions\",\n uniqExact(event_action) AS \"Operations\"\nFROM dfe.o365\nWHERE $__timeFilter(_timestamp) AND (event_code = 'ExchangeAdmin' OR event_action IN ('SiteCollectionAdminAdded', 'SiteCollectionAdminRemoved'))\nGROUP BY 1\nORDER BY 2 DESC"
+ },
+ "h": 9,
+ "id": "actors",
+ "w": 10,
+ "x": 0,
+ "y": 6
+ },
+ {
+ "config": {
+ "configType": "sql",
+ "displayType": "table",
+ "name": "Admin operations by actor",
+ "source": "o365",
+ "sqlTemplate": "SELECT user_id AS \"Actor\",\n event_action AS \"Operation\",\n count() AS \"Actions\"\nFROM dfe.o365\nWHERE $__timeFilter(_timestamp) AND (event_code = 'ExchangeAdmin' OR event_action IN ('SiteCollectionAdminAdded', 'SiteCollectionAdminRemoved'))\nGROUP BY 1, 2\nORDER BY 3 DESC\nLIMIT 16"
+ },
+ "h": 9,
+ "id": "operations",
+ "w": 14,
+ "x": 10,
+ "y": 6
+ }
+ ]
+}
diff --git a/resources/demo-cyber/console/dashboards/demo-cyber-sign-ins.json b/resources/demo-cyber/console/dashboards/demo-cyber-sign-ins.json
new file mode 100644
index 00000000..7a1fbb11
--- /dev/null
+++ b/resources/demo-cyber/console/dashboards/demo-cyber-sign-ins.json
@@ -0,0 +1,64 @@
+{
+ "name": "demo-cyber-sign-ins",
+ "tags": [
+ "demo"
+ ],
+ "tiles": [
+ {
+ "config": {
+ "configType": "sql",
+ "displayType": "stacked_bar",
+ "name": "Okta sign-ins per minute, by outcome",
+ "source": "okta",
+ "sqlTemplate": "SELECT $__timeInterval(_timestamp) AS ts,\n toString(event_outcome) AS outcome,\n count() * 60 / $__interval_s AS \"sign-ins/min\"\nFROM dfe.okta\nWHERE $__timeFilter(_timestamp) AND event_action = 'user.session.start'\nGROUP BY ts, outcome\nORDER BY ts"
+ },
+ "h": 6,
+ "id": "rate",
+ "w": 16,
+ "x": 0,
+ "y": 0
+ },
+ {
+ "config": {
+ "configType": "sql",
+ "displayType": "number",
+ "name": "Failed sign-ins in the time range",
+ "source": "okta",
+ "sqlTemplate": "SELECT count() AS \"failed\"\nFROM dfe.okta\nWHERE $__timeFilter(_timestamp) AND event_action = 'user.session.start' AND event_outcome = 'failure'"
+ },
+ "h": 6,
+ "id": "failed",
+ "w": 8,
+ "x": 16,
+ "y": 0
+ },
+ {
+ "config": {
+ "configType": "sql",
+ "displayType": "table",
+ "name": "Sign-ins by country, failures first",
+ "source": "okta",
+ "sqlTemplate": "SELECT coalesce(client_geo_country_name, 'unknown') AS \"Country\",\n countIf(event_outcome = 'failure') AS \"Failed\",\n countIf(event_outcome = 'success') AS \"Succeeded\",\n round(100 * countIf(event_outcome = 'failure') / count(), 1) AS \"Failed %\"\nFROM dfe.okta\nWHERE $__timeFilter(_timestamp) AND event_action = 'user.session.start'\nGROUP BY 1\nORDER BY 2 DESC, 3 DESC"
+ },
+ "h": 9,
+ "id": "countries",
+ "w": 10,
+ "x": 0,
+ "y": 6
+ },
+ {
+ "config": {
+ "configType": "sql",
+ "displayType": "table",
+ "name": "Failed sign-ins by user and address",
+ "source": "okta",
+ "sqlTemplate": "SELECT user_name AS \"User\",\n replaceOne(IPv6NumToString(assumeNotNull(client_ip)), '::ffff:', '') AS \"Address\",\n client_geo_country_name AS \"Country\",\n count() AS \"Failures\"\nFROM dfe.okta\nWHERE $__timeFilter(_timestamp) AND event_action = 'user.session.start' AND event_outcome = 'failure'\nGROUP BY 1, 2, 3\nORDER BY 4 DESC\nLIMIT 14"
+ },
+ "h": 9,
+ "id": "who",
+ "w": 14,
+ "x": 10,
+ "y": 6
+ }
+ ]
+}
diff --git a/resources/demo-cyber/console/searches/demo-cyber-cisco-asa-live.json b/resources/demo-cyber/console/searches/demo-cyber-cisco-asa-live.json
new file mode 100644
index 00000000..ae16b32b
--- /dev/null
+++ b/resources/demo-cyber/console/searches/demo-cyber-cisco-asa-live.json
@@ -0,0 +1,11 @@
+{
+ "name": "demo-cyber-cisco-asa-live",
+ "orderBy": "_timestamp DESC",
+ "select": "_timestamp, event_action, event_outcome, replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', '') AS source, source_port, replaceOne(IPv6NumToString(assumeNotNull(destination_ip)), '::ffff:', '') AS destination, destination_port, network_transport, network_bytes, event_original",
+ "source": "cisco-asa",
+ "tags": [
+ "demo"
+ ],
+ "where": "",
+ "whereLanguage": "sql"
+}
diff --git a/resources/demo-cyber/console/searches/demo-cyber-crowdstrike-live.json b/resources/demo-cyber/console/searches/demo-cyber-crowdstrike-live.json
new file mode 100644
index 00000000..f6ae69d7
--- /dev/null
+++ b/resources/demo-cyber/console/searches/demo-cyber-crowdstrike-live.json
@@ -0,0 +1,11 @@
+{
+ "name": "demo-cyber-crowdstrike-live",
+ "orderBy": "_timestamp DESC",
+ "select": "_timestamp, event_kind, event_action, event_severity, host_name, user_name, rule_name, threat_tactic_name, replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', '') AS address",
+ "source": "crowdstrike",
+ "tags": [
+ "demo"
+ ],
+ "where": "",
+ "whereLanguage": "sql"
+}
diff --git a/resources/demo-cyber/console/searches/demo-cyber-denied-drop.json b/resources/demo-cyber/console/searches/demo-cyber-denied-drop.json
new file mode 100644
index 00000000..78c4e0bc
--- /dev/null
+++ b/resources/demo-cyber/console/searches/demo-cyber-denied-drop.json
@@ -0,0 +1,11 @@
+{
+ "name": "demo-cyber-denied-drop",
+ "orderBy": "_timestamp DESC",
+ "select": "_timestamp, event_action, event_outcome, replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', '') AS source, source_port, replaceOne(IPv6NumToString(assumeNotNull(destination_ip)), '::ffff:', '') AS destination, destination_port, network_transport, network_bytes, event_original, cisco_asa_rule_name",
+ "source": "cisco-asa",
+ "tags": [
+ "demo"
+ ],
+ "where": "event_outcome = 'failure' AND event_action != 'logon-failed' AND arrayExists(n -> isIPAddressInRange(replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', ''), n), ['42.128.0.0/12', '42.160.0.0/12', '42.208.0.0/12', '147.16.0.0/14', '196.16.0.0/14', '101.134.0.0/15', '112.142.0.0/15', '168.80.0.0/15'])",
+ "whereLanguage": "sql"
+}
diff --git a/resources/demo-cyber/console/searches/demo-cyber-failed-sign-ins.json b/resources/demo-cyber/console/searches/demo-cyber-failed-sign-ins.json
new file mode 100644
index 00000000..9636877a
--- /dev/null
+++ b/resources/demo-cyber/console/searches/demo-cyber-failed-sign-ins.json
@@ -0,0 +1,11 @@
+{
+ "name": "demo-cyber-failed-sign-ins",
+ "orderBy": "_timestamp DESC",
+ "select": "_timestamp, event_action, event_outcome, user_name, replaceOne(IPv6NumToString(assumeNotNull(client_ip)), '::ffff:', '') AS address, client_geo_city_name, client_geo_country_name, user_agent_name",
+ "source": "okta",
+ "tags": [
+ "demo"
+ ],
+ "where": "event_action = 'user.session.start' AND event_outcome = 'failure' AND _timestamp > now() - INTERVAL 1 HOUR",
+ "whereLanguage": "sql"
+}
diff --git a/resources/demo-cyber/console/searches/demo-cyber-fortinet-live.json b/resources/demo-cyber/console/searches/demo-cyber-fortinet-live.json
new file mode 100644
index 00000000..14299d2d
--- /dev/null
+++ b/resources/demo-cyber/console/searches/demo-cyber-fortinet-live.json
@@ -0,0 +1,11 @@
+{
+ "name": "demo-cyber-fortinet-live",
+ "orderBy": "_timestamp_load DESC",
+ "select": "_timestamp_load, event_action, event_outcome, replaceOne(IPv6NumToString(assumeNotNull(source_ip)), '::ffff:', '') AS source, source_port, replaceOne(IPv6NumToString(assumeNotNull(destination_ip)), '::ffff:', '') AS destination, destination_port, network_transport, network_bytes, event_original",
+ "source": "fortinet",
+ "tags": [
+ "demo"
+ ],
+ "where": "",
+ "whereLanguage": "sql"
+}
diff --git a/resources/demo-cyber/console/searches/demo-cyber-o365-live.json b/resources/demo-cyber/console/searches/demo-cyber-o365-live.json
new file mode 100644
index 00000000..ccc25b98
--- /dev/null
+++ b/resources/demo-cyber/console/searches/demo-cyber-o365-live.json
@@ -0,0 +1,11 @@
+{
+ "name": "demo-cyber-o365-live",
+ "orderBy": "_timestamp DESC",
+ "select": "_timestamp, event_provider, event_code, event_action, event_outcome, user_id, replaceOne(IPv6NumToString(assumeNotNull(client_ip)), '::ffff:', '') AS address",
+ "source": "o365",
+ "tags": [
+ "demo"
+ ],
+ "where": "",
+ "whereLanguage": "sql"
+}
diff --git a/resources/demo-cyber/console/searches/demo-cyber-okta-live.json b/resources/demo-cyber/console/searches/demo-cyber-okta-live.json
new file mode 100644
index 00000000..76f120cb
--- /dev/null
+++ b/resources/demo-cyber/console/searches/demo-cyber-okta-live.json
@@ -0,0 +1,11 @@
+{
+ "name": "demo-cyber-okta-live",
+ "orderBy": "_timestamp DESC",
+ "select": "_timestamp, event_action, event_outcome, user_name, replaceOne(IPv6NumToString(assumeNotNull(client_ip)), '::ffff:', '') AS address, client_geo_city_name, client_geo_country_name, user_agent_name, user_agent_os_name",
+ "source": "okta",
+ "tags": [
+ "demo"
+ ],
+ "where": "",
+ "whereLanguage": "sql"
+}
diff --git a/resources/demo-cyber/demo.json b/resources/demo-cyber/demo.json
index ff0bdf35..6473eb3e 100644
--- a/resources/demo-cyber/demo.json
+++ b/resources/demo-cyber/demo.json
@@ -2,14 +2,40 @@
"archive": {
"max_megabytes": 200,
"retention_minutes": 15,
- "sources": [],
+ "sources": [
+ "demo-syslog"
+ ],
"sweep_minutes": 5
},
"console": {
- "dashboards": [],
- "searches": []
+ "dashboards": [
+ "demo-cyber-denied",
+ "demo-cyber-drop",
+ "demo-cyber-edr",
+ "demo-cyber-o365-admin",
+ "demo-cyber-sign-ins"
+ ],
+ "searches": [
+ "demo-cyber-cisco-asa-live",
+ "demo-cyber-crowdstrike-live",
+ "demo-cyber-denied-drop",
+ "demo-cyber-failed-sign-ins",
+ "demo-cyber-fortinet-live",
+ "demo-cyber-o365-live",
+ "demo-cyber-okta-live"
+ ]
},
- "sources": [],
+ "hunts": [
+ "demo-cyber-drop-sign-in"
+ ],
+ "sources": [
+ "cisco-asa",
+ "crowdstrike",
+ "demo-syslog",
+ "fortinet",
+ "o365",
+ "okta"
+ ],
"title": "Cyber",
- "use_case": "/solutions/"
+ "use_case": "/solutions/security-monitoring/"
}
diff --git a/resources/demo-cyber/events/LICENSES/Apache-2.0-panther-analysis.txt b/resources/demo-cyber/events/LICENSES/Apache-2.0-panther-analysis.txt
new file mode 100644
index 00000000..b8a36926
--- /dev/null
+++ b/resources/demo-cyber/events/LICENSES/Apache-2.0-panther-analysis.txt
@@ -0,0 +1,201 @@
+ Apache License
+ Version 2.0, January 2004
+ http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are under common
+ control with that entity. For the purposes of this definition,
+ "control" means (i) the power, direct or indirect, to cause the
+ direction or management of such entity, whether by contract or
+ otherwise, or (ii) ownership of fifty percent (50%) or more of the
+ outstanding shares, or (iii) beneficial ownership of such entity.
+
+ "You" (or "Your") shall mean an individual or Legal Entity
+ exercising permissions granted by this License.
+
+ "Source" form shall mean the preferred form for making modifications,
+ including but not limited to software source code, documentation
+ source, and configuration files.
+
+ "Object" form shall mean any form resulting from mechanical
+ transformation or translation of a Source form, including but
+ not limited to compiled object code, generated documentation,
+ and conversions to other media types.
+
+ "Work" shall mean the work of authorship, whether in Source or
+ Object form, made available under the License, as indicated by a
+ copyright notice that is included in or attached to the work
+ (an example is provided in the Appendix below).
+
+ "Derivative Works" shall mean any work, whether in Source or Object
+ form, that is based on (or derived from) the Work and for which the
+ editorial revisions, annotations, elaborations, or other modifications
+ represent, as a whole, an original work of authorship. For the purposes
+ of this License, Derivative Works shall not include works that remain
+ separable from, or merely link (or bind by name) to the interfaces of,
+ the Work and Derivative Works thereof.
+
+ "Contribution" shall mean any work of authorship, including
+ the original version of the Work and any modifications or additions
+ to that Work or Derivative Works thereof, that is intentionally
+ submitted to Licensor for inclusion in the Work by the copyright owner
+ or by an individual or Legal Entity authorized to submit on behalf of
+ the copyright owner. For the purposes of this definition, "submitted"
+ means any form of electronic, verbal, or written communication sent
+ to the Licensor or its representatives, including but not limited to
+ communication on electronic mailing lists, source code control systems,
+ and issue tracking systems that are managed by, or on behalf of, the
+ Licensor for the purpose of discussing and improving the Work, but
+ excluding communication that is conspicuously marked or otherwise
+ designated in writing by the copyright owner as "Not a Contribution."
+
+ "Contributor" shall mean Licensor and any individual or Legal Entity
+ on behalf of whom a Contribution has been received by Licensor and
+ subsequently incorporated within the Work.
+
+ 2. Grant of Copyright License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ copyright license to reproduce, prepare Derivative Works of,
+ publicly display, publicly perform, sublicense, and distribute the
+ Work and such Derivative Works in Source or Object form.
+
+ 3. Grant of Patent License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ (except as stated in this section) patent license to make, have made,
+ use, offer to sell, sell, import, and otherwise transfer the Work,
+ where such license applies only to those patent claims licensable
+ by such Contributor that are necessarily infringed by their
+ Contribution(s) alone or by combination of their Contribution(s)
+ with the Work to which such Contribution(s) was submitted. If You
+ institute patent litigation against any entity (including a
+ cross-claim or counterclaim in a lawsuit) alleging that the Work
+ or a Contribution incorporated within the Work constitutes direct
+ or contributory patent infringement, then any patent licenses
+ granted to You under this License for that Work shall terminate
+ as of the date such litigation is filed.
+
+ 4. Redistribution. You may reproduce and distribute copies of the
+ Work or Derivative Works thereof in any medium, with or without
+ modifications, and in Source or Object form, provided that You
+ meet the following conditions:
+
+ (a) You must give any other recipients of the Work or
+ Derivative Works a copy of this License; and
+
+ (b) You must cause any modified files to carry prominent notices
+ stating that You changed the files; and
+
+ (c) You must retain, in the Source form of any Derivative Works
+ that You distribute, all copyright, patent, trademark, and
+ attribution notices from the Source form of the Work,
+ excluding those notices that do not pertain to any part of
+ the Derivative Works; and
+
+ (d) If the Work includes a "NOTICE" text file as part of its
+ distribution, then any Derivative Works that You distribute must
+ include a readable copy of the attribution notices contained
+ within such NOTICE file, excluding those notices that do not
+ pertain to any part of the Derivative Works, in at least one
+ of the following places: within a NOTICE text file distributed
+ as part of the Derivative Works; within the Source form or
+ documentation, if provided along with the Derivative Works; or,
+ within a display generated by the Derivative Works, if and
+ wherever such third-party notices normally appear. The contents
+ of the NOTICE file are for informational purposes only and
+ do not modify the License. You may add Your own attribution
+ notices within Derivative Works that You distribute, alongside
+ or as an addendum to the NOTICE text from the Work, provided
+ that such additional attribution notices cannot be construed
+ as modifying the License.
+
+ You may add Your own copyright statement to Your modifications and
+ may provide additional or different license terms and conditions
+ for use, reproduction, or distribution of Your modifications, or
+ for any such Derivative Works as a whole, provided Your use,
+ reproduction, and distribution of the Work otherwise complies with
+ the conditions stated in this License.
+
+ 5. Submission of Contributions. Unless You explicitly state otherwise,
+ any Contribution intentionally submitted for inclusion in the Work
+ by You to the Licensor shall be under the terms and conditions of
+ this License, without any additional terms or conditions.
+ Notwithstanding the above, nothing herein shall supersede or modify
+ the terms of any separate license agreement you may have executed
+ with Licensor regarding such Contributions.
+
+ 6. Trademarks. This License does not grant permission to use the trade
+ names, trademarks, service marks, or product names of the Licensor,
+ except as required for reasonable and customary use in describing the
+ origin of the Work and reproducing the content of the NOTICE file.
+
+ 7. Disclaimer of Warranty. Unless required by applicable law or
+ agreed to in writing, Licensor provides the Work (and each
+ Contributor provides its Contributions) on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ implied, including, without limitation, any warranties or conditions
+ of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
+ PARTICULAR PURPOSE. You are solely responsible for determining the
+ appropriateness of using or redistributing the Work and assume any
+ risks associated with Your exercise of permissions under this License.
+
+ 8. Limitation of Liability. In no event and under no legal theory,
+ whether in tort (including negligence), contract, or otherwise,
+ unless required by applicable law (such as deliberate and grossly
+ negligent acts) or agreed to in writing, shall any Contributor be
+ liable to You for damages, including any direct, indirect, special,
+ incidental, or consequential damages of any character arising as a
+ result of this License or out of the use or inability to use the
+ Work (including but not limited to damages for loss of goodwill,
+ work stoppage, computer failure or malfunction, or any and all
+ other commercial damages or losses), even if such Contributor
+ has been advised of the possibility of such damages.
+
+ 9. Accepting Warranty or Additional Liability. While redistributing
+ the Work or Derivative Works thereof, You may choose to offer,
+ and charge a fee for, acceptance of support, warranty, indemnity,
+ or other liability obligations and/or rights consistent with this
+ License. However, in accepting such obligations, You may act only
+ on Your own behalf and on Your sole responsibility, not on behalf
+ of any other Contributor, and only if You agree to indemnify,
+ defend, and hold each Contributor harmless for any liability
+ incurred by, or claims asserted against, such Contributor by reason
+ of your accepting any such warranty or additional liability.
+
+ END OF TERMS AND CONDITIONS
+
+ APPENDIX: How to apply the Apache License to your work.
+
+ To apply the Apache License to your work, attach the following
+ boilerplate notice, with the fields enclosed by brackets "[]"
+ replaced with your own identifying information. (Don't include
+ the brackets!) The text should be enclosed in the appropriate
+ comment syntax for the file format. We also recommend that a
+ file or class name and description of purpose be included on the
+ same "printed page" as the copyright notice for easier
+ identification within third-party archives.
+
+ Copyright 2023 Panther Labs, Inc.
+
+ Licensed under the Apache License, Version 2.0 (the "License");
+ you may not use this file except in compliance with the License.
+ You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
diff --git a/resources/demo-cyber/events/LICENSES/CC0-1.0-botsv3.txt b/resources/demo-cyber/events/LICENSES/CC0-1.0-botsv3.txt
new file mode 100644
index 00000000..670154e3
--- /dev/null
+++ b/resources/demo-cyber/events/LICENSES/CC0-1.0-botsv3.txt
@@ -0,0 +1,116 @@
+CC0 1.0 Universal
+
+Statement of Purpose
+
+The laws of most jurisdictions throughout the world automatically confer
+exclusive Copyright and Related Rights (defined below) upon the creator and
+subsequent owner(s) (each and all, an "owner") of an original work of
+authorship and/or a database (each, a "Work").
+
+Certain owners wish to permanently relinquish those rights to a Work for the
+purpose of contributing to a commons of creative, cultural and scientific
+works ("Commons") that the public can reliably and without fear of later
+claims of infringement build upon, modify, incorporate in other works, reuse
+and redistribute as freely as possible in any form whatsoever and for any
+purposes, including without limitation commercial purposes. These owners may
+contribute to the Commons to promote the ideal of a free culture and the
+further production of creative, cultural and scientific works, or to gain
+reputation or greater distribution for their Work in part through the use and
+efforts of others.
+
+For these and/or other purposes and motivations, and without any expectation
+of additional consideration or compensation, the person associating CC0 with a
+Work (the "Affirmer"), to the extent that he or she is an owner of Copyright
+and Related Rights in the Work, voluntarily elects to apply CC0 to the Work
+and publicly distribute the Work under its terms, with knowledge of his or her
+Copyright and Related Rights in the Work and the meaning and intended legal
+effect of CC0 on those rights.
+
+1. Copyright and Related Rights. A Work made available under CC0 may be
+protected by copyright and related or neighboring rights ("Copyright and
+Related Rights"). Copyright and Related Rights include, but are not limited
+to, the following:
+
+ i. the right to reproduce, adapt, distribute, perform, display, communicate,
+ and translate a Work;
+
+ ii. moral rights retained by the original author(s) and/or performer(s);
+
+ iii. publicity and privacy rights pertaining to a person's image or likeness
+ depicted in a Work;
+
+ iv. rights protecting against unfair competition in regards to a Work,
+ subject to the limitations in paragraph 4(a), below;
+
+ v. rights protecting the extraction, dissemination, use and reuse of data in
+ a Work;
+
+ vi. database rights (such as those arising under Directive 96/9/EC of the
+ European Parliament and of the Council of 11 March 1996 on the legal
+ protection of databases, and under any national implementation thereof,
+ including any amended or successor version of such directive); and
+
+ vii. other similar, equivalent or corresponding rights throughout the world
+ based on applicable law or treaty, and any national implementations thereof.
+
+2. Waiver. To the greatest extent permitted by, but not in contravention of,
+applicable law, Affirmer hereby overtly, fully, permanently, irrevocably and
+unconditionally waives, abandons, and surrenders all of Affirmer's Copyright
+and Related Rights and associated claims and causes of action, whether now
+known or unknown (including existing as well as future claims and causes of
+action), in the Work (i) in all territories worldwide, (ii) for the maximum
+duration provided by applicable law or treaty (including future time
+extensions), (iii) in any current or future medium and for any number of
+copies, and (iv) for any purpose whatsoever, including without limitation
+commercial, advertising or promotional purposes (the "Waiver"). Affirmer makes
+the Waiver for the benefit of each member of the public at large and to the
+detriment of Affirmer's heirs and successors, fully intending that such Waiver
+shall not be subject to revocation, rescission, cancellation, termination, or
+any other legal or equitable action to disrupt the quiet enjoyment of the Work
+by the public as contemplated by Affirmer's express Statement of Purpose.
+
+3. Public License Fallback. Should any part of the Waiver for any reason be
+judged legally invalid or ineffective under applicable law, then the Waiver
+shall be preserved to the maximum extent permitted taking into account
+Affirmer's express Statement of Purpose. In addition, to the extent the Waiver
+is so judged Affirmer hereby grants to each affected person a royalty-free,
+non transferable, non sublicensable, non exclusive, irrevocable and
+unconditional license to exercise Affirmer's Copyright and Related Rights in
+the Work (i) in all territories worldwide, (ii) for the maximum duration
+provided by applicable law or treaty (including future time extensions), (iii)
+in any current or future medium and for any number of copies, and (iv) for any
+purpose whatsoever, including without limitation commercial, advertising or
+promotional purposes (the "License"). The License shall be deemed effective as
+of the date CC0 was applied by Affirmer to the Work. Should any part of the
+License for any reason be judged legally invalid or ineffective under
+applicable law, such partial invalidity or ineffectiveness shall not
+invalidate the remainder of the License, and in such case Affirmer hereby
+affirms that he or she will not (i) exercise any of his or her remaining
+Copyright and Related Rights in the Work or (ii) assert any associated claims
+and causes of action with respect to the Work, in either case contrary to
+Affirmer's express Statement of Purpose.
+
+4. Limitations and Disclaimers.
+
+ a. No trademark or patent rights held by Affirmer are waived, abandoned,
+ surrendered, licensed or otherwise affected by this document.
+
+ b. Affirmer offers the Work as-is and makes no representations or warranties
+ of any kind concerning the Work, express, implied, statutory or otherwise,
+ including without limitation warranties of title, merchantability, fitness
+ for a particular purpose, non infringement, or the absence of latent or
+ other defects, accuracy, or the present or absence of errors, whether or not
+ discoverable, all to the greatest extent permissible under applicable law.
+
+ c. Affirmer disclaims responsibility for clearing rights of other persons
+ that may apply to the Work or any use thereof, including without limitation
+ any person's Copyright and Related Rights in the Work. Further, Affirmer
+ disclaims responsibility for obtaining any necessary consents, permissions
+ or other rights required for any use of the Work.
+
+ d. Affirmer understands and acknowledges that Creative Commons is not a
+ party to this document and has no duty or obligation with respect to this
+ CC0 or use of the Work.
+
+For more information, please see
+
diff --git a/resources/demo-cyber/events/PROVENANCE.md b/resources/demo-cyber/events/PROVENANCE.md
new file mode 100644
index 00000000..c03487b9
--- /dev/null
+++ b/resources/demo-cyber/events/PROVENANCE.md
@@ -0,0 +1,13 @@
+# Where the cyber demo's events come from
+
+Every `