script.thyme

_ackfile = "ack.txt";
_infile = "input.txt";
_outfile = "output.txt";
_lastline = -1;
_pollEvery = 15;
_currentLine = "";
_currentCmd = "";
_currentSeq = 0;
_currentSplit = [];
_parsedCmd = "";
_init = false;

onSpawn = (e)=> {
  Sim.running = true;
  scene.my.marblecount = 10;
};

postStep = (e) => {
  e.this._init ? {} : {
      scene.my._outfile = e.this._outfile;
      scene.my._eventCount = 0;
      scene.my.sendEvent = (type, params) => {
          line := "" + scene.my._eventCount + " " + type + " " + math.toString(params);
          System.WriteToFile(scene.my._outfile, line + "\n");
          scene.my._eventCount = scene.my._eventCount + 1;
      };
      e.this._init = true;
  };

  ((Sim.tick % e.this._pollEvery) == 0) ? {
      e.this._pollCommands(e.this);
  } : {};
};

_pollCommands = (e) => {
    t = System.ReadWholeFile(e._infile);
    (t == nil) ? {} : {
        lines = string.split(t, "\n");
        for(string.length(lines), (i) => {
            (string.length(lines(i)) == 0) ? {} : {
                e._currentLine = lines(i);
                e._readLine(e);
            };
        })
    }
};

_readLine = (e) => {
    split = string.split(e._currentLine, " ");
    e._currentSplit = split;
    seq = math.toInt(split(0));
    cmd = split(1);
    e._currentSeq = seq;
    e._currentCmd = cmd;

    (e._lastline >= seq) ? {} : {
        (e._currentCmd == "PING") ? {
            e._executePingCmd(e);
        } : {};

        (e._currentCmd == "PRINT") ? {
            e._executePrintCmd(e);
        } : {};

        (e._currentCmd == "EVAL") ? {
            e._executeEvalCmd(e);
        } : {};

        (e._currentCmd == "RESET") ? {
            e._executeResetCmd(e);
        } : {
            e._ackCmd(e);
        };
    }
};

_executePrintCmd = (e) => {
    print(e._currentSplit(2));
};

_executePingCmd = (e) => {
    print("received PING");
};

_executeEvalCmd = (e) => {
  parts = e._currentSplit;
  n = string.length(parts);
  start = 2;
  cmd = "";

  joinChunks = (from) => {
    remaining = n - from;
    (remaining <= 0) ? {} : {
      chunk = (remaining < 50) ? remaining : 50;
      for(chunk, (i) => {
        tok = parts(from + i);
        cmd = (string.length(cmd) == 0) ? tok : cmd + " " + tok;
      });
      ((from + chunk) < n) ? { joinChunks(from + chunk); } : {};
    }();
  };

  joinChunks(start);
  e._parsedCmd = cmd;
  print("received command: " + cmd);
  geval(cmd);
};

_executeResetCmd = (e) => {
    print("reset");
    seq = e._currentSeq;
    scene.my._eventCount = 0;
    System.WriteToFile(e._ackfile, "" + seq + "\n");
    e._lastline = -1;
};

_ackCmd = (e) => {
    seq = e._currentSeq;
    System.WriteToFile(e._ackfile, "" + seq + "\n");
    e._lastline = seq;
};