module/txpool: added Status()

module/txpool/status.go

@@ -0,0 +1,37 @@
+package txpool
+
+import (
+	"encoding/json"
+
+	"github.com/ethereum/go-ethereum/common/hexutil"
+	"github.com/lmittmann/w3/internal/module"
+	"github.com/lmittmann/w3/w3types"
+)
+
+// Status requests the txpool status.
+func Status() w3types.CallerFactory[StatusResponse] {
+	return module.NewFactory[StatusResponse](
+		"txpool_status",
+		nil,
+	)
+}
+
+type StatusResponse struct {
+	Pending uint
+	Queued  uint
+}
+
+func (s *StatusResponse) UnmarshalJSON(input []byte) error {
+	type statusResponse struct {
+		Pending hexutil.Uint `json:"pending"`
+		Queued  hexutil.Uint `json:"queued"`
+	}
+
+	var dec statusResponse
+	if err := json.Unmarshal(input, &dec); err != nil {
+		return err
+	}
+	s.Pending = uint(dec.Pending)
+	s.Queued = uint(dec.Queued)
+	return nil
+}

module/txpool/status_test.go

@@ -0,0 +1,20 @@
+package txpool_test
+
+import (
+	"testing"
+
+	"github.com/lmittmann/w3/module/txpool"
+	"github.com/lmittmann/w3/rpctest"
+)
+
+func TestStatus(t *testing.T) {
+	tests := []rpctest.TestCase[txpool.StatusResponse]{
+		{
+			Golden:  "status",
+			Call:    txpool.Status(),
+			WantRet: txpool.StatusResponse{Pending: 10, Queued: 7},
+		},
+	}
+
+	rpctest.RunTestCases(t, tests)
+}

module/txpool/testdata/status.golden

@@ -0,0 +1,2 @@
+> {"jsonrpc":"2.0","id":1,"method":"txpool_status"}
+< {"jsonrpc":"2.0","id":1,"result":{"pending":"0xa","queued":"0x7"}}