| // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file |
| // for details. All rights reserved. Use of this source code is governed by a |
| // BSD-style license that can be found in the LICENSE file. |
| |
| #include "bin/directory.h" |
| |
| #include "bin/dartutils.h" |
| #include "bin/thread.h" |
| #include "include/dart_api.h" |
| #include "platform/assert.h" |
| |
| |
| namespace dart { |
| namespace bin { |
| |
| // Forward declaration. |
| static void DirectoryService(Dart_Port, Dart_Port, Dart_CObject*); |
| |
| NativeService Directory::directory_service_("DirectoryService", |
| DirectoryService, |
| 16); |
| |
| |
| void FUNCTION_NAME(Directory_Current)(Dart_NativeArguments args) { |
| Dart_EnterScope(); |
| char* current = Directory::Current(); |
| if (current != NULL) { |
| Dart_SetReturnValue(args, DartUtils::NewString(current)); |
| free(current); |
| } |
| Dart_ExitScope(); |
| } |
| |
| |
| void FUNCTION_NAME(Directory_Exists)(Dart_NativeArguments args) { |
| static const int kExists = 1; |
| static const int kDoesNotExist = 0; |
| Dart_EnterScope(); |
| Dart_Handle path = Dart_GetNativeArgument(args, 0); |
| Directory::ExistsResult result = |
| Directory::Exists(DartUtils::GetStringValue(path)); |
| if (result == Directory::EXISTS) { |
| Dart_SetReturnValue(args, Dart_NewInteger(kExists)); |
| } else if (result == Directory::DOES_NOT_EXIST) { |
| Dart_SetReturnValue(args, Dart_NewInteger(kDoesNotExist)); |
| } else { |
| Dart_Handle err = DartUtils::NewDartOSError(); |
| if (Dart_IsError(err)) Dart_PropagateError(err); |
| Dart_SetReturnValue(args, err); |
| } |
| Dart_ExitScope(); |
| } |
| |
| |
| void FUNCTION_NAME(Directory_Create)(Dart_NativeArguments args) { |
| Dart_EnterScope(); |
| Dart_Handle path = Dart_GetNativeArgument(args, 0); |
| if (Directory::Create(DartUtils::GetStringValue(path))) { |
| Dart_SetReturnValue(args, Dart_True()); |
| } else { |
| Dart_Handle err = DartUtils::NewDartOSError(); |
| if (Dart_IsError(err)) Dart_PropagateError(err); |
| Dart_SetReturnValue(args, err); |
| } |
| Dart_ExitScope(); |
| } |
| |
| |
| void FUNCTION_NAME(Directory_CreateTemp)(Dart_NativeArguments args) { |
| Dart_EnterScope(); |
| Dart_Handle path = Dart_GetNativeArgument(args, 0); |
| char* result = Directory::CreateTemp(DartUtils::GetStringValue(path)); |
| if (result != NULL) { |
| Dart_SetReturnValue(args, DartUtils::NewString(result)); |
| free(result); |
| } else { |
| Dart_Handle err = DartUtils::NewDartOSError(); |
| if (Dart_IsError(err)) Dart_PropagateError(err); |
| Dart_SetReturnValue(args, err); |
| } |
| Dart_ExitScope(); |
| } |
| |
| |
| void FUNCTION_NAME(Directory_Delete)(Dart_NativeArguments args) { |
| Dart_EnterScope(); |
| Dart_Handle path = Dart_GetNativeArgument(args, 0); |
| Dart_Handle recursive = Dart_GetNativeArgument(args, 1); |
| if (Directory::Delete(DartUtils::GetStringValue(path), |
| DartUtils::GetBooleanValue(recursive))) { |
| Dart_SetReturnValue(args, Dart_True()); |
| } else { |
| Dart_Handle err = DartUtils::NewDartOSError(); |
| if (Dart_IsError(err)) Dart_PropagateError(err); |
| Dart_SetReturnValue(args, err); |
| } |
| Dart_ExitScope(); |
| } |
| |
| |
| void FUNCTION_NAME(Directory_Rename)(Dart_NativeArguments args) { |
| Dart_EnterScope(); |
| Dart_Handle path = Dart_GetNativeArgument(args, 0); |
| Dart_Handle newPath = Dart_GetNativeArgument(args, 1); |
| if (Directory::Rename(DartUtils::GetStringValue(path), |
| DartUtils::GetStringValue(newPath))) { |
| Dart_SetReturnValue(args, Dart_True()); |
| } else { |
| Dart_Handle err = DartUtils::NewDartOSError(); |
| if (Dart_IsError(err)) Dart_PropagateError(err); |
| Dart_SetReturnValue(args, err); |
| } |
| Dart_ExitScope(); |
| } |
| |
| |
| void FUNCTION_NAME(Directory_List)(Dart_NativeArguments args) { |
| Dart_EnterScope(); |
| Dart_Handle path = Dart_GetNativeArgument(args, 0); |
| Dart_Handle recursive = Dart_GetNativeArgument(args, 1); |
| // Create the list to hold the directory listing here, and pass it to the |
| // SyncDirectoryListing object, which adds elements to it. |
| Dart_Handle follow_links = Dart_GetNativeArgument(args, 2); |
| // Create the list to hold the directory listing here, and pass it to the |
| // SyncDirectoryListing object, which adds elements to it. |
| Dart_Handle results = |
| Dart_New(DartUtils::GetDartClass(DartUtils::kCoreLibURL, "List"), |
| Dart_Null(), |
| 0, |
| NULL); |
| SyncDirectoryListing sync_listing(results); |
| Directory::List(DartUtils::GetStringValue(path), |
| DartUtils::GetBooleanValue(recursive), |
| DartUtils::GetBooleanValue(follow_links), |
| &sync_listing); |
| Dart_SetReturnValue(args, results); |
| Dart_ExitScope(); |
| } |
| |
| |
| static CObject* DirectoryCreateRequest(const CObjectArray& request) { |
| if (request.Length() == 2 && request[1]->IsString()) { |
| CObjectString path(request[1]); |
| if (Directory::Create(path.CString())) { |
| return CObject::True(); |
| } else { |
| return CObject::NewOSError(); |
| } |
| } |
| return CObject::IllegalArgumentError(); |
| } |
| |
| |
| static CObject* DirectoryDeleteRequest(const CObjectArray& request) { |
| if (request.Length() == 3 && request[1]->IsString() && request[2]->IsBool()) { |
| CObjectString path(request[1]); |
| CObjectBool recursive(request[2]); |
| if (Directory::Delete(path.CString(), recursive.Value())) { |
| return CObject::True(); |
| } else { |
| return CObject::NewOSError(); |
| } |
| } |
| return CObject::IllegalArgumentError(); |
| } |
| |
| |
| static CObject* DirectoryExistsRequest(const CObjectArray& request) { |
| static const int kExists = 1; |
| static const int kDoesNotExist = 0; |
| if (request.Length() == 2 && request[1]->IsString()) { |
| CObjectString path(request[1]); |
| Directory::ExistsResult result = Directory::Exists(path.CString()); |
| if (result == Directory::EXISTS) { |
| return new CObjectInt32(CObject::NewInt32(kExists)); |
| } else if (result == Directory::DOES_NOT_EXIST) { |
| return new CObjectInt32(CObject::NewInt32(kDoesNotExist)); |
| } else { |
| return CObject::NewOSError(); |
| } |
| } |
| return CObject::IllegalArgumentError(); |
| } |
| |
| |
| static CObject* DirectoryCreateTempRequest(const CObjectArray& request) { |
| if (request.Length() == 2 && request[1]->IsString()) { |
| CObjectString path(request[1]); |
| char* result = Directory::CreateTemp(path.CString()); |
| if (result != NULL) { |
| CObject* temp_dir = new CObjectString(CObject::NewString(result)); |
| free(result); |
| return temp_dir; |
| } else { |
| return CObject::NewOSError(); |
| } |
| } |
| return CObject::IllegalArgumentError(); |
| } |
| |
| |
| static CObject* DirectoryListRequest(const CObjectArray& request, |
| Dart_Port response_port) { |
| if (request.Length() == 4 && |
| request[1]->IsString() && |
| request[2]->IsBool() && |
| request[3]->IsBool()) { |
| AsyncDirectoryListing* dir_listing = |
| new AsyncDirectoryListing(response_port); |
| CObjectString path(request[1]); |
| CObjectBool recursive(request[2]); |
| CObjectBool follow_links(request[3]); |
| bool completed = Directory::List( |
| path.CString(), recursive.Value(), follow_links.Value(), dir_listing); |
| delete dir_listing; |
| CObjectArray* response = new CObjectArray(CObject::NewArray(2)); |
| response->SetAt( |
| 0, |
| new CObjectInt32(CObject::NewInt32(AsyncDirectoryListing::kListDone))); |
| response->SetAt(1, CObject::Bool(completed)); |
| return response; |
| } |
| // Respond with an illegal argument list error message. |
| CObjectArray* response = new CObjectArray(CObject::NewArray(3)); |
| response->SetAt(0, new CObjectInt32( |
| CObject::NewInt32(AsyncDirectoryListing::kListError))); |
| response->SetAt(1, CObject::Null()); |
| response->SetAt(2, CObject::IllegalArgumentError()); |
| Dart_PostCObject(response_port, response->AsApiCObject()); |
| |
| response = new CObjectArray(CObject::NewArray(2)); |
| response->SetAt( |
| 0, new CObjectInt32(CObject::NewInt32(AsyncDirectoryListing::kListDone))); |
| response->SetAt(1, CObject::False()); |
| return response; |
| } |
| |
| |
| static CObject* DirectoryRenameRequest(const CObjectArray& request, |
| Dart_Port response_port) { |
| if (request.Length() == 3 && |
| request[1]->IsString() && |
| request[2]->IsString()) { |
| CObjectString path(request[1]); |
| CObjectString new_path(request[2]); |
| bool completed = Directory::Rename(path.CString(), new_path.CString()); |
| if (completed) return CObject::True(); |
| return CObject::NewOSError(); |
| } |
| return CObject::IllegalArgumentError(); |
| } |
| |
| |
| static void DirectoryService(Dart_Port dest_port_id, |
| Dart_Port reply_port_id, |
| Dart_CObject* message) { |
| CObject* response = CObject::IllegalArgumentError(); |
| CObjectArray request(message); |
| if (message->type == Dart_CObject::kArray) { |
| if (request.Length() > 1 && request[0]->IsInt32()) { |
| CObjectInt32 requestType(request[0]); |
| switch (requestType.Value()) { |
| case Directory::kCreateRequest: |
| response = DirectoryCreateRequest(request); |
| break; |
| case Directory::kDeleteRequest: |
| response = DirectoryDeleteRequest(request); |
| break; |
| case Directory::kExistsRequest: |
| response = DirectoryExistsRequest(request); |
| break; |
| case Directory::kCreateTempRequest: |
| response = DirectoryCreateTempRequest(request); |
| break; |
| case Directory::kListRequest: |
| response = DirectoryListRequest(request, reply_port_id); |
| break; |
| case Directory::kRenameRequest: |
| response = DirectoryRenameRequest(request, reply_port_id); |
| break; |
| default: |
| UNREACHABLE(); |
| } |
| } |
| } |
| |
| Dart_PostCObject(reply_port_id, response->AsApiCObject()); |
| } |
| |
| |
| Dart_Port Directory::GetServicePort() { |
| return directory_service_.GetServicePort(); |
| } |
| |
| |
| void FUNCTION_NAME(Directory_NewServicePort)(Dart_NativeArguments args) { |
| Dart_EnterScope(); |
| Dart_SetReturnValue(args, Dart_Null()); |
| Dart_Port service_port = Directory::GetServicePort(); |
| if (service_port != ILLEGAL_PORT) { |
| // Return a send port for the service port. |
| Dart_Handle send_port = Dart_NewSendPort(service_port); |
| Dart_SetReturnValue(args, send_port); |
| } |
| Dart_ExitScope(); |
| } |
| |
| |
| CObjectArray* AsyncDirectoryListing::NewResponse(Response type, char* arg) { |
| CObjectArray* response = new CObjectArray(CObject::NewArray(2)); |
| response->SetAt(0, new CObjectInt32(CObject::NewInt32(type))); |
| response->SetAt(1, new CObjectString(CObject::NewString(arg))); |
| return response; |
| } |
| |
| |
| bool AsyncDirectoryListing::HandleDirectory(char* dir_name) { |
| CObjectArray* response = NewResponse(kListDirectory, dir_name); |
| return Dart_PostCObject(response_port_, response->AsApiCObject()); |
| } |
| |
| |
| bool AsyncDirectoryListing::HandleFile(char* file_name) { |
| CObjectArray* response = NewResponse(kListFile, file_name); |
| return Dart_PostCObject(response_port_, response->AsApiCObject()); |
| } |
| |
| |
| bool AsyncDirectoryListing::HandleLink(char* link_name) { |
| CObjectArray* response = NewResponse(kListLink, link_name); |
| return Dart_PostCObject(response_port_, response->AsApiCObject()); |
| } |
| |
| |
| bool AsyncDirectoryListing::HandleError(const char* dir_name) { |
| CObject* err = CObject::NewOSError(); |
| CObjectArray* response = new CObjectArray(CObject::NewArray(3)); |
| response->SetAt(0, new CObjectInt32(CObject::NewInt32(kListError))); |
| response->SetAt(1, new CObjectString(CObject::NewString(dir_name))); |
| response->SetAt(2, err); |
| return Dart_PostCObject(response_port_, response->AsApiCObject()); |
| } |
| |
| bool SyncDirectoryListing::HandleDirectory(char* dir_name) { |
| Dart_Handle dir_name_dart = DartUtils::NewString(dir_name); |
| Dart_Handle dir = |
| Dart_New(directory_class_, Dart_Null(), 1, &dir_name_dart); |
| Dart_Invoke(results_, add_string_, 1, &dir); |
| return true; |
| } |
| |
| bool SyncDirectoryListing::HandleLink(char* link_name) { |
| Dart_Handle link_name_dart = DartUtils::NewString(link_name); |
| Dart_Handle link = |
| Dart_New(link_class_, Dart_Null(), 1, &link_name_dart); |
| Dart_Invoke(results_, add_string_, 1, &link); |
| return true; |
| } |
| |
| bool SyncDirectoryListing::HandleFile(char* file_name) { |
| Dart_Handle file_name_dart = DartUtils::NewString(file_name); |
| Dart_Handle file = |
| Dart_New(file_class_, Dart_Null(), 1, &file_name_dart); |
| Dart_Invoke(results_, add_string_, 1, &file); |
| return true; |
| } |
| |
| bool SyncDirectoryListing::HandleError(const char* dir_name) { |
| Dart_Handle dart_os_error = DartUtils::NewDartOSError(); |
| Dart_Handle args[3]; |
| args[0] = DartUtils::NewString("Directory listing failed"); |
| args[1] = DartUtils::NewString(dir_name); |
| args[2] = dart_os_error; |
| Dart_ThrowException(Dart_New( |
| DartUtils::GetDartClass(DartUtils::kIOLibURL, "DirectoryIOException"), |
| Dart_Null(), |
| 3, |
| args)); |
| return true; |
| } |
| |
| } // namespace bin |
| } // namespace dart |