// Decompiled by Jad v1.5.8e. Copyright 2001 Pavel Kouznetsov.
// Jad home page: http://www.geocities.com/kpdus/jad.html
// Decompiler options: braces fieldsfirst space lnc 

package com.olio.olios.model.record;

import android.content.AsyncTaskLoader;
import android.content.ContentResolver;
import android.content.Context;
import android.database.ContentObserver;
import android.net.Uri;
import android.os.Handler;
import com.olio.util.ALog;
import java.util.Objects;

// Referenced classes of package com.olio.olios.model.record:
//            SerializedRecord, DatabaseRecord

public abstract class AsyncSerializedRecordLoader extends AsyncTaskLoader
{
    private class RecordObserver extends ContentObserver
    {

        final AsyncSerializedRecordLoader this$0;

        public boolean deliverSelfNotifications()
        {
            return false;
        }

        public void onChange(boolean flag)
        {
            onChange(flag, null);
        }

        public void onChange(boolean flag, Uri uri)
        {
            ALog.d("Record changed for URI: %s", new Object[] {
                uri.toString()
            });
            if (Objects.equals(uri.getQueryParameter("typeName"), getType()))
            {
                ALog.d("Record Matched updating loader", new Object[0]);
                onContentChanged();
            }
        }

        public RecordObserver()
        {
            this$0 = AsyncSerializedRecordLoader.this;
            super(new Handler());
        }
    }


    RecordObserver mObserver;

    public AsyncSerializedRecordLoader(Context context)
    {
        super(context);
    }

    private void register()
    {
        if (mObserver == null)
        {
            ALog.d("Registering record observer.", new Object[0]);
            mObserver = new RecordObserver();
            getContext().getContentResolver().registerContentObserver(getUri(), true, mObserver);
        }
    }

    private void unregister()
    {
        if (mObserver != null)
        {
            ALog.d("Unregistering record observer.", new Object[0]);
            getContext().getContentResolver().unregisterContentObserver(mObserver);
            mObserver = null;
        }
    }

    public abstract String getType();

    public Uri getUri()
    {
        return SerializedRecord.staticFactory().getRecordInstance().tableUri();
    }

    protected void onReset()
    {
        ALog.d("Reset.", new Object[0]);
        super.onReset();
        onStopLoading();
    }

    protected void onStartLoading()
    {
        super.onStartLoading();
        ALog.d("Start loading.", new Object[0]);
        register();
    }

    protected void onStopLoading()
    {
        ALog.d("stop loading.", new Object[0]);
        unregister();
    }
}