(async function() {
  var conn = await r.connect(config.database);

  try {
    await r.dbCreate(config.database.db).run(conn);
    await r.tableCreate("messages").run(conn);
    await r.table("messages").indexCreate("time").run(conn);
  }
  catch (err) {
    if (err.message.indexOf("already exists") < 0)
      console.log(err.message);
  }

  (await r.table("messages").changes().run(conn)).each((err, item) => {
    if (item && item.new_val)
      io.sockets.emit("message", item.new_val);
  });
})();

 .finally(() => {
     return r.tableCreate("users").run(conn);
 }).finally(() => {

 function (tableExists) {
     return r.branch(tableExists, { created: 0 }, r.tableCreate('users', { primaryKey: 'global_client_id' }));
 }