pkg

type Registry struct {
	Config      RegistryConfig
	Db          db.Db
	EventSystem events.EventSystem

	OnChange func(registry *Registry)
	// contains filtered or unexported fields
}

type RegistryClient interface {
	// EndpointsByOrganization returns all registered endpoints for an organization
	EndpointsByOrganizationAndType(organizationIdentifier core.PartyID, endpointType *string) ([]db.Endpoint, error)

	// SearchOrganizations searches the registry for any Organization matching the given query
	SearchOrganizations(query string) ([]db.Organization, error)

	// OrganizationById returns an Organization given the Id or an error if it doesn't exist
	OrganizationById(id core.PartyID) (*db.Organization, error)

	// ReverseLookup finds an exact match on name or returns an error if not found
	ReverseLookup(name string) (*db.Organization, error)

	// RegisterEndpoint registers an endpoint for an organization
	RegisterEndpoint(organizationID core.PartyID, id string, url string, endpointType string, status string, properties map[string]string) (events.Event, error)

	// VendorClaim registers an organization under a vendor. orgKeys are the organization's keys in JWK format
	VendorClaim(orgID core.PartyID, orgName string, orgKeys []interface{}) (events.Event, error)

	// RegisterVendor registers a vendor with the given id, name for the specified domain. If the vendor with this ID
	// already exists, it functions as an update.
	RegisterVendor(certificate *x509.Certificate) (events.Event, error)

	// RefreshOrganizationCertificate issues a new certificate for the organization. The organization must be registered under the current vendor.
	// If successful it returns the resulting event.
	RefreshOrganizationCertificate(organizationID core.PartyID) (events.Event, error)

	// Verify verifies the data in the registry owned by this node.
	// If fix=true, data will be fixed/upgraded when necessary (e.g. issue certificates). Events resulting from fixing the data are returned.
	// If the returned bool=true there's data to be fixed and Verify should be run with fix=true.
	Verify(fix bool) ([]events.Event, bool, error)

	// VendorCAs returns all registered vendors as list of chains, PEM encoded. The first entry in a chain will be the leaf and the last one the root.
	VendorCAs() [][]*x509.Certificate

	// VendorById finds a vendor by its ID. When not found it returns an ErrVendorNotFound error and a nil result.
	VendorById(vID core.PartyID) (*db.Vendor, error)
}

type RegistryConfig struct {
	Mode                            string
	SyncMode                        string
	SyncAddress                     string
	SyncInterval                    int
	Datadir                         string
	Address                         string
	VendorCACertificateValidity     int
	OrganisationCertificateValidity int
	ClientTimeout                   int
}