-
Notifications
You must be signed in to change notification settings - Fork 62
/
domain.go
79 lines (68 loc) · 2.44 KB
/
domain.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
// SPDX-License-Identifier: AGPL-3.0-only
//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU Affero General Public License as published
// by the Free Software Foundation, version 3.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
// See the GNU Affero General Public License for more details.
//
// You should have received a copy of the GNU Affero General Public License
// along with this program. If not, see <https://www.gnu.org/licenses/>
package collections
import (
"context"
"time"
"github.com/bangumi/server/dal/query"
"github.com/bangumi/server/internal/collections/domain/collection"
"github.com/bangumi/server/internal/model"
"github.com/bangumi/server/internal/pkg/null"
)
type Repo interface {
// WithQuery is used to replace repo's query to txn
WithQuery(query *query.Query) Repo
CountSubjectCollections(
ctx context.Context,
userID model.UserID,
subjectType model.SubjectType,
collectionType collection.SubjectCollection,
showPrivate bool,
) (int64, error)
ListSubjectCollection(
ctx context.Context,
userID model.UserID,
subjectType model.SubjectType,
collectionType collection.SubjectCollection,
showPrivate bool,
limit, offset int,
) ([]collection.UserSubjectCollection, error)
GetSubjectCollection(
ctx context.Context, userID model.UserID, subjectID model.SubjectID,
) (collection.UserSubjectCollection, error)
GetSubjectEpisodesCollection(
ctx context.Context, userID model.UserID, subjectID model.SubjectID,
) (collection.UserSubjectEpisodesCollection, error)
UpdateSubjectCollection(
ctx context.Context, userID model.UserID, subjectID model.SubjectID,
at time.Time, ip string,
update func(ctx context.Context, s *collection.Subject) (*collection.Subject, error),
) error
UpdateEpisodeCollection(
ctx context.Context,
userID model.UserID, subjectID model.SubjectID,
episodeIDs []model.EpisodeID, collection collection.EpisodeCollection,
at time.Time,
) (collection.UserSubjectEpisodesCollection, error)
}
type Update struct {
IP string
Comment null.String
Tags []string // nil 表示无数据,[]string{} 表示清空tag
VolStatus null.Uint32
EpStatus null.Uint32
Type null.Null[collection.SubjectCollection]
Rate null.Uint8
Privacy null.Null[collection.CollectPrivacy]
}