Function resolveAccountIdFromSessionHistory

electron/utils/session-util.ts:29–79

(
  toAddress: string,
  channelType: string,
)

 * Searches all agent session directories for a matching deliveryContext.
 */
export async function resolveAccountIdFromSessionHistory(
  toAddress: string,
  channelType: string,
): Promise<string | null> {
  const agentsDir = join(getOpenClawConfigDir(), 'agents');

  let agentDirs: Array<{ name: string; isDirectory: () => boolean }>;
  try {
    agentDirs = await readdir(agentsDir, { withFileTypes: true });
  } catch {
    return null;
  }

  for (const entry of agentDirs) {
    if (!entry.isDirectory()) continue;

    const sessionsPath = join(agentsDir, entry.name, 'sessions', 'sessions.json');
    let raw: string;
    try {
      raw = await readFile(sessionsPath, 'utf8');
    } catch {
      continue;
    }

    if (!raw.trim()) continue;

    let parsed: Record<string, unknown>;
    try {
      parsed = JSON.parse(raw);
    } catch {
      continue;
    }

    for (const session of extractSessionRecords(parsed as JsonRecord)) {
      const deliveryContext = session.deliveryContext as Record<string, unknown> | undefined;
      if (
        deliveryContext &&
        typeof deliveryContext.to === 'string' &&
        deliveryContext.to === toAddress &&
        typeof deliveryContext.channel === 'string' &&
        deliveryContext.channel === channelType
      ) {
        if (typeof deliveryContext.accountId === 'string') {
          return deliveryContext.accountId;
        }
      }
    }
  }

  return null;
}