Initial commit

Author: kern

.gitignore

@@ -0,0 +1,34 @@
+# mono
+*.log
+etc/openvpn
+pkg
+src/dash/protobufs/*.proto
+src/reports/**/report.html
+src/reports/**/report.pdf
+src/vendor
+usr/local
+tmp
+.vimlocal
+
+# macOS
+.DS_Store
+
+# Python
+.ipynb_checkpoints
+*.ipynb
+__pycache__/
+*.py[cod]
+*$py.class
+.python-version
+.venv/
+
+# Java
+*.jar
+
+# Go
+bin/golint
+bin/protoc-gen-go
+bazel-*
+
+# JavaScript
+node_modules

LICENSE

@@ -0,0 +1,13 @@
+Copyright 2018 Distributed Systems, Inc.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.

README.md

@@ -0,0 +1,24 @@
+# eth-explorer
+
+Explore the Ethereum blockchain using a rich GraphQL API.
+
+## Usage
+
+[Demo](https://multi-api-jisphshaoi.now.sh/)
+
+```sh
+git clone [email protected]:dsys/eth-explorer.git
+cd eth-explorer
+yarn install
+yarn start # listening on localhost:4000
+```
+
+## Development
+
+```sh
+yarn dev
+```
+
+## License
+
+Apache 2.0

package.json

@@ -0,0 +1,21 @@
+{
+  "name": "eth-explorer",
+  "license": "Apache-2.0",
+  "author": "Alex Kern <[email protected]>",
+  "scripts": {
+    "start": "nodemon -e js,graphql -x node -r dotenv/config src/index.js",
+    "debug": "nodemon -e js,graphql -x node --inspect -r dotenv/config src/index.js",
+    "playground": "graphql playground",
+    "dev": "npm-run-all --parallel start playground"
+  },
+  "dependencies": {
+    "graphql-yoga": "1.14.6",
+    "web3": "^1.0.0-beta.34"
+  },
+  "devDependencies": {
+    "dotenv": "5.0.1",
+    "graphql-cli": "2.16.0",
+    "nodemon": "1.17.5",
+    "npm-run-all": "4.1.3"
+  }
+}

src/index.js

@@ -0,0 +1,15 @@
+const { GraphQLServer } = require('graphql-yoga');
+const resolvers = require('./resolvers');
+
+const server = new GraphQLServer({
+  typeDefs: './src/schema.graphql',
+  resolvers,
+  context: req => ({ ...req })
+});
+
+server.start(info =>
+  // eslint-disable-next-line no-console
+  console.log(
+    `Server is running on http://localhost:${info.port}`
+  )
+);

src/resolvers/EthereumAddress.js

@@ -0,0 +1,12 @@
+const { web3 } = require('../web3');
+
+const EthereumAddress = {
+  balance: ({ network = 'MAINNET', hash }, args, ctx, info) => {
+    return web3[network].eth.getBalance(hash);
+  },
+  transactionCount: async ({ network = 'MAINNET', hash }, args, ctx, info) => {
+    return web3[network].eth.getTransactionCount(hash);
+  }
+};
+
+module.exports = { EthereumAddress };

src/resolvers/EthereumBlock.js

@@ -0,0 +1,14 @@
+const { getBlock, getTransaction } = require('../web3');
+
+const EthereumBlock = {
+  parent: (parent, args, ctx, info) => {
+    return getBlock({ hash: parent.parentHash, network: parent.network });
+  },
+  transactions: (parent, args, ctx, info) => {
+    return parent.transactions.map(hash =>
+      getTransaction({ network: args.network, hash })
+    );
+  }
+};
+
+module.exports = { EthereumBlock };

src/resolvers/EthereumTransaction.js

@@ -0,0 +1,15 @@
+const { getBlock } = require('../web3');
+
+const EthereumTransaction = {
+  from: (parent, args, ctx, info) => {
+    return { network: parent.network, hash: parent.from };
+  },
+  to: (parent, args, ctx, info) => {
+    return { network: parent.network, hash: parent.to };
+  },
+  block: (parent, args, ctx, info) => {
+    return getBlock({ network: parent.network, hash: parent.blockHash });
+  }
+};
+
+module.exports = { EthereumTransaction };

src/resolvers/Query.js

@@ -0,0 +1,21 @@
+const { web3, getBlock, getTransaction } = require('../web3');
+
+const Query = {
+  ethereumGasPrice(parent, { network = 'MAINNET' }) {
+    return web3[network].eth.getGasPrice();
+  },
+
+  ethereumAddress(parent, { hash, network = 'MAINNET' }, ctx, info) {
+    return { hash, network };
+  },
+
+  ethereumBlock(parent, args, ctx, info) {
+    return getBlock(args);
+  },
+
+  ethereumTransaction(parent, args, ctx, info) {
+    return getTransaction(args);
+  }
+};
+
+module.exports = { Query };

src/resolvers/index.js

@@ -0,0 +1,11 @@
+const { EthereumAddress } = require('./EthereumAddress');
+const { EthereumBlock } = require('./EthereumBlock');
+const { EthereumTransaction } = require('./EthereumTransaction');
+const { Query } = require('./Query');
+
+module.exports = {
+  Query,
+  EthereumAddress,
+  EthereumTransaction,
+  EthereumBlock
+};

src/schema.graphql

@@ -0,0 +1,57 @@
+enum ETHEREUM_NETWORK {
+  MAINNET
+  ROPSTEN
+  KOVAN
+  RINKEBY
+}
+
+type Query {
+  ethereumGasPrice(network: ETHEREUM_NETWORK): String!
+
+  ethereumBlock(hash: String, number: Int, network: ETHEREUM_NETWORK): EthereumBlock
+  ethereumTransaction(hash: String!, network: ETHEREUM_NETWORK): EthereumTransaction
+  ethereumAddress(hash: String!, network: ETHEREUM_NETWORK): EthereumAddress
+}
+
+type EthereumAddress {
+  network: ETHEREUM_NETWORK!
+  hash: String!
+  balance: String!
+  transactionCount: Int!
+}
+
+type EthereumTransaction {
+  network: ETHEREUM_NETWORK!
+  hash: String!
+  nonce: Int!
+  block: EthereumBlock
+  transactionIndex: Int!
+  from: EthereumAddress
+  to: EthereumAddress
+  value: String!
+  gas: Int!
+  gasPrice: String!
+  input: String!
+}
+
+type EthereumBlock {
+  network: ETHEREUM_NETWORK!
+  hash: String!
+  number: Int!
+  parent: EthereumBlock
+  nonce: String!
+  sha3Uncles: String!
+  logsBloom: String!
+  transactionsRoot: String!
+  stateRoot: String!
+  miner: EthereumAddress!
+  difficulty: String!
+  totalDifficulty: String!
+  size: Int!
+  extraData: String!
+  gasLimit: Int!
+  gasUsed: Int!
+  timestamp: Int!
+  transactions: [EthereumTransaction!]!
+  uncles: [EthereumBlock!]!
+}

src/web3.js

@@ -0,0 +1,27 @@
+const Web3 = require('web3');
+
+const ETHEREUM_NETWORKS = ['MAINNET', 'ROPSTEN', 'KOVAN', 'RINKEBY'];
+const web3Connections = [];
+for (const network of ETHEREUM_NETWORKS) {
+  web3Connections[network] = new Web3(
+    new Web3.providers.HttpProvider(
+      `https://${network}.infura.io/${process.env.INFURA_API_KEY}`
+    )
+  );
+}
+
+async function getBlock({ hash, number, network = 'MAINNET' }) {
+  const block = await web3Connections[network].eth.getBlock(hash || number);
+  if (!block) return null;
+  block.network = network;
+  return block;
+}
+
+async function getTransaction({ hash, network = 'MAINNET' }) {
+  const tx = await web3Connections[network].eth.getTransaction(hash);
+  if (!tx) return null;
+  tx.network = network;
+  return tx;
+}
+
+module.exports = { web3: web3Connections, getBlock, getTransaction };