laciferin2024
commented
4 weeks ago package web3
import (
"context"
"github.com/ethereum/go-ethereum/accounts/abi/bind"
"github.com/ethereum/go-ethereum/event"
"github.com/rs/zerolog/log"
"gitlab.com/darts-network/darts/pkg/system"
"gitlab.com/darts-network/darts/pkg/web3/bindings/storage"
)
type StorageEventChannels struct {
dealStateChangeChan chan *storage.StorageDealStateChange
dealStateChangeSubs []func(storage.StorageDealStateChange)
}
func NewStorageEventChannels() *StorageEventChannels {
return &StorageEventChannels{
dealStateChangeChan: make(chan *storage.StorageDealStateChange),
dealStateChangeSubs: []func(storage.StorageDealStateChange){},
}
}
func (s *StorageEventChannels) Start(
sdk *Web3SDK,
ctx context.Context,
cm *system.CleanupManager,
) (err error) {
defer func() {
eventErrorHandler(err)
}()
blockNumber, err := sdk.getBlockNumber()
if err != nil {
return err
}
var dealStateChangeSub event.Subscription
connectDealStateChangeSub := func() (event.Subscription, error) {
log.Debug().
Str("storage->connect", "DealStateChange").
Msgf("")
return sdk.Contracts.Storage.WatchDealStateChange(
&bind.WatchOpts{Start: &blockNumber, Context: ctx},
s.dealStateChangeChan,
)
}
dealStateChangeSub, err = connectDealStateChangeSub()
if err != nil {
log.Error().Err(err).Msgf("subscribe to dealStateChanges failed")
return err
}
go func() {
<-ctx.Done()
dealStateChangeSub.Unsubscribe()
}()
for {
select {
case event := <-s.dealStateChangeChan:
log.Debug().
Str("storage->event", "DealStateChange").
Msgf("%+v", event)
for _, handler := range s.dealStateChangeSubs {
go handler(*event)
}
case err := <-dealStateChangeSub.Err():
dealStateChangeSub.Unsubscribe()
dealStateChangeSub, err = connectDealStateChangeSub()
if err != nil {
return err
}
}
}
}
func (t *StorageEventChannels) SubscribeDealStateChange(handler func(storage.StorageDealStateChange)) {
t.dealStateChangeSubs = append(t.dealStateChangeSubs, handler)
}
Describe the bug
The dePin I built is working on ethereum but fails to work e2e on skale. After debugging around for 11 hours, I discovered that all evm operations are successfully. Deals are agreed but events are not emitted from the Storage Contract
This issue is the storage contract: https://aware-fake-trim-testnet.explorer.testnet.skalenodes.com/address/0x298e6C04a8cB0569cF02427CBF4511E8398a422B?tab=txs
Its a secondary contract managed by Controller contract.
WE have services listening to the DealStateChange events.
But none of the services are getting those events.
Additionally deals are getting stored and updated successfully via these txs: https://aware-fake-trim-testnet.explorer.testnet.skalenodes.com/address/0x7dF66926b83Bda6E9D95267D51a38EAb9579e93B
Screenshots
The gud news is that evm is working just fine, its updating deals. I manually updated deals without contract modifications and its all working but for e2e working we will need the nodes to emit the events of storage and payment contracts!