// 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.communication.bluetooth;

import android.content.ContentResolver;
import android.content.Context;
import com.olio.communication.messages.MessagePayload;
import com.olio.olios.detector.ManagedDetector;
import com.olio.olios.model.record.SerializedRecord;
import com.olio.util.ALog;
import java.util.Iterator;
import java.util.List;

public abstract class SyncConnectionMonitor
    implements ManagedDetector
{

    protected ContentResolver mContentResolver;
    protected Context mContext;

    public SyncConnectionMonitor(Context context)
    {
        mContext = context;
        mContentResolver = context.getContentResolver();
    }

    public void onDisconnect()
    {
    }

    public void register()
    {
    }

    public abstract void sendMessagePayload(MessagePayload messagepayload);

    public abstract boolean shouldSync(com.olio.olios.model.SyncableMessageMonitor.SyncableMessage syncablemessage);

    public boolean shouldUpdate()
    {
        return false;
    }

    public void unregister()
    {
    }

    public void update()
    {
        for (Iterator iterator = SerializedRecord.allRecords(mContentResolver).iterator(); iterator.hasNext();)
        {
            Object obj = ((SerializedRecord)iterator.next()).getObject();
            if (obj != null && (obj instanceof com.olio.olios.model.SyncableMessageMonitor.SyncableMessage))
            {
                obj = (com.olio.olios.model.SyncableMessageMonitor.SyncableMessage)obj;
                if (shouldSync(((com.olio.olios.model.SyncableMessageMonitor.SyncableMessage) (obj))))
                {
                    ALog.v("Synchronizing: %s", new Object[] {
                        obj
                    });
                    sendMessagePayload(((com.olio.olios.model.SyncableMessageMonitor.SyncableMessage) (obj)).getMessagePayload());
                } else
                {
                    ALog.v("Shouldn't sync: %s", new Object[] {
                        obj
                    });
                }
            } else
            {
                ALog.v("Object '%s' doesn't implement SyncableMessage", new Object[] {
                    obj
                });
            }
        }

    }

    public Long updateFrequency()
    {
        return null;
    }

    public boolean updateOnReconnect()
    {
        return true;
    }
}