vmess.js

//const clipboardy = require('clipboardy');

var fs = require('fs');
var exec = require('child_process').exec;
var express = require("express");
var app = express();
var bodyParser = require("body-parser");
var https = require('https');
var path = require('path');
const fileUpload = require('express-fileupload');
const cors = require('cors');
const morgan = require('morgan');
const _ = require('lodash');

//------------------------------------------------------
 

/*
function insert(main_string, ins_string, pos) {
	if(typeof(pos) == "undefined") {
	 pos = 0;
   }
	if(typeof(ins_string) == "undefined") {
	 ins_string = '';
   }
	return main_string.slice(0, pos) + ins_string + main_string.slice(pos);
	 }
 

 
var ts="o";
for (var i=0;i<wordStringMax.length;i++){

	 
	var l=ts.length;
	var v=Math.random()*l;
	var s=wordStringMax[i];
	ts.insert ( v, s );
 

}
*/
var vmessListString='';
var bak='';

var isRun=false;
 
//var execProcess = require("./exec_process.js");

var execProcess = function(command, cb){
    var child = exec(command, function(err, stdout, stderr){
        if(err != null){
            return cb(new Error(err), null);
        }else if(typeof(stderr) != "string"){
            return cb(new Error(stderr), null);
        }else{
            return cb(null, stdout);
        }
    });
}

//----------------------------------------------------
var optionsArray = [];
var options0 = {
	index:0,
	host :  'github.com',
	port : 443,
	path : '/Alvin9999/new-pac/wiki/v2ray%E5%85%8D%E8%B4%B9%E8%B4%A6%E5%8F%B7',
	method : 'GET',
	timeout: 8000
}
var options1 = {
	index :1,
	host :  'awesomeopensource.com',
	port : 443,
	path : '/project/iwxf/free-v2ray?categoryPage=11',///project/iwxf/free-v2ray?categoryPage=11',
	method : 'GET',
	timeout: 8000
}
var options2 = {
	index :2,
	host :  'github.com',
	port : 443,
	path : '/iwxf/free-v2ray',///project/iwxf/free-v2ray?categoryPage=11',
	method : 'GET',
	timeout: 8000
}
var options3 = {
	index :3,
	host :  'github.com',
	port : 443,
	path : '/selierlin/Share-SSR-V2ray/blob/master/1-share-ssr-v2ray.md',///project/iwxf/free-v2ray?categoryPage=11',
	method : 'GET',
	timeout: 8000
}

 
  
var originalAmountArray=[];
var actualAmountArray=[];
var vmessStringArray=[];
//----------------------------------------------------
optionsArray.push(options0);
optionsArray.push(options1);
optionsArray.push(options2);
optionsArray.push(options3);

var valueArray=[9,5,3,8,0,2,7,4,1,6];
var wordStringMax="*SvW)$KPaQ8u:X;'z9>?ZbM1dh3jlR6E(nIpBrVt|w0A25<eC7~!y@of%D#gsJ4qTU={L}[iG]xkmYHc&^_FO+`-N,./";
var globalStep=0;
var d=0;
 
var aaa="888\r\n9999";
 
function encodeString(s){
 
	var returnString="";
 
 
	 
	var t="";
	var t1="";
	var step=0;

	var ttt="";
	 
	for(var i=0;i<s.length;i++){

		var c=s[i];
		if(c=='\r'){
		    i=i+1;
			c=s[i];
			if(c=='\n'){

				returnString=returnString+t+"\r\n";
				if(step==7){
			 
				}
				if(step==8){
			 
				}
				step=step+1;
				 
				if(step==7){
			 
				}
				if(step==8){
	 
				}
				ttt="";
				t="";
				t1="";
			}

		}else if(c=='\n'){

			returnString=returnString+t+"\n";
			step=step+1;
	 
			if(step==7){
			 
			}
			if(step==8){
		 
			}
			t="";
			
		}else{

			var n = wordStringMax.indexOf(c);
			var k=step % 10;
			var m=valueArray[k] ;
			var p=n+m +i ;

			p=p % wordStringMax.length;
			t=t+wordStringMax[p]; 
			t1=t1+c;

		}
 

	}
    
	return returnString;// t;
 
} 
function encodeString0(s){
 
	var returnString="";
	var t="";
	var t1="";
	var step=0;
	var ttt="";
	 
	for(var i=0;i<s.length;i++){

		var c=s[i];
		var n = wordStringMax.indexOf(c);
		var k=step % 10;
		var m=valueArray[k] ;
		var p=n+m +i ;

		p=p % wordStringMax.length;
		t=t+wordStringMax[p]; 
		t1=t1+c;
 
	}
    returnString=returnString+t +"\n";
	return returnString; 
 
}


function decodeS(s){
 
	var returnString="";
	var t="";
	var t1="";
	var step=0;

	var ttt="";
 
	for(var i=0;i<s.length;i++){

		var c=s[i];

		if(c=='\r'){

		    i=i+1;
			c=s[i];
			if(c=='\n'){

				returnString=returnString+t+"\r\n";
				step=step+1;
				t="";
				ttt="";
			
			}

		}else if(c=='\n'){

			returnString=returnString+t+"\n";
			step=step+1;
			t="";
			ttt="";
			
		}else{

			var p = wordStringMax.indexOf(c);
                    var k = step % 10;
                    var m = valueArray[k];
                    var v = 0;
                    while ((v+p) < (m + i  ))
                    {
                        v=v+ wordStringMax.length;
                    }
                    var n =p+v - m - i;
                    if (n == wordStringMax.length) n = 0;
                    t = t + wordStringMax[n];

		}
	}
    
	return returnString;// t;
 
}

function decodeHTML(index, htmlString){

 
	switch(index){
		case 0:{//host : 'github.com',
                //port : 443,
                //path : '/Alvin9999/new-pac/wiki/v2ray%E5%85%8D%E8%B4%B9%E8%B4%A6%E5%8F%B7',
			var tems='';
			var s=htmlString;
			var exitNumber=false;
			var errorNumber=false;
		 
			var tStringArray=[];
			do{
				var x=s.indexOf('vmess://');
				if (x==-1){
					exitNumber=true;
					break;
				}
				var l=s.length; 
				var sub=s.substring(x,l);
			 
				var l1=sub.length;
				var x1=sub.indexOf('</p');
				 
				if(x1==-1){
					//errorNumber=true;
					break;
				}
				var ts=sub.substring(0,x1) ;
				tems=tems+ts +'\r\n'; 
				tStringArray.push(ts  +'\r\n');
				s=sub.substring( x1, l1-x1 );
		
			}while (exitNumber==false);

			if(errorNumber==false){
 
				vmessListString=vmessListString + tems; 
				vmessStringArray.push(tStringArray);
				globalStep=globalStep+1;
			 
			} 
			break;
		}
		case 1:{

			var tems='';
			var s=htmlString;
			var exitNumber=false;
			var errorNumber=false;
		 
			var tStringArray=[];
			var n=0;
			do{
				var x=s.indexOf('vmess://');
				if (x==-1){
					exitNumber=true;
					break;
				}
				var l=s.length; 
				var sub=s.substring(x,l );
				var x1=sub.indexOf('</code>');
				if(x1==-1){
					errorNumber=true;
					break;
				}
				var tems=sub.substring(0,x1) ;
				break;

			}while (exitNumber==false);
			var h='';
			var ts="";
			for(var i=0;i<tems.length;i++){

				h=tems[i];
				if(h=='\n'){

					tems=tems+ts +'\r\n'; 
					tStringArray.push(ts  +'\r\n');
					ts="";

				}else{

					ts =ts+h; 
			 
				}

			}
			if(errorNumber==false){
 
				vmessListString=vmessListString+tems; 
				vmessStringArray.push(tStringArray);
				globalStep=globalStep+1;
			} 
		
			break;
		}

		case 2:{

			var tems='';
			var s=htmlString;
			var exitNumber=false;
			var errorNumber=false;
		 
			var tStringArray=[];
			var n=0;
			do{
				var x=s.indexOf('vmess://');
				if (x==-1){
					exitNumber=true;
					break;
				}
				var l=s.length; 
				var sub=s.substring(x,l );
				var x1=sub.indexOf('</code>');
				if(x1==-1){
					errorNumber=true;
					break;
				}
				var tems=sub.substring(0,x1) ;
			 
				break;

			}while (exitNumber==false); 
			if(errorNumber==false){
			 
				vmessListString=vmessListString+tems; 
				globalStep=globalStep+1;
				vmessStringArray.push(tStringArray);
			} 
		
			break;
		}
		
		case 3:{

			var tems='';
			var s=htmlString;
			var exitNumber=false;
			var errorNumber=false;
 
			var tStringArray=[];
			do{
				var x=s.indexOf('vmess://');
				if (x==-1){
		
					exitNumber=true;
			 
					break;
				}
				var l=s.length; 
				var sub=s.substring(x,l);
			 
				var l1=sub.length;
				var x1=sub.indexOf('</p>');
				 
				if(x1==-1){
					errorNumber=true;
					break;
				}
 
				var ts=sub.substring(0,x1) ;
	 
				tems=tems+ts +'\r\n'; 
				tStringArray.push(ts  +  '\r\n');
				s=sub.substring( x1, l1-x1 );
		
			}while (exitNumber==false);

			if(errorNumber==false){
			 
				vmessListString=vmessListString+tems; 
				globalStep=globalStep+1;
				vmessStringArray.push(tStringArray);

			} 
			break;
		}

	}

 }
 var fileString0="";
 var aFileArray=[];
 var bFileArray=[];
 var aStringArray=[];
 var bStringArray=[];

 //a.txt b.txt
 var aFileString="";
 var aAmount=0;
 var aString="";
 var bAmount=0;
 var bFileString="";
 var bString="";
//------------------------------------------------------------------------------------------
function formatLinkInfo(){

	aFileArray=[];
	bFileArray=[];
	aStringArray=[];
	bStringArray=[];
	var tArray=[];
	var tAmount=0;

	for(var j=0;j<vmessStringArray.length;j++){
		tAmount=tAmount+vmessStringArray[j].length;
		for(var i=0;i<vmessStringArray[j].length;i++){
 
			tArray.push(vmessStringArray[j][i]);//tArray[i]+'\r\n';

		}
	}
	var maxA=5;
	var maxB=10;

	var tDivA=Math.floor(tAmount/maxA);
	var tModA=tAmount % maxA;
	if (tModA!=0) tDivA=tDivA+1;

	//-----------------------------------------------------

	var tDivB=Math.floor(tAmount/maxB);
	var tModB=tAmount % maxB;
	if (tModB!=0) tDivB=tDivB+1;

	console.log(tAmount+'|'+maxA+'|'+maxB+'|'+tDivA+"|"+tModA+"|"+tDivB+"|"+tModB+"|");

	var amountAFileArray=tDivA;
	var amountBFileArray=tDivB;
 
	//aStringArray.push(vmessListString);
	//bStringArray.push(vmessListString);
 
	for(var j=0;j<tDivA;j++){
		if(tModA!=0){
			var h='';
			if(j==tDivA-1){
				for(var i=0;i<5;i++)
				h=h+tArray[tArray.length-1-i];//+'\r\n';
			}else{
				for(var i=0;i<5;i++)
				h=h+tArray[j*5+i];//+'\r\n';
			
			}
			aStringArray.push(h);
		}else{

			var h='';
			for(var i=0;i<5;i++)
			h=h+tArray[j*5+i] +'\r\n';
			aStringArray.push(h);
		}	 
	}
 
	for(var j=0;j<tDivA;j++){
		if(tModB!=0){
			var h='';
			if(j==tDivB-1){
				for(var i=0;i<5;i++)
				h=h+tArray[tArray.length-1-i];//+'\r\n';
			}else{
				for(var i=0;i<5;i++)
				h=h+tArray[j*5+i] +'\r\n';
			
			}
			bStringArray.push(h);
		}else{

			var h='';
			for(var i=0;i<5;i++)
			h=h+tArray[j*5+i];//+'\r\n';
			bStringArray.push(h);
		}	 
	}
	for(var j=0;j<tDivB;j++){
		bStringArray.push("b"+ j.toString()+".txt");
	}

	//-------------------------------------------------------------

	for(var j=0;j<amountAFileArray;j++){
		//aFileArray.push("a"+ j.toString()+".txt");
		aFileArray.push("a"+ j.toString()+".txt");
	}
 
	for(var j=0;j<amountBFileArray;j++){
		//bFileArray.push("b"+ j.toString()+".txt");
		bFileArray.push("b"+ j.toString()+".txt");
	}
 
 

	today = new Date();
 
	var yeT=today.getFullYear();
	var moT=today.getMonth();
	var daT=today.getDay();
	var hoT=today.getHours();
	var miT=today.getMinutes();
	var sT=yeT.toString()+moT.toString()+daT.toString()+hoT.toString()+miT.toString();

	//console.log(sT);

	aFileString="a.txt";
	//aString="{v:\"2021020101\",u:\"https://github.com/alohabooster/alohabooster/a\",a:"+aFileArray.length.toString()+"}";//10
	aString="{v:\""+sT+"\",u:\"a\",a:"+aFileArray.length.toString()+"}";//10
	
	bFileString="b.txt";
	//bString="{v:\"2021020101\",m:{\"https://alohaboost.herokuapp.com/\",\"https://aloha1boost.herokuapp.com/\"},u:\"https://github.com/alohabooster/alohabooster/b\",a:"+bFileArray.length.toString()+"}";//5
	//bString="{v:\""+sT+"\",m:{\"https://alohaboost.herokuapp.com/\",\"https://aloha1boost.herokuapp.com/\"},u:\"b\",a:"+bFileArray.length.toString()+"}";//5
	 
	bString="{v:\""+sT+"\",m:{\"https://alohabooster.teriyaki.workers.dev/\"},u:\"b\",a:"+bFileArray.length.toString()+"}";//5
	

 
 }
 async function writeLinkInfo1(){
 
    var errorNumber=0;
    var aString1="[core]\r\nrepositoryformatversion = 0\r\nfilemode = false\r\nbare = false\r\nlogallrefupdates = true\r\nsymlinks = false\r\nignorecase = true\r\n[remote \"origin\"]\r\nurl = https://alohabooster:Wangzheng2020__@github.com/alohabooster/alohabooster.git\r\nfetch = +refs/heads/*:refs/remotes/origin/*\r\n[branch \"master\"]\r\nremote = origin\r\nmerge = refs/heads/master";
    var aString2="[core]\r\nrepositoryformatversion = 0\r\nfilemode = false\r\nbare = false\r\nlogallrefupdates = true\r\nsymlinks = false\r\nignorecase = true\r\n[remote \"origin\"]\r\nurl = https://alohabooster:Wangzheng2020__@gitea.com/alohabooster/alohabooster.git\r\nfetch = +refs/heads/*:refs/remotes/origin/*\r\n[branch \"master\"]\r\nremote = origin\r\nmerge = refs/heads/master";
    var aString3="[core]\r\nrepositoryformatversion = 0\r\nfilemode = false\r\nbare = false\r\nlogallrefupdates = true\r\nsymlinks = false\r\nignorecase = true\r\n[remote \"origin\"]\r\nurl = https://alohabooster:Wangzheng2020__@gitlab.com/alohabooster/alohabooster.git\r\nfetch = +refs/heads/*:refs/remotes/origin/*\r\n[branch \"master\"]\r\nremote = origin\r\nmerge = refs/heads/master";
    var aString4="[core]\r\nrepositoryformatversion = 0\r\nfilemode = false\r\nbare = false\r\nlogallrefupdates = true\r\nsymlinks = false\r\nignorecase = true\r\n[remote \"origin\"]\r\nurl = https://alohabooster:Wangzheng2020__@bitbucket.org/alohabooster/alohabooster.git\r\nfetch = +refs/heads/*:refs/remotes/origin/*\r\n[branch \"master\"]\r\nremote = origin\r\nmerge = refs/heads/master";
    
    await fs.writeFile(".git/config", aString3, function (err) {	//gitlab
		console.log('config gitlab ok->');errorNumber=0; });
    await execProcess("sh command1.sh", function(err, response){// 
            if(!err) {

			 
				console.log('execute ok');errorNumber=0;
				
                 
            }   
            else {console.log('execute error'+err);errorNumber=1};
        });


        setTimeout(function() {
            //your code to be executed after 1 second
            
            fs.writeFile(".git/config", aString4, function (err) { 
    
                if(!err) {
                    console.log('config bitbucket ok->');errorNumber=0;
                    execProcess("sh command1.sh", function(err, response){// 
                        if(!err){
                        
                            console.log('execute ok');
                             
                        }else {
                                
                            console.log('execute error'+err);
                          
                        }
                         
                    });
                     
                }   
                else {console.log('execute error->'+err);errorNumber=1};
            });
    
          }, 10000);
    
    
          setTimeout(function() {
            //your code to be executed after 1 second
            
            fs.writeFile(".git/config", aString1, function (err) { 
    
                if(!err) {
                    console.log('config github ok->');errorNumber=0;
                    execProcess("sh command1.sh", function(err, response){// 
                        if(!err){
                        
                            console.log('execute ok');
                             
                        }else {
                                
                            console.log('execute error'+err);
                          
                        }
                         
                    });
                     
                }   
                else {console.log('execute error->'+err);errorNumber=1};
            });
    
          }, 20000);
    
          setTimeout(function() {
            //your code to be executed after 1 second
            
            fs.writeFile(".git/config", aString2, function (err) { 
    
                if(!err) {
                    console.log('config gitea ok->');errorNumber=0;
                    execProcess("sh command1.sh", function(err, response){// 
                        if(!err){
                        
                            console.log('execute ok');
                             
                        }else {
                                
                            console.log('execute error '+err);
                          
                        }
                         
                    });
                     
                }   
                else {console.log('execute error->'+err);errorNumber=1};
            });
    
          }, 30000);


}
async function writeLinkInfo(){


	/*
	for(var i=0;i<aFileArray.length;i++){
		
	}

	for(var i=0;i<bFileArray.length;i++){
		
	}
	*/

	//console.log('write file:'+aFileString+'-'+aFileArray.length);
	//console.log('write file:'+bFileString+'-'+bFileArray.length);

	if(aFileArray.length>0){


		// await fs.writeFile(aFileString, aString, function (err) { });
		 await fs.writeFile(aFileString, encodeString0(aString+"|TgJ3f[=W7$J#qHUO{Xm(+9_Pkkcsc]Q'FImvY/G7r}4^;/;w~W[5)%hU<#"), function (err) { });
		  
		for(var i=0;i<aFileArray.length;i++){

		 
			//console.log(aFileArray[i]+':'+encodeString( aStringArray[i]));
			await fs.writeFile(aFileArray[i], encodeString( aStringArray[i]), function (err) {});
			 
		}
		 
			 
		 
	}

	 
	if(bFileArray.length>0){
		//await fs.writeFile(bFileString, bString, function (err) { });
		 await fs.writeFile(bFileString, encodeString0(bString+"|1k}$uc].jhSS#-8KpH0$8W,hEPP/Ou7?znL4%qY"), function (err) { });
		 
		 
		for(var i=0;i<bFileArray.length;i++){

			//console.log(bFileArray[i]+':'+encodeString( bStringArray[i]));
			await fs.writeFile(bFileArray[i], encodeString( bStringArray[i]), function (err) {});
		}

			 
  

	}
 
	writeLinkInfo1();


	/* 
  
	execProcess("sh command1.sh", function(err, response){// 
	//execProcess("command1.bat", function(err, response){//sh command1.sh
			if(!err){
	
				console.log('execute ok');
				//return callbackFunction();
			}else {
			
				console.log('execute error');
				//return callbackFunction();
			}
		});

	 

		*/
		 
 
}

 
 
 async function getCall(index, isWriteToFile, callbackFunction) {

	var options=optionsArray[index];
 
    //initialize options values, the value of the method can be changed to POST to make https post calls
    //var userAccessToken = 'CAAKoIMGu5SAyfOyVhugi7cZAaZA1kHzjrdLvtPlndoKzMJ8xZBtR3YV2iX39FSnhxK1lvtfYXO5FvcbK4MVGJphxeYDZC7HJ5FCmhOr2Ys8ZBG9qYNRSfFGuzoeRgwZBdliKvoW6YPl41b8i3dfrTpR98gFAm6qag9vYM2yD0aEv47fnWQWF1SoXRs6PFFrFu5XOe';
    //var appAccessToken = '24562343562751562|hPEXIpDl0CXt0tNJ';
 
	var str = '';
	var decodeString='';
	//making the https get call
	 
    var getReq = https.request(options, function(res) {
        res.on('data', function(data) {
			str += data;
		});
		res.on("end", function() {
		 
			decodeHTML(index, str);
			console.clear;

			if(isWriteToFile){

			 
				console.log("------formatLinkInfo");
				formatLinkInfo();
				console.log("------writeLinkInfo");
				writeLinkInfo();
				console.log("------callbackFunction");
				callbackFunction();

 

			}else{
			 	return callbackFunction();
			}
 
        });
	 
    });
 

	 
	//end the request
 
 
	getReq.end();

	getReq.on('timeout', () => {
		getReq.abort();
	});
	 
    getReq.on('error', function(err){

		console.log("Error: ", err);
		var t=[];
		vmessStringArray.push(t);

		if(isWriteToFile){

			console.log("------formatLinkInfo");
			formatLinkInfo();
			console.log("------writeLinkInfo");
			writeLinkInfo();
			//console.log("------callbackFunction");
		}
		callbackFunction();
         
	}); 

 
}
//----------------------------------------------------------------------
var today = new Date();
var time = today.getFullYear()+'/'+today.getMonth()+'/'+today.getDay()+' '+ today.getHours() + ":" + today.getMinutes() + ":" + today.getSeconds();		 
console.log('change on time:'+time.toString());
 
async function startToRun(){
 
	vmessListString='';
	isRun=true;
	globalStep=0;
	vmessStringArray=[];
	//vmessStringArray[0]=[];//.clear;
	//vmessStringArray[1]=[];
	//vmessStringArray[2]=[];
	//vmessStringArray[3]=[];
 

	await getCall(0, false,function(){});
	await getCall(1, false,function(){});
    await getCall(2, false,function(){});
	await getCall(3, true,function(){


	});

	//setTimeout(function(){ if(isRun) startToRun(); }, 3000);


	 
	const timeoutObj = setTimeout(() => {

		 
    if(isRun) startToRun();
  

	}, 180000);

 
 
	 
	/*
	 

 
	*/

 
}
 
startToRun();

 
 
 
//-----------------------------------------
// enable files upload
app.use(fileUpload({
    createParentPath: true
}));

//add other middleware
app.use(cors());
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({extended: true}));
app.use(morgan('dev'));

//---------------------------------------------------------------
 
app.get('/stop/', async (req, res) => {

	isRun=false;
	res.send({
		status: false,
		message: 'stop'
	});

});
app.get('/github/', async (req, res) => {
	
	        //execProcess.result
			execProcess("command1.bat", function(err, response ){//sh command1.sh
				if(!err){
					console.log(response );
				//	return callbackFunction();
				}else {
					console.log(err);
				//	return callbackFunction();
				}
	 
			});

			res.send({
				status: false,
				message: 'git'
			});

		});

app.post('/upload/', async (req, res) => {
    try {
        if(!req.files) {
            res.send({
                status: false,
                message: 'No file uploaded'
            });
        } else {

            //Use the name of the input field (i.e. "avatar") to retrieve the uploaded file
			let a = req.files.file;
	 
 
			a.mv('./' + a.name);
		 
		 
			res.send({
				status: false,
				message: 'git'
			});

		 

             
        }
    } catch (err) {
        res.status(500).send(err);
    }
});
 
//---------------------------------------------------------------app
// default route
app.get("/", function (req, res) {
	return res.send({ e: "f", i: "." });
  });

app.get("/Grapetreetown306/", function (req, res) {

	let user_id = req.params.id;
    res.sendFile(path.join(__dirname, '/',  "url.txt"));
	 
});
  
app.listen(process.env.PORT || 3002, function () {
	console.log("Node app is running on port 3002");
  });