rpcdef

type Agent interface {
	// ExportStarted should be called when starting export for each modelType.
	// It returns session id to be used later when sending objects.
	ExportStarted(modelType string) (sessionID string, lastProcessed interface{})

	// ExportDone should be called when export of a certain modelType is complete.
	// TODO: rename to SessionDone
	ExportDone(sessionID string, lastProcessed interface{})

	// SendExported forwards the exported objects from intergration to agent,
	// which then uploads the data (or queues for uploading).
	// TODO: rename to SessionSend
	SendExported(
		sessionID string,
		objs []ExportObj)

	// SessionStart creates a new export session with optional parent.
	// isTracking is a bool to create a tracking session instead of normal session. Tracking sessions do not allow sending data, they are only used for organizing progress events.
	// name - For normal sessions use model name. For tracking sessions any string is allows, it will be shown in the progress log.
	// parentSessionID - parent session. Can be 0 for root sessions.
	// parentObjectID - id of the parent object. To show in progress logs.
	// parentObjectName - name of the parent object
	SessionStart(isTracking bool, name string, parentSessionID int, parentObjectID, parentObjectName string) (sessionID int, lastProcessed interface{}, _ error)

	// SessionProgress updates progress for a session
	SessionProgress(id int, current, total int) error

	// SessionRollback does not update lastProcessed, and deletes temp session file
	SessionRollback(id int) error

	// Integration can ask agent to download and process git repo using ripsrc.
	ExportGitRepo(fetch GitRepoFetch) error

	// OAuthNewAccessToken returns a new access token for integrations with UseOAuth: true. It askes agent to retrieve a new token from backend based on refresh token agent has.
	OAuthNewAccessToken() (token string, _ error)

	SendPauseEvent(msg string, resumeDate time.Time) error

	SendResumeEvent(msg string) error
}

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

type AgentServer struct {
	Impl Agent
}

type ExportConfig struct {
	Pinpoint    ExportConfigPinpoint
	Integration IntegrationConfig
	UseOAuth    bool
}

type ExportConfigPinpoint struct {
	CustomerID string
}

type ExportObj struct {
	Data interface{}
}

type ExportProject struct {
	ID         string `json:"id"`
	RefID      string `json:"ref_id"`
	ReadableID string `json:"name"`
	Error      string `json:"error"`
}

type ExportResult struct {
	Projects []ExportProject
}

type GitRepoFetch struct {
	RepoID            string
	UniqueName        string
	RefType           string
	URL               string
	CommitURLTemplate string
	BranchURLTemplate string
	PRs               []GitRepoFetchPR
}

type GitRepoFetchPR struct {
	ID            string
	RefID         string
	URL           string
	BranchName    string
	LastCommitSHA string
}

type Integration interface {
	// Init provides the connection details for connecting back to agent.
	Init(agent Agent) error
	// Export starts export of all data types for this integration.
	// Config contains typed config common for all integrations and map[string]interface{} for custom fields.
	Export(context.Context, ExportConfig) (ExportResult, error)
	ValidateConfig(context.Context, ExportConfig) (ValidationResult, error)
	// OnboardExport returns the data used in onboard. Kind is one of users, repos, projects.
	OnboardExport(ctx context.Context, objectType OnboardExportType, config ExportConfig) (OnboardExportResult, error)

	// Mutate changes integration data
	Mutate(ctx context.Context, fn string, data string, config ExportConfig) (MutateResult, error)

	// Webhook takes the objects provided by integration webhooks and queries for additional fields if needed
	Webhook(ctx context.Context, headers map[string]string, body string, config ExportConfig) (WebhookResult, error)
}

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

type IntegrationConfig inconfig.Integration

type IntegrationPlugin struct {
	plugin.Plugin
	Impl Integration
}

type IntegrationServer struct {
	Impl Integration
	// contains filtered or unexported fields
}

type MutateResult struct {
	MutatedObjects MutatedObjects
	WebappResponse interface{}
	Error          string
	ErrorCode      string
}

type MutatedObjects map[string][]interface{}

type OnboardExportResult struct {
	Error error
	Data  interface{}
}

type OnboardExportType string

type ValidationResult struct {
	Errors        []string `json:"errors"`
	RepoURL       string   `json:"repo"`
	ServerVersion string   `json:"server_version"`
}

type WebhookResult struct {
	MutatedObjects MutatedObjects
	Error          string
}