[IMP] dms: Upload file and create dms.file directly

Related to #470 (comment)

(cherry picked from commit 938f72d)

Co-authored-by: Don Kendall <dkendall@ledoweb.com>

Author: victoralmau

dms/controllers/main.py

@@ -1,8 +1,15 @@
 # Copyright 2017-2019 MuK IT GmbH
+# Copyright 2026 Tecnativa - Víctor Martínez
 # License LGPL-3.0 or later (http://www.gnu.org/licenses/lgpl).
+import json
+import unicodedata
+
 from odoo import http
+from odoo.exceptions import AccessError
 from odoo.http import request
 
+from odoo.addons.web.controllers.binary import clean
+
 
 class OnboardingController(http.Controller):
     @http.route("/config/dms.forbidden_extensions", type="jsonrpc", auth="user")
@@ -13,3 +20,55 @@ def forbidden_extensions(self, **_kwargs):
                 "dms.forbidden_extensions", default=""
             )
         }
+
+    @http.route("/web/binary/upload_dms_file", type="http", auth="user")
+    def upload_dms_file(self, ufile, directory_id, callback=None):
+        """Similar to the web upload_attachment() method, but customized to
+        directly create dms.file records.
+        """
+        directory_id = int(directory_id)
+        files = request.httprequest.files.getlist("ufile")
+        Model = request.env["dms.file"]
+        out = """<script language="javascript" type="text/javascript">
+                    var win = window.top.window;
+                    win.jQuery(win).trigger(%s, %s);
+                </script>"""
+        args = []
+        for ufile in files:
+            filename = ufile.filename
+            if request.httprequest.user_agent.browser == "safari":
+                # Safari sends NFD UTF-8 (where é is composed by 'e' and [accent])
+                # we need to send it the same stuff, otherwise it'll fail
+                filename = unicodedata.normalize("NFD", ufile.filename)
+            try:
+                dms_file = Model.create(
+                    {
+                        "directory_id": directory_id,
+                        "name": filename,
+                        "content_binary": ufile.read(),
+                    }
+                )
+            except AccessError:
+                args.append(
+                    {
+                        "error": request.env._(
+                            "You are not allowed to upload a file here."
+                        )
+                    }
+                )
+            except Exception:
+                args.append({"error": request.env._("Something horrible happened")})
+            else:
+                args.append(
+                    {
+                        "filename": clean(filename),
+                        "mimetype": dms_file.mimetype,
+                        "id": dms_file.id,
+                        "size": dms_file.size,
+                    }
+                )
+        return (
+            out % (json.dumps(clean(callback)), json.dumps(args))
+            if callback
+            else json.dumps(args)
+        )

dms/models/dms_file.py

@@ -650,29 +650,3 @@ def _compute_locked(self):
                 )
             else:
                 record.update({"is_locked": False, "is_lock_editor": False})
-
-    def get_attachment_object(self, attachment):
-        return {
-            "name": attachment.name,
-            "datas": attachment.datas,
-            "res_model": attachment.res_model,
-            "mimetype": attachment.mimetype,
-        }
-
-    @api.model
-    def get_dms_files_from_attachments(self, attachment_ids=None):
-        """Get the dms files from uploaded attachments.
-        :return: An Array of dms files.
-        """
-        if not attachment_ids:
-            raise UserError(self.env._("No attachment was provided"))
-
-        attachments = self.env["ir.attachment"].browse(attachment_ids)
-
-        if any(
-            attachment.res_id or attachment.res_model != "dms.file"
-            for attachment in attachments
-        ):
-            raise UserError(self.env._("Invalid attachments!"))
-
-        return [self.get_attachment_object(attachment) for attachment in attachments]

dms/static/src/js/views/dms_file_upload.esm.js

@@ -80,37 +80,8 @@ export function createFileUploadExtension() {
         },
 
         async onChangeFileInput() {
-            const params = {
-                csrf_token: odoo.csrf_token,
-                ufile: [...this.fileInput.el.files],
-                model: "dms.file",
-                id: 0,
-            };
-
-            const fileData = await this.http.post(
-                "/web/binary/upload_attachment",
-                params,
-                "text"
-            );
-            const attachments = JSON.parse(fileData);
-            if (attachments.error) {
-                throw new Error(attachments.error);
-            }
-
-            await this.onUpload(attachments);
-        },
-
-        async onUpload(attachments) {
             const self = this;
-            const attachmentIds = attachments.map((a) => a.id);
-            const ctx = this.props.context;
             const controllerID = this.actionService.currentController.jsId;
-
-            if (!attachmentIds.length) {
-                this.notification.add(_t("An error occurred during the upload"));
-                return;
-            }
-
             // Search the correct directory_id value according to the domain
             let directory_id = false;
             if (this.props.domain) {
@@ -133,37 +104,22 @@ export function createFileUploadExtension() {
                 });
             }
 
-            const attachment_datas = await this.orm.call(
-                "dms.file",
-                "get_dms_files_from_attachments",
-                [],
-                {attachment_ids: attachmentIds}
-            );
-
-            const attachments_args = [];
-
-            attachment_datas.forEach((attachment_data) => {
-                attachments_args.push({
-                    name: attachment_data.name,
-                    content: attachment_data.datas,
-                    mimetype: attachment_data.mimetype,
-                    directory_id,
-                });
-            });
+            const params = {
+                csrf_token: odoo.csrf_token,
+                ufile: [...this.fileInput.el.files],
+                directory_id: directory_id,
+            };
 
-            this.orm
-                .call("dms.file", "create", [attachments_args], {
-                    context: ctx,
-                })
-                .then(() => {
-                    self.actionService.restore(controllerID);
-                })
-                .catch((error) => {
-                    self.notification.add(error.data.message, {
-                        type: "danger",
-                    });
-                    self.actionService.restore(controllerID);
-                });
+            const fileData = await this.http.post(
+                "/web/binary/upload_dms_file",
+                params,
+                "text"
+            );
+            const result = JSON.parse(fileData);
+            if (result.error) {
+                throw new Error(result.error);
+            }
+            self.actionService.restore(controllerID);
         },
     };
 }