feat: add reaction

errs/code/scope.go

@@ -14,4 +14,5 @@ const (
 	CloudEPSecKill
 	CloudEPCart
 	CloudEPComment
+	CloudEPReaction
 )

mongo/config.go

@@ -7,7 +7,6 @@ type Conf struct {
 	User                             string
 	Password                         string
 	Host                             string
-	Port                             string
 	Database                         string
 	ReplicaName                      string
 	MaxStaleness                     time.Duration

mongo/doc-db-with-cache.go

@@ -15,8 +15,8 @@ type DocumentDBWithCache struct {
 	Cache cache.Cache
 }
 
-func MustDocumentDBWithCache(conf *Conf, cacheConf cache.CacheConf, dbOpts []mon.Option, cacheOpts []cache.Option) (DocumentDBWithCacheUseCase, error) {
-	documentDB, err := NewDocumentDB(conf, dbOpts...)
+func MustDocumentDBWithCache(conf *Conf, collection string, cacheConf cache.CacheConf, dbOpts []mon.Option, cacheOpts []cache.Option) (DocumentDBWithCacheUseCase, error) {
+	documentDB, err := NewDocumentDB(conf, collection, dbOpts...)
 	if err != nil {
 		return nil, fmt.Errorf("failed to initialize DocumentDB: %w", err)
 	}

mongo/doc-db.go

@@ -20,7 +20,7 @@ type DocumentDB struct {
 	Mon *mon.Model
 }
 
-func NewDocumentDB(config *Conf, opts ...mon.Option) (DocumentDBUseCase, error) {
+func NewDocumentDB(config *Conf, collection string, opts ...mon.Option) (DocumentDBUseCase, error) {
 	authenticationURI := ""
 	if config.User != "" {
 		authenticationURI = fmt.Sprintf(
@@ -34,7 +34,7 @@ func NewDocumentDB(config *Conf, opts ...mon.Option) (DocumentDBUseCase, error)
 		connectionStringTemplate,
 		config.Schema,
 		authenticationURI,
-		fmt.Sprintf("%s:%s", config.Host, config.Port),
+		config.Host,
 	)
 
 	connectUri, _ := url.Parse(connectionURI)
@@ -50,7 +50,7 @@ func NewDocumentDB(config *Conf, opts ...mon.Option) (DocumentDBUseCase, error)
 	opts = append(opts, intOpt)
 
 	logx.Infof("[DocumentDB] Try to connect document db `%s`", printConnectUri)
-	client, err := mon.NewModel(connectionURI, config.Database, config.Database, opts...)
+	client, err := mon.NewModel(connectionURI, config.Database, collection, opts...)
 	if err != nil {
 		return nil, err
 	}

utils/invited_code/const.go

@@ -2,7 +2,7 @@ package invited_code
 
 const (
 	DefaultCodeLen = 8
-	InitAutoId     = 10000000
+	InitAutoID     = 10000000
 )
 
 var ConvertTable = []string{