/*
 *  rhrdweb
 *
 *  Copyright (C) 2016 Christian Pointner <equinox@helsinki.at>
 *
 *  This file is part of rhrdweb.
 *
 *  rhrdweb is free software: you can redistribute it and/or modify
 *  it under the terms of the GNU Affero General Public License as published by
 *  the Free Software Foundation, either version 3 of the License, or
 *  any later version.
 *
 *  rhrdweb is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU Affero General Public License for more details.
 *
 *  You should have received a copy of the GNU Affero General Public License
 *  along with rhrdweb. If not, see <http://www.gnu.org/licenses/>.
 */

'use strict';

function Rhctl() {
  this.draw_callbacks = $.Callbacks('unique');
  this.state = 'NEW';

  this.sock_onmessage = function(event) {
    var msg = JSON.parse(event.data);
    if (msg.RESPONSE_CODE != 200) {
      console.log("got error message: ", event.data)
    } else {
      switch(msg.TYPE) {
      case 'state':
        this.draw_callbacks.fireWith(window, [ msg.STATE ]);
        break;
      case 'ack':
        break;
      default:
        console.log("rhctl: got unexpected message type '" + msg.TYPE + "'")
      }
    }
  }

  this.addCallback = function(cb) {
    this.draw_callbacks.add(cb);
  }

  this.sock_onopen = function() {
    this.state = 'CONNECTED';
    console.log('rhctl: ' + this.state)
    this.sock.onmessage = this.sock_onmessage.bind(this);
    this.sock.send(JSON.stringify({ COMMAND: 'subscribe', ARGS: [ 'state' ] }));
    this.sock.send(JSON.stringify({ COMMAND: 'state' }));
  }

  this.sock_onclose = function(event) {
    this.sock.close();
    delete this.sock;
    setTimeout(this.connect.bind(this), 1000);
    this.state = 'RECONNECTING';
    console.log('rhctl: ' + this.state)
  }

  this.connect = function() {
    this.sock = new WebSocket('wss://' + window.location.host + '/rhctl/socket');
    this.sock.onopen = this.sock_onopen.bind(this);
    this.sock.onclose = this.sock_onclose.bind(this);
    this.state = 'CONNECTING';
    console.log('rhctl: ' + this.state)
  }
}

var rhctl = new Rhctl();

function rhctl_init() {
  rhctl.connect();
  $('#rhctlraw').text("loading...");
  rhctl.addCallback(rhctl_draw_state);
}

function rhctl_draw_state(state) {
  $('#rhctlraw').text(JSON.stringify(state, null, '\t'));

  var mood = $('<img>').attr('src', '/img/mood-' + state.Mood + '.png');
  if(state.Settled) {
    mood.attr('title', state.Mood);
  } else {
    mood.addClass('blink').attr('title', state.Mood + ' (Settling)');
  }
  $('#rhctlmood').empty().append(mood);

  var srv = $('<span>').addClass('label').text(state.ActiveServer);
  switch(state.ActiveServer) {
  case 'master':
    srv.addClass('label-success');
    break;
  case 'standby':
    srv.addClass('label-warning');
    break;
  default:
    if(!state.ActiveServer) {
      srv.text('none');
    }
    srv.addClass('label-default');
  }
  $('#rhctlactiveserver').empty().append($('<h1>').append(srv));
}