Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

feat(cli): add remove subscriptions command #979

Merged
merged 13 commits into from
Jan 10, 2024
Merged

feat(cli): add remove subscriptions command #979

Changes from all commits
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
8c736b0
add remove subscriptions flag
almostinf Dec 27, 2023
e342176
update remove subscription log
almostinf Dec 27, 2023
6932e4f
add started log
almostinf Dec 27, 2023
dc790c5
fix start log message
almostinf Dec 27, 2023
d344b1c
add debug log
almostinf Dec 27, 2023
27ae19b
update split strings character
almostinf Dec 28, 2023
4130f60
fix debug log
almostinf Dec 28, 2023
c968883
update remove subscription command description
almostinf Dec 28, 2023
5ee17b0
change separate character on dot with comma
almostinf Dec 28, 2023
b21d53d
update log level
almostinf Dec 28, 2023
84be47a
update description of remove subscriptions command
almostinf Dec 28, 2023
31e6212
update log naming
almostinf Jan 9, 2024
90fe6a0
add deleted to log
almostinf Jan 9, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
31 changes: 30 additions & 1 deletion cmd/cli/main.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,10 @@ var (
plotting = flag.Bool("plotting", false, "enable images in all notifications")
)

var (
removeSubscriptions = flag.String("remove-subscriptions", "", "Remove given subscriptions separated by semicolons.")
)

var (
cleanupUsers = flag.Bool("cleanup-users", false, "Disable/delete contacts and subscriptions of missing users")
cleanupLastChecks = flag.Bool("cleanup-last-checks", false, "Delete abandoned triggers last checks.")
Expand Down Expand Up @@ -320,6 +324,31 @@ func main() { //nolint
}
logger.Info().Msg("Dump was pushed")
}

if *removeSubscriptions != "" {
logger.Info().Msg("Start deletion of subscriptions")
subscriptionIDs := strings.Split(*removeSubscriptions, ";")
deleted := 0

logger.Debug().
Interface("subscription_ids", subscriptionIDs).
Msg("Remove subscription IDs")

for _, subscriptionID := range subscriptionIDs {
if err := database.RemoveSubscription(strings.TrimSpace(subscriptionID)); err != nil {
kissken marked this conversation as resolved.
Show resolved Hide resolved
logger.Error().
Error(err).
String("subscription_id", subscriptionID).
Msg("Failed to remove subscription")
continue
}
deleted++
}

logger.Info().
Int("deleted", deleted).
Msg("Deletion of subscriptions finished")
}
}

func GetDumpBriefInfo(dump *dto.TriggerDump) string {
Expand All @@ -334,7 +363,7 @@ func GetDumpBriefInfo(dump *dto.TriggerDump) string {
func initApp() (cleanupConfig, moira.Logger, moira.Database) {
flag.Parse()
if *printVersion {
fmt.Println("Moira - alerting system based on graphite data")
fmt.Println("Moira - alerting system based on graphite or prometheus data")
fmt.Println("Version:", MoiraVersion)
fmt.Println("Git Commit:", GitCommit)
fmt.Println("Go Version:", GoVersion)
Expand Down
Loading