From 0c875774ceaca7c4173b10c97dc59a4217f38e35 Mon Sep 17 00:00:00 2001 From: vyzo Date: Fri, 21 Aug 2020 20:31:25 +0300 Subject: [PATCH] add mpool clear cli command --- cli/mpool.go | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) diff --git a/cli/mpool.go b/cli/mpool.go index 62ab06dae..3ec77a647 100644 --- a/cli/mpool.go +++ b/cli/mpool.go @@ -20,6 +20,7 @@ var mpoolCmd = &cli.Command{ Usage: "Manage message pool", Subcommands: []*cli.Command{ mpoolPending, + mpoolClear, mpoolSub, mpoolStat, mpoolReplaceCmd, @@ -83,6 +84,22 @@ var mpoolPending = &cli.Command{ }, } +var mpoolClear = &cli.Command{ + Name: "clear", + Usage: "Clear all pending messages from the mpool (USE WITH CARE)", + Action: func(cctx *cli.Context) error { + api, closer, err := GetFullNodeAPI(cctx) + if err != nil { + return err + } + defer closer() + + ctx := ReqContext(cctx) + + return api.MpoolClear(ctx) + }, +} + var mpoolSub = &cli.Command{ Name: "sub", Usage: "Subscribe to mpool changes",