hub

package

Go to main page

Versions in this module

v0

v0.26.0

Feb 24, 2020

v0.25.0

Feb 23, 2020

Changes in this version

+ const ConfigADCRedirectTLS

+ const ConfigHubPrivate

+ const ConfigNMDCRedirectADC

+ const ConfigNMDCRedirectTLS

+ const PermDropAll

+ const PermRedirect

+ const PermRedirectAll

+ const PermRegister

+ const PermRegisterProfile

+ const PermRoomsNew

+ const PermRoomsOpChat

+ var ErrCantJoinRoom = errors.New("cannot join the room")

+ func IsBot(p Peer) bool

type Config

+ Private bool

type ConnInfo

+ Proto string

type Hub

+ func (h *Hub) GlobalChatRoom() *Room

+ func (h *Hub) IsPrivate() bool

+ func (h *Hub) Log(args ...interface{})

+ func (h *Hub) Logf(format string, args ...interface{})

+ func (h *Hub) NewPermRoom(name string, perm string) (*Room, error)

+ func (h *Hub) NewPrivateRoom(name string) (*Room, error)

+ func (h *Hub) OnConnectedIP4(fnc func(c net.Conn, ip net.IP) bool)

+ func (h *Hub) OnConnectedIP6(fnc func(c net.Conn, ip net.IP) bool)

+ func (h *Hub) OnGlobalChat(fnc func(p Peer, m Message) bool)

+ func (h *Hub) OnPM(fnc func(from, to Peer, m Message) bool)

+ func (h *Hub) OnPermJoined(perm string, fnc func(p Peer) bool)

+ func (h *Hub) OnPermLeave(perm string, fnc func(p Peer))

+ func (h *Hub) OpLog(args ...interface{})

+ func (h *Hub) OpLogf(format string, args ...interface{})

+ func (h *Hub) RoomsFor(p Peer) []*Room

type Peer

+ Redirect func(addr string) error

+ type ReleaseInfo struct

+ Desc string

+ Time time.Time

+ URL string

+ Version semver.Version

+ func CheckForUpdates(ctx context.Context, force bool) (*ReleaseInfo, error)

type Room

+ func (r *Room) CanJoin(p Peer) bool

+ func (r *Room) IsPrivate() bool

type Stats

+ Private bool

v0.20.0

May 5, 2019

Changes in this version

+ const ConfigHubDesc

+ const ConfigHubEmail

+ const ConfigHubMOTD

+ const ConfigHubName

+ const ConfigHubOwner

+ const ConfigHubTopic

+ const ConfigHubWebsite

+ const ConfigZlibLevel

+ const PermConfigRead

+ const PermConfigWrite

+ const PermTopic

+ func NMDCUserInfo(p Peer) nmdcp.MyINFO

+ func ToNMDCChatMsg(from Peer, msg Message) *nmdcp.ChatMessage

type Ban

+ Hard bool

+ Key BanKey

+ type BanDatabase interface

+ ClearBans func() error

+ DelBans func(keys []BanKey) error

+ GetBan func(key BanKey) (*Ban, error)

+ ListBans func() ([]Ban, error)

+ PutBans func(bans []Ban) error

+ type BanKey string

+ func MinAddrKey(a net.Addr) BanKey

+ func MinIPKey(ip net.IP) BanKey

+ func (k BanKey) ToIP() net.IP

type Bot

+ func (b *Bot) UserInfo() UserInfo

type Config

+ Topic string

type Hub

+ func (h *Hub) ConfigKeys() []string

+ func (h *Hub) GetConfig(key string) (interface{}, bool)

+ func (h *Hub) GetConfigBool(key string) (bool, bool)

+ func (h *Hub) GetConfigFloat(key string) (float64, bool)

+ func (h *Hub) GetConfigInt(key string) (int64, bool)

+ func (h *Hub) GetConfigString(key string) (string, bool)

+ func (h *Hub) GetConfigUint(key string) (uint64, bool)

+ func (h *Hub) MergeConfig(m Map)

+ func (h *Hub) MergeConfigPath(path string, m Map)

+ func (h *Hub) NewBotDesc(name, desc, email string, soft dc.Software) (*Bot, error)

+ func (h *Hub) OnLeave(fnc func(p Peer))

+ func (h *Hub) SendNMDCTo(p Peer, msgs ...nmdcp.Message) error

+ func (h *Hub) SetConfig(key string, val interface{})

+ func (h *Hub) SetConfigBool(key string, val bool)

+ func (h *Hub) SetConfigFloat(key string, val float64)

+ func (h *Hub) SetConfigInt(key string, val int64)

+ func (h *Hub) SetConfigString(key string, val string)

+ func (h *Hub) SetConfigUint(key string, val uint64)

+ type PeerTopic interface

+ Topic func(topic string) error

type User

+ func (u *User) IsOp() bool

+ func (u *User) IsRegistered() bool

type UserInfo

+ Desc string

type UserProfile

+ func (p *UserProfile) HasParent(id string) bool

v0.18.0

May 4, 2019

Changes in this version

type Bot

+ func (b *Bot) Name() string

+ type PeersJoinEvent struct

+ Peers []Peer

+ type PeersLeaveEvent struct

+ Peers []Peer

+ type PeersUpdateEvent struct

+ Peers []Peer

v0.16.5

May 2, 2019

Changes in this version

type Hub

+ func (h *Hub) Uptime() time.Duration

v0.16.4

May 1, 2019

Changes in this version

+ const FlagOpIcon

+ const FlagRegIcon

+ const PermBanIP

+ const PermBroadcast

+ const PermDrop

+ const PermIP

+ const PermOwner

+ const PermRoomsJoin

+ const PermRoomsList

+ const ProfileNameGuest

+ const ProfileNameOperator

+ const ProfileNameRegistered

+ const ProfileNameRoot

+ const ProfileParent

+ const UserBot

+ const UserHub

+ const UserNormal

+ var ErrNameTaken = errors.New("user name already taken")

+ var ErrUserNotFound = errors.New("user does not exist")

+ func DefaultProfiles() map[string]Map

+ func RegisterPlugin(p Plugin)

+ type Ban struct

+ Reason string

+ Until time.Time

type BasePeer

+ func (p *BasePeer) ConnInfo() *ConnInfo

+ func (p *BasePeer) Name() string

+ func (p *BasePeer) Online() bool

+ func (p *BasePeer) User() *User

+ type Bot struct

+ func (b *Bot) Close() error

+ func (b *Bot) SendGlobal(m Message) error

+ func (b *Bot) SendPrivate(to Peer, m Message) error

+ type Broadcaster interface

+ BroadcastJoinTo func(peers []Peer)

+ BroadcastLeaveTo func(peers []Peer)

+ BroadcastUpdateTo func(peers []Peer)

+ type CID = adc.CID

type Command

+ Menu []string

+ Require string

+ type CommandFunc = func(p Peer, args string) error

+ type ConnInfo struct

+ ALPN string

+ Local net.Addr

+ Remote net.Addr

+ Secure bool

+ TLSVers uint16

type Database

+ func NewDatabase() Database

+ Close func() error

+ type ErrUnknownProtocol struct

+ Magic []byte

+ Secure bool

+ func (e *ErrUnknownProtocol) Error() string

type Hub

+ func (h *Hub) AddAddress(addr string)

+ func (h *Hub) Close() error

+ func (h *Hub) DeleteUser(name string) error

+ func (h *Hub) EachHardBlockedIP(fnc func(ip net.IP) bool)

+ func (h *Hub) HardBlock(a net.Addr)

+ func (h *Hub) HardBlockIP(ip net.IP)

+ func (h *Hub) HardUnBlockIP(ip net.IP)

+ func (h *Hub) HubUser() *Bot

+ func (h *Hub) IsHardBlocked(a net.Addr) bool

+ func (h *Hub) IsHardBlockedIP(ip net.IP) bool

+ func (h *Hub) LoadPluginsInDir(dir string) error

+ func (h *Hub) NewBot(name string, soft dc.Software) (*Bot, error)

+ func (h *Hub) OnChat(fnc func(p Peer, m Message) bool)

+ func (h *Hub) OnConnected(fnc func(c net.Conn) bool)

+ func (h *Hub) OnDisconnected(fnc func(c net.Conn))

+ func (h *Hub) OnJoined(fnc func(p Peer) bool)

+ func (h *Hub) PeerByName(name string) Peer

+ func (h *Hub) Profile(id string) *UserProfile

+ func (h *Hub) RegisterCommand(cmd Command)

+ func (h *Hub) Rooms() []*Room

+ func (h *Hub) SendGlobalChat(text string)

+ func (h *Hub) Start() error

+ func (h *Hub) UpdateUser(name string, fnc func(u *UserRecord) (bool, error)) error

+ type Map map[string]interface

+ func (m Map) Clone() Map

type Message

+ Me bool

type Peer

+ ConnInfo func() *ConnInfo

+ Online func() bool

+ PeersUpdate func(peers []Peer) error

+ Searchable func() bool

+ UserInfo func() UserInfo

+ type Plugin interface

+ Close func() error

+ Init func(h *Hub, path string) error

+ Name func() string

+ Version func() Version

+ type ProfileDatabase interface

+ DelProfile func(id string) error

+ GetProfile func(id string) (Map, error)

+ ListProfiles func() ([]string, error)

+ PutProfile func(id string, m Map) error

+ type RawCmd string

type User

+ func (u *User) BanUntil(t time.Time, reason string)

+ func (u *User) Has(flag string) bool

+ func (u *User) HasPerm(perm string) bool

+ func (u *User) IsBanned() *Ban

+ func (u *User) IsOwner() bool

+ func (u *User) Profile() *UserProfile

+ func (u *User) SetName(name string)

+ func (u *User) SetProfile(p *UserProfile)

type UserDatabase

+ CreateUser func(rec UserRecord) error

+ DeleteUser func(name string) error

+ GetUser func(name string) (*UserRecord, error)

+ ListUsers func() ([]UserRecord, error)

+ UpdateUser func(name string, fnc func(u *UserRecord) (bool, error)) error

+ type UserInfo struct

+ App dc.Software

+ Email string

+ HubsNormal int

+ HubsOperator int

+ HubsRegistered int

+ IPv4 bool

+ IPv6 bool

+ Kind UserKind

+ Name string

+ Share uint64

+ Slots int

+ TLS bool

+ type UserKind int

+ type UserProfile struct

+ func (p *UserProfile) Get(key string) (interface{}, bool)

+ func (p *UserProfile) GetBool(key string) bool

+ func (p *UserProfile) GetString(key string) string

+ func (p *UserProfile) Has(flag string) bool

+ func (p *UserProfile) ID() string

+ func (p *UserProfile) IsOwner() bool

+ func (p *UserProfile) Parent() *UserProfile

+ func (p *UserProfile) SetParent(par *UserProfile) *UserProfile

+ type UserRecord struct

+ Name string

+ Pass string

+ Profile string

+ type Version struct

+ Major int

+ Minor int

+ Patch int

+ Rev string

+ func (v Version) String() string

+ func (v Version) Vers3() string

v0.8.16

Mar 17, 2019

v0.8.15

Mar 17, 2019

v0.8.14

Mar 15, 2019

v0.8.13

Mar 13, 2019

v0.8.12

Mar 13, 2019

v0.8.11

Mar 10, 2019

v0.8.8

Mar 7, 2019

Changes in this version

+ const FileTypeAny

+ const FileTypeAudio

+ const FileTypeCompressed

+ const FileTypeDocuments

+ const FileTypeExecutable

+ const FileTypePicture

+ const FileTypeVideo

+ const HTTPInfoPathV0

+ var ErrRoomExists = errors.New("room already exists")

+ var ErrUserRegDisabled = errors.New("user registration is disabled")

+ type BasePeer struct

+ func (p *BasePeer) LocalAddr() net.Addr

+ func (p *BasePeer) RemoteAddr() net.Addr

+ func (p *BasePeer) SID() SID

+ type Command struct

+ Aliases []string

+ Func func(h *Hub, p Peer, args string) error

+ Long string

+ Name string

+ Path []string

+ Short string

+ type Config struct

+ Addr string

+ ChatLog int

+ ChatLogJoin int

+ Desc string

+ Email string

+ FallbackEncoding string

+ Keyprint string

+ MOTD string

+ Name string

+ Owner string

+ Soft Software

+ TLS *tls.Config

+ Website string

+ type Database = UserDatabase

+ type Dir struct

+ Path string

+ Peer Peer

+ func (f Dir) From() Peer

+ type DirSearch struct

+ func (s DirSearch) Match(r SearchResult) bool

+ type File struct

+ Path string

+ Peer Peer

+ Size uint64

+ TTH *TTH

+ func (f File) From() Peer

+ type FileSearch struct

+ Ext []string

+ FileType FileType

+ MaxSize uint64

+ MinSize uint64

+ NoExt []string

+ func (s FileSearch) Match(r SearchResult) bool

+ type FileType int

+ type Hub struct

+ func NewHub(conf Config) (*Hub, error)

+ func (h *Hub) IsRegistered(name string) (bool, error)

+ func (h *Hub) ListCommands() []*Command

+ func (h *Hub) ListenAndServe(addr string) error

+ func (h *Hub) NewRoom(name string) (*Room, error)

+ func (h *Hub) Peers() []Peer

+ func (h *Hub) RegisterUser(name, pass string) error

+ func (h *Hub) Room(name string) *Room

+ func (h *Hub) Search(req SearchRequest, s Search, peers []Peer)

+ func (h *Hub) Serve(conn net.Conn) error

+ func (h *Hub) ServeADC(conn net.Conn) error

+ func (h *Hub) ServeHTTP1(conn net.Conn) error

+ func (h *Hub) ServeHTTP2(conn net.Conn) error

+ func (h *Hub) ServeIRC(conn net.Conn) error

+ func (h *Hub) ServeNMDC(conn net.Conn) error

+ func (h *Hub) SetDatabase(db Database)

+ func (h *Hub) Stats() Stats

+ type Message struct

+ Name string

+ Text string

+ Time time.Time

+ type NameSearch struct

+ And []string

+ Not []string

+ func (f NameSearch) Match(r SearchResult) bool

+ func (f NameSearch) MatchName(name string) bool

+ type Peer interface

+ BroadcastJoin func(peers []Peer)

+ BroadcastLeave func(peers []Peer)

+ ChatMsg func(room *Room, from Peer, m Message) error

+ Close func() error

+ ConnectTo func(peer Peer, addr string, token string, secure bool) error

+ HubChatMsg func(text string) error

+ JoinRoom func(room *Room) error

+ LeaveRoom func(room *Room) error

+ LocalAddr func() net.Addr

+ Name func() string

+ PeersJoin func(peers []Peer) error

+ PeersLeave func(peers []Peer) error

+ PrivateMsg func(from Peer, m Message) error

+ RemoteAddr func() net.Addr

+ RevConnectTo func(peer Peer, token string, secure bool) error

+ SID func() SID

+ Search func(ctx context.Context, req SearchRequest, out Search) error

+ User func() User

+ type Room struct

+ func (r *Room) InRoom(p Peer) bool

+ func (r *Room) Join(p Peer)

+ func (r *Room) Leave(p Peer)

+ func (r *Room) Name() string

+ func (r *Room) Peers() []Peer

+ func (r *Room) ReplayChat(to Peer, n int)

+ func (r *Room) SID() SID

+ func (r *Room) SendChat(from Peer, text string)

+ func (r *Room) Users() int

+ type SID = adc.SID

+ type Search interface

+ Close func() error

+ Peer func() Peer

+ SendResult func(r SearchResult) error

+ type SearchRequest interface

+ Match func(r SearchResult) bool

+ type SearchResult interface

+ From func() Peer

+ type Software struct

+ Name string

+ Vers string

+ type Stats struct

+ Addr []string

+ Desc string

+ Email string

+ Enc string

+ Icon string

+ Keyprint string

+ MaxShare uint64

+ MaxUsers int

+ Name string

+ Owner string

+ Share uint64

+ Soft Software

+ Uptime uint64

+ Users int

+ Website string

+ func (st *Stats) DefaultAddr() string

+ type TTH = tiger.Hash

+ type TTHSearch TTH

+ func (h TTHSearch) Match(r SearchResult) bool

+ type User struct

+ App Software

+ Email string

+ HubsNormal int

+ HubsOperator int

+ HubsRegistered int

+ IPv4 bool

+ IPv6 bool

+ Name string

+ Share uint64

+ Slots int

+ TLS bool

+ type UserDatabase interface

+ Close func() error

+ GetUserPassword func(name string) (string, error)

+ IsRegistered func(name string) (bool, error)

+ RegisterUser func(name, pass string) error

+ func NewUserDatabase() UserDatabase

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL