services

type DatabaseOutput struct {
	Body DatabaseResponse `doc:"Information about the requested available database"`
}

type DatabaseResponse struct {
	Id           string `json:"id" example:"jdp" `
	Name         string `json:"name" example:"JGI Data portal"`
	Organization string `json:"organization" example:"Joint Genome Institute"`
	URL          string `json:"url" example:"https://data.jgi.doe.gov"`
}

type DatabasesOutput struct {
	Body []DatabaseResponse `doc:"A list of information about available databases"`
}

type FileMetadataOutput struct {
	Body FileMetadataResponse `doc:"Metadata for files with the given IDs"`
}

type FileMetadataResponse struct {
	// name of organization database
	Database string `json:"database" example:"jdp" doc:"the database searched"`
	// resources corresponding to given file IDs
	Descriptors []map[string]any `json:"resources" doc:"an array of validated Frictionless descriptors"`
}

type SearchDatabaseInput struct {
	Authorization string `header:"authorization" doc:"Authorization header with encoded access token"`
	SearchDatabaseInputWithoutHeader
}

type SearchDatabaseInputWithoutHeader struct {
	Database string `json:"database" query:"database" example:"jdp" doc:"The ID of the database to search"`
	Orcid    string `json:"orcid" query:"orcid" example:"1234-5678-9101=112X" doc:"The ORCID of the user searching for files"`
	Query    string `json:"query" query:"query" example:"prochlorococcus" doc:"A query used to search the database for matching files"`
	Status   string `json:"status" query:"status" example:"\"staged\"" doc:"(Optional) The staged or unstaged status of the desired files"`
	Offset   int    `json:"offset" query:"offset" example:"100" doc:"Search results begin at the given offset"`
	Limit    int    `json:"limit" query:"limit" example:"50" doc:"Limits the number of search results returned"`
}

type SearchParametersOutput struct {
	Body map[string]any `doc:"a JSON object whose fields are search parameters and whose values indicate their type"`
}

type SearchResultsOutput struct {
	Body SearchResultsResponse `doc:"Search results containing matching files that match the given query"`
}

type SearchResultsResponse struct {
	// name of organization database
	Database string `json:"database" example:"jdp" doc:"the database searched"`
	// ElasticSearch query string
	Query string `json:"query" example:"prochlorococcus" doc:"the given query string"`
	// resources matching the query
	Descriptors []map[string]any `json:"resources" doc:"an array of validated Frictionless descriptors"`
}

type ServiceInfoOutput struct {
	Body ServiceInfoResponse `doc:"information about the service itself"`
}

type ServiceInfoResponse struct {
	Name          string `json:"name" example:"DTS" doc:"The name of the service API"`
	Version       string `json:"version" example:"1.0.0" doc:"The version string (major.minor.patch)"`
	Uptime        int    `json:"uptime" example:"345600" doc:"The time the service has been up (seconds)"`
	Documentation string `json:"documentation" example:"/docs" doc:"The OpenAPI documentation endpoint"`
}

type TaskDeletionOutput struct {
	Status int
}

type TransferOutput struct {
	Body   TransferResponse `doc:"A UUID for the requested transfer"`
	Status int
}

type TransferRecordsOutput struct {
	Body []journal.Record
}

type TransferRequest struct {
	// user ORCID
	Orcid string `json:"orcid" example:"0000-0002-9227-8514" doc:"ORCID for user requesting transfer"`
	// name of source database
	Source string `json:"source" example:"jdp" doc:"source database identifier"`
	// identifiers for files to be transferred
	FileIds []string `json:"file_ids" example:"[\"fileid1\", \"fileid2\"]" doc:"source-specific identifiers for files to be transferred"`
	// name of destination database
	Destination string `json:"destination" example:"kbase" doc:"destination database identifier"`
	// a Markdown description of the transfer request
	Description string `json:"description,omitempty" example:"# title\n* type: assembly\n" doc:"Markdown task description"`
	// machine-readable instructions for processing a payload at the destination site
	Instructions map[string]any `` /* 126-byte string literal not displayed */
}

type TransferResponse struct {
	// transfer job ID
	Id uuid.UUID `json:"id" doc:"a UUID for the requested transfer"`
}

type TransferService interface {
	// Configures and starts the service, returning an error that indicates success or failure.
	Start(conf config.Config) error
	// Gracefully shuts down the service without interrupting active connections.
	Shutdown(ctx context.Context) error
	// Closes down the service, freeing all resources.
	Close()
}

type TransferStatusOutput struct {
	Body TransferStatusResponse `doc:"A status message for the transfer task with the given ID"`
}

type TransferStatusResponse struct {
	// transfer job ID
	Id string `json:"id"`
	// transfer job status
	Status string `json:"status"`
	// message (if any) related to status
	Message string `json:"message,omitempty"`
	// number of files being transferred
	NumFiles int `json:"num_files"`
	// number of files that have been completely transferred
	NumFilesTransferred int `json:"num_files_transferred"`
}