Updated Invalid Document error message to have doc

Author: Navjot Singh

bson/__init__.py

@@ -1006,7 +1006,10 @@ def _dict_to_bson(
             elements.append(_name_value_to_bson(b"_id\x00", doc["_id"], check_keys, opts))
         for key, value in doc.items():
             if not top_level or key != "_id":
-                elements.append(_element_to_bson(key, value, check_keys, opts))
+                try:
+                    elements.append(_element_to_bson(key, value, check_keys, opts))
+                except InvalidDocument as err:
+                    raise InvalidDocument("Invalid document {} | {}".format(doc,err)) from err
     except AttributeError:
         raise TypeError(f"encoder expected a mapping type but got: {doc!r}") from None
 

bson/_cbsonmodule.c

@@ -1743,6 +1743,45 @@ int write_dict(PyObject* self, buffer_t buffer,
         while (PyDict_Next(dict, &pos, &key, &value)) {
             if (!decode_and_write_pair(self, buffer, key, value,
                                     check_keys, options, top_level)) {
+                if (PyErr_Occurred()) {
+                    PyObject *etype, *evalue, *etrace;
+                    PyErr_Fetch(&etype, &evalue, &etrace);
+                    PyObject *InvalidDocument = _error("InvalidDocument");
+
+                    if (PyErr_GivenExceptionMatches(etype, InvalidDocument)) {
+
+                        if (InvalidDocument) {
+                            Py_DECREF(etype);
+                            etype = InvalidDocument;
+
+                            if (evalue) {
+                                PyObject *msg = PyObject_Str(evalue);
+                                Py_DECREF(evalue);
+
+                                if (msg) {
+                                    // Prepend doc to the existing message
+                                    PyObject *dict_str = PyObject_Str(dict);
+                                    PyObject *new_msg = PyUnicode_FromFormat("Invalid document %s | %s", PyUnicode_AsUTF8(dict_str), PyUnicode_AsUTF8(msg));
+                                    Py_DECREF(dict_str);
+
+                                    if (new_msg) {
+                                        evalue = new_msg;
+                                        Py_DECREF(new_msg);
+                                    }
+                                    else{
+                                    evalue = msg;
+                                    }
+
+                                     Py_DECREF(msg);
+
+                                }
+                            }
+                            PyErr_NormalizeException(&etype, &evalue, &etrace);
+                        }
+                    }
+                    PyErr_Restore(etype, evalue, etrace);
+                    Py_DECREF(InvalidDocument);
+                }
                 return 0;
             }
         }

test/test_bson.py

@@ -1000,6 +1000,22 @@ def __repr__(self):
         ):
             encode({"t": Wrapper(1)})
 
+    def test_doc_in_invalid_document_error_message(self):
+
+        class Wrapper:
+            def __init__(self, val):
+                self.val = val
+
+            def __repr__(self):
+                return repr(self.val)
+
+        self.assertEqual("1", repr(Wrapper(1)))
+        doc = {"t": Wrapper(1)}
+        with self.assertRaisesRegex(
+            InvalidDocument, "Invalid document {}".format(doc)
+        ):
+            encode(doc)
+
 
 class TestCodecOptions(unittest.TestCase):
     def test_document_class(self):