Skip to content

Commit 4bf5e0c

Browse files
authored
chore: fix typo in subscription naming (#13086)
Fix typo in subscription naming Fix a few typos in code and remove redundant type declarations.
1 parent a95be3b commit 4bf5e0c

File tree

3 files changed

+7
-7
lines changed

3 files changed

+7
-7
lines changed

cli/util/api.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -409,7 +409,7 @@ type GetFullNodeOptions struct {
409409

410410
type GetFullNodeOption func(*GetFullNodeOptions)
411411

412-
func FullNodeWithEthSubscribtionHandler(sh api.EthSubscriber) GetFullNodeOption {
412+
func FullNodeWithEthSubscriptionHandler(sh api.EthSubscriber) GetFullNodeOption {
413413
return func(opts *GetFullNodeOptions) {
414414
opts.EthSubHandler = sh
415415
}

cmd/lotus-gateway/main.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -176,12 +176,12 @@ var runCmd = &cli.Command{
176176
v1SubHnd := gateway.NewEthSubHandler()
177177
v2SubHnd := gateway.NewEthSubHandler()
178178

179-
v1, closerV1, err := lcli.GetFullNodeAPIV1(cctx, cliutil.FullNodeWithEthSubscribtionHandler(v1SubHnd))
179+
v1, closerV1, err := lcli.GetFullNodeAPIV1(cctx, cliutil.FullNodeWithEthSubscriptionHandler(v1SubHnd))
180180
if err != nil {
181181
return err
182182
}
183183
defer closerV1()
184-
v2, closerV2, err := lcli.GetFullNodeAPIV2(cctx, cliutil.FullNodeWithEthSubscribtionHandler(v2SubHnd))
184+
v2, closerV2, err := lcli.GetFullNodeAPIV2(cctx, cliutil.FullNodeWithEthSubscriptionHandler(v2SubHnd))
185185
if err != nil {
186186
return err
187187
}

node/modules/eth.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -202,7 +202,7 @@ func MakeEthEventsExtended(cfg config.EventsConfig, enableEthRPC bool) func(EthE
202202
lctx := helpers.LifecycleCtx(params.MetricsCtx, params.Lifecycle)
203203

204204
var (
205-
subscribtionCtx context.Context = lctx
205+
subscriptionCtx = lctx
206206
chainStore eth.ChainStore = params.ChainStore
207207
stateManager eth.StateManager = params.StateManager
208208
chainIndexer index.Indexer = params.Indexer
@@ -211,14 +211,14 @@ func MakeEthEventsExtended(cfg config.EventsConfig, enableEthRPC bool) func(EthE
211211
memPoolFilterManager *filter.MemPoolFilterManager
212212
filterStore filter.FilterStore
213213
subscriptionManager *eth.EthSubscriptionManager
214-
maxFilterHeightRange abi.ChainEpoch = abi.ChainEpoch(cfg.MaxFilterHeightRange)
214+
maxFilterHeightRange = abi.ChainEpoch(cfg.MaxFilterHeightRange)
215215
)
216216

217217
if !enableEthRPC {
218218
// all event functionality is disabled
219219
// the historic filter API relies on the real time one
220220
return eth.NewEthEventsAPI(
221-
subscribtionCtx,
221+
subscriptionCtx,
222222
chainStore,
223223
stateManager,
224224
chainIndexer,
@@ -238,7 +238,7 @@ func MakeEthEventsExtended(cfg config.EventsConfig, enableEthRPC bool) func(EthE
238238
eventFilterManager = params.EventFilterManager
239239

240240
ee := eth.NewEthEventsAPI(
241-
subscribtionCtx,
241+
subscriptionCtx,
242242
chainStore,
243243
stateManager,
244244
chainIndexer,

0 commit comments

Comments
 (0)