@@ -19,7 +19,7 @@ import (
1919 "github.com/sygmaprotocol/sygma-core/relayer/proposal"
2020)
2121
22- type SprinterRemoteCollateralMessageHandler struct {
22+ type SprinterCreditMessageHandler struct {
2323 chainID uint64
2424
2525 liquidators map [common.Address ]common.Address
@@ -32,16 +32,16 @@ type SprinterRemoteCollateralMessageHandler struct {
3232 sigChn chan any
3333}
3434
35- func NewSprinterRemoteCollateralMessageHandler (
35+ func NewSprinterCreditMessageHandler (
3636 chainID uint64 ,
3737 liquidators map [common.Address ]common.Address ,
3838 coordinator Coordinator ,
3939 host host.Host ,
4040 comm comm.Communication ,
4141 fetcher signing.SaveDataFetcher ,
4242 sigChn chan any ,
43- ) * SprinterRemoteCollateralMessageHandler {
44- return & SprinterRemoteCollateralMessageHandler {
43+ ) * SprinterCreditMessageHandler {
44+ return & SprinterCreditMessageHandler {
4545 chainID : chainID ,
4646 coordinator : coordinator ,
4747 liquidators : liquidators ,
@@ -54,8 +54,8 @@ func NewSprinterRemoteCollateralMessageHandler(
5454
5555// HandleMessage signs the liquidation request if the transaction
5656// is going to the Liquidator contract.
57- func (h * SprinterRemoteCollateralMessageHandler ) HandleMessage (m * message.Message ) (* proposal.Proposal , error ) {
58- data := m .Data .(* SprinterRemoteCollateralData )
57+ func (h * SprinterCreditMessageHandler ) HandleMessage (m * message.Message ) (* proposal.Proposal , error ) {
58+ data := m .Data .(* SprinterCreditData )
5959
6060 log .Info ().Msgf ("Handling sprinter remote collateral message %+v" , data )
6161
@@ -113,26 +113,26 @@ func (h *SprinterRemoteCollateralMessageHandler) HandleMessage(m *message.Messag
113113 return nil , nil
114114}
115115
116- func (h * SprinterRemoteCollateralMessageHandler ) Listen (ctx context.Context ) {
116+ func (h * SprinterCreditMessageHandler ) Listen (ctx context.Context ) {
117117 msgChn := make (chan * comm.WrappedMessage )
118118 subID := h .comm .Subscribe (
119- fmt .Sprintf ("%d-%s-%s" , h .chainID , h .token .Hex (), comm .SprinterRemoteCollateralSessionID ),
120- comm .SprinterRemoteCollateralMsg ,
119+ fmt .Sprintf ("%d-%s-%s" , h .chainID , h .token .Hex (), comm .SprinterCreditSessionID ),
120+ comm .SprinterCreditMsg ,
121121 msgChn )
122122
123123 for {
124124 select {
125125 case wMsg := <- msgChn :
126126 {
127- d := & SprinterRemoteCollateralData {}
127+ d := & SprinterCreditData {}
128128 err := json .Unmarshal (wMsg .Payload , d )
129129 if err != nil {
130130 log .Warn ().Msgf ("Failed unmarshaling across message: %s" , err )
131131 continue
132132 }
133133
134134 d .ErrChn = make (chan error , 1 )
135- msg := NewSprinterRemoteCollateralMessage (d .Source , d .Destination , d )
135+ msg := NewSprinterCreditMessage (d .Source , d .Destination , d )
136136 _ , err = h .HandleMessage (msg )
137137 if err != nil {
138138 log .Err (err ).Msgf ("Failed handling across message %+v because of: %s" , msg , err )
@@ -147,7 +147,7 @@ func (h *SprinterRemoteCollateralMessageHandler) Listen(ctx context.Context) {
147147 }
148148}
149149
150- func (h * SprinterRemoteCollateralMessageHandler ) notify (data * SprinterRemoteCollateralData ) error {
150+ func (h * SprinterCreditMessageHandler ) notify (data * SprinterCreditData ) error {
151151 if data .Coordinator != peer .ID ("" ) {
152152 return nil
153153 }
@@ -161,6 +161,6 @@ func (h *SprinterRemoteCollateralMessageHandler) notify(data *SprinterRemoteColl
161161 return h .comm .Broadcast (
162162 h .host .Peerstore ().Peers (),
163163 msgBytes ,
164- comm .SprinterRemoteCollateralMsg ,
165- fmt .Sprintf ("%d-%s" , h .chainID , comm .SprinterRemoteCollateralSessionID ))
164+ comm .SprinterCreditMsg ,
165+ fmt .Sprintf ("%d-%s" , h .chainID , comm .SprinterCreditSessionID ))
166166}
0 commit comments