schema.graphql

type OracleMessage @entity {
  "Transaction hash the message was posted"
  id: ID!
  "JSON string payload of oracle message. Users can filter on topic field and use the IPFS hash to pull and parse QoS data."
  payload: String!
  "Epoch timestamp (in seconds) the message was posted to chain"
  createdAt: BigInt!
  "Block number the message was posted to chain"
  createdAtBlock: BigInt!
  "Whether the message is valid or not"
  valid: Boolean!
  "Error message. Null if no error"
  errorMessage: String
}

type MessageDataPoint @entity {
  id: ID!

  rawData: String!

  ipfsHash: String!

  allocationDataPointCount: BigInt!

  queryDataPointCount: BigInt!

  timestamp: BigInt!

  dataPoints: [DataPoint!]! @derivedFrom(field: "messageDataPoint")

  oracleMessage: OracleMessage!
}

interface DataPoint @entity {
  id: ID!

  messageDataPoint: MessageDataPoint!

  rawData: String!
}

# This entity represents a GATEWAY wide daily data point for all qos metrics for a given indexer
type IndexerDailyDataPoint @entity {
  id: ID!

  indexer: Indexer

  dataPoints: [AllocationDataPoint!]! @derivedFrom(field:"indexerDailyDataPoint")

  dayStart: BigInt!
  dayEnd: BigInt!
  dayNumber: Int!
  dataPointCount: BigInt!

  indexer_url: String!
  indexer_wallet: String!

  # Parsed fields
  avg_indexer_blocks_behind: BigDecimal!
  avg_indexer_latency_ms: BigDecimal!
  avg_query_fee: BigDecimal!
  end_epoch: BigDecimal!
  max_indexer_blocks_behind: BigDecimal!
  max_indexer_latency_ms: BigDecimal!
  max_query_fee: BigDecimal!
  num_indexer_200_responses: BigDecimal!
  proportion_indexer_200_responses: BigDecimal!
  query_count: BigDecimal!
  start_epoch: BigDecimal!
  total_query_fees: BigDecimal!
  subgraph_deployment_ipfs_hash: String!
  chain_id: String
  gateway_id: String
}

type AllocationDataPoint implements DataPoint @entity {
  id: ID!

  messageDataPoint: MessageDataPoint!

  rawData: String!

  indexer: Indexer

  subgraphDeployment: SubgraphDeployment

  allocationDailyDataPoint: AllocationDailyDataPoint

  indexerDailyDataPoint: IndexerDailyDataPoint

  # Copied from the daily data point entity
  dayStart: BigInt!
  dayEnd: BigInt!
  dayNumber: Int!

  # Parsed fields
  avg_indexer_blocks_behind: BigDecimal!
  avg_indexer_latency_ms: BigDecimal!
  avg_query_fee: BigDecimal!
  end_epoch: BigDecimal!
  indexer_url: String!
  indexer_wallet: String!
  max_indexer_blocks_behind: BigDecimal!
  max_indexer_latency_ms: BigDecimal!
  max_query_fee: BigDecimal!
  num_indexer_200_responses: BigDecimal!
  proportion_indexer_200_responses: BigDecimal!
  query_count: BigDecimal!
  start_epoch: BigDecimal!
  stdev_indexer_latency_ms: BigDecimal!
  subgraph_deployment_ipfs_hash: String!
  total_query_fees: BigDecimal!
  chain_id: String
  gateway_id: String
}

# This entity represents the GATEWAY wide daily data point for all qos metrics for a given indexer on a particular deployment
type AllocationDailyDataPoint @entity {
  id: ID!

  indexer: Indexer

  subgraphDeployment: SubgraphDeployment

  dataPoints: [AllocationDataPoint!]! @derivedFrom(field:"allocationDailyDataPoint")

  dayStart: BigInt!
  dayEnd: BigInt!
  dayNumber: Int!
  dataPointCount: BigInt!

  indexer_url: String!
  indexer_wallet: String!

  # Parsed fields
  avg_indexer_blocks_behind: BigDecimal!
  avg_indexer_latency_ms: BigDecimal!
  avg_query_fee: BigDecimal!
  end_epoch: BigDecimal!
  max_indexer_blocks_behind: BigDecimal!
  max_indexer_latency_ms: BigDecimal!
  max_query_fee: BigDecimal!
  num_indexer_200_responses: BigDecimal!
  proportion_indexer_200_responses: BigDecimal!
  query_count: BigDecimal!
  start_epoch: BigDecimal!
  total_query_fees: BigDecimal!
  subgraph_deployment_ipfs_hash: String!
  chain_id: String
  gateway_id: String
}

type QueryDataPoint implements DataPoint @entity {
  id: ID!

  messageDataPoint: MessageDataPoint!

  rawData: String!

  subgraphDeployment: SubgraphDeployment

  dailyDataPoint: QueryDailyDataPoint

  # Copied from the daily data point entity
  dayStart: BigInt!
  dayEnd: BigInt!
  dayNumber: Int!

  #Parsed fields
  avg_gateway_latency_ms: BigDecimal!
  avg_query_fee: BigDecimal!
  end_epoch: BigDecimal!
  gateway_query_success_rate: BigDecimal!
  max_gateway_latency_ms: BigDecimal!
  max_query_fee: BigDecimal!
  most_recent_query_ts: BigDecimal!
  query_count: BigDecimal!
  start_epoch: BigDecimal!
  stdev_gateway_latency_ms: BigDecimal!
  subgraph_deployment_ipfs_hash: String!
  total_query_fees: BigDecimal!
  user_attributed_error_rate: BigDecimal!
  chain_id: String
  gateway_id: String
}

# This entity represents the GATEWAY wide daily data qos metrics for a given deployment
type QueryDailyDataPoint @entity {
  id: ID!

  dayStart: BigInt!
  dayEnd: BigInt!
  dayNumber: Int!
  dataPointCount: BigInt!

  subgraphDeployment: SubgraphDeployment

  dataPoints: [QueryDataPoint!]! @derivedFrom(field:"dailyDataPoint")

  avg_gateway_latency_ms: BigDecimal!
  avg_query_fee: BigDecimal!
  end_epoch: BigDecimal!
  gateway_query_success_rate: BigDecimal!
  max_gateway_latency_ms: BigDecimal!
  max_query_fee: BigDecimal!
  most_recent_query_ts: BigDecimal!
  query_count: BigDecimal!
  start_epoch: BigDecimal!
  total_query_fees: BigDecimal!
  user_attributed_error_rate: BigDecimal!
  chain_id: String
  gateway_id: String
}

type Indexer @entity {
  "ETH address"
  id: ID!

  indexerDailyDataPoints: [IndexerDailyDataPoint!]! @derivedFrom(field: "indexer")

  allocationDataPoints: [AllocationDataPoint!]! @derivedFrom(field: "indexer")

  allocationDailyDataPoints: [AllocationDailyDataPoint!]! @derivedFrom(field: "indexer")
}

type SubgraphDeployment @entity {
  "IPFS Hash of the deployment"
  id: ID!

  queryDataPoints: [QueryDataPoint!]! @derivedFrom(field: "subgraphDeployment")

  queryDailyDataPoints: [QueryDailyDataPoint!]! @derivedFrom(field: "subgraphDeployment")

  allocationDataPoints: [AllocationDataPoint!]! @derivedFrom(field: "subgraphDeployment")

  allocationDailyDataPoints: [AllocationDailyDataPoint!]! @derivedFrom(field: "subgraphDeployment")
}