/
JavaRESTClient_ServiceMonitor
JavaRESTClient_ServiceMonitor
- Robert Avery
Owned by Robert Avery
SheetsterRESTClient.java
package JavaRESTClient_ServiceMonitor;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLConnection;
import java.util.zip.GZIPInputStream;
import com.extentech.ExtenXLS.ExcelTools;
import com.extentech.toolkit.Logger;
/**
* Helper class that encapsulates REST api calls to DocsFree Sheetster which provides for simplified REST handling
*
* @author john :: Sep 17, 2011 :: Copyright ©2011 <a href = "http://www.extentech.com">Extentech Inc.</a>
*
*/
public class SheetsterRESTClient implements Runnable {
// change this to the ID of the report template
private static final int REPORT_ID = 329;
/*
* NOTE: set the following credentials:
*/
private String username = "", password = "",
serveraddress = "http://127.0.0.1:8000", sessionAuthTicket = null,
memeId;
String portalSheetname = "Sheet1", errorSheetname = "Sheet1", dataSheetName="Sheet1";
private boolean debug = true;
/**
* @param debug
* The debug to set.
*/
public void setDebug(boolean debug) {
this.debug = debug;
}
/**
* @return Returns the memeId.
*/
public String getMemeId() {
return memeId;
}
/**
* @param memeId
* The memeId to set.
*/
public void setMemeId(String memeId) {
this.memeId = memeId;
}
/**
* @return Returns the username.
*/
public String getUsername() {
return username;
}
/**
* @param username
* The username to set.
*/
public void setUsername(String u) {
username = u;
}
/**
* @return Returns the password.
*/
public String getPassword() {
return password;
}
/**
* @param password
* The password to set.
*/
public void setPassword(String p) {
password = p;
}
/**
* @return Returns the serveraddress.
*/
public String getServeraddress() {
return serveraddress;
}
/**
* @param serveraddress
* The serveraddress to set.
*/
public void setServeraddress(String s) {
serveraddress = s;
}
/**
* Open a browser window and loads the current document
*/
public void launchBrowser(){
String openstr = serveraddress + "/index.jsp?meme_id=" + memeId+"&sessionAuthTicket=" + sessionAuthTicket;
launchBrowser(openstr);
}
/**
* launches native browser
*
* @param cmd
*/
public static void launchBrowser(String cmd) {
try {
edu.stanford.cs.ejalbert.BrowserLauncher.openURL(cmd);
} catch (Exception e) {
Logger.logErr("WARNING: ServerControl.launchBrowser failed: " + e);
}
}
/**
* run through the tests
*
* @param args
*/
public static void main(String[] args) {
try {
String sid = null;
SheetsterRESTClient test3 = new SheetsterRESTClient();
test3.run();
String openstr = test3.serveraddress
+ "/index.jsp?sessionAuthTicket=" + test3.sessionAuthTicket
+ "&meme_id=" + test3.memeId;
Logger.logInfo("Opening: " + openstr);
launchBrowser(openstr);
for (int t = 0; t < 10; t++) {
SheetsterRESTClient test = new SheetsterRESTClient();
Thread tx = new Thread(test);
tx.start();
// cache session id
if (sid == null)
sid = test.session;
else
test.session = sid;
try {
long sleeps = Math.round(Math.random() * 3000);
Logger.logInfo("New Session in :" + (float) sleeps / 1000
+ " seconds.");
Thread.sleep(sleeps);
} catch (Exception e) {
;
}
}
} catch (Exception e) {
Logger.logErr("SheetsterRESTClient failed" + e.toString());
}
}
/**
* threaded runner allows stress testing
*
* @see java.lang.Runnable#run()
*/
public void run() {
try {
// authenticate and create a new workbook
createDocumentFromURL(serveraddress, username,password);
// test a variety of REST commands
testRESTapi(serveraddress);
} catch (Exception e) {
Logger.logErr("SheetsterRESTClient failed: " + e.toString());
}
}
/**
* runs a suite of JSON/XML assertions against a running Server
*
* optional load testing
*
* @param srvurl
* @param testload
*/
public void testRESTapi(String srvurl) throws Exception {
if (srvurl == null)
srvurl = "http://127.0.0.1:8000"; // default to 127.0.0.1
// create new document on server, return document ID String
createDocumentFromURL(srvurl, username, password);
String[] reqs = {
// the usual init steps...
// memeId + "/xml/workbook/copy/0", // test copy existing
memeId + "/json/workbook/getsheetnames/",
memeId + "/json/row/getheader/Sheet1/",
memeId + "/json/style/getall/",
memeId + "/json/namedrange/getallranges/",
memeId + "/json/sheet/get/Sheet1/",
memeId + "/json/chart/getcharts/Sheet1/",
// memeId + "/json/cellbinder/getboundranges/Sheet1/",
memeId + "/json/workbook/getrestlog/0",
// insert a new sheet named "New Sheet" at index 0
memeId + "/xml/sheet/add/New Sheet/0",
// insert a new cell at "New Sheet!A1" with the initial value of
// "Hello World!"
memeId + "/xml/cell/get/New Sheet!A1/",
// insert a new cell at "New Sheet!A2" with the initial value of
// "=SUM(10+11)"
memeId + "/json/cell/add/New%20Sheet!A2/=SUM(10+11)",
// create a named range
memeId + "/json/namedrange/createnamedrange/New Sheet/A1:A2?rangeName=input_1",
// access a named range
memeId + "/json/namedrange/getcellvalues/input_1",
// runs the cellbinder to merge data with loaded workbook
// memeId + "/json/cellbinder/bind/1314?year=2008",
// gets a whole row of JavaScript Cell Objects from row 1:
memeId + "/json/cellrange/get/Sheet1!A1:VU1",
memeId + "/json/sheet/get/Sheet1/",
memeId + "/json/cell/add/Sheet1!B3/%3Dsum(b2%2B100)",
memeId + "/json/messaging/getmessages/",
memeId + "/json/workbook/getsheetnames/",
memeId + "/json/style/getall/",
memeId + "/json/col/resize/Sheet1!A/324",
// some more advanced stuff...
memeId + "/json/col/resize/Sheet1!A/324",
// rename this doc
memeId + "/xml/workbook/setname/workbook/new name",
memeId + "/json/col/resize/Sheet1!A/324",
memeId + "/xml/cell/add/Sheet1!c4/5000",
memeId + "/xml/cell/add/Sheet1!c5/1500",
memeId + "/xml/cell/add/Sheet1!C6/=sum(c4+c5)",
// cleanup
// memeId + "/json/workbook/delete"
};
// convert human-readable commands to REST urls
for (int t = 0; t < reqs.length; t++) {
try {
// TODO: implement assertions
String svx = srvurl + "/workbook/id/" + reqs[t];
if (debug)
Logger.logInfo("TESTING: "+ com.extentech.ExtenXLS.plugin.builtin.REST2English.getTranslated(svx));
if (debug)
Logger.logInfo("COMMAND: " + svx);
if (debug)
Logger.logInfo("RESULT FROM SERVER: " + getHTTPData(svx)
+ "\r\n");
} catch (Exception ex) {
Logger.logErr("SheetsterRESTClient testServer failed: "
+ ex.toString());
}
}
}
/**
* create a WebWorkBook
*
* @return
* @throws Exception
*/
public void createDocument() throws Exception {
createDocumentFromURL(serveraddress, username, password);
}
/**
* create a WebWorkBook
*
* @return
* @throws Exception
*/
public String destroyDocument() throws Exception {
// cleanup
String delete = "/workbook/id/" +memeId + "/json/workbook/delete";
return getHTTPData(delete);
}
/**
* Creating the document from a URL
*
*
* Sep 13, 2011
*
* @param srvurl
* @param username
* @param password
* @return
* @throws IOException
* @throws MalformedURLException
*/
public void createDocumentFromURL(String srvurl, String username,
String password) throws Exception {
authenticate();
// create new workbook -- do the usual init steps
String new_book_url = srvurl + "/workbook/id/-1/csv/workbook/getid";
// copy existing template that you have already uploaded
//String new_book_url = srvurl + "/workbook/id/"+REPORT_ID+"/csv/workbook/copy";
memeId = new String(getHTTPBytes(new_book_url));
}
/**
* Logs in the user with the credentials set on this object
*
*/
public void authenticate() throws Exception {
if (session == null) {
// authenticate the user
String login_url = serveraddress
+ "/workbook/id/-2/txt/system/login/?username=" + username
+ "&password=" + password;
sessionAuthTicket = new String(getHTTPBytes(login_url));
if (debug)
Logger
.logInfo("SheetsterRESTClient successfully logged in user got session auth ticket: "
+ sessionAuthTicket);
}
}
String session = null;
/**
* fetch the contents of a URL as a buest-guess Java data type...
*
* @param urlstr
* @return Object value returned from Server
* @throws IOException
* @throws MalformedURLException
*/
public Object getHTTPObject(String urlstr) throws Exception {
// Create a URL object from urlString
String ret = new String(getHTTPBytes(urlstr));
// try numbers
try{
Double d = Double.parseDouble(ret);
return d;
}catch(NumberFormatException de){
try{
Float f = Float.parseFloat(ret);
return f;
}catch(NumberFormatException fe){
try{
Integer i = Integer.parseInt(ret);
return i;
}catch(NumberFormatException ie){
// ok not a number
}
}
}
// try boolean
if(ret.equalsIgnoreCase("true")){
return new Boolean(true);
}else if(ret.equalsIgnoreCase("false")){
return new Boolean(false);
}
//finally returns string val
return ret;
}
/**
* fetch the contents of a URL as a string...
*
* @param urlstr
* @return String value returned from Server
* @throws IOException
* @throws MalformedURLException
*/
public String getHTTPData(String urlstr) throws Exception {
// Create a URL object from urlString
String strx = new String(getHTTPBytes(urlstr));
// Logger.logInfo(urlstr + ":" + strx);
return strx;
}
/**
* fetch the contents of a URL as a byte array
*
* @param urlstr
* @return byte values returned from server
* @throws IOException
* @throws MalformedURLException
*/
public byte[] getHTTPBytes(String urlstr) throws Exception {
if(!urlstr.startsWith(serveraddress)){
urlstr = serveraddress + urlstr;
}
// Create a URL object from urlString
URL pageURL = new URL(urlstr);
// Open a connection to the URL
URLConnection pageConnection;
pageConnection = pageURL.openConnection();
if (session != null)
pageConnection.addRequestProperty("Cookie", session);
else
Logger.logWarn("Getting Valid Session");
// TODO: Use Base64 Security over HTTPS
pageConnection.setConnectTimeout(10000);
// Get the InputStream from the URL connection
InputStream webPageInputStream;
pageConnection.connect();
webPageInputStream = pageConnection.getInputStream();
// handle the InputStream encoding (for gzip output)
String enc = pageConnection.getContentEncoding();
try {
if (enc.equalsIgnoreCase("gzip"))
webPageInputStream = new GZIPInputStream(pageConnection
.getInputStream());
} catch (NullPointerException e) {
;// normal
}
// Read the web page via the InputStream
ByteArrayOutputStream webPageData = new ByteArrayOutputStream();
int totalBytesRead = 0;
boolean moreToRead = true;
byte[] readBuf = new byte[2048]; // Read the web page in 4K chunks
while (moreToRead) {
int numBytesRead = 0;
try {
numBytesRead = webPageInputStream.read(readBuf);
} catch (IOException e) {
moreToRead = false;
}
if (numBytesRead > 0) {
totalBytesRead += numBytesRead;
webPageData.write(readBuf, 0, numBytesRead);
} else
moreToRead = false;
}
// Logger.logInfo("Communicator read: " + totalBytesRead +
// " bytes from:" + urlstr);
webPageInputStream.close();
// webPageData.setLength(totalBytesRead);
// Pull the session ID out of the connection headers
if (session == null)
try {
session = pageConnection.getHeaderField("Set-Cookie");
if (session == null)
throw new Exception("session cookie not present");
if (!session.startsWith("sessionid="))
throw new Exception("invalid session cookie");
// Strip off any extraneous header fields
if (session.contains(";"))
session = session.substring(0, session.indexOf(";"));
} catch (Exception e) {
throw new RuntimeException("failed to parse session cookie", e);
}
//
return webPageData.toByteArray();
}
/**
* @param celladdr
* @param val
* @throws Exception
*/
public void addCell(String celladdr, String sn, Object val)
throws Exception{
String cellval = "/workbook/id/" + getMemeId()+"/json/cell/add/"+sn+"!"; // always use Sheet1
cellval += celladdr;
cellval += "/";
cellval += val.toString();
getHTTPData(cellval);
}
/**
* bulk sets a rows of data into sheet
*
* @param objarr
*/
public void setDataRow(Object[][] objarr, String sn, int row)
throws Exception{
for(int t=0;t<objarr.length;t++){ // iterate rows
Object[] bo = objarr[t];
for(int x=0;x<bo.length;x++){ // put together
String celladdr = ExcelTools.getAlphaVal(x);
celladdr += (t+row);
addCell(celladdr, sn, bo[x]);;
}
}
// saveSheet();
}
int lastInsertRow = 1;
/**
* bulk inserts rows of data into sheet
*
* @param objarr
*/
public void addData(Object[][] objarr, String sn)
throws Exception{
for(int t=0;t<objarr.length;t++){ // iterate rows
Object[] bo = objarr[t];
for(int x=0;x<bo.length;x++){ // put together
String celladdr = ExcelTools.getAlphaVal(x);
celladdr += (t+lastInsertRow);
addCell(celladdr, sn, bo[x]);;
}
lastInsertRow++;
}
// saveSheet();
}
/**
*
* http://127.0.0.1:8000/workbook/id/133071/json/namedrange/createnamedrange/Sheet1/A5:C6?rangeName=test
*
* @param rangename
* @param rangeaddr
* @throws Exception
*/
public void addName(String rangename, String rangeaddr)
throws Exception{
String cmdx = "/workbook/id/" + getMemeId()+"/json/namedrange/createnamedrange/"+portalSheetname+"/"; // always use Sheet1
cmdx += rangeaddr;
cmdx += "?";
cmdx +="rangename="+rangename;
getHTTPData(cmdx);
}
/**
* save the workbook
*
* @throws Exception
*/
public void saveSheet()
throws Exception{
String sv = "/workbook/id/" + getMemeId()+"/csv/workbook/save/0";
getHTTPData(sv);
}
/**
* http://127.0.0.1:8000/workbook/id/133071/json/sheet/rename/Sheet1/Sheet1x
*
* @param sheet
* @param newname
*/
public void renameSheet(String sheet, String newname)
throws Exception{
String rename = "/workbook/id/" + getMemeId() + "/json/sheet/rename/"+sheet+"/"+newname;
if(sheet.equals(portalSheetname))
portalSheetname = newname;
else if(sheet.equals(errorSheetname))
errorSheetname = newname;
getHTTPData(rename);
}
/**
* http://127.0.0.1:8000/workbook/id/133071/xml/workbook/setname/0/test
*
* @param sheet
* @param newname
*/
public void renameWorkBook(String newname)
throws Exception{
String rename = "/workbook/id/" + getMemeId() + "/xml/workbook/setname/0/"+newname;
getHTTPData(rename);
}
}
SheetsterServiceMonitor.java
package JavaRESTClient_ServiceMonitor;
/**
* SheetsterServiceMonitor.java
*
* ##LICENSE##
*
* Sep 17, 2011
*
* @author john
*
*/
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.URL;
import java.net.URLConnection;
import java.util.Date;
import java.util.Hashtable;
import java.util.Map;
import com.extentech.ExtenXLS.ExcelTools;
import com.extentech.toolkit.Logger;
/**
* SheetsterServiceMonitor is a sample REST Client for DocsFree Sheetster Server demonstrating
* creation and execution of a service monitor which records results to a Sheetster Portal.
*
* This demonstrates Java using the REST api.
*
* @author John McMahon :: 1/11/2011 :: Copyright ©2011 <a href = "http://www.extentech.com">Extentech Inc.</a>
*
*/
public class SheetsterServiceMonitor extends SheetsterRESTClient{
private String portalSheetname = "Sheet1", errorSheetname = "Sheet2";
private String watchedServerAddress;
// TODO: set reporting credentials
private static String reportingServerAddress = "http://127.0.0.1:8000",
reportingServerUserName = "admin@acme.com",
reportingServerPassword = "T1TAN1UM",
// FYI: mail server configured through resources/jsmtp.server.properties
mailServerUserName = "admin@acme.com",
mailServerPassword = "T1TAN1UM";
private int watchedServerPort = 80;
private int pulse = 1000 * 60 * 10; // every 10 minutes
private int lastInsertRow = 4;
/**
* @return Returns the watchedServerPort.
*/
public int getWatchedServerPort() {
return watchedServerPort;
}
/**
* @param watchedServerPort The watchedServerPort to set.
*/
public void setWatchedServerPort(int watchedServerPort) {
this.watchedServerPort = watchedServerPort;
}
/**
* Test a basic service monitoring
*
* @param args
*/
public static void main(String[] args) {
String[] monitored = {
"http://extentech.com/workbook/id/117921/html/sheet/get/Sheet1/excel_2_html.xsl",
"http://www.sheetster.com/workbook/id/66361/html/sheet/get/Printer_Troubleshooter/excel_2_html.xsl"
};
for(String msv : monitored){
// create in-memory Spreadsheet for calculation
SheetsterServiceMonitor cmd = new SheetsterServiceMonitor();
// These credentials are for the reporting server -- NOT the monitored server.
// For obvious reasons, the monitoring and reporting server should not be the same.
cmd.setServeraddress(reportingServerAddress);
cmd.setUsername(reportingServerUserName);
cmd.setPassword(reportingServerPassword);
// pick a fast public doc that should come up cleanly
cmd.setWatchedServerAddress(msv);
Thread runit = new Thread(cmd);
//runit.setPriority(Thread.MAX_PRIORITY);
//runit.setDaemon(true);
try{
runit.start();
Thread.sleep(10000); // stagger start time for robustica
}catch(Exception e){ // oh yes it will run
Logger.logErr("Problem starting SheetsterServiceMonitor: "+ cmd.getWatchedServerAddress(),e);
}
}
}
/**
* threaded runner allows stress testing
*
* @see java.lang.Runnable#run()
*/
public void run() {
try {
// login the user session
authenticate();
// create a new workbook
// TODO: Load existing template
createDocument();
String smpl = this.getWatchedServerAddress().substring(7);
try{
smpl = smpl.substring(0,smpl.indexOf("/"));
}catch(Exception e){;}
String workbookname = "Service Monitoring: " + smpl;
renameWorkBook(workbookname);
//renameSheet("Sheet1","Service Portal");
//renameSheet("Sheet2","Monitor_Data");
// create the headers for report
// add the named range
addName("elapsed_time",portalSheetname + "!A8:C8");
Object[][] data = {
{"Service Monitor Report", this.getWatchedServerAddress(), new Date(System.currentTimeMillis()).toString()},
{"Average / Max Response Time", "=AVERAGE(elapsed_time)", "=MAX(elapsed_time)"},
{"Connected OK","Connect Elapsed Time","Timestamp"}
};
addData(data, portalSheetname);
// begin monitoring
watch();
// clean it up
// destroyDocument();
// let's take a look at the report
// launchBrowser();
} catch (Exception e) {
Logger.logErr("SheetsterServiceMonitor failed: " + e.toString());
}
}
/**
* bulk inserts rows of data into sheet
*
* In order to leave room for the business logic calculations this
* Adds cells starting at A3
*
* @param objarr
*/
public void addData(Object[][] objarr, String sn)
throws Exception{
for(int t=0;t<objarr.length;t++){ // iterate rows
Object[] bo = objarr[t];
for(int x=0;x<bo.length;x++){ // put together
String celladdr = ExcelTools.getAlphaVal(x);
celladdr += (t+lastInsertRow);
addCell(celladdr, sn, bo[x]);;
}
lastInsertRow++;
}
saveSheet();
}
/**
* http://127.0.0.1:8000/workbook/id/133071/json/sheet/rename/Sheet1/Sheet1x
*
* @param sheet
* @param newname
*/
public void renameSheet(String sheet, String newname)
throws Exception{
String rename = "/workbook/id/" + super.getMemeId() + "/json/sheet/rename/"+sheet+"/"+newname;
if(sheet.equals(portalSheetname))
portalSheetname = newname;
else if(sheet.equals(errorSheetname))
errorSheetname = newname;
getHTTPData(rename);
}
/**
* http://127.0.0.1:8000/workbook/id/133071/xml/workbook/setname/0/test
*
* @param sheet
* @param newname
*/
public void renameWorkBook(String newname)
throws Exception{
String rename = "/workbook/id/" + super.getMemeId() + "/xml/workbook/setname/0/"+newname;
getHTTPData(rename);
}
/**
* adds a named business rule (formula) to the sheet at A2
*
* @param s
* @param fmla
*/
public void watch()
throws Exception{
boolean OK = true;
String errorcode = "";
while(true){
long elapsed = System.currentTimeMillis();
errorcode = "";
try{
OK = connectCheck(getWatchedServerAddress(), getWatchedServerPort());
}catch(Exception e){
OK = false;
errorcode = e.toString();
}
elapsed = System.currentTimeMillis() - elapsed;
// create the headers for report
Object[][] data = {{new Boolean(OK),new Long(elapsed),
new Date(System.currentTimeMillis()).toString(),
errorcode}};
if(errorcode.equals(""))
addData(data, portalSheetname);
else{
addData(data, errorSheetname);
restartService();
}
// TODO: use this to relaunch from within Luminet
// _launcher.restartServer(i);
OK = false;
Thread.sleep(pulse);
}
};
/**
* check that the server is up, register data in report
*
* Jan 11, 2011
* @param host
* @param p
* @return
* @throws IOException
*/
private boolean connectCheck(String host,int p) throws IOException
{
OutputStream out = null;
String stat = getPage(host);
if(stat.indexOf("Exception")==-1){
return true;
}
return false;
}
public static final String getPage(String urlString) throws IOException{
// Create a URL object from urlString
URL pageURL = new URL(urlString);
// Open a connection to the URL
URLConnection pageConnection;
pageConnection = pageURL.openConnection();
//pageConnection.setConnectTimeout(15000);
// Get the InputStream from the URL connection
InputStream webPageInputStream = null;
String mtyp = pageConnection.getContentType();
pageConnection.connect();
webPageInputStream = pageConnection.getInputStream();
// handle gunzip
if(mtyp.equalsIgnoreCase("text/json")){
java.util.zip.GZIPInputStream giz = new java.util.zip.GZIPInputStream(webPageInputStream);
webPageInputStream = giz;
}
// Read the web page via the InputStream
StringBuffer webPageData = new StringBuffer();
int totalBytesRead = 0;
boolean moreToRead = true;
byte[] readBuf = new byte[8192]; // Read the web page in 8K chunks
while (moreToRead){
int numBytesRead = 0;
try {
numBytesRead = webPageInputStream.read(readBuf);
}catch (IOException e){
moreToRead = false;
}
if (numBytesRead > 0) {
totalBytesRead += numBytesRead;
webPageData.append(new String(readBuf, 0, numBytesRead));
}else
moreToRead = false;
}
// Logger.logInfo("Communicator read: " + totalBytesRead + " bytes from:" + urlString);
webPageInputStream.close();
webPageData.setLength(totalBytesRead);
return webPageData.toString();
}
/**
* delete a worksheet
*
* @param portalSheetname
* @throws Exception
*/
public void deleteSheet(String portalSheetname)
throws Exception{
String delete = "/workbook/id/" + super.getMemeId() + "/json/sheet/delete/"+portalSheetname+"/0";
getHTTPData(delete);
}
/**
*
* http://127.0.0.1:8000/workbook/id/133071/json/namedrange/createnamedrange/Sheet1/A5:C6?rangeName=test
*
* @param rangename
* @param rangeaddr
* @throws Exception
*/
public void addName(String rangename, String rangeaddr)
throws Exception{
String cmdx = "/workbook/id/" + getMemeId()+"/json/namedrange/createnamedrange/"+portalSheetname+"/"; // always use Sheet1
cmdx += rangeaddr;
cmdx += "?";
cmdx +="rangename="+rangename;
getHTTPData(cmdx);
}
/**
* save the workbook
*
* @throws Exception
*/
public void saveSheet()
throws Exception{
String sv = "/workbook/id/" + getMemeId()+"/csv/workbook/save/0";
getHTTPData(sv);
}
/**
* @param celladdr
* @param val
* @throws Exception
*/
public void addCell(String celladdr, String sn, Object val)
throws Exception{
String cellval = "/workbook/id/" + getMemeId()+"/json/cell/add/"+sn+"!"; // always use Sheet1
cellval += celladdr;
cellval += "/";
cellval += val.toString();
getHTTPData(cellval);
}
/**
* @param celladdr
* @throws Exception
*/
public Object getCell(String celladdr)
throws Exception{
String getcmd = "/workbook/id/" + getMemeId()+"/txt/cell/get/"+portalSheetname+"!"; // always use Sheet1
String cellval = getcmd;
cellval += celladdr;
cellval += "/0";
return getHTTPObject(cellval);
}
/**
* @return Returns the watchedServerAddress.
*/
public String getWatchedServerAddress() {
return watchedServerAddress;
}
/**
* @param watchedServerAddress The watchedServerAddress to set.
*/
public void setWatchedServerAddress(String w) {
this.watchedServerAddress = w;
}
/**
* Make whatever onerous native calls needed to make the server restart gracefully
*
*/
private synchronized void restartService(){
Logger.logWarn("Flatlined Restarting: " + this.watchedServerAddress);
String mailsubj = "[SERVICE MON] RESTART alert: " + this.watchedServerAddress;
String mailbody = "Service Monitor detected that the service at: " + this.watchedServerAddress + " has stopped responding and requires a restart.";
String mailsender = this.watchedServerAddress + "@extentech.com";
String mailrecip = "support@extentech.com";
// send mail message to admin
Map msg = new Hashtable();
msg.put("subject",mailsubj);
msg.put("sender",mailsubj);
msg.put("recipient",mailrecip);
msg.put("body",mailbody);
try{
this.mailer.setRelayAuthUser(mailServerUserName);
this.mailer.setRelayAuthPassword(mailServerPassword);
this.mailer.sendMessage( msg);
}catch(Exception e){
Logger.logErr("Sheetster Service Monitor watching " + this.watchedServerAddress + " could not send restart alert email.",e);
}
Object[][] data = {
{"SERVICE RESTART ATTEMPT", this.getWatchedServerAddress(), new Date(System.currentTimeMillis()).toString()}
};
try {
addData(data, portalSheetname);
} catch (Exception e) {
Logger.logErr("Sheetster Service Monitor watching " + this.watchedServerAddress + " could not log restart event.",e);
}
// do the evil native stuff
try {
Runtime.getRuntime().exec("cd /usr/local/sheetster/");
Runtime.getRuntime().exec("killall java -9");
Runtime.getRuntime().exec("");
} catch (IOException e) {
// TODO Auto-generated catch block
// e.printStackTrace();
}
}
com.extentech.jsmtp.jsmtpDaemon mailer = new com.extentech.jsmtp.jsmtpDaemon();
}
, multiple selections available,