Наблюдение за каталогом

Наблюдайте за каталогом, если приложение должно реагировать на создание или изменение файлов в работающей песочнице.

mjs

import { FilesystemEventType, Sandbox } from "@abox-dev/sdk";

const sandbox = await Sandbox.create();

try {
  let receiveEvent;
  const nextWrite = new Promise((resolve) => {
    receiveEvent = resolve;
  });

  const watcher = await sandbox.files.watchDir(
    "~",
    (event) => {
      if (event.type === FilesystemEventType.WRITE) receiveEvent(event);
    },
    { includeEntry: true, user: "root" },
  );

  await sandbox.files.write("~/message.txt", "Hello", { user: "root" });
  const event = await nextWrite;
  console.log(event.type, event.entry?.path);

  await watcher.stop();
} finally {
  await sandbox.kill();
}

from time import sleep

from agentbox import FilesystemEventType, Sandbox


sandbox = Sandbox.create()

try:
    watcher = sandbox.files.watch_dir("~", include_entry=True, user="root")
    sandbox.files.write("~/message.txt", "Hello", user="root")

    sleep(1)
    for event in watcher.get_new_events():
        if event.type == FilesystemEventType.WRITE:
            print(event.type.value, event.entry.path if event.entry else None)

    watcher.stop()
finally:
    sandbox.kill()

package main

import (
	"context"
	"fmt"
	"log"

	"github.com/abox-dev/sdk/packages/go-sdk"
)

func kill(sandbox *agentbox.Sandbox) {
	if _, err := sandbox.Kill(context.Background()); err != nil {
		log.Printf("cleanup sandbox: %v", err)
	}
}

func run() (err error) {
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()
	client, err := agentbox.NewClient()
	if err != nil {
		return err
	}
	sandbox, err := client.Sandboxes.Create(ctx, nil)
	if err != nil {
		return err
	}
	defer kill(sandbox)

	watch, err := sandbox.Files.Watch(ctx, "~", &agentbox.WatchOptions{IncludeEntry: true, User: "root"})
	if err != nil {
		return err
	}
	defer watch.Close()
	if _, err := sandbox.Files.WriteText(ctx, "~/message.txt", "Hello", &agentbox.WriteFileOptions{User: "root"}); err != nil {
		return err
	}
	for event := range watch.Events {
		if event.Type == "write" && event.Entry != nil {
			fmt.Println(event.Type, event.Entry.Path)
			break
		}
	}
	return nil
}

func main() {
	if err := run(); err != nil {
		log.Fatal(err)
	}
}

JavaScript передаёт события в обработчик watchDir. Python накапливает их до вызова get_new_events(). Go передаёт события через канал WatchHandle.Events. Остановите наблюдение, когда оно больше не нужно.

Параметр recursive включает существующие вложенные каталоги. Чтобы получать сведения о файле вместе с событием, задайте includeEntry в JavaScript, include_entry в Python или IncludeEntry в Go. После удаления файла сведения могут отсутствовать.

Для сетевой файловой системы нужно явно включить allowNetworkMounts, allow_network_mounts или AllowNetworkMounts. Доставка таких событий не гарантируется: изменения от другого клиента не попадают в наблюдатель песочницы.

Чтобы вычислять путь наблюдаемого каталога для выбранного пользователя, задайте user в JavaScript/Python или WatchOptions.User в Go. Например, наблюдение за ~ с пользователем root выбирает домашний каталог root. Пустой пользователь в Go означает пользователя шаблона.

Наблюдение за каталогом ​

Наблюдение за каталогом