dinoagw_bot.js.backup

const admins = ["dinoagw"];
const autostartProgramme = [
  "twitchChat",
  "more_dinoagw_bot",
  "hallo",
  "punkte",
  "duell",
  "rennen",
  "todo",
  "chatsync",
];
const DEBUG = false;

const channels = [
  "dinoagw"
//  , "lechtalnixe"
//  , "apexfabinatorxy"
//  , "smithhover"
];

const pwd = require('./Passwort.js');

const erlaubteProgramme = [
  
].concat(autostartProgramme);

const scriptname = "dinoagw_bot:";

const konstanten = require('./Konstanten.js');
const mariadb = require('mariadb');
const fork = require('child_process').fork;

const pool = mariadb.createPool({
     host: 'localhost', 
     user:'chatsync', 
     password: pwd.mariadb,
     database: 'db1',
     connectionLimit: 5
});

var kinder = {};
var prefixe = {};

for ( let iter in autostartProgramme ) {
  erzeuge( autostartProgramme[iter] );
}
kinder["twitchChat"].send({
  type: konstanten.starteTwitchChat,
  script: "dinoagw_bot",
  username: "dinoagw_bot",
  password: pwd.dinoagw_bot,
  channels: channels
});

var time = 0;
var anfragen = [];
setInterval(() => {
  time++;
  for (iter in anfragen) {
    if ( time >= anfragen[iter].time ) {
      let anfrage = anfragen[iter];
      anfragen.splice(iter, 1);
      iter--;
      anfrage.child.send(anfrage.nachricht);
    }
  }
}, 1000);

var geheimModus = false;

function empfange(target, context, msg) {
  var nachricht = msg.trim();
  var geheim = false;
  if (nachricht.startsWith("~")) {
    geheim = true;
    nachricht = nachricht.substring(1);
  }
  var isCommand = false;
  var befehl;
  var argument;
  var endeDesBefehls = nachricht.indexOf(" ");
  var prefix;
  if( endeDesBefehls == -1 ) {
    prefix = nachricht.toLowerCase();
    argument = "";
  } else {
    prefix = nachricht.slice(0, endeDesBefehls).toLowerCase();
    argument = nachricht.substring(prefix.length + 1);
  }
  let myPrefix = "!";
  if ( nachricht.startsWith(myPrefix) ) {
    isCommand = true;
    befehl = prefix.substring(myPrefix.length);
  }
  var username = context.username;
  var isStreamer = false;
  if ( "#" + username == target ) {
    isStreamer = true;
  }
  var isMod = context.mod;
  var isAdmin = admins.includes(username);

  for (var iter2 in prefixe ) {
    if ( prefixe[iter2].prefixe.includes(prefix) ) {
      prefixe[iter2].child.send({
        type: konstanten.befehl,
        prefix: prefix,
        argument: argument,
        target: target,
        username:  username,
        isSreamer: isStreamer,
        isMod: isMod,
        isAdmin: isAdmin
      });
    }
  }
  
  if ( isCommand ) {
    if ( befehl == "status" ) {
      let nachrichtToSend = "Hallo " + username + ". Du bist";
      if (!isStreamer) nachrichtToSend += " nicht";
      nachrichtToSend += " der Streamer dieses Kanals. Du bist"
      if (!isMod) nachrichtToSend += " nicht";
      nachrichtToSend += " Mod auf diesem Kanal. Du bist";
      if (!isAdmin) nachrichtToSend += " nicht";
      nachrichtToSend += " Admin des dinoagw_bot's."
      if ( argument != "" ) {
        nachrichtToSend += " Das Argument ist: '" + argument + "'.";
      }
      sende(target, nachrichtToSend);
    }
    
    if ( befehl == "starte:" && isAdmin ) {
      kinder[argument].send({
        type: konstanten.befehl,
        prefix: "!stop",
        argument: argument
      });
      delete kinder[argument];
      delete prefixe[argument];
      if ( erlaubteProgramme.includes(argument) ) {
        erzeuge( argument );
      } else {
        sende(target, "Das darf ich nich starten.");
      }
    }

    if ( befehl == "stoppe:" && isAdmin ) {
      kinder[argument].send({
        type: konstanten.befehl,
        prefix: "!stop",
        argument: argument
      });
      delete kinder[iter];
      delete prefixe[argument];
    }
    
    if ( befehl == "kinder:" && isAdmin ) {
      for ( var iter in kinder ) {
        kinder[iter].send({type: konstanten.nachricht, nachricht: argument});
        console.log(scriptname, "ausgegeben: ", {type: konstanten.nachricht, nachricht: argument});
      }
    }
    
    if ( befehl == "stop" && isAdmin ) {
      for ( var iter in kinder ) {
        kinder[iter].send({
          type: konstanten.befehl,
          prefix: "!stop",
          argument: argument
        });
      }
      kinder = {};
      prefixe = {};
    }
    
    if ( befehl == "geheimmodus" && isAdmin ) {
      geheimModus = !geheimModus;
      if ( geheimModus ) {
        sende( target, "Geheimmodus aktiviert." );
      } else {
        sende( target, "Geheimmodus deaktiviert." );
      }
    }
  }
}

function erzeuge(kind) {
  var program = `${__dirname}/${kind}.js`;
  var parameters = [];
  var options = {
    stdio: [ 'inherit', 'inherit', 'inherit', 'ipc' ]
  };
  var child = fork(program, parameters, options);
  child.on('message', async (message) => {
    if ( DEBUG ) console.log(scriptname, "Kind schreibt: ", message);
    if ( message.type == konstanten.sendeAnChat ) {
      sende(message.target, message.nachricht);
    }
    if ( message.type == konstanten.anwesend ) {
      prefixe[kind] = {
        child: child,
        prefixe: message.prefixe
      };
    }
    if ( message.type == konstanten.datenbankEingabe ) {
      let conn;
      let res;
      try {
        conn = await pool.getConnection();
        if ( DEBUG ) console.log(scriptname, "Datenbankeingabe: ", message.query, message.variables);
        res = await conn.query(message.query, message.variables);
        if ( DEBUG ) console.log(scriptname, "Datenbankeingabe ergab: ", res);
      } catch (err) {
        console.log(scriptname, "Datenbankanfrage fehlgeschlagen: ", message.query, " " , message.variables);
        throw err;
      } finally {
        if (conn) return conn.end();
      }
    }
    if ( message.type == konstanten.datenbankAbfrage ) {
      let conn;
      let res;
      if ( DEBUG ) console.log(scriptname, "Datenbankabfrage: ", message.query, message.variables);
      try {
        conn = await pool.getConnection();
        res = await conn.query(message.query, message.variables);
        if ( DEBUG ) console.log(scriptname, "Datenbankabfrage ergab: ", res);
        child.send({
          type: konstanten.datenbankAntwort,
          anfragenID: message.anfragenID,
          res: res
        });
      } catch (err) {
        console.log(scriptname, "Datenbankanfrage fehlgeschlagen: ", message.query, " " , message.variables);
        throw err;
      } finally {
        if (conn) return conn.end();
      }
    }
    if ( message.type == konstanten.erinnereMich ) {
      let anfrage = {
        time: time+message.time,
        child: child,
        nachricht: message.nachricht
      }
      anfragen.push(anfrage);
    }
    if ( message.type == konstanten.empfangeVonTwitchChat ) {
      console.log( scriptname, "empfangeVonTwitch", message.script, message.username, message.target, message.msg );
      if ( message.script == "dinoagw_bot" ) {
        empfange( message.target, message.context, message.msg );
      } else {
        kinder[message.script].send({
          type: konstanten.empfangeVonTwitchChat,
          script: message.script,
          username: message.username,
          target: message.target,
          context: message.context,
          msg: message.msg
        })
      }
    }
    if ( message.type == konstanten.starteTwitchChat ) {
      kinder["twitchChat"].send({
        type: konstanten.starteTwitchChat,
        script: message.script,
        username: message.username,
        password: message.password,
        channels: message.channels
      });
    }
    if ( message.type == konstanten.sendeAnTwitchChat ) {
      kinder["twitchChat"].send({
        type: konstanten.sendeAnTwitchChat,
        script: kind,
        username: message.username,
        target: message.target,
        nachricht: message.nachricht,
      });
    }
    if ( message.type == konstanten.joinTwitchChat ) {
      kinder["twitchChat"].send({
        type: konstanten.joinTwitchChat,
        script: message.script,
        username: message.username,
        target: message.target,
      });
    }
    if ( message.type == konstanten.partTwitchChat ) {
      kinder["twitchChat"].send({
        type: konstanten.partTwitchChat,
        script: message.script,
        username: message.username,
        target: message.target
      });
    }
  });
  child.on('error', (err) => {
    console.log(scriptname, kind + " gibt einen Fehler aus: " + err);
    delete kinder[kind];
    delete prefixe[kind];
  });
  kinder[kind] = child;
  return child;
}

function sende(target, nachricht) {
  if ( geheimModus ) {
    nachricht = "~" + nachricht;
  }
  kinder["twitchChat"].send({
    type: konstanten.sendeAnTwitchChat,
    script: "dinoagw_bot",
    username: "dinoagw_bot",
    target: target,
    nachricht: nachricht
  });
}