wip: sim sanitizer

Author: alextekartik

firestore_sembast/example/example.dart

@@ -0,0 +1,10 @@
+import 'package:tekartik_firebase_firestore_sembast/firestore_sembast.dart';
+import 'package:tekartik_firebase_firestore_test/menu/firebase_client_menu.dart';
+
+Future<void> main(List<String> args) async {
+  var firestore = newFirestoreMemory(); // .debugQuickLoggerWrapper();
+  await mainMenu(args, () {
+    firestoreMainMenu(
+        context: FirestoreMainMenuContext(doc: firestore.doc('test/1')));
+  });
+}

firestore_sim/lib/firestore_sim_server.dart

@@ -0,0 +1,5 @@
+@Deprecated('wip obsolete')
+library;
+
+/// FirestoreSimServer is a class that simulates the Firestore server.
+export 'src/firestore_sim_server.dart' show FirestoreSimServer;

firestore_sim/lib/src/firestore_sim_server.dart

@@ -392,16 +392,17 @@ class FirestireSimPluginClient implements FirebaseSimPluginClient {
 class FirestoreSimServer implements FirebaseSimPlugin {
   final FirestoreService firestoreService;
   final FirebaseSimServer firebaseSimServer;
-  final Firebase firebase;
+  late final Firebase firebase;
   final Map<Firestore, Lock> _locks = <Firestore, Lock>{};
 
   Lock? transactionLock(Firestore firestore) => _locks[firestore];
 
   // App app;
   Firestore? firestore;
 
-  FirestoreSimServer(
-      this.firestoreService, this.firebaseSimServer, this.firebase) {
+  FirestoreSimServer(this.firestoreService, this.firebaseSimServer,
+      [Firebase? firebase]) {
+    this.firebase = firebase ?? firebaseSimServer.firebase!;
     firebaseSimServer.addPlugin(this);
   }
 

firestore_sim/test/firestore_sim_multi_test.dart

@@ -0,0 +1,33 @@
+library;
+
+import 'dart:async';
+
+import 'package:tekartik_firebase_firestore_sim/firestore_sim.dart';
+import 'package:tekartik_firebase_firestore_test/firestore_multi_client_test.dart';
+import 'package:tekartik_firebase_firestore_test/firestore_test.dart';
+import 'package:tekartik_firebase_sim_io/firebase_sim_client_io.dart' as sim;
+import 'package:tekartik_web_socket_io/web_socket_io.dart';
+import 'package:test/test.dart';
+
+import 'test_common.dart';
+
+Future main() async {
+  // debugSimServerMessage = true;
+  skipConcurrentTransactionTests = true;
+  var testContext = await initTestContextSim();
+  var firebase = testContext.firebase;
+  var firebase2 = sim.getFirebaseSim(
+      clientFactory: webSocketChannelClientFactoryMemory,
+      url: testContext.simServer.webSocketChannelServer.url);
+  var app1 = firebase.initializeApp();
+  var app2 = firebase2.initializeApp();
+
+  var firestore1 = firestoreServiceSim.firestore(app1);
+  var firestore2 = firestoreServiceSim.firestore(app2);
+
+  firestoreMulticlientTest(
+      firestore1: firestore1, firestore2: firestore2, docTopPath: 'test/doc');
+  tearDownAll(() async {
+    await close(testContext);
+  });
+}

…tore_sim_io/test/firestore_sim_test.dart …restore_sim/test/firestore_sim_test.dartfirestore_sim_io/test/firestore_sim_test.dart renamed to firestore_sim/test/firestore_sim_test.dart firestore_sim_io/test/firestore_sim_test.dart renamed to firestore_sim/test/firestore_sim_test.dart

@@ -13,7 +13,15 @@ Future main() async {
   skipConcurrentTransactionTests = true;
   var testContext = await initTestContextSim();
   var firebase = testContext.firebase;
-  runFirestoreTests(firebase: firebase, firestoreService: firestoreServiceSim);
+  var app = firebase.initializeApp();
+  runFirestoreAppTests(
+      app: app,
+      firestoreService: firestoreServiceSim,
+      testContext: FirestoreTestContext());
+
+  test('projectId', () {
+    expect(app.options.projectId, 'sim');
+  });
 
   tearDownAll(() async {
     await close(testContext);

firestore_sim/test/test_common.dart

@@ -0,0 +1,30 @@
+import 'dart:async';
+
+import 'package:tekartik_firebase_firestore_sembast/firestore_sembast_io.dart';
+import 'package:tekartik_firebase_firestore_sim/src/firestore_sim_server.dart';
+import 'package:tekartik_firebase_local/firebase_local.dart';
+import 'package:tekartik_firebase_sim/firebase_sim_server.dart';
+import 'package:tekartik_firebase_sim_io/firebase_sim_client_io.dart' as sim;
+import 'package:tekartik_web_socket_io/web_socket_io.dart';
+
+class TestContext {
+  late FirebaseSimServer simServer;
+  late Firebase firebase;
+}
+
+// memory only
+Future<TestContext> initTestContextSim() async {
+  var testContext = TestContext();
+  // The server use firebase io
+  testContext.simServer =
+      await serve(FirebaseLocal(), webSocketChannelFactoryMemory);
+  testContext.firebase = sim.getFirebaseSim(
+      clientFactory: webSocketChannelClientFactoryMemory,
+      url: testContext.simServer.webSocketChannelServer.url);
+  FirestoreSimServer(newFirestoreServiceMemory(), testContext.simServer);
+  return testContext;
+}
+
+Future close(TestContext testContext) async {
+  await testContext.simServer.close();
+}

firestore_sim/tool/travis.dart

@@ -1,6 +1,7 @@
 # tekartik analysis_options extension to pedantic
-include: package:tekartik_lints/strict.yaml
+include: package:tekartik_lints/package.yaml
 
 linter:
   rules:
-    depend_on_referenced_packages: false
+    public_member_api_docs: false
+    # depend_on_referenced_packages: false

firestore_sim_io/analysis_options.yaml

@@ -0,0 +1,20 @@
+import 'package:tekartik_firebase_firestore_sim/firestore_sim.dart';
+import 'package:tekartik_firebase_firestore_test/menu/firebase_client_menu.dart';
+import 'package:tekartik_firebase_sim/firebase_sim.dart';
+import 'package:tekartik_firebase_sim_io/firebase_sim_client_io.dart';
+
+var urlKv = '4338987.url'.kvFromVar(
+    defaultValue: 'ws://localhost:${firebaseSimDefaultPort.toString()}');
+
+int? get urlKvPort => int.tryParse((urlKv.value ?? '').split(':').last);
+Future<void> main(List<String> args) async {
+  var firebase = getFirebaseSim(url: urlKv.value);
+  var app = firebase.initializeApp();
+  var firestore =
+      firestoreServiceSim.firestore(app); // .debugQuickLoggerWrapper();
+  await mainMenu(args, () {
+    firestoreMainMenu(
+        context: FirestoreMainMenuContext(doc: firestore.doc('test/1')));
+    keyValuesMenu('kv', [urlKv]);
+  });
+}

firestore_sim_io/example/example_io_client.dart

@@ -0,0 +1,17 @@
+// ignore_for_file: avoid_print
+
+import 'package:tekartik_firebase_firestore_sembast/firestore_sembast.dart';
+// ignore: deprecated_member_use
+import 'package:tekartik_firebase_firestore_sim/firestore_sim_server.dart';
+import 'package:tekartik_firebase_local/firebase_local.dart';
+import 'package:tekartik_firebase_sim/firebase_sim_server.dart';
+import 'package:tekartik_web_socket_io/web_socket_io.dart';
+
+import 'example_io_client.dart';
+
+Future<void> main(List<String> args) async {
+  var firebaseSimServer =
+      await serve(FirebaseLocal(), webSocketChannelFactoryIo, port: urlKvPort);
+  print('url ${firebaseSimServer.webSocketChannelServer.url}');
+  FirestoreSimServer(firestoreServiceMemory, firebaseSimServer);
+}