tasks

package
v0.0.0-...-1fa52ee Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 3, 2024 License: Apache-2.0, BSD-2-Clause, ISC, + 1 more Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source 
const RAW_PULL_REQUEST_ACTIVITIES_TABLE = "bitbucket_server_api_pull_request_activities"
View Source 
const RAW_PULL_REQUEST_COMMITS_TABLE = "bitbucket_server_api_pull_request_commits"
View Source 
const RAW_PULL_REQUEST_TABLE = "bitbucket_server_api_pull_requests"
View Source 
const RAW_REPOSITORIES_TABLE = "bitbucket_server_api_repositories"
View Source 
const RAW_USER_TABLE = "bitbucket_server_api_users"

Variables

View Source 
var CollectApiPrActivitiesMeta = plugin.SubTaskMeta{
	Name:             "collectApiPullRequestsActivities",
	EntryPoint:       CollectApiPullRequestsActivities,
	EnabledByDefault: true,
	Required:         false,
	Description:      "Collect pull requests activities data from Bitbucket Server api",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CODE_REVIEW},
	ProductTables:    []string{RAW_PULL_REQUEST_ACTIVITIES_TABLE},
}
View Source 
var CollectApiPrCommitsMeta = plugin.SubTaskMeta{
	Name:             "collectApiPullRequestCommits",
	EntryPoint:       CollectApiPullRequestCommits,
	EnabledByDefault: true,
	Description:      "Collect PullRequestCommits data from Bitbucket Server api",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CODE_REVIEW},
	ProductTables:    []string{RAW_PULL_REQUEST_COMMITS_TABLE},
}
View Source 
var CollectApiPullRequestsMeta = plugin.SubTaskMeta{
	Name:             "collectApiPullRequests",
	EntryPoint:       CollectApiPullRequests,
	EnabledByDefault: true,
	Required:         false,
	Description:      "Collect PullRequests data from Bitbucket Server api",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CODE_REVIEW},
	ProductTables:    []string{RAW_PULL_REQUEST_TABLE},
}
View Source 
var ConvertPrCommentsMeta = plugin.SubTaskMeta{
	Name:             "convertPullRequestComments",
	EntryPoint:       ConvertPullRequestComments,
	EnabledByDefault: true,
	Description:      "ConvertPullRequestComments data from Bitbucket api",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CODE_REVIEW},
}
View Source 
var ConvertPrCommitsMeta = plugin.SubTaskMeta{
	Name:             "convertPullRequestCommits",
	EntryPoint:       ConvertPullRequestCommits,
	EnabledByDefault: true,
	Description:      "Convert tool layer table bitbucket_server_pull_request_commits into  domain layer table pull_request_commits",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CODE_REVIEW},
}
View Source 
var ConvertPullRequestsMeta = plugin.SubTaskMeta{
	Name:             "convertPullRequests",
	EntryPoint:       ConvertPullRequests,
	EnabledByDefault: true,
	Required:         false,
	Description:      "ConvertPullRequests data from Bitbucket api",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CODE_REVIEW},
}
View Source 
var ConvertRepoMeta = plugin.SubTaskMeta{
	Name:             "convertRepo",
	EntryPoint:       ConvertRepo,
	EnabledByDefault: true,
	Description:      "Convert tool layer table bitbucket_server_repos into  domain layer table repos and boards",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CODE},
}
View Source 
var ConvertUsersMeta = plugin.SubTaskMeta{
	Name:             "convertUsers",
	EntryPoint:       ConvertUsers,
	EnabledByDefault: true,
	Required:         false,
	Description:      "Convert tool layer table bitbucket_users into domain layer table users",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CROSS},
}
View Source 
var ExtractApiPrActivitiesMeta = plugin.SubTaskMeta{
	Name:             "extractApiPullRequestsActivities",
	EntryPoint:       ExtractApiPullRequestActivities,
	EnabledByDefault: true,
	Required:         false,
	Description:      "Extract raw pull requests activity data into tool layer table(s)",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CODE_REVIEW},
}
View Source 
var ExtractApiPrCommitsMeta = plugin.SubTaskMeta{
	Name:             "extractApiPullRequestCommits",
	EntryPoint:       ExtractApiPullRequestCommits,
	EnabledByDefault: true,
	Description:      "Extract raw PullRequestCommits data into tool layer table bitbucket_commits",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CODE_REVIEW},
}
View Source 
var ExtractApiPullRequestsMeta = plugin.SubTaskMeta{
	Name:             "extractApiPullRequests",
	EntryPoint:       ExtractApiPullRequests,
	EnabledByDefault: true,
	Required:         false,
	Description:      "Extract raw PullRequests data into tool layer table bitbucket_pull_requests",
	DomainTypes:      []string{plugin.DOMAIN_TYPE_CODE_REVIEW},
}

Functions

func CollectApiPullRequestCommits 

func CollectApiPullRequestCommits(taskCtx plugin.SubTaskContext) errors.Error

func CollectApiPullRequests 

func CollectApiPullRequests(taskCtx plugin.SubTaskContext) errors.Error

func CollectApiPullRequestsActivities 

func CollectApiPullRequestsActivities(taskCtx plugin.SubTaskContext) errors.Error

func ConvertPullRequestComments 

func ConvertPullRequestComments(taskCtx plugin.SubTaskContext) errors.Error

func ConvertPullRequestCommits 

func ConvertPullRequestCommits(taskCtx plugin.SubTaskContext) (err errors.Error)

func ConvertPullRequests 

func ConvertPullRequests(taskCtx plugin.SubTaskContext) errors.Error

func ConvertRepo 

func ConvertRepo(taskCtx plugin.SubTaskContext) errors.Error

func ConvertUsers 

func ConvertUsers(taskCtx plugin.SubTaskContext) errors.Error

func CreateApiClient 

func CreateApiClient(taskCtx plugin.TaskContext, connection *models.BitbucketServerConnection) (*api.ApiAsyncClient, errors.Error)

func EncodeTaskOptions 

func EncodeTaskOptions(op *BitbucketServerOptions) (map[string]interface{}, errors.Error)

func ExtractApiPullRequestActivities 

func ExtractApiPullRequestActivities(taskCtx plugin.SubTaskContext) errors.Error

func ExtractApiPullRequestCommits 

func ExtractApiPullRequestCommits(taskCtx plugin.SubTaskContext) errors.Error

func ExtractApiPullRequests 

func ExtractApiPullRequests(taskCtx plugin.SubTaskContext) errors.Error

func GetApiRepo 

func GetApiRepo(
	op *BitbucketServerOptions,
	apiClient plugin.ApiClient,
) (*models.BitbucketServerApiRepo, errors.Error)

func GetNextPageCustomData 

func GetNextPageCustomData(_ *helper.RequestData, prevPageResponse *http.Response) (interface{}, errors.Error)

func GetPullRequestsIterator 

func GetPullRequestsIterator(taskCtx plugin.SubTaskContext, collectorWithState *helper.ApiCollectorStateManager) (*helper.DalCursorIterator, errors.Error)

func GetQueryForNextPage 

func GetQueryForNextPage(reqData *helper.RequestData) (url.Values, errors.Error)

func GetRawMessageFromResponse 

func GetRawMessageFromResponse(res *http.Response) ([]json.RawMessage, errors.Error)

func ValidateTaskOptions 

func ValidateTaskOptions(op *BitbucketServerOptions) errors.Error

Types

type ApiPrActivityResponse 

type ApiPrActivityResponse struct {
	BitbucketId int   `json:"id"`
	CreatedOn   int64 `json:"createdDate"`

	User *ApiUserResponse `json:"user"`

	Action string `json:"action"`

	CommentAction *string `json:"commentAction"`
	Comment       *struct {
		BitbucketId int    `json:"id"`
		Text        string `json:"text"`
		CreatedAt   int64  `json:"createdDate"`
		UpdatedAt   *int64 `json:"updatedDate"`
		Severity    string `json:"severity"`
		State       string `json:"state"`
	} `json:"comment"`

	Commit *struct {
		BitbucketId        string          `json:"id"`
		DisplayId          string          `json:"displayId"`
		Author             ApiUserResponse `json:"author"`
		Message            string          `json:"message"`
		AuthorTimestamp    int64           `json:"authorTimestamp"`
		CommitterTimestamp int64           `json:"committerTimestamp"`
		Parents            []struct {
			BitbucketID string `json:"id"`
			DisplayID   string `json:"displayId"`
		} `json:"parents"`
	} `json:"commit"`
}

type ApiPrCommitResponse 

type ApiPrCommitResponse struct {
	BitbucketId        string          `json:"id"`
	DisplayId          string          `json:"displayId"`
	Author             ApiUserResponse `json:"author"`
	Message            string          `json:"message"`
	AuthorTimestamp    int64           `json:"authorTimestamp"`
	CommitterTimestamp int64           `json:"committerTimestamp"`
}

type ApiPrResponse 

type ApiPrResponse struct {
	BitbucketId int `json:"id"`
	// Type        string `json:"type"`
	State       string `json:"state"`
	Title       string `json:"title"`
	Description string `json:"description"`
	MergeCommit *struct {
		Hash string `json:"hash"`
		// date only return when fields defined
		Date *common.Iso8601Time `json:"date"`
	} `json:"merge_commit"`
	Links *struct {
		Html struct {
			Href string `json:"href"`
		} `json:"html"`
	} `json:"links"`
	Author *struct {
		User *ApiUserResponse `json:"user"`
	} `json:"author"`
	BitbucketCreatedAt int64  `json:"createdDate"`
	BitbucketUpdatedAt int64  `json:"updatedDate"`
	BitbucketClosedAt  *int64 `json:"closedDate"`
	BaseRef            *struct {
		Branch string                         `json:"displayId"`
		Commit string                         `json:"latestCommit"`
		Repo   *models.BitbucketServerApiRepo `json:"repository"`
	} `json:"toRef"`
	HeadRef *struct {
		Branch string                         `json:"displayId"`
		Commit string                         `json:"latestCommit"`
		Repo   *models.BitbucketServerApiRepo `json:"repository"`
	} `json:"fromRef"`
	Properties *struct {
		ResolvedTaskCount int `json:"resolvedTaskCount"`
		CommentCount      int `json:"commentCount"`
		OpenTaskCount     int `json:"openTaskCount"`
	} `json:"properties"`
}

type ApiUserResponse 

type ApiUserResponse struct {
	BitbucketId  int    `json:"id"`
	Name         string `json:"name"`
	EmailAddress string `json:"emailAddress"`
	Active       bool   `json:"active"`
	DisplayName  string `json:"displayName"`
	Slug         string `json:"slug"`
	Type         string `json:"type"`
	Links        struct {
		Self []struct {
			Href string `json:"href"`
		} `json:"self"`
	} `json:"links"`
}

type BitbucketServerApiParams 

type BitbucketServerApiParams struct {
	ConnectionId uint64
	FullName     string
}

type BitbucketServerBranchInput 

type BitbucketServerBranchInput struct {
	Branch string
}

type BitbucketServerCommitInput 

type BitbucketServerCommitInput struct {
	CommitSha string
}

type BitbucketServerInput 

type BitbucketServerInput struct {
	BitbucketId int
}

type BitbucketServerOptions 

type BitbucketServerOptions struct {
	ConnectionId                       uint64   `json:"connectionId" mapstructure:"connectionId,omitempty"`
	Tasks                              []string `json:"tasks,omitempty" mapstructure:",omitempty"`
	FullName                           string   `json:"fullName" mapstructure:"fullName"`
	ScopeConfigId                      uint64   `json:"scopeConfigId" mapstructure:"scopeConfigId,omitempty"`
	*models.BitbucketServerScopeConfig `mapstructure:"scopeConfig,omitempty" json:"scopeConfig"`
}

func DecodeAndValidateTaskOptions 

func DecodeAndValidateTaskOptions(options map[string]interface{}) (*BitbucketServerOptions, errors.Error)

func DecodeTaskOptions 

func DecodeTaskOptions(options map[string]interface{}) (*BitbucketServerOptions, errors.Error)

type BitbucketServerTaskData 

type BitbucketServerTaskData struct {
	Options       *BitbucketServerOptions
	ApiClient     *api.ApiAsyncClient
	RegexEnricher *api.RegexEnricher
}

func CreateRawDataSubTaskArgs 

func CreateRawDataSubTaskArgs(taskCtx plugin.SubTaskContext, Table string) (*helper.RawDataSubTaskArgs, *BitbucketServerTaskData)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.