// Copyright Joyent, Inc. and other Node contributors.

//

// Permission is hereby granted, free of charge, to any person obtaining a

// copy of this software and associated documentation files (the

// "Software"), to deal in the Software without restriction, including

// without limitation the rights to use, copy, modify, merge, publish,

// distribute, sublicense, and/or sell copies of the Software, and to permit

// persons to whom the Software is furnished to do so, subject to the

// following conditions:

//

// The above copyright notice and this permission notice shall be included

// in all copies or substantial portions of the Software.

//

// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS

// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF

// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN

// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,

// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR

// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE

// USE OR OTHER DEALINGS IN THE SOFTWARE.

#include "node.h"

#include "node_buffer.h"

#include "node_internals.h"

#include "node_stat_watcher.h"

#include "env.h"

#include "env-inl.h"

#include "req-wrap.h"

#include "req-wrap-inl.h"

#include "string_bytes.h"

#include "util.h"

#include <fcntl.h>

#include <sys/types.h>

#include <sys/stat.h>

#include <string.h>

#include <errno.h>

#include <limits.h>

#if defined(__MINGW32__) || defined(_MSC_VER)

# include <io.h>

#endif

#include <vector>

namespace node {

namespace {

using v8::Array;

using v8::ArrayBuffer;

using v8::Context;

using v8::Float64Array;

using v8::Function;

using v8::FunctionCallbackInfo;

using v8::FunctionTemplate;

using v8::HandleScope;

using v8::Integer;

using v8::Local;

using v8::Number;

using v8::Object;

using v8::String;

using v8::Value;

#ifndef MIN

# define MIN(a, b) ((a) < (b) ? (a) : (b))

#endif

#define TYPE_ERROR(msg) env->ThrowTypeError(msg)

#define GET_OFFSET(a) ((a)->IsNumber() ? (a)->IntegerValue() : -1)

class FSReqWrap: public ReqWrap<uv_fs_t> {

public:

enum Ownership { COPY, MOVE };

inline static FSReqWrap* New(Environment* env,

Local<Object> req,

const char* syscall,

const char* data = nullptr,

enum encoding encoding = UTF8,

Ownership ownership = COPY);

inline void Dispose();

void ReleaseEarly() {

if (data_ != inline_data()) {

delete[] data_;

data_ = nullptr;

}

}

const char* syscall() const { return syscall_; }

const char* data() const { return data_; }

const enum encoding encoding_;

size_t self_size() const override { return sizeof(*this); }

private:

FSReqWrap(Environment* env,

Local<Object> req,

const char* syscall,

const char* data,

enum encoding encoding)

: ReqWrap(env, req, AsyncWrap::PROVIDER_FSREQWRAP),

encoding_(encoding),

syscall_(syscall),

data_(data) {

Wrap(object(), this);

}

~FSReqWrap() { ReleaseEarly(); }

void* operator new(size_t size) = delete;

void* operator new(size_t size, char* storage) { return storage; }

char* inline_data() { return reinterpret_cast<char*>(this + 1); }

const char* syscall_;

const char* data_;

DISALLOW_COPY_AND_ASSIGN(FSReqWrap);

};

#define ASSERT_PATH(path) \

if (*path == nullptr) \

return TYPE_ERROR( #path " must be a string or Buffer");

FSReqWrap* FSReqWrap::New(Environment* env,

Local<Object> req,

const char* syscall,

const char* data,

enum encoding encoding,

Ownership ownership) {

const bool copy = (data != nullptr && ownership == COPY);

const size_t size = copy ? 1 + strlen(data) : 0;

FSReqWrap* that;

char* const storage = new char[sizeof(*that) + size];

that = new(storage) FSReqWrap(env, req, syscall, data, encoding);

if (copy)

that->data_ = static_cast<char*>(memcpy(that->inline_data(), data, size));

return that;

}

void FSReqWrap::Dispose() {

this->~FSReqWrap();

delete[] reinterpret_cast<char*>(this);

}

void NewFSReqWrap(const FunctionCallbackInfo<Value>& args) {

CHECK(args.IsConstructCall());

}

inline bool IsInt64(double x) {

return x == static_cast<double>(static_cast<int64_t>(x));

}

void After(uv_fs_t *req) {

FSReqWrap* req_wrap = static_cast<FSReqWrap*>(req->data);

CHECK_EQ(req_wrap->req(), req);

req_wrap->ReleaseEarly(); // Free memory that's no longer used now.

Environment* env = req_wrap->env();

HandleScope handle_scope(env->isolate());

Context::Scope context_scope(env->context());

// there is always at least one argument. "error"

int argc = 1;

// Allocate space for two args. We may only use one depending on the case.

// (Feel free to increase this if you need more)

Local<Value> argv[2];

Local<Value> link;

if (req->result < 0) {

// An error happened.

argv[0] = UVException(env->isolate(),

req->result,

req_wrap->syscall(),

nullptr,

req->path,

req_wrap->data());

} else {

// error value is empty or null for non-error.

argv[0] = Null(env->isolate());

// All have at least two args now.

argc = 2;

switch (req->fs_type) {

// These all have no data to pass.

case UV_FS_ACCESS:

case UV_FS_CLOSE:

case UV_FS_RENAME:

case UV_FS_UNLINK:

case UV_FS_RMDIR:

case UV_FS_MKDIR:

case UV_FS_FTRUNCATE:

case UV_FS_FSYNC:

case UV_FS_FDATASYNC:

case UV_FS_LINK:

case UV_FS_SYMLINK:

case UV_FS_CHMOD:

case UV_FS_FCHMOD:

case UV_FS_CHOWN:

case UV_FS_FCHOWN:

// These, however, don't.

argc = 1;

break;

case UV_FS_STAT:

case UV_FS_LSTAT:

case UV_FS_FSTAT:

argc = 1;

FillStatsArray(env->fs_stats_field_array(),

static_cast<const uv_stat_t*>(req->ptr));

break;

case UV_FS_UTIME:

case UV_FS_FUTIME:

argc = 0;

break;

case UV_FS_OPEN:

argv[1] = Integer::New(env->isolate(), req->result);

break;

case UV_FS_WRITE:

argv[1] = Integer::New(env->isolate(), req->result);

break;

case UV_FS_MKDTEMP:

link = StringBytes::Encode(env->isolate(),

static_cast<const char*>(req->path),

req_wrap->encoding_);

if (link.IsEmpty()) {

argv[0] = UVException(env->isolate(),

UV_EINVAL,

req_wrap->syscall(),

"Invalid character encoding for filename",

req->path,

req_wrap->data());

} else {

argv[1] = link;

}

break;

case UV_FS_READLINK:

link = StringBytes::Encode(env->isolate(),

static_cast<const char*>(req->ptr),

req_wrap->encoding_);

if (link.IsEmpty()) {

argv[0] = UVException(env->isolate(),

UV_EINVAL,

req_wrap->syscall(),

"Invalid character encoding for link",

req->path,

req_wrap->data());

} else {

argv[1] = link;

}

break;

case UV_FS_REALPATH:

link = StringBytes::Encode(env->isolate(),

static_cast<const char*>(req->ptr),

req_wrap->encoding_);

if (link.IsEmpty()) {

argv[0] = UVException(env->isolate(),

UV_EINVAL,

req_wrap->syscall(),

"Invalid character encoding for link",

req->path,

req_wrap->data());

} else {

argv[1] = link;

}

break;

case UV_FS_READ:

// Buffer interface

argv[1] = Integer::New(env->isolate(), req->result);

break;

case UV_FS_SCANDIR:

{

int r;

Local<Array> names = Array::New(env->isolate(), 0);

Local<Function> fn = env->push_values_to_array_function();

Local<Value> name_argv[NODE_PUSH_VAL_TO_ARRAY_MAX];

size_t name_idx = 0;

for (int i = 0; ; i++) {

uv_dirent_t ent;

r = uv_fs_scandir_next(req, &ent);

if (r == UV_EOF)

break;

if (r != 0) {

argv[0] = UVException(r,

nullptr,

req_wrap->syscall(),

static_cast<const char*>(req->path));

break;

}

Local<Value> filename = StringBytes::Encode(env->isolate(),

ent.name,

req_wrap->encoding_);

if (filename.IsEmpty()) {

argv[0] = UVException(env->isolate(),

UV_EINVAL,

req_wrap->syscall(),

"Invalid character encoding for filename",

req->path,

req_wrap->data());

break;

}

name_argv[name_idx++] = filename;

if (name_idx >= arraysize(name_argv)) {

fn->Call(env->context(), names, name_idx, name_argv)

.ToLocalChecked();

name_idx = 0;

}

}

if (name_idx > 0) {

fn->Call(env->context(), names, name_idx, name_argv)

.ToLocalChecked();

}

argv[1] = names;

}

break;

default:

CHECK(0 && "Unhandled eio response");

}

}

req_wrap->MakeCallback(env->oncomplete_string(), argc, argv);

uv_fs_req_cleanup(req_wrap->req());

req_wrap->Dispose();

}

// This struct is only used on sync fs calls.

// For async calls FSReqWrap is used.

class fs_req_wrap {

public:

fs_req_wrap() {}

~fs_req_wrap() { uv_fs_req_cleanup(&req); }

uv_fs_t req;

private:

DISALLOW_COPY_AND_ASSIGN(fs_req_wrap);

};

#define ASYNC_DEST_CALL(func, request, dest, encoding, ...) \

Environment* env = Environment::GetCurrent(args); \

CHECK(request->IsObject()); \

FSReqWrap* req_wrap = FSReqWrap::New(env, request.As<Object>(), \

#func, dest, encoding); \

int err = uv_fs_ ## func(env->event_loop(), \

req_wrap->req(), \

__VA_ARGS__, \

After); \

req_wrap->Dispatched(); \

if (err < 0) { \

uv_fs_t* uv_req = req_wrap->req(); \

uv_req->result = err; \

uv_req->path = nullptr; \

After(uv_req); \

req_wrap = nullptr; \

} else { \

args.GetReturnValue().Set(req_wrap->persistent()); \

}

#define ASYNC_CALL(func, req, encoding, ...) \

ASYNC_DEST_CALL(func, req, nullptr, encoding, __VA_ARGS__) \

#define SYNC_DEST_CALL(func, path, dest, ...) \

fs_req_wrap req_wrap; \

env->PrintSyncTrace(); \

int err = uv_fs_ ## func(env->event_loop(), \

&req_wrap.req, \

__VA_ARGS__, \

nullptr); \

if (err < 0) { \

return env->ThrowUVException(err, #func, nullptr, path, dest); \

} \

#define SYNC_CALL(func, path, ...) \

SYNC_DEST_CALL(func, path, nullptr, __VA_ARGS__) \

#define SYNC_REQ req_wrap.req

#define SYNC_RESULT err

void Access(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args.GetIsolate());

HandleScope scope(env->isolate());

if (args.Length() < 2)

return TYPE_ERROR("path and mode are required");

if (!args[1]->IsInt32())

return TYPE_ERROR("mode must be an integer");

BufferValue path(env->isolate(), args[0]);

ASSERT_PATH(path)

int mode = static_cast<int>(args[1]->Int32Value());

if (args[2]->IsObject()) {

ASYNC_CALL(access, args[2], UTF8, *path, mode);

} else {

SYNC_CALL(access, *path, *path, mode);

}

}

void Close(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args);

if (args.Length() < 1)

return TYPE_ERROR("fd is required");

if (!args[0]->IsInt32())

return TYPE_ERROR("fd must be a file descriptor");

int fd = args[0]->Int32Value();

if (args[1]->IsObject()) {

ASYNC_CALL(close, args[1], UTF8, fd)

} else {

SYNC_CALL(close, 0, fd)

}

}

} // anonymous namespace

void FillStatsArray(double* fields, const uv_stat_t* s) {

fields[0] = s->st_dev;

fields[1] = s->st_mode;

fields[2] = s->st_nlink;

fields[3] = s->st_uid;

fields[4] = s->st_gid;

fields[5] = s->st_rdev;

#if defined(__POSIX__)

fields[6] = s->st_blksize;

#else

fields[6] = -1;

#endif

fields[7] = s->st_ino;

fields[8] = s->st_size;

#if defined(__POSIX__)

fields[9] = s->st_blocks;

#else

fields[9] = -1;

#endif

// Dates.

#define X(idx, name) \

fields[idx] = (static_cast<double>(s->st_##name.tv_sec) * 1000) + \

(static_cast<double>(s->st_##name.tv_nsec / 1000000)); \

X(10, atim)

X(11, mtim)

X(12, ctim)

X(13, birthtim)

#undef X

}

// Used to speed up module loading. Returns the contents of the file as

// a string or undefined when the file cannot be opened. The speedup

// comes from not creating Error objects on failure.

static void InternalModuleReadFile(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args);

uv_loop_t* loop = env->event_loop();

CHECK(args[0]->IsString());

node::Utf8Value path(env->isolate(), args[0]);

uv_fs_t open_req;

const int fd = uv_fs_open(loop, &open_req, *path, O_RDONLY, 0, nullptr);

uv_fs_req_cleanup(&open_req);

if (fd < 0) {

return;

}

const size_t kBlockSize = 32 << 10;

std::vector<char> chars;

int64_t offset = 0;

ssize_t numchars;

do {

const size_t start = chars.size();

chars.resize(start + kBlockSize);

uv_buf_t buf;

buf.base = &chars[start];

buf.len = kBlockSize;

uv_fs_t read_req;

numchars = uv_fs_read(loop, &read_req, fd, &buf, 1, offset, nullptr);

uv_fs_req_cleanup(&read_req);

CHECK_GE(numchars, 0);

offset += numchars;

} while (static_cast<size_t>(numchars) == kBlockSize);

uv_fs_t close_req;

CHECK_EQ(0, uv_fs_close(loop, &close_req, fd, nullptr));

uv_fs_req_cleanup(&close_req);

size_t start = 0;

if (offset >= 3 && 0 == memcmp(&chars[0], "\xEF\xBB\xBF", 3)) {

start = 3; // Skip UTF-8 BOM.

}

Local<String> chars_string =

String::NewFromUtf8(env->isolate(),

&chars[start],

String::kNormalString,

offset - start);

args.GetReturnValue().Set(chars_string);

}

// Used to speed up module loading. Returns 0 if the path refers to

// a file, 1 when it's a directory or < 0 on error (usually -ENOENT.)

// The speedup comes from not creating thousands of Stat and Error objects.

static void InternalModuleStat(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args);

CHECK(args[0]->IsString());

node::Utf8Value path(env->isolate(), args[0]);

uv_fs_t req;

int rc = uv_fs_stat(env->event_loop(), &req, *path, nullptr);

if (rc == 0) {

const uv_stat_t* const s = static_cast<const uv_stat_t*>(req.ptr);

rc = !!(s->st_mode & S_IFDIR);

}

uv_fs_req_cleanup(&req);

args.GetReturnValue().Set(rc);

}

static void Stat(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args);

if (args.Length() < 1)

return TYPE_ERROR("path required");

BufferValue path(env->isolate(), args[0]);

ASSERT_PATH(path)

if (args[1]->IsObject()) {

ASYNC_CALL(stat, args[1], UTF8, *path)

} else {

SYNC_CALL(stat, *path, *path)

FillStatsArray(env->fs_stats_field_array(),

static_cast<const uv_stat_t*>(SYNC_REQ.ptr));

}

}

static void LStat(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args);

if (args.Length() < 1)

return TYPE_ERROR("path required");

BufferValue path(env->isolate(), args[0]);

ASSERT_PATH(path)

if (args[1]->IsObject()) {

ASYNC_CALL(lstat, args[1], UTF8, *path)

} else {

SYNC_CALL(lstat, *path, *path)

FillStatsArray(env->fs_stats_field_array(),

static_cast<const uv_stat_t*>(SYNC_REQ.ptr));

}

}

static void FStat(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args);

if (args.Length() < 1)

return TYPE_ERROR("fd is required");

if (!args[0]->IsInt32())

return TYPE_ERROR("fd must be a file descriptor");

int fd = args[0]->Int32Value();

if (args[1]->IsObject()) {

ASYNC_CALL(fstat, args[1], UTF8, fd)

} else {

SYNC_CALL(fstat, nullptr, fd)

FillStatsArray(env->fs_stats_field_array(),

static_cast<const uv_stat_t*>(SYNC_REQ.ptr));

}

}

static void Symlink(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args);

int len = args.Length();

if (len < 1)

return TYPE_ERROR("target path required");

if (len < 2)

return TYPE_ERROR("src path required");

BufferValue target(env->isolate(), args[0]);

ASSERT_PATH(target)

BufferValue path(env->isolate(), args[1]);

ASSERT_PATH(path)

int flags = 0;

if (args[2]->IsString()) {

node::Utf8Value mode(env->isolate(), args[2]);

if (strcmp(*mode, "dir") == 0) {

flags |= UV_FS_SYMLINK_DIR;

} else if (strcmp(*mode, "junction") == 0) {

flags |= UV_FS_SYMLINK_JUNCTION;

} else if (strcmp(*mode, "file") != 0) {

return env->ThrowError("Unknown symlink type");

}

}

if (args[3]->IsObject()) {

ASYNC_DEST_CALL(symlink, args[3], *path, UTF8, *target, *path, flags)

} else {

SYNC_DEST_CALL(symlink, *target, *path, *target, *path, flags)

}

}

static void Link(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args);

int len = args.Length();

if (len < 1)

return TYPE_ERROR("src path required");

if (len < 2)

return TYPE_ERROR("dest path required");

BufferValue src(env->isolate(), args[0]);

ASSERT_PATH(src)

BufferValue dest(env->isolate(), args[1]);

ASSERT_PATH(dest)

if (args[2]->IsObject()) {

ASYNC_DEST_CALL(link, args[2], *dest, UTF8, *src, *dest)

} else {

SYNC_DEST_CALL(link, *src, *dest, *src, *dest)

}

}

static void ReadLink(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args);

const int argc = args.Length();

if (argc < 1)

return TYPE_ERROR("path required");

BufferValue path(env->isolate(), args[0]);

ASSERT_PATH(path)

const enum encoding encoding = ParseEncoding(env->isolate(), args[1], UTF8);

Local<Value> callback = Null(env->isolate());

if (argc == 3)

callback = args[2];

if (callback->IsObject()) {

ASYNC_CALL(readlink, callback, encoding, *path)

} else {

SYNC_CALL(readlink, *path, *path)

const char* link_path = static_cast<const char*>(SYNC_REQ.ptr);

Local<Value> rc = StringBytes::Encode(env->isolate(),

link_path,

encoding);

if (rc.IsEmpty()) {

return env->ThrowUVException(UV_EINVAL,

"readlink",

"Invalid character encoding for link",

*path);

}

args.GetReturnValue().Set(rc);

}

}

static void Rename(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args);

int len = args.Length();

if (len < 1)

return TYPE_ERROR("old path required");

if (len < 2)

return TYPE_ERROR("new path required");

BufferValue old_path(env->isolate(), args[0]);

ASSERT_PATH(old_path)

BufferValue new_path(env->isolate(), args[1]);

ASSERT_PATH(new_path)

if (args[2]->IsObject()) {

ASYNC_DEST_CALL(rename, args[2], *new_path, UTF8, *old_path, *new_path)

} else {

SYNC_DEST_CALL(rename, *old_path, *new_path, *old_path, *new_path)

}

}

static void FTruncate(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args);

if (args.Length() < 2)

return TYPE_ERROR("fd and length are required");

if (!args[0]->IsInt32())

return TYPE_ERROR("fd must be a file descriptor");

int fd = args[0]->Int32Value();

// FIXME(bnoordhuis) It's questionable to reject non-ints here but still

// allow implicit coercion from null or undefined to zero. Probably best

// handled in lib/fs.js.

Local<Value> len_v(args[1]);

if (!len_v->IsUndefined() &&

!len_v->IsNull() &&

!IsInt64(len_v->NumberValue())) {

return env->ThrowTypeError("Not an integer");

}

const int64_t len = len_v->IntegerValue();

if (args[2]->IsObject()) {

ASYNC_CALL(ftruncate, args[2], UTF8, fd, len)

} else {

SYNC_CALL(ftruncate, 0, fd, len)

}

}

static void Fdatasync(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args);

if (args.Length() < 1)

return TYPE_ERROR("fd is required");

if (!args[0]->IsInt32())

return TYPE_ERROR("fd must be a file descriptor");

int fd = args[0]->Int32Value();

if (args[1]->IsObject()) {

ASYNC_CALL(fdatasync, args[1], UTF8, fd)

} else {

SYNC_CALL(fdatasync, 0, fd)

}

}

static void Fsync(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args);

if (args.Length() < 1)

return TYPE_ERROR("fd is required");

if (!args[0]->IsInt32())

return TYPE_ERROR("fd must be a file descriptor");

int fd = args[0]->Int32Value();

if (args[1]->IsObject()) {

ASYNC_CALL(fsync, args[1], UTF8, fd)

} else {

SYNC_CALL(fsync, 0, fd)

}

}

static void Unlink(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args);

if (args.Length() < 1)

return TYPE_ERROR("path required");

BufferValue path(env->isolate(), args[0]);

ASSERT_PATH(path)

if (args[1]->IsObject()) {

ASYNC_CALL(unlink, args[1], UTF8, *path)

} else {

SYNC_CALL(unlink, *path, *path)

}

}

static void RMDir(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args);

if (args.Length() < 1)

return TYPE_ERROR("path required");

BufferValue path(env->isolate(), args[0]);

ASSERT_PATH(path)

if (args[1]->IsObject()) {

ASYNC_CALL(rmdir, args[1], UTF8, *path)

} else {

SYNC_CALL(rmdir, *path, *path)

}

}

static void MKDir(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args);

if (args.Length() < 2)

return TYPE_ERROR("path and mode are required");

if (!args[1]->IsInt32())

return TYPE_ERROR("mode must be an integer");

BufferValue path(env->isolate(), args[0]);

ASSERT_PATH(path)

int mode = static_cast<int>(args[1]->Int32Value());

if (args[2]->IsObject()) {

ASYNC_CALL(mkdir, args[2], UTF8, *path, mode)

} else {

SYNC_CALL(mkdir, *path, *path, mode)

}

}

static void RealPath(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args);

const int argc = args.Length();

if (argc < 1)

return TYPE_ERROR("path required");

BufferValue path(env->isolate(), args[0]);

ASSERT_PATH(path)

const enum encoding encoding = ParseEncoding(env->isolate(), args[1], UTF8);

Local<Value> callback = Null(env->isolate());

if (argc == 3)

callback = args[2];

if (callback->IsObject()) {

ASYNC_CALL(realpath, callback, encoding, *path);

} else {

SYNC_CALL(realpath, *path, *path);

const char* link_path = static_cast<const char*>(SYNC_REQ.ptr);

Local<Value> rc = StringBytes::Encode(env->isolate(),

link_path,

encoding);

if (rc.IsEmpty()) {

return env->ThrowUVException(UV_EINVAL,

"realpath",

"Invalid character encoding for path",

*path);

}

args.GetReturnValue().Set(rc);

}

}

static void ReadDir(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args);

const int argc = args.Length();

if (argc < 1)

return TYPE_ERROR("path required");

BufferValue path(env->isolate(), args[0]);

ASSERT_PATH(path)

const enum encoding encoding = ParseEncoding(env->isolate(), args[1], UTF8);

Local<Value> callback = Null(env->isolate());

if (argc == 3)

callback = args[2];

if (callback->IsObject()) {

ASYNC_CALL(scandir, callback, encoding, *path, 0 /*flags*/)

} else {

SYNC_CALL(scandir, *path, *path, 0 /*flags*/)

CHECK_GE(SYNC_REQ.result, 0);

int r;

Local<Array> names = Array::New(env->isolate(), 0);

Local<Function> fn = env->push_values_to_array_function();

Local<Value> name_v[NODE_PUSH_VAL_TO_ARRAY_MAX];

size_t name_idx = 0;

for (int i = 0; ; i++) {

uv_dirent_t ent;

r = uv_fs_scandir_next(&SYNC_REQ, &ent);

if (r == UV_EOF)

break;

if (r != 0)

return env->ThrowUVException(r, "readdir", "", *path);

Local<Value> filename = StringBytes::Encode(env->isolate(),

ent.name,

encoding);

if (filename.IsEmpty()) {

return env->ThrowUVException(UV_EINVAL,

"readdir",

"Invalid character encoding for filename",

*path);

}

name_v[name_idx++] = filename;

if (name_idx >= arraysize(name_v)) {

fn->Call(env->context(), names, name_idx, name_v)

.ToLocalChecked();

name_idx = 0;

}

}

if (name_idx > 0) {

fn->Call(env->context(), names, name_idx, name_v).ToLocalChecked();

}

args.GetReturnValue().Set(names);

}

}

static void Open(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args);

int len = args.Length();

if (len < 1)

return TYPE_ERROR("path required");

if (len < 2)

return TYPE_ERROR("flags required");

if (len < 3)

return TYPE_ERROR("mode required");

if (!args[1]->IsInt32())

return TYPE_ERROR("flags must be an int");

if (!args[2]->IsInt32())

return TYPE_ERROR("mode must be an int");

BufferValue path(env->isolate(), args[0]);

ASSERT_PATH(path)

int flags = args[1]->Int32Value();

int mode = static_cast<int>(args[2]->Int32Value());

if (args[3]->IsObject()) {

ASYNC_CALL(open, args[3], UTF8, *path, flags, mode)

} else {

SYNC_CALL(open, *path, *path, flags, mode)

args.GetReturnValue().Set(SYNC_RESULT);

}

}

// Wrapper for write(2).

//

// bytesWritten = write(fd, buffer, offset, length, position, callback)

// 0 fd integer. file descriptor

// 1 buffer the data to write

// 2 offset where in the buffer to start from

// 3 length how much to write

// 4 position if integer, position to write at in the file.

// if null, write from the current position

static void WriteBuffer(const FunctionCallbackInfo<Value>& args) {

Environment* env = Environment::GetCurrent(args);

if (!args[0]->IsInt32())

return env->ThrowTypeError("First argument must be file descriptor");

CHECK(Buffer::HasInstance(args[1]));

int fd = args[0]->Int32Value();

Local<Object> obj = args[1].As<Object>();

const char* buf = Buffer::Data(obj);

size_t buffer_length = Buffer::Length(obj);

size_t off = args[2]->Uint32Value();

size_t len = args[3]->Uint32Value();

int64_t pos = GET_OFFSET(args[4]);

Local<Value> req = args[5];

if (off > buffer_length)

return env->ThrowRangeError("offset out of bounds");

if (len > buffer_length)

return env->ThrowRangeError("length out of bounds");

if (off + len < off)

return env->ThrowRangeError("off + len overflow");

if (!Buffer::IsWithinBounds(off, len, buffer_length))

return env->ThrowRangeError("off + len > buffer.length");

buf += off;

uv_buf_t uvbuf = uv_buf_init(const_cast<char*>(buf), len);