var sys = require('util');

var Client = require('mysql').Client;
var client = new Client();

client.user = 'root';
client.password = 'root';
client.host = 'localhost';
client.port = '8889';



ClientConnectionReady = function(client)
{
	client.query('USE joomla17stable', function(error, results) {
		if(error) {
			console.log('ClientConnectionReady Error: ' + error.message);
			client.end();
			return;
		} else {
      console.log('Connected to MySQL');
    }
	});
};

ClientConnectionReady(client);

list_events = function(req, res)
{
  client.query('SELECT * FROM ndpg5_ohanah_events', function(error, results, fields) {
    if (error) {
      console.log('GetData Error: ' + error.message);
      client.end();
      return;
    }

    res.json(results);
  });
};

read_event = function(req, res)
{
  client.query('SELECT * FROM ndpg5_ohanah_events WHERE ohanah_event_id = '+req.params.id, function(error, results, fields) {
    if (error) {
      console.log('GetData Error: ' + error.message);
      client.end();
      return;
    }

    res.json(results);
  });
};

delete_event = function(req, res)
{
  var event_id = req.params.id;


  if (event_id && event_id != 0) {
    client.query('DELETE FROM ndpg5_ohanah_events WHERE ohanah_event_id = '+req.params.id, function(error, results, fields) {
      if (error) {
        console.log('GetData Error: ' + error.message);
        client.end();
        return;
      }

      if (results.affectedRows != 0) {
        res.send('OK', 200);
      } else {
        res.send('Event not found', 404);
      }

    });
  } else {
    res.send('Please provide a valid event id', 400);
  }
};

var app = require('express').createServer();

// List
app.get('/events', list_events);

// Create
//app.post('/events', create_event);

// Read
app.get('/events/:id?', read_event);

// Update
//app.put('/events/:id?', update_event);

// Delete
app.del('/events/:id?', delete_event);

app.listen(8887);





// var auth = exports.auth = {
//   username: 'admin',
//   password: 'password',
//   basicAuth: function (request, body, callback) {
//     var realm = "Authorization Required",
//         authorization = request.headers.authorization;

//     if (!authorization) {
//       return callback(new journey.NotAuthorized("Authorization header is required."));
//     }

//     var parts       = authorization.split(" "),           // Basic salkd787&u34n=
//         scheme      = parts[0],                           // Basic
//         credentials = base64.decode(parts[1]).split(":"); // admin:password

//     if (scheme !== "Basic") {
//       return callback(new journey.NotAuthorized("Authorization scheme must be 'Basic'"));
//     }
//     else if(!credentials[0] && !credentials[1]){
//       return callback(new journey.NotAuthorized("Both username and password are required"));
//     }
//     else if(credentials[0] !== auth.username || credentials[1] !== auth.password) {
//       return callback(new journey.NotAuthorized("Invalid username or password"));
//     }

//     // Respond with no error if username and password match
//     callback(null);
//   }
// };