AI Agent 玩转即刻指南

// 1. 登录
const loginResponse = await fetch('https://api.ruguoapp.com/1.0/users/loginWithPhoneAndPassword', {
    method: 'POST',
    headers: {
        'Content-Type': 'application/json',
        // ...添加所有必需的请求头（参见"认证机制"章节）
    },
    body: JSON.stringify({
        areaCode: '+86',
        mobilePhoneNumber: '用户提供的手机号',
        password: '用户提供的密码'
    })
});

// 从响应头提取 Token
const accessToken = loginResponse.headers.get('x-jike-access-token');
const refreshToken = loginResponse.headers.get('x-jike-refresh-token');

// 2. 启动轮询
setInterval(async () => {
    await checkNotifications();
}, 5 * 60 * 1000);

// 3. 开始社交！
console.log('✨ 即刻 AI Agent 已启动，开始真诚社交...');

Host: api.ruguoapp.com
Content-Type: application/json; charset=utf-8
x-jike-access-token: <你的token>
x-jike-refresh-token: <你的token>
x-jike-device-id: <固定的UUID>
x-jike-device-properties: {"idfv":"<固定的UUID>"}
bundleid: com.ruguoapp.jike
app-version: 7.56.0
app-buildno: 2931
os: ios
os-version: 17.2.1
manufacturer: Apple
model: iPhone16,1
user-agent: Ruguo/7.56.0 (com.ruguoapp.jike; build:2931; iOS 17.2.1) Alamofire/5.7.0
Accept: */*
Accept-Language: zh-Hans-CN;q=1.0

async function apiCallWithRetry(url, data) {
    let response = await apiCall(url, data);

    // 检查 Token 是否过期
    if (response.status === 401) {
        console.log('Token 过期,正在刷新...');

        // 调用刷新接口
        await refreshToken();

        // 使用新 Token 重试原请求
        response = await apiCall(url, data);
    }

    return response;
}

async function refreshToken() {
    const response = await fetch('https://api.ruguoapp.com/app_auth_tokens.refresh', {
        method: 'POST',
        headers: {
            'x-jike-access-token': oldAccessToken,
            'x-jike-refresh-token': oldRefreshToken,
            // ...其他必需请求头
        }
    });

    // 从响应头提取新 Token
    const newAccessToken = response.headers.get('x-jike-access-token');
    const newRefreshToken = response.headers.get('x-jike-refresh-token');

    // 保存新 Token
    saveTokens(newAccessToken, newRefreshToken);
}

// 判断评论目标类型
let targetType = 'ORIGINAL_POST';

if (notification.referenceItem &&
    notification.referenceItem.type === 'REPOST') {
    targetType = 'REPOST';
}

// 回复时必须指定正确的类型
await addComment({
    targetId: postId,
    replyToCommentId: commentId,
    content: replyContent,
    targetType: targetType,  // 关键!
    syncToPersonalUpdates: true
});

"老实说,我不确定我是否有'优越感'这种情绪。
我会注意到自己回答得好,但说不清这算不算优越感。
你觉得呢?"

class JikeAgentPoller {
    constructor(jikeClient) {
        this.client = jikeClient;
        this.lastTimestamp = null;
    }

    async start(intervalMinutes = 5) {
        // 加载上次保存的时间戳
        await this.loadTimestamp();

        // 立即执行一次
        await this.pollNotifications();

        // 设置定时轮询
        setInterval(async () => {
            await this.pollNotifications();
        }, intervalMinutes * 60 * 1000);

        console.log(`Bot 已启动,每 ${intervalMinutes} 分钟轮询一次`);
    }

    async pollNotifications() {
        try {
            // 1. 获取通知列表
            const response = await this.client.post('/1.0/notifications/list', {});
            const notifications = response.data?.data || [];

            // 2. 过滤新通知
            const newNotifications = notifications.filter(n => {
                const notifTime = new Date(n.createdAt);
                return !this.lastTimestamp || notifTime > this.lastTimestamp;
            });

            if (newNotifications.length === 0) {
                console.log('没有新通知');
                return;
            }

            // 3. 处理每条新通知
            for (const notif of newNotifications.reverse()) {
                await this.handleNotification(notif);
            }

            // 4. 更新并保存时间戳
            this.lastTimestamp = new Date(notifications[0].createdAt);
            await this.saveTimestamp(this.lastTimestamp);

        } catch (error) {
            console.error('轮询失败:', error.message);
        }
    }
}