code: def handle(self, buffer, request_id, mindsdb_env, session):
      # https://docs.mongodb.com/manual/reference/mongodb-wire-protocol/#wire-op-query
      flags, pos = unpack(UINT, buffer)
      namespace, pos = get_utf8_string(buffer, pos)
      is_command = namespace.endswith(".$cmd")
      num_to_skip, pos = unpack(INT, buffer, pos)
      num_to_return, pos = unpack(INT, buffer, pos)
      docs = bson.decode_all(buffer[pos:], CODEC_OPTIONS)
  
      query = docs[0]  # docs = [query, returnFieldsSelector]
  
      logger.debug(f"GET OpQuery={query}")
  
      responder = self.responders.find_match(query)
      assert responder is not None, "query cant be processed"
  
      request_args = {
          "num_to_skip": num_to_skip,
          "num_to_return": num_to_return,
          "request_id": request_id,
          "is_command": is_command,
      }
  
      documents = responder.handle(
          query, request_args, mindsdb_env, session
      )
  
      return documents
  
imports: import socketserver
  import socket
  import struct
  import bson
  import traceback
  from bson import codec_options
  from collections import OrderedDict
  from abc import abstractmethod
  from bson.codec_options import CodecOptions
  from bson.codec_options import TypeCodec
  from bson.codec_options import TypeRegistry
  import numpy
  import datetime
  import mindsdb.api.mongo.functions
  from mindsdb.api.mongo.classes import RespondersCollection, Session
  from mindsdb.interfaces.storage import db
  from mindsdb.interfaces.model.model_controller import ModelController
  from mindsdb.interfaces.database.integrations import integration_controller
  from mindsdb.interfaces.database.projects import ProjectController
  from mindsdb.interfaces.database.database import DatabaseController
  from mindsdb.utilities.context import context
  from mindsdb.utilities import log
label_desc: Use image node_id 1 for calling the OpQueryResponder obj's underlying member method code with example usage: obj.handle(buffer, request_id, mindsdb_env, session) and returns: documents