types.go 1.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. package handler
  2. import (
  3. "context"
  4. "time"
  5. "github.com/mkaminski/goaim/oscar"
  6. "github.com/mkaminski/goaim/state"
  7. )
  8. type FeedbagManager interface {
  9. Blocked(sn1, sn2 string) (state.BlockedState, error)
  10. Buddies(screenName string) ([]string, error)
  11. Delete(screenName string, items []oscar.FeedbagItem) error
  12. InterestedUsers(screenName string) ([]string, error)
  13. LastModified(screenName string) (time.Time, error)
  14. Retrieve(screenName string) ([]oscar.FeedbagItem, error)
  15. Upsert(screenName string, items []oscar.FeedbagItem) error
  16. }
  17. type UserManager interface {
  18. GetUser(screenName string) (*state.User, error)
  19. UpsertUser(u state.User) error
  20. }
  21. type SessionManager interface {
  22. Empty() bool
  23. NewSessionWithSN(sessID string, screenName string) *state.Session
  24. Remove(sess *state.Session)
  25. Retrieve(ID string) (*state.Session, bool)
  26. }
  27. type ProfileManager interface {
  28. RetrieveProfile(screenName string) (string, error)
  29. UpsertProfile(screenName string, body string) error
  30. }
  31. type MessageRelayer interface {
  32. BroadcastToScreenNames(ctx context.Context, screenNames []string, msg oscar.SNACMessage)
  33. RetrieveByScreenName(screenName string) *state.Session
  34. SendToScreenName(ctx context.Context, screenName string, msg oscar.SNACMessage)
  35. }
  36. type ChatMessageRelayer interface {
  37. MessageRelayer
  38. BroadcastExcept(ctx context.Context, except *state.Session, msg oscar.SNACMessage)
  39. Participants() []*state.Session
  40. }