TopicsSubscriber.smali
.class Lcom/google/firebase/messaging/TopicsSubscriber;
.super Ljava/lang/Object;
.source ""
# static fields
.field private static final MAX_DELAY_SEC:J
# instance fields
.field private final context:Landroid/content/Context;
.field private final iid:Lcom/google/firebase/iid/FirebaseInstanceId;
.field private final metadata:Lcom/google/firebase/iid/Metadata;
.field private final pendingOperations:Ljava/util/Map;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/Map<",
"Ljava/lang/String;",
"Ljava/util/ArrayDeque<",
"Lcom/google/android/gms/tasks/TaskCompletionSource<",
"Ljava/lang/Void;",
">;>;>;"
}
.end annotation
.end field
.field private final rpc:Lcom/google/firebase/iid/GmsRpc;
.field private final store:Lcom/google/firebase/messaging/TopicsStore;
.field private final syncExecutor:Ljava/util/concurrent/ScheduledExecutorService;
.field private syncScheduledOrRunning:Z
# direct methods
.method static constructor <clinit>()V
.registers 3
sget-object v0, Ljava/util/concurrent/TimeUnit;->HOURS:Ljava/util/concurrent/TimeUnit;
const-wide/16 v1, 0x8
invoke-virtual {v0, v1, v2}, Ljava/util/concurrent/TimeUnit;->toSeconds(J)J
move-result-wide v0
sput-wide v0, Lcom/google/firebase/messaging/TopicsSubscriber;->MAX_DELAY_SEC:J
return-void
.end method
.method private constructor <init>(Lcom/google/firebase/iid/FirebaseInstanceId;Lcom/google/firebase/iid/Metadata;Lcom/google/firebase/messaging/TopicsStore;Lcom/google/firebase/iid/GmsRpc;Landroid/content/Context;Ljava/util/concurrent/ScheduledExecutorService;)V
.registers 8
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
new-instance v0, Le/e/a;
invoke-direct {v0}, Le/e/a;-><init>()V
iput-object v0, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->pendingOperations:Ljava/util/Map;
const/4 v0, 0x0
iput-boolean v0, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->syncScheduledOrRunning:Z
iput-object p1, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->iid:Lcom/google/firebase/iid/FirebaseInstanceId;
iput-object p2, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->metadata:Lcom/google/firebase/iid/Metadata;
iput-object p3, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->store:Lcom/google/firebase/messaging/TopicsStore;
iput-object p4, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->rpc:Lcom/google/firebase/iid/GmsRpc;
iput-object p5, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->context:Landroid/content/Context;
iput-object p6, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->syncExecutor:Ljava/util/concurrent/ScheduledExecutorService;
return-void
.end method
.method private addToPendingOperations(Lcom/google/firebase/messaging/TopicOperation;Lcom/google/android/gms/tasks/TaskCompletionSource;)V
.registers 6
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lcom/google/firebase/messaging/TopicOperation;",
"Lcom/google/android/gms/tasks/TaskCompletionSource<",
"Ljava/lang/Void;",
">;)V"
}
.end annotation
iget-object v0, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->pendingOperations:Ljava/util/Map;
monitor-enter v0
:try_start_3
invoke-virtual {p1}, Lcom/google/firebase/messaging/TopicOperation;->serialize()Ljava/lang/String;
move-result-object p1
iget-object v1, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->pendingOperations:Ljava/util/Map;
invoke-interface {v1, p1}, Ljava/util/Map;->containsKey(Ljava/lang/Object;)Z
move-result v1
if-eqz v1, :cond_18
iget-object v1, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->pendingOperations:Ljava/util/Map;
invoke-interface {v1, p1}, Ljava/util/Map;->get(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object p1
check-cast p1, Ljava/util/ArrayDeque;
goto :goto_23
:cond_18
new-instance v1, Ljava/util/ArrayDeque;
invoke-direct {v1}, Ljava/util/ArrayDeque;-><init>()V
iget-object v2, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->pendingOperations:Ljava/util/Map;
invoke-interface {v2, p1, v1}, Ljava/util/Map;->put(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
move-object p1, v1
:goto_23
invoke-virtual {p1, p2}, Ljava/util/ArrayDeque;->add(Ljava/lang/Object;)Z
monitor-exit v0
return-void
:catchall_28
move-exception p1
monitor-exit v0
:try_end_2a
.catchall {:try_start_3 .. :try_end_2a} :catchall_28
throw p1
.end method
.method private static awaitTask(Lcom/google/android/gms/tasks/Task;)Ljava/lang/Object;
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(",
"Lcom/google/android/gms/tasks/Task<",
"TT;>;)TT;"
}
.end annotation
:try_start_0
sget-object v0, Ljava/util/concurrent/TimeUnit;->SECONDS:Ljava/util/concurrent/TimeUnit;
const-wide/16 v1, 0x1e
invoke-static {p0, v1, v2, v0}, Lcom/google/android/gms/tasks/Tasks;->await(Lcom/google/android/gms/tasks/Task;JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;
move-result-object p0
:try_end_8
.catch Ljava/util/concurrent/ExecutionException; {:try_start_0 .. :try_end_8} :catch_14
.catch Ljava/lang/InterruptedException; {:try_start_0 .. :try_end_8} :catch_b
.catch Ljava/util/concurrent/TimeoutException; {:try_start_0 .. :try_end_8} :catch_9
return-object p0
:catch_9
move-exception p0
goto :goto_c
:catch_b
move-exception p0
:goto_c
new-instance v0, Ljava/io/IOException;
const-string v1, "SERVICE_NOT_AVAILABLE"
invoke-direct {v0, v1, p0}, Ljava/io/IOException;-><init>(Ljava/lang/String;Ljava/lang/Throwable;)V
throw v0
:catch_14
move-exception p0
invoke-virtual {p0}, Ljava/util/concurrent/ExecutionException;->getCause()Ljava/lang/Throwable;
move-result-object v0
instance-of v1, v0, Ljava/io/IOException;
if-nez v1, :cond_2a
instance-of v1, v0, Ljava/lang/RuntimeException;
if-eqz v1, :cond_24
check-cast v0, Ljava/lang/RuntimeException;
throw v0
:cond_24
new-instance v0, Ljava/io/IOException;
invoke-direct {v0, p0}, Ljava/io/IOException;-><init>(Ljava/lang/Throwable;)V
throw v0
:cond_2a
check-cast v0, Ljava/io/IOException;
throw v0
.end method
.method private blockingSubscribeToTopic(Ljava/lang/String;)V
.registers 5
iget-object v0, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->iid:Lcom/google/firebase/iid/FirebaseInstanceId;
invoke-virtual {v0}, Lcom/google/firebase/iid/FirebaseInstanceId;->getInstanceId()Lcom/google/android/gms/tasks/Task;
move-result-object v0
invoke-static {v0}, Lcom/google/firebase/messaging/TopicsSubscriber;->awaitTask(Lcom/google/android/gms/tasks/Task;)Ljava/lang/Object;
move-result-object v0
check-cast v0, Lcom/google/firebase/iid/InstanceIdResult;
iget-object v1, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->rpc:Lcom/google/firebase/iid/GmsRpc;
invoke-interface {v0}, Lcom/google/firebase/iid/InstanceIdResult;->getId()Ljava/lang/String;
move-result-object v2
invoke-interface {v0}, Lcom/google/firebase/iid/InstanceIdResult;->getToken()Ljava/lang/String;
move-result-object v0
invoke-virtual {v1, v2, v0, p1}, Lcom/google/firebase/iid/GmsRpc;->subscribeToTopic(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lcom/google/android/gms/tasks/Task;
move-result-object p1
invoke-static {p1}, Lcom/google/firebase/messaging/TopicsSubscriber;->awaitTask(Lcom/google/android/gms/tasks/Task;)Ljava/lang/Object;
return-void
.end method
.method private blockingUnsubscribeFromTopic(Ljava/lang/String;)V
.registers 5
iget-object v0, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->iid:Lcom/google/firebase/iid/FirebaseInstanceId;
invoke-virtual {v0}, Lcom/google/firebase/iid/FirebaseInstanceId;->getInstanceId()Lcom/google/android/gms/tasks/Task;
move-result-object v0
invoke-static {v0}, Lcom/google/firebase/messaging/TopicsSubscriber;->awaitTask(Lcom/google/android/gms/tasks/Task;)Ljava/lang/Object;
move-result-object v0
check-cast v0, Lcom/google/firebase/iid/InstanceIdResult;
iget-object v1, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->rpc:Lcom/google/firebase/iid/GmsRpc;
invoke-interface {v0}, Lcom/google/firebase/iid/InstanceIdResult;->getId()Ljava/lang/String;
move-result-object v2
invoke-interface {v0}, Lcom/google/firebase/iid/InstanceIdResult;->getToken()Ljava/lang/String;
move-result-object v0
invoke-virtual {v1, v2, v0, p1}, Lcom/google/firebase/iid/GmsRpc;->unsubscribeFromTopic(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lcom/google/android/gms/tasks/Task;
move-result-object p1
invoke-static {p1}, Lcom/google/firebase/messaging/TopicsSubscriber;->awaitTask(Lcom/google/android/gms/tasks/Task;)Ljava/lang/Object;
return-void
.end method
.method static createInstance(Lcom/google/firebase/FirebaseApp;Lcom/google/firebase/iid/FirebaseInstanceId;Lcom/google/firebase/iid/Metadata;Lcom/google/firebase/inject/Provider;Lcom/google/firebase/inject/Provider;Lcom/google/firebase/installations/FirebaseInstallationsApi;Landroid/content/Context;Ljava/util/concurrent/ScheduledExecutorService;)Lcom/google/android/gms/tasks/Task;
.registers 15
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lcom/google/firebase/FirebaseApp;",
"Lcom/google/firebase/iid/FirebaseInstanceId;",
"Lcom/google/firebase/iid/Metadata;",
"Lcom/google/firebase/inject/Provider<",
"Lcom/google/firebase/platforminfo/UserAgentPublisher;",
">;",
"Lcom/google/firebase/inject/Provider<",
"Lcom/google/firebase/heartbeatinfo/HeartBeatInfo;",
">;",
"Lcom/google/firebase/installations/FirebaseInstallationsApi;",
"Landroid/content/Context;",
"Ljava/util/concurrent/ScheduledExecutorService;",
")",
"Lcom/google/android/gms/tasks/Task<",
"Lcom/google/firebase/messaging/TopicsSubscriber;",
">;"
}
.end annotation
new-instance v6, Lcom/google/firebase/iid/GmsRpc;
move-object v0, v6
move-object v1, p0
move-object v2, p2
move-object v3, p3
move-object v4, p4
move-object v5, p5
invoke-direct/range {v0 .. v5}, Lcom/google/firebase/iid/GmsRpc;-><init>(Lcom/google/firebase/FirebaseApp;Lcom/google/firebase/iid/Metadata;Lcom/google/firebase/inject/Provider;Lcom/google/firebase/inject/Provider;Lcom/google/firebase/installations/FirebaseInstallationsApi;)V
invoke-static {p1, p2, v6, p6, p7}, Lcom/google/firebase/messaging/TopicsSubscriber;->createInstance(Lcom/google/firebase/iid/FirebaseInstanceId;Lcom/google/firebase/iid/Metadata;Lcom/google/firebase/iid/GmsRpc;Landroid/content/Context;Ljava/util/concurrent/ScheduledExecutorService;)Lcom/google/android/gms/tasks/Task;
move-result-object p0
return-object p0
.end method
.method static createInstance(Lcom/google/firebase/iid/FirebaseInstanceId;Lcom/google/firebase/iid/Metadata;Lcom/google/firebase/iid/GmsRpc;Landroid/content/Context;Ljava/util/concurrent/ScheduledExecutorService;)Lcom/google/android/gms/tasks/Task;
.registers 12
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lcom/google/firebase/iid/FirebaseInstanceId;",
"Lcom/google/firebase/iid/Metadata;",
"Lcom/google/firebase/iid/GmsRpc;",
"Landroid/content/Context;",
"Ljava/util/concurrent/ScheduledExecutorService;",
")",
"Lcom/google/android/gms/tasks/Task<",
"Lcom/google/firebase/messaging/TopicsSubscriber;",
">;"
}
.end annotation
new-instance v6, Lcom/google/firebase/messaging/TopicsSubscriber$$Lambda$0;
move-object v0, v6
move-object v1, p3
move-object v2, p4
move-object v3, p0
move-object v4, p1
move-object v5, p2
invoke-direct/range {v0 .. v5}, Lcom/google/firebase/messaging/TopicsSubscriber$$Lambda$0;-><init>(Landroid/content/Context;Ljava/util/concurrent/ScheduledExecutorService;Lcom/google/firebase/iid/FirebaseInstanceId;Lcom/google/firebase/iid/Metadata;Lcom/google/firebase/iid/GmsRpc;)V
invoke-static {p4, v6}, Lcom/google/android/gms/tasks/Tasks;->call(Ljava/util/concurrent/Executor;Ljava/util/concurrent/Callable;)Lcom/google/android/gms/tasks/Task;
move-result-object p0
return-object p0
.end method
.method static isDebugLogEnabled()Z
.registers 6
const-string v0, "FirebaseMessaging"
const/4 v1, 0x3
invoke-static {v0, v1}, Landroid/util/Log;->isLoggable(Ljava/lang/String;I)Z
move-result v2
const/4 v3, 0x0
const/4 v4, 0x1
if-nez v2, :cond_19
sget v2, Landroid/os/Build$VERSION;->SDK_INT:I
const/16 v5, 0x17
if-ne v2, v5, :cond_1a
invoke-static {v0, v1}, Landroid/util/Log;->isLoggable(Ljava/lang/String;I)Z
move-result v0
if-eqz v0, :cond_18
goto :goto_19
:cond_18
return v3
:cond_19
:goto_19
const/4 v3, 0x1
:cond_1a
return v3
.end method
.method static final synthetic lambda$createInstance$0$TopicsSubscriber(Landroid/content/Context;Ljava/util/concurrent/ScheduledExecutorService;Lcom/google/firebase/iid/FirebaseInstanceId;Lcom/google/firebase/iid/Metadata;Lcom/google/firebase/iid/GmsRpc;)Lcom/google/firebase/messaging/TopicsSubscriber;
.registers 13
invoke-static {p0, p1}, Lcom/google/firebase/messaging/TopicsStore;->getInstance(Landroid/content/Context;Ljava/util/concurrent/Executor;)Lcom/google/firebase/messaging/TopicsStore;
move-result-object v3
new-instance v7, Lcom/google/firebase/messaging/TopicsSubscriber;
move-object v0, v7
move-object v1, p2
move-object v2, p3
move-object v4, p4
move-object v5, p0
move-object v6, p1
invoke-direct/range {v0 .. v6}, Lcom/google/firebase/messaging/TopicsSubscriber;-><init>(Lcom/google/firebase/iid/FirebaseInstanceId;Lcom/google/firebase/iid/Metadata;Lcom/google/firebase/messaging/TopicsStore;Lcom/google/firebase/iid/GmsRpc;Landroid/content/Context;Ljava/util/concurrent/ScheduledExecutorService;)V
return-object v7
.end method
.method private markCompletePendingOperation(Lcom/google/firebase/messaging/TopicOperation;)V
.registers 6
iget-object v0, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->pendingOperations:Ljava/util/Map;
monitor-enter v0
:try_start_3
invoke-virtual {p1}, Lcom/google/firebase/messaging/TopicOperation;->serialize()Ljava/lang/String;
move-result-object p1
iget-object v1, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->pendingOperations:Ljava/util/Map;
invoke-interface {v1, p1}, Ljava/util/Map;->containsKey(Ljava/lang/Object;)Z
move-result v1
if-nez v1, :cond_11
monitor-exit v0
return-void
:cond_11
iget-object v1, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->pendingOperations:Ljava/util/Map;
invoke-interface {v1, p1}, Ljava/util/Map;->get(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
check-cast v1, Ljava/util/ArrayDeque;
invoke-virtual {v1}, Ljava/util/ArrayDeque;->poll()Ljava/lang/Object;
move-result-object v2
check-cast v2, Lcom/google/android/gms/tasks/TaskCompletionSource;
if-eqz v2, :cond_25
const/4 v3, 0x0
invoke-virtual {v2, v3}, Lcom/google/android/gms/tasks/TaskCompletionSource;->setResult(Ljava/lang/Object;)V
:cond_25
invoke-virtual {v1}, Ljava/util/ArrayDeque;->isEmpty()Z
move-result v1
if-eqz v1, :cond_30
iget-object v1, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->pendingOperations:Ljava/util/Map;
invoke-interface {v1, p1}, Ljava/util/Map;->remove(Ljava/lang/Object;)Ljava/lang/Object;
:cond_30
monitor-exit v0
return-void
:catchall_32
move-exception p1
monitor-exit v0
:try_end_34
.catchall {:try_start_3 .. :try_end_34} :catchall_32
throw p1
.end method
.method private startSync()V
.registers 3
invoke-virtual {p0}, Lcom/google/firebase/messaging/TopicsSubscriber;->isSyncScheduledOrRunning()Z
move-result v0
if-nez v0, :cond_b
const-wide/16 v0, 0x0
invoke-virtual {p0, v0, v1}, Lcom/google/firebase/messaging/TopicsSubscriber;->syncWithDelaySecondsInternal(J)V
:cond_b
return-void
.end method
# virtual methods
.method hasPendingOperation()Z
.registers 2
iget-object v0, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->store:Lcom/google/firebase/messaging/TopicsStore;
invoke-virtual {v0}, Lcom/google/firebase/messaging/TopicsStore;->getNextTopicOperation()Lcom/google/firebase/messaging/TopicOperation;
move-result-object v0
if-eqz v0, :cond_a
const/4 v0, 0x1
return v0
:cond_a
const/4 v0, 0x0
return v0
.end method
.method declared-synchronized isSyncScheduledOrRunning()Z
.registers 2
monitor-enter p0
:try_start_1
iget-boolean v0, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->syncScheduledOrRunning:Z
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_5
monitor-exit p0
return v0
:catchall_5
move-exception v0
monitor-exit p0
throw v0
.end method
.method performTopicOperation(Lcom/google/firebase/messaging/TopicOperation;)Z
.registers 8
const-string v0, "FirebaseMessaging"
const/4 v1, 0x0
:try_start_3
invoke-virtual {p1}, Lcom/google/firebase/messaging/TopicOperation;->getOperation()Ljava/lang/String;
move-result-object v2
invoke-virtual {v2}, Ljava/lang/String;->hashCode()I
move-result v3
:try_end_b
.catch Ljava/io/IOException; {:try_start_3 .. :try_end_b} :catch_bf
const/16 v4, 0x53
const/4 v5, 0x1
if-eq v3, v4, :cond_1f
const/16 v4, 0x55
if-eq v3, v4, :cond_15
goto :goto_29
:cond_15
const-string v3, "U"
invoke-virtual {v2, v3}, Ljava/lang/String;->equals(Ljava/lang/Object;)Z
move-result v2
if-eqz v2, :cond_29
const/4 v2, 0x1
goto :goto_2a
:cond_1f
const-string v3, "S"
invoke-virtual {v2, v3}, Ljava/lang/String;->equals(Ljava/lang/Object;)Z
move-result v2
if-eqz v2, :cond_29
const/4 v2, 0x0
goto :goto_2a
:cond_29
:goto_29
const/4 v2, -0x1
:goto_2a
const-string v3, " succeeded."
if-eqz v2, :cond_8e
if-eq v2, v5, :cond_5e
:try_start_30
invoke-static {}, Lcom/google/firebase/messaging/TopicsSubscriber;->isDebugLogEnabled()Z
move-result v2
if-eqz v2, :cond_be
invoke-static {p1}, Ljava/lang/String;->valueOf(Ljava/lang/Object;)Ljava/lang/String;
move-result-object p1
invoke-static {p1}, Ljava/lang/String;->valueOf(Ljava/lang/Object;)Ljava/lang/String;
move-result-object v2
invoke-virtual {v2}, Ljava/lang/String;->length()I
move-result v2
add-int/lit8 v2, v2, 0x18
new-instance v3, Ljava/lang/StringBuilder;
invoke-direct {v3, v2}, Ljava/lang/StringBuilder;-><init>(I)V
const-string v2, "Unknown topic operation"
invoke-virtual {v3, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v3, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string p1, "."
invoke-virtual {v3, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v3}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p1
:goto_5a
invoke-static {v0, p1}, Landroid/util/Log;->d(Ljava/lang/String;Ljava/lang/String;)I
goto :goto_be
:cond_5e
invoke-virtual {p1}, Lcom/google/firebase/messaging/TopicOperation;->getTopic()Ljava/lang/String;
move-result-object v2
invoke-direct {p0, v2}, Lcom/google/firebase/messaging/TopicsSubscriber;->blockingUnsubscribeFromTopic(Ljava/lang/String;)V
invoke-static {}, Lcom/google/firebase/messaging/TopicsSubscriber;->isDebugLogEnabled()Z
move-result v2
if-eqz v2, :cond_be
invoke-virtual {p1}, Lcom/google/firebase/messaging/TopicOperation;->getTopic()Ljava/lang/String;
move-result-object p1
invoke-static {p1}, Ljava/lang/String;->valueOf(Ljava/lang/Object;)Ljava/lang/String;
move-result-object v2
invoke-virtual {v2}, Ljava/lang/String;->length()I
move-result v2
add-int/lit8 v2, v2, 0x23
new-instance v4, Ljava/lang/StringBuilder;
invoke-direct {v4, v2}, Ljava/lang/StringBuilder;-><init>(I)V
const-string v2, "Unsubscribe from topic: "
invoke-virtual {v4, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v4, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v4, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v4}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p1
goto :goto_5a
:cond_8e
invoke-virtual {p1}, Lcom/google/firebase/messaging/TopicOperation;->getTopic()Ljava/lang/String;
move-result-object v2
invoke-direct {p0, v2}, Lcom/google/firebase/messaging/TopicsSubscriber;->blockingSubscribeToTopic(Ljava/lang/String;)V
invoke-static {}, Lcom/google/firebase/messaging/TopicsSubscriber;->isDebugLogEnabled()Z
move-result v2
if-eqz v2, :cond_be
invoke-virtual {p1}, Lcom/google/firebase/messaging/TopicOperation;->getTopic()Ljava/lang/String;
move-result-object p1
invoke-static {p1}, Ljava/lang/String;->valueOf(Ljava/lang/Object;)Ljava/lang/String;
move-result-object v2
invoke-virtual {v2}, Ljava/lang/String;->length()I
move-result v2
add-int/lit8 v2, v2, 0x1f
new-instance v4, Ljava/lang/StringBuilder;
invoke-direct {v4, v2}, Ljava/lang/StringBuilder;-><init>(I)V
const-string v2, "Subscribe to topic: "
invoke-virtual {v4, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v4, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v4, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v4}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p1
:try_end_bd
.catch Ljava/io/IOException; {:try_start_30 .. :try_end_bd} :catch_bf
goto :goto_5a
:cond_be
:goto_be
return v5
:catch_bf
move-exception p1
invoke-virtual {p1}, Ljava/io/IOException;->getMessage()Ljava/lang/String;
move-result-object v2
const-string v3, "SERVICE_NOT_AVAILABLE"
invoke-virtual {v3, v2}, Ljava/lang/String;->equals(Ljava/lang/Object;)Z
move-result v2
if-nez v2, :cond_e6
invoke-virtual {p1}, Ljava/io/IOException;->getMessage()Ljava/lang/String;
move-result-object v2
const-string v3, "INTERNAL_SERVER_ERROR"
invoke-virtual {v3, v2}, Ljava/lang/String;->equals(Ljava/lang/Object;)Z
move-result v2
if-eqz v2, :cond_d9
goto :goto_e6
:cond_d9
invoke-virtual {p1}, Ljava/io/IOException;->getMessage()Ljava/lang/String;
move-result-object v2
if-nez v2, :cond_e5
const-string p1, "Topic operation failed without exception message. Will retry Topic operation."
:goto_e1
invoke-static {v0, p1}, Landroid/util/Log;->e(Ljava/lang/String;Ljava/lang/String;)I
return v1
:cond_e5
throw p1
:cond_e6
:goto_e6
invoke-virtual {p1}, Ljava/io/IOException;->getMessage()Ljava/lang/String;
move-result-object p1
invoke-static {p1}, Ljava/lang/String;->valueOf(Ljava/lang/Object;)Ljava/lang/String;
move-result-object v2
invoke-virtual {v2}, Ljava/lang/String;->length()I
move-result v2
new-instance v3, Ljava/lang/StringBuilder;
add-int/lit8 v2, v2, 0x35
invoke-direct {v3, v2}, Ljava/lang/StringBuilder;-><init>(I)V
const-string v2, "Topic operation failed: "
invoke-virtual {v3, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v3, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string p1, ". Will retry Topic operation."
invoke-virtual {v3, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v3}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p1
goto :goto_e1
.end method
.method scheduleSyncTaskWithDelaySeconds(Ljava/lang/Runnable;J)V
.registers 6
iget-object v0, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->syncExecutor:Ljava/util/concurrent/ScheduledExecutorService;
sget-object v1, Ljava/util/concurrent/TimeUnit;->SECONDS:Ljava/util/concurrent/TimeUnit;
invoke-interface {v0, p1, p2, p3, v1}, Ljava/util/concurrent/ScheduledExecutorService;->schedule(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
return-void
.end method
.method scheduleTopicOperation(Lcom/google/firebase/messaging/TopicOperation;)Lcom/google/android/gms/tasks/Task;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lcom/google/firebase/messaging/TopicOperation;",
")",
"Lcom/google/android/gms/tasks/Task<",
"Ljava/lang/Void;",
">;"
}
.end annotation
iget-object v0, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->store:Lcom/google/firebase/messaging/TopicsStore;
invoke-virtual {v0, p1}, Lcom/google/firebase/messaging/TopicsStore;->addTopicOperation(Lcom/google/firebase/messaging/TopicOperation;)Z
new-instance v0, Lcom/google/android/gms/tasks/TaskCompletionSource;
invoke-direct {v0}, Lcom/google/android/gms/tasks/TaskCompletionSource;-><init>()V
invoke-direct {p0, p1, v0}, Lcom/google/firebase/messaging/TopicsSubscriber;->addToPendingOperations(Lcom/google/firebase/messaging/TopicOperation;Lcom/google/android/gms/tasks/TaskCompletionSource;)V
invoke-virtual {v0}, Lcom/google/android/gms/tasks/TaskCompletionSource;->getTask()Lcom/google/android/gms/tasks/Task;
move-result-object p1
return-object p1
.end method
.method declared-synchronized setSyncScheduledOrRunning(Z)V
.registers 2
monitor-enter p0
:try_start_1
iput-boolean p1, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->syncScheduledOrRunning:Z
:try_end_3
.catchall {:try_start_1 .. :try_end_3} :catchall_5
monitor-exit p0
return-void
:catchall_5
move-exception p1
monitor-exit p0
throw p1
.end method
.method startTopicsSyncIfNecessary()V
.registers 2
invoke-virtual {p0}, Lcom/google/firebase/messaging/TopicsSubscriber;->hasPendingOperation()Z
move-result v0
if-eqz v0, :cond_9
invoke-direct {p0}, Lcom/google/firebase/messaging/TopicsSubscriber;->startSync()V
:cond_9
return-void
.end method
.method subscribeToTopic(Ljava/lang/String;)Lcom/google/android/gms/tasks/Task;
.registers 2
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/lang/String;",
")",
"Lcom/google/android/gms/tasks/Task<",
"Ljava/lang/Void;",
">;"
}
.end annotation
invoke-static {p1}, Lcom/google/firebase/messaging/TopicOperation;->subscribe(Ljava/lang/String;)Lcom/google/firebase/messaging/TopicOperation;
move-result-object p1
invoke-virtual {p0, p1}, Lcom/google/firebase/messaging/TopicsSubscriber;->scheduleTopicOperation(Lcom/google/firebase/messaging/TopicOperation;)Lcom/google/android/gms/tasks/Task;
move-result-object p1
invoke-virtual {p0}, Lcom/google/firebase/messaging/TopicsSubscriber;->startTopicsSyncIfNecessary()V
return-object p1
.end method
.method syncTopics()Z
.registers 3
:goto_0
monitor-enter p0
:try_start_1
iget-object v0, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->store:Lcom/google/firebase/messaging/TopicsStore;
invoke-virtual {v0}, Lcom/google/firebase/messaging/TopicsStore;->getNextTopicOperation()Lcom/google/firebase/messaging/TopicOperation;
move-result-object v0
if-nez v0, :cond_19
invoke-static {}, Lcom/google/firebase/messaging/TopicsSubscriber;->isDebugLogEnabled()Z
move-result v0
if-eqz v0, :cond_16
const-string v0, "FirebaseMessaging"
const-string v1, "topic sync succeeded"
invoke-static {v0, v1}, Landroid/util/Log;->d(Ljava/lang/String;Ljava/lang/String;)I
:cond_16
monitor-exit p0
const/4 v0, 0x1
return v0
:cond_19
monitor-exit p0
:try_end_1a
.catchall {:try_start_1 .. :try_end_1a} :catchall_2b
invoke-virtual {p0, v0}, Lcom/google/firebase/messaging/TopicsSubscriber;->performTopicOperation(Lcom/google/firebase/messaging/TopicOperation;)Z
move-result v1
if-nez v1, :cond_22
const/4 v0, 0x0
return v0
:cond_22
iget-object v1, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->store:Lcom/google/firebase/messaging/TopicsStore;
invoke-virtual {v1, v0}, Lcom/google/firebase/messaging/TopicsStore;->removeTopicOperation(Lcom/google/firebase/messaging/TopicOperation;)Z
invoke-direct {p0, v0}, Lcom/google/firebase/messaging/TopicsSubscriber;->markCompletePendingOperation(Lcom/google/firebase/messaging/TopicOperation;)V
goto :goto_0
:catchall_2b
move-exception v0
:try_start_2c
monitor-exit p0
:try_end_2d
.catchall {:try_start_2c .. :try_end_2d} :catchall_2b
goto :goto_2f
:goto_2e
throw v0
:goto_2f
goto :goto_2e
.end method
.method syncWithDelaySecondsInternal(J)V
.registers 13
add-long v0, p1, p1
const-wide/16 v2, 0x1e
invoke-static {v2, v3, v0, v1}, Ljava/lang/Math;->max(JJ)J
move-result-wide v0
sget-wide v2, Lcom/google/firebase/messaging/TopicsSubscriber;->MAX_DELAY_SEC:J
invoke-static {v0, v1, v2, v3}, Ljava/lang/Math;->min(JJ)J
move-result-wide v8
new-instance v0, Lcom/google/firebase/messaging/TopicsSyncTask;
iget-object v6, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->context:Landroid/content/Context;
iget-object v7, p0, Lcom/google/firebase/messaging/TopicsSubscriber;->metadata:Lcom/google/firebase/iid/Metadata;
move-object v4, v0
move-object v5, p0
invoke-direct/range {v4 .. v9}, Lcom/google/firebase/messaging/TopicsSyncTask;-><init>(Lcom/google/firebase/messaging/TopicsSubscriber;Landroid/content/Context;Lcom/google/firebase/iid/Metadata;J)V
invoke-virtual {p0, v0, p1, p2}, Lcom/google/firebase/messaging/TopicsSubscriber;->scheduleSyncTaskWithDelaySeconds(Ljava/lang/Runnable;J)V
const/4 p1, 0x1
invoke-virtual {p0, p1}, Lcom/google/firebase/messaging/TopicsSubscriber;->setSyncScheduledOrRunning(Z)V
return-void
.end method
.method unsubscribeFromTopic(Ljava/lang/String;)Lcom/google/android/gms/tasks/Task;
.registers 2
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/lang/String;",
")",
"Lcom/google/android/gms/tasks/Task<",
"Ljava/lang/Void;",
">;"
}
.end annotation
invoke-static {p1}, Lcom/google/firebase/messaging/TopicOperation;->unsubscribe(Ljava/lang/String;)Lcom/google/firebase/messaging/TopicOperation;
move-result-object p1
invoke-virtual {p0, p1}, Lcom/google/firebase/messaging/TopicsSubscriber;->scheduleTopicOperation(Lcom/google/firebase/messaging/TopicOperation;)Lcom/google/android/gms/tasks/Task;
move-result-object p1
invoke-virtual {p0}, Lcom/google/firebase/messaging/TopicsSubscriber;->startTopicsSyncIfNecessary()V
return-object p1
.end method