From f1866a03ed1a65876e07416adda7d15114f56f7e Mon Sep 17 00:00:00 2001
From: Gerrit Niezen <gerrit@tidepool.org>
Date: Tue, 5 Mar 2024 11:17:30 +0000
Subject: [PATCH] add extension

---
 extension/background.js              |  51 +++++++
 extension/icon-128.png               | Bin 0 -> 1712 bytes
 extension/manifest.json              |  19 +++
 extension/verio-helper/helper.reg    |   3 +
 extension/verio-helper/helper.zig    | 193 +++++++++++++++++++++++++++
 extension/verio-helper/manifest.json |   9 ++
 6 files changed, 275 insertions(+)
 create mode 100644 extension/background.js
 create mode 100644 extension/icon-128.png
 create mode 100644 extension/manifest.json
 create mode 100644 extension/verio-helper/helper.reg
 create mode 100644 extension/verio-helper/helper.zig
 create mode 100644 extension/verio-helper/manifest.json

diff --git a/extension/background.js b/extension/background.js
new file mode 100644
index 0000000000..84eb53bb80
--- /dev/null
+++ b/extension/background.js
@@ -0,0 +1,51 @@
+
+let reply;
+let port;
+
+function connect() {
+    const hostName = 'org.tidepool.uploader';
+    console.log('Connecting to native messaging host', hostName);
+    port = chrome.runtime.connectNative(hostName);
+    port.onMessage.addListener(onNativeMessage);
+    port.onDisconnect.addListener(onDisconnected);
+}
+
+function sendNativeMessage(message) {
+    port.postMessage(message);
+    //port.postMessage('\n');
+    console.log('Sent message:', JSON.stringify(message));
+}
+  
+function onNativeMessage(message) {
+	if (message.msgType == 'info') {
+    	console.log(message.details);
+    } else {
+ 		reply(message);
+ 	}
+}
+  
+function onDisconnected() {
+    console.log('Disconnected: ' + chrome.runtime.lastError.message);
+    port = null;
+    reply({ msgType: 'error', details: 'Disconnected: ' + chrome.runtime.lastError.message });
+}
+
+chrome.runtime.onMessageExternal.addListener(
+    function(request, sender, sendResponse) {
+        console.log("Received message from the web page:", request);
+
+        if (request.command == "openDevice") {
+        	connect();
+        }
+        
+        // Process the request here
+        if (port) {
+	        sendNativeMessage(request);
+
+	        reply = sendResponse;
+	        return true; // indicates you will asynchronously use sendResponse
+	    } else {
+	    	sendResponse({ msgType: 'error', details: 'Not connected.'});
+	    }
+    }
+);
diff --git a/extension/icon-128.png b/extension/icon-128.png
new file mode 100644
index 0000000000000000000000000000000000000000..dd2cf75b40a5b55ddfd9089ea074edc3ddf1fed9
GIT binary patch
literal 1712
zcmV;h22c5kP)<h;3K|Lk000e1NJLTq004jh004jp0{{R3^x%>C0006UP)t-s0000f
z8b^SDfGHYADH}*B8b(!BRVf-rKtO;g9ZD%2Oeh*gDj7#98c6^D|0x<rD;q~D8Am7?
zM=2UdDH=yfBuOb6M=2XeC>cg58AmA@M=T#pDH=v78Ad4@M<^RnDH=v88b>J^MkpFb
zD;iBeAYd*dQ8OA%D;!5C8b~P_MkpCZDH=yB8%QY{M=TvmC>lm68Ad1>M=2UcDH=y9
z8b>G@M*si+DH=y&eE%yPNP~Km<>Tq!-Q+ACNyER)TypGHNo`MC!Ba<TVtoGo{{CrS
zephJOLNr`CD^)x@g)}W}b7_XSv%>lL`ZFa^LrI=bUBilkn&RN*HZgIxvcY(7i@CMK
zF)3sA_4jpah}hNLsiU<`KxLhls=~g?%*fL|KaGxtonTdVQC`MAF<Cz{TKD$&@bB_0
zAXAo)rBr0nEFn}cAxwRAkE5Kgj)$I~nXQ<Sr%6$+J350iEo<}g^fxI}KR}L9UBtPx
z!ahEVQeev{8An@i=`0{pDjQ0_yU1E@<xN?<E+kqqBu_9VUPCrrH78O1{r%nA;bT~M
zG$v5{`}|l<aIB`c=H%%uA4{sFwpM7`Kths<fts<byzJ}mpqZ`O*x!tVoc#R!wz0rQ
zOr=LUV2FU3k%^#PQFF+|&(O`+oRz9LD^$I>#^mGZJT6ynWrJdT{X02=>gnxpW`w@F
z$2~7tg?*OF$I{c#*`AoJbKM(-0000sbW%=J0AvDCeA)x%1U@C?J#_)EL5=F0!UuL<
z-TZGUr~d5|;i&Y*9tai`B$B}C&R{Y$y)$J+M7*B9L|Om<1Pw_<K~#9!?b`)&;#?F4
z;1dWzOG{}>g?3wN3#HWGTiSKs&)wbK-S%^LcXyXR__4`MhNX}TH*#iY_W1+6GYPrL
z5jy3h)t^X(wc!C>9~jocsYE{o$Eaw<QgRe07)_RnTE!s0rI+-z0$M7p=}T$yjj@`Y
zgVbDh)gV8NWO~u2-pmMjEEMiTNBY7c@=i>Ppkom&M&1bJ2BBmy7a|YD%TQL1lUp-+
zxRReCSLVmy(%3wy+tv*abZ;X?JyCcf+CxgZhTxH*F6!L$1Uxh`O&yw@gr_EFsUuSn
zcq}qS9oRk&&y8>I;P<2OLA31zQ{(W(_!PBeHUghSW~mL+lkm;tG|5fCM-wE~1z&ZM
zM9&a>HPj<H|Dy0&)cI`ehVQz`!8`&mPc6-iApm1D)Jh(K$Wse(1SC#Pg~|v>IYiCm
z5SSb_5gSBc24l39h5%`_MJR#*MMBglj6j8{Q6B=;M-4_0u*Mon1~Tu!wrd@(W#|M(
zFPxpRQ`~Zum0|xi2hTe5MwlLd;=QI0@4EobdJU?#0%sSA<1R+cm6wW|^Up@j{neI!
z{SD4ms9qM1)_)hKy#O8)rt<(?a-iDUo+sfbOLfw7aCAgiHUaDqrV9aFTXpgx9L?2N
zG#B9P<%7a>8Gy@$=?VbvR~;O<70wojY&s;a7RNpGFo5fX>3Ug!8z7+**%l#j(@r78
z&4*C4>lsmV8zcd4zXKABWHSnox$~~O?>Pd?p?mM!i@E@ZPut>w2O(83>;OwpVF!2=
zYASYsWu5@bc7P&JfTA6s#1o)o2T1Y+NZS3UQJw&!{bWgiCjb&;NpS^8ktNI(AWRmG
zD}Y9pVXgqfWEtQJFhCZaD}c@(fc+A%--PUcL-q%e+eh&uRntBwO1V9ZPOqBIfue-l
z;~3{wYo0ph_Bf^_6g~aLvwNO<9&TSqs00?Jx|dQG#byOEo>JKol)Z2i$||x?Gr5;`
zzan0J4QdL8<l|KCb+cCR#+y*GCi^^>`#_j>Ly0acP{@5KOdmnXlB`4{_pva20ttDE
zhO$tx->Tev3KdzZw+bbjp9vv8-++qM#zLi%FTeWw8_3BEm6SoiGVH}_?sC014U3J<
zZ@>Hg2Pg=8(z03qQPlkOv&)u^`kDNTFujY8Y2LK$-V&y_y=mJ~F1P?Wk6O2XC|-hc
z$fM@<`k$g^$6x4B+_U!m#^3+^``=M?D9=8?z&*mjKg7a6#=}3z#6QZ#Kg`BI&c{E{
z$UoA_Kh(-U*2_QG%s<-AKitkg-p{|_z`x?bzvRNd=EJ|}#J}przwE}p?#I9IC}*s+
zxAM7SkZ;lp`l8d)>!QApCcnih%gxt*mn#P6;`1pdtN#HX@vpf(V_BL20000<MNUMn
GLSTY3J{-IN

literal 0
HcmV?d00001

diff --git a/extension/manifest.json b/extension/manifest.json
new file mode 100644
index 0000000000..00f3aaf57d
--- /dev/null
+++ b/extension/manifest.json
@@ -0,0 +1,19 @@
+{
+  "manifest_version": 3,
+  "key": "MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQDcBHwzDvyBQ6bDppkIs9MP4ksKqCMyXQ/A52JivHZKh4YO/9vJsT3oaYhSpDCE9RPocOEQvwsHsFReW2nUEc6OLLyoCFFxIb7KkLGsmfakkut/fFdNJYh0xOTbSN8YvLWcqph09XAY2Y/f0AL7vfO1cuCqtkMt8hFrBGWxDdf9CQIDAQAB",
+  "name": "Native Messaging Example",
+  "version": "1.0",
+  "description": "Send a message to a native application.",
+  "icons": {
+    "128": "icon-128.png"
+  },
+  "permissions": [
+    "nativeMessaging"
+  ],
+  "background": {
+    "service_worker": "background.js"
+  },
+  "externally_connectable": {
+    "matches": ["http://localhost:3005/*"]
+  }
+}
diff --git a/extension/verio-helper/helper.reg b/extension/verio-helper/helper.reg
new file mode 100644
index 0000000000..b2986c2887
--- /dev/null
+++ b/extension/verio-helper/helper.reg
@@ -0,0 +1,3 @@
+Windows Registry Editor Version 5.00
+[HKEY_CURRENT_USER\Software\Google\Chrome\NativeMessagingHosts\org.tidepool.uploader]
+@="C:\\Users\\gerri\\sandbox\\manifest.json"
\ No newline at end of file
diff --git a/extension/verio-helper/helper.zig b/extension/verio-helper/helper.zig
new file mode 100644
index 0000000000..e5e767c056
--- /dev/null
+++ b/extension/verio-helper/helper.zig
@@ -0,0 +1,193 @@
+const std = @import("std");
+const windows = @import("std").os.windows;
+const W = std.unicode.utf8ToUtf16LeStringLiteral;
+const Allocator = std.mem.allocator;
+
+const OpenError = error {
+	InvalidHandle,
+	LockFailed,
+	ReadFailed,	
+};
+
+fn openDevice() !windows.HANDLE {
+    const devicePath = "\\\\.\\E:"; // Change C: to your target volume
+    const FSCTL_LOCK_VOLUME = 0x00090018;
+
+    // Open the volume
+    const handle = windows.kernel32.CreateFileW(
+	W(devicePath),
+	windows.GENERIC_READ | windows.GENERIC_WRITE,
+	windows.FILE_SHARE_READ | windows.FILE_SHARE_WRITE,
+	null,
+	windows.OPEN_EXISTING,
+	windows.FILE_FLAG_NO_BUFFERING,
+	null);
+
+    if (handle == windows.INVALID_HANDLE_VALUE) {
+        try sendReply("error", "Failed to open file");
+        return OpenError.InvalidHandle;
+    }
+	
+    // Lock the volume
+    windows.DeviceIoControl(
+        handle,
+        FSCTL_LOCK_VOLUME,
+        null,
+        null,
+    ) catch {
+		try sendReply("error", "Failed to lock volume");
+        windows.CloseHandle(handle);
+        return OpenError.LockFailed;
+    };
+
+    try sendReply("success", "Volume locked successfully");
+    
+    return handle;
+}
+    
+fn checkDevice(handle: windows.HANDLE) !void {
+    const allocator = std.heap.page_allocator;
+    const alignment = 4096;
+    const size = 512;
+
+    const buffer = try allocator.alignedAlloc(u8, alignment, size);
+    defer allocator.free(buffer);
+
+    @memset(buffer, 0);
+
+    try sendReply("info", "Reading from volume..");
+
+    var bytesRead: windows.DWORD = 0;
+    const readSuccess = windows.kernel32.ReadFile(handle, buffer.ptr, size, &bytesRead, null);
+    if (readSuccess == 0) {
+        try sendReply("error", "Failed to read from volume");
+		return OpenError.ReadFailed;
+    }
+
+    var gpa = std.heap.GeneralPurposeAllocator(.{}){};
+    const printAllocator = gpa.allocator();
+
+    const slice = try std.fmt.allocPrint(printAllocator, "Read {d} bytes from volume.", .{bytesRead});
+	defer printAllocator.free(slice);
+    try sendReply("info", slice);
+    try sendReply("data", buffer[0x2b..0x3b]);
+}
+
+fn retrieveData(seekOffset: u64, linkLayerFrame: []const u8, handle: windows.HANDLE ) !void {
+    const allocator = std.heap.page_allocator;
+    const alignment = 4096;
+    const size = 512;
+
+    var gpa = std.heap.GeneralPurposeAllocator(.{}){};
+    const printAllocator = gpa.allocator();
+    
+	const buffer = try allocator.alignedAlloc(u8, alignment, size);
+	defer allocator.free(buffer);
+
+	@memset(buffer, 0);
+	@memcpy(buffer[0..linkLayerFrame.len], linkLayerFrame);
+
+	try sendReply("info", "Sending request");
+
+	_ = try windows.WriteFile(handle, buffer, seekOffset);
+
+	@memset(buffer, 0);
+
+	const bytesRead = try windows.ReadFile(handle, buffer, seekOffset);
+
+	const slice = try std.fmt.allocPrint(printAllocator, "Read {d} bytes from volume.", .{bytesRead});
+	defer printAllocator.free(slice);
+	try sendReply("info", slice);
+	try sendReply("data", buffer);
+}
+
+pub fn main() !void { 
+
+    const stdin = std.io.getStdIn().reader();
+    var buffer: [4096]u8 = undefined;
+   	var handle: windows.HANDLE = undefined;
+
+   	var gpa = std.heap.GeneralPurposeAllocator(.{}){};
+   	const allocator = gpa.allocator();
+
+   	const Message = struct {
+   		command: []u8,
+   		request: [512]u8 = undefined,
+   		seekOffset: u64 = 0,
+   	};
+
+    while (true) {
+
+	    // Read the length of the incoming message
+	    _ = try stdin.read(&buffer);
+	    
+	    const length = std.mem.readInt(u32, buffer[0..4], .little);
+	    
+	    // Read the message based on the length
+	    const message = std.mem.bytesAsSlice(u8, buffer[4..(length+4)]);
+
+	    const parsed = try std.json.parseFromSlice(
+	        Message,
+	        allocator,
+	        message,
+	        .{},
+	    );
+
+	    const data = parsed.value;
+
+	    if (std.mem.eql(u8, data.command, "openDevice")) {
+	    	try sendReply("info", "Trying to open device");
+			handle = try openDevice();
+		}
+
+		if (std.mem.eql(u8, data.command, "checkDevice")) {
+			try sendReply("info", "Checking device");
+			try checkDevice(handle);
+		}
+
+		if (std.mem.eql(u8, data.command, "retrieveData")) {
+			try sendReply("info", "Retrieving data");
+			try retrieveData(data.seekOffset, &data.request, handle);
+		}
+
+		if (std.mem.eql(u8, data.command, "closeDevice")) {
+			try sendReply("info", "Closing device");
+			break;
+		}
+
+		parsed.deinit();
+	}
+
+	// exit gracefully
+	windows.CloseHandle(handle);
+	std.os.exit(0);
+}
+
+
+
+fn sendReply(msgtype: []const u8, result: []const u8) !void {
+    const stdout = std.io.getStdOut().writer();
+    
+    var gpa = std.heap.GeneralPurposeAllocator(.{}){};
+    defer _ = gpa.deinit();
+    const allocator = gpa.allocator();
+    var string = std.ArrayList(u8).init(allocator);
+
+    const Reply = struct {
+    	msgType: []const u8,
+        details: []const u8,
+    };
+    
+    const x = Reply{
+    	.msgType = msgtype,
+        .details = result,
+    };
+
+    try std.json.stringify(x, .{}, string.writer());
+    const response = try string.toOwnedSlice();
+            
+    var response_length: [4]u8 = undefined;
+    std.mem.writeInt(u32, &response_length, @intCast(response.len), .little);
+    _ = try stdout.write(&response_length);
+    _ = try stdout.writeAll(response);
+}
diff --git a/extension/verio-helper/manifest.json b/extension/verio-helper/manifest.json
new file mode 100644
index 0000000000..31cca5f372
--- /dev/null
+++ b/extension/verio-helper/manifest.json
@@ -0,0 +1,9 @@
+{
+	"name": "org.tidepool.uploader",
+	"description": "Tidepool Uploader",
+	"path": "C:\\Users\\gerri\\sandbox\\native-msg.exe",
+	"type": "stdio",
+	"allowed_origins": [
+		"chrome-extension://knldjmfmopnpolahpmmgbagdohdnhkik/"
+	]
+}