niagara-ax/modules/cfr_output/com/tridium/alarm/fox/BFoxAlarmDatabase.java

/*
 * Decompiled with CFR 0.152.
 * 
 * Could not load the following classes:
 *  com.tridium.fox.sys.BFoxChannelRegistry
 *  com.tridium.fox.sys.BFoxSession
 *  javax.baja.bql.BqlQuery
 *  javax.baja.bql.Queryable
 *  javax.baja.bql.RemoteQueryable
 *  javax.baja.naming.BOrd
 *  javax.baja.naming.BOrdList
 *  javax.baja.sys.BAbsTime
 *  javax.baja.sys.BObject
 *  javax.baja.sys.BValue
 *  javax.baja.sys.Context
 *  javax.baja.sys.Cursor
 *  javax.baja.sys.Sys
 *  javax.baja.sys.Type
 *  javax.baja.util.BUuid
 */
package com.tridium.alarm.fox;

import com.tridium.alarm.fox.BAlarmDbChannel;
import com.tridium.fox.sys.BFoxChannelRegistry;
import com.tridium.fox.sys.BFoxSession;
import java.io.IOException;
import javax.baja.alarm.AlarmException;
import javax.baja.alarm.BAlarmDatabase;
import javax.baja.alarm.BAlarmRecord;
import javax.baja.bql.BqlQuery;
import javax.baja.bql.Queryable;
import javax.baja.bql.RemoteQueryable;
import javax.baja.naming.BOrd;
import javax.baja.naming.BOrdList;
import javax.baja.sys.BAbsTime;
import javax.baja.sys.BObject;
import javax.baja.sys.BValue;
import javax.baja.sys.Context;
import javax.baja.sys.Cursor;
import javax.baja.sys.Sys;
import javax.baja.sys.Type;
import javax.baja.util.BUuid;

/*
 * Illegal identifiers - consider using --renameillegalidents true
 */
public class BFoxAlarmDatabase
extends BAlarmDatabase
implements Queryable,
RemoteQueryable {
    public static final Type TYPE;
    private BFoxSession session;
    static /* synthetic */ Class class$com$tridium$alarm$fox$BFoxAlarmDatabase;

    public BAlarmDbChannel getChannel() {
        BAlarmDbChannel bAlarmDbChannel = null;
        try {
            bAlarmDbChannel = (BAlarmDbChannel)this.session.getConnection().getChannels().get("alarmdb", BAlarmDbChannel.TYPE);
        }
        catch (Exception exception) {
            BFoxChannelRegistry.getPrototype().add("alarmdb", (BValue)new BAlarmDbChannel());
            bAlarmDbChannel = (BAlarmDbChannel)this.session.getConnection().getChannels().get("alarmdb", BAlarmDbChannel.TYPE);
        }
        return bAlarmDbChannel;
    }

    public void append(BAlarmRecord bAlarmRecord) throws AlarmException {
        throw new UnsupportedOperationException();
    }

    public void update(BAlarmRecord bAlarmRecord) throws AlarmException {
        try {
            this.getChannel().update(bAlarmRecord);
        }
        catch (Exception exception) {
            if (exception instanceof AlarmException) {
                throw (AlarmException)((Object)exception);
            }
            throw new AlarmException(exception);
        }
    }

    public int getRecordCount() {
        try {
            return this.getChannel().getRecordCount();
        }
        catch (Exception exception) {
            if (exception instanceof AlarmException) {
                throw (AlarmException)((Object)exception);
            }
            throw new AlarmException(exception);
        }
    }

    public BAlarmRecord getRecord(BUuid bUuid) {
        try {
            return this.getChannel().getRecord(bUuid);
        }
        catch (Exception exception) {
            if (exception instanceof AlarmException) {
                throw (AlarmException)((Object)exception);
            }
            throw new AlarmException(exception);
        }
    }

    public Cursor scan() throws IOException, AlarmException {
        try {
            return this.getChannel().scan();
        }
        catch (Exception exception) {
            if (exception instanceof AlarmException) {
                throw (AlarmException)((Object)exception);
            }
            throw new AlarmException(exception);
        }
    }

    public Cursor timeQuery(BAbsTime bAbsTime, BAbsTime bAbsTime2) throws IOException, AlarmException {
        try {
            return this.getChannel().timeQuery(bAbsTime, bAbsTime2);
        }
        catch (Exception exception) {
            if (exception instanceof AlarmException) {
                throw (AlarmException)((Object)exception);
            }
            throw new AlarmException(exception);
        }
    }

    public Cursor doBqlQuery(BqlQuery bqlQuery) throws IOException, AlarmException {
        try {
            return this.getChannel().bqlQuery(bqlQuery);
        }
        catch (Exception exception) {
            throw new AlarmException(exception);
        }
    }

    public Cursor getAlarmsForSource(BOrdList bOrdList) {
        throw new UnsupportedOperationException();
    }

    public Cursor getOpenAlarms() {
        throw new UnsupportedOperationException();
    }

    public Cursor getAckPendingAlarms() {
        throw new UnsupportedOperationException();
    }

    public BObject bqlQuery(BOrd bOrd) {
        try {
            return this.getChannel().resolve(bOrd);
        }
        catch (Exception exception) {
            if (exception instanceof AlarmException) {
                throw (AlarmException)((Object)exception);
            }
            throw new AlarmException(exception);
        }
    }

    public void clearAllRecords(Context context) throws IOException {
        try {
            this.getChannel().clearAllRecords();
        }
        catch (Exception exception) {
            if (exception instanceof AlarmException) {
                throw (AlarmException)((Object)exception);
            }
            throw new AlarmException(exception);
        }
    }

    public void clearOldRecords(BAbsTime bAbsTime, Context context) throws IOException {
        try {
            this.getChannel().clearOldRecords(bAbsTime);
        }
        catch (Exception exception) {
            if (exception instanceof AlarmException) {
                throw (AlarmException)((Object)exception);
            }
            throw new AlarmException(exception);
        }
    }

    public void clearRecord(BUuid bUuid, Context context) throws IOException {
        try {
            this.getChannel().clearRecord(bUuid);
        }
        catch (Exception exception) {
            if (exception instanceof AlarmException) {
                throw (AlarmException)((Object)exception);
            }
            throw new AlarmException(exception);
        }
    }

    public Type getType() {
        return TYPE;
    }

    static /* synthetic */ Class class(String string, boolean bl) {
        try {
            Class<?> clazz = Class.forName(string);
            if (!bl) {
                clazz = clazz.getComponentType();
            }
            return clazz;
        }
        catch (ClassNotFoundException classNotFoundException) {
            throw new NoClassDefFoundError(classNotFoundException.getMessage());
        }
    }

    public BFoxAlarmDatabase(BFoxSession bFoxSession) {
        this.session = bFoxSession;
    }

    static {
        Class clazz = class$com$tridium$alarm$fox$BFoxAlarmDatabase;
        if (clazz == null) {
            clazz = class$com$tridium$alarm$fox$BFoxAlarmDatabase = BFoxAlarmDatabase.class("[Lcom.tridium.alarm.fox.BFoxAlarmDatabase;", false);
        }
        TYPE = Sys.loadType((Class)clazz);
    }
}