package info.nightscout.androidaps.db; import com.google.common.base.Charsets; import com.google.common.hash.Hashing; import com.j256.ormlite.field.DatabaseField; import com.j256.ormlite.table.DatabaseTable; import org.json.JSONException; import org.json.JSONObject; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Created by mike on 27.02.2016. *

* Allowed actions "dbAdd" || "dbUpdate" || "dbUpdateUnset" || "dbRemove" */ @DatabaseTable(tableName = DatabaseHelper.DATABASE_DBREQUESTS) public class DbRequest { private static Logger log = LoggerFactory.getLogger(DbRequest.class); @DatabaseField(id = true) public String nsClientID = null; @DatabaseField public String action = null; @DatabaseField public String collection = null; @DatabaseField public String data = null; @DatabaseField public String _id = null; public DbRequest() { } // dbAdd public DbRequest(String action, String collection, String nsClientID, JSONObject data) { this.action = action; this.collection = collection; this.data = data.toString(); this.nsClientID = nsClientID; this._id = ""; } // dbUpdate, dbUpdateUnset public DbRequest(String action, String collection, String nsClientID, String _id, JSONObject data) { this.action = action; this.collection = collection; this.data = data.toString(); this.nsClientID = nsClientID; this._id = _id; } // dbRemove public DbRequest(String action, String collection, String nsClientID, String _id) { this.action = action; this.collection = collection; this.data = new JSONObject().toString(); this.nsClientID = nsClientID; this._id = _id; } public String hash() { return Hashing.sha1().hashString(action + collection + _id + data.toString(), Charsets.UTF_8).toString(); } public JSONObject toJSON() { JSONObject object = new JSONObject(); try { object.put("action", action); object.put("collection", collection); object.put("data", new JSONObject(data)); if (_id != null) object.put("_id", _id); if (nsClientID != null) object.put("nsClientID", nsClientID); } catch (JSONException e) { e.printStackTrace(); } return object; } public static DbRequest fromJSON(JSONObject jsonObject) { DbRequest result = new DbRequest(); try { if (jsonObject.has("action")) result.action = jsonObject.getString("action"); if (jsonObject.has("collection")) result.collection = jsonObject.getString("collection"); if (jsonObject.has("data")) result.data = jsonObject.getJSONObject("data").toString(); if (jsonObject.has("_id")) result._id = jsonObject.getString("_id"); if (jsonObject.has("nsClientID")) result.nsClientID = jsonObject.getString("nsClientID"); } catch (JSONException e) { e.printStackTrace(); } return result; } }