mirror of
https://github.com/FAUSheppy/icinga-webhook-gateway
synced 2026-04-26 22:22:30 +02:00
Compare commits
9 Commits
95c3551a5c
...
smart-dev
| Author | SHA1 | Date | |
|---|---|---|---|
| d5d964ea8e | |||
| 8d4882d7c4 | |||
| 6ca2278838 | |||
| 8884e924e8 | |||
| 9eef4b1353 | |||
| ebb644fdf2 | |||
| c487c769b0 | |||
| ff2d8296f3 | |||
| ad08f69df1 |
5
.github/workflows/main.yaml
vendored
5
.github/workflows/main.yaml
vendored
@@ -4,8 +4,6 @@ on:
|
|||||||
push:
|
push:
|
||||||
branches:
|
branches:
|
||||||
- "master"
|
- "master"
|
||||||
schedule:
|
|
||||||
- cron: "0 2 * * 0"
|
|
||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
docker:
|
docker:
|
||||||
@@ -16,6 +14,9 @@ jobs:
|
|||||||
-
|
-
|
||||||
name: Checkout
|
name: Checkout
|
||||||
uses: actions/checkout@v3
|
uses: actions/checkout@v3
|
||||||
|
-
|
||||||
|
name: Set up QEMU
|
||||||
|
uses: docker/setup-qemu-action@v2
|
||||||
-
|
-
|
||||||
name: Set up Docker Buildx
|
name: Set up Docker Buildx
|
||||||
uses: docker/setup-buildx-action@v2
|
uses: docker/setup-buildx-action@v2
|
||||||
|
|||||||
1
req.txt
1
req.txt
@@ -5,4 +5,3 @@ flask-wtf
|
|||||||
waitress
|
waitress
|
||||||
requests
|
requests
|
||||||
icinga2api
|
icinga2api
|
||||||
psycopg2-binary
|
|
||||||
|
|||||||
45
server.py
45
server.py
@@ -29,10 +29,9 @@ import smarttools
|
|||||||
app = flask.Flask("Icinga Report In Gateway")
|
app = flask.Flask("Icinga Report In Gateway")
|
||||||
|
|
||||||
|
|
||||||
app.config['SQLALCHEMY_DATABASE_URI'] = os.environ.get('SQLALCHEMY_DATABASE_URI') or 'sqlite:///database.sqlite'
|
app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:///database.sqlite'
|
||||||
app.config['JSON_CONFIG_FILE'] = 'services.json'
|
app.config['JSON_CONFIG_FILE'] = 'services.json'
|
||||||
app.config['JSON_CONFIG_DIR'] = 'config'
|
app.config['JSON_CONFIG_DIR'] = 'config'
|
||||||
app.config['AUTH_HEADER'] = os.environ.get("AUTH_HEADER") or "X-Forwarded-Preferred-Username"
|
|
||||||
db = SQLAlchemy(app)
|
db = SQLAlchemy(app)
|
||||||
|
|
||||||
class Service(db.Model):
|
class Service(db.Model):
|
||||||
@@ -66,12 +65,12 @@ class SMARTStatus(db.Model):
|
|||||||
|
|
||||||
service = Column(String, primary_key=True)
|
service = Column(String, primary_key=True)
|
||||||
timestamp = Column(Integer, primary_key=True)
|
timestamp = Column(Integer, primary_key=True)
|
||||||
model_number = Column(String, primary_key=True)
|
|
||||||
power_cycles = Column(Integer)
|
power_cycles = Column(Integer)
|
||||||
temperature = Column(Integer)
|
temperature = Column(Integer)
|
||||||
available_spare = Column(Integer)
|
available_spare = Column(Integer)
|
||||||
unsafe_shutdowns = Column(Integer)
|
unsafe_shutdowns = Column(Integer)
|
||||||
critical_warning = Column(Integer)
|
critical_warning = Column(Integer)
|
||||||
|
model_number = Column(String)
|
||||||
power_cycles = Column(Integer)
|
power_cycles = Column(Integer)
|
||||||
power_on_hours = Column(Integer)
|
power_on_hours = Column(Integer)
|
||||||
wearleveling_count = Column(Integer)
|
wearleveling_count = Column(Integer)
|
||||||
@@ -92,7 +91,7 @@ def buildReponseDict(status, service=None):
|
|||||||
@app.route('/overview')
|
@app.route('/overview')
|
||||||
def overview():
|
def overview():
|
||||||
|
|
||||||
user = str(flask.request.headers.get(app.config['AUTH_HEADER']))
|
user = str(flask.request.headers.get("X-Forwarded-Preferred-Username"))
|
||||||
|
|
||||||
# query all services #
|
# query all services #
|
||||||
services = db.session.query(Service).filter(Service.owner == user).all()
|
services = db.session.query(Service).filter(Service.owner == user).all()
|
||||||
@@ -162,7 +161,7 @@ def create_entry(form, user):
|
|||||||
@app.route("/service-details")
|
@app.route("/service-details")
|
||||||
def service_details():
|
def service_details():
|
||||||
|
|
||||||
user = flask.request.headers.get(app.config['AUTH_HEADER'])
|
user = str(flask.request.headers.get("X-Forwarded-Preferred-Username"))
|
||||||
service = flask.request.args.get("service")
|
service = flask.request.args.get("service")
|
||||||
|
|
||||||
# query service #
|
# query service #
|
||||||
@@ -190,7 +189,7 @@ def service_details():
|
|||||||
@app.route("/entry-form", methods=["GET", "POST", "DELETE"])
|
@app.route("/entry-form", methods=["GET", "POST", "DELETE"])
|
||||||
def create_interface():
|
def create_interface():
|
||||||
|
|
||||||
user = flask.request.headers.get(app.config['AUTH_HEADER'])
|
user = str(flask.request.headers.get("X-Forwarded-Preferred-Username"))
|
||||||
|
|
||||||
# check if is delete #
|
# check if is delete #
|
||||||
operation = flask.request.args.get("operation")
|
operation = flask.request.args.get("operation")
|
||||||
@@ -343,7 +342,7 @@ def default():
|
|||||||
text, status = record_and_check_smart(verifiedServiceObj,
|
text, status = record_and_check_smart(verifiedServiceObj,
|
||||||
timestamp, smart)
|
timestamp, smart)
|
||||||
|
|
||||||
status = Status(service=service, timestamp=timestamp, status=status,
|
status = Status(service=service, timestamp=timestamp, status=status,
|
||||||
info_text=text)
|
info_text=text)
|
||||||
db.session.merge(status)
|
db.session.merge(status)
|
||||||
db.session.commit()
|
db.session.commit()
|
||||||
@@ -397,7 +396,7 @@ def record_and_check_smart(service, timestamp, smart):
|
|||||||
return ("SMART report prefail disk (wear_level < 20%)", "CRITICAL")
|
return ("SMART report prefail disk (wear_level < 20%)", "CRITICAL")
|
||||||
|
|
||||||
# temp max > X #
|
# temp max > X #
|
||||||
if smart_last.temperature > 60:
|
if smart_last.temperature > 50:
|
||||||
return ("Disk Temperatur {}".format(smart_last.temperature), "CRITICAL")
|
return ("Disk Temperatur {}".format(smart_last.temperature), "CRITICAL")
|
||||||
|
|
||||||
# available_SSD spare #
|
# available_SSD spare #
|
||||||
@@ -413,12 +412,11 @@ def record_and_check_smart(service, timestamp, smart):
|
|||||||
spare_change), "WARNING")
|
spare_change), "WARNING")
|
||||||
|
|
||||||
# unsafe_shutdowns +1 #
|
# unsafe_shutdowns +1 #
|
||||||
if(smart_second_last and
|
if smart_second_last.unsafe_shutdowns - smart_last.unsafe_shutdowns >= 1:
|
||||||
smart_second_last.unsafe_shutdowns - smart_last.unsafe_shutdowns >= 1):
|
|
||||||
return ("Disk had {} unsafe shutdowns".format(smart_last.unsafe_shutdowns),
|
return ("Disk had {} unsafe shutdowns".format(smart_last.unsafe_shutdowns),
|
||||||
"WARNING")
|
"WARNING")
|
||||||
|
|
||||||
return ("{} - no problems detected".format(smart_last.model_number), "OK")
|
return ("", "OK")
|
||||||
|
|
||||||
|
|
||||||
def create_app():
|
def create_app():
|
||||||
@@ -449,7 +447,8 @@ def create_app():
|
|||||||
config |= json.load(f)
|
config |= json.load(f)
|
||||||
|
|
||||||
if not config:
|
if not config:
|
||||||
print("No static services configuration found - loading finished.")
|
print("No valid configuration found - need at least one service")
|
||||||
|
return
|
||||||
|
|
||||||
for key in config:
|
for key in config:
|
||||||
timeout = timeparse.timeparse(config[key]["timeout"])
|
timeout = timeparse.timeparse(config[key]["timeout"])
|
||||||
@@ -459,34 +458,12 @@ def create_app():
|
|||||||
owner=config[key]["owner"]))
|
owner=config[key]["owner"]))
|
||||||
db.session.commit()
|
db.session.commit()
|
||||||
|
|
||||||
LOAD_FROM_ENV = [
|
|
||||||
"ICINGA_API_USER",
|
|
||||||
"ICINGA_API_PASS",
|
|
||||||
"ICINGA_API_URL",
|
|
||||||
"ICINGA_WEB_URL",
|
|
||||||
"ASYNC_ICINGA_DUMMY_HOST"
|
|
||||||
]
|
|
||||||
|
|
||||||
enforce_load_from_env = os.environ.get("ENFORCE_LOAD_FROM_ENV") or ""
|
|
||||||
missing = [k for k in LOAD_FROM_ENV if k not in os.environ]
|
|
||||||
if missing and enforce_load_from_env.lower() == "true":
|
|
||||||
print(f"ENFORCE_LOAD_FROM_ENV is 'true' but we are missing: {missing} - Abort.")
|
|
||||||
sys.exit(1)
|
|
||||||
|
|
||||||
for key in LOAD_FROM_ENV:
|
|
||||||
if key in os.environ:
|
|
||||||
print(f"Loading/Overwriting {key} from environment", file=sys.stderr)
|
|
||||||
app.config[key] = os.environ[key]
|
|
||||||
|
|
||||||
|
|
||||||
# create icinga host #
|
# create icinga host #
|
||||||
if not app.config.get("ICINGA_API_URL"):
|
if not app.config.get("ICINGA_API_URL"):
|
||||||
print("ICINGA_API_URL not defined. Not connecting Icinga", file=sys.stderr)
|
print("ICINGA_API_URL not defined. Not connecting Icinga", file=sys.stderr)
|
||||||
else:
|
else:
|
||||||
icingatools.create_master_host(app)
|
icingatools.create_master_host(app)
|
||||||
|
|
||||||
print(f"Expected AUTH_HEADER is: {app.config['AUTH_HEADER']}")
|
|
||||||
|
|
||||||
|
|
||||||
if __name__ == "__main__":
|
if __name__ == "__main__":
|
||||||
|
|
||||||
|
|||||||
@@ -34,8 +34,6 @@ def normalize(smart):
|
|||||||
elif name == "power_on_hours":
|
elif name == "power_on_hours":
|
||||||
target_name = "power_on_hours"
|
target_name = "power_on_hours"
|
||||||
use_raw = True
|
use_raw = True
|
||||||
elif name == "perc_avail_resrvd_space":
|
|
||||||
target_name = "available_spare"
|
|
||||||
|
|
||||||
# check if metric should be recorded #
|
# check if metric should be recorded #
|
||||||
if target_name in ret:
|
if target_name in ret:
|
||||||
@@ -48,7 +46,4 @@ def normalize(smart):
|
|||||||
|
|
||||||
ret[target_name] = value
|
ret[target_name] = value
|
||||||
|
|
||||||
if ret["critical_warning"] == 0 and "smart_status" in smart:
|
|
||||||
ret["critical_warning"] = int(not smart["smart_status"]["passed"])
|
|
||||||
|
|
||||||
return ret
|
return ret
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
body{
|
body{
|
||||||
background: radial-gradient(ellipse at center, #47918a 0%, #0b3161 100%);
|
background: radial-gradient(ellipse at center, #47918a 0%, #0b3161 100%);
|
||||||
background-attachment: fixed;
|
|
||||||
color: aliceblue !important;
|
color: aliceblue !important;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -83,13 +83,13 @@
|
|||||||
</div>
|
</div>
|
||||||
{% endif %}
|
{% endif %}
|
||||||
|
|
||||||
{% if service.special_type == "SMART" %}
|
{% if smart %}
|
||||||
<h5 class="clear my-4">Linux</h5>
|
<h5 class="clear my-4">Linux</h5>
|
||||||
{% else %}
|
{% else %}
|
||||||
<h5 class="clear my-4">Curl</h5>
|
<h5 class="clear my-4">Curl</h5>
|
||||||
{% endif %}
|
{% endif %}
|
||||||
<div class="ml-3 example">
|
<div class="ml-3 example">
|
||||||
{% if service.special_type == "SMART" %}
|
{% if smart %}
|
||||||
SMART='{ <br>
|
SMART='{ <br>
|
||||||
<div class="example-indent">
|
<div class="example-indent">
|
||||||
"service" : "{{ service.service }}", <br>
|
"service" : "{{ service.service }}", <br>
|
||||||
@@ -115,7 +115,7 @@
|
|||||||
{% endif %}
|
{% endif %}
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
{% if service.special_type == "SMART" %}
|
{% if smart %}
|
||||||
<h5 class="my-4">Windows</h5>
|
<h5 class="my-4">Windows</h5>
|
||||||
<div class="ml-3 example">
|
<div class="ml-3 example">
|
||||||
$SMART = @{ <br>
|
$SMART = @{ <br>
|
||||||
@@ -128,22 +128,6 @@
|
|||||||
} | ConvertTo-Json<br><br>
|
} | ConvertTo-Json<br><br>
|
||||||
Invoke-RestMethod -TimeoutSec 2 -Uri "{{ flask.request.url_root.replace("http://", "https://" )}}report" -Method Post -Headers @{"Content-Type"="application/json"} -Body $SMART
|
Invoke-RestMethod -TimeoutSec 2 -Uri "{{ flask.request.url_root.replace("http://", "https://" )}}report" -Method Post -Headers @{"Content-Type"="application/json"} -Body $SMART
|
||||||
</div>
|
</div>
|
||||||
<!-- register task example -->
|
|
||||||
<h5 class="my-4">Windows Task (requires Admin-Powershell)</h5>
|
|
||||||
<div class="ml-3 example">
|
|
||||||
$ScriptPath = Join-Path $HOME -ChildPath "smart_monitor.ps1" <br>
|
|
||||||
echo '$SMART = @{ <br>
|
|
||||||
<div class="example-indent">
|
|
||||||
service = "{{ service.service }}"<br>
|
|
||||||
token = "{{ service.token }}"<br>
|
|
||||||
status = "N/A"<br>
|
|
||||||
smart = "$(smartctl -a C: --json | Out-String)"<br>
|
|
||||||
</div>
|
|
||||||
} | ConvertTo-Json<br><br>
|
|
||||||
Invoke-RestMethod -TimeoutSec 2 -Uri "{{ flask.request.url_root.replace("http://", "https://" )}}report" -Method Post -Headers @{"Content-Type"="application/json"} -Body $SMART' > $ScriptPath <br>
|
|
||||||
schtasks /create /tn SMART_Monitor /tr "powershell.exe -executionpolicy bypass -File '$ScriptPath'" /sc hourly /mo 1 /ru "Administratoren"<br>
|
|
||||||
echo "Done" <br>
|
|
||||||
</div>
|
|
||||||
{% else %}
|
{% else %}
|
||||||
<h5 class="my-4">Python</h5>
|
<h5 class="my-4">Python</h5>
|
||||||
<div class="ml-3 example">
|
<div class="ml-3 example">
|
||||||
|
|||||||
Reference in New Issue
Block a user