package com.strmr.ps.data.local.dao; import android.database.Cursor; import android.os.CancellationSignal; import androidx.room.RoomDatabase; import com.strmr.ps.data.local.dao.TraktAccountDao; import com.strmr.ps.data.local.entity.TraktAccount; import defpackage.e6a; import defpackage.j43; import defpackage.mk1; import defpackage.n58; import defpackage.oq8; import defpackage.p58; import defpackage.pe9; import defpackage.q2; import defpackage.rq6; import defpackage.sp1; import defpackage.vo6; import defpackage.vw2; import defpackage.xm2; import defpackage.yn1; import java.util.ArrayList; import java.util.Collections; import java.util.List; import java.util.concurrent.Callable; import kotlin.coroutines.Continuation; /* JADX INFO: loaded from: classes3.dex */ public final class TraktAccountDao_Impl implements TraktAccountDao { private final RoomDatabase __db; private final xm2 __insertionAdapterOfTraktAccount; private final oq8 __preparedStmtOfCheckpointPhaseTimestamps; private final oq8 __preparedStmtOfClearActiveStatus; private final oq8 __preparedStmtOfDeleteAccount; private final oq8 __preparedStmtOfDeleteAllAccounts; private final oq8 __preparedStmtOfSetActive; private final oq8 __preparedStmtOfUpdateAvatar; private final oq8 __preparedStmtOfUpdateStats; private final oq8 __preparedStmtOfUpdateSyncTimestamps; private final oq8 __preparedStmtOfUpdateTokens; public TraktAccountDao_Impl(@vo6 RoomDatabase roomDatabase) { this.__db = roomDatabase; this.__insertionAdapterOfTraktAccount = new xm2(roomDatabase) { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.1 @Override // defpackage.oq8 @vo6 public String createQuery() { return "INSERT OR REPLACE INTO `trakt_accounts` (`userSlug`,`userName`,`accessToken`,`refreshToken`,`tokenType`,`scope`,`expiresAt`,`createdAt`,`isActive`,`avatarResourceId`,`statsMoviesWatched`,`statsShowsWatched`,`statsMinutesWatched`,`lastSyncAt`,`lastHistorySync`,`lastCollectionSync`,`lastWatchlistSync`,`lastDroppedSync`,`lastActivitiesAt`) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; } @Override // defpackage.xm2 public void bind(@vo6 pe9 pe9Var, @vo6 TraktAccount traktAccount) { pe9Var.bindString(1, traktAccount.getUserSlug()); if (traktAccount.getUserName() == null) { pe9Var.bindNull(2); } else { pe9Var.bindString(2, traktAccount.getUserName()); } pe9Var.bindString(3, traktAccount.getAccessToken()); if (traktAccount.getRefreshToken() == null) { pe9Var.bindNull(4); } else { pe9Var.bindString(4, traktAccount.getRefreshToken()); } if (traktAccount.getTokenType() == null) { pe9Var.bindNull(5); } else { pe9Var.bindString(5, traktAccount.getTokenType()); } if (traktAccount.getScope() == null) { pe9Var.bindNull(6); } else { pe9Var.bindString(6, traktAccount.getScope()); } pe9Var.bindLong(7, traktAccount.getExpiresAt()); pe9Var.bindLong(8, traktAccount.getCreatedAt()); pe9Var.bindLong(9, traktAccount.isActive() ? 1L : 0L); if (traktAccount.getAvatarResourceId() == null) { pe9Var.bindNull(10); } else { pe9Var.bindLong(10, traktAccount.getAvatarResourceId().intValue()); } if (traktAccount.getStatsMoviesWatched() == null) { pe9Var.bindNull(11); } else { pe9Var.bindLong(11, traktAccount.getStatsMoviesWatched().intValue()); } if (traktAccount.getStatsShowsWatched() == null) { pe9Var.bindNull(12); } else { pe9Var.bindLong(12, traktAccount.getStatsShowsWatched().intValue()); } if (traktAccount.getStatsMinutesWatched() == null) { pe9Var.bindNull(13); } else { pe9Var.bindLong(13, traktAccount.getStatsMinutesWatched().longValue()); } if (traktAccount.getLastSyncAt() == null) { pe9Var.bindNull(14); } else { pe9Var.bindLong(14, traktAccount.getLastSyncAt().longValue()); } if (traktAccount.getLastHistorySync() == null) { pe9Var.bindNull(15); } else { pe9Var.bindLong(15, traktAccount.getLastHistorySync().longValue()); } if (traktAccount.getLastCollectionSync() == null) { pe9Var.bindNull(16); } else { pe9Var.bindLong(16, traktAccount.getLastCollectionSync().longValue()); } if (traktAccount.getLastWatchlistSync() == null) { pe9Var.bindNull(17); } else { pe9Var.bindLong(17, traktAccount.getLastWatchlistSync().longValue()); } if (traktAccount.getLastDroppedSync() == null) { pe9Var.bindNull(18); } else { pe9Var.bindLong(18, traktAccount.getLastDroppedSync().longValue()); } if (traktAccount.getLastActivitiesAt() == null) { pe9Var.bindNull(19); } else { pe9Var.bindLong(19, traktAccount.getLastActivitiesAt().longValue()); } } }; this.__preparedStmtOfClearActiveStatus = new oq8(roomDatabase) { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.2 @Override // defpackage.oq8 @vo6 public String createQuery() { return "UPDATE trakt_accounts SET isActive = 0"; } }; this.__preparedStmtOfSetActive = new oq8(roomDatabase) { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.3 @Override // defpackage.oq8 @vo6 public String createQuery() { return "UPDATE trakt_accounts SET isActive = 1 WHERE userSlug = ?"; } }; this.__preparedStmtOfUpdateTokens = new oq8(roomDatabase) { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.4 @Override // defpackage.oq8 @vo6 public String createQuery() { return "\n UPDATE trakt_accounts\n SET accessToken = ?,\n refreshToken = ?,\n expiresAt = ?,\n tokenType = ?,\n scope = ?\n WHERE userSlug = ?\n "; } }; this.__preparedStmtOfUpdateStats = new oq8(roomDatabase) { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.5 @Override // defpackage.oq8 @vo6 public String createQuery() { return "\n UPDATE trakt_accounts\n SET statsMoviesWatched = ?,\n statsShowsWatched = ?,\n statsMinutesWatched = ?,\n userName = ?\n WHERE userSlug = ?\n "; } }; this.__preparedStmtOfUpdateAvatar = new oq8(roomDatabase) { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.6 @Override // defpackage.oq8 @vo6 public String createQuery() { return "UPDATE trakt_accounts SET avatarResourceId = ? WHERE userSlug = ?"; } }; this.__preparedStmtOfUpdateSyncTimestamps = new oq8(roomDatabase) { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.7 @Override // defpackage.oq8 @vo6 public String createQuery() { return "\n UPDATE trakt_accounts\n SET lastSyncAt = ?,\n lastHistorySync = ?,\n lastCollectionSync = ?,\n lastWatchlistSync = ?,\n lastActivitiesAt = ?\n WHERE userSlug = ?\n "; } }; this.__preparedStmtOfCheckpointPhaseTimestamps = new oq8(roomDatabase) { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.8 @Override // defpackage.oq8 @vo6 public String createQuery() { return "\n UPDATE trakt_accounts\n SET lastHistorySync = COALESCE(?, lastHistorySync),\n lastCollectionSync = COALESCE(?, lastCollectionSync),\n lastWatchlistSync = COALESCE(?, lastWatchlistSync),\n lastDroppedSync = COALESCE(?, lastDroppedSync)\n WHERE userSlug = ?\n "; } }; this.__preparedStmtOfDeleteAccount = new oq8(roomDatabase) { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.9 @Override // defpackage.oq8 @vo6 public String createQuery() { return "DELETE FROM trakt_accounts WHERE userSlug = ?"; } }; this.__preparedStmtOfDeleteAllAccounts = new oq8(roomDatabase) { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.10 @Override // defpackage.oq8 @vo6 public String createQuery() { return "DELETE FROM trakt_accounts"; } }; } @vo6 public static List> getRequiredConverters() { return Collections.EMPTY_LIST; } /* JADX INFO: Access modifiers changed from: private */ public /* synthetic */ Object lambda$setActiveAccount$0(String str, Continuation continuation) { return TraktAccountDao.DefaultImpls.setActiveAccount(this, str, continuation); } @Override // com.strmr.ps.data.local.dao.TraktAccountDao public Object checkpointPhaseTimestamps(final String str, final Long l, final Long l2, final Long l3, final Long l4, Continuation continuation) { return mk1.b(this.__db, new Callable() { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.18 /* JADX WARN: Can't rename method to resolve collision */ @Override // java.util.concurrent.Callable @vo6 public e6a call() throws Exception { pe9 pe9VarAcquire = TraktAccountDao_Impl.this.__preparedStmtOfCheckpointPhaseTimestamps.acquire(); Long l5 = l; if (l5 == null) { pe9VarAcquire.bindNull(1); } else { pe9VarAcquire.bindLong(1, l5.longValue()); } Long l6 = l2; if (l6 == null) { pe9VarAcquire.bindNull(2); } else { pe9VarAcquire.bindLong(2, l6.longValue()); } Long l7 = l3; if (l7 == null) { pe9VarAcquire.bindNull(3); } else { pe9VarAcquire.bindLong(3, l7.longValue()); } Long l8 = l4; if (l8 == null) { pe9VarAcquire.bindNull(4); } else { pe9VarAcquire.bindLong(4, l8.longValue()); } pe9VarAcquire.bindString(5, str); try { TraktAccountDao_Impl.this.__db.beginTransaction(); try { pe9VarAcquire.executeUpdateDelete(); TraktAccountDao_Impl.this.__db.setTransactionSuccessful(); return e6a.a; } finally { TraktAccountDao_Impl.this.__db.endTransaction(); } } finally { TraktAccountDao_Impl.this.__preparedStmtOfCheckpointPhaseTimestamps.release(pe9VarAcquire); } } }, continuation); } @Override // com.strmr.ps.data.local.dao.TraktAccountDao public Object clearActiveStatus(Continuation continuation) { return mk1.b(this.__db, new Callable() { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.12 /* JADX WARN: Can't rename method to resolve collision */ @Override // java.util.concurrent.Callable @vo6 public e6a call() throws Exception { pe9 pe9VarAcquire = TraktAccountDao_Impl.this.__preparedStmtOfClearActiveStatus.acquire(); try { TraktAccountDao_Impl.this.__db.beginTransaction(); try { pe9VarAcquire.executeUpdateDelete(); TraktAccountDao_Impl.this.__db.setTransactionSuccessful(); return e6a.a; } finally { TraktAccountDao_Impl.this.__db.endTransaction(); } } finally { TraktAccountDao_Impl.this.__preparedStmtOfClearActiveStatus.release(pe9VarAcquire); } } }, continuation); } @Override // com.strmr.ps.data.local.dao.TraktAccountDao public Object deleteAccount(final String str, Continuation continuation) { return mk1.b(this.__db, new Callable() { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.19 /* JADX WARN: Can't rename method to resolve collision */ @Override // java.util.concurrent.Callable @vo6 public e6a call() throws Exception { pe9 pe9VarAcquire = TraktAccountDao_Impl.this.__preparedStmtOfDeleteAccount.acquire(); pe9VarAcquire.bindString(1, str); try { TraktAccountDao_Impl.this.__db.beginTransaction(); try { pe9VarAcquire.executeUpdateDelete(); TraktAccountDao_Impl.this.__db.setTransactionSuccessful(); return e6a.a; } finally { TraktAccountDao_Impl.this.__db.endTransaction(); } } finally { TraktAccountDao_Impl.this.__preparedStmtOfDeleteAccount.release(pe9VarAcquire); } } }, continuation); } @Override // com.strmr.ps.data.local.dao.TraktAccountDao public Object deleteAllAccounts(Continuation continuation) { return mk1.b(this.__db, new Callable() { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.20 /* JADX WARN: Can't rename method to resolve collision */ @Override // java.util.concurrent.Callable @vo6 public e6a call() throws Exception { pe9 pe9VarAcquire = TraktAccountDao_Impl.this.__preparedStmtOfDeleteAllAccounts.acquire(); try { TraktAccountDao_Impl.this.__db.beginTransaction(); try { pe9VarAcquire.executeUpdateDelete(); TraktAccountDao_Impl.this.__db.setTransactionSuccessful(); return e6a.a; } finally { TraktAccountDao_Impl.this.__db.endTransaction(); } } finally { TraktAccountDao_Impl.this.__preparedStmtOfDeleteAllAccounts.release(pe9VarAcquire); } } }, continuation); } @Override // com.strmr.ps.data.local.dao.TraktAccountDao public Object getAccountBySlug(String str, Continuation continuation) { final p58 p58VarD = p58.d(1, "SELECT * FROM trakt_accounts WHERE userSlug = ? LIMIT 1"); return mk1.c(this.__db, false, vw2.f(p58VarD, 1, str), new Callable() { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.25 /* JADX WARN: Can't rename method to resolve collision */ @Override // java.util.concurrent.Callable @rq6 public TraktAccount call() throws Exception { int iB; int iB2; int iB3; int iB4; int iB5; int iB6; int iB7; int iB8; int iB9; int iB10; int iB11; int iB12; int iB13; int iB14; AnonymousClass25 anonymousClass25 = this; Cursor cursorB = sp1.b(TraktAccountDao_Impl.this.__db, p58VarD, false); try { iB = yn1.b(cursorB, "userSlug"); iB2 = yn1.b(cursorB, "userName"); iB3 = yn1.b(cursorB, "accessToken"); iB4 = yn1.b(cursorB, "refreshToken"); iB5 = yn1.b(cursorB, "tokenType"); iB6 = yn1.b(cursorB, "scope"); iB7 = yn1.b(cursorB, "expiresAt"); iB8 = yn1.b(cursorB, "createdAt"); iB9 = yn1.b(cursorB, "isActive"); iB10 = yn1.b(cursorB, "avatarResourceId"); iB11 = yn1.b(cursorB, "statsMoviesWatched"); iB12 = yn1.b(cursorB, "statsShowsWatched"); iB13 = yn1.b(cursorB, "statsMinutesWatched"); iB14 = yn1.b(cursorB, "lastSyncAt"); } catch (Throwable th) { th = th; } try { int iB15 = yn1.b(cursorB, "lastHistorySync"); int iB16 = yn1.b(cursorB, "lastCollectionSync"); int iB17 = yn1.b(cursorB, "lastWatchlistSync"); int iB18 = yn1.b(cursorB, "lastDroppedSync"); int iB19 = yn1.b(cursorB, "lastActivitiesAt"); TraktAccount traktAccount = null; if (cursorB.moveToFirst()) { traktAccount = new TraktAccount(cursorB.getString(iB), cursorB.isNull(iB2) ? null : cursorB.getString(iB2), cursorB.getString(iB3), cursorB.isNull(iB4) ? null : cursorB.getString(iB4), cursorB.isNull(iB5) ? null : cursorB.getString(iB5), cursorB.isNull(iB6) ? null : cursorB.getString(iB6), cursorB.getLong(iB7), cursorB.getLong(iB8), cursorB.getInt(iB9) != 0, cursorB.isNull(iB10) ? null : Integer.valueOf(cursorB.getInt(iB10)), cursorB.isNull(iB11) ? null : Integer.valueOf(cursorB.getInt(iB11)), cursorB.isNull(iB12) ? null : Integer.valueOf(cursorB.getInt(iB12)), cursorB.isNull(iB13) ? null : Long.valueOf(cursorB.getLong(iB13)), cursorB.isNull(iB14) ? null : Long.valueOf(cursorB.getLong(iB14)), cursorB.isNull(iB15) ? null : Long.valueOf(cursorB.getLong(iB15)), cursorB.isNull(iB16) ? null : Long.valueOf(cursorB.getLong(iB16)), cursorB.isNull(iB17) ? null : Long.valueOf(cursorB.getLong(iB17)), cursorB.isNull(iB18) ? null : Long.valueOf(cursorB.getLong(iB18)), cursorB.isNull(iB19) ? null : Long.valueOf(cursorB.getLong(iB19))); } cursorB.close(); p58VarD.release(); return traktAccount; } catch (Throwable th2) { th = th2; anonymousClass25 = this; cursorB.close(); p58VarD.release(); throw th; } } }, continuation); } @Override // com.strmr.ps.data.local.dao.TraktAccountDao public Object getAccountCount(Continuation continuation) { final p58 p58VarD = p58.d(0, "SELECT COUNT(*) FROM trakt_accounts"); return mk1.c(this.__db, false, new CancellationSignal(), new Callable() { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.26 /* JADX WARN: Can't rename method to resolve collision */ @Override // java.util.concurrent.Callable @vo6 public Integer call() throws Exception { Cursor cursorB = sp1.b(TraktAccountDao_Impl.this.__db, p58VarD, false); try { int iValueOf = cursorB.moveToFirst() ? Integer.valueOf(cursorB.getInt(0)) : 0; cursorB.close(); p58VarD.release(); return iValueOf; } catch (Throwable th) { cursorB.close(); p58VarD.release(); throw th; } } }, continuation); } @Override // com.strmr.ps.data.local.dao.TraktAccountDao public Object getActiveAccount(Continuation continuation) { final p58 p58VarD = p58.d(0, "SELECT * FROM trakt_accounts WHERE isActive = 1 LIMIT 1"); return mk1.c(this.__db, false, new CancellationSignal(), new Callable() { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.23 /* JADX WARN: Can't rename method to resolve collision */ @Override // java.util.concurrent.Callable @rq6 public TraktAccount call() throws Exception { int iB; int iB2; int iB3; int iB4; int iB5; int iB6; int iB7; int iB8; int iB9; int iB10; int iB11; int iB12; int iB13; int iB14; AnonymousClass23 anonymousClass23 = this; Cursor cursorB = sp1.b(TraktAccountDao_Impl.this.__db, p58VarD, false); try { iB = yn1.b(cursorB, "userSlug"); iB2 = yn1.b(cursorB, "userName"); iB3 = yn1.b(cursorB, "accessToken"); iB4 = yn1.b(cursorB, "refreshToken"); iB5 = yn1.b(cursorB, "tokenType"); iB6 = yn1.b(cursorB, "scope"); iB7 = yn1.b(cursorB, "expiresAt"); iB8 = yn1.b(cursorB, "createdAt"); iB9 = yn1.b(cursorB, "isActive"); iB10 = yn1.b(cursorB, "avatarResourceId"); iB11 = yn1.b(cursorB, "statsMoviesWatched"); iB12 = yn1.b(cursorB, "statsShowsWatched"); iB13 = yn1.b(cursorB, "statsMinutesWatched"); iB14 = yn1.b(cursorB, "lastSyncAt"); } catch (Throwable th) { th = th; } try { int iB15 = yn1.b(cursorB, "lastHistorySync"); int iB16 = yn1.b(cursorB, "lastCollectionSync"); int iB17 = yn1.b(cursorB, "lastWatchlistSync"); int iB18 = yn1.b(cursorB, "lastDroppedSync"); int iB19 = yn1.b(cursorB, "lastActivitiesAt"); TraktAccount traktAccount = null; if (cursorB.moveToFirst()) { traktAccount = new TraktAccount(cursorB.getString(iB), cursorB.isNull(iB2) ? null : cursorB.getString(iB2), cursorB.getString(iB3), cursorB.isNull(iB4) ? null : cursorB.getString(iB4), cursorB.isNull(iB5) ? null : cursorB.getString(iB5), cursorB.isNull(iB6) ? null : cursorB.getString(iB6), cursorB.getLong(iB7), cursorB.getLong(iB8), cursorB.getInt(iB9) != 0, cursorB.isNull(iB10) ? null : Integer.valueOf(cursorB.getInt(iB10)), cursorB.isNull(iB11) ? null : Integer.valueOf(cursorB.getInt(iB11)), cursorB.isNull(iB12) ? null : Integer.valueOf(cursorB.getInt(iB12)), cursorB.isNull(iB13) ? null : Long.valueOf(cursorB.getLong(iB13)), cursorB.isNull(iB14) ? null : Long.valueOf(cursorB.getLong(iB14)), cursorB.isNull(iB15) ? null : Long.valueOf(cursorB.getLong(iB15)), cursorB.isNull(iB16) ? null : Long.valueOf(cursorB.getLong(iB16)), cursorB.isNull(iB17) ? null : Long.valueOf(cursorB.getLong(iB17)), cursorB.isNull(iB18) ? null : Long.valueOf(cursorB.getLong(iB18)), cursorB.isNull(iB19) ? null : Long.valueOf(cursorB.getLong(iB19))); } cursorB.close(); p58VarD.release(); return traktAccount; } catch (Throwable th2) { th = th2; anonymousClass23 = this; cursorB.close(); p58VarD.release(); throw th; } } }, continuation); } @Override // com.strmr.ps.data.local.dao.TraktAccountDao public j43 getActiveAccountFlow() { final p58 p58VarD = p58.d(0, "SELECT * FROM trakt_accounts WHERE isActive = 1 LIMIT 1"); return mk1.a(this.__db, false, new String[]{"trakt_accounts"}, new Callable() { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.24 public void finalize() { p58VarD.release(); } /* JADX WARN: Can't rename method to resolve collision */ @Override // java.util.concurrent.Callable @rq6 public TraktAccount call() throws Exception { Cursor cursorB = sp1.b(TraktAccountDao_Impl.this.__db, p58VarD, false); try { int iB = yn1.b(cursorB, "userSlug"); int iB2 = yn1.b(cursorB, "userName"); int iB3 = yn1.b(cursorB, "accessToken"); int iB4 = yn1.b(cursorB, "refreshToken"); int iB5 = yn1.b(cursorB, "tokenType"); int iB6 = yn1.b(cursorB, "scope"); int iB7 = yn1.b(cursorB, "expiresAt"); int iB8 = yn1.b(cursorB, "createdAt"); int iB9 = yn1.b(cursorB, "isActive"); int iB10 = yn1.b(cursorB, "avatarResourceId"); int iB11 = yn1.b(cursorB, "statsMoviesWatched"); int iB12 = yn1.b(cursorB, "statsShowsWatched"); int iB13 = yn1.b(cursorB, "statsMinutesWatched"); int iB14 = yn1.b(cursorB, "lastSyncAt"); int iB15 = yn1.b(cursorB, "lastHistorySync"); int iB16 = yn1.b(cursorB, "lastCollectionSync"); int iB17 = yn1.b(cursorB, "lastWatchlistSync"); int iB18 = yn1.b(cursorB, "lastDroppedSync"); int iB19 = yn1.b(cursorB, "lastActivitiesAt"); TraktAccount traktAccount = null; if (cursorB.moveToFirst()) { traktAccount = new TraktAccount(cursorB.getString(iB), cursorB.isNull(iB2) ? null : cursorB.getString(iB2), cursorB.getString(iB3), cursorB.isNull(iB4) ? null : cursorB.getString(iB4), cursorB.isNull(iB5) ? null : cursorB.getString(iB5), cursorB.isNull(iB6) ? null : cursorB.getString(iB6), cursorB.getLong(iB7), cursorB.getLong(iB8), cursorB.getInt(iB9) != 0, cursorB.isNull(iB10) ? null : Integer.valueOf(cursorB.getInt(iB10)), cursorB.isNull(iB11) ? null : Integer.valueOf(cursorB.getInt(iB11)), cursorB.isNull(iB12) ? null : Integer.valueOf(cursorB.getInt(iB12)), cursorB.isNull(iB13) ? null : Long.valueOf(cursorB.getLong(iB13)), cursorB.isNull(iB14) ? null : Long.valueOf(cursorB.getLong(iB14)), cursorB.isNull(iB15) ? null : Long.valueOf(cursorB.getLong(iB15)), cursorB.isNull(iB16) ? null : Long.valueOf(cursorB.getLong(iB16)), cursorB.isNull(iB17) ? null : Long.valueOf(cursorB.getLong(iB17)), cursorB.isNull(iB18) ? null : Long.valueOf(cursorB.getLong(iB18)), cursorB.isNull(iB19) ? null : Long.valueOf(cursorB.getLong(iB19))); } return traktAccount; } finally { cursorB.close(); } } }); } @Override // com.strmr.ps.data.local.dao.TraktAccountDao public j43> getAllAccounts() { final p58 p58VarD = p58.d(0, "SELECT * FROM trakt_accounts ORDER BY createdAt ASC"); return mk1.a(this.__db, false, new String[]{"trakt_accounts"}, new Callable>() { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.21 public void finalize() { p58VarD.release(); } @Override // java.util.concurrent.Callable @vo6 public List call() throws Exception { int i; int i2; Long lValueOf; int i3; int i4; Long l; int i5; int i6; Long l2; int i7; int i8; Long l3; int i9; int i10; Long l4; Cursor cursorB = sp1.b(TraktAccountDao_Impl.this.__db, p58VarD, false); try { int iB = yn1.b(cursorB, "userSlug"); int iB2 = yn1.b(cursorB, "userName"); int iB3 = yn1.b(cursorB, "accessToken"); int iB4 = yn1.b(cursorB, "refreshToken"); int iB5 = yn1.b(cursorB, "tokenType"); int iB6 = yn1.b(cursorB, "scope"); int iB7 = yn1.b(cursorB, "expiresAt"); int iB8 = yn1.b(cursorB, "createdAt"); int iB9 = yn1.b(cursorB, "isActive"); int iB10 = yn1.b(cursorB, "avatarResourceId"); int iB11 = yn1.b(cursorB, "statsMoviesWatched"); int iB12 = yn1.b(cursorB, "statsShowsWatched"); int iB13 = yn1.b(cursorB, "statsMinutesWatched"); int iB14 = yn1.b(cursorB, "lastSyncAt"); int iB15 = yn1.b(cursorB, "lastHistorySync"); int iB16 = yn1.b(cursorB, "lastCollectionSync"); int iB17 = yn1.b(cursorB, "lastWatchlistSync"); int iB18 = yn1.b(cursorB, "lastDroppedSync"); int iB19 = yn1.b(cursorB, "lastActivitiesAt"); int i11 = iB14; ArrayList arrayList = new ArrayList(cursorB.getCount()); while (cursorB.moveToNext()) { String string = cursorB.getString(iB); String string2 = cursorB.isNull(iB2) ? null : cursorB.getString(iB2); String string3 = cursorB.getString(iB3); String string4 = cursorB.isNull(iB4) ? null : cursorB.getString(iB4); String string5 = cursorB.isNull(iB5) ? null : cursorB.getString(iB5); String string6 = cursorB.isNull(iB6) ? null : cursorB.getString(iB6); long j = cursorB.getLong(iB7); long j2 = cursorB.getLong(iB8); boolean z = cursorB.getInt(iB9) != 0; Integer numValueOf = cursorB.isNull(iB10) ? null : Integer.valueOf(cursorB.getInt(iB10)); Integer numValueOf2 = cursorB.isNull(iB11) ? null : Integer.valueOf(cursorB.getInt(iB11)); Integer numValueOf3 = cursorB.isNull(iB12) ? null : Integer.valueOf(cursorB.getInt(iB12)); Long lValueOf2 = cursorB.isNull(iB13) ? null : Long.valueOf(cursorB.getLong(iB13)); int i12 = i11; if (cursorB.isNull(i12)) { int i13 = iB15; i = iB; i2 = i13; lValueOf = null; } else { int i14 = iB15; i = iB; i2 = i14; lValueOf = Long.valueOf(cursorB.getLong(i12)); } if (cursorB.isNull(i2)) { int i15 = iB16; i3 = i2; i4 = i15; l = null; } else { Long lValueOf3 = Long.valueOf(cursorB.getLong(i2)); int i16 = iB16; i3 = i2; i4 = i16; l = lValueOf3; } if (cursorB.isNull(i4)) { int i17 = iB17; i5 = i4; i6 = i17; l2 = null; } else { Long lValueOf4 = Long.valueOf(cursorB.getLong(i4)); int i18 = iB17; i5 = i4; i6 = i18; l2 = lValueOf4; } if (cursorB.isNull(i6)) { int i19 = iB18; i7 = i6; i8 = i19; l3 = null; } else { Long lValueOf5 = Long.valueOf(cursorB.getLong(i6)); int i20 = iB18; i7 = i6; i8 = i20; l3 = lValueOf5; } if (cursorB.isNull(i8)) { int i21 = iB19; i9 = i8; i10 = i21; l4 = null; } else { Long lValueOf6 = Long.valueOf(cursorB.getLong(i8)); int i22 = iB19; i9 = i8; i10 = i22; l4 = lValueOf6; } int i23 = i10; arrayList.add(new TraktAccount(string, string2, string3, string4, string5, string6, j, j2, z, numValueOf, numValueOf2, numValueOf3, lValueOf2, lValueOf, l, l2, l3, l4, cursorB.isNull(i10) ? null : Long.valueOf(cursorB.getLong(i10)))); iB = i; iB15 = i3; iB16 = i5; iB17 = i7; iB18 = i9; iB19 = i23; i11 = i12; } return arrayList; } finally { cursorB.close(); } } }); } @Override // com.strmr.ps.data.local.dao.TraktAccountDao public Object getAllAccountsSync(Continuation> continuation) { final p58 p58VarD = p58.d(0, "SELECT * FROM trakt_accounts ORDER BY createdAt ASC"); return mk1.c(this.__db, false, new CancellationSignal(), new Callable>() { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.22 @Override // java.util.concurrent.Callable @vo6 public List call() throws Exception { AnonymousClass22 anonymousClass22; int iB; int iB2; int iB3; int iB4; int iB5; int iB6; int iB7; int iB8; int iB9; int iB10; int iB11; int iB12; int iB13; int iB14; int i; int i2; Long lValueOf; int i3; int i4; Long l; int i5; int i6; Long l2; int i7; int i8; Long l3; int i9; int i10; Long l4; Cursor cursorB = sp1.b(TraktAccountDao_Impl.this.__db, p58VarD, false); try { iB = yn1.b(cursorB, "userSlug"); iB2 = yn1.b(cursorB, "userName"); iB3 = yn1.b(cursorB, "accessToken"); iB4 = yn1.b(cursorB, "refreshToken"); iB5 = yn1.b(cursorB, "tokenType"); iB6 = yn1.b(cursorB, "scope"); iB7 = yn1.b(cursorB, "expiresAt"); iB8 = yn1.b(cursorB, "createdAt"); iB9 = yn1.b(cursorB, "isActive"); iB10 = yn1.b(cursorB, "avatarResourceId"); iB11 = yn1.b(cursorB, "statsMoviesWatched"); iB12 = yn1.b(cursorB, "statsShowsWatched"); iB13 = yn1.b(cursorB, "statsMinutesWatched"); iB14 = yn1.b(cursorB, "lastSyncAt"); } catch (Throwable th) { th = th; anonymousClass22 = this; } try { int iB15 = yn1.b(cursorB, "lastHistorySync"); int iB16 = yn1.b(cursorB, "lastCollectionSync"); int iB17 = yn1.b(cursorB, "lastWatchlistSync"); int iB18 = yn1.b(cursorB, "lastDroppedSync"); int iB19 = yn1.b(cursorB, "lastActivitiesAt"); int i11 = iB14; ArrayList arrayList = new ArrayList(cursorB.getCount()); while (cursorB.moveToNext()) { String string = cursorB.getString(iB); String string2 = cursorB.isNull(iB2) ? null : cursorB.getString(iB2); String string3 = cursorB.getString(iB3); String string4 = cursorB.isNull(iB4) ? null : cursorB.getString(iB4); String string5 = cursorB.isNull(iB5) ? null : cursorB.getString(iB5); String string6 = cursorB.isNull(iB6) ? null : cursorB.getString(iB6); long j = cursorB.getLong(iB7); long j2 = cursorB.getLong(iB8); boolean z = cursorB.getInt(iB9) != 0; Integer numValueOf = cursorB.isNull(iB10) ? null : Integer.valueOf(cursorB.getInt(iB10)); Integer numValueOf2 = cursorB.isNull(iB11) ? null : Integer.valueOf(cursorB.getInt(iB11)); Integer numValueOf3 = cursorB.isNull(iB12) ? null : Integer.valueOf(cursorB.getInt(iB12)); Long lValueOf2 = cursorB.isNull(iB13) ? null : Long.valueOf(cursorB.getLong(iB13)); int i12 = i11; if (cursorB.isNull(i12)) { int i13 = iB15; i = iB; i2 = i13; lValueOf = null; } else { int i14 = iB15; i = iB; i2 = i14; lValueOf = Long.valueOf(cursorB.getLong(i12)); } if (cursorB.isNull(i2)) { int i15 = iB16; i3 = i2; i4 = i15; l = null; } else { Long lValueOf3 = Long.valueOf(cursorB.getLong(i2)); int i16 = iB16; i3 = i2; i4 = i16; l = lValueOf3; } if (cursorB.isNull(i4)) { int i17 = iB17; i5 = i4; i6 = i17; l2 = null; } else { Long lValueOf4 = Long.valueOf(cursorB.getLong(i4)); int i18 = iB17; i5 = i4; i6 = i18; l2 = lValueOf4; } if (cursorB.isNull(i6)) { int i19 = iB18; i7 = i6; i8 = i19; l3 = null; } else { Long lValueOf5 = Long.valueOf(cursorB.getLong(i6)); int i20 = iB18; i7 = i6; i8 = i20; l3 = lValueOf5; } if (cursorB.isNull(i8)) { int i21 = iB19; i9 = i8; i10 = i21; l4 = null; } else { Long lValueOf6 = Long.valueOf(cursorB.getLong(i8)); int i22 = iB19; i9 = i8; i10 = i22; l4 = lValueOf6; } int i23 = i10; arrayList.add(new TraktAccount(string, string2, string3, string4, string5, string6, j, j2, z, numValueOf, numValueOf2, numValueOf3, lValueOf2, lValueOf, l, l2, l3, l4, cursorB.isNull(i10) ? null : Long.valueOf(cursorB.getLong(i10)))); iB = i; iB15 = i3; iB16 = i5; iB17 = i7; iB18 = i9; iB19 = i23; i11 = i12; } cursorB.close(); p58VarD.release(); return arrayList; } catch (Throwable th2) { th = th2; anonymousClass22 = this; cursorB.close(); p58VarD.release(); throw th; } } }, continuation); } @Override // com.strmr.ps.data.local.dao.TraktAccountDao public Object setActive(final String str, Continuation continuation) { return mk1.b(this.__db, new Callable() { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.13 /* JADX WARN: Can't rename method to resolve collision */ @Override // java.util.concurrent.Callable @vo6 public e6a call() throws Exception { pe9 pe9VarAcquire = TraktAccountDao_Impl.this.__preparedStmtOfSetActive.acquire(); pe9VarAcquire.bindString(1, str); try { TraktAccountDao_Impl.this.__db.beginTransaction(); try { pe9VarAcquire.executeUpdateDelete(); TraktAccountDao_Impl.this.__db.setTransactionSuccessful(); return e6a.a; } finally { TraktAccountDao_Impl.this.__db.endTransaction(); } } finally { TraktAccountDao_Impl.this.__preparedStmtOfSetActive.release(pe9VarAcquire); } } }, continuation); } @Override // com.strmr.ps.data.local.dao.TraktAccountDao public Object setActiveAccount(String str, Continuation continuation) { return n58.a(this.__db, new q2(this, str, 21), continuation); } @Override // com.strmr.ps.data.local.dao.TraktAccountDao public Object updateAvatar(final String str, final int i, Continuation continuation) { return mk1.b(this.__db, new Callable() { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.16 /* JADX WARN: Can't rename method to resolve collision */ @Override // java.util.concurrent.Callable @vo6 public e6a call() throws Exception { pe9 pe9VarAcquire = TraktAccountDao_Impl.this.__preparedStmtOfUpdateAvatar.acquire(); pe9VarAcquire.bindLong(1, i); pe9VarAcquire.bindString(2, str); try { TraktAccountDao_Impl.this.__db.beginTransaction(); try { pe9VarAcquire.executeUpdateDelete(); TraktAccountDao_Impl.this.__db.setTransactionSuccessful(); return e6a.a; } finally { TraktAccountDao_Impl.this.__db.endTransaction(); } } finally { TraktAccountDao_Impl.this.__preparedStmtOfUpdateAvatar.release(pe9VarAcquire); } } }, continuation); } @Override // com.strmr.ps.data.local.dao.TraktAccountDao public Object updateStats(final String str, final Integer num, final Integer num2, final Long l, final String str2, Continuation continuation) { return mk1.b(this.__db, new Callable() { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.15 /* JADX WARN: Can't rename method to resolve collision */ @Override // java.util.concurrent.Callable @vo6 public e6a call() throws Exception { pe9 pe9VarAcquire = TraktAccountDao_Impl.this.__preparedStmtOfUpdateStats.acquire(); if (num == null) { pe9VarAcquire.bindNull(1); } else { pe9VarAcquire.bindLong(1, r1.intValue()); } if (num2 == null) { pe9VarAcquire.bindNull(2); } else { pe9VarAcquire.bindLong(2, r1.intValue()); } Long l2 = l; if (l2 == null) { pe9VarAcquire.bindNull(3); } else { pe9VarAcquire.bindLong(3, l2.longValue()); } String str3 = str2; if (str3 == null) { pe9VarAcquire.bindNull(4); } else { pe9VarAcquire.bindString(4, str3); } pe9VarAcquire.bindString(5, str); try { TraktAccountDao_Impl.this.__db.beginTransaction(); try { pe9VarAcquire.executeUpdateDelete(); TraktAccountDao_Impl.this.__db.setTransactionSuccessful(); return e6a.a; } finally { TraktAccountDao_Impl.this.__db.endTransaction(); } } finally { TraktAccountDao_Impl.this.__preparedStmtOfUpdateStats.release(pe9VarAcquire); } } }, continuation); } @Override // com.strmr.ps.data.local.dao.TraktAccountDao public Object updateSyncTimestamps(final String str, final Long l, final Long l2, final Long l3, final Long l4, final Long l5, Continuation continuation) { return mk1.b(this.__db, new Callable() { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.17 /* JADX WARN: Can't rename method to resolve collision */ @Override // java.util.concurrent.Callable @vo6 public e6a call() throws Exception { pe9 pe9VarAcquire = TraktAccountDao_Impl.this.__preparedStmtOfUpdateSyncTimestamps.acquire(); Long l6 = l; if (l6 == null) { pe9VarAcquire.bindNull(1); } else { pe9VarAcquire.bindLong(1, l6.longValue()); } Long l7 = l2; if (l7 == null) { pe9VarAcquire.bindNull(2); } else { pe9VarAcquire.bindLong(2, l7.longValue()); } Long l8 = l3; if (l8 == null) { pe9VarAcquire.bindNull(3); } else { pe9VarAcquire.bindLong(3, l8.longValue()); } Long l9 = l4; if (l9 == null) { pe9VarAcquire.bindNull(4); } else { pe9VarAcquire.bindLong(4, l9.longValue()); } Long l10 = l5; if (l10 == null) { pe9VarAcquire.bindNull(5); } else { pe9VarAcquire.bindLong(5, l10.longValue()); } pe9VarAcquire.bindString(6, str); try { TraktAccountDao_Impl.this.__db.beginTransaction(); try { pe9VarAcquire.executeUpdateDelete(); TraktAccountDao_Impl.this.__db.setTransactionSuccessful(); return e6a.a; } finally { TraktAccountDao_Impl.this.__db.endTransaction(); } } finally { TraktAccountDao_Impl.this.__preparedStmtOfUpdateSyncTimestamps.release(pe9VarAcquire); } } }, continuation); } @Override // com.strmr.ps.data.local.dao.TraktAccountDao public Object updateTokens(final String str, final String str2, final String str3, final long j, final String str4, final String str5, Continuation continuation) { return mk1.b(this.__db, new Callable() { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.14 /* JADX WARN: Can't rename method to resolve collision */ @Override // java.util.concurrent.Callable @vo6 public e6a call() throws Exception { pe9 pe9VarAcquire = TraktAccountDao_Impl.this.__preparedStmtOfUpdateTokens.acquire(); pe9VarAcquire.bindString(1, str2); String str6 = str3; if (str6 == null) { pe9VarAcquire.bindNull(2); } else { pe9VarAcquire.bindString(2, str6); } pe9VarAcquire.bindLong(3, j); String str7 = str4; if (str7 == null) { pe9VarAcquire.bindNull(4); } else { pe9VarAcquire.bindString(4, str7); } String str8 = str5; if (str8 == null) { pe9VarAcquire.bindNull(5); } else { pe9VarAcquire.bindString(5, str8); } pe9VarAcquire.bindString(6, str); try { TraktAccountDao_Impl.this.__db.beginTransaction(); try { pe9VarAcquire.executeUpdateDelete(); TraktAccountDao_Impl.this.__db.setTransactionSuccessful(); return e6a.a; } finally { TraktAccountDao_Impl.this.__db.endTransaction(); } } finally { TraktAccountDao_Impl.this.__preparedStmtOfUpdateTokens.release(pe9VarAcquire); } } }, continuation); } @Override // com.strmr.ps.data.local.dao.TraktAccountDao public Object upsert(final TraktAccount traktAccount, Continuation continuation) { return mk1.b(this.__db, new Callable() { // from class: com.strmr.ps.data.local.dao.TraktAccountDao_Impl.11 /* JADX WARN: Can't rename method to resolve collision */ @Override // java.util.concurrent.Callable @vo6 public e6a call() throws Exception { TraktAccountDao_Impl.this.__db.beginTransaction(); try { TraktAccountDao_Impl.this.__insertionAdapterOfTraktAccount.insert(traktAccount); TraktAccountDao_Impl.this.__db.setTransactionSuccessful(); return e6a.a; } finally { TraktAccountDao_Impl.this.__db.endTransaction(); } } }, continuation); } }