mORMot Open Source

program Test;

{$APPTYPE CONSOLE}

uses
  {$I SynDprUses.inc}  // use FastMM4 on older Delphi, or set FPC threads
  SynCommons,
  mORMot;

type
  TSQLMyRec = class(TSQLRecord)
  private
    fGroupId: string;
    fProp: string;
  published
    property GroupId: string read fGroupId write fGroupId;
    property Prop: string read fProp write fProp;
  end;

var
  aModel: TSQLModel;
  aRestServer: TSQLRestServer;
  sTemp: RawUTF8;

begin

  aModel := TSQLModel.Create([TSQLMyRec]);
  try
    aRestServer := TSQLRestServerFullMemory.Create(aModel);
    try
      aRestServer.AddSimple(TSQLMyRec, ['TA_FK', 'SomeValue']);
      aRestServer.AddSimple(TSQLMyRec, ['TA_SPEDYTOR', 'SomeValue']);

      writeln(aRestServer.RetrieveListJSON(TSQLMyRec, ''));
      sTemp := aRestServer.OneFieldValues(TSQLMyRec, 'GroupId', FormatUTF8('Prop=:(%):', ['SomeValue']));
      writeln(sTemp);
      writeln;

      writeln('Press [Enter] to close.');
      readln;
    finally
      aRestServer.Free;
    end;
  finally
    aModel.Free;
  end;

end. 

[
{"RowID":1,"GroupId":"TA_FK","Prop":"SomeValue"},
{"RowID":2,"GroupId":"TA_SPEDYTOR","Prop":"SomeValue"}]

TA_FK  ,TA_SP

Press [Enter] to close.

{"notify": "event_test", "alert": null}

{"notify": {"event": "TEST", "timestamp": "1532530174.872"}, "alert": null}

    var data = JSON.parse(this.responseText);
    var i = data.result.indexOf("+");
    //console.log("data.result: " + data.result);                        
    Client._instance.SessionID = parseInt(data.result.slice(0, i), 10);
    //console.log("sessionID: " + Client._instance.SessionID);                        
    Client._instance.SessionIDHexa8 = Client._instance.SessionID.toString(16);
    while (Client._instance.SessionIDHexa8.length < 8) {
        Client._instance.SessionIDHexa8 = '0' + Client._instance.SessionIDHexa8;
    }
    //console.log("SessionIDHexa8: " + Client._instance.SessionIDHexa8);
    Client._instance.loggedIn = true;
    Client._instance.SessionPrivateKey = Client._instance.crc32(Client._instance.PasswordHashHexa, Client._instance.crc32(data.result, 0));

    Client.prototype.signUrl = function (url) {
        if (Client._instance.loggedIn === true) {
            var Tix, Nonce, s, ss, d = new Date();
            Tix = d.getTime() - Client._instance.SessionTickCountOffset;
            Nonce = Tix.toString(16);
            while (Nonce.length < 8) {
                Nonce = '0' + Nonce;
            }
            if (Nonce.length > 8) {
                Nonce = Nonce.slice(Nonce.length - 8);
            }
            ss = Client._instance.crc32(url, Client._instance.crc32(Nonce, Client._instance.SessionPrivateKey)).toString(16);
            while (ss.length < 8) {
                ss = '0' + ss;
            }
            s = url.indexOf("?") === -1 ? url + '?session_signature=' : url + '&session_signature=';
            return s + Client._instance.SessionIDHexa8 + Nonce + ss;
        } else {
            return url;
        }
    };

    try
      fConnection.URI(Call,inType,fKeepAlive);
      break; // do not retry on transmission success, or asynchronous request
    except
      on E: Exception do begin
        Log(E);
        fConnection.Free;
        fConnection := nil;
        if Length(Call.OutBody) = 0 then                       // added
          Call.OutBody := TextToHttpBody(E.message);
        Call.OutStatus := HTTP_NOTIMPLEMENTED;                 //?
        if fForceTerminate then
          break;
      end; // will retry once (e.g. if connection broken)
    end;