XINFO_GROUPS.js 607 B

123456789101112131415161718
  1. "use strict";
  2. Object.defineProperty(exports, "__esModule", { value: true });
  3. exports.transformReply = exports.transformArguments = exports.IS_READ_ONLY = exports.FIRST_KEY_INDEX = void 0;
  4. exports.FIRST_KEY_INDEX = 2;
  5. exports.IS_READ_ONLY = true;
  6. function transformArguments(key) {
  7. return ['XINFO', 'GROUPS', key];
  8. }
  9. exports.transformArguments = transformArguments;
  10. function transformReply(rawReply) {
  11. return rawReply.map(group => ({
  12. name: group[1],
  13. consumers: group[3],
  14. pending: group[5],
  15. lastDeliveredId: group[7]
  16. }));
  17. }
  18. exports.transformReply = transformReply;