import 'dart:convert'; import 'dart:ffi'; import 'dart:io'; import 'dart:isolate'; import 'dart:io' show Platform; import 'package:cwtch/cwtch/cwtchNotifier.dart'; import 'package:path/path.dart' as path; import 'package:ffi/ffi.dart'; import 'package:cwtch/cwtch/cwtch.dart'; import '../config.dart'; import "package:path/path.dart" show dirname, join; import 'dart:io' show Platform; ///////////////////// /// Cwtch API /// ///////////////////// typedef start_cwtch_function = Int8 Function(Pointer str, Int32 length, Pointer str2, Int32 length2); typedef StartCwtchFn = int Function(Pointer dir, int len, Pointer tor, int torLen); typedef void_from_void_funtion = Void Function(); typedef VoidFromVoidFunction = void Function(); typedef free_function = Void Function(Pointer); typedef FreeFn = void Function(Pointer); typedef void_from_string_string_function = Void Function(Pointer, Int32, Pointer, Int32); typedef VoidFromStringStringFn = void Function(Pointer, int, Pointer, int); typedef void_from_string_string_string_function = Void Function(Pointer, Int32, Pointer, Int32, Pointer, Int32); typedef VoidFromStringStringStringFn = void Function(Pointer, int, Pointer, int, Pointer, int); typedef void_from_string_string_string_string_function = Void Function(Pointer, Int32, Pointer, Int32, Pointer, Int32, Pointer, Int32); typedef VoidFromStringStringStringStringFn = void Function(Pointer, int, Pointer, int, Pointer, int, Pointer, int); // DownloadFile typedef void_from_string_int_string_string_string_function = Void Function(Pointer, Int32, Int32, Pointer, Int32, Pointer, Int32, Pointer, Int32); typedef VoidFromStringIntStringStringStringFn = void Function(Pointer, int, int, Pointer, int, Pointer, int, Pointer, int); typedef void_from_string_string_int_int_function = Void Function(Pointer, Int32, Pointer, Int32, Int64, Int64); typedef VoidFromStringStringIntIntFn = void Function(Pointer, int, Pointer, int, int, int); typedef void_from_string_string_byte_function = Void Function(Pointer, Int32, Pointer, Int32, Int8); typedef VoidFromStringStringByteFn = void Function(Pointer, int, Pointer, int, int); typedef string_to_void_function = Void Function(Pointer str, Int32 length); typedef StringFn = void Function(Pointer dir, int); typedef string_string_to_void_function = Void Function(Pointer str, Int32 length, Pointer str2, Int32 length2); typedef StringStringFn = void Function(Pointer, int, Pointer, int); typedef string_int_to_void_function = Void Function(Pointer str, Int32 length, Int32 handle); typedef VoidFromStringIntFn = void Function(Pointer, int, int); typedef get_json_blob_string_function = Pointer Function(Pointer str, Int32 length); typedef GetJsonBlobStringFn = Pointer Function(Pointer str, int len); //func GetMessage(profile_ptr *C.char, profile_len C.int, handle_ptr *C.char, handle_len C.int, message_index C.int) *C.char { typedef get_json_blob_from_str_str_int_function = Pointer Function(Pointer, Int32, Pointer, Int32, Int32); typedef GetJsonBlobFromStrStrIntFn = Pointer Function(Pointer, int, Pointer, int, int); typedef get_json_blob_from_str_int_int_function = Pointer Function(Pointer, Int32, Int32, Int32); typedef GetJsonBlobFromStrIntIntFn = Pointer Function(Pointer, int, int, int); typedef get_json_blob_from_str_int_string_function = Pointer Function(Pointer, Int32, Int32, Pointer, Int32); typedef GetJsonBlobFromStrIntStringFn = Pointer Function( Pointer, int, int, Pointer, int, ); // func c_GetMessagesByContentHash(profile_ptr *C.char, profile_len C.int, handle_ptr *C.char, handle_len C.int, contenthash_ptr *C.char, contenthash_len C.int) *C.char typedef get_json_blob_from_str_str_str_function = Pointer Function(Pointer, Int32, Pointer, Int32, Pointer, Int32); typedef GetJsonBlobFromStrStrStrFn = Pointer Function(Pointer, int, Pointer, int, Pointer, int); typedef void_from_string_int_string_function = Void Function(Pointer, Int32, Int32, Pointer, Int32); typedef VoidFromStringIntStringFn = void Function(Pointer, int, int, Pointer, int); typedef void_from_string_int_string_string_function = Void Function(Pointer, Int32, Int32, Pointer, Int32, Pointer, Int32); typedef VoidFromStringIntStringStringFn = void Function(Pointer, int, int, Pointer, int, Pointer, int); typedef void_from_string_int_int_int_string_string_function = Void Function(Pointer, Int32, Int32, Int32, Int32, Pointer, Int32, Pointer, Int32); typedef VoidFromStringIntIntIntStringStringFn = void Function(Pointer, int, int, int, int, Pointer, int, Pointer, int); typedef void_from_string_int_int_function = Void Function(Pointer, Int32, Int32, Int32); typedef VoidFromStringIntIntFn = void Function(Pointer, int, int, int); typedef appbus_events_function = Pointer Function(); typedef AppbusEventsFn = Pointer Function(); const String UNSUPPORTED_OS = "unsupported-os"; class CwtchFfi implements Cwtch { late DynamicLibrary library; late CwtchNotifier cwtchNotifier; late Isolate cwtchIsolate; ReceivePort _receivePort = ReceivePort(); static String getLibraryPath() { if (Platform.isWindows) { return "libCwtch.dll"; } else if (Platform.isLinux) { return "libCwtch.so"; } else if (Platform.isMacOS) { print(dirname(Platform.script.path)); return "libCwtch.dylib"; } else { return UNSUPPORTED_OS; } } CwtchFfi(CwtchNotifier _cwtchNotifier) { String libraryPath = getLibraryPath(); if (libraryPath == UNSUPPORTED_OS) { print("OS ${Platform.operatingSystem} not supported by cwtch/ffi"); // emergency, ideally the app stays on splash and just posts the error till user closes exit(0); } library = DynamicLibrary.open(libraryPath); cwtchNotifier = _cwtchNotifier; } // ignore: non_constant_identifier_names Future Start() async { String home = ""; String bundledTor = ""; Map envVars = Platform.environment; String cwtchDir = ""; if (Platform.isLinux) { cwtchDir = envVars['CWTCH_HOME'] ?? path.join(envVars['HOME']!, ".cwtch"); if (await File("linux/tor").exists()) { bundledTor = "linux/tor"; } else if (await File("lib/tor").exists()) { bundledTor = "lib/tor"; } else if (await File(path.join(home, ".local/lib/cwtch/tor")).exists()) { bundledTor = path.join(home, ".local/lib/cwtch/tor"); } else if (await File("/usr/lib/cwtch/tor").exists()) { bundledTor = "/usr/lib/cwtch/tor"; } else { bundledTor = "tor"; } } else if (Platform.isWindows) { cwtchDir = envVars['CWTCH_DIR'] ?? path.join(envVars['UserProfile']!, ".cwtch"); bundledTor = "Tor\\Tor\\tor.exe"; } else if (Platform.isMacOS) { cwtchDir = envVars['CWTCH_HOME'] ?? path.join(envVars['HOME']!, "Library/Application Support/Cwtch"); if (await File("Cwtch.app/Contents/MacOS/Tor/tor.real").exists()) { bundledTor = "Cwtch.app/Contents/MacOS/Tor/tor.real"; } else if (await File("/Applications/Cwtch.app/Contents/MacOS/Tor/tor.real").exists()) { bundledTor = "/Applications/Cwtch.app/Contents/MacOS/Tor/tor.real"; } else if (await File("/Volumes/Cwtch/Cwtch.app/Contents/MacOS/Tor/tor.real").exists()) { bundledTor = "/Volumes/Cwtch/Cwtch.app/Contents/MacOS/Tor/tor.real"; } else if (await File("/Applications/Tor Browser.app/Contents/MacOS/Tor/tor.real").exists()) { bundledTor = "/Applications/Tor Browser.app/Contents/MacOS/Tor/tor.real"; print("We couldn't find Tor in the Cwtch app directory, however we can fall back to the Tor Browser binary"); } else { var splitPath = path.split(dirname(Platform.script.path)); if (splitPath[0] == "/" && splitPath[1] == "Applications") { var appName = splitPath[2]; print("We're running in /Applications in a non standard app name: $appName"); if (await File("/Applications/$appName/Contents/MacOS/Tor/tor.real").exists()) { bundledTor = "/Applications/$appName/Contents/MacOS/Tor/tor.real"; } } } } // the first Cwtch MacOS release (1.2) accidently was a dev build // we need to temporarily remedy this for a release or two then delete // if macOs and release build and no profile and is dev profile // copy dev profile to release profile if (Platform.isMacOS && EnvironmentConfig.BUILD_VER != dev_version) { var devProfileExists = await Directory(path.join(cwtchDir, "dev", "profiles")).exists(); var releaseProfileExists = await Directory(path.join(cwtchDir, "profiles")).exists(); if (devProfileExists && !releaseProfileExists) { print("MacOS one time dev -> release profile migration..."); await Process.run("cp", ["-r", "-p", path.join(cwtchDir, "dev", "profiles"), cwtchDir]); await Process.run("cp", ["-r", "-p", path.join(cwtchDir, "dev", "SALT"), cwtchDir]); await Process.run("cp", ["-r", "-p", path.join(cwtchDir, "dev", "ui.globals"), cwtchDir]); } } if (EnvironmentConfig.BUILD_VER == dev_version) { cwtchDir = path.join(cwtchDir, "dev"); } print("StartCwtch( cwtchdir: $cwtchDir, torPath: $bundledTor )"); var startCwtchC = library.lookup>("c_StartCwtch"); // ignore: non_constant_identifier_names final StartCwtch = startCwtchC.asFunction(); final ut8CwtchDir = cwtchDir.toNativeUtf8(); StartCwtch(ut8CwtchDir, ut8CwtchDir.length, bundledTor.toNativeUtf8(), bundledTor.length); // Spawn an isolate to listen to events from libcwtch-go and then dispatch them when received on main thread to cwtchNotifier cwtchIsolate = await Isolate.spawn(_checkAppbusEvents, _receivePort.sendPort); _receivePort.listen((message) { var env = jsonDecode(message); cwtchNotifier.handleMessage(env["EventType"], env["Data"]); }); } // ignore: non_constant_identifier_names Future ReconnectCwtchForeground() async { var reconnectCwtch = library.lookup>("c_ReconnectCwtchForeground"); // ignore: non_constant_identifier_names final ReconnectCwtchForeground = reconnectCwtch.asFunction(); ReconnectCwtchForeground(); } // Called on object being disposed to (presumably on app close) to close the isolate that's listening to libcwtch-go events @override void dispose() { cwtchIsolate.kill(priority: Isolate.immediate); } // Entry point for an isolate to listen to a stream of events pulled from libcwtch-go and return them on the sendPort static void _checkAppbusEvents(SendPort sendPort) async { var stream = pollAppbusEvents(); await for (var value in stream) { sendPort.send(value); } print("checkAppBusEvents finished..."); } // Steam of appbus events. Call blocks in libcwtch-go GetAppbusEvent. Static so the isolate can use it static Stream pollAppbusEvents() async* { late DynamicLibrary library = DynamicLibrary.open(getLibraryPath()); var getAppbusEventC = library.lookup>("c_GetAppBusEvent"); // ignore: non_constant_identifier_names final GetAppbusEvent = getAppbusEventC.asFunction(); // Embedded Version of _UnsafeFreePointerAnyUseOfThisFunctionMustBeDoubleApproved var free = library.lookup>("c_FreePointer"); final Free = free.asFunction(); // ignore: non_constant_identifier_names final GetAppBusEvent = () { // ignore: non_constant_identifier_names Pointer result = GetAppbusEvent(); String event = result.toDartString(); Free(result); return event; }; while (true) { final event = GetAppBusEvent(); if (event.startsWith("{\"EventType\":\"Shutdown\"")) { print("Shutting down isolate thread: $event"); return; } yield event; } } // ignore: non_constant_identifier_names void CreateProfile(String nick, String pass) { var createProfileC = library.lookup>("c_CreateProfile"); // ignore: non_constant_identifier_names final CreateProfile = createProfileC.asFunction(); final utf8nick = nick.toNativeUtf8(); final ut8pass = pass.toNativeUtf8(); CreateProfile(utf8nick, utf8nick.length, ut8pass, ut8pass.length); malloc.free(utf8nick); malloc.free(ut8pass); } // ignore: non_constant_identifier_names void LoadProfiles(String pass) { var loadProfileC = library.lookup>("c_LoadProfiles"); // ignore: non_constant_identifier_names final LoadProfiles = loadProfileC.asFunction(); final ut8pass = pass.toNativeUtf8(); LoadProfiles(ut8pass, ut8pass.length); malloc.free(ut8pass); } // ignore: non_constant_identifier_names Future GetMessage(String profile, int handle, int index) async { var getMessageC = library.lookup>("c_GetMessage"); // ignore: non_constant_identifier_names final GetMessage = getMessageC.asFunction(); final utf8profile = profile.toNativeUtf8(); Pointer jsonMessageBytes = GetMessage(utf8profile, utf8profile.length, handle, index); String jsonMessage = jsonMessageBytes.toDartString(); _UnsafeFreePointerAnyUseOfThisFunctionMustBeDoubleApproved(jsonMessageBytes); malloc.free(utf8profile); return jsonMessage; } @override // ignore: non_constant_identifier_names void SendProfileEvent(String onion, String json) { var sendAppBusEvent = library.lookup>("c_SendProfileEvent"); // ignore: non_constant_identifier_names final SendAppBusEvent = sendAppBusEvent.asFunction(); final utf8onion = onion.toNativeUtf8(); final utf8json = json.toNativeUtf8(); SendAppBusEvent(utf8onion, utf8onion.length, utf8json, utf8json.length); malloc.free(utf8onion); malloc.free(utf8json); } @override // ignore: non_constant_identifier_names void SendAppEvent(String json) { var sendAppBusEvent = library.lookup>("c_SendAppEvent"); // ignore: non_constant_identifier_names final SendAppBusEvent = sendAppBusEvent.asFunction(); final utf8json = json.toNativeUtf8(); SendAppBusEvent(utf8json, utf8json.length); malloc.free(utf8json); } @override // ignore: non_constant_identifier_names void AcceptContact(String profileOnion, int contactHandle) { var acceptContact = library.lookup>("c_AcceptConversation"); // ignore: non_constant_identifier_names final AcceptContact = acceptContact.asFunction(); final u1 = profileOnion.toNativeUtf8(); AcceptContact(u1, u1.length, contactHandle); malloc.free(u1); } @override // ignore: non_constant_identifier_names void BlockContact(String profileOnion, int contactHandle) { var blockContact = library.lookup>("c_BlockContact"); // ignore: non_constant_identifier_names final BlockContact = blockContact.asFunction(); final u1 = profileOnion.toNativeUtf8(); BlockContact(u1, u1.length, contactHandle); malloc.free(u1); } @override // ignore: non_constant_identifier_names void SendMessage(String profileOnion, int contactHandle, String message) { var sendMessage = library.lookup>("c_SendMessage"); // ignore: non_constant_identifier_names final SendMessage = sendMessage.asFunction(); final u1 = profileOnion.toNativeUtf8(); final u3 = message.toNativeUtf8(); SendMessage(u1, u1.length, contactHandle, u3, u3.length); malloc.free(u1); malloc.free(u3); } @override // ignore: non_constant_identifier_names void SendInvitation(String profileOnion, int contactHandle, int target) { var sendInvitation = library.lookup>("c_SendInvitation"); // ignore: non_constant_identifier_names final SendInvitation = sendInvitation.asFunction(); final u1 = profileOnion.toNativeUtf8(); SendInvitation(u1, u1.length, contactHandle, target); malloc.free(u1); } @override // ignore: non_constant_identifier_names void ShareFile(String profileOnion, int contactHandle, String filepath) { var shareFile = library.lookup>("c_ShareFile"); // ignore: non_constant_identifier_names final ShareFile = shareFile.asFunction(); final u1 = profileOnion.toNativeUtf8(); final u3 = filepath.toNativeUtf8(); ShareFile(u1, u1.length, contactHandle, u3, u3.length); malloc.free(u1); malloc.free(u3); } @override // ignore: non_constant_identifier_names void DownloadFile(String profileOnion, int contactHandle, String filepath, String manifestpath, String filekey) { var dlFile = library.lookup>("c_DownloadFile"); // ignore: non_constant_identifier_names final DownloadFile = dlFile.asFunction(); final u1 = profileOnion.toNativeUtf8(); final u3 = filepath.toNativeUtf8(); final u4 = manifestpath.toNativeUtf8(); final u5 = filekey.toNativeUtf8(); DownloadFile(u1, u1.length, contactHandle, u3, u3.length, u4, u4.length, u5, u5.length); malloc.free(u1); malloc.free(u3); malloc.free(u4); malloc.free(u5); } @override // ignore: non_constant_identifier_names void CreateDownloadableFile(String profileOnion, int contactHandle, String filenameSuggestion, String filekey) { // android only - do nothing } // ignore: non_constant_identifier_names void ExportPreviewedFile(String sourceFile, String suggestion) { // android only - do nothing } @override // ignore: non_constant_identifier_names void CheckDownloadStatus(String profileOnion, String fileKey) { var checkDownloadStatus = library.lookup>("c_CheckDownloadStatus"); // ignore: non_constant_identifier_names final CheckDownloadStatus = checkDownloadStatus.asFunction(); final u1 = profileOnion.toNativeUtf8(); final u2 = fileKey.toNativeUtf8(); CheckDownloadStatus(u1, u1.length, u2, u2.length); malloc.free(u1); malloc.free(u2); } @override // ignore: non_constant_identifier_names void VerifyOrResumeDownload(String profileOnion, int contactHandle, String filekey) { var fn = library.lookup>("c_VerifyOrResumeDownload"); // ignore: non_constant_identifier_names final VerifyOrResumeDownload = fn.asFunction(); final u1 = profileOnion.toNativeUtf8(); final u3 = filekey.toNativeUtf8(); VerifyOrResumeDownload(u1, u1.length, contactHandle, u3, u3.length); malloc.free(u1); malloc.free(u3); } @override // ignore: non_constant_identifier_names void ResetTor() { var resetTor = library.lookup>("c_ResetTor"); // ignore: non_constant_identifier_names final ResetTor = resetTor.asFunction(); ResetTor(); } @override // ignore: non_constant_identifier_names void ImportBundle(String profileOnion, String bundle) { var importBundle = library.lookup>("c_ImportBundle"); // ignore: non_constant_identifier_names final ImportBundle = importBundle.asFunction(); final u1 = profileOnion.toNativeUtf8(); final u2 = bundle.toNativeUtf8(); ImportBundle(u1, u1.length, u2, u2.length); malloc.free(u1); malloc.free(u2); } @override // ignore: non_constant_identifier_names void CreateGroup(String profileOnion, String server, String groupName) { var createGroup = library.lookup>("c_CreateGroup"); // ignore: non_constant_identifier_names final CreateGroup = createGroup.asFunction(); final u1 = profileOnion.toNativeUtf8(); final u2 = server.toNativeUtf8(); final u3 = groupName.toNativeUtf8(); CreateGroup(u1, u1.length, u2, u2.length, u3, u3.length); malloc.free(u1); malloc.free(u2); malloc.free(u3); } @override // ignore: non_constant_identifier_names void ArchiveConversation(String profileOnion, int handle) { var archiveConversation = library.lookup>("c_ArchiveConversation"); // ignore: non_constant_identifier_names final ArchiveConversation = archiveConversation.asFunction(); final u1 = profileOnion.toNativeUtf8(); ArchiveConversation(u1, u1.length, handle); malloc.free(u1); } @override // ignore: non_constant_identifier_names void DeleteContact(String profileOnion, int handle) { var deleteContact = library.lookup>("c_DeleteContact"); // ignore: non_constant_identifier_names final DeleteContact = deleteContact.asFunction(); final u1 = profileOnion.toNativeUtf8(); DeleteContact(u1, u1.length, handle); malloc.free(u1); } @override // ignore: non_constant_identifier_names void DeleteProfile(String onion, String currentPassword) { var deleteprofile = library.lookup>("c_DeleteProfile"); // ignore: non_constant_identifier_names final DeleteProfile = deleteprofile.asFunction(); final u1 = onion.toNativeUtf8(); final u2 = currentPassword.toNativeUtf8(); DeleteProfile(u1, u1.length, u2, u2.length); malloc.free(u1); malloc.free(u2); } @override // ignore: non_constant_identifier_names void SetProfileAttribute(String profile, String key, String val) { var setProfileAttribute = library.lookup>("c_SetProfileAttribute"); // ignore: non_constant_identifier_names final SetProfileAttribute = setProfileAttribute.asFunction(); final u1 = profile.toNativeUtf8(); final u2 = key.toNativeUtf8(); final u3 = val.toNativeUtf8(); SetProfileAttribute(u1, u1.length, u2, u2.length, u3, u3.length); malloc.free(u1); malloc.free(u2); malloc.free(u3); } @override // ignore: non_constant_identifier_names void SetConversationAttribute(String profile, int contact, String key, String val) { var setContactAttribute = library.lookup>("c_SetConversationAttribute"); // ignore: non_constant_identifier_names final SetContactAttribute = setContactAttribute.asFunction(); final u1 = profile.toNativeUtf8(); final u3 = key.toNativeUtf8(); final u4 = val.toNativeUtf8(); SetContactAttribute(u1, u1.length, contact, u3, u3.length, u4, u4.length); malloc.free(u1); malloc.free(u3); malloc.free(u4); } @override // ignore: non_constant_identifier_names void SetMessageAttribute(String profile, int conversation, int channel, int message, String key, String val) { var setMessageAttribute = library.lookup>("c_SetMessageAttribute"); // ignore: non_constant_identifier_names final SetMessageAttribute = setMessageAttribute.asFunction(); final u1 = profile.toNativeUtf8(); final u3 = key.toNativeUtf8(); final u4 = val.toNativeUtf8(); SetMessageAttribute(u1, u1.length, conversation, channel, message, u3, u3.length, u4, u4.length); malloc.free(u1); malloc.free(u3); malloc.free(u4); } @override // ignore: non_constant_identifier_names void LoadServers(String password) { var loadServers = library.lookup>("c_LoadServers"); // ignore: non_constant_identifier_names final LoadServers = loadServers.asFunction(); final u1 = password.toNativeUtf8(); LoadServers(u1, u1.length); malloc.free(u1); } @override // ignore: non_constant_identifier_names void CreateServer(String password, String description, bool autostart) { var createServer = library.lookup>("c_CreateServer"); // ignore: non_constant_identifier_names final CreateServer = createServer.asFunction(); final u1 = password.toNativeUtf8(); final u2 = description.toNativeUtf8(); CreateServer(u1, u1.length, u2, u2.length, autostart ? 1 : 0); malloc.free(u1); malloc.free(u2); } @override // ignore: non_constant_identifier_names void DeleteServer(String serverOnion, String password) { var deleteServer = library.lookup>("c_DeleteServer"); // ignore: non_constant_identifier_names final DeleteServer = deleteServer.asFunction(); final u1 = serverOnion.toNativeUtf8(); final u2 = password.toNativeUtf8(); DeleteServer(u1, u1.length, u2, u2.length); malloc.free(u1); malloc.free(u2); } @override // ignore: non_constant_identifier_names void LaunchServers() { var launchServers = library.lookup>("c_LaunchServers"); // ignore: non_constant_identifier_names final LaunchServers = launchServers.asFunction(); LaunchServers(); } @override // ignore: non_constant_identifier_names void LaunchServer(String serverOnion) { var launchServer = library.lookup>("c_LaunchServer"); // ignore: non_constant_identifier_names final LaunchServer = launchServer.asFunction(); final u1 = serverOnion.toNativeUtf8(); LaunchServer(u1, u1.length); malloc.free(u1); } @override // ignore: non_constant_identifier_names void StopServer(String serverOnion) { var shutdownServer = library.lookup>("c_StopServer"); // ignore: non_constant_identifier_names final ShutdownServer = shutdownServer.asFunction(); final u1 = serverOnion.toNativeUtf8(); ShutdownServer(u1, u1.length); malloc.free(u1); } @override // ignore: non_constant_identifier_names void StopServers() { var shutdownServers = library.lookup>("c_StopServers"); // ignore: non_constant_identifier_names final ShutdownServers = shutdownServers.asFunction(); ShutdownServers(); } @override // ignore: non_constant_identifier_names void DestroyServers() { var destroyServers = library.lookup>("c_DestroyServers"); // ignore: non_constant_identifier_names final DestroyServers = destroyServers.asFunction(); DestroyServers(); } @override // ignore: non_constant_identifier_names void SetServerAttribute(String serverOnion, String key, String val) { var setServerAttribute = library.lookup>("c_SetServerAttribute"); // ignore: non_constant_identifier_names final SetServerAttribute = setServerAttribute.asFunction(); final u1 = serverOnion.toNativeUtf8(); final u2 = key.toNativeUtf8(); final u3 = val.toNativeUtf8(); SetServerAttribute(u1, u1.length, u2, u2.length, u3, u3.length); malloc.free(u1); malloc.free(u2); malloc.free(u3); } @override // ignore: non_constant_identifier_names Future Shutdown() async { var shutdown = library.lookup>("c_ShutdownCwtch"); // ignore: non_constant_identifier_names // Shutdown Cwtch + Tor... // ignore: non_constant_identifier_names final Shutdown = shutdown.asFunction(); Shutdown(); // Kill our Isolate cwtchIsolate.kill(priority: Isolate.immediate); print("Isolate killed"); _receivePort.close(); print("Receive Port Closed"); } @override // ignore: non_constant_identifier_names Future GetMessageByContentHash(String profile, int handle, String contentHash) async { var getMessagesByContentHashC = library.lookup>("c_GetMessagesByContentHash"); // ignore: non_constant_identifier_names final GetMessagesByContentHash = getMessagesByContentHashC.asFunction(); final utf8profile = profile.toNativeUtf8(); final utf8contentHash = contentHash.toNativeUtf8(); Pointer jsonMessageBytes = GetMessagesByContentHash(utf8profile, utf8profile.length, handle, utf8contentHash, utf8contentHash.length); String jsonMessage = jsonMessageBytes.toDartString(); _UnsafeFreePointerAnyUseOfThisFunctionMustBeDoubleApproved(jsonMessageBytes); malloc.free(utf8profile); malloc.free(utf8contentHash); return jsonMessage; } // ignore: non_constant_identifier_names // Incredibly dangerous function which invokes a free in libCwtch, should only be used // as documented in `MEMORY.md` in libCwtch repo. void _UnsafeFreePointerAnyUseOfThisFunctionMustBeDoubleApproved(Pointer ptr) { var free = library.lookup>("c_FreePointer"); final Free = free.asFunction(); Free(ptr); } @override String defaultDownloadPath() { Map envVars = Platform.environment; return path.join(envVars[Platform.isWindows ? 'UserProfile' : 'HOME']!, "Downloads"); } @override // ignore: non_constant_identifier_names Future GetMessageByID(String profile, int handle, int index) async { var getMessageC = library.lookup>("c_GetMessageByID"); // ignore: non_constant_identifier_names final GetMessage = getMessageC.asFunction(); final utf8profile = profile.toNativeUtf8(); Pointer jsonMessageBytes = GetMessage(utf8profile, utf8profile.length, handle, index); String jsonMessage = jsonMessageBytes.toDartString(); _UnsafeFreePointerAnyUseOfThisFunctionMustBeDoubleApproved(jsonMessageBytes); malloc.free(utf8profile); return jsonMessage; } @override // ignore: non_constant_identifier_names void ChangePassword(String profile, String pass, String newpass, String newpassAgain) { var changePasswordC = library.lookup>("c_ChangePassword"); // ignore: non_constant_identifier_names final ChangePasswordFn = changePasswordC.asFunction(); final utf8profile = profile.toNativeUtf8(); final utf8pass = pass.toNativeUtf8(); final utf8newpass = newpass.toNativeUtf8(); final utf8newpasssagain = newpassAgain.toNativeUtf8(); ChangePasswordFn(utf8profile, utf8profile.length, utf8pass, utf8pass.length, utf8newpass, utf8newpass.length, utf8newpasssagain, utf8newpasssagain.length); malloc.free(utf8profile); malloc.free(utf8pass); malloc.free(utf8newpass); malloc.free(utf8newpasssagain); } }