package zeta.handler.approve;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp;
import java.util.Properties;
import java.util.zip.ZipEntry;
import java.util.zip.ZipInputStream;
import javax.servlet.ServletException;
import zeta.ZetaServlet;
import zeta.util.DatabaseUtils;
import zeta.util.StreamUtils;
import zeta.util.ThrowableHandler;
public class ApproveProperties extends ApproveBase {
public ApproveProperties(ZetaServlet servlet, int userId, String user, String eMail) {
super(servlet, userId, user, eMail);
}
public String getKey() {
return "user properties";
}
final public String approve(Statement stmt, String value, long timeMillis) throws SQLException, ServletException {
ResultSet rs = stmt.executeQuery("SELECT data FROM zeta.approve WHERE server_id=" + servlet.getServerId() + " AND user_id=" + userId + " AND approved IS NULL AND key='" + value + '\'');
if (!rs.next()) {
rs.close();
return "<html><body><b>Error:</b> The key is invalid! Please check if the URL is similar to that in your e-mail.</body></html>";
}
byte[] data = rs.getBytes(1);
rs.close();
StringBuffer result = new StringBuffer(500);
result.append("<html><body>The following properties are successfully changed:<p> ");
rs = stmt.executeQuery("SELECT email_valid_YN,team_name,properties FROM zeta.user WHERE server_id=" + servlet.getServerId() + " AND id=" + userId);
if (rs.next()) {
String messages = rs.getString(1);
String team = rs.getString(2);
String prop = rs.getString(3);
rs.close();
if (prop == null) {
prop = "";
}
String userOrig = user;
String eMailOrig = eMail;
String messagesOrig = messages;
String teamOrig = team;
Properties properties = null;
try {
properties = new Properties();
properties.load(new ByteArrayInputStream(prop.getBytes()));
ZipInputStream in = new ZipInputStream(new ByteArrayInputStream(data));
while (true) {
ZipEntry entry = in.getNextEntry();
if (entry == null) {
break;
}
String entryName = entry.getName();
ByteArrayOutputStream out = new ByteArrayOutputStream(300);
StreamUtils.writeData(in, out, false, true);
String val = out.toString();
if (entryName.equals("user")) {
user = val;
} else if (entryName.equals("email")) {
eMail = val;
} else if (entryName.equals("messages")) {
messages = val;
} else if (entryName.equals("team")) {
team = val;
} else {
properties.setProperty(entryName, val);
}
result.append("<br>");
result.append(entryName);
result.append(": ");
result.append(val);
}
in.close();
} catch (IOException ioe) {
ThrowableHandler.handle(ioe);
}
StringBuffer sql = new StringBuffer(500);
StringBuffer values = new StringBuffer(2048);
if (!user.equals(userOrig)) {
if (sql.length() > 0) {
sql.append(',');
values.append(',');
}
sql.append("name");
values.append('\'');
values.append(user);
values.append('\'');
}
if (!eMail.equals(eMailOrig)) {
if (sql.length() > 0) {
sql.append(',');
values.append(',');
}
sql.append("email");
values.append('\'');
values.append(eMail);
values.append('\'');
}
if (!messages.equals(messagesOrig)) {
if (sql.length() > 0) {
sql.append(',');
values.append(',');
}
sql.append("email_valid_YN");
values.append('\'');
values.append(messages);
values.append('\'');
}
if (!team.equals(teamOrig)) {
if (sql.length() > 0) {
sql.append(',');
values.append(',');
}
sql.append("team_name,join_in_team");
if (team.trim().length() == 0) {
values.append("NULL,NULL");
} else {
values.append('\'');
values.append(team);
values.append("','");
values.append(new Timestamp(timeMillis));
values.append('\'');
}
}
if (sql.length() > 0) {
sql.append(',');
values.append(',');
}
sql.append("properties");
values.append('\'');
if (properties != null) {
try {
ByteArrayOutputStream out = new ByteArrayOutputStream(1024);
properties.remove("user_id");
properties.remove("user_orig");
properties.remove("email_orig");
properties.store(out, null);
out.close();
String val = out.toString();
if (val.length() > 1024) {
val = val.substring(0, 1024);
}
values.append(DatabaseUtils.encodeName(val));
} catch (IOException ioe) {
}
}
values.append('\'');
DatabaseUtils.executeAndLogUpdate(servlet, "UPDATE zeta.user SET (" + sql.toString() + ")=(" + values.toString()
+ ") WHERE server_id=" + servlet.getServerId() + " AND id=" + userId);
}
stmt.executeUpdate("UPDATE zeta.approve SET approved=CURRENT TIMESTAMP WHERE server_id=" + servlet.getServerId() + " AND user_id=" + userId + " AND approved IS NULL AND key='" + value + '\'');
result.append("<br> <p><b>Remark:</b> The server needs at least 1 hour to update your changes in the statistics.</body></html>");
return result.toString();
}
}