// Copyright © 2023 OpenIM. All rights reserved. // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package relation //import ( // "context" // // "github.com/OpenIMSDK/tools/errs" // // "github.com/OpenIMSDK/tools/ormutil" // // "gorm.io/gorm" // // "github.com/OpenIMSDK/tools/utils" // // "github.com/openimsdk/open-im-server/v3/pkg/common/db/table/relation" //) // //type BlackGorm struct { // *MetaDB //} // //func NewBlackGorm(db *gorm.DB) relation.BlackModelInterface { // return &BlackGorm{NewMetaDB(db, &relation.BlackModel{})} //} // //func (b *BlackGorm) Create(ctx context.Context, blacks []*relation.BlackModel) (err error) { // return utils.Wrap(b.db(ctx).Create(&blacks).Error, "") //} // //func (b *BlackGorm) Delete(ctx context.Context, blacks []*relation.BlackModel) (err error) { // return utils.Wrap(b.db(ctx).Delete(blacks).Error, "") //} // //func (b *BlackGorm) UpdateByMap( // ctx context.Context, // ownerUserID, blockUserID string, // args map[string]any, //) (err error) { // return utils.Wrap( // b.db(ctx).Where("block_user_id = ? and block_user_id = ?", ownerUserID, blockUserID).Updates(args).Error, // "", // ) //} // //func (b *BlackGorm) Update(ctx context.Context, blacks []*relation.BlackModel) (err error) { // return utils.Wrap(b.db(ctx).Updates(&blacks).Error, "") //} // //func (b *BlackGorm) Find( // ctx context.Context, // blacks []*relation.BlackModel, //) (blackList []*relation.BlackModel, err error) { // var where [][]any // for _, black := range blacks { // where = append(where, []any{black.OwnerUserID, black.BlockUserID}) // } // return blackList, utils.Wrap( // b.db(ctx).Where("(owner_user_id, block_user_id) in ?", where).Find(&blackList).Error, // "", // ) //} // //func (b *BlackGorm) Take(ctx context.Context, ownerUserID, blockUserID string) (black *relation.BlackModel, err error) { // black = &relation.BlackModel{} // return black, utils.Wrap( // b.db(ctx).Where("owner_user_id = ? and block_user_id = ?", ownerUserID, blockUserID).Take(black).Error, // "", // ) //} // //func (b *BlackGorm) FindOwnerBlacks( // ctx context.Context, // ownerUserID string, // pageNumber, showNumber int32, //) (blacks []*relation.BlackModel, total int64, err error) { // err = b.db(ctx).Count(&total).Error // if err != nil { // return nil, 0, utils.Wrap(err, "") // } // totalUint32, blacks, err := ormutil.GormPage[relation.BlackModel]( // b.db(ctx).Where("owner_user_id = ?", ownerUserID), // pageNumber, // showNumber, // ) // total = int64(totalUint32) // return //} // //func (b *BlackGorm) FindBlackUserIDs(ctx context.Context, ownerUserID string) (blackUserIDs []string, err error) { // return blackUserIDs, utils.Wrap( // b.db(ctx).Where("owner_user_id = ?", ownerUserID).Pluck("block_user_id", &blackUserIDs).Error, // "", // ) //} // //func (b *BlackGorm) FindOwnerBlackInfos(ctx context.Context, ownerUserID string, userIDs []string) (blacks []*relation.BlackModel, err error) { // return blacks, errs.Wrap(b.db(ctx).Where("owner_user_id = ? and block_user_id in ?", ownerUserID, userIDs).Find(&blacks).Error) //}