From 13a4b83e64ba93a0e68935e1c4481720025b190f Mon Sep 17 00:00:00 2001
From: dpdrabla <159772288+dpdrabla@users.noreply.github.com>
Date: Fri, 16 Feb 2024 15:52:50 +0000
Subject: [PATCH] Feat: London Transport Integration (#226)

Co-authored-by: Joshua Croft <32483134+devjsc@users.noreply.github.com>
---
 integrations/.DS_Store                        | Bin 0 -> 8196 bytes
 .../london-transport-integration/.gitignore   |   8 ++
 .../london-transport-integration/README.md    |  38 +++++++
 .../london-transport-integration/project.json |   5 +
 .../src/agents/tfl_agent.py                   |  93 ++++++++++++++++++
 .../src/agents/user.py                        |  38 +++++++
 .../london-transport-integration/src/main.py  |  10 ++
 .../src/message/model.py                      |  11 +++
 8 files changed, 203 insertions(+)
 create mode 100644 integrations/.DS_Store
 create mode 100644 integrations/london-transport-integration/.gitignore
 create mode 100644 integrations/london-transport-integration/README.md
 create mode 100644 integrations/london-transport-integration/project.json
 create mode 100644 integrations/london-transport-integration/src/agents/tfl_agent.py
 create mode 100644 integrations/london-transport-integration/src/agents/user.py
 create mode 100644 integrations/london-transport-integration/src/main.py
 create mode 100644 integrations/london-transport-integration/src/message/model.py

diff --git a/integrations/.DS_Store b/integrations/.DS_Store
new file mode 100644
index 0000000000000000000000000000000000000000..efd62c4794e9c2ba1f8c557ead24b6cf903c30cc
GIT binary patch
literal 8196
zcmeHM!EVz)5S>i}aj8m!L`5Y)vc$E8q_mYPE+LcySAyUGDA=`|Sh#j%JB_L;QqJ%X
z`~p|Lgn!`#Z)Ueu?9vMYio|ZUJL}zfv*WircE%+l)g1?IqBSCNP+2yY(EOzEJlAuj
zW=5_<D&UDW$S03-3emI0GGH073|Iy%1D1h*kpaB3xi}ZR_w}r8Ed!Q;|B?ZIKDekX
zJ4Vj5lt%{|NdX}17?y%Q@&LiOMs|#xX(>?H)Y*eFP-RjKrQw)&Ssk)t<V;HqC#B(}
z%*x7SC`wib&J}f19W8BZ8L$kTXMl6}8_3#2%BU#i?_)}6-(>T_vpC)N<J5;X2iRlO
z``@LYM|2w&Vv1-43lSXxHIQ!rj32>nL@BIAr~_!k7|mFtV)b*y>I$rm@il>QA!Lqc
z!hu``>~9&Z?pDy(D1dG*tH)T4{n)HvK2|U*updHipN8<$1AYV7?6vq%L4T{DmrLj&
z?wL6WVCT4utPLv2hPf}Z4`pp(`_mlTcVL(K45aPD-wbOcxYrRzcpv-XZvo#2GG}(6
zY*)PaEq47$J~F4{i$98^ylAz)s@g*R%GHL`aF(36y<s}(6<#sUyI%I1uU@2S?4R~M
z|78?T`puh9(xmXBB+LX51tC=4yo!<_opjT266AvI=?Q1iS?o90PEOi8?R9r+dw06-
zp6qV6(0{lyoh~}7_Z~cY-hUq-Cg}$-j-t%#gO>I6S<5Hkmw7$vWl5YSysK<~6%ml)
z>_)Qx1szLNB-oeAeo$WC5#k7#-;rCeGm;ai&*B8<lFu}cW%H4Q{?WP9%@HwgZB?Sd
zlUU_1bQ~WC_|q}QCyK4K(QcLfQq0c0r3UV08+ztzUqzeaVotk*OXg*!rQQMi{%1C9
zu?$=u0}FcTHO~K^Ui|(4@*K1)TLvrxf1CkT-|OvlvCQd@qw0#BYrClLP`R+)OiO{F
lk#rnV(s9VMe;A_gLX|NcBWGG-1jYUk5E^V_8ThLV`~bCzDJ1{^

literal 0
HcmV?d00001

diff --git a/integrations/london-transport-integration/.gitignore b/integrations/london-transport-integration/.gitignore
new file mode 100644
index 00000000..cfaa10e9
--- /dev/null
+++ b/integrations/london-transport-integration/.gitignore
@@ -0,0 +1,8 @@
+.idea/
+*.py[cgo]
+__pycache__
+*.json
+!project.json
+dist/
+*.sqlite3
+.DS_Store
diff --git a/integrations/london-transport-integration/README.md b/integrations/london-transport-integration/README.md
new file mode 100644
index 00000000..b12a1af8
--- /dev/null
+++ b/integrations/london-transport-integration/README.md
@@ -0,0 +1,38 @@
+# uAgent London Transport Examples 
+
+This repository contains examples of london transport journey planner integrations using three agents: `tfl_agent` and `user_agent`.
+
+1. `user_agent` : This agent takes from and to location request as details from user, and responds with all possible routes with detailed plan.
+
+2. `tfl_agent`: This agent takes from and to location from user, fetches the post code using [UK PostCode API](https://rapidapi.com/search/uk%2Bpostcodes) and sends request to tfl request link with journey endpoint. https://api.tfl.gov.uk/Journey/JourneyResults/from_loc/to/to_loc. This sends all possible routes to the user agent.
+
+## Getting Started 🚀
+
+To use these agents, follow the steps below:
+
+### Step 1: Obtain API Keys 🔑
+
+Before running the agents, you need to obtain the required API keys:
+
+#### UK_POSTCODE_API
+
+1. Visit the RapidAPI website: https://rapidapi.com/search/uk%2Bpostcodes
+2. If you don't have an account, create one by signing up.
+3. Once you are logged in, click on test endpoint and register for API on free-tier.
+4. Once done you will see X-RapidAPI-Key in header parameter.
+
+### Step 2: Set API Keys and address in agent scripts
+
+1. Fill in the API Keys in the `tfl_agent` scripts.
+2. Replace the london_transport agent address in user agent's script.
+
+### Step 3: Run Project
+
+To run the project and its agents:
+
+```bash
+cd src
+python main.py
+```
+
+Now you have the agents up and running to perform london transport journey planner integrations using the provided APIs. Happy integrating! 🎉
diff --git a/integrations/london-transport-integration/project.json b/integrations/london-transport-integration/project.json
new file mode 100644
index 00000000..79c0d189
--- /dev/null
+++ b/integrations/london-transport-integration/project.json
@@ -0,0 +1,5 @@
+{
+    "title": "London Transport Journey Planner",
+    "description": "This integration helps user to plan Journey using london transport",
+    "categories":    ["London Transport", "Transport"]
+}
\ No newline at end of file
diff --git a/integrations/london-transport-integration/src/agents/tfl_agent.py b/integrations/london-transport-integration/src/agents/tfl_agent.py
new file mode 100644
index 00000000..16fbc937
--- /dev/null
+++ b/integrations/london-transport-integration/src/agents/tfl_agent.py
@@ -0,0 +1,93 @@
+# importing required libraries
+import requests
+from uagents import Agent, Model, Context, Protocol
+from uagents.setup import fund_agent_if_low
+from message.model import Response, Location
+import os
+
+
+# defining london transport angent 
+london_transport = Agent(
+    name = 'london_transport_agent',
+    port = 1123,
+    seed = 'London Transport agent secret seed phrase',
+    endpoint = 'http://localhost:1123/submit'
+)
+
+# funding london transport agent
+fund_agent_if_low(london_transport.wallet.address())
+
+# define function to get postcode from area name
+async def get_area_pincode(area_name: str):
+    api_key = 'YOUR_RAPID_API_KEY'  # Replace with your actual RapidAPI key
+    base_url = "https://uk-postcode.p.rapidapi.com/search"
+    headers = {
+        "X-RapidAPI-Host": "uk-postcode.p.rapidapi.com",
+        "X-RapidAPI-Key": api_key,
+    }
+    querystring = {"q": area_name}
+    try:
+        response = requests.get(base_url, headers=headers, params=querystring)
+        response.raise_for_status()  # Raises an HTTPError if the response was an error
+        data = response.json()
+        pinCode = data['results'][0]['postCode']
+        return pinCode
+    except (requests.RequestException, IndexError) as e:
+        print(f"Error fetching pin code for {area_name}: {e}")
+        return None
+
+# define function to get possible routes from location1 to location2
+async def get_journey_data(loc1_pin, loc2_pin):
+    try:
+        tfl_url = f"https://api.tfl.gov.uk/Journey/JourneyResults/{loc1_pin}/to/{loc2_pin}"
+        reply = requests.get(tfl_url)
+        reply.raise_for_status()  # Check for HTTP errors
+        data = reply.json()
+        return data
+    except requests.RequestException as e:
+        print(f"Error fetching journey data: {e}")
+        return None
+
+# checking user agent's address
+@london_transport.on_event('startup')
+async def agent_address(ctx: Context):
+    ctx.logger.info(london_transport.address)
+
+# Define Message handler to handle user request
+@london_transport.on_message(model = Location, replies = Response)
+async def handle_request(ctx: Context, sender: str, msg: Location):
+    # Get pin codes for the locations
+    loc1_pin = await get_area_pincode(msg.from_loc)
+    loc2_pin = await get_area_pincode(msg.to_loc)
+
+    response = ""  # Initialize an empty string to hold the response
+
+    if loc1_pin and loc2_pin:
+        # Make the initial TfL API request
+        journey_data = await get_journey_data(loc1_pin, loc2_pin)
+        for journey in journey_data['journeys']:
+            response += f"Start Time: {journey['startDateTime']}\n"
+            response += f"Duration: {journey['duration']} minutes\n"
+            response += f"Arrival Time: {journey['arrivalDateTime']}\n"
+
+            # Loop through each leg of the journey
+            for leg in journey['legs']:
+                mode = leg['mode']['name']
+                departure_time = leg['departureTime']
+                arrival_time = leg['arrivalTime']
+                distance = leg.get('distance', 'N/A')  # Some legs might not have distance information
+
+                # Append leg details to the response string
+                response += f"\nLeg Mode: {mode}\n"
+                response += f"Departure Time: {departure_time}\n"
+                response += f"Arrival Time: {arrival_time}\n"
+                response += f"Distance: {distance} meters\n"
+
+                # Instruction details if available
+                if 'instruction' in leg:
+                    instruction_summary = leg['instruction']['summary']
+                    response += f"Instructions: {instruction_summary}\n"
+                
+            response += "\n--------------------------------\n"
+    # Sending back response to user agent
+    await ctx.send(sender, Response(response = response))
diff --git a/integrations/london-transport-integration/src/agents/user.py b/integrations/london-transport-integration/src/agents/user.py
new file mode 100644
index 00000000..6975ee20
--- /dev/null
+++ b/integrations/london-transport-integration/src/agents/user.py
@@ -0,0 +1,38 @@
+# import required libraries
+from uagents import Agent, Context
+from uagents.setup import fund_agent_if_low
+from message.model import Response, Location
+import os
+ 
+# restuarant agent's address
+londonTransportAgent = "YOUR_TRANSPORT_AGENT_ADDRESS" # replace with your london transport agent
+
+# defining user agent
+user = Agent(
+    name="user",
+    port=8000,
+    seed="user secret phrase",
+    endpoint=["http://localhost:8000/submit"],
+)
+ 
+ #funding user agent
+fund_agent_if_low(user.wallet.address())
+ 
+#checking user agent's address
+@user.on_event('startup')
+async def agent_address(ctx: Context):
+    ctx.logger.info(user.address)
+ 
+# This on_interval agent function performs a request on a defined period of 100 seconds
+@user.on_interval(period=100.0, messages=Location)
+async def interval(ctx: Context):
+    #taking input for city and category from user
+    from_loc = str(input('From where you want to travel using london transport?'))
+    to_loc = str(input('To where you want to travel using london transport?'))  
+    await ctx.send(londonTransportAgent, Location(from_loc = from_loc, to_loc = to_loc))
+
+#Logging response from Business finder agent
+@user.on_message(Response)
+async def handle_query_response(ctx: Context, sender: str, msg: Response):
+    ctx.logger.info(msg.response)
+ 
\ No newline at end of file
diff --git a/integrations/london-transport-integration/src/main.py b/integrations/london-transport-integration/src/main.py
new file mode 100644
index 00000000..dba1081d
--- /dev/null
+++ b/integrations/london-transport-integration/src/main.py
@@ -0,0 +1,10 @@
+from agents.tfl_agent import london_transport
+from agents.user import user
+from uagents import Bureau
+
+#adding all users to bureau and running it
+if __name__ == "__main__":
+    bureau = Bureau(endpoint="http://127.0.0.1:8000/submit", port=8000)
+    bureau.add(london_transport)
+    bureau.add(user)
+    bureau.run()
\ No newline at end of file
diff --git a/integrations/london-transport-integration/src/message/model.py b/integrations/london-transport-integration/src/message/model.py
new file mode 100644
index 00000000..dceebb21
--- /dev/null
+++ b/integrations/london-transport-integration/src/message/model.py
@@ -0,0 +1,11 @@
+# Importing model from uagents libraru
+from uagents import Model
+
+# defining model to take input form user
+class Location(Model):
+    from_loc : str
+    to_loc : str
+
+# defining model to give response to user.
+class Response(Model):
+    response : str
\ No newline at end of file