package dorm

import (
	"go.mongodb.org/mongo-driver/mongo"
	"go.mongodb.org/mongo-driver/mongo/options"
	"reflect"
)

type MongoSessionDatabaseOptions struct {
	db                 *mongo.Client        // 驱动
	configDatabaseName string               // 库名
	session            mongo.SessionContext // 会话
	dbDatabase         *mongo.Database      // 数据库
}

// Database 选择数据库
func (cs *MongoSessionOptions) Database(name string, opts ...*options.DatabaseOptions) *MongoSessionDatabaseOptions {
	return &MongoSessionDatabaseOptions{
		db:                 cs.db,                         // 驱动
		configDatabaseName: cs.configDatabaseName,         // 库名
		session:            cs.Session,                    // 会话
		dbDatabase:         cs.db.Database(name, opts...), // 数据库
	}
}

// Model 传入模型自动获取库名和表名
// https://studygolang.com/articles/896
// DatabaseName 库名
// CollectionName 集合名
func (cs *MongoSessionOptions) Model(value interface{}) *MongoSessionCollectionOptions {

	var sessionDatabaseOptions *MongoSessionDatabaseOptions
	var sessionCollectionOptions *MongoSessionCollectionOptions

	val := reflect.ValueOf(value)
	if methodValue := val.MethodByName("DatabaseName"); methodValue.IsValid() {
		databaseName := methodValue.Call(nil)[0].String()
		sessionDatabaseOptions = cs.Database(databaseName)
	} else {
		sessionDatabaseOptions = cs.Database(cs.configDatabaseName)
	}

	if methodValue := val.MethodByName("CollectionName"); methodValue.IsValid() {
		collectionName := methodValue.Call(nil)[0].String()
		sessionCollectionOptions = sessionDatabaseOptions.Collection(collectionName)
	} else {
		panic(NoConfigCollectionName)
	}

	return sessionCollectionOptions
}