مونگو

هر رویداد → MongoDB (Insert One)
  - Collection: activity_logs
  - Document:
    {
      "userId": "{{$json.userId}}",
      "action": "{{$json.action}}",
      "details": {{$json.details}},
      "ip": "{{$json.ip}}",
      "userAgent": "{{$json.userAgent}}",
      "timestamp": "{{$now.toISO()}}"
    }

Webhook (Login)
  → MongoDB (Insert One)
    Collection: sessions
    {
      "userId": "{{$json.userId}}",
      "token": "{{$json.token}}",
      "expiresAt": "{{$now.plus({hours: 24}).toISO()}}",
      "device": "{{$json.device}}"
    }

Webhook (Check Session)
  → MongoDB (Find)
    Collection: sessions
    Query: {
      "token": "{{$json.token}}",
      "expiresAt": {"$gt": "{{$now.toISO()}}"}
    }

Webhook (درخواست)
  → MongoDB (Find)
    Collection: cache
    Query: {"key": "{{$json.cacheKey}}"}
  → IF (نتیجه پیدا شد و منقضی نشده)
    → True: برگرداندن از Cache
    → False:
      → HTTP Request (فراخوانی API اصلی)
      → MongoDB (Update One, upsert: true)
        Filter: {"key": "{{$json.cacheKey}}"}
        Update: {
          "$set": {
            "value": {{$json.result}},
            "expiresAt": "{{$now.plus({minutes: 30}).toISO()}}"
          }
        }

Schedule (اول هر ماه) → MongoDB (Aggregate)
  Collection: orders
  Pipeline: [
    {"$match": {"status": "completed"}},
    {"$group": {
      "_id": {"$month": "$createdAt"},
      "totalSales": {"$sum": "$amount"},
      "orderCount": {"$sum": 1},
      "avgOrder": {"$avg": "$amount"}
    }},
    {"$sort": {"_id": -1}},
    {"$limit": 12}
  ]
  → Set (فرمت فارسی)
  → Telegram (ارسال گزارش)

Webhook (جستجو) → MongoDB (Find)
  Collection: products
  Query: {
    "$and": [
      {"name": {"$regex": "{{$json.keyword}}", "$options": "i"}},
      {"price": {"$gte": {{$json.minPrice}}, "$lte": {{$json.maxPrice}}}},
      {"category": "{{$json.category}}"},
      {"inStock": true}
    ]
  }
  Sort: {"price": 1}
  Limit: 20
  → Respond to Webhook

Webhook (نظر جدید) → MongoDB (Insert One)
  Collection: reviews
  {
    "productId": "{{$json.productId}}",
    "userId": "{{$json.userId}}",
    "rating": {{$json.rating}},
    "comment": "{{$json.comment}}",
    "createdAt": "{{$now.toISO()}}"
  }

-- خواندن نظرات یک محصول با آمار:
MongoDB (Aggregate)
  Pipeline: [
    {"$match": {"productId": "product123"}},
    {"$group": {
      "_id": null,
      "avgRating": {"$avg": "$rating"},
      "totalReviews": {"$sum": 1},
      "reviews": {"$push": "$$ROOT"}
    }}
  ]

Webhook (پیام جدید) → MongoDB (Insert One)
  Collection: messages
  {
    "roomId": "{{$json.roomId}}",
    "sender": "{{$json.userId}}",
    "text": "{{$json.message}}",
    "type": "text",
    "read": false,
    "createdAt": "{{$now.toISO()}}"
  }

-- خواندن پیام‌های یک اتاق:
MongoDB (Find)
  Collection: messages
  Query: {"roomId": "{{$json.roomId}}"}
  Sort: {"createdAt": -1}
  Limit: 50

Webhook (بازدید صفحه) → MongoDB (Update One)
  Collection: page_views
  Filter: {"pageId": "{{$json.pageId}}"}
  Update: {
    "$inc": {"views": 1},
    "$set": {"lastViewed": "{{$now.toISO()}}"},
    "$push": {"visitors": {"ip": "{{$json.ip}}", "date": "{{$now.toISO()}}"}}
  }
  Upsert: true

MQTT/Webhook (داده سنسور) → MongoDB (Insert One)
  Collection: sensor_data
  {
    "sensorId": "{{$json.sensorId}}",
    "temperature": {{$json.temp}},
    "humidity": {{$json.humidity}},
    "timestamp": "{{$now.toISO()}}"
  }

Webhook (حذف) → MongoDB (Update One)
  Collection: users
  Filter: {"_id": "{{$json.userId}}"}
  Update: {
    "$set": {
      "deletedAt": "{{$now.toISO()}}",
      "isActive": false
    }
  }

{"age": {"$gt": 18}}           // بزرگتر از
   {"age": {"$gte": 18}}          // بزرگتر مساوی
   {"age": {"$lt": 30}}           // کوچکتر از
   {"price": {"$in": [100, 200]}} // در لیست
   {"status": {"$ne": "deleted"}} // نامساوی
   {"name": {"$regex": "ali", "$options": "i"}} // Regex

{"$set": {"name": "Ali"}}         // تنظیم مقدار
   {"$unset": {"temp": ""}}          // حذف فیلد
   {"$inc": {"views": 1}}            // افزایش
   {"$push": {"tags": "new"}}        // اضافه به آرایه
   {"$pull": {"tags": "old"}}        // حذف از آرایه
   {"$addToSet": {"tags": "unique"}} // اضافه بدون تکرار
   {"$rename": {"old": "new"}}       // تغییر نام فیلد

{"name": 1, "email": 1, "_id": 0}

{"$match": {}}      // فیلتر
   {"$group": {}}      // گروه‌بندی
   {"$sort": {}}       // مرتب‌سازی
   {"$limit": 10}      // محدود کردن
   {"$skip": 20}       // رد کردن
   {"$project": {}}    // انتخاب فیلد
   {"$unwind": "$arr"} // باز کردن آرایه
   {"$lookup": {}}     // JOIN

{
     "$lookup": {
       "from": "customers",
       "localField": "customerId",
       "foreignField": "_id",
       "as": "customer"
     }
   }

// Single field
   db.users.createIndex({"email": 1})

   // Compound
   db.orders.createIndex({"status": 1, "createdAt": -1})

   // TTL (حذف خودکار)
   db.sessions.createIndex({"expiresAt": 1}, {expireAfterSeconds: 0})

   // Text (جستجوی متنی)
   db.articles.createIndex({"title": "text", "content": "text"})

// حذف Sessions بعد از 24 ساعت
   db.sessions.createIndex(
     {"createdAt": 1},
     {expireAfterSeconds: 86400}
   )

// صفحه 3 (هر صفحه 20 رکورد)
   Skip: 40
   Limit: 20
   Sort: {"createdAt": -1}

mongodb://user:pass@host:27017/db?maxPoolSize=50

Schedule (هر شب) → Bash (mongodump)
      → Google Drive (آپلود بک‌آپ)

// ID Document
    {{$json._id}}

    // تبدیل string به ObjectId در کوئری
    {"_id": {"$oid": "{{$json.id}}"}}

// ذخیره تاریخ
    {"createdAt": {"$date": "{{$now.toISO()}}"}}

db.createCollection("orders", {
      validator: {
        $jsonSchema: {
          bsonType: "object",
          required: ["customerId", "amount"],
          properties: {
            amount: {bsonType: "number", minimum: 0}
          }
        }
      }
    })

mongodb://user:pass@host:27017/mydb?authSource=admin

db.getCollectionNames()

db.collection.getIndexes()

db.collection.createIndex({"email": 1})
  db.collection.createIndex({"status": 1, "createdAt": -1})