net

Nov 23, 2017

Changes in this version

+ var DuplicateMessage error = errors.New("Duplicate Message")

Oct 13, 2017

Changes in this version

type NetworkService

+ DisconnectFromPeer func(p peer.ID) error

Jul 7, 2017

Changes in this version

+ var OutOfOrderMessage error = errors.New("Message arrived out of order")

Mar 10, 2017

Changes in this version

+ type BanManager struct

+ func NewBanManager(blockedIds []peer.ID) *BanManager

+ func (bm *BanManager) AddBlockedId(peerId peer.ID)

+ func (bm *BanManager) GetBlockedIds() []peer.ID

+ func (bm *BanManager) IsBanned(peerId peer.ID) bool

+ func (bm *BanManager) RemoveBlockedId(peerId peer.ID)

+ func (bm *BanManager) SetBlockedIds(peerIds []peer.ID)

Jan 25, 2017

Changes in this version

+ const EphemeralPublicKeyBytes

+ const NonceBytes

+ var BoxDecryptionError = errors.New("Failed to decrypt curve25519")

Sep 20, 2016

Changes in this version

+ func CreateHiddenServiceKey(repoPath string) error

+ func GetTorControlPort() (int, error)

+ func MaybeCreateHiddenServiceKey(repoPath string) error

type NetworkService

+ HandlerForMsgType func(t pb.Message_MessageType) func(peer.ID, *pb.Message) (*pb.Message, error)

Aug 27, 2016

Changes in this version

+ const AESKeyBytes

+ const CiphertextVersion

+ const CiphertextVersionBytes

+ const EncryptedSecretKeyBytes

+ const MacBytes

+ const MacKeyBytes

+ const SecretKeyBytes

+ var ErrInvalidHmac = errors.New("Invalid Hmac")

+ var ErrShortCiphertext = errors.New("Ciphertext is too short")

+ var Salt = []byte("OpenBazaar Encryption Algorithm")

+ func Decrypt(privKey libp2p.PrivKey, ciphertext []byte) ([]byte, error)

+ func Encrypt(pubKey libp2p.PubKey, plaintext []byte) ([]byte, error)

Aug 17, 2016

Changes in this version

+ var STUN_PORT int = 3478

+ var STUN_SERVERS []string = []string

+ func NATtoString(i stunlib.NATType) string

+ func Shuffle(a []string)

+ func Stun() (int, error)

+ type MessageRetriever struct

+ func NewMessageRetriever(db repo.Datastore, ctx commands.Context, node *core.IpfsNode, ...) *MessageRetriever

+ func (m *MessageRetriever) Run()

+ type NetworkService interface

+ HandleNewStream func(s inet.Stream)

+ SendMessage func(ctx context.Context, p peer.ID, pmes *pb.Message) error

+ SendRequest func(ctx context.Context, p peer.ID, pmes *pb.Message) (*pb.Message, error)

+ type PointerRepublisher struct

+ func NewPointerRepublisher(node *core.IpfsNode, database repo.Datastore) *PointerRepublisher

+ func (r *PointerRepublisher) Run()