service

Documentation

Index

• func DecodeRequestToNewSession(r *http.Response) (*model.Session, error)
• func WriteResponse(w http.ResponseWriter, object interface{}, err error)
• type AuthService
  • func CreateDefaultAuthService() *AuthService
  • func (a *AuthService) CreateSession(newSession model.NewSession) (*model.Session, error)
  • func (a *AuthService) DoWithValidSession(w http.ResponseWriter, r *http.Request, ...)
  • func (a *AuthService) DoWithValidSessionAndUser(w http.ResponseWriter, r *http.Request, userUuid uuid.UUID, ...)
  • func (a *AuthService) GetSessionFromRequest(r *http.Request) *model.Session
• type ConsumerService
  • func CreateConsumerService() *ConsumerService
  • func (c *ConsumerService) CreatePostLikeNotification(postLike *model.PostLike)
  • func (c *ConsumerService) UpdateProfilePic(userUuid uuid.UUID, s3Key string)
  • func (c *ConsumerService) UpsertFollow(followModel *model.Follow)
  • func (c *ConsumerService) UpsertPost(postModel *model.Post)
  • func (c *ConsumerService) UpsertUser(userModel *model.User)
• type FollowService
  • func CreateFollowService() *FollowService
  • func (f *FollowService) UpsertFollow(followModel *model.Follow) bool
• type NotificationService
  • func CreateNotificationService() *NotificationService
  • func (n *NotificationService) AcknowledgeNotifications(userUuid uuid.UUID, ack *model.NotificationAcknowledgement) error
  • func (n *NotificationService) CreateFollowNotification(followModel *model.Follow)
  • func (n *NotificationService) CreatePostLikeNotification(postLikeModel *model.PostLike)
  • func (n *NotificationService) GetNotifications(userUuid uuid.UUID, limit int) ([]*model.Notification, error)
• type PostService
  • func CreatePostService() *PostService
  • func (p *PostService) UpsertPost(postModel *model.Post)
• type UserService
  • func CreateUserService() *UserService
  • func (u *UserService) UpdateProfilePic(userUuid uuid.UUID, s3Key string)
  • func (u *UserService) UpsertUser(userModel *model.User)

Functions

func DecodeRequestToNewSession

func DecodeRequestToNewSession(r *http.Response) (*model.Session, error)

func WriteResponse

func WriteResponse(w http.ResponseWriter, object interface{}, err error)

Types

type AuthService

type AuthService struct {
	// contains filtered or unexported fields
}

func CreateDefaultAuthService

func CreateDefaultAuthService() *AuthService

func (*AuthService) CreateSession

func (a *AuthService) CreateSession(newSession model.NewSession) (*model.Session, error)

func (*AuthService) DoWithValidSession

func (a *AuthService) DoWithValidSession(w http.ResponseWriter, r *http.Request, doAction func(session *model.Session) (interface{}, error))

func (*AuthService) DoWithValidSessionAndUser

func (a *AuthService) DoWithValidSessionAndUser(w http.ResponseWriter, r *http.Request, userUuid uuid.UUID, doAction func() (interface{}, error))

func (*AuthService) GetSessionFromRequest

func (a *AuthService) GetSessionFromRequest(r *http.Request) *model.Session

type ConsumerService

type ConsumerService struct {
	// contains filtered or unexported fields
}

func CreateConsumerService

func CreateConsumerService() *ConsumerService

func (*ConsumerService) CreatePostLikeNotification

func (c *ConsumerService) CreatePostLikeNotification(postLike *model.PostLike)

func (*ConsumerService) UpdateProfilePic

func (c *ConsumerService) UpdateProfilePic(userUuid uuid.UUID, s3Key string)

func (*ConsumerService) UpsertFollow

func (c *ConsumerService) UpsertFollow(followModel *model.Follow)

func (*ConsumerService) UpsertPost

func (c *ConsumerService) UpsertPost(postModel *model.Post)

func (*ConsumerService) UpsertUser

func (c *ConsumerService) UpsertUser(userModel *model.User)

type FollowService

type FollowService struct {
	// contains filtered or unexported fields
}

func CreateFollowService

func CreateFollowService() *FollowService

func (*FollowService) UpsertFollow

func (f *FollowService) UpsertFollow(followModel *model.Follow) bool

type NotificationService

type NotificationService struct {
	// contains filtered or unexported fields
}

func CreateNotificationService

func CreateNotificationService() *NotificationService

func (*NotificationService) AcknowledgeNotifications

func (n *NotificationService) AcknowledgeNotifications(userUuid uuid.UUID, ack *model.NotificationAcknowledgement) error

func (*NotificationService) CreateFollowNotification

func (n *NotificationService) CreateFollowNotification(followModel *model.Follow)

func (*NotificationService) CreatePostLikeNotification

func (n *NotificationService) CreatePostLikeNotification(postLikeModel *model.PostLike)

func (*NotificationService) GetNotifications

func (n *NotificationService) GetNotifications(userUuid uuid.UUID, limit int) ([]*model.Notification, error)

type PostService

type PostService struct {
	// contains filtered or unexported fields
}

func CreatePostService

func CreatePostService() *PostService

func (*PostService) UpsertPost

func (p *PostService) UpsertPost(postModel *model.Post)

type UserService

type UserService struct {
	// contains filtered or unexported fields
}

func CreateUserService

func CreateUserService() *UserService

func (*UserService) UpdateProfilePic

func (u *UserService) UpdateProfilePic(userUuid uuid.UUID, s3Key string)

func (*UserService) UpsertUser

func (u *UserService) UpsertUser(userModel *model.User)