mirror of
https://github.com/hanzoai/runtime.git
synced 2026-10-30 18:23:13 +00:00
zeekay
ea80dc3638
- Add main Dockerfile for production builds - Add Dockerfile.runtime for secure code execution - Add Dockerfile.runtime.fixed with improved configuration - Include .dockerignore for build optimization - Add integration documentation and publishing guides - Update API and CLI components for better runtime support - Enhance sandbox and container management features
62 lines
1.8 KiB
Go
62 lines
1.8 KiB
Go
// Copyright 2025 Hanzo Industries Inc.
|
|
// SPDX-License-Identifier: AGPL-3.0
|
|
|
|
package common
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/hanzoai/apiclient"
|
|
apiclient_cli "github.com/hanzoai/runtime/cli/apiclient"
|
|
)
|
|
|
|
func AwaitSnapshotState(ctx context.Context, apiClient *apiclient.APIClient, targetImage string, state apiclient.SnapshotState) error {
|
|
for {
|
|
snapshots, res, err := apiClient.SnapshotsAPI.GetAllSnapshots(ctx).Execute()
|
|
if err != nil {
|
|
return apiclient_cli.HandleErrorResponse(res, err)
|
|
}
|
|
|
|
for _, snapshot := range snapshots.Items {
|
|
if snapshot.Name == targetImage {
|
|
if snapshot.State == state {
|
|
return nil
|
|
} else if snapshot.State == apiclient.SNAPSHOTSTATE_ERROR || snapshot.State == apiclient.SNAPSHOTSTATE_BUILD_FAILED {
|
|
if !snapshot.ErrorReason.IsSet() {
|
|
return fmt.Errorf("snapshot processing failed")
|
|
}
|
|
return fmt.Errorf("snapshot processing failed: %s", *snapshot.ErrorReason.Get())
|
|
}
|
|
}
|
|
}
|
|
|
|
time.Sleep(time.Second)
|
|
}
|
|
}
|
|
|
|
func AwaitSandboxState(ctx context.Context, apiClient *apiclient.APIClient, targetSandbox string, state apiclient.SandboxState) error {
|
|
for {
|
|
sandboxes, res, err := apiClient.SandboxAPI.ListSandboxes(ctx).Execute()
|
|
if err != nil {
|
|
return apiclient_cli.HandleErrorResponse(res, err)
|
|
}
|
|
|
|
for _, sandbox := range sandboxes {
|
|
if sandbox.Id == targetSandbox {
|
|
if sandbox.State != nil && *sandbox.State == state {
|
|
return nil
|
|
} else if sandbox.State != nil && (*sandbox.State == apiclient.SANDBOXSTATE_ERROR || *sandbox.State == apiclient.SANDBOXSTATE_BUILD_FAILED) {
|
|
if sandbox.ErrorReason == nil {
|
|
return fmt.Errorf("sandbox processing failed")
|
|
}
|
|
return fmt.Errorf("sandbox processing failed: %s", *sandbox.ErrorReason)
|
|
}
|
|
}
|
|
}
|
|
|
|
time.Sleep(time.Second)
|
|
}
|
|
}
|