18
18
import androidx .core .util .Consumer ;
19
19
20
20
import com .urbanairship .CancelableOperation ;
21
- import com .urbanairship .Logger ;
21
+ import com .urbanairship .UALog ;
22
22
import com .urbanairship .PendingResult ;
23
23
import com .urbanairship .Predicate ;
24
24
import com .urbanairship .PreferenceDataStore ;
52
52
import com .urbanairship .reactive .Subscriber ;
53
53
import com .urbanairship .reactive .Subscription ;
54
54
import com .urbanairship .util .AirshipHandlerThread ;
55
- import com .urbanairship .util .Network ;
56
55
57
56
import java .math .BigDecimal ;
58
57
import java .util .ArrayList ;
@@ -358,7 +357,7 @@ public void run() {
358
357
cleanSchedules ();
359
358
360
359
if (dao .getScheduleCount () >= SCHEDULE_LIMIT ) {
361
- Logger . error ("AutomationEngine - Unable to insert schedule due to schedule exceeded limit." );
360
+ UALog . e ("AutomationEngine - Unable to insert schedule due to schedule exceeded limit." );
362
361
pendingResult .setResult (false );
363
362
return ;
364
363
}
@@ -369,7 +368,7 @@ public void run() {
369
368
370
369
notifyNewSchedule (Collections .<Schedule <? extends ScheduleData >>singletonList (schedule ));
371
370
372
- Logger . verbose ("Scheduled entries: %s" , schedule );
371
+ UALog . v ("Scheduled entries: %s" , schedule );
373
372
pendingResult .setResult (true );
374
373
}
375
374
});
@@ -393,7 +392,7 @@ public void run() {
393
392
cleanSchedules ();
394
393
395
394
if (dao .getScheduleCount () + schedules .size () > SCHEDULE_LIMIT ) {
396
- Logger . error ("AutomationDataManager - Unable to insert schedule due to schedule exceeded limit." );
395
+ UALog . e ("AutomationDataManager - Unable to insert schedule due to schedule exceeded limit." );
397
396
pendingResult .setResult (false );
398
397
return ;
399
398
}
@@ -410,7 +409,7 @@ public void run() {
410
409
Collection <Schedule <? extends ScheduleData >> result = convertSchedulesUnknownTypes (entries );
411
410
notifyNewSchedule (result );
412
411
413
- Logger . verbose ("Scheduled entries: %s" , result );
412
+ UALog . v ("Scheduled entries: %s" , result );
414
413
pendingResult .setResult (true );
415
414
}
416
415
});
@@ -437,7 +436,7 @@ public void run() {
437
436
return ;
438
437
}
439
438
440
- Logger . verbose ("Cancelled schedules: %s" , ids );
439
+ UALog . v ("Cancelled schedules: %s" , ids );
441
440
442
441
dao .deleteSchedules (entries );
443
442
notifyCancelledSchedule (entries );
@@ -467,7 +466,7 @@ public void run() {
467
466
ids .add (entry .schedule .scheduleId );
468
467
}
469
468
470
- Logger . verbose ("Cancelled schedules: %s" , ids );
469
+ UALog . v ("Cancelled schedules: %s" , ids );
471
470
dao .deleteSchedules (entries );
472
471
notifyCancelledSchedule (entries );
473
472
cancelScheduleAlarms (ids );
@@ -494,7 +493,7 @@ public void run() {
494
493
List <FullSchedule > entries = dao .getSchedulesWithGroup (group );
495
494
496
495
if (entries .isEmpty ()) {
497
- Logger . verbose ("Failed to cancel schedule group: %s" , group );
496
+ UALog . v ("Failed to cancel schedule group: %s" , group );
498
497
pendingResult .setResult (false );
499
498
} else {
500
499
dao .deleteSchedules (entries );
@@ -635,7 +634,7 @@ public void run() {
635
634
FullSchedule entry = dao .getSchedule (scheduleId );
636
635
637
636
if (entry == null ) {
638
- Logger . error ("AutomationEngine - Schedule no longer exists. Unable to edit: %s" , scheduleId );
637
+ UALog . e ("AutomationEngine - Schedule no longer exists. Unable to edit: %s" , scheduleId );
639
638
pendingResult .setResult (false );
640
639
return ;
641
640
}
@@ -669,7 +668,7 @@ public void run() {
669
668
subscribeStateObservables (entry , stateChangeTimeStamp );
670
669
}
671
670
672
- Logger . verbose ("Updated schedule: %s" , scheduleId );
671
+ UALog . v ("Updated schedule: %s" , scheduleId );
673
672
pendingResult .setResult (true );
674
673
}
675
674
});
@@ -921,7 +920,7 @@ private void resetWaitingSchedules() {
921
920
}
922
921
923
922
dao .updateSchedules (entries );
924
- Logger . verbose ("AutomationEngine: Schedules reset state to STATE_PREPARING_SCHEDULE: %s" , entries );
923
+ UALog . v ("AutomationEngine: Schedules reset state to STATE_PREPARING_SCHEDULE: %s" , entries );
925
924
}
926
925
927
926
/**
@@ -955,7 +954,7 @@ private void cleanSchedules() {
955
954
}
956
955
957
956
if (!schedulesToDelete .isEmpty ()) {
958
- Logger . verbose ("Deleting finished schedules: %s" , schedulesToDelete );
957
+ UALog . v ("Deleting finished schedules: %s" , schedulesToDelete );
959
958
dao .deleteSchedules (schedulesToDelete );
960
959
}
961
960
}
@@ -1073,7 +1072,7 @@ private void onEventAdded(@NonNull final JsonSerializable json, final int type,
1073
1072
backgroundHandler .post (new Runnable () {
1074
1073
@ Override
1075
1074
public void run () {
1076
- Logger . debug ("Updating triggers with type: %s" , type );
1075
+ UALog . d ("Updating triggers with type: %s" , type );
1077
1076
List <TriggerEntity > triggerEntities = dao .getActiveTriggers (type );
1078
1077
if (triggerEntities .isEmpty ()) {
1079
1078
return ;
@@ -1294,9 +1293,9 @@ private <T extends ScheduleData> Schedule<T> convert(@Nullable FullSchedule entr
1294
1293
try {
1295
1294
return ScheduleConverters .convert (entry );
1296
1295
} catch (ClassCastException e ) {
1297
- Logger . error (e , "Exception converting entity to schedule %s" , entry .schedule .scheduleId );
1296
+ UALog . e (e , "Exception converting entity to schedule %s" , entry .schedule .scheduleId );
1298
1297
} catch (Exception e ) {
1299
- Logger . error (e , "Exception converting entity to schedule %s. Cancelling." , entry .schedule .scheduleId );
1298
+ UALog . e (e , "Exception converting entity to schedule %s. Cancelling." , entry .schedule .scheduleId );
1300
1299
cancel (Collections .singleton (entry .schedule .scheduleId ));
1301
1300
}
1302
1301
return null ;
@@ -1334,7 +1333,7 @@ private <T extends ScheduleData> Collection<Schedule<T>> convertSchedules(@NonNu
1334
1333
@ WorkerThread
1335
1334
private void attemptExecution (@ NonNull final FullSchedule entry ) {
1336
1335
if (entry .schedule .executionState != ScheduleState .WAITING_SCHEDULE_CONDITIONS ) {
1337
- Logger . error ("Unable to execute schedule when state is %s scheduleID: %s" , entry .schedule .executionState , entry .schedule .scheduleId );
1336
+ UALog . e ("Unable to execute schedule when state is %s scheduleID: %s" , entry .schedule .executionState , entry .schedule .scheduleId );
1338
1337
return ;
1339
1338
}
1340
1339
@@ -1360,7 +1359,7 @@ public void run() {
1360
1359
schedule = ScheduleConverters .convert (entry );
1361
1360
result = driver .onCheckExecutionReadiness (schedule );
1362
1361
} catch (Exception e ) {
1363
- Logger . error (e , "Unable to create schedule." );
1362
+ UALog . e (e , "Unable to create schedule." );
1364
1363
this .exception = e ;
1365
1364
}
1366
1365
}
@@ -1377,36 +1376,36 @@ public void run() {
1377
1376
try {
1378
1377
latch .await ();
1379
1378
} catch (InterruptedException ex ) {
1380
- Logger . error (ex , "Failed to execute schedule. " );
1379
+ UALog . e (ex , "Failed to execute schedule. " );
1381
1380
Thread .currentThread ().interrupt ();
1382
1381
}
1383
1382
1384
1383
if (runnable .exception != null ) {
1385
- Logger . error ("Failed to check conditions. Deleting schedule: %s" , entry .schedule .scheduleId );
1384
+ UALog . e ("Failed to check conditions. Deleting schedule: %s" , entry .schedule .scheduleId );
1386
1385
dao .delete (entry );
1387
1386
notifyCancelledSchedule (Collections .singleton (entry ));
1388
1387
} else {
1389
1388
int result = runnable .result == null ? AutomationDriver .READY_RESULT_NOT_READY : runnable .result ;
1390
1389
switch (result ) {
1391
1390
case AutomationDriver .READY_RESULT_INVALIDATE :
1392
- Logger . verbose ("Schedule invalidated: %s" , entry .schedule .scheduleId );
1391
+ UALog . v ("Schedule invalidated: %s" , entry .schedule .scheduleId );
1393
1392
updateExecutionState (entry , ScheduleState .PREPARING_SCHEDULE );
1394
1393
dao .update (entry );
1395
1394
prepareSchedules (Collections .singletonList (dao .getSchedule (entry .schedule .scheduleId )));
1396
1395
break ;
1397
1396
1398
1397
case AutomationDriver .READY_RESULT_CONTINUE :
1399
- Logger . verbose ("Schedule executing: %s" , entry .schedule .scheduleId );
1398
+ UALog . v ("Schedule executing: %s" , entry .schedule .scheduleId );
1400
1399
updateExecutionState (entry , ScheduleState .EXECUTING );
1401
1400
dao .update (entry );
1402
1401
break ;
1403
1402
1404
1403
case AutomationDriver .READY_RESULT_NOT_READY :
1405
- Logger . verbose ("Schedule not ready for execution: %s" , entry .schedule .scheduleId );
1404
+ UALog . v ("Schedule not ready for execution: %s" , entry .schedule .scheduleId );
1406
1405
break ;
1407
1406
1408
1407
case AutomationDriver .READY_RESULT_SKIP :
1409
- Logger . verbose ("Schedule execution skipped: %s" , entry .schedule .scheduleId );
1408
+ UALog . v ("Schedule execution skipped: %s" , entry .schedule .scheduleId );
1410
1409
updateExecutionState (entry , ScheduleState .IDLE );
1411
1410
dao .update (entry );
1412
1411
break ;
@@ -1518,7 +1517,7 @@ private void onScheduleFinishedExecuting(@Nullable final FullSchedule entry) {
1518
1517
return ;
1519
1518
}
1520
1519
1521
- Logger . verbose ("Schedule finished: %s" , entry .schedule .scheduleId );
1520
+ UALog . v ("Schedule finished: %s" , entry .schedule .scheduleId );
1522
1521
1523
1522
entry .schedule .count ++;
1524
1523
boolean isOverLimit = isOverLimit (entry );
0 commit comments