enh: check topic privilege

c0c98320 · Liu Jicong · 332ecd1d · c0c98320
显示空白变更内容
内联并排

Showing with 6 addition and 0 deletion

source/dnode/mnode/impl/src/mndConsumer.c source/dnode/mnode/impl/src/mndConsumer.c +6 -0

未找到文件。
--- a/source/dnode/mnode/impl/src/mndConsumer.c
+++ b/source/dnode/mnode/impl/src/mndConsumer.c
@@ -555,6 +555,12 @@ static int32_t mndProcessSubscribeReq(SRpcMsg *pMsg) {
    }

    if (mndCheckDbPrivilegeByName(pMnode, pMsg->info.conn.user, MND_OPER_READ_DB, pTopic->db) != 0) {
+      mndReleaseTopic(pMnode, pTopic);
+      goto SUBSCRIBE_OVER;
+    }
+
+    if (mndCheckTopicPrivilege(pMnode, pMsg->info.conn.user, MND_OPER_SUBSCRIBE, pTopic) != 0) {
+      mndReleaseTopic(pMnode, pTopic);
      goto SUBSCRIBE_OVER;
    }