command

type Aggregate struct {
	Aggregate                bson.RawValue `bson:"aggregate"` // This is either a collection name or a 1 (int) to indicate a pipeline
	Pipeline                 primitive.A   `bson:"pipeline"`
	Cursor                   pipeCmdCursor `bson:"cursor"`
	Explain                  *bool         `bson:"explain,omitempty"`
	AllowDisk                *bool         `bson:"allowDiskUse,omitempty"` // TODO: disallow (or have option for it)
	MaxTimeMS                *int64        `bson:"maxTimeMS,omitempty"`
	BypassDocumentValidation *bool         `bson:"bypassDocumentValidation,omitempty"`
	ReadConcern              *ReadConcern  `bson:"readConcern,omitempty"`
	Collation                *Collation    `bson:"collation,omitempty"`
	Hint                     interface{}   `bson:"hint,omitempty"`
	Comment                  string        `bson:"comment,omitempty"`
	WriteConcern             *WriteConcern `bson:"writeConcern,omitempty"`

	Common `bson:",inline"`
}

type BuildInfo struct {
	V  int `bson:"buildinfo"`
	V2 int `bson:"buildInfo"`

	Common `bson:",inline"`
}

type ClusterTime struct {
	ClusterTime primitive.Timestamp `bson:"clusterTime,omitempty"`
	Signature   bson.Raw            `bson:"signature,omitempty"`
}

type CollStats struct {
	Collection string `bson:"collStats"`
	Scale      *int64 `bson:"scale,omitempty"`
	Verbose    *int64 `bson:"verbose,omitempty"`

	Common `bson:",inline"`
}

type Collation struct {
	Locale          string `bson:"locale,omitempty"`          // The locale
	CaseLevel       bool   `bson:"caseLevel,omitempty"`       // The case level
	CaseFirst       string `bson:"caseFirst,omitempty"`       // The case ordering
	Strength        int    `bson:"strength,omitempty"`        // The number of comparison levels to use
	NumericOrdering bool   `bson:"numericOrdering,omitempty"` // Whether to order numbers based on numerical order and not collation order
	Alternate       string `bson:"alternate,omitempty"`       // Whether spaces and punctuation are considered base characters
	MaxVariable     string `bson:"maxVariable,omitempty"`     // Which characters are affected by alternate: "shifted"
	Normalization   bool   `bson:"normalization,omitempty"`   // Causes text to be normalized into Unicode NFD
	Backwards       bool   `bson:"backwards,omitempty"`       // Causes secondary differences to be considered in reverse order, as it is done in the French language
}

type Command interface {
	GetSession() *Session
	FromBSOND(d bson.D) error
}

type CommandCollection interface {
	Command
	GetCollection() string
}

type CommandDatabase interface {
	Command
	GetDatabase() string
}

type CommandFunc func() Command

type CommandReadPreference interface {
	Command
	GetReadPreference() *ReadPreference
}

type Common struct {
	ReadPreference *ReadPreference `bson:"$readPreference,omitempty"`
	Database       string          `bson:"$db,omitempty"`
	Session        `bson:",inline"`
}

type ConnectionStatus struct {
	ConnectionStatus int   `bson:"connectionStatus"`
	ShowPrivileges   *bool `bson:"showPrivileges,omitempty"`

	Common `bson:",inline"`
}

type Count struct {
	Collection  string       `bson:"count"`
	Query       bson.D       `bson:"query"`
	MaxTimeMS   *int64       `bson:"maxTimeMS,omitempty"`
	Skip        *int64       `bson:"skip,omitempty"`
	Limit       *int64       `bson:"limit,omitempty"`
	Hint        interface{}  `bson:"hint,omitempty"`
	Collation   *Collation   `bson:"collation,omitempty"`
	ReadConcern *ReadConcern `bson:"readConcern,omitempty"`
	Fields      bson.D       `bson:"fields,omitempty"` // Mongo shell sends this for w/e reason, but can't find this in the docs anywhere

	Common `bson:",inline"`
}

type Create struct {
	Collection          string        `bson:"create"`
	Capped              *bool         `bson:"capped,omitempty"`
	AutoIndexID         *bool         `bson:"autoIndexId,omitempty"`
	Size                *int          `bson:"size,omitempty"`
	Max                 *int          `bson:"max,omitempty"`
	StorageEngine       bson.D        `bson:"storageEngine,omitempty"`
	Validator           bson.D        `bson:"validator,omitempty"`
	ValidationLevel     string        `bson:"validationLevel,omitempty"`
	ValidationAction    string        `bson:"validationAction,omitempty"`
	IndexOptionDefaults bson.D        `bson:"indexOptionDefaults,omitempty"`
	ViewOn              string        `bson:"viewOn,omitempty"`
	Pipeline            primitive.A   `bson:"pipeline,omitempty"`
	Collation           *Collation    `bson:"collation,omitempty"`
	WriteConcern        *WriteConcern `bson:"writeConcern,omitempty"`

	Common `bson:",inline"`
}

type CreateIndexes struct {
	Collection   string               `bson:"createIndexes"`
	Indexes      []CreateIndexesIndex `bson:"indexes"`
	WriteConcern *WriteConcern        `bson:"writeConcern,omitempty"`
	CommitQuorum interface{}          `bson:"commitQuorum,omitempty"`

	Common `bson:",inline"`
}

type CreateIndexesIndex struct {
	Key                     bson.D  `bson:"key"`
	Name                    string  `bson:"name"`
	Background              *bool   `bson:"background,omitempty"`
	Unique                  *bool   `bson:"unique,omitempty"`
	PartialFilterExpression bson.D  `bson:"partialFilterExpression,omitempty"`
	Sparse                  *bool   `bson:"sparse,omitempty"`
	ExpireAfterSeconds      *int    `bson:"expireAfterSeconds,omitempty"`
	Hidden                  *bool   `bson:"hidden,omitempty"`
	StorageEngine           bson.D  `bson:"storageEngine,omitempty"`
	Weights                 bson.D  `bson:"weights,omitempty"`
	DefaultLanguage         string  `bson:"default_language,omitempty"`
	LanguageOverride        string  `bson:"language_override,omitempty"`
	TextIndexVersion        int     `bson:"textIndexVersion,omitempty"`
	TwoDSphereIndexVersion  int     `bson:"2dsphereIndexVersion,omitempty"`
	Bits                    int     `bson:"bits,omitempty"`
	Min                     float64 `bson:"min,omitempty"`
	Max                     float64 `bson:"max,omitempty"`
	BucketSize              int     `bson:"bucketSize,omitempty"`
	Collation               bson.D  `bson:"collation,omitempty"`
	WildcardProjection      bson.D  `bson:"wildcardProjection,omitempty"`
}

type CurrentOp struct {
	CurrentOp interface{} `bson:"currentOp"`
	OwnOps    *bool       `bson:"$ownOps,omitempty"`
	All       *bool       `bson:"$all,omitempty"`
	Filter    bson.D      `bson:"filter,omitempty"`

	Common `bson:",inline"`
}

type Cursor struct {
	BatchSize *int32 `bson:"batchSize,omitempty"`
}

type DbStats struct {
	DbStats int `bson:"dbstats"`
	Scale   int `bson:"scale,omitempty"`

	Common `bson:",inline"`
}

type Delete struct {
	Collection   string        `bson:"delete"`
	Deletes      []bson.D      `bson:"deletes"`
	Ordered      *bool         `bson:"ordered,omitempty"`
	WriteConcern *WriteConcern `bson:"writeConcern,omitempty"`
	Hint         interface{}   `bson:"hint,omitempty"`

	Common `bson:",inline"`
}

type DeleteIndexes struct {
	Collection string      `bson:"deleteIndexes"`
	Index      interface{} `bson:"index"`

	Common `bson:",inline"`
}

type Distinct struct {
	Collection  string       `bson:"distinct"`
	Collation   *Collation   `bson:"collation,omitempty"`
	Key         string       `bson:"key"`
	MaxTimeMS   *int64       `bson:"maxTimeMS,omitempty"`
	Query       bson.D       `bson:"query"`
	ReadConcern *ReadConcern `bson:"readConcern,omitempty"`

	Common `bson:",inline"`
}

type Drop struct {
	Collection   string        `bson:"drop"`
	WriteConcern *WriteConcern `bson:"writeConcern,omitempty"`
	Comment      string        `bson:"comment,omitempty"`

	Common `bson:",inline"`
}

type DropDatabase struct {
	DropDatabase int           `bson:"dropDatabase"`
	WriteConcern *WriteConcern `bson:"writeConcern,omitempty"`
	Comment      string        `bson:"comment,omitempty"`

	Common `bson:",inline"`
}

type DropIndexes struct {
	Collection   string        `bson:"dropIndexes"`
	Index        interface{}   `bson:"index"`
	WriteConcern *WriteConcern `bson:"writeConcern,omitempty"`

	Common `bson:",inline"`
}

type EndSessions struct {
	SessionIDs []bsoncore.Document `bson:"endSessions"`

	Common `bson:",inline"`
}

type Explain struct {
	Cmd       Command `bson:"explain"`
	Verbosity string  `bson:"verbosity,omitempty"`
	Comment   string  `bson:"comment,omitempty"`

	Common `bson:",inline"`
}

type Find struct {
	Collection          string      `bson:"find"`
	Filter              bson.D      `bson:"filter,omitempty"`
	Sort                bson.D      `bson:"sort,omitempty"`
	Projection          bson.D      `bson:"projection,omitempty"`
	Min                 bson.D      `bson:"min,omitempty"`
	Max                 bson.D      `bson:"max,omitempty"`
	Skip                *int64      `bson:"skip,omitempty"`
	Limit               *int64      `bson:"limit,omitempty"`
	Tailable            *bool       `bson:"tailable,omitempty"`
	OplogReplay         *bool       `bson:"oplogReplay,omitempty"` // TODO Check
	SingleBatch         *bool       `bson:"singleBatch,omitempty"`
	NoCursorTimeout     *bool       `bson:"noCursorTimeout,omitempty"` // TODO: check
	AllowDiskUse        *bool       `bson:"allowDiskUse,omitempty"`    // TODO: restrict usage of
	AllowPartialResults *bool       `bson:"allowPartialResults,omitempty"`
	AwaitData           *bool       `bson:"awaitData,omitempty"`
	BatchSize           *int32      `bson:"batchSize,omitempty"`
	Collation           *Collation  `bson:"collation,omitempty"`
	Comment             string      `bson:"comment,omitempty"`
	Hint                interface{} `bson:"hint,omitempty"`

	MaxTimeMS    *int64       `bson:"maxTimeMS,omitempty"`
	ShowRecordId *bool        `bson:"showRecordId,omitempty"`
	ReturnKey    *bool        `bson:"returnKey,omitempty"`
	ShowRecordID *bool        `bson:"showRecordID,omitempty"`
	ReadConcern  *ReadConcern `bson:"readConcern,omitempty"`

	Common `bson:",inline"`
}

type FindAndModify struct {
	Collection               string        `bson:"findAndModify"`
	Query                    bson.D        `bson:"query,omitempty"`
	Sort                     bson.D        `bson:"sort,omitempty"`
	Remove                   *bool         `bson:"remove,omitempty"`
	Update                   bson.D        `bson:"update,omitempty"`
	New                      *bool         `bson:"new,omitempty"`
	Fields                   bson.D        `bson:"fields,omitempty"`
	Upsert                   *bool         `bson:"upsert,omitempty"`
	BypassDocumentValidation *bool         `bson:"bypassDocumentValidation,omitempty"`
	WriteConcern             *WriteConcern `bson:"writeConcern,omitempty"`
	Collation                *Collation    `bson:"collation,omitempty"`
	ArrayFilters             interface{}   `bson:"arrayFilters,omitempty"` // TODO

	Common `bson:",inline"`
}

type FindAndModifyLegacy struct {
	Collection               string        `bson:"findandmodify"`
	Query                    bson.D        `bson:"query,omitempty"`
	Sort                     bson.D        `bson:"sort,omitempty"`
	Remove                   *bool         `bson:"remove,omitempty"`
	Update                   interface{}   `bson:"update,omitempty"`
	New                      *bool         `bson:"new,omitempty"`
	Fields                   bson.D        `bson:"fields,omitempty"`
	Upsert                   *bool         `bson:"upsert,omitempty"`
	BypassDocumentValidation *bool         `bson:"bypassDocumentValidation,omitempty"`
	WriteConcern             *WriteConcern `bson:"writeConcern,omitempty"`
	Collation                *Collation    `bson:"collation,omitempty"`
	ArrayFilters             interface{}   `bson:"arrayFilters,omitempty"` // TODO

	Common `bson:",inline"`
}

type GetMore struct {
	CursorID   int64  `bson:"getMore"`
	Collection string `bson:"collection"`
	BatchSize  *int32 `bson:"batchSize,omitempty"`

	Common `bson:",inline"`
}

type GetNonce struct {
	GetNonce int `bson:"getnonce"`

	Common `bson:",inline"`
}

type HedgeOptions struct {
	Enabled bool `bson:"enabled"`
}

type HostInfo struct {
	HostInfo interface{} `bson:"hostInfo"`

	Common `bson:",inline"`
}

type Insert struct {
	Collection string   `bson:"insert"`
	Documents  []bson.D `bson:"documents"`
	Ordered    *bool    `bson:"ordered,omitempty"`
	//selector                 description.ServerSelector
	WriteConcern             *WriteConcern `bson:"writeConcern,omitempty"`
	BypassDocumentValidation *bool         `bson:"bypassDocumentValidation,omitempty"`

	Common `bson:",inline"`
}

type IsDBGrid struct {
	IsDBGrid int `bson:"isdbgrid"`

	Common `bson:",inline"`
}

type IsMaster struct {
	IsMaster       int      `bson:"isMaster"`
	IsMasterLegacy int      `bson:"ismaster"`
	HelloOk        bool     `bson:"helloOk"`
	Client         bson.D   `bson:"client"` // TODO parse out
	Compression    []string `bson:"compression"`
	HostInfo       string   `bson:"hostInfo"`

	Common `bson:",inline"`
}

type KillAllSessions struct {
	KillAllSessions []KillAllSessionsFilter `bson:"killAllSessions"`

	Common `bson:",inline"`
}

type KillAllSessionsFilter struct {
	User string `bson:"user,omitempty"`
	DB   string `bson:"db,omitempty"`
}

type KillCursors struct {
	Collection string      `bson:"killCursors"`
	Cursors    primitive.A `bson:"cursors"`

	Common `bson:",inline"`
}

type KillOp struct {
	KillOp  int    `bson:"killOp"`
	OpID    int    `bson:"op"`
	Comment string `bson:"comment,omitempty"`

	Common `bson:",inline"`
}

type ListCollections struct {
	ListCollections       int    `bson:"listCollections"`
	Filter                bson.D `bson:"filter,omitempty"`
	NameOnly              *bool  `bson:"nameOnly,omitempty"`
	AuthorizedDatabases   *bool  `bson:"authorizedDatabases,omitempty"`
	AuthorizedCollections *bool  `bson:"authorizedCollections,omitempty"`

	MaxTimeMS *int64 `bson:"maxTimeMS,omitempty"`
	Common    `bson:",inline"`
	*Cursor   `bson:"cursor,omitempty"`
}

type ListDatabases struct {
	ListDatabases       int    `bson:"listDatabases"`
	Filter              bson.D `bson:"filter,omitempty"`
	NameOnly            *bool  `bson:"nameOnly,omitempty"`
	AuthorizedDatabases *bool  `bson:"authorizedDatabases,omitempty"`

	Common `bson:",inline"`
}

type ListIndexes struct {
	Collection string `bson:"listIndexes"`

	Common  `bson:",inline"`
	*Cursor `bson:"cursor,omitempty"`
}

type Logout struct {
	Logout int `bson:"logout"`

	Common `bson:",inline"`
}

type MapReduce struct {
	// TODO: split types?
	Collection               string        `bson:"mapReduce,omitempty"`
	CollectionLegacy         string        `bson:"mapreduce,omitempty"`
	Map                      interface{}   `bson:"map"`
	Reduce                   interface{}   `bson:"reduce"`
	Out                      interface{}   `bson:"out"`
	Query                    bson.D        `bson:"query,omitempty"`
	Sort                     bson.D        `bson:"sort,omitempty"`
	Limit                    *int64        `bson:"limit,omitempty"`
	Finalize                 interface{}   `bson:"finalize,omitempty"`
	Scope                    bson.D        `bson:"scope,omitempty"`
	JSMode                   *bool         `bson:"jsMode,omitempty"`
	Verbose                  *bool         `bson:"verbose,omitempty"`
	BypassDocumentValidation *bool         `bson:"bypassDocumentValidation,omitempty"`
	Collation                *Collation    `bson:"collation,omitempty"`
	WriteConcern             *WriteConcern `bson:"writeConcern,omitempty"`
	Comment                  string        `bson:"comment,omitempty"`

	Common `bson:",inline"`
}

type OptionalDoc struct {
	bson.D
}

type Ping struct {
	Ping int `bson:"ping"`

	Common `bson:",inline"`
}

type ReadConcern struct {
	Level string `bson:"level,omitempty"`
}

type ReadPreference struct {
	Mode         string `bson:"mode"`
	TagSet       bson.A `bson:"tagSet,omitempty"`
	HedgeOptions `bson:"hedgeOptions,omitempty"`
}

type SaslStart struct {
	SaslStart     int    `bson:"saslStart"`
	Mechanism     string `bson:"mechanism"`
	Payload       []byte `bson:"payload"`
	AutoAuthorize int    `bson:"autoAuthorize,omitempty"`
	Options       bson.D `bson:"options,omitempty"` // TODO: expand

	Common `bson:",inline"`
}

type ServerStatus struct {
	ServerStatus int `bson:"serverStatus"`

	Common `bson:",inline"`
}

type Session struct {
	LSID        bson.D       `bson:"lsid,omitempty"`
	TxnNumber   *int64       `bson:"txnNumber,omitempty"`
	StmtIDs     []int32      `bson:"stmtIds,omitempty"`
	ClusterTime *ClusterTime `bson:"$clusterTime,omitempty"`
}

type ShardCollection struct {
	Collection string `bson:"shardCollection"`
	Key        bson.D `bson:"key"`
	Unique     *bool  `bson:"unique,omitempty"`

	Common `bson:",inline"`
}

type Update struct {
	Collection               string            `bson:"update"`
	Updates                  []UpdateStatement `bson:"updates"`
	WriteConcern             *WriteConcern     `bson:"writeConcern,omitempty"`
	Ordered                  *bool             `bson:"ordered,omitempty"`
	BypassDocumentValidation *bool             `bson:"bypassDocumentValidation,omitempty"`

	Common `bson:",inline"`
}

type UpdateStatement struct {
	Query        bson.D      `bson:"q"`
	U            bson.D      `bson:"u"`
	Upsert       *bool       `bson:"upsert,omitempty"`
	Multi        *bool       `bson:"multi,omitempty"`
	Collation    *Collation  `bson:"collation,omitempty"`
	ArrayFilters interface{} `bson:"arrayFilters,omitempty"` // TODO
	Hint         interface{} `bson:"hint,omitempty"`
}

type Validate struct {
	Collection string `bson:"validate"`
	Full       *bool  `bson:"full,omitempty"`

	Common `bson:",inline"`
}

type WriteConcern struct {
	W        interface{}   `bson:"w"`
	J        bool          `bson:"j"`
	WTimeout time.Duration `bson:"wtimeout"`
}