platform/packages/mongo/test/generic_test.dart

import 'package:angel3_container/mirrors.dart';
import 'package:angel3_framework/angel3_framework.dart';
import 'package:angel3_framework/http.dart';
import 'package:angel3_mongo/angel3_mongo.dart';
import 'package:http/http.dart' as http;
import 'package:belatuk_json_serializer/belatuk_json_serializer.dart' as god;
import 'package:mongo_dart/mongo_dart.dart';
import 'package:test/test.dart';

final headers = {
  'accept': 'application/json',
  'content-type': 'application/json'
};

final Map testGreeting = {'to': 'world'};

void wireHooked(HookedService hooked) {
  hooked.afterAll((HookedServiceEvent event) {
    print('Just ${event.eventName}: ${event.result}');
    print('Params: ${event.params}');
  });
}

void main() {
  group('Generic Tests', () {
    Angel app;
    late AngelHttp transport;
    late http.Client client;
    var db = Db('mongodb://localhost:27017/testDB');

    late DbCollection testData;
    String? url;
    late HookedService<String, Map<String, dynamic>, MongoService>
        greetingService;

    setUp(() async {
      app = Angel(reflector: MirrorsReflector());
      transport = AngelHttp(app);
      client = http.Client();
      await db.open();
      await db.authenticate("root", "Qwerty", authDb: "admin");

      testData = db.collection('testData');
      // Delete anything before we start
      await testData.remove(<String, dynamic>{});

      var service = MongoService(testData);
      greetingService = HookedService(service);
      wireHooked(greetingService);

      app.use('/api', greetingService as Service);

      await transport.startServer('127.0.0.1', 0);
      url = transport.uri.toString();
    });

    tearDown(() async {
      // Delete anything left over
      await testData.remove(<String, dynamic>{});
      await db.close();
      await transport.close();
    });

    test('query fields mapped to filters', () async {
      await greetingService.create({'foo': 'bar'});
      expect(
        await greetingService.index({
          'query': {'foo': 'not bar'}
        }),
        isEmpty,
      );
      expect(
        await greetingService.index(),
        isNotEmpty,
      );
    });

    test('insert items', () async {
      var response = await client.post(Uri.parse('$url/api'),
          body: god.serialize(testGreeting), headers: headers);
      expect(response.statusCode, isIn([200, 201]));

      response = await client.get(Uri.parse('$url/api'));
      expect(response.statusCode, isIn([200, 201]));
      var users = god.deserialize(response.body,
          outputType: <Map>[].runtimeType) as List<Map>;
      expect(users.length, equals(1));
    });

    test('read item', () async {
      var response = await client.post(Uri.parse('$url/api'),
          body: god.serialize(testGreeting), headers: headers);
      expect(response.statusCode, isIn([200, 201]));
      var created = god.deserialize(response.body) as Map;

      response = await client.get(Uri.parse("$url/api/${created['id']}"));
      expect(response.statusCode, isIn([200, 201]));
      var read = god.deserialize(response.body) as Map;
      expect(read['id'], equals(created['id']));
      expect(read['to'], equals('world'));
      //expect(read['createdAt'], isNot(null));
    });

    test('findOne', () async {
      var response = await client.post(Uri.parse('$url/api'),
          body: god.serialize(testGreeting), headers: headers);
      expect(response.statusCode, isIn([200, 201]));
      var created = god.deserialize(response.body) as Map;

      var id = ObjectId.fromHexString(created['id'] as String);
      var read = await greetingService.findOne({'query': where.id(id)});
      expect(read['id'], equals(created['id']));
      expect(read['to'], equals('world'));
      //expect(read['createdAt'], isNot(null));
    });

    test('readMany', () async {
      var response = await client.post(Uri.parse('$url/api'),
          body: god.serialize(testGreeting), headers: headers);
      expect(response.statusCode, isIn([200, 201]));
      var created = god.deserialize(response.body) as Map;

      var id = ObjectId.fromHexString(created['id'] as String);
      var read = await greetingService.readMany([id.oid]);
      expect(read, [created]);
      //expect(read['createdAt'], isNot(null));
    });

    test('modify item', () async {
      var response = await client.post(Uri.parse('$url/api'),
          body: god.serialize(testGreeting), headers: headers);
      expect(response.statusCode, isIn([200, 201]));
      var createdDoc = god.deserialize(response.body) as Map;

      response = await client.patch(Uri.parse("$url/api/${createdDoc['id']}"),
          body: god.serialize({'to': 'Mom'}), headers: headers);
      var modifiedDoc = god.deserialize(response.body) as Map;
      expect(response.statusCode, isIn([200, 201]));
      expect(modifiedDoc['id'], equals(createdDoc['id']));
      expect(modifiedDoc['to'], equals('Mom'));
      expect(modifiedDoc['updatedAt'], isNot(null));
    });

    test('update item', () async {
      var response = await client.post(Uri.parse('$url/api'),
          body: god.serialize(testGreeting), headers: headers);
      expect(response.statusCode, isIn([200, 201]));
      var createdDoc = god.deserialize(response.body) as Map;

      response = await client.post(Uri.parse("$url/api/${createdDoc['id']}"),
          body: god.serialize({'to': 'Updated'}), headers: headers);
      var modifiedDoc = god.deserialize(response.body) as Map;
      expect(response.statusCode, isIn([200, 201]));
      expect(modifiedDoc['id'], equals(createdDoc['id']));
      expect(modifiedDoc['to'], equals('Updated'));
      expect(modifiedDoc['updatedAt'], isNot(null));
    });

    test('remove item', () async {
      var response = await client.post(Uri.parse('$url/api'),
          body: god.serialize(testGreeting), headers: headers);
      var created = god.deserialize(response.body) as Map;

      var lastCount = (await greetingService.index()).length;

      await client.delete(Uri.parse("$url/api/${created['id']}"));
      expect((await greetingService.index()).length, equals(lastCount - 1));
    });

    test('cannot remove all unless explicitly set', () async {
      var response = await client.delete(Uri.parse('$url/api/null'));
      expect(response.statusCode, 403);
    });

    test('\$sort and query parameters', () async {
      // Search by where.eq
      Map world = await greetingService.create({'to': 'world'});
      await greetingService.create({'to': 'Mom'});
      await greetingService.create({'to': 'Updated'});

      var response = await client.get(Uri.parse('$url/api?to=world'));
      print(response.body);
      var queried = god.deserialize(response.body,
          outputType: <Map>[].runtimeType) as List<Map>;
      expect(queried.length, equals(1));
      expect(queried[0].keys.length, equals(2));
      expect(queried[0]['id'], equals(world['id']));
      expect(queried[0]['to'], equals(world['to']));
      //expect(queried[0]["createdAt"], equals(world["createdAt"]));

      /*response = await client.get(Uri.parse("$url/api?\$sort.createdAt=-1"));
      print(response.body);
      queried = god.deserialize(response.body);
      expect(queried[0]["id"], equals(Updated["id"]));
      expect(queried[1]["id"], equals(Mom["id"]));
      expect(queried[2]["id"], equals(world["id"]));*/

      queried = await greetingService.index({
        '\$query': {
          '_id': where.id(ObjectId.fromHexString(world['id'] as String))
        }
      });
      print(queried);
      expect(queried.length, equals(1));
      expect(queried[0], equals(world));
    });
  });
}