sync-github/gropius.sync.github/GithubSync

GithubSync

@Component

class GithubSync(val githubDataService: GithubDataService, val issuePileService: IssuePileService, val helper: JsonHelper, val cursorResourceWalkerDataService: CursorResourceWalkerDataService, val imsConfigManager: IMSConfigManager, collectedSyncInfo: CollectedSyncInfo, val loadBalancedDataFetcher: LoadBalancedDataFetcher = LoadBalancedDataFetcher()) : AbstractSync, LoadBalancedDataFetcherImplementation, DataFetcher

This class is responsible for syncing data from and to GitHub

Parameters

githubDataService

The service used to access the database

issuePileService

The service used to access the issue pile

helper

The helper used to convert data to and from JSON

cursorResourceWalkerDataService

The service used to access the cursor resource walker data

imsConfigManager

The manager used to access the IMS config

collectedSyncInfo

The collected sync info

loadBalancedDataFetcher

The load balanced data fetcher

Constructors

GithubSync

constructor(githubDataService: GithubDataService, issuePileService: IssuePileService, helper: JsonHelper, cursorResourceWalkerDataService: CursorResourceWalkerDataService, imsConfigManager: IMSConfigManager, collectedSyncInfo: CollectedSyncInfo, loadBalancedDataFetcher: LoadBalancedDataFetcher = LoadBalancedDataFetcher())

Properties

collectedSyncInfo

val collectedSyncInfo: CollectedSyncInfo

cursorResourceWalkerDataService

val cursorResourceWalkerDataService: CursorResourceWalkerDataService

githubDataService

val githubDataService: GithubDataService

helper

val helper: JsonHelper

imsConfigManager

val imsConfigManager: IMSConfigManager

issueDereplicator

val issueDereplicator: IssueDereplicator

issuePileService

val issuePileService: IssuePileService

loadBalancedDataFetcher

val loadBalancedDataFetcher: LoadBalancedDataFetcher

logger

private val logger: Logger?

Logger used to print notifications

Functions

balancedFetchData

open suspend override fun balancedFetchData(imsProject: IMSProject, generalBudget: GeneralResourceWalkerBudget): List<ResourceWalker>

createBudget

open suspend override fun createBudget(): GeneralResourceWalkerBudget

createOutgoingIssue

open suspend override fun createOutgoingIssue(imsProject: IMSProject, issue: Issue): IssueConversionInformation?

doIncoming

private suspend fun doIncoming(imsProject: IMSProject)

doOutgoing

open suspend fun doOutgoing(imsProject: IMSProject)

fetchData

open suspend override fun fetchData(imsProjects: List<IMSProject>)

findFinalBlock

private inline suspend fun <T, BT : TimelineItem> findFinalBlock(relevantTimeline: List<BT>, searchLambda: suspend (BT) -> T): List<BT>

findFinalTypeBlock

private suspend fun findFinalTypeBlock(relevantTimeline: List<TimelineItem>): List<TimelineItem>

findTemplates

open suspend override fun findTemplates(): Set<IMSTemplate>

findUnsyncedIssues

open suspend override fun findUnsyncedIssues(imsProject: IMSProject): List<IncomingIssue>

gropiusUserList

suspend fun gropiusUserList(users: List<User>): List<GropiusUser>

integrateLabelToState

private suspend fun integrateLabelToState(timelineItems: MutableList<TimelineItem>, rawTimelineItems: List<TimelineItem>, issue: Issue, imsProject: IMSProject)

integrateLabelToStateAddedLabel

private suspend fun integrateLabelToStateAddedLabel(timelineItems: MutableList<TimelineItem>, issue: Issue, imsProject: IMSProject, timelineItem: AddedLabelEvent, lastState: IssueState, mappedStates: List<IssueState>)

integrateLabelToStateFindCurrentState

private suspend fun integrateLabelToStateFindCurrentState(issue: Issue, timelineItem: TimelineItem): Pair<Set<Label>, IssueState>

integrateLabelToStateRemovedLabel

private suspend fun integrateLabelToStateRemovedLabel(timelineItems: MutableList<TimelineItem>, issue: Issue, imsProject: IMSProject, timelineItem: RemovedLabelEvent, lastState: IssueState, mappedStates: List<IssueState>)

isOutgoingAssignmentsEnabled

open suspend override fun isOutgoingAssignmentsEnabled(imsProject: IMSProject): Boolean

isOutgoingCommentsEnabled

open suspend override fun isOutgoingCommentsEnabled(imsProject: IMSProject): Boolean

isOutgoingEnabled

open suspend override fun isOutgoingEnabled(imsProject: IMSProject): Boolean

isOutgoingLabelsEnabled

open suspend override fun isOutgoingLabelsEnabled(imsProject: IMSProject): Boolean

isOutgoingStatesEnabled

open suspend override fun isOutgoingStatesEnabled(imsProject: IMSProject): Boolean

isOutgoingTemplatedFieldsEnabled

open suspend override fun isOutgoingTemplatedFieldsEnabled(imsProject: IMSProject): Boolean

isOutgoingTitleChangedEnabled

open suspend override fun isOutgoingTitleChangedEnabled(imsProject: IMSProject): Boolean

labelStateMap

open suspend override fun labelStateMap(imsProject: IMSProject): Map<String, String>

lookupState

private suspend fun lookupState(id: String?): IssueState?

shouldSyncType

private inline suspend fun <AddingItem : TimelineItem, RemovingItem : TimelineItem> shouldSyncType(imsProject: IMSProject, finalBlock: List<TimelineItem>, relevantTimeline: List<TimelineItem>, restoresDefaultState: Boolean, virtualIDs: Map<TimelineItem, String>): Boolean

private suspend fun shouldSyncType(imsProject: IMSProject, isAddingItem: suspend (TimelineItem) -> Boolean, isRemovingItem: suspend (TimelineItem) -> Boolean, finalBlock: List<TimelineItem>, relevantTimeline: List<TimelineItem>, restoresDefaultState: Boolean, virtualIDs: Map<TimelineItem, String>): Boolean

sync

suspend fun sync()

syncAddedLabel

open suspend override fun syncAddedLabel(imsProject: IMSProject, issueId: String, label: Label, users: List<User>): TimelineItemConversionInformation?

syncComment

open suspend override fun syncComment(imsProject: IMSProject, issueId: String, issueComment: IssueComment, users: List<User>): TimelineItemConversionInformation?

syncDataService

open override fun syncDataService(): SyncDataService

syncFallbackComment

open suspend override fun syncFallbackComment(imsProject: IMSProject, issueId: String, comment: String, original: TimelineItem?, users: List<User>): TimelineItemConversionInformation?

syncIncomingIssue

private suspend fun syncIncomingIssue(oldImsProject: IMSProject, incomingIssue: IncomingIssue, dereplicatorRequest: SimpleIssueDereplicatorRequest)

syncIncomingTimelineItem

private suspend fun syncIncomingTimelineItem(imsProject: IMSProject, timelineItem: IncomingTimelineItem, issue: Issue, dereplicatorRequest: SimpleIssueDereplicatorRequest, nodesToSave: MutableList<Node>, savedNodeHandlers: MutableList<suspend (node: Node) -> Unit>)

syncOutgoingAssignments

private suspend fun syncOutgoingAssignments(timeline: List<TimelineItem>, imsProject: IMSProject, issueInfo: IssueConversionInformation)

syncOutgoingComments

private suspend fun syncOutgoingComments(timeline: List<TimelineItem>, imsProject: IMSProject, issueInfo: IssueConversionInformation)

syncOutgoingLabels

private suspend fun syncOutgoingLabels(timeline: List<TimelineItem>, imsProject: IMSProject, issueInfo: IssueConversionInformation)

syncOutgoingSingleAssignment

private suspend fun syncOutgoingSingleAssignment(relevantTimeline: List<TimelineItem>, imsProject: IMSProject, issueInfo: IssueConversionInformation, assignment: Assignment, virtualIDs: Map<TimelineItem, String>)

syncOutgoingSingleAssignmentBlock

private suspend fun syncOutgoingSingleAssignmentBlock(relevantTimeline: List<TimelineItem>, imsProject: IMSProject, issueInfo: IssueConversionInformation, assignment: Assignment, virtualIDs: Map<TimelineItem, String>, finalBlock: List<TimelineItem>)

syncOutgoingSingleLabel

private suspend fun syncOutgoingSingleLabel(relevantTimeline: List<TimelineItem>, imsProject: IMSProject, issueInfo: IssueConversionInformation, label: Label?, virtualIDs: Map<TimelineItem, String>)

syncOutgoingStateChanges

private suspend fun syncOutgoingStateChanges(timeline: List<TimelineItem>, imsProject: IMSProject, issueInfo: IssueConversionInformation)

syncOutgoingTemplatedFields

private suspend fun syncOutgoingTemplatedFields(timeline: List<TimelineItem>, imsProject: IMSProject, issueInfo: IssueConversionInformation)

syncOutgoingTitleChanges

private suspend fun syncOutgoingTitleChanges(timeline: List<TimelineItem>, imsProject: IMSProject, issueInfo: IssueConversionInformation)

syncRemovedLabel

open suspend override fun syncRemovedLabel(imsProject: IMSProject, issueId: String, label: Label, users: List<User>): TimelineItemConversionInformation?

syncSingleAssigned

open suspend override fun syncSingleAssigned(imsProject: IMSProject, issueId: String, assignment: Assignment, users: List<User>): TimelineItemConversionInformation?

syncSingleUnassigned

open suspend override fun syncSingleUnassigned(imsProject: IMSProject, issueId: String, assignment: Assignment, users: List<User>): TimelineItemConversionInformation?

syncStateChange

open suspend override fun syncStateChange(imsProject: IMSProject, issueId: String, newState: IssueState, users: List<User>): TimelineItemConversionInformation?

syncTemplatedField

open suspend fun syncTemplatedField(imsProject: IMSProject, issueId: String, fieldChangedEvent: TemplatedFieldChangedEvent, users: List<User>): TimelineItemConversionInformation?

syncTitleChange

open suspend override fun syncTitleChange(imsProject: IMSProject, issueId: String, newTitle: String, users: List<User>): TimelineItemConversionInformation?

GithubSync ​

Parameters

Constructors

Properties

Functions

GithubSync