32 lines
1 KiB
Go
32 lines
1 KiB
Go
|
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
|
||
|
|
// See LICENSE.txt for license information.
|
||
|
|
package main
|
||
|
|
|
||
|
|
import (
|
||
|
|
"errors"
|
||
|
|
"time"
|
||
|
|
)
|
||
|
|
|
||
|
|
var ErrInsufficientLicense = errors.New("appropriate license required")
|
||
|
|
|
||
|
|
func (p *Plugin) RunDataRetention(nowTime, batchSize int64) (int64, error) {
|
||
|
|
p.server.Logger().Debug("Boards RunDataRetention")
|
||
|
|
license := p.server.Store().GetLicense()
|
||
|
|
if license == nil || !(*license.Features.DataRetention) {
|
||
|
|
return 0, ErrInsufficientLicense
|
||
|
|
}
|
||
|
|
|
||
|
|
if p.server.Config().EnableDataRetention {
|
||
|
|
boardsRetentionDays := p.server.Config().DataRetentionDays
|
||
|
|
endTimeBoards := convertDaysToCutoff(boardsRetentionDays, time.Unix(nowTime/1000, 0))
|
||
|
|
return p.server.Store().RunDataRetention(endTimeBoards, batchSize)
|
||
|
|
}
|
||
|
|
return 0, nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func convertDaysToCutoff(days int, now time.Time) int64 {
|
||
|
|
upToStartOfDay := now.AddDate(0, 0, -days)
|
||
|
|
cutoffDate := time.Date(upToStartOfDay.Year(), upToStartOfDay.Month(), upToStartOfDay.Day(), 0, 0, 0, 0, time.Local)
|
||
|
|
return cutoffDate.UnixNano() / int64(time.Millisecond)
|
||
|
|
}
|