tera/Source/dapp/messager.js
progr76@gmail.com 3029d69c0e 0.884
2019-02-10 22:53:54 +03:00

144 lines
4.0 KiB
JavaScript

/*
* @project: TERA
* @version: Development (beta)
* @license: MIT (not for evil)
* @copyright: Yuriy Ivanov 2017-2019 [progr76@gmail.com]
* Web: https://terafoundation.org
* Twitter: https://twitter.com/terafoundation
* Telegram: https://web.telegram.org/#/im?p=@terafoundation
*/
"use strict";
require('../core/crypto-library');
const OPEN_TYPE_TRANSACTION = 11;
const MESSAGE_TYPE_TRANSACTION = 12;
const MAX_MSG_SIZE = 1024;
var TempArrayTr = new Uint8Array(MAX_MSG_SIZE);
const MESSAGE_START = 9;
const MESSAGE_END = MAX_MSG_SIZE - 5;
require("./names");
class CApp extends require("./dapp")
{
constructor()
{
super()
this.Channels = {}
this.NamesMap = NAMES.KeyValueMap
global.MESSAGER = this
}
Decrypt(Body)
{
for(var key in this.Channels)
{
var Node = this.Channels[key];
Decrypt(Body, TempArrayTr, Node.Secret)
if(IsZeroArr(TempArrayTr.slice(MESSAGE_END)))
{
var Str = Utf8ArrayToStr(TempArrayTr.slice(MESSAGE_START));
return Str;
}
}
return undefined;
}
Encrypt(StrMessage, StrTo)
{
var NameArr;
if(typeof StrTo === "string")
{
NameArr = GetArrFromStr(StrTo, 32)
}
else
{
NameArr = Str
}
var arrMessage = GetArrFromStr(StrMessage, MESSAGE_END);
var ArrayTr = new Uint8Array(MAX_MSG_SIZE);
ArrayTr[0] = MESSAGE_TYPE_TRANSACTION
for(var i = 5; i < MAX_MSG_SIZE; i++)
{
ArrayTr[i] = arrMessage[i - MESSAGE_START]
}
var Body = new Uint8Array(MAX_MSG_SIZE);
var Node = this.OpenChannel(NameArr);
Encrypt(ArrayTr, Body, Node.Secret)
return Body;
}
OpenChannel(FromNameArr)
{
var FromArr;
var StrKeyFrom = GetHexFromAddres(FromNameArr);
if(this.NamesMap[StrKeyFrom])
{
FromArr = this.NamesMap[StrKeyFrom]
}
else
{
FromArr = FromNameArr
}
var StrKey = GetHexFromAddres(FromArr);
var Node = this.Channels[StrKey];
if(!Node)
{
Node = {addrArr:FromArr}
CheckContextSecret(this.Server, Node)
this.Channels[StrKey] = Node
}
return Node;
}
OnWriteTransaction(Block, Body, BlockNum, TrNum)
{
var Type = Body[0];
if(Type === OPEN_TYPE_TRANSACTION)
{
var ToArr = Body.slice(33);
if(CompareArr(ToArr, NAMES.CurrentNameArr) === 0 || CompareArr(ToArr, this.Server.addrArr) === 0)
{
var FromNameArr = Body.slice(1, 33);
this.OpenChannel(FromNameArr)
}
}
else
if(Type === MESSAGE_TYPE_TRANSACTION)
{
var Str = this.Decrypt(Body);
if(Str !== undefined)
ToLog("GET MESSAGE:" + Str)
}
}
OnMessage(Msg)
{
ToLog("GET MESSAGE:" + Msg.body)
return ;
var Body = Msg.body;
var Type = Body[0];
if(Type === MESSAGE_TYPE_TRANSACTION)
{
var Str = this.Decrypt(Body);
if(Str !== undefined)
{
ToLog("GET MESSAGE:" + Str)
}
}
}
};
function TestEncryptDecrypt()
{
const CMessager = module.exports;
var Server = {KeyPair:GetKeyPairTest("Test"), DApp:{Names:{KeyValueMap:{}}}, };
var Test = new CMessager(Server);
var KeyPair2 = GetKeyPairTest("Test2");
var StrTest1 = GetArrFromStr("Test2", 32);
var StrKey = GetHexFromAddres(StrTest1);
MESSAGER.NamesMap[StrKey] = KeyPair2.addrArr;
var Body = MESSAGER.Encrypt("This is a test message!", "Test2");
var Str2 = MESSAGER.Decrypt(Body);
console.log("Decrypt:");
console.log(Str2);
};
module.exports = CApp;
var App = new CApp;
DApps["Messager"] = App;
DAppByType[OPEN_TYPE_TRANSACTION] = App;
DAppByType[MESSAGE_TYPE_TRANSACTION] = App;