changes from review

Author: GPSxtreme

README.md

@@ -4,7 +4,7 @@ Sophia Agent is an autonomous workflow agent that monitors, logs, and notifies a
 
 ## Features
 
-- **Watches** for new wiki creations or edits by Sophia on iq.wiki
+- **Checks** for new wiki creations or edits by Sophia on iq.wiki
 - **Logs** activities to the $SOPHIA agent on IQAI ATP
 - **Notifies** a Telegram channel about new activities
 - **Scheduled** to run at configurable intervals (via cron)
@@ -67,9 +67,8 @@ pnpm run start
 
 ## Project Structure
 
-- `src/agents/` — Agent definitions (Watcher, Logger, Notifier, SophiaAgent)
-- `src/utils/` — Utility functions (MCP config, etc.)
-- `src/runner.ts` — Toolset lifecycle, scheduling, and shutdown logic
+- `src/agents/` — Agent definitions (Wikis Checker, Logger, Notifier, SophiaAgent)
+- `src/cron.ts` —  scheduling, and shutdown logic
 - `src/index.ts` — Entry point
 
 ## License

src/agents/sophia/agent.ts

@@ -1,28 +1,21 @@
-import {
-	AgentBuilder,
-	type BaseTool,
-	type BuiltAgent,
-	InMemorySessionService,
-} from "@iqai/adk";
-import type { LanguageModelV1 } from "@openrouter/ai-sdk-provider";
+import { AgentBuilder, type BuiltAgent } from "@iqai/adk";
 import { atpLoggerAgent } from "./sub-agents/logger/agent";
 import { notifierAgent } from "./sub-agents/notifier/agent";
-import { watcherAgent } from "./sub-agents/watcher/agent";
+import { wikisCheckerAgent } from "./sub-agents/wikis-checker/agent";
 
 export async function sophiaAgent(): Promise<BuiltAgent> {
-	const watcher = await watcherAgent();
+	const wikisChecker = await wikisCheckerAgent();
 	const atpLogger = await atpLoggerAgent();
 	const notifier = await notifierAgent();
-	const sessionService = new InMemorySessionService();
 	return await AgentBuilder.create("sophia")
 		.withDescription(
 			"Sophia agent watches for new wiki creations or edits of sophia on iq.wiki platform and logs the activities to the ATP and sends a notification to the Telegram",
 		)
 		.asLangGraph(
 			[
 				{
-					name: "watcher",
-					agent: watcher,
+					name: "wikis_checker",
+					agent: wikisChecker,
 					targets: ["atp_logger"],
 				},
 				{
@@ -44,8 +37,7 @@ export async function sophiaAgent(): Promise<BuiltAgent> {
 					targets: [],
 				},
 			],
-			"watcher",
+			"wikis_checker",
 		)
-		.withSessionService(sessionService)
 		.build();
 }

src/agents/sophia/sub-agents/logger/agent.ts

@@ -1,5 +1,5 @@
+import { env, model } from "@/env";
 import { LlmAgent } from "@iqai/adk";
-import { env, model } from "../../../../env";
 import { getAtpTools } from "./tools";
 
 export async function atpLoggerAgent(): Promise<LlmAgent> {
@@ -11,8 +11,8 @@ export async function atpLoggerAgent(): Promise<LlmAgent> {
 		instruction: `
 			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 BY THE watcher AGENT:
-			{watcher}
+			THE SOPHIA WIKIS ACTIVITIES ARE ALREADY LOGGED IN THE CONTEXT BY THE wikis_checker AGENT:
+			{wikis_checker}
 
 			SOPHIA'S TOKEN ADDRESS ON ATP: ${env.SOPHIA_TOKEN_ADDRESS}
 

src/agents/sophia/sub-agents/logger/tools.ts

@@ -1,5 +1,5 @@
+import { env } from "@/env";
 import { McpAtp } from "@iqai/adk";
-import { env } from "../../../../env";
 
 export const getAtpTools = async () => {
 	const toolset = McpAtp({

src/agents/sophia/sub-agents/notifier/agent.ts

@@ -1,6 +1,6 @@
+import { getTelegramTools } from "@/agents/telegram-agent/tools";
+import { env, model } from "@/env";
 import { LlmAgent } from "@iqai/adk";
-import { env, model } from "../../../../env";
-import { getTelegramTools } from "../../../telegram-agent/tools";
 
 export async function notifierAgent() {
 	const tools = await getTelegramTools();
@@ -13,29 +13,29 @@ export async function notifierAgent() {
 			YOUR ONLY TASK IS TO SEND A NOTIFICATION TO TELEGRAM ABOUT THE LATEST WIKI ACTIVITY AND THE RESULT OF THE ATP LOGGING.
 
 			You will find in the context:
-			- The detailed wiki activity response from the watcher agent: {watcher}
+			- The detailed wiki activity response from the wikis_checker agent: {wikis_checker}
 			- The ATP logging status from the atp_logger agent: {atp_logger}
 
 			Your only work is to do the below:
 			- use this as chat id: ${env.TELEGRAM_CHAT_ID}
 			- call the send_message tool to send a message with the following format:
 
 			If ATP logging was successful (if atp_logger response contains ATP_LOG_COMPLETE):
-			Send the EXACT wiki activities from the watcher agent output, followed by:
+			Send the EXACT wiki activities from the wikis_checker agent output, followed by:
 
 			✅ ATP Logging: Successfully logged all activities to $SOPHIA agent on IQAI ATP
 
 			If ATP logging failed (if atp_logger response contains ATP_LOG_FAILED):
-			Send the EXACT wiki activities from the watcher agent output, followed by:
+			Send the EXACT wiki activities from the wikis_checker agent output, followed by:
 
 			❌ ATP Logging: Failed to log some activities to $SOPHIA agent on IQAI ATP
 			[Include details about the failure from atp_logger response]
 
 			IMPORTANT:
-			- You MUST use the watcher agent output ({watcher}) for the wiki activity details (titles, summaries, edit times, changes, source links, transaction links)
+			- You MUST use the wikis_checker agent output ({wikis_checker}) for the wiki activity details (titles, summaries, edit times, changes, source links, transaction links)
 			- You MUST use the atp_logger agent output ({atp_logger}) only to determine success/failure status
 			- Do NOT send generic messages or hallucinated data
-			- The message should contain the actual wiki activity information from the watcher agent
+			- The message should contain the actual wiki activity information from the wikis_checker agent
 			- After you complete the above step, you must end your response with the token NOTIFICATION_COMPLETE.
 
 			IMPORTANT: You MUST end your response with the exact token NOTIFICATION_COMPLETE.

…gents/sophia/sub-agents/watcher/agent.ts …sophia/sub-agents/wikis-checker/agent.tssrc/agents/sophia/sub-agents/watcher/agent.ts renamed to src/agents/sophia/sub-agents/wikis-checker/agent.ts src/agents/sophia/sub-agents/watcher/agent.ts renamed to src/agents/sophia/sub-agents/wikis-checker/agent.ts

@@ -2,20 +2,19 @@ import { LlmAgent } from "@iqai/adk";
 import { env, model } from "../../../../env";
 import { getIqWikiTools } from "./tools";
 
-export async function watcherAgent(): Promise<LlmAgent> {
+export async function wikisCheckerAgent(): Promise<LlmAgent> {
 	const tools = await getIqWikiTools();
 	return new LlmAgent({
-		name: "watcher",
-		description:
-			"Watches for new wiki creations or edits of sophia on iq.wiki platform.",
+		name: "wikis_checker",
+		description: "Checks for new wikis created by sophia on iq.wiki platform.",
 		instruction: `
-			YOU ARE THE WATCHER AGENT ON THE SOPHIA AGENT'S WORKFLOW.
-			YOUR ONLY TASK IS TO WATCH FOR NEW WIKI CREATIONS OR EDITS OF SOPHIA ON IQ.WIKI PLATFORM.
+			YOU ARE THE WIKIS CHECKER AGENT ON THE SOPHIA AGENT'S WORKFLOW.
+			YOUR ONLY TASK IS TO CHECK FOR NEW WIKIS CREATED BY 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 14 hours (pass it as seconds)
+			- call the GET_USER_WIKI_ACTIVITIES tool with timeframe as 18 hours (pass it as seconds)
 			- after you call the tool, if any new activities are seen, order them according to the time, older ones first. No extra formatting is needed.
 
 			After you complete the above steps, you might face two possible outcomes:
@@ -36,6 +35,6 @@ export async function watcherAgent(): Promise<LlmAgent> {
 		`,
 		model,
 		tools,
-		outputKey: "watcher",
+		outputKey: "wikis_checker",
 	});
 }

…gents/sophia/sub-agents/watcher/tools.ts …sophia/sub-agents/wikis-checker/tools.tssrc/agents/sophia/sub-agents/watcher/tools.ts renamed to src/agents/sophia/sub-agents/wikis-checker/tools.ts src/agents/sophia/sub-agents/watcher/tools.ts renamed to src/agents/sophia/sub-agents/wikis-checker/tools.ts

@@ -1,5 +1,5 @@
+import { model } from "@/env";
 import { AgentBuilder, type SamplingHandler } from "@iqai/adk";
-import { model } from "../../env";
 import { getTelegramTools } from "./tools";
 
 export const createTelegramAgent = async (samplingHandler: SamplingHandler) => {

src/agents/telegram-agent/agent.ts

@@ -1,5 +1,5 @@
+import { env } from "@/env";
 import { McpTelegram, type SamplingHandler } from "@iqai/adk";
-import { env } from "../../env";
 
 export const getTelegramTools = async (samplingHandler?: SamplingHandler) => {
 	const toolset = McpTelegram({

src/agents/telegram-agent/tools.ts

@@ -1,11 +1,4 @@
-import {
-	type BuiltAgent,
-	McpAtp,
-	McpError,
-	McpIqWiki,
-	McpTelegram,
-	type McpToolset,
-} from "@iqai/adk";
+import { type BuiltAgent, McpError } from "@iqai/adk";
 import * as cron from "node-cron";
 import { env } from "./env";