client.py

import socket
import threading
import random
import time

client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client.connect(('127.0.0.1', 12129))

# Intiation for simulated data 
mean = [2, 500, 3]      # ph, tds, chlorine levels
deviation = [1, 550, 2]

idName = input("Choose a name: ")
mail = input("Enter mail for alert")

# This method continuously listens to the incoming messages
def recieveMessage():
    while True:  # infinite loop
        try:
            message = client.recv(1024).decode('utf-8')
            if message == "RequestIdName":
                client.send(idName.encode('utf-8'))

            elif message == "RequestMail":
                client.send(mail.encode('utf-8'))
            else:
                print(message)

        except:
            print("An error occurred!")
            client.close()
            break


def sendMessage():
    while True:
        # value generation using gaussian method
        valuePh = random.gauss(mean[0], deviation[0])
        valueTurbidity = random.gauss(mean[1], deviation[1])
        valueChlorine = random.gauss(mean[2], deviation[2])

        if 6.5 < valuePh < 8.5:
            client.send(f'Permissible ph level for drinking water {valuePh}'.encode("utf-8"))
        elif valuePh > 8.5:
            client.send(f'Over the Permissible ph levels!!'.encode("utf-8"))
        else:
            client.send(f'Under the Permissible ph levels!!{valuePh}'.encode("utf-8"))

        if 100 < valueTurbidity < 1000:
            client.send(f'Permissible TDS Level for drinking water {valueTurbidity}'.encode("utf-8"))
        else:
            client.send(f'TDS levels Not in the permissible range!'.encode("utf-8"))

        if valueChlorine < 4:
            client.send(f'Chlorine levels in range {valueChlorine}'.encode("utf-8"))
        else:
            client.send(f'Chlorine levels not in permissible range'.encode("utf-8"))

        time.sleep(10)


recieveThread = threading.Thread(target=recieveMessage)
recieveThread.start()

sendThread = threading.Thread(target=sendMessage)
sendThread.start()