config

type Config struct {
	CCtx client.Context

	// BootstrapMultiaddrs is the list of bootstrap nodes
	BootstrapMultiaddrs []string

	// Callback is the callback for the motor
	Callback common.NodeCallback

	// RendezvousString is the rendezvous string for the motor
	RendezvousString string

	// GroupIDs is the list of peer ids for the node
	GroupIDs []party.ID

	// SelfPartyID is the party id for the node
	SelfPartyID party.ID

	// PeerType is the type of peer
	PeerType common.PeerType

	// RemoteIPFSURL is the remote IPFS URL
	RemoteIPFSURL string

	// EncryptionKey is the encryption key for the node
	EncryptionKey p2pcrypto.PrivKey

	// EncryptionPrivKeyPath is the encryption key for the node
	EncryptionPrivKeyPath string

	// EncryptionPubKeyPath is the encryption key for the node
	EncryptionPubKeyPath string
}

type IPFSNode interface {
	Node

	// Get the IPFS Core API
	CoreAPI() icore.CoreAPI

	// Get the IPFS PubSub API
	GetCapabilityDelegation() *types.VerificationMethod

	// Add a file to the network
	Add(data []byte) (string, error)

	// AddEncrypted adds a file to the network, encrypted with the given public key.
	AddEncrypted(file []byte, pubKey []byte) (string, error)

	// AddPath adds a file to the network
	AddPath(path string) (string, error)

	// Get a file from the network
	Get(hash string) ([]byte, error)

	// GetDecrypted takes a cid and a public key and returns the decrypted file.
	GetDecrypted(cidStr string, pubKey []byte) ([]byte, error)

	// GetPath gets a file from the network
	GetPath(hash string) (map[string]files.Node, error)
}

type Node interface {
	// PeerID returns the peer ID of the node
	PeerID() peer.ID

	// Connect to a peer
	Connect(peers ...string) error

	// MultiAddrs returns the multiaddr of the node
	MultiAddrs() string

	// Close the node
	Close() error
}

type Option func(*Config) error

type P2PNode interface {
	Node

	// NewStream creates a new stream to a peer
	NewStream(to peer.ID, protocol protocol.ID, msg proto.Message) error

	// SetStreamHandler sets the handler for a given protocol
	SetStreamHandler(protocol protocol.ID, handler network.StreamHandler)

	// Publish a message to a topic
	Publish(topic string, message []byte, opts ...ps.TopicOpt) error

	// Subscribe to a topic
	Subscribe(topic string, handlers ...func(msg *ps.Message)) (*ps.Subscription, error)
}