dsl

type BulkCreateDto struct {
	// 集合命名
	Collection string `path:"collection,required" vd:"regexp('^[a-z_]+$');msg:'集合名称必须是小写字母与下划线'"`
	// 批量文档数据
	Data []M `json:"data,required" vd:"len($)>0 && range($,len(#v)>0);msg:'批量文档不能存在空数据'"`
	// Body.data[*] 格式转换
	Format M `json:"format"`
}

type BulkDeleteDto struct {
	// 集合命名
	Collection string `path:"collection,required" vd:"regexp('^[a-z_]+$');msg:'集合名称必须是小写字母与下划线'"`
	// 筛选条件
	Data M `json:"data,required" vd:"len($)>0;msg:'筛选条件不能为空'"`
	// Body.data 格式转换
	Format M `json:"format"`
}

type Controller struct {
	DSLService *Service
}

type CreateDto struct {
	// 集合命名
	Collection string `path:"collection" vd:"regexp('^[a-z_]+$');msg:'集合名称必须是小写字母与下划线'"`
	// 文档数据
	Data M `json:"data,required" vd:"len($)>0;msg:'文档不能为空数据'"`
	// Body.data 格式转换
	Format M `json:"format"`
}

type DSL struct {
	Namespace     string
	Db            *mongo.Database
	DynamicValues *kv.DynamicValues
	Js            nats.JetStreamContext
}

type DeleteDto struct {
	// 集合命名
	Collection string `path:"collection,required" vd:"regexp('^[a-z_]+$');msg:'集合名称必须是小写字母与下划线'"`
	// 文档 ID
	Id string `path:"id,required" vd:"mongoId($);msg:'文档 ID 不规范'"`
}

type FindByIdDto struct {
	// 集合命名
	Collection string `path:"collection,required" vd:"regexp('^[a-z_]+$');msg:'集合名称必须是小写字母与下划线'"`
	// 文档 ID
	Id string `path:"id,required" vd:"mongoId($);msg:'文档 ID 不规范'"`
	// 投影规则
	Keys []string `query:"keys" vd:"range($,regexp('^[a-z_]+$',#v));msg:'投影规则不规范'"`
}

type FindDto struct {
	// 集合命名
	Collection string `path:"collection,required" vd:"regexp('^[a-z_]+$');msg:'集合名称必须是小写字母与下划线'"`
	// 分页大小（默认 100 自定义必须在1~1000之间 ）
	Pagesize int64 `header:"x-pagesize" vd:"$>=0 && $<=1000;msg:'分页数量必须在 1~1000 之间'"`
	// 分页页码
	Page int64 `header:"x-page" vd:"$>=0;msg:'页码必须大于 0'"`
	// 筛选条件
	Filter M `query:"filter"`
	// Query.filter 格式转换
	Format M `query:"format"`
	// 排序规则
	Sort []string `query:"sort" vd:"range($,regexp('^[a-z_]+:(-1|1)$',#v)));msg:'排序规则不规范'"`
	// 投影规则
	Keys []string `query:"keys" vd:"range($,regexp('^[a-z_]+$',#v));msg:'投影规则不规范'"`
}

type FindOneDto struct {
	// 集合命名
	Collection string `path:"collection,required" vd:"regexp('^[a-z_]+$');msg:'集合名称必须是小写字母与下划线'"`
	// 筛选条件
	Filter M `query:"filter,required" vd:"len($)>0;msg:'筛选条件不能为空'"`
	// Query.filter 格式转换
	Format M `query:"format"`
	// 投影规则
	Keys []string `query:"keys" vd:"range($,regexp('^[a-z_]+$',#v));msg:'投影规则不规范'"`
}

type M = map[string]interface{}

type Option func(x *DSL)

type PublishDto struct {
	Event        string      `json:"event"`
	Id           string      `json:"id,omitempty"`
	Filter       M           `json:"filter,omitempty"`
	FilterFormat M           `json:"filter_format,omitempty"`
	Data         interface{} `json:"data,omitempty"`
	DataFormat   M           `json:"data_format,omitempty"`
	Result       interface{} `json:"result"`
}

type ReplaceDto struct {
	// 集合命名
	Collection string `path:"collection,required" vd:"regexp('^[a-z_]+$');msg:'集合名称必须是小写字母与下划线'"`
	// 文档 ID
	Id string `path:"id,required" vd:"mongoId($);msg:'文档 ID 不规范'"`
	// 文档数据
	Data M `json:"data,required" vd:"len($)>0;msg:'文档数据不能为空'"`
	// Body.data 格式转换
	Format M `json:"format"`
}

type Service struct {
	*DSL
}

type SizeDto struct {
	// 集合命名
	Collection string `path:"collection,required" vd:"regexp('^[a-z_]+$');msg:'集合名称必须是小写字母与下划线'"`
	// 筛选条件
	Filter M `query:"filter"`
	// Query.filter 格式转换
	Format M `query:"format"`
}

type SortDto struct {
	// 集合命名
	Collection string `path:"collection,required" vd:"regexp('^[a-z_]+$');msg:'集合名称必须是小写字母与下划线'"`
	// 文档 ID 数组
	Data []primitive.ObjectID `json:"data,required" vd:"len($)>0;msg:'数组必须均为文档 ID'"`
}

type UpdateByIdDto struct {
	// 集合命名
	Collection string `path:"collection,required" vd:"regexp('^[a-z_]+$');msg:'集合名称必须是小写字母与下划线'"`
	// 文档 ID
	Id string `path:"id,required" vd:"mongoId($);msg:'文档 ID 不规范'"`
	// 更新操作
	Data M `json:"data,required" vd:"len($)>0;msg:'更新操作不能为空'"`
	// Body.data 格式转换
	Format M `json:"format"`
}

type UpdateDto struct {
	// 集合命名
	Collection string `path:"collection" vd:"regexp('^[a-z_]+$');msg:'集合名称必须是小写字母与下划线'"`
	// 筛选条件
	Filter M `query:"filter,required" vd:"len($)>0;msg:'筛选条件不能为空'"`
	// Query.filter 格式转换
	FFormat M `query:"format"`
	// 更新操作
	Data M `json:"data,required" vd:"len($)>0;msg:'更新操作不能为空'"`
	// Body.data 格式转换
	DFormat M `json:"format"`
}