Multi drop

BtcRelaxTelegramBot.js

@@ -0,0 +1,136 @@
+function prepareUpdateRequest(vEntry)
+{
+  var cEntry;
+  if (vEntry!==undefined)
+  {
+     cEntry=vEntry;
+  }
+  else
+  {
+     cEntry=entry();
+  };
+
+  var mU=cEntry.field("APItoken");
+  var vO=cEntry.field("UpdateId");
+  if (vO>0)
+  {
+    cEntry.set("ServerRequest",mU+'getUpdates?offset='+vO);
+  }
+  else
+  {
+ cEntry.set("ServerRequest",mU+'getUpdates');
+  };    
+};
+
+
+function getUpdateInfo(vEntry)
+{
+var vRequest = vEntry.field("ServerRequest");
+var result=http().get(vRequest);
+if(result.code===200) {
+   var json=JSON.parse(result.body);
+   vEntry.set("ServerResponse",JSON.stringify(json));
+   var state =json.ok;
+   if (state===true)
+   { 
+   var vUList=json.result;
+   for (var UInfo in vUList)
+    {
+       var uI=vUList[UInfo];
+       var vLast=vEntry.field("UpdateId");
+       if (vLast!==uI.update_id)
+       {
+        processUpdateInfo(vEntry,uI);
+       };
+    };
+   };
+  };
+};
+
+function processUpdateInfo(vEntry, vUpdateInfo)
+{
+    var vUId = vUpdateInfo.update_id;
+    var vHLib = libByName("TelegramUpdates");
+    var vUInfo = new Object();
+    if (vUpdateInfo.message !== undefined) 
+    {
+     vUInfo["UpdateType"]="Message";
+     var vM = vUpdateInfo.message;  
+     vUInfo["Text"]=vM.text;  
+     var vUF=vM.from;
+     var vUsr=getUser(vUF);
+     vUsr.set("TelegramBot",vEntry);
+     var vCO=vM.chat;
+     var vC=getChat(vCO);
+     vC.set("Users",vUsr);
+     vC.set("TelegramBot",vEntry);
+    };
+    vUInfo["UpdateId"]=vUId;
+    var nUI=vHLib.create(vUInfo);
+    nUI.set("TelegramBot",vEntry);
+    var vRI=JSON.stringify(vUpdateInfo);
+    nUI.set("RawUpdateInfo",vRI);
+    vEntry.set("UpdateId",vUId);
+};
+
+function getChat(vChat)
+{
+   var vCL=libByName("TelegramChats");
+   var vCId=vChat.id;
+   var vCLE=vCL.entries();
+   var count=vCLE.length;
+   for (i=0;i<count;i++)
+   {
+      var vCE=vCLE[i];
+      var cId=vCE.field("ChatId");
+      if (cId==vCId)      
+      {
+        return vCE;
+      };
+   };
+   var nC=new Object();
+   nC["ChatId"]=vCId;
+   nC["Title"]=vChat.title;
+   nC["ChatType"]=vChat.type;
+   var nCE=vCL.create(nC);
+   return nCE;
+
+};
+
+function getUser(vUser)
+{
+    var vUL=libByName("TelegramUsers");
+    var vID=vUser.id;
+    var vULE=vUL.entries();
+    var count=vULE.length;
+
+    var isUserExists=false;
+    for (i=0;i<count;i++)
+    {
+       var vU=vULE[i];
+       var cId=vU.field("UserId");
+       if (vID==cId)
+       {
+          return vU;
+          isUserExists=true;
+       };
+    };
+    if (!isUserExists)
+    {
+     var nU = new Object();
+     nU["UserId"]=vID;
+     nU["UserName"]=vUser.username;
+     nU["FirstName"]=vUser.first_name;
+     nU["LastName"]=vUser.last_name;
+     nU["isBot"]=vUser.is_bot;
+     var nUE=vUL.create(nU);
+     return nUE;
+    };
+};
+
+
+
+
+var vC=entry();
+prepareUpdateRequest(vC);
+getUpdateInfo(vC);

README.md

@@ -1 +1,7 @@
 # scripts
+
+Define object for communicate from libraries into MementoDatabase to BtcRelax system.
+
+For productive recomended to use, quick files:
+refreshAllPubs.js;
+refreshPub.js;

data-sources/discogs.js

@@ -56,4 +56,4 @@ Discogs.prototype.extra = function(id) {
     if (result.genres !== undefined)
         result['genres'] = result.genres.join();        
     return result;
-}
+}

refreshAllPubs.js

@@ -0,0 +1,3 @@
+var vServer='https://ua.bitganj.website';
+refreshAllPubs(vServer);
+

refreshOrders.js

@@ -0,0 +1 @@
+refreshAllOrders('https://ua.bitganj.website');

refreshPub.js

@@ -0,0 +1,2 @@
+var vServer='https://ua.bitganj.website';
+refreshPub(vServer);

syncAll.js

@@ -0,0 +1 @@
+syncAll('https://ua.bitganj.website');

syncCurrent.js

@@ -0,0 +1,2 @@
+syncCurrent('https://ua.bitganj.website');
+