schema.graphql

type Stream @entity {
  id: ID!
  sender: String!
  receiver: String!
  token: String!
  flowRate: BigInt!
  txHash: String!
  createdAt: BigInt!
  updatedAt: BigInt!
}

type StreamRevision @entity {
  """
  ID composed of: keccak256(abi.encode(sender,receiver))-tokenAddress
  """
  id: ID!
  revisionIndex: Int!
  periodRevisionIndex: Int!

  """
  The "most recently alive" stream between a sender and receiver.
  Note: The `revisionIndex` property may not be the same as the `revisionIndex` of `mostRecentStream`. Which means `mostRecentStream` has been closed and no new stream has been opened.
  """
  mostRecentStream: Stream!
}