Eventstore replicator implemented as a read-model

examples/hacker-news/config.app.js

@@ -24,12 +24,6 @@ const appConfig = {
       resolvers: 'common/read-models/search.resolvers.js',
       connectorName: 'elasticSearch',
     },
-    /*{
-      name: 'Replicator',
-      projection: 'common/read-models/empty.js',
-      resolvers: 'common/read-models/empty.js',
-      connectorName: 'replicator',
-    },*/
   ],
   sagas: [
     {

examples/hacker-news/config.cloud.common.js

@@ -0,0 +1,88 @@
+import { declareRuntimeEnv } from '@resolve-js/scripts'
+
+const cloudCommonConfig = {
+  target: 'cloud',
+  mode: 'production',
+  staticPath: declareRuntimeEnv('RESOLVE_CLOUD_STATIC_URL'),
+  eventstoreAdapter: {
+    module: '@resolve-js/eventstore-postgresql-serverless',
+    options: {
+      awsSecretStoreArn: declareRuntimeEnv('RESOLVE_USER_SECRET_ARN'),
+      dbClusterOrInstanceArn: declareRuntimeEnv(
+        'RESOLVE_EVENT_STORE_CLUSTER_ARN'
+      ),
+      databaseName: declareRuntimeEnv('RESOLVE_EVENT_STORE_DATABASE_NAME'),
+      eventsTableName: 'events',
+      secretsTableName: 'secrets',
+      region: declareRuntimeEnv('AWS_REGION'),
+      snapshotBucketSize: 100,
+    },
+  },
+  readModelConnectors: {
+    default: {
+      module: '@resolve-js/readmodel-postgresql-serverless',
+      options: {
+        dbClusterOrInstanceArn: declareRuntimeEnv(
+          'RESOLVE_READMODEL_CLUSTER_ARN'
+        ),
+        awsSecretStoreArn: declareRuntimeEnv('RESOLVE_USER_SECRET_ARN'),
+        databaseName: declareRuntimeEnv('RESOLVE_READMODEL_DATABASE_NAME'),
+        region: declareRuntimeEnv('AWS_REGION'),
+      },
+    },
+    /*replicator: {
+      module: '@resolve-js/replicator-postgresql-serverless',
+      options: {
+        dbClusterOrInstanceArn: declareRuntimeEnv(
+          'RESOLVE_READMODEL_CLUSTER_ARN'
+        ),
+        awsSecretStoreArn: declareRuntimeEnv('RESOLVE_USER_SECRET_ARN'),
+        databaseName: declareRuntimeEnv('RESOLVE_READMODEL_DATABASE_NAME'),
+        region: declareRuntimeEnv('AWS_REGION'),
+        targetEventStore: {
+          dbClusterOrInstanceArn: declareRuntimeEnv(
+            'RESOLVE_READMODEL_CLUSTER_ARN'
+          ),
+          awsSecretStoreArn: declareRuntimeEnv('RESOLVE_USER_SECRET_ARN'),
+          databaseName: '',
+        },
+      },
+    },*/
+    hackerNews: {
+      module: '@resolve-js/readmodel-postgresql-serverless',
+      options: {
+        dbClusterOrInstanceArn: declareRuntimeEnv(
+          'RESOLVE_READMODEL_CLUSTER_ARN'
+        ),
+        awsSecretStoreArn: declareRuntimeEnv('RESOLVE_USER_SECRET_ARN'),
+        databaseName: declareRuntimeEnv('RESOLVE_READMODEL_DATABASE_NAME'),
+        region: declareRuntimeEnv('AWS_REGION'),
+      },
+    },
+    comments: {
+      module: '@resolve-js/readmodel-postgresql-serverless',
+      options: {
+        dbClusterOrInstanceArn: declareRuntimeEnv(
+          'RESOLVE_READMODEL_CLUSTER_ARN'
+        ),
+        awsSecretStoreArn: declareRuntimeEnv('RESOLVE_USER_SECRET_ARN'),
+        databaseName: declareRuntimeEnv('RESOLVE_READMODEL_DATABASE_NAME'),
+        region: declareRuntimeEnv('AWS_REGION'),
+      },
+    },
+    elasticSearch: {
+      module: 'common/read-models/elastic-search-connector.js',
+      options: {
+        /*
+        node: "<your-cloud-elastic-search-host>:port",
+        auth: {
+          username: 'name',
+          password: 'pass'
+        }
+        */
+      },
+    },
+  },
+}
+
+export default cloudCommonConfig

examples/hacker-news/config.cloud.js

@@ -1,86 +1,22 @@
-import { declareRuntimeEnv } from '@resolve-js/scripts'
+import cloudCommonConfig from './config.cloud.common'
 
 export default {
-  target: 'cloud',
-  mode: 'production',
-  staticPath: declareRuntimeEnv('RESOLVE_CLOUD_STATIC_URL'),
-  eventstoreAdapter: {
-    module: '@resolve-js/eventstore-postgresql-serverless',
-    options: {
-      awsSecretStoreArn: declareRuntimeEnv('RESOLVE_USER_SECRET_ARN'),
-      dbClusterOrInstanceArn: declareRuntimeEnv(
-        'RESOLVE_EVENT_STORE_CLUSTER_ARN'
-      ),
-      databaseName: declareRuntimeEnv('RESOLVE_EVENT_STORE_DATABASE_NAME'),
-      eventsTableName: 'events',
-      secretsTableName: 'secrets',
-      region: declareRuntimeEnv('AWS_REGION'),
-      snapshotBucketSize: 100,
+  ...cloudCommonConfig,
+  /*readModels: [
+    {
+      name: 'Replicator',
+      projection: 'common/read-models/empty.js',
+      resolvers: 'common/read-models/empty.js',
+      connectorName: 'replicator',
     },
-  },
+  ],
   readModelConnectors: {
-    default: {
-      module: '@resolve-js/readmodel-postgresql-serverless',
+    ...cloudCommonConfig.readModelConnectors,
+    replicator: {
+      module: '@resolve-js/replicator-via-api-handler',
       options: {
-        dbClusterOrInstanceArn: declareRuntimeEnv(
-          'RESOLVE_READMODEL_CLUSTER_ARN'
-        ),
-        awsSecretStoreArn: declareRuntimeEnv('RESOLVE_USER_SECRET_ARN'),
-        databaseName: declareRuntimeEnv('RESOLVE_READMODEL_DATABASE_NAME'),
-        region: declareRuntimeEnv('AWS_REGION'),
+        targetApplicationUrl: '...',
       },
     },
-    /*replicator: {
-      module: '@resolve-js/replicator-postgresql-serverless',
-      options: {
-        dbClusterOrInstanceArn: declareRuntimeEnv(
-          'RESOLVE_READMODEL_CLUSTER_ARN'
-        ),
-        awsSecretStoreArn: declareRuntimeEnv('RESOLVE_USER_SECRET_ARN'),
-        databaseName: declareRuntimeEnv('RESOLVE_READMODEL_DATABASE_NAME'),
-        region: declareRuntimeEnv('AWS_REGION'),
-        targetEventStore: {
-          dbClusterOrInstanceArn: declareRuntimeEnv(
-            'RESOLVE_READMODEL_CLUSTER_ARN'
-          ),
-          awsSecretStoreArn: declareRuntimeEnv('RESOLVE_USER_SECRET_ARN'),
-          databaseName: '',
-        },
-      },
-    },*/
-    hackerNews: {
-      module: '@resolve-js/readmodel-postgresql-serverless',
-      options: {
-        dbClusterOrInstanceArn: declareRuntimeEnv(
-          'RESOLVE_READMODEL_CLUSTER_ARN'
-        ),
-        awsSecretStoreArn: declareRuntimeEnv('RESOLVE_USER_SECRET_ARN'),
-        databaseName: declareRuntimeEnv('RESOLVE_READMODEL_DATABASE_NAME'),
-        region: declareRuntimeEnv('AWS_REGION'),
-      },
-    },
-    comments: {
-      module: '@resolve-js/readmodel-postgresql-serverless',
-      options: {
-        dbClusterOrInstanceArn: declareRuntimeEnv(
-          'RESOLVE_READMODEL_CLUSTER_ARN'
-        ),
-        awsSecretStoreArn: declareRuntimeEnv('RESOLVE_USER_SECRET_ARN'),
-        databaseName: declareRuntimeEnv('RESOLVE_READMODEL_DATABASE_NAME'),
-        region: declareRuntimeEnv('AWS_REGION'),
-      },
-    },
-    elasticSearch: {
-      module: 'common/read-models/elastic-search-connector.js',
-      options: {
-        /*
-        node: "<your-cloud-elastic-search-host>:port",
-        auth: {
-          username: 'name',
-          password: 'pass'
-        }
-        */
-      },
-    },
-  },
+  },*/
 }

examples/hacker-news/config.cloud.replica.js

@@ -0,0 +1,6 @@
+import cloudCommonConfig from './config.cloud.common'
+
+export default {
+  ...cloudCommonConfig,
+  distDir: 'dist',
+}

examples/hacker-news/config.dev.common.js

@@ -0,0 +1,42 @@
+const devCommonConfig = {
+  target: 'local',
+  mode: 'development',
+  readModelConnectors: {
+    default: {
+      module: '@resolve-js/readmodel-lite',
+      options: {
+        databaseFile: 'data/read-model-default.db',
+      },
+    },
+    hackerNews: {
+      module: '@resolve-js/readmodel-lite',
+      options: {
+        databaseFile: 'data/read-model-hackerNews.db',
+      },
+    },
+    comments: {
+      module: '@resolve-js/readmodel-lite',
+      options: {
+        databaseFile: 'data/read-model-comments.db',
+      },
+    },
+    elasticSearch: {
+      module: 'common/read-models/elastic-search-connector.js',
+      options: {
+        /*
+        node: "<your-cloud-elastic-search-host>:port",
+        auth: {
+          username: 'name',
+          password: 'pass'
+        }
+        */
+      },
+    },
+  },
+  jwtCookie: {
+    name: 'jwt',
+    maxAge: 31536000000,
+  },
+}
+
+export default devCommonConfig

examples/hacker-news/config.dev.js

@@ -1,53 +1,33 @@
 import { declareRuntimeEnv } from '@resolve-js/scripts'
+import devCommonConfig from './config.dev.common'
 
 const devConfig = {
-  target: 'local',
+  ...devCommonConfig,
   port: declareRuntimeEnv('PORT', '3000'),
-  mode: 'development',
   eventstoreAdapter: {
     module: '@resolve-js/eventstore-lite',
     options: {
       databaseFile: 'data/event-store.db',
-      secretsFile: 'data/secrets.db',
       snapshotBucketSize: 100,
     },
   },
-  readModelConnectors: {
-    default: {
-      module: '@resolve-js/readmodel-lite',
-      options: {
-        databaseFile: 'data/read-model-default.db',
-      },
-    },
-    hackerNews: {
-      module: '@resolve-js/readmodel-lite',
-      options: {
-        databaseFile: 'data/read-model-hackerNews.db',
-      },
+  /*readModels: [
+    {
+      name: 'Replicator',
+      projection: 'common/read-models/empty.js',
+      resolvers: 'common/read-models/empty.js',
+      connectorName: 'replicator',
     },
-    comments: {
-      module: '@resolve-js/readmodel-lite',
-      options: {
-        databaseFile: 'data/read-model-comments.db',
-      },
-    },
-    elasticSearch: {
-      module: 'common/read-models/elastic-search-connector.js',
+  ],
+  readModelConnectors: {
+    ...devCommonConfig.readModelConnectors,
+    replicator: {
+      module: '@resolve-js/replicator-via-api-handler',
       options: {
-        /*
-        node: "<your-cloud-elastic-search-host>:port",
-        auth: {
-          username: 'name',
-          password: 'pass'
-        }
-        */
+        targetApplicationUrl: 'http://localhost:3001',
       },
     },
-  },
-  jwtCookie: {
-    name: 'jwt',
-    maxAge: 31536000000,
-  },
+  },*/
 }
 
 export default devConfig

examples/hacker-news/config.dev.replica.js

@@ -1,10 +1,17 @@
-import devConfig from './config.dev'
+import devCommonConfig from './config.dev.common'
 
 const devReplicaConfig = {
-  ...devConfig,
+  ...devCommonConfig,
   name: 'hacker-news-replica',
   port: '3001',
   distDir: 'dist-replica',
+  eventstoreAdapter: {
+    module: '@resolve-js/eventstore-lite',
+    options: {
+      databaseFile: 'data-replica/event-store.db',
+      snapshotBucketSize: 100,
+    },
+  },
   readModelConnectors: {
     default: {
       module: '@resolve-js/readmodel-lite',

examples/hacker-news/package.json

@@ -6,6 +6,7 @@
   "scripts": {
     "build": "babel-node ./run.js build",
     "cloud": "babel-node ./run.js cloud",
+    "cloud:replica": "babel-node ./run.js cloud:replica",
     "dev": "babel-node ./run.js dev",
     "dev:replica": "babel-node ./run.js dev:replica",
     "export-event-store": "babel-node ./run.js export-event-store",
@@ -31,10 +32,11 @@
     "@resolve-js/module-admin": "0.30.0",
     "@resolve-js/module-auth": "0.30.0",
     "@resolve-js/module-comments": "0.30.0",
+    "@resolve-js/module-replication": "0.30.0",
     "@resolve-js/readmodel-lite": "0.30.0",
     "@resolve-js/readmodel-postgresql-serverless": "0.30.0",
     "@resolve-js/redux": "0.30.0",
-    "@resolve-js/replicator-postgresql-serverless": "0.30.0",
+    "@resolve-js/replicator-via-api-handler": "0.30.0",
     "@resolve-js/scripts": "0.30.0",
     "history": "4.10.1",
     "isomorphic-fetch": "3.0.0",