package cn.jpush.android.d; import android.content.Context; import android.content.Intent; import android.text.TextUtils; import androidx.core.view.PointerIconCompat; import cn.jpush.android.api.CustomMessage; import cn.jpush.android.api.JPushInterface; import cn.jpush.android.cache.a; import cn.jpush.android.helper.JCoreHelper; import cn.jpush.android.helper.Logger; import cn.jpush.android.helper.c; import cn.jpush.android.local.JPushConstants; import cn.jpush.android.p.d; import java.io.LineNumberReader; import java.io.StringReader; import java.util.Locale; import org.json.JSONObject; public class b { public static CustomMessage a(Intent intent) { CustomMessage customMessage; Throwable th; try { String stringExtra = intent.getStringExtra("data"); String stringExtra2 = intent.getStringExtra("msgid"); JSONObject jSONObject = new JSONObject(stringExtra); customMessage = new CustomMessage(); try { customMessage.messageId = stringExtra2; customMessage.appId = intent.getStringExtra("appId"); customMessage.senderId = intent.getStringExtra("senderId"); customMessage.message = jSONObject.optString("message", ""); customMessage.contentType = jSONObject.optString("content_type", ""); customMessage.title = jSONObject.optString("title", ""); customMessage.extra = jSONObject.optString("extras", ""); } catch (Throwable th2) { th = th2; } } catch (Throwable th3) { th = th3; customMessage = null; Logger.w("MessageHelper", "processMessage failed:" + th.getMessage()); return customMessage; } return customMessage; } private static cn.jpush.android.b.b a(d dVar) { try { cn.jpush.android.b.b a = cn.jpush.android.b.b.a(new JSONObject(dVar.g).optJSONObject("geofence")); if (a == null) { return null; } a.t = dVar; return a; } catch (Throwable unused) { return null; } } private static void a(Context context, int i, long j, long j2) { JCoreHelper.sendData(context, JPushConstants.SDK_TYPE, 4, 2, j2, cn.jpush.android.r.b.a(0, (byte) i, j)); } public static void a(Context context, int i, String str, String str2, String str3, long j, byte b) { if (!str2.equals(context.getPackageName())) { Logger.e("MessageHelper", "msg appId is not mine pkgname,appid:" + str2 + ",pkgname:" + context.getPackageName()); return; } Logger.d("MessageHelper", "action:receivedPushMessage msgId = " + j); d a = d.a(str, str2, str3, j); if (a != null && !c.a(context, a.a()) && !d.a(context, a.c, a.f)) { a.ab = b; cn.jpush.android.b.b a2 = a(a); if (a2 == null || TextUtils.isEmpty(a2.a)) { a(context, a); } else { cn.jpush.android.b.d.a(context).a(a2); } } } public static void a(Context context, d dVar) { Logger.d("MessageHelper", "processBasicEntity type:" + dVar.e); dVar.e = dVar.i ? dVar.h == 4 ? 3 : 1 : 2; if ((dVar.e & 2) != 0) { Logger.d("MessageHelper", "processBasicEntity user-defined message."); if (!TextUtils.isEmpty(dVar.l) || !TextUtils.isEmpty(dVar.o)) { b(context, dVar); } else { Logger.ww("MessageHelper", "no message or extra send to user"); } } if ((dVar.e & 1) != 0) { Logger.d("MessageHelper", "processBasicEntity notification"); if (a.d(context)) { Logger.i("MessageHelper", "Service is stoped, give up all the message"); return; } dVar.a(context); if (!cn.jpush.android.p.b.b(context)) { c.a(dVar.c, 986, context); Logger.ii("MessageHelper", "push is invalidPushTime,Intercept the message"); return; } d.b(context, dVar.c); cn.jpush.android.p.b.a(context, dVar); } } public static void a(Context context, cn.jpush.android.r.c cVar) { a(context, cVar.a(), cVar.b(), cVar.getRid()); long b = cVar.b(); int a = cVar.a(); String c = cVar.c(); Logger.d("MessageHelper", "msgType = " + a + ", msgId = " + b); StringBuilder sb = new StringBuilder(); sb.append("msgContent: \n"); sb.append(c); Logger.v("MessageHelper", sb.toString()); Logger.d("MessageHelper", "msgContent size:" + c.getBytes().length); LineNumberReader lineNumberReader = new LineNumberReader(new StringReader(c)); try { String readLine = lineNumberReader.readLine(); String readLine2 = lineNumberReader.readLine(); if (readLine == null) { Logger.e("MessageHelper", "NO appId"); } else if (readLine2 == null) { Logger.e("MessageHelper", "NO senderId"); } else { int length = readLine.length() + readLine2.length() + 2; if (c.length() > length + 1) { String substring = c.substring(length); if (!readLine2.equals(JCoreHelper.getAppKey(context))) { Logger.e("MessageHelper", "msg senderId is not mine appkey,senderId:" + readLine2 + ",appkey:" + JCoreHelper.getAppKey(context)); return; } Logger.v("MessageHelper", "Message Fields - appId:" + readLine + ", senderId:" + readLine2 + ", msgContent:" + substring); if (!(a == 0 || a == 2)) { if (a != 20) { switch (a) { case 100: case 101: break; default: Logger.ww("MessageHelper", "unkown msg type"); return; } } else { cn.jpush.android.s.a.a(context, substring, 0, -1L); return; } } a(context, a, substring, readLine, readLine2, b, (byte) 0); return; } Logger.d("MessageHelper", "No msgContent"); } } catch (Throwable th) { Logger.e("MessageHelper", "Parse msgContent failed", th); } } public static void b(Context context, d dVar) { try { String messageReceiverClass = JPushConstants.getMessageReceiverClass(context); if (!TextUtils.isEmpty(messageReceiverClass)) { Intent intent = new Intent(context, Class.forName(messageReceiverClass)); intent.setAction(cn.jpush.android.u.a.e(context, "custom_msg")); intent.putExtra("data", dVar.g); intent.putExtra("msgid", dVar.c); intent.putExtra("appId", dVar.a); intent.putExtra("senderId", dVar.b); if (JPushConstants.getPushMessageReceiver(context) != null) { JPushConstants.getPushMessageReceiver(context).onMessage(context, a(intent)); } else { context.sendBroadcast(intent); } } else { Logger.dd("MessageHelper", "not found user push message,use old action to user"); Intent intent2 = new Intent(JPushInterface.ACTION_MESSAGE_RECEIVED); intent2.putExtra(JPushInterface.EXTRA_APP_KEY, dVar.b); intent2.putExtra(JPushInterface.EXTRA_MESSAGE, dVar.l); intent2.putExtra(JPushInterface.EXTRA_CONTENT_TYPE, dVar.m); intent2.putExtra(JPushInterface.EXTRA_TITLE, dVar.n); intent2.putExtra(JPushInterface.EXTRA_EXTRA, dVar.o); intent2.putExtra(JPushInterface.EXTRA_MSG_ID, dVar.c); intent2.addCategory(dVar.a); intent2.setPackage(context.getPackageName()); context.sendBroadcast(intent2, String.format(Locale.ENGLISH, "%s.permission.JPUSH_MESSAGE", dVar.a)); Logger.i("MessageHelper", "Send broadcast to app: " + String.format(Locale.ENGLISH, "%s.permission.JPUSH_MESSAGE", dVar.a)); } if (dVar.ab != 0) { c.a(dVar.c, "", dVar.ab, PointerIconCompat.TYPE_ZOOM_IN, context); } else { c.a(dVar.c, PointerIconCompat.TYPE_ZOOM_IN, context); } } catch (Throwable th) { Logger.e("MessageHelper", "sendBroadcastToApp error:" + th.getMessage()); } } }