import { MarketPrice, MarketPriceSDKType } from "./market_price";
import * as _m0 from "protobufjs/minimal";
import { DeepPartial } from "../../helpers";
/** StreamPriceUpdate provides information on a price update. */

export interface StreamPriceUpdate {
  /** The `Id` of the `Market`. */
  marketId: number;
  /** The updated price. */

  price?: MarketPrice;
  /** Snapshot indicates if the response is from a snapshot of the price. */

  snapshot: boolean;
}
/** StreamPriceUpdate provides information on a price update. */

export interface StreamPriceUpdateSDKType {
  market_id: number;
  price?: MarketPriceSDKType;
  snapshot: boolean;
}

function createBaseStreamPriceUpdate(): StreamPriceUpdate {
  return {
    marketId: 0,
    price: undefined,
    snapshot: false
  };
}

export const StreamPriceUpdate = {
  encode(message: StreamPriceUpdate, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
    if (message.marketId !== 0) {
      writer.uint32(8).uint32(message.marketId);
    }

    if (message.price !== undefined) {
      MarketPrice.encode(message.price, writer.uint32(18).fork()).ldelim();
    }

    if (message.snapshot === true) {
      writer.uint32(24).bool(message.snapshot);
    }

    return writer;
  },

  decode(input: _m0.Reader | Uint8Array, length?: number): StreamPriceUpdate {
    const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
    let end = length === undefined ? reader.len : reader.pos + length;
    const message = createBaseStreamPriceUpdate();

    while (reader.pos < end) {
      const tag = reader.uint32();

      switch (tag >>> 3) {
        case 1:
          message.marketId = reader.uint32();
          break;

        case 2:
          message.price = MarketPrice.decode(reader, reader.uint32());
          break;

        case 3:
          message.snapshot = reader.bool();
          break;

        default:
          reader.skipType(tag & 7);
          break;
      }
    }

    return message;
  },

  fromPartial(object: DeepPartial<StreamPriceUpdate>): StreamPriceUpdate {
    const message = createBaseStreamPriceUpdate();
    message.marketId = object.marketId ?? 0;
    message.price = object.price !== undefined && object.price !== null ? MarketPrice.fromPartial(object.price) : undefined;
    message.snapshot = object.snapshot ?? false;
    return message;
  }

};