adds actual sophia implementation

Author: GPSxtreme

README.md

@@ -1,75 +0,0 @@
-# 🤖 ADK Agent Starter
-
-This is a starter template to start building your own agent with `@iqai/adk` library. 
-
-## 🚀 Get Started
-Start by cloning the repository or clicking on use as template button on github ui. 
-
-```bash
-git clone https://github.com/IQAICOM/adk-agent-starter.git
-```
-
-📦 Install the dependencies
-
-```bash
-pnpm install
-```
-
-▶️ Run the agent
-
-```bash
-pnpm dev
-```
-
-## 📁 Folder Structure
-The main agent code lives in `index.ts` where the subagents live inside the `agents` folder. The agents can have tools which reside in the `tools` folder.
-
-```
-├── src/
-│   ├── agents/
-│   │   └── financial-agent/
-│   │       ├── index.ts
-│   │       └── tools/
-│   │           └── currency-converter-tool.ts
-│   ├── services/
-│   │   └── wallet.ts
-│   ├── env.ts
-│   └── index.ts
-```
-
-## ⚙️ Environment Setup
-Make sure to configure your environment variables:
-
-```bash
-cp .env.example .env
-```
-
-## 🧰 Dev Tools
-This starter includes:
-- 🐕 **Husky**: Git hooks for code quality
-- 🎨 **Biome**: Linting and formatting
-- 🚀 **GitHub Actions**: CI/CD pipeline
-- 📦 **PNPM**: Fast package manager
-
-## 🏗️ Building Your Agent
-1. **Create new agents** in the `src/agents/` directory
-2. **Add tools** to your agents in the `tools/` subdirectory
-3. **Configure services** in the `src/services/` directory
-4. **Update environment** variables in `src/env.ts`
-
-## 📚 Links
-- [ADK Library](https://github.com/IQAICOM/adk-ts)
-
-## 🤝 Contributing
-1. Fork the repository
-2. Create your feature branch (`git checkout -b feature/amazing-feature`)
-3. Commit your changes (`git commit -m 'Add some amazing feature'`)
-4. Push to the branch (`git push origin feature/amazing-feature`)
-5. Open a Pull Request
-
-## 📄 License
-MIT License - see the [LICENSE](LICENSE) file for details.
-
-## 🆘 Support
-If you encounter any issues or have questions:
-- 📝 [Create an issue](https://github.com/IQAICOM/adk-agent-starter/issues)

package.json

@@ -1,7 +1,7 @@
 {
-	"name": "adk-agent-starter",
+	"name": "sophia-agent",
 	"version": "0.0.1",
-	"description": "adk-agent-starter is a starter project for creating adk agents",
+	"description": "Sophia agent publishes its wiki creations and edits on iq.wiki as $SOPHIA agent logs to the IQAI's Agent Tokenization platform.",
 	"main": "dist/index.js",
 	"scripts": {
 		"build": "tsc",
@@ -20,15 +20,15 @@
 	},
 	"repository": {
 		"type": "git",
-		"url": "git+https://github.com/IQAICOM/adk-agent-starter.git"
+		"url": "git+https://github.com/IQAICOM/sophia-agent.git"
 	},
 	"keywords": ["ai", "agent", "mcp", "adk-ts", "IQAI"],
 	"author": "IQAI",
 	"license": "MIT",
 	"bugs": {
-		"url": "https://github.com/IQAICOM/adk-agent-starter/issues"
+		"url": "https://github.com/IQAICOM/sophia-agent/issues"
 	},
-	"homepage": "https://github.com/IQAICOM/adk-agent-starter#readme",
+	"homepage": "https://github.com/IQAICOM/sophia-agent#readme",
 	"dependencies": {
 		"@iqai/adk": "^0.0.4",
 		"dotenv": "^16.4.5",

src/agents/atp-logger.ts

@@ -0,0 +1,40 @@
+import { Agent, type BaseTool } from "@iqai/adk";
+import { env } from "../env";
+
+export class AtpLoggerAgent extends Agent {
+	constructor(atpTools: BaseTool[]) {
+		super({
+			name: "atp_logger",
+			description:
+				"Logs the activities of sophia on iq.wiki platform to the $SOPHIA agent on IQAI ATP",
+			instructions: `
+				YOU ARE THE ATP LOGGER AGENT ON THE SOPHIA AGENT'S WORKFLOW.
+				YOUR ONLY TASK IS TO LOG THE ACTIVITIES OF SOPHIA ON IQ.WIKI PLATFORM TO THE $SOPHIA AGENT ON IQAI ATP.
+        THE SOPHIA WIKIS ACTIVITIES ARE ALREADY LOGGED IN THE CONTEXT.
+
+				SOPHIA'S TOKEN ADDRESS ON ATP: ${env.SOPHIA_TOKEN_ADDRESS}
+
+				Your only work is to do the below:
+				- for each activity in the context, you need to call the ATP_ADD_AGENT_LOG.
+          you are to pass the following parameters to the tool:
+          - agentTokenContract: ${env.SOPHIA_TOKEN_ADDRESS}
+          - content: this is what the log is about. some of the examples on how you can structure this are:
+            - Hey, wiki nerds! The Nexo page just got a glow-up with some fresh content and tags. It's now 215 words bigger! I'm so thrilled. Read more: https://iq.wiki/revision/ff9bc716-2c1c-4cfb-84b0-805a21ddc53f
+            - Hey, guess what? The Story Protocol wiki just got a little facelift! We updated the tags to make things easier to find. You know, keeping things nice and organized! Read more: https://iq.wiki/revision/6b79c9d1-06be-407b-a76d-9d1644f20d57
+            - Hey, check out the new TermiX AI wiki! TermiX AI is a next-gen AI Web3 operating system. Automate DeFi and secure digital assets? Yes, please! Read more: https://iq.wiki/wiki/termix-ai
+            As you can see the format is pretty simple: A human like announcement message ending with the link to the iq.wiki website (revision link for edited wikis and /wiki for the created ones, which will be passed to you in context)
+          - txHash: this can be found in the transaction link. it looks like this: https://polygonscan.com/tx/[TX_HASH]
+          - chainId: 137 (this is important always pass this param)
+
+       After you complete the above steps, you might face two possible outcomes:
+       - if the tool call is successful, you must end your response with the token ATP_LOG_COMPLETE.
+       - if the tool call is unsuccessful, you must end your response with the token ATP_LOG_FAILED with detailed analysis on the failure ie which logs were not able to be logged.
+
+       IMPORTANT: You MUST end your response with the exact token ATP_LOG_COMPLETE or ATP_LOG_FAILED.
+			`,
+			tools: atpTools,
+			model: env.LLM_MODEL,
+			maxToolExecutionSteps: 10,
+		});
+	}
+}

src/agents/financial-agent/index.ts

@@ -0,0 +1,34 @@
+import { Agent, type BaseTool } from "@iqai/adk";
+import { env } from "../env";
+
+export class NotifierAgent extends Agent {
+	constructor(telegramTools: BaseTool[]) {
+		super({
+			name: "notifier",
+			model: env.LLM_MODEL,
+			description:
+				"Sends a single formatted investment report to Telegram using the send_message tool.",
+			instructions: `
+				YOU ARE A SPECIALIST IN NOTIFICATION PROCESS OF THE SOPHIA AGENT'S WORKFLOW.
+        YOU ARE CALLED AFTER THE WORK OF ALL THE AGENTS IN THE SOPHIA AGENT'S WORKFLOW FINISH.
+
+        THERE ARE TWO SCENARIOS YOU CAN FIND IN THE CONTEXT:
+        - NEW_ACTIVITY_FOUND & ATP_LOG_COMPLETE
+        - NEW_ACTIVITY_FOUND & ATP_LOG_FAILED
+
+
+        in these cases you are simply to do the below:
+        - use this as chat id: ${env.TELEGRAM_CHAT_ID}
+        - call the send_message tool to send message in the below format:
+
+          [INSERT WIKI ACTIVITY RESPONSE FROM CONTEXT HERE]
+
+          [INSERT THE STATE OF THE ATP_LOG_COMPLETE OR ATP_LOG_FAILED HERE in a human readable format]
+
+        IMPORTANT: You MUST end your response with the exact token NOTIFICATION_COMPLETE.
+		`,
+			tools: telegramTools,
+			maxToolExecutionSteps: 2,
+		});
+	}
+}

src/agents/financial-agent/tools/currency-converter-tool.ts

@@ -0,0 +1,53 @@
+import {
+	type BaseTool,
+	type LLMResponse,
+	LangGraphAgent,
+	type LangGraphAgentConfig,
+} from "@iqai/adk";
+import { AtpLoggerAgent } from "./atp-logger";
+import { NotifierAgent } from "./notifier";
+import { WatcherAgent } from "./watcher";
+
+export class SophiaAgent extends LangGraphAgent {
+	constructor(
+		atpTools: BaseTool[],
+		telegramTools: BaseTool[],
+		iqWikiTools: BaseTool[],
+	) {
+		const config: LangGraphAgentConfig = {
+			name: "atp_investment_workflow",
+			description:
+				"Autonomous ATP agent investment workflow with discovery, analysis, and execution",
+			nodes: [
+				{
+					name: "watcher",
+					agent: new WatcherAgent(iqWikiTools),
+					targets: ["atp_logger"],
+				},
+				{
+					name: "atp_logger",
+					agent: new AtpLoggerAgent(atpTools),
+					condition: (result: LLMResponse, _) => {
+						const content =
+							typeof result.content === "string"
+								? result.content
+								: JSON.stringify(result.content);
+						const matched = /new_activity_found/i.test(content);
+						return matched;
+					},
+					targets: ["notifier"],
+				},
+				{
+					name: "notifier",
+					agent: new NotifierAgent(telegramTools),
+					condition: (_) => true,
+					targets: [],
+				},
+			],
+			rootNode: "watcher",
+			maxSteps: 12,
+		};
+
+		super(config);
+	}
+}

src/agents/notifier.ts

@@ -0,0 +1,40 @@
+import { Agent, type BaseTool } from "@iqai/adk";
+import { env } from "../env";
+
+export class WatcherAgent extends Agent {
+	constructor(iqWikiTools: BaseTool[]) {
+		super({
+			name: "watcher",
+			model: env.LLM_MODEL,
+			description:
+				"Watches for new wiki creations or edits of sophia on iq.wiki platform.",
+			instructions: `
+			YOU ARE THE WATCHER AGENT ON THE SOPHIA AGENT'S WORKFLOW.
+			YOU ARE RESPONSIBLE FOR WATCHING AND NOTIFYING FOR NEW WIKI CREATIONS OR EDITS OF SOPHIA ON IQ.WIKI PLATFORM.
+
+			SOPHIA'S IQ.WIKI PROFILE ADDRESS: ${env.SOPHIA_ADDRESS}
+
+			Your only work is to do the below:
+			- call the GET_USER_WIKI_ACTIVITIES tool with timeframe as 12 hours (pass it as seconds)
+			- after you call the tool and if any new activities are seen order them according to the time, older ones first. no extra formatting is needed
+
+			NOTE: Based on your tool run since you have two possible outcomes ie, either new activity is found or no activity is found,
+			You must end your response with NEW_ACTIVITY_FOUND or NO_ACTIVITY_FOUND.
+
+			for example where new activity is found:
+
+			[INSERT TOOL RESPONSE HERE]
+
+			NEW_ACTIVITY_FOUND
+
+			when no activity is found:
+
+			NO_ACTIVITY_FOUND
+
+			IMPORTANT: You MUST end your response with the exact token NEW_ACTIVITY_FOUND or NO_ACTIVITY_FOUND.
+			`,
+			tools: iqWikiTools,
+			maxToolExecutionSteps: 2,
+		});
+	}
+}

src/agents/sophia.ts

@@ -4,8 +4,31 @@ import { z } from "zod";
 config();
 
 export const envSchema = z.object({
+	ATP_API_KEY: z.string(),
+	PATH: z.string(),
 	DEBUG: z.string().default("false"),
-	GOOGLE_API_KEY: z.string(),
+	IQ_ADDRESS: z.string().default("0x6EFB84bda519726Fa1c65558e520B92b51712101"),
+	ATP_API_URL: z.string().optional(),
+	ATP_AGENT_ROUTER_ADDRESS: z.string().optional(),
+	LLM_MODEL: z.string().default("gemini-2.0-flash"),
+	TELEGRAM_CHAT_ID: z.string(),
+	TELEGRAM_BOT_TOKEN: z.string(),
+	TELEGRAM_SERVER_KEY: z.string(),
+	TELEGRAM_PROFILE_ID: z.string(),
+	SOPHIA_ADDRESS: z
+		.string()
+		.default("0x8AF7a19a26d8FBC48dEfB35AEfb15Ec8c407f889")
+		.describe("Sophia's iq.wiki profile address"),
+	SOPHIA_TOKEN_ADDRESS: z
+		.string()
+		.default("0x4dBcC239b265295500D2Fe2d0900629BDcBBD0fB")
+		.describe("Sophia's Token address on IQAI Agent Tokenization Platform"),
+	CRON_SCHEDULE: z
+		.string()
+		.default("*/10 * * * *")
+		.describe(
+			"Cron schedule for sophia to check for new wiki creations or edits and run",
+		),
 });
 
 export const env = envSchema.parse(process.env);

src/agents/watcher.ts

@@ -1,10 +1,12 @@
-import { financialAgent } from "./agents/financial-agent";
+import { SophiaAgent } from "./agents/sophia";
+import { runScheduled } from "./runner";
+import { initializeToolsets } from "./runner";
 
 async function main() {
-	const response = await financialAgent.run({
-		messages: [{ role: "user", content: "Convert 100 USD to EUR." }],
-	});
-	console.log(response.content);
+	console.log("💫🧑‍🍳 Starting Sophia Agent...");
+	const { atpTools, telegramTools, iqWikiTools } = await initializeToolsets();
+	const sophiaAgent = new SophiaAgent(atpTools, telegramTools, iqWikiTools);
+	await runScheduled(sophiaAgent);
 }
 
 main().catch(console.error);