Skip to content
Permalink

Comparing changes

This is a direct comparison between two commits made in this repository or its related repositories. View the default comparison for this range or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: graphprotocol/graph-node
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: 9658d8ca96502d2ca58701b180f89c2fc9b60fe3
Choose a base ref
..
head repository: graphprotocol/graph-node
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: cca4d6fb16439d374ba9dca037035e9e88c3d9c2
Choose a head ref
Showing with 12,175 additions and 5,566 deletions.
  1. +1 −0 .github/workflows/ci.yml
  2. +487 −448 Cargo.lock
  3. +30 −5 Cargo.toml
  4. +113 −0 NEWS.md
  5. +2 −2 chain/arweave/src/chain.rs
  6. +2 −2 chain/cosmos/src/chain.rs
  7. +1 −2 chain/ethereum/examples/firehose.rs
  8. +3 −3 chain/ethereum/src/chain.rs
  9. +4 −4 chain/ethereum/src/ingestor.rs
  10. +41 −37 chain/ethereum/src/network.rs
  11. +1 −1 chain/ethereum/src/transport.rs
  12. +2 −2 chain/near/src/chain.rs
  13. +0 −18 chain/starknet/Cargo.toml
  14. +0 −7 chain/starknet/build.rs
  15. +0 −37 chain/starknet/proto/starknet.proto
  16. +0 −27 chain/starknet/src/adapter.rs
  17. +0 −524 chain/starknet/src/chain.rs
  18. +0 −35 chain/starknet/src/codec.rs
  19. +0 −407 chain/starknet/src/data_source.rs
  20. +0 −88 chain/starknet/src/felt.rs
  21. +0 −10 chain/starknet/src/lib.rs
  22. +0 −70 chain/starknet/src/protobuf/zklend.starknet.r#type.v1.rs
  23. +0 −106 chain/starknet/src/runtime/abi.rs
  24. +0 −100 chain/starknet/src/runtime/generated.rs
  25. +0 −3 chain/starknet/src/runtime/mod.rs
  26. +0 −105 chain/starknet/src/trigger.rs
  27. +1 −2 chain/substreams/examples/substreams.rs
  28. +4 −4 chain/substreams/src/block_ingestor.rs
  29. +3 −3 chain/substreams/src/chain.rs
  30. +5 −1 chain/substreams/src/trigger.rs
  31. +1 −5 core/Cargo.toml
  32. +14 −0 core/graphman/Cargo.toml
  33. +81 −0 core/graphman/src/commands/deployment/info.rs
  34. +3 −0 core/graphman/src/commands/deployment/mod.rs
  35. +83 −0 core/graphman/src/commands/deployment/pause.rs
  36. +83 −0 core/graphman/src/commands/deployment/resume.rs
  37. +1 −0 core/graphman/src/commands/mod.rs
  38. +148 −0 core/graphman/src/deployment.rs
  39. +19 −0 core/graphman/src/error.rs
  40. +84 −0 core/graphman/src/execution_tracker.rs
  41. +15 −0 core/graphman/src/lib.rs
  42. +10 −0 core/graphman_store/Cargo.toml
  43. +127 −0 core/graphman_store/src/lib.rs
  44. +86 −61 core/src/polling_monitor/ipfs_service.rs
  45. +7 −3 core/src/subgraph/context/mod.rs
  46. +3 −0 core/src/subgraph/inputs.rs
  47. +164 −100 core/src/subgraph/instance_manager.rs
  48. +0 −18 core/src/subgraph/registrar.rs
  49. +89 −22 core/src/subgraph/runner.rs
  50. +25 −23 docker/Dockerfile
  51. +213 −0 docs/graphman-graphql-api.md
  52. +5 −2 graph/Cargo.toml
  53. +43 −7 graph/proto/firehose.proto
  54. +10 −9 graph/src/blockchain/block_stream.rs
  55. +5 −4 graph/src/blockchain/firehose_block_ingestor.rs
  56. +6 −10 graph/src/blockchain/mod.rs
  57. +6 −0 graph/src/blockchain/types.rs
  58. +0 −898 graph/src/components/adapter.rs
  59. +124 −201 graph/src/components/link_resolver/ipfs.rs
  60. +53 −0 graph/src/components/metrics/registry.rs
  61. +65 −6 graph/src/components/metrics/subgraph.rs
  62. +1 −2 graph/src/components/mod.rs
  63. +121 −0 graph/src/components/network_provider/chain_identifier_store.rs
  64. +235 −0 graph/src/components/network_provider/extended_blocks_check.rs
  65. +473 −0 graph/src/components/network_provider/genesis_hash_check.rs
  66. +24 −0 graph/src/components/network_provider/mod.rs
  67. +17 −0 graph/src/components/network_provider/network_details.rs
  68. +44 −0 graph/src/components/network_provider/provider_check.rs
  69. +957 −0 graph/src/components/network_provider/provider_manager.rs
  70. +20 −2 graph/src/components/store/entity_cache.rs
  71. +1 −1 graph/src/components/store/traits.rs
  72. +7 −1 graph/src/components/subgraph/instance.rs
  73. +1 −1 graph/src/data/query/mod.rs
  74. +28 −5 graph/src/data/query/result.rs
  75. +22 −2 graph/src/data/store/scalar/bigdecimal.rs
  76. +8 −0 graph/src/data/store/scalar/bytes.rs
  77. +12 −2 graph/src/data/store/scalar/timestamp.rs
  78. +1 −7 graph/src/data/subgraph/mod.rs
  79. +2 −2 graph/src/data/subgraph/status.rs
  80. +18 −0 graph/src/data/value.rs
  81. +5 −1 graph/src/data_source/causality_region.rs
  82. +11 −13 graph/src/data_source/offchain.rs
  83. +3 −9 graph/src/data_source/tests.rs
  84. +2 −4 graph/src/endpoint.rs
  85. +39 −0 graph/src/env/mod.rs
  86. +11 −0 graph/src/env/store.rs
  87. +46 −0 graph/src/firehose/endpoint_info/client.rs
  88. +96 −0 graph/src/firehose/endpoint_info/info_response.rs
  89. +5 −0 graph/src/firehose/endpoint_info/mod.rs
  90. +97 −237 graph/src/firehose/endpoints.rs
  91. +1 −0 graph/src/firehose/mod.rs
  92. +363 −0 graph/src/firehose/sf.firehose.v2.rs
  93. +195 −0 graph/src/ipfs/client.rs
  94. +236 −0 graph/src/ipfs/content_path.rs
  95. +134 −0 graph/src/ipfs/error.rs
  96. +494 −0 graph/src/ipfs/gateway_client.rs
  97. +126 −0 graph/src/ipfs/mod.rs
  98. +257 −0 graph/src/ipfs/pool.rs
  99. +214 −0 graph/src/ipfs/retry_policy.rs
  100. +458 −0 graph/src/ipfs/rpc_client.rs
  101. +199 −0 graph/src/ipfs/server_address.rs
  102. +76 −0 graph/src/ipfs/test_utils.rs
  103. +0 −330 graph/src/ipfs_client.rs
  104. +2 −3 graph/src/lib.rs
  105. +17 −2 graphql/src/runner.rs
  106. +4 −1 node/Cargo.toml
  107. +78 −50 node/src/bin/manager.rs
  108. +13 −144 node/src/chain.rs
  109. +2 −2 node/src/config.rs
  110. +86 −19 node/src/main.rs
  111. +4 −4 node/src/manager/commands/chain.rs
  112. +5 −45 node/src/manager/commands/config.rs
  113. +161 −0 node/src/manager/commands/deployment/info.rs
  114. +4 −0 node/src/manager/commands/deployment/mod.rs
  115. +22 −0 node/src/manager/commands/deployment/pause.rs
  116. +32 −0 node/src/manager/commands/deployment/restart.rs
  117. +22 −0 node/src/manager/commands/deployment/resume.rs
  118. +0 −29 node/src/manager/commands/info.rs
  119. +2 −1 node/src/manager/commands/mod.rs
  120. +146 −0 node/src/manager/commands/provider_checks.rs
  121. +28 −9 node/src/manager/commands/run.rs
  122. +1 −71 node/src/manager/deployment.rs
  123. +52 −126 node/src/network_setup.rs
  124. +8 −1 node/src/opt.rs
  125. +1 −1 node/src/store_builder.rs
  126. +6 −3 runtime/test/src/common.rs
  127. +24 −45 runtime/test/src/test.rs
  128. +5 −2 runtime/wasm/src/host_exports.rs
  129. +27 −0 server/graphman/Cargo.toml
  130. +148 −0 server/graphman/src/auth.rs
  131. +31 −0 server/graphman/src/entities/block_hash.rs
  132. +29 −0 server/graphman/src/entities/block_number.rs
  133. +19 −0 server/graphman/src/entities/block_ptr.rs
  134. +8 −0 server/graphman/src/entities/command_kind.rs
  135. +44 −0 server/graphman/src/entities/deployment_info.rs
  136. +46 −0 server/graphman/src/entities/deployment_selector.rs
  137. +37 −0 server/graphman/src/entities/deployment_status.rs
  138. +19 −0 server/graphman/src/entities/deployment_version_selector.rs
  139. +15 −0 server/graphman/src/entities/empty_response.rs
  140. +56 −0 server/graphman/src/entities/execution.rs
  141. +35 −0 server/graphman/src/entities/execution_id.rs
  142. +25 −0 server/graphman/src/entities/mod.rs
  143. +14 −0 server/graphman/src/entities/subgraph_health.rs
  144. +10 −0 server/graphman/src/error.rs
  145. +36 −0 server/graphman/src/handlers/graphql.rs
  146. +6 −0 server/graphman/src/handlers/mod.rs
  147. +6 −0 server/graphman/src/handlers/state.rs
  148. +12 −0 server/graphman/src/lib.rs
  149. +27 −0 server/graphman/src/resolvers/context.rs
  150. +84 −0 server/graphman/src/resolvers/deployment_mutation.rs
  151. +26 −0 server/graphman/src/resolvers/deployment_mutation/create.rs
  152. +18 −0 server/graphman/src/resolvers/deployment_mutation/pause.rs
  153. +27 −0 server/graphman/src/resolvers/deployment_mutation/remove.rs
  154. +51 −0 server/graphman/src/resolvers/deployment_mutation/restart.rs
  155. +18 −0 server/graphman/src/resolvers/deployment_mutation/resume.rs
  156. +29 −0 server/graphman/src/resolvers/deployment_query.rs
  157. +54 −0 server/graphman/src/resolvers/deployment_query/info.rs
  158. +24 −0 server/graphman/src/resolvers/execution_query.rs
  159. +12 −0 server/graphman/src/resolvers/mod.rs
  160. +14 −0 server/graphman/src/resolvers/mutation_root.rs
  161. +20 −0 server/graphman/src/resolvers/query_root.rs
  162. +7 −0 server/graphman/src/schema.rs
  163. +148 −0 server/graphman/src/server.rs
  164. +66 −0 server/graphman/tests/auth.rs
  165. +392 −0 server/graphman/tests/deployment_mutation.rs
  166. +251 −0 server/graphman/tests/deployment_query.rs
  167. +34 −0 server/graphman/tests/util/client.rs
  168. +46 −0 server/graphman/tests/util/mod.rs
  169. +45 −0 server/graphman/tests/util/server.rs
  170. +0 −1 server/index-node/Cargo.toml
  171. +1 −20 server/index-node/src/resolver.rs
  172. +4 −1 store/postgres/Cargo.toml
  173. +2 −0 store/postgres/migrations/2024-08-14-205601_store_synced_at_block/down.sql
  174. +2 −0 store/postgres/migrations/2024-08-14-205601_store_synced_at_block/up.sql
  175. +1 −0 store/postgres/migrations/2024-10-01-100427_create_graphman_command_executions_table/down.sql
  176. +10 −0 store/postgres/migrations/2024-10-01-100427_create_graphman_command_executions_table/up.sql
  177. +0 −22 store/postgres/src/block_range.rs
  178. +19 −5 store/postgres/src/block_store.rs
  179. +35 −6 store/postgres/src/deployment.rs
  180. +21 −6 store/postgres/src/deployment_store.rs
  181. +1 −0 store/postgres/src/detail.rs
  182. +92 −0 store/postgres/src/graphman/mod.rs
  183. +11 −0 store/postgres/src/graphman/schema.rs
  184. +2 −0 store/postgres/src/lib.rs
  185. +9 −0 store/postgres/src/primary.rs
  186. +75 −9 store/postgres/src/relational.rs
  187. +789 −0 store/postgres/src/relational/dsl.rs
  188. +3 −2 store/postgres/src/relational/query_tests.rs
  189. +47 −1 store/postgres/src/relational/rollup.rs
  190. +263 −0 store/postgres/src/relational/value.rs
  191. +565 −834 store/postgres/src/relational_queries.rs
  192. +8 −6 store/postgres/src/writable.rs
  193. +2 −2 store/test-store/src/store.rs
  194. +14 −10 store/test-store/tests/graph/entity_cache.rs
  195. +2 −2 store/test-store/tests/postgres/graft.rs
  196. +42 −0 store/test-store/tests/postgres/relational.rs
  197. +9 −5 store/test-store/tests/postgres/subgraph.rs
  198. +6 −6 store/test-store/tests/postgres/writable.rs
  199. +1 −1 substreams/substreams-trigger-filter/package.json
  200. +20 −0 tests/runner-tests/end-block/subgraph.yaml
  201. +29 −12 tests/src/fixture/mod.rs
  202. +2 −2 tests/src/fixture/substreams.rs
  203. +14 −14 tests/tests/runner_tests.rs
1 change: 1 addition & 0 deletions .github/workflows/ci.yml
View file
Original file line number Diff line number Diff line change
@@ -70,6 +70,7 @@ jobs:
POSTGRES_DB: graph_node_test
POSTGRES_INITDB_ARGS: "-E UTF8 --locale=C"
POSTGRESQL_EXTRA_FLAGS: "-c max_connections=1000"
POSTGRESQL_REPLICATION_USE_PASSFILE: no
options: >-
--health-cmd "pg_isready -U postgres"
--health-interval 10s
Loading