ReConnectTool.smali

.class public Lcn/rongcloud/rtc/proxy/ReConnectTool;
.super Ljava/lang/Object;
.source "ReConnectTool.java"


# static fields
.field public static final NEED_MODIFY_RESOURCE:Ljava/lang/String; = "need_modify_Resource"

.field public static final NEED_PUBLISH:Ljava/lang/String; = "need_Publish"

.field public static final NEED_UNPUBLISH:Ljava/lang/String; = "need_unPublish"

.field private static final TAG:Ljava/lang/String; = "ReConnectTool"


# direct methods
.method public constructor <init>()V
    .registers 1

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

    return-void
.end method

.method private static parsePublishData(Ljava/util/List;)Ljava/lang/String;
    .registers 3
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Ljava/util/List<",
            "Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;",
            ">;)",
            "Ljava/lang/String;"
        }
    .end annotation

    if-eqz p0, :cond_24

    .line 1
    new-instance v0, Lorg/json/JSONArray;

    invoke-direct {v0}, Lorg/json/JSONArray;-><init>()V

    .line 2
    invoke-interface {p0}, Ljava/util/List;->iterator()Ljava/util/Iterator;

    move-result-object p0

    :goto_b
    invoke-interface {p0}, Ljava/util/Iterator;->hasNext()Z

    move-result v1

    if-eqz v1, :cond_1f

    invoke-interface {p0}, Ljava/util/Iterator;->next()Ljava/lang/Object;

    move-result-object v1

    check-cast v1, Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;

    .line 3
    invoke-virtual {v1}, Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;->getJsonObject()Lorg/json/JSONObject;

    move-result-object v1

    invoke-virtual {v0, v1}, Lorg/json/JSONArray;->put(Ljava/lang/Object;)Lorg/json/JSONArray;

    goto :goto_b

    .line 4
    :cond_1f
    invoke-virtual {v0}, Lorg/json/JSONArray;->toString()Ljava/lang/String;

    move-result-object p0

    goto :goto_26

    :cond_24
    const-string p0, ""

    :goto_26
    return-object p0
.end method

.method private static republish(Ljava/lang/String;Ljava/util/List;Ljava/util/List;)Lcn/rongcloud/rtc/base/AsyncResult;
    .registers 9
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Ljava/lang/String;",
            "Ljava/util/List<",
            "Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;",
            ">;",
            "Ljava/util/List<",
            "+",
            "Lcn/rongcloud/rtc/webrtc/IStreamResource;",
            ">;)",
            "Lcn/rongcloud/rtc/base/AsyncResult;"
        }
    .end annotation

    const-string v0, "ReConnectTool"

    const-string v1, "republish"

    .line 1
    invoke-static {v0, v1}, Lcn/rongcloud/rtc/utils/FinLog;->d(Ljava/lang/String;Ljava/lang/String;)V

    .line 2
    new-instance v1, Ljava/util/ArrayList;

    invoke-direct {v1}, Ljava/util/ArrayList;-><init>()V

    .line 3
    invoke-interface {p2}, Ljava/util/List;->iterator()Ljava/util/Iterator;

    move-result-object p2

    :cond_10
    :goto_10
    invoke-interface {p2}, Ljava/util/Iterator;->hasNext()Z

    move-result v2

    if-eqz v2, :cond_2f

    invoke-interface {p2}, Ljava/util/Iterator;->next()Ljava/lang/Object;

    move-result-object v2

    check-cast v2, Lcn/rongcloud/rtc/webrtc/IStreamResource;

    .line 4
    invoke-interface {v2}, Lcn/rongcloud/rtc/webrtc/IStreamResource;->getUri()Ljava/lang/String;

    move-result-object v3

    invoke-static {v3}, Landroid/text/TextUtils;->isEmpty(Ljava/lang/CharSequence;)Z

    move-result v3

    if-nez v3, :cond_10

    .line 5
    new-instance v3, Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;

    invoke-direct {v3, v2}, Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;-><init>(Lcn/rongcloud/rtc/webrtc/IStreamResource;)V

    invoke-interface {v1, v3}, Ljava/util/List;->add(Ljava/lang/Object;)Z

    goto :goto_10

    .line 6
    :cond_2f
    invoke-static {p1}, Lcn/rongcloud/rtc/proxy/ReConnectTool;->parsePublishData(Ljava/util/List;)Ljava/lang/String;

    move-result-object p2

    .line 7
    new-instance v2, Ljava/lang/StringBuilder;

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

    const-string v3, "republish->totalContent: "

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

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

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

    move-result-object v2

    invoke-static {v0, v2}, Lcn/rongcloud/rtc/utils/FinLog;->d(Ljava/lang/String;Ljava/lang/String;)V

    const/4 v0, 0x1

    .line 8
    new-array v2, v0, [Lio/rong/imlib/model/RTCStatusDate;

    const-string v3, "uris"

    .line 9
    invoke-static {v3, p2}, Lcn/rongcloud/rtc/utils/ResourceTools;->getStatusDate(Ljava/lang/String;Ljava/lang/String;)Lio/rong/imlib/model/RTCStatusDate;

    move-result-object p2

    const/4 v3, 0x0

    aput-object p2, v2, v3

    const/4 p2, 0x2

    .line 10
    new-array p2, p2, [Lio/rong/imlib/model/RTCStatusDate;

    const-string v4, ""

    .line 11
    invoke-static {v1, v0, v4}, Lcn/rongcloud/rtc/utils/ResourceTools;->getURIS(Ljava/util/List;ZLjava/lang/String;)Ljava/lang/String;

    move-result-object v1

    const-string v5, "RCRTC:UnpublishResource"

    invoke-static {v5, v1}, Lcn/rongcloud/rtc/utils/ResourceTools;->getStatusDate(Ljava/lang/String;Ljava/lang/String;)Lio/rong/imlib/model/RTCStatusDate;

    move-result-object v1

    aput-object v1, p2, v3

    .line 12
    invoke-static {p1, v0, v4}, Lcn/rongcloud/rtc/utils/ResourceTools;->getURIS(Ljava/util/List;ZLjava/lang/String;)Ljava/lang/String;

    move-result-object p1

    const-string v1, "RCRTC:PublishResource"

    invoke-static {v1, p1}, Lcn/rongcloud/rtc/utils/ResourceTools;->getStatusDate(Ljava/lang/String;Ljava/lang/String;)Lio/rong/imlib/model/RTCStatusDate;

    move-result-object p1

    aput-object p1, p2, v0

    .line 13
    invoke-static {}, Lcn/rongcloud/rtc/signal/SignalManager;->getInstance()Lcn/rongcloud/rtc/signal/SignalManager;

    move-result-object p1

    const-string v0, "RCRTC:TotalContentResources"

    invoke-virtual {p1, p0, v2, v0, p2}, Lcn/rongcloud/rtc/signal/SignalManager;->syncRTCSetUserResource(Ljava/lang/String;[Lio/rong/imlib/model/RTCStatusDate;Ljava/lang/String;[Lio/rong/imlib/model/RTCStatusDate;)Lcn/rongcloud/rtc/base/AsyncResult;

    move-result-object p0

    return-object p0
.end method

.method public static sendSourceMessage(Ljava/lang/String;ZLjava/util/List;Ljava/util/List;)Lcn/rongcloud/rtc/base/AsyncResult;
    .registers 14
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Ljava/lang/String;",
            "Z",
            "Ljava/util/List<",
            "Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;",
            ">;",
            "Ljava/util/List<",
            "+",
            "Lcn/rongcloud/rtc/webrtc/IStreamResource;",
            ">;)",
            "Lcn/rongcloud/rtc/base/AsyncResult;"
        }
    .end annotation

    if-eqz p1, :cond_7

    .line 1
    invoke-static {p0, p2}, Lcn/rongcloud/rtc/proxy/ReConnectTool;->sendpublishResourceMessage(Ljava/lang/String;Ljava/util/List;)Lcn/rongcloud/rtc/base/AsyncResult;

    move-result-object p0

    return-object p0

    .line 2
    :cond_7
    invoke-interface {p2}, Ljava/util/List;->size()I

    move-result p1

    invoke-interface {p3}, Ljava/util/List;->size()I

    move-result v0

    const/4 v1, 0x1

    if-eq p1, v0, :cond_14

    const/4 p1, 0x1

    goto :goto_15

    :cond_14
    const/4 p1, 0x0

    .line 3
    :goto_15
    invoke-interface {p2}, Ljava/util/List;->iterator()Ljava/util/Iterator;

    move-result-object v0

    :cond_19
    invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z

    move-result v2

    const-string v3, "ReConnectTool"

    if-eqz v2, :cond_86

    invoke-interface {v0}, Ljava/util/Iterator;->next()Ljava/lang/Object;

    move-result-object v2

    check-cast v2, Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;

    .line 4
    invoke-interface {p3}, Ljava/util/List;->iterator()Ljava/util/Iterator;

    move-result-object v4

    :cond_2b
    invoke-interface {v4}, Ljava/util/Iterator;->hasNext()Z

    move-result v5

    if-eqz v5, :cond_19

    invoke-interface {v4}, Ljava/util/Iterator;->next()Ljava/lang/Object;

    move-result-object v5

    check-cast v5, Lcn/rongcloud/rtc/webrtc/IStreamResource;

    .line 5
    invoke-virtual {v2}, Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;->getUri()Ljava/lang/String;

    move-result-object v6

    .line 6
    invoke-interface {v5}, Lcn/rongcloud/rtc/webrtc/IStreamResource;->getUri()Ljava/lang/String;

    move-result-object v7

    .line 7
    invoke-interface {v5}, Lcn/rongcloud/rtc/webrtc/IStreamResource;->getMediaType()Lcn/rongcloud/rtc/base/RCRTCMediaType;

    move-result-object v8

    invoke-virtual {v2}, Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;->getType()Lcn/rongcloud/rtc/base/RCRTCMediaType;

    move-result-object v9

    if-ne v8, v9, :cond_2b

    invoke-interface {v5}, Lcn/rongcloud/rtc/webrtc/IStreamResource;->getTag()Ljava/lang/String;

    move-result-object v5

    invoke-virtual {v2}, Lcn/rongcloud/rtc/proxy/message/messagebeans/MediaResourceInfo;->getTag()Ljava/lang/String;

    move-result-object v8

    invoke-static {v5, v8}, Landroid/text/TextUtils;->equals(Ljava/lang/CharSequence;Ljava/lang/CharSequence;)Z

    move-result v5

    if-eqz v5, :cond_2b

    .line 8
    invoke-virtual {v6, v7}, Ljava/lang/String;->equals(Ljava/lang/Object;)Z

    move-result v5

    if-nez v5, :cond_2b

    .line 9
    new-instance p1, Ljava/lang/StringBuilder;

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

    const-string v0, "mediaResourceUri      : "

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

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

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

    move-result-object p1

    invoke-static {v3, p1}, Lcn/rongcloud/rtc/utils/FinLog;->e(Ljava/lang/String;Ljava/lang/String;)V

    .line 10
    new-instance p1, Ljava/lang/StringBuilder;

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

    const-string v0, "localMediaResourceUri : "

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

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

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

    move-result-object p1

    invoke-static {v3, p1}, Lcn/rongcloud/rtc/utils/FinLog;->e(Ljava/lang/String;Ljava/lang/String;)V

    const/4 p1, 0x1

    .line 11
    :cond_86
    new-instance v0, Ljava/lang/StringBuilder;

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

    const-string v1, "need unpublish : "

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

    invoke-virtual {v0, p1}, Ljava/lang/StringBuilder;->append(Z)Ljava/lang/StringBuilder;

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

    move-result-object v0

    invoke-static {v3, v0}, Lcn/rongcloud/rtc/utils/FinLog;->i(Ljava/lang/String;Ljava/lang/String;)V

    if-eqz p1, :cond_a1

    .line 12
    invoke-static {p0, p2, p3}, Lcn/rongcloud/rtc/proxy/ReConnectTool;->republish(Ljava/lang/String;Ljava/util/List;Ljava/util/List;)Lcn/rongcloud/rtc/base/AsyncResult;

    move-result-object p0

    return-object p0

    .line 13
    :cond_a1
    invoke-static {}, Lcn/rongcloud/rtc/base/AsyncResult;->create()Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;

    move-result-object p0

    invoke-virtual {p0}, Lcn/rongcloud/rtc/base/AsyncResult$TemporaryResult;->getResult()Lcn/rongcloud/rtc/base/AsyncResult;

    move-result-object p0

    return-object