auto: autocommit

README.md

@@ -2,13 +2,3 @@
 Telegram client utils for making telegram more fun!
 
 
-### TODO
-- [ ] Clickhouse
-- [ ] Full ru localization
-- [ ] Refactor mongo repository
-- [ ] Save kandinsky images
-- [ ] Precommit hooks
-- [ ] Better golint
-- [ ] Docker-build from github actions
-- [ ] Revork errors to go-fast-errors
-- [ ] Add https://github.com/dominikbraun/graph

VERSION

@@ -1 +1 @@
-v1.11.58
+v1.11.59

core/repository/mongo_repository/member_methods.go

@@ -49,7 +49,40 @@ func (r *Repository) GetUsersInChat(ctx context.Context, chatId int64) (UsersInC
 				"tg_username": "$user.tg_username",
 				"tg_name":     "$user.tg_name",
 				"is_bot":      "$user.is_bot",
-				// "tg_chat_id":  1,
+			},
+		},
+	)
+	if err != nil {
+		return nil, errors.WithStack(err)
+	}
+
+	return usersInChat, nil
+}
+
+func (r *Repository) GetUsersInChatOnlyActive(
+	ctx context.Context,
+	chatId int64,
+) (UsersInChat, error) {
+	usersInChat := make(UsersInChat, 0, 100)
+
+	err := r.memberCollection.SimpleAggregateWithCtx(
+		ctx,
+		&usersInChat,
+		builder.Lookup(r.userCollection.Name(), "tg_user_id", "tg_id", "user"),
+		bson.M{operator.Match: bson.M{"tg_chat_id": chatId}},
+		bson.M{operator.Unwind: "$user"},
+		bson.M{
+			operator.Project: bson.M{
+				"status":      1,
+				"tg_id":       "$user.tg_id",
+				"tg_username": "$user.tg_username",
+				"tg_name":     "$user.tg_name",
+				"is_bot":      "$user.is_bot",
+			},
+		},
+		bson.M{
+			operator.Match: bson.M{
+				"status": bson.M{operator.In: []MemberStatus{Plain, Creator, Admin}},
 			},
 		},
 	)

core/service/analitics/service.go

@@ -183,7 +183,7 @@ func (r *Service) analiseUserChat(
 		return AnaliseReport{}, nil
 	}
 
-	usersInChat, err := r.mongoRepository.GetUsersInChat(ctx, input.TgChatId)
+	usersInChat, err := r.mongoRepository.GetUsersInChatOnlyActive(ctx, input.TgChatId)
 	if err != nil {
 		return AnaliseReport{}, errors.Wrap(
 			err,
@@ -236,7 +236,7 @@ func (r *Service) analiseWholeChat(
 	ctx context.Context,
 	input *AnaliseChatInput,
 ) (AnaliseReport, error) {
-	usersInChat, err := r.mongoRepository.GetUsersInChat(ctx, input.TgChatId)
+	usersInChat, err := r.mongoRepository.GetUsersInChatOnlyActive(ctx, input.TgChatId)
 	if err != nil {
 		return AnaliseReport{}, errors.Wrap(
 			err,

docker-compose.yaml

@@ -9,7 +9,7 @@ services:
       fun_storage__mongo_db_url: "mongodb://mongodb:27017"
       fun_storage__clickhouse_url: "clickhouse:9000"
       fun_ds_supplier_url: "http://ds:8000"
-    image: ghcr.io/teadove/fun-telegram:v1.11.58
+    image: ghcr.io/teadove/fun-telegram:v1.11.59
     volumes:
       - ".mtproto:/.mtproto"
       - ".env:/.env"