FCTokenRequestCallback$2.smali

.class Lim/tpelyyftgw/tgnet/FCTokenRequestCallback$2;
.super Ljava/lang/Object;
.source "FCTokenRequestCallback.java"

# interfaces
.implements Lio/reactivex/ObservableOnSubscribe;


# annotations
.annotation system Ldalvik/annotation/EnclosingMethod;
    value = Lim/tpelyyftgw/tgnet/FCTokenRequestCallback;->requestToken(Lio/reactivex/ObservableEmitter;)V
.end annotation

.annotation system Ldalvik/annotation/InnerClass;
    accessFlags = 0x0
    name = null
.end annotation

.annotation system Ldalvik/annotation/Signature;
    value = {
        "Ljava/lang/Object;",
        "Lio/reactivex/ObservableOnSubscribe<",
        "Ljava/lang/String;",
        ">;"
    }
.end annotation


# instance fields
.field final synthetic this$0:Lim/tpelyyftgw/tgnet/FCTokenRequestCallback;


# direct methods
.method static constructor <clinit>()V
    .registers 1

    return-void
.end method

.method constructor <init>(Lim/tpelyyftgw/tgnet/FCTokenRequestCallback;)V
    .registers 2
    .param p1, "this$0"    # Lim/tpelyyftgw/tgnet/FCTokenRequestCallback;

    .line 53
    iput-object p1, p0, Lim/tpelyyftgw/tgnet/FCTokenRequestCallback$2;->this$0:Lim/tpelyyftgw/tgnet/FCTokenRequestCallback;

    invoke-direct {p0}, Ljava/lang/Object;-><init>()V

    return-void
.end method

.method static synthetic lambda$subscribe$0(Lio/reactivex/ObservableEmitter;Lim/tpelyyftgw/tgnet/TLObject;Lim/tpelyyftgw/tgnet/TLRPC$TL_error;)V
    .registers 15
    .param p0, "e"    # Lio/reactivex/ObservableEmitter;
    .param p1, "response"    # Lim/tpelyyftgw/tgnet/TLObject;
    .param p2, "error"    # Lim/tpelyyftgw/tgnet/TLRPC$TL_error;

    .line 60
    instance-of v0, p1, Lim/tpelyyftgw/tgnet/TLRPCBasic$TL_AllToken;

    const-string/jumbo v1, "\u83b7\u53d6\u670b\u53cb\u5708Token error == "

    const/4 v2, 0x0

    const/4 v3, 0x1

    if-eqz v0, :cond_b5

    .line 61
    move-object v0, p1

    check-cast v0, Lim/tpelyyftgw/tgnet/TLRPCBasic$TL_AllToken;

    .line 62
    .local v0, "tl_allToken":Lim/tpelyyftgw/tgnet/TLRPCBasic$TL_AllToken;
    iget-object v4, v0, Lim/tpelyyftgw/tgnet/TLRPCBasic$TL_AllToken;->tokens:Lim/tpelyyftgw/tgnet/TLRPC$TL_dataJSON;

    .line 63
    .local v4, "tokens":Lim/tpelyyftgw/tgnet/TLRPC$TL_dataJSON;
    const-string/jumbo v5, "\u83b7\u53d6Token\u5931\u8d25"

    if-eqz v4, :cond_89

    .line 65
    iget-object v6, v4, Lim/tpelyyftgw/tgnet/TLRPC$TL_dataJSON;->data:Ljava/lang/String;

    .line 66
    .local v6, "data":Ljava/lang/String;
    invoke-static {v6}, Landroid/text/TextUtils;->isEmpty(Ljava/lang/CharSequence;)Z

    move-result v7

    if-nez v7, :cond_72

    .line 68
    :try_start_1b
    new-instance v5, Lcom/google/gson/Gson;

    invoke-direct {v5}, Lcom/google/gson/Gson;-><init>()V

    const-class v7, Lim/tpelyyftgw/javaBean/AllTokenResponse;

    invoke-virtual {v5, v6, v7}, Lcom/google/gson/Gson;->fromJson(Ljava/lang/String;Ljava/lang/Class;)Ljava/lang/Object;

    move-result-object v5

    check-cast v5, Lim/tpelyyftgw/javaBean/AllTokenResponse;

    .line 69
    .local v5, "tokenResponse":Lim/tpelyyftgw/javaBean/AllTokenResponse;
    if-eqz v5, :cond_71

    .line 70
    invoke-virtual {v5}, Lim/tpelyyftgw/javaBean/AllTokenResponse;->getMomenttoken()Ljava/lang/String;

    move-result-object v7

    .line 71
    .local v7, "momenttoken":Ljava/lang/String;
    # getter for: Lim/tpelyyftgw/tgnet/FCTokenRequestCallback;->TAG:Ljava/lang/String;
    invoke-static {}, Lim/tpelyyftgw/tgnet/FCTokenRequestCallback;->access$200()Ljava/lang/String;

    move-result-object v8

    new-array v9, v3, [Ljava/lang/Object;

    new-instance v10, Ljava/lang/StringBuilder;

    invoke-direct {v10}, Ljava/lang/StringBuilder;-><init>()V

    const-string/jumbo v11, "\u83b7\u53d6\u670b\u53cb\u5708Token == "

    invoke-virtual {v10, v11}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {v10, v7}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {v10}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object v10

    aput-object v10, v9, v2

    invoke-static {v8, v9}, Lcom/socks/library/KLog;->e(Ljava/lang/String;[Ljava/lang/Object;)V

    .line 72
    invoke-interface {p0, v7}, Lio/reactivex/ObservableEmitter;->onNext(Ljava/lang/Object;)V
    :try_end_4e
    .catch Ljava/lang/Exception; {:try_start_1b .. :try_end_4e} :catch_4f

    goto :goto_71

    .line 74
    .end local v5    # "tokenResponse":Lim/tpelyyftgw/javaBean/AllTokenResponse;
    .end local v7    # "momenttoken":Ljava/lang/String;
    :catch_4f
    move-exception v5

    .line 75
    .local v5, "exception":Ljava/lang/Exception;
    # getter for: Lim/tpelyyftgw/tgnet/FCTokenRequestCallback;->TAG:Ljava/lang/String;
    invoke-static {}, Lim/tpelyyftgw/tgnet/FCTokenRequestCallback;->access$200()Ljava/lang/String;

    move-result-object v7

    new-array v3, v3, [Ljava/lang/Object;

    new-instance v8, Ljava/lang/StringBuilder;

    invoke-direct {v8}, Ljava/lang/StringBuilder;-><init>()V

    invoke-virtual {v8, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {v5}, Ljava/lang/Exception;->getMessage()Ljava/lang/String;

    move-result-object v1

    invoke-virtual {v8, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {v8}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object v1

    aput-object v1, v3, v2

    invoke-static {v7, v3}, Lcom/socks/library/KLog;->e(Ljava/lang/String;[Ljava/lang/Object;)V

    .line 76
    invoke-interface {p0, v5}, Lio/reactivex/ObservableEmitter;->onError(Ljava/lang/Throwable;)V

    .line 77
    .end local v5    # "exception":Ljava/lang/Exception;
    :cond_71
    :goto_71
    goto :goto_88

    .line 80
    :cond_72
    # getter for: Lim/tpelyyftgw/tgnet/FCTokenRequestCallback;->TAG:Ljava/lang/String;
    invoke-static {}, Lim/tpelyyftgw/tgnet/FCTokenRequestCallback;->access$200()Ljava/lang/String;

    move-result-object v1

    new-array v3, v3, [Ljava/lang/Object;

    const-string/jumbo v7, "\u83b7\u53d6\u670b\u53cb\u5708Token data == null "

    aput-object v7, v3, v2

    invoke-static {v1, v3}, Lcom/socks/library/KLog;->e(Ljava/lang/String;[Ljava/lang/Object;)V

    .line 81
    new-instance v1, Ljava/lang/Throwable;

    invoke-direct {v1, v5}, Ljava/lang/Throwable;-><init>(Ljava/lang/String;)V

    invoke-interface {p0, v1}, Lio/reactivex/ObservableEmitter;->onError(Ljava/lang/Throwable;)V

    .line 83
    .end local v6    # "data":Ljava/lang/String;
    :goto_88
    goto :goto_b4

    .line 84
    :cond_89
    # getter for: Lim/tpelyyftgw/tgnet/FCTokenRequestCallback;->TAG:Ljava/lang/String;
    invoke-static {}, Lim/tpelyyftgw/tgnet/FCTokenRequestCallback;->access$200()Ljava/lang/String;

    move-result-object v6

    new-array v3, v3, [Ljava/lang/Object;

    new-instance v7, Ljava/lang/StringBuilder;

    invoke-direct {v7}, Ljava/lang/StringBuilder;-><init>()V

    invoke-virtual {v7, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    iget-object v1, p2, Lim/tpelyyftgw/tgnet/TLRPC$TL_error;->text:Ljava/lang/String;

    invoke-virtual {v7, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {v7}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object v1

    aput-object v1, v3, v2

    invoke-static {v6, v3}, Lcom/socks/library/KLog;->e(Ljava/lang/String;[Ljava/lang/Object;)V

    .line 85
    new-instance v1, Ljava/lang/Throwable;

    iget-object v2, p2, Lim/tpelyyftgw/tgnet/TLRPC$TL_error;->text:Ljava/lang/String;

    if-nez v2, :cond_ac

    goto :goto_ae

    :cond_ac
    iget-object v5, p2, Lim/tpelyyftgw/tgnet/TLRPC$TL_error;->text:Ljava/lang/String;

    :goto_ae
    invoke-direct {v1, v5}, Ljava/lang/Throwable;-><init>(Ljava/lang/String;)V

    invoke-interface {p0, v1}, Lio/reactivex/ObservableEmitter;->onError(Ljava/lang/Throwable;)V

    .line 87
    .end local v0    # "tl_allToken":Lim/tpelyyftgw/tgnet/TLRPCBasic$TL_AllToken;
    .end local v4    # "tokens":Lim/tpelyyftgw/tgnet/TLRPC$TL_dataJSON;
    :goto_b4
    goto :goto_d1

    .line 88
    :cond_b5
    # getter for: Lim/tpelyyftgw/tgnet/FCTokenRequestCallback;->TAG:Ljava/lang/String;
    invoke-static {}, Lim/tpelyyftgw/tgnet/FCTokenRequestCallback;->access$200()Ljava/lang/String;

    move-result-object v0

    new-array v3, v3, [Ljava/lang/Object;

    new-instance v4, Ljava/lang/StringBuilder;

    invoke-direct {v4}, Ljava/lang/StringBuilder;-><init>()V

    invoke-virtual {v4, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    iget-object v1, p2, Lim/tpelyyftgw/tgnet/TLRPC$TL_error;->text:Ljava/lang/String;

    invoke-virtual {v4, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {v4}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object v1

    aput-object v1, v3, v2

    invoke-static {v0, v3}, Lcom/socks/library/KLog;->e(Ljava/lang/String;[Ljava/lang/Object;)V

    .line 92
    :goto_d1
    return-void
.end method


# virtual methods
.method public subscribe(Lio/reactivex/ObservableEmitter;)V
    .registers 6
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lio/reactivex/ObservableEmitter<",
            "Ljava/lang/String;",
            ">;)V"
        }
    .end annotation

    .annotation system Ldalvik/annotation/Throws;
        value = {
            Ljava/lang/Exception;
        }
    .end annotation

    .line 56
    .local p1, "e":Lio/reactivex/ObservableEmitter;, "Lio/reactivex/ObservableEmitter<Ljava/lang/String;>;"
    new-instance v0, Lim/tpelyyftgw/tgnet/TLRPCBasic$TL_GetToken;

    invoke-direct {v0}, Lim/tpelyyftgw/tgnet/TLRPCBasic$TL_GetToken;-><init>()V

    .line 57
    .local v0, "req":Lim/tpelyyftgw/tgnet/TLRPCBasic$TL_GetToken;
    const/4 v1, 0x1

    iput-boolean v1, v0, Lim/tpelyyftgw/tgnet/TLRPCBasic$TL_GetToken;->friendCircle:Z

    .line 58
    sget v1, Lim/tpelyyftgw/messenger/UserConfig;->selectedAccount:I

    invoke-static {v1}, Lim/tpelyyftgw/messenger/AccountInstance;->getInstance(I)Lim/tpelyyftgw/messenger/AccountInstance;

    move-result-object v1

    .line 59
    .local v1, "instance":Lim/tpelyyftgw/messenger/AccountInstance;
    invoke-virtual {v1}, Lim/tpelyyftgw/messenger/AccountInstance;->getConnectionsManager()Lim/tpelyyftgw/tgnet/ConnectionsManager;

    move-result-object v2

    new-instance v3, Lim/tpelyyftgw/tgnet/-$$Lambda$FCTokenRequestCallback$2$5t_d0mLFap9OnMJcg9Y7A4IYWwc;

    invoke-direct {v3, p1}, Lim/tpelyyftgw/tgnet/-$$Lambda$FCTokenRequestCallback$2$5t_d0mLFap9OnMJcg9Y7A4IYWwc;-><init>(Lio/reactivex/ObservableEmitter;)V

    invoke-virtual {v2, v0, v3}, Lim/tpelyyftgw/tgnet/ConnectionsManager;->sendRequest(Lim/tpelyyftgw/tgnet/TLObject;Lim/tpelyyftgw/tgnet/RequestDelegate;)I

    .line 93
    return-void
.end method