main.go

package main

import (
	"fmt"
	"log"
	"os"
	"time"

	eos "github.com/eoscanada/eos-go"
	"github.com/eoscanada/eos-go/system"
)

// Define EOS_CLAIMER_KEY (with the private key that is allowed to
// call `eosio::claimrewards`)
//
// Define EOS_CLAIMER_PERMISSION if the permission of the
// EOS_CLAIMER_OWNER account is not `active` (because you linkauth'd
// the action to another permission.
//
// Define EOS_CLAIMER_OWNER which is your BP account.
//
// Define EOS_CLAIMER_URL to a reachable endpoint where to send
// transactions.

func main() {
	if os.Getenv("EOS_CLAIMER_URL") == "" {
		log.Fatalln("EOS_CLAIMER_URL not set: make sure you set all of the required env vars. See main.go for details.")
	}

	api := eos.New(os.Getenv("EOS_CLAIMER_URL"))

	keyBag := eos.NewKeyBag()
	for _, key := range []string{
		os.Getenv("EOS_CLAIMER_KEY"),
	} {
		if err := keyBag.Add(key); err != nil {
			log.Fatalln("Couldn't load private key specified by env var EOS_CLAIMER_KEY:", err)
		}
	}

	api.SetSigner(keyBag)

	act := system.NewClaimRewards(eos.AccountName(os.Getenv("EOS_CLAIMER_OWNER")))
	if perm := os.Getenv("EOS_CLAIMER_PERMISSION"); perm != "" {
		act.Authorization[0].Permission = eos.PermissionName(perm)
	}

	var sleep time.Duration
	for {
		time.Sleep(sleep)
		sleep = 10 * time.Second

		log.Println("Submitting claimrewards")
		actionResp, err := api.SignPushActions(act)
		if err != nil {
			fmt.Println("ERROR sending claimrewards:", err)
		} else {
			fmt.Println("SUCCESSFUL RESP:", actionResp)
		}
	}
}