import com.google.api.client.repackaged.org.apache.commons.codec.binary.Base64; //导入依赖的package包/类
public static List<File> downloadAttachments(Message message, String downloadLocation) throws IOException {
    List<File> attachmentsList = new ArrayList<>();
    List<MessagePart> parts = message.getPayload().getParts();
    if(parts !=null){
    for(MessagePart part: parts){
        if(part.getFilename() != null && part.getFilename().length() >0){
            String filename = part.getFilename();
            String attId = part.getBody().getAttachmentId();
            MessagePartBody attachPart = Login.service.users().messages().attachments()
                    .get("me", message.getId(), attId).execute();

            Base64 base64Url = new Base64(true);
            byte[] fileByteArray = base64Url.decodeBase64(attachPart.getData());
            File temp = new File(downloadLocation);
            if(!temp.exists())
                temp.mkdir();
            FileOutputStream fileOutputStream = new FileOutputStream(temp+"/"+filename);
            fileOutputStream.write(fileByteArray);
            fileOutputStream.close();
            attachmentsList.add(new File(temp+"/"+filename));
        }
    }
    }
    return attachmentsList;
}
 

import com.google.api.client.repackaged.org.apache.commons.codec.binary.Base64; //导入依赖的package包/类
@Override
public String sign(HttpRequest request, HttpParameters requestParams)
    throws OAuthMessageSignerException {

  final OAuthRsaSigner signer = new OAuthRsaSigner();
  final byte[] privateBytes = Base64.decodeBase64(getConsumerSecret());
  final PKCS8EncodedKeySpec keySpec = new PKCS8EncodedKeySpec(privateBytes);

  try {
    signer.privateKey = KeyFactory.getInstance("RSA").generatePrivate(keySpec);
    final String signatureBaseString = new SignatureBaseString(request, requestParams).generate();
    return signer.computeSignature(signatureBaseString);
  } catch (GeneralSecurityException e) {
    throw new OAuthMessageSignerException(e);
  }
}
 

import com.google.api.client.repackaged.org.apache.commons.codec.binary.Base64; //导入依赖的package包/类
private Message createMessageWithEmail(MimeMessage email) throws MessagingException, IOException {
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    email.writeTo(baos);
    String encodedEmail = Base64.encodeBase64URLSafeString(baos.toByteArray());
    Message message = new Message();
    message.setRaw(encodedEmail);
    return message;
}
 

import com.google.api.client.repackaged.org.apache.commons.codec.binary.Base64; //导入依赖的package包/类
private String getLocalMd5hash(String filePath) throws IOException
{
    try {
        MessageDigest md = MessageDigest.getInstance("MD5");
        try (BufferedInputStream input = new BufferedInputStream(new FileInputStream(new File(filePath)))) {
            byte[] buffer = new byte[256];
            int len;
            while ((len = input.read(buffer, 0, buffer.length)) >= 0) {
                md.update(buffer, 0, len);
            }
            return new String(Base64.encodeBase64(md.digest()));
        }
    }
    catch (NoSuchAlgorithmException ex) {
        throw new ConfigException("MD5 algorism not found");
    }
}
 

import com.google.api.client.repackaged.org.apache.commons.codec.binary.Base64; //导入依赖的package包/类
public static String getMessageBody(Message m) throws IOException {
    String string = null;
    if (m.getPayload().getParts() == null)
        string = m.getPayload().getBody().getData().toString();
    else {
        string = getHtmlParts(m.getPayload().getParts());
    }
    String decodedString = new String(Base64.decodeBase64(string.getBytes()));
    return decodedString;
}
 

import com.google.api.client.repackaged.org.apache.commons.codec.binary.Base64; //导入依赖的package包/类
private static Message createFromMimeMessage(MimeMessage email) throws IOException, MessagingException {
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    email.writeTo(baos);
    String encodedEmail = Base64.encodeBase64URLSafeString(baos.toByteArray());
    Message message = new Message();
    message.setRaw(encodedEmail);
    return message;
}
 

import com.google.api.client.repackaged.org.apache.commons.codec.binary.Base64; //导入依赖的package包/类
@Override
public String sign(HttpRequest request, HttpParameters requestParams) throws OAuthMessageSignerException {

	final OAuthRsaSigner signer = new OAuthRsaSigner();
	final byte[] privateBytes = Base64.decodeBase64(getConsumerSecret());
	final PKCS8EncodedKeySpec keySpec = new PKCS8EncodedKeySpec(privateBytes);

	try {
		signer.privateKey = KeyFactory.getInstance("RSA").generatePrivate(keySpec);
		final String signatureBaseString = new SignatureBaseString(request, requestParams).generate();
		return signer.computeSignature(signatureBaseString);
	} catch (GeneralSecurityException e) {
		throw new OAuthMessageSignerException(e);
	}
}
 

import com.google.api.client.repackaged.org.apache.commons.codec.binary.Base64; //导入依赖的package包/类
private Message createMessageWithEmail(MimeMessage email)
        throws MessagingException, IOException {
    ByteArrayOutputStream bytes = new ByteArrayOutputStream();
    email.writeTo(bytes);
    String encodedEmail = Base64.encodeBase64URLSafeString(bytes.toByteArray());
    Message message = new Message();
    message.setRaw(encodedEmail);
    return message;
}
 

import com.google.api.client.repackaged.org.apache.commons.codec.binary.Base64; //导入依赖的package包/类
private MimeMessage toMimeMessage(Message message) throws MessagingException {
    byte[] emailBytes = Base64.decodeBase64(message.getRaw());

    Properties props = new Properties();
    Session session = Session.getDefaultInstance(props, null);

    return new MimeMessage(session, new ByteArrayInputStream(emailBytes));
}
 

import com.google.api.client.repackaged.org.apache.commons.codec.binary.Base64; //导入依赖的package包/类
private String validateToken(String token, String nonce)
{
	
	try 
	{
		String[] base64EncodedSegments = token.split("\\.");		 

		String base64EncodedHeader = base64EncodedSegments[0];
		String base64EncodedClaims = base64EncodedSegments[1];
		JSONParser parser = new JSONParser();
		JSONObject claims = (JSONObject)parser.parse(StringUtils.newStringUtf8(Base64.decodeBase64(base64EncodedClaims)));
		
		
		String sub = (String) claims.get("sub");
		String tokenNonce = (String) claims.get("nonce");// This value should be checked to match the one sent in the request
		String iss = (String) claims.get("iss"); // Should be https://idp.privakeyapp.com/identityserver
		String aud = (String) claims.get("aud"); //Should contain our client id
		Long expTime = (Long) claims.get("exp");
		
		if(tokenNonce.equals(nonce) && aud.equals(UniversalConstants.PRIVAKEY_CLIENT_ID))
		{
			return sub;
		}
		else
		{
			return null;
		}
	} catch (Exception e) {
		return null;
	}
	
}
 

import com.google.api.client.repackaged.org.apache.commons.codec.binary.Base64; //导入依赖的package包/类
public static Message getMessage(Gmail service, String userId, String messageId)
     throws IOException {
   Message message = service.users().messages().get(userId, messageId).setFormat("raw").execute();

 // System.out.println(message.getRaw());
//   System.out.println(message.getPayload().getHeaders()..getValue()+"####"+message.getPayload().getHeaders().get(37).getValue());
  String s=new String(Base64.decode(message.getRaw(),Base64.URL_SAFE));
  // Base64.getDecoder().decode(message.getRaw().toString());
  
  
//  System.out.println(s);
  mail_data.add(s);
  // System.out.println(base64UrlDecode(message.getRaw().toString()));
   return message;
 }
 

import com.google.api.client.repackaged.org.apache.commons.codec.binary.Base64; //导入依赖的package包/类
private List<String> getDataFromApi(String query) throws IOException {
    List<String> messageList = new ArrayList<>();
    String user = "me";
    ListMessagesResponse response = mService.users().messages().list(user).setQ(query).execute();
    int total = 1;
    String deliverTo = "";
    String from = "";
    String subject = "";
    String content = "";
    long timestamp = 0;
    if (response.getMessages() != null) {
        for(int i = response.getMessages().size()-1;i>=0;i--){
            Message item = response.getMessages().get(i);
            if (total > mMaxResult) {
                break;
            }
            Message message = mService.users().messages().get(user, item.getId()).setFormat("full").execute();
            List<MessagePart> messageParts = message.getPayload().getParts();
            List<MessagePartHeader> headers = message.getPayload().getHeaders();

            if (!headers.isEmpty()) {
                for (MessagePartHeader header : headers) {
                    String name = header.getName();
                    switch (name) {
                        case "From":
                            from = header.getValue();
                            break;
                        case "To":
                            deliverTo = header.getValue();
                            break;
                        case "Subject":
                            subject = header.getValue();
                            break;
                        case "Date":
                            String date = header.getValue();
                            if(date.contains(","))
                                date = date.substring(date.indexOf(",") + 2,date.length());;
                            String timestampFormat = "dd MMM yyyy HH:mm:ss Z";
                            timestamp = TimeUtils.fromFormattedString(timestampFormat,date) / 1000;
                            break;
                    }
                }
            }
            if (messageParts != null && !messageParts.isEmpty()) {
                byte[] bytes = Base64.decodeBase64(messageParts.get(0).getBody().getData());
                if (bytes != null) {
                    String mailText = new String(bytes);
                    if (!mailText.isEmpty()) {
                        total++;
                        content = mailText;
                        messageList.add(mailText);
                    }
                }
            }
            if(mLastEmailTime < timestamp) mLastEmailTime = timestamp;
            this.output(new Email(content, AppUtils.APP_PACKAGE_GMAIL, from, deliverTo, subject, timestamp));
        }
    }

    //Reset the value for from and to
    mBegin = 0;
    mEnd = 0;
    return messageList;
}
 

import com.google.api.client.repackaged.org.apache.commons.codec.binary.Base64; //导入依赖的package包/类
/**
 * Encrypt the Data with the secret key.
 * **WARNING** Can only be decrypted by this class!!!
 *
 * @param data The data to encrypt.
 * @return The encrypted, unreadable data.
 * @throws Exception If something fails.
 */
public String encrypt(String data) throws Exception {
	cipher.init(Cipher.ENCRYPT_MODE, secretKeySpec, ivParameterSpec);
	byte[] encrypted = cipher.doFinal(data.getBytes());
	return Base64.encodeBase64String(encrypted);
}
 

import com.google.api.client.repackaged.org.apache.commons.codec.binary.Base64; //导入依赖的package包/类
/**
 * Decrypt the Data with the secret key.
 * **WARNING** Can only be encrypted with this class!!!
 * **WARNING** Decrypting of data can be a security risk! Treat with care!!
 *
 * @param encryptedData The data to decrypt.
 * @return The data, decrypted.
 * @throws Exception If something fails.
 */
public String decrypt(String encryptedData) throws Exception {
	cipher.init(Cipher.DECRYPT_MODE, secretKeySpec, ivParameterSpec);
	byte[] decryptedBytes = cipher.doFinal(Base64.decodeBase64(encryptedData));
	return new String(decryptedBytes);
}