style_mongo 1.0.0+1 style_mongo: ^1.0.0+1 copied to clipboard
MongoDb DataAccess implementation for style_dart.
example/style_mongo_example.dart
import 'package:mongo_dart/mongo_dart.dart';
import 'package:style_dart/style_dart.dart';
import 'package:style_mongo/src/mongo_query.dart';
import 'package:style_mongo/src/style_mongo_base.dart';
/// In this example usage
///
/// Examples for client.
///
/// create:
///
/// ```http request
/// http://localhost/c/users
///
/// {
/// "data" : {
/// "name" : "Mehmet"
/// }
/// }
/// ```
///
/// read:
///
/// ```http request
/// http://localhost/r/users
///
/// {
/// "query" : where.eq("name" ,"Mehmet").map
/// }
/// ```
/// for more example look tests
void main() {
runService(MongoDbExampleServer());
}
class MongoDbExampleServer extends StatelessComponent {
const MongoDbExampleServer({Key? key}) : super(key: key);
@override
Component build(BuildContext context) {
return Server(
dataAccess: DataAccess(MongoDbDataAccessImplementation(
"mongodb://0.0.0.0:27017/demo_col")),
children: [
Route("{type}", child: Route("{collection}", root: MyAccessPoint()))
]);
}
}
///
class MyAccessPoint extends StatelessComponent {
final Map<String, AccessType> _types = {
"r": AccessType.read,
"c": AccessType.create,
"u": AccessType.update,
"d": AccessType.delete,
"rl": AccessType.readMultiple,
"e": AccessType.exists,
"co": AccessType.count,
"a": AccessType.aggregation
};
@override
Component build(BuildContext context) {
return AccessPoint((req, c) {
if (req.body != null && req.body is! JsonBody?) {
print(req.body.runtimeType);
throw BadRequests();
}
var type = _types[req.arguments["type"]];
if (type == null) {
throw BadRequests();
}
var body = (req.body as JsonBody?)?.data;
return AccessEvent(
access: Access(
collection: req.arguments["collection"],
type: type,
data: body?["data"],
pipeline: body?["pipeline"],
query: body["query"] != null
? MongoQuery(SelectorBuilder().raw(body["query"]))
: null),
context: c,
request: req);
});
}
}