Hawkin
/
arangodb
mirror of https://gitee.com/bigwinds/arangodb
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

added fs.append

This commit is contained in:
Frank Celler 2016-01-24 11:34:00 +01:00
parent 2f106544e7
commit 8a7f409380
3 changed files with 88 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
Documentation/Books/Users/ModuleFs/README.mdpp
View File

@ -227,21 +227,24 @@ the file contents will be returned as a string. Supported encodings are:
If no `encoding` is specified, the file contents will be returned in a Buffer
object.
!SUBSUBSECTION save
writes to a file
!SUBSUBSECTION write
`fs.write(filename, content)`
Writes the content into a file. Content can be a string or a Buffer object.
Writes the content into a file. Content can be a string or a Buffer
object. If the file already exists, it is truncated.
!SUBSUBSECTION writeFileSync
`fs.writeFileSync(filename, content)`
This is an alias for `fs.write(filename, content)`.
!SUBSUBSECTION append
`fs.append(filename, content)`
Writes the content into a file. Content can be a string or a Buffer
object. If the file already exists, the content is appended at the
end.
!SECTION Recursive Manipulation
!SUBSUBSECTION copyRecursive

15
js/common/bootstrap/modules/fs.js
View File

@ -528,13 +528,22 @@ if (global.FS_UNZIP_FILE) {
delete global.FS_UNZIP_FILE;
}
////////////////////////////////////////////////////////////////////////////////
/// @brief append
////////////////////////////////////////////////////////////////////////////////
if (global.SYS_APPEND) {
exports.append = global.SYS_APPEND;
delete global.SYS_APPEND;
}
////////////////////////////////////////////////////////////////////////////////
/// @brief write
////////////////////////////////////////////////////////////////////////////////
if (global.SYS_SAVE) {
exports.write = global.SYS_SAVE;
delete global.SYS_SAVE;
if (global.SYS_WRITE) {
exports.write = global.SYS_WRITE;
delete global.SYS_WRITE;
}
////////////////////////////////////////////////////////////////////////////////

70
lib/V8/v8-utils.cpp
View File

@ -2354,10 +2354,69 @@ static void JS_Read64(v8::FunctionCallbackInfo<v8::Value> const& args) {
}
////////////////////////////////////////////////////////////////////////////////
/// @brief was docuBlock JS_Save
/// @brief append to a file
////////////////////////////////////////////////////////////////////////////////
static void JS_Save(v8::FunctionCallbackInfo<v8::Value> const& args) {
static void JS_Append(v8::FunctionCallbackInfo<v8::Value> const& args) {
TRI_V8_TRY_CATCH_BEGIN(isolate)
v8::HandleScope scope(isolate);
if (args.Length() != 2) {
TRI_V8_THROW_EXCEPTION_USAGE("write(<filename>, <content>)");
}
TRI_Utf8ValueNFC name(TRI_UNKNOWN_MEM_ZONE, args[0]);
if (*name == nullptr) {
TRI_V8_THROW_TYPE_ERROR("<filename> must be a string");
}
if (args[1]->IsObject() && V8Buffer::hasInstance(isolate, args[1])) {
// content is a buffer
char const* data = V8Buffer::data(args[1].As<v8::Object>());
size_t size = V8Buffer::length(args[1].As<v8::Object>());
if (data == nullptr) {
TRI_V8_THROW_EXCEPTION_MESSAGE(TRI_ERROR_BAD_PARAMETER,
"invalid <content> buffer value");
}
ofstream file;
file.open(*name, ios::out | ios::binary | ios::app);
if (file.is_open()) {
file.write(data, size);
file.close();
TRI_V8_RETURN_TRUE();
}
} else {
TRI_Utf8ValueNFC content(TRI_UNKNOWN_MEM_ZONE, args[1]);
if (*content == nullptr) {
TRI_V8_THROW_TYPE_ERROR("<content> must be a string");
}
ofstream file;
file.open(*name, ios::out | ios::binary | ios::app);
if (file.is_open()) {
file << *content;
file.close();
TRI_V8_RETURN_TRUE();
}
}
TRI_V8_THROW_EXCEPTION_SYS("cannot write file");
TRI_V8_TRY_CATCH_END
}
////////////////////////////////////////////////////////////////////////////////
/// @brief write to a file
////////////////////////////////////////////////////////////////////////////////
static void JS_Write(v8::FunctionCallbackInfo<v8::Value> const& args) {
TRI_V8_TRY_CATCH_BEGIN(isolate)
v8::HandleScope scope(isolate);
@ -4110,6 +4169,8 @@ void TRI_InitV8Utils(v8::Isolate* isolate, v8::Handle<v8::Context> context,
TRI_AddGlobalFunctionVocbase(isolate, context,
TRI_V8_ASCII_STRING("FS_ZIP_FILE"), JS_ZipFile);
TRI_AddGlobalFunctionVocbase(isolate, context,
TRI_V8_ASCII_STRING("SYS_APPEND"), JS_Append);
TRI_AddGlobalFunctionVocbase(isolate, context,
TRI_V8_ASCII_STRING("SYS_BASE64DECODE"),
JS_Base64Decode);
@ -4179,8 +4240,6 @@ void TRI_InitV8Utils(v8::Isolate* isolate, v8::Handle<v8::Context> context,
TRI_V8_ASCII_STRING("SYS_READ64"), JS_Read64);
TRI_AddGlobalFunctionVocbase(
isolate, context, TRI_V8_ASCII_STRING("SYS_READ_BUFFER"), JS_ReadBuffer);
TRI_AddGlobalFunctionVocbase(isolate, context,
TRI_V8_ASCII_STRING("SYS_SAVE"), JS_Save);
TRI_AddGlobalFunctionVocbase(isolate, context,
TRI_V8_ASCII_STRING("SYS_SHA1"), JS_Sha1);
TRI_AddGlobalFunctionVocbase(isolate, context,
@ -4204,9 +4263,12 @@ void TRI_InitV8Utils(v8::Isolate* isolate, v8::Handle<v8::Context> context,
TRI_V8_ASCII_STRING("SYS_TIME"), JS_Time);
TRI_AddGlobalFunctionVocbase(isolate, context,
TRI_V8_ASCII_STRING("SYS_WAIT"), JS_Wait);
TRI_AddGlobalFunctionVocbase(isolate, context,
TRI_V8_ASCII_STRING("SYS_WRITE"), JS_Write);
TRI_AddGlobalFunctionVocbase(isolate, context,
TRI_V8_ASCII_STRING("SYS_DEBUG_CAN_USE_FAILAT"),
JS_DebugCanUseFailAt);
// .............................................................................
// create the global variables
// .............................................................................