ctrl

Documentation

Index

• Variables
• type Ctrl
  • func New(episode episode.Repo, cache cache.RedisCache, subject subject.Repo, ...) Ctrl
  • func (ctl Ctrl) CreatePrivateMessage(ctx context.Context, senderID model.UserID, receiverIDs []model.UserID, ...) ([]pm.PrivateMessage, error)
  • func (ctl Ctrl) UpdateEpisodeCollection(ctx context.Context, u auth.Auth, episodeID model.EpisodeID, ...) error
  • func (ctl Ctrl) UpdateEpisodesCollection(ctx context.Context, u auth.Auth, subjectID model.SubjectID, ...) error
  • func (ctl Ctrl) UpdateSubjectCollection(ctx context.Context, u auth.Auth, subjectID model.SubjectID, ...) error
• type UpdateCollectionRequest

Variables

var ErrInvalidInput = errors.New("invalid input")

var ErrPmBlocked = errors.New("have been blocked")

var ErrPmNotAFriend = errors.New("not a friend to some receivers")

var ErrPmNotAllReceiversExist = errors.New("some receivers not exist")

var ErrPmReceiverReject = errors.New("some receivers reject private message")

var Module = fx.Module("controller",
	fx.Provide(New),
)

Types

type Ctrl

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

func New

func New(
	episode episode.Repo,
	cache cache.RedisCache,
	subject subject.Repo,
	subjectCached subject.CachedRepo,
	collection collections.Repo,
	timeline timeline.Service,
	user user.Repo,
	tx dal.Transaction,
	dam dam.Dam,
	privateMessage pm.Repo,
	log *zap.Logger,
) Ctrl

func (Ctrl) CreatePrivateMessage

func (ctl Ctrl) CreatePrivateMessage(
	ctx context.Context,
	senderID model.UserID,
	receiverIDs []model.UserID,
	relatedIDFilter pm.IDFilter,
	title string,
	content string) ([]pm.PrivateMessage, error)

func (Ctrl) UpdateEpisodeCollection

func (ctl Ctrl) UpdateEpisodeCollection(
	ctx context.Context,
	u auth.Auth,
	episodeID model.EpisodeID,
	t collection.EpisodeCollection,
) error

func (Ctrl) UpdateEpisodesCollection

func (ctl Ctrl) UpdateEpisodesCollection(
	ctx context.Context,
	u auth.Auth,
	subjectID model.SubjectID,
	episodeIDs []model.EpisodeID,
	t collection.EpisodeCollection,
) error

func (Ctrl) UpdateSubjectCollection

func (ctl Ctrl) UpdateSubjectCollection(
	ctx context.Context,
	u auth.Auth,
	subjectID model.SubjectID,
	req UpdateCollectionRequest,
	allowCreate bool,
) error

type UpdateCollectionRequest

type UpdateCollectionRequest struct {
	IP  string
	UID model.UserID

	Comment   null.String
	Tags      []string
	VolStatus null.Uint32
	EpStatus  null.Uint32
	Type      null.Null[collection.SubjectCollection]
	Rate      null.Uint8
	Private   null.Bool
}