package main import ( "context" "fmt" "math/rand" "os" "time" "github.com/filecoin-project/go-state-types/crypto" "github.com/filecoin-project/go-address" "github.com/filecoin-project/lotus/api" "github.com/filecoin-project/lotus/build" "github.com/filecoin-project/lotus/chain/types" lcli "github.com/filecoin-project/lotus/cli" "github.com/urfave/cli/v2" ) func main() { app := &cli.App{ Name: "chain-noise", Usage: "Generate some spam transactions in the network", Flags: []cli.Flag{ &cli.StringFlag{ Name: "repo", EnvVars: []string{"LOTUS_PATH"}, Hidden: true, Value: "~/.lotus", // TODO: Consider XDG_DATA_HOME }, }, Commands: []*cli.Command{runCmd}, } if err := app.Run(os.Args); err != nil { fmt.Println("Error: ", err) os.Exit(1) } } var runCmd = &cli.Command{ Name: "run", Action: func(cctx *cli.Context) error { addr, err := address.NewFromString(cctx.Args().First()) if err != nil { return err } api, closer, err := lcli.GetFullNodeAPI(cctx) if err != nil { return err } defer closer() ctx := lcli.ReqContext(cctx) return sendSmallFundsTxs(ctx, api, addr, 5) }, } func sendSmallFundsTxs(ctx context.Context, api api.FullNode, from address.Address, rate int) error { var sendSet []address.Address for i := 0; i < 20; i++ { naddr, err := api.WalletNew(ctx, crypto.SigTypeSecp256k1) if err != nil { return err } sendSet = append(sendSet, naddr) } tick := build.Clock.Ticker(time.Second / time.Duration(rate)) for { select { case <-tick.C: msg := &types.Message{ From: from, To: sendSet[rand.Intn(20)], Value: types.NewInt(1), } smsg, err := api.MpoolPushMessage(ctx, msg, nil) if err != nil { return err } fmt.Println("Message sent: ", smsg.Cid()) case <-ctx.Done(): return nil } } }