package dorm

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

type MongoDatabaseOptions struct {
	dbDatabase *mongo.Database // 数据库
}

// Database 选择数据库
func (c *MongoClient) Database(name string, opts ...*options.DatabaseOptions) *MongoDatabaseOptions {
	return &MongoDatabaseOptions{
		dbDatabase: c.Db.Database(name, opts...),
	}
}

// CreateCollection 创建集合
func (cd *MongoDatabaseOptions) CreateCollection(ctx context.Context, name string, opts ...*options.CreateCollectionOptions) error {
	return cd.dbDatabase.CreateCollection(ctx, name, opts...)
}

// CreateTimeSeriesCollection 创建时间序列集合
func (cd *MongoDatabaseOptions) CreateTimeSeriesCollection(ctx context.Context, name string, timeField string) error {
	return cd.dbDatabase.CreateCollection(ctx, name, options.CreateCollection().SetTimeSeriesOptions(options.TimeSeries().SetTimeField(timeField)))
}

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

	var databaseOptions *MongoDatabaseOptions
	var collectionOptions *MongoCollectionOptions

	val := reflect.ValueOf(value)
	if methodValue := val.MethodByName("DatabaseName"); methodValue.IsValid() {
		databaseName := methodValue.Call(nil)[0].String()
		databaseOptions = c.Database(databaseName)
	} else {
		panic(NoConfigDatabaseName)
	}

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

	return collectionOptions
}