report can now be received by client

Author: SatpreetMakhija

__pycache__/create_report.cpython-38.pyc

@@ -85,11 +85,13 @@ def choose_file_callback(sender, app_data):
 
 def send_model_data():
     model_degree = dpg.get_value("model_degree")
+    client.send(model_degree.encode())
+    print(f"model degree is {model_degree}")
     model_test_percentage = str(dpg.get_value("model_test_percentage"))
     print(dpg.get_value("model_degree"))
     print(dpg.get_value("model_test_percentage"))
     #======client code starts=====
-    client.send(model_degree.encode())
+    
     client.send(model_test_percentage.encode())
     #========client code ends=======
 
@@ -99,6 +101,32 @@ def send_model_data():
         dpg.add_text("Data sent to server")
         dpg.add_text("Model is getting trained by the model.....")
 
+    #==============client code starts===========
+            #Receive Report from server
+    file_size = client.recv(1024).decode()
+    print(file_size)
+    file_path = 'sentreport.pdf'
+    file = open(file_path, "wb")
+    c = 0
+    # Starting the time capture.
+    start_time = time.time()
+
+    # Running the loop while file is recieved.
+    while c < int(file_size):
+        data = client.recv(1024)
+        if not (data):
+            break
+        file.write(data)
+        c += len(data)
+    file.close()
+
+    # Ending the time capture.
+    end_time = time.time()
+
+    print("[INFO]: Report file received. Total time: ", end_time - start_time)
+
+
+    #===========client code ends========
 
 def get_model_inputs():
     pass

__pycache__/models.cpython-38.pyc

@@ -1,7 +1,7 @@
 x,y
 32.502345269453031,31.70700584656992
 53.426804033275019,68.77759598163891
-61.530358025636438,62.562382297945803
+61.53035802563,62.56238229794
 47.475639634786098,71.546632233567777
 59.813207869512318,87.230925133687393
 55.142188413943821,78.211518270799232
@@ -98,5 +98,4 @@ x,y
 49.239765342753763,72.111832469615663
 50.039575939875988,85.232007342325673
 48.149858891028863,66.224957888054632
-25.128484647772304,53.454394214850524
-22.23, 21.23
+25.128484647772304,53.454394214850524

__pycache__/utils.cpython-38.pyc

@@ -68,7 +68,7 @@ def reg_training_model(df, user_dir, degree = 1, split_ratio = 0.2):
 	plt.legend(loc='upper left')	
 	plt.title("Polynomial Fitting")
 	plt.savefig(f"{user_dir}/fitting.png")
-	plt.show()
+	# plt.show()
 
 
 	##-------------------------------------------------
@@ -135,6 +135,6 @@ def reg_training_model(df, user_dir, degree = 1, split_ratio = 0.2):
 	sm.qqplot(residual_test, line='45',  ax = ax2)
 	ax2.set_title("Test")
 	ax2.set_ylabel("Standard Residual")
-	plt.savefig(f"{user_dir}/residual_pred.png")
+	plt.savefig(f"{user_dir}/normalqq.png")
 	return 0
 

app.py

@@ -64,6 +64,7 @@
     #receive info about model training from client
     degree = conn.recv(100).decode()
     print(degree)
+    print("hello")
     training_ratio = conn.recv(100).decode()
     print(training_ratio)
 
@@ -74,7 +75,36 @@
     reg_training_model(df, degree = int(degree), split_ratio = int(training_ratio)/100, user_dir = user_dir)
 
     tot, maxi, mini, mean, medi, sd = stats_summary(df)
+    print("model training done......")
     c_report(tot, maxi, mini, mean, medi, sd, training_points, testing_points, degree, split = training_ratio, user_dir = user_dir)
+    print(str(tot))
+    print("report generated now")
+
+
+    file_path = f'./server_data/{initial}/report.pdf'
+    file_size = os.path.getsize(file_path)
+    print(file_size)
+    conn.send(str(file_size).encode())
+
+
+    with open(file_path, "rb") as file:
+        c = 0
+        # Starting the time capture.
+        start_time = time.time()
+
+        # Running loop while c != file_size.
+        while c <= file_size:
+            data = file.read(1024)
+            if not (data):
+                break
+            conn.sendall(data)
+            c += len(data)
+
+        # Ending the time capture.
+        end_time = time.time()
+
+    print("[INFO] Report file Transfer Complete.Total time: ", end_time - start_time)
+
 
     # Closing the socket.
     conn.close()