diff --git a/decentralized-api/internal/server/public/get_epoch.go b/decentralized-api/internal/server/public/get_epoch.go index 98f50341ac..7ca756df93 100644 --- a/decentralized-api/internal/server/public/get_epoch.go +++ b/decentralized-api/internal/server/public/get_epoch.go @@ -18,7 +18,7 @@ type EpochResponse struct { ActiveConfirmationPocEvent *types.ConfirmationPoCEvent `json:"active_confirmation_poc_event,omitempty"` } -// LatestEpochDto, had to indroduced it, because types.Epoch doesn't serialize when +// LatestEpochDto, had to introduce it, because types.Epoch doesn't serialize when // Index and PocStartBlockHeight are 0 type LatestEpochDto struct { Index uint64 `json:"index"` diff --git a/decentralized-api/internal/validation/proposal.md b/decentralized-api/internal/validation/proposal.md index d52394c459..05eda7b7f9 100644 --- a/decentralized-api/internal/validation/proposal.md +++ b/decentralized-api/internal/validation/proposal.md @@ -49,7 +49,7 @@ The nodes might be unavailable and we will lose the validation request. 1. Create a `InferenceValidationTaskStorage` interface and it's first implementation: `InMemoryInferenceValidationTaskStorage` 2. In `event_listener.go` instead of immediately spawning a goroutine, we will store the validation request in the `InferenceValidationTaskStorage` -3. `InferenceValidator` now will spawn a woker pool that will periodically check the tasks in the storage and execute them when nodes are available +3. `InferenceValidator` now will spawn a worker pool that will periodically check the tasks in the storage and execute them when nodes are available # 3. Persistent validation task storage diff --git a/inference-chain/app/ante_validation.go b/inference-chain/app/ante_validation.go index 5499589898..13a9e451c9 100644 --- a/inference-chain/app/ante_validation.go +++ b/inference-chain/app/ante_validation.go @@ -38,7 +38,7 @@ func (d ValidationEarlyRejectDecorator) checkValidationMsg(ctx sdk.Context, msg "inferenceId", msg.InferenceId, ) // It may filter legit transaction if the node is behind (node lag / state sync), - // But hope that it will be propogated by other nodes + // But hope that it will be propagated by other nodes // TODO: In the next release, skip the filter on CheckTx, and enforce only on DeliverTx. return inferencetypes.ErrInferenceNotFound } diff --git a/inference-chain/cmd/inferenced/cmd/sync_snapshots.go b/inference-chain/cmd/inferenced/cmd/sync_snapshots.go index bf6989b938..b4058c279f 100644 --- a/inference-chain/cmd/inferenced/cmd/sync_snapshots.go +++ b/inference-chain/cmd/inferenced/cmd/sync_snapshots.go @@ -117,7 +117,7 @@ func SetTrustedBlock() *cobra.Command { } if err = updateTrustedBlock(configFilePath, trustedBlockHeight, trustedBlockHash); err != nil { - return fmt.Errorf("failed to set trusted block wih block_height %v and block_hash %v: %w", trustedBlockHeight, trustedBlockHash, err) + return fmt.Errorf("failed to set trusted block with block_height %v and block_hash %v: %w", trustedBlockHeight, trustedBlockHash, err) } fmt.Printf("Successfully set the statesync.trust_height with value %v and statesync.trust_hash with value %v", trustedBlockHeight, trustedBlockHash) return nil diff --git a/inference-chain/x/inference/keeper/bridge_native.go b/inference-chain/x/inference/keeper/bridge_native.go index 48d81b1407..a715e2c354 100644 --- a/inference-chain/x/inference/keeper/bridge_native.go +++ b/inference-chain/x/inference/keeper/bridge_native.go @@ -38,7 +38,7 @@ func (k Keeper) ReleaseFromEscrow(ctx sdk.Context, toAddr sdk.AccAddress, amount // IsBridgeContractAddress checks if the given contract address matches any registered bridge addresses for the specific chain func (k Keeper) IsBridgeContractAddress(ctx context.Context, chainId, contractAddress string) bool { - // Set already forces toLower, so we can directy index + // Set already forces toLower, so we can directly index normalizedInput := strings.ToLower(contractAddress) has, err := k.BridgeContractAddresses.Has(ctx, collections.Join(chainId, normalizedInput)) diff --git a/inference-chain/x/inference/keeper/bridge_transaction_split_test.go b/inference-chain/x/inference/keeper/bridge_transaction_split_test.go index 5f6903a7bb..df87b32dc1 100644 --- a/inference-chain/x/inference/keeper/bridge_transaction_split_test.go +++ b/inference-chain/x/inference/keeper/bridge_transaction_split_test.go @@ -51,7 +51,7 @@ func TestSetBridgeTransaction_StripsAndSyncsValidators(t *testing.T) { require.True(t, found) require.ElementsMatch(t, []string{"valA", "valB", "valC"}, got.Validators) - // Delete every KeySet entry and verify Get's Validators is now empty. + // Delete every KeySet entry and verify Gets Validators is now empty. // If Validators had been stored inline in the base, deleting the // KeySet wouldn't clear them — catching a regression that leaves // inline entries behind. diff --git a/inference-chain/x/inference/keeper/developer_stats_aggregation.go b/inference-chain/x/inference/keeper/developer_stats_aggregation.go index 0d98260763..6494d03ae0 100644 --- a/inference-chain/x/inference/keeper/developer_stats_aggregation.go +++ b/inference-chain/x/inference/keeper/developer_stats_aggregation.go @@ -245,7 +245,7 @@ func (k Keeper) GetSummaryLastNEpochsByDeveloper(ctx context.Context, developerA if val := byTimeStore.Get(timeKey); val != nil { err := k.cdc.Unmarshal(val, &statsByTime) if err != nil { - k.LogError("unabled to unmarhsal DeveloperStatsByTime", types.Participants, "key", iterator.Key(), "error", err) + k.LogError("unable to unmarshal DeveloperStatsByTime", types.Participants, "key", iterator.Key(), "error", err) continue } summary.TokensUsed += int64(statsByTime.Inference.TotalTokenCount) diff --git a/inference-chain/x/inference/keeper/msg_server_validation.go b/inference-chain/x/inference/keeper/msg_server_validation.go index 2410ebcc6c..3ca772671b 100644 --- a/inference-chain/x/inference/keeper/msg_server_validation.go +++ b/inference-chain/x/inference/keeper/msg_server_validation.go @@ -420,7 +420,7 @@ func (k msgServer) inferenceIsBeforeClaimsSet(ctx context.Context, inference typ // This would be before IsStartOfPocStage return true, "Validation during inference epoch" } - // Somewhere inbetween StartOfPocStage and SetNewValidatorsStage + // Somewhere in between StartOfPocStage and SetNewValidatorsStage // ActiveParticipants are set during EndOfPoCValidationStage, which is also when we set claims _, found = k.GetActiveParticipants(ctx, upcomingEpoch.Index) if found { diff --git a/inference-chain/x/inference/keeper/poc_period_validation.go b/inference-chain/x/inference/keeper/poc_period_validation.go index 01690a7c35..889a912e66 100644 --- a/inference-chain/x/inference/keeper/poc_period_validation.go +++ b/inference-chain/x/inference/keeper/poc_period_validation.go @@ -20,7 +20,7 @@ func (k Keeper) CheckPoCMessageTooLate(ctx sdk.Context, startBlockHeight int64, if startBlockHeight > currentBlockHeight { // It may filter legit transaction if the node is behind (node lag / state sync), - // But hope that it will be propogated by other nodes + // But hope that it will be propagated by other nodes // TODO: In the next release, skip the filter on CheckTx, and enforce only on DeliverTx. k.Logger().Debug( "[ValidatePocPeriod] POC submission is too early", diff --git a/inference-chain/x/inference/types/message_register_model.go b/inference-chain/x/inference/types/message_register_model.go index 099f0e739e..c6eebb752c 100644 --- a/inference-chain/x/inference/types/message_register_model.go +++ b/inference-chain/x/inference/types/message_register_model.go @@ -20,7 +20,7 @@ func NewMsgRegisterModel(authority string, proposedBy string, id string, unitsOf func (msg *MsgRegisterModel) ValidateBasic() error { _, err := sdk.AccAddressFromBech32(msg.Authority) if err != nil { - return errorsmod.Wrapf(sdkerrors.ErrInvalidAddress, "invalid authrority address (%s)", err) + return errorsmod.Wrapf(sdkerrors.ErrInvalidAddress, "invalid authority address (%s)", err) } _, err = sdk.AccAddressFromBech32(msg.ProposedBy) if err != nil { diff --git a/testermint/README.md b/testermint/README.md index d8768c6b4f..91025d3f14 100644 --- a/testermint/README.md +++ b/testermint/README.md @@ -231,5 +231,5 @@ From this point on, you will gain a lot of additional functionality when opening - Most Log lines are tagged with `subsystem=` identifiers - Example: `subsystem=Stages` shows all epoch transition logs - Find subsystem definitions in: `inference-chain/x/inference/types/logging.go` -You can also use the consts in `logging.go` to see exactly where specific subsytems are used. +You can also use the consts in `logging.go` to see exactly where specific subsystems are used. --- diff --git a/testermint/mcp_log_examiner/src/main/resources/guides/logging_overview.md b/testermint/mcp_log_examiner/src/main/resources/guides/logging_overview.md index c498abd7e2..136cb8e9b2 100644 --- a/testermint/mcp_log_examiner/src/main/resources/guides/logging_overview.md +++ b/testermint/mcp_log_examiner/src/main/resources/guides/logging_overview.md @@ -39,7 +39,7 @@ Subsystem is especially useful. It represents the specific subsystem inside of t - Nodes - related to updating ML nodes for an API - Config - related to updating or retrieving config values - EventProcessing - related to processing events coming from the chain to the API -- Upgrades - related to upgrading components of the systen +- Upgrades - related to upgrading components of the system - Server - related to the API server (requests, responses, etc) - Training - related to AI training - Stages - related to moving between stages of an Epoch diff --git a/testermint/mcp_log_examiner/src/main/resources/guides/step_by_step.md b/testermint/mcp_log_examiner/src/main/resources/guides/step_by_step.md index 2f4d0536be..90882fd43f 100644 --- a/testermint/mcp_log_examiner/src/main/resources/guides/step_by_step.md +++ b/testermint/mcp_log_examiner/src/main/resources/guides/step_by_step.md @@ -16,7 +16,7 @@ a problem with config or bad state. But if it's in the test itself, the errors c unexpected problem such as an exception or an assertion failure, as well as many other issues. **HOWEVER**: There are usually a few errors expected here and there, especially when any part of the system -is rebooted or reinitialized. Additionally, Upgrade tests will have several errors in them regarging +is rebooted or reinitialized. Additionally, Upgrade tests will have several errors in them regarding missing upgrade code, which is what TRIGGERS the upgrade. ### Known Errors: (ignore) #### Related to restarting the chain: diff --git a/testermint/src/main/kotlin/DockerGroup.kt b/testermint/src/main/kotlin/DockerGroup.kt index 012bdfb66a..ebf7b6cdd7 100644 --- a/testermint/src/main/kotlin/DockerGroup.kt +++ b/testermint/src/main/kotlin/DockerGroup.kt @@ -557,7 +557,7 @@ fun initCluster( Logger.error(e, "Failed to initialize cluster, rebooting") throw e } - Logger.error(e, "Error initializing cluser, retrying") + Logger.error(e, "Error initializing cluster, retrying") logSection("Exception during cluster initialization, retrying") return initCluster(joinCount, finalConfig, reboot = true) } diff --git a/testermint/src/test/kotlin/CollateralTests.kt b/testermint/src/test/kotlin/CollateralTests.kt index 73ceffab7e..d85eddfccd 100644 --- a/testermint/src/test/kotlin/CollateralTests.kt +++ b/testermint/src/test/kotlin/CollateralTests.kt @@ -84,7 +84,7 @@ class CollateralTests : TestermintTest() { participant.withdrawCollateral(depositAmount) participant.node.waitForNextBlock(2) - logSection("Verifying withdrawl") + logSection("Verifying withdrawal") val activeCollateral = participant.queryCollateral(participantAddress) assertThat(activeCollateral.amount).isNull() val balanceAfterWithdraw = participant.getBalance(participantAddress) diff --git a/testermint/src/test/kotlin/StreamVestingTests.kt b/testermint/src/test/kotlin/StreamVestingTests.kt index 2b6c2e9fc8..9f1a5285a4 100644 --- a/testermint/src/test/kotlin/StreamVestingTests.kt +++ b/testermint/src/test/kotlin/StreamVestingTests.kt @@ -240,7 +240,7 @@ class StreamVestingTests : TestermintTest() { logHighlight("Total aggregated vesting amount: $aggregatedTotalAmount ngonka") // The aggregated amount should be greater than a single reward - // TODO: unfortunatelly, it's not true, because we can't guarantee that the rewards are equal each time to the same validator + // TODO: unfortunately, it's not true, because we can't guarantee that the rewards are equal each time to the same validator // assertThat(aggregatedTotalAmount).isGreaterThan(totalVestingAmount) logSection("=== LEGACY REWARD SYSTEM VESTING TEST COMPLETED ===")