"code till receiving data on flask server"

Author: skp-github

app/src/main/AndroidManifest.xml

@@ -13,7 +13,8 @@
       android:label="@string/app_name"
       android:supportsRtl="true"
       android:theme="@style/AppTheme"
-      android:requestLegacyExternalStorage="true">
+      android:requestLegacyExternalStorage="true"
+      android:usesCleartextTraffic="true">
 
     <activity
         android:name=".MainActivity"

app/src/main/java/com/googleresearch/capturesync/MainActivity.java

@@ -388,6 +388,26 @@ private void handleWebSocketMsg(@NotNull WsMessageContext wsMessageContext){
 
             case "UPLOAD" :
                 Log.i(TAG,"handling the message in DOWNLOAD:" + infoParts[1] );
+                try {
+                    File sdcard = Environment.getExternalStorageDirectory();
+                    String filePath = sdcard.getAbsolutePath()+ "/RecSync/VID/";
+                    File path = new File(filePath);
+                    File list[] = path.listFiles();
+                    String filename;
+                    for(int i=0; i< list.length; i++){
+                            filename = list[i].getName();
+                            if(filename.startsWith(infoParts[2])){
+                                String[] fileList = {filePath + filename};
+                                new RemoteFileUpload().execute(fileList);
+                            }
+                    }
+                }
+                catch(Exception e){
+                    Log.i(TAG,"In exception block");
+                    e.printStackTrace();
+                }
+
+
                 break;
 
 

fileserver/file_server.py

@@ -2,16 +2,22 @@
 from flask import Flask, json, request, jsonify
 import os
 import urllib.request
+import base64
 from werkzeug.utils import secure_filename
+import multipart as mp
 
+try:
+    from io import BytesIO
+except ImportError:
+    from StringIO import StringIO as BytesIO
 app = Flask(__name__)
 
 app.secret_key = "recSync-fileserver"
 
 UPLOAD_FOLDER = 'static/uploads'
 app.config['UPLOAD_FOLDER'] = UPLOAD_FOLDER
 
-ALLOWED_EXTENSIONS = set(['txt', 'pdf', 'png', 'jpg', 'jpeg', 'gif'])
+ALLOWED_EXTENSIONS = set(['txt', 'pdf', 'png', 'jpg', 'jpeg', 'gif', 'mov', 'mp4'])
 
 def allowed_file(filename):
     return '.' in filename and filename.rsplit('.', 1)[1].lower() in ALLOWED_EXTENSIONS
@@ -23,37 +29,25 @@ def main():
 @app.route('/upload', methods=['POST'])
 def upload_file():
     # check if the post request has the file part
-    if 'files[]' not in request.files:
+    data = request.get_data()
+    import pdb;pdb.set_trace()
+    dd = b''.join(data.split(b'\r')[3:6])[2:]
+    #dd = data.split(b'\r')[5]
+    with open('binary.mp4', 'wb') as wfile:
+        wfile.write(dd.decode())
+
+    if 'name' not in request.files:
+        print("request inside files not found")
         resp = jsonify({'message' : 'No file part in the request'})
+        print(resp.data)
         resp.status_code = 400
         return resp
 
-    files = request.files.getlist('files[]')
-
     errors = {}
     success = False
-
-    for file in files:
-        if file and allowed_file(file.filename):
-            filename = secure_filename(file.filename)
-            file.save(os.path.join(app.config['UPLOAD_FOLDER'], filename))
-            success = True
-        else:
-            errors[file.filename] = 'File type is not allowed'
-
-    if success and errors:
-        errors['message'] = 'File(s) successfully uploaded'
-        resp = jsonify(errors)
-        resp.status_code = 500
-        return resp
-    if success:
-        resp = jsonify({'message' : 'Files successfully uploaded'})
-        resp.status_code = 201
-        return resp
-    else:
-        resp = jsonify(errors)
-        resp.status_code = 500
-        return resp
+    resp = jsonify({"message" : "git files"})
+    resp.status_code = 200
+    return resp
 
 if __name__ == '__main__':
-    app.run(debug=True)
+    app.run(host='0.0.0.0', port=5000,debug=True)

remote_control/remote_control.py

@@ -34,7 +34,7 @@ def statusBtn(self):
         self.label.setText(message)
     def downloadBtn(self):
         endpoint = self.api_input.toPlainText()
-        self.ws.send("UPLOAD@@"+endpoint+"@@testsession")
+        self.ws.send("UPLOAD@@"+endpoint+"@@Test_UPLOAD")
 
     def setupUi(self, MainWindow):
         self.ws = websocket.WebSocket()