db = db.getSiblingDB('jaltsu_pulsedb')

chunks = db.chunk.find();
var chunk;

var datapoint;

while ( chunks.hasNext() ) {
   chunk = chunks.next();

   datapoints = db.datapoint.find({"chunkId": chunk._id.valueOf()});
   print("Length: " + datapoints.length())
   var rms = [];
   var decibel = [];

   var lowest_timestamp = 9999999999999999;

   //while (datapoints.hasNext())
   //{
    for (var i = 0; i < datapoints.length(); i++)
    {
        datapoint = datapoints[i];
        //chunk.rms.push([datapoint.timestamp, datapoint.rms]);
        //chunk.decibel.push([datapoint.timestamp, datapoint.decibel]);
        rms.push([datapoint.timestamp, datapoint.rms]);
        decibel.push([datapoint.timestamp, datapoint.decibel]);

        if (lowest_timestamp > datapoint.timestamp)
            lowest_timestamp = datapoint.timestamp;
        //printjson(datapoint);
   //}
    }

   chunk.lowestTimestamp = lowest_timestamp;
   chunk.rms = rms;
   chunk.decibel = decibel;

   db.chunk.save(chunk);
}