@Override
    public Mono<Boolean> createCollectionIfNotExists(Class<?> clazz) {
        MongoEntity<?> entity = context.getEntity(clazz);
        BsonDocument jsonSchema = entity.jsonSchema();
        if (jsonSchema == null) {
            return Mono.error(new RuntimeException(
                    "Failed to create the collection \""
                            + entity.collectionName()
                            + "\" because no JSON schema is specified"));
        }
        return collectionExists(clazz)
                .flatMap(exists -> createCollectionIfNotExists0(exists, clazz, jsonSchema, entity));
    }
@implNote Send requests to ensure indexes and shard collections synchronously to avoid mongo
          servers throwing "LockBusy" error (error code 46)
turms-server-common/src/main/java/im/turms/server/common/storage/mongo/operation/TurmsMongoOperations.java