Tag update

backend/core-api/src/commands/migrateContentType.ts

@@ -60,6 +60,9 @@ const command = async () => {
   }
 
   console.log(`Process finished at: ${new Date().toISOString()}`);
+
+  await client.close();
+  process.exit();
 };
 
 command();

backend/core-api/src/commands/migrateTags.ts

@@ -0,0 +1,44 @@
+import * as dotenv from 'dotenv';
+
+dotenv.config();
+
+import { Collection, Db, MongoClient } from 'mongodb';
+
+const { MONGO_URL = 'mongodb://localhost:27017/erxes?directConnection=true' } =
+  process.env;
+
+if (!MONGO_URL) {
+  throw new Error(`Environment variable MONGO_URL not set.`);
+}
+
+const client = new MongoClient(MONGO_URL);
+
+let db: Db;
+let Tags: Collection;
+
+const command = async () => {
+  await client.connect();
+  db = client.db() as Db;
+
+  Tags = db.collection('tags');
+
+  try {
+    await Tags.updateMany(
+      {},
+      {
+        $unset: { scopeBrandIds: '' },
+        $set: { isGroup: false, parentId: '', order: '' }, // flatten parentId: no nested parent tags allowed
+      },
+    );
+  } catch (e) {
+    console.log(`Error occurred: ${e.message}`);
+    await client.close();
+  }
+
+  console.log(`Process finished at: ${new Date().toISOString()}`);
+
+  await client.close();
+  process.exit();
+};
+
+command();

backend/core-api/src/modules/contacts/trpc/customer.ts

@@ -223,5 +223,31 @@ export const customerRouter = t.router({
           data: doc,
         });
       }),
+
+    tag: t.procedure.input(z.any()).mutation(async ({ ctx, input }) => {
+      const { action, _ids, tagIds, targetIds } = input;
+      const { models } = ctx;
+
+      let response = {};
+
+      if (action === 'count') {
+        response = await models.Customers.countDocuments({
+          tagIds: { $in: _ids },
+        });
+      }
+
+      if (action === 'tagObject') {
+        await models.Customers.updateMany(
+          { _id: { $in: targetIds } },
+          { $set: { tagIds } },
+        );
+
+        response = await models.Customers.find({
+          _id: { $in: targetIds },
+        }).lean();
+      }
+
+      return response;
+    }),
   }),
 });

backend/core-api/src/modules/documents/db/definitions/documents.ts

@@ -8,7 +8,7 @@ export const documentSchema = new Schema(
     name: { type: String },
     content: { type: String },
     replacer: { type: String },
-    code: { type: String },
+    code: { type: String, optional: true },
   },
   {
     timestamps: true,

backend/core-api/src/modules/tags/@types/tag.ts

@@ -9,6 +9,7 @@ export interface ITagFilterQueryParams
   type: string;
   tagIds?: string[];
   parentId?: string;
+  isGroup?: boolean;
   ids: string[];
   excludeIds: boolean;
 }

backend/core-api/src/modules/tags/db/definitions/tags.ts

@@ -5,32 +5,20 @@ export const tagSchema = schemaWrapper(
   new Schema(
     {
       _id: mongooseStringRandomId,
-      name: { type: String, label: 'Name' },
-      type: {
-        type: String,
-        label: 'Type',
-        index: true,
-      },
+      name: { type: String, label: 'Name', unique: true },
       colorCode: { type: String, label: 'Color code' },
+      parentId: { type: String, label: 'Parent' },
+      relatedIds: { type: [String], label: 'Children tag ids' },
+      isGroup: { type: Boolean, label: 'Is group', default: false },
+      type: { type: String, label: 'Content type' },
+      description: { type: String, label: 'Description' },
       objectCount: { type: Number, label: 'Object count' },
-      order: { type: String, label: 'Order', index: true },
-      parentId: {
-        type: String,
-        optional: true,
-        index: true,
-        label: 'Parent',
-      },
-      relatedIds: {
-        type: [String],
-        optional: true,
-        label: 'Children tag ids',
-      },
+      order: { type: String, label: 'Order' },
     },
     {
       timestamps: true,
     },
   ),
 );
 
-// for tags query. increases search speed, avoids in-memory sorting
-tagSchema.index({ _id: 1, type: 1, order: 1, name: 1, createdAt: 1 });
+tagSchema.index({ _id: 1, name: 1, parentId: 1, type: 1 });