ragflow_sender_test.ts

import axios from 'axios';

const gRagApiUrl = "http://demo.ragflow.io/v1/api/";
const gRagUserId = "YourUserIdHere";
const gRagApiToken = "ragflow-Q1N2EwYzdlODdkODExZWZhOTAxNDIwMT";

// Function to send data to Ragflow
export async function sendToRagflow(data: { tokenId: string, steps: any, heartRate: any, oxygen: any }) {
    // Create a detailed question with structured data         Sleep analysis: ${JSON.stringify(data.sleep)}.
    const question = `
        You are an AI analyzing health data for tokenId ${data.tokenId}.//

        Steps analysis: ${JSON.stringify(data.steps)}.
        Heart rate analysis: ${JSON.stringify(data.heartRate)}.
        Oxygen level analysis: ${JSON.stringify(data.oxygen)}.
        Please provide suggestions based on this health data.
    `;

    try {
        // Create a new conversation
        const url_new = `${gRagApiUrl}/new_conversation?user_id=${gRagUserId}`;
        const headers = { Authorization: `Bearer ${gRagApiToken}` };

        const newConversationResponse = await axios.get(url_new, { headers });
        const conversationId = newConversationResponse.data?.data?.id;

        if (!conversationId) {
            console.error("Failed to create a new conversation:", newConversationResponse.data);
            return;
        }

        // Post the message to the conversation
        const url_completion = `${gRagApiUrl}/completion`;
        const postData = {
            conversation_id: conversationId,
            messages: [
                {
                    role: 'user',
                    content: question // Send the structured data in the question
                }
            ],
            quote: false,
            stream: false
        };

        const completionResponse = await axios.post(url_completion, postData, { headers });

        // Check for errors
        if (completionResponse.data.retcode !== 0) {
            console.error("Error from Ragflow:", completionResponse.data.retmsg);
        } else {
            const answer = completionResponse.data?.data?.answer;
            console.log("Ragflow Response:", answer);
        }
    } catch (error) {
        console.error("Error sending to Ragflow:", error);
    }
}