Compare commits
26 Commits
gx/v0.7.8
...
gx/v0.7.16
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
1aa1093d28 | ||
|
|
f4f9847100 | ||
|
|
83b0d39470 | ||
|
|
b7772ebfe3 | ||
|
|
e449699cc1 | ||
|
|
7d345d4817 | ||
|
|
3c03b9e581 | ||
|
|
f6990413f7 | ||
|
|
3f7f6c6a1d | ||
|
|
05eac5f7ca | ||
|
|
1f385a8224 | ||
|
|
b42583c8bf | ||
|
|
45ce89d41a | ||
|
|
a20203df14 | ||
|
|
d4ebfff511 | ||
|
|
e310d23e36 | ||
|
|
7e7f6811b4 | ||
|
|
daa83089b3 | ||
|
|
7ef01bd895 | ||
|
|
05ed406b31 | ||
|
|
92cac2f002 | ||
|
|
a22bf1e2bf | ||
|
|
7bcaf9264a | ||
|
|
c1db98f9ae | ||
|
|
40c5ff1bfe | ||
|
|
ebda3c73ae |
@@ -1 +1 @@
|
|||||||
0.7.8: QmXm6Di2T89xAeprno3x6nD6jRgtMm2wRy25DX4zc4gk8V
|
0.7.16: Qma4RJSuh7mMeJQYCqMbKzekn6EwBo7HEs5AQYjVRMQATB
|
||||||
|
|||||||
32
.travis.yml
32
.travis.yml
@@ -1,24 +1,24 @@
|
|||||||
os:
|
sudo: false
|
||||||
- linux
|
|
||||||
- osx
|
|
||||||
|
|
||||||
language: go
|
language: go
|
||||||
|
|
||||||
go:
|
go:
|
||||||
- 1.7
|
- 'tip'
|
||||||
|
|
||||||
install: true
|
install:
|
||||||
|
- go get github.com/whyrusleeping/gx
|
||||||
before_install:
|
- go get github.com/whyrusleeping/gx-go
|
||||||
- make deps
|
- gx install --global
|
||||||
|
|
||||||
script:
|
script:
|
||||||
- go vet
|
- gx test -v -race -coverprofile=coverage.txt -covermode=atomic .
|
||||||
- $GOPATH/bin/goveralls -service="travis-ci"
|
|
||||||
|
after_success:
|
||||||
|
- bash <(curl -s https://codecov.io/bash)
|
||||||
|
|
||||||
cache:
|
cache:
|
||||||
directories:
|
directories:
|
||||||
- $GOPATH/src/gx
|
- $GOPATH/src/gx
|
||||||
|
|
||||||
notifications:
|
notifications:
|
||||||
email: false
|
email: false
|
||||||
|
|
||||||
|
|||||||
57
README.md
57
README.md
@@ -4,13 +4,15 @@ go-cid
|
|||||||
[](http://ipn.io)
|
[](http://ipn.io)
|
||||||
[](http://ipfs.io/)
|
[](http://ipfs.io/)
|
||||||
[](http://webchat.freenode.net/?channels=%23ipfs)
|
[](http://webchat.freenode.net/?channels=%23ipfs)
|
||||||
|
[](https://github.com/RichardLitt/standard-readme)
|
||||||
|
[](https://godoc.org/github.com/ipfs/go-cid)
|
||||||
[](https://coveralls.io/github/ipfs/go-cid?branch=master)
|
[](https://coveralls.io/github/ipfs/go-cid?branch=master)
|
||||||
[](https://travis-ci.org/ipfs/go-cid)
|
[](https://travis-ci.org/ipfs/go-cid)
|
||||||
|
|
||||||
> A package to handle content IDs in go.
|
> A package to handle content IDs in Go.
|
||||||
|
|
||||||
This is an implementation in go of the [CID spec](https://github.com/ipld/cid).
|
This is an implementation in Go of the [CID spec](https://github.com/ipld/cid).
|
||||||
It is used in go-ipfs and related packages to refer to a typed hunk of data.
|
It is used in `go-ipfs` and related packages to refer to a typed hunk of data.
|
||||||
|
|
||||||
|
|
||||||
## Table of Contents
|
## Table of Contents
|
||||||
@@ -23,20 +25,46 @@ It is used in go-ipfs and related packages to refer to a typed hunk of data.
|
|||||||
|
|
||||||
## Install
|
## Install
|
||||||
|
|
||||||
|
`go-cid` is a standard Go module which can be installed with:
|
||||||
|
|
||||||
|
```sh
|
||||||
|
go get github.com/ipfs/go-cid
|
||||||
|
```
|
||||||
|
|
||||||
|
Note that `go-cid` is packaged with Gx, so it is recommended to use Gx to install and use it (see Usage section).
|
||||||
|
|
||||||
|
## Usage
|
||||||
|
|
||||||
|
### Using Gx and Gx-go
|
||||||
|
|
||||||
|
This module is packaged with [Gx](https://github.com/whyrusleeping/gx). In order to use it in your own project it is recommended that you:
|
||||||
|
|
||||||
|
```sh
|
||||||
|
go get -u github.com/whyrusleeping/gx
|
||||||
|
go get -u github.com/whyrusleeping/gx-go
|
||||||
|
cd <your-project-repository>
|
||||||
|
gx init
|
||||||
|
gx import github.com/ipfs/go-cid
|
||||||
|
gx install --global
|
||||||
|
gx-go --rewrite
|
||||||
|
```
|
||||||
|
|
||||||
|
Please check [Gx](https://github.com/whyrusleeping/gx) and [Gx-go](https://github.com/whyrusleeping/gx-go) documentation for more information.
|
||||||
|
|
||||||
|
### Running tests
|
||||||
|
|
||||||
|
Before running tests, please run:
|
||||||
|
|
||||||
```sh
|
```sh
|
||||||
make deps
|
make deps
|
||||||
```
|
```
|
||||||
|
|
||||||
## Examples
|
This will make sure that dependencies are rewritten to known working versions.
|
||||||
|
|
||||||
To use CIDs, import it in your code like:
|
### Examples
|
||||||
```go
|
|
||||||
import "github.com/ipfs/go-cid"
|
|
||||||
```
|
|
||||||
|
|
||||||
Then, depending on how you want to use it, something like one of the following examples should work:
|
#### Parsing string input from users
|
||||||
|
|
||||||
### Parsing string input from users
|
|
||||||
```go
|
```go
|
||||||
// Create a cid from a marshaled string
|
// Create a cid from a marshaled string
|
||||||
c, err := cid.Decode("zdvgqEMYmNeH5fKciougvQcfzMcNjF3Z1tPouJ8C7pc3pe63k")
|
c, err := cid.Decode("zdvgqEMYmNeH5fKciougvQcfzMcNjF3Z1tPouJ8C7pc3pe63k")
|
||||||
@@ -45,7 +73,8 @@ if err != nil {...}
|
|||||||
fmt.Println("Got CID: ", c)
|
fmt.Println("Got CID: ", c)
|
||||||
```
|
```
|
||||||
|
|
||||||
### Creating a CID from scratch
|
#### Creating a CID from scratch
|
||||||
|
|
||||||
```go
|
```go
|
||||||
// Create a cid manually by specifying the 'prefix' parameters
|
// Create a cid manually by specifying the 'prefix' parameters
|
||||||
pref := cid.Prefix{
|
pref := cid.Prefix{
|
||||||
@@ -62,7 +91,8 @@ if err != nil {...}
|
|||||||
fmt.Println("Created CID: ", c)
|
fmt.Println("Created CID: ", c)
|
||||||
```
|
```
|
||||||
|
|
||||||
### Check if two CIDs match
|
#### Check if two CIDs match
|
||||||
|
|
||||||
```go
|
```go
|
||||||
// To test if two cid's are equivalent, be sure to use the 'Equals' method:
|
// To test if two cid's are equivalent, be sure to use the 'Equals' method:
|
||||||
if c1.Equals(c2) {
|
if c1.Equals(c2) {
|
||||||
@@ -70,7 +100,8 @@ if c1.Equals(c2) {
|
|||||||
}
|
}
|
||||||
```
|
```
|
||||||
|
|
||||||
### Check if some data matches a given CID
|
#### Check if some data matches a given CID
|
||||||
|
|
||||||
```go
|
```go
|
||||||
// To check if some data matches a given cid,
|
// To check if some data matches a given cid,
|
||||||
// Get your CIDs prefix, and use that to sum the data in question:
|
// Get your CIDs prefix, and use that to sum the data in question:
|
||||||
|
|||||||
208
cid.go
208
cid.go
@@ -1,8 +1,28 @@
|
|||||||
|
// Package cid implements the Content-IDentifiers specification
|
||||||
|
// (https://github.com/ipld/cid) in Go. CIDs are
|
||||||
|
// self-describing content-addressed identifiers useful for
|
||||||
|
// distributed information systems. CIDs are used in the IPFS
|
||||||
|
// (https://ipfs.io) project ecosystem.
|
||||||
|
//
|
||||||
|
// CIDs have two major versions. A CIDv0 corresponds to a multihash of type
|
||||||
|
// DagProtobuf, is deprecated and exists for compatibility reasons. Usually,
|
||||||
|
// CIDv1 should be used.
|
||||||
|
//
|
||||||
|
// A CIDv1 has four parts:
|
||||||
|
//
|
||||||
|
// <cidv1> ::= <multibase-prefix><cid-version><multicodec-packed-content-type><multihash-content-address>
|
||||||
|
//
|
||||||
|
// As shown above, the CID implementation relies heavily on Multiformats,
|
||||||
|
// particularly Multibase
|
||||||
|
// (https://github.com/multiformats/go-multibase), Multicodec
|
||||||
|
// (https://github.com/multiformats/multicodec) and Multihash
|
||||||
|
// implementations (https://github.com/multiformats/go-multihash).
|
||||||
package cid
|
package cid
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"bytes"
|
"bytes"
|
||||||
"encoding/binary"
|
"encoding/binary"
|
||||||
|
"encoding/json"
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
"strings"
|
"strings"
|
||||||
@@ -11,44 +31,109 @@ import (
|
|||||||
mh "github.com/multiformats/go-multihash"
|
mh "github.com/multiformats/go-multihash"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
// UnsupportedVersionString just holds an error message
|
||||||
const UnsupportedVersionString = "<unsupported cid version>"
|
const UnsupportedVersionString = "<unsupported cid version>"
|
||||||
|
|
||||||
|
var (
|
||||||
|
// ErrVarintBuffSmall means that a buffer passed to the cid parser was not
|
||||||
|
// long enough, or did not contain an invalid cid
|
||||||
|
ErrVarintBuffSmall = errors.New("reading varint: buffer too small")
|
||||||
|
|
||||||
|
// ErrVarintTooBig means that the varint in the given cid was above the
|
||||||
|
// limit of 2^64
|
||||||
|
ErrVarintTooBig = errors.New("reading varint: varint bigger than 64bits" +
|
||||||
|
" and not supported")
|
||||||
|
|
||||||
|
// ErrCidTooShort means that the cid passed to decode was not long
|
||||||
|
// enough to be a valid Cid
|
||||||
|
ErrCidTooShort = errors.New("cid too short")
|
||||||
|
|
||||||
|
// ErrInvalidEncoding means that selected encoding is not supported
|
||||||
|
// by this Cid version
|
||||||
|
ErrInvalidEncoding = errors.New("invalid base encoding")
|
||||||
|
)
|
||||||
|
|
||||||
|
// These are multicodec-packed content types. The should match
|
||||||
|
// the codes described in the authoritative document:
|
||||||
|
// https://github.com/multiformats/multicodec/blob/master/table.csv
|
||||||
const (
|
const (
|
||||||
Raw = 0x55
|
Raw = 0x55
|
||||||
|
|
||||||
DagProtobuf = 0x70
|
DagProtobuf = 0x70
|
||||||
DagCBOR = 0x71
|
DagCBOR = 0x71
|
||||||
|
|
||||||
EthereumBlock = 0x90
|
GitRaw = 0x78
|
||||||
EthereumTx = 0x91
|
|
||||||
BitcoinBlock = 0xb0
|
EthBlock = 0x90
|
||||||
BitcoinTx = 0xb1
|
EthBlockList = 0x91
|
||||||
ZcashBlock = 0xc0
|
EthTxTrie = 0x92
|
||||||
ZcashTx = 0xc1
|
EthTx = 0x93
|
||||||
|
EthTxReceiptTrie = 0x94
|
||||||
|
EthTxReceipt = 0x95
|
||||||
|
EthStateTrie = 0x96
|
||||||
|
EthAccountSnapshot = 0x97
|
||||||
|
EthStorageTrie = 0x98
|
||||||
|
BitcoinBlock = 0xb0
|
||||||
|
BitcoinTx = 0xb1
|
||||||
|
ZcashBlock = 0xc0
|
||||||
|
ZcashTx = 0xc1
|
||||||
)
|
)
|
||||||
|
|
||||||
func NewCidV0(h mh.Multihash) *Cid {
|
// Codecs maps the name of a codec to its type
|
||||||
|
var Codecs = map[string]uint64{
|
||||||
|
"v0": DagProtobuf,
|
||||||
|
"raw": Raw,
|
||||||
|
"protobuf": DagProtobuf,
|
||||||
|
"cbor": DagCBOR,
|
||||||
|
"git-raw": GitRaw,
|
||||||
|
"eth-block": EthBlock,
|
||||||
|
"eth-block-list": EthBlockList,
|
||||||
|
"eth-tx-trie": EthTxTrie,
|
||||||
|
"eth-tx": EthTx,
|
||||||
|
"eth-tx-receipt-trie": EthTxReceiptTrie,
|
||||||
|
"eth-tx-receipt": EthTxReceipt,
|
||||||
|
"eth-state-trie": EthStateTrie,
|
||||||
|
"eth-account-snapshot": EthAccountSnapshot,
|
||||||
|
"eth-storage-trie": EthStorageTrie,
|
||||||
|
"bitcoin-block": BitcoinBlock,
|
||||||
|
"bitcoin-tx": BitcoinTx,
|
||||||
|
"zcash-block": ZcashBlock,
|
||||||
|
"zcash-tx": ZcashTx,
|
||||||
|
}
|
||||||
|
|
||||||
|
// NewCidV0 returns a Cid-wrapped multihash.
|
||||||
|
// They exist to allow IPFS to work with Cids while keeping
|
||||||
|
// compatibility with the plain-multihash format used used in IPFS.
|
||||||
|
// NewCidV1 should be used preferentially.
|
||||||
|
func NewCidV0(mhash mh.Multihash) *Cid {
|
||||||
return &Cid{
|
return &Cid{
|
||||||
version: 0,
|
version: 0,
|
||||||
codec: DagProtobuf,
|
codec: DagProtobuf,
|
||||||
hash: h,
|
hash: mhash,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewCidV1(c uint64, h mh.Multihash) *Cid {
|
// NewCidV1 returns a new Cid using the given multicodec-packed
|
||||||
|
// content type.
|
||||||
|
func NewCidV1(codecType uint64, mhash mh.Multihash) *Cid {
|
||||||
return &Cid{
|
return &Cid{
|
||||||
version: 1,
|
version: 1,
|
||||||
codec: c,
|
codec: codecType,
|
||||||
hash: h,
|
hash: mhash,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Cid represents a self-describing content adressed
|
||||||
|
// identifier. It is formed by a Version, a Codec (which indicates
|
||||||
|
// a multicodec-packed content type) and a Multihash.
|
||||||
type Cid struct {
|
type Cid struct {
|
||||||
version uint64
|
version uint64
|
||||||
codec uint64
|
codec uint64
|
||||||
hash mh.Multihash
|
hash mh.Multihash
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Parse is a short-hand function to perform Decode, Cast etc... on
|
||||||
|
// a generic interface{} type.
|
||||||
func Parse(v interface{}) (*Cid, error) {
|
func Parse(v interface{}) (*Cid, error) {
|
||||||
switch v2 := v.(type) {
|
switch v2 := v.(type) {
|
||||||
case string:
|
case string:
|
||||||
@@ -67,9 +152,21 @@ func Parse(v interface{}) (*Cid, error) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Decode parses a Cid-encoded string and returns a Cid object.
|
||||||
|
// For CidV1, a Cid-encoded string is primarily a multibase string:
|
||||||
|
//
|
||||||
|
// <multibase-type-code><base-encoded-string>
|
||||||
|
//
|
||||||
|
// The base-encoded string represents a:
|
||||||
|
//
|
||||||
|
// <version><codec-type><multihash>
|
||||||
|
//
|
||||||
|
// Decode will also detect and parse CidV0 strings. Strings
|
||||||
|
// starting with "Qm" are considered CidV0 and treated directly
|
||||||
|
// as B58-encoded multihashes.
|
||||||
func Decode(v string) (*Cid, error) {
|
func Decode(v string) (*Cid, error) {
|
||||||
if len(v) < 2 {
|
if len(v) < 2 {
|
||||||
return nil, fmt.Errorf("cid too short")
|
return nil, ErrCidTooShort
|
||||||
}
|
}
|
||||||
|
|
||||||
if len(v) == 46 && v[:2] == "Qm" {
|
if len(v) == 46 && v[:2] == "Qm" {
|
||||||
@@ -89,12 +186,6 @@ func Decode(v string) (*Cid, error) {
|
|||||||
return Cast(data)
|
return Cast(data)
|
||||||
}
|
}
|
||||||
|
|
||||||
var (
|
|
||||||
ErrVarintBuffSmall = errors.New("reading varint: buffer to small")
|
|
||||||
ErrVarintTooBig = errors.New("reading varint: varint bigger than 64bits" +
|
|
||||||
" and not supported")
|
|
||||||
)
|
|
||||||
|
|
||||||
func uvError(read int) error {
|
func uvError(read int) error {
|
||||||
switch {
|
switch {
|
||||||
case read == 0:
|
case read == 0:
|
||||||
@@ -106,6 +197,17 @@ func uvError(read int) error {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Cast takes a Cid data slice, parses it and returns a Cid.
|
||||||
|
// For CidV1, the data buffer is in the form:
|
||||||
|
//
|
||||||
|
// <version><codec-type><multihash>
|
||||||
|
//
|
||||||
|
// CidV0 are also supported. In particular, data buffers starting
|
||||||
|
// with length 34 bytes, which starts with bytes [18,32...] are considered
|
||||||
|
// binary multihashes.
|
||||||
|
//
|
||||||
|
// Please use decode when parsing a regular Cid string, as Cast does not
|
||||||
|
// expect multibase-encoded data. Cast accepts the output of Cid.Bytes().
|
||||||
func Cast(data []byte) (*Cid, error) {
|
func Cast(data []byte) (*Cid, error) {
|
||||||
if len(data) == 34 && data[0] == 18 && data[1] == 32 {
|
if len(data) == 34 && data[0] == 18 && data[1] == 32 {
|
||||||
h, err := mh.Cast(data)
|
h, err := mh.Cast(data)
|
||||||
@@ -147,10 +249,14 @@ func Cast(data []byte) (*Cid, error) {
|
|||||||
}, nil
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Type returns the multicodec-packed content type of a Cid.
|
||||||
func (c *Cid) Type() uint64 {
|
func (c *Cid) Type() uint64 {
|
||||||
return c.codec
|
return c.codec
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// String returns the default string representation of a
|
||||||
|
// Cid. Currently, Base58 is used as the encoding for the
|
||||||
|
// multibase string.
|
||||||
func (c *Cid) String() string {
|
func (c *Cid) String() string {
|
||||||
switch c.version {
|
switch c.version {
|
||||||
case 0:
|
case 0:
|
||||||
@@ -167,10 +273,30 @@ func (c *Cid) String() string {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// String returns the string representation of a Cid
|
||||||
|
// encoded is selected base
|
||||||
|
func (c *Cid) StringOfBase(base mbase.Encoding) (string, error) {
|
||||||
|
switch c.version {
|
||||||
|
case 0:
|
||||||
|
if base != mbase.Base58BTC {
|
||||||
|
return "", ErrInvalidEncoding
|
||||||
|
}
|
||||||
|
return c.hash.B58String(), nil
|
||||||
|
case 1:
|
||||||
|
return mbase.Encode(base, c.bytesV1())
|
||||||
|
default:
|
||||||
|
panic("not possible to reach this point")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Hash returns the multihash contained by a Cid.
|
||||||
func (c *Cid) Hash() mh.Multihash {
|
func (c *Cid) Hash() mh.Multihash {
|
||||||
return c.hash
|
return c.hash
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Bytes returns the byte representation of a Cid.
|
||||||
|
// The output of bytes can be parsed back into a Cid
|
||||||
|
// with Cast().
|
||||||
func (c *Cid) Bytes() []byte {
|
func (c *Cid) Bytes() []byte {
|
||||||
switch c.version {
|
switch c.version {
|
||||||
case 0:
|
case 0:
|
||||||
@@ -199,17 +325,33 @@ func (c *Cid) bytesV1() []byte {
|
|||||||
return buf[:n+len(c.hash)]
|
return buf[:n+len(c.hash)]
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Equals checks that two Cids are the same.
|
||||||
|
// In order for two Cids to be considered equal, the
|
||||||
|
// Version, the Codec and the Multihash must match.
|
||||||
func (c *Cid) Equals(o *Cid) bool {
|
func (c *Cid) Equals(o *Cid) bool {
|
||||||
return c.codec == o.codec &&
|
return c.codec == o.codec &&
|
||||||
c.version == o.version &&
|
c.version == o.version &&
|
||||||
bytes.Equal(c.hash, o.hash)
|
bytes.Equal(c.hash, o.hash)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// UnmarshalJSON parses the JSON representation of a Cid.
|
||||||
func (c *Cid) UnmarshalJSON(b []byte) error {
|
func (c *Cid) UnmarshalJSON(b []byte) error {
|
||||||
if len(b) < 2 {
|
if len(b) < 2 {
|
||||||
return fmt.Errorf("invalid cid json blob")
|
return fmt.Errorf("invalid cid json blob")
|
||||||
}
|
}
|
||||||
out, err := Decode(string(b[1 : len(b)-1]))
|
obj := struct {
|
||||||
|
CidTarget string `json:"/"`
|
||||||
|
}{}
|
||||||
|
err := json.Unmarshal(b, &obj)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
if obj.CidTarget == "" {
|
||||||
|
return fmt.Errorf("cid was incorrectly formatted")
|
||||||
|
}
|
||||||
|
|
||||||
|
out, err := Decode(obj.CidTarget)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
@@ -220,20 +362,30 @@ func (c *Cid) UnmarshalJSON(b []byte) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// MarshalJSON procudes a JSON representation of a Cid, which looks as follows:
|
||||||
|
//
|
||||||
|
// { "/": "<cid-string>" }
|
||||||
|
//
|
||||||
|
// Note that this formatting comes from the IPLD specification
|
||||||
|
// (https://github.com/ipld/specs/tree/master/ipld)
|
||||||
func (c *Cid) MarshalJSON() ([]byte, error) {
|
func (c *Cid) MarshalJSON() ([]byte, error) {
|
||||||
return []byte(fmt.Sprintf("\"%s\"", c.String())), nil
|
return []byte(fmt.Sprintf("{\"/\":\"%s\"}", c.String())), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// KeyString casts the result of cid.Bytes() as a string, and returns it.
|
||||||
func (c *Cid) KeyString() string {
|
func (c *Cid) KeyString() string {
|
||||||
return string(c.Bytes())
|
return string(c.Bytes())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Loggable returns a Loggable (as defined by
|
||||||
|
// https://godoc.org/github.com/ipfs/go-log).
|
||||||
func (c *Cid) Loggable() map[string]interface{} {
|
func (c *Cid) Loggable() map[string]interface{} {
|
||||||
return map[string]interface{}{
|
return map[string]interface{}{
|
||||||
"cid": c,
|
"cid": c,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Prefix builds and returns a Prefix out of a Cid.
|
||||||
func (c *Cid) Prefix() Prefix {
|
func (c *Cid) Prefix() Prefix {
|
||||||
dec, _ := mh.Decode(c.hash) // assuming we got a valid multiaddr, this will not error
|
dec, _ := mh.Decode(c.hash) // assuming we got a valid multiaddr, this will not error
|
||||||
return Prefix{
|
return Prefix{
|
||||||
@@ -244,14 +396,19 @@ func (c *Cid) Prefix() Prefix {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Prefix represents all the metadata of a cid, minus any actual content information
|
// Prefix represents all the metadata of a Cid,
|
||||||
|
// that is, the Version, the Codec, the Multihash type
|
||||||
|
// and the Multihash length. It does not contains
|
||||||
|
// any actual content information.
|
||||||
type Prefix struct {
|
type Prefix struct {
|
||||||
Version uint64
|
Version uint64
|
||||||
Codec uint64
|
Codec uint64
|
||||||
MhType int
|
MhType uint64
|
||||||
MhLength int
|
MhLength int
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Sum uses the information in a prefix to perform a multihash.Sum()
|
||||||
|
// and return a newly constructed Cid with the resulting multihash.
|
||||||
func (p Prefix) Sum(data []byte) (*Cid, error) {
|
func (p Prefix) Sum(data []byte) (*Cid, error) {
|
||||||
hash, err := mh.Sum(data, p.MhType, p.MhLength)
|
hash, err := mh.Sum(data, p.MhType, p.MhLength)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -268,6 +425,9 @@ func (p Prefix) Sum(data []byte) (*Cid, error) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Bytes returns a byte representation of a Prefix. It looks like:
|
||||||
|
//
|
||||||
|
// <version><codec><mh-type><mh-length>
|
||||||
func (p Prefix) Bytes() []byte {
|
func (p Prefix) Bytes() []byte {
|
||||||
buf := make([]byte, 4*binary.MaxVarintLen64)
|
buf := make([]byte, 4*binary.MaxVarintLen64)
|
||||||
n := binary.PutUvarint(buf, p.Version)
|
n := binary.PutUvarint(buf, p.Version)
|
||||||
@@ -277,6 +437,8 @@ func (p Prefix) Bytes() []byte {
|
|||||||
return buf[:n]
|
return buf[:n]
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// PrefixFromBytes parses a Prefix-byte representation onto a
|
||||||
|
// Prefix.
|
||||||
func PrefixFromBytes(buf []byte) (Prefix, error) {
|
func PrefixFromBytes(buf []byte) (Prefix, error) {
|
||||||
r := bytes.NewReader(buf)
|
r := bytes.NewReader(buf)
|
||||||
vers, err := binary.ReadUvarint(r)
|
vers, err := binary.ReadUvarint(r)
|
||||||
@@ -302,7 +464,7 @@ func PrefixFromBytes(buf []byte) (Prefix, error) {
|
|||||||
return Prefix{
|
return Prefix{
|
||||||
Version: vers,
|
Version: vers,
|
||||||
Codec: codec,
|
Codec: codec,
|
||||||
MhType: int(mhtype),
|
MhType: mhtype,
|
||||||
MhLength: int(mhlen),
|
MhLength: int(mhlen),
|
||||||
}, nil
|
}, nil
|
||||||
}
|
}
|
||||||
|
|||||||
125
cid_test.go
125
cid_test.go
@@ -2,14 +2,39 @@ package cid
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"bytes"
|
"bytes"
|
||||||
|
"encoding/json"
|
||||||
"fmt"
|
"fmt"
|
||||||
"math/rand"
|
"math/rand"
|
||||||
"strings"
|
"strings"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
|
mbase "github.com/multiformats/go-multibase"
|
||||||
mh "github.com/multiformats/go-multihash"
|
mh "github.com/multiformats/go-multihash"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
// Copying the "silly test" idea from
|
||||||
|
// https://github.com/multiformats/go-multihash/blob/7aa9f26a231c6f34f4e9fad52bf580fd36627285/multihash_test.go#L13
|
||||||
|
// Makes it so changing the table accidentally has to happen twice.
|
||||||
|
var tCodecs = map[uint64]string{
|
||||||
|
Raw: "raw",
|
||||||
|
DagProtobuf: "protobuf",
|
||||||
|
DagCBOR: "cbor",
|
||||||
|
GitRaw: "git-raw",
|
||||||
|
EthBlock: "eth-block",
|
||||||
|
EthBlockList: "eth-block-list",
|
||||||
|
EthTxTrie: "eth-tx-trie",
|
||||||
|
EthTx: "eth-tx",
|
||||||
|
EthTxReceiptTrie: "eth-tx-receipt-trie",
|
||||||
|
EthTxReceipt: "eth-tx-receipt",
|
||||||
|
EthStateTrie: "eth-state-trie",
|
||||||
|
EthAccountSnapshot: "eth-account-snapshot",
|
||||||
|
EthStorageTrie: "eth-storage-trie",
|
||||||
|
BitcoinBlock: "bitcoin-block",
|
||||||
|
BitcoinTx: "bitcoin-tx",
|
||||||
|
ZcashBlock: "zcash-block",
|
||||||
|
ZcashTx: "zcash-tx",
|
||||||
|
}
|
||||||
|
|
||||||
func assertEqual(t *testing.T, a, b *Cid) {
|
func assertEqual(t *testing.T, a, b *Cid) {
|
||||||
if a.codec != b.codec {
|
if a.codec != b.codec {
|
||||||
t.Fatal("mismatch on type")
|
t.Fatal("mismatch on type")
|
||||||
@@ -24,6 +49,26 @@ func assertEqual(t *testing.T, a, b *Cid) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestTable(t *testing.T) {
|
||||||
|
if len(tCodecs) != len(Codecs)-1 {
|
||||||
|
t.Errorf("Item count mismatch in the Table of Codec. Should be %d, got %d", len(tCodecs)+1, len(Codecs))
|
||||||
|
}
|
||||||
|
|
||||||
|
for k, v := range tCodecs {
|
||||||
|
if Codecs[v] != k {
|
||||||
|
t.Errorf("Table mismatch: 0x%x %s", k, v)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// The table returns cid.DagProtobuf for "v0"
|
||||||
|
// so we test it apart
|
||||||
|
func TestTableForV0(t *testing.T) {
|
||||||
|
if Codecs["v0"] != DagProtobuf {
|
||||||
|
t.Error("Table mismatch: Codecs[\"v0\"] should resolve to DagProtobuf (0x70)")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func TestBasicMarshaling(t *testing.T) {
|
func TestBasicMarshaling(t *testing.T) {
|
||||||
h, err := mh.Sum([]byte("TEST"), mh.SHA3, 4)
|
h, err := mh.Sum([]byte("TEST"), mh.SHA3, 4)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -54,6 +99,60 @@ func TestBasicMarshaling(t *testing.T) {
|
|||||||
assertEqual(t, cid, out2)
|
assertEqual(t, cid, out2)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestBasesMarshaling(t *testing.T) {
|
||||||
|
h, err := mh.Sum([]byte("TEST"), mh.SHA3, 4)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
cid := &Cid{
|
||||||
|
codec: 7,
|
||||||
|
version: 1,
|
||||||
|
hash: h,
|
||||||
|
}
|
||||||
|
|
||||||
|
data := cid.Bytes()
|
||||||
|
|
||||||
|
out, err := Cast(data)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
assertEqual(t, cid, out)
|
||||||
|
|
||||||
|
testBases := []mbase.Encoding{
|
||||||
|
mbase.Base16,
|
||||||
|
mbase.Base32,
|
||||||
|
mbase.Base32hex,
|
||||||
|
mbase.Base32pad,
|
||||||
|
mbase.Base32hexPad,
|
||||||
|
mbase.Base58BTC,
|
||||||
|
mbase.Base58Flickr,
|
||||||
|
mbase.Base64pad,
|
||||||
|
mbase.Base64urlPad,
|
||||||
|
mbase.Base64url,
|
||||||
|
mbase.Base64,
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, b := range testBases {
|
||||||
|
s, err := cid.StringOfBase(b)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
if s[0] != byte(b) {
|
||||||
|
t.Fatal("Invalid multibase header")
|
||||||
|
}
|
||||||
|
|
||||||
|
out2, err := Decode(s)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
assertEqual(t, cid, out2)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func TestEmptyString(t *testing.T) {
|
func TestEmptyString(t *testing.T) {
|
||||||
_, err := Decode("")
|
_, err := Decode("")
|
||||||
if err == nil {
|
if err == nil {
|
||||||
@@ -200,3 +299,29 @@ func TestHexDecode(t *testing.T) {
|
|||||||
t.Fatal("hash value failed to round trip decoding from hex")
|
t.Fatal("hash value failed to round trip decoding from hex")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func ExampleDecode() {
|
||||||
|
encoded := "zb2rhhFAEMepUBbGyP1k8tGfz7BSciKXP6GHuUeUsJBaK6cqG"
|
||||||
|
c, err := Decode(encoded)
|
||||||
|
if err != nil {
|
||||||
|
fmt.Printf("Error: %s", err)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
fmt.Println(c)
|
||||||
|
// Output: zb2rhhFAEMepUBbGyP1k8tGfz7BSciKXP6GHuUeUsJBaK6cqG
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestFromJson(t *testing.T) {
|
||||||
|
cval := "zb2rhhFAEMepUBbGyP1k8tGfz7BSciKXP6GHuUeUsJBaK6cqG"
|
||||||
|
jsoncid := []byte(`{"/":"` + cval + `"}`)
|
||||||
|
var c Cid
|
||||||
|
err := json.Unmarshal(jsoncid, &c)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
if c.String() != cval {
|
||||||
|
t.Fatal("json parsing failed")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
3
codecov.yml
Normal file
3
codecov.yml
Normal file
@@ -0,0 +1,3 @@
|
|||||||
|
coverage:
|
||||||
|
range: "50...100"
|
||||||
|
comment: off
|
||||||
10
package.json
10
package.json
@@ -9,15 +9,15 @@
|
|||||||
"gxDependencies": [
|
"gxDependencies": [
|
||||||
{
|
{
|
||||||
"author": "whyrusleeping",
|
"author": "whyrusleeping",
|
||||||
"hash": "QmYDds3421prZgqKbLpEK7T9Aa2eVdQ7o3YarX1LVLdP2J",
|
"hash": "QmVGtdTZdTFaLsaj2RwdVG8jcjNNcp1DE914DKZ2kHmXHw",
|
||||||
"name": "go-multihash",
|
"name": "go-multihash",
|
||||||
"version": "1.0.0"
|
"version": "1.0.4"
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"author": "whyrusleeping",
|
"author": "whyrusleeping",
|
||||||
"hash": "QmXzWFN4iLdX1Vq8Sc13mET7aXsHkTyJoMbaJJD3NGRhiJ",
|
"hash": "Qme4T6BE4sQxg7ZouamF5M7Tx1ZFTqzcns7BkyQPXpoT99",
|
||||||
"name": "go-multibase",
|
"name": "go-multibase",
|
||||||
"version": "0.2.1"
|
"version": "0.2.4"
|
||||||
}
|
}
|
||||||
],
|
],
|
||||||
"gxVersion": "0.8.0",
|
"gxVersion": "0.8.0",
|
||||||
@@ -25,6 +25,6 @@
|
|||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"name": "go-cid",
|
"name": "go-cid",
|
||||||
"releaseCmd": "git commit -a -m \"gx publish $VERSION\"",
|
"releaseCmd": "git commit -a -m \"gx publish $VERSION\"",
|
||||||
"version": "0.7.8"
|
"version": "0.7.16"
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
16
set.go
16
set.go
@@ -1,39 +1,49 @@
|
|||||||
package cid
|
package cid
|
||||||
|
|
||||||
|
// Set is a implementation of a set of Cids, that is, a structure
|
||||||
|
// to which holds a single copy of every Cids that is added to it.
|
||||||
type Set struct {
|
type Set struct {
|
||||||
set map[string]struct{}
|
set map[string]struct{}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// NewSet initializes and returns a new Set.
|
||||||
func NewSet() *Set {
|
func NewSet() *Set {
|
||||||
return &Set{set: make(map[string]struct{})}
|
return &Set{set: make(map[string]struct{})}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Add puts a Cid in the Set.
|
||||||
func (s *Set) Add(c *Cid) {
|
func (s *Set) Add(c *Cid) {
|
||||||
s.set[string(c.Bytes())] = struct{}{}
|
s.set[string(c.Bytes())] = struct{}{}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Has returns if the Set contains a given Cid.
|
||||||
func (s *Set) Has(c *Cid) bool {
|
func (s *Set) Has(c *Cid) bool {
|
||||||
_, ok := s.set[string(c.Bytes())]
|
_, ok := s.set[string(c.Bytes())]
|
||||||
return ok
|
return ok
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Remove deletes a Cid from the Set.
|
||||||
func (s *Set) Remove(c *Cid) {
|
func (s *Set) Remove(c *Cid) {
|
||||||
delete(s.set, string(c.Bytes()))
|
delete(s.set, string(c.Bytes()))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Len returns how many elements the Set has.
|
||||||
func (s *Set) Len() int {
|
func (s *Set) Len() int {
|
||||||
return len(s.set)
|
return len(s.set)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Keys returns the Cids in the set.
|
||||||
func (s *Set) Keys() []*Cid {
|
func (s *Set) Keys() []*Cid {
|
||||||
out := make([]*Cid, 0, len(s.set))
|
out := make([]*Cid, 0, len(s.set))
|
||||||
for k, _ := range s.set {
|
for k := range s.set {
|
||||||
c, _ := Cast([]byte(k))
|
c, _ := Cast([]byte(k))
|
||||||
out = append(out, c)
|
out = append(out, c)
|
||||||
}
|
}
|
||||||
return out
|
return out
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Visit adds a Cid to the set only if it is
|
||||||
|
// not in it already.
|
||||||
func (s *Set) Visit(c *Cid) bool {
|
func (s *Set) Visit(c *Cid) bool {
|
||||||
if !s.Has(c) {
|
if !s.Has(c) {
|
||||||
s.Add(c)
|
s.Add(c)
|
||||||
@@ -43,8 +53,10 @@ func (s *Set) Visit(c *Cid) bool {
|
|||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// ForEach allows to run a custom function on each
|
||||||
|
// Cid in the set.
|
||||||
func (s *Set) ForEach(f func(c *Cid) error) error {
|
func (s *Set) ForEach(f func(c *Cid) error) error {
|
||||||
for cs, _ := range s.set {
|
for cs := range s.set {
|
||||||
c, _ := Cast([]byte(cs))
|
c, _ := Cast([]byte(cs))
|
||||||
err := f(c)
|
err := f(c)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
Reference in New Issue
Block a user