poi tracing

graph/build.rs

@@ -13,6 +13,11 @@ fn main() {
  )
  .expect("Failed to compile Firehose proto(s)");
 
+ tonic_build::configure()
+ .out_dir("src/components/tracing")
+ .compile(&["proto/x-ray.proto"], &["proto"])
+ .expect("Failed to compile common proto(s)");
+
  tonic_build::configure()
  .protoc_arg("--experimental_allow_proto3_optional")
  .out_dir("src/substreams")

graph/proto/x-ray.proto

@@ -0,0 +1,119 @@
+syntax = "proto3";
+
+package thegraph.tracing.v1;
+
+message EthereumABIToken {
+ message FixedBytes {
+ uint32 size = 1;
+ bytes items = 2;
+ }
+
+ message FixedArray {
+ uint32 size = 1;
+ repeated EthereumABIToken items = 2;
+ }
+
+ message Array {
+ repeated EthereumABIToken array = 1;
+ }
+
+ oneof value {
+ string address = 1;
+ FixedBytes bytes = 2;
+ int64 int = 3;
+ uint64 uint = 4;
+ bool bool = 5;
+ string str = 6;
+ Array array = 7;
+ Array tuple = 8;
+ }
+}
+
+message EthCallResult {
+ oneof result {
+ string error = 1;
+ EthereumABIToken.Array array = 2;
+ }
+}
+
+message EthereumCall {
+ string contract_name = 1;
+ string contract_address = 2;
+ string function_name = 3;
+ string function_signature = 4;
+ repeated EthereumABIToken function_args = 5;
+ EthCallResult result = 6;
+}
+
+message WasmError {
+ string message = 1;
+ bool deterministic = 2;
+}
+
+message Output {
+ oneof output {
+ EntityChanges entity_changes = 1;
+ WasmError error = 2;
+ }
+}
+
+message Trigger {}
+
+message Input {
+ repeated Trigger triggers = 1;
+ repeated ChainSpecificInput chain_inputs = 2;
+}
+
+message ChainSpecificInput {
+ oneof input{
+ EthereumCall call = 1;
+ }
+}
+
+message Trace {
+ Input inputs = 1;
+ Output output = 2;
+ string poi = 3;
+}
+
+
+message EntityChanges {
+ repeated EntityChange entity_changes = 5;
+}
+
+message EntityChange {
+ string entity = 1;
+ string id = 2;
+ uint64 ordinal = 3;
+ enum Operation {
+ UNSET = 0; // Protobuf default should not be used, this is used so that the consume can ensure that the value was actually specified
+ CREATE = 1;
+ UPDATE = 2;
+ DELETE = 3;
+ }
+ Operation operation = 4;
+ repeated Field fields = 5;
+}
+
+message Value {
+ oneof typed {
+ int32 int32 = 1;
+ string bigdecimal = 2;
+ string bigint = 3;
+ string string = 4;
+ bytes bytes = 5;
+ bool bool = 6;
+
+ Array array = 10;
+ }
+}
+
+message Array {
+ repeated Value value = 1;
+}
+
+message Field {
+ string name = 1;
+ optional Value new_value = 3;
+ optional Value old_value = 5;
+}

graph/src/components/mod.rs

@@ -62,6 +62,8 @@ pub mod versions;
 
 pub mod adapter;
 
+pub mod tracing;
+
 /// A component that receives events of type `T`.
 pub trait EventConsumer<E> {
  /// Get the event sink.

graph/src/components/tracing/mod.rs

@@ -0,0 +1,3 @@
+#[rustfmt::skip]
+#[path = "thegraph.tracing.v1.rs"]
+mod pbtracing;