distibutedbanking

Author: RobielEliasRedie

Bank/Client.py

@@ -0,0 +1,57 @@
+import random
+import json
+import os
+import sys
+import time
+from networking.udpSocket import udp_socket
+
+
+# Define a list of stocks with their ticker symbols and initial prices
+stocks = [
+    {"symbol": "VW", "price": 170.0},
+    {"symbol": "KIA", "price": 3000.0},
+    {"symbol": "AUDI", "price": 400.0},
+    {"symbol": "BMW", "price": 5000.0},
+]
+
+
+SERVER_HOSTNAME = os.environ.get("SERVER_HOSTNAME", "127.0.0.1")
+SERVER_PORT = int(os.environ.get("SERVER_PORT", "6789"))
+
+
+
+
+while True:
+    # Simulate the prices of the stocks
+    for stock in stocks:
+        # Generate a random percentage change between -1% and +1%
+        percent_change = random.uniform(-0.01, 0.01)
+        # Calculate the new price based on the percent change
+        new_price = stock["price"] * (1 + percent_change)
+        # Update the stocks's price
+        stock["price"] = new_price
+
+    # Print the updated prices of the stocks
+    print("Updated prices of stocks:")
+    for stock in stocks:
+        print(f"{stock['symbol']}: {stock['price']}")
+
+    message = json.dumps(stocks)
+
+    try:
+        udp_client = udp_socket(SERVER_HOSTNAME, SERVER_PORT)
+        start_time= time.time()
+        response_server = udp_client.send(SERVER_HOSTNAME, SERVER_PORT, message, 4096)
+        end_time= time.time()
+        roundtriptime= end_time - start_time
+        print("Response from the server => %s" % response_server)
+        print("Round-trip time => %.2f ms" % (roundtriptime * 1000))
+    except Exception as e:          # catch execption for catching the error
+        print(f"Error occurred while sending/receiving data: {e}")
+        sys.exit(1)
+
+    #user_input = input("Do you want to quit? (y/n)")
+    #if user_input == "y":
+         #break
+         # 
+    time.sleep(300) 

Dockerfile.Server

@@ -0,0 +1,41 @@
+FROM python:3
+
+WORKDIR /Server
+
+COPY ./Server ./Server
+
+COPY ./networking ./Server/networking
+
+COPY stockportfolio.thrift ./Server/
+
+RUN apt-get update && apt-get install -y iputils-ping
+
+
+
+# Install Conda
+RUN wget https://repo.anaconda.com/miniconda/Miniconda3-latest-Linux-x86_64.sh && \
+    bash Miniconda3-latest-Linux-x86_64.sh -b -p /opt/conda && \
+    rm Miniconda3-latest-Linux-x86_64.sh && \
+    export PATH="/opt/conda/bin:$PATH" && \
+    echo "export PATH=/opt/conda/bin:$PATH" >> ~/.bashrc
+
+# Activate Conda environment
+ENV PATH="/opt/conda/bin:$PATH"
+
+RUN conda install -c conda-forge thriftpy2
+
+RUN pip install rpyc
+
+RUN pip install kafka-python
+
+#RUN pip install aiokafka==0.8.0
+RUN pip install aiokafka
+#RUN pip install aiomonitor
+
+
+#ENTRYPOINT [ "python", "-u", "Server/Server.py" ]
+ENTRYPOINT ["python", "-X", "dev", "-u", "Server/Server.py"]
+
+#CMD ["tail", "-f", "/dev/null"]
+EXPOSE 6789/UDP
+