reduce scope to backup and replication

Author: fbeauchamp

@xen-orchestra/vmdk/.npmignore

@@ -0,0 +1,22 @@
+import { Datastore } from './_Datastore.mjs'
+
+export class DatastoreSoapEsxi extends Datastore {
+  #esxi
+  constructor(datastoreName, { esxi, ...otherOptions } = {}) {
+    super(datastoreName, otherOptions)
+    this.#esxi = esxi
+  }
+  async getStream(path, start, end) {
+    const res = await this.#esxi.download(this.datastoreName, path, start || end ? `${start}-${end}` : undefined)
+    return res.body
+  }
+  async getBuffer(path, start, end) {
+    return (
+      await this.#esxi.download(this.datastoreName, path, start || end ? `${start}-${end - 1}` : undefined)
+    ).buffer()
+  }
+  async getSize(path) {
+    const res = await this.#esxi.download(this.datastoreName, path)
+    return Number(res.headers.get('content-length'))
+  }
+}

@xen-orchestra/vmdk/.npmignore copy

@@ -0,0 +1,22 @@
+import assert from 'node:assert'
+import { Datastore } from './_Datastore.mjs'
+
+export const DatastoreXoRemote = class DatastoreXoRemote extends Datastore {
+  #handler
+  constructor(datastoreName, { handler, ...otherOptions }) {
+    super(datastoreName, otherOptions)
+    this.#handler = handler
+  }
+  async getStream(path, start, end) {
+    return this.#handler.createReadStream(path, { start, end })
+  }
+  async getBuffer(path, start, end) {
+    const buffer = Buffer.alloc(end - start)
+    const { bytesRead } = await this.#handler.read(path, buffer, start)
+    assert.strictEqual(bytesRead, end - start)
+    return buffer
+  }
+  async getSize(path) {
+    return this.#handler.getSize(path)
+  }
+}