diff --git a/.github/workflows/quality_gate.yml b/.github/workflows/quality_gate.yml
index 76d8d9b..bfa589b 100644
--- a/.github/workflows/quality_gate.yml
+++ b/.github/workflows/quality_gate.yml
@@ -40,3 +40,20 @@ jobs:
           echo "const password = '${{ secrets.test_password }}';" >> test/test_config.dart
       - run: dart pub get
       - run: dart run test
+    
+  test-emulator:
+    timeout-minutes: 10
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v3
+      - uses: dart-lang/setup-dart@v1
+      - name: Load test credentials
+        run: |
+          echo "${{ secrets.test_service_account }}" | base64 -d - > test/service-account.json
+          echo "const apiKey = '${{ secrets.test_api_key }}';" > test/test_config.dart
+          echo "const projectId = '${{ secrets.test_project_id }}';" >> test/test_config.dart
+          echo "const email = '${{ secrets.test_email }}';" >> test/test_config.dart
+          echo "const password = '${{ secrets.test_password }}';" >> test/test_config.dart
+      - run: dart pub get
+      - run: curl -sL https://firebase.tools | bash
+      - run: firebase emulators:exec 'test/run_test.sh' --only firestore --project ${{ secrets.test_project_id }}
\ No newline at end of file
diff --git a/test/firestore_emulator.dart b/test/firestore_emulator.dart
new file mode 100644
index 0000000..ab7c614
--- /dev/null
+++ b/test/firestore_emulator.dart
@@ -0,0 +1,266 @@
+import 'dart:convert';
+// import 'dart:io';
+
+import 'package:firedart/firedart.dart';
+import 'package:firedart/firestore/application_default_authenticator.dart';
+import 'package:firedart/firestore/token_authenticator.dart';
+import 'package:test/test.dart';
+
+import 'firebase_auth_test.dart';
+import 'test_config.dart';
+
+Future main() async {
+  group('FirebaseAuth', () {
+    var tokenStore = VolatileStore();
+    var auth = FirebaseAuth(apiKey, tokenStore);
+    final authenticator = TokenAuthenticator.from(auth)?.authenticate;
+    var firestore = Firestore(
+      projectId,
+      authenticator: authenticator,
+      emulator: Emulator('localhost', 8080),
+    );
+
+    setUpAll(() async {
+      await auth.signIn(email, password);
+    });
+
+    runTests(firestore);
+
+    test('Refresh token when expired', () async {
+      tokenStore.expireToken();
+      var map = await firestore.collection('test').get();
+      expect(auth.isSignedIn, true);
+      expect(map, isNot(null));
+    });
+
+    test('Sign out on bad refresh token', () async {
+      tokenStore.setToken('user_id', 'bad_token', 'bad_token', 0);
+      try {
+        await firestore.collection('test').get();
+      } catch (_) {}
+      expect(auth.isSignedIn, false);
+    });
+  });
+
+  group('Custom token', () {
+    var tokenStore = VolatileStore();
+    var auth = FirebaseAuth(apiKey, tokenStore);
+    final authenticator = TokenAuthenticator.from(auth)?.authenticate;
+    var firestore = Firestore(
+      projectId,
+      authenticator: authenticator,
+      emulator: Emulator('localhost', 8080),
+    );
+
+    setUpAll(() async {
+      final token = await createCustomToken();
+      await auth.signInWithCustomToken(token);
+    });
+
+    runTests(firestore);
+  });
+
+  group('ApplicationDefaultAuthenticator', () {
+    // assert(
+    //   Platform.environment.containsKey('GOOGLE_APPLICATION_CREDENTIALS'),
+    //   'GOOGLE_APPLICATION_CREDENTIALS environment variable must be set. '
+    //   'See the docs: https://cloud.google.com/docs/authentication/application-default-credentials#GAC',
+    // );
+
+    final auth = ApplicationDefaultAuthenticator(useEmulator: true);
+    var firestore = Firestore(
+      projectId,
+      authenticator: auth.authenticate,
+      emulator: Emulator('localhost', 8080),
+    );
+
+    runTests(firestore);
+  });
+}
+
+void runTests(Firestore firestore) {
+  test('Create reference', () async {
+    // Ensure document exists
+    var reference = firestore.document('test/reference');
+    await reference.set({'field': 'test'});
+
+    var collectionReference = firestore.reference('test');
+    expect(collectionReference.runtimeType, equals(CollectionReference));
+    var documentReference = firestore.reference('test/types');
+    expect(documentReference.runtimeType, equals(DocumentReference));
+
+    await reference.delete();
+  });
+
+  test('Get collection', () async {
+    var reference = firestore.collection('test');
+    var documents = await reference.get();
+    expect(documents.isNotEmpty, true);
+  });
+
+  test('Limit collection page size', () async {
+    var reference = firestore.collection('test');
+    var documents = await reference.get(pageSize: 1);
+    expect(documents.length, 1);
+    expect(documents.hasNextPage, isTrue);
+  });
+
+  test('Get next collection page', () async {
+    var reference = firestore.collection('test');
+    var documents = await reference.get(pageSize: 1);
+    var first = documents[0];
+    documents = await reference.get(
+        pageSize: 1, nextPageToken: documents.nextPageToken);
+    var second = documents[0];
+    expect(first.id, isNot(second.id));
+  });
+
+  test('Simple query', () async {
+    await firestore.document('test/query').set({'test_field': 'test_value'});
+    var query = await firestore
+        .collection('test')
+        .where('test_field', isEqualTo: 'test_value')
+        .get();
+    expect(query.isNotEmpty, true);
+  });
+
+  test('Timestamp query', () async {
+    await firestore.document('test/query').set({'test_field': DateTime.now()});
+    var query = await firestore
+        .collection('test')
+        .where('test_field', isLessThan: DateTime.now())
+        .get();
+    expect(query.isNotEmpty, true);
+  });
+
+  test('Multiple query parameters', () async {
+    await firestore.document('test/query').set({'test_field': 42});
+    var query = await firestore
+        .collection('test')
+        .where('test_field', isEqualTo: 42, isGreaterThan: 41, isLessThan: 43)
+        .get();
+    expect(query.isNotEmpty, true);
+  });
+
+  test('Add and delete collection document', () async {
+    var reference = firestore.collection('test');
+    var docReference = await reference.add({'field': 'test'});
+    expect(docReference['field'], 'test');
+    var document = reference.document(docReference.id);
+    expect(await document.exists, true);
+    await document.delete();
+    expect(await document.exists, false);
+  });
+
+  test('Add and delete named document', () async {
+    var reference = firestore.document('test/add_remove');
+    await reference.set({'field': 'test'});
+    expect(await reference.exists, true);
+    await reference.delete();
+    expect(await reference.exists, false);
+  });
+
+  test('Path with leading slash', () async {
+    var reference = firestore.document('/test/path');
+    await reference.set({'field': 'test'});
+    expect(await reference.exists, true);
+    await reference.delete();
+    expect(await reference.exists, false);
+  });
+
+  test('Path with trailing slash', () async {
+    var reference = firestore.document('test/path/');
+    await reference.set({'field': 'test'});
+    expect(await reference.exists, true);
+    await reference.delete();
+    expect(await reference.exists, false);
+  });
+
+  test('Path with leading and trailing slashes', () async {
+    var reference = firestore.document('/test/path/');
+    await reference.set({'field': 'test'});
+    expect(await reference.exists, true);
+    await reference.delete();
+    expect(await reference.exists, false);
+  });
+
+  test('Read data from document', () async {
+    var reference = firestore.collection('test').document('read_data');
+    await reference.set({'field': 'test'});
+    var map = await reference.get();
+    expect(map['field'], 'test');
+    await reference.delete();
+  });
+
+  test('Overwrite document', () async {
+    var reference = firestore.collection('test').document('overwrite');
+    await reference.set({'field1': 'test1', 'field2': 'test1'});
+    await reference.set({'field1': 'test2'});
+    var doc = await reference.get();
+    expect(doc['field1'], 'test2');
+    expect(doc['field2'], null);
+    await reference.delete();
+  });
+
+  test('Update document', () async {
+    var reference = firestore.collection('test').document('update');
+    await reference.set({'field1': 'test1', 'field2': 'test1'});
+    await reference.update({'field1': 'test2'});
+    var doc = await reference.get();
+    expect(doc['field1'], 'test2');
+    expect(doc['field2'], 'test1');
+    await reference.delete();
+  });
+
+  // test('Stream document changes', () async {
+  //   var reference = firestore.document('test/subscribe');
+  //
+  //   // Firestore may send empty events on subscription because we're reusing the
+  //   // document path.
+  //   expect(reference.stream.where((doc) => doc != null),
+  //       emits((document) => document['field'] == 'test'));
+  //
+  //   await reference.set({'field': 'test'});
+  //   await reference.delete();
+  // });
+
+  test('Stream collection changes', () async {
+    var reference = firestore.collection('test');
+
+    var document = await reference.add({'field': 'test'});
+    expect(reference.stream,
+        emits((List<Document> documents) => documents.isNotEmpty));
+    await document.reference.delete();
+  });
+
+  test('Document field types', () async {
+    var reference = firestore.collection('test').document('types');
+    var dateTime = DateTime.now();
+    var geoPoint = GeoPoint(38.7223, 9.1393);
+    await reference.set({
+      'null': null,
+      'bool': true,
+      'int': 1,
+      'double': 0.1,
+      'timestamp': dateTime,
+      'bytes': utf8.encode('byte array'),
+      'string': 'text',
+      'reference': reference,
+      'coordinates': geoPoint,
+      'list': [1, 'text'],
+      'map': {'int': 1, 'string': 'text'},
+    });
+    var doc = await reference.get();
+    expect(doc['null'], null);
+    expect(doc['bool'], true);
+    expect(doc['int'], 1);
+    expect(doc['double'], 0.1);
+    expect(doc['timestamp'], dateTime);
+    expect(doc['bytes'], utf8.encode('byte array'));
+    expect(doc['string'], 'text');
+    expect(doc['reference'], reference);
+    expect(doc['coordinates'], geoPoint);
+    expect(doc['list'], [1, 'text']);
+    expect(doc['map'], {'int': 1, 'string': 'text'});
+  });
+}
diff --git a/test/run_test.sh b/test/run_test.sh
new file mode 100755
index 0000000..69ac9b4
--- /dev/null
+++ b/test/run_test.sh
@@ -0,0 +1 @@
+dart test test/firestore_emulator.dart