mprpc.pas

unit mpRPC;

{$mode objfpc}{$H+}

interface

uses
  Classes, SysUtils, mpgui, FPJSON, jsonparser,strutils, mpCoin, mpRed, mpBlock,nosodebug,
  nosogeneral, nosocrypto, nosounit, nosoconsensus, nosowallcon,nosopsos,nosonetwork,nosoblock,
  nosogvts,nosomasternodes;

Procedure SetRPCPort(LineText:string);
Procedure setRPCpassword(newpassword:string);
Procedure SetRPCOn();
Procedure SetRPCOff();

// *** RPC PARSE FUNCTIONS ***

function IsValidJSON (MyJSONstring:string):boolean;
Function GetJSONErrorString(ErrorCode:integer):string;
function GetJSONErrorCode(ErrorCode, JSONIdNumber:integer):string;
function GetJSONResponse(ResultToSend:string;JSONIdNumber:integer):string;
function ParseRPCJSON(jsonreceived:string):string;

function ObjectFromString(MyString:string): string;

function RPC_Restart(NosoPParams:string):string;
function RPC_Banned(NosoPParams:string):string;
function RPC_AddressBalance(NosoPParams:string):string;
function RPC_OrderInfo(NosoPParams:string):string;
function RPC_Blockinfo(NosoPParams:string):string;
function RPC_Mainnetinfo(NosoPParams:string):string;
function RPC_PendingOrders(NosoPParams:string):string;
function RPC_LockedMNs(NosoPParams:string):String;
function RPC_GetPeers(NosoPParams:string):string;
function RPC_BlockOrders(NosoPParams:string):string;
function RPC_Masternodes(NosoPParams:string):string;
function RPC_Blockmns(NosoPParams:string):string;
Function RPC_WalletBalance(NosoPParams:string):string;
function RPC_NewAddress(NosoPParams:string):string;
function RPC_NewAddressFull(NosoPParams:string):string;
Function RPC_ValidateAddress(NosoPParams:string):string;
Function RPC_SetDefault(NosoPParams:string):string;
Function RPC_GVTInfo(NosoPParams:string):string;
Function RPC_CheckCertificate(NosoPParams:string):string;
Function RPC_SubmitOrder(NosoPParams:string;waitresponse:boolean=false):string;
function RPC_SendFunds(NosoPParams:string):string;


implementation

Uses
  MasterPaskalForm,mpparser, mpDisk, mpProtocol;

// Sets RPC port
Procedure SetRPCPort(LineText:string);
var
  value : integer;
Begin
value := StrToIntDef(parameter(LineText,1),0);
if ((value <=0) or (value >65535)) then
   begin
   ToLog('console','Invalid value');
   end
else if Form1.RPCServer.Active then
   ToLog('console','Can not change the RPC port when it is active')
else
   begin
   RPCPort := value;
   ToLog('console','RPC port set to: '+IntToStr(value));
   S_AdvOpt := true;
   end;
End;

Procedure setRPCpassword(newpassword:string);
var
  counter : integer;
  oldpassword : string;
Begin
oldpassword := RPCPass;
trim(newpassword);
RPCPass := newpassword;
End;

// Turn on RPC server
Procedure SetRPCOn();
Begin
if not Form1.RPCServer.Active then
   begin
      TRY
      Form1.RPCServer.Bindings.Clear;
      Form1.RPCServer.DefaultPort:=RPCPort;
      Form1.RPCServer.Active:=true;
      G_Launching := true;
      G_Launching := false;
      ToLog('console','RPC server ENABLED');
      EXCEPT on E:Exception do
         begin
         ToLog('console','Unable to start RPC port');
         G_Launching := true;
         G_Launching := false;
         end;
      END; {TRY}
   end
else ToLog('console','RPC server already ENABLED');
End;

// Turns off RPC server
Procedure SetRPCOff();
Begin
if Form1.RPCServer.Active then
   begin
   Form1.RPCServer.Active:=false;
   ToLog('console','RPC server DISABLED');
   G_Launching := true;
   G_Launching := false;
   end
else ToLog('console','RPC server already DISABLED');
End;

// ***************************
// *** RPC PARSE FUNCTIONS ***
// ***************************

// Returns if a string is a valid JSON data
function IsValidJSON (MyJSONstring:string):boolean;
var
  MyData: TJSONData;
begin
result := true;
   Try
   MyData := GetJSON(MyJSONstring);
   Mydata.free;
   except on E:ejsonparser do
      result := false;
   end;
end;

// Returns the string of each error code
Function GetJSONErrorString(ErrorCode:integer):string;
Begin
if ErrorCode = 400 then result := 'Bad Request'
else if ErrorCode = 401 then result := 'Invalid JSON request'
else if ErrorCode = 402 then result := 'Invalid method'
else if ErrorCode = 407 then result := 'Send funds failed'
else if ErrorCode = 498 then result := 'Not authorized'
else if ErrorCode = 499 then result := 'Unexpected error'

{...}
else result := 'Unknown error code';
End;

// Returns a valid error JSON String
function GetJSONErrorCode(ErrorCode, JSONIdNumber:integer):string;
var
  JSONResultado,JSONErrorObj: TJSONObject;
Begin
  result := '';
JSONResultado := TJSONObject.Create;
JSONErrorObj  := TJSONObject.Create;
   TRY
   JSONResultado.Add('jsonrpc', TJSONString.Create('2.0'));
   JSONErrorObj.Add('code', TJSONIntegerNumber.Create(ErrorCode));
   JSONErrorObj.Add('message', TJSONString.Create(GetJSONErrorString(ErrorCode)));
   JSONResultado.Add('error',JSONErrorObj);
   JSONResultado.Add('id', TJSONIntegerNumber.Create(JSONIdNumber));
   EXCEPT ON E:Exception do
      ToLog('exceps',FormatDateTime('dd mm YYYY HH:MM:SS.zzz', Now)+' -> '+'Error on GetJSONErrorCode: '+E.Message)
   END; {TRY}
result := JSONResultado.AsJSON;
JSONResultado.Free;
End;

// Returns a valid response JSON string
function GetJSONResponse(ResultToSend:string;JSONIdNumber:integer):string;
var
  JSONResultado, Resultado: TJSONObject;
  paramsarray :  TJSONArray;
  myParams: TStringArray;
  counter : integer;
  Errored : boolean = false;
Begin
result := '';
paramsarray := TJSONArray.Create;
if length(ResultToSend)>0 then myParams:= ResultToSend.Split(' ');
JSONResultado := TJSONObject.Create;
   TRY
   JSONResultado.Add('jsonrpc', TJSONString.Create('2.0'));
   if length(myparams) > 0 then
      for counter := low(myParams) to high(myParams) do
         if myParams[counter] <>'' then
            begin
            paramsarray.Add(GetJSON(ObjectFromString(myParams[counter])));
            end;
   SetLength(MyParams, 0);
   JSONResultado.Add('result', paramsarray);
   JSONResultado.Add('id', TJSONIntegerNumber.Create(JSONIdNumber));
   EXCEPT ON E:Exception do
      begin
      result := GetJSONErrorCode(499,JSONIdNumber);
      JSONResultado.Free;
      paramsarray.Free;
      Errored := true;
      ToLog('exceps',FormatDateTime('dd mm YYYY HH:MM:SS.zzz', Now)+' -> '+'Error on GetJSONResponse: '+E.Message);
      end;
   END; {TRY}
if not errored then result := JSONResultado.AsJSON;
JSONResultado.Free;
End;

function ObjectFromString(MyString:string): string;
var
  resultado: TJSONObject;
  orderobject : TJSONObject;
  objecttype : string;
  blockorders, Newaddresses : integer;
  ordersarray : TJSONArray;
  counter : integer;
Begin
resultado := TJSONObject.Create;
MyString := StringReplace(MyString,#127,' ',[rfReplaceAll, rfIgnoreCase]);
objecttype := parameter(mystring,0);
if objecttype = 'test' then
   begin
   resultado.Add('result','testok');
   end
else if objecttype = 'banned' then
   begin
   resultado.Add('result','banned');
   end
else if objecttype = 'restart' then
   begin
   resultado.Add('result','True');
   end
else if objecttype = 'balance' then
   begin
   resultado.Add('valid',StrToBool(parameter(mystring,1)));
   resultado.Add('address', TJSONString.Create(parameter(mystring,2)));
   if parameter(mystring,3)='null' then resultado.Add('alias',TJSONNull.Create)
   else resultado.Add('alias',parameter(mystring,3));
   resultado.Add('balance', TJSONInt64Number.Create(StrToInt64(parameter(mystring,4))));
   resultado.Add('incoming', TJSONInt64Number.Create(StrToInt64(parameter(mystring,5))));
   resultado.Add('outgoing', TJSONInt64Number.Create(StrToInt64(parameter(mystring,6))));
   end
else if objecttype = 'orderinfo' then
   begin
   resultado.Add('valid',StrToBool(parameter(mystring,1)));
   if StrToBool(parameter(mystring,1)) then
      begin
      orderobject := TJSONObject.Create;
         orderobject.Add('orderid',parameter(mystring,2));
         orderobject.Add('timestamp',StrToInt64(parameter(mystring,3)));
         orderobject.Add('block',StrToInt64(parameter(mystring,4)));
         orderobject.Add('type',parameter(mystring,5));
         orderobject.Add('trfrs',StrToInt(parameter(mystring,6)));
         orderobject.Add('receiver',parameter(mystring,7));
         orderobject.Add('amount',StrToInt64(parameter(mystring,8)));
         orderobject.Add('fee',StrToInt64(parameter(mystring,9)));
         if parameter(mystring,10)='null' then orderobject.Add('reference',TJSONNull.Create)
         else orderobject.Add('reference',parameter(mystring,10));
         orderobject.Add('sender',parameter(mystring,11));
      resultado.Add('order',orderobject)
      end
   else resultado.Add('order',TJSONNull.Create)
   end
else if objecttype = 'blockinfo' then
   begin
   resultado.Add('valid',StrToBool(parameter(mystring,1)));
   resultado.Add('number',StrToIntDef(parameter(mystring,2),-1));
   resultado.Add('timestart',StrToInt64Def(parameter(mystring,3),-1));
   resultado.Add('timeend',StrToInt64Def(parameter(mystring,4),-1));
   resultado.Add('timetotal',StrToIntDef(parameter(mystring,5),-1));
   resultado.Add('last20',StrToIntDef(parameter(mystring,6),-1));
   resultado.Add('totaltransactions',StrToIntDef(parameter(mystring,7),-1));
   resultado.Add('difficulty',StrToIntDef(parameter(mystring,8),-1));
   resultado.Add('target',parameter(mystring,9));
   resultado.Add('solution',parameter(mystring,10));
   resultado.Add('lastblockhash',parameter(mystring,11));
   resultado.Add('nextdifficult',StrToIntDef(parameter(mystring,12),-1));
   resultado.Add('miner',parameter(mystring,13));
   resultado.Add('feespaid',StrToInt64Def(parameter(mystring,14),-1));
   resultado.Add('reward',StrToInt64Def(parameter(mystring,15),-1));
   resultado.Add('hash',parameter(mystring,16));
   end
else if objecttype = 'pendingorders' then
   begin
   counter := 1;
   ordersarray := TJSONArray.Create;
   while parameter(mystring,counter) <> '' do
      begin
      ordersarray.Add(parameter(mystring,counter));
      Inc(Counter);
      end;
   resultado.Add('pendings',ordersarray);
   end
else if objecttype = 'lockedmns' then
   begin
   counter := 1;
   ordersarray := TJSONArray.Create;
   while parameter(mystring,counter) <> '' do
      begin
      ordersarray.Add(parameter(mystring,counter));
      Inc(Counter);
      end;
   resultado.Add('lockedmns',ordersarray);
   end
else if objecttype = 'peers' then
   begin
   counter := 1;
   ordersarray := TJSONArray.Create;
   while parameter(mystring,counter) <> '' do
      begin
      ordersarray.Add(parameter(mystring,counter));
      Inc(Counter);
      end;
   resultado.Add('peers',ordersarray);
   end

else if objecttype = 'gvtinfo' then
   begin
   resultado.Add('available',StrToIntDef(parameter(mystring,1),0));
   resultado.Add('buy',StrToInt64Def(parameter(mystring,2),0));
   resultado.Add('sell',StrToInt64Def(parameter(mystring,3),0));
   end

else if objecttype = 'mainnetinfo' then
   begin
   resultado.Add('lastblock',StrToIntDef(parameter(mystring,1),0));
   resultado.Add('lastblockhash',parameter(mystring,2));
   resultado.Add('headershash',parameter(mystring,3));
   resultado.Add('sumaryhash',parameter(mystring,4));
   resultado.Add('pending',StrToInt(parameter(mystring,5)));
   resultado.Add('supply',StrToInt64Def(parameter(mystring,6),0));
   end
else if objecttype = 'blockorder' then
   begin
   resultado.Add('valid',StrToBool(parameter(mystring,1)));
   resultado.Add('block',StrToIntDef(parameter(mystring,2),-1));
   blockorders := StrToIntDef(parameter(mystring,3),0);
   ordersarray := TJSONArray.Create;
   if blockorders>0 then
      begin
      for counter := 0 to blockorders-1 do
         begin
         orderobject:=TJSONObject.Create;
         orderobject.Add('orderid',parameter(mystring,4+(counter*10)));
         orderobject.Add('timestamp',StrToIntDef(parameter(mystring,5+(counter*10)),0));
         orderobject.Add('block',StrToIntDef(parameter(mystring,6+(counter*10)),0));
         orderobject.Add('type',parameter(mystring,7+(counter*10)));
         orderobject.Add('trfrs',StrToIntDef(parameter(mystring,8+(counter*10)),0));
         orderobject.Add('receiver',parameter(mystring,9+(counter*10)));
         orderobject.Add('amount',StrToInt64Def(parameter(mystring,10+(counter*10)),0));
         orderobject.Add('fee',StrToIntDef(parameter(mystring,11+(counter*10)),0));
         orderobject.Add('reference',parameter(mystring,12+(counter*10)));
         orderobject.Add('sender',parameter(mystring,13+(counter*10)));
         ordersarray.Add(orderobject);
         end;
      end;
   resultado.Add('orders',ordersarray);
   end
else if objecttype = 'blockmns' then
   begin
   resultado.Add('valid',StrToBool(parameter(mystring,1)));
   resultado.Add('block',StrToIntDef(parameter(mystring,2),-1));
   resultado.Add('count',StrToIntDef(parameter(mystring,3),-1));
   resultado.Add('reward',StrToInt64Def(parameter(mystring,4),-1));
   resultado.Add('total',StrToInt64Def(parameter(mystring,5),-1));
   resultado.Add('addresses',parameter(mystring,6));
   end
else if objecttype = 'getmasternodes' then
   begin
   resultado.Add('block',StrToIntDef(parameter(mystring,1),-1));
   resultado.Add('count',StrToIntDef(parameter(mystring,2),-1));
   resultado.Add('nodes',parameter(mystring,3));
   end
else if objecttype = 'newaddressfull' then
   begin
   resultado.Add('hash',parameter(mystring,1));
   resultado.Add('public',parameter(mystring,2));
   resultado.Add('private',parameter(mystring,3));
   end
else if objecttype = 'newaddress' then
   begin
   //resultado.Add('valid',StrToBool(parameter(mystring,1)));
   Newaddresses := StrToIntDef(parameter(mystring,2),1);
   //resultado.Add('number',Newaddresses);
   ordersarray := TJSONArray.Create;
   for counter := 1 to Newaddresses do
      begin
      ordersarray.Add(parameter(mystring,2+counter));
      end;
   resultado.Add('addresses',ordersarray);
   end
else if objecttype = 'checkcertificate' then
   begin
   if parameter(mystring,1) = 'True' then
      begin
      resultado.Add('valid',true);
      resultado.Add('address',parameter(mystring,2));
      resultado.Add('signtime',StrToInt64(parameter(mystring,3)));
      end
   else resultado.Add('valid',False);
   end
else if objecttype = 'sendfunds' then
   begin
   if parameter(mystring,1) = 'ERROR' then
      begin
      resultado.Add('valid',false);
      resultado.add('result',StrToIntDef(parameter(mystring,2),-1));
      end
   else
      begin
      resultado.Add('valid',True);
      resultado.Add('result',parameter(mystring,1));
      end
   end
else if objecttype = 'islocaladdress' then
   begin
   resultado.Add('result',StrToBool(parameter(mystring,1)))
   end

else if objecttype = 'setdefault' then
   begin
   resultado.Add('result',StrToBool(parameter(mystring,1)))
   end

else if objecttype = 'walletbalance' then
   begin
   resultado.Add('balance',StrToInt64(parameter(mystring,1)))
   end
else if objecttype = 'submitorder' then
   begin
   resultado.Add('result',StrToBool(parameter(mystring,1)))
   end
else if objecttype = 'submitorderwr' then
   begin
   resultado.Add('result',StrToBool(parameter(mystring,1)));
   resultado.Add('response',StringReplace(parameter(mystring,2),'_',' ',[rfReplaceAll, rfIgnoreCase]))
   end;

result := resultado.AsJSON;
resultado.free;
End;

// Parses a incoming JSON string
function ParseRPCJSON(jsonreceived:string):string;
var
  jData : TJSONData;
  jObject : TJSONObject;
  method : string;
  params: TJSONArray;
  jsonID : integer;
  NosoPParams: String = '';
  counter : integer;
Begin
Result := '';
if not IsValidJSON(jsonreceived) then result := GetJSONErrorCode(401,-1)
else
   begin
   jData := GetJSON(jsonreceived);
      try
      jObject := TJSONObject(jData);
      method := jObject.Strings['method'];
      params := jObject.Arrays['params'];
      jsonid := jObject.Integers['id'];
      for counter := 0 to params.Count-1 do
         NosoPParams:= NosoPParams+' '+params[counter].AsString;
      NosoPParams:= Trim(NosoPParams);
      //ToLog('console',jsonreceived);
      //ToLog('console','NosoPParams: '+NosoPParams);
      if AnsiContainsStr(RPCBanned,Method) then method := 'banned';
      if method = 'test' then result := GetJSONResponse('test',jsonid)
      else if method = 'banned' then result := GetJSONResponse(RPC_Banned(NosoPParams),jsonid)
      else if method = 'restart' then result := GetJSONResponse(RPC_Restart(NosoPParams),jsonid)
      else if method = 'getaddressbalance' then result := GetJSONResponse(RPC_AddressBalance(NosoPParams),jsonid)
      else if method = 'getorderinfo' then result := GetJSONResponse(RPC_OrderInfo(NosoPParams),jsonid)
      else if method = 'getblocksinfo' then result := GetJSONResponse(RPC_Blockinfo(NosoPParams),jsonid)
      else if method = 'getmainnetinfo' then result := GetJSONResponse(RPC_Mainnetinfo(NosoPParams),jsonid)
      else if method = 'getpendingorders' then result := GetJSONResponse(RPC_PendingOrders(NosoPParams),jsonid)
      else if method = 'lockedmns' then result := GetJSONResponse(RPC_LockedMNs(NosoPParams),jsonid)
      else if method = 'getpeers' then result := GetJSONResponse(RPC_GetPeers(NosoPParams),jsonid)
      else if method = 'getblockorders' then result := GetJSONResponse(RPC_BlockOrders(NosoPParams),jsonid)
      else if method = 'getblockmns' then result := GetJSONResponse(RPC_BlockMNs(NosoPParams),jsonid)
      else if method = 'getmasternodes' then result := GetJSONResponse(RPC_Masternodes(NosoPParams),jsonid)
      else if method = 'getwalletbalance' then result := GetJSONResponse(RPC_WalletBalance(NosoPParams),jsonid)
      else if method = 'getnewaddress' then result := GetJSONResponse(RPC_NewAddress(NosoPParams),jsonid)
      else if method = 'getnewaddressfull' then result := GetJSONResponse(RPC_NewAddressFull(NosoPParams),jsonid)
      else if method = 'islocaladdress' then result := GetJSONResponse(RPC_ValidateAddress(NosoPParams),jsonid)
      else if method = 'setdefault' then result := GetJSONResponse(RPC_SetDefault(NosoPParams),jsonid)
      else if method = 'getgvtinfo' then result := GetJSONResponse(RPC_GVTInfo(NosoPParams),jsonid)
      else if method = 'sendfunds' then result := GetJSONResponse(RPC_SendFunds(NosoPParams),jsonid)
      else if method = 'checkcertificate' then result := GetJSONResponse(RPC_CheckCertificate(NosoPParams),jsonid)
      else if method = 'submitorder' then result := GetJSONResponse(RPC_SubmitOrder(NosoPParams),jsonid)
      else if method = 'submitorderwr' then result := GetJSONResponse(RPC_SubmitOrder(NosoPParams,true),jsonid)
      else result := GetJSONErrorCode(402,-1);
      Except on E:Exception do
         ToLog('exceps',FormatDateTime('dd mm YYYY HH:MM:SS.zzz', Now)+' -> '+'JSON RPC error: '+E.Message);
      end;
   jData.Free;
   end;
End;

// GET DATA FUNCTIONS

function RPC_Restart(NosoPParams:string):string;
var
  ThDirect  : TThreadDirective;
Begin
  ThDirect := TThreadDirective.Create(true,'rpcrestart');
  ThDirect.FreeOnTerminate:=true;
  ThDirect.Start;
  result := 'restart';
End;

function RPC_Banned(NosoPParams:string):string;
Begin
  Result := 'banned';
End;

function RPC_AddressBalance(NosoPParams:string):string;
var
  ThisAddress: string;
  counter : integer = 0;
  Balance, incoming, outgoing : int64;
  addalias : string = '';
  sumposition  : integer = 0;
  valid : string;
  LRecord : TSummaryData;
Begin
BeginPerformance('RPC_AddressBalance');
result := '';
if NosoPParams <> '' then
   begin
   Repeat
   ThisAddress := parameter(NosoPParams,counter);
   if ThisAddress<> '' then
      begin
      if IsValidHashAddress(ThisAddress) then sumposition := GetIndexPosition(ThisAddress,LRecord)
      else
         begin
         sumposition := GetIndexPosition(ThisAddress,LRecord,true);
         ThisAddress := LRecord.Hash;
         end;
      if ThisAddress <>'' then
         begin
         if sumposition<0 then
            begin
            balance :=-1;incoming := -1;outgoing := -1;
            addalias := 'null'; valid := 'false';
            end
         else
            begin
            Balance := GetAddressBalanceIndexed(ThisAddress);
            incoming := GetAddressIncomingpays(ThisAddress);
            outgoing := GetAddressPendingPays(ThisAddress);
            addalias := LRecord.Custom;
            if addalias = '' then addalias := 'null';
            valid := 'true';
            end;
         result := result+format('balance'#127'%s'#127'%s'#127'%s'#127'%d'#127'%d'#127'%d ',[valid,ThisAddress,addalias,balance,incoming,outgoing]);
         end;
      end;
   counter+=1;
   until ThisAddress = '';
   trim(result);
   end;
EndPerformance('RPC_AddressBalance');
End;

function RPC_OrderInfo(NosoPParams:string):string;
var
  thisOr : TOrderGroup;
  validID : string = 'true';
Begin
BeginPerformance('RPC_OrderInfo');
ToLog('events',TimeToStr(now)+'GetOrderDetails requested: '+NosoPParams);
NosoPParams := Trim(NosoPParams);
ThisOr := Default(TOrderGroup);
if NosoPParams='' then
   begin
   validID := 'false';
   result := format('orderinfo'#127'%s'#127'%s'#127+
                 '%d'#127'%d'#127'%s'#127+
                 '%d'#127'%s'#127'%d'#127+
                 '%d'#127'%s'#127'%s'#127,
                [validid,NosoPParams,
                thisor.timestamp,thisor.block,thisor.OrderType,
                thisor.OrderLines,thisor.Receiver,thisor.AmmountTrf,
                thisor.AmmountFee,thisor.reference,thisor.sender]);
   exit;
   end;
thisor := GetOrderDetails(NosoPParams);
if thisor.OrderID = '' then validID := 'false';
result := format('orderinfo'#127'%s'#127'%s'#127+
                 '%d'#127'%d'#127'%s'#127+
                 '%d'#127'%s'#127'%d'#127+
                 '%d'#127'%s'#127'%s'#127,
                [validid,NosoPParams,
                thisor.timestamp,thisor.block,thisor.OrderType,
                thisor.OrderLines,thisor.Receiver,thisor.AmmountTrf,
                thisor.AmmountFee,thisor.reference,thisor.sender]);
EndPerformance('RPC_OrderInfo');
End;

function RPC_Blockinfo(NosoPParams:string):string;
var
  thisblock : string;
  counter : integer = 0;
Begin
BeginPerformance('RPC_Blockinfo');
result := '';
if NosoPParams <> '' then
   begin
   Repeat
   thisblock := parameter(NosoPParams,counter);
   if thisblock <>''  then
      begin
      if ((StrToIntDef(thisblock,-1)>=0) and (StrToIntDef(thisblock,-1)<=MyLastblock)) then
         begin
         result := result+'blockinfo'#127'true'#127+GetBlockHeaders(StrToIntDef(thisblock,-1))+' ';
         end
      else result := result+'blockinfo'#127'false'#127+thisblock+#127'-1'#127'-1'#127'-1'#127'-1'#127'-1'#127'-1'#127'-1'#127'null'#127'null'#127'null'#127'-1'#127'null'#127'-1'#127'-1'#127'null ';
      end;
   counter+=1;
   until thisblock = '';
   trim(result);
   end;
EndPerformance('RPC_Blockinfo');
End;

function RPC_Mainnetinfo(NosoPParams:string):string;
Begin
BeginPerformance('RPC_Mainnetinfo');
result := format('mainnetinfo'#127'%s'#127'%s'#127'%s'#127'%s'#127'%s'#127'%d',
       [GetConsensus(2),Copy(GetConsensus(10),0,5),copy(GetConsensus(15),0,5),copy(GetConsensus(17),0,5),
       GetConsensus(3),GetSupply(StrToIntDef(GetConsensus(2),0))]);
EndPerformance('RPC_Mainnetinfo');
End;

function RPC_PendingOrders(NosoPParams:string):string;
var
  LData : String;
Begin
BeginPerformance('RPC_PendingOrders');
LData :=PendingRawInfo;
LData := StringReplace(LData,' ',#127,[rfReplaceAll, rfIgnoreCase]);
result := format('pendingorders'#127'%s',[LData]);
EndPerformance('RPC_PendingOrders');
End;

function RPC_LockedMNs(NosoPParams:string):String;
var
  LData : String;
Begin
  BeginPerformance('RPC_LockedMNs');
  LData := LockedMNsRawString;
  LData := StringReplace(LData,' ',#127,[rfReplaceAll, rfIgnoreCase]);
  result := format('lockedmns'#127'%s',[LData]);
  EndPerformance('RPC_LockedMNs');
End;

function RPC_GetPeers(NosoPParams:string):string;
var
  LData : String;
Begin
  BeginPerformance('RPC_GetPeers');
  LData := GetConnectedPeers;
  LData := StringReplace(LData,' ',#127,[rfReplaceAll, rfIgnoreCase]);
  result := format('peers'#127'%s',[LData]);
  EndPerformance('RPC_GetPeers');
End;

function RPC_BlockOrders(NosoPParams:string):string;
var
  blocknumber : integer;
  ArraTrxs : TBlockOrdersArray;
  counter : integer;
  Thisorderinfo : string;
  arrayOrds : array of TOrderGroup;

  Procedure AddOrder(order:TOrderData);
  var
    cont : integer;
    existed : boolean = false;
  begin
  if length(arrayOrds)>0 then
     begin
     for cont := 0 to length(arrayOrds)-1 do
        begin
        if arrayords[cont].OrderID = order.OrderID then
           begin
           arrayords[cont].AmmountTrf:=arrayords[cont].AmmountTrf+order.AmmountTrf;
           arrayords[cont].AmmountFee:=arrayords[cont].AmmountFee+order.AmmountFee;
           arrayords[cont].sender    :=arrayords[cont].sender+
              format('[%s,%d,%d]',[order.Address,order.AmmountTrf,order.AmmountFee]);
           arrayords[cont].OrderLines+=1;
           existed := true;
           break;
           end;
        end;
     end;
  if not Existed then
     begin
     setlength(arrayords,length(arrayords)+1);
     arrayords[length(arrayords)-1].OrderID:=order.OrderID;
     arrayords[length(arrayords)-1].TimeStamp:=order.TimeStamp;
     arrayords[length(arrayords)-1].Block:=order.Block;
     arrayords[length(arrayords)-1].OrderType:=order.OrderType;
     arrayords[length(arrayords)-1].OrderLines:=1;
     arrayords[length(arrayords)-1].Receiver:=order.Receiver;
     arrayords[length(arrayords)-1].AmmountTrf:=order.AmmountTrf;
     arrayords[length(arrayords)-1].AmmountFee:=order.AmmountFee;
     arrayords[length(arrayords)-1].Reference:=order.Reference;
     if order.OrderLines=1 then
        arrayords[length(arrayords)-1].sender:=order.sender
     else arrayords[length(arrayords)-1].sender:=arrayords[length(arrayords)-1].sender+
          format('[%s,%d,%d]',[order.Address,order.AmmountTrf,order.AmmountFee]);
     end;
  end;

Begin
BeginPerformance('RPC_BlockOrders');
result := '';
setlength(arrayOrds,0);
blocknumber := StrToIntDef(NosoPParams,-1);
if ((blocknumber<0) or (blocknumber>MyLastblock)) then
   result := 'blockorder'#127'false'#127+NosoPParams+#127'0'
else
   begin
   ArraTrxs := GetBlockTrxs(BlockNumber);
   result := 'blockorder'#127'true'#127+NosoPParams+#127;
   if length(ArraTrxs) > 0 then
      begin
      for counter := 0 to length(ArraTrxs)-1 do
         AddOrder(ArraTrxs[counter]);
      result := result+IntToStr(length(arrayOrds))+#127;
      for counter := 0 to length(arrayOrds)-1 do
         begin
         thisorderinfo := format('%s'#127'%d'#127'%d'#127'%s'#127'%d'#127'%s'#127'%d'#127'%d'#127'%s'#127'%s'#127,
            [ arrayOrds[counter].OrderID,arrayOrds[counter].TimeStamp,arrayOrds[counter].Block,
            arrayOrds[counter].OrderType,arrayOrds[counter].OrderLines,arrayOrds[counter].Receiver,
            arrayOrds[counter].AmmountTrf,arrayOrds[counter].AmmountFee,arrayOrds[counter].Reference,
            arrayOrds[counter].sender]);
         result := result+thisorderinfo;
         end;
      end
   else result := result+'0'#127;
   trim(result);
   end;
EndPerformance('RPC_BlockOrders');
End;

function RPC_Masternodes(NosoPParams:string):string;
var
  source : String;
  counter : integer = 1;
  Block : string;
  ThisData : String;
  Nodes    : string = '';
  Total    : integer = 0;
  IpAndport,Ip,port,address,age : string;
Begin
  BeginPerformance('RPC_Masternodes');
  Result := '';
  source:= GetMN_FileText;
  Block := parameter(source,0);
  repeat
  ThisData := parameter(Source,counter);
  if thisData <> '' then
    begin
    ThisData := StringReplace(ThisData,':',' ',[rfReplaceAll]);
    ipandport:=Parameter(ThisData,0);
    ipandport := StringReplace(ipandport,';',' ',[rfReplaceAll]);
    ip := Parameter(ipandport,0);
    port := Parameter(ipandport,1);
    address  :=Parameter(ThisData,1);
    age      :=Parameter(ThisData,2);
    nodes := nodes+format('[%s,%s,%s,%s]',[ip,port,address,age]);
    Inc(Total);
    end;
  inc(counter);
  until thisdata = '';
  Result := 'getmasternodes'#127+Block+#127+IntToStr(Total)+#127+Nodes;
  //Tolog('console',result);
  EndPerformance('RPC_Masternodes');
End;

function RPC_Blockmns(NosoPParams:string):string;
var
  blocknumber : integer;
  ArrayMNs : BlockArraysPos;
  MNsReward : int64;
  MNsCount, Totalpaid : int64;
  counter : integer;
  AddressesString : string = '';
Begin
BeginPerformance('RPC_Blockmns');
result := '';
blocknumber := StrToIntDef(NosoPParams,-1);
if ((blocknumber<48010) or (blocknumber>MyLastblock)) then
   result := 'blockmns'#127'false'#127+NosoPParams+#127'0'#127'0'#127'0'
else
   begin
   ArrayMNs := GetBlockMNs(blocknumber);
   MNsReward := StrToInt64Def(ArrayMNs[length(ArrayMNs)-1].address,0);
   SetLength(ArrayMNs,length(ArrayMNs)-1);
   MNSCount := length(ArrayMNs);
   TotalPAid := MNSCount * MNsReward;
   for counter := 0 to MNsCount-1 do
      AddressesString := AddressesString+ArrayMNs[counter].address+' ';
   AddressesString := Trim(AddressesString);
   AddressesString := StringReplace(AddressesString,' ',',',[rfReplaceAll, rfIgnoreCase]);
   result := 'blockmns'#127'true'#127+blocknumber.ToString+#127+MNSCount.ToString+#127+
              MNsReward.ToString+#127+TotalPAid.ToString+#127+AddressesString;
   end;
EndPerformance('RPC_Blockmns');
End;

Function RPC_WalletBalance(NosoPParams:string):string;
var
  LData : int64;
Begin
  BeginPerformance('RPC_WalletBalance');
  LData := GetWalletBalance;
  result := format('walletbalance'#127'%d',[LData]);
  EndPerformance('RPC_WalletBalance');
End;

function RPC_NewAddress(NosoPParams:string):string;
var
  TotalNumber : integer;
  counter : integer;
  NewAddress : WalletData;
  PubKey,PriKey : string;
Begin
BeginPerformance('RPC_NewAddress');
TotalNumber := StrToIntDef(NosoPParams,1);
if TotalNumber > 100 then TotalNumber := 100;
result := 'newaddress'#127'true'#127+IntToStr(TotalNumber)+#127;
for counter := 1 to totalnumber do
   begin
   NewAddress := Default(WalletData);
   NewAddress.Hash:=GenerateNewAddress(PubKey,PriKey);
   NewAddress.PublicKey:=pubkey;
   NewAddress.PrivateKey:=PriKey;
   InsertToWallArr(NewAddress);
   if RPCSaveNew then SaveAddresstoFile(RPCBakDirectory+NewAddress.Hash+'.pkw',NewAddress);
   Result := result+NewAddress.Hash+#127;
   end;
trim(result);
S_Wallet := true;
U_DirPanel := true;
EndPerformance('RPC_NewAddress');
End;

function RPC_NewAddressFull(NosoPParams:string):string;
var
  counter : integer;
  NewAddress : WalletData;
  PubKey,PriKey : string;
Begin
  BeginPerformance('RPC_NewAddressFull');
  result := 'newaddressfull'#127;
  NewAddress := Default(WalletData);
  NewAddress.Hash:=GenerateNewAddress(PubKey,PriKey);
  NewAddress.PublicKey:=pubkey;
  NewAddress.PrivateKey:=PriKey;
  InsertToWallArr(NewAddress);
  if RPCSaveNew then SaveAddresstoFile(RPCBakDirectory+NewAddress.Hash+'.pkw',NewAddress);
  Result := result+NewAddress.Hash+#127+NewAddress.PublicKey+#127+NewAddress.PrivateKey;
  trim(result);
  S_Wallet := true;
  U_DirPanel := true;
  EndPerformance('RPC_NewAddressFull');
End;

Function RPC_ValidateAddress(NosoPParams:string):string;
Begin
  BeginPerformance('RPC_NewAddressFull');
  If VerifyAddressOnDisk(Parameter(NosoPParams,0)) then
    result := 'islocaladdress'#127'True'
  else result := 'islocaladdress'#127'False';
  EndPerformance('RPC_NewAddressFull');
End;

Function RPC_SetDefault(NosoPParams:string):string;
var
  address : string;
Begin
  BeginPerformance('RPC_SetDefault');
  address := Parameter(NosoPParams,0);
  if SetDefaultAddress('SETDEFAULT '+Address) then result := 'setdefault'#127'True'
  else result  := 'setdefault'#127'False';
  EndPerformance('RPC_SetDefault');
End;

Function RPC_GVTInfo(NosoPParams:string):string;
var
  available:int64;
Begin
  BeginPerformance('RPC_GVTInfo');
  available := CountAvailableGVTs;
  result := 'gvtinfo'#127+IntToStr(available)+#127+IntToStr(GetGVTPrice(Available))+#127+IntToStr(GetGVTPrice(Available,True));
  EndPerformance('RPC_GVTInfo');
End;

Function RPC_CheckCertificate(NosoPParams:string):string;
var
  cert     : string;
  SignTime : string;
  Address  : string;
Begin
  BeginPerformance('RPC_CheckCertificate');
  result  := 'checkcertificate'#127;
  cert := Parameter(NosoPParams,0);
  Address := CheckCertificate(cert,SignTime);
  if  Address <> '' then
    begin
    Result := result+'True'#127+Address+#127+SignTime;
    end
  else
    begin
    Result := Result+'False';
    end;
  EndPerformance('RPC_CheckCertificate');
End;


Function RPC_SubmitOrder(NosoPParams:string;waitresponse:boolean=false):string;
var
  ResultLine : string;
Begin
  BeginPerformance('RPC_SubmitOrder');
  //ToLog('Console',NosoPParams);
  ResultLine := SendOrderToNode(NosoPParams);
  ResultLine := StringReplace(ResultLine,' ','_',[rfReplaceAll, rfIgnoreCase]);
  if not waitresponse then result := 'submitorder'#127'True'
  else
    begin
    result := 'submitorderwr'#127'True'#127+ResultLine;
    end;
  EndPerformance('RPC_SubmitOrder');
End;

function RPC_SendFunds(NosoPParams:string):string;
var
  destination,  reference : string;
  amount : int64;
  resultado : string;
  ErrorCode : integer;
Begin
  BeginPerformance('RPC_SendFunds');
  destination := Parameter(NosoPParams,0);
  amount := StrToInt64Def(Parameter(NosoPParams,1),0);
  reference := Parameter(NosoPParams,2); if reference = '' then reference := 'null';
  //ToLog('console','Send to '+destination+' '+int2curr(amount)+' with reference: '+reference);
  Resultado := SendFunds('sendto '+destination+' '+IntToStr(amount)+' '+Reference);
  if ( (Resultado <>'') and (Parameter(Resultado,0)<>'ERROR') and (copy(resultado,0,2)='OR')) then
    begin
    result := 'sendfunds'#127+resultado;
    end
  else if (Parameter(Resultado,0)='ERROR') then
    begin
    ErrorCode := StrToIntDef(Parameter(Resultado,1),0);
    result := 'sendfunds'#127+'ERROR'#127+IntToStr(ErrorCode);
    end
  else
    begin
    result := 'sendfunds'#127+'ERROR'#127+'999';
    end;
  EndPerformance('RPC_SendFunds');
End;


END.  // END UNIT