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