bprocessor-commit

[Michael L. <he...@us...>]

Update of /cvsroot/bprocessor/model/src/net/sourceforge/bprocessor/model/sense/ti
In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv26351/src/net/sourceforge/bprocessor/model/sense/ti

Added Files:
	Adapter.java CoreMeasurement.java TIHistory.java 
Log Message:


--- NEW FILE: TIHistory.java ---
package net.sourceforge.bprocessor.model.sense.ti;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Date;
import java.util.LinkedList;
import java.util.List;

import net.sourceforge.bprocessor.model.sense.core.History;
import net.sourceforge.bprocessor.model.sense.core.Measurement;
import net.sourceforge.bprocessor.model.sense.core.Sensor;
import net.sourceforge.bprocessor.model.sense.core.Target;

public class TIHistory extends History {
  int port = 15343;
  String host = "localhost";
  
  List<CoreMeasurement> buffer;
  
  public TIHistory() {
    buffer = new LinkedList<CoreMeasurement>();
  }
  
  long stamp;
  
  public void fill(long time) throws Exception {
    if (time > stamp) {
      Socket server = new Socket(host, port);
      BufferedReader reader = new BufferedReader(new InputStreamReader(server.getInputStream()));
      PrintStream printer = new PrintStream(server.getOutputStream());
      printer.println("fetch " + time);
      String line = reader.readLine();
      while (line != null && !line.equals("done")) { 
        CoreMeasurement core = new CoreMeasurement(line);
        buffer.add(core);
      }
      stamp = time;
    }
  }
  
  public List<Measurement> fetch(Target target, Sensor sensor, Date from) {
    return null;
  }

  @Override
  public List<Measurement> fetch(Target target, Sensor sensor, Date from,
    Date to) {
    // TODO Auto-generated method stub
    return null;
  }

}

--- NEW FILE: Adapter.java ---
package net.sourceforge.bprocessor.model.sense.ti;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;
import java.util.LinkedList;

import net.sourceforge.bprocessor.model.sense.core.Producer;

public class Adapter extends Producer{
     String host = "camel15.cs.au.dk";
     int port = 15343;
     
     public void fill() throws Exception {
       Socket server = new Socket(host, port);
       BufferedReader reader = new BufferedReader(new InputStreamReader(server.getInputStream()));
       PrintStream printer = new PrintStream(server.getOutputStream());
       printer.println("fetch");
       
       LinkedList<CoreMeasurement> buffer = new LinkedList<CoreMeasurement>();
       
       String line = reader.readLine();
       while (line != null && !line.equals("done")) { 
         CoreMeasurement core = new CoreMeasurement(line);
         buffer.add(core);
         line = reader.readLine();
       }
       server.close();
       
       for (CoreMeasurement current : buffer) {
         consume(current);
       }
     }
}

--- NEW FILE: CoreMeasurement.java ---
package net.sourceforge.bprocessor.model.sense.ti;

import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;

public class CoreMeasurement {
  public long id;
  public long time;
  public double temperature;
  public double humidity;
  
  public CoreMeasurement(String line) {
    String s[] = line.split(";");
    id = Long.valueOf(s[0]);
    time = Long.valueOf(s[1]);
    temperature = Double.valueOf(s[2]);
    humidity = Double.valueOf(s[3]);
  }
  
  public CoreMeasurement(long id, long time, double temperature, double humidity) {
    this.id = id;
    this.time = time;
    this.temperature = temperature;
    this.humidity = humidity; 
  }
  
  public String toString() {
    DateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    return "[" + id + " | " + format.format(new Date(time))
      + " | " + temperature + " | " + humidity + "]";
  }
}