Publish tx data

[Thomasvdam]

Explanation of Changes

The main thing I'm unsure about is how we pass the codec around, is this idiomatic Golang or is there a cleaner way to do this?

Made a small improvement in the ListenFinalizeBlock handler by preallocating the slice since we should know up front how long it is going to be.

Testing

You can 'just' set up the plugin, queue emulator, and start a local node. Once it's running submit a transaction (for the example I used a bank transfer, but I have tried a bunch of different ones). You should start see a "tx" message getting added to the queue:

{"level":"info","msg":"2024-03-27 17:23:39: Queue: local-updates.fifo, Message: {\"type\":\"tx\",\"data\":{\"hash\":\"1D3D58C0F82BCDFC1B4A2FDC43CD73C9DC6EC5C48AB78265072736A21B9A2392\",\"time\":\"2024-03-27T17:23:31.469443Z\",\"tx\":{\"body\":{\"messages\":[{\"@type\":\"/cosmos.bank.v1beta1.MsgSend\",\"from_address\":\"seda12rype4zl8wxcgqwl237fll6hvufkgcj8kwnuah\",\"to_address\":\"seda12rype4zl8wxcgqwl237fll6hvufkgcj8kwnuah\",\"amount\":[{\"denom\":\"aseda\",\"amount\":\"10000000000000000000\"}]}],\"memo\":\"\",\"timeout_height\":\"0\",\"extension_options\":[],\"non_critical_extension_options\":[]},\"auth_info\":{\"signer_infos\":[{\"public_key\":{\"@type\":\"/cosmos.crypto.secp256k1.PubKey\",\"key\":\"AyR0Wa9Qq1PJAzxCI75KAQQQYTpBDXGGWBkjy14QVDxM\"},\"mode_info\":{\"single\":{\"mode\":\"SIGN_MODE_DIRECT\"}},\"sequence\":\"17\"}],\"fee\":{\"amount\":[],\"gas_limit\":\"200000\",\"payer\":\"\",\"granter\":\"\"},\"tip\":null},\"signatures\":[\"PstBgoDh52267uZMmMzUYot+UpWNuhlkCd+Jj0Dnhd5km5A29Mjd3KwRLLeegK84W3C6hGfNmG28bSzniknnmw==\"]},\"result\":{\"code\":0,\"data\":\"EiYKJC9jb3Ntb3MuYmFuay52MWJldGExLk1zZ1NlbmRSZXNwb25zZQ==\",\"log\":\"\",\"info\":\"\",\"gas_wanted\":\"200000\",\"gas_used\":\"54728\",\"events\":[{\"type\":\"tx\",\"attributes\":[{\"key\":\"fee\",\"value\":\"\",\"index\":true},{\"key\":\"fee_payer\",\"value\":\"seda12rype4zl8wxcgqwl237fll6hvufkgcj8kwnuah\",\"index\":true}]},{\"type\":\"tx\",\"attributes\":[{\"key\":\"acc_seq\",\"value\":\"seda12rype4zl8wxcgqwl237fll6hvufkgcj8kwnuah/17\",\"index\":true}]},{\"type\":\"tx\",\"attributes\":[{\"key\":\"signature\",\"value\":\"PstBgoDh52267uZMmMzUYot+UpWNuhlkCd+Jj0Dnhd5km5A29Mjd3KwRLLeegK84W3C6hGfNmG28bSzniknnmw==\",\"index\":true}]},{\"type\":\"message\",\"attributes\":[{\"key\":\"action\",\"value\":\"/cosmos.bank.v1beta1.MsgSend\",\"index\":true},{\"key\":\"sender\",\"value\":\"seda12rype4zl8wxcgqwl237fll6hvufkgcj8kwnuah\",\"index\":true},{\"key\":\"module\",\"value\":\"bank\",\"index\":true},{\"key\":\"msg_index\",\"value\":\"0\",\"index\":true}]},{\"type\":\"coin_spent\",\"attributes\":[{\"key\":\"spender\",\"value\":\"seda12rype4zl8wxcgqwl237fll6hvufkgcj8kwnuah\",\"index\":true},{\"key\":\"amount\",\"value\":\"10000000000000000000aseda\",\"index\":true},{\"key\":\"msg_index\",\"value\":\"0\",\"index\":true}]},{\"type\":\"coin_received\",\"attributes\":[{\"key\":\"receiver\",\"value\":\"seda12rype4zl8wxcgqwl237fll6hvufkgcj8kwnuah\",\"index\":true},{\"key\":\"amount\",\"value\":\"10000000000000000000aseda\",\"index\":true},{\"key\":\"msg_index\",\"value\":\"0\",\"index\":true}]},{\"type\":\"transfer\",\"attributes\":[{\"key\":\"recipient\",\"value\":\"seda12rype4zl8wxcgqwl237fll6hvufkgcj8kwnuah\",\"index\":true},{\"key\":\"sender\",\"value\":\"seda12rype4zl8wxcgqwl237fll6hvufkgcj8kwnuah\",\"index\":true},{\"key\":\"amount\",\"value\":\"10000000000000000000aseda\",\"index\":true},{\"key\":\"msg_index\",\"value\":\"0\",\"index\":true}]},{\"type\":\"message\",\"attributes\":[{\"key\":\"sender\",\"value\":\"seda12rype4zl8wxcgqwl237fll6hvufkgcj8kwnuah\",\"index\":true},{\"key\":\"msg_index\",\"value\":\"0\",\"index\":true}]}],\"codespace\":\"\"}}}\n","time":"2024-03-27T17:23:39Z"}

Just the message:

{
  "type": "tx",
  "data": {
    "hash": "1D3D58C0F82BCDFC1B4A2FDC43CD73C9DC6EC5C48AB78265072736A21B9A2392",
    "time": "2024-03-27T17:23:31.469443Z",
    "tx": {
      "body": {
        "messages": [
          {
            "@type": "/cosmos.bank.v1beta1.MsgSend",
            "from_address": "seda12rype4zl8wxcgqwl237fll6hvufkgcj8kwnuah",
            "to_address": "seda12rype4zl8wxcgqwl237fll6hvufkgcj8kwnuah",
            "amount": [{ "denom": "aseda", "amount": "10000000000000000000" }]
          }
        ],
        "memo": "",
        "timeout_height": "0",
        "extension_options": [],
        "non_critical_extension_options": []
      },
      "auth_info": {
        "signer_infos": [
          {
            "public_key": {
              "@type": "/cosmos.crypto.secp256k1.PubKey",
              "key": "AyR0Wa9Qq1PJAzxCI75KAQQQYTpBDXGGWBkjy14QVDxM"
            },
            "mode_info": { "single": { "mode": "SIGN_MODE_DIRECT" } },
            "sequence": "17"
          }
        ],
        "fee": {
          "amount": [],
          "gas_limit": "200000",
          "payer": "",
          "granter": ""
        },
        "tip": null
      },
      "signatures": [
        "PstBgoDh52267uZMmMzUYot+UpWNuhlkCd+Jj0Dnhd5km5A29Mjd3KwRLLeegK84W3C6hGfNmG28bSzniknnmw=="
      ]
    },
    "result": {
      "code": 0,
      "data": "EiYKJC9jb3Ntb3MuYmFuay52MWJldGExLk1zZ1NlbmRSZXNwb25zZQ==",
      "log": "",
      "info": "",
      "gas_wanted": "200000",
      "gas_used": "54728",
      "events": [
        {
          "type": "tx",
          "attributes": [
            { "key": "fee", "value": "", "index": true },
            {
              "key": "fee_payer",
              "value": "seda12rype4zl8wxcgqwl237fll6hvufkgcj8kwnuah",
              "index": true
            }
          ]
        },
        {
          "type": "tx",
          "attributes": [
            {
              "key": "acc_seq",
              "value": "seda12rype4zl8wxcgqwl237fll6hvufkgcj8kwnuah/17",
              "index": true
            }
          ]
        },
        {
          "type": "tx",
          "attributes": [
            {
              "key": "signature",
              "value": "PstBgoDh52267uZMmMzUYot+UpWNuhlkCd+Jj0Dnhd5km5A29Mjd3KwRLLeegK84W3C6hGfNmG28bSzniknnmw==",
              "index": true
            }
          ]
        },
        {
          "type": "message",
          "attributes": [
            {
              "key": "action",
              "value": "/cosmos.bank.v1beta1.MsgSend",
              "index": true
            },
            {
              "key": "sender",
              "value": "seda12rype4zl8wxcgqwl237fll6hvufkgcj8kwnuah",
              "index": true
            },
            { "key": "module", "value": "bank", "index": true },
            { "key": "msg_index", "value": "0", "index": true }
          ]
        },
        {
          "type": "coin_spent",
          "attributes": [
            {
              "key": "spender",
              "value": "seda12rype4zl8wxcgqwl237fll6hvufkgcj8kwnuah",
              "index": true
            },
            {
              "key": "amount",
              "value": "10000000000000000000aseda",
              "index": true
            },
            { "key": "msg_index", "value": "0", "index": true }
          ]
        },
        {
          "type": "coin_received",
          "attributes": [
            {
              "key": "receiver",
              "value": "seda12rype4zl8wxcgqwl237fll6hvufkgcj8kwnuah",
              "index": true
            },
            {
              "key": "amount",
              "value": "10000000000000000000aseda",
              "index": true
            },
            { "key": "msg_index", "value": "0", "index": true }
          ]
        },
        {
          "type": "transfer",
          "attributes": [
            {
              "key": "recipient",
              "value": "seda12rype4zl8wxcgqwl237fll6hvufkgcj8kwnuah",
              "index": true
            },
            {
              "key": "sender",
              "value": "seda12rype4zl8wxcgqwl237fll6hvufkgcj8kwnuah",
              "index": true
            },
            {
              "key": "amount",
              "value": "10000000000000000000aseda",
              "index": true
            },
            { "key": "msg_index", "value": "0", "index": true }
          ]
        },
        {
          "type": "message",
          "attributes": [
            {
              "key": "sender",
              "value": "seda12rype4zl8wxcgqwl237fll6hvufkgcj8kwnuah",
              "index": true
            },
            { "key": "msg_index", "value": "0", "index": true }
          ]
        }
      ],
      "codespace": ""
    }
  }
}

Related PRs and Issues

Closes: #223

[gluax]

P sure how you are dealing with the codec right now is idiomatic go, at least afaik.

[hacheigriega]

I think Golang idiomatic way is to shorten local variables whenever possible. So like msg instead of msgs. (I double-checked with geth repo 😀)