Compare commits
37 Commits
v0.0.5
...
update-x-c
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
e2d6877ec4 | ||
|
|
de3d9105b0 | ||
|
|
57a5ebd412 | ||
|
|
6f6f7847b9 | ||
|
|
d9a0b590b9 | ||
|
|
9aebf1d9d0 | ||
|
|
0582f6b9b2 | ||
|
|
0717510dfb | ||
|
|
e530276a70 | ||
|
|
45f4147a06 | ||
|
|
b34ad3cfa5 | ||
|
|
ec089b8a53 | ||
|
|
efe2d2de45 | ||
|
|
46aac88838 | ||
|
|
f60e346b24 | ||
|
|
8647a1d84b | ||
|
|
de49849130 | ||
|
|
8b9ff3906e | ||
|
|
f7cb4c91eb | ||
|
|
85cd30874e | ||
|
|
12e2623f35 | ||
|
|
d683e9243c | ||
|
|
18af217de6 | ||
|
|
9830f823b5 | ||
|
|
d110f73c43 | ||
|
|
95a7ed4233 | ||
|
|
8dd6fe2778 | ||
|
|
a25d68f3e4 | ||
|
|
7c82f3b81c | ||
|
|
75caa6bdbd | ||
|
|
c1c89c20c1 | ||
|
|
628a0123ed | ||
|
|
266e76d591 | ||
|
|
7d7cb88d78 | ||
|
|
723b4ab105 | ||
|
|
9cb3848e51 | ||
|
|
f458e04107 |
8
.github/ISSUE_TEMPLATE/config.yml
vendored
Normal file
8
.github/ISSUE_TEMPLATE/config.yml
vendored
Normal file
@@ -0,0 +1,8 @@
|
|||||||
|
blank_issues_enabled: false
|
||||||
|
contact_links:
|
||||||
|
- name: Getting Help on IPFS
|
||||||
|
url: https://ipfs.io/help
|
||||||
|
about: All information about how and where to get help on IPFS.
|
||||||
|
- name: IPFS Official Forum
|
||||||
|
url: https://discuss.ipfs.io
|
||||||
|
about: Please post general questions, support requests, and discussions here.
|
||||||
19
.github/ISSUE_TEMPLATE/open_an_issue.md
vendored
Normal file
19
.github/ISSUE_TEMPLATE/open_an_issue.md
vendored
Normal file
@@ -0,0 +1,19 @@
|
|||||||
|
---
|
||||||
|
name: Open an issue
|
||||||
|
about: Only for actionable issues relevant to this repository.
|
||||||
|
title: ''
|
||||||
|
labels: need/triage
|
||||||
|
assignees: ''
|
||||||
|
|
||||||
|
---
|
||||||
|
<!--
|
||||||
|
Hello! To ensure this issue is correctly addressed as soon as possible by the IPFS team, please try to make sure:
|
||||||
|
|
||||||
|
- This issue is relevant to this repository's topic or codebase.
|
||||||
|
|
||||||
|
- A clear description is provided. It should includes as much relevant information as possible and clear scope for the issue to be actionable.
|
||||||
|
|
||||||
|
FOR GENERAL DISCUSSION, HELP OR QUESTIONS, please see the options at https://ipfs.io/help or head directly to https://discuss.ipfs.io.
|
||||||
|
|
||||||
|
(you can delete this section after reading)
|
||||||
|
-->
|
||||||
68
.github/config.yml
vendored
Normal file
68
.github/config.yml
vendored
Normal file
@@ -0,0 +1,68 @@
|
|||||||
|
# Configuration for welcome - https://github.com/behaviorbot/welcome
|
||||||
|
|
||||||
|
# Configuration for new-issue-welcome - https://github.com/behaviorbot/new-issue-welcome
|
||||||
|
# Comment to be posted to on first time issues
|
||||||
|
newIssueWelcomeComment: >
|
||||||
|
Thank you for submitting your first issue to this repository! A maintainer
|
||||||
|
will be here shortly to triage and review.
|
||||||
|
|
||||||
|
In the meantime, please double-check that you have provided all the
|
||||||
|
necessary information to make this process easy! Any information that can
|
||||||
|
help save additional round trips is useful! We currently aim to give
|
||||||
|
initial feedback within **two business days**. If this does not happen, feel
|
||||||
|
free to leave a comment.
|
||||||
|
|
||||||
|
Please keep an eye on how this issue will be labeled, as labels give an
|
||||||
|
overview of priorities, assignments and additional actions requested by the
|
||||||
|
maintainers:
|
||||||
|
|
||||||
|
- "Priority" labels will show how urgent this is for the team.
|
||||||
|
- "Status" labels will show if this is ready to be worked on, blocked, or in progress.
|
||||||
|
- "Need" labels will indicate if additional input or analysis is required.
|
||||||
|
|
||||||
|
Finally, remember to use https://discuss.ipfs.io if you just need general
|
||||||
|
support.
|
||||||
|
|
||||||
|
# Configuration for new-pr-welcome - https://github.com/behaviorbot/new-pr-welcome
|
||||||
|
# Comment to be posted to on PRs from first time contributors in your repository
|
||||||
|
newPRWelcomeComment: >
|
||||||
|
Thank you for submitting this PR!
|
||||||
|
|
||||||
|
A maintainer will be here shortly to review it.
|
||||||
|
|
||||||
|
We are super grateful, but we are also overloaded! Help us by making sure
|
||||||
|
that:
|
||||||
|
|
||||||
|
* The context for this PR is clear, with relevant discussion, decisions
|
||||||
|
and stakeholders linked/mentioned.
|
||||||
|
|
||||||
|
* Your contribution itself is clear (code comments, self-review for the
|
||||||
|
rest) and in its best form. Follow the [code contribution
|
||||||
|
guidelines](https://github.com/ipfs/community/blob/master/CONTRIBUTING.md#code-contribution-guidelines)
|
||||||
|
if they apply.
|
||||||
|
|
||||||
|
Getting other community members to do a review would be great help too on
|
||||||
|
complex PRs (you can ask in the chats/forums). If you are unsure about
|
||||||
|
something, just leave us a comment.
|
||||||
|
|
||||||
|
Next steps:
|
||||||
|
|
||||||
|
* A maintainer will triage and assign priority to this PR, commenting on
|
||||||
|
any missing things and potentially assigning a reviewer for high
|
||||||
|
priority items.
|
||||||
|
|
||||||
|
* The PR gets reviews, discussed and approvals as needed.
|
||||||
|
|
||||||
|
* The PR is merged by maintainers when it has been approved and comments addressed.
|
||||||
|
|
||||||
|
We currently aim to provide initial feedback/triaging within **two business
|
||||||
|
days**. Please keep an eye on any labelling actions, as these will indicate
|
||||||
|
priorities and status of your contribution.
|
||||||
|
|
||||||
|
We are very grateful for your contribution!
|
||||||
|
|
||||||
|
|
||||||
|
# Configuration for first-pr-merge - https://github.com/behaviorbot/first-pr-merge
|
||||||
|
# Comment to be posted to on pull requests merged by a first time user
|
||||||
|
# Currently disabled
|
||||||
|
#firstPRMergeComment: ""
|
||||||
27
.github/workflows/automerge.yml
vendored
Normal file
27
.github/workflows/automerge.yml
vendored
Normal file
@@ -0,0 +1,27 @@
|
|||||||
|
# File managed by web3-bot. DO NOT EDIT.
|
||||||
|
# See https://github.com/protocol/.github/ for details.
|
||||||
|
|
||||||
|
# Automatically merge pull requests opened by web3-bot, as soon as (and only if) all tests pass.
|
||||||
|
# This reduces the friction associated with updating with our workflows.
|
||||||
|
|
||||||
|
on: [ pull_request ]
|
||||||
|
|
||||||
|
jobs:
|
||||||
|
automerge:
|
||||||
|
if: github.event.pull_request.user.login == 'web3-bot'
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
steps:
|
||||||
|
- name: Wait on tests
|
||||||
|
uses: lewagon/wait-on-check-action@bafe56a6863672c681c3cf671f5e10b20abf2eaa # v0.2
|
||||||
|
with:
|
||||||
|
ref: ${{ github.event.pull_request.head.sha }}
|
||||||
|
repo-token: ${{ secrets.GITHUB_TOKEN }}
|
||||||
|
wait-interval: 10
|
||||||
|
running-workflow-name: 'automerge' # the name of this job
|
||||||
|
- name: Merge PR
|
||||||
|
uses: pascalgn/automerge-action@741c311a47881be9625932b0a0de1b0937aab1ae # v0.13.1
|
||||||
|
env:
|
||||||
|
GITHUB_TOKEN: "${{ secrets.GITHUB_TOKEN }}"
|
||||||
|
MERGE_LABELS: ""
|
||||||
|
MERGE_METHOD: "squash"
|
||||||
|
MERGE_DELETE_BRANCH: true
|
||||||
41
.github/workflows/go-check.yml
vendored
Normal file
41
.github/workflows/go-check.yml
vendored
Normal file
@@ -0,0 +1,41 @@
|
|||||||
|
# File managed by web3-bot. DO NOT EDIT.
|
||||||
|
# See https://github.com/protocol/.github/ for details.
|
||||||
|
|
||||||
|
on: [push, pull_request]
|
||||||
|
|
||||||
|
jobs:
|
||||||
|
unit:
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
name: Go checks
|
||||||
|
steps:
|
||||||
|
- uses: actions/checkout@v2
|
||||||
|
- uses: actions/setup-go@v2
|
||||||
|
with:
|
||||||
|
go-version: "1.16.x"
|
||||||
|
- name: Install staticcheck
|
||||||
|
run: go install honnef.co/go/tools/cmd/staticcheck@be534f007836a777104a15f2456cd1fffd3ddee8 # v2020.2.2
|
||||||
|
- name: Check that go.mod is tidy
|
||||||
|
run: |
|
||||||
|
go mod tidy
|
||||||
|
if [[ -n $(git ls-files --other --exclude-standard --directory -- go.sum) ]]; then
|
||||||
|
echo "go.sum was added by go mod tidy"
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
|
git diff --exit-code -- go.sum go.mod
|
||||||
|
- name: gofmt
|
||||||
|
if: ${{ success() || failure() }} # run this step even if the previous one failed
|
||||||
|
run: |
|
||||||
|
out=$(gofmt -s -l .)
|
||||||
|
if [[ -n "$out" ]]; then
|
||||||
|
echo $out | awk '{print "::error file=" $0 ",line=0,col=0::File is not gofmt-ed."}'
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
|
- name: go vet
|
||||||
|
if: ${{ success() || failure() }} # run this step even if the previous one failed
|
||||||
|
run: go vet ./...
|
||||||
|
- name: staticcheck
|
||||||
|
if: ${{ success() || failure() }} # run this step even if the previous one failed
|
||||||
|
run: |
|
||||||
|
set -o pipefail
|
||||||
|
staticcheck ./... | sed -e 's@\(.*\)\.go@./\1.go@g'
|
||||||
|
|
||||||
38
.github/workflows/go-test.yml
vendored
Normal file
38
.github/workflows/go-test.yml
vendored
Normal file
@@ -0,0 +1,38 @@
|
|||||||
|
# File managed by web3-bot. DO NOT EDIT.
|
||||||
|
# See https://github.com/protocol/.github/ for details.
|
||||||
|
|
||||||
|
on: [push, pull_request]
|
||||||
|
|
||||||
|
jobs:
|
||||||
|
unit:
|
||||||
|
strategy:
|
||||||
|
fail-fast: false
|
||||||
|
matrix:
|
||||||
|
os: [ "ubuntu", "windows", "macos" ]
|
||||||
|
go: [ "1.15.x", "1.16.x" ]
|
||||||
|
runs-on: ${{ matrix.os }}-latest
|
||||||
|
name: Unit tests (${{ matrix.os}}, Go ${{ matrix.go }})
|
||||||
|
steps:
|
||||||
|
- uses: actions/checkout@v2
|
||||||
|
- uses: actions/setup-go@v2
|
||||||
|
with:
|
||||||
|
go-version: ${{ matrix.go }}
|
||||||
|
- name: Go information
|
||||||
|
run: |
|
||||||
|
go version
|
||||||
|
go env
|
||||||
|
- name: Run tests
|
||||||
|
run: go test -v -coverprofile coverage.txt ./...
|
||||||
|
- name: Run tests (32 bit)
|
||||||
|
if: ${{ matrix.os != 'macos' }} # can't run 32 bit tests on OSX.
|
||||||
|
env:
|
||||||
|
GOARCH: 386
|
||||||
|
run: go test -v ./...
|
||||||
|
- name: Run tests with race detector
|
||||||
|
if: ${{ matrix.os == 'ubuntu' }} # speed things up. Windows and OSX VMs are slow
|
||||||
|
run: go test -v -race ./...
|
||||||
|
- name: Upload coverage to Codecov
|
||||||
|
uses: codecov/codecov-action@967e2b38a85a62bd61be5529ada27ebc109948c2 # v1.4.1
|
||||||
|
with:
|
||||||
|
file: coverage.txt
|
||||||
|
env_vars: OS=${{ matrix.os }}, GO=${{ matrix.go }}
|
||||||
@@ -1 +0,0 @@
|
|||||||
0.9.3: QmTbxNB1NwDesLmKTscr4udL2tVP7MaxvXnD1D9yX7g3PN
|
|
||||||
31
.travis.yml
31
.travis.yml
@@ -1,31 +0,0 @@
|
|||||||
os:
|
|
||||||
- linux
|
|
||||||
|
|
||||||
language: go
|
|
||||||
|
|
||||||
go:
|
|
||||||
- 1.11.x
|
|
||||||
|
|
||||||
env:
|
|
||||||
global:
|
|
||||||
- GOTFLAGS="-race"
|
|
||||||
matrix:
|
|
||||||
- BUILD_DEPTYPE=gomod
|
|
||||||
|
|
||||||
|
|
||||||
# disable travis install
|
|
||||||
install:
|
|
||||||
- true
|
|
||||||
|
|
||||||
script:
|
|
||||||
- bash <(curl -s https://raw.githubusercontent.com/ipfs/ci-helpers/master/travis-ci/run-standard-tests.sh)
|
|
||||||
|
|
||||||
|
|
||||||
cache:
|
|
||||||
directories:
|
|
||||||
- $GOPATH/src/gx
|
|
||||||
- $GOPATH/pkg/mod
|
|
||||||
- $HOME/.cache/go-build
|
|
||||||
|
|
||||||
notifications:
|
|
||||||
email: false
|
|
||||||
13
Makefile
13
Makefile
@@ -1,16 +1,5 @@
|
|||||||
all: deps
|
all: deps
|
||||||
|
|
||||||
gx:
|
deps:
|
||||||
go get github.com/whyrusleeping/gx
|
|
||||||
go get github.com/whyrusleeping/gx-go
|
|
||||||
|
|
||||||
covertools:
|
|
||||||
go get github.com/mattn/goveralls
|
go get github.com/mattn/goveralls
|
||||||
go get golang.org/x/tools/cmd/cover
|
go get golang.org/x/tools/cmd/cover
|
||||||
|
|
||||||
deps: gx covertools
|
|
||||||
gx --verbose install --global
|
|
||||||
gx-go rewrite
|
|
||||||
|
|
||||||
publish:
|
|
||||||
gx-go rewrite --undo
|
|
||||||
|
|||||||
@@ -65,9 +65,29 @@ func TestCodecChange(t *testing.T) {
|
|||||||
p := Prefix{Version: 1, Codec: DagProtobuf, MhType: mh.SHA2_256, MhLength: mh.DefaultLengths[mh.SHA2_256]}
|
p := Prefix{Version: 1, Codec: DagProtobuf, MhType: mh.SHA2_256, MhLength: mh.DefaultLengths[mh.SHA2_256]}
|
||||||
testCodecChange(t, p)
|
testCodecChange(t, p)
|
||||||
})
|
})
|
||||||
|
t.Run("Prefix-NoChange", func(t *testing.T) {
|
||||||
|
p := Prefix{Version: 0, Codec: DagProtobuf, MhType: mh.SHA2_256, MhLength: mh.DefaultLengths[mh.SHA2_256]}
|
||||||
|
if p.GetCodec() != DagProtobuf {
|
||||||
|
t.Fatal("original builder not using Protobuf codec")
|
||||||
|
}
|
||||||
|
pn := p.WithCodec(DagProtobuf)
|
||||||
|
if pn != p {
|
||||||
|
t.Fatal("should have returned same builder")
|
||||||
|
}
|
||||||
|
})
|
||||||
t.Run("V0Builder", func(t *testing.T) {
|
t.Run("V0Builder", func(t *testing.T) {
|
||||||
testCodecChange(t, V0Builder{})
|
testCodecChange(t, V0Builder{})
|
||||||
})
|
})
|
||||||
|
t.Run("V0Builder-NoChange", func(t *testing.T) {
|
||||||
|
b := V0Builder{}
|
||||||
|
if b.GetCodec() != DagProtobuf {
|
||||||
|
t.Fatal("original builder not using Protobuf codec")
|
||||||
|
}
|
||||||
|
bn := b.WithCodec(DagProtobuf)
|
||||||
|
if bn != b {
|
||||||
|
t.Fatal("should have returned same builder")
|
||||||
|
}
|
||||||
|
})
|
||||||
t.Run("V1Builder", func(t *testing.T) {
|
t.Run("V1Builder", func(t *testing.T) {
|
||||||
testCodecChange(t, V1Builder{Codec: DagProtobuf, MhType: mh.SHA2_256})
|
testCodecChange(t, V1Builder{Codec: DagProtobuf, MhType: mh.SHA2_256})
|
||||||
})
|
})
|
||||||
|
|||||||
199
cid.go
199
cid.go
@@ -25,6 +25,7 @@ import (
|
|||||||
"encoding/json"
|
"encoding/json"
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
"io"
|
||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
mbase "github.com/multiformats/go-multibase"
|
mbase "github.com/multiformats/go-multibase"
|
||||||
@@ -57,75 +58,84 @@ const (
|
|||||||
|
|
||||||
GitRaw = 0x78
|
GitRaw = 0x78
|
||||||
|
|
||||||
EthBlock = 0x90
|
DagJOSE = 0x85
|
||||||
EthBlockList = 0x91
|
EthBlock = 0x90
|
||||||
EthTxTrie = 0x92
|
EthBlockList = 0x91
|
||||||
EthTx = 0x93
|
EthTxTrie = 0x92
|
||||||
EthTxReceiptTrie = 0x94
|
EthTx = 0x93
|
||||||
EthTxReceipt = 0x95
|
EthTxReceiptTrie = 0x94
|
||||||
EthStateTrie = 0x96
|
EthTxReceipt = 0x95
|
||||||
EthAccountSnapshot = 0x97
|
EthStateTrie = 0x96
|
||||||
EthStorageTrie = 0x98
|
EthAccountSnapshot = 0x97
|
||||||
BitcoinBlock = 0xb0
|
EthStorageTrie = 0x98
|
||||||
BitcoinTx = 0xb1
|
BitcoinBlock = 0xb0
|
||||||
ZcashBlock = 0xc0
|
BitcoinTx = 0xb1
|
||||||
ZcashTx = 0xc1
|
ZcashBlock = 0xc0
|
||||||
DecredBlock = 0xe0
|
ZcashTx = 0xc1
|
||||||
DecredTx = 0xe1
|
DecredBlock = 0xe0
|
||||||
DashBlock = 0xf0
|
DecredTx = 0xe1
|
||||||
DashTx = 0xf1
|
DashBlock = 0xf0
|
||||||
|
DashTx = 0xf1
|
||||||
|
FilCommitmentUnsealed = 0xf101
|
||||||
|
FilCommitmentSealed = 0xf102
|
||||||
)
|
)
|
||||||
|
|
||||||
// Codecs maps the name of a codec to its type
|
// Codecs maps the name of a codec to its type
|
||||||
var Codecs = map[string]uint64{
|
var Codecs = map[string]uint64{
|
||||||
"v0": DagProtobuf,
|
"v0": DagProtobuf,
|
||||||
"raw": Raw,
|
"raw": Raw,
|
||||||
"protobuf": DagProtobuf,
|
"protobuf": DagProtobuf,
|
||||||
"cbor": DagCBOR,
|
"cbor": DagCBOR,
|
||||||
"libp2p-key": Libp2pKey,
|
"libp2p-key": Libp2pKey,
|
||||||
"git-raw": GitRaw,
|
"git-raw": GitRaw,
|
||||||
"eth-block": EthBlock,
|
"eth-block": EthBlock,
|
||||||
"eth-block-list": EthBlockList,
|
"eth-block-list": EthBlockList,
|
||||||
"eth-tx-trie": EthTxTrie,
|
"eth-tx-trie": EthTxTrie,
|
||||||
"eth-tx": EthTx,
|
"eth-tx": EthTx,
|
||||||
"eth-tx-receipt-trie": EthTxReceiptTrie,
|
"eth-tx-receipt-trie": EthTxReceiptTrie,
|
||||||
"eth-tx-receipt": EthTxReceipt,
|
"eth-tx-receipt": EthTxReceipt,
|
||||||
"eth-state-trie": EthStateTrie,
|
"eth-state-trie": EthStateTrie,
|
||||||
"eth-account-snapshot": EthAccountSnapshot,
|
"eth-account-snapshot": EthAccountSnapshot,
|
||||||
"eth-storage-trie": EthStorageTrie,
|
"eth-storage-trie": EthStorageTrie,
|
||||||
"bitcoin-block": BitcoinBlock,
|
"bitcoin-block": BitcoinBlock,
|
||||||
"bitcoin-tx": BitcoinTx,
|
"bitcoin-tx": BitcoinTx,
|
||||||
"zcash-block": ZcashBlock,
|
"zcash-block": ZcashBlock,
|
||||||
"zcash-tx": ZcashTx,
|
"zcash-tx": ZcashTx,
|
||||||
"decred-block": DecredBlock,
|
"decred-block": DecredBlock,
|
||||||
"decred-tx": DecredTx,
|
"decred-tx": DecredTx,
|
||||||
"dash-block": DashBlock,
|
"dash-block": DashBlock,
|
||||||
"dash-tx": DashTx,
|
"dash-tx": DashTx,
|
||||||
|
"fil-commitment-unsealed": FilCommitmentUnsealed,
|
||||||
|
"fil-commitment-sealed": FilCommitmentSealed,
|
||||||
|
"dag-jose": DagJOSE,
|
||||||
}
|
}
|
||||||
|
|
||||||
// CodecToStr maps the numeric codec to its name
|
// CodecToStr maps the numeric codec to its name
|
||||||
var CodecToStr = map[uint64]string{
|
var CodecToStr = map[uint64]string{
|
||||||
Raw: "raw",
|
Raw: "raw",
|
||||||
DagProtobuf: "protobuf",
|
DagProtobuf: "protobuf",
|
||||||
DagCBOR: "cbor",
|
DagCBOR: "cbor",
|
||||||
GitRaw: "git-raw",
|
GitRaw: "git-raw",
|
||||||
EthBlock: "eth-block",
|
EthBlock: "eth-block",
|
||||||
EthBlockList: "eth-block-list",
|
EthBlockList: "eth-block-list",
|
||||||
EthTxTrie: "eth-tx-trie",
|
EthTxTrie: "eth-tx-trie",
|
||||||
EthTx: "eth-tx",
|
EthTx: "eth-tx",
|
||||||
EthTxReceiptTrie: "eth-tx-receipt-trie",
|
EthTxReceiptTrie: "eth-tx-receipt-trie",
|
||||||
EthTxReceipt: "eth-tx-receipt",
|
EthTxReceipt: "eth-tx-receipt",
|
||||||
EthStateTrie: "eth-state-trie",
|
EthStateTrie: "eth-state-trie",
|
||||||
EthAccountSnapshot: "eth-account-snapshot",
|
EthAccountSnapshot: "eth-account-snapshot",
|
||||||
EthStorageTrie: "eth-storage-trie",
|
EthStorageTrie: "eth-storage-trie",
|
||||||
BitcoinBlock: "bitcoin-block",
|
BitcoinBlock: "bitcoin-block",
|
||||||
BitcoinTx: "bitcoin-tx",
|
BitcoinTx: "bitcoin-tx",
|
||||||
ZcashBlock: "zcash-block",
|
ZcashBlock: "zcash-block",
|
||||||
ZcashTx: "zcash-tx",
|
ZcashTx: "zcash-tx",
|
||||||
DecredBlock: "decred-block",
|
DecredBlock: "decred-block",
|
||||||
DecredTx: "decred-tx",
|
DecredTx: "decred-tx",
|
||||||
DashBlock: "dash-block",
|
DashBlock: "dash-block",
|
||||||
DashTx: "dash-tx",
|
DashTx: "dash-tx",
|
||||||
|
FilCommitmentUnsealed: "fil-commitment-unsealed",
|
||||||
|
FilCommitmentSealed: "fil-commitment-sealed",
|
||||||
|
DagJOSE: "dag-jose",
|
||||||
}
|
}
|
||||||
|
|
||||||
// tryNewCidV0 tries to convert a multihash into a CIDv0 CID and returns an
|
// tryNewCidV0 tries to convert a multihash into a CIDv0 CID and returns an
|
||||||
@@ -175,10 +185,12 @@ func NewCidV1(codecType uint64, mhash mh.Multihash) Cid {
|
|||||||
return Cid{string(buf[:n+hashlen])}
|
return Cid{string(buf[:n+hashlen])}
|
||||||
}
|
}
|
||||||
|
|
||||||
var _ encoding.BinaryMarshaler = Cid{}
|
var (
|
||||||
var _ encoding.BinaryUnmarshaler = (*Cid)(nil)
|
_ encoding.BinaryMarshaler = Cid{}
|
||||||
var _ encoding.TextMarshaler = Cid{}
|
_ encoding.BinaryUnmarshaler = (*Cid)(nil)
|
||||||
var _ encoding.TextUnmarshaler = (*Cid)(nil)
|
_ encoding.TextMarshaler = Cid{}
|
||||||
|
_ encoding.TextUnmarshaler = (*Cid)(nil)
|
||||||
|
)
|
||||||
|
|
||||||
// Cid represents a self-describing content addressed
|
// Cid represents a self-describing content addressed
|
||||||
// identifier. It is formed by a Version, a Codec (which indicates
|
// identifier. It is formed by a Version, a Codec (which indicates
|
||||||
@@ -337,8 +349,8 @@ func (c Cid) Type() uint64 {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// String returns the default string representation of a
|
// String returns the default string representation of a
|
||||||
// Cid. Currently, Base58 is used as the encoding for the
|
// Cid. Currently, Base32 is used for CIDV1 as the encoding for the
|
||||||
// multibase string.
|
// multibase string, Base58 is used for CIDV0.
|
||||||
func (c Cid) String() string {
|
func (c Cid) String() string {
|
||||||
switch c.Version() {
|
switch c.Version() {
|
||||||
case 0:
|
case 0:
|
||||||
@@ -408,6 +420,30 @@ func (c Cid) Bytes() []byte {
|
|||||||
return []byte(c.str)
|
return []byte(c.str)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// ByteLen returns the length of the CID in bytes.
|
||||||
|
// It's equivalent to `len(c.Bytes())`, but works without an allocation,
|
||||||
|
// and should therefore be preferred.
|
||||||
|
//
|
||||||
|
// (See also the WriteTo method for other important operations that work without allocation.)
|
||||||
|
func (c Cid) ByteLen() int {
|
||||||
|
return len(c.str)
|
||||||
|
}
|
||||||
|
|
||||||
|
// WriteBytes writes the CID bytes to the given writer.
|
||||||
|
// This method works without incurring any allocation.
|
||||||
|
//
|
||||||
|
// (See also the ByteLen method for other important operations that work without allocation.)
|
||||||
|
func (c Cid) WriteBytes(w io.Writer) (int, error) {
|
||||||
|
n, err := io.WriteString(w, c.str)
|
||||||
|
if err != nil {
|
||||||
|
return n, err
|
||||||
|
}
|
||||||
|
if n != len(c.str) {
|
||||||
|
return n, fmt.Errorf("failed to write entire cid string")
|
||||||
|
}
|
||||||
|
return n, nil
|
||||||
|
}
|
||||||
|
|
||||||
// MarshalBinary is equivalent to Bytes(). It implements the
|
// MarshalBinary is equivalent to Bytes(). It implements the
|
||||||
// encoding.BinaryMarshaler interface.
|
// encoding.BinaryMarshaler interface.
|
||||||
func (c Cid) MarshalBinary() ([]byte, error) {
|
func (c Cid) MarshalBinary() ([]byte, error) {
|
||||||
@@ -487,12 +523,29 @@ func (c Cid) Loggable() map[string]interface{} {
|
|||||||
|
|
||||||
// Prefix builds and returns a Prefix out of a Cid.
|
// 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
|
if c.Version() == 0 {
|
||||||
|
return Prefix{
|
||||||
|
MhType: mh.SHA2_256,
|
||||||
|
MhLength: 32,
|
||||||
|
Version: 0,
|
||||||
|
Codec: DagProtobuf,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
offset := 0
|
||||||
|
version, n, _ := uvarint(c.str[offset:])
|
||||||
|
offset += n
|
||||||
|
codec, n, _ := uvarint(c.str[offset:])
|
||||||
|
offset += n
|
||||||
|
mhtype, n, _ := uvarint(c.str[offset:])
|
||||||
|
offset += n
|
||||||
|
mhlen, _, _ := uvarint(c.str[offset:])
|
||||||
|
|
||||||
return Prefix{
|
return Prefix{
|
||||||
MhType: dec.Code,
|
MhType: mhtype,
|
||||||
MhLength: dec.Length,
|
MhLength: int(mhlen),
|
||||||
Version: c.Version(),
|
Version: version,
|
||||||
Codec: c.Type(),
|
Codec: codec,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -513,7 +566,7 @@ type Prefix struct {
|
|||||||
// and return a newly constructed Cid with the resulting multihash.
|
// 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) {
|
||||||
length := p.MhLength
|
length := p.MhLength
|
||||||
if p.MhType == mh.ID {
|
if p.MhType == mh.IDENTITY {
|
||||||
length = -1
|
length = -1
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -4,7 +4,6 @@ package cid
|
|||||||
|
|
||||||
func Fuzz(data []byte) int {
|
func Fuzz(data []byte) int {
|
||||||
cid, err := Cast(data)
|
cid, err := Cast(data)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return 0
|
return 0
|
||||||
}
|
}
|
||||||
|
|||||||
254
cid_test.go
254
cid_test.go
@@ -5,6 +5,7 @@ import (
|
|||||||
"encoding/json"
|
"encoding/json"
|
||||||
"fmt"
|
"fmt"
|
||||||
"math/rand"
|
"math/rand"
|
||||||
|
"reflect"
|
||||||
"strings"
|
"strings"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
@@ -16,28 +17,31 @@ import (
|
|||||||
// https://github.com/multiformats/go-multihash/blob/7aa9f26a231c6f34f4e9fad52bf580fd36627285/multihash_test.go#L13
|
// https://github.com/multiformats/go-multihash/blob/7aa9f26a231c6f34f4e9fad52bf580fd36627285/multihash_test.go#L13
|
||||||
// Makes it so changing the table accidentally has to happen twice.
|
// Makes it so changing the table accidentally has to happen twice.
|
||||||
var tCodecs = map[uint64]string{
|
var tCodecs = map[uint64]string{
|
||||||
Raw: "raw",
|
Raw: "raw",
|
||||||
DagProtobuf: "protobuf",
|
DagProtobuf: "protobuf",
|
||||||
DagCBOR: "cbor",
|
DagCBOR: "cbor",
|
||||||
Libp2pKey: "libp2p-key",
|
Libp2pKey: "libp2p-key",
|
||||||
GitRaw: "git-raw",
|
GitRaw: "git-raw",
|
||||||
EthBlock: "eth-block",
|
EthBlock: "eth-block",
|
||||||
EthBlockList: "eth-block-list",
|
EthBlockList: "eth-block-list",
|
||||||
EthTxTrie: "eth-tx-trie",
|
EthTxTrie: "eth-tx-trie",
|
||||||
EthTx: "eth-tx",
|
EthTx: "eth-tx",
|
||||||
EthTxReceiptTrie: "eth-tx-receipt-trie",
|
EthTxReceiptTrie: "eth-tx-receipt-trie",
|
||||||
EthTxReceipt: "eth-tx-receipt",
|
EthTxReceipt: "eth-tx-receipt",
|
||||||
EthStateTrie: "eth-state-trie",
|
EthStateTrie: "eth-state-trie",
|
||||||
EthAccountSnapshot: "eth-account-snapshot",
|
EthAccountSnapshot: "eth-account-snapshot",
|
||||||
EthStorageTrie: "eth-storage-trie",
|
EthStorageTrie: "eth-storage-trie",
|
||||||
BitcoinBlock: "bitcoin-block",
|
BitcoinBlock: "bitcoin-block",
|
||||||
BitcoinTx: "bitcoin-tx",
|
BitcoinTx: "bitcoin-tx",
|
||||||
ZcashBlock: "zcash-block",
|
ZcashBlock: "zcash-block",
|
||||||
ZcashTx: "zcash-tx",
|
ZcashTx: "zcash-tx",
|
||||||
DecredBlock: "decred-block",
|
DecredBlock: "decred-block",
|
||||||
DecredTx: "decred-tx",
|
DecredTx: "decred-tx",
|
||||||
DashBlock: "dash-block",
|
DashBlock: "dash-block",
|
||||||
DashTx: "dash-tx",
|
DashTx: "dash-tx",
|
||||||
|
FilCommitmentUnsealed: "fil-commitment-unsealed",
|
||||||
|
FilCommitmentSealed: "fil-commitment-sealed",
|
||||||
|
DagJOSE: "dag-jose",
|
||||||
}
|
}
|
||||||
|
|
||||||
func assertEqual(t *testing.T, a, b Cid) {
|
func assertEqual(t *testing.T, a, b Cid) {
|
||||||
@@ -78,7 +82,7 @@ func TestPrefixSum(t *testing.T) {
|
|||||||
// Test creating CIDs both manually and with Prefix.
|
// Test creating CIDs both manually and with Prefix.
|
||||||
// Tests: https://github.com/ipfs/go-cid/issues/83
|
// Tests: https://github.com/ipfs/go-cid/issues/83
|
||||||
for _, hashfun := range []uint64{
|
for _, hashfun := range []uint64{
|
||||||
mh.ID, mh.SHA3, mh.SHA2_256,
|
mh.IDENTITY, mh.SHA3, mh.SHA2_256,
|
||||||
} {
|
} {
|
||||||
h1, err := mh.Sum([]byte("TEST"), hashfun, -1)
|
h1, err := mh.Sum([]byte("TEST"), hashfun, -1)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -182,8 +186,32 @@ func TestBasesMarshaling(t *testing.T) {
|
|||||||
}
|
}
|
||||||
s2 := cid.Encode(encoder)
|
s2 := cid.Encode(encoder)
|
||||||
if s != s2 {
|
if s != s2 {
|
||||||
t.Fatalf("'%s' != '%s'", s, s2)
|
t.Fatalf("%q != %q", s, s2)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
ee, err := ExtractEncoding(s)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
if ee != b {
|
||||||
|
t.Fatalf("could not properly determine base (got %v)", ee)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
ee, err := ExtractEncoding("QmdfTbBqBPQ7VNxZEYEj14VmRuZBkqFbiwReogJgS1zR1n")
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
if ee != mbase.Base58BTC {
|
||||||
|
t.Fatalf("expected Base58BTC from Qm string (got %v)", ee)
|
||||||
|
}
|
||||||
|
|
||||||
|
ee, err = ExtractEncoding("1")
|
||||||
|
if err == nil {
|
||||||
|
t.Fatal("expected too-short error from ExtractEncoding")
|
||||||
|
}
|
||||||
|
if ee != -1 {
|
||||||
|
t.Fatal("expected -1 from too-short ExtractEncoding")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -192,18 +220,32 @@ func TestBinaryMarshaling(t *testing.T) {
|
|||||||
hash, _ := mh.Sum(data, mh.SHA2_256, -1)
|
hash, _ := mh.Sum(data, mh.SHA2_256, -1)
|
||||||
c := NewCidV1(DagCBOR, hash)
|
c := NewCidV1(DagCBOR, hash)
|
||||||
var c2 Cid
|
var c2 Cid
|
||||||
|
var c3 Cid
|
||||||
|
|
||||||
data, err := c.MarshalBinary()
|
data, err := c.MarshalBinary()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
err = c2.UnmarshalBinary(data)
|
if err = c2.UnmarshalBinary(data); err != nil {
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
if !c.Equals(c2) {
|
if !c.Equals(c2) {
|
||||||
t.Errorf("cids should be the same: %s %s", c, c2)
|
t.Errorf("cids should be the same: %s %s", c, c2)
|
||||||
}
|
}
|
||||||
|
var buf bytes.Buffer
|
||||||
|
wrote, err := c.WriteBytes(&buf)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
if wrote != 36 {
|
||||||
|
t.Fatalf("expected 36 bytes written (got %d)", wrote)
|
||||||
|
}
|
||||||
|
if err = c3.UnmarshalBinary(data); err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
if !c.Equals(c3) {
|
||||||
|
t.Errorf("cids should be the same: %s %s", c, c3)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestTextMarshaling(t *testing.T) {
|
func TestTextMarshaling(t *testing.T) {
|
||||||
@@ -216,13 +258,16 @@ func TestTextMarshaling(t *testing.T) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
err = c2.UnmarshalText(data)
|
if err = c2.UnmarshalText(data); err != nil {
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
if !c.Equals(c2) {
|
if !c.Equals(c2) {
|
||||||
t.Errorf("cids should be the same: %s %s", c, c2)
|
t.Errorf("cids should be the same: %s %s", c, c2)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if c.KeyString() != string(c.Bytes()) {
|
||||||
|
t.Errorf("got unexpected KeyString() result")
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestEmptyString(t *testing.T) {
|
func TestEmptyString(t *testing.T) {
|
||||||
@@ -252,6 +297,11 @@ func TestV0Handling(t *testing.T) {
|
|||||||
t.Fatal("marshaling roundtrip failed")
|
t.Fatal("marshaling roundtrip failed")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
byteLen := cid.ByteLen()
|
||||||
|
if byteLen != 34 {
|
||||||
|
t.Fatalf("expected V0 ByteLen to be 34 (got %d)", byteLen)
|
||||||
|
}
|
||||||
|
|
||||||
new, err := cid.StringOfBase(mbase.Base58BTC)
|
new, err := cid.StringOfBase(mbase.Base58BTC)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
@@ -267,6 +317,11 @@ func TestV0Handling(t *testing.T) {
|
|||||||
if cid.Encode(encoder) != old {
|
if cid.Encode(encoder) != old {
|
||||||
t.Fatal("Encode roundtrip failed")
|
t.Fatal("Encode roundtrip failed")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
_, err = cid.StringOfBase(mbase.Base32)
|
||||||
|
if err != ErrInvalidEncoding {
|
||||||
|
t.Fatalf("expected ErrInvalidEncoding for V0 StringOfBase(Base32) (got %v)", err)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestV0ErrorCases(t *testing.T) {
|
func TestV0ErrorCases(t *testing.T) {
|
||||||
@@ -333,7 +388,6 @@ func TestNewPrefixV0(t *testing.T) {
|
|||||||
if c1.Prefix() != c2.Prefix() {
|
if c1.Prefix() != c2.Prefix() {
|
||||||
t.Fatal("prefixes mismatch")
|
t.Fatal("prefixes mismatch")
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestInvalidV0Prefix(t *testing.T) {
|
func TestInvalidV0Prefix(t *testing.T) {
|
||||||
@@ -367,7 +421,14 @@ func TestInvalidV0Prefix(t *testing.T) {
|
|||||||
t.Fatalf("should error (index %d)", i)
|
t.Fatalf("should error (index %d)", i)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestBadPrefix(t *testing.T) {
|
||||||
|
p := Prefix{Version: 3, Codec: DagProtobuf, MhType: mh.SHA2_256, MhLength: 3}
|
||||||
|
_, err := p.Sum([]byte{0x00, 0x01, 0x03})
|
||||||
|
if err == nil {
|
||||||
|
t.Fatalf("expected error on v3 prefix Sum")
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestPrefixRoundtrip(t *testing.T) {
|
func TestPrefixRoundtrip(t *testing.T) {
|
||||||
@@ -399,6 +460,25 @@ func TestPrefixRoundtrip(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestBadPrefixFromBytes(t *testing.T) {
|
||||||
|
_, err := PrefixFromBytes([]byte{0x80})
|
||||||
|
if err == nil {
|
||||||
|
t.Fatal("expected error for bad byte 0")
|
||||||
|
}
|
||||||
|
_, err = PrefixFromBytes([]byte{0x01, 0x80})
|
||||||
|
if err == nil {
|
||||||
|
t.Fatal("expected error for bad byte 1")
|
||||||
|
}
|
||||||
|
_, err = PrefixFromBytes([]byte{0x01, 0x01, 0x80})
|
||||||
|
if err == nil {
|
||||||
|
t.Fatal("expected error for bad byte 2")
|
||||||
|
}
|
||||||
|
_, err = PrefixFromBytes([]byte{0x01, 0x01, 0x01, 0x80})
|
||||||
|
if err == nil {
|
||||||
|
t.Fatal("expected error for bad byte 3")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func Test16BytesVarint(t *testing.T) {
|
func Test16BytesVarint(t *testing.T) {
|
||||||
data := []byte("this is some test content")
|
data := []byte("this is some test content")
|
||||||
hash, _ := mh.Sum(data, mh.SHA2_256, -1)
|
hash, _ := mh.Sum(data, mh.SHA2_256, -1)
|
||||||
@@ -431,13 +511,13 @@ func TestParse(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
assertions := [][]interface{}{
|
assertions := [][]interface{}{
|
||||||
[]interface{}{NewCidV0(h), theHash},
|
{NewCidV0(h), theHash},
|
||||||
[]interface{}{NewCidV0(h).Bytes(), theHash},
|
{NewCidV0(h).Bytes(), theHash},
|
||||||
[]interface{}{h, theHash},
|
{h, theHash},
|
||||||
[]interface{}{theHash, theHash},
|
{theHash, theHash},
|
||||||
[]interface{}{"/ipfs/" + theHash, theHash},
|
{"/ipfs/" + theHash, theHash},
|
||||||
[]interface{}{"https://ipfs.io/ipfs/" + theHash, theHash},
|
{"https://ipfs.io/ipfs/" + theHash, theHash},
|
||||||
[]interface{}{"http://localhost:8080/ipfs/" + theHash, theHash},
|
{"http://localhost:8080/ipfs/" + theHash, theHash},
|
||||||
}
|
}
|
||||||
|
|
||||||
assert := func(arg interface{}, expected string) error {
|
assert := func(arg interface{}, expected string) error {
|
||||||
@@ -446,7 +526,7 @@ func TestParse(t *testing.T) {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
if cid.Version() != 0 {
|
if cid.Version() != 0 {
|
||||||
return fmt.Errorf("expected version 0, got %s", string(cid.Version()))
|
return fmt.Errorf("expected version 0, got %d", cid.Version())
|
||||||
}
|
}
|
||||||
actual := cid.Hash().B58String()
|
actual := cid.Hash().B58String()
|
||||||
if actual != expected {
|
if actual != expected {
|
||||||
@@ -460,8 +540,7 @@ func TestParse(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
for _, args := range assertions {
|
for _, args := range assertions {
|
||||||
err := assert(args[0], args[1].(string))
|
if err := assert(args[0], args[1].(string)); err != nil {
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -495,8 +574,7 @@ func TestFromJson(t *testing.T) {
|
|||||||
cval := "bafkreie5qrjvaw64n4tjm6hbnm7fnqvcssfed4whsjqxzslbd3jwhsk3mm"
|
cval := "bafkreie5qrjvaw64n4tjm6hbnm7fnqvcssfed4whsjqxzslbd3jwhsk3mm"
|
||||||
jsoncid := []byte(`{"/":"` + cval + `"}`)
|
jsoncid := []byte(`{"/":"` + cval + `"}`)
|
||||||
var c Cid
|
var c Cid
|
||||||
err := json.Unmarshal(jsoncid, &c)
|
if err := json.Unmarshal(jsoncid, &c); err != nil {
|
||||||
if err != nil {
|
|
||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -506,6 +584,7 @@ func TestFromJson(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func TestJsonRoundTrip(t *testing.T) {
|
func TestJsonRoundTrip(t *testing.T) {
|
||||||
|
expectedJSON := `{"/":"bafkreie5qrjvaw64n4tjm6hbnm7fnqvcssfed4whsjqxzslbd3jwhsk3mm"}`
|
||||||
exp, err := Decode("bafkreie5qrjvaw64n4tjm6hbnm7fnqvcssfed4whsjqxzslbd3jwhsk3mm")
|
exp, err := Decode("bafkreie5qrjvaw64n4tjm6hbnm7fnqvcssfed4whsjqxzslbd3jwhsk3mm")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
@@ -517,21 +596,50 @@ func TestJsonRoundTrip(t *testing.T) {
|
|||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
var actual Cid
|
var actual Cid
|
||||||
err = json.Unmarshal(enc, &actual)
|
if err = json.Unmarshal(enc, &actual); err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
if !exp.Equals(actual) {
|
if !exp.Equals(actual) {
|
||||||
t.Fatal("cids not equal for *Cid")
|
t.Fatal("cids not equal for *Cid")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if string(enc) != expectedJSON {
|
||||||
|
t.Fatalf("did not get expected JSON form (got %q)", string(enc))
|
||||||
|
}
|
||||||
|
|
||||||
// Verify it works for a Cid.
|
// Verify it works for a Cid.
|
||||||
enc, err = json.Marshal(exp)
|
enc, err = json.Marshal(exp)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
var actual2 Cid
|
var actual2 Cid
|
||||||
err = json.Unmarshal(enc, &actual2)
|
if err = json.Unmarshal(enc, &actual2); err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
if !exp.Equals(actual2) {
|
if !exp.Equals(actual2) {
|
||||||
t.Fatal("cids not equal for Cid")
|
t.Fatal("cids not equal for Cid")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if err = actual2.UnmarshalJSON([]byte("1")); err == nil {
|
||||||
|
t.Fatal("expected error for too-short JSON")
|
||||||
|
}
|
||||||
|
|
||||||
|
if err = actual2.UnmarshalJSON([]byte(`{"nope":"nope"}`)); err == nil {
|
||||||
|
t.Fatal("expected error for bad CID JSON")
|
||||||
|
}
|
||||||
|
|
||||||
|
if err = actual2.UnmarshalJSON([]byte(`bad "" json!`)); err == nil {
|
||||||
|
t.Fatal("expected error for bad JSON")
|
||||||
|
}
|
||||||
|
|
||||||
|
var actual3 Cid
|
||||||
|
enc, err = actual3.MarshalJSON()
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
if string(enc) != "null" {
|
||||||
|
t.Fatalf("expected 'null' string for undefined CID (got %q)", string(enc))
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func BenchmarkStringV1(b *testing.B) {
|
func BenchmarkStringV1(b *testing.B) {
|
||||||
@@ -554,6 +662,7 @@ func BenchmarkStringV1(b *testing.B) {
|
|||||||
func TestReadCidsFromBuffer(t *testing.T) {
|
func TestReadCidsFromBuffer(t *testing.T) {
|
||||||
cidstr := []string{
|
cidstr := []string{
|
||||||
"bafkreie5qrjvaw64n4tjm6hbnm7fnqvcssfed4whsjqxzslbd3jwhsk3mm",
|
"bafkreie5qrjvaw64n4tjm6hbnm7fnqvcssfed4whsjqxzslbd3jwhsk3mm",
|
||||||
|
"k2cwueckqkibutvhkr4p2ln2pjcaxaakpd9db0e7j7ax1lxhhxy3ekpv",
|
||||||
"Qmf5Qzp6nGBku7CEn2UQx4mgN8TW69YUok36DrGa6NN893",
|
"Qmf5Qzp6nGBku7CEn2UQx4mgN8TW69YUok36DrGa6NN893",
|
||||||
"zb2rhZi1JR4eNc2jBGaRYJKYM8JEB4ovenym8L1CmFsRAytkz",
|
"zb2rhZi1JR4eNc2jBGaRYJKYM8JEB4ovenym8L1CmFsRAytkz",
|
||||||
}
|
}
|
||||||
@@ -585,6 +694,52 @@ func TestReadCidsFromBuffer(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestBadCidFromBytes(t *testing.T) {
|
||||||
|
l, c, err := CidFromBytes([]byte{mh.SHA2_256, 32, 0x00})
|
||||||
|
if err == nil {
|
||||||
|
t.Fatal("expected not-enough-bytes for V0 CidFromBytes")
|
||||||
|
}
|
||||||
|
if l != 0 {
|
||||||
|
t.Fatal("expected length=0 from bad CidFromBytes")
|
||||||
|
}
|
||||||
|
if c != Undef {
|
||||||
|
t.Fatal("expected Undef CID from bad CidFromBytes")
|
||||||
|
}
|
||||||
|
|
||||||
|
c, err = Decode("bafkreie5qrjvaw64n4tjm6hbnm7fnqvcssfed4whsjqxzslbd3jwhsk3mm")
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
byts := make([]byte, c.ByteLen())
|
||||||
|
copy(byts, c.Bytes())
|
||||||
|
byts[1] = 0x80 // bad codec varint
|
||||||
|
byts[2] = 0x00
|
||||||
|
l, c, err = CidFromBytes(byts)
|
||||||
|
if err == nil {
|
||||||
|
t.Fatal("expected not-enough-bytes for V1 CidFromBytes")
|
||||||
|
}
|
||||||
|
if l != 0 {
|
||||||
|
t.Fatal("expected length=0 from bad CidFromBytes")
|
||||||
|
}
|
||||||
|
if c != Undef {
|
||||||
|
t.Fatal("expected Undef CID from bad CidFromBytes")
|
||||||
|
}
|
||||||
|
|
||||||
|
copy(byts, c.Bytes())
|
||||||
|
byts[2] = 0x80 // bad multihash varint
|
||||||
|
byts[3] = 0x00
|
||||||
|
l, c, err = CidFromBytes(byts)
|
||||||
|
if err == nil {
|
||||||
|
t.Fatal("expected not-enough-bytes for V1 CidFromBytes")
|
||||||
|
}
|
||||||
|
if l != 0 {
|
||||||
|
t.Fatal("expected length=0 from bad CidFromBytes")
|
||||||
|
}
|
||||||
|
if c != Undef {
|
||||||
|
t.Fatal("expected Undef CID from bad CidFromBytes")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func TestBadParse(t *testing.T) {
|
func TestBadParse(t *testing.T) {
|
||||||
hash, err := mh.Sum([]byte("foobar"), mh.SHA3_256, -1)
|
hash, err := mh.Sum([]byte("foobar"), mh.SHA3_256, -1)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -595,3 +750,16 @@ func TestBadParse(t *testing.T) {
|
|||||||
t.Fatal("expected to fail to parse an invalid CIDv1 CID")
|
t.Fatal("expected to fail to parse an invalid CIDv1 CID")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestLoggable(t *testing.T) {
|
||||||
|
c, err := Decode("bafkreie5qrjvaw64n4tjm6hbnm7fnqvcssfed4whsjqxzslbd3jwhsk3mm")
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
actual := c.Loggable()
|
||||||
|
expected := make(map[string]interface{})
|
||||||
|
expected["cid"] = c
|
||||||
|
if !reflect.DeepEqual(actual, expected) {
|
||||||
|
t.Fatalf("did not get expected loggable form (got %v)", actual)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
9
go.mod
9
go.mod
@@ -1,9 +1,10 @@
|
|||||||
module github.com/ipfs/go-cid
|
module github.com/ipfs/go-cid
|
||||||
|
|
||||||
require (
|
require (
|
||||||
github.com/multiformats/go-multibase v0.0.1
|
github.com/multiformats/go-multibase v0.0.3
|
||||||
github.com/multiformats/go-multihash v0.0.13
|
github.com/multiformats/go-multihash v0.0.14
|
||||||
github.com/multiformats/go-varint v0.0.5
|
github.com/multiformats/go-varint v0.0.6
|
||||||
|
golang.org/x/crypto v0.0.0-20210506145944-38f3c27a63bf // indirect
|
||||||
)
|
)
|
||||||
|
|
||||||
go 1.13
|
go 1.15
|
||||||
|
|||||||
28
go.sum
28
go.sum
@@ -2,29 +2,33 @@ github.com/minio/blake2b-simd v0.0.0-20160723061019-3f5f724cb5b1 h1:lYpkrQH5ajf0
|
|||||||
github.com/minio/blake2b-simd v0.0.0-20160723061019-3f5f724cb5b1/go.mod h1:pD8RvIylQ358TN4wwqatJ8rNavkEINozVn9DtGI3dfQ=
|
github.com/minio/blake2b-simd v0.0.0-20160723061019-3f5f724cb5b1/go.mod h1:pD8RvIylQ358TN4wwqatJ8rNavkEINozVn9DtGI3dfQ=
|
||||||
github.com/minio/sha256-simd v0.1.1-0.20190913151208-6de447530771 h1:MHkK1uRtFbVqvAgvWxafZe54+5uBxLluGylDiKgdhwo=
|
github.com/minio/sha256-simd v0.1.1-0.20190913151208-6de447530771 h1:MHkK1uRtFbVqvAgvWxafZe54+5uBxLluGylDiKgdhwo=
|
||||||
github.com/minio/sha256-simd v0.1.1-0.20190913151208-6de447530771/go.mod h1:B5e1o+1/KgNmWrSQK08Y6Z1Vb5pwIktudl0J58iy0KM=
|
github.com/minio/sha256-simd v0.1.1-0.20190913151208-6de447530771/go.mod h1:B5e1o+1/KgNmWrSQK08Y6Z1Vb5pwIktudl0J58iy0KM=
|
||||||
github.com/mr-tron/base58 v1.1.0 h1:Y51FGVJ91WBqCEabAi5OPUz38eAx8DakuAm5svLcsfQ=
|
|
||||||
github.com/mr-tron/base58 v1.1.0/go.mod h1:xcD2VGqlgYjBdcBLw+TuYLr8afG+Hj8g2eTVqeSzSU8=
|
github.com/mr-tron/base58 v1.1.0/go.mod h1:xcD2VGqlgYjBdcBLw+TuYLr8afG+Hj8g2eTVqeSzSU8=
|
||||||
github.com/mr-tron/base58 v1.1.3 h1:v+sk57XuaCKGXpWtVBX8YJzO7hMGx4Aajh4TQbdEFdc=
|
github.com/mr-tron/base58 v1.1.3 h1:v+sk57XuaCKGXpWtVBX8YJzO7hMGx4Aajh4TQbdEFdc=
|
||||||
github.com/mr-tron/base58 v1.1.3/go.mod h1:BinMc/sQntlIE1frQmRFPUoPA1Zkr8VRgBdjWI2mNwc=
|
github.com/mr-tron/base58 v1.1.3/go.mod h1:BinMc/sQntlIE1frQmRFPUoPA1Zkr8VRgBdjWI2mNwc=
|
||||||
github.com/multiformats/go-base32 v0.0.3 h1:tw5+NhuwaOjJCC5Pp82QuXbrmLzWg7uxlMFp8Nq/kkI=
|
github.com/multiformats/go-base32 v0.0.3 h1:tw5+NhuwaOjJCC5Pp82QuXbrmLzWg7uxlMFp8Nq/kkI=
|
||||||
github.com/multiformats/go-base32 v0.0.3/go.mod h1:pLiuGC8y0QR3Ue4Zug5UzK9LjgbkL8NSQj0zQ5Nz/AA=
|
github.com/multiformats/go-base32 v0.0.3/go.mod h1:pLiuGC8y0QR3Ue4Zug5UzK9LjgbkL8NSQj0zQ5Nz/AA=
|
||||||
github.com/multiformats/go-multibase v0.0.1 h1:PN9/v21eLywrFWdFNsFKaU04kLJzuYzmrJR+ubhT9qA=
|
github.com/multiformats/go-base36 v0.1.0 h1:JR6TyF7JjGd3m6FbLU2cOxhC0Li8z8dLNGQ89tUg4F4=
|
||||||
github.com/multiformats/go-multibase v0.0.1/go.mod h1:bja2MqRZ3ggyXtZSEDKpl0uO/gviWFaSteVbWT51qgs=
|
github.com/multiformats/go-base36 v0.1.0/go.mod h1:kFGE83c6s80PklsHO9sRn2NCoffoRdUUOENyW/Vv6sM=
|
||||||
github.com/multiformats/go-multihash v0.0.12 h1:i2PQZWlsq8asUZwPS5w7VMCoUKEz/k/XG6WH30gsTU8=
|
github.com/multiformats/go-multibase v0.0.3 h1:l/B6bJDQjvQ5G52jw4QGSYeOTZoAwIO77RblWplfIqk=
|
||||||
github.com/multiformats/go-multihash v0.0.12/go.mod h1:2+oRiLVLqXx+yxM/RIdhLstp1q2WMJAlQ4kdLkS3un0=
|
github.com/multiformats/go-multibase v0.0.3/go.mod h1:5+1R4eQrT3PkYZ24C3W2Ue2tPwIdYQD509ZjSb5y9Oc=
|
||||||
github.com/multiformats/go-multihash v0.0.13 h1:06x+mk/zj1FoMsgNejLpy6QTvJqlSt/BhLEy87zidlc=
|
github.com/multiformats/go-multihash v0.0.14 h1:QoBceQYQQtNUuf6s7wHxnE2c8bhbMqhfGzNI032se/I=
|
||||||
github.com/multiformats/go-multihash v0.0.13/go.mod h1:VdAWLKTwram9oKAatUcLxBNUjdtcVwxObEQBtRfuyjc=
|
github.com/multiformats/go-multihash v0.0.14/go.mod h1:VdAWLKTwram9oKAatUcLxBNUjdtcVwxObEQBtRfuyjc=
|
||||||
github.com/multiformats/go-varint v0.0.4 h1:CplQWhUouUgTZ53vNFE8VoWr2VjaKXci+xyrKyyFuSw=
|
|
||||||
github.com/multiformats/go-varint v0.0.4/go.mod h1:3Ls8CIEsrijN6+B7PbrXRPxHRPuXSrVKRY101jdMZYE=
|
|
||||||
github.com/multiformats/go-varint v0.0.5 h1:XVZwSo04Cs3j/jS0uAEPpT3JY6DzMcVLLoWOSnCxOjg=
|
|
||||||
github.com/multiformats/go-varint v0.0.5/go.mod h1:3Ls8CIEsrijN6+B7PbrXRPxHRPuXSrVKRY101jdMZYE=
|
github.com/multiformats/go-varint v0.0.5/go.mod h1:3Ls8CIEsrijN6+B7PbrXRPxHRPuXSrVKRY101jdMZYE=
|
||||||
|
github.com/multiformats/go-varint v0.0.6 h1:gk85QWKxh3TazbLxED/NlDVv8+q+ReFJk7Y2W/KhfNY=
|
||||||
|
github.com/multiformats/go-varint v0.0.6/go.mod h1:3Ls8CIEsrijN6+B7PbrXRPxHRPuXSrVKRY101jdMZYE=
|
||||||
github.com/spaolacci/murmur3 v1.1.0 h1:7c1g84S4BPRrfL5Xrdp6fOJ206sU9y293DDHaoy0bLI=
|
github.com/spaolacci/murmur3 v1.1.0 h1:7c1g84S4BPRrfL5Xrdp6fOJ206sU9y293DDHaoy0bLI=
|
||||||
github.com/spaolacci/murmur3 v1.1.0/go.mod h1:JwIasOWyU6f++ZhiEuf87xNszmSA2myDM2Kzu9HwQUA=
|
github.com/spaolacci/murmur3 v1.1.0/go.mod h1:JwIasOWyU6f++ZhiEuf87xNszmSA2myDM2Kzu9HwQUA=
|
||||||
golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
|
golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
|
||||||
golang.org/x/crypto v0.0.0-20190611184440-5c40567a22f8 h1:1wopBVtVdWnn03fZelqdXTqk7U7zPQCb+T4rbU9ZEoU=
|
|
||||||
golang.org/x/crypto v0.0.0-20190611184440-5c40567a22f8/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
|
golang.org/x/crypto v0.0.0-20190611184440-5c40567a22f8/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
|
||||||
|
golang.org/x/crypto v0.0.0-20210506145944-38f3c27a63bf h1:B2n+Zi5QeYRDAEodEu72OS36gmTWjgpXr2+cWcBW90o=
|
||||||
|
golang.org/x/crypto v0.0.0-20210506145944-38f3c27a63bf/go.mod h1:P+XmwS30IXTQdn5tA2iutPOUgjI07+tq3H3K9MVA1s8=
|
||||||
golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
|
golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
|
||||||
|
golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=
|
||||||
golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
|
golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
|
||||||
golang.org/x/sys v0.0.0-20190412213103-97732733099d h1:+R4KGOnez64A81RvjARKc4UT5/tI9ujCIVX+P5KiHuI=
|
|
||||||
golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
|
golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
|
||||||
|
golang.org/x/sys v0.0.0-20201119102817-f84b799fce68 h1:nxC68pudNYkKU6jWhgrqdreuFiOQWj1Fs7T3VrH4Pjw=
|
||||||
|
golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
|
||||||
|
golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
|
||||||
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
|
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
|
||||||
|
golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
|
||||||
|
golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
|
||||||
|
|||||||
30
package.json
30
package.json
@@ -1,30 +0,0 @@
|
|||||||
{
|
|
||||||
"author": "whyrusleeping",
|
|
||||||
"bugs": {
|
|
||||||
"url": "https://github.com/ipfs/go-cid"
|
|
||||||
},
|
|
||||||
"gx": {
|
|
||||||
"dvcsimport": "github.com/ipfs/go-cid"
|
|
||||||
},
|
|
||||||
"gxDependencies": [
|
|
||||||
{
|
|
||||||
"author": "whyrusleeping",
|
|
||||||
"hash": "QmerPMzPk1mJVowm8KgmoknWa4yCYvvugMPsgWmDNUvDLW",
|
|
||||||
"name": "go-multihash",
|
|
||||||
"version": "1.0.9"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"author": "whyrusleeping",
|
|
||||||
"hash": "QmekxXDhCxCJRNuzmHreuaT3BsuJcsjcXWNrtV9C8DRHtd",
|
|
||||||
"name": "go-multibase",
|
|
||||||
"version": "0.3.0"
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"gxVersion": "0.8.0",
|
|
||||||
"language": "go",
|
|
||||||
"license": "MIT",
|
|
||||||
"name": "go-cid",
|
|
||||||
"releaseCmd": "git commit -a -m \"gx publish $VERSION\"",
|
|
||||||
"version": "0.9.3"
|
|
||||||
}
|
|
||||||
|
|
||||||
17
varint.go
17
varint.go
@@ -4,7 +4,7 @@ import (
|
|||||||
"github.com/multiformats/go-varint"
|
"github.com/multiformats/go-varint"
|
||||||
)
|
)
|
||||||
|
|
||||||
// Version of varint function that work with a string rather than
|
// Version of varint function that works with a string rather than
|
||||||
// []byte to avoid unnecessary allocation
|
// []byte to avoid unnecessary allocation
|
||||||
|
|
||||||
// Copyright 2011 The Go Authors. All rights reserved.
|
// Copyright 2011 The Go Authors. All rights reserved.
|
||||||
@@ -12,23 +12,20 @@ import (
|
|||||||
// license as given at https://golang.org/LICENSE
|
// license as given at https://golang.org/LICENSE
|
||||||
|
|
||||||
// uvarint decodes a uint64 from buf and returns that value and the
|
// uvarint decodes a uint64 from buf and returns that value and the
|
||||||
// number of characters read (> 0). If an error occurred, the value is 0
|
// number of bytes read (> 0). If an error occurred, then 0 is
|
||||||
// and the number of bytes n is <= 0 meaning:
|
// returned for both the value and the number of bytes read, and an
|
||||||
//
|
// error is returned.
|
||||||
// n == 0: buf too small
|
|
||||||
// n < 0: value larger than 64 bits (overflow)
|
|
||||||
// and -n is the number of bytes read
|
|
||||||
//
|
|
||||||
func uvarint(buf string) (uint64, int, error) {
|
func uvarint(buf string) (uint64, int, error) {
|
||||||
var x uint64
|
var x uint64
|
||||||
var s uint
|
var s uint
|
||||||
// we have a binary string so we can't use a range loope
|
// we have a binary string so we can't use a range loop
|
||||||
for i := 0; i < len(buf); i++ {
|
for i := 0; i < len(buf); i++ {
|
||||||
b := buf[i]
|
b := buf[i]
|
||||||
if b < 0x80 {
|
if b < 0x80 {
|
||||||
if i > 9 || i == 9 && b > 1 {
|
if i > 9 || i == 9 && b > 1 {
|
||||||
return 0, 0, varint.ErrOverflow
|
return 0, 0, varint.ErrOverflow
|
||||||
} else if b == 0 && i > 0 {
|
}
|
||||||
|
if b == 0 && i > 0 {
|
||||||
return 0, 0, varint.ErrNotMinimal
|
return 0, 0, varint.ErrNotMinimal
|
||||||
}
|
}
|
||||||
return x | uint64(b)<<s, i + 1, nil
|
return x | uint64(b)<<s, i + 1, nil
|
||||||
|
|||||||
@@ -28,3 +28,29 @@ func TestUvarintRoundTrip(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestUvarintEdges(t *testing.T) {
|
||||||
|
tests := []struct {
|
||||||
|
name string
|
||||||
|
input []byte
|
||||||
|
want error
|
||||||
|
}{
|
||||||
|
{"ErrNotMinimal", []byte{0x01 | 0x80, 0}, varint.ErrNotMinimal},
|
||||||
|
{"ErrOverflow", []byte{0x80, 0x80, 0x80, 0x80, 0x80, 0x80, 0x80, 0x80, 0x80, 0x80, 0x01}, varint.ErrOverflow},
|
||||||
|
{"ErrUnderflow", []byte{0x80}, varint.ErrUnderflow},
|
||||||
|
}
|
||||||
|
for _, test := range tests {
|
||||||
|
t.Run(test.name, func(t *testing.T) {
|
||||||
|
v, l1, err := uvarint(string(test.input))
|
||||||
|
if err != test.want {
|
||||||
|
t.Fatalf("error case (%v) should return varint.%s (got: %v)", test.input, test.name, err)
|
||||||
|
}
|
||||||
|
if v != 0 {
|
||||||
|
t.Fatalf("error case (%v) should return 0 value (got %d)", test.input, v)
|
||||||
|
}
|
||||||
|
if l1 != 0 {
|
||||||
|
t.Fatalf("error case (%v) should return 0 length (got %d)", test.input, l1)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user