| /** |
| * @license |
| * Copyright 2018 Google LLC |
| * SPDX-License-Identifier: Apache-2.0 |
| */ |
| import '../../shared/gr-comment-thread/gr-comment-thread'; |
| import '../../checks/gr-diff-check-result'; |
| import '../../../embed/diff/gr-diff/gr-diff'; |
| import { |
| anyLineTooLong, |
| getDiffLength, |
| isImageDiff, |
| SYNTAX_MAX_LINE_LENGTH, |
| } from '../../../utils/diff-util'; |
| import {getAppContext} from '../../../services/app-context'; |
| import { |
| getParentIndex, |
| isAParent, |
| isMergeParent, |
| isNumber, |
| } from '../../../utils/patch-set-util'; |
| import { |
| createNew, |
| isInBaseOfPatchRange, |
| isInRevisionOfPatchRange, |
| } from '../../../utils/comment-util'; |
| import {CoverageRange, DiffLayer, PatchSetFile} from '../../../types/types'; |
| import { |
| Base64ImageFile, |
| BlameInfo, |
| ChangeInfo, |
| CommentThread, |
| DraftInfo, |
| EDIT, |
| NumericChangeId, |
| PARENT, |
| PatchRange, |
| PatchSetNum, |
| RepoName, |
| RevisionPatchSetNum, |
| } from '../../../types/common'; |
| import { |
| DiffInfo, |
| DiffPreferencesInfo, |
| IgnoreWhitespaceType, |
| WebLinkInfo, |
| } from '../../../types/diff'; |
| import {GrDiff} from '../../../embed/diff/gr-diff/gr-diff'; |
| import {DiffViewMode, Side, CommentSide} from '../../../constants/constants'; |
| import {FilesWebLinks} from '../gr-patch-range-select/gr-patch-range-select'; |
| import {KnownExperimentId} from '../../../services/flags/flags'; |
| import { |
| firePageError, |
| fireAlert, |
| fireServerError, |
| fire, |
| waitForEventOnce, |
| } from '../../../utils/event-util'; |
| import {assertIsDefined} from '../../../utils/common-util'; |
| import {TokenHighlightLayer} from '../../../embed/diff/gr-diff-builder/token-highlight-layer'; |
| import {Timing} from '../../../constants/reporting'; |
| import {ChangeComments} from '../gr-comment-api/gr-comment-api'; |
| import {Subscription} from 'rxjs'; |
| import { |
| CreateCommentEventDetail, |
| DiffContextExpandedExternalDetail, |
| DisplayLine, |
| FILE, |
| LineNumber, |
| LineSelectedEventDetail, |
| LOST, |
| RenderPreferences, |
| } from '../../../api/diff'; |
| import {resolve} from '../../../models/dependency'; |
| import {browserModelToken} from '../../../models/browser/browser-model'; |
| import {commentsModelToken} from '../../../models/comments/comments-model'; |
| import {checksModelToken, RunResult} from '../../../models/checks/checks-model'; |
| import {distinctUntilChanged, map} from 'rxjs/operators'; |
| import {deepEqual} from '../../../utils/deep-util'; |
| import {Category} from '../../../api/checks'; |
| import {GrSyntaxLayerWorker} from '../../../embed/diff/gr-syntax-layer/gr-syntax-layer-worker'; |
| import { |
| CODE_MAX_LINES, |
| highlightServiceToken, |
| } from '../../../services/highlight/highlight-service'; |
| import {html, LitElement, PropertyValues} from 'lit'; |
| import {customElement, property, query, state} from 'lit/decorators.js'; |
| import {ValueChangedEvent} from '../../../types/events'; |
| import { |
| debounceP, |
| DelayedPromise, |
| DELAYED_CANCELLATION, |
| noAwait, |
| } from '../../../utils/async-util'; |
| import {subscribe} from '../../lit/subscription-controller'; |
| import {userModelToken} from '../../../models/user/user-model'; |
| import {pluginLoaderToken} from '../../shared/gr-js-api-interface/gr-plugin-loader'; |
| import {keyed} from 'lit/directives/keyed.js'; |
| import {repeat} from 'lit/directives/repeat.js'; |
| import {ifDefined} from 'lit/directives/if-defined.js'; |
| import {Shortcut} from '../../lit/shortcut-controller'; |
| import {shortcutsServiceToken} from '../../../services/shortcuts/shortcuts-service'; |
| |
| const EMPTY_BLAME = 'No blame information for this diff.'; |
| |
| const EVENT_AGAINST_PARENT = 'diff-against-parent'; |
| const EVENT_ZERO_REBASE = 'rebase-percent-zero'; |
| const EVENT_NONZERO_REBASE = 'rebase-percent-nonzero'; |
| |
| // visible for testing |
| export interface LineInfo { |
| beforeNumber?: LineNumber; |
| afterNumber?: LineNumber; |
| } |
| |
| declare global { |
| interface HTMLElementEventMap { |
| // prettier-ignore |
| 'render': CustomEvent<{}>; |
| 'create-comment': CustomEvent<CreateCommentEventDetail>; |
| 'is-blame-loaded-changed': ValueChangedEvent<boolean>; |
| 'diff-changed': ValueChangedEvent<DiffInfo | undefined>; |
| 'edit-weblinks-changed': ValueChangedEvent<WebLinkInfo[] | undefined>; |
| 'files-weblinks-changed': ValueChangedEvent<FilesWebLinks | undefined>; |
| 'is-image-diff-changed': ValueChangedEvent<boolean>; |
| // Fired when the user selects a line (See gr-diff). |
| 'line-selected': CustomEvent<LineSelectedEventDetail>; |
| // Fired if being logged in is required. |
| 'show-auth-required': CustomEvent<{}>; |
| 'reload-diff': CustomEvent<{path: string | undefined}>; |
| } |
| } |
| |
| /** |
| * Wrapper around gr-diff. |
| * |
| * Webcomponent fetching diffs and related data from restAPI and passing them |
| * to the presentational gr-diff for rendering. <gr-diff-host> is a Gerrit |
| * specific component, while <gr-diff> is a re-usable component. |
| */ |
| @customElement('gr-diff-host') |
| export class GrDiffHost extends LitElement { |
| @query('#diff') |
| diffElement?: GrDiff; |
| |
| @property({type: Number}) |
| changeNum?: NumericChangeId; |
| |
| @property({type: Object}) |
| change?: ChangeInfo; |
| |
| @property({type: Boolean}) |
| noAutoRender = false; |
| |
| @property({type: Object}) |
| patchRange?: PatchRange; |
| |
| @property({type: Object}) |
| file?: PatchSetFile; |
| |
| @property({type: String}) |
| path?: string; |
| |
| @property({type: Object}) |
| prefs?: DiffPreferencesInfo; |
| |
| @property({type: String}) |
| projectName?: RepoName; |
| |
| @state() |
| private _editWeblinks?: WebLinkInfo[]; |
| |
| get editWeblinks() { |
| return this._editWeblinks; |
| } |
| |
| set editWeblinks(editWeblinks: WebLinkInfo[] | undefined) { |
| if (this._editWeblinks === editWeblinks) return; |
| this._editWeblinks = editWeblinks; |
| fire(this, 'edit-weblinks-changed', {value: editWeblinks}); |
| } |
| |
| @state() |
| private _filesWeblinks?: FilesWebLinks; |
| |
| get filesWeblinks() { |
| return this._filesWeblinks; |
| } |
| |
| set filesWeblinks(filesWeblinks: FilesWebLinks | undefined) { |
| if (this._filesWeblinks === filesWeblinks) return; |
| this._filesWeblinks = filesWeblinks; |
| fire(this, 'files-weblinks-changed', {value: filesWeblinks}); |
| } |
| |
| @property({type: Boolean, reflect: true}) |
| override hidden = false; |
| |
| @property({type: Boolean}) |
| noRenderOnPrefsChange = false; |
| |
| @state() |
| threads: CommentThread[] = []; |
| |
| @state() |
| checks: RunResult[] = []; |
| |
| @property({type: Boolean}) |
| lineWrapping = false; |
| |
| @property({type: Object}) |
| lineOfInterest?: DisplayLine; |
| |
| @property({type: String}) |
| viewMode = DiffViewMode.SIDE_BY_SIDE; |
| |
| @property({type: Boolean}) |
| showLoadFailure?: boolean; |
| |
| @state() |
| private loggedIn = false; |
| |
| // Private but used in tests. |
| @state() |
| errorMessage: string | null = null; |
| |
| @state() |
| private baseImage?: Base64ImageFile; |
| |
| @state() |
| private revisionImage?: Base64ImageFile; |
| |
| private readonly getShortcutsService = resolve(this, shortcutsServiceToken); |
| |
| // Do not use, use diff instead through the getters and setters. |
| // This is not a regular @state because we need to also send the |
| // 'diff-changed' event when it is changed. And if we rely on @state |
| // then the name to look for in willUpdate/update/updated is '_diff'. |
| private _diff?: DiffInfo; |
| |
| get diff() { |
| return this._diff; |
| } |
| |
| set diff(diff: DiffInfo | undefined) { |
| if (this._diff === diff) return; |
| const oldDiff = this._diff; |
| this._diff = diff; |
| fire(this, 'diff-changed', {value: this._diff}); |
| this.requestUpdate('diff', oldDiff); |
| } |
| |
| @state() |
| private changeComments?: ChangeComments; |
| |
| @state() |
| private fetchDiffPromise: Promise<DiffInfo> | null = null; |
| |
| // Do not use, use blame instead through the getters and setters. This is not |
| // a regular @state because we need to also send the |
| // 'is-blame-loading-changed' event when it is changed. And if we rely on |
| // @state then the name to look for in willUpdate/update/updated is '_blame'. |
| private _blame: BlameInfo[] | null = null; |
| |
| @state() |
| get blame() { |
| return this._blame; |
| } |
| |
| set blame(blame: BlameInfo[] | null) { |
| if (this._blame === blame) return; |
| const oldBlame = this._blame; |
| this._blame = blame; |
| fire(this, 'is-blame-loaded-changed', {value: !!this._blame}); |
| this.requestUpdate('blame', oldBlame); |
| } |
| |
| @state() |
| private coverageRanges: CoverageRange[] = []; |
| |
| @state() |
| private loadedWhitespaceLevel?: IgnoreWhitespaceType; |
| |
| @state() |
| private layers: DiffLayer[] = []; |
| |
| @state() |
| private renderPrefs: RenderPreferences = { |
| num_lines_rendered_at_once: 128, |
| }; |
| |
| // Debounces across multiple reload calls and ensures that waiters can |
| // wait on it whenever a reload is requested. If more than one reload is |
| // requested within a given time-frame, the first one is canceled but will |
| // still be resolved when the second one is resolved. (and inductively, any |
| // further ones that were requested within a animation-frame). |
| private reloadPromise?: DelayedPromise<void>; |
| |
| private readonly getBrowserModel = resolve(this, browserModelToken); |
| |
| private readonly getCommentsModel = resolve(this, commentsModelToken); |
| |
| private readonly getChecksModel = resolve(this, checksModelToken); |
| |
| private readonly getPluginLoader = resolve(this, pluginLoaderToken); |
| |
| // visible for testing |
| readonly reporting = getAppContext().reportingService; |
| |
| private readonly flags = getAppContext().flagsService; |
| |
| private readonly restApiService = getAppContext().restApiService; |
| |
| // visible for testing |
| readonly getUserModel = resolve(this, userModelToken); |
| |
| // visible for testing |
| readonly syntaxLayer: GrSyntaxLayerWorker; |
| |
| private checksSubscription?: Subscription; |
| |
| /** |
| * This key is used for the `keyed()` directive when rendering `gr-diff` and |
| * can thus be used to trigger re-construction of `gr-diff`. |
| */ |
| private grDiffKey = 0; |
| |
| constructor() { |
| super(); |
| this.syntaxLayer = new GrSyntaxLayerWorker( |
| resolve(this, highlightServiceToken), |
| () => getAppContext().reportingService |
| ); |
| this.addEventListener( |
| // These are named inconsistently for a reason: |
| // The create-comment event is fired to indicate that we should |
| // create a comment. |
| // The comment-* events are just notifying that the comments did already |
| // change in some way, and that we should update any models we may want |
| // to keep in sync. |
| 'create-comment', |
| e => this.handleCreateThread(e) |
| ); |
| this.addEventListener('diff-context-expanded', event => |
| this.handleDiffContextExpanded(event) |
| ); |
| this.addEventListener('reload-diff', (e: CustomEvent) => { |
| if (e.detail.path === this.path) { |
| this.reload(false); |
| } |
| }); |
| subscribe( |
| this, |
| () => this.getBrowserModel().diffViewMode$, |
| diffView => (this.viewMode = diffView) |
| ); |
| subscribe( |
| this, |
| () => this.getUserModel().loggedIn$, |
| loggedIn => (this.loggedIn = loggedIn) |
| ); |
| subscribe( |
| this, |
| () => this.getCommentsModel().changeComments$, |
| changeComments => { |
| this.changeComments = changeComments; |
| } |
| ); |
| subscribe( |
| this, |
| () => this.getUserModel().diffPreferences$, |
| diffPreferences => { |
| this.prefs = diffPreferences; |
| } |
| ); |
| } |
| |
| override connectedCallback() { |
| super.connectedCallback(); |
| this.subscribeToChecks(); |
| this.getPluginLoader().jsApiService.handleShowDiff({ |
| change: this.change!, |
| fileRange: this.file!, |
| patchRange: this.patchRange!, |
| }); |
| } |
| |
| override disconnectedCallback() { |
| if (this.reloadPromise) { |
| this.reloadPromise.cancel(); |
| this.reloadPromise = undefined; |
| } |
| if (this.checksSubscription) { |
| this.checksSubscription.unsubscribe(); |
| this.checksSubscription = undefined; |
| } |
| this.clear(); |
| super.disconnectedCallback(); |
| } |
| |
| protected override willUpdate(changedProperties: PropertyValues) { |
| // Important to call as this will call render, see LitElement. |
| super.willUpdate(changedProperties); |
| if ( |
| changedProperties.has('changeComments') || |
| changedProperties.has('patchRange') || |
| changedProperties.has('file') |
| ) { |
| this.threads = this.computeFileThreads( |
| this.changeComments, |
| this.patchRange, |
| this.file |
| ); |
| } |
| if ( |
| changedProperties.has('noRenderOnPrefsChange') || |
| changedProperties.has('prefs') || |
| changedProperties.has('path') || |
| changedProperties.has('changeNum') |
| ) { |
| this.syntaxHighlightingChanged( |
| this.noRenderOnPrefsChange, |
| changedProperties.get('prefs'), |
| this.prefs, |
| this.path, |
| this.changeNum |
| ); |
| } |
| if ( |
| changedProperties.has('prefs') || |
| changedProperties.has('loadedWhitespaceLevel') || |
| changedProperties.has('noRenderOnPrefsChange') || |
| changedProperties.has('path') || |
| changedProperties.has('changeNum') |
| ) { |
| this.whitespaceChanged( |
| this.prefs?.ignore_whitespace, |
| this.loadedWhitespaceLevel, |
| this.noRenderOnPrefsChange, |
| this.path, |
| this.changeNum |
| ); |
| } |
| } |
| |
| async waitForReloadToRender(): Promise<void> { |
| await this.updateComplete; |
| if (this.reloadPromise) { |
| try { |
| // If we are reloading, wait for the reload to finish and then ensure |
| // that any changes are captured in another update. |
| await this.reloadPromise; |
| } catch (e: unknown) { |
| // TODO: Consider moving this logic to a helper method. |
| if (e === DELAYED_CANCELLATION) { |
| // Do nothing. |
| } else if (e instanceof Error) { |
| this.reporting.error('GrDiffHost Reload:', e); |
| } else { |
| this.reporting.error( |
| 'GrDiffHost Reload:', |
| new Error('reloadPromise error'), |
| e |
| ); |
| } |
| } |
| await this.updateComplete; |
| } |
| } |
| |
| override render() { |
| const showNewlineWarningLeft = |
| this.hasTrailingNewlines(this.diff, true) === false; |
| const showNewlineWarningRight = |
| this.hasTrailingNewlines(this.diff, false) === false; |
| const useNewImageDiffUi = this.flags.isEnabled( |
| KnownExperimentId.NEW_IMAGE_DIFF_UI |
| ); |
| |
| return keyed( |
| this.grDiffKey, |
| html`<gr-diff |
| id="diff" |
| ?hidden=${this.hidden} |
| .noAutoRender=${this.noAutoRender} |
| .path=${this.path} |
| .prefs=${this.prefs} |
| .noRenderOnPrefsChange=${this.noRenderOnPrefsChange} |
| .renderPrefs=${this.renderPrefs} |
| .lineWrapping=${this.lineWrapping} |
| .viewMode=${this.viewMode} |
| .lineOfInterest=${this.lineOfInterest} |
| .loggedIn=${this.loggedIn} |
| .errorMessage=${this.errorMessage} |
| .baseImage=${this.baseImage} |
| .revisionImage=${this.revisionImage} |
| .coverageRanges=${this.coverageRanges} |
| .blame=${this.blame} |
| .layers=${this.layers} |
| .diff=${this.diff} |
| .showNewlineWarningLeft=${showNewlineWarningLeft} |
| .showNewlineWarningRight=${showNewlineWarningRight} |
| .useNewImageDiffUi=${useNewImageDiffUi} |
| .binaryDiffHint=${` Download commit to view (shortcut: |
| ${this.getShortcutsService().getShortcut( |
| Shortcut.OPEN_DOWNLOAD_DIALOG |
| )})`} |
| > |
| ${repeat( |
| this.threads, |
| t => t.rootId, |
| t => this.renderThread(t) |
| )} |
| ${repeat( |
| this.checks, |
| c => c.internalResultId, |
| c => this.renderCheck(c) |
| )} |
| </gr-diff>` |
| ); |
| } |
| |
| async initLayers() { |
| const preferencesPromise = this.restApiService.getPreferences(); |
| const prefs = await preferencesPromise; |
| const enableTokenHighlight = !prefs?.disable_token_highlighting; |
| |
| assertIsDefined(this.path, 'path'); |
| this.layers = this.getLayers(enableTokenHighlight); |
| this.coverageRanges = []; |
| // We kick off fetching the data here, but we don't return the promise, |
| // so awaiting initLayers() will not wait for coverage data to be |
| // completely loaded. |
| noAwait(this.getCoverageData()); |
| } |
| |
| /** |
| * @param shouldReportMetric indicate a new Diff Page. This is a |
| * signal to report metrics event that started on location change. |
| */ |
| reload(shouldReportMetric?: boolean): Promise<void> { |
| this.reloadPromise = debounceP( |
| this.reloadPromise, |
| async () => { |
| try { |
| await this.reloadInternal(shouldReportMetric); |
| return; |
| } catch (e: unknown) { |
| if (e instanceof Error) { |
| this.reporting.error('GrDiffHost Reload:', e); |
| } else { |
| this.reporting.error( |
| 'GrDiffHost Reload:', |
| new Error('reloadInternal error'), |
| e |
| ); |
| } |
| } finally { |
| this.reloadPromise = undefined; |
| } |
| }, |
| 0 |
| ); |
| return this.reloadPromise; |
| } |
| |
| async reloadInternal(shouldReportMetric?: boolean) { |
| this.reporting.time(Timing.DIFF_TOTAL); |
| this.reporting.time(Timing.DIFF_LOAD); |
| this.grDiffKey++; |
| // TODO: Find better names for these 3 clear/cancel methods. Ideally the |
| // <gr-diff-host> should not re-used at all for another diff rendering pass. |
| this.clear(); |
| assertIsDefined(this.path, 'path'); |
| assertIsDefined(this.changeNum, 'changeNum'); |
| this.diff = undefined; |
| this.errorMessage = null; |
| const whitespaceLevel = this.getIgnoreWhitespace(); |
| |
| try { |
| // We are carefully orchestrating operations that have to wait for another |
| // and operations that can be run in parallel. Plugins may provide layers, |
| // so we have to wait on plugins being loaded before we can initialize |
| // layers and proceed to rendering. OTOH we want to fetch diffs and diff |
| // assets in parallel. |
| const layerPromise = this.initLayers(); |
| const diff = await this.getDiff(); |
| this.loadedWhitespaceLevel = whitespaceLevel; |
| this.reportDiff(diff); |
| |
| await this.loadDiffAssets(diff); |
| // Only now we are awaiting layers (and plugin loading), which was kicked |
| // off above. |
| await layerPromise; |
| |
| // Not waiting for coverage ranges intentionally as |
| // plugin loading should not block the content rendering |
| |
| this.editWeblinks = this.getEditWeblinks(diff); |
| this.filesWeblinks = this.getFilesWeblinks(diff); |
| this.diff = diff; |
| this.reporting.timeEnd(Timing.DIFF_LOAD, this.timingDetails()); |
| |
| this.reporting.time(Timing.DIFF_CONTENT); |
| this.syntaxLayer.setEnabled(this.isSyntaxHighlightingEnabled()); |
| const syntaxLayerPromise = this.syntaxLayer.process(diff); |
| await waitForEventOnce(this, 'render'); |
| this.subscribeToChecks(); |
| this.reporting.timeEnd(Timing.DIFF_CONTENT, this.timingDetails()); |
| |
| if (shouldReportMetric) { |
| // We report diffViewContentDisplayed only on reload caused |
| // by params changed - expected only on Diff Page. |
| this.reporting.diffViewContentDisplayed(); |
| } |
| |
| this.reporting.time(Timing.DIFF_SYNTAX); |
| await syntaxLayerPromise; |
| this.reporting.timeEnd(Timing.DIFF_SYNTAX, this.timingDetails()); |
| } catch (e: unknown) { |
| if (e instanceof Response) { |
| this.handleGetDiffError(e); |
| } else if (e instanceof Error) { |
| this.reporting.error('GrDiffHost Reload:', e); |
| } else { |
| this.reporting.error( |
| 'GrDiffHost Reload:', |
| new Error('reload error'), |
| e |
| ); |
| } |
| } finally { |
| this.reporting.timeEnd(Timing.DIFF_TOTAL, this.timingDetails()); |
| } |
| } |
| |
| /** |
| * Produces an event detail object for reporting. |
| */ |
| private timingDetails() { |
| if (!this.diff) return {}; |
| const metaLines = |
| (this.diff.meta_a?.lines ?? 0) + (this.diff.meta_b?.lines ?? 0); |
| |
| let contentLines = 0; |
| let contentChanged = 0; |
| let contentUnchanged = 0; |
| for (const chunk of this.diff.content) { |
| const ab = chunk.ab?.length ?? 0; |
| const a = chunk.a?.length ?? 0; |
| const b = chunk.b?.length ?? 0; |
| contentLines += ab + ab + a + b; |
| contentChanged += a + b; |
| contentUnchanged += ab + ab; |
| } |
| return { |
| metaLines, |
| contentLines, |
| contentUnchanged, |
| contentChanged, |
| height: |
| this.diffElement?.shadowRoot?.querySelector('.diffContainer') |
| ?.clientHeight, |
| }; |
| } |
| |
| private getLayers(enableTokenHighlight: boolean): DiffLayer[] { |
| const layers = []; |
| if (enableTokenHighlight) { |
| layers.push( |
| new TokenHighlightLayer(this, highlight => { |
| for (const plugin of this.getPluginLoader().pluginsModel.getState() |
| .tokenHighlightPlugins) { |
| plugin.listener( |
| { |
| change: this.change!, |
| basePatchNum: this.patchRange!.basePatchNum, |
| patchNum: this.patchRange!.patchNum, |
| fileRange: this.file!, |
| path: this.path!, |
| diffElement: this.diffElement!, |
| }, |
| highlight |
| ); |
| } |
| }) |
| ); |
| } |
| layers.push(this.syntaxLayer); |
| return layers; |
| } |
| |
| clear() { |
| this.layers = []; |
| } |
| |
| /** |
| * This should be called when either `path` or `patchRange` has changed. |
| * We will then subscribe to the checks model and filter the relevant |
| * check results for this diff. Path and patchset must match, and a code |
| * pointer must be included. |
| */ |
| private subscribeToChecks() { |
| if (this.checksSubscription) { |
| this.checksSubscription.unsubscribe(); |
| this.checksSubscription = undefined; |
| this.checks = []; |
| } |
| |
| const path = this.path; |
| const patchNum = this.patchRange?.patchNum; |
| if (!path || !patchNum || patchNum === EDIT) return; |
| this.checksSubscription = this.getChecksModel() |
| .allResults$.pipe( |
| map(results => |
| results.filter(result => { |
| if (result.patchset !== patchNum) return false; |
| if (result.category === Category.SUCCESS) return false; |
| // Only one code pointer is supported. See API docs. |
| const pointer = result.codePointers?.[0]; |
| return pointer?.path === this.path && !!pointer?.range; |
| }) |
| ), |
| distinctUntilChanged(deepEqual) |
| ) |
| .subscribe(results => (this.checks = results)); |
| } |
| |
| private renderCheck(check: RunResult) { |
| const pointer = check.codePointers?.[0]; |
| assertIsDefined(pointer, 'code pointer of check result in diff'); |
| let pointerAttr: string | undefined = undefined; |
| if ( |
| pointer.range?.start_line > 0 && |
| pointer.range?.end_line > 0 && |
| pointer.range?.start_character >= 0 && |
| pointer.range?.end_character >= 0 |
| ) { |
| pointerAttr = `${JSON.stringify(pointer.range)}`; |
| } |
| const line: LineNumber = |
| pointer.range?.end_line || pointer.range?.start_line || FILE; |
| |
| return html` |
| <gr-diff-check-result |
| class="comment-thread" |
| .rootId=${check.internalResultId} |
| .result=${check} |
| slot=${`${Side.RIGHT}-${line}`} |
| diff-side=${Side.RIGHT} |
| line-num=${line} |
| range=${ifDefined(pointerAttr)} |
| ></gr-diff-check-result> |
| `; |
| } |
| |
| private async getCoverageData() { |
| assertIsDefined(this.changeNum, 'changeNum'); |
| assertIsDefined(this.change, 'change'); |
| assertIsDefined(this.path, 'path'); |
| assertIsDefined(this.patchRange, 'patchRange'); |
| const changeNum = this.changeNum; |
| const change = this.change; |
| const path = this.path; |
| // Coverage providers do not provide data for EDIT and PARENT patch sets. |
| |
| const toNumberOnly = (patchNum: PatchSetNum) => |
| isNumber(patchNum) ? patchNum : undefined; |
| |
| const basePatchNum = toNumberOnly(this.patchRange.basePatchNum); |
| const patchNum = toNumberOnly(this.patchRange.patchNum); |
| // We are simply waiting here for all plugins to be loaded. Ideally we would |
| // just react to state changes, but plugins are loaded quickly once at app |
| // startup, and coordinating incoming coverage providers with the reloading |
| // process seems to be complex enough to avoid it for the time being. |
| await this.getPluginLoader().awaitPluginsLoaded(); |
| const plugins = |
| this.getPluginLoader().pluginsModel.getState().coveragePlugins; |
| const providers = plugins.map(p => p.provider); |
| for (const provider of providers) { |
| try { |
| const coverageRanges = await provider( |
| changeNum, |
| path, |
| basePatchNum, |
| patchNum, |
| change |
| ); |
| assertIsDefined(this.patchRange, 'patchRange'); |
| if ( |
| !coverageRanges || |
| changeNum !== this.changeNum || |
| change !== this.change || |
| path !== this.path || |
| basePatchNum !== toNumberOnly(this.patchRange.basePatchNum) || |
| patchNum !== toNumberOnly(this.patchRange.patchNum) |
| ) { |
| continue; |
| } |
| this.coverageRanges = coverageRanges; |
| } catch (e) { |
| if (e instanceof Error) this.reporting.error('GrDiffHost Coverage', e); |
| } |
| } |
| } |
| |
| private computeFileThreads( |
| changeComments?: ChangeComments, |
| patchRange?: PatchRange, |
| file?: PatchSetFile |
| ) { |
| if (!changeComments || !patchRange || !file) return this.threads; |
| return changeComments.getThreadsBySideForFile(file, patchRange); |
| } |
| |
| private getEditWeblinks(diff: DiffInfo) { |
| return diff?.edit_web_links ?? []; |
| } |
| |
| private getFilesWeblinks(diff: DiffInfo) { |
| return { |
| meta_a: diff?.meta_a?.web_links ?? [], |
| meta_b: diff?.meta_b?.web_links ?? [], |
| }; |
| } |
| |
| getCursorStops() { |
| assertIsDefined(this.diffElement); |
| return this.diffElement.getCursorStops(); |
| } |
| |
| isRangeSelected() { |
| assertIsDefined(this.diffElement); |
| return this.diffElement.isRangeSelected(); |
| } |
| |
| createRangeComment() { |
| assertIsDefined(this.diffElement); |
| this.diffElement.createRangeComment(); |
| } |
| |
| toggleLeftDiff() { |
| assertIsDefined(this.diffElement); |
| this.renderPrefs = { |
| ...this.renderPrefs, |
| hide_left_side: !this.renderPrefs.hide_left_side, |
| }; |
| } |
| |
| /** |
| * Load and display blame information for the base of the diff. |
| */ |
| loadBlame(): Promise<BlameInfo[]> { |
| assertIsDefined(this.changeNum, 'changeNum'); |
| assertIsDefined(this.patchRange, 'patchRange'); |
| assertIsDefined(this.path, 'path'); |
| return this.restApiService |
| .getBlame(this.changeNum, this.patchRange.patchNum, this.path, true) |
| .then(blame => { |
| if (!blame || !blame.length) { |
| fireAlert(this, EMPTY_BLAME); |
| return Promise.reject(EMPTY_BLAME); |
| } |
| |
| this.blame = blame; |
| return blame; |
| }); |
| } |
| |
| clearBlame() { |
| this.blame = null; |
| } |
| |
| toggleAllContext() { |
| assertIsDefined(this.diffElement); |
| this.diffElement.toggleAllContext(); |
| } |
| |
| // TODO(milutin): Use rest-api with fetchCacheURL instead of this. |
| prefetchDiff() { |
| if ( |
| !!this.changeNum && |
| !!this.patchRange && |
| !!this.path && |
| this.fetchDiffPromise === null |
| ) { |
| this.fetchDiffPromise = this.getDiff(); |
| } |
| } |
| |
| // Private but used in tests. |
| getDiff(): Promise<DiffInfo> { |
| if (this.fetchDiffPromise !== null) { |
| const fetchDiffPromise = this.fetchDiffPromise; |
| this.fetchDiffPromise = null; |
| return fetchDiffPromise; |
| } |
| // Wrap the diff request in a new promise so that the error handler |
| // rejects the promise, allowing the error to be handled in the .catch. |
| return new Promise((resolve, reject) => { |
| assertIsDefined(this.changeNum, 'changeNum'); |
| assertIsDefined(this.patchRange, 'patchRange'); |
| assertIsDefined(this.path, 'path'); |
| this.restApiService |
| .getDiff( |
| this.changeNum, |
| this.patchRange.basePatchNum, |
| this.patchRange.patchNum, |
| this.path, |
| this.getIgnoreWhitespace(), |
| reject |
| ) |
| .then(diff => resolve(diff!)); // reject is called in case of error, so we can't get undefined here |
| }); |
| } |
| |
| // Private but used in tests. |
| handleGetDiffError(response: Response) { |
| // Loading the diff may respond with 409 if the file is too large. In this |
| // case, use a toast error.. |
| if (response.status === 409) { |
| fireServerError(response); |
| return; |
| } |
| |
| if (this.showLoadFailure) { |
| this.errorMessage = [ |
| 'Encountered error when loading the diff:', |
| response.status, |
| response.statusText, |
| ].join(' '); |
| return; |
| } |
| |
| firePageError(response); |
| } |
| |
| /** |
| * Report info about the diff response. |
| * |
| * Private but used in tests. |
| */ |
| reportDiff(diff?: DiffInfo) { |
| if (!diff || !diff.content) return; |
| |
| // Count the delta lines stemming from normal deltas, and from |
| // due_to_rebase deltas. |
| let nonRebaseDelta = 0; |
| let rebaseDelta = 0; |
| diff.content.forEach(chunk => { |
| if (chunk.ab) { |
| return; |
| } |
| const deltaSize = Math.max( |
| chunk.a ? chunk.a.length : 0, |
| chunk.b ? chunk.b.length : 0 |
| ); |
| if (chunk.due_to_rebase) { |
| rebaseDelta += deltaSize; |
| } else { |
| nonRebaseDelta += deltaSize; |
| } |
| }); |
| |
| // Find the percent of the delta from due_to_rebase chunks rounded to two |
| // digits. Diffs with no delta are considered 0%. |
| const totalDelta = rebaseDelta + nonRebaseDelta; |
| const percentRebaseDelta = !totalDelta |
| ? 0 |
| : Math.round((100 * rebaseDelta) / totalDelta); |
| |
| // Report the due_to_rebase percentage in the "diff" category when |
| // applicable. |
| assertIsDefined(this.patchRange, 'patchRange'); |
| if (this.patchRange.basePatchNum === PARENT) { |
| this.reporting.reportInteraction(EVENT_AGAINST_PARENT); |
| } else if (percentRebaseDelta === 0) { |
| this.reporting.reportInteraction(EVENT_ZERO_REBASE); |
| } else { |
| this.reporting.reportInteraction(EVENT_NONZERO_REBASE, { |
| percentRebaseDelta, |
| }); |
| } |
| } |
| |
| private loadDiffAssets(diff?: DiffInfo) { |
| if (isImageDiff(diff)) { |
| // diff! is justified, because isImageDiff() returns false otherwise |
| return this.getImages(diff!).then(images => { |
| this.baseImage = images.baseImage ?? undefined; |
| this.revisionImage = images.revisionImage ?? undefined; |
| }); |
| } else { |
| this.baseImage = undefined; |
| this.revisionImage = undefined; |
| return Promise.resolve(); |
| } |
| } |
| |
| private getImages(diff: DiffInfo) { |
| assertIsDefined(this.changeNum, 'changeNum'); |
| assertIsDefined(this.patchRange, 'patchRange'); |
| return this.restApiService.getImagesForDiff( |
| this.changeNum, |
| diff, |
| this.patchRange |
| ); |
| } |
| |
| handleCreateThread(e: CustomEvent<CreateCommentEventDetail>) { |
| if (!this.patchRange) throw Error('patch range not set'); |
| |
| const {lineNum, side, range} = e.detail; |
| |
| // Usually, the comment is stored on the patchset shown on the side the |
| // user added the comment on, and the commentSide will be REVISION. |
| // However, if the comment is added on the left side of the diff and the |
| // version shown there is not a patchset that is part the change, but |
| // instead a base (a PARENT or a merge parent commit), the comment is |
| // stored on the patchset shown on the right, and commentSide=PARENT |
| // indicates that the comment should still be shown on the left side. |
| const patchNum = |
| side === Side.LEFT && !isAParent(this.patchRange.basePatchNum) |
| ? this.patchRange.basePatchNum |
| : this.patchRange.patchNum; |
| const commentSide = |
| side === Side.LEFT && isAParent(this.patchRange.basePatchNum) |
| ? CommentSide.PARENT |
| : CommentSide.REVISION; |
| if (!this.canCommentOnPatchSetNum(patchNum)) return; |
| const path = |
| this.file?.basePath && |
| side === Side.LEFT && |
| commentSide === CommentSide.REVISION |
| ? this.file?.basePath |
| : this.path; |
| assertIsDefined(path, 'path'); |
| |
| const parentIndex = this.computeParentIndex(); |
| const draft: DraftInfo = { |
| ...createNew('', true), |
| patch_set: patchNum as RevisionPatchSetNum, |
| side: commentSide, |
| parent: parentIndex ?? undefined, |
| path, |
| line: typeof lineNum === 'number' ? lineNum : undefined, |
| range, |
| }; |
| this.getCommentsModel().addNewDraft(draft); |
| } |
| |
| private canCommentOnPatchSetNum(patchNum: PatchSetNum) { |
| if (!this.loggedIn) { |
| fire(this, 'show-auth-required', {}); |
| return false; |
| } |
| if (!this.patchRange) { |
| fireAlert(this, 'Cannot create comment. patchRange undefined.'); |
| return false; |
| } |
| |
| const isEdit = patchNum === EDIT; |
| const isEditBase = patchNum === PARENT && this.patchRange.patchNum === EDIT; |
| |
| if (isEdit) { |
| fireAlert(this, 'You cannot comment on an edit.'); |
| return false; |
| } |
| if (isEditBase) { |
| fireAlert(this, 'You cannot comment on the base patchset of an edit.'); |
| return false; |
| } |
| return true; |
| } |
| |
| private getDiffSide(thread: CommentThread) { |
| let diffSide: Side; |
| assertIsDefined(this.patchRange, 'patchRange'); |
| const commentProps = { |
| patch_set: thread.patchNum, |
| side: thread.commentSide, |
| parent: thread.mergeParentNum, |
| }; |
| if (isInBaseOfPatchRange(commentProps, this.patchRange)) { |
| diffSide = Side.LEFT; |
| } else if (isInRevisionOfPatchRange(commentProps, this.patchRange)) { |
| diffSide = Side.RIGHT; |
| } else { |
| const propsStr = JSON.stringify(commentProps); |
| const rangeStr = JSON.stringify(this.patchRange); |
| throw new Error(`comment ${propsStr} not in range ${rangeStr}`); |
| } |
| return diffSide; |
| } |
| |
| private renderThread(thread: CommentThread) { |
| const diffSide = this.getDiffSide(thread); |
| const rangeAttr = thread.range ? JSON.stringify(thread.range) : undefined; |
| return html` |
| <gr-comment-thread |
| class="comment-thread" |
| .rootId=${thread.rootId} |
| .thread=${thread} |
| .showPatchset=${false} |
| .showPortedComment=${!!thread.ported} |
| slot=${`${diffSide}-${thread.line || LOST}`} |
| diff-side=${diffSide} |
| line-num=${thread.line || LOST} |
| range=${ifDefined(rangeAttr)} |
| > |
| </gr-comment-thread> |
| `; |
| } |
| |
| private getIgnoreWhitespace(): IgnoreWhitespaceType { |
| if (!this.prefs || !this.prefs.ignore_whitespace) { |
| return 'IGNORE_NONE'; |
| } |
| return this.prefs.ignore_whitespace; |
| } |
| |
| private whitespaceChanged( |
| preferredWhitespaceLevel: IgnoreWhitespaceType | undefined, |
| loadedWhitespaceLevel: IgnoreWhitespaceType | undefined, |
| noRenderOnPrefsChange: boolean | undefined, |
| path: string | undefined, |
| changeNum: NumericChangeId | undefined |
| ): void | Promise<void> { |
| if (preferredWhitespaceLevel === undefined) return; |
| if (loadedWhitespaceLevel === undefined) return; |
| if (noRenderOnPrefsChange === undefined) return; |
| if (path === undefined) return; |
| if (changeNum === undefined) return; |
| |
| this.fetchDiffPromise = null; |
| if ( |
| preferredWhitespaceLevel !== loadedWhitespaceLevel && |
| !noRenderOnPrefsChange |
| ) { |
| return this.reload(); |
| } |
| } |
| |
| private syntaxHighlightingChanged( |
| noRenderOnPrefsChange: boolean | undefined, |
| oldPrefs: DiffPreferencesInfo | undefined, |
| prefs: DiffPreferencesInfo | undefined, |
| path: string | undefined, |
| changeNum: NumericChangeId | undefined |
| ): void | Promise<void> { |
| if (noRenderOnPrefsChange === undefined) return; |
| if (prefs === undefined) return; |
| if (path === undefined) return; |
| if (changeNum === undefined) return; |
| if (oldPrefs?.syntax_highlighting === prefs.syntax_highlighting) return; |
| |
| if (!noRenderOnPrefsChange) { |
| return this.reload(); |
| } |
| } |
| |
| private computeParentIndex() { |
| if (!this.patchRange) return null; |
| return isMergeParent(this.patchRange.basePatchNum) |
| ? getParentIndex(this.patchRange.basePatchNum) |
| : null; |
| } |
| |
| private isSyntaxHighlightingEnabled() { |
| if (!this.prefs?.syntax_highlighting || !this.diff) { |
| return false; |
| } |
| if (anyLineTooLong(this.diff)) { |
| fireAlert( |
| this, |
| `Files with line longer than ${SYNTAX_MAX_LINE_LENGTH} characters` + |
| ' will not be syntax highlighted.' |
| ); |
| return false; |
| } |
| assertIsDefined(this.diffElement); |
| if (getDiffLength(this.diff) > CODE_MAX_LINES) { |
| fireAlert( |
| this, |
| `Files with more than ${CODE_MAX_LINES} lines` + |
| ' will not be syntax highlighted.' |
| ); |
| return false; |
| } |
| return true; |
| } |
| |
| private handleDiffContextExpanded( |
| e: CustomEvent<DiffContextExpandedExternalDetail> |
| ) { |
| this.reporting.reportInteraction('diff-context-expanded', { |
| numLines: e.detail.numLines, |
| }); |
| } |
| |
| /** |
| * Find the last chunk for the given side. |
| * |
| * @param leftSide true if checking the base of the diff, |
| * false if testing the revision. |
| * @return returns the chunk object or null if there was |
| * no chunk for that side. |
| * |
| * Private but used in tests. |
| */ |
| lastChunkForSide(diff: DiffInfo | undefined, leftSide: boolean) { |
| if (!diff?.content.length) { |
| return null; |
| } |
| |
| let chunkIndex = diff.content.length; |
| let chunk; |
| |
| // Walk backwards until we find a chunk for the given side. |
| do { |
| chunkIndex--; |
| chunk = diff.content[chunkIndex]; |
| } while ( |
| // We haven't reached the beginning. |
| chunkIndex >= 0 && |
| // The chunk doesn't have both sides. |
| !chunk.ab && |
| // The chunk doesn't have the given side. |
| ((leftSide && (!chunk.a || !chunk.a.length)) || |
| (!leftSide && (!chunk.b || !chunk.b.length))) |
| ); |
| |
| // If we reached the beginning of the diff and failed to find a chunk |
| // with the given side, return null. |
| if (chunkIndex === -1) { |
| return null; |
| } |
| |
| return chunk; |
| } |
| |
| /** |
| * Check whether the specified side of the diff has a trailing newline. |
| * |
| * @param leftSide true if checking the base of the diff, |
| * false if testing the revision. |
| * @return Return true if the side has a trailing newline. |
| * Return false if it doesn't. Return null if not applicable (for |
| * example, if the diff has no content on the specified side). |
| * |
| * Private but used in tests. |
| */ |
| hasTrailingNewlines(diff: DiffInfo | undefined, leftSide: boolean) { |
| const chunk = this.lastChunkForSide(diff, leftSide); |
| if (!chunk) return null; |
| let lines; |
| if (chunk.ab) { |
| lines = chunk.ab; |
| } else { |
| lines = leftSide ? chunk.a : chunk.b; |
| } |
| if (!lines) return null; |
| return lines[lines.length - 1] === ''; |
| } |
| } |
| |
| declare global { |
| interface HTMLElementTagNameMap { |
| 'gr-diff-host': GrDiffHost; |
| } |
| } |