org.xdi.oxauth.service.push.sns.PushSnsService クラス

org.xdi.oxauth.service.push.sns.PushSnsService 連携図

公開メンバ関数
AmazonSNS	createSnsClient (String accessKey, String secretKey, String region)
String	createPlatformArn (AmazonSNS snsClient, String platformApplicationArn, String token, User user)
String	getCustomUserData (User user)
PublishResult	sendPushMessage (AmazonSNS snsClient, PushPlatform platform, String targetArn, Map< String, Object > customAppMessageMap, Map< String, MessageAttributeValue > messageAttributes) throws IOException
PublishResult	sendPushMessage (AmazonSNS snsClient, PushPlatform platform, String targetArn, String message, Map< String, MessageAttributeValue > messageAttributes) throws IOException

非公開変数類
EncryptionService	encryptionService
AppConfiguration	appConfiguration
PersistenceEntryManager	ldapEntryManager

詳解

Provides operations to send AWS SNS push messages

著者

Yuriy Movchan Date: 08/31/2017

関数詳解

createPlatformArn()

String org.xdi.oxauth.service.push.sns.PushSnsService.createPlatformArn ( AmazonSNS  snsClient, String  platformApplicationArn, String  token, User  user  )

inline

                                                                                                                     {
                CreatePlatformEndpointRequest platformEndpointRequest = new CreatePlatformEndpointRequest();
                platformEndpointRequest.setPlatformApplicationArn(platformApplicationArn);
                platformEndpointRequest.setToken(token);
                
                String customUserData = getCustomUserData(user);
                platformEndpointRequest.setCustomUserData(customUserData);
                
                CreatePlatformEndpointResult platformEndpointResult = snsClient.createPlatformEndpoint(platformEndpointRequest);

                return platformEndpointResult.getEndpointArn();
        }

createSnsClient()

AmazonSNS org.xdi.oxauth.service.push.sns.PushSnsService.createSnsClient ( String  accessKey, String  secretKey, String  region  )

inline

                                                                                            {
                String decryptedAccessKey = encryptionService.decrypt(accessKey, true);
                String decryptedSecretKey = encryptionService.decrypt(secretKey, true);

                BasicAWSCredentials credentials = new BasicAWSCredentials(decryptedAccessKey, decryptedSecretKey);
            AmazonSNS snsClient = AmazonSNSClientBuilder.standard().withRegion(Regions.fromName(region)).withCredentials(new AWSStaticCredentialsProvider(credentials)).build();
            
            return snsClient;
        }

getCustomUserData()

String org.xdi.oxauth.service.push.sns.PushSnsService.getCustomUserData ( User  user )

inline

                                                   {
                String customUserData = String.format("Issuer: %s, user: %s, date: %s", appConfiguration.getIssuer(), user.getUserId(),
                                ldapEntryManager.encodeTime(new Date()));
                return customUserData;
        }

sendPushMessage() [1/2]

PublishResult org.xdi.oxauth.service.push.sns.PushSnsService.sendPushMessage ( AmazonSNS  snsClient, PushPlatform  platform, String  targetArn, Map< String, Object >  customAppMessageMap, Map< String, MessageAttributeValue >  messageAttributes  ) throws IOException

inline

                                                                                                                                                                                                                             {
                Map<String, Object> appMessageMap = new HashMap<String, Object>();

                if (platform == PushPlatform.GCM) {
                        appMessageMap.put("collapse_key", "single");
                        appMessageMap.put("delay_while_idle", true);
                        appMessageMap.put("time_to_live", 30);
                        appMessageMap.put("dry_run", false);
                }

                if (customAppMessageMap != null) {
                        appMessageMap.putAll(customAppMessageMap);
                }

                String message = ServerUtil.asJson(appMessageMap);

                return sendPushMessage(snsClient, platform, targetArn, message, messageAttributes);
        }

sendPushMessage() [2/2]

PublishResult org.xdi.oxauth.service.push.sns.PushSnsService.sendPushMessage ( AmazonSNS  snsClient, PushPlatform  platform, String  targetArn, String  message, Map< String, MessageAttributeValue >  messageAttributes  ) throws IOException

inline

                                                                                                 {
                Map<String, String> messageMap = new HashMap<String, String>();
                messageMap.put(platform.name(), message);
                message = ServerUtil.asJson(messageMap);

            PublishRequest publishRequest = new PublishRequest();
                publishRequest.setMessageStructure("json");
                
                if (messageAttributes != null) {
                        publishRequest.setMessageAttributes(messageAttributes);
                }

                publishRequest.setTargetArn(targetArn);
                publishRequest.setMessage(message);

                PublishResult publishResult = snsClient.publish(publishRequest);

                return publishResult;
        }

メンバ詳解

appConfiguration

AppConfiguration org.xdi.oxauth.service.push.sns.PushSnsService.appConfiguration

private

encryptionService

EncryptionService org.xdi.oxauth.service.push.sns.PushSnsService.encryptionService

private

ldapEntryManager

PersistenceEntryManager org.xdi.oxauth.service.push.sns.PushSnsService.ldapEntryManager

private

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/OpenId/gluu/src/oxAuth/Server/src/main/java/org/xdi/oxauth/service/push/sns/PushSnsService.java