Refactoring examples so that journey is "clear" (#60)

* hard cuts and refactor

* numbering

* minor reorder

Author: devjsc

…examples_existing/01-first-agent/main.py 1-uagents/01-first-agent/main.py1-uagents/examples_existing/01-first-agent/main.py renamed to 1-uagents/01-first-agent/main.py 1-uagents/examples_existing/01-first-agent/main.py renamed to 1-uagents/01-first-agent/main.py

@@ -0,0 +1,31 @@
+import random
+from uagents import Agent, Bureau, Context, Model
+
+# Define telemetry model
+class Telemetry(Model):
+    temperature: float
+    vibration: float
+
+# Define response model
+class RepairResponse(Model):
+    status: str
+
+agent = Agent(name="machinery",
+              seed="machinery seed phrase 09dkkefneff_93",
+              port=8000,
+              endpoint=["http://localhost:8000/submit"])
+
+
+# Machinery Agent (Sends telemetry data)
+@agent.on_interval(period=20.0)  # Sends telemetry every 20 seconds
+async def send_telemetry(ctx: Context):
+    telemetry = Telemetry(
+        temperature=random.uniform(20, 100),
+        vibration=random.uniform(0, 10)
+    )
+    await ctx.send('agent1qvk2ppctpjjj7ev6afdze3raup304pz7sc77sf6fk7h7n4uuexktx3t0der', telemetry)
+    ctx.logger.info(f"Sent Telemetry: {telemetry}")
+
+@agent.on_message(model=RepairResponse)
+async def handle_repair(ctx: Context, sender: str, msg: RepairResponse):
+    ctx.logger.info(f"Received repair info from {sender}: {msg.dict()}")

…amples_existing/02-interval-task/main.py 1-uagents/02-interval-task/main.py1-uagents/examples_existing/02-interval-task/main.py renamed to 1-uagents/02-interval-task/main.py 1-uagents/examples_existing/02-interval-task/main.py renamed to 1-uagents/02-interval-task/main.py

@@ -0,0 +1,34 @@
+import random
+from uagents import Agent, Bureau, Context, Model
+
+# Define telemetry model
+class Telemetry(Model):
+    temperature: float
+    vibration: float
+
+# Define repair request model
+class RepairRequest(Model):
+    issue: str
+    value: float
+
+agent = Agent(name="monitor",
+              seed="monitor seed phrase piwefgp99_iwefpie",
+              port=8001,
+              endpoint=["http://localhost:8001/submit"])
+
+# Monitor Agent (Applies threshold rules to check anomalies)
+@agent.on_message(model=Telemetry)
+async def analyze_telemetry(ctx: Context, sender: str, msg: Telemetry):
+    ctx.logger.info(f"Received telemetry from {sender}: {msg}")
+    if msg.temperature > 80:
+        request = RepairRequest(issue="High Temperature", value=msg.temperature)
+        await ctx.send('agent1qt5k53m7p3qt6kshx46g8jgg4drr8dczrgvkt5xuyl303scclmxuv4556sw', request)
+        await ctx.send(sender, request)  # Notify sender
+        ctx.logger.info(f"High Temp! Sent repair request: {request} to 'agent1qt5k53m7p3qt6kshx46g8jgg4drr8dczrgvkt5xuyl303scclmxuv4556sw' and {sender}")
+    elif msg.vibration > 7:
+        request = RepairRequest(issue="High Vibration", value=msg.vibration)
+        await ctx.send('agent1qt5k53m7p3qt6kshx46g8jgg4drr8dczrgvkt5xuyl303scclmxuv4556sw', request)
+        await ctx.send(sender, request)  # Notify sender
+        ctx.logger.info(f"High Vibration! Sent repair request: {request} to 'agent1qt5k53m7p3qt6kshx46g8jgg4drr8dczrgvkt5xuyl303scclmxuv4556sw' and {sender}")
+    else:
+        ctx.logger.info("Telemetry Normal")

1-uagents/03-multi-agent-communication/machinery.py

@@ -0,0 +1,25 @@
+from uagents import Agent, Bureau, Context, Model
+
+# Define response model
+class RepairResponse(Model):
+    status: str
+
+# Define repair request model
+class RepairRequest(Model):
+    issue: str
+    value: float
+
+
+
+agent = Agent(name="repairer",
+              seed="repairer seed phrase ouweufweif_838383",
+              port=8002,
+              endpoint=["http://localhost:8002/submit"])
+
+# Repairer Agent (Handles repair requests)
+@agent.on_message(model=RepairRequest)
+async def handle_repair(ctx: Context, sender: str, msg: RepairRequest):
+    ctx.logger.info(f"Received repair request from {sender}: {msg}")
+    response = RepairResponse(status=f"Repair initiated for {msg.issue}")
+    await ctx.send('agent1q0samncsypdkf5tp0kh7r2ep233vt79uerk50jlgxpnt3d5mhcw6ywjastg', response)
+    ctx.logger.info(f"Sent repair response to 'agent1q0samncsypdkf5tp0kh7r2ep233vt79uerk50jlgxpnt3d5mhcw6ywjastg': {response}")