ipfs

Documentation

Index

• Constants
• Variables
• func AddDirectory(ctx commands.Context, fpath string) (rootHash string, err error)
• func AddFile(ctx commands.Context, fpath string) (string, error)
• func Cat(ctx commands.Context, hash string) ([]byte, error)
• func ConnectedPeers(ctx commands.Context) ([]string, error)
• func FindPointers(dht *routing.IpfsDHT, ctx context.Context, mhKey multihash.Multihash, ...) ([]ps.PeerInfo, error)
• func FindPointersAsync(dht *routing.IpfsDHT, ctx context.Context, mhKey multihash.Multihash, ...) <-chan ps.PeerInfo
• func IdentityFromKey(privkey []byte) (config.Identity, error)
• func IdentityKeyFromSeed(seed []byte, bits int) ([]byte, error)
• func MockCmdsCtx() (commands.Context, error)
• func MockHostOption(mn mocknet.Mocknet) core.HostOption
• func NewMockNode() (*core.IpfsNode, error)
• func NewRequest(ctx cmds.Context, args []string) (cmds.Request, *cmds.Command, error)
• func NewRequestWithTimeout(ctx cmds.Context, args []string, timeout time.Duration) (cmds.Request, *cmds.Command, error)
• func Publish(ctx commands.Context, hash string) (string, error)
• func Query(ctx commands.Context, peerID string) ([]peer.ID, error)
• func RePublishPointer(node *core.IpfsNode, ctx context.Context, pointer Pointer) error
• func Resolve(ctx commands.Context, hash string) (string, error)
• func ResolveThenCat(ctx commands.Context, ipnsPath path.Path) ([]byte, error)
• func UnPinDir(ctx commands.Context, rootHash string) error
• type DeterministicReader
  • func (d *DeterministicReader) Read(p []byte) (n int, err error)
• type Pointer
  • func PublishPointer(node *core.IpfsNode, ctx context.Context, mhKey multihash.Multihash, ...) (Pointer, error)
• type Purpose

Constants

const CatTimeout = 30 * time.Second

const MAGIC string = "000000000000000000000000"

const ResolveTimeout = 30 * time.Second

Variables

var Root = &cmds.Command{
	Options:  commands.Root.Options,
	Helptext: commands.Root.Helptext,
}

Functions

func AddDirectory

func AddDirectory(ctx commands.Context, fpath string) (rootHash string, err error)

Resursively add a directory to IPFS and return the root hash

func AddFile

func AddFile(ctx commands.Context, fpath string) (string, error)

func Cat

func Cat(ctx commands.Context, hash string) ([]byte, error)

Fetch data from IPFS given the hash

func ConnectedPeers

func ConnectedPeers(ctx commands.Context) ([]string, error)

func FindPointers

func FindPointers(dht *routing.IpfsDHT, ctx context.Context, mhKey multihash.Multihash, prefixLen int) ([]ps.PeerInfo, error)

Fetch pointers from the dht

func FindPointersAsync

func FindPointersAsync(dht *routing.IpfsDHT, ctx context.Context, mhKey multihash.Multihash, prefixLen int) <-chan ps.PeerInfo

Fetch pointers from the dht. They will be returned asynchronously.

func IdentityFromKey

func IdentityFromKey(privkey []byte) (config.Identity, error)

func IdentityKeyFromSeed

func IdentityKeyFromSeed(seed []byte, bits int) ([]byte, error)

func MockCmdsCtx

func MockCmdsCtx() (commands.Context, error)

func MockHostOption

func MockHostOption(mn mocknet.Mocknet) core.HostOption

func NewMockNode

func NewMockNode() (*core.IpfsNode, error)

NewMockNode constructs an IpfsNode for use in tests.

func NewRequest

func NewRequest(ctx cmds.Context, args []string) (cmds.Request, *cmds.Command, error)

func NewRequestWithTimeout

func NewRequestWithTimeout(ctx cmds.Context, args []string, timeout time.Duration) (cmds.Request, *cmds.Command, error)

func Publish

func Publish(ctx commands.Context, hash string) (string, error)

Publish a signed IPNS record to our Peer ID

func Query

func Query(ctx commands.Context, peerID string) ([]peer.ID, error)

func RePublishPointer

func RePublishPointer(node *core.IpfsNode, ctx context.Context, pointer Pointer) error

func Resolve

func Resolve(ctx commands.Context, hash string) (string, error)

Publish a signed IPNS record to our Peer ID

func ResolveThenCat

func ResolveThenCat(ctx commands.Context, ipnsPath path.Path) ([]byte, error)

func UnPinDir

func UnPinDir(ctx commands.Context, rootHash string) error

Recursively un-pin a directory given its hash.

This will allow it to be garbage collected.

Types

type DeterministicReader

type DeterministicReader struct {
	Seed    []byte
	Counter uint64
}

func (*DeterministicReader) Read

func (d *DeterministicReader) Read(p []byte) (n int, err error)

type Pointer

type Pointer struct {
	Key       key.Key
	Value     ps.PeerInfo
	Purpose   Purpose
	Timestamp time.Time
}

A pointer is a custom provider inserted into the DHT which points to a location of a file.

For offline messaging purposes we use a hash of the recipient's ID as the key and set the
provider to the location of the ciphertext. We set the Peer ID of the provider object to
a magic number so we distinguish it from regular providers and use a longer ttl.
Note this will only be compatible with the OpenBazaar/go-ipfs fork.

func PublishPointer

func PublishPointer(node *core.IpfsNode, ctx context.Context, mhKey multihash.Multihash, prefixLen int, addr ma.Multiaddr) (Pointer, error)

type Purpose

type Purpose int

const (
	MESSAGE   Purpose = 1
	MODERATOR Purpose = 2
	TAG       Purpose = 3
	CHANNEL   Purpose = 4
)