This is the ussd bit

With this bit one can be able to report sitings of places where trash has been dumped wrecklessly.

Author: georges-mars

Diff for: mqtt_client.py

@@ -0,0 +1,77 @@
+#my code
+from flask import Flask, request
+import threading 
+import paho.mqtt.client as mqtt
+import requests
+import json
+
+import os
+
+response = ""
+######added now........unique = ['1','mars', 'elvis', 'Kori', 'brian','205', 'keith']    
+mqtt_data = {}
+
+def start_mqtt_subscriber():
+    #####i doubt whether this 2 lines of code are functional
+    clientid="14"
+    client = mqtt.Client(client_id=clientid)
+
+    def on_connect(client, userdata, flags, rc):
+        if rc == 0:
+            # data = request.get_json()
+        # Perform an HTTP request
+            # url = data.get('url')
+            # response = requests.get(url)
+            client.subscribe("keith",0)  # Subscribe to all topics under the client's ID
+           
+            
+            print("Connected to MQTT broker")
+            
+        else:
+            print(f"Connection failed with code {rc}")
+    
+    def on_message(client, userdata, message):
+        
+        topic = message.topic
+        answer = message.payload.decode()
+        #payload = message.payload.decode()
+        print(f"Received message on topic: {topic}, payload: {answer}")
+        if topic == "P1":
+            mqtt_data["P1"]=answer
+        if topic == "P2":
+            mqtt_data["P2"]=answer
+        if topic == "P3":
+            mqtt_data["P3"]=answer
+        if topic == "P4":
+            mqtt_data["P4"]=answer
+        if topic == "P5":
+            mqtt_data["P5"]=answer
+        if topic == "P6":
+            mqtt_data["P6"]=answer
+        
+
+        # Process the incoming MQTT message here above
+        
+        url = 'http://localhost:5000/post_data'
+        # payload = {'temp': 10}
+        r = requests.post(url, json=mqtt_data)
+        print(r.text)
+        
+        
+    client.on_connect = on_connect
+    client.on_message = on_message
+    broker_address = "mqtt.eclipseprojects.io"  # Replace with your broker's address
+    client.connect(broker_address, 1883, 30)
+    
+    
+    
+    
+    # Start the MQTT subscriber loop
+    client.loop_forever()
+
+if __name__ == '__main__':
+    start_mqtt_subscriber()
+
+
+
+

Diff for: server.py

@@ -0,0 +1,117 @@
+#my code
+from flask import Flask, request
+import threading 
+import paho.mqtt.client as mqtt
+import requests
+import json
+from mqtt_client import start_mqtt_subscriber
+import random
+
+
+
+app = Flask(__name__)
+
+import os
+
+response = ""
+#identity = data_queue.get()
+mqtt_data = {}
+
+
+
+
+def calculating(amount):
+    try:
+        price = float(amount) * 1
+    except Exception as e:
+        raise Exception("Amount cannot be converted to valid number. Check and try again")
+    return price
+
+#///creating the methods of communiction
+
+    
+    
+@app.route('/', methods=['POST', 'GET'])
+def ussd_callback():
+    
+    print 
+    global response
+    global mqtt_data
+    session_id = request.values.get("sessionId", None)#/////getting the session id
+    service_code = request.values.get("serviceCode", None)#//////////getting the service code
+    phone_number = request.values.get("phoneNumber", None)#getting the phone number that requested
+    text =request.values.get("text", "default")#getting the request
+    session_state = text.split('*')  
+    
+    current_level = len(session_state)
+    
+
+    
+    
+    
+    
+    if current_level == 1:
+        response  = "CON Hello and welcome team Zuri Bin.We work with you to deliver your domestic waste prompty; when you need it.\n"
+        response += "1. Report someone 's trash\n"
+        response += "2. Report my own trash"
+        
+    elif current_level == 2 and session_state[1] == '1':
+        response = "CON Hello and thank you  for reporting trash. Kindly choose location\n"
+        response += "1:Nairobi\n"
+        response += "2:We are currently not in other regions"
+        
+        
+        
+    elif current_level ==2 and session_state[1]== '2':
+        response = "END Thanks we will try our best to get into your region."
+    
+    elif current_level ==3 and session_state[2]== '1':
+        response = "CON Kindly specify  your region\n"
+        response += "1:CBD\n"
+        response += "2:Pipeline\n"
+        response += "3:Kileleshwa\n"
+        response += "4:Langata"
+        
+    elif current_level == 4 and session_state[3] == '1':
+        response = "CON How big is your trash\n"
+        response += "1:Big\n"
+        response += "2:Medium\n"
+        response += "3:Small"
+        
+    elif current_level == 5 and session_state[4] == '1':
+        response = 'END Thank you. Your concern is noted.'  
+                
+    elif current_level == 5 and session_state[4] == '2':
+        response = 'END Thank you. Your concern is noted.'
+        
+    elif current_level == 5 and session_state[4] == '3':
+        response = 'END Thank you. Your concern is noted.'
+        
+    elif current_level == 5 and session_state[3] == '2':
+        response = 'END Apparently we have not reached this region\n.'
+    elif current_level == 5 and session_state[3] == '3':
+        response = 'END Apparently we have not reached this region\n.'
+    elif current_level == 5 and session_state[3] == '4':
+        response = 'END Apparently we have not reached this region\n.'
+    
+    return response
+      
+        
+   
+#Receive response from africas talking
+@app.route('/call', methods=['POST'])
+def call_back_client():
+    return '<Response> <Dial phoneNumbers="" maxDuration="5"/></Response>'
+
+
+if __name__ == '__main__':
+    mqtt_thread = threading.Thread(target=start_mqtt_subscriber)
+ 
+    mqtt_thread.daemon = True
+    # Daemonize the thread so it exits when the main thread exits
+    mqtt_thread.start()
+    app.run(host="0.0.0.0", port=os.environ.get('PORT'))
+
+
+
+