REST-API

[love-dev.1988]

Hi Experts;

I'm trying to complete a task in kie-wb using eclipse, I'm based on REST-API.

I added the class rest.java to my project:

1. package com.acme.rewards.ejb;
3. import java.io.BufferedReader;
4. import java.io.IOException;
5. import java.io.InputStreamReader;
6. import java.io.OutputStream;
7. import java.io.OutputStreamWriter;
8. import java.io.Writer;
9. import java.net.HttpURLConnection;
10. import java.net.URL;
11. import java.net.URLEncoder;
13. public class rest {
14.         public static String httpGet(String urlStr) throws IOException {
15.                   URL url = new URL(urlStr);
16.                   HttpURLConnection conn =(HttpURLConnection) url.openConnection();
17.                   System.out.println(conn.getResponseCode());
18.                   if (conn.getResponseCode() != 200) {
19.                     throw new IOException(conn.getResponseMessage());
20.                   }
21.                   BufferedReader rd = new BufferedReader(new InputStreamReader(conn.getInputStream()));
22.                   StringBuilder sb = new StringBuilder();
23.                   String line;
24.                   while ((line = rd.readLine()) != null) {
25.                     sb.append(line);
26.                   }
27.                   rd.close();
28.                   conn.disconnect();
29.                   return sb.toString();
30.                 }
31. 
    
32.    public static String httpPost(String urlStr, String[] paramName,
33.                         String[] paramVal) throws Exception {
34.                           URL url = new URL(urlStr);
35.                           HttpURLConnection conn =(HttpURLConnection) url.openConnection();
36.                           conn.setRequestMethod("POST");
37.                           conn.setDoOutput(true);
38.                           conn.setDoInput(true);
39.                           conn.setUseCaches(false);
40.                           conn.setAllowUserInteraction(false);
41.                           conn.setRequestProperty("Content-Type",
42.                               "application/x-www-form-urlencoded");
44.                           // Create the form content
45.                           OutputStream out = conn.getOutputStream();
46.                           Writer writer = new OutputStreamWriter(out, "UTF-8");
47.                           for (int i = 0; i < paramName.length; i++) {
48.                             writer.write(paramName[i]);
49.                             writer.write("=");
50.                             writer.write(URLEncoder.encode(paramVal[i], "UTF-8"));
51.                             writer.write("&");
52.                           }
53.                           writer.close();
54.                           out.close();
55.                           if (conn.getResponseCode() != 200) {
56.                             throw new IOException(conn.getResponseMessage());
57.                           }
58.                           BufferedReader rd = new BufferedReader(
59.                           new InputStreamReader(conn.getInputStream()));
60.                           StringBuilder sb = new StringBuilder();
61.                           String line;
62.                           while ((line = rd.readLine()) != null) {
63.                             sb.append(line);
64.                           }
65.                           rd.close();
66.                           conn.disconnect();
67.                           return sb.toString();
68.                         }
69.       
70.       public static void main(String[] args) {
71.                 String urlStr="http://localhost:8080/jbpm-console/rest/task/778";                           
72.                 try {
73.                         httpGet(urlStr);
74.                 } catch (IOException e) {
75.                         e.printStackTrace();
76.                 }
77.         }
78.       
79.       
80. }

When I http://localhost:8080/jbpm-console/rest/task/778 on the browser, I obtained the file XML: So it's well.

The problem is :Once I run as java Application, I obtained this error:

1. 401
2. java.io.IOException: Unauthorized
3.         at com.acme.rewards.ejb.rest.httpGet(rest.java:23)
4.         at com.acme.rewards.ejb.rest.main(rest.java:91)

Could you please help me solving this error ?

Thanks in advance.

[jaredmladner]

My REST client accessing jBPM REST API is in NodeJS. In NodeJS I am using the Restify module to create an HTTP connection and we had to set the Basic Auth credentials. It works in your browser because you have probably logged into the console previously and still have the cookie cached.

Try setting the Basic Auth creds and see if that works.

[love-dev.1988]

Hi Jared,

Thanks for your reply.

I'm using Advanced REST Client available in GOOGLE Chrome,

• When I put in this REST Client  http://localhost:8080/jbpm-console/rest/task/778/complete  the task 778 is completed in KIE-WB.

          ---> So it's OK .

• When I put in Google Chrome browser http://localhost:8080/jbpm-console/rest/task/778 , I obtained the different informations about this task(id, potential-owner, status, ...)

        ---> So it's OK .

==> So Basic Auth credentials are correct.

The problem is when I run as java application the class rest.java, I recieve the error presented previously.

I didn't know what I missed   !!!!?.

Thanks for help.

[jaredmladner]

I still think your problem is that you are not setting the Basic Authorization Header and credentials in rest.java. The Advanced REST client and Google Chrome will use the your cached authorization cookies if you have already logged into the jbpm-console manually. If you logout of the jbpm-console and try accessing the URL in Advanced REST client and Google Chrome it should not work and you will get Unauthorized.

Your rest.java HttpURLConnection needs to set the "Authorization" header with the credentials.

HttpURLConnection connection = (HttpURLConnection) new URL(url).openConnection();
String encoded = Base64.encode(username+":"+password);
connection.setRequestProperty("Authorization", "Basic "+encoded);

We are using using the Apache HTTP Client as below and works for us:

  public static String doHttpGet(String uri, String user, String pass)

  {

  HttpGet httpget = new HttpGet(uri);

  //Set the Authorization Header

  UsernamePasswordCredentials credentials = new UsernamePasswordCredentials(user, pass);

        BasicScheme scheme = new BasicScheme();

        Header authorizationHeader;

  try {

  authorizationHeader = scheme.authenticate(credentials, httpget, null);

  httpget.addHeader(authorizationHeader);

  } catch (AuthenticationException e) {

  logger.error("Couldn't add authorization header.", e);

  }

  return makeHttpRequest(httpget);

  }