replicator for community_meetups (#7050)

open-learning-exchange · Jan 7, 2022 · acfa7ce · acfa7ce
1 parent c10e6e0
commit acfa7ce
Show file tree

Hide file tree

Showing 4 changed files with 25 additions and 6 deletions.
diff --git a/couchdb-setup.sh b/couchdb-setup.sh
@@ -156,6 +156,7 @@ DBS=(
   "messages"
   "course_activities"
   "search_activities"
+  "community_meetups"
 )
 
 insert_dbs $DBS

diff --git a/design/security-update/security-update.json b/design/security-update/security-update.json
@@ -284,5 +284,18 @@
         "roles": ["learner"]
       }
     }
+  },
+  {
+    "dbName": "community_meetups",
+    "json": {
+      "admins": {
+        "names": [],
+        "roles": ["manager"]
+      },
+      "members": {
+        "names": [],
+        "roles": []
+      }
+    }
   }
 ]
diff --git a/src/app/configuration/configuration.service.ts b/src/app/configuration/configuration.service.ts
@@ -67,19 +67,23 @@ export class ConfigurationService {
       selector: { 'sendOnAccept': true }
     };
     const userReplicator = {
-      dbSource: '_users',
-      db: 'tablet_users',
+      dbSource: '_users', db: 'tablet_users',
       selector: { 'isUserAdmin': false, 'requestId': { '$exists': false } },
-      continuous: true,
-      type: 'internal'
+      continuous: true, type: 'internal'
+    };
+    const meetupReplicator = {
+      dbSource: 'meetups', db: 'community_meetups',
+      selector: { 'link': { 'teams': { '$eq': `${configuration.code}@${configuration.parentCode}` } } },
+      continuous: true, type: 'internal'
     };
     return forkJoin([
       // create replicator for pulling from parent at first as we do not have session
       this.syncService.sync({ ...replicatorObj, db: 'courses' }, credentials),
       this.syncService.sync({ ...replicatorObj, db: 'resources' }, credentials),
       this.syncService.sync({ ...replicatorObj, db: 'exams' }, credentials),
       this.syncService.sync({ ...replicatorObj, db: 'tags' }, credentials),
-      this.syncService.sync(userReplicator, credentials)
+      this.syncService.sync(userReplicator, credentials),
+      this.syncService.sync(meetupReplicator, credentials)
     ]);
   }
 

diff --git a/src/app/manager-dashboard/sync.directive.ts b/src/app/manager-dashboard/sync.directive.ts
@@ -79,7 +79,8 @@ export class SyncDirective {
     const pushList = [ ...this.pushList(), ...bothList ];
     const pullList = [ ...this.pullList(), ...bothList ];
     const internalList = [
-      { dbSource: '_users', db: 'tablet_users', selector: { 'isUserAdmin': false, 'requestId': { '$exists': false } }, continuous: true }
+      { dbSource: '_users', db: 'tablet_users', selector: { 'isUserAdmin': false, 'requestId': { '$exists': false } }, continuous: true },
+      { dbSource: 'meetups', db: 'community_meetups', selector: { 'link': { 'teams': { '$eq': `${this.planetConfiguration.code}@${this.planetConfiguration.parentCode}` } } }, continuous: true }
     ];
     return pushList.map(mapFunc('push')).concat(pullList.map(mapFunc('pull'))).concat(internalList.map(mapFunc('internal')));
   }