PX OrderInfo

Lumen supports the OAuth 2.0 client credentials authorization grant flow for external access by client-side applications. Once your credentials are approved you can go to Using OAuth 2.0 for detailed steps on getting a bearer token using basic authorization base64 encoding.  Use the navigation menu and select Code Samples for an example of authorization.

PxAuthenticationService.java
----------------------------

package com.ctl.px.api.client;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import org.apache.oltu.oauth2.client.OAuthClient;
import org.apache.oltu.oauth2.client.URLConnectionClient;
import org.apache.oltu.oauth2.client.request.OAuthClientRequest;
import org.apache.oltu.oauth2.client.response.OAuthJSONAccessTokenResponse;
import org.apache.oltu.oauth2.common.OAuth;
import org.apache.oltu.oauth2.common.message.types.GrantType;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

@Service
public class PxAuthenticationService {

    Logger log = LoggerFactory.getLogger(PxAuthenticationService.class);
    
    @Value("${px.sf.token.url}")
    private String tokenURL;
    
    @Value("${px.sf.token.basicAuth}")
    private String basicAuth;

    public String getAccessToken() {
        String accessToken = null;
        String methodName = new Object() {
        }.getClass().getEnclosingMethod().getName();

        try {
            OAuthClient client = new OAuthClient(new URLConnectionClient());

            OAuthClientRequest request = OAuthClientRequest.tokenLocation(tokenURL)
                    .setGrantType(GrantType.CLIENT_CREDENTIALS).buildBodyMessage();

            request.addHeader(OAuth.HeaderType.AUTHORIZATION, "Basic " + basicAuth);
            accessToken = client.accessToken(request, OAuthJSONAccessTokenResponse.class).getAccessToken();

        } catch (Exception exn) {
            exn.printStackTrace();
        }
        return accessToken;
    }

}

PxNewOrderRestClient.java
------------------------

package com.ctl.px.api.client;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.web.client.RestTemplateBuilder;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.http.converter.json.MappingJackson2HttpMessageConverter;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;

import com.ctl.px.api.model.NewOrderRequestObj;
@Component
public class PxNewOrderRestClient {

    @Autowired
    private PxAuthenticationService authenticationService;

    @Autowired
    private RestTemplateBuilder restTemplateBuilder;

    @Value("${px.newOrder.url}")
    private String newOrderUrl;

    Logger log = LoggerFactory.getLogger(PxNewOrderRestClient.class);

    public ResponseEntity<String> getNewOrder(NewOrderRequestObj newOrderRequest) {
        RestTemplate restTemplate;
        restTemplate = restTemplateBuilder.build();
        String accessToken = authenticationService.getAccessToken();
        log.debug("Using access token: " + accessToken);
        HttpHeaders headers = new HttpHeaders();
        headers.add("Authorization", "Bearer " + accessToken);
        headers.setContentType(MediaType.APPLICATION_JSON);
        restTemplate.getMessageConverters().add(new MappingJackson2HttpMessageConverter());
        ResponseEntity<String> response = null;
        try {
            HttpEntity<NewOrderRequestObj> request = new HttpEntity<>(newOrderRequest, headers);
            response = restTemplate.postForEntity(newOrderUrl, request, String.class);
        } catch (Exception e) {
            log.debug("Exception occurred while making rest call to " + newOrderUrl + ", Exception was: "
                    + e.getStackTrace());
        }

        return response;

    }

}

PxOpenOrderRestClient.java
--------------------------

package com.ctl.px.api.client;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.web.client.RestTemplateBuilder;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.http.converter.json.MappingJackson2HttpMessageConverter;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;

import com.ctl.px.api.model.OpenOrderRequestObj;

@Component
public class PxOpenOrderRestClient {
    
    @Autowired
    private PxAuthenticationService authenticationService;
    
    @Autowired
    private RestTemplateBuilder restTemplateBuilder;
    
    @Value("${px.openOrder.url}")
    private String openOrderUrl;

    Logger log = LoggerFactory.getLogger(PxOpenOrderRestClient.class);    
    
    public ResponseEntity<String> getOpenOrders(OpenOrderRequestObj openOrderRequest) {
        RestTemplate restTemplate;
        restTemplate = restTemplateBuilder.build();
        String accessToken = authenticationService.getAccessToken();
        log.debug("Using access token: "+accessToken);
        HttpHeaders headers = new HttpHeaders();
        headers.add("Authorization","Bearer "+accessToken);
        headers.setContentType(MediaType.APPLICATION_JSON);
        restTemplate.getMessageConverters().add(new MappingJackson2HttpMessageConverter());
        ResponseEntity<String> response = null;
        try {
            HttpEntity<OpenOrderRequestObj> request = new HttpEntity<>(openOrderRequest, headers);
            response = restTemplate.postForEntity(openOrderUrl, request, String.class);            
        }catch(Exception e) {
            log.debug("Exception occurred while making rest call to "+openOrderUrl+", Exception was: "+ e.getStackTrace());
        }        
        
        return response;

        
    }    

}

PxOrderDetailClient.java
------------------------

package com.ctl.px.api.client;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.web.client.RestTemplateBuilder;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.http.converter.json.MappingJackson2HttpMessageConverter;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;

import com.ctl.px.api.model.OrderDetailRequestObj;

@Component
public class PxOrderDetailClient {

    @Autowired
    private PxAuthenticationService authenticationService;

    @Autowired
    private RestTemplateBuilder restTemplateBuilder;

    @Value("${px.orderDetail.url}")
    private String orderDetailUrl;

    Logger log = LoggerFactory.getLogger(PxOrderDetailClient.class);

    public ResponseEntity<String> getOrderDetail(OrderDetailRequestObj orderDetailRequest) {
        RestTemplate restTemplate;
        restTemplate = restTemplateBuilder.build();
        String accessToken = authenticationService.getAccessToken();
        log.debug("Using access token: " + accessToken);
        HttpHeaders headers = new HttpHeaders();
        headers.add("Authorization", "Bearer " + accessToken);
        headers.setContentType(MediaType.APPLICATION_JSON);
        restTemplate.getMessageConverters().add(new MappingJackson2HttpMessageConverter());
        ResponseEntity<String> response = null;
        try {
            HttpEntity<OrderDetailRequestObj> request = new HttpEntity<>(orderDetailRequest, headers);
            response = restTemplate.postForEntity(orderDetailUrl, request, String.class);
        } catch (Exception e) {
            log.debug("Exception occurred while making rest call to " + orderDetailUrl + ", Exception was: "
                    + e.getStackTrace());
        }

        return response;

    }

}