Method AddPriceEntry

x/oracle/keeper/keeper.go:166–269

AddPriceEntry adds a price from a specific source (e.g., smart contract) This implements multi-source price validation with deviation checks

(ctx sdk.Context, source sdk.Address, id types.DataID, price sdkmath.LegacyDec, timestamp time.Time)

// AddPriceEntry adds a price from a specific source (e.g., smart contract)
// This implements multi-source price validation with deviation checks
func (k *keeper) AddPriceEntry(ctx sdk.Context, source sdk.Address, id types.DataID, price sdkmath.LegacyDec, timestamp time.Time) error {
	sourceID, authorized := k.getAuthorizedSource(ctx, source.String())
	if !authorized {
		return errorsmod.Wrapf(
			sdkerrors.ErrUnauthorized,
			"source %s is not authorized oracle provider",
			source.String(),
		)
	}

	if id.Denom != sdkutil.DenomAkt {
		return errorsmod.Wrapf(
			sdkerrors.ErrInvalidRequest,
			"unsupported denom %s", id.Denom,
		)
	}

	if id.BaseDenom != sdkutil.DenomUSD {
		return errorsmod.Wrapf(
			sdkerrors.ErrInvalidRequest,
			"unsupported base denom %s", id.BaseDenom,
		)
	}

	if !price.IsPositive() {
		return errorsmod.Wrap(
			sdkerrors.ErrInvalidRequest,
			"price must be positive",
		)
	}

	latestID, err := k.loadLatestPriceID(ctx, types.PriceDataID{
		Source:    sourceID,
		Denom:     id.Denom,
		BaseDenom: id.BaseDenom,
	})

	if err != nil {
		if !errors.Is(err, collections.ErrNotFound) {
			return err
		}

		// applies only to very first record.
		// set here reasonable window
		latestID.Timestamp = ctx.BlockTime().Add(-(time.Second * 12))
	}

	if latestID.Timestamp.After(timestamp) {
		return errorsmod.Wrap(
			sdkerrors.ErrInvalidRequest,
			"price timestamp is too old",
		)
	}

	seq, err := k.priceRecordSeq(ctx, types.DataID{
		Denom:     id.Denom,
		BaseDenom: id.BaseDenom,
	})