package com.google.firebase.iid;

import android.app.PendingIntent;
import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.content.pm.ActivityInfo;
import android.content.pm.ApplicationInfo;
import android.content.pm.PackageManager;
import android.content.pm.PackageManager.NameNotFoundException;
import android.content.pm.ResolveInfo;
import android.content.pm.ServiceInfo;
import android.os.Build.VERSION;
import android.os.Bundle;
import android.os.ConditionVariable;
import android.os.Handler;
import android.os.Looper;
import android.os.Message;
import android.os.Messenger;
import android.os.Process;
import android.os.RemoteException;
import android.os.SystemClock;
import android.support.v4.util.SimpleArrayMap;
import android.util.Log;
import com.google.android.gms.common.util.zzt;
import com.google.android.gms.iid.MessengerCompat;
import java.io.IOException;
import java.security.KeyPair;
import java.security.PublicKey;
import java.util.Iterator;
import java.util.List;
import java.util.Random;

public class zzf
{
  static String a = null;
  static boolean b = false;
  static int c = 0;
  static int d = 0;
  static int e = 0;
  static BroadcastReceiver f = null;
  Context g;
  Messenger h;
  Messenger i;
  MessengerCompat j;
  PendingIntent k;
  long l;
  long m;
  int n;
  int o;
  long p;
  private final SimpleArrayMap<String, b> q = new SimpleArrayMap();
  
  public zzf(Context paramContext)
  {
    this.g = paramContext;
  }
  
  /* Error */
  private static String a(KeyPair paramKeyPair, String... paramVarArgs)
  {
    // Byte code:
    //   0: ldc 73
    //   2: aload_1
    //   3: invokestatic 79	android/text/TextUtils:join	(Ljava/lang/CharSequence;[Ljava/lang/Object;)Ljava/lang/String;
    //   6: ldc 81
    //   8: invokevirtual 87	java/lang/String:getBytes	(Ljava/lang/String;)[B
    //   11: astore_1
    //   12: aload_0
    //   13: invokevirtual 93	java/security/KeyPair:getPrivate	()Ljava/security/PrivateKey;
    //   16: astore_2
    //   17: aload_2
    //   18: instanceof 95
    //   21: ifeq +43 -> 64
    //   24: ldc 97
    //   26: astore_0
    //   27: aload_0
    //   28: invokestatic 103	java/security/Signature:getInstance	(Ljava/lang/String;)Ljava/security/Signature;
    //   31: astore_0
    //   32: aload_0
    //   33: aload_2
    //   34: invokevirtual 107	java/security/Signature:initSign	(Ljava/security/PrivateKey;)V
    //   37: aload_0
    //   38: aload_1
    //   39: invokevirtual 111	java/security/Signature:update	([B)V
    //   42: aload_0
    //   43: invokevirtual 115	java/security/Signature:sign	()[B
    //   46: invokestatic 120	com/google/firebase/iid/FirebaseInstanceId:a	([B)Ljava/lang/String;
    //   49: astore_0
    //   50: aload_0
    //   51: areturn
    //   52: astore_0
    //   53: ldc 122
    //   55: ldc 124
    //   57: aload_0
    //   58: invokestatic 129	android/util/Log:e	(Ljava/lang/String;Ljava/lang/String;Ljava/lang/Throwable;)I
    //   61: pop
    //   62: aconst_null
    //   63: areturn
    //   64: ldc -125
    //   66: astore_0
    //   67: goto -40 -> 27
    //   70: astore_0
    //   71: ldc 122
    //   73: ldc -123
    //   75: aload_0
    //   76: invokestatic 129	android/util/Log:e	(Ljava/lang/String;Ljava/lang/String;Ljava/lang/Throwable;)I
    //   79: pop
    //   80: aconst_null
    //   81: areturn
    // Local variable table:
    //   start	length	slot	name	signature
    //   0	82	0	paramKeyPair	KeyPair
    //   0	82	1	paramVarArgs	String[]
    //   16	18	2	localPrivateKey	java.security.PrivateKey
    // Exception table:
    //   from	to	target	type
    //   0	12	52	java/io/UnsupportedEncodingException
    //   12	24	70	java/security/GeneralSecurityException
    //   27	50	70	java/security/GeneralSecurityException
  }
  
  private void a(String paramString, Intent paramIntent)
  {
    b localb;
    synchronized (this.q)
    {
      localb = (b)this.q.remove(paramString);
      if (localb == null)
      {
        paramString = String.valueOf(paramString);
        if (paramString.length() != 0)
        {
          paramString = "Missing callback for ".concat(paramString);
          Log.w("InstanceID/Rpc", paramString);
          return;
        }
        paramString = new String("Missing callback for ");
      }
    }
    localb.a(paramIntent);
  }
  
  private void a(String paramString1, String paramString2)
  {
    SimpleArrayMap localSimpleArrayMap = this.q;
    int i1;
    if (paramString1 == null) {
      i1 = 0;
    }
    for (;;)
    {
      try
      {
        if (i1 < this.q.size())
        {
          ((b)this.q.valueAt(i1)).a(paramString2);
          i1 += 1;
          continue;
        }
        this.q.clear();
        return;
      }
      finally {}
      b localb = (b)this.q.remove(paramString1);
      if (localb == null)
      {
        paramString1 = String.valueOf(paramString1);
        if (paramString1.length() != 0)
        {
          paramString1 = "Missing callback for ".concat(paramString1);
          Log.w("InstanceID/Rpc", paramString1);
          return;
        }
        paramString1 = new String("Missing callback for ");
        continue;
      }
      localb.a(paramString2);
    }
  }
  
  private static boolean a(PackageManager paramPackageManager)
  {
    Iterator localIterator = paramPackageManager.queryIntentServices(new Intent("com.google.android.c2dm.intent.REGISTER"), 0).iterator();
    while (localIterator.hasNext()) {
      if (a(paramPackageManager, ((ResolveInfo)localIterator.next()).serviceInfo.packageName, "com.google.android.c2dm.intent.REGISTER"))
      {
        b = false;
        return true;
      }
    }
    return false;
  }
  
  private static boolean a(PackageManager paramPackageManager, String paramString)
  {
    try
    {
      paramPackageManager = paramPackageManager.getApplicationInfo(paramString, 0);
      a = paramPackageManager.packageName;
      d = paramPackageManager.uid;
      return true;
    }
    catch (PackageManager.NameNotFoundException paramPackageManager) {}
    return false;
  }
  
  private static boolean a(PackageManager paramPackageManager, String paramString1, String paramString2)
  {
    if (paramPackageManager.checkPermission("com.google.android.c2dm.permission.SEND", paramString1) == 0) {
      return a(paramPackageManager, paramString1);
    }
    Log.w("InstanceID/Rpc", String.valueOf(paramString1).length() + 56 + String.valueOf(paramString2).length() + "Possible malicious package " + paramString1 + " declares " + paramString2 + " without permission");
    return false;
  }
  
  static String b(Intent paramIntent)
    throws IOException
  {
    if (paramIntent == null) {
      throw new IOException("SERVICE_NOT_AVAILABLE");
    }
    String str2 = paramIntent.getStringExtra("registration_id");
    String str1 = str2;
    if (str2 == null) {
      str1 = paramIntent.getStringExtra("unregistered");
    }
    if (str1 == null)
    {
      str1 = paramIntent.getStringExtra("error");
      if (str1 != null) {
        throw new IOException(str1);
      }
      paramIntent = String.valueOf(paramIntent.getExtras());
      Log.w("InstanceID/Rpc", String.valueOf(paramIntent).length() + 29 + "Unexpected response from GCM " + paramIntent, new Throwable());
      throw new IOException("SERVICE_NOT_AVAILABLE");
    }
    return str1;
  }
  
  private static boolean b(PackageManager paramPackageManager)
  {
    Iterator localIterator = paramPackageManager.queryBroadcastReceivers(new Intent("com.google.iid.TOKEN_REQUEST"), 0).iterator();
    while (localIterator.hasNext()) {
      if (a(paramPackageManager, ((ResolveInfo)localIterator.next()).activityInfo.packageName, "com.google.iid.TOKEN_REQUEST"))
      {
        b = true;
        return true;
      }
    }
    return false;
  }
  
  public static String zzHn()
  {
    try
    {
      int i1 = e;
      e = i1 + 1;
      String str = Integer.toString(i1);
      return str;
    }
    finally
    {
      localObject = finally;
      throw ((Throwable)localObject);
    }
  }
  
  public static String zzbA(Context paramContext)
  {
    if (a != null) {
      return a;
    }
    c = Process.myUid();
    paramContext = paramContext.getPackageManager();
    if (zzt.zzzq())
    {
      if ((b(paramContext)) || (a(paramContext))) {
        return a;
      }
    }
    else if ((a(paramContext)) || (b(paramContext))) {
      return a;
    }
    Log.w("InstanceID/Rpc", "Failed to resolve IID implementation package, falling back");
    if (a(paramContext, "com.google.android.gms"))
    {
      b = zzt.zzzq();
      return a;
    }
    if ((Build.VERSION.SDK_INT < 21) && (a(paramContext, "com.google.android.gsf")))
    {
      b = false;
      return a;
    }
    Log.w("InstanceID/Rpc", "Google Play services is missing, unable to get tokens");
    return null;
  }
  
  final Intent a(Bundle arg1, KeyPair paramKeyPair)
    throws IOException
  {
    String str = zzHn();
    a locala = new a((byte)0);
    synchronized (this.q)
    {
      this.q.put(str, locala);
      zza(???, paramKeyPair, str);
      try
      {
        if (!locala.a.block(30000L))
        {
          Log.w("InstanceID/Rpc", "No response");
          throw new IOException("TIMEOUT");
        }
      }
      finally {}
    }
    synchronized (this.q)
    {
      this.q.remove(str);
      throw paramKeyPair;
      ??? = finally;
      throw ???;
      if (locala.c != null) {
        throw new IOException(locala.c);
      }
      paramKeyPair = locala.b;
      synchronized (this.q)
      {
        this.q.remove(str);
        return paramKeyPair;
      }
    }
  }
  
  final void a(Intent paramIntent)
  {
    try
    {
      if (this.k == null)
      {
        Intent localIntent = new Intent();
        localIntent.setPackage("com.google.example.invalidpackage");
        this.k = PendingIntent.getBroadcast(this.g, 0, localIntent, 0);
      }
      paramIntent.putExtra("app", this.k);
      return;
    }
    finally {}
  }
  
  final void c(Intent paramIntent)
  {
    Object localObject2 = null;
    if (paramIntent == null) {
      Log.isLoggable("InstanceID/Rpc", 3);
    }
    do
    {
      return;
      if ("com.google.android.c2dm.intent.REGISTRATION".equals(paramIntent.getAction())) {
        break;
      }
    } while (!Log.isLoggable("InstanceID/Rpc", 3));
    paramIntent = String.valueOf(paramIntent.getAction());
    if (paramIntent.length() != 0)
    {
      "Unexpected response ".concat(paramIntent);
      return;
    }
    new String("Unexpected response ");
    return;
    Object localObject3 = paramIntent.getStringExtra("registration_id");
    Object localObject1 = localObject3;
    if (localObject3 == null) {
      localObject1 = paramIntent.getStringExtra("unregistered");
    }
    if (localObject1 == null)
    {
      localObject1 = paramIntent.getStringExtra("error");
      if (localObject1 == null)
      {
        paramIntent = String.valueOf(paramIntent.getExtras());
        Log.w("InstanceID/Rpc", String.valueOf(paramIntent).length() + 49 + "Unexpected response, no error or registration id " + paramIntent);
        return;
      }
      if (Log.isLoggable("InstanceID/Rpc", 3))
      {
        localObject2 = String.valueOf(localObject1);
        if (((String)localObject2).length() != 0) {
          "Received InstanceID error ".concat((String)localObject2);
        }
      }
      else
      {
        label197:
        if (!((String)localObject1).startsWith("|")) {
          break label856;
        }
        localObject2 = ((String)localObject1).split("\\|");
        if (!"ID".equals(localObject2[1]))
        {
          localObject1 = String.valueOf(localObject1);
          if (((String)localObject1).length() == 0) {
            break label425;
          }
          localObject1 = "Unexpected structured response ".concat((String)localObject1);
          label256:
          Log.w("InstanceID/Rpc", (String)localObject1);
        }
        if (localObject2.length <= 2) {
          break label440;
        }
        localObject3 = localObject2[2];
        Object localObject4 = localObject2[3];
        localObject2 = localObject3;
        localObject1 = localObject4;
        if (((String)localObject4).startsWith(":"))
        {
          localObject1 = ((String)localObject4).substring(1);
          localObject2 = localObject3;
        }
        label314:
        paramIntent.putExtra("error", (String)localObject1);
      }
    }
    for (;;)
    {
      a((String)localObject2, (String)localObject1);
      long l1 = paramIntent.getLongExtra("Retry-After", 0L);
      if (l1 > 0L)
      {
        this.m = SystemClock.elapsedRealtime();
        this.o = ((int)l1 * 1000);
        this.p = (SystemClock.elapsedRealtime() + this.o);
        i1 = this.o;
        Log.w("InstanceID/Rpc", 52 + "Explicit request from server to backoff: " + i1);
        return;
        new String("Received InstanceID error ");
        break label197;
        label425:
        localObject1 = new String("Unexpected structured response ");
        break label256;
        label440:
        localObject1 = "UNKNOWN";
        localObject2 = null;
        break label314;
      }
      if (((!"SERVICE_NOT_AVAILABLE".equals(localObject1)) && (!"AUTHENTICATION_FAILED".equals(localObject1))) || (!"com.google.android.gsf".equals(a))) {
        break;
      }
      this.n += 1;
      if (this.n < 3) {
        break;
      }
      if (this.n == 3) {
        this.o = (new Random().nextInt(1000) + 1000);
      }
      this.o *= 2;
      this.p = (SystemClock.elapsedRealtime() + this.o);
      int i1 = this.o;
      Log.w("InstanceID/Rpc", String.valueOf(localObject1).length() + 31 + "Backoff due to " + (String)localObject1 + " for " + i1);
      return;
      this.l = SystemClock.elapsedRealtime();
      this.p = 0L;
      this.n = 0;
      this.o = 0;
      if (((String)localObject1).startsWith("|"))
      {
        localObject3 = ((String)localObject1).split("\\|");
        if (!"ID".equals(localObject3[1]))
        {
          localObject1 = String.valueOf(localObject1);
          if (((String)localObject1).length() == 0) {
            break label787;
          }
          localObject1 = "Unexpected structured response ".concat((String)localObject1);
          Log.w("InstanceID/Rpc", (String)localObject1);
        }
        localObject2 = localObject3[2];
        if (localObject3.length > 4)
        {
          if (!"SYNC".equals(localObject3[3])) {
            break label802;
          }
          FirebaseInstanceId.c(this.g);
        }
      }
      label787:
      label802:
      while (!"RST".equals(localObject3[3]))
      {
        localObject3 = localObject3[(localObject3.length - 1)];
        localObject1 = localObject3;
        if (((String)localObject3).startsWith(":")) {
          localObject1 = ((String)localObject3).substring(1);
        }
        paramIntent.putExtra("registration_id", (String)localObject1);
        if (localObject2 != null) {
          break label848;
        }
        Log.isLoggable("InstanceID/Rpc", 3);
        return;
        localObject1 = new String("Unexpected structured response ");
        break;
      }
      FirebaseInstanceId.a(this.g, zzd.zzb(this.g, null).zzabQ());
      paramIntent.removeExtra("registration_id");
      a((String)localObject2, paramIntent);
      return;
      label848:
      a((String)localObject2, paramIntent);
      return;
      label856:
      localObject2 = null;
    }
  }
  
  public void zza(Bundle paramBundle, KeyPair paramKeyPair, String paramString)
    throws IOException
  {
    long l1 = SystemClock.elapsedRealtime();
    if ((this.p != 0L) && (l1 <= this.p))
    {
      long l2 = this.p;
      int i1 = this.o;
      Log.w("InstanceID/Rpc", 78 + "Backoff mode, next request attempt: " + (l2 - l1) + " interval: " + i1);
      throw new IOException("RETRY_LATER");
    }
    if (this.h == null)
    {
      zzbA(this.g);
      this.h = new Messenger(new Handler(Looper.getMainLooper())
      {
        public final void handleMessage(Message paramAnonymousMessage)
        {
          zzf localzzf = zzf.this;
          if (paramAnonymousMessage != null)
          {
            if ((paramAnonymousMessage.obj instanceof Intent))
            {
              Object localObject = (Intent)paramAnonymousMessage.obj;
              ((Intent)localObject).setExtrasClassLoader(MessengerCompat.class.getClassLoader());
              if (((Intent)localObject).hasExtra("google.messenger"))
              {
                localObject = ((Intent)localObject).getParcelableExtra("google.messenger");
                if ((localObject instanceof MessengerCompat)) {
                  localzzf.j = ((MessengerCompat)localObject);
                }
                if ((localObject instanceof Messenger)) {
                  localzzf.i = ((Messenger)localObject);
                }
              }
              localzzf.c((Intent)paramAnonymousMessage.obj);
            }
          }
          else {
            return;
          }
          Log.w("InstanceID/Rpc", "Dropping invalid message");
        }
      });
    }
    if (a == null) {
      throw new IOException("MISSING_INSTANCEID_SERVICE");
    }
    this.l = SystemClock.elapsedRealtime();
    if (b) {}
    for (Object localObject = "com.google.iid.TOKEN_REQUEST";; localObject = "com.google.android.c2dm.intent.REGISTER")
    {
      localObject = new Intent((String)localObject);
      ((Intent)localObject).setPackage(a);
      paramBundle.putString("gmsv", Integer.toString(FirebaseInstanceId.a(this.g, zzbA(this.g))));
      paramBundle.putString("osv", Integer.toString(Build.VERSION.SDK_INT));
      paramBundle.putString("app_ver", Integer.toString(FirebaseInstanceId.a(this.g)));
      paramBundle.putString("app_ver_name", FirebaseInstanceId.b(this.g));
      paramBundle.putString("cliv", "fiid-10298000");
      paramBundle.putString("appid", FirebaseInstanceId.a(paramKeyPair));
      String str = FirebaseInstanceId.a(paramKeyPair.getPublic().getEncoded());
      paramBundle.putString("pub2", str);
      paramBundle.putString("sig", a(paramKeyPair, new String[] { this.g.getPackageName(), str }));
      ((Intent)localObject).putExtras(paramBundle);
      a((Intent)localObject);
      zzb((Intent)localObject, paramString);
      return;
    }
  }
  
  protected void zzb(Intent paramIntent, String paramString)
  {
    this.l = SystemClock.elapsedRealtime();
    paramIntent.putExtra("kid", String.valueOf(paramString).length() + 5 + "|ID|" + paramString + "|");
    paramIntent.putExtra("X-kid", String.valueOf(paramString).length() + 5 + "|ID|" + paramString + "|");
    boolean bool = "com.google.android.gsf".equals(a);
    if (Log.isLoggable("InstanceID/Rpc", 3))
    {
      paramString = String.valueOf(paramIntent.getExtras());
      new StringBuilder(String.valueOf(paramString).length() + 8).append("Sending ").append(paramString);
    }
    if (bool) {
      try
      {
        if (f == null)
        {
          f = new BroadcastReceiver()
          {
            public final void onReceive(Context paramAnonymousContext, Intent paramAnonymousIntent)
            {
              if (Log.isLoggable("InstanceID/Rpc", 3))
              {
                paramAnonymousContext = String.valueOf(paramAnonymousIntent.getExtras());
                new StringBuilder(String.valueOf(paramAnonymousContext).length() + 44).append("Received GSF callback via dynamic receiver: ").append(paramAnonymousContext);
              }
              zzf.this.c(paramAnonymousIntent);
            }
          };
          Log.isLoggable("InstanceID/Rpc", 3);
          paramString = new IntentFilter("com.google.android.c2dm.intent.REGISTRATION");
          paramString.addCategory(this.g.getPackageName());
          this.g.registerReceiver(f, paramString, "com.google.android.c2dm.permission.SEND", null);
        }
        this.g.startService(paramIntent);
        return;
      }
      finally {}
    }
    paramIntent.putExtra("google.messenger", this.h);
    if ((this.i != null) || (this.j != null))
    {
      paramString = Message.obtain();
      paramString.obj = paramIntent;
      try
      {
        if (this.i == null) {
          break label306;
        }
        this.i.send(paramString);
        return;
      }
      catch (RemoteException paramString)
      {
        Log.isLoggable("InstanceID/Rpc", 3);
      }
    }
    else
    {
      if (!b) {
        break label315;
      }
      this.g.sendBroadcast(paramIntent);
      return;
    }
    label306:
    this.j.send(paramString);
    return;
    label315:
    this.g.startService(paramIntent);
  }
  
  static final class a
    implements zzf.b
  {
    final ConditionVariable a = new ConditionVariable();
    Intent b;
    String c;
    
    public final void a(Intent paramIntent)
    {
      this.b = paramIntent;
      this.a.open();
    }
    
    public final void a(String paramString)
    {
      this.c = paramString;
      this.a.open();
    }
  }
  
  static abstract interface b
  {
    public abstract void a(Intent paramIntent);
    
    public abstract void a(String paramString);
  }
}


/* Location:              /home/merong/decompile/hackery-dex2jar.jar!/com/google/firebase/iid/zzf.class
 * Java compiler version: 6 (50.0)
 * JD-Core Version:       0.7.1
 */