Internal query message helper.
(
options: int,
collection_name: str,
num_to_skip: int,
num_to_return: int,
query: Mapping[str, Any],
field_selector: Optional[Mapping[str, Any]],
opts: CodecOptions[Any],
)
| 473 | |
| 474 | |
| 475 | def _query_uncompressed( |
| 476 | options: int, |
| 477 | collection_name: str, |
| 478 | num_to_skip: int, |
| 479 | num_to_return: int, |
| 480 | query: Mapping[str, Any], |
| 481 | field_selector: Optional[Mapping[str, Any]], |
| 482 | opts: CodecOptions[Any], |
| 483 | ) -> tuple[int, bytes, int]: |
| 484 | """Internal query message helper.""" |
| 485 | op_query, max_bson_size = _query_impl( |
| 486 | options, collection_name, num_to_skip, num_to_return, query, field_selector, opts |
| 487 | ) |
| 488 | rid, msg = __pack_message(2004, op_query) |
| 489 | return rid, msg, max_bson_size |
| 490 | |
| 491 | |
| 492 | if _use_c: |
no test coverage detected