Method _parse_aggregate_resp3

redis/commands/search/commands.py:484–527

Parse RESP3 FT.AGGREGATE response into an AggregateResult object.

(self, res, **kwargs)

        )

    def _parse_aggregate_resp3(self, res, **kwargs):
        """Parse RESP3 FT.AGGREGATE response into an AggregateResult object."""
        query = kwargs.get("query")
        has_cursor = kwargs.get("has_cursor", False)

        # When has_cursor is True, RESP3 returns [data_dict, cursor_id].
        cursor_id = 0
        if has_cursor and isinstance(res, list):
            data = res[0]
            cursor_id = res[1] if len(res) > 1 else 0
        else:
            data = res

        if data is None:
            data = {}
        # On RESP3 connections with decode_responses=False the server's map
        # keys arrive as bytes, so normalise structural keys to strings
        # before lookup.  Mirrors ``Result.from_resp3``.
        data = {str_if_bytes(k): v for k, v in data.items()}

        warnings = [str_if_bytes(w) for w in data.get("warning", [])]
        total = data.get("total_results", 0)

        rows = []
        for result_item in data.get("results", []):
            result_item = {str_if_bytes(k): v for k, v in result_item.items()}
            extra_attrs = result_item.get("extra_attributes", {})
            # Convert dict to flat list [key, value, key, value, ...]
            # to match RESP2 row format consumers expect.
            flat = []
            for k, v in extra_attrs.items():
                flat.append(k)
                flat.append(v)
            rows.append(flat)

        cursor = None
        if has_cursor:
            if isinstance(query, Cursor):
                query.cid = cursor_id
                cursor = query
            else:
                cursor = Cursor(cursor_id)

        return AggregateResult(rows, cursor, None, total=total, warnings=warnings)

    # ---- RESP3 HYBRID parsers ----