I want to Start a long time Service which observes the android Downloads folder ,
I have created a BroadcastReceiver which receives the BOOT_COMPLETED event and this BroadcastReceiver will start the Service using context.startStartService() method.
It seems the way it is working correct in android versions below 8 but for higher versions of android I get an error which is
android.app.RemoteServiceException: Context.startForegroundService() did not then call Service.startForeground(): ServiceRecord{ba36f7 u0 packagename/.FileSystemObserverService}
StartupBroadCastReceiver
public class StartupReceiver extends BroadcastReceiver {
private static final String TAG = "StartupReceiver";
@Override
public void onReceive(Context context, Intent intent) {
Log.e(TAG, "onReceive: called " );
appendLog(context,"OnReceived called StartupReceive line 20");
Toast.makeText(context, "Boot Completed", Toast.LENGTH_SHORT).show();
Intent myIntent = new Intent(context, FileSystemObserverService.class);
if (Build.VERSION.SDK_INT>=Build.VERSION_CODES.O){
context.startForegroundService(myIntent);
return;
}
context.startService(myIntent);
}
private void appendLog(Context context,String log){
SharedPreferences sp = context.getSharedPreferences("sp",Context.MODE_PRIVATE);
String preLogs = sp.getString("logs","");
preLogs+="\n"+log;
sp.edit().putString("logs",preLogs).apply();
}
}
Above code is my BroadcastReceiver which receives BOOT_COMPLETED event.
FileSystemObserver
public class FileSystemObserverService extends Service {
private Observer mMainObserver;
private static final String TAG = "FileSystemObserverServi";
@Override
public int onStartCommand(Intent intent, int flags, int startId) {
Log.e(TAG, "onStartCommand: get called " );
observe();
return super.onStartCommand(intent, flags, startId);
}
@Override
public void onDestroy() {
super.onDestroy();
Log.e(TAG, "onDestroy: called for fileObserverService");
}
@Nullable
@Override
public IBinder onBind(Intent intent) {
return null;
}
public void observe(){
Thread t= new Thread(new Runnable() {
@Override
public void run() {
Log.e(TAG, "run: thread is running " );
File str = Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS);
if (str!=null){
Log.e(TAG, "run: "+str.getAbsolutePath());
String downloadsPath = str.getAbsolutePath();
mMainObserver= new Observer(downloadsPath, new DataInterface() {
@Override
public String getMacAddress() {
SharedPreferences sp = getSharedPreferences("sp",MODE_PRIVATE);
return sp.getString("mac_address",null);
}
@Override
public void appendLog(String log) {
SharedPreferences sp = getSharedPreferences("sp",MODE_PRIVATE);
String preLogs = sp.getString("logs","");
preLogs+="\n"+log;
sp.edit().putString("logs",preLogs).apply();
}
});
mMainObserver.startWatching();
}
}
});
t.setPriority(Thread.MIN_PRIORITY);
t.start();
}
}
interface DataInterface{
public String getMacAddress();
public void appendLog(String log);
}
class Observer extends FileObserver{
private static final String TAG = "Observer";
List<SingleFileObserver> mObserves;
String mPath;
int mMask;
Context mContext;
private SendPDF sendPDF;
private DataInterface di ;
public Observer(String path,DataInterface di) {
this(path,ALL_EVENTS);
this.di = di;
}
@Override
public void startWatching() {
Log.e(TAG, "startWatching: getCalled" );
di.appendLog("Line 104 FileSystemObserverService startWatching : called");
try{
if(mObserves!=null)
return;
mObserves = new ArrayList<SingleFileObserver>();
Stack<String> stack = new Stack<String>();
stack.push(mPath);
while (!stack.isEmpty()){
String parent = stack.pop();
mObserves.add(new SingleFileObserver(parent,mMask));
File path = new File(parent);
File[] files = path.listFiles();
if (files==null) continue;
}
for (SingleFileObserver ob : mObserves){
ob.startWatching();
}
}catch (Exception e){
di.appendLog("Line 124 FileSystemObserverService "+e.getMessage());
}
}
@Override
public void stopWatching() {
if (mObserves==null)
return;
for (SingleFileObserver ob : mObserves){
ob.stopWatching();
}
mObserves.clear();
mObserves = null;
}
public Observer(String path , int mask){
super(path,mask);
mPath = path;
mMask = mask;
}
public String getReadableEventName(int e ){
switch (e){
case FileObserver.OPEN:
return "OPEN";
case FileObserver.CREATE:
return "CREATE";
case DELETE_SELF:
return "DELETE_SELF";
case DELETE :
return "DELETE";
case MOVED_FROM :
return "MOVED_FROM";
case MOVED_TO:
return "MOVED_TO";
case MOVE_SELF:
return "MOVED_SELF";
default:
return "UNKNOWN";
}
}
@Override
public void onEvent(int event, @Nullable String path) {
// if (mContext!=null)
// Toast.makeText(mContext, "Event Called " +path, Toast.LENGTH_SHORT).show();
Log.e(TAG, "onEvent: Called "+path);
di.appendLog("Line 157 FileSystemObserverService onEventCalled with " +event+" name: " +getReadableEventName(event)+ " path: "+path);
try{
switch (event){
case FileObserver.OPEN:
Log.e(TAG, "onEvent: OPEN" );
break;
case FileObserver.CREATE:
Log.e(TAG, "onEvent: CREATE");
if (path!=null) {
File file = new File(path);
if (file.isDirectory())
return;
if (!path.endsWith(".pdf"))
return;
sendPDF = new SendPDF(path,di.getMacAddress(),di);
di.appendLog("Line 200 FileSystemObserverService SendPdf instantiated and trying to execute");
sendPDF.execute();
}
break;
case DELETE_SELF:
case DELETE :
Log.e(TAG, "onEvent: DELETE");
break;
case MOVED_FROM :
case MOVED_TO:
case MOVE_SELF:
Log.e(TAG, "onEvent: MOVE");
break;
default:
}
}catch (Exception e){
di.appendLog( "Line 215 FileSystemObserverService "+e.getMessage());
}
}
private class SingleFileObserver extends FileObserver{
private String mPath ;
public SingleFileObserver(String path, int mask) {
super(path, mask);
mPath = path;
}
@Override
public void onEvent(int event, @Nullable String path) {
try{
String newPath = mPath+"/"+path;
Observer.this.onEvent(event,newPath);
Log.e(TAG, "onEvent: "+newPath);
}catch (Exception e){
Log.e(TAG, "onEvent: "+e.getMessage());
}
}
}
}