!7

concept ALine {
  S token;
  S line;
}

concept ALineToSend > ALine {
}

concept AIncomingLine > ALine {
}

concept AAction > ALine {
  bool verified;
}

cmodule AssistantWebServer > DynPrintLog {
  int httpPort = 8083, interval = 200;
  
  start-thread {
    logModuleOutput();
    dm_serveHttpFromFunction(httpPort, func(S uri, SS params) {
      if (eq(uri, "/register"))
        ret serveText((S) dm_call(dm_assistant_usersCRUD(), 'registerUser, params.get('email), params.get('pwHash)));

      if (eq(uri, "/checkPW")) {
        S mail = params.get('email);
        if (!isValidEmailAddress(mail))
          ret serveText("Not a valid email address");
        S userID = cast dm_call(dm_assistant_usersCRUD(), 'userIDForEmail, mail);
        if (userID == null)
          ret serveText("User not found");
        bool ok = cast dm_call(dm_assistant_passwordsCRUD(), 'checkPassword, userID, params.get('pwHash));
        ret serveText(ok ? "OK" : "Wrong password");
      }

      // token-based
      
      S token = params.get('token);
      
      if (eq(uri, "/poll") && l(token) == 24) {
        ret serveLongPoll(timeout, interval, func {
          S text = withDBLock(func -> S {
            L<ALineToSend> l = conceptsWhere(ALineToSend, +token);
            if (empty(l)) null;
            deleteConcepts(l);
            S text = lines_rtrim(collect line(sortConceptsByID(l)));
            ret text;
          });
          printWithTime("Served output to " + token + ": " + text);
          ret text;
        });
      }
      
      if (eq(uri, "/heard") && l(token) == 24) {
        S line = params.get('line);
        if (nempty(line))
          cnew/*_sync*/(AIncomingLine, +token, +line);
        ret "OK";
      }

      ret serveText("hä");
    });
  }
}