This is the work repository for the EthereumJS client project targeting both Node.js and the browser.
See Technical Guidelines to dive directly into development info.
Current development stage: EARLY DEVELOPMENT
Project summary from this document is currently outdated. Please refer to our communication channels for some information on the current state of client development.
npm install ethereumjs-client
For the ethereumjs
CLI command to work run:
npm link
Note: for development purposes, you can invoke the client with npm run client:start
from the client
root directory (e.g. packages/client
if working on a local copy of the monorepo)
You can get up the client up and running with default settings with:
ethereumjs --network=mainnet [--loglevel=debug]
You can connect to specific networks by name using the --network
parameter as below: (rinkeby
is used here)
ethereumjs --network rinkeby
The client currently supports the below networks:
- mainnet
- rinkeby
- ropsten
- goerli
- calaveras
- kovan -- Note: kovan support is limited and chain syncing may not work due to the kovan consensus mechanism not being implemented
The help can be shown with:
ethereumjs --help
The client's logging verbosity level can be set with --loglevel
. Available levels are
error
, warn
, info
, debug
ethereumjs --loglevel=debug
If you want to have verbose logging output across the stack you can use...
DEBUG=*,-babel [CLIENT_START_COMMAND]
for all output or something more targeted by listing the loggers like
DEBUG=devp2p:rlpx,devp2p:eth,-babel [CLIENT_START_COMMAND]
To programmatically run a client do:
import { Config, EthereumClient } from '@ethereumjs/client'
const config = new Config()
const client = new EthereumClient({ config })
client.open()
client.start()
client.stop()
You can also provide your custom @ethereumjs/vm instance:
import VM from '@ethereumjs/vm'
import { Config, EthereumClient } from '@ethereumjs/client'
const vm = new VM()
const config = new Config({ vm })
const client = new EthereumClient({ config })
[WORK-IN-PROGRESS] Programmatic invocation on the client is in a very early stage and only meant for experimental purposes. You are invited to play around, please let us know what control functionality you would want the client to expose and what information you would need to get out of the client to be useful in your usage context.
See also this diagram for an overview of the client structure with the initialization and message flow.
You can expose a JSON-RPC interface along a client run with:
ethereumjs --rpc
To run just the server without syncing:
ethereumjs --rpc --maxPeers=0
Currently only a small subset of RPC
methods are implemented.(*) You can have a look at the
./lib/rpc/modules/ source folder or the tracking issue
#1114 for an overview.
(*) Side note: implementing RPC methods is actually an extremely thankful task for a first-time contribution on the project *hint* hint. 😄
You can use cURL
to request data from an API endpoint. Here is a simple example for
web3_clientVersion:
curl -X POST -H "Content-Type: application/json" --data '{"jsonrpc":"2.0","id":1,"method":"web3_clientVersion", "params": []}' http://localhost:8545
Note that "params": []
can also be omitted in this case.
Or - somewhat more convenient and with formatted output - with a tool like httpie:
http POST http://localhost:8545 jsonrpc=2.0 id=1 method=web3_clientVersion params:=[]
Note the :=
separator for the params
parameter to
indicate raw JSON
as an input.
This will give you an output like the following:
{
"id": "1",
"jsonrpc": "2.0",
"result": "EthereumJS/0.0.5/darwin/node12.15.0"
}
Here's an example for a call on an endpoint with the need for parameters. The following call uses
the eth_getBlockByNumer endpoint
to request data for block number 436 (you can use an tool like
RapidTables for conversion to hex
):
curl -X POST -H "Content-Type: application/json" --data '{"jsonrpc":"2.0","method":"eth_getBlockByNumber","params":["0x1b4", true],"id":1}' http://127.0.0.1:8545
Same with httpie
:
http POST http://localhost:8545 jsonrpc=2.0 id=1 method=eth_getBlockByNumber params:='["0x1b4",true]'
Output:
{
"id": "1",
"jsonrpc": "2.0",
"result": {
"header": {
"bloom": "0x00000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000",
"coinbase": "0xbb7b8287f3f0a933474a79eae42cbca977791171",
"difficulty": "0x04ea3f27bc",
"extraData": "0x476574682f4c5649562f76312e302e302f6c696e75782f676f312e342e32",
"gasLimit": "0x1388",
"gasUsed": "0x",
"mixHash": "0x4fffe9ae21f1c9e15207b1f472d5bbdd68c9595d461666602f2be20daf5e7843",
"nonce": "0x689056015818adbe",
"number": "0x01b4",
"parentHash": "0xe99e022112df268087ea7eafaf4790497fd21dbeeb6bd7a1721df161a6657a54",
"receiptTrie": "0x56e81f171bcc55a6ff8345e692c0f86e5b48e01b996cadc001622fb5e363b421",
"stateRoot": "0xddc8b0234c2e0cad087c8b389aa7ef01f7d79b2570bccb77ce48648aa61c904d",
"timestamp": "0x55ba467c",
"transactionsTrie": "0x56e81f171bcc55a6ff8345e692c0f86e5b48e01b996cadc001622fb5e363b421",
"uncleHash": "0x1dcc4de8dec75d7aab85b567b6ccd41ad312451b948a7413f0a142fd40d49347"
},
"transactions": [],
"uncleHeaders": []
}
}
In this example, we will run two ethereumjs-clients. The first will be a full sync client that will connect to the rinkeby network and start downloading the blockchain. The second will be a light client that connects to the first client and syncs headers as they are downloaded.
The first client will use RLPx to connect to the rinkeby network, but will also provide a libp2p listener. The second client will use libp2p to connect to the first client.
Run the first client and start downloading blocks:
ethereumjs --syncmode full --lightserv true --datadir first --network rinkeby --transports rlpx libp2p --multiaddrs /ip4/127.0.0.1/tcp/50505/ws
Output:
... INFO [10-24|11:42:26] Listener up transport=rlpx url=enode://1c3a3d70e9fb7c274355b7ffbbb34465576ecec7ab275947fd4bdc7ddcd19320dfb61b210cbacc0702011aea6971204d4309cf9cc1856fce4887145962281907@[::]:30303 INFO [10-24|11:37:48] Listener up transport=libp2p url=/ip4/127.0.0.1/tcp/50505/ws/p2p/QmYAuYxw6QX1x5aafs6g3bUrPbMDifP5pDun3N9zbVLpEa ...
Copy the libp2p URL from the output. In this example, the url is /ip4/127.0.0.1/tcp/50505/ws/p2p/QmYAuYxw6QX1x5aafs6g3bUrPbMDifP5pDun3N9zbVLpEa
but it will be different in your case.
Wait until a few thousand blocks are downloaded and then run the second client in a new terminal, using the url above to connect to the first client:
ethereumjs --syncmode light --network rinkeby --datadir second --transports libp2p --multiaddrs /ip4/0.0.0.0/tcp/50506 --bootnodes=/ip4/127.0.0.1/tcp/50505/ws/p2p/QmYAuYxw6QX1x5aafs6g3bUrPbMDifP5pDun3N9zbVLpEa
Notice that we have to run the second client on port 50506 using the --multiaddrs /ip4/0.0.0.0/tcp/50506
libp2p option to avoid port conflicts.
In this example, we will again perform a light sync by connecting to the first client from above. However, this time we will connect directly to the first client from within a browser window using libp2p websockets.
First, let's make the bundle:
git clone https://github.com/ethereumjs/ethereumjs-monorepo
cd ethereumjs-monorepo
npm i
cd packages/client
npm run build:browser
This will create the file dist/bundle.js
. Now, we will create anindex.html
file that serves it up on http://localhost:8080
.
echo '<script src="/dist/bundle.js"></script>' > index.html
npm i -g http-server
http-server
Now, open a new browser window and navigate to http://localhost:8080
. Open the developer console in your browser and run the following command to start syncing to the first client. Again, remember to change the value of bootnodes to match the url of the first client from above:
ethereumjs.run({
network: 'rinkeby',
syncmode: 'light',
bootnodes: '/ip4/127.0.0.1/tcp/50505/ws/p2p/QmYAuYxw6QX1x5aafs6g3bUrPbMDifP5pDun3N9zbVLpEa',
discDns: false
})
That's it! Now, you should start seeing headers being downloaded to the local storage of your browser. Since IndexDB is being used, even if you close and re-open the browser window, the headers you've downloaded will be saved.
Goals
Contributors should aim to achieve the following goals when making design decisions:
- Loosely coupled components: Components should require as little knowledge of the definitions of other components as possible. This reduces dependencies between PRs and encourages contributors to work in parallel. It also improves extensibility of the code as new features like sharding and libp2p support are added.
- Easily tested: The design should make testing of individual components as easy as possible. This goes hand in hand with the previous goal of loose coupling.
- Readable code: More readable code should encourage more contributions from the community and help with bug fixing.
- Well documented: Similar to above, this will help both contributors and users of the project.
The current design tries to achieves the goals of loose coupling and ease of testing by using an event-driven architecture where possible. Readability is improved by using features of JavaScript ES6 such as classes, async/await, promises, arrow functions, for...of, template literals and destructuring assignment among others. Shorter names are used when possible and long functions are broken up into smaller helpers, along with TypeDoc annotations for most methods and parameters. Documentation is auto-generated from TypeDoc comments and many examples of usage are provided (TO DO).
We will now briefly describe the directory structure and main components of the Ethereumjs client to help contributors better understand how the project is organized.
Directory structure
/bin
Contains the CLI script for theethereumjs
command./docs
Contains auto-generated API docs./lib/blockchain
Contains theChain
class./lib/net
Contains all of the network layer classes includingPeer
,Protocol
and its subclasses,Server
and its subclasses, andPeerPool
./lib/service
Contains the main Ethereum services (FullEthereumService
andLightEthereumService
)./lib/rpc
Contains the RPC server (optionally) embedded in the client./lib/sync
Contains the various chain synchronizers andFetcher
helpers./test
Contains test cases, testing helper functions, mocks and test data.
Components
Chain
[In Progress] This class represents the blockchain and is a wrapper around@ethereumjs/blockchain
. It handles creation of the data directory, provides basic blockchain operations and maintains an updated current state of the blockchain, including current height, total difficulty, and latest block.Server
This class represents a server that discovers new peers and handles incoming and dropped connections. When a new peer connects, theServer
class will negotiate protocols and emit aconnected
event with a newPeer
instance. The peer will have properties corresponding to each protocol. For example, if a new peer understands theeth
protocol, it will contain aneth
property that provides alleth
protocol methods (for example:peer.eth.getBlockHeaders()
) -RlpxServer
[In Progress] Subclass ofServer
that implements thedevp2p/rlpx
transport. -Libp2pServer
[In Progress] Subclass ofServer
that implements thelibp2p
transport.Peer
Represents a network peer. Instances ofPeer
are generated by theServer
subclasses and contain instances of supported protocol classes as properties. Instances ofPeer
subclasses can also be used to directly connect to other nodes via theconnect()
method. Peers emitmessage
events whenever a new message is received using any of the supported protocols. -RlpxPeer
[In Progress] Subclass ofPeer
that implements thedevp2p/rlpx
transport. -Libp2pPeer
[In Progress] Subclass ofPeer
that implements thelibp2p
transport.Protocol
[In Progress] This class and subclasses provide a user-friendly wrapper around the low level ethereum protocols such aseth/62
,eth/63
andles/2
. Subclasses must define the messages provided by the protocol. -EthProtocol
[In Progress] Implements theeth/62
andeth/63
protocols. -LesProtocol
[In Progress] Implements theles/2
protocol. -ShhProtocol
[Not Started] Implements the whisper protocol.PeerPool
[In Progress] Represents a pool of network peers.PeerPool
instances emitadded
andremoved
events when new peers are added and removed and also emit themessage
event whenever any of the peers in the pool emit a message. EachService
has an associatedPeerPool
and they are used primarily bySynchronizer
s to help with blockchain synchronization.Synchronizer
Subclasses of this class implements a specific blockchain synchronization strategy. They also make use of subclasses of theFetcher
class that help fetch headers and bodies from pool peers. The fetchers internally make use of streams to handle things like queuing and backpressure. -FullSynchronizer
[In Progress] Implements full syncing of the blockchain -LightSynchronizer
[In Progress] Implements light syncing of the blockchainHandler
Subclasses of this class implements a protocol message handler. Handlers respond to incoming requests from peers.EthHandler
[In Progress] Handles incoming ETH requestsLesHandler
[In Progress] Handles incoming LES requests
Service
Subclasses ofService
will implement specific functionality of aClient
. For example, theEthereumService
subclasses will synchronize the blockchain using the full or light sync protocols. Each service must specify which protocols it needs and define astart()
andstop()
function.FullEthereumService
[In Progress] Implementation of ethereum full sync.LightEthereumService
[In Progress] Implementation of ethereum light sync.WhisperService
[Not Started] Implementation of an ethereum whisper node.
Client
[In Progress] Represents the top-level ethereum client, and is responsible for managing the lifecycle of included services.RPCManager
[In Progress] Implements an embedded JSON-RPC server to handle incoming RPC requests.
For debugging on networking issues there are two custom npm start scripts with appropriate settings.
Start a first client listening on the default port and using the default data directory with:
DEBUG=devp2p:* npm run client:start:dev1
DEBUG=devp2p:* npm run client:start:dev1 -- --datadir=datadir-dev1
Then take the enode address from the started client instance (use 127.0.0.1
for the IP address) and start a second client with:
DEBUG=devp2p:* npm run client:start:dev2 -- --bootnodes=enode://[DEV1_NODE_ID]@127.0.0.1:30303
This second client is using './datadir-dev2' for its data directory.
To connect Geth to a running EthereumJS instance start a client with:
DEBUG=devp2p:* npm run client:start:dev1
Then connect with your Geth instance via:
geth --maxpeers=1 --bootnodes=enode://[DEV1_NODE_ID]@127.0.0.1:30303
Depending on your use case you might want to turn off your internet connection to not allow further incoming connections on your Geth instance in case the EthereumJS connection gets disconnected.
Start your Geth instance:
geth [--syncmode=full] [--verbosity=5]
Note that you might want to turn off your internet connection to limit on the Geth discovery process (setting the --nodiscover
flag won't work since this also disallows our local client from connecting).
Then connect with your EthereumJS instance via:
DEBUG=devp2p:* npm run client:start:dev2 -- --bootnodes=enode://[GETH_NODE_ID]@127.0.0.1:30303
To update the structure diagram files in the root folder open the client.drawio
file in draw.io, make your changes, and open a PR with the updated files. Export svg
and png
with border
width=20
and transparency=false
. For png
go to "Advanced" and select 300 DPI
.
EthereumJS Ecosystem
This project will be embedded in the EthereumJS ecosystem and many submodules already exist and can be used within the project, have a look e.g. at @ethereumjs/block, @ethereumjs/vm, merkle-patricia-tree or the @ethereumjs/devp2p implementation. Work needs to be done both within these repos and related libraries.
See our organizational documentation for an introduction to EthereumJS
as well as information on current standards and best practices.
If you want to join for work or do improvements on the libraries have a look at our contribution guidelines.