Add this script to your Rank Tester website/backend. It connects to your database, reads any collection (e.g. books, tests), and streams them securely to Grid-Vault for automated learning.

// Node.js Database Ingestion Client Script
const axios = require('axios');
const MongoClient = require('mongodb').MongoClient;

async function syncCollection() {
    const mongoUri = "mongodb://localhost:27017";
    const client = new MongoClient(mongoUri);

    try {
        await client.connect();
        const db = client.db("rank_tester");
        
        // Fetch book/questions collection data
        const records = await db.collection("questions").find({}).toArray();
        console.log(`Fetched ${records.length} records. Syncing...`);

        // Post data to Grid-Vault API Gateway
        const response = await axios.post("http://localhost:8080/api/admin/ingest", {
            collectionName: "questions_sync",
            records: records,
            mapping: {
                intentField: "subject",  // Match database subject
                aliasField: "question",  // Match database question
                responseField: "solution" // Match database answer
            }
        }, {
            headers: {
                Authorization: "Bearer grid_secret_token_1234"
            }
        });

        console.log("Sync Status:", response.data.status);
        console.log("Added:", response.data.itemsAdded, "Updated:", response.data.itemsUpdated);

        // Optional: Trigger retrain
        const trainRes = await axios.post("http://localhost:8080/api/admin/train", {}, {
            headers: {
                Authorization: "Bearer grid_secret_token_1234"
            }
        });
        console.log("Retrain status:", trainRes.data.status);
    } catch (err) {
        console.error("Sync failed:", err.message);
    } finally {
        await client.close();
    }
}

syncCollection();