Versions in this module Expand all Collapse all v0 v0.1.9 Sep 11, 2018 Changes in this version + type Config struct + Blocks func() repo.BlockStore + GetHead func() (string, error) + GetUsername func() (*string, error) + Ipfs func() *core.IpfsNode + NewEnvelope func(message *pb.Message) (*pb.Envelope, error) + Notifications func() repo.NotificationStore + Peers func() repo.PeerStore + Publish func(payload []byte) error + PutPinRequest func(id string) error + RepoPath string + Send func(message *pb.Envelope, peerId string, hash *string) error + SendUpdate func(update Update) + UpdateHead func(head string) error + type Info struct + BlockCount int + Head *repo.Block + LatestPhoto *repo.Block + PhotoCount int + type Thread struct + GetHead func() (string, error) + Id string + Name string + PrivKey libp2pc.PrivKey + func NewThread(model *repo.Thread, config *Config) (*Thread, error) + func (t *Thread) AddComment(dataId string, body string) (mh.Multihash, error) + func (t *Thread) AddExternalInvite() (mh.Multihash, []byte, error) + func (t *Thread) AddInvite(inviteePk libp2pc.PubKey) (mh.Multihash, error) + func (t *Thread) AddLike(dataId string) (mh.Multihash, error) + func (t *Thread) AddPhoto(dataId string, caption string, key []byte) (mh.Multihash, error) + func (t *Thread) Blocks(offsetId string, limit int, btype *repo.BlockType, dataId *string) []repo.Block + func (t *Thread) Decrypt(data []byte) ([]byte, error) + func (t *Thread) Encrypt(data []byte) ([]byte, error) + func (t *Thread) FollowParents(parents []string, from *peer.ID) ([]repo.Peer, error) + func (t *Thread) GetBlockData(path string, block *repo.Block) ([]byte, error) + func (t *Thread) GetBlockDataKey(block *repo.Block) ([]byte, error) + func (t *Thread) GetPhotoMetaData(id string, block *repo.Block) (*util.PhotoMetadata, error) + func (t *Thread) HandleAnnotationBlock(from *peer.ID, env *pb.Envelope, signed *pb.SignedThreadBlock, ...) (mh.Multihash, error) + func (t *Thread) HandleDataBlock(from *peer.ID, env *pb.Envelope, signed *pb.SignedThreadBlock, ...) (mh.Multihash, error) + func (t *Thread) HandleExternalInviteMessage(content *pb.ThreadExternalInvite) error + func (t *Thread) HandleIgnoreBlock(from *peer.ID, env *pb.Envelope, signed *pb.SignedThreadBlock, ...) (mh.Multihash, error) + func (t *Thread) HandleInviteMessage(content *pb.ThreadInvite) error + func (t *Thread) HandleJoinBlock(from *peer.ID, env *pb.Envelope, signed *pb.SignedThreadBlock, ...) (mh.Multihash, *repo.Peer, error) + func (t *Thread) HandleLeaveBlock(from *peer.ID, env *pb.Envelope, signed *pb.SignedThreadBlock, ...) (mh.Multihash, error) + func (t *Thread) HandleMergeBlock(from *peer.ID, message *pb.Message, signed *pb.SignedThreadBlock, ...) (mh.Multihash, error) + func (t *Thread) Ignore(blockId string) (mh.Multihash, error) + func (t *Thread) Info() (*Info, error) + func (t *Thread) Join(inviterPk libp2pc.PubKey, blockId string) (mh.Multihash, error) + func (t *Thread) JoinInitial() (mh.Multihash, error) + func (t *Thread) Leave() (mh.Multihash, error) + func (t *Thread) Merge(head string) (mh.Multihash, error) + func (t *Thread) Peers() []repo.Peer + func (t *Thread) Verify(signed *pb.SignedThreadBlock) error + type Update struct + Block repo.Block + ThreadId string + ThreadName string
Go to main page