正在查看: Top浏览器 v4.6.16 应用的 AudioPlayService.java JAVA 源代码文件
本页面展示 JAVA 反编译生成的源代码文件,支持语法高亮显示。 仅供安全研究与技术分析使用,严禁用于任何非法用途。请遵守相关法律法规。
正在查看: Top浏览器 v4.6.16 应用的 AudioPlayService.java JAVA 源代码文件
本页面展示 JAVA 反编译生成的源代码文件,支持语法高亮显示。 仅供安全研究与技术分析使用,严禁用于任何非法用途。请遵守相关法律法规。
package com.pocket.topbrowser.reader.service;
import android.annotation.SuppressLint;
import android.app.PendingIntent;
import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.media.AudioManager;
import android.net.Uri;
import android.os.Build;
import android.support.v4.media.session.MediaSessionCompat;
import android.support.v4.media.session.PlaybackStateCompat;
import androidx.media.AudioFocusRequestCompat;
import c.l.a.a.p2;
import com.google.android.exoplayer2.DeviceInfo;
import com.google.android.exoplayer2.MediaItem;
import com.google.android.exoplayer2.MediaMetadata;
import com.google.android.exoplayer2.PlaybackException;
import com.google.android.exoplayer2.PlaybackParameters;
import com.google.android.exoplayer2.Player;
import com.google.android.exoplayer2.SimpleExoPlayer;
import com.google.android.exoplayer2.Timeline;
import com.google.android.exoplayer2.Tracks;
import com.google.android.exoplayer2.audio.AudioAttributes;
import com.google.android.exoplayer2.metadata.Metadata;
import com.google.android.exoplayer2.text.CueGroup;
import com.google.android.exoplayer2.trackselection.TrackSelectionParameters;
import com.google.android.exoplayer2.video.VideoSize;
import com.pocket.common.db.DatabaseHelper;
import com.pocket.common.db.read.Book;
import com.pocket.common.db.read.BookChapter;
import com.pocket.common.db.read.BookSource;
import com.pocket.topbrowser.reader.model.analyzeRule.AnalyzeUrl;
import com.pocket.topbrowser.reader.receiver.MediaButtonReceiver;
import com.umeng.analytics.pro.d;
import h.b0.c.p;
import h.b0.c.q;
import h.b0.d.m;
import h.l;
import h.u;
import h.y.j.a.l;
import i.a.d1;
import i.a.l2;
import i.a.n0;
import i.a.o0;
import i.a.y0;
import i.a.z1;
import java.util.List;
import java.util.Objects;
public final class AudioPlayService extends BaseService implements AudioManager.OnAudioFocusChangeListener, Player.Listener {
public static boolean f1904c;
public static boolean f1905d;
public static int f1906e;
public MediaSessionCompat f1913l;
public BroadcastReceiver f1914m;
public int n;
public z1 o;
public z1 p;
public static final a b = new a(null);
public static String f1907f = "";
public final h.f f1908g = h.h.b(new b());
public final h.f f1909h = h.h.b(new h());
public final h.f f1910i = h.h.b(new d());
public String f1911j = "";
public String f1912k = "";
public float q = 1.0f;
public static final class a {
public a() {
}
public a(h.b0.d.g gVar) {
this();
}
public final boolean a() {
return AudioPlayService.f1905d;
}
public final int b() {
return AudioPlayService.f1906e;
}
public final boolean c() {
return AudioPlayService.f1904c;
}
}
public static final class b extends m implements h.b0.c.a<AudioManager> {
public b() {
super(0);
}
@Override
public final AudioManager invoke() {
Object systemService = AudioPlayService.this.getSystemService("audio");
Objects.requireNonNull(systemService, "null cannot be cast to non-null type android.media.AudioManager");
return (AudioManager) systemService;
}
}
@h.y.j.a.f(c = "com.pocket.topbrowser.reader.service.AudioPlayService$doDs$1", f = "AudioPlayService.kt", l = {280}, m = "invokeSuspend")
public static final class c extends l implements p<n0, h.y.d<? super u>, Object> {
public int a;
public Object b;
public c(h.y.d<? super c> dVar) {
super(2, dVar);
}
@Override
public final h.y.d<u> create(Object obj, h.y.d<?> dVar) {
c cVar = AudioPlayService.this.new c(dVar);
cVar.b = obj;
return cVar;
}
@Override
public final Object invoke(n0 n0Var, h.y.d<? super u> dVar) {
return ((c) create(n0Var, dVar)).invokeSuspend(u.a);
}
@Override
public final java.lang.Object invokeSuspend(java.lang.Object r7) {
throw new UnsupportedOperationException("Method not decompiled: com.pocket.topbrowser.reader.service.AudioPlayService.c.invokeSuspend(java.lang.Object):java.lang.Object");
}
}
public static final class d extends m implements h.b0.c.a<SimpleExoPlayer> {
public d() {
super(0);
}
@Override
public final SimpleExoPlayer invoke() {
SimpleExoPlayer build = new SimpleExoPlayer.Builder(AudioPlayService.this).build();
h.b0.d.l.e(build, "Builder(this).build()");
return build;
}
}
@h.y.j.a.f(c = "com.pocket.topbrowser.reader.service.AudioPlayService$loadContent$1$1$1", f = "AudioPlayService.kt", l = {324}, m = "invokeSuspend")
public static final class e extends l implements q<n0, String, h.y.d<? super u>, Object> {
public int a;
public Object b;
public final BookChapter f1917d;
@h.y.j.a.f(c = "com.pocket.topbrowser.reader.service.AudioPlayService$loadContent$1$1$1$1", f = "AudioPlayService.kt", l = {}, m = "invokeSuspend")
public static final class a extends l implements p<n0, h.y.d<? super u>, Object> {
public int a;
public final AudioPlayService b;
public a(AudioPlayService audioPlayService, h.y.d<? super a> dVar) {
super(2, dVar);
this.b = audioPlayService;
}
@Override
public final h.y.d<u> create(Object obj, h.y.d<?> dVar) {
return new a(this.b, dVar);
}
@Override
public final Object invoke(n0 n0Var, h.y.d<? super u> dVar) {
return ((a) create(n0Var, dVar)).invokeSuspend(u.a);
}
@Override
public final Object invokeSuspend(Object obj) {
h.y.i.c.c();
if (this.a != 0) {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
h.m.b(obj);
c.t.a.k.a.h(this.b, "未获取到资源链接");
return u.a;
}
}
public e(BookChapter bookChapter, h.y.d<? super e> dVar) {
super(3, dVar);
this.f1917d = bookChapter;
}
@Override
public final Object c(n0 n0Var, String str, h.y.d<? super u> dVar) {
e eVar = AudioPlayService.this.new e(this.f1917d, dVar);
eVar.b = str;
return eVar.invokeSuspend(u.a);
}
@Override
public final Object invokeSuspend(Object obj) {
Object c2 = h.y.i.c.c();
int i2 = this.a;
if (i2 == 0) {
h.m.b(obj);
String str = (String) this.b;
if (str.length() == 0) {
l2 c3 = d1.c();
a aVar = new a(AudioPlayService.this, null);
this.a = 1;
if (i.a.j.g(c3, aVar, this) == c2) {
return c2;
}
} else {
AudioPlayService.this.o(this.f1917d, str);
}
} else {
if (i2 != 1) {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
h.m.b(obj);
}
return u.a;
}
}
@h.y.j.a.f(c = "com.pocket.topbrowser.reader.service.AudioPlayService$loadContent$1$1$2", f = "AudioPlayService.kt", l = {}, m = "invokeSuspend")
public static final class f extends l implements q<n0, Throwable, h.y.d<? super u>, Object> {
public int a;
public Object b;
public Object f1918c;
public final BookChapter f1920e;
public f(BookChapter bookChapter, h.y.d<? super f> dVar) {
super(3, dVar);
this.f1920e = bookChapter;
}
@Override
public final Object c(n0 n0Var, Throwable th, h.y.d<? super u> dVar) {
f fVar = AudioPlayService.this.new f(this.f1920e, dVar);
fVar.b = n0Var;
fVar.f1918c = th;
return fVar.invokeSuspend(u.a);
}
@Override
public final Object invokeSuspend(Object obj) {
h.y.i.c.c();
if (this.a != 0) {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
h.m.b(obj);
n0 n0Var = (n0) this.b;
Throwable th = (Throwable) this.f1918c;
AudioPlayService audioPlayService = AudioPlayService.this;
BookChapter bookChapter = this.f1920e;
String localizedMessage = th.getLocalizedMessage();
if (localizedMessage == null) {
localizedMessage = n0Var.toString();
}
audioPlayService.o(bookChapter, localizedMessage);
return u.a;
}
}
@h.y.j.a.f(c = "com.pocket.topbrowser.reader.service.AudioPlayService$loadContent$1$1$3", f = "AudioPlayService.kt", l = {}, m = "invokeSuspend")
public static final class g extends l implements p<n0, h.y.d<? super u>, Object> {
public int a;
public final BookChapter f1921c;
public g(BookChapter bookChapter, h.y.d<? super g> dVar) {
super(2, dVar);
this.f1921c = bookChapter;
}
@Override
public final h.y.d<u> create(Object obj, h.y.d<?> dVar) {
return AudioPlayService.this.new g(this.f1921c, dVar);
}
@Override
public final Object invoke(n0 n0Var, h.y.d<? super u> dVar) {
return ((g) create(n0Var, dVar)).invokeSuspend(u.a);
}
@Override
public final Object invokeSuspend(Object obj) {
h.y.i.c.c();
if (this.a != 0) {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
h.m.b(obj);
AudioPlayService.this.y(this.f1921c.getIndex());
return u.a;
}
}
public static final class h extends m implements h.b0.c.a<AudioFocusRequestCompat> {
public h() {
super(0);
}
@Override
public final AudioFocusRequestCompat invoke() {
return c.t.c.o.s.i.a.a(AudioPlayService.this);
}
}
@h.y.j.a.f(c = "com.pocket.topbrowser.reader.service.AudioPlayService$saveProgress$1", f = "AudioPlayService.kt", l = {}, m = "invokeSuspend")
public static final class i extends l implements p<n0, h.y.d<? super u>, Object> {
public int a;
public final Book b;
public i(Book book, h.y.d<? super i> dVar) {
super(2, dVar);
this.b = book;
}
@Override
public final h.y.d<u> create(Object obj, h.y.d<?> dVar) {
return new i(this.b, dVar);
}
@Override
public final Object invoke(n0 n0Var, h.y.d<? super u> dVar) {
return ((i) create(n0Var, dVar)).invokeSuspend(u.a);
}
@Override
public final Object invokeSuspend(Object obj) {
h.y.i.c.c();
if (this.a != 0) {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
h.m.b(obj);
DatabaseHelper.Companion.getBookDao().upProgress(this.b.getBookUrl(), this.b.getDurChapterPos());
return u.a;
}
}
@h.y.j.a.f(c = "com.pocket.topbrowser.reader.service.AudioPlayService$upPlayProgress$1", f = "AudioPlayService.kt", l = {307}, m = "invokeSuspend")
public static final class j extends l implements p<n0, h.y.d<? super u>, Object> {
public int a;
public Object b;
public j(h.y.d<? super j> dVar) {
super(2, dVar);
}
@Override
public final h.y.d<u> create(Object obj, h.y.d<?> dVar) {
j jVar = AudioPlayService.this.new j(dVar);
jVar.b = obj;
return jVar;
}
@Override
public final Object invoke(n0 n0Var, h.y.d<? super u> dVar) {
return ((j) create(n0Var, dVar)).invokeSuspend(u.a);
}
@Override
public final Object invokeSuspend(Object obj) {
n0 n0Var;
Object c2 = h.y.i.c.c();
int i2 = this.a;
if (i2 == 0) {
h.m.b(obj);
n0Var = (n0) this.b;
} else {
if (i2 != 1) {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
n0Var = (n0) this.b;
h.m.b(obj);
}
while (o0.g(n0Var)) {
Book a = c.t.c.o.u.a.a.a();
if (a != null) {
AudioPlayService audioPlayService = AudioPlayService.this;
a.setDurChapterPos((int) audioPlayService.r().getCurrentPosition());
c.o.a.a.a("audioProgress").b(h.y.j.a.b.b(a.getDurChapterPos()));
audioPlayService.B(a);
}
this.b = n0Var;
this.a = 1;
if (y0.a(1000L, this) == c2) {
return c2;
}
}
return u.a;
}
}
public final void A() {
try {
f1905d = false;
if (!r().isPlaying()) {
r().play();
}
E();
D(3);
c.t.c.o.u.a.a.n(1);
c.o.a.a.a("audioState").b(1);
} catch (Exception e2) {
c.h.b.j.e.c(new Object[]{e2});
stopSelf();
}
}
public final void B(Book book) {
BaseService.b(this, null, null, new i(book, null), 3, null);
}
public final void C(int i2) {
f1906e = i2;
p();
}
public final void D(int i2) {
MediaSessionCompat mediaSessionCompat = this.f1913l;
if (mediaSessionCompat == null) {
return;
}
mediaSessionCompat.setPlaybackState(new PlaybackStateCompat.Builder().setActions(3670015L).setState(i2, this.n, 1.0f).build());
}
public final void E() {
z1 d2;
z1 z1Var = this.p;
if (z1Var != null) {
z1.a.a(z1Var, null, 1, null);
}
d2 = i.a.l.d(this, null, null, new j(null), 3, null);
this.p = d2;
}
public final void F(float f2) {
try {
l.a aVar = h.l.a;
if (Build.VERSION.SDK_INT >= 23) {
this.q += f2;
r().setPlaybackSpeed(this.q);
c.o.a.a.a("audioSpeed").b(Float.valueOf(this.q));
}
h.l.b(u.a);
} catch (Throwable th) {
l.a aVar2 = h.l.a;
h.l.b(h.m.a(th));
}
}
public final boolean l(int i2) {
synchronized (this) {
c.t.c.o.u.a aVar = c.t.c.o.u.a.a;
if (aVar.d().contains(Integer.valueOf(i2))) {
return false;
}
aVar.d().add(Integer.valueOf(i2));
return true;
}
}
public final void m() {
int i2 = f1906e;
if (i2 == 60) {
f1906e = 0;
} else {
int i3 = i2 + 10;
f1906e = i3;
if (i3 > 60) {
f1906e = 60;
}
}
p();
}
public final void n(int i2) {
this.n = i2;
r().seekTo(i2);
}
public final void o(BookChapter bookChapter, String str) {
int index = bookChapter.getIndex();
Book a2 = c.t.c.o.u.a.a.a();
boolean z = false;
if (a2 != null && index == a2.getDurChapterIndex()) {
z = true;
}
if (z) {
this.f1912k = bookChapter.getTitle();
f1907f = str;
x();
}
}
public void onAudioAttributesChanged(AudioAttributes audioAttributes) {
p2.a(this, audioAttributes);
}
@Override
public void onAudioFocusChange(int i2) {
if (i2 == -2) {
if (f1905d) {
return;
}
w(false);
} else if (i2 == 1 && !f1905d) {
A();
}
}
public void onAudioSessionIdChanged(int i2) {
p2.b(this, i2);
}
public void onAvailableCommandsChanged(Player.Commands commands) {
p2.c(this, commands);
}
@Override
public void onCreate() {
super.onCreate();
f1904c = true;
r().addListener(this);
u();
t();
D(3);
}
public void onCues(CueGroup cueGroup) {
p2.d(this, cueGroup);
}
public void onCues(List list) {
p2.e(this, list);
}
@Override
public void onDestroy() {
super.onDestroy();
f1904c = false;
r().release();
MediaSessionCompat mediaSessionCompat = this.f1913l;
if (mediaSessionCompat != null) {
mediaSessionCompat.release();
}
unregisterReceiver(this.f1914m);
D(1);
c.t.c.o.u.a.a.n(0);
c.o.a.a.a("audioState").b(0);
}
public void onDeviceInfoChanged(DeviceInfo deviceInfo) {
p2.f(this, deviceInfo);
}
public void onDeviceVolumeChanged(int i2, boolean z) {
p2.g(this, i2, z);
}
public void onEvents(Player player, Player.Events events) {
p2.h(this, player, events);
}
public void onIsLoadingChanged(boolean z) {
p2.i(this, z);
}
public void onIsPlayingChanged(boolean z) {
p2.j(this, z);
}
public void onLoadingChanged(boolean z) {
p2.k(this, z);
}
public void onMaxSeekToPreviousPositionChanged(long j2) {
p2.l(this, j2);
}
public void onMediaItemTransition(MediaItem mediaItem, int i2) {
p2.m(this, mediaItem, i2);
}
public void onMediaMetadataChanged(MediaMetadata mediaMetadata) {
p2.n(this, mediaMetadata);
}
public void onMetadata(Metadata metadata) {
p2.o(this, metadata);
}
public void onPlayWhenReadyChanged(boolean z, int i2) {
p2.p(this, z, i2);
}
public void onPlaybackParametersChanged(PlaybackParameters playbackParameters) {
p2.q(this, playbackParameters);
}
public void onPlaybackStateChanged(int i2) {
p2.r(this, i2);
if (i2 != 3) {
if (i2 != 4) {
return;
}
z1 z1Var = this.p;
if (z1Var != null) {
z1.a.a(z1Var, null, 1, null);
}
c.t.c.o.u.a.a.f(this);
return;
}
if (r().getCurrentPosition() != this.n) {
r().seekTo(this.n);
}
if (r().getPlayWhenReady()) {
c.t.c.o.u.a.a.n(1);
c.o.a.a.a("audioState").b(1);
} else {
c.t.c.o.u.a.a.n(3);
c.o.a.a.a("audioState").b(3);
}
c.o.a.a.a("audioSize").b(Long.valueOf(r().getDuration()));
E();
c.t.c.o.u.a.a.k(r().getDuration());
}
public void onPlaybackSuppressionReasonChanged(int i2) {
p2.s(this, i2);
}
public void onPlayerError(PlaybackException playbackException) {
h.b0.d.l.f(playbackException, com.umeng.analytics.pro.d.O);
p2.t(this, playbackException);
c.t.c.o.u.a.a.n(0);
c.o.a.a.a("audioState").b(0);
c.t.a.k.a.h(this, "音频播放出错\n" + playbackException.getErrorCodeName() + ' ' + playbackException.errorCode);
c.h.b.j.e.c(new Object[]{playbackException});
}
public void onPlayerErrorChanged(PlaybackException playbackException) {
p2.u(this, playbackException);
}
public void onPlayerStateChanged(boolean z, int i2) {
p2.v(this, z, i2);
}
public void onPlaylistMetadataChanged(MediaMetadata mediaMetadata) {
p2.w(this, mediaMetadata);
}
public void onPositionDiscontinuity(int i2) {
p2.x(this, i2);
}
public void onPositionDiscontinuity(Player.PositionInfo positionInfo, Player.PositionInfo positionInfo2, int i2) {
p2.y(this, positionInfo, positionInfo2, i2);
}
public void onRenderedFirstFrame() {
p2.z(this);
}
public void onRepeatModeChanged(int i2) {
p2.A(this, i2);
}
public void onSeekBackIncrementChanged(long j2) {
p2.B(this, j2);
}
public void onSeekForwardIncrementChanged(long j2) {
p2.C(this, j2);
}
public void onSeekProcessed() {
p2.D(this);
}
public void onShuffleModeEnabledChanged(boolean z) {
p2.E(this, z);
}
public void onSkipSilenceEnabledChanged(boolean z) {
p2.F(this, z);
}
@Override
public int onStartCommand(Intent intent, int i2, int i3) {
String action;
String title;
if (intent != null && (action = intent.getAction()) != null) {
switch (action.hashCode()) {
case -1334092068:
if (action.equals("adjustProgress")) {
n(intent.getIntExtra("position", this.n));
break;
}
stopSelf();
break;
case -1246307548:
if (action.equals("addTimer")) {
m();
break;
}
stopSelf();
break;
case -934426579:
if (action.equals("resume")) {
A();
break;
}
stopSelf();
break;
case 3377907:
if (action.equals("next")) {
c.t.c.o.u.a.a.f(this);
break;
}
stopSelf();
break;
case 3443508:
if (action.equals("play")) {
c.t.c.o.u.a aVar = c.t.c.o.u.a.a;
Book a2 = aVar.a();
if (a2 != null) {
this.f1911j = a2.getName();
BookChapter c2 = aVar.c();
String str = "";
if (c2 != null && (title = c2.getTitle()) != null) {
str = title;
}
this.f1912k = str;
this.n = a2.getDurChapterPos();
v();
break;
}
}
stopSelf();
break;
case 3449395:
if (action.equals("prev")) {
c.t.c.o.u.a.a.i(this);
break;
}
stopSelf();
break;
case 106440182:
if (action.equals("pause")) {
w(true);
break;
}
stopSelf();
break;
case 1136409080:
if (action.equals("adjustSpeed")) {
F(intent.getFloatExtra("adjust", 1.0f));
break;
}
stopSelf();
break;
case 1405077507:
if (action.equals("setTimer")) {
C(intent.getIntExtra("minute", 0));
break;
}
stopSelf();
break;
default:
stopSelf();
break;
}
}
return super.onStartCommand(intent, i2, i3);
}
public void onSurfaceSizeChanged(int i2, int i3) {
p2.G(this, i2, i3);
}
public void onTimelineChanged(Timeline timeline, int i2) {
p2.H(this, timeline, i2);
}
public void onTrackSelectionParametersChanged(TrackSelectionParameters trackSelectionParameters) {
p2.I(this, trackSelectionParameters);
}
public void onTracksChanged(Tracks tracks) {
p2.J(this, tracks);
}
public void onVideoSizeChanged(VideoSize videoSize) {
p2.K(this, videoSize);
}
public void onVolumeChanged(float f2) {
p2.L(this, f2);
}
public final void p() {
z1 d2;
c.o.a.a.a("ttsDs").b(Integer.valueOf(f1906e));
z1 z1Var = this.o;
if (z1Var != null) {
z1.a.a(z1Var, null, 1, null);
}
d2 = i.a.l.d(this, null, null, new c(null), 3, null);
this.o = d2;
}
public final AudioManager q() {
return (AudioManager) this.f1908g.getValue();
}
public final SimpleExoPlayer r() {
return (SimpleExoPlayer) this.f1910i.getValue();
}
public final AudioFocusRequestCompat s() {
return (AudioFocusRequestCompat) this.f1909h.getValue();
}
public final void t() {
this.f1914m = new BroadcastReceiver() {
@Override
public void onReceive(Context context, Intent intent) {
h.b0.d.l.f(context, d.R);
h.b0.d.l.f(intent, "intent");
if (h.b0.d.l.b("android.media.AUDIO_BECOMING_NOISY", intent.getAction())) {
AudioPlayService.this.w(true);
}
}
};
registerReceiver(this.f1914m, new IntentFilter("android.media.AUDIO_BECOMING_NOISY"));
}
@SuppressLint({"UnspecifiedImmutableFlag"})
public final void u() {
MediaSessionCompat mediaSessionCompat = new MediaSessionCompat(this, "readAloud");
this.f1913l = mediaSessionCompat;
if (mediaSessionCompat != null) {
mediaSessionCompat.setCallback(new MediaSessionCompat.Callback() {
public boolean onMediaButtonEvent(Intent intent) {
h.b0.d.l.f(intent, "mediaButtonEvent");
return MediaButtonReceiver.a.a(AudioPlayService.this, intent);
}
});
}
MediaSessionCompat mediaSessionCompat2 = this.f1913l;
if (mediaSessionCompat2 != null) {
Intent intent = new Intent(this, (Class<?>) MediaButtonReceiver.class);
intent.setAction("android.intent.action.MEDIA_BUTTON");
u uVar = u.a;
mediaSessionCompat2.setMediaButtonReceiver(PendingIntent.getBroadcast(this, 0, intent, 268435456));
}
MediaSessionCompat mediaSessionCompat3 = this.f1913l;
if (mediaSessionCompat3 == null) {
return;
}
mediaSessionCompat3.setActive(true);
}
public final u v() {
c.t.c.o.u.a aVar = c.t.c.o.u.a.a;
BookChapter c2 = aVar.c();
if (c2 == null) {
return null;
}
if (l(c2.getIndex())) {
Book a2 = aVar.a();
BookSource b2 = aVar.b();
if (a2 == null || b2 == null) {
y(c2.getIndex());
c.t.a.k.a.h(this, "book or source is null");
} else {
c.t.c.o.s.l.a.o(c.t.c.o.s.l.a.m(c.t.c.o.s.l.a.q(c.t.c.o.u.j.c.e(c.t.c.o.u.j.c.a, this, b2, a2, c2, null, null, 48, null), null, new e(c2, null), 1, null), null, new f(c2, null), 1, null), null, new g(c2, null), 1, null);
}
}
return u.a;
}
public final void w(boolean z) {
try {
f1905d = z;
z1 z1Var = this.p;
if (z1Var != null) {
z1.a.a(z1Var, null, 1, null);
}
this.n = (int) r().getCurrentPosition();
if (r().isPlaying()) {
r().pause();
}
D(2);
c.t.c.o.u.a.a.n(3);
c.o.a.a.a("audioState").b(3);
} catch (Exception e2) {
c.h.b.j.e.c(new Object[]{e2});
}
}
public final void x() {
Object b2;
if (z()) {
try {
l.a aVar = h.l.a;
c.t.c.o.u.a aVar2 = c.t.c.o.u.a.a;
aVar2.n(0);
c.o.a.a.a("audioState").b(0);
z1 z1Var = this.p;
if (z1Var != null) {
z1.a.a(z1Var, null, 1, null);
}
AnalyzeUrl analyzeUrl = new AnalyzeUrl(f1907f, null, null, null, null, null, aVar2.b(), aVar2.a(), aVar2.c(), aVar2.e(true), 62, null);
Uri parse = Uri.parse(analyzeUrl.getUrl());
c.t.c.o.s.m.a aVar3 = c.t.c.o.s.m.a.a;
h.b0.d.l.e(parse, "uri");
r().setMediaSource(aVar3.c(parse, analyzeUrl.getHeaderMap()));
r().setPlayWhenReady(true);
r().prepare();
b2 = h.l.b(u.a);
} catch (Throwable th) {
l.a aVar4 = h.l.a;
b2 = h.l.b(h.m.a(th));
}
Throwable d2 = h.l.d(b2);
if (d2 != null) {
c.h.b.j.e.c(new Object[]{d2});
c.t.a.k.a.h(this, f1907f + ' ' + ((Object) d2.getLocalizedMessage()));
stopSelf();
}
}
}
public final void y(int i2) {
synchronized (this) {
c.t.c.o.u.a.a.d().remove(Integer.valueOf(i2));
}
}
public final boolean z() {
return c.t.c.o.s.i.a.e(q(), s());
}
}