aboutsummaryrefslogtreecommitdiff
path: root/jobs/PeerChecker.py
blob: 965f4a41827034b7543d97ccc69316d42a5e322c (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
#!/usr/bin/env python

import os
import base64
import datetime 

import imaplib
import requests

import JobBase

class PeerChecker(JobBase.JobBase):
    def executeEvery(self):
        return JobBase.JobFrequency.HOUR
    def execute(self):
        testSuccess = True
        peers = self.config.items('peers')
        for p in peers:
            peer = p[1].split(',')
            peerOK = False

            subject = ""
            body = ""

            try:
                response = requests.get(peer[0])
                if response.status_code != 200:
                    peerOK = False
                    subject = peer[0] + " returned a non-standard status code."
                    body = str(response.status_code) + "\n" + response.content
                else:
                    if "True" in response.content:
                        peerOK = True
                    elif "False" in response.content:
                        peerOK = False
                        subject = peer[0] + " reports it cannot send email."
                        body = str(response.status_code) + "\n" + response.content
            except Exception as e:
                peerOK = False
                subject = peer[0] + " is not responding."
                body = str(e)
            
            if not peerOK:
                if not self.sendEmail(subject, body, peer[1]):
                    testSuccess = False
        return testSuccess