1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
#[macro_use]
#[cfg(test)]
extern crate pretty_assertions;
mod macros;
pub mod index;
pub mod operator;
pub mod repository;
pub use index::{sync_indexes, Index, IndexOption, Indexes, SortOrder};
pub use repository::{BulkUpdate, BulkUpdateResult, BulkUpdateUpsertResult, Repository};
pub use mongodb as mongo;
pub use mongodb::bson;
pub use mongodb::bson::{bson, doc};
pub trait Model: serde::ser::Serialize + serde::de::DeserializeOwned + Unpin {
type CollConf: CollectionConfig;
}
pub trait CollectionConfig {
fn collection_name() -> &'static str;
fn collection_options() -> Option<mongodb::options::CollectionOptions> {
None
}
fn indexes() -> index::Indexes {
index::Indexes::default()
}
}
pub trait ToRepository {
fn repository<M: Model>(&self) -> Repository<M>;
fn repository_with_options<M: Model>(
&self,
options: mongodb::options::CollectionOptions,
) -> Repository<M>;
}
impl ToRepository for mongodb::Database {
fn repository<M: Model>(&self) -> Repository<M> {
Repository::new(self.clone())
}
fn repository_with_options<M: Model>(
&self,
options: mongodb::options::CollectionOptions,
) -> Repository<M> {
Repository::new_with_options(self.clone(), options)
}
}
pub mod prelude {
#[doc(no_inline)]
pub use crate::mongo::bson::{
bson, de::Error as BsonDeError, doc, from_bson, oid::ObjectId, ser::Error as BsonSerError,
to_bson, Binary as BsonBinary, Bson, DateTime as BsonDateTime,
Deserializer as BsonDeserializer, Document as BsonDocument,
JavaScriptCodeWithScope as BsonJavaScriptCodeWithScope, Regex as BsonRegex,
Serializer as BsonSerializer, Timestamp as BsonTimestamp,
};
#[doc(no_inline)]
pub use crate::mongo::{
error::{
BulkWriteError as MongoBulkWriteError, BulkWriteFailure as MongoBulkWriteFailure,
CommandError as MongoCommandError, Error as MongoError, ErrorKind as MongoErrorKind,
WriteConcernError as MongoWriteConcernError, WriteError as MongoWriteError,
WriteFailure as MongoWriteFailure,
},
options::{
Acknowledgment as MongoAcknowledgment, AggregateOptions as MongoAggregateOptions,
AuthMechanism as MongoAuthMechanism, ClientOptions as MongoClientOptions,
Collation as MongoCollation, CollectionOptions as MongoCollectionOptions,
CountOptions as MongoCountOptions,
CreateCollectionOptions as MongoCreateCollectionOptions, Credential as MongoCredential,
CursorType as MongoCursorType, DatabaseOptions as MongoDatabaseOptions,
DeleteOptions as MongoDeleteOptions, DistinctOptions as MongoDistinctOptions,
DriverInfo as MongoDriverInfo, DropCollectionOptions as MongoDropCollectionOptions,
DropDatabaseOptions as MongoDropDatabaseOptions,
EstimatedDocumentCountOptions as MongoEstimatedDocumentCountOptions,
FindOneAndDeleteOptions as MongoFindOneAndDeleteOptions,
FindOneAndReplaceOptions as MongoFindOneAndReplaceOptions,
FindOneAndUpdateOptions as MongoFindOneAndUpdateOptions,
FindOneOptions as MongoFindOneOptions, FindOptions as MongoFindOptions,
Hint as MongoHint, InsertManyOptions as MongoInsertManyOptions,
InsertOneOptions as MongoInsertOneOptions,
ListCollectionsOptions as MongoListCollectionsOptions,
ListDatabasesOptions as MongoListDatabasesOptions, Predicate as MongoPredicate,
ReadConcern as MongoReadConcern, ReadConcernLevel as MongoReadConcernLevel,
ReadPreference as MongoReadPreference,
ReadPreferenceOptions as MongoReadPreferenceOptions,
ReplaceOptions as MongoReplaceOptions, ReturnDocument as MongoReturnDocument,
SelectionCriteria as MongoSelectionCriteria, ServerAddress as MongoServerAddress,
TagSet as MongoTagSet, Tls as MongoTls, TlsOptions as MongoTlsOptions,
UpdateModifications as MongoUpdateModifications, UpdateOptions as MongoUpdateOptions,
ValidationAction as MongoValidationAction, ValidationLevel as MongoValidationLevel,
WriteConcern as MongoWriteConcern,
},
results::{
DeleteResult as MongoDeleteResult, InsertManyResult as MongoInsertManyResult,
InsertOneResult as MongoInsertOneResult, UpdateResult as MongoUpdateResult,
},
Client as MongoClient, Collection as MongoCollection, Cursor as MongoCursor,
Database as MongoDatabase,
};
#[doc(no_inline)]
pub use crate::ToRepository;
#[doc(no_inline)]
pub use crate::{
f, field, mongo::Cursor, operator::*, pipeline, sync_indexes, BulkUpdate, BulkUpdateResult,
BulkUpdateUpsertResult, CollectionConfig, Index, IndexOption, Indexes, Model, Repository,
SortOrder,
};
#[doc(no_inline)]
pub use futures_util::future::{BoxFuture, FutureExt};
#[doc(no_inline)]
pub use futures_util::StreamExt;
}