package mongo

import (
	"context"
	"time"
)

// 文档创建，返回InsertedID
func DocumentCreate(colName string, obj interface{}) (interface{}, error) {
	client, err := New()
	if err != nil {
		return nil, err
	}
	ctx, cancel := context.WithTimeout(context.Background(), time.Duration(config.Timeout)*time.Second)
	defer cancel()
	defer client.Disconnect(ctx)
	col, err := Collection(client, colName)
	if err != nil {
		return nil, err
	}

	ret, err := col.InsertOne(ctx, obj)
	if err != nil {
		return nil, err
	}
	return ret.InsertedID, nil
}