Method handle

src/client/cli/admin/AdminUserCtrl.cc:77–111

  }

  static CoTryTask<Dispatcher::OutputTable> handle(IEnv &ienv,
                                                   const argparse::ArgumentParser &parser,
                                                   const Dispatcher::Args &args) {
    auto &env = dynamic_cast<AdminEnv &>(ienv);
    ENSURE_USAGE(args.empty());
    Dispatcher::OutputTable output;

    auto uid = Uid(parser.get<uint32_t>("uid"));
    auto name = parser.get<std::string>("name");
    auto isRootUser = parser.get<bool>("--root");
    auto isAdmin = parser.get<bool>("--admin");
    auto token = parser.present<String>("--token").value_or("");
    auto gids = splitAndTransform(parser.present<String>("--groups").value_or(""), boost::is_any_of(","), [](auto s) {
      return flat::Gid(folly::to<uint32_t>(s));
    });

    core::UserStore store;
    auto handler = [&](kv::IReadWriteTransaction &txn) -> CoTryTask<flat::UserAttr> {
      auto userList = co_await store.listUsers(txn);
      CO_RETURN_ON_ERROR(userList);
      if (userList->empty()) {
        if (!isAdmin) {
          co_return makeError(StatusCode::kInvalidArg, "The first user must be admin");
        }
      } else {
        CO_RETURN_ON_ERROR(co_await ensureAdmin(txn, store, env.userInfo.token));
      }
      co_return co_await store.addUser(txn, uid, name, gids, isRootUser, isAdmin, token);
    };
    auto commitRes = co_await kv::WithTransaction(getRetryStrategy())
                         .run(env.kvEngineGetter()->createReadWriteTransaction(), std::move(handler));
    CO_RETURN_ON_ERROR(commitRes);
    printUserAttr(output, uid, *commitRes);
    co_return output;
  }
};

struct UserRemoveHandler {