mirror of
https://github.com/hanzoui/registry-backend.git
synced 2026-10-30 20:30:45 +00:00
- Updated copyright to Hanzo AI, Inc. - Replaced ComfyUI references with Hanzo Studio - Updated GitHub org URLs (Comfy-Org → hanzoui) - Updated domains (comfy.org → hanzo.ai) - Updated package names and npm scopes - Updated LICENSE with Hanzo AI copyright header
5146 lines
182 KiB
Go
5146 lines
182 KiB
Go
// Package drip provides primitives to interact with the openapi HTTP API.
|
|
//
|
|
// Code generated by github.com/deepmap/oapi-codegen/v2 version v2.1.0 DO NOT EDIT.
|
|
package drip
|
|
|
|
import (
|
|
"bytes"
|
|
"compress/gzip"
|
|
"context"
|
|
"encoding/base64"
|
|
"encoding/json"
|
|
"fmt"
|
|
"net/http"
|
|
"net/url"
|
|
"path"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/getkin/kin-openapi/openapi3"
|
|
"github.com/labstack/echo/v4"
|
|
"github.com/oapi-codegen/runtime"
|
|
strictecho "github.com/oapi-codegen/runtime/strictmiddleware/echo"
|
|
openapi_types "github.com/oapi-codegen/runtime/types"
|
|
)
|
|
|
|
const (
|
|
BearerAuthScopes = "BearerAuth.Scopes"
|
|
)
|
|
|
|
// Defines values for NodeStatus.
|
|
const (
|
|
NodeStatusActive NodeStatus = "NodeStatusActive"
|
|
NodeStatusBanned NodeStatus = "NodeStatusBanned"
|
|
NodeStatusDeleted NodeStatus = "NodeStatusDeleted"
|
|
)
|
|
|
|
// Defines values for NodeVersionStatus.
|
|
const (
|
|
NodeVersionStatusActive NodeVersionStatus = "NodeVersionStatusActive"
|
|
NodeVersionStatusBanned NodeVersionStatus = "NodeVersionStatusBanned"
|
|
NodeVersionStatusDeleted NodeVersionStatus = "NodeVersionStatusDeleted"
|
|
NodeVersionStatusFlagged NodeVersionStatus = "NodeVersionStatusFlagged"
|
|
NodeVersionStatusPending NodeVersionStatus = "NodeVersionStatusPending"
|
|
)
|
|
|
|
// Defines values for PublisherStatus.
|
|
const (
|
|
PublisherStatusActive PublisherStatus = "PublisherStatusActive"
|
|
PublisherStatusBanned PublisherStatus = "PublisherStatusBanned"
|
|
)
|
|
|
|
// Defines values for WorkflowRunStatus.
|
|
const (
|
|
WorkflowRunStatusCompleted WorkflowRunStatus = "WorkflowRunStatusCompleted"
|
|
WorkflowRunStatusFailed WorkflowRunStatus = "WorkflowRunStatusFailed"
|
|
WorkflowRunStatusStarted WorkflowRunStatus = "WorkflowRunStatusStarted"
|
|
)
|
|
|
|
// ActionJobResult defines model for ActionJobResult.
|
|
type ActionJobResult struct {
|
|
// ActionJobId Identifier of the job this result belongs to
|
|
ActionJobId *string `json:"action_job_id,omitempty"`
|
|
|
|
// ActionRunId Identifier of the run this result belongs to
|
|
ActionRunId *string `json:"action_run_id,omitempty"`
|
|
|
|
// Author The author of the commit
|
|
Author *string `json:"author,omitempty"`
|
|
|
|
// AvgVram The average VRAM used by the job
|
|
AvgVram *int `json:"avg_vram,omitempty"`
|
|
|
|
// BranchName Name of the relevant git branch
|
|
BranchName *string `json:"branch_name,omitempty"`
|
|
|
|
// ComfyRunFlags The comfy run flags. E.g. `--low-vram`
|
|
ComfyRunFlags *string `json:"comfy_run_flags,omitempty"`
|
|
|
|
// CommitHash The hash of the commit
|
|
CommitHash *string `json:"commit_hash,omitempty"`
|
|
|
|
// CommitId The ID of the commit
|
|
CommitId *string `json:"commit_id,omitempty"`
|
|
|
|
// CommitMessage The message of the commit
|
|
CommitMessage *string `json:"commit_message,omitempty"`
|
|
|
|
// CommitTime The Unix timestamp when the commit was made
|
|
CommitTime *int64 `json:"commit_time,omitempty"`
|
|
|
|
// CudaVersion CUDA version used
|
|
CudaVersion *string `json:"cuda_version,omitempty"`
|
|
|
|
// EndTime The end time of the job as a Unix timestamp.
|
|
EndTime *int64 `json:"end_time,omitempty"`
|
|
|
|
// GitRepo The repository name
|
|
GitRepo *string `json:"git_repo,omitempty"`
|
|
|
|
// Id Unique identifier for the job result
|
|
Id *openapi_types.UUID `json:"id,omitempty"`
|
|
|
|
// JobTriggerUser The user who triggered the job.
|
|
JobTriggerUser *string `json:"job_trigger_user,omitempty"`
|
|
MachineStats *MachineStats `json:"machine_stats,omitempty"`
|
|
|
|
// OperatingSystem Operating system used
|
|
OperatingSystem *string `json:"operating_system,omitempty"`
|
|
|
|
// PeakVram The peak VRAM used by the job
|
|
PeakVram *int `json:"peak_vram,omitempty"`
|
|
|
|
// PrNumber The pull request number
|
|
PrNumber *string `json:"pr_number,omitempty"`
|
|
|
|
// PythonVersion PyTorch version used
|
|
PythonVersion *string `json:"python_version,omitempty"`
|
|
|
|
// PytorchVersion PyTorch version used
|
|
PytorchVersion *string `json:"pytorch_version,omitempty"`
|
|
|
|
// StartTime The start time of the job as a Unix timestamp.
|
|
StartTime *int64 `json:"start_time,omitempty"`
|
|
Status *WorkflowRunStatus `json:"status,omitempty"`
|
|
StorageFile *StorageFile `json:"storage_file,omitempty"`
|
|
|
|
// WorkflowName Name of the workflow
|
|
WorkflowName *string `json:"workflow_name,omitempty"`
|
|
}
|
|
|
|
// ComfyNode defines model for ComfyNode.
|
|
type ComfyNode struct {
|
|
// Category UI category where the node is listed, used for grouping nodes.
|
|
Category *string `json:"category,omitempty"`
|
|
|
|
// ComfyNodeId Unique identifier for the node
|
|
ComfyNodeId *string `json:"comfy_node_id,omitempty"`
|
|
|
|
// Deprecated Indicates if the node is deprecated. Deprecated nodes are hidden in the UI.
|
|
Deprecated *bool `json:"deprecated,omitempty"`
|
|
|
|
// Description Brief description of the node's functionality or purpose.
|
|
Description *string `json:"description,omitempty"`
|
|
|
|
// Experimental Indicates if the node is experimental, subject to changes or removal.
|
|
Experimental *bool `json:"experimental,omitempty"`
|
|
|
|
// Function Name of the entry-point function to execute the node.
|
|
Function *string `json:"function,omitempty"`
|
|
|
|
// InputTypes Defines input parameters
|
|
InputTypes *string `json:"input_types,omitempty"`
|
|
|
|
// OutputIsList Boolean values indicating if each output is a list.
|
|
OutputIsList *[]bool `json:"output_is_list,omitempty"`
|
|
|
|
// ReturnNames Names of the outputs for clarity in workflows.
|
|
ReturnNames *string `json:"return_names,omitempty"`
|
|
|
|
// ReturnTypes Specifies the types of outputs produced by the node.
|
|
ReturnTypes *string `json:"return_types,omitempty"`
|
|
}
|
|
|
|
// ComfyNodeCloudBuildInfo defines model for ComfyNodeCloudBuildInfo.
|
|
type ComfyNodeCloudBuildInfo struct {
|
|
BuildId *string `json:"build_id,omitempty"`
|
|
Location *string `json:"location,omitempty"`
|
|
ProjectId *string `json:"project_id,omitempty"`
|
|
ProjectNumber *string `json:"project_number,omitempty"`
|
|
}
|
|
|
|
// Error defines model for Error.
|
|
type Error struct {
|
|
// Details Optional detailed information about the error or hints for resolving it.
|
|
Details *[]string `json:"details,omitempty"`
|
|
|
|
// Message A clear and concise description of the error.
|
|
Message *string `json:"message,omitempty"`
|
|
}
|
|
|
|
// ErrorResponse defines model for ErrorResponse.
|
|
type ErrorResponse struct {
|
|
Error string `json:"error"`
|
|
Message string `json:"message"`
|
|
}
|
|
|
|
// GitCommitSummary defines model for GitCommitSummary.
|
|
type GitCommitSummary struct {
|
|
// Author The author of the commit
|
|
Author *string `json:"author,omitempty"`
|
|
|
|
// BranchName The branch where the commit was made
|
|
BranchName *string `json:"branch_name,omitempty"`
|
|
|
|
// CommitHash The hash of the commit
|
|
CommitHash *string `json:"commit_hash,omitempty"`
|
|
|
|
// CommitName The name of the commit
|
|
CommitName *string `json:"commit_name,omitempty"`
|
|
|
|
// StatusSummary A map of operating system to status pairs
|
|
StatusSummary *map[string]string `json:"status_summary,omitempty"`
|
|
|
|
// Timestamp The timestamp when the commit was made
|
|
Timestamp *time.Time `json:"timestamp,omitempty"`
|
|
}
|
|
|
|
// MachineStats defines model for MachineStats.
|
|
type MachineStats struct {
|
|
// CpuCapacity Total CPU on the machine.
|
|
CpuCapacity *string `json:"cpu_capacity,omitempty"`
|
|
|
|
// DiskCapacity Total disk capacity on the machine.
|
|
DiskCapacity *string `json:"disk_capacity,omitempty"`
|
|
|
|
// GpuType The GPU type. eg. NVIDIA Tesla K80
|
|
GpuType *string `json:"gpu_type,omitempty"`
|
|
|
|
// InitialCpu Initial CPU available before the job starts.
|
|
InitialCpu *string `json:"initial_cpu,omitempty"`
|
|
|
|
// InitialDisk Initial disk available before the job starts.
|
|
InitialDisk *string `json:"initial_disk,omitempty"`
|
|
|
|
// InitialRam Initial RAM available before the job starts.
|
|
InitialRam *string `json:"initial_ram,omitempty"`
|
|
|
|
// MachineName Name of the machine.
|
|
MachineName *string `json:"machine_name,omitempty"`
|
|
|
|
// MemoryCapacity Total memory on the machine.
|
|
MemoryCapacity *string `json:"memory_capacity,omitempty"`
|
|
|
|
// OsVersion The operating system version. eg. Ubuntu Linux 20.04
|
|
OsVersion *string `json:"os_version,omitempty"`
|
|
|
|
// PipFreeze The pip freeze output
|
|
PipFreeze *string `json:"pip_freeze,omitempty"`
|
|
|
|
// VramTimeSeries Time series of VRAM usage.
|
|
VramTimeSeries *map[string]interface{} `json:"vram_time_series,omitempty"`
|
|
}
|
|
|
|
// Node defines model for Node.
|
|
type Node struct {
|
|
Author *string `json:"author,omitempty"`
|
|
|
|
// Category The category of the node.
|
|
Category *string `json:"category,omitempty"`
|
|
Description *string `json:"description,omitempty"`
|
|
|
|
// Downloads The number of downloads of the node.
|
|
Downloads *int `json:"downloads,omitempty"`
|
|
|
|
// Icon URL to the node's icon.
|
|
Icon *string `json:"icon,omitempty"`
|
|
|
|
// Id The unique identifier of the node.
|
|
Id *string `json:"id,omitempty"`
|
|
LatestVersion *NodeVersion `json:"latest_version,omitempty"`
|
|
|
|
// License The path to the LICENSE file in the node's repository.
|
|
License *string `json:"license,omitempty"`
|
|
|
|
// Name The display name of the node.
|
|
Name *string `json:"name,omitempty"`
|
|
Publisher *Publisher `json:"publisher,omitempty"`
|
|
|
|
// Rating The average rating of the node.
|
|
Rating *float32 `json:"rating,omitempty"`
|
|
|
|
// Repository URL to the node's repository.
|
|
Repository *string `json:"repository,omitempty"`
|
|
Status *NodeStatus `json:"status,omitempty"`
|
|
|
|
// StatusDetail The status detail of the node.
|
|
StatusDetail *string `json:"status_detail,omitempty"`
|
|
Tags *[]string `json:"tags,omitempty"`
|
|
}
|
|
|
|
// NodeStatus defines model for NodeStatus.
|
|
type NodeStatus string
|
|
|
|
// NodeVersion defines model for NodeVersion.
|
|
type NodeVersion struct {
|
|
// Changelog Summary of changes made in this version
|
|
Changelog *string `json:"changelog,omitempty"`
|
|
|
|
// CreatedAt The date and time the version was created.
|
|
CreatedAt *time.Time `json:"createdAt,omitempty"`
|
|
|
|
// Dependencies A list of pip dependencies required by the node.
|
|
Dependencies *[]string `json:"dependencies,omitempty"`
|
|
|
|
// Deprecated Indicates if this version is deprecated.
|
|
Deprecated *bool `json:"deprecated,omitempty"`
|
|
|
|
// DownloadUrl [Output Only] URL to download this version of the node
|
|
DownloadUrl *string `json:"downloadUrl,omitempty"`
|
|
Id *string `json:"id,omitempty"`
|
|
|
|
// NodeId The unique identifier of the node.
|
|
NodeId *string `json:"node_id,omitempty"`
|
|
Status *NodeVersionStatus `json:"status,omitempty"`
|
|
|
|
// StatusReason The reason for the status change.
|
|
StatusReason *string `json:"status_reason,omitempty"`
|
|
|
|
// Version The version identifier, following semantic versioning. Must be unique for the node.
|
|
Version *string `json:"version,omitempty"`
|
|
}
|
|
|
|
// NodeVersionStatus defines model for NodeVersionStatus.
|
|
type NodeVersionStatus string
|
|
|
|
// NodeVersionUpdateRequest defines model for NodeVersionUpdateRequest.
|
|
type NodeVersionUpdateRequest struct {
|
|
// Changelog The changelog describing the version changes.
|
|
Changelog *string `json:"changelog,omitempty"`
|
|
|
|
// Deprecated Whether the version is deprecated.
|
|
Deprecated *bool `json:"deprecated,omitempty"`
|
|
}
|
|
|
|
// PersonalAccessToken defines model for PersonalAccessToken.
|
|
type PersonalAccessToken struct {
|
|
// CreatedAt [Output Only]The date and time the token was created.
|
|
CreatedAt *time.Time `json:"createdAt,omitempty"`
|
|
|
|
// Description Optional. A more detailed description of the token's intended use.
|
|
Description *string `json:"description,omitempty"`
|
|
|
|
// Id Unique identifier for the GitCommit
|
|
Id *openapi_types.UUID `json:"id,omitempty"`
|
|
|
|
// Name Required. The name of the token. Can be a simple description.
|
|
Name *string `json:"name,omitempty"`
|
|
|
|
// Token [Output Only]. The personal access token. Only returned during creation.
|
|
Token *string `json:"token,omitempty"`
|
|
}
|
|
|
|
// Publisher defines model for Publisher.
|
|
type Publisher struct {
|
|
// CreatedAt The date and time the publisher was created.
|
|
CreatedAt *time.Time `json:"createdAt,omitempty"`
|
|
Description *string `json:"description,omitempty"`
|
|
|
|
// Id The unique identifier for the publisher. It's akin to a username. Should be lowercase.
|
|
Id *string `json:"id,omitempty"`
|
|
|
|
// Logo URL to the publisher's logo.
|
|
Logo *string `json:"logo,omitempty"`
|
|
|
|
// Members A list of members in the publisher.
|
|
Members *[]PublisherMember `json:"members,omitempty"`
|
|
Name *string `json:"name,omitempty"`
|
|
SourceCodeRepo *string `json:"source_code_repo,omitempty"`
|
|
Status *PublisherStatus `json:"status,omitempty"`
|
|
Support *string `json:"support,omitempty"`
|
|
Website *string `json:"website,omitempty"`
|
|
}
|
|
|
|
// PublisherMember defines model for PublisherMember.
|
|
type PublisherMember struct {
|
|
// Id The unique identifier for the publisher member.
|
|
Id *string `json:"id,omitempty"`
|
|
|
|
// Role The role of the user in the publisher.
|
|
Role *string `json:"role,omitempty"`
|
|
User *PublisherUser `json:"user,omitempty"`
|
|
}
|
|
|
|
// PublisherStatus defines model for PublisherStatus.
|
|
type PublisherStatus string
|
|
|
|
// PublisherUser defines model for PublisherUser.
|
|
type PublisherUser struct {
|
|
// Email The email address for this user.
|
|
Email *string `json:"email,omitempty"`
|
|
|
|
// Id The unique id for this user.
|
|
Id *string `json:"id,omitempty"`
|
|
|
|
// Name The name for this user.
|
|
Name *string `json:"name,omitempty"`
|
|
}
|
|
|
|
// StorageFile defines model for StorageFile.
|
|
type StorageFile struct {
|
|
// FilePath Path to the file in storage
|
|
FilePath *string `json:"file_path,omitempty"`
|
|
|
|
// Id Unique identifier for the storage file
|
|
Id *openapi_types.UUID `json:"id,omitempty"`
|
|
|
|
// PublicUrl Public URL
|
|
PublicUrl *string `json:"public_url,omitempty"`
|
|
}
|
|
|
|
// User defines model for User.
|
|
type User struct {
|
|
// Email The email address for this user.
|
|
Email *string `json:"email,omitempty"`
|
|
|
|
// Id The unique id for this user.
|
|
Id *string `json:"id,omitempty"`
|
|
|
|
// IsAdmin Indicates if the user has admin privileges.
|
|
IsAdmin *bool `json:"isAdmin,omitempty"`
|
|
|
|
// IsApproved Indicates if the user is approved.
|
|
IsApproved *bool `json:"isApproved,omitempty"`
|
|
|
|
// Name The name for this user.
|
|
Name *string `json:"name,omitempty"`
|
|
}
|
|
|
|
// WorkflowRunStatus defines model for WorkflowRunStatus.
|
|
type WorkflowRunStatus string
|
|
|
|
// AdminUpdateNodeVersionJSONBody defines parameters for AdminUpdateNodeVersion.
|
|
type AdminUpdateNodeVersionJSONBody struct {
|
|
Status *NodeVersionStatus `json:"status,omitempty"`
|
|
|
|
// StatusReason The reason for the status change.
|
|
StatusReason *string `json:"status_reason,omitempty"`
|
|
}
|
|
|
|
// GetBranchParams defines parameters for GetBranch.
|
|
type GetBranchParams struct {
|
|
// RepoName The repo to filter by.
|
|
RepoName string `form:"repo_name" json:"repo_name"`
|
|
}
|
|
|
|
// ComfyNodesBackfillParams defines parameters for ComfyNodesBackfill.
|
|
type ComfyNodesBackfillParams struct {
|
|
MaxNode *int `form:"max_node,omitempty" json:"max_node,omitempty"`
|
|
}
|
|
|
|
// GetGitcommitParams defines parameters for GetGitcommit.
|
|
type GetGitcommitParams struct {
|
|
// CommitId The ID of the commit to fetch data for.
|
|
CommitId *string `form:"commitId,omitempty" json:"commitId,omitempty"`
|
|
|
|
// OperatingSystem The operating system to filter the CI data by.
|
|
OperatingSystem *string `form:"operatingSystem,omitempty" json:"operatingSystem,omitempty"`
|
|
|
|
// WorkflowName The name of the workflow to filter the CI data by.
|
|
WorkflowName *string `form:"workflowName,omitempty" json:"workflowName,omitempty"`
|
|
|
|
// Branch The branch of the gitcommit to filter the CI data by.
|
|
Branch *string `form:"branch,omitempty" json:"branch,omitempty"`
|
|
|
|
// Page The page number to retrieve.
|
|
Page *int `form:"page,omitempty" json:"page,omitempty"`
|
|
|
|
// PageSize The number of items to include per page.
|
|
PageSize *int `form:"pageSize,omitempty" json:"pageSize,omitempty"`
|
|
|
|
// RepoName The repo to filter by.
|
|
RepoName *string `form:"repoName,omitempty" json:"repoName,omitempty"`
|
|
}
|
|
|
|
// GetGitcommitsummaryParams defines parameters for GetGitcommitsummary.
|
|
type GetGitcommitsummaryParams struct {
|
|
// RepoName The repository name to filter the git commits by.
|
|
RepoName *string `form:"repoName,omitempty" json:"repoName,omitempty"`
|
|
|
|
// BranchName The branch name to filter the git commits by.
|
|
BranchName *string `form:"branchName,omitempty" json:"branchName,omitempty"`
|
|
|
|
// Page The page number to retrieve.
|
|
Page *int `form:"page,omitempty" json:"page,omitempty"`
|
|
|
|
// PageSize The number of items to include per page.
|
|
PageSize *int `form:"pageSize,omitempty" json:"pageSize,omitempty"`
|
|
}
|
|
|
|
// ListAllNodesParams defines parameters for ListAllNodes.
|
|
type ListAllNodesParams struct {
|
|
// Page Page number of the nodes list
|
|
Page *int `form:"page,omitempty" json:"page,omitempty"`
|
|
|
|
// Limit Number of nodes to return per page
|
|
Limit *int `form:"limit,omitempty" json:"limit,omitempty"`
|
|
|
|
// IncludeBanned Number of nodes to return per page
|
|
IncludeBanned *bool `form:"include_banned,omitempty" json:"include_banned,omitempty"`
|
|
|
|
// Timestamp Retrieve nodes created or updated after this timestamp (ISO 8601 format)
|
|
Timestamp *time.Time `form:"timestamp,omitempty" json:"timestamp,omitempty"`
|
|
|
|
// Latest Whether to fetch fresh result from database or use cached one if false
|
|
Latest *bool `form:"latest,omitempty" json:"latest,omitempty"`
|
|
}
|
|
|
|
// ReindexNodesParams defines parameters for ReindexNodes.
|
|
type ReindexNodesParams struct {
|
|
// MaxBatch Maximum number of nodes to send to algolia at a time
|
|
MaxBatch *int `form:"max_batch,omitempty" json:"max_batch,omitempty"`
|
|
|
|
// MinAge Minimum interval from the last time the nodes were indexed to algolia
|
|
MinAge *time.Duration `form:"min_age,omitempty" json:"min_age,omitempty"`
|
|
}
|
|
|
|
// SearchNodesParams defines parameters for SearchNodes.
|
|
type SearchNodesParams struct {
|
|
// Page Page number of the nodes list
|
|
Page *int `form:"page,omitempty" json:"page,omitempty"`
|
|
|
|
// Limit Number of nodes to return per page
|
|
Limit *int `form:"limit,omitempty" json:"limit,omitempty"`
|
|
|
|
// Search Keyword to search the nodes
|
|
Search *string `form:"search,omitempty" json:"search,omitempty"`
|
|
|
|
// IncludeBanned Number of nodes to return per page
|
|
IncludeBanned *bool `form:"include_banned,omitempty" json:"include_banned,omitempty"`
|
|
}
|
|
|
|
// InstallNodeParams defines parameters for InstallNode.
|
|
type InstallNodeParams struct {
|
|
// Version Specific version of the node to retrieve. If omitted, the latest version is returned.
|
|
Version *string `form:"version,omitempty" json:"version,omitempty"`
|
|
}
|
|
|
|
// PostNodeReviewParams defines parameters for PostNodeReview.
|
|
type PostNodeReviewParams struct {
|
|
// Star number of star given to the node version
|
|
Star int `form:"star" json:"star"`
|
|
}
|
|
|
|
// ListNodeVersionsParams defines parameters for ListNodeVersions.
|
|
type ListNodeVersionsParams struct {
|
|
Statuses *[]NodeVersionStatus `form:"statuses,omitempty" json:"statuses,omitempty"`
|
|
IncludeStatusReason *bool `form:"include_status_reason,omitempty" json:"include_status_reason,omitempty"`
|
|
}
|
|
|
|
// CreateComfyNodesJSONBody defines parameters for CreateComfyNodes.
|
|
type CreateComfyNodesJSONBody struct {
|
|
CloudBuildInfo *ComfyNodeCloudBuildInfo `json:"cloud_build_info,omitempty"`
|
|
Nodes *map[string]ComfyNode `json:"nodes,omitempty"`
|
|
Reason *string `json:"reason,omitempty"`
|
|
Success *bool `json:"success,omitempty"`
|
|
}
|
|
|
|
// ValidatePublisherParams defines parameters for ValidatePublisher.
|
|
type ValidatePublisherParams struct {
|
|
// Username The publisher username to validate.
|
|
Username string `form:"username" json:"username"`
|
|
}
|
|
|
|
// ListNodesForPublisherParams defines parameters for ListNodesForPublisher.
|
|
type ListNodesForPublisherParams struct {
|
|
// IncludeBanned Number of nodes to return per page
|
|
IncludeBanned *bool `form:"include_banned,omitempty" json:"include_banned,omitempty"`
|
|
}
|
|
|
|
// PublishNodeVersionJSONBody defines parameters for PublishNodeVersion.
|
|
type PublishNodeVersionJSONBody struct {
|
|
Node Node `json:"node"`
|
|
NodeVersion NodeVersion `json:"node_version"`
|
|
PersonalAccessToken string `json:"personal_access_token"`
|
|
}
|
|
|
|
// SecurityScanParams defines parameters for SecurityScan.
|
|
type SecurityScanParams struct {
|
|
MinAge *time.Duration `form:"minAge,omitempty" json:"minAge,omitempty"`
|
|
MaxNodes *int `form:"maxNodes,omitempty" json:"maxNodes,omitempty"`
|
|
}
|
|
|
|
// PostUploadArtifactJSONBody defines parameters for PostUploadArtifact.
|
|
type PostUploadArtifactJSONBody struct {
|
|
// Author The author of the commit
|
|
Author string `json:"author"`
|
|
|
|
// AvgVram The average amount of VRAM used in the run.
|
|
AvgVram *int `json:"avg_vram,omitempty"`
|
|
BranchName string `json:"branch_name"`
|
|
|
|
// BucketName The name of the bucket where the output files are stored
|
|
BucketName *string `json:"bucket_name,omitempty"`
|
|
|
|
// ComfyLogsGcsPath The path to Hanzo Studio logs. eg. gs://bucket-name/logs
|
|
ComfyLogsGcsPath *string `json:"comfy_logs_gcs_path,omitempty"`
|
|
|
|
// ComfyRunFlags The flags used in the comfy run
|
|
ComfyRunFlags *string `json:"comfy_run_flags,omitempty"`
|
|
CommitHash string `json:"commit_hash"`
|
|
|
|
// CommitMessage The commit message
|
|
CommitMessage string `json:"commit_message"`
|
|
|
|
// CommitTime The time of the commit in the format of "YYYY-MM-DDTHH:MM:SSZ" (2016-10-10T00:00:00Z)
|
|
CommitTime string `json:"commit_time"`
|
|
|
|
// CudaVersion Cuda version.
|
|
CudaVersion *string `json:"cuda_version,omitempty"`
|
|
|
|
// EndTime The end time of the job as a Unix timestamp.
|
|
EndTime int64 `json:"end_time"`
|
|
|
|
// JobId Unique identifier for the job
|
|
JobId string `json:"job_id"`
|
|
|
|
// JobTriggerUser The user who triggered the job
|
|
JobTriggerUser string `json:"job_trigger_user"`
|
|
MachineStats *MachineStats `json:"machine_stats,omitempty"`
|
|
|
|
// Os Operating system used in the run
|
|
Os string `json:"os"`
|
|
|
|
// OutputFilesGcsPaths A comma separated string that contains GCS path(s) to output files. eg. gs://bucket-name/output, gs://bucket-name/output2
|
|
OutputFilesGcsPaths *string `json:"output_files_gcs_paths,omitempty"`
|
|
|
|
// PeakVram The peak amount of VRAM used in the run.
|
|
PeakVram *int `json:"peak_vram,omitempty"`
|
|
|
|
// PrNumber The pull request number
|
|
PrNumber string `json:"pr_number"`
|
|
|
|
// PythonVersion The python version used in the run
|
|
PythonVersion string `json:"python_version"`
|
|
|
|
// PytorchVersion The pytorch version used in the run
|
|
PytorchVersion *string `json:"pytorch_version,omitempty"`
|
|
|
|
// Repo Repository name
|
|
Repo string `json:"repo"`
|
|
|
|
// RunId Unique identifier for the run
|
|
RunId string `json:"run_id"`
|
|
|
|
// StartTime The start time of the job as a Unix timestamp.
|
|
StartTime int64 `json:"start_time"`
|
|
Status WorkflowRunStatus `json:"status"`
|
|
|
|
// WorkflowName The name of the workflow
|
|
WorkflowName string `json:"workflow_name"`
|
|
}
|
|
|
|
// ListAllNodeVersionsParams defines parameters for ListAllNodeVersions.
|
|
type ListAllNodeVersionsParams struct {
|
|
NodeId *string `form:"nodeId,omitempty" json:"nodeId,omitempty"`
|
|
Statuses *[]NodeVersionStatus `form:"statuses,omitempty" json:"statuses,omitempty"`
|
|
IncludeStatusReason *bool `form:"include_status_reason,omitempty" json:"include_status_reason,omitempty"`
|
|
|
|
// Page The page number to retrieve.
|
|
Page *int `form:"page,omitempty" json:"page,omitempty"`
|
|
|
|
// PageSize The number of items to include per page.
|
|
PageSize *int `form:"pageSize,omitempty" json:"pageSize,omitempty"`
|
|
}
|
|
|
|
// AdminUpdateNodeVersionJSONRequestBody defines body for AdminUpdateNodeVersion for application/json ContentType.
|
|
type AdminUpdateNodeVersionJSONRequestBody AdminUpdateNodeVersionJSONBody
|
|
|
|
// CreateComfyNodesJSONRequestBody defines body for CreateComfyNodes for application/json ContentType.
|
|
type CreateComfyNodesJSONRequestBody CreateComfyNodesJSONBody
|
|
|
|
// CreatePublisherJSONRequestBody defines body for CreatePublisher for application/json ContentType.
|
|
type CreatePublisherJSONRequestBody = Publisher
|
|
|
|
// UpdatePublisherJSONRequestBody defines body for UpdatePublisher for application/json ContentType.
|
|
type UpdatePublisherJSONRequestBody = Publisher
|
|
|
|
// CreateNodeJSONRequestBody defines body for CreateNode for application/json ContentType.
|
|
type CreateNodeJSONRequestBody = Node
|
|
|
|
// UpdateNodeJSONRequestBody defines body for UpdateNode for application/json ContentType.
|
|
type UpdateNodeJSONRequestBody = Node
|
|
|
|
// PublishNodeVersionJSONRequestBody defines body for PublishNodeVersion for application/json ContentType.
|
|
type PublishNodeVersionJSONRequestBody PublishNodeVersionJSONBody
|
|
|
|
// UpdateNodeVersionJSONRequestBody defines body for UpdateNodeVersion for application/json ContentType.
|
|
type UpdateNodeVersionJSONRequestBody = NodeVersionUpdateRequest
|
|
|
|
// CreatePersonalAccessTokenJSONRequestBody defines body for CreatePersonalAccessToken for application/json ContentType.
|
|
type CreatePersonalAccessTokenJSONRequestBody = PersonalAccessToken
|
|
|
|
// PostUploadArtifactJSONRequestBody defines body for PostUploadArtifact for application/json ContentType.
|
|
type PostUploadArtifactJSONRequestBody PostUploadArtifactJSONBody
|
|
|
|
// ServerInterface represents all server handlers.
|
|
type ServerInterface interface {
|
|
// Admin Update Node Version Status
|
|
// (PUT /admin/nodes/{nodeId}/versions/{versionNumber})
|
|
AdminUpdateNodeVersion(ctx echo.Context, nodeId string, versionNumber string) error
|
|
// Retrieve all distinct branches for a given repo
|
|
// (GET /branch)
|
|
GetBranch(ctx echo.Context, params GetBranchParams) error
|
|
// trigger comfy nodes backfill
|
|
// (POST /comfy-nodes/backfill)
|
|
ComfyNodesBackfill(ctx echo.Context, params ComfyNodesBackfillParams) error
|
|
// Retrieve CI data for a given commit
|
|
// (GET /gitcommit)
|
|
GetGitcommit(ctx echo.Context, params GetGitcommitParams) error
|
|
// Retrieve a summary of git commits
|
|
// (GET /gitcommitsummary)
|
|
GetGitcommitsummary(ctx echo.Context, params GetGitcommitsummaryParams) error
|
|
// Retrieves a list of nodes
|
|
// (GET /nodes)
|
|
ListAllNodes(ctx echo.Context, params ListAllNodesParams) error
|
|
// Reindex all nodes for searching.
|
|
// (POST /nodes/reindex)
|
|
ReindexNodes(ctx echo.Context, params ReindexNodesParams) error
|
|
// Retrieves a list of nodes
|
|
// (GET /nodes/search)
|
|
SearchNodes(ctx echo.Context, params SearchNodesParams) error
|
|
// Retrieve a specific node by ID
|
|
// (GET /nodes/{nodeId})
|
|
GetNode(ctx echo.Context, nodeId string) error
|
|
// Returns a node version to be installed.
|
|
// (GET /nodes/{nodeId}/install)
|
|
InstallNode(ctx echo.Context, nodeId string, params InstallNodeParams) error
|
|
// Add review to a specific version of a node
|
|
// (POST /nodes/{nodeId}/reviews)
|
|
PostNodeReview(ctx echo.Context, nodeId string, params PostNodeReviewParams) error
|
|
// List all versions of a node
|
|
// (GET /nodes/{nodeId}/versions)
|
|
ListNodeVersions(ctx echo.Context, nodeId string, params ListNodeVersionsParams) error
|
|
// Retrieve a specific version of a node
|
|
// (GET /nodes/{nodeId}/versions/{versionId})
|
|
GetNodeVersion(ctx echo.Context, nodeId string, versionId string) error
|
|
// create comfy-nodes for certain node
|
|
// (POST /nodes/{nodeId}/versions/{version}/comfy-nodes)
|
|
CreateComfyNodes(ctx echo.Context, nodeId string, version string) error
|
|
// get specify comfy-node based on its id
|
|
// (GET /nodes/{nodeId}/versions/{version}/comfy-nodes/{comfyNodeId})
|
|
GetComfyNode(ctx echo.Context, nodeId string, version string, comfyNodeId string) error
|
|
// Retrieve all publishers
|
|
// (GET /publishers)
|
|
ListPublishers(ctx echo.Context) error
|
|
// Create a new publisher
|
|
// (POST /publishers)
|
|
CreatePublisher(ctx echo.Context) error
|
|
// Validate if a publisher username is available
|
|
// (GET /publishers/validate)
|
|
ValidatePublisher(ctx echo.Context, params ValidatePublisherParams) error
|
|
// Delete a publisher
|
|
// (DELETE /publishers/{publisherId})
|
|
DeletePublisher(ctx echo.Context, publisherId string) error
|
|
// Retrieve a publisher by ID
|
|
// (GET /publishers/{publisherId})
|
|
GetPublisher(ctx echo.Context, publisherId string) error
|
|
// Update a publisher
|
|
// (PUT /publishers/{publisherId})
|
|
UpdatePublisher(ctx echo.Context, publisherId string) error
|
|
// Ban a publisher
|
|
// (POST /publishers/{publisherId}/ban)
|
|
BanPublisher(ctx echo.Context, publisherId string) error
|
|
// Retrieve all nodes
|
|
// (GET /publishers/{publisherId}/nodes)
|
|
ListNodesForPublisher(ctx echo.Context, publisherId string, params ListNodesForPublisherParams) error
|
|
// Create a new custom node
|
|
// (POST /publishers/{publisherId}/nodes)
|
|
CreateNode(ctx echo.Context, publisherId string) error
|
|
// Delete a specific node
|
|
// (DELETE /publishers/{publisherId}/nodes/{nodeId})
|
|
DeleteNode(ctx echo.Context, publisherId string, nodeId string) error
|
|
// Update a specific node
|
|
// (PUT /publishers/{publisherId}/nodes/{nodeId})
|
|
UpdateNode(ctx echo.Context, publisherId string, nodeId string) error
|
|
// Ban a publisher's Node
|
|
// (POST /publishers/{publisherId}/nodes/{nodeId}/ban)
|
|
BanPublisherNode(ctx echo.Context, publisherId string, nodeId string) error
|
|
// Retrieve permissions the user has for a given publisher
|
|
// (GET /publishers/{publisherId}/nodes/{nodeId}/permissions)
|
|
GetPermissionOnPublisherNodes(ctx echo.Context, publisherId string, nodeId string) error
|
|
// Publish a new version of a node
|
|
// (POST /publishers/{publisherId}/nodes/{nodeId}/versions)
|
|
PublishNodeVersion(ctx echo.Context, publisherId string, nodeId string) error
|
|
// Unpublish (delete) a specific version of a node
|
|
// (DELETE /publishers/{publisherId}/nodes/{nodeId}/versions/{versionId})
|
|
DeleteNodeVersion(ctx echo.Context, publisherId string, nodeId string, versionId string) error
|
|
// Update changelog and deprecation status of a node version
|
|
// (PUT /publishers/{publisherId}/nodes/{nodeId}/versions/{versionId})
|
|
UpdateNodeVersion(ctx echo.Context, publisherId string, nodeId string, versionId string) error
|
|
// Retrieve permissions the user has for a given publisher
|
|
// (GET /publishers/{publisherId}/permissions)
|
|
GetPermissionOnPublisher(ctx echo.Context, publisherId string) error
|
|
// Retrieve all personal access tokens for a publisher
|
|
// (GET /publishers/{publisherId}/tokens)
|
|
ListPersonalAccessTokens(ctx echo.Context, publisherId string) error
|
|
// Create a new personal access token
|
|
// (POST /publishers/{publisherId}/tokens)
|
|
CreatePersonalAccessToken(ctx echo.Context, publisherId string) error
|
|
// Delete a specific personal access token
|
|
// (DELETE /publishers/{publisherId}/tokens/{tokenId})
|
|
DeletePersonalAccessToken(ctx echo.Context, publisherId string, tokenId string) error
|
|
// Security Scan
|
|
// (GET /security-scan)
|
|
SecurityScan(ctx echo.Context, params SecurityScanParams) error
|
|
// Receive artifacts (output files) from the Hanzo Studio GitHub Action
|
|
// (POST /upload-artifact)
|
|
PostUploadArtifact(ctx echo.Context) error
|
|
// Get information about the calling user.
|
|
// (GET /users)
|
|
GetUser(ctx echo.Context) error
|
|
// Retrieve all publishers for a given user
|
|
// (GET /users/publishers/)
|
|
ListPublishersForUser(ctx echo.Context) error
|
|
// List all node versions given some filters.
|
|
// (GET /versions)
|
|
ListAllNodeVersions(ctx echo.Context, params ListAllNodeVersionsParams) error
|
|
// Retrieve a specific commit by ID
|
|
// (GET /workflowresult/{workflowResultId})
|
|
GetWorkflowResult(ctx echo.Context, workflowResultId string) error
|
|
}
|
|
|
|
// ServerInterfaceWrapper converts echo contexts to parameters.
|
|
type ServerInterfaceWrapper struct {
|
|
Handler ServerInterface
|
|
}
|
|
|
|
// AdminUpdateNodeVersion converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) AdminUpdateNodeVersion(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "nodeId" -------------
|
|
var nodeId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "nodeId", ctx.Param("nodeId"), &nodeId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter nodeId: %s", err))
|
|
}
|
|
|
|
// ------------- Path parameter "versionNumber" -------------
|
|
var versionNumber string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "versionNumber", ctx.Param("versionNumber"), &versionNumber, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter versionNumber: %s", err))
|
|
}
|
|
|
|
ctx.Set(BearerAuthScopes, []string{})
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.AdminUpdateNodeVersion(ctx, nodeId, versionNumber)
|
|
return err
|
|
}
|
|
|
|
// GetBranch converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) GetBranch(ctx echo.Context) error {
|
|
var err error
|
|
|
|
// Parameter object where we will unmarshal all parameters from the context
|
|
var params GetBranchParams
|
|
// ------------- Required query parameter "repo_name" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, true, "repo_name", ctx.QueryParams(), ¶ms.RepoName)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter repo_name: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.GetBranch(ctx, params)
|
|
return err
|
|
}
|
|
|
|
// ComfyNodesBackfill converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) ComfyNodesBackfill(ctx echo.Context) error {
|
|
var err error
|
|
|
|
// Parameter object where we will unmarshal all parameters from the context
|
|
var params ComfyNodesBackfillParams
|
|
// ------------- Optional query parameter "max_node" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "max_node", ctx.QueryParams(), ¶ms.MaxNode)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter max_node: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.ComfyNodesBackfill(ctx, params)
|
|
return err
|
|
}
|
|
|
|
// GetGitcommit converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) GetGitcommit(ctx echo.Context) error {
|
|
var err error
|
|
|
|
// Parameter object where we will unmarshal all parameters from the context
|
|
var params GetGitcommitParams
|
|
// ------------- Optional query parameter "commitId" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "commitId", ctx.QueryParams(), ¶ms.CommitId)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter commitId: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "operatingSystem" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "operatingSystem", ctx.QueryParams(), ¶ms.OperatingSystem)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter operatingSystem: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "workflowName" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "workflowName", ctx.QueryParams(), ¶ms.WorkflowName)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter workflowName: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "branch" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "branch", ctx.QueryParams(), ¶ms.Branch)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter branch: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "page" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "page", ctx.QueryParams(), ¶ms.Page)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter page: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "pageSize" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "pageSize", ctx.QueryParams(), ¶ms.PageSize)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter pageSize: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "repoName" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "repoName", ctx.QueryParams(), ¶ms.RepoName)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter repoName: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.GetGitcommit(ctx, params)
|
|
return err
|
|
}
|
|
|
|
// GetGitcommitsummary converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) GetGitcommitsummary(ctx echo.Context) error {
|
|
var err error
|
|
|
|
// Parameter object where we will unmarshal all parameters from the context
|
|
var params GetGitcommitsummaryParams
|
|
// ------------- Optional query parameter "repoName" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "repoName", ctx.QueryParams(), ¶ms.RepoName)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter repoName: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "branchName" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "branchName", ctx.QueryParams(), ¶ms.BranchName)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter branchName: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "page" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "page", ctx.QueryParams(), ¶ms.Page)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter page: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "pageSize" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "pageSize", ctx.QueryParams(), ¶ms.PageSize)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter pageSize: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.GetGitcommitsummary(ctx, params)
|
|
return err
|
|
}
|
|
|
|
// ListAllNodes converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) ListAllNodes(ctx echo.Context) error {
|
|
var err error
|
|
|
|
// Parameter object where we will unmarshal all parameters from the context
|
|
var params ListAllNodesParams
|
|
// ------------- Optional query parameter "page" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "page", ctx.QueryParams(), ¶ms.Page)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter page: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "limit" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "limit", ctx.QueryParams(), ¶ms.Limit)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter limit: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "include_banned" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "include_banned", ctx.QueryParams(), ¶ms.IncludeBanned)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter include_banned: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "timestamp" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "timestamp", ctx.QueryParams(), ¶ms.Timestamp)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter timestamp: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "latest" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "latest", ctx.QueryParams(), ¶ms.Latest)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter latest: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.ListAllNodes(ctx, params)
|
|
return err
|
|
}
|
|
|
|
// ReindexNodes converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) ReindexNodes(ctx echo.Context) error {
|
|
var err error
|
|
|
|
// Parameter object where we will unmarshal all parameters from the context
|
|
var params ReindexNodesParams
|
|
// ------------- Optional query parameter "max_batch" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "max_batch", ctx.QueryParams(), ¶ms.MaxBatch)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter max_batch: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "min_age" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "min_age", ctx.QueryParams(), ¶ms.MinAge)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter min_age: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.ReindexNodes(ctx, params)
|
|
return err
|
|
}
|
|
|
|
// SearchNodes converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) SearchNodes(ctx echo.Context) error {
|
|
var err error
|
|
|
|
// Parameter object where we will unmarshal all parameters from the context
|
|
var params SearchNodesParams
|
|
// ------------- Optional query parameter "page" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "page", ctx.QueryParams(), ¶ms.Page)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter page: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "limit" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "limit", ctx.QueryParams(), ¶ms.Limit)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter limit: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "search" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "search", ctx.QueryParams(), ¶ms.Search)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter search: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "include_banned" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "include_banned", ctx.QueryParams(), ¶ms.IncludeBanned)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter include_banned: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.SearchNodes(ctx, params)
|
|
return err
|
|
}
|
|
|
|
// GetNode converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) GetNode(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "nodeId" -------------
|
|
var nodeId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "nodeId", ctx.Param("nodeId"), &nodeId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter nodeId: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.GetNode(ctx, nodeId)
|
|
return err
|
|
}
|
|
|
|
// InstallNode converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) InstallNode(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "nodeId" -------------
|
|
var nodeId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "nodeId", ctx.Param("nodeId"), &nodeId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter nodeId: %s", err))
|
|
}
|
|
|
|
// Parameter object where we will unmarshal all parameters from the context
|
|
var params InstallNodeParams
|
|
// ------------- Optional query parameter "version" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "version", ctx.QueryParams(), ¶ms.Version)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter version: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.InstallNode(ctx, nodeId, params)
|
|
return err
|
|
}
|
|
|
|
// PostNodeReview converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) PostNodeReview(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "nodeId" -------------
|
|
var nodeId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "nodeId", ctx.Param("nodeId"), &nodeId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter nodeId: %s", err))
|
|
}
|
|
|
|
// Parameter object where we will unmarshal all parameters from the context
|
|
var params PostNodeReviewParams
|
|
// ------------- Required query parameter "star" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, true, "star", ctx.QueryParams(), ¶ms.Star)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter star: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.PostNodeReview(ctx, nodeId, params)
|
|
return err
|
|
}
|
|
|
|
// ListNodeVersions converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) ListNodeVersions(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "nodeId" -------------
|
|
var nodeId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "nodeId", ctx.Param("nodeId"), &nodeId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter nodeId: %s", err))
|
|
}
|
|
|
|
// Parameter object where we will unmarshal all parameters from the context
|
|
var params ListNodeVersionsParams
|
|
// ------------- Optional query parameter "statuses" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "statuses", ctx.QueryParams(), ¶ms.Statuses)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter statuses: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "include_status_reason" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "include_status_reason", ctx.QueryParams(), ¶ms.IncludeStatusReason)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter include_status_reason: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.ListNodeVersions(ctx, nodeId, params)
|
|
return err
|
|
}
|
|
|
|
// GetNodeVersion converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) GetNodeVersion(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "nodeId" -------------
|
|
var nodeId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "nodeId", ctx.Param("nodeId"), &nodeId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter nodeId: %s", err))
|
|
}
|
|
|
|
// ------------- Path parameter "versionId" -------------
|
|
var versionId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "versionId", ctx.Param("versionId"), &versionId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter versionId: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.GetNodeVersion(ctx, nodeId, versionId)
|
|
return err
|
|
}
|
|
|
|
// CreateComfyNodes converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) CreateComfyNodes(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "nodeId" -------------
|
|
var nodeId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "nodeId", ctx.Param("nodeId"), &nodeId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter nodeId: %s", err))
|
|
}
|
|
|
|
// ------------- Path parameter "version" -------------
|
|
var version string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "version", ctx.Param("version"), &version, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter version: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.CreateComfyNodes(ctx, nodeId, version)
|
|
return err
|
|
}
|
|
|
|
// GetComfyNode converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) GetComfyNode(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "nodeId" -------------
|
|
var nodeId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "nodeId", ctx.Param("nodeId"), &nodeId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter nodeId: %s", err))
|
|
}
|
|
|
|
// ------------- Path parameter "version" -------------
|
|
var version string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "version", ctx.Param("version"), &version, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter version: %s", err))
|
|
}
|
|
|
|
// ------------- Path parameter "comfyNodeId" -------------
|
|
var comfyNodeId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "comfyNodeId", ctx.Param("comfyNodeId"), &comfyNodeId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter comfyNodeId: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.GetComfyNode(ctx, nodeId, version, comfyNodeId)
|
|
return err
|
|
}
|
|
|
|
// ListPublishers converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) ListPublishers(ctx echo.Context) error {
|
|
var err error
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.ListPublishers(ctx)
|
|
return err
|
|
}
|
|
|
|
// CreatePublisher converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) CreatePublisher(ctx echo.Context) error {
|
|
var err error
|
|
|
|
ctx.Set(BearerAuthScopes, []string{})
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.CreatePublisher(ctx)
|
|
return err
|
|
}
|
|
|
|
// ValidatePublisher converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) ValidatePublisher(ctx echo.Context) error {
|
|
var err error
|
|
|
|
// Parameter object where we will unmarshal all parameters from the context
|
|
var params ValidatePublisherParams
|
|
// ------------- Required query parameter "username" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, true, "username", ctx.QueryParams(), ¶ms.Username)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter username: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.ValidatePublisher(ctx, params)
|
|
return err
|
|
}
|
|
|
|
// DeletePublisher converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) DeletePublisher(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "publisherId" -------------
|
|
var publisherId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "publisherId", ctx.Param("publisherId"), &publisherId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter publisherId: %s", err))
|
|
}
|
|
|
|
ctx.Set(BearerAuthScopes, []string{})
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.DeletePublisher(ctx, publisherId)
|
|
return err
|
|
}
|
|
|
|
// GetPublisher converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) GetPublisher(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "publisherId" -------------
|
|
var publisherId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "publisherId", ctx.Param("publisherId"), &publisherId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter publisherId: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.GetPublisher(ctx, publisherId)
|
|
return err
|
|
}
|
|
|
|
// UpdatePublisher converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) UpdatePublisher(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "publisherId" -------------
|
|
var publisherId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "publisherId", ctx.Param("publisherId"), &publisherId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter publisherId: %s", err))
|
|
}
|
|
|
|
ctx.Set(BearerAuthScopes, []string{})
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.UpdatePublisher(ctx, publisherId)
|
|
return err
|
|
}
|
|
|
|
// BanPublisher converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) BanPublisher(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "publisherId" -------------
|
|
var publisherId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "publisherId", ctx.Param("publisherId"), &publisherId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter publisherId: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.BanPublisher(ctx, publisherId)
|
|
return err
|
|
}
|
|
|
|
// ListNodesForPublisher converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) ListNodesForPublisher(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "publisherId" -------------
|
|
var publisherId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "publisherId", ctx.Param("publisherId"), &publisherId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter publisherId: %s", err))
|
|
}
|
|
|
|
ctx.Set(BearerAuthScopes, []string{})
|
|
|
|
// Parameter object where we will unmarshal all parameters from the context
|
|
var params ListNodesForPublisherParams
|
|
// ------------- Optional query parameter "include_banned" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "include_banned", ctx.QueryParams(), ¶ms.IncludeBanned)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter include_banned: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.ListNodesForPublisher(ctx, publisherId, params)
|
|
return err
|
|
}
|
|
|
|
// CreateNode converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) CreateNode(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "publisherId" -------------
|
|
var publisherId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "publisherId", ctx.Param("publisherId"), &publisherId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter publisherId: %s", err))
|
|
}
|
|
|
|
ctx.Set(BearerAuthScopes, []string{})
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.CreateNode(ctx, publisherId)
|
|
return err
|
|
}
|
|
|
|
// DeleteNode converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) DeleteNode(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "publisherId" -------------
|
|
var publisherId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "publisherId", ctx.Param("publisherId"), &publisherId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter publisherId: %s", err))
|
|
}
|
|
|
|
// ------------- Path parameter "nodeId" -------------
|
|
var nodeId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "nodeId", ctx.Param("nodeId"), &nodeId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter nodeId: %s", err))
|
|
}
|
|
|
|
ctx.Set(BearerAuthScopes, []string{})
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.DeleteNode(ctx, publisherId, nodeId)
|
|
return err
|
|
}
|
|
|
|
// UpdateNode converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) UpdateNode(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "publisherId" -------------
|
|
var publisherId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "publisherId", ctx.Param("publisherId"), &publisherId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter publisherId: %s", err))
|
|
}
|
|
|
|
// ------------- Path parameter "nodeId" -------------
|
|
var nodeId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "nodeId", ctx.Param("nodeId"), &nodeId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter nodeId: %s", err))
|
|
}
|
|
|
|
ctx.Set(BearerAuthScopes, []string{})
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.UpdateNode(ctx, publisherId, nodeId)
|
|
return err
|
|
}
|
|
|
|
// BanPublisherNode converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) BanPublisherNode(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "publisherId" -------------
|
|
var publisherId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "publisherId", ctx.Param("publisherId"), &publisherId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter publisherId: %s", err))
|
|
}
|
|
|
|
// ------------- Path parameter "nodeId" -------------
|
|
var nodeId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "nodeId", ctx.Param("nodeId"), &nodeId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter nodeId: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.BanPublisherNode(ctx, publisherId, nodeId)
|
|
return err
|
|
}
|
|
|
|
// GetPermissionOnPublisherNodes converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) GetPermissionOnPublisherNodes(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "publisherId" -------------
|
|
var publisherId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "publisherId", ctx.Param("publisherId"), &publisherId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter publisherId: %s", err))
|
|
}
|
|
|
|
// ------------- Path parameter "nodeId" -------------
|
|
var nodeId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "nodeId", ctx.Param("nodeId"), &nodeId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter nodeId: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.GetPermissionOnPublisherNodes(ctx, publisherId, nodeId)
|
|
return err
|
|
}
|
|
|
|
// PublishNodeVersion converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) PublishNodeVersion(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "publisherId" -------------
|
|
var publisherId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "publisherId", ctx.Param("publisherId"), &publisherId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter publisherId: %s", err))
|
|
}
|
|
|
|
// ------------- Path parameter "nodeId" -------------
|
|
var nodeId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "nodeId", ctx.Param("nodeId"), &nodeId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter nodeId: %s", err))
|
|
}
|
|
|
|
ctx.Set(BearerAuthScopes, []string{})
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.PublishNodeVersion(ctx, publisherId, nodeId)
|
|
return err
|
|
}
|
|
|
|
// DeleteNodeVersion converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) DeleteNodeVersion(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "publisherId" -------------
|
|
var publisherId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "publisherId", ctx.Param("publisherId"), &publisherId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter publisherId: %s", err))
|
|
}
|
|
|
|
// ------------- Path parameter "nodeId" -------------
|
|
var nodeId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "nodeId", ctx.Param("nodeId"), &nodeId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter nodeId: %s", err))
|
|
}
|
|
|
|
// ------------- Path parameter "versionId" -------------
|
|
var versionId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "versionId", ctx.Param("versionId"), &versionId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter versionId: %s", err))
|
|
}
|
|
|
|
ctx.Set(BearerAuthScopes, []string{})
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.DeleteNodeVersion(ctx, publisherId, nodeId, versionId)
|
|
return err
|
|
}
|
|
|
|
// UpdateNodeVersion converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) UpdateNodeVersion(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "publisherId" -------------
|
|
var publisherId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "publisherId", ctx.Param("publisherId"), &publisherId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter publisherId: %s", err))
|
|
}
|
|
|
|
// ------------- Path parameter "nodeId" -------------
|
|
var nodeId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "nodeId", ctx.Param("nodeId"), &nodeId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter nodeId: %s", err))
|
|
}
|
|
|
|
// ------------- Path parameter "versionId" -------------
|
|
var versionId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "versionId", ctx.Param("versionId"), &versionId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter versionId: %s", err))
|
|
}
|
|
|
|
ctx.Set(BearerAuthScopes, []string{})
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.UpdateNodeVersion(ctx, publisherId, nodeId, versionId)
|
|
return err
|
|
}
|
|
|
|
// GetPermissionOnPublisher converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) GetPermissionOnPublisher(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "publisherId" -------------
|
|
var publisherId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "publisherId", ctx.Param("publisherId"), &publisherId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter publisherId: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.GetPermissionOnPublisher(ctx, publisherId)
|
|
return err
|
|
}
|
|
|
|
// ListPersonalAccessTokens converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) ListPersonalAccessTokens(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "publisherId" -------------
|
|
var publisherId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "publisherId", ctx.Param("publisherId"), &publisherId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter publisherId: %s", err))
|
|
}
|
|
|
|
ctx.Set(BearerAuthScopes, []string{})
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.ListPersonalAccessTokens(ctx, publisherId)
|
|
return err
|
|
}
|
|
|
|
// CreatePersonalAccessToken converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) CreatePersonalAccessToken(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "publisherId" -------------
|
|
var publisherId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "publisherId", ctx.Param("publisherId"), &publisherId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter publisherId: %s", err))
|
|
}
|
|
|
|
ctx.Set(BearerAuthScopes, []string{})
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.CreatePersonalAccessToken(ctx, publisherId)
|
|
return err
|
|
}
|
|
|
|
// DeletePersonalAccessToken converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) DeletePersonalAccessToken(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "publisherId" -------------
|
|
var publisherId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "publisherId", ctx.Param("publisherId"), &publisherId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter publisherId: %s", err))
|
|
}
|
|
|
|
// ------------- Path parameter "tokenId" -------------
|
|
var tokenId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "tokenId", ctx.Param("tokenId"), &tokenId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter tokenId: %s", err))
|
|
}
|
|
|
|
ctx.Set(BearerAuthScopes, []string{})
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.DeletePersonalAccessToken(ctx, publisherId, tokenId)
|
|
return err
|
|
}
|
|
|
|
// SecurityScan converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) SecurityScan(ctx echo.Context) error {
|
|
var err error
|
|
|
|
// Parameter object where we will unmarshal all parameters from the context
|
|
var params SecurityScanParams
|
|
// ------------- Optional query parameter "minAge" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "minAge", ctx.QueryParams(), ¶ms.MinAge)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter minAge: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "maxNodes" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "maxNodes", ctx.QueryParams(), ¶ms.MaxNodes)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter maxNodes: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.SecurityScan(ctx, params)
|
|
return err
|
|
}
|
|
|
|
// PostUploadArtifact converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) PostUploadArtifact(ctx echo.Context) error {
|
|
var err error
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.PostUploadArtifact(ctx)
|
|
return err
|
|
}
|
|
|
|
// GetUser converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) GetUser(ctx echo.Context) error {
|
|
var err error
|
|
|
|
ctx.Set(BearerAuthScopes, []string{})
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.GetUser(ctx)
|
|
return err
|
|
}
|
|
|
|
// ListPublishersForUser converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) ListPublishersForUser(ctx echo.Context) error {
|
|
var err error
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.ListPublishersForUser(ctx)
|
|
return err
|
|
}
|
|
|
|
// ListAllNodeVersions converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) ListAllNodeVersions(ctx echo.Context) error {
|
|
var err error
|
|
|
|
// Parameter object where we will unmarshal all parameters from the context
|
|
var params ListAllNodeVersionsParams
|
|
// ------------- Optional query parameter "nodeId" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "nodeId", ctx.QueryParams(), ¶ms.NodeId)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter nodeId: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "statuses" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "statuses", ctx.QueryParams(), ¶ms.Statuses)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter statuses: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "include_status_reason" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "include_status_reason", ctx.QueryParams(), ¶ms.IncludeStatusReason)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter include_status_reason: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "page" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "page", ctx.QueryParams(), ¶ms.Page)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter page: %s", err))
|
|
}
|
|
|
|
// ------------- Optional query parameter "pageSize" -------------
|
|
|
|
err = runtime.BindQueryParameter("form", true, false, "pageSize", ctx.QueryParams(), ¶ms.PageSize)
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter pageSize: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.ListAllNodeVersions(ctx, params)
|
|
return err
|
|
}
|
|
|
|
// GetWorkflowResult converts echo context to params.
|
|
func (w *ServerInterfaceWrapper) GetWorkflowResult(ctx echo.Context) error {
|
|
var err error
|
|
// ------------- Path parameter "workflowResultId" -------------
|
|
var workflowResultId string
|
|
|
|
err = runtime.BindStyledParameterWithOptions("simple", "workflowResultId", ctx.Param("workflowResultId"), &workflowResultId, runtime.BindStyledParameterOptions{ParamLocation: runtime.ParamLocationPath, Explode: false, Required: true})
|
|
if err != nil {
|
|
return echo.NewHTTPError(http.StatusBadRequest, fmt.Sprintf("Invalid format for parameter workflowResultId: %s", err))
|
|
}
|
|
|
|
// Invoke the callback with all the unmarshaled arguments
|
|
err = w.Handler.GetWorkflowResult(ctx, workflowResultId)
|
|
return err
|
|
}
|
|
|
|
// This is a simple interface which specifies echo.Route addition functions which
|
|
// are present on both echo.Echo and echo.Group, since we want to allow using
|
|
// either of them for path registration
|
|
type EchoRouter interface {
|
|
CONNECT(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
|
|
DELETE(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
|
|
GET(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
|
|
HEAD(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
|
|
OPTIONS(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
|
|
PATCH(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
|
|
POST(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
|
|
PUT(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
|
|
TRACE(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
|
|
}
|
|
|
|
// RegisterHandlers adds each server route to the EchoRouter.
|
|
func RegisterHandlers(router EchoRouter, si ServerInterface) {
|
|
RegisterHandlersWithBaseURL(router, si, "")
|
|
}
|
|
|
|
// Registers handlers, and prepends BaseURL to the paths, so that the paths
|
|
// can be served under a prefix.
|
|
func RegisterHandlersWithBaseURL(router EchoRouter, si ServerInterface, baseURL string) {
|
|
|
|
wrapper := ServerInterfaceWrapper{
|
|
Handler: si,
|
|
}
|
|
|
|
router.PUT(baseURL+"/admin/nodes/:nodeId/versions/:versionNumber", wrapper.AdminUpdateNodeVersion)
|
|
router.GET(baseURL+"/branch", wrapper.GetBranch)
|
|
router.POST(baseURL+"/comfy-nodes/backfill", wrapper.ComfyNodesBackfill)
|
|
router.GET(baseURL+"/gitcommit", wrapper.GetGitcommit)
|
|
router.GET(baseURL+"/gitcommitsummary", wrapper.GetGitcommitsummary)
|
|
router.GET(baseURL+"/nodes", wrapper.ListAllNodes)
|
|
router.POST(baseURL+"/nodes/reindex", wrapper.ReindexNodes)
|
|
router.GET(baseURL+"/nodes/search", wrapper.SearchNodes)
|
|
router.GET(baseURL+"/nodes/:nodeId", wrapper.GetNode)
|
|
router.GET(baseURL+"/nodes/:nodeId/install", wrapper.InstallNode)
|
|
router.POST(baseURL+"/nodes/:nodeId/reviews", wrapper.PostNodeReview)
|
|
router.GET(baseURL+"/nodes/:nodeId/versions", wrapper.ListNodeVersions)
|
|
router.GET(baseURL+"/nodes/:nodeId/versions/:versionId", wrapper.GetNodeVersion)
|
|
router.POST(baseURL+"/nodes/:nodeId/versions/:version/comfy-nodes", wrapper.CreateComfyNodes)
|
|
router.GET(baseURL+"/nodes/:nodeId/versions/:version/comfy-nodes/:comfyNodeId", wrapper.GetComfyNode)
|
|
router.GET(baseURL+"/publishers", wrapper.ListPublishers)
|
|
router.POST(baseURL+"/publishers", wrapper.CreatePublisher)
|
|
router.GET(baseURL+"/publishers/validate", wrapper.ValidatePublisher)
|
|
router.DELETE(baseURL+"/publishers/:publisherId", wrapper.DeletePublisher)
|
|
router.GET(baseURL+"/publishers/:publisherId", wrapper.GetPublisher)
|
|
router.PUT(baseURL+"/publishers/:publisherId", wrapper.UpdatePublisher)
|
|
router.POST(baseURL+"/publishers/:publisherId/ban", wrapper.BanPublisher)
|
|
router.GET(baseURL+"/publishers/:publisherId/nodes", wrapper.ListNodesForPublisher)
|
|
router.POST(baseURL+"/publishers/:publisherId/nodes", wrapper.CreateNode)
|
|
router.DELETE(baseURL+"/publishers/:publisherId/nodes/:nodeId", wrapper.DeleteNode)
|
|
router.PUT(baseURL+"/publishers/:publisherId/nodes/:nodeId", wrapper.UpdateNode)
|
|
router.POST(baseURL+"/publishers/:publisherId/nodes/:nodeId/ban", wrapper.BanPublisherNode)
|
|
router.GET(baseURL+"/publishers/:publisherId/nodes/:nodeId/permissions", wrapper.GetPermissionOnPublisherNodes)
|
|
router.POST(baseURL+"/publishers/:publisherId/nodes/:nodeId/versions", wrapper.PublishNodeVersion)
|
|
router.DELETE(baseURL+"/publishers/:publisherId/nodes/:nodeId/versions/:versionId", wrapper.DeleteNodeVersion)
|
|
router.PUT(baseURL+"/publishers/:publisherId/nodes/:nodeId/versions/:versionId", wrapper.UpdateNodeVersion)
|
|
router.GET(baseURL+"/publishers/:publisherId/permissions", wrapper.GetPermissionOnPublisher)
|
|
router.GET(baseURL+"/publishers/:publisherId/tokens", wrapper.ListPersonalAccessTokens)
|
|
router.POST(baseURL+"/publishers/:publisherId/tokens", wrapper.CreatePersonalAccessToken)
|
|
router.DELETE(baseURL+"/publishers/:publisherId/tokens/:tokenId", wrapper.DeletePersonalAccessToken)
|
|
router.GET(baseURL+"/security-scan", wrapper.SecurityScan)
|
|
router.POST(baseURL+"/upload-artifact", wrapper.PostUploadArtifact)
|
|
router.GET(baseURL+"/users", wrapper.GetUser)
|
|
router.GET(baseURL+"/users/publishers/", wrapper.ListPublishersForUser)
|
|
router.GET(baseURL+"/versions", wrapper.ListAllNodeVersions)
|
|
router.GET(baseURL+"/workflowresult/:workflowResultId", wrapper.GetWorkflowResult)
|
|
|
|
}
|
|
|
|
type AdminUpdateNodeVersionRequestObject struct {
|
|
NodeId string `json:"nodeId"`
|
|
VersionNumber string `json:"versionNumber"`
|
|
Body *AdminUpdateNodeVersionJSONRequestBody
|
|
}
|
|
|
|
type AdminUpdateNodeVersionResponseObject interface {
|
|
VisitAdminUpdateNodeVersionResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type AdminUpdateNodeVersion200JSONResponse NodeVersion
|
|
|
|
func (response AdminUpdateNodeVersion200JSONResponse) VisitAdminUpdateNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type AdminUpdateNodeVersion400JSONResponse ErrorResponse
|
|
|
|
func (response AdminUpdateNodeVersion400JSONResponse) VisitAdminUpdateNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(400)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type AdminUpdateNodeVersion401Response struct {
|
|
}
|
|
|
|
func (response AdminUpdateNodeVersion401Response) VisitAdminUpdateNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(401)
|
|
return nil
|
|
}
|
|
|
|
type AdminUpdateNodeVersion403JSONResponse ErrorResponse
|
|
|
|
func (response AdminUpdateNodeVersion403JSONResponse) VisitAdminUpdateNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(403)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type AdminUpdateNodeVersion404JSONResponse ErrorResponse
|
|
|
|
func (response AdminUpdateNodeVersion404JSONResponse) VisitAdminUpdateNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(404)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type AdminUpdateNodeVersion500JSONResponse ErrorResponse
|
|
|
|
func (response AdminUpdateNodeVersion500JSONResponse) VisitAdminUpdateNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetBranchRequestObject struct {
|
|
Params GetBranchParams
|
|
}
|
|
|
|
type GetBranchResponseObject interface {
|
|
VisitGetBranchResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type GetBranch200JSONResponse struct {
|
|
Branches *[]string `json:"branches,omitempty"`
|
|
}
|
|
|
|
func (response GetBranch200JSONResponse) VisitGetBranchResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetBranch404Response struct {
|
|
}
|
|
|
|
func (response GetBranch404Response) VisitGetBranchResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(404)
|
|
return nil
|
|
}
|
|
|
|
type GetBranch500Response struct {
|
|
}
|
|
|
|
func (response GetBranch500Response) VisitGetBranchResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(500)
|
|
return nil
|
|
}
|
|
|
|
type ComfyNodesBackfillRequestObject struct {
|
|
Params ComfyNodesBackfillParams
|
|
}
|
|
|
|
type ComfyNodesBackfillResponseObject interface {
|
|
VisitComfyNodesBackfillResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type ComfyNodesBackfill204Response struct {
|
|
}
|
|
|
|
func (response ComfyNodesBackfill204Response) VisitComfyNodesBackfillResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(204)
|
|
return nil
|
|
}
|
|
|
|
type ComfyNodesBackfill400JSONResponse ErrorResponse
|
|
|
|
func (response ComfyNodesBackfill400JSONResponse) VisitComfyNodesBackfillResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(400)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ComfyNodesBackfill401Response struct {
|
|
}
|
|
|
|
func (response ComfyNodesBackfill401Response) VisitComfyNodesBackfillResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(401)
|
|
return nil
|
|
}
|
|
|
|
type ComfyNodesBackfill403JSONResponse ErrorResponse
|
|
|
|
func (response ComfyNodesBackfill403JSONResponse) VisitComfyNodesBackfillResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(403)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ComfyNodesBackfill500JSONResponse ErrorResponse
|
|
|
|
func (response ComfyNodesBackfill500JSONResponse) VisitComfyNodesBackfillResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetGitcommitRequestObject struct {
|
|
Params GetGitcommitParams
|
|
}
|
|
|
|
type GetGitcommitResponseObject interface {
|
|
VisitGetGitcommitResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type GetGitcommit200JSONResponse struct {
|
|
JobResults *[]ActionJobResult `json:"jobResults,omitempty"`
|
|
TotalNumberOfPages *int `json:"totalNumberOfPages,omitempty"`
|
|
}
|
|
|
|
func (response GetGitcommit200JSONResponse) VisitGetGitcommitResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetGitcommit404Response struct {
|
|
}
|
|
|
|
func (response GetGitcommit404Response) VisitGetGitcommitResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(404)
|
|
return nil
|
|
}
|
|
|
|
type GetGitcommit500Response struct {
|
|
}
|
|
|
|
func (response GetGitcommit500Response) VisitGetGitcommitResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(500)
|
|
return nil
|
|
}
|
|
|
|
type GetGitcommitsummaryRequestObject struct {
|
|
Params GetGitcommitsummaryParams
|
|
}
|
|
|
|
type GetGitcommitsummaryResponseObject interface {
|
|
VisitGetGitcommitsummaryResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type GetGitcommitsummary200JSONResponse struct {
|
|
CommitSummaries *[]GitCommitSummary `json:"commitSummaries,omitempty"`
|
|
TotalNumberOfPages *int `json:"totalNumberOfPages,omitempty"`
|
|
}
|
|
|
|
func (response GetGitcommitsummary200JSONResponse) VisitGetGitcommitsummaryResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetGitcommitsummary500JSONResponse struct {
|
|
Message *string `json:"message,omitempty"`
|
|
}
|
|
|
|
func (response GetGitcommitsummary500JSONResponse) VisitGetGitcommitsummaryResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListAllNodesRequestObject struct {
|
|
Params ListAllNodesParams
|
|
}
|
|
|
|
type ListAllNodesResponseObject interface {
|
|
VisitListAllNodesResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type ListAllNodes200JSONResponse struct {
|
|
// Limit Maximum number of nodes per page
|
|
Limit *int `json:"limit,omitempty"`
|
|
Nodes *[]Node `json:"nodes,omitempty"`
|
|
|
|
// Page Current page number
|
|
Page *int `json:"page,omitempty"`
|
|
|
|
// Total Total number of nodes available
|
|
Total *int `json:"total,omitempty"`
|
|
|
|
// TotalPages Total number of pages available
|
|
TotalPages *int `json:"totalPages,omitempty"`
|
|
}
|
|
|
|
func (response ListAllNodes200JSONResponse) VisitListAllNodesResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListAllNodes400Response struct {
|
|
}
|
|
|
|
func (response ListAllNodes400Response) VisitListAllNodesResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(400)
|
|
return nil
|
|
}
|
|
|
|
type ListAllNodes404Response struct {
|
|
}
|
|
|
|
func (response ListAllNodes404Response) VisitListAllNodesResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(404)
|
|
return nil
|
|
}
|
|
|
|
type ListAllNodes500JSONResponse ErrorResponse
|
|
|
|
func (response ListAllNodes500JSONResponse) VisitListAllNodesResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ReindexNodesRequestObject struct {
|
|
Params ReindexNodesParams
|
|
}
|
|
|
|
type ReindexNodesResponseObject interface {
|
|
VisitReindexNodesResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type ReindexNodes200Response struct {
|
|
}
|
|
|
|
func (response ReindexNodes200Response) VisitReindexNodesResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(200)
|
|
return nil
|
|
}
|
|
|
|
type ReindexNodes400JSONResponse ErrorResponse
|
|
|
|
func (response ReindexNodes400JSONResponse) VisitReindexNodesResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(400)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ReindexNodes500JSONResponse ErrorResponse
|
|
|
|
func (response ReindexNodes500JSONResponse) VisitReindexNodesResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type SearchNodesRequestObject struct {
|
|
Params SearchNodesParams
|
|
}
|
|
|
|
type SearchNodesResponseObject interface {
|
|
VisitSearchNodesResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type SearchNodes200JSONResponse struct {
|
|
// Limit Maximum number of nodes per page
|
|
Limit *int `json:"limit,omitempty"`
|
|
Nodes *[]Node `json:"nodes,omitempty"`
|
|
|
|
// Page Current page number
|
|
Page *int `json:"page,omitempty"`
|
|
|
|
// Total Total number of nodes available
|
|
Total *int `json:"total,omitempty"`
|
|
|
|
// TotalPages Total number of pages available
|
|
TotalPages *int `json:"totalPages,omitempty"`
|
|
}
|
|
|
|
func (response SearchNodes200JSONResponse) VisitSearchNodesResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type SearchNodes400Response struct {
|
|
}
|
|
|
|
func (response SearchNodes400Response) VisitSearchNodesResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(400)
|
|
return nil
|
|
}
|
|
|
|
type SearchNodes404Response struct {
|
|
}
|
|
|
|
func (response SearchNodes404Response) VisitSearchNodesResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(404)
|
|
return nil
|
|
}
|
|
|
|
type SearchNodes500JSONResponse ErrorResponse
|
|
|
|
func (response SearchNodes500JSONResponse) VisitSearchNodesResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetNodeRequestObject struct {
|
|
NodeId string `json:"nodeId"`
|
|
}
|
|
|
|
type GetNodeResponseObject interface {
|
|
VisitGetNodeResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type GetNode200JSONResponse Node
|
|
|
|
func (response GetNode200JSONResponse) VisitGetNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetNode403JSONResponse ErrorResponse
|
|
|
|
func (response GetNode403JSONResponse) VisitGetNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(403)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetNode404JSONResponse ErrorResponse
|
|
|
|
func (response GetNode404JSONResponse) VisitGetNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(404)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetNode500JSONResponse ErrorResponse
|
|
|
|
func (response GetNode500JSONResponse) VisitGetNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type InstallNodeRequestObject struct {
|
|
NodeId string `json:"nodeId"`
|
|
Params InstallNodeParams
|
|
}
|
|
|
|
type InstallNodeResponseObject interface {
|
|
VisitInstallNodeResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type InstallNode200JSONResponse NodeVersion
|
|
|
|
func (response InstallNode200JSONResponse) VisitInstallNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type InstallNode400JSONResponse ErrorResponse
|
|
|
|
func (response InstallNode400JSONResponse) VisitInstallNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(400)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type InstallNode403JSONResponse ErrorResponse
|
|
|
|
func (response InstallNode403JSONResponse) VisitInstallNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(403)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type InstallNode404JSONResponse ErrorResponse
|
|
|
|
func (response InstallNode404JSONResponse) VisitInstallNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(404)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type InstallNode500JSONResponse ErrorResponse
|
|
|
|
func (response InstallNode500JSONResponse) VisitInstallNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type PostNodeReviewRequestObject struct {
|
|
NodeId string `json:"nodeId"`
|
|
Params PostNodeReviewParams
|
|
}
|
|
|
|
type PostNodeReviewResponseObject interface {
|
|
VisitPostNodeReviewResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type PostNodeReview200JSONResponse Node
|
|
|
|
func (response PostNodeReview200JSONResponse) VisitPostNodeReviewResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type PostNodeReview400Response struct {
|
|
}
|
|
|
|
func (response PostNodeReview400Response) VisitPostNodeReviewResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(400)
|
|
return nil
|
|
}
|
|
|
|
type PostNodeReview404JSONResponse Error
|
|
|
|
func (response PostNodeReview404JSONResponse) VisitPostNodeReviewResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(404)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type PostNodeReview500JSONResponse ErrorResponse
|
|
|
|
func (response PostNodeReview500JSONResponse) VisitPostNodeReviewResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListNodeVersionsRequestObject struct {
|
|
NodeId string `json:"nodeId"`
|
|
Params ListNodeVersionsParams
|
|
}
|
|
|
|
type ListNodeVersionsResponseObject interface {
|
|
VisitListNodeVersionsResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type ListNodeVersions200JSONResponse []NodeVersion
|
|
|
|
func (response ListNodeVersions200JSONResponse) VisitListNodeVersionsResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListNodeVersions403JSONResponse ErrorResponse
|
|
|
|
func (response ListNodeVersions403JSONResponse) VisitListNodeVersionsResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(403)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListNodeVersions404JSONResponse Error
|
|
|
|
func (response ListNodeVersions404JSONResponse) VisitListNodeVersionsResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(404)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListNodeVersions500JSONResponse ErrorResponse
|
|
|
|
func (response ListNodeVersions500JSONResponse) VisitListNodeVersionsResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetNodeVersionRequestObject struct {
|
|
NodeId string `json:"nodeId"`
|
|
VersionId string `json:"versionId"`
|
|
}
|
|
|
|
type GetNodeVersionResponseObject interface {
|
|
VisitGetNodeVersionResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type GetNodeVersion200JSONResponse NodeVersion
|
|
|
|
func (response GetNodeVersion200JSONResponse) VisitGetNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetNodeVersion404JSONResponse Error
|
|
|
|
func (response GetNodeVersion404JSONResponse) VisitGetNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(404)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetNodeVersion500JSONResponse ErrorResponse
|
|
|
|
func (response GetNodeVersion500JSONResponse) VisitGetNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type CreateComfyNodesRequestObject struct {
|
|
NodeId string `json:"nodeId"`
|
|
Version string `json:"version"`
|
|
Body *CreateComfyNodesJSONRequestBody
|
|
}
|
|
|
|
type CreateComfyNodesResponseObject interface {
|
|
VisitCreateComfyNodesResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type CreateComfyNodes204Response struct {
|
|
}
|
|
|
|
func (response CreateComfyNodes204Response) VisitCreateComfyNodesResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(204)
|
|
return nil
|
|
}
|
|
|
|
type CreateComfyNodes401Response struct {
|
|
}
|
|
|
|
func (response CreateComfyNodes401Response) VisitCreateComfyNodesResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(401)
|
|
return nil
|
|
}
|
|
|
|
type CreateComfyNodes403JSONResponse ErrorResponse
|
|
|
|
func (response CreateComfyNodes403JSONResponse) VisitCreateComfyNodesResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(403)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type CreateComfyNodes404JSONResponse ErrorResponse
|
|
|
|
func (response CreateComfyNodes404JSONResponse) VisitCreateComfyNodesResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(404)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type CreateComfyNodes409JSONResponse ErrorResponse
|
|
|
|
func (response CreateComfyNodes409JSONResponse) VisitCreateComfyNodesResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(409)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type CreateComfyNodes500JSONResponse ErrorResponse
|
|
|
|
func (response CreateComfyNodes500JSONResponse) VisitCreateComfyNodesResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetComfyNodeRequestObject struct {
|
|
NodeId string `json:"nodeId"`
|
|
Version string `json:"version"`
|
|
ComfyNodeId string `json:"comfyNodeId"`
|
|
}
|
|
|
|
type GetComfyNodeResponseObject interface {
|
|
VisitGetComfyNodeResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type GetComfyNode200JSONResponse ComfyNode
|
|
|
|
func (response GetComfyNode200JSONResponse) VisitGetComfyNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetComfyNode401Response struct {
|
|
}
|
|
|
|
func (response GetComfyNode401Response) VisitGetComfyNodeResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(401)
|
|
return nil
|
|
}
|
|
|
|
type GetComfyNode403JSONResponse ErrorResponse
|
|
|
|
func (response GetComfyNode403JSONResponse) VisitGetComfyNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(403)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetComfyNode404JSONResponse ErrorResponse
|
|
|
|
func (response GetComfyNode404JSONResponse) VisitGetComfyNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(404)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetComfyNode500JSONResponse ErrorResponse
|
|
|
|
func (response GetComfyNode500JSONResponse) VisitGetComfyNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListPublishersRequestObject struct {
|
|
}
|
|
|
|
type ListPublishersResponseObject interface {
|
|
VisitListPublishersResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type ListPublishers200JSONResponse []Publisher
|
|
|
|
func (response ListPublishers200JSONResponse) VisitListPublishersResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListPublishers400JSONResponse ErrorResponse
|
|
|
|
func (response ListPublishers400JSONResponse) VisitListPublishersResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(400)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListPublishers500JSONResponse ErrorResponse
|
|
|
|
func (response ListPublishers500JSONResponse) VisitListPublishersResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type CreatePublisherRequestObject struct {
|
|
Body *CreatePublisherJSONRequestBody
|
|
}
|
|
|
|
type CreatePublisherResponseObject interface {
|
|
VisitCreatePublisherResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type CreatePublisher201JSONResponse Publisher
|
|
|
|
func (response CreatePublisher201JSONResponse) VisitCreatePublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(201)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type CreatePublisher400JSONResponse ErrorResponse
|
|
|
|
func (response CreatePublisher400JSONResponse) VisitCreatePublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(400)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type CreatePublisher401Response struct {
|
|
}
|
|
|
|
func (response CreatePublisher401Response) VisitCreatePublisherResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(401)
|
|
return nil
|
|
}
|
|
|
|
type CreatePublisher403JSONResponse ErrorResponse
|
|
|
|
func (response CreatePublisher403JSONResponse) VisitCreatePublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(403)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type CreatePublisher500JSONResponse ErrorResponse
|
|
|
|
func (response CreatePublisher500JSONResponse) VisitCreatePublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ValidatePublisherRequestObject struct {
|
|
Params ValidatePublisherParams
|
|
}
|
|
|
|
type ValidatePublisherResponseObject interface {
|
|
VisitValidatePublisherResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type ValidatePublisher200JSONResponse struct {
|
|
// IsAvailable True if the username is available, false otherwise.
|
|
IsAvailable *bool `json:"isAvailable,omitempty"`
|
|
}
|
|
|
|
func (response ValidatePublisher200JSONResponse) VisitValidatePublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ValidatePublisher400JSONResponse ErrorResponse
|
|
|
|
func (response ValidatePublisher400JSONResponse) VisitValidatePublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(400)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ValidatePublisher500JSONResponse ErrorResponse
|
|
|
|
func (response ValidatePublisher500JSONResponse) VisitValidatePublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type DeletePublisherRequestObject struct {
|
|
PublisherId string `json:"publisherId"`
|
|
}
|
|
|
|
type DeletePublisherResponseObject interface {
|
|
VisitDeletePublisherResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type DeletePublisher204Response struct {
|
|
}
|
|
|
|
func (response DeletePublisher204Response) VisitDeletePublisherResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(204)
|
|
return nil
|
|
}
|
|
|
|
type DeletePublisher404JSONResponse ErrorResponse
|
|
|
|
func (response DeletePublisher404JSONResponse) VisitDeletePublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(404)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type DeletePublisher500JSONResponse ErrorResponse
|
|
|
|
func (response DeletePublisher500JSONResponse) VisitDeletePublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetPublisherRequestObject struct {
|
|
PublisherId string `json:"publisherId"`
|
|
}
|
|
|
|
type GetPublisherResponseObject interface {
|
|
VisitGetPublisherResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type GetPublisher200JSONResponse Publisher
|
|
|
|
func (response GetPublisher200JSONResponse) VisitGetPublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetPublisher404JSONResponse ErrorResponse
|
|
|
|
func (response GetPublisher404JSONResponse) VisitGetPublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(404)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetPublisher500JSONResponse ErrorResponse
|
|
|
|
func (response GetPublisher500JSONResponse) VisitGetPublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type UpdatePublisherRequestObject struct {
|
|
PublisherId string `json:"publisherId"`
|
|
Body *UpdatePublisherJSONRequestBody
|
|
}
|
|
|
|
type UpdatePublisherResponseObject interface {
|
|
VisitUpdatePublisherResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type UpdatePublisher200JSONResponse Publisher
|
|
|
|
func (response UpdatePublisher200JSONResponse) VisitUpdatePublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type UpdatePublisher400JSONResponse ErrorResponse
|
|
|
|
func (response UpdatePublisher400JSONResponse) VisitUpdatePublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(400)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type UpdatePublisher401Response struct {
|
|
}
|
|
|
|
func (response UpdatePublisher401Response) VisitUpdatePublisherResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(401)
|
|
return nil
|
|
}
|
|
|
|
type UpdatePublisher404JSONResponse ErrorResponse
|
|
|
|
func (response UpdatePublisher404JSONResponse) VisitUpdatePublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(404)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type UpdatePublisher500JSONResponse ErrorResponse
|
|
|
|
func (response UpdatePublisher500JSONResponse) VisitUpdatePublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type BanPublisherRequestObject struct {
|
|
PublisherId string `json:"publisherId"`
|
|
}
|
|
|
|
type BanPublisherResponseObject interface {
|
|
VisitBanPublisherResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type BanPublisher204Response struct {
|
|
}
|
|
|
|
func (response BanPublisher204Response) VisitBanPublisherResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(204)
|
|
return nil
|
|
}
|
|
|
|
type BanPublisher401Response struct {
|
|
}
|
|
|
|
func (response BanPublisher401Response) VisitBanPublisherResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(401)
|
|
return nil
|
|
}
|
|
|
|
type BanPublisher403JSONResponse ErrorResponse
|
|
|
|
func (response BanPublisher403JSONResponse) VisitBanPublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(403)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type BanPublisher404JSONResponse ErrorResponse
|
|
|
|
func (response BanPublisher404JSONResponse) VisitBanPublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(404)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type BanPublisher500JSONResponse ErrorResponse
|
|
|
|
func (response BanPublisher500JSONResponse) VisitBanPublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListNodesForPublisherRequestObject struct {
|
|
PublisherId string `json:"publisherId"`
|
|
Params ListNodesForPublisherParams
|
|
}
|
|
|
|
type ListNodesForPublisherResponseObject interface {
|
|
VisitListNodesForPublisherResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type ListNodesForPublisher200JSONResponse []Node
|
|
|
|
func (response ListNodesForPublisher200JSONResponse) VisitListNodesForPublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListNodesForPublisher400JSONResponse ErrorResponse
|
|
|
|
func (response ListNodesForPublisher400JSONResponse) VisitListNodesForPublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(400)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListNodesForPublisher500JSONResponse ErrorResponse
|
|
|
|
func (response ListNodesForPublisher500JSONResponse) VisitListNodesForPublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type CreateNodeRequestObject struct {
|
|
PublisherId string `json:"publisherId"`
|
|
Body *CreateNodeJSONRequestBody
|
|
}
|
|
|
|
type CreateNodeResponseObject interface {
|
|
VisitCreateNodeResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type CreateNode201JSONResponse Node
|
|
|
|
func (response CreateNode201JSONResponse) VisitCreateNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(201)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type CreateNode400JSONResponse ErrorResponse
|
|
|
|
func (response CreateNode400JSONResponse) VisitCreateNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(400)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type CreateNode401Response struct {
|
|
}
|
|
|
|
func (response CreateNode401Response) VisitCreateNodeResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(401)
|
|
return nil
|
|
}
|
|
|
|
type CreateNode500JSONResponse ErrorResponse
|
|
|
|
func (response CreateNode500JSONResponse) VisitCreateNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type DeleteNodeRequestObject struct {
|
|
PublisherId string `json:"publisherId"`
|
|
NodeId string `json:"nodeId"`
|
|
}
|
|
|
|
type DeleteNodeResponseObject interface {
|
|
VisitDeleteNodeResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type DeleteNode204Response struct {
|
|
}
|
|
|
|
func (response DeleteNode204Response) VisitDeleteNodeResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(204)
|
|
return nil
|
|
}
|
|
|
|
type DeleteNode403JSONResponse ErrorResponse
|
|
|
|
func (response DeleteNode403JSONResponse) VisitDeleteNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(403)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type DeleteNode404JSONResponse ErrorResponse
|
|
|
|
func (response DeleteNode404JSONResponse) VisitDeleteNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(404)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type DeleteNode500JSONResponse ErrorResponse
|
|
|
|
func (response DeleteNode500JSONResponse) VisitDeleteNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type UpdateNodeRequestObject struct {
|
|
PublisherId string `json:"publisherId"`
|
|
NodeId string `json:"nodeId"`
|
|
Body *UpdateNodeJSONRequestBody
|
|
}
|
|
|
|
type UpdateNodeResponseObject interface {
|
|
VisitUpdateNodeResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type UpdateNode200JSONResponse Node
|
|
|
|
func (response UpdateNode200JSONResponse) VisitUpdateNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type UpdateNode400JSONResponse ErrorResponse
|
|
|
|
func (response UpdateNode400JSONResponse) VisitUpdateNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(400)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type UpdateNode401Response struct {
|
|
}
|
|
|
|
func (response UpdateNode401Response) VisitUpdateNodeResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(401)
|
|
return nil
|
|
}
|
|
|
|
type UpdateNode403JSONResponse ErrorResponse
|
|
|
|
func (response UpdateNode403JSONResponse) VisitUpdateNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(403)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type UpdateNode404JSONResponse ErrorResponse
|
|
|
|
func (response UpdateNode404JSONResponse) VisitUpdateNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(404)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type UpdateNode500JSONResponse ErrorResponse
|
|
|
|
func (response UpdateNode500JSONResponse) VisitUpdateNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type BanPublisherNodeRequestObject struct {
|
|
PublisherId string `json:"publisherId"`
|
|
NodeId string `json:"nodeId"`
|
|
}
|
|
|
|
type BanPublisherNodeResponseObject interface {
|
|
VisitBanPublisherNodeResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type BanPublisherNode204Response struct {
|
|
}
|
|
|
|
func (response BanPublisherNode204Response) VisitBanPublisherNodeResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(204)
|
|
return nil
|
|
}
|
|
|
|
type BanPublisherNode401Response struct {
|
|
}
|
|
|
|
func (response BanPublisherNode401Response) VisitBanPublisherNodeResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(401)
|
|
return nil
|
|
}
|
|
|
|
type BanPublisherNode403JSONResponse ErrorResponse
|
|
|
|
func (response BanPublisherNode403JSONResponse) VisitBanPublisherNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(403)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type BanPublisherNode404JSONResponse ErrorResponse
|
|
|
|
func (response BanPublisherNode404JSONResponse) VisitBanPublisherNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(404)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type BanPublisherNode500JSONResponse ErrorResponse
|
|
|
|
func (response BanPublisherNode500JSONResponse) VisitBanPublisherNodeResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetPermissionOnPublisherNodesRequestObject struct {
|
|
PublisherId string `json:"publisherId"`
|
|
NodeId string `json:"nodeId"`
|
|
}
|
|
|
|
type GetPermissionOnPublisherNodesResponseObject interface {
|
|
VisitGetPermissionOnPublisherNodesResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type GetPermissionOnPublisherNodes200JSONResponse struct {
|
|
CanEdit *bool `json:"canEdit,omitempty"`
|
|
}
|
|
|
|
func (response GetPermissionOnPublisherNodes200JSONResponse) VisitGetPermissionOnPublisherNodesResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetPermissionOnPublisherNodes400JSONResponse ErrorResponse
|
|
|
|
func (response GetPermissionOnPublisherNodes400JSONResponse) VisitGetPermissionOnPublisherNodesResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(400)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetPermissionOnPublisherNodes500JSONResponse ErrorResponse
|
|
|
|
func (response GetPermissionOnPublisherNodes500JSONResponse) VisitGetPermissionOnPublisherNodesResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type PublishNodeVersionRequestObject struct {
|
|
PublisherId string `json:"publisherId"`
|
|
NodeId string `json:"nodeId"`
|
|
Body *PublishNodeVersionJSONRequestBody
|
|
}
|
|
|
|
type PublishNodeVersionResponseObject interface {
|
|
VisitPublishNodeVersionResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type PublishNodeVersion201JSONResponse struct {
|
|
NodeVersion *NodeVersion `json:"node_version,omitempty"`
|
|
|
|
// SignedUrl The signed URL to upload the node version token.
|
|
SignedUrl *string `json:"signedUrl,omitempty"`
|
|
}
|
|
|
|
func (response PublishNodeVersion201JSONResponse) VisitPublishNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(201)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type PublishNodeVersion400JSONResponse ErrorResponse
|
|
|
|
func (response PublishNodeVersion400JSONResponse) VisitPublishNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(400)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type PublishNodeVersion403JSONResponse ErrorResponse
|
|
|
|
func (response PublishNodeVersion403JSONResponse) VisitPublishNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(403)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type PublishNodeVersion500JSONResponse ErrorResponse
|
|
|
|
func (response PublishNodeVersion500JSONResponse) VisitPublishNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type DeleteNodeVersionRequestObject struct {
|
|
PublisherId string `json:"publisherId"`
|
|
NodeId string `json:"nodeId"`
|
|
VersionId string `json:"versionId"`
|
|
}
|
|
|
|
type DeleteNodeVersionResponseObject interface {
|
|
VisitDeleteNodeVersionResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type DeleteNodeVersion204Response struct {
|
|
}
|
|
|
|
func (response DeleteNodeVersion204Response) VisitDeleteNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(204)
|
|
return nil
|
|
}
|
|
|
|
type DeleteNodeVersion403JSONResponse ErrorResponse
|
|
|
|
func (response DeleteNodeVersion403JSONResponse) VisitDeleteNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(403)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type DeleteNodeVersion404JSONResponse Error
|
|
|
|
func (response DeleteNodeVersion404JSONResponse) VisitDeleteNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(404)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type DeleteNodeVersion500JSONResponse ErrorResponse
|
|
|
|
func (response DeleteNodeVersion500JSONResponse) VisitDeleteNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type UpdateNodeVersionRequestObject struct {
|
|
PublisherId string `json:"publisherId"`
|
|
NodeId string `json:"nodeId"`
|
|
VersionId string `json:"versionId"`
|
|
Body *UpdateNodeVersionJSONRequestBody
|
|
}
|
|
|
|
type UpdateNodeVersionResponseObject interface {
|
|
VisitUpdateNodeVersionResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type UpdateNodeVersion200JSONResponse NodeVersion
|
|
|
|
func (response UpdateNodeVersion200JSONResponse) VisitUpdateNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type UpdateNodeVersion400JSONResponse ErrorResponse
|
|
|
|
func (response UpdateNodeVersion400JSONResponse) VisitUpdateNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(400)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type UpdateNodeVersion401Response struct {
|
|
}
|
|
|
|
func (response UpdateNodeVersion401Response) VisitUpdateNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(401)
|
|
return nil
|
|
}
|
|
|
|
type UpdateNodeVersion403JSONResponse ErrorResponse
|
|
|
|
func (response UpdateNodeVersion403JSONResponse) VisitUpdateNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(403)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type UpdateNodeVersion404JSONResponse ErrorResponse
|
|
|
|
func (response UpdateNodeVersion404JSONResponse) VisitUpdateNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(404)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type UpdateNodeVersion500JSONResponse ErrorResponse
|
|
|
|
func (response UpdateNodeVersion500JSONResponse) VisitUpdateNodeVersionResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetPermissionOnPublisherRequestObject struct {
|
|
PublisherId string `json:"publisherId"`
|
|
}
|
|
|
|
type GetPermissionOnPublisherResponseObject interface {
|
|
VisitGetPermissionOnPublisherResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type GetPermissionOnPublisher200JSONResponse struct {
|
|
CanEdit *bool `json:"canEdit,omitempty"`
|
|
}
|
|
|
|
func (response GetPermissionOnPublisher200JSONResponse) VisitGetPermissionOnPublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetPermissionOnPublisher400JSONResponse ErrorResponse
|
|
|
|
func (response GetPermissionOnPublisher400JSONResponse) VisitGetPermissionOnPublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(400)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetPermissionOnPublisher500JSONResponse ErrorResponse
|
|
|
|
func (response GetPermissionOnPublisher500JSONResponse) VisitGetPermissionOnPublisherResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListPersonalAccessTokensRequestObject struct {
|
|
PublisherId string `json:"publisherId"`
|
|
}
|
|
|
|
type ListPersonalAccessTokensResponseObject interface {
|
|
VisitListPersonalAccessTokensResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type ListPersonalAccessTokens200JSONResponse []PersonalAccessToken
|
|
|
|
func (response ListPersonalAccessTokens200JSONResponse) VisitListPersonalAccessTokensResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListPersonalAccessTokens403JSONResponse ErrorResponse
|
|
|
|
func (response ListPersonalAccessTokens403JSONResponse) VisitListPersonalAccessTokensResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(403)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListPersonalAccessTokens404JSONResponse ErrorResponse
|
|
|
|
func (response ListPersonalAccessTokens404JSONResponse) VisitListPersonalAccessTokensResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(404)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListPersonalAccessTokens500JSONResponse ErrorResponse
|
|
|
|
func (response ListPersonalAccessTokens500JSONResponse) VisitListPersonalAccessTokensResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type CreatePersonalAccessTokenRequestObject struct {
|
|
PublisherId string `json:"publisherId"`
|
|
Body *CreatePersonalAccessTokenJSONRequestBody
|
|
}
|
|
|
|
type CreatePersonalAccessTokenResponseObject interface {
|
|
VisitCreatePersonalAccessTokenResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type CreatePersonalAccessToken201JSONResponse struct {
|
|
// Token The newly created personal access token.
|
|
Token *string `json:"token,omitempty"`
|
|
}
|
|
|
|
func (response CreatePersonalAccessToken201JSONResponse) VisitCreatePersonalAccessTokenResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(201)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type CreatePersonalAccessToken400JSONResponse ErrorResponse
|
|
|
|
func (response CreatePersonalAccessToken400JSONResponse) VisitCreatePersonalAccessTokenResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(400)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type CreatePersonalAccessToken403JSONResponse ErrorResponse
|
|
|
|
func (response CreatePersonalAccessToken403JSONResponse) VisitCreatePersonalAccessTokenResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(403)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type CreatePersonalAccessToken500JSONResponse ErrorResponse
|
|
|
|
func (response CreatePersonalAccessToken500JSONResponse) VisitCreatePersonalAccessTokenResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type DeletePersonalAccessTokenRequestObject struct {
|
|
PublisherId string `json:"publisherId"`
|
|
TokenId string `json:"tokenId"`
|
|
}
|
|
|
|
type DeletePersonalAccessTokenResponseObject interface {
|
|
VisitDeletePersonalAccessTokenResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type DeletePersonalAccessToken204Response struct {
|
|
}
|
|
|
|
func (response DeletePersonalAccessToken204Response) VisitDeletePersonalAccessTokenResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(204)
|
|
return nil
|
|
}
|
|
|
|
type DeletePersonalAccessToken403JSONResponse ErrorResponse
|
|
|
|
func (response DeletePersonalAccessToken403JSONResponse) VisitDeletePersonalAccessTokenResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(403)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type DeletePersonalAccessToken404JSONResponse ErrorResponse
|
|
|
|
func (response DeletePersonalAccessToken404JSONResponse) VisitDeletePersonalAccessTokenResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(404)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type DeletePersonalAccessToken500JSONResponse ErrorResponse
|
|
|
|
func (response DeletePersonalAccessToken500JSONResponse) VisitDeletePersonalAccessTokenResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type SecurityScanRequestObject struct {
|
|
Params SecurityScanParams
|
|
}
|
|
|
|
type SecurityScanResponseObject interface {
|
|
VisitSecurityScanResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type SecurityScan200Response struct {
|
|
}
|
|
|
|
func (response SecurityScan200Response) VisitSecurityScanResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(200)
|
|
return nil
|
|
}
|
|
|
|
type SecurityScan400JSONResponse ErrorResponse
|
|
|
|
func (response SecurityScan400JSONResponse) VisitSecurityScanResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(400)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type SecurityScan401Response struct {
|
|
}
|
|
|
|
func (response SecurityScan401Response) VisitSecurityScanResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(401)
|
|
return nil
|
|
}
|
|
|
|
type SecurityScan403JSONResponse ErrorResponse
|
|
|
|
func (response SecurityScan403JSONResponse) VisitSecurityScanResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(403)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type SecurityScan500JSONResponse ErrorResponse
|
|
|
|
func (response SecurityScan500JSONResponse) VisitSecurityScanResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type PostUploadArtifactRequestObject struct {
|
|
Body *PostUploadArtifactJSONRequestBody
|
|
}
|
|
|
|
type PostUploadArtifactResponseObject interface {
|
|
VisitPostUploadArtifactResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type PostUploadArtifact200JSONResponse struct {
|
|
Message *string `json:"message,omitempty"`
|
|
}
|
|
|
|
func (response PostUploadArtifact200JSONResponse) VisitPostUploadArtifactResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type PostUploadArtifact400Response struct {
|
|
}
|
|
|
|
func (response PostUploadArtifact400Response) VisitPostUploadArtifactResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(400)
|
|
return nil
|
|
}
|
|
|
|
type PostUploadArtifact500Response struct {
|
|
}
|
|
|
|
func (response PostUploadArtifact500Response) VisitPostUploadArtifactResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(500)
|
|
return nil
|
|
}
|
|
|
|
type GetUserRequestObject struct {
|
|
}
|
|
|
|
type GetUserResponseObject interface {
|
|
VisitGetUserResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type GetUser200JSONResponse User
|
|
|
|
func (response GetUser200JSONResponse) VisitGetUserResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetUser401Response struct {
|
|
}
|
|
|
|
func (response GetUser401Response) VisitGetUserResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(401)
|
|
return nil
|
|
}
|
|
|
|
type GetUser404Response struct {
|
|
}
|
|
|
|
func (response GetUser404Response) VisitGetUserResponse(w http.ResponseWriter) error {
|
|
w.WriteHeader(404)
|
|
return nil
|
|
}
|
|
|
|
type ListPublishersForUserRequestObject struct {
|
|
}
|
|
|
|
type ListPublishersForUserResponseObject interface {
|
|
VisitListPublishersForUserResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type ListPublishersForUser200JSONResponse []Publisher
|
|
|
|
func (response ListPublishersForUser200JSONResponse) VisitListPublishersForUserResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListPublishersForUser400JSONResponse ErrorResponse
|
|
|
|
func (response ListPublishersForUser400JSONResponse) VisitListPublishersForUserResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(400)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListPublishersForUser500JSONResponse ErrorResponse
|
|
|
|
func (response ListPublishersForUser500JSONResponse) VisitListPublishersForUserResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListAllNodeVersionsRequestObject struct {
|
|
Params ListAllNodeVersionsParams
|
|
}
|
|
|
|
type ListAllNodeVersionsResponseObject interface {
|
|
VisitListAllNodeVersionsResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type ListAllNodeVersions200JSONResponse struct {
|
|
// Page Current page number
|
|
Page *int `json:"page,omitempty"`
|
|
|
|
// PageSize Maximum number of node versions per page. Maximum is 100.
|
|
PageSize *int `json:"pageSize,omitempty"`
|
|
|
|
// Total Total number of node versions available
|
|
Total *int `json:"total,omitempty"`
|
|
|
|
// TotalPages Total number of pages available
|
|
TotalPages *int `json:"totalPages,omitempty"`
|
|
Versions *[]NodeVersion `json:"versions,omitempty"`
|
|
}
|
|
|
|
func (response ListAllNodeVersions200JSONResponse) VisitListAllNodeVersionsResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListAllNodeVersions400JSONResponse ErrorResponse
|
|
|
|
func (response ListAllNodeVersions400JSONResponse) VisitListAllNodeVersionsResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(400)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListAllNodeVersions403JSONResponse ErrorResponse
|
|
|
|
func (response ListAllNodeVersions403JSONResponse) VisitListAllNodeVersionsResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(403)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type ListAllNodeVersions500JSONResponse ErrorResponse
|
|
|
|
func (response ListAllNodeVersions500JSONResponse) VisitListAllNodeVersionsResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetWorkflowResultRequestObject struct {
|
|
WorkflowResultId string `json:"workflowResultId"`
|
|
}
|
|
|
|
type GetWorkflowResultResponseObject interface {
|
|
VisitGetWorkflowResultResponse(w http.ResponseWriter) error
|
|
}
|
|
|
|
type GetWorkflowResult200JSONResponse ActionJobResult
|
|
|
|
func (response GetWorkflowResult200JSONResponse) VisitGetWorkflowResultResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetWorkflowResult404JSONResponse ErrorResponse
|
|
|
|
func (response GetWorkflowResult404JSONResponse) VisitGetWorkflowResultResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(404)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
type GetWorkflowResult500JSONResponse ErrorResponse
|
|
|
|
func (response GetWorkflowResult500JSONResponse) VisitGetWorkflowResultResponse(w http.ResponseWriter) error {
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(500)
|
|
|
|
return json.NewEncoder(w).Encode(response)
|
|
}
|
|
|
|
// StrictServerInterface represents all server handlers.
|
|
type StrictServerInterface interface {
|
|
// Admin Update Node Version Status
|
|
// (PUT /admin/nodes/{nodeId}/versions/{versionNumber})
|
|
AdminUpdateNodeVersion(ctx context.Context, request AdminUpdateNodeVersionRequestObject) (AdminUpdateNodeVersionResponseObject, error)
|
|
// Retrieve all distinct branches for a given repo
|
|
// (GET /branch)
|
|
GetBranch(ctx context.Context, request GetBranchRequestObject) (GetBranchResponseObject, error)
|
|
// trigger comfy nodes backfill
|
|
// (POST /comfy-nodes/backfill)
|
|
ComfyNodesBackfill(ctx context.Context, request ComfyNodesBackfillRequestObject) (ComfyNodesBackfillResponseObject, error)
|
|
// Retrieve CI data for a given commit
|
|
// (GET /gitcommit)
|
|
GetGitcommit(ctx context.Context, request GetGitcommitRequestObject) (GetGitcommitResponseObject, error)
|
|
// Retrieve a summary of git commits
|
|
// (GET /gitcommitsummary)
|
|
GetGitcommitsummary(ctx context.Context, request GetGitcommitsummaryRequestObject) (GetGitcommitsummaryResponseObject, error)
|
|
// Retrieves a list of nodes
|
|
// (GET /nodes)
|
|
ListAllNodes(ctx context.Context, request ListAllNodesRequestObject) (ListAllNodesResponseObject, error)
|
|
// Reindex all nodes for searching.
|
|
// (POST /nodes/reindex)
|
|
ReindexNodes(ctx context.Context, request ReindexNodesRequestObject) (ReindexNodesResponseObject, error)
|
|
// Retrieves a list of nodes
|
|
// (GET /nodes/search)
|
|
SearchNodes(ctx context.Context, request SearchNodesRequestObject) (SearchNodesResponseObject, error)
|
|
// Retrieve a specific node by ID
|
|
// (GET /nodes/{nodeId})
|
|
GetNode(ctx context.Context, request GetNodeRequestObject) (GetNodeResponseObject, error)
|
|
// Returns a node version to be installed.
|
|
// (GET /nodes/{nodeId}/install)
|
|
InstallNode(ctx context.Context, request InstallNodeRequestObject) (InstallNodeResponseObject, error)
|
|
// Add review to a specific version of a node
|
|
// (POST /nodes/{nodeId}/reviews)
|
|
PostNodeReview(ctx context.Context, request PostNodeReviewRequestObject) (PostNodeReviewResponseObject, error)
|
|
// List all versions of a node
|
|
// (GET /nodes/{nodeId}/versions)
|
|
ListNodeVersions(ctx context.Context, request ListNodeVersionsRequestObject) (ListNodeVersionsResponseObject, error)
|
|
// Retrieve a specific version of a node
|
|
// (GET /nodes/{nodeId}/versions/{versionId})
|
|
GetNodeVersion(ctx context.Context, request GetNodeVersionRequestObject) (GetNodeVersionResponseObject, error)
|
|
// create comfy-nodes for certain node
|
|
// (POST /nodes/{nodeId}/versions/{version}/comfy-nodes)
|
|
CreateComfyNodes(ctx context.Context, request CreateComfyNodesRequestObject) (CreateComfyNodesResponseObject, error)
|
|
// get specify comfy-node based on its id
|
|
// (GET /nodes/{nodeId}/versions/{version}/comfy-nodes/{comfyNodeId})
|
|
GetComfyNode(ctx context.Context, request GetComfyNodeRequestObject) (GetComfyNodeResponseObject, error)
|
|
// Retrieve all publishers
|
|
// (GET /publishers)
|
|
ListPublishers(ctx context.Context, request ListPublishersRequestObject) (ListPublishersResponseObject, error)
|
|
// Create a new publisher
|
|
// (POST /publishers)
|
|
CreatePublisher(ctx context.Context, request CreatePublisherRequestObject) (CreatePublisherResponseObject, error)
|
|
// Validate if a publisher username is available
|
|
// (GET /publishers/validate)
|
|
ValidatePublisher(ctx context.Context, request ValidatePublisherRequestObject) (ValidatePublisherResponseObject, error)
|
|
// Delete a publisher
|
|
// (DELETE /publishers/{publisherId})
|
|
DeletePublisher(ctx context.Context, request DeletePublisherRequestObject) (DeletePublisherResponseObject, error)
|
|
// Retrieve a publisher by ID
|
|
// (GET /publishers/{publisherId})
|
|
GetPublisher(ctx context.Context, request GetPublisherRequestObject) (GetPublisherResponseObject, error)
|
|
// Update a publisher
|
|
// (PUT /publishers/{publisherId})
|
|
UpdatePublisher(ctx context.Context, request UpdatePublisherRequestObject) (UpdatePublisherResponseObject, error)
|
|
// Ban a publisher
|
|
// (POST /publishers/{publisherId}/ban)
|
|
BanPublisher(ctx context.Context, request BanPublisherRequestObject) (BanPublisherResponseObject, error)
|
|
// Retrieve all nodes
|
|
// (GET /publishers/{publisherId}/nodes)
|
|
ListNodesForPublisher(ctx context.Context, request ListNodesForPublisherRequestObject) (ListNodesForPublisherResponseObject, error)
|
|
// Create a new custom node
|
|
// (POST /publishers/{publisherId}/nodes)
|
|
CreateNode(ctx context.Context, request CreateNodeRequestObject) (CreateNodeResponseObject, error)
|
|
// Delete a specific node
|
|
// (DELETE /publishers/{publisherId}/nodes/{nodeId})
|
|
DeleteNode(ctx context.Context, request DeleteNodeRequestObject) (DeleteNodeResponseObject, error)
|
|
// Update a specific node
|
|
// (PUT /publishers/{publisherId}/nodes/{nodeId})
|
|
UpdateNode(ctx context.Context, request UpdateNodeRequestObject) (UpdateNodeResponseObject, error)
|
|
// Ban a publisher's Node
|
|
// (POST /publishers/{publisherId}/nodes/{nodeId}/ban)
|
|
BanPublisherNode(ctx context.Context, request BanPublisherNodeRequestObject) (BanPublisherNodeResponseObject, error)
|
|
// Retrieve permissions the user has for a given publisher
|
|
// (GET /publishers/{publisherId}/nodes/{nodeId}/permissions)
|
|
GetPermissionOnPublisherNodes(ctx context.Context, request GetPermissionOnPublisherNodesRequestObject) (GetPermissionOnPublisherNodesResponseObject, error)
|
|
// Publish a new version of a node
|
|
// (POST /publishers/{publisherId}/nodes/{nodeId}/versions)
|
|
PublishNodeVersion(ctx context.Context, request PublishNodeVersionRequestObject) (PublishNodeVersionResponseObject, error)
|
|
// Unpublish (delete) a specific version of a node
|
|
// (DELETE /publishers/{publisherId}/nodes/{nodeId}/versions/{versionId})
|
|
DeleteNodeVersion(ctx context.Context, request DeleteNodeVersionRequestObject) (DeleteNodeVersionResponseObject, error)
|
|
// Update changelog and deprecation status of a node version
|
|
// (PUT /publishers/{publisherId}/nodes/{nodeId}/versions/{versionId})
|
|
UpdateNodeVersion(ctx context.Context, request UpdateNodeVersionRequestObject) (UpdateNodeVersionResponseObject, error)
|
|
// Retrieve permissions the user has for a given publisher
|
|
// (GET /publishers/{publisherId}/permissions)
|
|
GetPermissionOnPublisher(ctx context.Context, request GetPermissionOnPublisherRequestObject) (GetPermissionOnPublisherResponseObject, error)
|
|
// Retrieve all personal access tokens for a publisher
|
|
// (GET /publishers/{publisherId}/tokens)
|
|
ListPersonalAccessTokens(ctx context.Context, request ListPersonalAccessTokensRequestObject) (ListPersonalAccessTokensResponseObject, error)
|
|
// Create a new personal access token
|
|
// (POST /publishers/{publisherId}/tokens)
|
|
CreatePersonalAccessToken(ctx context.Context, request CreatePersonalAccessTokenRequestObject) (CreatePersonalAccessTokenResponseObject, error)
|
|
// Delete a specific personal access token
|
|
// (DELETE /publishers/{publisherId}/tokens/{tokenId})
|
|
DeletePersonalAccessToken(ctx context.Context, request DeletePersonalAccessTokenRequestObject) (DeletePersonalAccessTokenResponseObject, error)
|
|
// Security Scan
|
|
// (GET /security-scan)
|
|
SecurityScan(ctx context.Context, request SecurityScanRequestObject) (SecurityScanResponseObject, error)
|
|
// Receive artifacts (output files) from the Hanzo Studio GitHub Action
|
|
// (POST /upload-artifact)
|
|
PostUploadArtifact(ctx context.Context, request PostUploadArtifactRequestObject) (PostUploadArtifactResponseObject, error)
|
|
// Get information about the calling user.
|
|
// (GET /users)
|
|
GetUser(ctx context.Context, request GetUserRequestObject) (GetUserResponseObject, error)
|
|
// Retrieve all publishers for a given user
|
|
// (GET /users/publishers/)
|
|
ListPublishersForUser(ctx context.Context, request ListPublishersForUserRequestObject) (ListPublishersForUserResponseObject, error)
|
|
// List all node versions given some filters.
|
|
// (GET /versions)
|
|
ListAllNodeVersions(ctx context.Context, request ListAllNodeVersionsRequestObject) (ListAllNodeVersionsResponseObject, error)
|
|
// Retrieve a specific commit by ID
|
|
// (GET /workflowresult/{workflowResultId})
|
|
GetWorkflowResult(ctx context.Context, request GetWorkflowResultRequestObject) (GetWorkflowResultResponseObject, error)
|
|
}
|
|
|
|
type StrictHandlerFunc = strictecho.StrictEchoHandlerFunc
|
|
type StrictMiddlewareFunc = strictecho.StrictEchoMiddlewareFunc
|
|
|
|
func NewStrictHandler(ssi StrictServerInterface, middlewares []StrictMiddlewareFunc) ServerInterface {
|
|
return &strictHandler{ssi: ssi, middlewares: middlewares}
|
|
}
|
|
|
|
type strictHandler struct {
|
|
ssi StrictServerInterface
|
|
middlewares []StrictMiddlewareFunc
|
|
}
|
|
|
|
// AdminUpdateNodeVersion operation middleware
|
|
func (sh *strictHandler) AdminUpdateNodeVersion(ctx echo.Context, nodeId string, versionNumber string) error {
|
|
var request AdminUpdateNodeVersionRequestObject
|
|
|
|
request.NodeId = nodeId
|
|
request.VersionNumber = versionNumber
|
|
|
|
var body AdminUpdateNodeVersionJSONRequestBody
|
|
if err := ctx.Bind(&body); err != nil {
|
|
return err
|
|
}
|
|
request.Body = &body
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.AdminUpdateNodeVersion(ctx.Request().Context(), request.(AdminUpdateNodeVersionRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "AdminUpdateNodeVersion")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(AdminUpdateNodeVersionResponseObject); ok {
|
|
return validResponse.VisitAdminUpdateNodeVersionResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// GetBranch operation middleware
|
|
func (sh *strictHandler) GetBranch(ctx echo.Context, params GetBranchParams) error {
|
|
var request GetBranchRequestObject
|
|
|
|
request.Params = params
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.GetBranch(ctx.Request().Context(), request.(GetBranchRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "GetBranch")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(GetBranchResponseObject); ok {
|
|
return validResponse.VisitGetBranchResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// ComfyNodesBackfill operation middleware
|
|
func (sh *strictHandler) ComfyNodesBackfill(ctx echo.Context, params ComfyNodesBackfillParams) error {
|
|
var request ComfyNodesBackfillRequestObject
|
|
|
|
request.Params = params
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.ComfyNodesBackfill(ctx.Request().Context(), request.(ComfyNodesBackfillRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "ComfyNodesBackfill")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(ComfyNodesBackfillResponseObject); ok {
|
|
return validResponse.VisitComfyNodesBackfillResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// GetGitcommit operation middleware
|
|
func (sh *strictHandler) GetGitcommit(ctx echo.Context, params GetGitcommitParams) error {
|
|
var request GetGitcommitRequestObject
|
|
|
|
request.Params = params
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.GetGitcommit(ctx.Request().Context(), request.(GetGitcommitRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "GetGitcommit")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(GetGitcommitResponseObject); ok {
|
|
return validResponse.VisitGetGitcommitResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// GetGitcommitsummary operation middleware
|
|
func (sh *strictHandler) GetGitcommitsummary(ctx echo.Context, params GetGitcommitsummaryParams) error {
|
|
var request GetGitcommitsummaryRequestObject
|
|
|
|
request.Params = params
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.GetGitcommitsummary(ctx.Request().Context(), request.(GetGitcommitsummaryRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "GetGitcommitsummary")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(GetGitcommitsummaryResponseObject); ok {
|
|
return validResponse.VisitGetGitcommitsummaryResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// ListAllNodes operation middleware
|
|
func (sh *strictHandler) ListAllNodes(ctx echo.Context, params ListAllNodesParams) error {
|
|
var request ListAllNodesRequestObject
|
|
|
|
request.Params = params
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.ListAllNodes(ctx.Request().Context(), request.(ListAllNodesRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "ListAllNodes")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(ListAllNodesResponseObject); ok {
|
|
return validResponse.VisitListAllNodesResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// ReindexNodes operation middleware
|
|
func (sh *strictHandler) ReindexNodes(ctx echo.Context, params ReindexNodesParams) error {
|
|
var request ReindexNodesRequestObject
|
|
|
|
request.Params = params
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.ReindexNodes(ctx.Request().Context(), request.(ReindexNodesRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "ReindexNodes")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(ReindexNodesResponseObject); ok {
|
|
return validResponse.VisitReindexNodesResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// SearchNodes operation middleware
|
|
func (sh *strictHandler) SearchNodes(ctx echo.Context, params SearchNodesParams) error {
|
|
var request SearchNodesRequestObject
|
|
|
|
request.Params = params
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.SearchNodes(ctx.Request().Context(), request.(SearchNodesRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "SearchNodes")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(SearchNodesResponseObject); ok {
|
|
return validResponse.VisitSearchNodesResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// GetNode operation middleware
|
|
func (sh *strictHandler) GetNode(ctx echo.Context, nodeId string) error {
|
|
var request GetNodeRequestObject
|
|
|
|
request.NodeId = nodeId
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.GetNode(ctx.Request().Context(), request.(GetNodeRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "GetNode")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(GetNodeResponseObject); ok {
|
|
return validResponse.VisitGetNodeResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// InstallNode operation middleware
|
|
func (sh *strictHandler) InstallNode(ctx echo.Context, nodeId string, params InstallNodeParams) error {
|
|
var request InstallNodeRequestObject
|
|
|
|
request.NodeId = nodeId
|
|
request.Params = params
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.InstallNode(ctx.Request().Context(), request.(InstallNodeRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "InstallNode")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(InstallNodeResponseObject); ok {
|
|
return validResponse.VisitInstallNodeResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// PostNodeReview operation middleware
|
|
func (sh *strictHandler) PostNodeReview(ctx echo.Context, nodeId string, params PostNodeReviewParams) error {
|
|
var request PostNodeReviewRequestObject
|
|
|
|
request.NodeId = nodeId
|
|
request.Params = params
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.PostNodeReview(ctx.Request().Context(), request.(PostNodeReviewRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "PostNodeReview")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(PostNodeReviewResponseObject); ok {
|
|
return validResponse.VisitPostNodeReviewResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// ListNodeVersions operation middleware
|
|
func (sh *strictHandler) ListNodeVersions(ctx echo.Context, nodeId string, params ListNodeVersionsParams) error {
|
|
var request ListNodeVersionsRequestObject
|
|
|
|
request.NodeId = nodeId
|
|
request.Params = params
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.ListNodeVersions(ctx.Request().Context(), request.(ListNodeVersionsRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "ListNodeVersions")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(ListNodeVersionsResponseObject); ok {
|
|
return validResponse.VisitListNodeVersionsResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// GetNodeVersion operation middleware
|
|
func (sh *strictHandler) GetNodeVersion(ctx echo.Context, nodeId string, versionId string) error {
|
|
var request GetNodeVersionRequestObject
|
|
|
|
request.NodeId = nodeId
|
|
request.VersionId = versionId
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.GetNodeVersion(ctx.Request().Context(), request.(GetNodeVersionRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "GetNodeVersion")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(GetNodeVersionResponseObject); ok {
|
|
return validResponse.VisitGetNodeVersionResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// CreateComfyNodes operation middleware
|
|
func (sh *strictHandler) CreateComfyNodes(ctx echo.Context, nodeId string, version string) error {
|
|
var request CreateComfyNodesRequestObject
|
|
|
|
request.NodeId = nodeId
|
|
request.Version = version
|
|
|
|
var body CreateComfyNodesJSONRequestBody
|
|
if err := ctx.Bind(&body); err != nil {
|
|
return err
|
|
}
|
|
request.Body = &body
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.CreateComfyNodes(ctx.Request().Context(), request.(CreateComfyNodesRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "CreateComfyNodes")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(CreateComfyNodesResponseObject); ok {
|
|
return validResponse.VisitCreateComfyNodesResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// GetComfyNode operation middleware
|
|
func (sh *strictHandler) GetComfyNode(ctx echo.Context, nodeId string, version string, comfyNodeId string) error {
|
|
var request GetComfyNodeRequestObject
|
|
|
|
request.NodeId = nodeId
|
|
request.Version = version
|
|
request.ComfyNodeId = comfyNodeId
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.GetComfyNode(ctx.Request().Context(), request.(GetComfyNodeRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "GetComfyNode")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(GetComfyNodeResponseObject); ok {
|
|
return validResponse.VisitGetComfyNodeResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// ListPublishers operation middleware
|
|
func (sh *strictHandler) ListPublishers(ctx echo.Context) error {
|
|
var request ListPublishersRequestObject
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.ListPublishers(ctx.Request().Context(), request.(ListPublishersRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "ListPublishers")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(ListPublishersResponseObject); ok {
|
|
return validResponse.VisitListPublishersResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// CreatePublisher operation middleware
|
|
func (sh *strictHandler) CreatePublisher(ctx echo.Context) error {
|
|
var request CreatePublisherRequestObject
|
|
|
|
var body CreatePublisherJSONRequestBody
|
|
if err := ctx.Bind(&body); err != nil {
|
|
return err
|
|
}
|
|
request.Body = &body
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.CreatePublisher(ctx.Request().Context(), request.(CreatePublisherRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "CreatePublisher")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(CreatePublisherResponseObject); ok {
|
|
return validResponse.VisitCreatePublisherResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// ValidatePublisher operation middleware
|
|
func (sh *strictHandler) ValidatePublisher(ctx echo.Context, params ValidatePublisherParams) error {
|
|
var request ValidatePublisherRequestObject
|
|
|
|
request.Params = params
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.ValidatePublisher(ctx.Request().Context(), request.(ValidatePublisherRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "ValidatePublisher")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(ValidatePublisherResponseObject); ok {
|
|
return validResponse.VisitValidatePublisherResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// DeletePublisher operation middleware
|
|
func (sh *strictHandler) DeletePublisher(ctx echo.Context, publisherId string) error {
|
|
var request DeletePublisherRequestObject
|
|
|
|
request.PublisherId = publisherId
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.DeletePublisher(ctx.Request().Context(), request.(DeletePublisherRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "DeletePublisher")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(DeletePublisherResponseObject); ok {
|
|
return validResponse.VisitDeletePublisherResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// GetPublisher operation middleware
|
|
func (sh *strictHandler) GetPublisher(ctx echo.Context, publisherId string) error {
|
|
var request GetPublisherRequestObject
|
|
|
|
request.PublisherId = publisherId
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.GetPublisher(ctx.Request().Context(), request.(GetPublisherRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "GetPublisher")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(GetPublisherResponseObject); ok {
|
|
return validResponse.VisitGetPublisherResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// UpdatePublisher operation middleware
|
|
func (sh *strictHandler) UpdatePublisher(ctx echo.Context, publisherId string) error {
|
|
var request UpdatePublisherRequestObject
|
|
|
|
request.PublisherId = publisherId
|
|
|
|
var body UpdatePublisherJSONRequestBody
|
|
if err := ctx.Bind(&body); err != nil {
|
|
return err
|
|
}
|
|
request.Body = &body
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.UpdatePublisher(ctx.Request().Context(), request.(UpdatePublisherRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "UpdatePublisher")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(UpdatePublisherResponseObject); ok {
|
|
return validResponse.VisitUpdatePublisherResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// BanPublisher operation middleware
|
|
func (sh *strictHandler) BanPublisher(ctx echo.Context, publisherId string) error {
|
|
var request BanPublisherRequestObject
|
|
|
|
request.PublisherId = publisherId
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.BanPublisher(ctx.Request().Context(), request.(BanPublisherRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "BanPublisher")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(BanPublisherResponseObject); ok {
|
|
return validResponse.VisitBanPublisherResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// ListNodesForPublisher operation middleware
|
|
func (sh *strictHandler) ListNodesForPublisher(ctx echo.Context, publisherId string, params ListNodesForPublisherParams) error {
|
|
var request ListNodesForPublisherRequestObject
|
|
|
|
request.PublisherId = publisherId
|
|
request.Params = params
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.ListNodesForPublisher(ctx.Request().Context(), request.(ListNodesForPublisherRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "ListNodesForPublisher")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(ListNodesForPublisherResponseObject); ok {
|
|
return validResponse.VisitListNodesForPublisherResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// CreateNode operation middleware
|
|
func (sh *strictHandler) CreateNode(ctx echo.Context, publisherId string) error {
|
|
var request CreateNodeRequestObject
|
|
|
|
request.PublisherId = publisherId
|
|
|
|
var body CreateNodeJSONRequestBody
|
|
if err := ctx.Bind(&body); err != nil {
|
|
return err
|
|
}
|
|
request.Body = &body
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.CreateNode(ctx.Request().Context(), request.(CreateNodeRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "CreateNode")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(CreateNodeResponseObject); ok {
|
|
return validResponse.VisitCreateNodeResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// DeleteNode operation middleware
|
|
func (sh *strictHandler) DeleteNode(ctx echo.Context, publisherId string, nodeId string) error {
|
|
var request DeleteNodeRequestObject
|
|
|
|
request.PublisherId = publisherId
|
|
request.NodeId = nodeId
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.DeleteNode(ctx.Request().Context(), request.(DeleteNodeRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "DeleteNode")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(DeleteNodeResponseObject); ok {
|
|
return validResponse.VisitDeleteNodeResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// UpdateNode operation middleware
|
|
func (sh *strictHandler) UpdateNode(ctx echo.Context, publisherId string, nodeId string) error {
|
|
var request UpdateNodeRequestObject
|
|
|
|
request.PublisherId = publisherId
|
|
request.NodeId = nodeId
|
|
|
|
var body UpdateNodeJSONRequestBody
|
|
if err := ctx.Bind(&body); err != nil {
|
|
return err
|
|
}
|
|
request.Body = &body
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.UpdateNode(ctx.Request().Context(), request.(UpdateNodeRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "UpdateNode")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(UpdateNodeResponseObject); ok {
|
|
return validResponse.VisitUpdateNodeResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// BanPublisherNode operation middleware
|
|
func (sh *strictHandler) BanPublisherNode(ctx echo.Context, publisherId string, nodeId string) error {
|
|
var request BanPublisherNodeRequestObject
|
|
|
|
request.PublisherId = publisherId
|
|
request.NodeId = nodeId
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.BanPublisherNode(ctx.Request().Context(), request.(BanPublisherNodeRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "BanPublisherNode")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(BanPublisherNodeResponseObject); ok {
|
|
return validResponse.VisitBanPublisherNodeResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// GetPermissionOnPublisherNodes operation middleware
|
|
func (sh *strictHandler) GetPermissionOnPublisherNodes(ctx echo.Context, publisherId string, nodeId string) error {
|
|
var request GetPermissionOnPublisherNodesRequestObject
|
|
|
|
request.PublisherId = publisherId
|
|
request.NodeId = nodeId
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.GetPermissionOnPublisherNodes(ctx.Request().Context(), request.(GetPermissionOnPublisherNodesRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "GetPermissionOnPublisherNodes")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(GetPermissionOnPublisherNodesResponseObject); ok {
|
|
return validResponse.VisitGetPermissionOnPublisherNodesResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// PublishNodeVersion operation middleware
|
|
func (sh *strictHandler) PublishNodeVersion(ctx echo.Context, publisherId string, nodeId string) error {
|
|
var request PublishNodeVersionRequestObject
|
|
|
|
request.PublisherId = publisherId
|
|
request.NodeId = nodeId
|
|
|
|
var body PublishNodeVersionJSONRequestBody
|
|
if err := ctx.Bind(&body); err != nil {
|
|
return err
|
|
}
|
|
request.Body = &body
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.PublishNodeVersion(ctx.Request().Context(), request.(PublishNodeVersionRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "PublishNodeVersion")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(PublishNodeVersionResponseObject); ok {
|
|
return validResponse.VisitPublishNodeVersionResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// DeleteNodeVersion operation middleware
|
|
func (sh *strictHandler) DeleteNodeVersion(ctx echo.Context, publisherId string, nodeId string, versionId string) error {
|
|
var request DeleteNodeVersionRequestObject
|
|
|
|
request.PublisherId = publisherId
|
|
request.NodeId = nodeId
|
|
request.VersionId = versionId
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.DeleteNodeVersion(ctx.Request().Context(), request.(DeleteNodeVersionRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "DeleteNodeVersion")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(DeleteNodeVersionResponseObject); ok {
|
|
return validResponse.VisitDeleteNodeVersionResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// UpdateNodeVersion operation middleware
|
|
func (sh *strictHandler) UpdateNodeVersion(ctx echo.Context, publisherId string, nodeId string, versionId string) error {
|
|
var request UpdateNodeVersionRequestObject
|
|
|
|
request.PublisherId = publisherId
|
|
request.NodeId = nodeId
|
|
request.VersionId = versionId
|
|
|
|
var body UpdateNodeVersionJSONRequestBody
|
|
if err := ctx.Bind(&body); err != nil {
|
|
return err
|
|
}
|
|
request.Body = &body
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.UpdateNodeVersion(ctx.Request().Context(), request.(UpdateNodeVersionRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "UpdateNodeVersion")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(UpdateNodeVersionResponseObject); ok {
|
|
return validResponse.VisitUpdateNodeVersionResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// GetPermissionOnPublisher operation middleware
|
|
func (sh *strictHandler) GetPermissionOnPublisher(ctx echo.Context, publisherId string) error {
|
|
var request GetPermissionOnPublisherRequestObject
|
|
|
|
request.PublisherId = publisherId
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.GetPermissionOnPublisher(ctx.Request().Context(), request.(GetPermissionOnPublisherRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "GetPermissionOnPublisher")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(GetPermissionOnPublisherResponseObject); ok {
|
|
return validResponse.VisitGetPermissionOnPublisherResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// ListPersonalAccessTokens operation middleware
|
|
func (sh *strictHandler) ListPersonalAccessTokens(ctx echo.Context, publisherId string) error {
|
|
var request ListPersonalAccessTokensRequestObject
|
|
|
|
request.PublisherId = publisherId
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.ListPersonalAccessTokens(ctx.Request().Context(), request.(ListPersonalAccessTokensRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "ListPersonalAccessTokens")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(ListPersonalAccessTokensResponseObject); ok {
|
|
return validResponse.VisitListPersonalAccessTokensResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// CreatePersonalAccessToken operation middleware
|
|
func (sh *strictHandler) CreatePersonalAccessToken(ctx echo.Context, publisherId string) error {
|
|
var request CreatePersonalAccessTokenRequestObject
|
|
|
|
request.PublisherId = publisherId
|
|
|
|
var body CreatePersonalAccessTokenJSONRequestBody
|
|
if err := ctx.Bind(&body); err != nil {
|
|
return err
|
|
}
|
|
request.Body = &body
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.CreatePersonalAccessToken(ctx.Request().Context(), request.(CreatePersonalAccessTokenRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "CreatePersonalAccessToken")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(CreatePersonalAccessTokenResponseObject); ok {
|
|
return validResponse.VisitCreatePersonalAccessTokenResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// DeletePersonalAccessToken operation middleware
|
|
func (sh *strictHandler) DeletePersonalAccessToken(ctx echo.Context, publisherId string, tokenId string) error {
|
|
var request DeletePersonalAccessTokenRequestObject
|
|
|
|
request.PublisherId = publisherId
|
|
request.TokenId = tokenId
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.DeletePersonalAccessToken(ctx.Request().Context(), request.(DeletePersonalAccessTokenRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "DeletePersonalAccessToken")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(DeletePersonalAccessTokenResponseObject); ok {
|
|
return validResponse.VisitDeletePersonalAccessTokenResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// SecurityScan operation middleware
|
|
func (sh *strictHandler) SecurityScan(ctx echo.Context, params SecurityScanParams) error {
|
|
var request SecurityScanRequestObject
|
|
|
|
request.Params = params
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.SecurityScan(ctx.Request().Context(), request.(SecurityScanRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "SecurityScan")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(SecurityScanResponseObject); ok {
|
|
return validResponse.VisitSecurityScanResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// PostUploadArtifact operation middleware
|
|
func (sh *strictHandler) PostUploadArtifact(ctx echo.Context) error {
|
|
var request PostUploadArtifactRequestObject
|
|
|
|
var body PostUploadArtifactJSONRequestBody
|
|
if err := ctx.Bind(&body); err != nil {
|
|
return err
|
|
}
|
|
request.Body = &body
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.PostUploadArtifact(ctx.Request().Context(), request.(PostUploadArtifactRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "PostUploadArtifact")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(PostUploadArtifactResponseObject); ok {
|
|
return validResponse.VisitPostUploadArtifactResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// GetUser operation middleware
|
|
func (sh *strictHandler) GetUser(ctx echo.Context) error {
|
|
var request GetUserRequestObject
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.GetUser(ctx.Request().Context(), request.(GetUserRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "GetUser")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(GetUserResponseObject); ok {
|
|
return validResponse.VisitGetUserResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// ListPublishersForUser operation middleware
|
|
func (sh *strictHandler) ListPublishersForUser(ctx echo.Context) error {
|
|
var request ListPublishersForUserRequestObject
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.ListPublishersForUser(ctx.Request().Context(), request.(ListPublishersForUserRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "ListPublishersForUser")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(ListPublishersForUserResponseObject); ok {
|
|
return validResponse.VisitListPublishersForUserResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// ListAllNodeVersions operation middleware
|
|
func (sh *strictHandler) ListAllNodeVersions(ctx echo.Context, params ListAllNodeVersionsParams) error {
|
|
var request ListAllNodeVersionsRequestObject
|
|
|
|
request.Params = params
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.ListAllNodeVersions(ctx.Request().Context(), request.(ListAllNodeVersionsRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "ListAllNodeVersions")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(ListAllNodeVersionsResponseObject); ok {
|
|
return validResponse.VisitListAllNodeVersionsResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// GetWorkflowResult operation middleware
|
|
func (sh *strictHandler) GetWorkflowResult(ctx echo.Context, workflowResultId string) error {
|
|
var request GetWorkflowResultRequestObject
|
|
|
|
request.WorkflowResultId = workflowResultId
|
|
|
|
handler := func(ctx echo.Context, request interface{}) (interface{}, error) {
|
|
return sh.ssi.GetWorkflowResult(ctx.Request().Context(), request.(GetWorkflowResultRequestObject))
|
|
}
|
|
for _, middleware := range sh.middlewares {
|
|
handler = middleware(handler, "GetWorkflowResult")
|
|
}
|
|
|
|
response, err := handler(ctx, request)
|
|
|
|
if err != nil {
|
|
return err
|
|
} else if validResponse, ok := response.(GetWorkflowResultResponseObject); ok {
|
|
return validResponse.VisitGetWorkflowResultResponse(ctx.Response())
|
|
} else if response != nil {
|
|
return fmt.Errorf("unexpected response type: %T", response)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Base64 encoded, gzipped, json marshaled Swagger object
|
|
var swaggerSpec = []string{
|
|
|
|
"H4sIAAAAAAAC/+x9fW/bONL4VyH0O2Bb/Bw73est7sl/btL2crdJg6TpYq/t46Ml2mYrkTqSSuot8t0f",
|
|
"8E2iJFKWnTena2CxbU1qOCRnhjPDGc73KKZZTgkigkcH3yMeL1AG1V/HscCU/JNOzxEvUiF/yhnNERMY",
|
|
"qQ5QdZh8odMJTuQPCeIxw7n8NTqIjhNEBJ5hxACdAbFA4AudArHAHDAFEUxRSsmcA0GjQSSWOYoOIi4Y",
|
|
"JvPoZmDBs4L0BM8Ksg74Qiwoa8N9v0BAt1m4Mc0yLLwwruaTKwazAJQrxOAcgQ/n4xNQcJSA6dKuQwUN",
|
|
"E4HmiElwUwZJvJgQmKE2xFOYoXKmKEVXkAgwxwLor3zoxTSbLdUCzlI4534sVSe1dqrTELwezofgP3t7",
|
|
"Kb3ek5P7TwB0hsVkAfnCD1a2rF5AA8a3vxLI8VFvEBniHM6RH45p7A1M4CwA6ZLgb0A2cwGzHFwvEHFA",
|
|
"gmvIQQYTFA2iGWUZFHqDf3np3e+4SODkCjGu4DeHO7w8GgPTqsjHhzAiSQe2iCQKWZcBIQewMY1hP3Tn",
|
|
"WEwYyql/LNnCsaBsCRQBe5D1bfMlwf8tEMAVN88oK5HVnOyiVxTYuxBSCgmG53PEJgVHAcaWLeB6QYHp",
|
|
"ihI71NAHNIPxAhM04QJq8fgXhmbRQfT/RpXUHBmROTrRnS9U35tBJEUlFJjMJ3zJBfIIiXe2B9A9gruc",
|
|
"I/i1Q9DI5v5SJmcTUmTT0BLlRZoChv5bIC6A6ehDaSkWlISp92z5nrJ4sZKA86WQ/W4PiAvIujhXtd8h",
|
|
"N0iaKFYSxW+UfZ2l9Pq8IBf6A/UplQfDZIZTtArAhe77Rna9GUTXBl6PQ8J2bS/WTfkLnX5BsZCAD+Ux",
|
|
"cEoT1D7nYyjQnLKlh3mPgW2UopAhNTChCQKYgxRzgZKBJkrJ1XNGi1ySu+zBh+EjS7ZP1pMW8hMfwATl",
|
|
"DEkkfSoESbBs4gDPaphXHw3BUfl3jTaADIEFThJEANbC//LYmcuU0hRBosd2RmsO/ophNAPOb3bf5Cg/",
|
|
"cTAriFKAYIrFElAG8oLllCPvsqFvOWI4Q0TAdI15up8NAC8UNQBBQbyAZI64HJahjF7B1D9Di2Q3JSIi",
|
|
"2HIvp5iIclpyFPQNxYWoiMY7NUzyQkzkzx4F5gjNMJHzkp1ADhnMkECM+wDRQkhImE8kYXo2RE8LXMG0",
|
|
"UCDVoklyxTOAYLwAGoJcOKiIW+KLBcoUYu3FMb9AxuBS/pshUTCiOJf7F4zbFdMjcUXdcQqZJAFMSpb2",
|
|
"846BH1iqixzFkmW4GkB1kqPZkXJGkyKuTo/AfnSKjsOUFsmrAqfJMZnRtiCZyibD1y3sUypXW5NS+5Rg",
|
|
"VI4W+tY2V+daD7RfM6b1/zqSCRIQp9x3Wmt2BLoHSgAm+pyQ5AyntBCa2iVcyTkLTMwWMsRpeqVIyUs0",
|
|
"1UyaNBNUa8cgThFkAJIExJTEmCOfMFHI9NxHtSDniOeUcM8xgOx6tdWkCsn2MFKVwEyK348GRPXBZw8W",
|
|
"b7E4VMr0RZFlUJ86DbvzDiy3TlNLAtIdnFOtreHfs1EUxo04sjUMRisoE14tI0wSrGn4rLagnkOzTmoZ",
|
|
"zJWsaOqrggI9CsghdqVutZ2lWuWfynqmVAIF2lMqXi+CrmnkbbUmLyYxzGGMhUe1eU8FTMHh2SWgGi1j",
|
|
"C3glb4L515WwZCdgO/WBOs+Lif7Rt3Jvzy6VFB8CNB+C0w/HR8dj8B7xFIJ//X3ff5JigWE6ifPCpyOo",
|
|
"RjVjeAVxCqcpAlM0o4b+pbasdGg+7AIuZxmGrtbgNuC9NpCFLi2gTYBbM2+1Tt21XRnKKFuuJAPdrc/+",
|
|
"Ux62iiQFtNjR9NYUcTktiCjAr5gU38DP+8P9l17zC+eTGUPojwCV5TgHut1oCj4g0jJVlteEI4Z9ysd7",
|
|
"aXbpRrmUxlaFc3film99nOw3TKqDoC1DgzaL8nlZo8VRuf2MXdfg2+30mqQUJgHfmtZH5Chlx8CQjmGJ",
|
|
"Y9+GX57/KsWtYyDIfsO+bhbl/GgZT6umn0qjQbhU2GWqyk36YLrKj3GMjCLhoSsoFnY+vx4fvj69eA2k",
|
|
"OWxNKjPHyqnkxS98RCaY5ylc1o7K4DTzYppivtCaY9cMz8qOUrFRvNft+jX86UfAaKtKR7LT7LPxKxal",
|
|
"n2NCbpbrkVC6gtZsg/4TedDrLiuXVBh/c19NN8T0F+VkECkyqUNWv45jga+kKlD9dIRSJJR/qPrtFSQE",
|
|
"JY6uWeHgUmxbP1A2cEo9W2xUU7kK1lKWqoomXsytIPYqdwxBgZKxCNAtFEjp9MpRJZfY+r2kPmQ+HvbU",
|
|
"iZT3A5EEkdgrlcfKipWzkGLe7Qus1t40B/tbLms4XqoVazhf/F4VI0ovmYdSP77TNvo7ki4/A8M79ov6",
|
|
"UA4Jh6VoW+SEXFObSdj+zGrotMWzDEEe0hB0W+kjMyysSdaLTqe+Ue5ROb0BmNE0pddKB0EZJALHthsm",
|
|
"8yE4KbgA03JhXGddT6O0PfWGLKg11kRCraUuGWpNRkB4Ws4QSSRmnqY3KZzPV4uVy1zy57l2p68lY5Se",
|
|
"YpuNaT+VC+0KBSN9hut6Pn9bILFArAZrJev5tucMMS4NynEcI87f06/IJ0nDMq/Gr34BKCTQTcVfhwPW",
|
|
"+nOGYAwyaSmUfh2PH0UhIZUuIqSQTEAR8MSu57UunR19rrj82s65kdRD0HQNKJyH4BASyYIQcJzlac1L",
|
|
"5D+67SZ27JQeLDebD6DafTug7AG0M1IuZiEB673zD+mlK1cl601NfgIq1bs7IaJbqNt210uEhuBY/MQB",
|
|
"/IqVPxyq+0m5hUNwsaBFmsiNS+k1YjEM0FtK57RTaSwH+4kD2Tlku04R61QRTBeroFdzcLWCXsrzCbJ6",
|
|
"b1NnsBTePiZpwWI0ieXha6+gNzxLSzSck7TIc8qEF+g1mnIsUE+fcnOOLeK9BbGYHfC7/mkaMIRkixUI",
|
|
"6vbbt38tePYGvddCXsrO3cvRProbTeXB3fi9Q3mvj992V2dBU0Y1AZgkTEotvdCYq+XZzKDuAWOFN3cV",
|
|
"AN/qulfDrelLY3oirWzPjbpje1ub21xJ3/5EM4AU4D6HmqLDeFL4lHm1w7HU4vstyJMgBMzHSYZJj1ta",
|
|
"xa4LyAGUH4Cc4Sucorq659hFmI/znNGrXjfdWhRwAM0nfpD3QLTtgAhHKLQaLwRkWmtvNb1Rupqv5ZBK",
|
|
"PUd4xYaU9iguGBbLCynHNIm8QpAhNi40t0zVv95Yyv3nb++jgQ6MVMujWqvJLoTIo5sb5aPWl54CC8mR",
|
|
"+l4UjM+OI8ewil4M9010EIE5jg6ivw73hz9Hg0gyq8JmpPZ7pKINRt/lH8fJzchA4KPv5m+nyn10owi+",
|
|
"8ChDSg1ToDiIIbFbDaC+/rfO4qiMVKLkOJFHvvxE2y2uf0QiWF6vH3z8HkkaVkhHllAijWvkXvoJViCz",
|
|
"etB7iHoB1aa4FrzPujPi4hVNlDstplJnVwsE8zzF+pp59MVYzRWoutjYKsu8zUn1q1W5KuoHfXmr0P55",
|
|
"f3+t6fd27d60bgg/2NgsRTUJ4IUyCGZFmiq97uUdolK/pfYg8womNn5tADC5gilOTIBIAgUcaoRe+A41",
|
|
"faGA/0CJ7vTXh8P6DWVTFVSkR375cCPbzSNUgBktiJr73x5yx46JkGZPCjhiV4jpoIWarFYCx5XSHz9L",
|
|
"Ti/vtrXQAlpqAUmtwE7LsKV1SX+08+XRZznCyIRPH3yP5kj4zGtpx3IA09TEBCCtKUAwx1eIKG98W4i+",
|
|
"ReKVjctuyE1/6KxUyGY4FYiBqfLrK6n43wKxZSUWZceJia4Ni8QEzaAK2NfRdJBQssxowUfqQLo89oiX",
|
|
"z7eUHY04H7NOt7sAaNPJmADVW9oz5RgVuzQ3Lqdemu5NeyVxnSPBMJJHZ6qusAUmsQhTg/p6pNZ+Tx/i",
|
|
"Uxh/neFUaaE51Y7AOr2UMVT8le3rP3AbFJHBbxPjwfYQwIv99gWjZ689q2exqAKld3J8fTm+LVK0pGSz",
|
|
"mybpQ8ezTiuCsyKyokYjJOdYmECjPnKSFYQPwBc61f83Ufx8oNxyroHIAeScxlgpDddYLEo+0qN55erb",
|
|
"EpceorWZQaLELBLxQtGQZN2QrNX9lTbbqb32iMuoRLtE5PBYjx0W8yWAC504sDYGxBMGvjYW9sNTfd6s",
|
|
"iYKJnzNIlPSzNhZldtOa4+eSxkz8haCAGREeGibXzg+fDPWI0EF3sIc68+SomMRpkShHuUKoa/QL/Mc6",
|
|
"Unxwa0Wita+Prjd8sbmGdc2hSyo2kxQ9TmVBBUy1JfludgbntZhHZ0F76R+6EcgJQkwkj/cXdkFVRV8B",
|
|
"3bWyYnnLVU+M4KzLdCdCtFu0A17FPcyxMND4wNC5knhK2x442TZ6IWwmWrdEt5j01JmddLOGXHGwewAu",
|
|
"6BKAGyOnv99M+P7owu9uxU7shJtj1F/2tCLV71X4XDg+lXJHE4eYDHdiLWj+dqsl6YzoX4nqejZVQKpo",
|
|
"IaVU1B6SKYdzTJQaae8rTbJWzCjXWml548XbQuhXzMU4TbXKu0L6nDnM5YT36Hy3++Gw03I0PZLm6YKR",
|
|
"krkC46ZY68kbaxUbj2y4fzK1wTUtEebElXj2VROHHtRc2QPKSg8jnGlpirmTQvDs+OId+Psv+y+AvnZ6",
|
|
"HsCtyklw0eqXZRCMpLF2xYwhvrBPEMwYzdQpPIUcKfw5AjGMF3I2BAE8AzOY8uD2qfjb7sW7W1moCabF",
|
|
"aCfwG86KzCF7vTMOEbQDmUve7SVNVYi3R4Lm3vSnw4IxRIR70nlxUPI3FIrfnE2ZOxAGVYrwbngSrW54",
|
|
"vfTNkFhzfDFNyeu4SQZWWzXOk6D+ebqNnt/WSWGzLqtVqBwWrq9Cu9wYwiRB38Iet3PdoZfID5G/oIAr",
|
|
"zZYCmM5piiGAAkBghEfIYTeFwm/SdgjiE0wUCrILu4KpFi3y8EkhF1Wwk0bsGjEE1PyQi10IJ0wmzQOq",
|
|
"LvgG0be9Od0zPypF/qjQixkWQU2ZrvCRx7u+na3dEg0f07043FK61wsmdRe9q9KS4wiyeIHJfNhJ/rrb",
|
|
"/StOF2qcnd7UHPlfaHlNWaIlhFyiar6BIc2OrWXrPYh2tlMwdgrGTsFoSVgbmLNSxkrGN48KSMgQcP0S",
|
|
"Q1ymQbQcYqf6Ru9eAm4+33OYiG8X1IW8fVjhzxNZoaZNngTtN8kSTJfg+KgXA4ww4QLqy+0QIxj+Kt+e",
|
|
"KR3T5ls1/wFAuMxK0aYvUL7rErNgzNqxBuPnmw3ytO4sts37Bkvsy0GrOWrB8QzQDAv1fpKzHE6ujk2w",
|
|
"CLlVqxxE5yiGQpJEdBD976dPyf//9Gno/PGXe7jfuUVM2WlJJ2UqyeMaDI2jjxfxQj8fNoVJuTHaiTT8",
|
|
"0wq5bTWlrLnjhr5KjpsiK4JMDPRqccfQFUbXPOxZOKNcneDnquM9Bs7WF6JSDrmAzFz4OZnjTlay1/4Q",
|
|
"sFek7d3dwmyiSRyF315qnGBBFVYa/jYh8z6YJcgkV9scaOlEUiZAk7hOSeOeMwuWWdOr2cXGrTvqQfvu",
|
|
"xTkL+H1HmrfpXhRcKfvVt70NylbsdzOq8Xun/V2PFPf6G9T9wODuzfJ1p+iZXIu+fjXWk3VZgXLzH/o8",
|
|
"VAxnvBsPyuTbzdxqg+Tu2I3xcnMjQnpVIkrdCPYas/efRBJ+rsBV7cGzUypPisvL46PnAUW/nNVWmdUd",
|
|
"mnL/M7FUAXbnXi9LuOvIW5NJbtyA8I44cHXV7cTfPkba1eMkXMUpLZKJeSPUpNJ17Xro2VHXMRx68bAX",
|
|
"XPN8pU3iaueba3PUH9KwSb6WPzRwqfJZqiiIdnLVLpepM5fp5f7/PBwGr7+p/JA50NmfeuuQ/JFvpdjT",
|
|
"VAUc4aQfHUZMQEyaQq+VGLCW2Bt9j+33K3SGige3Xv75ITkT3Ro1whVsLVrZCZofJ2myZO45EkaZWToc",
|
|
"DqaQq/gzgAUH+lmGEH9Xd/+d9vtZ1e0hzNLaO4yrjFLnlbsKyy1LZttyjbgWBOKQi7Ptn28GnSpttWWb",
|
|
"64s9SaKPqvXivgb2vGCiHu8JC9XtosJdRuWd5qVr4pfWI7queCjEQnWJO1L7A/XjU96b1cMFir+Wb7pU",
|
|
"L0XZZ8TUCy8pQzBZAgG/Is/N6QczhsufK+9PPSMJCiy6oRtJ2/dBFaLG81t8XIbMtGNsWIHc93HKFbSf",
|
|
"DHSwNqBigdg1rr3ItsL0a/CThW6WTGoSrExg24ZbzQxzLq2Yah30s2FqS7fzks9SstxCGGIGN2CqBwd+",
|
|
"L/9uDJZEPSPaPuT086IdTOSxERzYt2SJl4G3s9T8Ncq+k+cB9eUKnSf9zIjeZpe8wtpQyLZ9LCLZf2iV",
|
|
"p0pS25Heeg7oSng1w7CaGnfhoTH9Cs4Dktmja/MPTtpP4aGrNbT5HTeuexCYl6bg2jp9TaMYTSEJ3wW9",
|
|
"gmQrFQr9Jiu42LkHn/yZ8wqSGg13U2szGdsfx8PfUPYwdPs082FukayyOuKGb+UzXU9Nutc8n6FUkG5/",
|
|
"Z+/Lqy3TvKr7oYdzoXamjTwFx2n/t+ietP8yLrigWVfsZ/fRUcuZ6vak3Dv7DO4vn8qbAKcSoEKOmF02",
|
|
"1NPy/tQDzb1HQ9gwf2Kk/ZhHzANlJv5g1vxOmjwtF8IqabLGwdrfofAjHrA7x8QajgnKwBNIWGg4KH7i",
|
|
"oIzM7c0TOWLqOrMrCektEmdlt3d1NuFPlU9u9SgiJK8TLPoHNweDrpzV30VdrXEN5CxcvRyQ+6Dr7dzP",
|
|
"Hal6gdRW/fW6KT1PWZOtswUxhcj7+O5UqdjNamfbyooTXVlxUtZkbL/GWS3Cx8goELWBQ8A+b5Si8OKW",
|
|
"a7fhenA8J8hf8VfVplbNttxvkZtiv6iZ7m0ioDZ40vQUXZdwLDU/CZ/ULlCvnzZuJJvxdK2R+LWucG2m",
|
|
"Ta72gz0pSduZWHEfmn9Ze4pUfPnMuNqeP66vzaKWUMSVnj1FKSXzVmXWB0vHfPysBQ8Ga9nMdpPtFj/f",
|
|
"IF1z4K+XZ+xxSlJd8r4qvg1J4pTGtsXa6m95tcZuh9puVlPvx+Po+/Eoeguu78rk7crk7crktXyOftEm",
|
|
"Z+fKtsajQevqP7dxu2x1aOzOUfKnc5Qo03FFCqSxssdKpr/XH2wzGffLtGzPat2wJOt+ANr9AMxa/pmu",
|
|
"qsycn+65UU8F9W6o4TYfnymyASeQwDnK5HxXJot6qO4pRrH7mOe+vWylq9BTpAldp8syoMq7jRu6x/QO",
|
|
"P6FQrZ1bbJP8VR/FdPN5j1N19F392S/B7oEFg9/2NfjevS9LL+CfPE5ML8IPFii2IevYEfd4rAM7vGng",
|
|
"Z0WampOZqCqMtbcXlY0XU5IUsQAWIJAAvfU8dPuFHK9fBWpMxreoHTMI1rW2V+/rv0DbeHQ7hiRQdWbn",
|
|
"dPkBalpbkgWKZhXb6BvAPcgEnsFYdD/VfKk6j23fu7op1vvlV8R0W70ydVvxGkTwaj65YjALQLlCqrgs",
|
|
"zGhBlLn14Xx8Is3fxKbrs8LV6JxaI7q66ERzm+dtu2kRf0WibO8uMa07g+sFYroIFS2EJGlT4pshVQdX",
|
|
"5dW0BlLPEk1SOueTecwn6qA98Nc0FQsgKDBlWIH8ZAjQfAjm/GA00jjsSbRGsik8FivIZJYquesbRzXV",
|
|
"FlEXS2cFCcDMsJgsIF94F9K0OwU120Oa+p22T3gUVVfMC0LV/6pXOjfY6ydBZdun6Pfff/997+Rk7+jo",
|
|
"/T/+cXBycnBx8e9PEXj28/6LX/Ze7O+92H+/v3+g/vv3cy8eRQLdK/xmzZwEujUaWp8jknTMwdYItvP4",
|
|
"Qqf6gf1Lgr9VZR4l5LJWIybil5deCv9CpxOc+CRps/aDNFzNeD6kJSBTN39ScBRgaeV0ul5QYLqipAtm",
|
|
"BuMFJvr955U+mBPd+UL1vRlE1EO575o15xtSwIeE5tKJ4tKS+Tywx4qiIOBIqgP6BkzCAGIBy1LYHLw9",
|
|
"vFBM+ow/l3zqyoAAn+oug1DDzz6kcwS/dshE2byRQMzZxFR58sOVKpY5GFrloBzslmJBSZhDFCjVp7ww",
|
|
"7LFR+VJQFi9WgpWd1oHLUE595VpqlbW9HxZkTd4KYKDKhHeIhKqM+N0IBX29sYrhfqPs6yyl1+eF87D7",
|
|
"tfmx55lou3v9KW7MltqEUlyVa6vYvH681I+B1tFSP9SbCNfW2pHELuW36Ncj/AZWsSkXc7NAsserTt0o",
|
|
"pB0jfGWEtdUX66WqOqqgsaqMxC3q9SsMysE5eOaKzudVoU+r+bzF4h/FFIxja0JFI7k1nbdsl9y8vHdP",
|
|
"N98Kvmex3/1r3Wco2pXj3qwfJ/IWCc9r6Eo5gmlqH7YaOovneql6PnX5hrK7WNbdi5fb/uJl7SLRSMHg",
|
|
"HWKveiem1vyKkicNn0gZu9Ppr0Tf8lQFKWuP5IOXPJHnwjKVP0j2i+6xAsrAbyZWVWbdimr3U2BWnfrl",
|
|
"oxNqCeWoZnLlqxNdo1/gP9AalWbvNnjhdrVPS/R7lnOtXJLlwgDbE3PwYn9/eNsaq47X8wFrrQ4il+vv",
|
|
"oLJODzVmRa2dx3tC0lcT9vEq/2xvCZ46uerDhdMMSb1PmGLbgZgrq9rrN0NH3+2/z9W/V7yt/1utc6/r",
|
|
"syb8rXmJUOvA/6RTMxn/w/YZbqj0D3ibZYZ/erVvjBdRP0B4o7VvCUATScHS6CBaCJHzg9EI5niovKRD",
|
|
"yubRzeeb/wsAAP//LQIeYVfGAAA=",
|
|
}
|
|
|
|
// GetSwagger returns the content of the embedded swagger specification file
|
|
// or error if failed to decode
|
|
func decodeSpec() ([]byte, error) {
|
|
zipped, err := base64.StdEncoding.DecodeString(strings.Join(swaggerSpec, ""))
|
|
if err != nil {
|
|
return nil, fmt.Errorf("error base64 decoding spec: %w", err)
|
|
}
|
|
zr, err := gzip.NewReader(bytes.NewReader(zipped))
|
|
if err != nil {
|
|
return nil, fmt.Errorf("error decompressing spec: %w", err)
|
|
}
|
|
var buf bytes.Buffer
|
|
_, err = buf.ReadFrom(zr)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("error decompressing spec: %w", err)
|
|
}
|
|
|
|
return buf.Bytes(), nil
|
|
}
|
|
|
|
var rawSpec = decodeSpecCached()
|
|
|
|
// a naive cached of a decoded swagger spec
|
|
func decodeSpecCached() func() ([]byte, error) {
|
|
data, err := decodeSpec()
|
|
return func() ([]byte, error) {
|
|
return data, err
|
|
}
|
|
}
|
|
|
|
// Constructs a synthetic filesystem for resolving external references when loading openapi specifications.
|
|
func PathToRawSpec(pathToFile string) map[string]func() ([]byte, error) {
|
|
res := make(map[string]func() ([]byte, error))
|
|
if len(pathToFile) > 0 {
|
|
res[pathToFile] = rawSpec
|
|
}
|
|
|
|
return res
|
|
}
|
|
|
|
// GetSwagger returns the Swagger specification corresponding to the generated code
|
|
// in this file. The external references of Swagger specification are resolved.
|
|
// The logic of resolving external references is tightly connected to "import-mapping" feature.
|
|
// Externally referenced files must be embedded in the corresponding golang packages.
|
|
// Urls can be supported but this task was out of the scope.
|
|
func GetSwagger() (swagger *openapi3.T, err error) {
|
|
resolvePath := PathToRawSpec("")
|
|
|
|
loader := openapi3.NewLoader()
|
|
loader.IsExternalRefsAllowed = true
|
|
loader.ReadFromURIFunc = func(loader *openapi3.Loader, url *url.URL) ([]byte, error) {
|
|
pathToFile := url.String()
|
|
pathToFile = path.Clean(pathToFile)
|
|
getSpec, ok := resolvePath[pathToFile]
|
|
if !ok {
|
|
err1 := fmt.Errorf("path not found: %s", pathToFile)
|
|
return nil, err1
|
|
}
|
|
return getSpec()
|
|
}
|
|
var specData []byte
|
|
specData, err = rawSpec()
|
|
if err != nil {
|
|
return
|
|
}
|
|
swagger, err = loader.LoadFromData(specData)
|
|
if err != nil {
|
|
return
|
|
}
|
|
return
|
|
}
|