Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Sign in
Toggle navigation
N
node-bigstream
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
3
Merge Requests
3
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
bs
node-bigstream
Commits
56224bd3
Commit
56224bd3
authored
Jun 02, 2017
by
project
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
--no commit message
--no commit message
parent
9dd23062
Show whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
37 additions
and
16 deletions
+37
-16
response.js
lib/ws/response.js
+11
-0
service-object.js
storage-service/ws/v0.1/service-object.js
+25
-11
test.js
test/test.js
+1
-5
No files found.
lib/ws/response.js
View file @
56224bd3
...
@@ -40,6 +40,17 @@ responseHelper.prototype.setLastModified = function(lm){
...
@@ -40,6 +40,17 @@ responseHelper.prototype.setLastModified = function(lm){
}
}
responseHelper
.
prototype
.
responseOK
=
responseResult
;
responseHelper
.
prototype
.
responseOK
=
responseResult
;
responseHelper
.
prototype
.
write
=
function
(
data
)
{
this
.
response
.
write
(
data
);
}
responseHelper
.
prototype
.
endOK
=
function
()
{
this
.
response
.
status
(
200
).
end
();
}
responseHelper
.
prototype
.
response304
=
function
(){
responseHelper
.
prototype
.
response304
=
function
(){
this
.
response
.
status
(
304
).
send
(
'Not Modified'
);
this
.
response
.
status
(
304
).
send
(
'Not Modified'
);
}
}
...
...
storage-service/ws/v0.1/service-object.js
View file @
56224bd3
...
@@ -17,7 +17,8 @@ router.get('/:id',function (req, res) {
...
@@ -17,7 +17,8 @@ router.get('/:id',function (req, res) {
var
respHelper
=
response
.
create
(
res
);
var
respHelper
=
response
.
create
(
res
);
var
oid
=
req
.
params
.
id
;
var
oid
=
req
.
params
.
id
;
get_object
(
reqHelper
,
respHelper
,
oid
);
var
opt
=
{}
get_object
(
reqHelper
,
respHelper
,{
'oid'
:
oid
,
'opt'
:
opt
});
});
});
...
@@ -27,13 +28,19 @@ router.get('/:id/data',function (req, res) {
...
@@ -27,13 +28,19 @@ router.get('/:id/data',function (req, res) {
var
query
=
reqHelper
.
getQuery
();
var
query
=
reqHelper
.
getQuery
();
var
oid
=
req
.
params
.
id
;
var
oid
=
req
.
params
.
id
;
get_object
(
reqHelper
,
respHelper
,
oid
);
var
opt
=
{
'field'
:
'data'
}
get_object
(
reqHelper
,
respHelper
,{
'oid'
:
oid
,
'opt'
:
opt
});
});
});
function
get_object
(
reqHelper
,
respHelper
,
oid
,
opt
)
function
get_object
(
reqHelper
,
respHelper
,
prm
)
{
{
opt
=
opt
||
{};
prm
=
prm
||
{};
var
oid
=
prm
.
oid
;
var
opt
=
prm
.
opt
||
{};
if
(
!
oid
){
if
(
!
oid
){
return
respHelper
.
response404
();
return
respHelper
.
response404
();
...
@@ -75,7 +82,7 @@ function get_object(reqHelper,respHelper,oid,opt)
...
@@ -75,7 +82,7 @@ function get_object(reqHelper,respHelper,oid,opt)
rd
.
objectAt
(
seq
,
function
(
err
,
obj
){
rd
.
objectAt
(
seq
,
function
(
err
,
obj
){
bss
.
close
(
function
(
err
){
bss
.
close
(
function
(
err
){
if
(
obj
&&
obj_id
.
toString
()
==
(
new
ObjId
(
obj
.
header
.
ID
)).
toString
()){
if
(
obj
&&
obj_id
.
toString
()
==
(
new
ObjId
(
obj
.
header
.
ID
)).
toString
()){
respHelper
.
responseOK
(
obj_out
(
obj
)
);
output
(
respHelper
,
obj
,
opt
);
}
else
{
respHelper
.
response404
();}
}
else
{
respHelper
.
response404
();}
});
});
});
});
...
@@ -89,12 +96,19 @@ function get_object(reqHelper,respHelper,oid,opt)
...
@@ -89,12 +96,19 @@ function get_object(reqHelper,respHelper,oid,opt)
}
}
function
obj_out
(
obj
,
opt
){
function
output
(
resp
,
obj
,
opt
)
return
{
"_id"
:
(
new
ObjId
(
obj
.
header
.
ID
)).
toString
(),
{
obj_out
(
resp
,
obj
,
opt
);
}
function
obj_out
(
resp
,
obj
,
opt
){
var
ret
=
{
"_id"
:
(
new
ObjId
(
obj
.
header
.
ID
)).
toString
(),
"meta"
:
obj
.
meta
,
"meta"
:
obj
.
meta
,
"data"
:
obj
.
data
"data"
:
obj
.
data
}
}
resp
.
responseOK
(
ret
);
}
}
module
.
exports
=
router
;
module
.
exports
=
router
;
test/test.js
View file @
56224bd3
...
@@ -241,8 +241,4 @@ var job_config = {
...
@@ -241,8 +241,4 @@ var job_config = {
// console.log(crons.list);
// console.log(crons.list);
// });
// });
var
wUrl
=
"http://203.155.220.231/Radar/pics/zfiltered.jpg"
;
var
dat
=
'hello'
;
var
request
=
require
(
'request'
).
defa
request
.
get
(
wUrl
,
function
(
err
,
res
,
body
)
{
console
.
log
(
body
);
});
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment