Add Aptos ViewRequest support for CRE workflows

capabilities/blockchain/aptos/client_sdk.go

@@ -0,0 +1,208 @@
+
+// Capability ID: aptos:ChainSelector:<chainSelector>@1.0.0, method "View".
+
+package aptos
+
+import (
+	"errors"
+	"fmt"
+	"strconv"
+
+	"google.golang.org/protobuf/encoding/protowire"
+	"google.golang.org/protobuf/proto"
+	"google.golang.org/protobuf/types/known/anypb"
+
+	sdkpb "github.com/smartcontractkit/chainlink-protos/cre/go/sdk"
+	"github.com/smartcontractkit/cre-sdk-go/cre"
+)
+
+type Client struct {
+	ChainSelector uint64
+}
+
+func (c *Client) WriteReport(runtime cre.Runtime, input *WriteReportRequest) cre.Promise[*WriteReportReply] {
+	if input == nil {
+		return cre.PromiseFromResult[*WriteReportReply](nil, errors.New("nil WriteReportRequest"))
+	}
+
+	wrapped := &anypb.Any{}
+	err := anypb.MarshalFrom(wrapped, input, proto.MarshalOptions{Deterministic: true})
+	if err != nil {
+		return cre.PromiseFromResult[*WriteReportReply](nil, err)
+	}
+
+	capID := "aptos:ChainSelector:" + strconv.FormatUint(c.ChainSelector, 10) + "@1.0.0"
+	return cre.Then(runtime.CallCapability(&sdkpb.CapabilityRequest{
+		Id:      capID,
+		Payload: wrapped,
+		Method:  "WriteReport",
+	}), func(i *sdkpb.CapabilityResponse) (_ *WriteReportReply, err error) {
+		defer func() {
+			if r := recover(); r != nil {
+				err = fmt.Errorf("aptos write decode panic: %v", r)
+			}
+		}()
+		if i == nil {
+			return nil, errors.New("nil capability response")
+		}
+		switch payload := i.Response.(type) {
+		case *sdkpb.CapabilityResponse_Error:
+			return nil, errors.New(payload.Error)
+		case *sdkpb.CapabilityResponse_Payload:
+			if payload.Payload == nil {
+				return nil, errors.New("nil capability payload")
+			}
+			return decodeWriteReportReply(payload.Payload.Value)
+		default:
+			return nil, errors.New("unexpected response type")
+		}
+	})
+}
+
+func (c *Client) View(runtime cre.Runtime, input *ViewRequest) cre.Promise[*ViewReply] {
+	if input == nil {
+		return cre.PromiseFromResult[*ViewReply](nil, errors.New("nil ViewRequest"))
+	}
+
+	wrapped := &anypb.Any{}
+	err := anypb.MarshalFrom(wrapped, input, proto.MarshalOptions{Deterministic: true})
+	if err != nil {
+		return cre.PromiseFromResult[*ViewReply](nil, err)
+	}
+	capID := "aptos:ChainSelector:" + strconv.FormatUint(c.ChainSelector, 10) + "@1.0.0"
+	capCallResponse := cre.Then(runtime.CallCapability(&sdkpb.CapabilityRequest{
+		Id:      capID,
+		Payload: wrapped,
+		Method:  "View",
+	}), func(i *sdkpb.CapabilityResponse) (_ *ViewReply, err error) {
+		defer func() {
+			if r := recover(); r != nil {
+				err = fmt.Errorf("aptos view decode panic: %v", r)
+			}
+		}()
+		if i == nil {
+			return nil, errors.New("nil capability response")
+		}
+		switch payload := i.Response.(type) {
+		case *sdkpb.CapabilityResponse_Error:
+			return nil, errors.New(payload.Error)
+		case *sdkpb.CapabilityResponse_Payload:
+			if payload.Payload == nil {
+				return nil, errors.New("nil capability payload")
+			}
+			return decodeViewReply(payload.Payload.Value)
+		default:
+			return nil, errors.New("unexpected response type")
+		}
+	})
+	return capCallResponse
+}
+
+// decodeWriteReportReply decodes capabilities.blockchain.aptos.v1alpha.WriteReportReply
+// via protobuf wire parsing to avoid runtime reflection panics under WASM.
+func decodeWriteReportReply(b []byte) (*WriteReportReply, error) {
+	out := &WriteReportReply{}
+	for len(b) > 0 {
+		num, typ, n := protowire.ConsumeTag(b)
+		if n < 0 {
+			return nil, fmt.Errorf("decode WriteReportReply tag: %v", protowire.ParseError(n))
+		}
+		b = b[n:]
+		switch num {
+		case 1: // tx_status enum (varint)
+			if typ != protowire.VarintType {
+				return nil, fmt.Errorf("decode WriteReportReply.tx_status: unexpected wire type %d", typ)
+			}
+			v, m := protowire.ConsumeVarint(b)
+			if m < 0 {
+				return nil, fmt.Errorf("decode WriteReportReply.tx_status varint: %v", protowire.ParseError(m))
+			}
+			out.TxStatus = TxStatus(v)
+			b = b[m:]
+		case 2: // receiver_contract_execution_status enum (varint)
+			if typ != protowire.VarintType {
+				return nil, fmt.Errorf("decode WriteReportReply.receiver_contract_execution_status: unexpected wire type %d", typ)
+			}
+			v, m := protowire.ConsumeVarint(b)
+			if m < 0 {
+				return nil, fmt.Errorf("decode WriteReportReply.receiver_contract_execution_status varint: %v", protowire.ParseError(m))
+			}
+			status := ReceiverContractExecutionStatus(v)
+			out.ReceiverContractExecutionStatus = &status
+			b = b[m:]
+		case 3: // tx_hash string
+			if typ != protowire.BytesType {
+				return nil, fmt.Errorf("decode WriteReportReply.tx_hash: unexpected wire type %d", typ)
+			}
+			v, m := protowire.ConsumeBytes(b)
+			if m < 0 {
+				return nil, fmt.Errorf("decode WriteReportReply.tx_hash bytes: %v", protowire.ParseError(m))
+			}
+			txHash := string(v)
+			out.TxHash = &txHash
+			b = b[m:]
+		case 4: // transaction_fee varint
+			if typ != protowire.VarintType {
+				return nil, fmt.Errorf("decode WriteReportReply.transaction_fee: unexpected wire type %d", typ)
+			}
+			v, m := protowire.ConsumeVarint(b)
+			if m < 0 {
+				return nil, fmt.Errorf("decode WriteReportReply.transaction_fee varint: %v", protowire.ParseError(m))
+			}
+			fee := uint64(v)
+			out.TransactionFee = &fee
+			b = b[m:]
+		case 5: // error_message string
+			if typ != protowire.BytesType {
+				return nil, fmt.Errorf("decode WriteReportReply.error_message: unexpected wire type %d", typ)
+			}
+			v, m := protowire.ConsumeBytes(b)
+			if m < 0 {
+				return nil, fmt.Errorf("decode WriteReportReply.error_message bytes: %v", protowire.ParseError(m))
+			}
+			msg := string(v)
+			out.ErrorMessage = &msg
+			b = b[m:]
+		default:
+			m := protowire.ConsumeFieldValue(num, typ, b)
+			if m < 0 {
+				return nil, fmt.Errorf("decode WriteReportReply skip field %d: %v", num, protowire.ParseError(m))
+			}
+			b = b[m:]
+		}
+	}
+	return out, nil
+}
+
+// decodeViewReply decodes capabilities.blockchain.aptos.v1alpha.ViewReply using
+// protobuf wire parsing to avoid runtime reflection panics seen under WASM.
+// ViewReply currently contains a single bytes field: data = 1.
+func decodeViewReply(b []byte) (*ViewReply, error) {
+	out := &ViewReply{}
+	for len(b) > 0 {
+		num, typ, n := protowire.ConsumeTag(b)
+		if n < 0 {
+			return nil, fmt.Errorf("decode ViewReply tag: %v", protowire.ParseError(n))
+		}
+		b = b[n:]
+		switch num {
+		case 1: // data bytes
+			if typ != protowire.BytesType {
+				return nil, fmt.Errorf("decode ViewReply.data: unexpected wire type %d", typ)
+			}
+			v, m := protowire.ConsumeBytes(b)
+			if m < 0 {
+				return nil, fmt.Errorf("decode ViewReply.data bytes: %v", protowire.ParseError(m))
+			}
+			out.Data = append([]byte(nil), v...)
+			b = b[m:]
+		default:
+			m := protowire.ConsumeFieldValue(num, typ, b)
+			if m < 0 {
+				return nil, fmt.Errorf("decode ViewReply skip field %d: %v", num, protowire.ParseError(m))
+			}
+			b = b[m:]
+		}
+	}
+	return out, nil
+}

capabilities/blockchain/aptos/client_sdk_test.go

@@ -0,0 +1,36 @@
+package aptos
+
+import (
+	"testing"
+
+	"github.com/stretchr/testify/require"
+	"google.golang.org/protobuf/proto"
+)
+
+func TestDecodeWriteReportReply_NewWireShape(t *testing.T) {
+	t.Parallel()
+
+	txHash := "0xabc123"
+	txFee := uint64(42)
+	errMsg := "receiver execution failed"
+	replyBytes, err := proto.Marshal(&WriteReportReply{
+		TxStatus:                        TxStatus_TX_STATUS_ABORTED,
+		ReceiverContractExecutionStatus: ReceiverContractExecutionStatus_RECEIVER_CONTRACT_EXECUTION_STATUS_REVERTED.Enum(),
+		TxHash:                          &txHash,
+		TransactionFee:                  &txFee,
+		ErrorMessage:                    &errMsg,
+	})
+	require.NoError(t, err)
+
+	reply, err := decodeWriteReportReply(replyBytes)
+	require.NoError(t, err)
+	require.Equal(t, TxStatus_TX_STATUS_ABORTED, reply.TxStatus)
+	require.NotNil(t, reply.ReceiverContractExecutionStatus)
+	require.Equal(t, ReceiverContractExecutionStatus_RECEIVER_CONTRACT_EXECUTION_STATUS_REVERTED, *reply.ReceiverContractExecutionStatus)
+	require.NotNil(t, reply.TxHash)
+	require.Equal(t, txHash, *reply.TxHash)
+	require.NotNil(t, reply.TransactionFee)
+	require.Equal(t, txFee, *reply.TransactionFee)
+	require.NotNil(t, reply.ErrorMessage)
+	require.Equal(t, errMsg, *reply.ErrorMessage)
+}

capabilities/blockchain/aptos/generate.go

@@ -0,0 +1,2 @@
+//go:generate go run ./generate
+package aptos

capabilities/blockchain/aptos/generate/main.go

@@ -0,0 +1,23 @@
+package main
+
+import (
+	"github.com/smartcontractkit/chainlink-protos/cre/go/installer/pkg"
+	"github.com/smartcontractkit/cre-sdk-go/generator/protos"
+)
+
+func main() {
+	gen, err := protos.NewGeneratorAndInstallToolsForCapability()
+	if err != nil {
+		panic(err)
+	}
+	gen.Plugins = []pkg.Plugin{pkg.GoPlugin}
+	if err := gen.Generate(&pkg.CapabilityConfig{
+		Category:      "blockchain",
+		Pkg:           "aptos",
+		MajorVersion:  1,
+		PreReleaseTag: "alpha",
+		Files:         []string{"client.proto"},
+	}); err != nil {
+		panic(err)
+	}
+}

capabilities/blockchain/aptos/go.mod

@@ -0,0 +1,20 @@
+module github.com/smartcontractkit/cre-sdk-go/capabilities/blockchain/aptos
+
+go 1.25.3
+
+require (
+	github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260318054214-bad7873faa1c
+	github.com/smartcontractkit/cre-sdk-go v1.5.0
+	github.com/stretchr/testify v1.11.1
+	google.golang.org/protobuf v1.36.11
+)
+
+require (
+	github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect
+	github.com/go-viper/mapstructure/v2 v2.4.0 // indirect
+	github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect
+	github.com/shopspring/decimal v1.4.0 // indirect
+	gopkg.in/yaml.v3 v3.0.1 // indirect
+)
+
+replace github.com/smartcontractkit/cre-sdk-go => ../../..

capabilities/blockchain/aptos/go.sum

@@ -0,0 +1,20 @@
+github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc h1:U9qPSI2PIWSS1VwoXQT9A3Wy9MM3WgvqSxFWenqJduM=
+github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/go-viper/mapstructure/v2 v2.4.0 h1:EBsztssimR/CONLSZZ04E8qAkxNYq4Qp9LvH92wZUgs=
+github.com/go-viper/mapstructure/v2 v2.4.0/go.mod h1:oJDH3BJKyqBA2TXFhDsKDGDTlndYOZ6rGS0BRZIxGhM=
+github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8=
+github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU=
+github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 h1:Jamvg5psRIccs7FGNTlIRMkT8wgtp5eCXdBlqhYGL6U=
+github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/shopspring/decimal v1.4.0 h1:bxl37RwXBklmTi0C79JfXCEBD1cqqHt0bbgBAGFp81k=
+github.com/shopspring/decimal v1.4.0/go.mod h1:gawqmDU56v4yIKSwfBSFip1HdCCXN8/+DMd9qYNcwME=
+github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260318054214-bad7873faa1c h1:m+XflniQiuMPvcKtiWpnsqpOiRNcONKrhF5zwpR2QJM=
+github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260318054214-bad7873faa1c/go.mod h1:Jqt53s27Tr0jDl8mdBXg1xhu6F8Fci8JOuq43tgHOM8=
+github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U=
+github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
+google.golang.org/protobuf v1.36.11 h1:fV6ZwhNocDyBLK0dj+fg8ektcVegBBuEolpbTQyBNVE=
+google.golang.org/protobuf v1.36.11/go.mod h1:HTf+CrKn2C3g5S8VImy6tdcUvCska2kB7j23XfzDpco=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=