js-libp2p-webrtc
A libp2p transport using WebRTC connections
Table of contents
Install
$ npm i js-libp2p-webrtc
Browser <script>
tag
Loading this module through a script tag will make it's exports available as JsLibp2pWebrtc
in the global namespace.
<script src="https://unpkg.com/js-libp2p-webrtc/dist/index.min.js"></script>
Usage
import { createLibp2p } from 'libp2p'
import { Noise } from '@chainsafe/libp2p-noise'
import { multiaddr } from '@multiformats/multiaddr'
import first from "it-first";
import { pipe } from "it-pipe";
import { fromString, toString } from "uint8arrays";
import { webRTC } from 'js-libp2p-webrtc'
const node = await createLibp2p({
transports: [webRTC()],
connectionEncryption: [() => new Noise()],
});
await node.start()
const ma = multiaddr('/ip4/0.0.0.0/udp/56093/webrtc/certhash/uEiByaEfNSLBexWBNFZy_QB1vAKEj7JAXDizRs4_SnTflsQ')
const stream = await node.dialProtocol(ma, ['/my-protocol/1.0.0'])
const message = `Hello js-libp2p-webrtc\n`
const response = await pipe([fromString(message)], stream, async (source) => await first(source))
const responseDecoded = toString(response.slice(0, response.length))
Examples
Examples can be found in the examples folder.
Interfaces
Transport
Browsers can only dial
, so listen
is not supported.
interface Transport {
[Symbol.toStringTag]: string
[symbol]: true
dial: (ma: Multiaddr, options: DialOptions) => Promise<Connection>
createListener: (options: CreateListenerOptions) => Listener
filter: MultiaddrFilter
}
class WebRTCTransport implements Transport {
async dial (ma: Multiaddr, options: WebRTCDialOptions): Promise<Connection> {
const rawConn = await this._connect(ma, options)
log(`dialing address - ${ma.toString()}`)
return rawConn
}
createListener (options: CreateListenerOptions): Listener {
throw unimplemented('WebRTCTransport.createListener')
}
}
Connection
interface MultiaddrConnection extends Duplex<Uint8Array> {
close: (err?: Error) => Promise<void>
remoteAddr: Multiaddr
timeline: MultiaddrConnectionTimeline
}
class WebRTCMultiaddrConnection implements MultiaddrConnection { }
Contribute
Contributions are welcome! The libp2p implementation in JavaScript is a work in progress. As such, there's a few things you can do right now to help out:
- Check out the existing issues.
- Perform code reviews.
- Add tests. There can never be enough tests.
- Go through the modules and check out existing issues. This is especially useful for modules in active development. Some knowledge of IPFS/libp2p may be required, as well as the infrastructure behind it - for instance, you may need to read up on p2p and more complex operations like muxing to be able to help technically.
Please be aware that all interactions related to libp2p are subject to the IPFS Code of Conduct.
Small note: If editing the README, please conform to the standard-readme specification.
This module leans heavily on (Aegir)[https://github.com/ipfs/aegir] for most of the package.json
scripts.
Build
The build script is a wrapper to aegir build
. To build this package:
npm run build
The build will be located in the /dist
folder.
Protocol Buffers
There is also npm run generate:proto
script that uses protoc to populate the generated code directory proto_ts
based on *.proto
files in src. Don't forget to run this step before build
any time you make a change to any of the *.proto
files.
Test
To run all tests:
npm test
To run tests for Chome only:
npm run test:chrome
To run tests for Firefox only:
npm run test:firefox
Lint
Aegir is also used to lint the code, which follows the Standard JS linter.
The VS Code plugin for this standard is located at https://marketplace.visualstudio.com/items?itemName=standard.vscode-standard.
To lint this repo:
npm run lint
You can also auto-fix when applicable:
npm run lint:fix
Clean
npm run clean
Check Dependencies
npm run deps-check
Build a Release
npm run release
License
Licensed under either of
Contribute
Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.