René's URL Explorer Experiment

{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"Error in Downloading converted mp3 file. Everything else works fine.","articleBody":"Hi @kantancoding ,\r\nI followed your Youtube tutorial. I experienced some errors during implementation in my local system. I tried in both Windows and Ubuntu. I got more parts working in Windows. In Ubuntu, I can move forward through MySQL Error. \r\n\r\nNow my problem is I am not able to download the converted mp3 file. Everything else works fine. The upload part works fine. The Rabbit MQ console page shows the message flow correctly in overview page. But when I try to download the converted file, I got error in gateway pod. The error is:\r\n\r\n```\r\nTraceback (most recent call last):                                                                                                 \r\n  File \"/usr/local/lib/python3.10/site-packages/flask/app.py\", line 1473, in wsgi_app                                                \r\n\tresponse = self.full_dispatch_request()                                                                                        \r\n  File \"/usr/local/lib/python3.10/site-packages/flask/app.py\", line 883, in full_dispatch_request                                    \r\n\treturn self.finalize_request(rv)                                                                                               \r\n  File \"/usr/local/lib/python3.10/site-packages/flask/app.py\", line 902, in finalize_request                                         \r\n\tresponse = self.make_response(rv)                                                                                              \r\n  File \"/usr/local/lib/python3.10/site-packages/flask/app.py\", line 1174, in make_response                                           \r\n\traise TypeError(                                                                                                             \r\nTypeError: The view function for 'download' did not return a valid response. The function either returned None or ended without  \r\n10.244.0.35 - - [13/Oct/2024 17:26:52] \"GET /download?fid=670c012c7b8bed687d11e620 HTTP/1.1\" 500 -\r\n```\r\n\r\nThe gateway/server.py file is:\r\n\r\n```\r\nimport os, gridfs, pika, json\r\nfrom flask import Flask, request, send_file\r\nfrom flask_pymongo import PyMongo\r\nfrom auth import validate\r\nfrom auth_svc import access\r\nfrom storage import util\r\nfrom bson.objectid import ObjectId\r\n\r\nserver = Flask(__name__)\r\n\r\nmongo_video = PyMongo(server, uri=\"mongodb://host.minikube.internal:27017/videos\")\r\n\r\nmongo_mp3 = PyMongo(server, uri=\"mongodb://host.minikube.internal:27017/mp3s\")\r\n\r\nfs_videos = gridfs.GridFS(mongo_video.db)\r\nfs_mp3s = gridfs.GridFS(mongo_mp3.db)\r\n\r\nconnection = pika.BlockingConnection(pika.ConnectionParameters(\"rabbitmq\"))\r\nchannel = connection.channel()\r\n\r\n\r\n@server.route(\"/login\", methods=[\"POST\"])\r\ndef login():\r\n    token, err = access.login(request)\r\n\r\n    if not err:\r\n        return token\r\n    else:\r\n        return err\r\n\r\n\r\n@server.route(\"/upload\", methods=[\"POST\"])\r\ndef upload():\r\n    access, err = validate.token(request)\r\n\r\n    if err:\r\n        return err\r\n\r\n    access = json.loads(access)\r\n\r\n    if access[\"admin\"]:\r\n        if len(request.files) \u003e 1 or len(request.files) \u003c 1:\r\n            return \"exactly 1 file required\", 400\r\n\r\n        for _, f in request.files.items():\r\n            err = util.upload(f, fs_videos, channel, access)\r\n\r\n            if err:\r\n                return err\r\n\r\n        return \"success!\", 200\r\n    else:\r\n        return \"not authorized\", 401\r\n\r\n\r\n@server.route(\"/download\", methods=[\"GET\"])\r\ndef download():\r\n    access, err = validate.token(request)\r\n\r\n    if err:\r\n        return err\r\n\r\n    access = json.loads(access)\r\n\r\n    if access[\"admin\"]:\r\n        fid_string = request.args.get(\"fid\")\r\n\r\n        if not fid_string:\r\n            return \"fid is required\", 400\r\n\r\n        try:\r\n            out = fs_mp3s.get(ObjectId(fid_string))\r\n            return send_file(out, download_name=f\"{fid_string}.mp3\")\r\n        except Exception as err:\r\n            print(err)\r\n            return \"internal server error\", 500\r\n\r\n    return \"not authorized\", 401\r\n\r\n\r\nif __name__ == \"__main__\":\r\n    server.run(host=\"0.0.0.0\", port=8080)\r\n```\r\n\r\nWhat will be the problem ? Can you please explain this and help me to solve the problem?","author":{"url":"https://github.com/vigneshs-dev","@type":"Person","name":"vigneshs-dev"},"datePublished":"2024-10-13T17:38:18.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":0},"url":"https://github.com/39/microservices-python/issues/39"}