Thomas Gambier · @tomo · Administrator · Nicolas Wavrant · Thomas Gambier · Nicolas Wavrant
--- a/slapos/promise/plugin/backupserver_check_backup.py 0 → 100644
+++ b/slapos/promise/plugin/backupserver_check_backup.py 0 → 100644
+      At the beginning of the backup, we have "backup running" printed in the text file.
+      At the end of the backup, we can have one of the following printed in the text file:
+         * "backup failed" -> backup failed
+         * "backup success" -> backup succeeded
+      A backup is valid only if we have the 2 conditions:
+         * we can grep "backup running" in the text file
+         * we can't grep "backup failed" in the text file
+    """
+
+    status_log = self.getConfig('status_log')
+    prev_cron = croniter(self.getConfig('cron_frequency'), datetime.now(pytz.utc)).get_prev(datetime) # date of the previous time cron launched
+
+    # First, parse the log file
+    backup_started = False
+    backup_ended = False
+    for line in open(status_log, 'r'):
--- a/slapos/promise/plugin/backupserver_check_backup.py 0 → 100644
+++ b/slapos/promise/plugin/backupserver_check_backup.py 0 → 100644
+      self.logger.error("Backup FAILED at {} (see log file : {})".format(backup_end, status_log))
+    elif not backup_started:
+      self.logger.error("Can't find backup start date. Is there a problem with log ? (see log file : {})".format(status_log))
+    elif backup_start < prev_cron:
+      self.logger.error("Backup didn't start at correct time: it started at {} but should have started after {}. (see log file : {})".format(backup_start, prev_cron, status_log))
+    elif not backup_ended:
+      self.logger.info("Backup currently running (started at {})".format(backup_start))
+    else:
+      self.logger.info("Backup OK (started at {} and lasted {})".format(backup_start, backup_end - backup_start))
+
+  # no need to define Test as it is the default implementation
+  #def test(self):
+  #  """
+  #    Test is failing if last sense was bad.
+  #  """
+  #  return self._test(result_count=1, failure_amount=1)
--- a/slapos/promise/plugin/backupserver_check_backup.py 0 → 100644
+++ b/slapos/promise/plugin/backupserver_check_backup.py 0 → 100644
+      self.logger.info("Backup currently running (started at {})".format(backup_start))
+    else:
+      self.logger.info("Backup OK (started at {} and lasted {})".format(backup_start, backup_end - backup_start))
+
+  # no need to define Test as it is the default implementation
+  #def test(self):
+  #  """
+  #    Test is failing if last sense was bad.
+  #  """
+  #  return self._test(result_count=1, failure_amount=1)
+
+  def anomaly(self):
+    """
+      There is never an anomaly as this promise will be checked manually.
+    """
+    return AnomalyResult(problem=False)
--- a/setup.py
+++ b/setup.py
        'slapos.core', # as it provides library for slap
        'xml_marshaller', # needed to dump information
        'GitPython', #needed for git manipulation into slaprunner
+        'croniter', # needed to know cron schedule
+        'python-dateutil', # needed by croniter
--- a/slapos/test/promise/plugin/test_backupserver_check_backup.py 0 → 100644
+++ b/slapos/test/promise/plugin/test_backupserver_check_backup.py 0 → 100644
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program; if not, write to the Free Software
+# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+#
+##############################################################################
+
+from slapos.test.promise.plugin import TestPromisePluginMixin
+from slapos.grid.promise import PromiseError
+import os
+from datetime import datetime,timedelta
+
+class TestBackupserverCheckBackup(TestPromisePluginMixin):
--- a/slapos/test/promise/plugin/test_backupserver_check_backup.py 0 → 100644
+++ b/slapos/test/promise/plugin/test_backupserver_check_backup.py 0 → 100644
+      self.launcher.run()
+    result = self.getPromiseResult(self.promise_name)
+    self.assertEquals(result['result']['message'][:13], "Backup FAILED")
+
+  def test_check_backup_too_long(self):
+    now = datetime.utcnow()
+    long_ago = now - timedelta(days = 2)
+    with open(self.status_fullpath, 'w') as f:
+      f.write(self.format_status(long_ago, "running"))
+
+    self.configureLauncher(enable_anomaly=True)
+    with self.assertRaises(PromiseError):
+      self.launcher.run()
+    result = self.getPromiseResult(self.promise_name)
+    self.assertEquals(result['result']['failed'], True)
+    self.assertEquals(result['result']['message'][:35], "Backup didn't start at correct time")