From e1185dd5b5397961ef647cfc6aaf9a7685d99889 Mon Sep 17 00:00:00 2001
From: ZenGround0 <ZenGround0@users.noreply.github.com>
Date: Thu, 22 Apr 2021 23:03:53 -0400
Subject: [PATCH 1/2] cron-wc

---
 cmd/lotus-shed/cron-count.go | 99 ++++++++++++++++++++++++++++++++++++
 cmd/lotus-shed/main.go       |  1 +
 2 files changed, 100 insertions(+)
 create mode 100644 cmd/lotus-shed/cron-count.go

diff --git a/cmd/lotus-shed/cron-count.go b/cmd/lotus-shed/cron-count.go
new file mode 100644
index 00000000000..91e7ab31396
--- /dev/null
+++ b/cmd/lotus-shed/cron-count.go
@@ -0,0 +1,99 @@
+package main
+
+import (
+	"fmt"
+
+	"github.com/filecoin-project/go-address"
+	"github.com/filecoin-project/lotus/build"
+	lcli "github.com/filecoin-project/lotus/cli"
+	"github.com/urfave/cli/v2"
+	"golang.org/x/xerrors"
+)
+
+var cronWcCmd = &cli.Command{
+	Name:        "cron-wc",
+	Description: "cron stats",
+	Subcommands: []*cli.Command{
+		minerDeadlineCronCountCmd,
+	},
+}
+
+var minerDeadlineCronCountCmd = &cli.Command{
+	Name:        "deadline",
+	Description: "list all addresses of miners with active deadline crons",
+	Action: func(c *cli.Context) error {
+		return countDeadlineCrons(c)
+	},
+	Flags: []cli.Flag{
+		&cli.StringFlag{
+			Name:  "tipset",
+			Usage: "specify tipset state to search on (pass comma separated array of cids)",
+		},
+	},
+}
+
+func findDeadlineCrons(c *cli.Context) (map[address.Address]struct{}, error) {
+	api, acloser, err := lcli.GetFullNodeAPI(c)
+	if err != nil {
+		return nil, err
+	}
+	defer acloser()
+	ctx := lcli.ReqContext(c)
+
+	ts, err := lcli.LoadTipSet(ctx, c, api)
+	if err != nil {
+		return nil, err
+	}
+	if ts == nil {
+		ts, err = api.ChainHead(ctx)
+		if err != nil {
+			return nil, err
+		}
+	}
+
+	mAddrs, err := api.StateListMiners(ctx, ts.Key())
+	if err != nil {
+		return nil, err
+	}
+	activeMiners := make(map[address.Address]struct{})
+	for _, mAddr := range mAddrs {
+		// All miners have active cron before v4.
+		// v4 upgrade epoch is last epoch running v3 epoch and api.StateReadState reads
+		// parent state, so v4 state isn't read until upgrade epoch + 2
+		if ts.Height() <= build.UpgradeActorsV4Height+1 {
+			activeMiners[mAddr] = struct{}{}
+			continue
+		}
+		st, err := api.StateReadState(ctx, mAddr, ts.Key())
+		if err != nil {
+			return nil, err
+		}
+		minerState, ok := st.State.(map[string]interface{})
+		if !ok {
+			return nil, xerrors.Errorf("internal error: failed to cast miner state to expected map type")
+		}
+
+		activeDlineIface, ok := minerState["DeadlineCronActive"]
+		if !ok {
+			return nil, xerrors.Errorf("miner %s had no deadline state, is this a v3 state root?", mAddr)
+		}
+		active := activeDlineIface.(bool)
+		if active {
+			activeMiners[mAddr] = struct{}{}
+		}
+	}
+
+	return activeMiners, nil
+}
+
+func countDeadlineCrons(c *cli.Context) error {
+	activeMiners, err := findDeadlineCrons(c)
+	if err != nil {
+		return err
+	}
+	for addr, _ := range activeMiners {
+		fmt.Printf("%s\n", addr)
+	}
+
+	return nil
+}
diff --git a/cmd/lotus-shed/main.go b/cmd/lotus-shed/main.go
index 3aa66745957..daf878c7316 100644
--- a/cmd/lotus-shed/main.go
+++ b/cmd/lotus-shed/main.go
@@ -20,6 +20,7 @@ func main() {
 		base32Cmd,
 		base16Cmd,
 		bitFieldCmd,
+		cronWcCmd,
 		frozenMinersCmd,
 		keyinfoCmd,
 		jwtCmd,

From 5351db9da723adafc02e8dfd861e6153ad74b8c6 Mon Sep 17 00:00:00 2001
From: ZenGround0 <ZenGround0@users.noreply.github.com>
Date: Thu, 6 May 2021 10:17:25 -0400
Subject: [PATCH 2/2] Lint

---
 cmd/lotus-shed/cron-count.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/cmd/lotus-shed/cron-count.go b/cmd/lotus-shed/cron-count.go
index 91e7ab31396..79fd6ec42cc 100644
--- a/cmd/lotus-shed/cron-count.go
+++ b/cmd/lotus-shed/cron-count.go
@@ -91,7 +91,7 @@ func countDeadlineCrons(c *cli.Context) error {
 	if err != nil {
 		return err
 	}
-	for addr, _ := range activeMiners {
+	for addr := range activeMiners {
 		fmt.Printf("%s\n", addr)
 	}