package com.google.firebase.iid;

import android.app.AlarmManager;
import android.app.PendingIntent;
import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.net.ConnectivityManager;
import android.net.NetworkInfo;
import android.os.Bundle;
import android.os.SystemClock;
import android.support.annotation.VisibleForTesting;
import android.support.annotation.WorkerThread;
import android.util.Log;
import java.io.IOException;
import rt;
import rt.a;

public class FirebaseInstanceIdService
  extends zzb
{
  @VisibleForTesting
  static final Object a = new Object();
  @VisibleForTesting
  static boolean b = false;
  private static BroadcastReceiver d;
  private boolean e = false;
  
  private zzd a(String paramString)
  {
    if (paramString == null) {
      return zzd.zzb(this, null);
    }
    Bundle localBundle = new Bundle();
    localBundle.putString("subtype", paramString);
    return zzd.zzb(this, localBundle);
  }
  
  private static String a(Intent paramIntent)
  {
    String str = paramIntent.getStringExtra("subtype");
    paramIntent = str;
    if (str == null) {
      paramIntent = "";
    }
    return paramIntent;
  }
  
  static void a(Context paramContext)
  {
    if (zzf.zzbA(paramContext) == null) {
      return;
    }
    synchronized (a)
    {
      if (!b)
      {
        zzg.zzabU().zzf(paramContext, b(0));
        b = true;
      }
      return;
    }
  }
  
  static void a(Context paramContext, FirebaseInstanceId paramFirebaseInstanceId)
  {
    synchronized (a)
    {
      if (b) {
        return;
      }
      paramFirebaseInstanceId = paramFirebaseInstanceId.a();
      if ((paramFirebaseInstanceId == null) || (paramFirebaseInstanceId.b(zzd.e)) || (FirebaseInstanceId.b().a() != null))
      {
        a(paramContext);
        return;
      }
    }
  }
  
  private void a(Intent arg1, String paramString)
  {
    final int i = 28800;
    boolean bool = c(this);
    int j;
    if (??? == null) {
      j = 10;
    }
    for (;;)
    {
      if ((j < 10) && (!bool))
      {
        i = 30;
        label33:
        new StringBuilder(String.valueOf(paramString).length() + 47).append("background sync failed: ").append(paramString).append(", retry in ").append(i).append("s");
      }
      synchronized (a)
      {
        paramString = (AlarmManager)getSystemService("alarm");
        PendingIntent localPendingIntent = zzg.zza(this, 0, b(i * 2), 134217728);
        paramString.set(3, SystemClock.elapsedRealtime() + i * 1000, localPendingIntent);
        b = true;
        if (!bool)
        {
          if (d == null) {
            d = new BroadcastReceiver()
            {
              public final void onReceive(Context paramAnonymousContext, Intent paramAnonymousIntent)
              {
                if (FirebaseInstanceIdService.b(paramAnonymousContext))
                {
                  FirebaseInstanceIdService.a(FirebaseInstanceIdService.this);
                  FirebaseInstanceIdService.this.getApplicationContext().unregisterReceiver(this);
                  zzg.zzabU().zzf(paramAnonymousContext, FirebaseInstanceIdService.a(i));
                }
              }
            };
          }
          getApplicationContext().registerReceiver(d, new IntentFilter("android.net.conn.CONNECTIVITY_CHANGE"));
        }
        return;
        j = ???.getIntExtra("next_retry_delay_in_seconds", 0);
        continue;
        if (j < 10)
        {
          i = 10;
          break label33;
        }
        if (j > 28800) {
          break label33;
        }
        i = j;
      }
    }
  }
  
  private void a(Intent paramIntent, boolean paramBoolean)
  {
    for (;;)
    {
      synchronized (a)
      {
        b = false;
        if (zzf.zzbA(this) == null) {
          return;
        }
      }
      ??? = FirebaseInstanceId.getInstance();
      localObject2 = ((FirebaseInstanceId)???).a();
      if ((localObject2 == null) || (((rt.a)localObject2).b(zzd.e))) {
        try
        {
          localObject3 = ((FirebaseInstanceId)???).getToken(((FirebaseInstanceId)???).b, "*");
          if (localObject3 != null)
          {
            a(this, (FirebaseInstanceId)???);
            if ((!paramBoolean) && (localObject2 != null) && ((localObject2 == null) || (((String)localObject3).equals(((rt.a)localObject2).a)))) {
              continue;
            }
            onTokenRefresh();
          }
        }
        catch (IOException localIOException1)
        {
          a(paramIntent, localIOException1.getMessage());
          return;
          a(paramIntent, "returned token is null");
          return;
        }
        catch (SecurityException paramIntent)
        {
          Log.e("FirebaseInstanceId", "Unable to get master token", paramIntent);
          return;
        }
      }
    }
    Object localObject3 = FirebaseInstanceId.b();
    String str1 = ((zze)localObject3).a();
    label158:
    Object localObject4;
    while (str1 != null)
    {
      localObject4 = str1.split("!");
      int j;
      if (localObject4.length == 2)
      {
        localObject2 = localObject4[0];
        localObject4 = localObject4[1];
        j = -1;
      }
      try
      {
        int k = ((String)localObject2).hashCode();
        int i = j;
        switch (k)
        {
        default: 
          i = j;
        }
        for (;;)
        {
          switch (i)
          {
          default: 
            ((zze)localObject3).a(str1);
            str1 = ((zze)localObject3).a();
            break label158;
            i = j;
            if (((String)localObject2).equals("S"))
            {
              i = 0;
              continue;
              i = j;
              if (((String)localObject2).equals("U")) {
                i = 1;
              }
            }
            break;
          }
        }
        localObject5 = FirebaseInstanceId.getInstance();
        localObject7 = ((FirebaseInstanceId)localObject5).a();
        if ((localObject7 == null) || (((rt.a)localObject7).b(zzd.e))) {
          throw new IOException("token not available");
        }
      }
      catch (IOException localIOException2)
      {
        a(paramIntent, localIOException2.getMessage());
        return;
      }
    }
    Object localObject6 = new Bundle();
    Object localObject2 = String.valueOf("/topics/");
    String str2 = String.valueOf(localObject4);
    if (str2.length() != 0)
    {
      localObject2 = ((String)localObject2).concat(str2);
      label405:
      ((Bundle)localObject6).putString("gcm.topic", (String)localObject2);
      localObject7 = ((rt.a)localObject7).a;
      localObject2 = String.valueOf("/topics/");
      localObject4 = String.valueOf(localObject4);
      if (((String)localObject4).length() == 0) {
        break label488;
      }
    }
    label488:
    for (localObject2 = ((String)localObject2).concat((String)localObject4);; localObject2 = new String((String)localObject2))
    {
      ((FirebaseInstanceId)localObject5).zzc((String)localObject7, (String)localObject2, (Bundle)localObject6);
      if (!this.e) {
        break;
      }
      break;
      localObject2 = new String((String)localObject2);
      break label405;
    }
    Object localObject7 = FirebaseInstanceId.getInstance();
    localObject6 = ((FirebaseInstanceId)localObject7).a();
    if ((localObject6 == null) || (((rt.a)localObject6).b(zzd.e))) {
      throw new IOException("token not available");
    }
    Object localObject5 = new Bundle();
    localObject2 = String.valueOf("/topics/");
    str2 = String.valueOf(localObject4);
    if (str2.length() != 0)
    {
      localObject2 = ((String)localObject2).concat(str2);
      label580:
      ((Bundle)localObject5).putString("gcm.topic", (String)localObject2);
      localObject7 = ((FirebaseInstanceId)localObject7).a;
      localObject6 = ((rt.a)localObject6).a;
      localObject2 = String.valueOf("/topics/");
      localObject4 = String.valueOf(localObject4);
      if (((String)localObject4).length() == 0) {
        break label662;
      }
    }
    label662:
    for (localObject2 = ((String)localObject2).concat((String)localObject4);; localObject2 = new String((String)localObject2))
    {
      ((zzd)localObject7).zzb((String)localObject6, (String)localObject2, (Bundle)localObject5);
      break;
      localObject2 = new String((String)localObject2);
      break label580;
    }
  }
  
  private static Intent b(int paramInt)
  {
    Intent localIntent = new Intent("ACTION_TOKEN_REFRESH_RETRY");
    localIntent.putExtra("next_retry_delay_in_seconds", paramInt);
    return localIntent;
  }
  
  private static boolean c(Context paramContext)
  {
    paramContext = ((ConnectivityManager)paramContext.getSystemService("connectivity")).getActiveNetworkInfo();
    return (paramContext != null) && (paramContext.isConnected());
  }
  
  public void handleIntent(Intent paramIntent)
  {
    String str2 = paramIntent.getAction();
    String str1 = str2;
    if (str2 == null) {
      str1 = "";
    }
    switch (str1.hashCode())
    {
    }
    label40:
    for (int i = -1;; i = 0) {
      switch (i)
      {
      default: 
        zzF(paramIntent);
        return;
        if (!str1.equals("ACTION_TOKEN_REFRESH_RETRY")) {
          break label40;
        }
      }
    }
    a(paramIntent, false);
  }
  
  @WorkerThread
  public void onTokenRefresh() {}
  
  protected Intent zzD(Intent paramIntent)
  {
    return zzg.zzabU().zzabV();
  }
  
  public boolean zzE(Intent paramIntent)
  {
    this.e = Log.isLoggable("FirebaseInstanceId", 3);
    if ((paramIntent.getStringExtra("error") != null) || (paramIntent.getStringExtra("registration_id") != null))
    {
      String str1 = a(paramIntent);
      if (this.e)
      {
        String str2 = String.valueOf(str1);
        if (str2.length() == 0) {
          break label76;
        }
        "Register result in service ".concat(str2);
      }
      for (;;)
      {
        a(str1).zzabR().c(paramIntent);
        return true;
        label76:
        new String("Register result in service ");
      }
    }
    return false;
  }
  
  public void zzF(Intent paramIntent)
  {
    String str = a(paramIntent);
    Object localObject2 = a(str);
    Object localObject1 = paramIntent.getStringExtra("CMD");
    Object localObject3;
    if (this.e)
    {
      localObject3 = String.valueOf(paramIntent.getExtras());
      new StringBuilder(String.valueOf(str).length() + 18 + String.valueOf(localObject1).length() + String.valueOf(localObject3).length()).append("Service command ").append(str).append(" ").append((String)localObject1).append(" ").append((String)localObject3);
    }
    if (paramIntent.getStringExtra("unregistered") != null)
    {
      localObject3 = ((zzd)localObject2).zzabQ();
      localObject1 = str;
      if (str == null) {
        localObject1 = "";
      }
      ((rt)localObject3).d((String)localObject1);
      ((zzd)localObject2).zzabR().c(paramIntent);
    }
    do
    {
      do
      {
        return;
        if ("gcm.googleapis.com/refresh".equals(paramIntent.getStringExtra("from")))
        {
          ((zzd)localObject2).zzabQ().d(str);
          a(paramIntent, true);
          return;
        }
        if ("RST".equals(localObject1))
        {
          ((zzd)localObject2).zzHi();
          a(paramIntent, true);
          return;
        }
        if (!"RST_FULL".equals(localObject1)) {
          break;
        }
      } while (((zzd)localObject2).zzabQ().a());
      ((zzd)localObject2).zzHi();
      ((zzd)localObject2).zzabQ().b();
      a(paramIntent, true);
      return;
      if ("SYNC".equals(localObject1))
      {
        ((zzd)localObject2).zzabQ().d(str);
        a(paramIntent, true);
        return;
      }
    } while (!"PING".equals(localObject1));
    localObject1 = ((zzd)localObject2).zzabR();
    paramIntent = paramIntent.getExtras();
    str = zzf.zzbA(this);
    if (str == null)
    {
      Log.w("FirebaseInstanceId", "Unable to respond to ping due to missing target package");
      return;
    }
    localObject2 = new Intent("com.google.android.gcm.intent.SEND");
    ((Intent)localObject2).setPackage(str);
    ((Intent)localObject2).putExtras(paramIntent);
    ((zzf)localObject1).a((Intent)localObject2);
    ((Intent)localObject2).putExtra("google.to", "google.com/iid");
    ((Intent)localObject2).putExtra("google.message_id", zzf.zzHn());
    sendOrderedBroadcast((Intent)localObject2, "com.google.android.gtalkservice.permission.GTALK_SERVICE");
  }
}


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