Added some common interfaces for compatibility

Author: shuwenwei

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/CnToDnAsyncRequestType.java

@@ -125,5 +125,6 @@ public enum CnToDnAsyncRequestType {
   DETECT_TREE_DEVICE_VIEW_FIELD_TYPE,
 
   // audit log and event write-back
-  INSERT_RECORD
+  INSERT_RECORD,
+  ENABLE_SEPARATION_OF_ADMIN_POWERS,
 }

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java

@@ -369,7 +369,7 @@ public ConfigManager() throws IOException {
     NodeInfo nodeInfo = new NodeInfo();
     ClusterSchemaInfo clusterSchemaInfo = new ClusterSchemaInfo();
     PartitionInfo partitionInfo = new PartitionInfo();
-    AuthorInfo authorInfo = new AuthorInfo();
+    AuthorInfo authorInfo = createAuthorInfo();
     ProcedureInfo procedureInfo = new ProcedureInfo(this);
     UDFInfo udfInfo = new UDFInfo();
     TriggerInfo triggerInfo = new TriggerInfo();
@@ -409,8 +409,8 @@ public ConfigManager() throws IOException {
             new ClusterSchemaQuotaStatistics(
                 COMMON_CONF.getSeriesLimitThreshold(), COMMON_CONF.getDeviceLimitThreshold()));
     this.partitionManager = new PartitionManager(this, partitionInfo);
-    this.permissionManager = new PermissionManager(this, authorInfo);
-    this.procedureManager = new ProcedureManager(this, procedureInfo);
+    this.permissionManager = createPermissionManager(authorInfo);
+    this.procedureManager = createProcedureManager(procedureInfo);
     this.udfManager = new UDFManager(this, udfInfo);
     this.triggerManager = new TriggerManager(this, triggerInfo);
     this.cqManager = new CQManager(this);
@@ -435,6 +435,18 @@ public void initConsensusManager() throws IOException {
     this.consensusManager.get().start();
   }
 
+  protected PermissionManager createPermissionManager(AuthorInfo authorInfo) {
+    return new PermissionManager(this, authorInfo);
+  }
+
+  protected ProcedureManager createProcedureManager(ProcedureInfo procedureInfo) {
+    return new ProcedureManager(this, procedureInfo);
+  }
+
+  protected AuthorInfo createAuthorInfo() {
+    return new AuthorInfo();
+  }
+
   protected void setNodeManager(NodeInfo nodeInfo) {
     this.nodeManager = new NodeManager(this, nodeInfo);
   }

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/PermissionManager.java

@@ -44,8 +44,8 @@ public class PermissionManager {
 
   private static final Logger LOGGER = LoggerFactory.getLogger(PermissionManager.class);
 
-  private final ConfigManager configManager;
-  private final AuthorInfo authorInfo;
+  protected final ConfigManager configManager;
+  protected final AuthorInfo authorInfo;
 
   public PermissionManager(final ConfigManager configManager, final AuthorInfo authorInfo) {
     this.configManager = configManager;
@@ -106,7 +106,7 @@ public PermissionInfoResp queryPermission(final AuthorPlan authorPlan) {
     }
   }
 
-  private ConsensusManager getConsensusManager() {
+  protected ConsensusManager getConsensusManager() {
     return configManager.getConsensusManager();
   }
 
@@ -145,4 +145,9 @@ public TPermissionInfoResp getUser(String username) throws AuthException {
   public String getUserName(long userId) throws AuthException {
     return authorInfo.getUserName(userId);
   }
+
+  public TSStatus enableSeparationOfPowers(
+      String systemAdminUsername, String securityAdminUsername, String auditAdminUsername) {
+    throw new UnsupportedOperationException("Enable separation of powers is not supported");
+  }
 }

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ProcedureManager.java

@@ -1799,7 +1799,7 @@ private TSStatus waitingProcedureFinished(final long procedureId) {
    * @param procedure The specific procedure
    * @return TSStatus the running result of this procedure
    */
-  private TSStatus waitingProcedureFinished(Procedure<?> procedure) {
+  protected TSStatus waitingProcedureFinished(Procedure<?> procedure) {
     if (procedure == null) {
       LOGGER.error("Unexpected null procedure parameters for waitingProcedureFinished");
       return RpcUtils.getStatus(TSStatusCode.INTERNAL_SERVER_ERROR);

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/service/HeartbeatService.java

@@ -138,7 +138,7 @@ private void heartbeatLoopBody() {
             });
   }
 
-  private TDataNodeHeartbeatReq genHeartbeatReq() {
+  protected TDataNodeHeartbeatReq genHeartbeatReq() {
     /* Generate heartbeat request */
     TDataNodeHeartbeatReq heartbeatReq = new TDataNodeHeartbeatReq();
     heartbeatReq.setHeartbeatTimestamp(System.nanoTime());

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/auth/AuthorInfo.java

@@ -51,8 +51,8 @@ public class AuthorInfo implements SnapshotProcessor {
   public static final CommonConfig COMMON_CONFIG = CommonDescriptor.getInstance().getConfig();
   public static final String NO_USER_MSG = "No such user : ";
 
-  private IAuthorizer authorizer;
-  private volatile IAuthorPlanExecutor authorPlanExecutor;
+  protected IAuthorizer authorizer;
+  protected volatile IAuthorPlanExecutor authorPlanExecutor;
 
   public AuthorInfo() {
     try {
@@ -149,6 +149,11 @@ public TPermissionInfoResp getUserPermissionInfo(String username, ModelType type
     return authorPlanExecutor.getUserPermissionInfo(username, type);
   }
 
+  public TSStatus enableSeparationOfAdminPowers(
+      String systemAdminUsername, String securityAdminUsername, String auditAdminUsername) {
+    throw new UnsupportedOperationException("EnableSeparationOfAdminPowers is not supported");
+  }
+
   @TestOnly
   public void clear() throws AuthException {
     File userFolder = new File(COMMON_CONFIG.getUserFolder());

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/store/ProcedureType.java

@@ -114,6 +114,8 @@ public enum ProcedureType {
   /** Auth privilege */
   AUTH_OPERATE_PROCEDURE((short) 1300),
 
+  ENABLE_SEPARATION_OF_ADMIN_POWERS_PROCEDURE((short) 1301),
+
   /** TTL */
   SET_TTL_PROCEDURE((short) 1400),
 

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/TableConfigTaskVisitor.java

@@ -1387,6 +1387,7 @@ protected IConfigTask visitShowCurrentTimestamp(
   protected IConfigTask visitRelationalAuthorPlan(
       RelationalAuthorStatement node, MPPQueryContext context) {
     context.setQueryType(node.getQueryType());
+    node.setExecutedByUserId(context.getUserId());
     TSStatus status = node.checkStatementIsValid(context.getSession().getUserName());
     if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
       throw new AccessDeniedException(status.getMessage());

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/TreeConfigTaskVisitor.java

@@ -312,6 +312,7 @@ public IConfigTask visitTestConnection(
 
   @Override
   public IConfigTask visitAuthor(AuthorStatement statement, MPPQueryContext context) {
+    statement.setExecutedByUserId(context.getUserId());
     if (statement.getAuthorType() == AuthorType.UPDATE_USER) {
       visitUpdateUser(statement);
     }

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/StatementType.java

@@ -188,5 +188,6 @@ public enum StatementType {
 
   SET_CONFIGURATION,
 
-  FAST_LAST_QUERY
+  FAST_LAST_QUERY,
+  SHOW_CONFIGURATION,
 }