penguin/term-notify-server
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Moved the files to extension library

Browse Source
This commit is contained in:
斟酌 鵬兄
2016-06-16 15:25:05 +08:00
parent 0a1e00226b
commit 088da13be2
13 changed files with 10 additions and 176 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
.gitmodules vendored
View File

@@ -1,3 +1,6 @@
[submodule "botanss"]
path = botanss
url = AstroGit:BotanSS.git
[submodule "ext/utils"]
path = ext/utils
url = AstroGit:botansx-utils

2
botanss

Submodule botanss updated: dcdd941f3b...cd2cce7e98

1
ext/utils Submodule

Submodule ext/utils added at 0ae868ac2d

2
index.js
View File

@@ -56,7 +56,7 @@ else
// Define AppNS
cl.rootNS( "notifyterm", "./notify-term" );
cl.rootNS( "notifysrv", "./notifysrv" );
cl.rootNS( "botansx", "./ext/" );
var App = cl.load( "notifyterm.app" );

2
notify-term/Notis.js
View File

@@ -4,7 +4,7 @@ var cl = global.botanLoader;
var Dragonfly = global.Dragonfly;
var HttpRequest = cl.load( "botanss.net.HttpRequest" );
var ustr = cl.load( "notifysrv.utils.string" );
var ustr = cl.load( "botansx.utils.string" );
class Notis
{

3
notify-term/WNSAuth.js
View File

@@ -6,7 +6,8 @@ var Dragonfly = global.Dragonfly;
var EventEmitter = require( "events" ).EventEmitter;
var HttpRequest = cl.load( "botanss.net.HttpRequest" );
var Rand = cl.load( "notifysrv.utils.random" );
var Rand = cl.load( "botansx.utils.random" );
var Notis = cl.load( "notifyterm.Notis" );
var Model = cl.load( "notifyterm.schema" );

2
notify-term/app.js
View File

@@ -4,7 +4,7 @@ var cl = global.botanLoader;
var Dragonfly = global.Dragonfly;
var HttpRequest = cl.load( "botanss.net.HttpRequest" );
var Base = cl.load( "notifysrv.postframe" );
var Base = cl.load( "botanss.net.PostFrame" );
var WNSAuth = cl.load( "notifyterm.WNSAuth" );
var Model = cl.load( "notifyterm.schema" );

15
notifysrv/eventargs/eventargs.js
View File

@@ -1,15 +0,0 @@
"use strict";
var cl = global.botanLoader;
var Dragonfly = global.Dragonfly;
var qstr = cl.load( "notifysrv.utils.querystr" );
class EventArgs
{
constructor()
{
this.Handled = false;
}
}
module.exports = EventArgs;

23
notifysrv/eventargs/postrequest.js
View File

@@ -1,23 +0,0 @@
"use strict";
var cl = global.botanLoader;
var Dragonfly = global.Dragonfly;
var qstr = cl.load( "notifysrv.utils.querystr" );
var EventArgs = cl.load( "notifysrv.eventargs.eventargs" );
class PostRequestEventArgs extends EventArgs
{
constructor( QueryString )
{
super();
this.Raw = QueryString;
}
get Data()
{
return qstr.queryStr( this.Raw );
}
}
module.exports = PostRequestEventArgs;

91
notifysrv/postframe.js
View File

@@ -1,91 +0,0 @@
"use strict";
var cl = global.botanLoader;
var Dragonfly = global.Dragonfly;
var PostRequestEventArgs = cl.load( "notifysrv.eventargs.postrequest" );
var EventEmitter = require( "events" ).EventEmitter;
class PostFrame extends EventEmitter
{
constructor( Http )
{
super();
this.HTTP = Http;
this.result = "Error: PostFrame is unhandled";
this.planted = false;
}
run()
{
var _self = this;
var requestStr = "";
if( this.HTTP.request.isPost )
{
var Req = this.HTTP.request.raw;
var ReceiveData = function( data )
{
requestStr += data + "";
if( 51200 < requestStr.length )
{
_self.result = "The size of request is too big ( 500KB < )";
Req.removeListener( "data", ReceiveData );
Req.removeListener( "end", ReceiveEnd );
_self.plantResult();
}
};
var ReceiveEnd = function()
{
var EventArgs = new PostRequestEventArgs( requestStr );
_self.emit( "PostRequest", this, EventArgs );
if( !EventArgs.Handled )
{
_self.result = "Error: Unhandled Request";
_self.plantResult();
}
};
Req.addListener( "data", ReceiveData );
Req.addListener( "end", ReceiveEnd );
return;
}
else
{
Dragonfly.Info(
"GET: " + encodeURI( this.HTTP.request.raw.url )
+ " - " + this.HTTP.request.raw.headers["user-agent"]
, Dragonfly.Visibility.VISIBLE
);
}
this.plantResult();
}
plantResult()
{
if( !this.planted )
{
this.planted = true;
if( this.HTTP )
{
if( !( this.result instanceof Buffer ) )
{
this.result = String( this.result );
}
this.HTTP.response.headers["Content-Type"] = "text/plain";
this.HTTP.response.headers["Content-Length"] = this.result.length;
this.HTTP.response.write( this.result );
this.HTTP.response.end();
}
}
}
}
module.exports = PostFrame;

14
notifysrv/utils/querystr.js
View File

@@ -1,14 +0,0 @@
module.exports = {
queryStr: function( qstr )
{
var qObj = {};
qstr.split( "&" ).forEach( function( val )
{
val = val.split( "=" );
qObj[ val[0] ] = val[1] ? decodeURIComponent( val[1].replace( /\+/g, " " ) ) : true;
} );
return qObj;
}
};

15
notifysrv/utils/random.js
View File

@@ -1,15 +0,0 @@
var lut = []; for ( var i=0; i<256; i++ ) { lut[i] = (i<16?'0':'')+(i).toString(16); }
module.exports = {
uuid: function()
{
var d0 = Math.random()*0xffffffff|0;
var d1 = Math.random()*0xffffffff|0;
var d2 = Math.random()*0xffffffff|0;
var d3 = Math.random()*0xffffffff|0;
return lut[d0&0xff]+lut[d0>>8&0xff]+lut[d0>>16&0xff]+lut[d0>>24&0xff]+'-'+
lut[d1&0xff]+lut[d1>>8&0xff]+'-'+lut[d1>>16&0x0f|0x40]+lut[d1>>24&0xff]+'-'+
lut[d2&0x3f|0x80]+lut[d2>>8&0xff]+'-'+lut[d2>>16&0xff]+lut[d2>>24&0xff]+
lut[d3&0xff]+lut[d3>>8&0xff]+lut[d3>>16&0xff]+lut[d3>>24&0xff];
}
};

13
notifysrv/utils/string.js
View File

@@ -1,13 +0,0 @@
module.exports = {
encodeHtml: function ( str, br )
{
str = ( str + "" ).replace(/&/g, "&amp;")
.replace(/</g, "&lt;")
.replace(/>/g, "&gt;")
.replace(/"/g, "&quot;")
.replace(/'/g, "&apos;")
;
if( br ) str = str.replace( /\n/g, "<br/>" );
return str;
}
}