import { Outbound } from './SLMessage';
import { ChemMessage, ChlorMessage, CircuitMessage, ConnectionMessage, EquipmentStateMessage, HeaterMessage, LightCommands, PumpMessage, ScheduleMessage, UnitConnection } from '../index';
import { EquipmentConfigurationMessage, rawData } from './config/EquipmentConfig';

export class Commands extends Outbound {
  protected unit: UnitConnection;
  constructor(unit: UnitConnection, senderId?: number) {
    super(unit.controllerId, senderId ?? unit.senderId);
    this.unit = unit;
  }
}

export class ConnectionCommands extends Commands {
  public sendLoginMessage(password?: Buffer, senderId?: number): ConnectionCommands {
    this.action = ConnectionMessage.ResponseIDs.Login - 1;
    this.createBaseMessage(senderId);
    // this.addHeader(this.senderId, this.messageId)
    this.writeInt32LE(348); // schema
    this.writeInt32LE(0); // connection type
    this.writeSLString('node-screenlogic'); // version

    if (!password) {
      password = Buffer.alloc(16);
    }
    if (password.length > 16) {
      password = password.slice(0, 16);
    }
    this.writeSLArray(password); // encoded password. empty/unused for local connections

    this.writeInt32LE(2); // procID
    this.unit.write(this.toBuffer());
    return this;
  }

  public sendChallengeMessage(senderId?: number): ConnectionCommands {
    this.action = ConnectionMessage.ResponseIDs.Challenge - 1;
    this.createBaseMessage(senderId);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendVersionMessage(senderId?: number): ConnectionCommands {
    this.action = ConnectionMessage.ResponseIDs.Version - 1;
    this.createBaseMessage(senderId);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendAddClientMessage(clientId?: number, senderId?: number): ConnectionCommands {
    this.action = ConnectionMessage.ResponseIDs.AddClient - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(this.unit.controllerId);
    this.writeInt32LE(clientId ?? this.unit.clientId);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendRemoveClientMessage(clientId?: number, senderId?: number): ConnectionCommands {
    this.action = ConnectionMessage.ResponseIDs.RemoveClient - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(this.unit.controllerId);
    this.writeInt32LE(clientId ?? this.unit.clientId);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendPingMessage(senderId?: number): ConnectionCommands {
    this.action = ConnectionMessage.ResponseIDs.Ping - 1;
    this.createBaseMessage(senderId);
    this.unit.write(this.toBuffer());
    return this;
  }
}


export class EquipmentCommands extends Commands {
  public sendGetEquipmentStateMessage(senderId?: number): EquipmentCommands {
    this.action = EquipmentStateMessage.ResponseIDs.EquipmentState - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(0);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendGetControllerConfigMessage(senderId?: number): EquipmentCommands {
    this.action = EquipmentConfigurationMessage.ResponseIDs.GetControllerConfig - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(0);
    this.writeInt32LE(0);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendGetNumCircuitNamesMessage(senderId?: number): EquipmentCommands {
    this.action = EquipmentConfigurationMessage.ResponseIDs.NumCircuitNames - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(0);
    this.writeInt32LE(0);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendGetCircuitNamesMessage(idx: number, cnt: number, senderId?: number): EquipmentCommands {
    this.action = EquipmentConfigurationMessage.ResponseIDs.GetCircuitNames;
    this.createBaseMessage(senderId);
    this.writeInt32LE(0);
    this.writeInt32LE(idx);
    this.writeInt32LE(cnt);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendGetCircuitDefinitionsMessage(senderId?: number): EquipmentCommands {
    this.action = EquipmentConfigurationMessage.ResponseIDs.GetCircuitDefinitions - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(0);
    this.writeInt32LE(0);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendGetEquipmentConfigurationMessage(senderId?: number): EquipmentCommands {
    this.action = EquipmentConfigurationMessage.ResponseIDs.GetEquipmentConfiguration - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(0);
    this.writeInt32LE(0);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendSetEquipmentConfigurationMessageAsync(data: rawData, senderId?: number): EquipmentCommands {
    this.action = EquipmentConfigurationMessage.ResponseIDs.SetEquipmentConfiguration; //setequipconfg
    this.createBaseMessage(senderId);
    this.writeInt32LE(0);
    this.writeInt32LE(0);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendGetSystemTimeMessage(senderId?: number): EquipmentCommands {
    this.action = EquipmentStateMessage.ResponseIDs.SystemTime - 1;
    this.createBaseMessage(senderId);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendCancelDelayMessage(senderId?: number): EquipmentCommands {
    this.action = EquipmentStateMessage.ResponseIDs.CancelDelay - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(0);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendGetCustomNamesMessage(senderId?: number): EquipmentCommands {
    this.action = EquipmentConfigurationMessage.ResponseIDs.GetCustomNamesAck - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(0);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendSetCustomNameMessage(idx: number, name: string, senderId?: number): EquipmentCommands {
    this.action = EquipmentConfigurationMessage.ResponseIDs.SetCustomNameAck - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(this.controllerId);
    this.writeInt32LE(idx);
    this.writeSLString(name);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendGetWeatherMessage(senderId?: number): EquipmentCommands {
    this.action = EquipmentConfigurationMessage.ResponseIDs.WeatherForecastAck - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(0);
    this.writeInt32LE(0);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendSetSystemTimeMessage(date: Date, shouldAdjustForDST: boolean, senderId?: number): EquipmentCommands {
    this.action = EquipmentStateMessage.ResponseIDs.SetSystemTime - 1;
    this.createBaseMessage(senderId);
    this.writeSLDateTime(date);
    this.writeInt32LE(shouldAdjustForDST ? 1 : 0);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendGetHistoryMessage(fromTime: Date, toTime: Date, senderId?: number): EquipmentCommands {
    this.action = EquipmentConfigurationMessage.ResponseIDs.HistoryDataPending - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(this.controllerId);
    this.writeSLDateTime(fromTime);
    this.writeSLDateTime(toTime);
    this.writeInt32LE(senderId ?? this.senderId);
    this.unit.write(this.toBuffer());
    return this;
  }
}

export class CircuitCommands extends Commands {
  public sendSetCircuitMessage(circuitId: number, nameIndex: number, circuitFunction: number, circuitInterface: number, freeze: boolean, colorPos: number, senderId?: number): CircuitCommands {
    this.action = CircuitMessage.ResponseIDs.SetCircuitInfo - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(this.controllerId);
    this.writeInt32LE(circuitId + 499);
    // normalize to 1 based ids for default names; 100 based for custom names
    // circuitArray[i].nameIndex = circuitArray[i].nameIndex < 101 ? circuitArray[i].nameIndex + 1 : circuitArray[i].nameIndex + 99;
    this.writeInt32LE(nameIndex < 102 ? nameIndex - 1 : nameIndex - 99);
    this.writeInt32LE(circuitFunction);
    this.writeInt32LE(circuitInterface);
    this.writeInt32LE(freeze ? 1 : 0); // could be other bits; this is a flag
    this.writeInt32LE(colorPos);
    this.encode();
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendSetCircuitStateMessage(circuitId: number, circuitState: boolean, senderId?: number): CircuitCommands {
    this.action = CircuitMessage.ResponseIDs.SetCircuitState - 1;
    this.createBaseMessage(senderId);
    // this.addHeader(this.senderId, this.messageId);
    // this._controllerId = controllerId;
    this.writeInt32LE(this.controllerId);
    this.writeInt32LE(circuitId + 499);
    this.writeInt32LE((circuitState ? 1 : 0) || 0);
    this.encode();
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendIntellibriteMessage(command: LightCommands, senderId?: number): CircuitCommands {
    this.action = CircuitMessage.ResponseIDs.SetLightState - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(this.unit.controllerId);
    this.writeInt32LE(command || 0);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendSetCircuitRuntimeMessage(circuitId: number, runTime: number, senderId?: number): CircuitCommands {
    this.action = CircuitMessage.ResponseIDs.SetCircuitRunTime - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(this.unit.controllerId);
    this.writeInt32LE(circuitId + 499);
    this.writeInt32LE(runTime);
    this.unit.write(this.toBuffer());
    return this;
  }
}
export class ChlorCommands extends Commands {
  public sendSetChlorOutputMessage(poolOutput: number, spaOutput: number, senderId?: number): ChlorCommands {
    this.action = ChlorMessage.ResponseIDs.SetIntellichlorConfig - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(this.unit.controllerId);
    this.writeInt32LE(poolOutput || 0);
    this.writeInt32LE(spaOutput || 0);
    this.writeInt32LE(0);
    this.writeInt32LE(0);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendGetSaltCellConfigMessage(senderId?: number): ChlorCommands {
    this.action = ChlorMessage.ResponseIDs.GetIntellichlorConfig - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(this.unit.controllerId);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendSetSaltCellEnableMessage(isActive?: boolean, senderId?: number): ChlorCommands {
    this.action = ChlorMessage.ResponseIDs.SetIntellichlorEnabled - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(this.unit.controllerId);
    this.writeInt32LE(isActive ? 1 : 0);
    this.unit.write(this.toBuffer());
    return this;
  }
}
export class ChemCommands extends Commands {
  public sendGetChemStatusMessage(senderId?: number): ChemCommands {
    this.action = ChemMessage.ResponseIDs.GetChemicalData - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(0);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendGetChemHistoryMessage(fromTime: Date, toTime: Date, senderId?: number): ChemCommands {
    this.action = ChemMessage.ResponseIDs.HistoryDataPending - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(0);
    this.writeSLDateTime(fromTime);
    this.writeSLDateTime(toTime);
    this.writeInt32LE(senderId ?? this.senderId);
    this.unit.write(this.toBuffer());
    return this;
  }
}
export class BodyCommands extends Commands {
  public sendSetPointMessage(bodyType: number, temperature: number, senderId?: number): BodyCommands {
    this.action = HeaterMessage.ResponseIDs.SetHeatSetPoint - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(this.unit.controllerId);
    this.writeInt32LE(bodyType || 0);
    this.writeInt32LE(temperature || 0);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendCoolSetPointMessage(bodyType: number, temperature: number, senderId?: number): BodyCommands {
    this.action = HeaterMessage.ResponseIDs.SetCoolSetPoint - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(this.unit.controllerId);
    this.writeInt32LE(bodyType || 0);
    this.writeInt32LE(temperature || 0);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendHeatModeMessage(bodyType: number, heatMode: number, senderId?: number): BodyCommands {
    this.action = HeaterMessage.ResponseIDs.SetHeatMode - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(this.unit.controllerId);
    this.writeInt32LE(bodyType || 0);
    this.writeInt32LE(heatMode || 0);
    this.unit.write(this.toBuffer());
    return this;
  }
}
export class ScheduleCommands extends Commands {
  public sendGetSchedulesMessage(schedType: number, senderId?: number): ScheduleCommands {
    this.action = ScheduleMessage.ResponseIDs.GetSchedule - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(0);
    this.writeInt32LE(schedType);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendAddScheduleEventMessage(schedType: number, senderId?: number): ScheduleCommands {
    this.action = ScheduleMessage.ResponseIDs.AddSchedule - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(0);
    this.writeInt32LE(schedType);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendDeleteScheduleEventMessage(schedId: number, senderId?: number): ScheduleCommands {
    this.action = ScheduleMessage.ResponseIDs.DeleteSchedule - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(this.controllerId);
    this.writeInt32LE(schedId + 699);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendSetScheduleEventMessage(scheduleId: number, circuitId: number, startTime: number, stopTime: number, dayMask: number, flags: number, heatCmd: number, heatSetPoint: number, senderId?: number): ScheduleCommands {
    this.action = ScheduleMessage.ResponseIDs.SetSchedule - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(0);
    this.writeInt32LE(scheduleId + 699);
    this.writeInt32LE(circuitId + 499);
    this.writeInt32LE(startTime);
    this.writeInt32LE(stopTime);
    this.writeInt32LE(dayMask);
    this.writeInt32LE(flags);
    this.writeInt32LE(heatCmd);
    this.writeInt32LE(heatSetPoint);
    this.unit.write(this.toBuffer());
    return this;
  }
}
export class PumpCommands extends Commands {
  public sendGetPumpStatusMessage(pumpId: number, senderId?: number): PumpCommands {
    this.action = PumpMessage.ResponseIDs.PumpStatus - 1;
    this.createBaseMessage(senderId);
    this.writeInt32LE(this.controllerId);
    this.writeInt32LE(pumpId - 1);
    this.unit.write(this.toBuffer());
    return this;
  }
  public sendSetPumpSpeed(pumpId: number, circuitId: number, speed: number, isRPMs?: boolean, senderId?: number): PumpCommands {
    this.action = PumpMessage.ResponseIDs.SetPumpSpeed - 1;
    if (typeof isRPMs === 'undefined') {
      if (speed < 400) { isRPMs = false; }
      else isRPMs = true;
    }
    const _isRPMs = isRPMs ? 1 : 0;
    this.createBaseMessage(senderId);
    this.writeInt32LE(this.controllerId);
    this.writeInt32LE(pumpId - 1);
    this.writeInt32LE(circuitId); // This is indexed to the array of circuits returned in GetPumpStatus
    this.writeInt32LE(speed);
    this.writeInt32LE(_isRPMs);
    this.unit.write(this.toBuffer());
    return this;
  }
}
export class OutboundGateway extends Outbound {
  public createSendGatewayMessage(systemName: string, senderId?: number): Buffer {
    this.action = ConnectionMessage.ResponseIDs.GatewayResponse - 1;
    this.createBaseMessage(senderId);
    this.writeSLString(systemName);
    this.writeSLString(systemName);
    return this.toBuffer();
  }
}