# 数据库安全规则

{
  "read": "true",
  "delete": "get(`database.user.${id}`).isManager"
}

db.collection('shop').where(_.or([{_id:1},{_id:2},{_id:3},{_id:4},{_id:5}])).get()

// 集合 test 的安全规则配置限制只能查询 age > 10 的记录
{
  "read": "doc.age > 10"
}

// 符合安全规则
const res = await db.collection('test').where({
  age: _.gt(10)
}).get()

// 不符合安全规则
const res = db.collection('test').where({
  age: _.gt(8)
}).get()

db.collection('test').where({
  publisher: '{openid}'
}).get()

db.collection('todo').where({
  _id: 'x',
  _openid: '{openid}',
})

db.collection('todo').where({
  progress: _.lt(50)
}).get()

db.collection('todo').where({
  _openid: '{openid}',
  progress: _.lt(50)
}).get()

db.collection('todo').where({
  _openid: '{openid}',
  category: 'sport'
}).update({
  progress: _.inc(10)
})

{
  _id: string,
  _openid: string,
  name: string,
}

{
  _id: string,
  owner: string, // 群主 openid
  name: string, // 群名
  members: string[], // 成员 openid 列表
}

{
  _id: string,
  room: string, // 房间 id
  sender: string, // 发送者 openid
  content: string, // 消息内容
  time: Date, // 发送时间
  withdrawn: boolean, // 是否已撤回
}

{
  "read": "doc._openid == auth.openid", // 私有读
  "write": "doc._openid == auth.openid", // 仅能修改自己的信息
}

{
  "read": "auth.openid in get(`database.room.${doc._id}`).members", // 仅群成员可以读群信息
  // 要求管理房间的写操作不能在前端：
  //  - 原子：建群时需保证room集合的members和各个成员的rooms都写入
  //  - 权限：仅群主能修改群信息
  //  - 权限：仅群成员可以拉新成员进群
  //  - 权限：仅群主可以踢人
  "write": false
}

{
  // 仅能读取自己所在房间的聊天消息，且不允许读取已撤回的消息
  "read": "auth.openid in get(`database.room.${doc.room}`).members && doc.withdrawn == false",
  // 只能在云函数写:
  //  - 仅能在自己所在的房间发消息
  //  - 只能修改自己发送的消息
  //  - 不能删除自己发送的消息（只能撤回）
  "create": "auth.openid in get(`database.room.${doc.room}`).members",
  "update": "auth.openid == doc.sender",
  "delete": false
}

wx.cloud.init({
  env: '环境 ID',
})
const db = wx.cloud.database()
const _ = db.command

const watcher = db.collection('message').where({
  room: '房间 id',
  time: _.gt(new Date('2019-09-01 10:00')),
}).watch({
  onChange: snapshot => {
    console.log(`新事件`, snapshot)
  },
  onError: err => {
    console.error(`监听错误`, err)
  }
})

{
  _id: string, // openid
  _openid: string,
  name: string,
  isManager: boolean, // 管理员标记位
}

{
  _id: string,
  publisher: string, // 发布者 openid
  content: string, // 内容
}

{
  _id: string,
  commenter: string, // 评论者 openid
  articleId: string, // 被评论的文章 id
  content: string, // 评论内容
}

{
  "read": true, // 公有读
  "create": "doc.publisher == auth.openid", // 都可以发文章，但对数据一致性校验，要求 publisher 为发布者 openid
  "update": "doc.publisher == auth.openid || get(`database.user.${auth.openid}`).isManager", // 仅发布者或管理员可以更新
  "delete": "doc.publisher == auth.openid || get(`database.user.${auth.openid}`).isManager", // 仅发布者或管理员可以删除
}

{
  "read": true, // 公有读
  "create": "doc.commenter == auth.openid", // 都可以发评论，但对数据一致性校验，要求 publisher 为发布者 openid
  "update": "doc.commenter == auth.openid || get(`database.user.${auth.openid}`).isManager", // 仅发布者或管理员可以更新
  "delete": "doc.commenter == auth.openid || get(`database.user.${auth.openid}`).isManager", // 仅发布者或管理员可以删除
}

wx.cloud.init({
  env: '环境 ID',
})
const db = wx.cloud.database()
const _ = db.command

const result = await db.collection('comment').add({
  data: {
    commenter: '{openid}', // 用 {openid} 变量，后台会自动替换为当前用户 openid
    articleId: '文章 ID',
    content: '评论内容',
  },
})

console.log('创建结果', result)

{
  _id: string,
  name: string, // 商店名
  location: GeoPoint, // 商店地理位置
  owner: string, // 商店拥有者 openid
  managers: string[], // 商店管理员 openid 列表
}

{
  _id: string,
  shopId: string, // 所在商店
  name: string, // 商品名
  price: number, // 价格
  stock: number, // 库存
}

{
  _id: string,
  shopId: string, // 下单的商店
  itemId: string, // 下单的商品
  price: number, // 成交价格
  amount: number, // 成交数量
  status: string, // 状态
  createTime: Date, // 创建时间
  updateTime: Date, // 更新时间
}

{
  "read": true, // 公有读
  "write": false, // 仅云函数端写
}

{
  // 公有读
  "read": true,
  // 仅商店所有者或管理员可写
  "write": "auth.openid == get(`database.shop.${doc.shopId}`).owner || auth.openid in get(`database.shop.${doc.shopId}`).managers",
}

{
  // 仅商店所有者或管理员可读写
  "read": "auth.openid == get(`database.shop.${doc.shopId}`).owner || auth.openid in get(`database.shop.${doc.shopId}`).managers",
  "write": "auth.openid == get(`database.shop.${doc.shopId}`).owner || auth.openid in get(`database.shop.${doc.shopId}`).managers",
  // 仅云函数端可删除订单记录
  "delete": false,
}

wx.cloud.init({
  env: '环境 ID',
})
const db = wx.cloud.database()
const _ = db.command

const watcher = db.collection('order').where({
  shopId: '商店 id',
  createTime: _.gt(new Date()),
}).watch({
  onChange: snapshot => {
    console.log(`新事件`, snapshot)
  },
  onError: err => {
    console.error(`监听错误`, err)
  }
})