Add post and comment to Chatter
This task use java to add post and comment to Chatter
Add post and comment to Chatter
- Create Chatter class as following
- Call postUserFeed() method and postComment() method as following
Call postUserFeed() method and postComment() method
Chatter class
| 1 | String username = ""; |
| 2 | String password = ""; |
| 3 | |
| 4 | ConnectorConfig cc = new ConnectorConfig(); |
| 5 | cc.setAuthEndpoint("https://login.salesforce.com/services/Soap/u/19.0"); |
| 6 | cc.setServiceEndpoint("https://login.salesforce.com/services/Soap/u/19.0"); |
| 7 | cc.setManualLogin(true); |
| 8 | PartnerConnection conn = Connector.newConnection(cc); |
| 9 | |
| 10 | LoginResult loginResult = conn.login(username, password); |
| 11 | conn.setSessionHeader(loginResult.getSessionId()); |
| 12 | String serverUrl = loginResult.getServerUrl(); |
| 13 | cc.setServiceEndpoint(serverUrl); |
| 14 | |
| 15 | Chatter chatter = new Chatter(loginResult); |
| 16 | Map<String, String> data = null; |
| 17 | |
| 18 | String postBody = "This is post!"; |
| 19 | data = new HashMap<String, String>(); |
| 20 | data.put("text", postBody); |
| 21 | String feedItemId = chatter.postUserFeed(data); |
| 22 | logger.info("Feed Item Id: " + feedItemId); |
| 23 | |
| 24 | String commentBody = "This is comment!"; |
| 25 | data = new HashMap<String, String>(); |
| 26 | data.put("text", commentBody); |
| 27 | String commentId = chatter.postComment(feedItemId, data); |
| 28 | logger.info("Comment Id: " + commentId); |
String username = "";
String password = "";
ConnectorConfig cc = new ConnectorConfig();
cc.setAuthEndpoint("https://login.salesforce.com/services/Soap/u/19.0");
cc.setServiceEndpoint("https://login.salesforce.com/services/Soap/u/19.0");
cc.setManualLogin(true);
PartnerConnection conn = Connector.newConnection(cc);
LoginResult loginResult = conn.login(username, password);
conn.setSessionHeader(loginResult.getSessionId());
String serverUrl = loginResult.getServerUrl();
cc.setServiceEndpoint(serverUrl);
Chatter chatter = new Chatter(loginResult);
Map<String, String> data = null;
String postBody = "This is post!";
data = new HashMap<String, String>();
data.put("text", postBody);
String feedItemId = chatter.postUserFeed(data);
logger.info("Feed Item Id: " + feedItemId);
String commentBody = "This is comment!";
data = new HashMap<String, String>();
data.put("text", commentBody);
String commentId = chatter.postComment(feedItemId, data);
logger.info("Comment Id: " + commentId);
| 1 | public class Chatter { |
| 2 | |
| 3 | private static Logger logger = Logger.getLogger(Chatter.class); |
| 4 | |
| 5 | private String token = ""; |
| 6 | private String instance = ""; |
| 7 | |
| 8 | public Chatter(String token, String instance) { |
| 9 | this.token = token; |
| 10 | this.instance = instance; |
| 11 | } |
| 12 | |
| 13 | public Chatter(LoginResult loginResult) { |
| 14 | this.token = getToken(loginResult); |
| 15 | this.instance = getInstance(loginResult); |
| 16 | } |
| 17 | |
| 18 | public String postUserFeed(Map<String, String> data) throws Exception { |
| 19 | String feedItemId = ""; |
| 20 | String html = request(token, "post", data, "https://" + instance + ".salesforce.com/services/data/v24.0/chatter/feeds/news/me/feed-items"); |
| 21 | JSONObject json = (JSONObject)JSONSerializer.toJSON(html); |
| 22 | feedItemId = json.getString("id"); |
| 23 | return feedItemId; |
| 24 | } |
| 25 | |
| 26 | public String postRecordFeed(String recordId, Map<String, String> data) throws Exception { |
| 27 | String feedItemId = ""; |
| 28 | String html = request(token, "post", data, "https://" + instance + ".salesforce.com/services/data/v24.0/chatter/feeds/record/" + recordId + "/feed-items"); |
| 29 | JSONObject json = (JSONObject)JSONSerializer.toJSON(html); |
| 30 | feedItemId = json.getString("id"); |
| 31 | return feedItemId; |
| 32 | } |
| 33 | |
| 34 | public String postComment(String feedItemId, Map<String, String> data) throws Exception { |
| 35 | String commentId = ""; |
| 36 | String html = request(token, "post", data, "https://" + instance + ".salesforce.com/services/data/v24.0/chatter/feed-items/" + feedItemId + "/comments"); |
| 37 | JSONObject json = (JSONObject)JSONSerializer.toJSON(html); |
| 38 | commentId = json.getString("id"); |
| 39 | return commentId; |
| 40 | } |
| 41 | |
| 42 | public static String getToken(LoginResult loginResult) { |
| 43 | return loginResult.getSessionId(); |
| 44 | } |
| 45 | |
| 46 | public static String getInstance(LoginResult loginResult) { |
| 47 | String url = loginResult.getServerUrl(); |
| 48 | String pat1 = "https://"; |
| 49 | String pat2 = "-api.salesforce.com"; |
| 50 | int pos1 = url.indexOf(pat1); |
| 51 | int pos2 = url.indexOf(pat2); |
| 52 | String instance = "ap1"; |
| 53 | if (pos1 >= 0 && pos2 >= 0 && pos1 + pat1.length() < pos2) { |
| 54 | instance = url.substring(pos1 + pat1.length(), pos2); |
| 55 | } |
| 56 | return instance; |
| 57 | } |
| 58 | |
| 59 | public static String request(String token, String method, Map<String, String> data, String link) throws Exception { |
| 60 | URL url = new URL(link); |
| 61 | URLConnection conn = url.openConnection(); |
| 62 | HttpURLConnection http = (HttpURLConnection)conn; |
| 63 | http.setRequestMethod(method.toUpperCase()); |
| 64 | conn.setDoInput(true); |
| 65 | conn.setDoOutput(true); |
| 66 | conn.setRequestProperty("Authorization", "OAuth " + token); |
| 67 | |
| 68 | String output = ""; |
| 69 | for (String key : data.keySet()) { |
| 70 | if (output.length() > 0) output += "&"; |
| 71 | output += key + "=" + URLEncoder.encode(data.get(key), "UTF-8"); |
| 72 | } |
| 73 | BufferedWriter out = new BufferedWriter(new OutputStreamWriter(conn.getOutputStream())); |
| 74 | out.write(output); |
| 75 | out.close(); |
| 76 | |
| 77 | BufferedReader in = new BufferedReader(new InputStreamReader(conn.getInputStream())); |
| 78 | String response = ""; |
| 79 | String line = null; |
| 80 | while ((line = in.readLine()) != null) { |
| 81 | if (response.length() > 0) { |
| 82 | response += "\r\n"; |
| 83 | } |
| 84 | response += line; |
| 85 | } |
| 86 | in.close(); |
| 87 | |
| 88 | return response; |
| 89 | } |
| 90 | |
| 91 | } |
public class Chatter {
private static Logger logger = Logger.getLogger(Chatter.class);
private String token = "";
private String instance = "";
public Chatter(String token, String instance) {
this.token = token;
this.instance = instance;
}
public Chatter(LoginResult loginResult) {
this.token = getToken(loginResult);
this.instance = getInstance(loginResult);
}
public String postUserFeed(Map<String, String> data) throws Exception {
String feedItemId = "";
String html = request(token, "post", data, "https://" + instance + ".salesforce.com/services/data/v24.0/chatter/feeds/news/me/feed-items");
JSONObject json = (JSONObject)JSONSerializer.toJSON(html);
feedItemId = json.getString("id");
return feedItemId;
}
public String postRecordFeed(String recordId, Map<String, String> data) throws Exception {
String feedItemId = "";
String html = request(token, "post", data, "https://" + instance + ".salesforce.com/services/data/v24.0/chatter/feeds/record/" + recordId + "/feed-items");
JSONObject json = (JSONObject)JSONSerializer.toJSON(html);
feedItemId = json.getString("id");
return feedItemId;
}
public String postComment(String feedItemId, Map<String, String> data) throws Exception {
String commentId = "";
String html = request(token, "post", data, "https://" + instance + ".salesforce.com/services/data/v24.0/chatter/feed-items/" + feedItemId + "/comments");
JSONObject json = (JSONObject)JSONSerializer.toJSON(html);
commentId = json.getString("id");
return commentId;
}
public static String getToken(LoginResult loginResult) {
return loginResult.getSessionId();
}
public static String getInstance(LoginResult loginResult) {
String url = loginResult.getServerUrl();
String pat1 = "https://";
String pat2 = "-api.salesforce.com";
int pos1 = url.indexOf(pat1);
int pos2 = url.indexOf(pat2);
String instance = "ap1";
if (pos1 >= 0 && pos2 >= 0 && pos1 + pat1.length() < pos2) {
instance = url.substring(pos1 + pat1.length(), pos2);
}
return instance;
}
public static String request(String token, String method, Map<String, String> data, String link) throws Exception {
URL url = new URL(link);
URLConnection conn = url.openConnection();
HttpURLConnection http = (HttpURLConnection)conn;
http.setRequestMethod(method.toUpperCase());
conn.setDoInput(true);
conn.setDoOutput(true);
conn.setRequestProperty("Authorization", "OAuth " + token);
String output = "";
for (String key : data.keySet()) {
if (output.length() > 0) output += "&";
output += key + "=" + URLEncoder.encode(data.get(key), "UTF-8");
}
BufferedWriter out = new BufferedWriter(new OutputStreamWriter(conn.getOutputStream()));
out.write(output);
out.close();
BufferedReader in = new BufferedReader(new InputStreamReader(conn.getInputStream()));
String response = "";
String line = null;
while ((line = in.readLine()) != null) {
if (response.length() > 0) {
response += "\r\n";
}
response += line;
}
in.close();
return response;
}
}
