fix(rsync): utimens, rename, init root folder

packages/fuse-client/syscalls/getattr.ts

@@ -7,20 +7,6 @@ export const getattr: (backend: SQLiteBackend) => MountOptions["getattr"] = (
 ) => {
  return async (path, cb) => {
  console.log("getattr(%s)", path);
- if (path === "/") {
- cb(0, {
- mtime: new Date(),
- atime: new Date(),
- ctime: new Date(),
- nlink: 1,
- size: 100, // Directory size, chosen arbitrarily
- mode: 16877,
- uid: process.getuid ? process.getuid() : 0,
- gid: process.getgid ? process.getgid() : 0,
- });
- return;
- }
-
  const r = await backend.getFile(path);
 
  await match(r)
@@ -39,6 +25,7 @@ export const getattr: (backend: SQLiteBackend) => MountOptions["getattr"] = (
  nlink: 1,
  size: rSize.size,
  mode: mode,
+ // TODO: enable posix mode where real uid/gid are returned
  uid: process.getuid ? process.getuid() : 0,
  gid: process.getgid ? process.getgid() : 0,
  });

packages/fuse-client/syscalls/init.ts

@@ -1,11 +1,24 @@
 import { SQLiteBackend } from "@zoid-fs/sqlite-backend";
-import { MountOptions } from "@zoid-fs/node-fuse-bindings";
+import fuse, { MountOptions } from "@zoid-fs/node-fuse-bindings";
+import { match } from "ts-pattern";
 
 export const init: (backend: SQLiteBackend) => MountOptions["init"] = (
  backend
 ) => {
  return async (cb) => {
  console.log("init");
+
+ //@ts-expect-error fix types
+ const context = fuse.context();
+ const { uid, gid } = context;
+
+ const rootFolder = await backend.getFile("/");
+ match(rootFolder)
+ .with({ status: "ok" }, () => {})
+ .with({ status: "not_found" }, async () => {
+ await backend.createFile("/", "dir", 16877, uid, gid);
+ })
+ .exhaustive();
  cb(0);
  };
 };

packages/fuse-client/syscalls/rename.ts

@@ -1,6 +1,5 @@
 import { SQLiteBackend } from "@zoid-fs/sqlite-backend";
 import fuse, { MountOptions } from "@zoid-fs/node-fuse-bindings";
-import path from "path";
 
 export const rename: (backend: SQLiteBackend) => MountOptions["rename"] = (
  backend
@@ -9,7 +8,7 @@ export const rename: (backend: SQLiteBackend) => MountOptions["rename"] = (
  console.log("rename(%s, %s)", srcPath, destPath);
  const r = await backend.renameFile(srcPath, destPath);
  if (r.status === "ok") {
- console.log("rename(%s, %s) success", srcPath, destPath);
+ console.log("rename(%s, %s)", srcPath, destPath);
  cb(0);
  } else {
  // TODO: can move fail, if yes, when?

packages/fuse-client/syscalls/utimens.ts

@@ -6,6 +6,11 @@ export const utimens: (backend: SQLiteBackend) => MountOptions["utimens"] = (
 ) => {
  return async (path, atime, mtime, cb) => {
  console.log("utimens(%s, %s, %s)", path, atime, mtime);
+ try {
+ await backend.updateTimes(path, atime, mtime);
+ } catch (e) {
+ console.error(e);
+ }
  cb(0);
  };
 };

packages/sqlite-backend/SQLiteBackend.ts

@@ -322,6 +322,14 @@ export class SQLiteBackend implements Backend {
  try {
  const parsedSrcPath = path.parse(srcPath);
  const parsedDestPath = path.parse(destPath);
+
+ // Note: Delete if the destiantion path already exists
+ await this.prisma.file.deleteMany({
+ where: {
+ path: destPath,
+ },
+ });
+
  const file = await this.prisma.file.update({
  where: {
  name: parsedSrcPath.base,
@@ -339,6 +347,7 @@ export class SQLiteBackend implements Backend {
  file: file,
  };
  } catch (e) {
+ console.error(e);
  return {
  // TODO: not_found is not the truth, it can fail for other reasons
  status: "not_found" as const,
@@ -366,4 +375,26 @@ export class SQLiteBackend implements Backend {
  };
  }
  }
+
+ async updateTimes(filepath: string, atime: number, mtime: number) {
+ try {
+ const file = await this.prisma.file.update({
+ where: {
+ path: filepath,
+ },
+ data: {
+ atime: new Date(atime),
+ mtime: new Date(mtime),
+ },
+ });
+ return {
+ status: "ok" as const,
+ file: file,
+ };
+ } catch (e) {
+ return {
+ status: "not_found" as const,
+ };
+ }
+ }
 }

packages/zoid-fs-client/package.json

@@ -4,7 +4,7 @@
  "license": "MIT",
  "type": "module",
  "scripts": {
- "start": "vite-node --watch index.ts /home/divyenduz/Documents/zoid/vfs/1",
+ "start": "vite-node --watch index.ts /home/divyendusingh/zoid/vfs/1",
  "test:prepare": "vite-node --watch index.ts /home/div/code/vfs/test-fs --tenant test",
  "ci:setup-fuse": "vite-node --watch index.ts",
  "test": "vitest",