feat: add basic table housekeeper to deleted data after x days

Signed-off-by: Alexander Trost <[email protected]>

gen/go/proto/resources/common/cron/cron.go

@@ -1,5 +1,9 @@
 package cron
 
+import "time"
+
+const DefaultCronTimeout = 10 * time.Second
+
 func (x *Cronjob) Merge(in *Cronjob) *Cronjob {
 	x.Schedule = in.Schedule
 
@@ -22,6 +26,14 @@ func (x *Cronjob) Merge(in *Cronjob) *Cronjob {
 	return x
 }
 
+func (x *Cronjob) GetRunTimeout() time.Duration {
+	if x.Timeout == nil {
+		return DefaultCronTimeout
+	}
+
+	return x.Timeout.AsDuration()
+}
+
 func (x *CronjobData) Merge(in *CronjobData) *CronjobData {
 	x.Data = in.Data
 

gen/go/proto/services/calendar/calendar.go

@@ -7,6 +7,7 @@ import (
 	"github.com/fivenet-app/fivenet/pkg/access"
 	"github.com/fivenet-app/fivenet/pkg/config/appconfig"
 	"github.com/fivenet-app/fivenet/pkg/events"
+	"github.com/fivenet-app/fivenet/pkg/housekeeper"
 	"github.com/fivenet-app/fivenet/pkg/mstlystcdata"
 	"github.com/fivenet-app/fivenet/pkg/notifi"
 	"github.com/fivenet-app/fivenet/pkg/perms"
@@ -33,6 +34,20 @@ var (
 	tUserProps = table.FivenetUserProps
 )
 
+func init() {
+	housekeeper.AddTable(&housekeeper.Table{
+		Table:           table.FivenetCalendar,
+		TimestampColumn: table.FivenetCalendar.DeletedAt,
+		MinDays:         60,
+	})
+
+	housekeeper.AddTable(&housekeeper.Table{
+		Table:           table.FivenetCalendarEntries,
+		TimestampColumn: table.FivenetCalendarEntries.DeletedAt,
+		MinDays:         60,
+	})
+}
+
 type Server struct {
 	CalendarServiceServer
 

gen/go/proto/services/docstore/docstore.go

@@ -16,6 +16,7 @@ import (
 	"github.com/fivenet-app/fivenet/pkg/grpc/auth"
 	"github.com/fivenet-app/fivenet/pkg/grpc/auth/userinfo"
 	"github.com/fivenet-app/fivenet/pkg/grpc/errswrap"
+	"github.com/fivenet-app/fivenet/pkg/housekeeper"
 	"github.com/fivenet-app/fivenet/pkg/html/htmldiffer"
 	"github.com/fivenet-app/fivenet/pkg/html/htmlsanitizer"
 	"github.com/fivenet-app/fivenet/pkg/mstlystcdata"
@@ -38,6 +39,8 @@ import (
 const (
 	DocsDefaultPageSize   = 16
 	DocShortContentLength = 128
+
+	housekeeperMinDays = 60
 )
 
 var (
@@ -50,6 +53,37 @@ var (
 	tDUserAccess   = table.FivenetDocumentsUserAccess.AS("user_access")
 )
 
+func init() {
+	housekeeper.AddTable(&housekeeper.Table{
+		Table:           table.FivenetDocuments,
+		TimestampColumn: table.FivenetDocuments.DeletedAt,
+		MinDays:         housekeeperMinDays,
+	})
+
+	housekeeper.AddTable(&housekeeper.Table{
+		Table:           table.FivenetDocumentsTemplates,
+		TimestampColumn: table.FivenetDocumentsTemplates.DeletedAt,
+		MinDays:         housekeeperMinDays,
+	})
+
+	housekeeper.AddTable(&housekeeper.Table{
+		Table:           table.FivenetDocumentsComments,
+		TimestampColumn: table.FivenetDocumentsComments.DeletedAt,
+		MinDays:         housekeeperMinDays,
+	})
+
+	housekeeper.AddTable(&housekeeper.Table{
+		Table:           table.FivenetDocumentsReferences,
+		TimestampColumn: table.FivenetDocumentsReferences.DeletedAt,
+		MinDays:         housekeeperMinDays,
+	})
+	housekeeper.AddTable(&housekeeper.Table{
+		Table:           table.FivenetDocumentsRelations,
+		TimestampColumn: table.FivenetDocumentsRelations.DeletedAt,
+		MinDays:         housekeeperMinDays,
+	})
+}
+
 type Server struct {
 	DocStoreServiceServer
 

gen/go/proto/services/docstore/workflow_state.go

@@ -59,7 +59,7 @@ type WorkflowParams struct {
 
 func NewWorkflow(p WorkflowParams) *Workflow {
 	w := &Workflow{
-		logger: p.Logger,
+		logger: p.Logger.Named("docstore.workflow"),
 		tracer: p.TP.Tracer("docstore_workflow"),
 		db:     p.DB,
 		notif:  p.Notif,
@@ -71,7 +71,7 @@ func NewWorkflow(p WorkflowParams) *Workflow {
 	p.LC.Append(fx.StartHook(func(ctx context.Context) error {
 		if err := p.Cron.RegisterCronjob(ctx, &cron.Cronjob{
 			Name:     "docstore.workflow_run",
-			Schedule: "*/15 * * * * *", // Every minute
+			Schedule: "@always", // Every minute
 		}); err != nil {
 			return err
 		}