package testclient_test

import (
	"context"
	"fmt"
	"math/big"
	"time"

	"github.com/brianvoe/gofakeit/v6"
	"github.com/ethereum/go-ethereum/accounts/abi/bind"
	"github.com/ethereum/go-ethereum/common"
	. "github.com/stretchr/testify/assert"
	"github.com/synapsecns/sanguine/agents/contracts/test/testclient"
)

func (h TestClientSuite) TestSendMessage() {
	messageSentSink := make(chan *testclient.TestClientMessageSent)
	sub, err := h.testClientContract.WatchMessageSent(&bind.WatchOpts{Context: h.GetTestContext()}, messageSentSink)
	Nil(h.T(), err)

	txContextTestClientOrigin := h.testBackend.GetTxContext(h.GetTestContext(), h.testClientMetadata.OwnerPtr())

	optimisticSeconds := uint32(10)
	recipient := common.BigToAddress(big.NewInt(gofakeit.Int64()))
	body := []byte{byte(gofakeit.Uint32())}
	gasLimit := uint64(10000000)
	version := uint32(1)
	testClientOnOriginTx, err := h.testClientContract.SendMessage(txContextTestClientOrigin.TransactOpts, h.destinationID, recipient, optimisticSeconds, gasLimit, version, body)
	h.Nil(err)
	h.testBackend.WaitForConfirmation(h.GetTestContext(), testClientOnOriginTx)

	watchCtx, cancel := context.WithTimeout(h.GetTestContext(), time.Second*10)
	defer cancel()

	select {
	// check for errors and fail
	case <-watchCtx.Done():
		h.T().Error(h.T(), fmt.Errorf("test context completed %w", h.GetTestContext().Err()))
	case <-sub.Err():
		h.T().Error(h.T(), sub.Err())
	// get sent event
	case item := <-messageSentSink:
		h.NotNil(item)
		break
	}
}