feat(meetings): new plugin (#338)

erxes · Sep 26, 2023 · 1fe97b1 · 1fe97b1
1 parent 5faaf56
commit 1fe97b1
Show file tree

Hide file tree

Showing 56 changed files with 4,567 additions and 365 deletions.
diff --git a/packages/api-plugin-template.erxes/src/index.ts b/packages/api-plugin-template.erxes/src/index.ts
@@ -224,74 +224,77 @@ async function startServer() {
   const apolloServer = await generateApolloServer(serviceDiscovery);
   await apolloServer.start();
 
-  app.use('/graphql', expressMiddleware(apolloServer, {
-    context: async ({ req, res }) => {
-      let user: any = null;
-
-      if (req.headers.user) {
-        if (Array.isArray(req.headers.user)) {
-          throw new Error(`Multiple user headers`);
+  app.use(
+    '/graphql',
+    expressMiddleware(apolloServer, {
+      context: async ({ req, res }) => {
+        let user: any = null;
+
+        if (req.headers.user) {
+          if (Array.isArray(req.headers.user)) {
+            throw new Error(`Multiple user headers`);
+          }
+          const userJson = Buffer.from(req.headers.user, 'base64').toString(
+            'utf-8'
+          );
+          user = JSON.parse(userJson);
         }
-        const userJson = Buffer.from(req.headers.user, 'base64').toString(
-          'utf-8'
-        );
-        user = JSON.parse(userJson);
-      }
 
-      let context;
-
-      if (USE_BRAND_RESTRICTIONS !== 'true') {
-        context = {
-          brandIdSelector: {},
-          singleBrandIdSelector: {},
-          userBrandIdsSelector: {},
-          docModifier: doc => doc,
-          commonQuerySelector: {},
-          user,
-          res
-        };
-      } else {
-        let scopeBrandIds = JSON.parse(req.cookies.scopeBrandIds || '[]');
-        let brandIds = [];
-        let brandIdSelector = {};
-        let commonQuerySelector = {};
-        let commonQuerySelectorElk;
-        let userBrandIdsSelector = {};
-        let singleBrandIdSelector = {};
-
-        if (user) {
-          brandIds = user.brandIds || [];
-
-          if (scopeBrandIds.length === 0) {
-            scopeBrandIds = brandIds;
+        let context;
+
+        if (USE_BRAND_RESTRICTIONS !== 'true') {
+          context = {
+            brandIdSelector: {},
+            singleBrandIdSelector: {},
+            userBrandIdsSelector: {},
+            docModifier: doc => doc,
+            commonQuerySelector: {},
+            user,
+            res
+          };
+        } else {
+          let scopeBrandIds = JSON.parse(req.cookies.scopeBrandIds || '[]');
+          let brandIds = [];
+          let brandIdSelector = {};
+          let commonQuerySelector = {};
+          let commonQuerySelectorElk;
+          let userBrandIdsSelector = {};
+          let singleBrandIdSelector = {};
+
+          if (user) {
+            brandIds = user.brandIds || [];
+
+            if (scopeBrandIds.length === 0) {
+              scopeBrandIds = brandIds;
+            }
+
+            if (!user.isOwner && scopeBrandIds.length > 0) {
+              brandIdSelector = { _id: { $in: scopeBrandIds } };
+              commonQuerySelector = { scopeBrandIds: { $in: scopeBrandIds } };
+              commonQuerySelectorElk = { terms: { scopeBrandIds } };
+              userBrandIdsSelector = { brandIds: { $in: scopeBrandIds } };
+              singleBrandIdSelector = { brandId: { $in: scopeBrandIds } };
+            }
           }
 
-          if (!user.isOwner && scopeBrandIds.length > 0) {
-            brandIdSelector = { _id: { $in: scopeBrandIds } };
-            commonQuerySelector = { scopeBrandIds: { $in: scopeBrandIds } };
-            commonQuerySelectorElk = { terms: { scopeBrandIds } };
-            userBrandIdsSelector = { brandIds: { $in: scopeBrandIds } };
-            singleBrandIdSelector = { brandId: { $in: scopeBrandIds } };
-          }
+          context = {
+            brandIdSelector,
+            singleBrandIdSelector,
+            docModifier: doc => ({ ...doc, scopeBrandIds }),
+            commonQuerySelector,
+            commonQuerySelectorElk,
+            userBrandIdsSelector,
+            user,
+            res
+          };
         }
 
-        context = {
-          brandIdSelector,
-          singleBrandIdSelector,
-          docModifier: doc => ({ ...doc, scopeBrandIds }),
-          commonQuerySelector,
-          commonQuerySelectorElk,
-          userBrandIdsSelector,
-          user,
-          res
-        };
-      }
-
-      await configs.apolloServerContext(context, req, res);
+        await configs.apolloServerContext(context, req, res);
 
-      return context;
-    }
-  }));
+        return context;
+      }
+    })
+  );
 
   await new Promise<void>(resolve =>
     httpServer.listen({ port: PORT }, resolve)

diff --git a/packages/api-utils/src/random.ts b/packages/api-utils/src/random.ts
@@ -1,4 +1,6 @@
 import { customAlphabet } from 'nanoid';
 
-export const randomAlphanumeric = customAlphabet('abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789');
-export const randomLowercase = customAlphabet('abcdefghijklmnopqrstuvwxyz');
+export const randomAlphanumeric = customAlphabet(
+  'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789'
+);
+export const randomLowercase = customAlphabet('abcdefghijklmnopqrstuvwxyz');
diff --git a/packages/api-utils/src/types.ts b/packages/api-utils/src/types.ts
@@ -162,5 +162,4 @@ export interface IAttachment {
   type: string;
 }
 
-
-// trigger
+// trigger
diff --git a/packages/core/src/apolloClient.ts b/packages/core/src/apolloClient.ts
@@ -38,39 +38,81 @@ export const initApolloServer = async (app, httpServer) => {
       }
     ]),
     // for graceful shutdowns
-    plugins: [ApolloServerPluginDrainHttpServer({ httpServer })],
+    plugins: [ApolloServerPluginDrainHttpServer({ httpServer })]
   });
 
   await apolloServer.start();
 
-  app.use('/graphql', expressMiddleware(apolloServer, {
-    context: async ({ req, res }) => {
-      const subdomain = getSubdomain(req);
-      const models = await generateModels(subdomain);
+  app.use(
+    '/graphql',
+    expressMiddleware(apolloServer, {
+      context: async ({ req, res }) => {
+        const subdomain = getSubdomain(req);
+        const models = await generateModels(subdomain);
 
-      let user: any = null;
+        let user: any = null;
 
-      if (req.headers.user) {
-        const userJson = Buffer.from(req.headers.user, 'base64').toString(
-          'utf-8'
-        );
-        user = JSON.parse(userJson);
-      }
+        if (req.headers.user) {
+          const userJson = Buffer.from(req.headers.user, 'base64').toString(
+            'utf-8'
+          );
+          user = JSON.parse(userJson);
+        }
+
+        const dataLoaders: IDataLoaders = generateAllDataLoaders(models);
+
+        const requestInfo = {
+          secure: req.secure,
+          cookies: req.cookies
+        };
 
-      const dataLoaders: IDataLoaders = generateAllDataLoaders(models);
+        if (USE_BRAND_RESTRICTIONS !== 'true') {
+          return {
+            brandIdSelector: {},
+            singleBrandIdSelector: {},
+            userBrandIdsSelector: {},
+            docModifier: doc => doc,
+            commonQuerySelector: {},
+            user,
+            res,
+            requestInfo,
+            dataLoaders,
+            subdomain,
+            models
+          };
+        }
 
-      const requestInfo = {
-        secure: req.secure,
-        cookies: req.cookies
-      };
+        let scopeBrandIds = JSON.parse(req.cookies.scopeBrandIds || '[]');
+        let brandIds = [];
+        let brandIdSelector = {};
+        let commonQuerySelector = {};
+        let commonQuerySelectorElk;
+        let userBrandIdsSelector = {};
+        let singleBrandIdSelector = {};
+
+        if (user) {
+          brandIds = user.brandIds || [];
+
+          if (scopeBrandIds.length === 0) {
+            scopeBrandIds = brandIds;
+          }
+
+          if (!user.isOwner && scopeBrandIds.length > 0) {
+            brandIdSelector = { _id: { $in: scopeBrandIds } };
+            commonQuerySelector = { scopeBrandIds: { $in: scopeBrandIds } };
+            commonQuerySelectorElk = { terms: { scopeBrandIds } };
+            userBrandIdsSelector = { brandIds: { $in: scopeBrandIds } };
+            singleBrandIdSelector = { brandId: { $in: scopeBrandIds } };
+          }
+        }
 
-      if (USE_BRAND_RESTRICTIONS !== 'true') {
         return {
-          brandIdSelector: {},
-          singleBrandIdSelector: {},
-          userBrandIdsSelector: {},
-          docModifier: doc => doc,
-          commonQuerySelector: {},
+          brandIdSelector,
+          singleBrandIdSelector,
+          docModifier: doc => ({ ...doc, scopeBrandIds }),
+          commonQuerySelector,
+          commonQuerySelectorElk,
+          userBrandIdsSelector,
           user,
           res,
           requestInfo,
@@ -79,47 +121,8 @@ export const initApolloServer = async (app, httpServer) => {
           models
         };
       }
-
-      let scopeBrandIds = JSON.parse(req.cookies.scopeBrandIds || '[]');
-      let brandIds = [];
-      let brandIdSelector = {};
-      let commonQuerySelector = {};
-      let commonQuerySelectorElk;
-      let userBrandIdsSelector = {};
-      let singleBrandIdSelector = {};
-
-      if (user) {
-        brandIds = user.brandIds || [];
-
-        if (scopeBrandIds.length === 0) {
-          scopeBrandIds = brandIds;
-        }
-
-        if (!user.isOwner && scopeBrandIds.length > 0) {
-          brandIdSelector = { _id: { $in: scopeBrandIds } };
-          commonQuerySelector = { scopeBrandIds: { $in: scopeBrandIds } };
-          commonQuerySelectorElk = { terms: { scopeBrandIds } };
-          userBrandIdsSelector = { brandIds: { $in: scopeBrandIds } };
-          singleBrandIdSelector = { brandId: { $in: scopeBrandIds } };
-        }
-      }
-
-      return {
-        brandIdSelector,
-        singleBrandIdSelector,
-        docModifier: doc => ({ ...doc, scopeBrandIds }),
-        commonQuerySelector,
-        commonQuerySelectorElk,
-        userBrandIdsSelector,
-        user,
-        res,
-        requestInfo,
-        dataLoaders,
-        subdomain,
-        models
-      };
-    }
-  }));
+    })
+  );
 
   return apolloServer;
 };

diff --git a/packages/core/src/db/models/utils.ts b/packages/core/src/db/models/utils.ts
@@ -7,7 +7,9 @@ export const getUniqueValue = async (
   defaultValue?: string
 ) => {
   const getRandomValue = (type: string) =>
-    type === 'email' ? faker.internet.email().toLowerCase() : randomAlphanumeric();
+    type === 'email'
+      ? faker.internet.email().toLowerCase()
+      : randomAlphanumeric();
 
   let uniqueValue = defaultValue || getRandomValue(fieldName);
 

diff --git a/packages/gateway/src/apollo-router/index.ts b/packages/gateway/src/apollo-router/index.ts
@@ -106,7 +106,9 @@ const startRouter = async (
 
   const devOptions = ['--dev', '--hot-reload'];
 
-  console.log("-------------------------------routerConfigPath--------------------------------")
+  console.log(
+    '-------------------------------routerConfigPath--------------------------------'
+  );
   console.log([
     ...(NODE_ENV === 'development' ? devOptions : []),
     '--log',
@@ -116,7 +118,9 @@ const startRouter = async (
     `--config`,
     routerConfigPath
   ]);
-  console.log("----------------------------------------------------------------------")
+  console.log(
+    '----------------------------------------------------------------------'
+  );
 
   const routerProcess = spawn(
     routerPath,

diff --git a/packages/gateway/src/subscription/SubscriptionResolver.ts b/packages/gateway/src/subscription/SubscriptionResolver.ts
@@ -268,9 +268,7 @@ export default class SubscriptionResolver {
   }
 
   private async query(graphqlRequest: GraphQLRequest): Promise<FetchResult> {
-    const response = await toPromise(
-      execute(this.apolloLink, graphqlRequest)
-    );
+    const response = await toPromise(execute(this.apolloLink, graphqlRequest));
     return response;
   }
 }
diff --git a/packages/plugin-clientportal-api/src/models/definitions/utils.ts b/packages/plugin-clientportal-api/src/models/definitions/utils.ts
@@ -3,7 +3,7 @@ import { nanoid } from 'nanoid';
 /*
  * Mongoose field options wrapper
  */
-export const field = (options) => {
+export const field = options => {
   const { pkey, type, optional } = options;
 
   if (type === String && !pkey && !optional) {
@@ -19,7 +19,7 @@ export const field = (options) => {
   return options;
 };
 
-export const schemaWrapper = (schema) => {
+export const schemaWrapper = schema => {
   schema.add({ scopeBrandIds: [String] });
 
   return schema;
@@ -33,7 +33,7 @@ const hookList = [
   'updateMany',
   'deleteOne',
   'deleteMany',
-  'findOneAndUpdate',
+  'findOneAndUpdate'
 ];
 
 export const schemaHooksWrapper = (schema, cacheKey: string) => {