persistence

type AgreementEventSource struct {
	AgreementId       string       `json:"agreement_id"`
	RunningWorkload   WorkloadInfo `json:"workload_to_run"`
	DependentServices ServiceSpecs `json:"dependent_services"`
	ConsumerId        string       `json:"consumer_id"`
	AgreementProtocol string       `json:"agreement_protocol"`
}

type AgreementProtocolAttributes struct {
	Meta         *AttributeMeta `json:"meta"`
	ServiceSpecs *ServiceSpecs  `json:"service_specs"`
	Protocols    interface{}    `json:"protocols"`
}

type Attribute interface {
	GetMeta() *AttributeMeta
	GetGenericMappings() map[string]interface{}
	Update(other Attribute) error
	String() string
}

type AttributeMeta struct {
	Id          string `json:"id"` // should correspond to something meangingful to the caller
	Type        string `json:"type"`
	Label       string `json:"label"`       // for humans only, never computable
	HostOnly    *bool  `json:"host_only"`   // determines whether or not the attribute will be published inside workload containers or exists only for Host use
	Publishable *bool  `json:"publishable"` // means sent to exchange or otherwise published; whether or not an attr ends up in a workload depends on the value of HostOnly
}

type Auth struct {
	Registry string `json:"registry"`
	UserName string `json:"username"` // The name of the user, the default is 'token'
	Token    string `json:"token"`    // It can be a token, a password, an api key etc.
}

type Configstate struct {
	State          string `json:"state"`
	LastUpdateTime uint64 `json:"last_update_time"`
}

type ConflictingAttributeFound struct {
	// contains filtered or unexported fields
}

type DatabaseEventSource struct {
}

type DeploymentConfig interface {
	ToPersistentForm() (map[string]interface{}, error)
	FromPersistentForm(pf map[string]interface{}) error
	IsNative() bool
	ToString() string
}

type DockerRegistryAuthAttributes struct {
	Meta  *AttributeMeta `json:"meta"`
	Auths []Auth         `json:"auths"`
}

type EAFilter func(EstablishedAgreement) bool

type EstablishedAgreement struct {
	Name                         string       `json:"name"`
	DependentServices            ServiceSpecs `json:"dependent_services"`
	Archived                     bool         `json:"archived"`
	CurrentAgreementId           string       `json:"current_agreement_id"`
	ConsumerId                   string       `json:"consumer_id"`
	CounterPartyAddress          string       `json:"counterparty_address"`
	AgreementCreationTime        uint64       `json:"agreement_creation_time"`
	AgreementAcceptedTime        uint64       `json:"agreement_accepted_time"`
	AgreementBCUpdateAckTime     uint64       `json:"agreement_bc_update_ack_time"` // V2 protocol - time when consumer acks our blockchain update
	AgreementFinalizedTime       uint64       `json:"agreement_finalized_time"`
	AgreementTerminatedTime      uint64       `json:"agreement_terminated_time"`
	AgreementForceTerminatedTime uint64       `json:"agreement_force_terminated_time"`
	AgreementExecutionStartTime  uint64       `json:"agreement_execution_start_time"`
	AgreementDataReceivedTime    uint64       `json:"agreement_data_received_time"`
	// One of the following 2 fields are set when the worker that owns deployment for this agreement, starts deploying the services in the agreement.
	CurrentDeployment               map[string]ServiceConfig `json:"current_deployment"`  // Native Horizon deployment config goes here, mutually exclusive with the extended deployment field. This field is set before the imagefetch worker starts the workload.
	ExtendedDeployment              map[string]interface{}   `json:"extended_deployment"` // All non-native deployment configs go here. This field is set before the helm worker installs the release.
	Proposal                        string                   `json:"proposal"`
	ProposalSig                     string                   `json:"proposal_sig"`           // the proposal currently in effect
	AgreementProtocol               string                   `json:"agreement_protocol"`     // the agreement protocol being used. It is also in the proposal.
	ProtocolVersion                 int                      `json:"protocol_version"`       // the agreement protocol version being used.
	TerminatedReason                uint64                   `json:"terminated_reason"`      // the reason that the agreement was terminated
	TerminatedDescription           string                   `json:"terminated_description"` // a string form of the reason that the agreement was terminated
	AgreementProtocolTerminatedTime uint64                   `json:"agreement_protocol_terminated_time"`
	WorkloadTerminatedTime          uint64                   `json:"workload_terminated_time"`
	MeteringNotificationMsg         MeteringNotification     `json:"metering_notification,omitempty"` // the most recent metering notification received
	BlockchainType                  string                   `json:"blockchain_type,omitempty"`       // the name of the type of the blockchain
	BlockchainName                  string                   `json:"blockchain_name,omitempty"`       // the name of the blockchain instance
	BlockchainOrg                   string                   `json:"blockchain_org,omitempty"`        // the org of the blockchain instance
	RunningWorkload                 WorkloadInfo             `json:"workload_to_run,omitempty"`       // For display purposes, a copy of the workload info that this agreement is managing. It should be the same info that is buried inside the proposal.
}

type EventLog struct {
	EventLogBase
	Source EventSourceInterface `json:"event_source"` // source involved for this event.
}

type EventLogBase struct {
	Id          string       `json:"record_id"` // unique primary key for records
	Timestamp   uint64       `json:"timestamp"`
	Severity    string       `json:"severity"` // info, warning or error
	Message     string       `json:"message"`  // obsolte in DB, used for backward compatibility and for output
	EventCode   string       `json:"event_code"`
	SourceType  string       `json:"source_type"`            // the type of the source. It can be agreement, service, image, workload etc.
	MessageMeta *MessageMeta `json:"message_meta,omitempty"` // the message and it's arguements for fmt.Sprintf. This is used for i18n.
}

type EventLogFilter func(EventLog) bool

type EventLogRaw struct {
	EventLogBase
	Source *json.RawMessage `json:"event_source"` // source involved for this event.
}

type EventSourceInterface interface {

	//Used for searching. The input is a map of selector array.
	// The input is a map of selector array.
	// For example:
	//   selectors = [string][]Selector{
	//			"a": [{"~": "test"}, {"~", "agreement"}],
	//          "b": [{"=", "this is a test"}],
	//			"c":[{">", 100}]
	//		}
	// It means checking if this event source matches the following logic:
	//  the attribute "a" contains the word "test" and "agreement",
	//  attribute "b" equals "this is a test" and attribute "c" is greater than 100.
	Matches(map[string][]Selector) bool
}

type ExchangeDevice struct {
	Id                 string      `json:"id"`
	Org                string      `json:"organization"`
	Pattern            string      `json:"pattern"`
	Name               string      `json:"name"`
	Token              string      `json:"token"`
	TokenLastValidTime uint64      `json:"token_last_valid_time"`
	TokenValid         bool        `json:"token_valid"`
	HA                 bool        `json:"ha"`
	Config             Configstate `json:"configstate"`
}

type ExchangeEventSource struct {
	ExchangeUrl string `json:"exchange_url"`
}

type HAAttributes struct {
	Meta     *AttributeMeta `json:"meta"`
	Partners []string       `json:"partners"`
}

type HTTPSBasicAuthAttributes struct {
	Meta     *AttributeMeta `json:"meta"`
	Url      string         `json:"url"`
	Username string         `json:"username"`
	Password string         `json:"password"`
}

type HardwareMatch map[string]interface{}

type HelmDeploymentConfig struct {
	ChartArchive string `json:"chart_archive"` // base64 encoded binary of helm package tar file
	ReleaseName  string `json:"release_name"`
}

type MIFilter func(MicroserviceInstance) bool

type MSFilter func(MicroserviceDefinition) bool

type MessageMeta struct {
	MessageKey  string        `json:"message_key"`
	MessageArgs []interface{} `json:"message_args,omitempty"`
}

type MetaAttributesOnly struct {
	Meta *AttributeMeta `json:"meta"`
}

type MeteringAttributes struct {
	Meta                  *AttributeMeta `json:"meta"`
	ServiceSpecs          *ServiceSpecs  `json:"service_specs"`
	Tokens                uint64         `json:"tokens"`
	PerTimeUnit           string         `json:"per_time_unit"`
	NotificationIntervalS int            `json:"notification_interval"`
}

type MeteringNotification struct {
	Amount                 uint64 `json:"amount"`                       // The number of tokens granted by this notification, rounded to the nearest minute
	StartTime              uint64 `json:"start_time"`                   // The time when the agreement started, in seconds since 1970.
	CurrentTime            uint64 `json:"current_time"`                 // The time when the notification was sent, in seconds since 1970.
	MissedTime             uint64 `json:"missed_time"`                  // The amount of time in seconds that the consumer detected missing data
	ConsumerMeterSignature string `json:"consumer_meter_signature"`     // The consumer's signature of the meter (amount, current time, agreement Id)
	AgreementHash          string `json:"agreement_hash"`               // The 32 byte SHA3 FIPS 202 hash of the proposal for the agreement.
	ConsumerSignature      string `json:"consumer_agreement_signature"` // The consumer's signature of the agreement hash.
	ConsumerAddress        string `json:"consumer_address"`             // The consumer's blockchain account/address.
	ProducerSignature      string `json:"producer_agreement_signature"` // The producer's signature of the agreement
	BlockchainType         string `json:"blockchain_type"`              // The type of the blockchain that this notification is intended to work with
}

type MicroserviceDefinition struct {
	Id                           string               `json:"record_id"` // unique primary key for records
	Owner                        string               `json:"owner"`
	Label                        string               `json:"label"`
	Description                  string               `json:"description"`
	SpecRef                      string               `json:"specRef"`
	Org                          string               `json:"organization"`
	Version                      string               `json:"version"`
	Arch                         string               `json:"arch"`
	Sharable                     string               `json:"sharable"`
	DownloadURL                  string               `json:"downloadUrl"`
	MatchHardware                HardwareMatch        `json:"matchHardware"`
	UserInputs                   []UserInput          `json:"userInput"`
	Workloads                    []WorkloadDeployment `json:"workloads"`            // Only used by old microservice definitions
	Public                       bool                 `json:"public"`               // Used by only services, indicates if the definition is public or not.
	RequiredServices             []ServiceDependency  `json:"requiredServices"`     // Used only by services, the list of services that this service depends on.
	Deployment                   string               `json:"deployment"`           // Used only by services, the deployment configuration of the implementation packages.
	DeploymentSignature          string               `json:"deployment_signature"` // Used only by services, the signature of the deployment configuration.
	LastUpdated                  string               `json:"lastUpdated"`
	Archived                     bool                 `json:"archived"`
	Name                         string               `json:"name"`                  //the sensor_name passed in from the POST /service call
	RequestedArch                string               `json:"requested_arch"`        //the arch from user input or from the ms referenced by a workload, it can be a synonym of the node arch.
	UpgradeVersionRange          string               `json:"upgrade_version_range"` //the sensor_version passed in from the POST service call
	AutoUpgrade                  bool                 `json:"auto_upgrade"`          // passed in from the POST service call
	ActiveUpgrade                bool                 `json:"active_upgrade"`        // passed in from the POST service call
	UpgradeStartTime             uint64               `json:"upgrade_start_time"`
	UpgradeMsUnregisteredTime    uint64               `json:"upgrade_ms_unregistered_time"`
	UpgradeAgreementsClearedTime uint64               `json:"upgrade_agreements_cleared_time"`
	UpgradeExecutionStartTime    uint64               `json:"upgrade_execution_start_time"`
	UpgradeMsReregisteredTime    uint64               `json:"upgrade_ms_reregistered_time"`
	UpgradeFailedTime            uint64               `json:"upgrade_failed_time"`
	UngradeFailureReason         uint64               `json:"upgrade_failure_reason"`
	UngradeFailureDescription    string               `json:"upgrade_failure_description"`
	UpgradeNewMsId               string               `json:"upgrade_new_ms_id"`
	MetadataHash                 []byte               `json:"metadata_hash"` // the hash of the whole exchange.MicroserviceDefinition

}

type MicroserviceInstance struct {
	SpecRef              string                         `json:"ref_url"`
	Org                  string                         `json:"organization"`
	Version              string                         `json:"version"`
	Arch                 string                         `json:"arch"`
	InstanceId           string                         `json:"instance_id"`
	Archived             bool                           `json:"archived"`
	InstanceCreationTime uint64                         `json:"instance_creation_time"`
	ExecutionStartTime   uint64                         `json:"execution_start_time"`
	ExecutionFailureCode uint                           `json:"execution_failure_code"`
	ExecutionFailureDesc string                         `json:"execution_failure_desc"`
	CleanupStartTime     uint64                         `json:"cleanup_start_time"`
	AssociatedAgreements []string                       `json:"associated_agreements"`
	MicroserviceDefId    string                         `json:"microservicedef_id"`
	ParentPath           [][]ServiceInstancePathElement `json:"service_instance_path"` // Set when instance is created
	AgreementLess        bool                           `json:"agreement_less"`        // Set when the service instance was started because it is an agreement-less service (as defined in the pattern)
	MaxRetries           uint                           `json:"max_retries"`           // maximum retries allowed
	MaxRetryDuration     uint                           `json:"max_retry_duration"`    // The number of seconds in which the specified number of retries must occur in order for next retry cycle.
	CurrentRetryCount    uint                           `json:"current_retry_count"`
	RetryStartTime       uint64                         `json:"retry_start_time"`
	EnvVars              map[string]string              `json:"env_vars"`
}

type NativeDeploymentConfig struct {
	Services map[string]ServiceConfig
}

type NodeEventSource struct {
	Id          string `json:"node_id"`
	Org         string `json:"node_org"`
	Pattern     string `json:"pattern"` // fprmat: pattern_org/pattern
	ConfigState string `json:"config_state"`
}

type OverwriteCandidateNotFound struct {
	// contains filtered or unexported fields
}

type Selector struct {
	Op         string
	MatchValue interface{}
}

type SensorUrls struct {
	SensorUrl []string `json:"sensor_url"`
}

type ServiceAttribute interface {
	GetServiceSpecs() *ServiceSpecs
}

type ServiceConfig struct {
	Config     docker.Config     `json:"config"`
	HostConfig docker.HostConfig `json:"host_config"`
}

type ServiceDependency struct {
	URL     string `json:"url"`
	Org     string `json:"org"`
	Version string `json:"version"`
	Arch    string `json:"arch"`
}

type ServiceEventSource struct {
	InstanceId           string   `json:"instance_id"`
	ServiceUrl           string   `json:"service_url"`
	Org                  string   `json:"organization"`
	Version              string   `json:"version"`
	Arch                 string   `json:"arch"`
	AssociatedAgreements []string `json:"agreement_id"`
}

type ServiceInstancePathElement struct {
	URL     string `json:"url"`
	Org     string `json:"org"`
	Version string `json:"version"`
}

type ServiceSpec struct {
	Url string `json:"url"`
	Org string `json:"organization,omitempty"` // default is the node org
}

type ServiceSpecs []ServiceSpec // empty if applicable to all services

type SurfaceError struct {
	Record_id  string       `json:"record_id"`
	Message    string       `json:"message"`
	Event_code string       `json:"event_code"`
	Hidden     bool         `json:"hidden"`
	Workload   WorkloadInfo `json:"workload"`
	Timestamp  string       `json:"timestamp"`
}

type UserInput struct {
	Name         string `json:"name"`
	Label        string `json:"label"`
	Type         string `json:"type"`
	DefaultValue string `json:"defaultValue"`
}

type UserInputAttributes struct {
	Meta         *AttributeMeta         `json:"meta"`
	ServiceSpecs *ServiceSpecs          `json:"service_specs"`
	Mappings     map[string]interface{} `json:"mappings"`
}

type WorkloadDeployment struct {
	Deployment          string `json:"deployment"`
	DeploymentSignature string `json:"deployment_signature"`
}

type WorkloadInfo struct {
	URL     string `json:"url,omitempty"`
	Org     string `json:"org,omitempty"`
	Version string `json:"version,omitempty"`
	Arch    string `json:"arch,omitempty"`
}