mirror of
https://github.com/ipfs/kubo.git
synced 2025-08-14 02:41:13 +08:00
76 lines
1.7 KiB
Go
76 lines
1.7 KiB
Go
package git
|
|
|
|
import (
|
|
"compress/zlib"
|
|
"fmt"
|
|
"io"
|
|
"math"
|
|
|
|
"github.com/ipfs/go-ipfs/core/coredag"
|
|
"github.com/ipfs/go-ipfs/plugin"
|
|
|
|
"gx/ipfs/QmNp85zy9RLrQ5oQD4hPyS39ezrrXpcaa7R4Y9kxdWQLLQ/go-cid"
|
|
"gx/ipfs/QmPN7cwmpcc4DWXb4KTB9dNAJgjuPY69h3npsMfhRrQL9c/go-ipld-format"
|
|
mh "gx/ipfs/QmU9a9NV9RdPNwZQDYd5uKsm6N6LJLSvLbywDDYFbaaC6P/go-multihash"
|
|
git "gx/ipfs/QmaWPGUJJFb75PvWwnkXAxYXUtsRFCRQiCZhpr5ks4F9K9/go-ipld-git"
|
|
)
|
|
|
|
// Plugins is exported list of plugins that will be loaded
|
|
var Plugins = []plugin.Plugin{
|
|
&gitPlugin{},
|
|
}
|
|
|
|
type gitPlugin struct{}
|
|
|
|
var _ plugin.PluginIPLD = (*gitPlugin)(nil)
|
|
|
|
func (*gitPlugin) Name() string {
|
|
return "ipld-git"
|
|
}
|
|
|
|
func (*gitPlugin) Version() string {
|
|
return "0.0.1"
|
|
}
|
|
|
|
func (*gitPlugin) Init() error {
|
|
return nil
|
|
}
|
|
|
|
func (*gitPlugin) RegisterBlockDecoders(dec format.BlockDecoder) error {
|
|
dec.Register(cid.GitRaw, git.DecodeBlock)
|
|
return nil
|
|
}
|
|
|
|
func (*gitPlugin) RegisterInputEncParsers(iec coredag.InputEncParsers) error {
|
|
iec.AddParser("raw", "git", parseRawGit)
|
|
iec.AddParser("zlib", "git", parseZlibGit)
|
|
return nil
|
|
}
|
|
|
|
func parseRawGit(r io.Reader, mhType uint64, mhLen int) ([]format.Node, error) {
|
|
if mhType != math.MaxUint64 && mhType != mh.SHA1 {
|
|
return nil, fmt.Errorf("unsupported mhType %d", mhType)
|
|
}
|
|
|
|
if mhLen != -1 && mhLen != mh.DefaultLengths[mh.SHA1] {
|
|
return nil, fmt.Errorf("invalid mhLen %d", mhLen)
|
|
}
|
|
|
|
nd, err := git.ParseObject(r)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return []format.Node{nd}, nil
|
|
}
|
|
|
|
func parseZlibGit(r io.Reader, mhType uint64, mhLen int) ([]format.Node, error) {
|
|
rc, err := zlib.NewReader(r)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
defer rc.Close()
|
|
return parseRawGit(rc, mhType, mhLen)
|
|
}
|