package com.juick.components; import com.fasterxml.jackson.databind.ObjectMapper; import com.juick.components.mpns.MPNSError; import com.juick.components.mpns.MPNSToken; import com.juick.service.BaseRestService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Value; import org.springframework.http.*; import javax.annotation.PostConstruct; import javax.inject.Inject; import java.io.IOException; /** * Created by vital on 29.03.2017. */ public class MPNSClient { private static Logger logger = LoggerFactory.getLogger(MPNSClient.class); private String accessToken; private NotificationClientListener listener; @Inject private ObjectMapper jsonMapper; @Value("${wns_application_sip}") private String applicationSip; @Value("${wns_client_secret}") private String applicationSecret; @Inject private BaseRestService restService; @PostConstruct public void authenticate() throws IOException { String url = "https://login.live.com/accesstoken.srf"; HttpHeaders httpHeaders = new HttpHeaders(); httpHeaders.add("grant_type", "client_credentials"); httpHeaders.add("client_id", applicationSip); httpHeaders.add("client_secret", applicationSecret); httpHeaders.add("scope", "notify.windows.com"); HttpEntity entity = new HttpEntity<>(httpHeaders); ResponseEntity response = restService.getRest().exchange(url, HttpMethod.POST, entity, String.class); String responseBody = response.getBody(); HttpStatus statusCode = response.getStatusCode(); if (statusCode != HttpStatus.OK) { MPNSError error = jsonMapper.readValue(responseBody, MPNSError.class); throw new IOException(error.getError() + ": " + error.getErrorDescription()); } MPNSToken token = jsonMapper.readValue(responseBody, MPNSToken.class); if (token.getTokenType().length() >= 1) { token.setTokenType(Character.toUpperCase(token.getTokenType().charAt(0)) + token.getTokenType().substring(1)); } accessToken = token.getTokenType() + " " + token.getAccessToken(); logger.info("MPNS authenticated"); } void sendNotification(final String url, final String xml) throws IOException { HttpHeaders httpHeaders = new HttpHeaders(); httpHeaders.add("Content-Type", "text/xml"); httpHeaders.add("Authorization", accessToken); httpHeaders.add("X-WNS-Type", "wns/toast"); HttpEntity requestEntity = new HttpEntity<>(httpHeaders); ResponseEntity responseEntity = restService.getRest().exchange(url, HttpMethod.POST, requestEntity, Void.class); HttpStatus statusCode = responseEntity.getStatusCode(); if (statusCode != HttpStatus.OK) { if (statusCode == HttpStatus.GONE) { // expired logger.info("{} is scheduled to remove", url); listener.invalidToken("mpns", url); } else { String headersContent = responseEntity.getHeaders().toString(); throw new IOException(headersContent); } } } public void setListener(NotificationClientListener listener) { this.listener = listener; } }