Merge pull request #11592 from Security-Onion-Solutions/minechanges

Minechanges
This commit is contained in:
Josh Patterson
2023-10-23 10:37:05 -04:00
committed by GitHub
5 changed files with 41 additions and 12 deletions

View File

@@ -406,12 +406,17 @@ function update_logstash_outputs() {
curl -K /opt/so/conf/elasticsearch/curl.config -L -X PUT "localhost:5601/api/fleet/outputs/so-manager_logstash" -H 'kbn-xsrf: true' -H 'Content-Type: application/json' -d "$JSON_STRING" curl -K /opt/so/conf/elasticsearch/curl.config -L -X PUT "localhost:5601/api/fleet/outputs/so-manager_logstash" -H 'kbn-xsrf: true' -H 'Content-Type: application/json' -d "$JSON_STRING"
} }
function checkMine() {
local func=$1
# make sure the minion sees itself in the mine since it needs to see itself for states as opposed to using salt-run
retry 20 1 "salt '$MINION_ID' mine.get '\*' '$func'" "$MINION_ID"
}
function updateMine() { function updateMine() {
salt "$MINION_ID" mine.send network.ip_addrs interface="$MNIC" retry 20 1 "salt '$MINION_ID' mine.update" True
}
function apply_ES_state() {
salt-call state.apply elasticsearch concurrent=True
} }
function createEVAL() { function createEVAL() {
is_pcaplimit=true is_pcaplimit=true
add_elasticsearch_to_minion add_elasticsearch_to_minion
@@ -547,8 +552,6 @@ function createSEARCHNODE() {
add_elasticsearch_to_minion add_elasticsearch_to_minion
add_logstash_to_minion add_logstash_to_minion
add_telegraf_to_minion add_telegraf_to_minion
updateMine
apply_ES_state
} }
function createRECEIVER() { function createRECEIVER() {
@@ -563,6 +566,19 @@ function createDESKTOP() {
} }
function testConnection() { function testConnection() {
# the minion should be trying to auth every 10 seconds so 15 seconds should be more than enough time to see this in the log
# this retry was put in because it is possible that a minion is attempted to be pinged before it has authenticated and connected to the Salt master
# causing the first ping to fail and typically wouldn't be successful until the second ping
# this check may pass without the minion being authenticated if it was previously connected and the line exists in the log
retry 15 1 "grep 'Authentication accepted from $MINION_ID' /opt/so/log/salt/master"
local retauth=$?
if [[ $retauth != 0 ]]; then
echo "The Minion did not authenticate with the Salt master in the allotted time"
echo "Deleting the key"
deleteminion
exit 1
fi
retry 15 3 "salt '$MINION_ID' test.ping" True retry 15 3 "salt '$MINION_ID' test.ping" True
local ret=$? local ret=$?
if [[ $ret != 0 ]]; then if [[ $ret != 0 ]]; then
@@ -582,9 +598,9 @@ if [[ "$OPERATION" = 'delete' ]]; then
deleteminion deleteminion
fi fi
if [[ "$OPERATION" = 'add' || "$OPERATION" = 'setup' ]]; then if [[ "$OPERATION" == 'add' || "$OPERATION" == 'setup' ]]; then
# Skip this if its setup # Skip this if its setup
if [ $OPERATION != 'setup' ]; then if [[ $OPERATION == 'add' ]]; then
# Accept the salt key # Accept the salt key
acceptminion acceptminion
# Test to see if the minion was accepted # Test to see if the minion was accepted
@@ -605,8 +621,19 @@ if [[ "$OPERATION" = 'add' || "$OPERATION" = 'setup' ]]; then
else else
add_sensoroni_to_minion add_sensoroni_to_minion
fi fi
create$NODETYPE create$NODETYPE
echo "Minion file created for $MINION_ID" echo "Minion file created for $MINION_ID"
if [[ "$OPERATION" == 'add' ]]; then
# tell the minion to populate the mine with data from mine_functions which is populated during setup
# this only needs to happen on non managers since they handle this during setup
# and they need to wait for ca creation to update the mine
updateMine
checkMine "network.ip_addrs"
# run this async so the cli doesn't wait for a return
salt "$MINION_ID" state.highstate --async
fi
fi fi
if [[ "$OPERATION" = 'test' ]]; then if [[ "$OPERATION" = 'test' ]]; then

View File

@@ -71,6 +71,7 @@ def start(interval=60):
log.error('checkmine engine: found minion %s is not in the mine' % (minion)) log.error('checkmine engine: found minion %s is not in the mine' % (minion))
mine_flush(minion) mine_flush(minion)
mine_update(minion) mine_update(minion)
continue
# Update the mine if the ip in the mine doesn't match returned from manage.alived # Update the mine if the ip in the mine doesn't match returned from manage.alived
network_ip_addrs = __salt__['saltutil.runner']('mine.get', tgt=minion, fun='network.ip_addrs') network_ip_addrs = __salt__['saltutil.runner']('mine.get', tgt=minion, fun='network.ip_addrs')
@@ -85,4 +86,5 @@ def start(interval=60):
log.error('checkmine engine: found minion %s is not in the mine' % (minion)) log.error('checkmine engine: found minion %s is not in the mine' % (minion))
mine_flush(minion) mine_flush(minion)
mine_update(minion) mine_update(minion)
sleep(interval) sleep(interval)

View File

@@ -3,5 +3,5 @@ post_setup_cron:
- name: 'PATH=$PATH:/usr/sbin salt-call state.highstate' - name: 'PATH=$PATH:/usr/sbin salt-call state.highstate'
- identifier: post_setup_cron - identifier: post_setup_cron
- user: root - user: root
- minute: '*/1' - minute: '*/5'
- identifier: post_setup_cron - identifier: post_setup_cron

View File

@@ -67,10 +67,10 @@ function manage_minion() {
response=$(so-minion "-o=$op" "-m=$minion_id") response=$(so-minion "-o=$op" "-m=$minion_id")
exit_code=$? exit_code=$?
if [[ exit_code -eq 0 ]]; then if [[ exit_code -eq 0 ]]; then
log "Successful command execution" log "Successful '$op' command execution on $minion_id"
respond "$id" "true" respond "$id" "true"
else else
log "Unsuccessful command execution: $response ($exit_code)" log "Unsuccessful '$op' command execution on $minion_id: $response ($exit_code)"
respond "$id" "false" respond "$id" "false"
fi fi
} }

View File

@@ -2500,7 +2500,7 @@ wait_for_salt_minion() {
local maxAttempts=20 local maxAttempts=20
until check_salt_minion_status; do until check_salt_minion_status; do
attempt=$((attempt+1)) attempt=$((attempt+1))
if [[ $attempt -gt $maxAttempts ]]; then if [[ $attempt -eq $maxAttempts ]]; then
fail_setup fail_setup
fi fi
sleep 10 sleep 10