From 6cf7179641f8210b38f07d90cccc70a36777d15d Mon Sep 17 00:00:00 2001
From: losyme <losyme@tutanota.com>
Date: Fri, 15 Apr 2022 17:18:59 +0200
Subject: [PATCH] =?UTF-8?q?En=20cours=20de=20d=C3=A9veloppement?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/application/events.go   |  7 +++++++
 internal/storage/memory/purge.go | 15 +++++++++++++++
 internal/storage/mongo/purge.go  | 15 +++++++++++++++
 internal/storage/storage.go      |  1 +
 4 files changed, 38 insertions(+)
 create mode 100644 internal/storage/memory/purge.go
 create mode 100644 internal/storage/mongo/purge.go

diff --git a/internal/application/events.go b/internal/application/events.go
index 8cf926f..973a277 100644
--- a/internal/application/events.go
+++ b/internal/application/events.go
@@ -12,6 +12,13 @@ func (app *Application) onMessage(msg *scheduler.Message) {
 	cs := app.cs
 
 	cs.Logger().Info("Event", "name", msg.Event) //:::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::
+
+	switch msg.Event {
+	case "storage.purge":
+		if err := cs.Storage().Purge(); err != nil {
+			cs.Logger().Error("Cannot delete old jobs/workflows", nil, err) //::::::::::::::::::::::::::::::::::::::::::
+		}
+	}
 }
 
 /*
diff --git a/internal/storage/memory/purge.go b/internal/storage/memory/purge.go
new file mode 100644
index 0000000..7796881
--- /dev/null
+++ b/internal/storage/memory/purge.go
@@ -0,0 +1,15 @@
+/*
+------------------------------------------------------------------------------------------------------------------------
+####### dune ####### Copyright (c) 2021-2022 losyme ################################################ MIT License #######
+------------------------------------------------------------------------------------------------------------------------
+*/
+
+package memory
+
+func (ms *memoryStorage) Purge() error {
+	return nil
+}
+
+/*
+######################################################################################################## @(°_°)@ #######
+*/
diff --git a/internal/storage/mongo/purge.go b/internal/storage/mongo/purge.go
new file mode 100644
index 0000000..acc83ed
--- /dev/null
+++ b/internal/storage/mongo/purge.go
@@ -0,0 +1,15 @@
+/*
+------------------------------------------------------------------------------------------------------------------------
+####### dune ####### Copyright (c) 2021-2022 losyme ################################################ MIT License #######
+------------------------------------------------------------------------------------------------------------------------
+*/
+
+package mongo
+
+func (ms *mongoStorage) Purge() error {
+	return nil
+}
+
+/*
+######################################################################################################## @(°_°)@ #######
+*/
diff --git a/internal/storage/storage.go b/internal/storage/storage.go
index d170cd4..0b7ea52 100644
--- a/internal/storage/storage.go
+++ b/internal/storage/storage.go
@@ -56,6 +56,7 @@ type Storage interface {
 	UpdateWorkflow(wf *jw.Workflow, job, nextJob *jw.Job) error
 	SetWorkflowPriority(id string, priority jw.Priority) error
 
+	Purge() error
 	State() (*State, error)
 	Close() error
 }