You can filter information on a particular DEX by mentioning them in the ProtocolFamily field. For example the below query retrieves all trades in real-time from the Phoenix DEX.

subscription {
  Solana {
    DEXTrades(where: {Trade: {Dex: {ProtocolFamily: {is: "Phoenix"}}}}) {
      Trade {
        Dex {
          ProgramAddress
          ProtocolFamily
          ProtocolName
        }
        Buy {
          Account {
            Address
          }
          Amount
          Currency {
            MintAddress
            Decimals
            Symbol
            ProgramAddress
            Name
          }
          PriceAgainstSellCurrency: Price
        }
        Sell {
          Account {
            Address
          }
          Amount
          Currency {
            MintAddress
            Decimals
            Symbol
            Name
          }
          PriceAgainstBuyCurrency: Price
        }
      }
      Block {
        Time
        Height
      }
      Transaction {
        Signature
        FeePayer
        Signer
      }
    }
  }
}

We have a 3-minute candle data based on token trading volume on centralized exchanges, so we refresh the USD price every 3 minutes.

subscription {
  Solana {
    DEXTrades(where: {
      Trade: {
        PriceAsymmetry: {
          le: 0.5
        }
      }
    }) {
      Block {
        Time
      }
      Trade {
        PriceAsymmetry
        Buy {
          Amount
          AmountInUSD
          PriceInUSD
          Currency {Symbol}
        }
        Sell {
          Amount
          AmountInUSD
          PriceInUSD
          Currency {Symbol}
        }
      }
    }
  }
}

Check more examples in Examples section

• Taking insights from our V1 APIs, we've introduced an improved price asymmetry metric to filter outliers. Read more here

1. trigger_on attribute for subscription default value set now to all. 2Transaction_Time field for mempool Transaction now returns the transaction time not in numeric, but in ISO8601 format up to 1 nanosecond ( 9 digits after the seconds ),

"2006-01-02T15:04:05.999999999Z"

• Added a new Token Holder API for archive dataset
• Added new indexes Gini Coefficient, Nakamoto Index, Theil Index
• Removed distinctBy filter to avoid any confusions over its usage.
• Compulsorily require field in sum aggregation , for example: sum(of: Balance_Amount)
• Added Support for aggregates in descendingByField

1. Filtering of arrays introduced filtering by arrays
2. Arguments / Returns usage in filters added

1. DEX Trades By Token introduced with OHLC example
2. Time/Date interval added

1. selectWhere for details
2. renamed where attribute on metrics to if

1. Arguments and return value for Calls and Events are now represented as arrays of structures. Use union to read values of arguments. Refer to arguments for details on data structures.
2. Names of objects in GraphQL schema are simplified and no more contain UUID identifiers. It simplifies working with schema and allows to use fragments easier
3. Set of bug fixed for using arrays, fragments and others

The first authors will be Bitquery developers, and later all our users and clients are welcome to participate.