import com.notnoop.apns.internal.Utilities; //导入依赖的package包/类
@Test
public void abitComplicatedEnglishLength() {
    byte[] dtBytes = new byte[32];
    new Random().nextBytes(dtBytes);

    String deviceToken = Utilities.encodeHex(dtBytes);
    PayloadBuilder builder = new PayloadBuilder().alertBody("test");

    SimpleApnsNotification fromString = new SimpleApnsNotification(deviceToken, builder.build());
    SimpleApnsNotification fromBytes = new SimpleApnsNotification(dtBytes, Utilities.toUTF8Bytes(builder.build()));

    String expected = "{\"aps\":{\"alert\":\"test\"}}";
    int actualPacketLength = 1 + 2 + dtBytes.length + 2 + /* payload length = */ Utilities.toUTF8Bytes(expected).length;
    assertEquals(actualPacketLength, fromString.length());
    assertEquals(actualPacketLength, fromBytes.length());
    assertEquals(expected.length(), fromString.getPayload().length);
    assertArrayEquals(fromString.marshall(), fromBytes.marshall());
    assertFalse(builder.isTooLong());
}
 

import com.notnoop.apns.internal.Utilities; //导入依赖的package包/类
@Provides
@Singleton
ApnsService provideApnsService(ServletContext context,
    @Flag(FlagName.APNS_CERT_PASSWORD) String password) {
  String ksAlgorithm =
      ((KeyManagerFactory.getDefaultAlgorithm() == null) ? "sunx509" : KeyManagerFactory
          .getDefaultAlgorithm());
  InputStream inputStream;
  if (SystemProperty.environment.value() == SystemProperty.Environment.Value.Production) {
    // The app is running on App Engine...
    // inputStream = context.getResourceAsStream("/WEB-INF/ApnsProduction.jks");
    inputStream = context.getResourceAsStream("/WEB-INF/ApnsDevelopment.jks");
  } else {
    inputStream = context.getResourceAsStream("/WEB-INF/ApnsDevelopment.jks");
  }
  SSLContext sslContext = Utilities.newSSLContext(inputStream, password, "JKS", ksAlgorithm);
  return APNS.newService().withSSLContext(sslContext).withSandboxDestination()
      .withNoErrorDetection().build();
}
 

import com.notnoop.apns.internal.Utilities; //导入依赖的package包/类
@Test
public void abitComplicatedEnglishLength() {
    final byte[] dtBytes = new byte[32];
    new Random().nextBytes(dtBytes);

    final String deviceToken = Utilities.encodeHex(dtBytes);
    final PayloadBuilder builder = new PayloadBuilder().alertBody("test");

    final SimpleApnsNotification fromString = new SimpleApnsNotification(deviceToken, builder.build());
    final SimpleApnsNotification fromBytes = new SimpleApnsNotification(dtBytes, Utilities.toUTF8Bytes(builder.build()));

    final String expected = "{\"aps\":{\"alert\":\"test\"}}";
    final int actualPacketLength = 1 + 2 + dtBytes.length + 2 + /* payload length = */ Utilities.toUTF8Bytes(expected).length;
    assertEquals(actualPacketLength, fromString.length());
    assertEquals(actualPacketLength, fromBytes.length());
    assertEquals(expected.length(), fromString.getPayload().length);
    assertArrayEquals(fromString.marshall(), fromBytes.marshall());
    assertFalse(builder.isTooLong());
}
 

import com.notnoop.apns.internal.Utilities; //导入依赖的package包/类
public ApnsServiceFactory() {
    this.gatewayHost = Utilities.PRODUCTION_GATEWAY_HOST;
    this.gatewayPort = Utilities.PRODUCTION_GATEWAY_PORT;

    this.feedbackHost = Utilities.PRODUCTION_FEEDBACK_HOST;
    this.feedbackPort = Utilities.PRODUCTION_FEEDBACK_PORT;
}
 

import com.notnoop.apns.internal.Utilities; //导入依赖的package包/类
public static ApnsServerStub prepareAndStartServer(int gatePort, int feedPort) {
    InputStream stream = ClassLoader.getSystemResourceAsStream(FixedCertificates.SERVER_STORE);
    SSLContext context = Utilities.newSSLContext(stream, FixedCertificates.SERVER_PASSWORD, 
                                                 "PKCS12", getAlgorithm());

    
    ApnsServerStub server = new ApnsServerStub(
            context.getServerSocketFactory(),
            gatePort, feedPort);
    server.start();
    return server;
}
 

import com.notnoop.apns.internal.Utilities; //导入依赖的package包/类
@Override
public String toString() {
    String payloadString = "???";
    try {
        payloadString = new String(payload, "UTF-8");
    } catch (Exception _) {}        
    return "Message(Token="+Utilities.encodeHex(deviceToken)+"; Payload="+payloadString+")";
}
 

import com.notnoop.apns.internal.Utilities; //导入依赖的package包/类
/**
 * Shrinks the alert message body so that the resulting payload
 * message fits within the passed expected payload length.
 *
 * This method performs best-effort approach, and its behavior
 * is unspecified when handling alerts where the payload
 * without body is already longer than the permitted size, or
 * if the break occurs within word.
 *
 * @param payloadLength the expected max size of the payload
 * @param postfix for the truncated body, e.g. "..."
 * @return  this
 */
public PayloadBuilder resizeAlertBody(final int payloadLength, final String postfix) {
    int currLength = length();
    if (currLength <= payloadLength) {
        return this;
    }

    // now we are sure that truncation is required
    String body = (String)customAlert.get("body");

    final int acceptableSize = Utilities.toUTF8Bytes(body).length
            - (currLength - payloadLength
                    + Utilities.toUTF8Bytes(postfix).length);
    body = Utilities.truncateWhenUTF8(body, acceptableSize) + postfix;

    // set it back
    customAlert.put("body", body);

    // calculate the length again
    currLength = length();

    if(currLength > payloadLength) {
        // string is still too long, just remove the body as the body is
        // anyway not the cause OR the postfix might be too long
        customAlert.remove("body");
    }

    return this;
}
 

import com.notnoop.apns.internal.Utilities; //导入依赖的package包/类
/**
 * Constructs an instance of {@code ApnsNotification}.
 *
 * The message encodes the payload with a {@code UTF-8} encoding.
 *
 * @param dtoken    The Hex of the device token of the destination phone
 * @param payload   The payload message to be sent
 */
public EnhancedApnsNotification(
        int identifier, int expiryTime,
        String dtoken, String payload) {
    this.identifier = identifier;
    this.expiry = expiryTime;
    this.deviceToken = Utilities.decodeHex(dtoken);
    this.payload = Utilities.toUTF8Bytes(payload);
}
 

import com.notnoop.apns.internal.Utilities; //导入依赖的package包/类
/**
 * Returns the binary representation of the message as expected by the
 * APNS server.
 *
 * The returned array can be used to sent directly to the APNS server
 * (on the wire/socket) without any modification.
 */
public byte[] marshall() {
    if (marshall == null) {
        marshall = Utilities.marshallEnhanced(COMMAND, identifier,
                expiry, deviceToken, payload);
    }
    return marshall;
}
 

import com.notnoop.apns.internal.Utilities; //导入依赖的package包/类
@Override
public String toString() {
    String payloadString = "???";
    try {
        payloadString = new String(payload, "UTF-8");
    } catch (Exception _) {}        
    return "Message(Id="+identifier+"; Token="+Utilities.encodeHex(deviceToken)+"; Payload="+payloadString+")";
}
 

import com.notnoop.apns.internal.Utilities; //导入依赖的package包/类
@Override
  public void messageSendFailed(ApnsNotification message, Throwable e) {
    LOGGER.error("APNS Message delivery failed for key:{}", key, e);
    if (message != null) {
      byte[] tokenByte = message.getDeviceToken();
      String deviceToken = Utilities.encodeHex(tokenByte);
      LOGGER.error("APNS Message delivery failed for key:{}", key, e);

      //TODO : Revisit failure handling. Commented on 12/17/2015
//      invalidateToken(deviceToken);
//      byte[] payload = message.getPayload();
//      String payloadString = fromBytes(payload);
//      if (payloadString != null) {
//        APNSPayloadInfo info = APNSPayloadInfo.parse(payloadString);
//        if (info != null && info.getMessageId() != null) {
//          Integer errorCode = null;
//          if (e instanceof ApnsDeliveryErrorException) {
//            errorCode = Integer.valueOf(((ApnsDeliveryErrorException) e).getDeliveryError().code());
//          }
//          //mark push message state as error
//          updatePushMessageState(info.getMessageId(), errorCode);
//        }
//      }
    } else {
      LOGGER.error("APNS Message delivery failed but ApnsNotification message is null and hence can't invalidate the token");
    }
  }
 

import com.notnoop.apns.internal.Utilities; //导入依赖的package包/类
/**
 * Shrinks the alert message body so that the resulting payload
 * message fits within the passed expected payload length.
 *
 * This method performs best-effort approach, and its behavior
 * is unspecified when handling alerts where the payload
 * without body is already longer than the permitted size, or
 * if the break occurs within word.
 *
 * @param payloadLength the expected max size of the payload
 * @param postfix for the truncated body, e.g. "..."
 * @return  this
 */
public PayloadBuilder resizeAlertBody(int payloadLength, String postfix) {
    int currLength = length();
    if (currLength <= payloadLength) {
        return this;
    }

    // now we are sure that truncation is required
    String body = (String)customAlert.get("body");

    int acceptableSize = Utilities.toUTF8Bytes(body).length
            - (currLength - payloadLength
                    + Utilities.toUTF8Bytes(postfix).length);
    body = Utilities.truncateWhenUTF8(body, acceptableSize) + postfix;

    // set it back
    customAlert.put("body", body);

    // calculate the length again
    currLength = length();

    if(currLength > payloadLength) {
        // string is still too long, just remove the body as the body is
        // anyway not the cause OR the postfix might be too long
        customAlert.remove("body");
    }

    return this;
}
 

import com.notnoop.apns.internal.Utilities; //导入依赖的package包/类
public static SSLContext serverContext() {
    try {
        System.setProperty("javax.net.ssl.trustStore", ClassLoader.getSystemResource(CLIENT_STORE).getPath());
        InputStream stream = ClassLoader.getSystemResourceAsStream(SERVER_STORE);
        SSLContext context = Utilities.newSSLContext(stream, SERVER_PASSWD, "PKCS12", "sunx509");

        return context;
    } catch (Exception e) {
        throw new RuntimeException(e);
    }
}
 

import com.notnoop.apns.internal.Utilities; //导入依赖的package包/类
public static SSLContext clientContext() {
    try {
        InputStream stream = ClassLoader.getSystemResourceAsStream(CLIENT_STORE);
        SSLContext context = Utilities.newSSLContext(stream, CLIENT_PASSWD, "PKCS12", "sunx509");
        context.init(null, new TrustManager[] { new X509TrustManagerTrustAll() }, new SecureRandom());
        return context;
    } catch (Exception e) {
        throw new RuntimeException(e);
    }
}
 

import com.notnoop.apns.internal.Utilities; //导入依赖的package包/类
@Theory
public void truncateUTF8Properly(Object[] p) {
    String str = (String)p[0];
    int maxBytes = (Integer)p[1];
    int expectedBytes = (Integer)p[2];

    String result = Utilities.truncateWhenUTF8(str, maxBytes);
    byte[] utf8 = Utilities.toUTF8Bytes(result);

    Assert.assertEquals(expectedBytes, utf8.length);
}
 

import com.notnoop.apns.internal.Utilities; //导入依赖的package包/类
@Test
public void simpleEnglishLength() {
    PayloadBuilder builder = new PayloadBuilder().alertBody("test");
    String expected = "{\"aps\":{\"alert\":\"test\"}}";
    assertEqualsJson(expected, builder.build());
    int actualLength = Utilities.toUTF8Bytes(expected).length;
    assertEquals(actualLength, builder.length());
    assertFalse(builder.isTooLong());
}
 

import com.notnoop.apns.internal.Utilities; //导入依赖的package包/类
@Theory
public void deviceTokenPart(String deviceToken, PayloadBuilder payload) {
    SimpleApnsNotification msg = new SimpleApnsNotification(deviceToken, payload.build());
    byte[] bytes = msg.marshall();

    byte[] dt = decodeHex(deviceToken);
    assertEquals(dt.length, /* found length */ (bytes[1] << 8) + bytes[2]);

    // verify the device token part
    assertArrayEquals(dt, Utilities.copyOfRange(bytes, 3, 3 + dt.length));
}
 

import com.notnoop.apns.internal.Utilities; //导入依赖的package包/类
@Theory
public void payloadPart(String deviceToken, PayloadBuilder payload) {
    String payloadString = payload.build();
    SimpleApnsNotification msg = new SimpleApnsNotification(deviceToken, payloadString);
    byte[] bytes = msg.marshall();

    byte[] pl = toUTF8Bytes(payloadString);

    // in reverse
    int plBegin = bytes.length - pl.length;

    /// verify the payload part
    assertArrayEquals(pl, Utilities.copyOfRange(bytes, plBegin, bytes.length));
    assertEquals(pl.length, (bytes[plBegin - 2] << 8) + bytes[plBegin - 1]);
}
 

import com.notnoop.apns.internal.Utilities; //导入依赖的package包/类
@Override
@SuppressFBWarnings("DE_MIGHT_IGNORE")
public String toString() {
    String payloadString;
    try {
        payloadString = new String(payload, "UTF-8");
    } catch (Exception ex) {
        payloadString = "???";
    }
    return "Message(Token="+Utilities.encodeHex(deviceToken)+"; Payload="+payloadString+")";
}
 

import com.notnoop.apns.internal.Utilities; //导入依赖的package包/类
/**
 * Returns the binary representation of the message as expected by the
 * APNS server.
 *
 * The returned array can be used to sent directly to the APNS server
 * (on the wire/socket) without any modification.
 */
public byte[] marshall() {
    if (marshall == null) {
        marshall = Utilities.marshallEnhanced(COMMAND, identifier,
                expiry, deviceToken, payload);
    }
    return marshall.clone();
}