From 4671e0dec5eab28941e598f109dbf77ed551a707 Mon Sep 17 00:00:00 2001
From: Tom Ritter <tom@ritter.vg>
Date: Mon, 7 Sep 2020 23:52:47 -0400
Subject: Correct line endings

---
 jobs/HTTPServerChecker.py | 102 ++++++++++++++++-----------------
 jobs/PeerChecker.py       | 140 +++++++++++++++++++++++-----------------------
 jobs/TCPServerChecker.py  | 108 +++++++++++++++++------------------
 3 files changed, 175 insertions(+), 175 deletions(-)

(limited to 'jobs')

diff --git a/jobs/HTTPServerChecker.py b/jobs/HTTPServerChecker.py
index 621e7b8..df96c1e 100755
--- a/jobs/HTTPServerChecker.py
+++ b/jobs/HTTPServerChecker.py
@@ -1,51 +1,51 @@
-#!/usr/bin/env python
-
-import logging
-import requests
-
-import JobBase
-import JobSpawner
-
-class HTTPServerChecker(JobSpawner.JobSpawner):
-    servers = [ 
-                #("http://example.com", JobBase.JobFrequency.MINUTE, JobBase.JobFailureNotificationFrequency.EVERYTIME, JobBase.JobFailureCountMinimumBeforeNotification.ONE),
-                #("https://exampletwo.com", JobBase.JobFrequency.MINUTE, JobBase.JobFailureNotificationFrequency.EVERYTIME, JobBase.JobFailureCountMinimumBeforeNotification.ONE)
-              ]
-
-    class ServerChecker(JobBase.JobBase):
-        def __init__(self, config, url, frequency, failureNotificationFrequency, failuresBeforeNotification):
-            self.config = config
-            self.url = url
-            self.frequency = frequency
-            self.failureNotificationFrequency = failureNotificationFrequency
-            self.failuresBeforeNotification = failuresBeforeNotification
-            super(HTTPServerChecker.ServerChecker, self).__init__(config, url)
-
-        def getName(self):
-            return str(self.__class__) + " for " + self.url
-        def executeEvery(self):
-            return self.frequency
-        def notifyOnFailureEvery(self):
-            return self.failureNotificationFrequency
-        def numberFailuresBeforeNotification(self):
-            return self.failuresBeforeNotification
-        def execute(self):
-            try:
-                i = requests.get(self.url)
-                if i.status_code != 200:
-                    self.failuremsg = "Error hitting server " + self.url + " (Code: " + str(i.status_code) + ")"
-                else:
-                    return True
-            except:
-                self.failuremsg = "Could not hit server " + self.url
-            logging.warn(self.failuremsg)
-            return False
-        def onFailure(self):
-            return self.sendEmail(self.failuremsg, "")
-        def onStateChangeSuccess(self):
-            return self.sendEmail("Successfully hit " + self.url, "")
-
-    def get_sub_jobs(self, config):
-        for s in self.servers:
-            yield self.ServerChecker(config, s[0], s[1], s[2], s[3])
-
+#!/usr/bin/env python
+
+import logging
+import requests
+
+import JobBase
+import JobSpawner
+
+class HTTPServerChecker(JobSpawner.JobSpawner):
+    servers = [ 
+                #("http://example.com", JobBase.JobFrequency.MINUTE, JobBase.JobFailureNotificationFrequency.EVERYTIME, JobBase.JobFailureCountMinimumBeforeNotification.ONE),
+                #("https://exampletwo.com", JobBase.JobFrequency.MINUTE, JobBase.JobFailureNotificationFrequency.EVERYTIME, JobBase.JobFailureCountMinimumBeforeNotification.ONE)
+              ]
+
+    class ServerChecker(JobBase.JobBase):
+        def __init__(self, config, url, frequency, failureNotificationFrequency, failuresBeforeNotification):
+            self.config = config
+            self.url = url
+            self.frequency = frequency
+            self.failureNotificationFrequency = failureNotificationFrequency
+            self.failuresBeforeNotification = failuresBeforeNotification
+            super(HTTPServerChecker.ServerChecker, self).__init__(config, url)
+
+        def getName(self):
+            return str(self.__class__) + " for " + self.url
+        def executeEvery(self):
+            return self.frequency
+        def notifyOnFailureEvery(self):
+            return self.failureNotificationFrequency
+        def numberFailuresBeforeNotification(self):
+            return self.failuresBeforeNotification
+        def execute(self):
+            try:
+                i = requests.get(self.url)
+                if i.status_code != 200:
+                    self.failuremsg = "Error hitting server " + self.url + " (Code: " + str(i.status_code) + ")"
+                else:
+                    return True
+            except:
+                self.failuremsg = "Could not hit server " + self.url
+            logging.warn(self.failuremsg)
+            return False
+        def onFailure(self):
+            return self.sendEmail(self.failuremsg, "")
+        def onStateChangeSuccess(self):
+            return self.sendEmail("Successfully hit " + self.url, "")
+
+    def get_sub_jobs(self, config):
+        for s in self.servers:
+            yield self.ServerChecker(config, s[0], s[1], s[2], s[3])
+
diff --git a/jobs/PeerChecker.py b/jobs/PeerChecker.py
index 7832b25..77df4ce 100755
--- a/jobs/PeerChecker.py
+++ b/jobs/PeerChecker.py
@@ -1,70 +1,70 @@
-#!/usr/bin/env python
-
-import os
-import base64
-import datetime 
-
-import imaplib
-import requests
-
-import JobBase
-import JobSpawner
-
-class PeerChecker(JobSpawner.JobSpawner):
-    class IndividualPeerChecker(JobBase.JobBase):
-        def __init__(self, config, checkurl, notificationAddress):
-            self.checkurl = checkurl
-            self.notificationAddress = notificationAddress
-            super(PeerChecker.IndividualPeerChecker, self).__init__(config, checkurl, notificationAddress)
-
-        def getName(self):
-            return str(self.__class__) + " for " + self.checkurl
-        def executeEvery(self):
-            return JobBase.JobFrequency.HOUR
-        def notifyOnFailureEvery(self):
-            return JobBase.JobFailureNotificationFrequency.EVERYTIME
-        def numberFailuresBeforeNotification(self):
-            return JobBase.JobFailureCountMinimumBeforeNotification.ONE
-        def execute(self):
-            peerOK = False
-
-            self.subject = ""
-            self.body = ""
-
-            try:
-                response = requests.get(self.checkurl)
-                if response.status_code != 200:
-                    peerOK = False
-                    self.subject = self.checkurl + " returned a non-standard status code."
-                    self.body = str(response.status_code) + "\n" + response.content
-                else:
-                    if "True" in response.content:
-                        peerOK = True
-                    elif "MailProblem" in response.content:
-                        peerOK = False
-                        self.subject = self.checkurl + " reports it cannot send email."
-                        self.body = str(response.status_code) + "\n" + response.content
-                    elif "JobProblem" in response.content:
-                        peerOK = False
-                        self.subject = self.checkurl + " reports its jobs are not running."
-                        self.body = str(response.status_code) + "\n" + response.content
-                    else:
-                        peerOK = False
-                        self.subject = self.checkurl + " had an unexpected response."
-                        self.body = str(response.status_code) + "\n" + response.content
-            except Exception as e:
-                peerOK = False
-                self.subject = self.checkurl + " is not responding."
-                self.body = str(e)
-            return peerOK
-
-        def onFailure(self):
-            return self.sendEmail(self.subject, self.body, self.notificationAddress)
-        def onStateChangeSuccess(self):
-            return self.sendEmail("Successfully hit " + self.checkurl, "", self.notificationAddress)
-
-    def get_sub_jobs(self, config):
-        peers = config.items('peers')
-        for p in peers:
-            (address, email) = p[1].split(',')
-            yield self.IndividualPeerChecker(config, address, email)
+#!/usr/bin/env python
+
+import os
+import base64
+import datetime 
+
+import imaplib
+import requests
+
+import JobBase
+import JobSpawner
+
+class PeerChecker(JobSpawner.JobSpawner):
+    class IndividualPeerChecker(JobBase.JobBase):
+        def __init__(self, config, checkurl, notificationAddress):
+            self.checkurl = checkurl
+            self.notificationAddress = notificationAddress
+            super(PeerChecker.IndividualPeerChecker, self).__init__(config, checkurl, notificationAddress)
+
+        def getName(self):
+            return str(self.__class__) + " for " + self.checkurl
+        def executeEvery(self):
+            return JobBase.JobFrequency.HOUR
+        def notifyOnFailureEvery(self):
+            return JobBase.JobFailureNotificationFrequency.EVERYTIME
+        def numberFailuresBeforeNotification(self):
+            return JobBase.JobFailureCountMinimumBeforeNotification.ONE
+        def execute(self):
+            peerOK = False
+
+            self.subject = ""
+            self.body = ""
+
+            try:
+                response = requests.get(self.checkurl)
+                if response.status_code != 200:
+                    peerOK = False
+                    self.subject = self.checkurl + " returned a non-standard status code."
+                    self.body = str(response.status_code) + "\n" + response.content
+                else:
+                    if "True" in response.content:
+                        peerOK = True
+                    elif "MailProblem" in response.content:
+                        peerOK = False
+                        self.subject = self.checkurl + " reports it cannot send email."
+                        self.body = str(response.status_code) + "\n" + response.content
+                    elif "JobProblem" in response.content:
+                        peerOK = False
+                        self.subject = self.checkurl + " reports its jobs are not running."
+                        self.body = str(response.status_code) + "\n" + response.content
+                    else:
+                        peerOK = False
+                        self.subject = self.checkurl + " had an unexpected response."
+                        self.body = str(response.status_code) + "\n" + response.content
+            except Exception as e:
+                peerOK = False
+                self.subject = self.checkurl + " is not responding."
+                self.body = str(e)
+            return peerOK
+
+        def onFailure(self):
+            return self.sendEmail(self.subject, self.body, self.notificationAddress)
+        def onStateChangeSuccess(self):
+            return self.sendEmail("Successfully hit " + self.checkurl, "", self.notificationAddress)
+
+    def get_sub_jobs(self, config):
+        peers = config.items('peers')
+        for p in peers:
+            (address, email) = p[1].split(',')
+            yield self.IndividualPeerChecker(config, address, email)
diff --git a/jobs/TCPServerChecker.py b/jobs/TCPServerChecker.py
index 7daf7f5..6098977 100755
--- a/jobs/TCPServerChecker.py
+++ b/jobs/TCPServerChecker.py
@@ -1,54 +1,54 @@
-#!/usr/bin/env python
-
-import os
-import socket
-import logging
-
-import JobBase
-import JobSpawner
-
-class TCPServerChecker(JobSpawner.JobSpawner):
-    servers = [ 
-                #("example.com", 53, "example.com:tcpdns", JobBase.JobFrequency.MINUTE, JobBase.JobFailureNotificationFrequency.EVERYTIME, JobBase.JobFailureCountMinimumBeforeNotification.ONE)
-              ]
-
-    class ServerChecker(JobBase.JobBase):
-        def __init__(self, config, ip, port, friendlyName, frequency, failureNotificationFrequency, failuresBeforeNotification):
-            self.config = config
-            self.ip = ip
-            self.port = port
-            self.friendlyName = friendlyName + "(" + self.ip + ":" + str(self.port) + ")"
-            self.frequency = frequency
-            self.failureNotificationFrequency = failureNotificationFrequency
-            self.failuresBeforeNotification = failuresBeforeNotification
-            super(TCPServerChecker.ServerChecker, self).__init__(config, ip, port)
-
-        def getName(self):
-            return str(self.__class__) + " for " + self.friendlyName
-        def executeEvery(self):
-            return self.frequency
-        def notifyOnFailureEvery(self):
-            return self.failureNotificationFrequency
-        def numberFailuresBeforeNotification(self):
-            return self.failuresBeforeNotification
-        def execute(self):
-            try:
-                s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
-                s.settimeout(10)
-                s.connect((self.ip, self.port))
-                s.close()
-                return True
-            except:
-                self.failuremsg = "Could not hit server " + self.friendlyName
-                logging.warn(self.failuremsg)
-                return False
-        def onFailure(self):
-            return self.sendEmail(self.failuremsg, "")
-        def onStateChangeSuccess(self):
-            return self.sendEmail("Successfully hit " + self.friendlyName, "")
-
-    def get_sub_jobs(self, config):
-        for s in self.servers:
-            yield self.ServerChecker(config, s[0], s[1], s[2], s[3], s[4], s[5])
-
-            
+#!/usr/bin/env python
+
+import os
+import socket
+import logging
+
+import JobBase
+import JobSpawner
+
+class TCPServerChecker(JobSpawner.JobSpawner):
+    servers = [ 
+                #("example.com", 53, "example.com:tcpdns", JobBase.JobFrequency.MINUTE, JobBase.JobFailureNotificationFrequency.EVERYTIME, JobBase.JobFailureCountMinimumBeforeNotification.ONE)
+              ]
+
+    class ServerChecker(JobBase.JobBase):
+        def __init__(self, config, ip, port, friendlyName, frequency, failureNotificationFrequency, failuresBeforeNotification):
+            self.config = config
+            self.ip = ip
+            self.port = port
+            self.friendlyName = friendlyName + "(" + self.ip + ":" + str(self.port) + ")"
+            self.frequency = frequency
+            self.failureNotificationFrequency = failureNotificationFrequency
+            self.failuresBeforeNotification = failuresBeforeNotification
+            super(TCPServerChecker.ServerChecker, self).__init__(config, ip, port)
+
+        def getName(self):
+            return str(self.__class__) + " for " + self.friendlyName
+        def executeEvery(self):
+            return self.frequency
+        def notifyOnFailureEvery(self):
+            return self.failureNotificationFrequency
+        def numberFailuresBeforeNotification(self):
+            return self.failuresBeforeNotification
+        def execute(self):
+            try:
+                s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+                s.settimeout(10)
+                s.connect((self.ip, self.port))
+                s.close()
+                return True
+            except:
+                self.failuremsg = "Could not hit server " + self.friendlyName
+                logging.warn(self.failuremsg)
+                return False
+        def onFailure(self):
+            return self.sendEmail(self.failuremsg, "")
+        def onStateChangeSuccess(self):
+            return self.sendEmail("Successfully hit " + self.friendlyName, "")
+
+    def get_sub_jobs(self, config):
+        for s in self.servers:
+            yield self.ServerChecker(config, s[0], s[1], s[2], s[3], s[4], s[5])
+
+            
-- 
cgit v1.2.3