feat: change api framework to angel3.
This commit is contained in:
@@ -0,0 +1,30 @@
|
||||
import 'package:angel3_configuration/angel3_configuration.dart';
|
||||
import 'package:angel3_framework/angel3_framework.dart';
|
||||
import 'package:angel3_jinja/angel3_jinja.dart';
|
||||
import 'package:file/file.dart';
|
||||
import 'plugins/plugins.dart' as plugins;
|
||||
|
||||
/// This is a perfect place to include configuration and load plug-ins.
|
||||
AngelConfigurer configureServer(FileSystem fileSystem) {
|
||||
return (Angel app) async {
|
||||
// Load configuration from the `config/` directory.
|
||||
//
|
||||
// See: https://github.com/angel-dart/configuration
|
||||
await app.configure(configuration(fileSystem));
|
||||
|
||||
// Configure our application to render jinja templates from the `views/` directory.
|
||||
//
|
||||
// See: https://github.com/angel-dart/jinja
|
||||
await app.configure(jinja(path: fileSystem.directory('views').path));
|
||||
|
||||
// Apply another plug-ins, i.e. ones that *you* have written.
|
||||
//
|
||||
// Typically, the plugins in `lib/src/config/plugins/plugins.dart` are plug-ins
|
||||
// that add functionality specific to your application.
|
||||
//
|
||||
// If you write a plug-in that you plan to use again, or are
|
||||
// using one created by the community, include it in
|
||||
// `lib/src/config/config.dart`.
|
||||
await plugins.configureServer(app);
|
||||
};
|
||||
}
|
||||
@@ -0,0 +1,35 @@
|
||||
import 'dart:async';
|
||||
import 'dart:io';
|
||||
import 'package:angel3_framework/angel3_framework.dart';
|
||||
import 'package:angel3_orm/angel3_orm.dart';
|
||||
import 'package:angel3_orm_postgres/angel3_orm_postgres.dart';
|
||||
import 'package:postgres/postgres.dart';
|
||||
|
||||
Future<void> configureServer(Angel app) async {
|
||||
var connection = await connectToPostgres(app.configuration);
|
||||
await connection.open();
|
||||
|
||||
var logger = app.environment.isProduction ? null : app.logger;
|
||||
var executor = PostgreSqlExecutor(connection, logger: logger);
|
||||
|
||||
app
|
||||
..container!.registerSingleton<QueryExecutor>(executor)
|
||||
..shutdownHooks.add((_) => connection.close());
|
||||
}
|
||||
|
||||
Future<PostgreSQLConnection> connectToPostgres(Map configuration) async {
|
||||
var postgresConfig = configuration['postgres'] as Map? ?? {};
|
||||
var connection = PostgreSQLConnection(
|
||||
postgresConfig['host'] as String? ?? 'localhost',
|
||||
postgresConfig['port'] as int? ?? 5432,
|
||||
postgresConfig['database_name'] as String? ??
|
||||
Platform.environment['USER'] ??
|
||||
Platform.environment['USERNAME'] ??
|
||||
'',
|
||||
username: postgresConfig['username'] as String?,
|
||||
password: postgresConfig['password'] as String?,
|
||||
timeZone: postgresConfig['time_zone'] as String? ?? 'UTC',
|
||||
timeoutInSeconds: postgresConfig['timeout_in_seconds'] as int? ?? 30,
|
||||
useSSL: postgresConfig['use_ssl'] as bool? ?? false);
|
||||
return connection;
|
||||
}
|
||||
@@ -0,0 +1,8 @@
|
||||
import 'dart:async';
|
||||
import 'package:angel3_framework/angel3_framework.dart';
|
||||
import 'orm.dart' as orm;
|
||||
|
||||
Future configureServer(Angel app) async {
|
||||
// Include any plugins you have made here.
|
||||
await app.configure(orm.configureServer);
|
||||
}
|
||||
@@ -0,0 +1,8 @@
|
||||
import 'package:angel3_orm/angel3_orm.dart';
|
||||
import 'package:angel3_serialize/angel3_serialize.dart';
|
||||
|
||||
abstract class BaseModel extends Model {
|
||||
@SerializableField(isNullable: true)
|
||||
@Column(type: ColumnType.json)
|
||||
Map<String, dynamic>? get metadata;
|
||||
}
|
||||
@@ -0,0 +1,19 @@
|
||||
import 'package:angel3_migration/angel3_migration.dart';
|
||||
import 'package:angel3_serialize/angel3_serialize.dart';
|
||||
import 'package:angel3_orm/angel3_orm.dart';
|
||||
import 'package:dde_gesture_manager_api/src/models/base_model.dart';
|
||||
import 'package:optional/optional.dart';
|
||||
part 'user.g.dart';
|
||||
|
||||
@serializable
|
||||
@orm
|
||||
abstract class _User extends BaseModel {
|
||||
@SerializableField(isNullable: false)
|
||||
String? get email;
|
||||
|
||||
@SerializableField(isNullable: false)
|
||||
String? get password;
|
||||
|
||||
@SerializableField(isNullable: false)
|
||||
String? get token;
|
||||
}
|
||||
@@ -0,0 +1,369 @@
|
||||
// GENERATED CODE - DO NOT MODIFY BY HAND
|
||||
|
||||
part of 'user.dart';
|
||||
|
||||
// **************************************************************************
|
||||
// MigrationGenerator
|
||||
// **************************************************************************
|
||||
|
||||
class UserMigration extends Migration {
|
||||
@override
|
||||
void up(Schema schema) {
|
||||
schema.create('users', (table) {
|
||||
table.serial('id').primaryKey();
|
||||
table.timeStamp('created_at');
|
||||
table.timeStamp('updated_at');
|
||||
table.declareColumn(
|
||||
'metadata', Column(type: ColumnType('jsonb'), length: 256));
|
||||
table.varChar('email', length: 256);
|
||||
table.varChar('password', length: 256);
|
||||
table.varChar('token', length: 256);
|
||||
});
|
||||
}
|
||||
|
||||
@override
|
||||
void down(Schema schema) {
|
||||
schema.drop('users');
|
||||
}
|
||||
}
|
||||
|
||||
// **************************************************************************
|
||||
// OrmGenerator
|
||||
// **************************************************************************
|
||||
|
||||
class UserQuery extends Query<User, UserQueryWhere> {
|
||||
UserQuery({Query? parent, Set<String>? trampoline}) : super(parent: parent) {
|
||||
trampoline ??= <String>{};
|
||||
trampoline.add(tableName);
|
||||
_where = UserQueryWhere(this);
|
||||
}
|
||||
|
||||
@override
|
||||
final UserQueryValues values = UserQueryValues();
|
||||
|
||||
UserQueryWhere? _where;
|
||||
|
||||
@override
|
||||
Map<String, String> get casts {
|
||||
return {};
|
||||
}
|
||||
|
||||
@override
|
||||
String get tableName {
|
||||
return 'users';
|
||||
}
|
||||
|
||||
@override
|
||||
List<String> get fields {
|
||||
return const [
|
||||
'id',
|
||||
'created_at',
|
||||
'updated_at',
|
||||
'metadata',
|
||||
'email',
|
||||
'password',
|
||||
'token'
|
||||
];
|
||||
}
|
||||
|
||||
@override
|
||||
UserQueryWhere? get where {
|
||||
return _where;
|
||||
}
|
||||
|
||||
@override
|
||||
UserQueryWhere newWhereClause() {
|
||||
return UserQueryWhere(this);
|
||||
}
|
||||
|
||||
static User? parseRow(List row) {
|
||||
if (row.every((x) => x == null)) {
|
||||
return null;
|
||||
}
|
||||
var model = User(
|
||||
id: row[0].toString(),
|
||||
createdAt: (row[1] as DateTime?),
|
||||
updatedAt: (row[2] as DateTime?),
|
||||
metadata: (row[3] as Map<String, dynamic>?),
|
||||
email: (row[4] as String?),
|
||||
password: (row[5] as String?),
|
||||
token: (row[6] as String?));
|
||||
return model;
|
||||
}
|
||||
|
||||
@override
|
||||
Optional<User> deserialize(List row) {
|
||||
return Optional.ofNullable(parseRow(row));
|
||||
}
|
||||
}
|
||||
|
||||
class UserQueryWhere extends QueryWhere {
|
||||
UserQueryWhere(UserQuery query)
|
||||
: id = NumericSqlExpressionBuilder<int>(query, 'id'),
|
||||
createdAt = DateTimeSqlExpressionBuilder(query, 'created_at'),
|
||||
updatedAt = DateTimeSqlExpressionBuilder(query, 'updated_at'),
|
||||
metadata = MapSqlExpressionBuilder(query, 'metadata'),
|
||||
email = StringSqlExpressionBuilder(query, 'email'),
|
||||
password = StringSqlExpressionBuilder(query, 'password'),
|
||||
token = StringSqlExpressionBuilder(query, 'token');
|
||||
|
||||
final NumericSqlExpressionBuilder<int> id;
|
||||
|
||||
final DateTimeSqlExpressionBuilder createdAt;
|
||||
|
||||
final DateTimeSqlExpressionBuilder updatedAt;
|
||||
|
||||
final MapSqlExpressionBuilder metadata;
|
||||
|
||||
final StringSqlExpressionBuilder email;
|
||||
|
||||
final StringSqlExpressionBuilder password;
|
||||
|
||||
final StringSqlExpressionBuilder token;
|
||||
|
||||
@override
|
||||
List<SqlExpressionBuilder> get expressionBuilders {
|
||||
return [id, createdAt, updatedAt, metadata, email, password, token];
|
||||
}
|
||||
}
|
||||
|
||||
class UserQueryValues extends MapQueryValues {
|
||||
@override
|
||||
Map<String, String> get casts {
|
||||
return {};
|
||||
}
|
||||
|
||||
String? get id {
|
||||
return (values['id'] as String?);
|
||||
}
|
||||
|
||||
set id(String? value) => values['id'] = value;
|
||||
DateTime? get createdAt {
|
||||
return (values['created_at'] as DateTime?);
|
||||
}
|
||||
|
||||
set createdAt(DateTime? value) => values['created_at'] = value;
|
||||
DateTime? get updatedAt {
|
||||
return (values['updated_at'] as DateTime?);
|
||||
}
|
||||
|
||||
set updatedAt(DateTime? value) => values['updated_at'] = value;
|
||||
Map<String, dynamic>? get metadata {
|
||||
return (values['metadata'] as Map<String, dynamic>?);
|
||||
}
|
||||
|
||||
set metadata(Map<String, dynamic>? value) => values['metadata'] = value;
|
||||
String? get email {
|
||||
return (values['email'] as String?);
|
||||
}
|
||||
|
||||
set email(String? value) => values['email'] = value;
|
||||
String? get password {
|
||||
return (values['password'] as String?);
|
||||
}
|
||||
|
||||
set password(String? value) => values['password'] = value;
|
||||
String? get token {
|
||||
return (values['token'] as String?);
|
||||
}
|
||||
|
||||
set token(String? value) => values['token'] = value;
|
||||
void copyFrom(User model) {
|
||||
createdAt = model.createdAt;
|
||||
updatedAt = model.updatedAt;
|
||||
metadata = model.metadata;
|
||||
email = model.email;
|
||||
password = model.password;
|
||||
token = model.token;
|
||||
}
|
||||
}
|
||||
|
||||
// **************************************************************************
|
||||
// JsonModelGenerator
|
||||
// **************************************************************************
|
||||
|
||||
@generatedSerializable
|
||||
class User extends _User {
|
||||
User(
|
||||
{this.id,
|
||||
this.createdAt,
|
||||
this.updatedAt,
|
||||
Map<String, dynamic>? metadata,
|
||||
required this.email,
|
||||
required this.password,
|
||||
required this.token})
|
||||
: metadata = Map.unmodifiable(metadata ?? {});
|
||||
|
||||
/// A unique identifier corresponding to this item.
|
||||
@override
|
||||
String? id;
|
||||
|
||||
/// The time at which this item was created.
|
||||
@override
|
||||
DateTime? createdAt;
|
||||
|
||||
/// The last time at which this item was updated.
|
||||
@override
|
||||
DateTime? updatedAt;
|
||||
|
||||
@override
|
||||
Map<String, dynamic>? metadata;
|
||||
|
||||
@override
|
||||
String? email;
|
||||
|
||||
@override
|
||||
String? password;
|
||||
|
||||
@override
|
||||
String? token;
|
||||
|
||||
User copyWith(
|
||||
{String? id,
|
||||
DateTime? createdAt,
|
||||
DateTime? updatedAt,
|
||||
Map<String, dynamic>? metadata,
|
||||
String? email,
|
||||
String? password,
|
||||
String? token}) {
|
||||
return User(
|
||||
id: id ?? this.id,
|
||||
createdAt: createdAt ?? this.createdAt,
|
||||
updatedAt: updatedAt ?? this.updatedAt,
|
||||
metadata: metadata ?? this.metadata,
|
||||
email: email ?? this.email,
|
||||
password: password ?? this.password,
|
||||
token: token ?? this.token);
|
||||
}
|
||||
|
||||
@override
|
||||
bool operator ==(other) {
|
||||
return other is _User &&
|
||||
other.id == id &&
|
||||
other.createdAt == createdAt &&
|
||||
other.updatedAt == updatedAt &&
|
||||
MapEquality<String, dynamic>(
|
||||
keys: DefaultEquality<String>(), values: DefaultEquality())
|
||||
.equals(other.metadata, metadata) &&
|
||||
other.email == email &&
|
||||
other.password == password &&
|
||||
other.token == token;
|
||||
}
|
||||
|
||||
@override
|
||||
int get hashCode {
|
||||
return hashObjects(
|
||||
[id, createdAt, updatedAt, metadata, email, password, token]);
|
||||
}
|
||||
|
||||
@override
|
||||
String toString() {
|
||||
return 'User(id=$id, createdAt=$createdAt, updatedAt=$updatedAt, metadata=$metadata, email=$email, password=$password, token=$token)';
|
||||
}
|
||||
|
||||
Map<String, dynamic> toJson() {
|
||||
return UserSerializer.toMap(this);
|
||||
}
|
||||
}
|
||||
|
||||
// **************************************************************************
|
||||
// SerializerGenerator
|
||||
// **************************************************************************
|
||||
|
||||
const UserSerializer userSerializer = UserSerializer();
|
||||
|
||||
class UserEncoder extends Converter<User, Map> {
|
||||
const UserEncoder();
|
||||
|
||||
@override
|
||||
Map convert(User model) => UserSerializer.toMap(model);
|
||||
}
|
||||
|
||||
class UserDecoder extends Converter<Map, User> {
|
||||
const UserDecoder();
|
||||
|
||||
@override
|
||||
User convert(Map map) => UserSerializer.fromMap(map);
|
||||
}
|
||||
|
||||
class UserSerializer extends Codec<User, Map> {
|
||||
const UserSerializer();
|
||||
|
||||
@override
|
||||
UserEncoder get encoder => const UserEncoder();
|
||||
@override
|
||||
UserDecoder get decoder => const UserDecoder();
|
||||
static User fromMap(Map map) {
|
||||
if (map['email'] == null) {
|
||||
throw FormatException("Missing required field 'email' on User.");
|
||||
}
|
||||
|
||||
if (map['password'] == null) {
|
||||
throw FormatException("Missing required field 'password' on User.");
|
||||
}
|
||||
|
||||
if (map['token'] == null) {
|
||||
throw FormatException("Missing required field 'token' on User.");
|
||||
}
|
||||
|
||||
return User(
|
||||
id: map['id'] as String?,
|
||||
createdAt: map['created_at'] != null
|
||||
? (map['created_at'] is DateTime
|
||||
? (map['created_at'] as DateTime)
|
||||
: DateTime.parse(map['created_at'].toString()))
|
||||
: null,
|
||||
updatedAt: map['updated_at'] != null
|
||||
? (map['updated_at'] is DateTime
|
||||
? (map['updated_at'] as DateTime)
|
||||
: DateTime.parse(map['updated_at'].toString()))
|
||||
: null,
|
||||
metadata: map['metadata'] is Map
|
||||
? (map['metadata'] as Map).cast<String, dynamic>()
|
||||
: {},
|
||||
email: map['email'] as String?,
|
||||
password: map['password'] as String?,
|
||||
token: map['token'] as String?);
|
||||
}
|
||||
|
||||
static Map<String, dynamic> toMap(_User? model) {
|
||||
if (model == null) {
|
||||
return {};
|
||||
}
|
||||
return {
|
||||
'id': model.id,
|
||||
'created_at': model.createdAt?.toIso8601String(),
|
||||
'updated_at': model.updatedAt?.toIso8601String(),
|
||||
'metadata': model.metadata,
|
||||
'email': model.email,
|
||||
'password': model.password,
|
||||
'token': model.token
|
||||
};
|
||||
}
|
||||
}
|
||||
|
||||
abstract class UserFields {
|
||||
static const List<String> allFields = <String>[
|
||||
id,
|
||||
createdAt,
|
||||
updatedAt,
|
||||
metadata,
|
||||
email,
|
||||
password,
|
||||
token
|
||||
];
|
||||
|
||||
static const String id = 'id';
|
||||
|
||||
static const String createdAt = 'created_at';
|
||||
|
||||
static const String updatedAt = 'updated_at';
|
||||
|
||||
static const String metadata = 'metadata';
|
||||
|
||||
static const String email = 'email';
|
||||
|
||||
static const String password = 'password';
|
||||
|
||||
static const String token = 'token';
|
||||
}
|
||||
@@ -0,0 +1,21 @@
|
||||
import 'dart:io';
|
||||
|
||||
import 'package:angel3_framework/angel3_framework.dart';
|
||||
import 'package:angel3_orm/angel3_orm.dart' as orm;
|
||||
|
||||
extension ResponseNoContent on ResponseContext {
|
||||
noContent() {
|
||||
statusCode = HttpStatus.noContent;
|
||||
return close();
|
||||
}
|
||||
}
|
||||
|
||||
extension QueryWhereId on orm.Query {
|
||||
set whereId(int id) {
|
||||
(where as dynamic).id.equals(id);
|
||||
}
|
||||
}
|
||||
|
||||
extension QueryExecutor on RequestContext {
|
||||
orm.QueryExecutor get queryExecutor => container!.make<orm.QueryExecutor>();
|
||||
}
|
||||
@@ -0,0 +1,16 @@
|
||||
import 'dart:async';
|
||||
import 'package:angel3_framework/angel3_framework.dart';
|
||||
import 'package:dde_gesture_manager_api/models.dart';
|
||||
import 'controller_extensions.dart';
|
||||
|
||||
Future configureServer(Angel app) async {
|
||||
app.get(
|
||||
'/user/int:id',
|
||||
(req, res) async {
|
||||
var user = await (UserQuery()..where?.metadata.contains({"uid": req.params[UserFields.id]}))
|
||||
.getOne(req.queryExecutor);
|
||||
|
||||
return res.json(user.value);
|
||||
},
|
||||
);
|
||||
}
|
||||
@@ -0,0 +1,39 @@
|
||||
import 'package:angel3_framework/angel3_framework.dart';
|
||||
import 'package:file/file.dart';
|
||||
import 'controllers/user_controllers.dart' as UserControllers;
|
||||
|
||||
/// Put your app routes here!
|
||||
///
|
||||
/// See the wiki for information about routing, requests, and responses:
|
||||
/// * https://angel3-docs.dukefirehawk.com/guides/basic-routing
|
||||
/// * https://angel3-docs.dukefirehawk.com/guides/requests-and-responses
|
||||
|
||||
AngelConfigurer configureServer(FileSystem fileSystem) {
|
||||
return (Angel app) async {
|
||||
// Typically, you want to mount controllers first, after any global middleware.
|
||||
await app.configure(UserControllers.configureServer);
|
||||
|
||||
// Throw a 404 if no route matched the request.
|
||||
app.fallback((req, res) => throw AngelHttpException.notFound());
|
||||
|
||||
// Set our application up to handle different errors.
|
||||
//
|
||||
// Read the following for documentation:
|
||||
// * https://angel3-docs.dukefirehawk.com/guides/error-handling
|
||||
|
||||
var oldErrorHandler = app.errorHandler;
|
||||
app.errorHandler = (e, req, res) async {
|
||||
if (req.accepts('text/html', strict: true)) {
|
||||
if (e.statusCode == 404 && req.accepts('text/html', strict: true)) {
|
||||
await res.render('error.html', {'message': 'No router exists for ${req.uri}'});
|
||||
} else {
|
||||
return await res.render('error.html', {
|
||||
'message': [e.message, '', e.stackTrace.toString().replaceAll('\n', '<br/>')].join('<br/>')
|
||||
});
|
||||
}
|
||||
} else {
|
||||
return await oldErrorHandler(e, req, res);
|
||||
}
|
||||
};
|
||||
};
|
||||
}
|
||||
Reference in New Issue
Block a user