From 6294efa9f93790108a06d2f41b517b7eac66810b Mon Sep 17 00:00:00 2001
From: Bart Van Der Meerssche <bart.vandermeerssche@flukso.net>
Date: Mon, 25 Apr 2011 16:52:27 +0000
Subject: [PATCH] [api] add support for sensor config POSTing on the
 /sensor/xyz endpoint

---
 server/api/flukso/src/flukso.erl            |  1 +
 server/api/flukso/src/flukso_sensor_xyz.erl | 37 +++++++++++++++++++--
 2 files changed, 35 insertions(+), 3 deletions(-)

diff --git a/server/api/flukso/src/flukso.erl b/server/api/flukso/src/flukso.erl
index 4c1ff2c..af7cd02 100644
--- a/server/api/flukso/src/flukso.erl
+++ b/server/api/flukso/src/flukso.erl
@@ -35,6 +35,7 @@ mysql_prepare() ->
     mysql:prepare(sensor_key, <<"SELECT sha FROM (logger_devices ld INNER JOIN logger_meters lm ON ld.device = lm.device) WHERE lm.meter = ?">>),
     mysql:prepare(sensor_props, <<"SELECT uid, device, night FROM logger_meters WHERE meter = ?">>),
     mysql:prepare(sensor_update, <<"UPDATE logger_meters SET access = ?, night = ?, value = ? WHERE meter = ?">>),
+    mysql:prepare(sensor_config, <<"UPDATE logger_meters SET class = ?, type = ?, function = ?, voltage = ?, current = ?, constant = ?, enabled = ? WHERE meter = ?">>),
     mysql:prepare(timezone, <<"SELECT timezone FROM users WHERE uid = ?">>),
     mysql:prepare(device_key, <<"SELECT sha FROM logger_devices WHERE device = ?">>),
     mysql:prepare(device_props, <<"SELECT sha, upgrade, resets FROM logger_devices WHERE device = ?">>),
diff --git a/server/api/flukso/src/flukso_sensor_xyz.erl b/server/api/flukso/src/flukso_sensor_xyz.erl
index 1ead5de..8d258f1 100644
--- a/server/api/flukso/src/flukso_sensor_xyz.erl
+++ b/server/api/flukso/src/flukso_sensor_xyz.erl
@@ -143,11 +143,42 @@ to_json(ReqData, #state{rrdSensor = RrdSensor, rrdStart = RrdStart, rrdEnd = Rrd
             {{halt, 404}, ReqData, State}
     end.
 
+
+process_post(ReqData, State) ->
+    {struct, JsonData} = mochijson2:decode(wrq:req_body(ReqData)),
+    Payload = {proplists:get_value(<<"measurements">>, JsonData),
+               proplists:get_value(<<"config">>, JsonData)},
+
+    case Payload of
+        {undefined, undefined} ->
+            {false, ReqData, State};
+	{Measurements, undefined} ->
+            process_measurements(Measurements, ReqData, State);
+        {undefined, Config} ->
+            process_config(Config, ReqData, State);
+        {_Measurements, _Config} ->
+            {false, ReqData, State}
+    end.
+
+% JSON: {"config":{"type":"electricity","enable":0,"class":"analog","current":50,"voltage":230}}
+% Mochijson2: {struct,[{<<"config">>, {struct,[{<<"type">>,<<"electricity">>}, {<<"enable">>,0}, ... ]} }]}
+process_config({struct, Params}, ReqData, #state{rrdSensor = Sensor} = State) ->
+    Args = [proplists:get_value(<<"class">>,    Params),
+            proplists:get_value(<<"type">>,     Params),
+            proplists:get_value(<<"function">>, Params),
+            proplists:get_value(<<"voltage">>,  Params),
+            proplists:get_value(<<"current">>,  Params),
+            proplists:get_value(<<"constant">>, Params),
+            proplists:get_value(<<"enable">>,   Params),
+            Sensor],
+
+    {updated, _Result} = mysql:execute(pool, sensor_config, Args),
+
+    {true, ReqData, State}.
+
 % JSON: {"measurements":[[<TS1>,<VALUE1>],...,[<TSn>,<VALUEn>]]}
 % Mochijson2: {struct,[{<<"measurements">>,[[<TS1>,<VALUE1>],...,[<TSn>,<VALUEn>]]}]}
-process_post(ReqData, #state{rrdSensor = RrdSensor} = State) ->
-    {struct, JsonData} = mochijson2:decode(wrq:req_body(ReqData)),
-    Measurements = proplists:get_value(<<"measurements">>, JsonData),
+process_measurements(Measurements, ReqData, #state{rrdSensor = RrdSensor} = State) ->
     RrdData = [[integer_to_list(Time), ":", integer_to_list(Counter), " "] || [Time, Counter] <- Measurements],
     [LastTimestamp, LastValue] = lists:last(Measurements),