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
159d8c25
Commit
159d8c25
authored
Jun 11, 2021
by
Kamron Aroonrua
💬
Browse files
Options
Browse Files
Download
Plain Diff
Merge branch 'ondev-gcs' into 'dev'
Ondev gcs See merge request
!36
parents
0d663f02
105fc95a
Hide whitespace changes
Inline
Side-by-side
Showing
18 changed files
with
91 additions
and
88 deletions
+91
-88
.env
.env
+1
-1
Changelog
Changelog
+2
-2
docker-compose.yml
docker-compose.yml
+1
-2
jobtask.js
jobworker/lib/jobtask.js
+4
-2
rpccaller.js
lib/amqp/rpccaller.js
+0
-39
file-access-buffer.js
lib/bss/file-access-buffer.js
+2
-1
oat.js
lib/bss/oat.js
+4
-2
objectdata.js
lib/bss/objectdata.js
+14
-4
objid.js
lib/bss/objid.js
+32
-16
root.js
lib/bss/root.js
+18
-9
bsdata.js
lib/model/bsdata.js
+4
-2
perform.js
plugins/di/di-http-request/perform.js
+1
-1
perform.js
plugins/di/di-sftp-filesync/perform.js
+2
-1
image_parser.js
plugins/dt/dt-agritronics/parser/image_parser.js
+1
-1
perform.js
plugins/dt/dt-gistda-air/perform.js
+1
-1
image_parser.js
plugins/dt/dt-tanpibut/parser/image_parser.js
+1
-1
perform.js
plugins/dt/dt-window-event/perform.js
+1
-1
version.json
version.json
+2
-2
No files found.
.env
View file @
159d8c25
BIGSTREAM_
TAG=
test
BIGSTREAM_
IMG=bigstream:
test
BS_SECRET=bigstream-server
BS_SECRET=bigstream-server
REDIS_TAG=4
REDIS_TAG=4
PREFIX_NO=19
PREFIX_NO=19
...
...
Changelog
View file @
159d8c25
#Changelog
#Changelog
## [1.2.4 Dev] - 2021-0
5-3
1
## [1.2.4 Dev] - 2021-0
6-1
1
### Added
### Added
- STORAGE :: Object Cache
- STORAGE :: Object Cache
###
Update
###
Changed
- SS :: Direct Idxstore
- SS :: Direct Idxstore
## [1.2.3] - 2021-05-05
## [1.2.3] - 2021-05-05
### Update
### Update
...
...
docker-compose.yml
View file @
159d8c25
version
:
'
3'
version
:
'
3'
services
:
services
:
bigstream
:
bigstream
:
image
:
"
bigstream:${BIGSTREAM_TAG}"
image
:
"
${BIGSTREAM_IMG}"
build
:
./
container_name
:
bs_bigstream
container_name
:
bs_bigstream
restart
:
always
restart
:
always
networks
:
networks
:
...
...
jobworker/lib/jobtask.js
View file @
159d8c25
...
@@ -217,11 +217,13 @@ JobTask.prototype.run = function ()
...
@@ -217,11 +217,13 @@ JobTask.prototype.run = function ()
if
(
!
err
){
if
(
!
err
){
self
.
stop
(
resp
)
self
.
stop
(
resp
)
// console.log('***** JOB SUCCESSFULLY DONE *****\n');
// console.log('***** JOB SUCCESSFULLY DONE *****\n');
console
.
log
(
'[JOB DONE] id='
+
job_id
+
' ,tr='
+
transaction_id
+
'
\
t
success
'
);
console
.
log
(
'[JOB DONE] id='
+
job_id
+
' ,tr='
+
transaction_id
+
'
\
t
SUCCESS
'
);
}
else
{
}
else
{
self
.
stop
(
err
)
self
.
stop
(
err
)
// console.log('***** JOB UNSUCCESSFULLY DONE *****\n');
// console.log('***** JOB UNSUCCESSFULLY DONE *****\n');
console
.
log
(
'[JOB DONE] id='
+
job_id
+
' ,tr='
+
transaction_id
+
'
\
tunsuccess'
);
var
st
=
'unsuccess'
;
if
(
err
.
status
){
st
=
String
(
err
.
status
).
toUpperCase
()}
console
.
log
(
'[JOB DONE] id='
+
job_id
+
' ,tr='
+
transaction_id
+
'
\
t'
+
st
);
}
}
});
});
...
...
lib/amqp/rpccaller.js
View file @
159d8c25
...
@@ -61,43 +61,4 @@ RPCCaller.prototype.call = function(req,cb){
...
@@ -61,43 +61,4 @@ RPCCaller.prototype.call = function(req,cb){
}
}
}
}
/*
function RPCCaller(config)
{
this.config = config;
this.url = config.url;
this.name = config.name || "rpc_queue";
}
RPCCaller.prototype.call = function(req,cb){
var self = this;
amqp.connect(self.url, function(err, conn) {
conn.createChannel(function(err, ch) {
ch.assertQueue('', {exclusive: true}, function(err, q) {
var corr = generateUuid();
ch.consume(q.queue, function(msg) {
if (msg.properties.correlationId == corr) {
var resp = JSON.parse(msg.content.toString());
conn.close();
cb(null,resp);
}
}, {noAck: true});
ch.sendToQueue(self.name,
new Buffer(JSON.stringify(req)),
{ correlationId: corr, replyTo: q.queue });
});
});
});
function generateUuid() {
return Math.random().toString() +
Math.random().toString() +
Math.random().toString();
}
}
*/
module
.
exports
=
RPCCaller
;
module
.
exports
=
RPCCaller
;
lib/bss/file-access-buffer.js
View file @
159d8c25
...
@@ -46,7 +46,8 @@ FileAccessBuffer.prototype.bufferedRead = function (offset, length, cb) {
...
@@ -46,7 +46,8 @@ FileAccessBuffer.prototype.bufferedRead = function (offset, length, cb) {
var
self
=
this
;
var
self
=
this
;
var
readStart
=
offset
;
var
readStart
=
offset
;
var
readEnd
=
(
offset
+
length
)
-
1
;
var
readEnd
=
(
offset
+
length
)
-
1
;
var
ret_buffer
=
new
Buffer
(
length
);
//var ret_buffer = new Buffer(length);
var
ret_buffer
=
Buffer
.
alloc
(
length
);
if
(
!
self
.
filesize
){
if
(
!
self
.
filesize
){
fs
.
stat
(
self
.
filename
,
function
(
err
,
stats
){
fs
.
stat
(
self
.
filename
,
function
(
err
,
stats
){
...
...
lib/bss/oat.js
View file @
159d8c25
...
@@ -164,7 +164,8 @@ Oat.prototype.readMeta = function(cb){
...
@@ -164,7 +164,8 @@ Oat.prototype.readMeta = function(cb){
}
}
Oat
.
prototype
.
writeMeta
=
function
(
cb
){
Oat
.
prototype
.
writeMeta
=
function
(
cb
){
var
buffer
=
new
Buffer
(
OATMETASIZE
);
//var buffer = new Buffer(OATMETASIZE);
var
buffer
=
Buffer
.
alloc
(
OATMETASIZE
);
BSON
.
serialize
(
this
.
oatmeta
,
buffer
);
BSON
.
serialize
(
this
.
oatmeta
,
buffer
);
this
.
file
.
write
(
this
.
address
,
buffer
,
cb
);
this
.
file
.
write
(
this
.
address
,
buffer
,
cb
);
}
}
...
@@ -174,7 +175,8 @@ Oat.prototype.writeSlot = function(index,data,cb){
...
@@ -174,7 +175,8 @@ Oat.prototype.writeSlot = function(index,data,cb){
return
cb
(
new
Error
(
"Index out of bound"
));
return
cb
(
new
Error
(
"Index out of bound"
));
}
}
var
slotAddr
=
this
.
address
+
OATMETASIZE
+
(
index
*
OBJHEADERSIZE
);
var
slotAddr
=
this
.
address
+
OATMETASIZE
+
(
index
*
OBJHEADERSIZE
);
var
buffer
=
new
Buffer
(
OBJHEADERSIZE
);
//var buffer = new Buffer(OBJHEADERSIZE);
var
buffer
=
Buffer
.
alloc
(
OBJHEADERSIZE
);
BSON
.
serialize
(
data
,
buffer
);
BSON
.
serialize
(
data
,
buffer
);
this
.
file
.
write
(
slotAddr
,
buffer
,
cb
);
this
.
file
.
write
(
slotAddr
,
buffer
,
cb
);
}
}
...
...
lib/bss/objectdata.js
View file @
159d8c25
...
@@ -10,14 +10,22 @@ const OBJECT_TYPE = 3;
...
@@ -10,14 +10,22 @@ const OBJECT_TYPE = 3;
//Header structure
//Header structure
var
header_struct
=
function
(){
var
header_struct
=
function
(){
return
{
// return {
// "ID" : null,
// "TY" : 1,
// "FG" : null,
// "MZ" : 0,
// "DZ" : 0,
// "AD" : 0
// }
return
JSON
.
parse
(
JSON
.
stringify
({
"ID"
:
null
,
"ID"
:
null
,
"TY"
:
1
,
"TY"
:
1
,
"FG"
:
null
,
"FG"
:
null
,
"MZ"
:
0
,
"MZ"
:
0
,
"DZ"
:
0
,
"DZ"
:
0
,
"AD"
:
0
"AD"
:
0
}
}
));
}
}
...
@@ -151,7 +159,8 @@ ObjectData.prototype.write = function(addr,cb){
...
@@ -151,7 +159,8 @@ ObjectData.prototype.write = function(addr,cb){
}
}
var
fd
=
this
.
file
;
var
fd
=
this
.
file
;
var
objBuffer
=
new
Buffer
(
this
.
header
.
MZ
+
this
.
header
.
DZ
)
//var objBuffer = new Buffer(this.header.MZ + this.header.DZ)
var
objBuffer
=
Buffer
.
alloc
(
this
.
header
.
MZ
+
this
.
header
.
DZ
)
if
(
this
.
header
.
MZ
>
0
){
if
(
this
.
header
.
MZ
>
0
){
this
.
metaBuffer
.
copy
(
objBuffer
);
this
.
metaBuffer
.
copy
(
objBuffer
);
}
}
...
@@ -183,7 +192,8 @@ module.exports.createByData = function(fd,prm){
...
@@ -183,7 +192,8 @@ module.exports.createByData = function(fd,prm){
case
'string'
:
case
'string'
:
header
.
TY
=
STRING_TYPE
;
header
.
TY
=
STRING_TYPE
;
header
.
DZ
=
Buffer
.
byteLength
(
data
,
'utf8'
);
header
.
DZ
=
Buffer
.
byteLength
(
data
,
'utf8'
);
dataBuffer
=
new
Buffer
(
data
);
//dataBuffer = new Buffer(data);
dataBuffer
=
Buffer
.
from
(
data
,
'utf8'
);
break
;
break
;
case
'object'
:
case
'object'
:
if
(
data
instanceof
Buffer
){
if
(
data
instanceof
Buffer
){
...
...
lib/bss/objid.js
View file @
159d8c25
...
@@ -7,26 +7,41 @@ function ObjId(prm){
...
@@ -7,26 +7,41 @@ function ObjId(prm){
}
}
this
.
bytes
=
prm
this
.
bytes
=
prm
}
else
if
(
typeof
prm
==
'object'
){
}
else
if
(
typeof
prm
==
'object'
){
var
fhn
=
(
Buffer
.
isBuffer
(
prm
.
fhn
)
)?
prm
.
fhn
:
new
Buffer
(
4
);
//var fhn = (Buffer.isBuffer(prm.fhn) )?prm.fhn:new Buffer(4);
var
fhn
=
(
Buffer
.
isBuffer
(
prm
.
fhn
)
)?
prm
.
fhn
:
Buffer
.
alloc
(
4
);
var
seq
=
prm
.
seq
||
1
;
var
seq
=
prm
.
seq
||
1
;
var
ts
=
(
prm
.
ts
)?
prm
.
ts
:(
Date
.
now
()
/
1000
)
&
0xFFFFFFFF
;
var
ts
=
(
prm
.
ts
)?
prm
.
ts
:(
Date
.
now
()
/
1000
)
&
0xFFFFFFFF
;
seq
=
seq
&
0xFFFFFFFF
;
seq
=
seq
&
0xFFFFFFFF
;
this
.
bytes
=
new
Buffer
([
// this.bytes = new Buffer([
fhn
[
0
],
// fhn[0],
fhn
[
1
],
// fhn[1],
fhn
[
2
],
// fhn[2],
fhn
[
3
],
// fhn[3],
seq
>>
24
,
// seq>>24,
seq
>>
16
,
// seq>>16,
seq
>>
8
,
// seq>>8,
seq
,
// seq,
ts
>>
24
,
// ts>>24,
ts
>>
16
,
// ts>>16,
ts
>>
8
,
// ts>>8,
ts
// ts
]);
// ]);
this
.
bytes
=
Buffer
.
from
([
fhn
[
0
],
fhn
[
1
],
fhn
[
2
],
fhn
[
3
],
seq
>>
24
,
seq
>>
16
,
seq
>>
8
,
seq
,
ts
>>
24
,
ts
>>
16
,
ts
>>
8
,
ts
]);
}
else
if
(
typeof
prm
==
'string'
)
{
}
else
if
(
typeof
prm
==
'string'
)
{
if
(
prm
.
length
!=
24
)
throw
new
Error
(
"String-based ObjectId must be 24 bytes"
)
if
(
prm
.
length
!=
24
)
throw
new
Error
(
"String-based ObjectId must be 24 bytes"
)
...
@@ -52,5 +67,6 @@ var toHex = function(buffer) {
...
@@ -52,5 +67,6 @@ var toHex = function(buffer) {
}
}
var
fromHex
=
function
(
string
)
{
var
fromHex
=
function
(
string
)
{
return
new
Buffer
(
string
,
'hex'
)
//return new Buffer(string, 'hex')
return
Buffer
.
from
(
string
,
'hex'
)
}
}
lib/bss/root.js
View file @
159d8c25
...
@@ -5,14 +5,22 @@ const VERSION = "1.0";
...
@@ -5,14 +5,22 @@ const VERSION = "1.0";
const
OATSIZE
=
10000
;
const
OATSIZE
=
10000
;
var
root_struct
=
function
(){
var
root_struct
=
function
(){
return
{
// return {
"VER"
:
VERSION
,
// "VER":VERSION,
"FHN"
:
new
Buffer
(
4
),
// "FHN":new Buffer(4),
"SEQ"
:
0
,
// "SEQ":0,
"OATA"
:
0
,
// "OATA":0,
"OATZ"
:
OATSIZE
,
// "OATZ":OATSIZE,
"AOF"
:
ROOTSIZE
// "AOF":ROOTSIZE
};
// };
return
JSON
.
parse
(
JSON
.
stringify
({
"VER"
:
VERSION
,
"FHN"
:
Buffer
.
alloc
(
4
),
"SEQ"
:
0
,
"OATA"
:
0
,
"OATZ"
:
OATSIZE
,
"AOF"
:
ROOTSIZE
}));
}
}
module
.
exports
=
Root
;
module
.
exports
=
Root
;
...
@@ -55,7 +63,8 @@ Root.prototype.load = function(cb){
...
@@ -55,7 +63,8 @@ Root.prototype.load = function(cb){
}
}
Root
.
prototype
.
write
=
function
(
cb
){
Root
.
prototype
.
write
=
function
(
cb
){
var
buffer
=
new
Buffer
(
ROOTSIZE
);
//var buffer = new Buffer(ROOTSIZE);
var
buffer
=
Buffer
.
alloc
(
ROOTSIZE
);
BSON
.
serialize
(
this
.
data
,
buffer
);
BSON
.
serialize
(
this
.
data
,
buffer
);
this
.
file
.
write
(
0
,
buffer
,
cb
);
this
.
file
.
write
(
0
,
buffer
,
cb
);
}
}
lib/model/bsdata.js
View file @
159d8c25
...
@@ -8,7 +8,8 @@ module.exports.parse = function(obj)
...
@@ -8,7 +8,8 @@ module.exports.parse = function(obj)
var
bsobj
=
JSON
.
parse
(
obj
);
var
bsobj
=
JSON
.
parse
(
obj
);
var
data
=
bsobj
.
data
;
var
data
=
bsobj
.
data
;
if
(
bsobj
.
data_type
==
'binary'
&&
bsobj
.
encoding
==
'base64'
){
if
(
bsobj
.
data_type
==
'binary'
&&
bsobj
.
encoding
==
'base64'
){
data
=
new
Buffer
(
bsobj
.
data
,
'base64'
);
//data = new Buffer(bsobj.data,'base64');
data
=
Buffer
.
from
(
bsobj
.
data
,
'base64'
);
}
}
return
new
BSData
(
data
,
bsobj
.
data_type
);
return
new
BSData
(
data
,
bsobj
.
data_type
);
...
@@ -21,7 +22,8 @@ module.exports.parse = function(obj)
...
@@ -21,7 +22,8 @@ module.exports.parse = function(obj)
}
else
if
(
((
obj
.
object_type
&&
obj
.
object_type
==
'bsdata'
)
||
(
obj
.
type
&&
obj
.
type
==
'bsdata'
))
&&
obj
.
data_type
&&
obj
.
data
){
}
else
if
(
((
obj
.
object_type
&&
obj
.
object_type
==
'bsdata'
)
||
(
obj
.
type
&&
obj
.
type
==
'bsdata'
))
&&
obj
.
data_type
&&
obj
.
data
){
var
oData
=
obj
.
data
;
var
oData
=
obj
.
data
;
if
(
obj
.
encoding
==
'base64'
){
if
(
obj
.
encoding
==
'base64'
){
oData
=
new
Buffer
(
obj
.
data
,
'base64'
);
//oData = new Buffer(obj.data,'base64');
oData
=
Buffer
.
from
(
obj
.
data
,
'base64'
);
}
}
return
new
BSData
(
oData
,
obj
.
data_type
);
return
new
BSData
(
oData
,
obj
.
data_type
);
}
else
{
}
else
{
...
...
plugins/di/di-http-request/perform.js
View file @
159d8c25
...
@@ -41,7 +41,7 @@ function execute_function(context,response){
...
@@ -41,7 +41,7 @@ function execute_function(context,response){
var
http_headers
=
{};
var
http_headers
=
{};
if
(
param
.
auth
){
if
(
param
.
auth
){
if
(
param
.
auth
.
type
==
'basic'
){
if
(
param
.
auth
.
type
==
'basic'
){
var
auth_header
=
"Basic "
+
new
Buffer
(
param
.
auth
.
username
+
":"
+
param
.
auth
.
password
).
toString
(
"base64"
);
var
auth_header
=
"Basic "
+
Buffer
.
from
(
param
.
auth
.
username
+
":"
+
param
.
auth
.
password
).
toString
(
"base64"
);
http_headers
.
Authorization
=
auth_header
;
http_headers
.
Authorization
=
auth_header
;
}
}
}
}
...
...
plugins/di/di-sftp-filesync/perform.js
View file @
159d8c25
...
@@ -22,7 +22,8 @@ function perform_function(context,response){
...
@@ -22,7 +22,8 @@ function perform_function(context,response){
var
meta
=
{};
var
meta
=
{};
var
last_mod
=
{
'fname'
:
''
,
'tts'
:
0
};
var
last_mod
=
{
'fname'
:
''
,
'tts'
:
0
};
var
fs_continue
=
false
;
var
fs_continue
=
false
;
var
buff_out
=
new
Buffer
(
0
);
//var buff_out = new Buffer(0);
var
buff_out
=
Buffer
.
alloc
(
0
);
if
(
param
.
last_modify_ts
)
if
(
param
.
last_modify_ts
)
{
{
...
...
plugins/dt/dt-agritronics/parser/image_parser.js
View file @
159d8c25
...
@@ -75,7 +75,7 @@ function getImage(url) {
...
@@ -75,7 +75,7 @@ function getImage(url) {
return
new
Promise
((
resolve
,
reject
)
=>
{
return
new
Promise
((
resolve
,
reject
)
=>
{
request
(
url
,
function
(
error
,
resp
,
body
)
{
request
(
url
,
function
(
error
,
resp
,
body
)
{
if
(
!
error
&&
resp
.
statusCode
==
200
)
{
if
(
!
error
&&
resp
.
statusCode
==
200
)
{
resolve
(
"data:"
+
resp
.
headers
[
"content-type"
]
+
";base64,"
+
new
Buffer
(
body
).
toString
(
'base64'
));
resolve
(
"data:"
+
resp
.
headers
[
"content-type"
]
+
";base64,"
+
Buffer
.
from
(
body
).
toString
(
'base64'
));
}
else
{
}
else
{
return
reject
(
error
);
return
reject
(
error
);
}
}
...
...
plugins/dt/dt-gistda-air/perform.js
View file @
159d8c25
...
@@ -138,7 +138,7 @@ function perform_image(_result, filecontent) {
...
@@ -138,7 +138,7 @@ function perform_image(_result, filecontent) {
function
getImage
(
filecontent
)
{
function
getImage
(
filecontent
)
{
return
new
Promise
((
resolve
,
reject
)
=>
{
return
new
Promise
((
resolve
,
reject
)
=>
{
resolve
(
"data:image/jpeg;base64,"
+
new
Buffer
(
filecontent
).
toString
(
'base64'
));
resolve
(
"data:image/jpeg;base64,"
+
Buffer
.
from
(
filecontent
).
toString
(
'base64'
));
});
});
}
}
...
...
plugins/dt/dt-tanpibut/parser/image_parser.js
View file @
159d8c25
...
@@ -75,7 +75,7 @@ function getImage(url) {
...
@@ -75,7 +75,7 @@ function getImage(url) {
return
new
Promise
((
resolve
,
reject
)
=>
{
return
new
Promise
((
resolve
,
reject
)
=>
{
request
(
url
,
function
(
error
,
resp
,
body
)
{
request
(
url
,
function
(
error
,
resp
,
body
)
{
if
(
!
error
&&
resp
.
statusCode
==
200
)
{
if
(
!
error
&&
resp
.
statusCode
==
200
)
{
resolve
(
"data:"
+
resp
.
headers
[
"content-type"
]
+
";base64,"
+
new
Buffer
(
body
).
toString
(
'base64'
));
resolve
(
"data:"
+
resp
.
headers
[
"content-type"
]
+
";base64,"
+
Buffer
.
from
(
body
).
toString
(
'base64'
));
}
else
{
}
else
{
return
reject
(
error
);
return
reject
(
error
);
}
}
...
...
plugins/dt/dt-window-event/perform.js
View file @
159d8c25
...
@@ -29,7 +29,7 @@ function perform_function(context,request,response){
...
@@ -29,7 +29,7 @@ function perform_function(context,request,response){
val
.
forEach
(
function
(
v
){
val
.
forEach
(
function
(
v
){
if
(
typeof
v
.
data
==
'object'
&&
v
.
data
.
type
==
'Buffer'
&&
Array
.
isArray
(
v
.
data
.
data
))
if
(
typeof
v
.
data
==
'object'
&&
v
.
data
.
type
==
'Buffer'
&&
Array
.
isArray
(
v
.
data
.
data
))
{
{
v
.
data
=
new
Buffer
(
v
.
data
.
data
);
v
.
data
=
Buffer
.
from
(
v
.
data
.
data
);
}
}
ret
.
push
(
v
);
ret
.
push
(
v
);
});
});
...
...
version.json
View file @
159d8c25
{
{
"version"
:
"1.2.4"
,
"version"
:
"1.2.4
-ur
"
,
"build"
:
"20210
53100
00"
"build"
:
"20210
61115
00"
}
}
\ No newline at end of file
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