This repository has been archived by the owner on Dec 15, 2022. It is now read-only.
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
6 changed files
with
253 additions
and
17 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,245 @@ | ||
| import {cloneRepository, buildRepositoryWithPipeline} from './helpers'; | ||
| import {GitError} from '../lib/git-shell-out-strategy'; | ||
|
|
||
|
|
||
| describe('getRepoPipelineManager()', function() { | ||
|
|
||
| let atomEnv, workspace, notificationManager, repo, pipelineManager, confirm; | ||
|
|
||
| const getPipeline = (pm, actionName) => { | ||
| const actionKey = pm.actionKeys[actionName]; | ||
| return pm.getPipeline(actionKey); | ||
| }; | ||
|
|
||
| const buildRepo = (workdir, override = {}) => { | ||
| const option = { | ||
| confirm, | ||
| notificationManager, | ||
| workspace, | ||
| ...override, | ||
| }; | ||
| return buildRepositoryWithPipeline(workdir, option); | ||
| }; | ||
|
|
||
| const gitErrorStub = (stdErr = '', stdOut = '') => { | ||
| return sinon.stub().throws(() => { | ||
| const err = new GitError(); | ||
| err.stdErr = stdErr; | ||
| err.stdOut = stdOut; | ||
| return err; | ||
| }); | ||
| }; | ||
|
|
||
| beforeEach(async function() { | ||
| atomEnv = global.buildAtomEnvironment(); | ||
| workspace = atomEnv.workspace; | ||
| notificationManager = atomEnv.notifications; | ||
| confirm = sinon.stub(atomEnv, 'confirm'); | ||
|
|
||
| const workdir = await cloneRepository('multiple-commits'); | ||
| repo = await buildRepo(workdir); | ||
| pipelineManager = repo.pipelineManager; | ||
| }); | ||
|
|
||
| afterEach(function() { | ||
| atomEnv.destroy(); | ||
| }); | ||
|
|
||
| it('has all the action pipelines', function() { | ||
| const expectedActions = ['PUSH', 'PULL', 'FETCH', 'COMMIT', 'CHECKOUT', 'ADDREMOTE']; | ||
| for (const actionName of expectedActions) { | ||
| assert.ok(getPipeline(pipelineManager, actionName)); | ||
| } | ||
| }); | ||
|
|
||
| describe('PUSH pipeline', function() { | ||
|
|
||
| it('confirm-force-push', function() { | ||
| it('before confirming', function() { | ||
| const pushPipeline = getPipeline(pipelineManager, 'PUSH'); | ||
| const pushStub = sinon.stub(); | ||
| sinon.spy(notificationManager, 'addError'); | ||
| pushPipeline.run(pushStub, repo, '', {force: true}); | ||
| assert.isTrue(confirm.calledWith({ | ||
| message: 'Are you sure you want to force push?', | ||
| detailedMessage: 'This operation could result in losing data on the remote.', | ||
| buttons: ['Force Push', 'Cancel'], | ||
| })); | ||
| assert.isTrue(pushStub.called()); | ||
| }); | ||
|
|
||
| it('after confirming', async function() { | ||
| const nWorkdir = await cloneRepository('multiple-commits'); | ||
| const confirmStub = sinon.stub(atomEnv, 'confirm').return(0); | ||
| const nRepo = buildRepo(nWorkdir, {confirm: confirmStub}); | ||
| const pushPipeline = getPipeline(nRepo.pipelineManager, 'PUSH'); | ||
| const pushStub = sinon.stub(); | ||
| sinon.spy(notificationManager, 'addError'); | ||
|
|
||
| pushPipeline.run(pushStub, repo, '', {force: true}); | ||
| assert.isFalse(confirm.called); | ||
| assert.isFalse(pushStub.called); | ||
| }); | ||
| }); | ||
|
|
||
| it('set-push-in-progress', async function() { | ||
| const pushPipeline = getPipeline(pipelineManager, 'PUSH'); | ||
| const pushStub = sinon.stub().callsFake(() => { | ||
| assert.isTrue(repo.getOperationStates().isPushInProgress()); | ||
| return Promise.resolve(); | ||
| }); | ||
| pushPipeline.run(pushStub, repo, '', {}); | ||
| assert.isTrue(pushStub.called); | ||
| await assert.async.isFalse(repo.getOperationStates().isPushInProgress()); | ||
| }); | ||
|
|
||
| it('failed-to-push-error', function() { | ||
| const pushPipeline = getPipeline(pipelineManager, 'PUSH'); | ||
| sinon.spy(notificationManager, 'addError'); | ||
|
|
||
|
|
||
| pushPipeline.run(gitErrorStub('rejected failed to push'), repo, '', {}); | ||
| assert.isTrue(notificationManager.addError.calledWithMatch('Push rejected', {dismissable: true})); | ||
|
|
||
| pushPipeline.run(gitErrorStub('something else'), repo, '', {}); | ||
| assert.isTrue(notificationManager.addError.calledWithMatch('Unable to push', {dismissable: true})); | ||
| }); | ||
| }); | ||
|
|
||
| describe('PULL pipeline', function() { | ||
| it('set-pull-in-progress', async function() { | ||
| const pull = getPipeline(pipelineManager, 'PULL'); | ||
| const pullStub = sinon.stub().callsFake(() => { | ||
| assert.isTrue(repo.getOperationStates().isPullInProgress()); | ||
| return Promise.resolve(); | ||
| }); | ||
| pull.run(pullStub, repo, '', {}); | ||
| assert.isTrue(pullStub.called); | ||
| await assert.async.isFalse(repo.getOperationStates().isPullInProgress()); | ||
| }); | ||
|
|
||
| it('failed-to-pull-error', function() { | ||
| const pullPipeline = getPipeline(pipelineManager, 'PULL'); | ||
| sinon.spy(notificationManager, 'addError'); | ||
| sinon.spy(notificationManager, 'addWarning'); | ||
|
|
||
| pullPipeline.run(gitErrorStub('error: Your local changes to the following files would be overwritten by merge'), repo, '', {}); | ||
| assert.isTrue(notificationManager.addError.calledWithMatch('Pull aborted', {dismissable: true})); | ||
|
|
||
| pullPipeline.run(gitErrorStub('', 'Automatic merge failed; fix conflicts and then commit the result.'), repo, '', {}); | ||
| // console.log(notificationManager.addError.args) | ||
| assert.isTrue(notificationManager.addWarning.calledWithMatch('Merge conflicts', {dismissable: true})); | ||
|
|
||
| pullPipeline.run(gitErrorStub('fatal: Not possible to fast-forward, aborting.'), repo, '', {}); | ||
| assert.isTrue(notificationManager.addWarning.calledWithMatch('Unmerged changes', {dismissable: true})); | ||
|
|
||
| pullPipeline.run(gitErrorStub('something else'), repo, '', {}); | ||
| assert.isTrue(notificationManager.addError.calledWithMatch('Unable to pull', {dismissable: true})); | ||
| }); | ||
| }); | ||
|
|
||
| describe('FETCH pipeline', function() { | ||
| let fetchPipeline; | ||
|
|
||
| beforeEach(function() { | ||
| fetchPipeline = getPipeline(pipelineManager, 'FETCH'); | ||
| }); | ||
|
|
||
| it('set-fetch-in-progress', async function() { | ||
| const fetchStub = sinon.stub().callsFake(() => { | ||
| assert.isTrue(repo.getOperationStates().isFetchInProgress()); | ||
| return Promise.resolve(); | ||
| }); | ||
| fetchPipeline.run(fetchStub, repo, '', {}); | ||
| assert.isTrue(fetchStub.called); | ||
| await assert.async.isFalse(repo.getOperationStates().isFetchInProgress()); | ||
| }); | ||
|
|
||
| it('failed-to-fetch-error', function() { | ||
| sinon.spy(notificationManager, 'addError'); | ||
|
|
||
| fetchPipeline.run(gitErrorStub('this is a nice error msg'), repo, '', {}); | ||
| assert.isTrue(notificationManager.addError.calledWithMatch('Unable to fetch', { | ||
| detail: 'this is a nice error msg', | ||
| dismissable: true, | ||
| })); | ||
| }); | ||
| }); | ||
|
|
||
| describe('CHECKOUT pipeline', function() { | ||
| let checkoutPipeline; | ||
|
|
||
| beforeEach(function() { | ||
| checkoutPipeline = getPipeline(pipelineManager, 'CHECKOUT'); | ||
| }); | ||
|
|
||
| it('set-checkout-in-progress', async function() { | ||
| const checkoutStub = sinon.stub().callsFake(() => { | ||
| assert.isTrue(repo.getOperationStates().isCheckoutInProgress()); | ||
| return Promise.resolve(); | ||
| }); | ||
| checkoutPipeline.run(checkoutStub, repo, '', {}); | ||
| assert.isTrue(checkoutStub.called); | ||
| await assert.async.isFalse(repo.getOperationStates().isCheckoutInProgress()); | ||
| }); | ||
|
|
||
| it('failed-to-checkout-error', function() { | ||
| sinon.spy(notificationManager, 'addError'); | ||
|
|
||
| checkoutPipeline.run(gitErrorStub('local changes would be overwritten'), repo, '', {createNew: false}); | ||
| assert.isTrue(notificationManager.addError.calledWithMatch('Checkout aborted', {dismissable: true})); | ||
|
|
||
| checkoutPipeline.run(gitErrorStub('branch x already exists'), repo, '', {createNew: false}); | ||
| assert.isTrue(notificationManager.addError.calledWithMatch('Checkout aborted', {dismissable: true})); | ||
|
|
||
| checkoutPipeline.run(gitErrorStub('error: you need to resolve your current index first'), repo, '', {createNew: false}); | ||
| assert.isTrue(notificationManager.addError.calledWithMatch('Checkout aborted', {dismissable: true})); | ||
|
|
||
| checkoutPipeline.run(gitErrorStub('something else'), repo, '', {createNew: true}); | ||
| assert.isTrue(notificationManager.addError.calledWithMatch('Cannot create branch', {detail: 'something else', dismissable: true})); | ||
| }); | ||
| }); | ||
|
|
||
| describe('COMMIT pipeline', function() { | ||
| let commitPipeline; | ||
|
|
||
| beforeEach(function() { | ||
| commitPipeline = getPipeline(pipelineManager, 'COMMIT'); | ||
| }); | ||
|
|
||
| // it('confirm-commit', function() { | ||
| // | ||
| // }); | ||
| // | ||
| // it('clean-up-disk-commit-msg', function() { | ||
| // | ||
| // }); | ||
|
|
||
| it('set-commit-in-progress', async function() { | ||
| const commitStub = sinon.stub().callsFake(() => { | ||
| assert.isTrue(repo.getOperationStates().isCommitInProgress()); | ||
| return Promise.resolve(); | ||
| }); | ||
| commitPipeline.run(commitStub, repo, '', {}); | ||
| assert.isTrue(commitStub.called); | ||
| await assert.async.isFalse(repo.getOperationStates().isCommitInProgress()); | ||
| }); | ||
|
|
||
| it('failed-to-commit-error', function() { | ||
| sinon.spy(notificationManager, 'addError'); | ||
|
|
||
| commitPipeline.run(gitErrorStub('a nice msg'), repo, '', {}); | ||
| assert.isTrue(notificationManager.addError.calledWithMatch('Unable to commit', {detail: 'a nice msg', dismissable: true})); | ||
| }); | ||
| }); | ||
|
|
||
| describe('ADDREMOTE pipeline', function() { | ||
| it('failed-to-add-remote', function() { | ||
| const addRemotePipeline = getPipeline(pipelineManager, 'ADDREMOTE'); | ||
| sinon.spy(notificationManager, 'addError'); | ||
|
|
||
| addRemotePipeline.run(gitErrorStub('fatal: remote XXX already exists'), repo, '', {}); | ||
| assert.isTrue(notificationManager.addError.calledWithMatch('Cannot create remote', {dismissable: true})); | ||
| }); | ||
| }); | ||
| }); |