Node-RED MongoDB Node

// This quickstart demonstrates direct MongoDB interaction
// using the 'mongodb' driver, which is what the Node-RED node
// 'node-red-node-mongodb' ultimately uses under the hood.
// The Node-RED node provides a visual, flow-based interface
// to these operations.
//
// To use the Node-RED node:
// 1. Ensure Node.js and npm are installed.
// 2. Install Node-RED globally: npm install -g node-red
// 3. Start Node-RED: node-red
// 4. Navigate to the Node-RED user directory (typically ~/.node-red).
// 5. Install the MongoDB node: npm install node-red-node-mongodb
// 6. Restart Node-RED and find the MongoDB nodes in the palette to build flows.

import { MongoClient } from 'mongodb';

async function runMongoExample() {
  // For actual Node-RED use, connection string would be in node config.
  const uri = process.env.MONGO_URI ?? 'mongodb://localhost:27017';
  const dbName = 'nodeRedExampleDB';
  const collectionName = 'sensorData';

  const client = new MongoClient(uri);

  try {
    await client.connect();
    console.log("Connected successfully to MongoDB server");
    const db = client.db(dbName);
    const collection = db.collection(collectionName);

    const dataToInsert = {
      timestamp: new Date(),
      temperature: Math.random() * 30 + 15, // Random temp between 15-45
      humidity: Math.random() * 40 + 50,    // Random humidity between 50-90
      location: 'serverRoom01',
      _id: `sensor_${Date.now()}` // Example for handling _id
    };

    // Insert a document (equivalent to Node-RED 'out' node with 'Insert' operator)
    const insertResult = await collection.insertOne(dataToInsert);
    console.log(`Document inserted with _id: ${insertResult.insertedId}`);

    // Find documents (equivalent to Node-RED 'in' node with 'Find' operator)
    const query = { location: 'serverRoom01' };
    const foundDocuments = await collection.find(query).limit(5).toArray();
    console.log(`Found ${foundDocuments.length} documents:`);
    foundDocuments.forEach(doc => console.log(doc));

    // Update a document (equivalent to Node-RED 'out' node with 'Update' operator)
    const updateResult = await collection.updateOne(
        { _id: dataToInsert._id },
        { $set: { temperature: 25.5, status: 'updated' } }
    );
    console.log(`Matched ${updateResult.matchedCount} docs, modified ${updateResult.modifiedCount} docs.`);

  } catch (err) {
    console.error("Failed to connect or perform MongoDB operations:", err);
  } finally {
    await client.close();
    console.log("MongoDB connection closed.");
  }
}

runMongoExample();