How to use buildPackage method in Cypress

Best JavaScript code snippet using cypress

teletype-package.test.js

Source:teletype-package.test.js Github

copy

Full Screen

...46 await atomEnvironments.destroyAtomEnvironments()47 })48 test('sharing and joining a portal', async function () {49 const hostEnv = buildAtomEnvironment()50 const hostPackage = await buildPackage(hostEnv)51 const guestEnv = buildAtomEnvironment()52 const guestPackage = await buildPackage(guestEnv)53 // Ensure we don't emit an add event more than once for a given guest editor54 const observedGuestItems = new Set()55 guestEnv.workspace.onDidAddPaneItem(({item}) => {56 assert(!observedGuestItems.has(item))57 observedGuestItems.add(item)58 })59 const portalId = (await hostPackage.sharePortal()).id60 guestPackage.joinPortal(portalId)61 const hostEditor1 = await hostEnv.workspace.open(temp.path({extension: '.js'}))62 hostEditor1.setText('const hello = "world"')63 hostEditor1.setCursorBufferPosition([0, 4])64 let guestEditor1 = await getNextActiveTextEditorPromise(guestEnv)65 assert.equal(guestEditor1.getText(), 'const hello = "world"')66 assert(!guestEditor1.isModified())67 await condition(() => deepEqual(getCursorDecoratedRanges(hostEditor1), getCursorDecoratedRanges(guestEditor1)))68 hostEditor1.setSelectedBufferRanges([69 [[0, 0], [0, 2]],70 [[0, 4], [0, 6]]71 ])72 guestEditor1.setSelectedBufferRanges([73 [[0, 1], [0, 3]],74 [[0, 5], [0, 7]]75 ])76 await condition(() => deepEqual(getCursorDecoratedRanges(hostEditor1), getCursorDecoratedRanges(guestEditor1)))77 await timeout(guestPackage.tetherDisconnectWindow)78 const hostEditor2 = await hostEnv.workspace.open(temp.path({extension: '.md'}))79 hostEditor2.setText('# Hello, World')80 hostEditor2.setCursorBufferPosition([0, 2])81 const guestEditor2 = await getNextActiveTextEditorPromise(guestEnv)82 assert.equal(guestEditor2.getText(), '# Hello, World')83 await condition(() => deepEqual(getCursorDecoratedRanges(hostEditor2), getCursorDecoratedRanges(guestEditor2)))84 hostEnv.workspace.paneForItem(hostEditor1).activateItem(hostEditor1)85 guestEditor1 = await getNextActiveTextEditorPromise(guestEnv)86 assert.equal(guestEditor1.getText(), 'const hello = "world"')87 assert(!guestEditor1.isModified())88 await condition(() => deepEqual(getCursorDecoratedRanges(hostEditor1), getCursorDecoratedRanges(guestEditor1)))89 assert.equal(observedGuestItems.size, 2)90 })91 suite('portal URIs', () => {92 function handleURI (pack, uri) {93 return pack.handleURI(url.parse(uri), uri)94 }95 test('opening URI for active portal', async () => {96 const hostEnv = buildAtomEnvironment()97 const hostPackage = await buildPackage(hostEnv)98 const guestEnv = buildAtomEnvironment({askBeforeJoiningPortalViaExternalApp: false})99 const guestPackage = await buildPackage(guestEnv)100 const hostPortal = await hostPackage.sharePortal()101 const uri = `atom://teletype/portal/${hostPortal.id}`102 await hostEnv.workspace.open()103 const guestPortal = await handleURI(guestPackage, uri)104 assert.equal(guestPortal.id, hostPortal.id)105 assert.equal(getRemotePaneItems(guestEnv).length, 1)106 })107 test('opening URI for nonexistent portal', async () => {108 const env = buildAtomEnvironment({askBeforeJoiningPortalViaExternalApp: false})109 const pack = await buildPackage(env)110 const notifications = []111 pack.notificationManager.onDidAddNotification((n) => notifications.push(n))112 const uri = 'atom://teletype/portal/00000000-0000-0000-0000-000000000000'113 const portal = await handleURI(pack, uri)114 assert(!portal)115 await condition(() => notifications.find((n) => n.message === 'Portal not found'))116 })117 test('opening URI for inaccessible portal', async () => {118 const hostEnv = buildAtomEnvironment()119 const hostPackage = await buildPackage(hostEnv)120 const TIMEOUT_IN_MILLISECONDS = 1121 const guestEnv = buildAtomEnvironment({askBeforeJoiningPortalViaExternalApp: false})122 const guestPackage = await buildPackage(guestEnv, {peerConnectionTimeout: TIMEOUT_IN_MILLISECONDS})123 const notifications = []124 guestPackage.notificationManager.onDidAddNotification((n) => notifications.push(n))125 const hostPortal = await hostPackage.sharePortal()126 const uri = `atom://teletype/portal/${hostPortal.id}`127 await hostPackage.closeHostPortal()128 const guestPortal = await handleURI(guestPackage, uri)129 assert(!guestPortal)130 await condition(() => notifications.find((n) => n.message === 'Failed to join portal'))131 })132 test('opening malformed URI', async () => {133 const env = buildAtomEnvironment({askBeforeJoiningPortalViaExternalApp: false})134 const pack = await buildPackage(env)135 const notifications = []136 pack.notificationManager.onDidAddNotification((n) => notifications.push(n))137 let portal = await handleURI(pack, 'atom://teletype/some-unsupported-uri')138 assert(!portal)139 await condition(() => notifications.find((n) => n.message === 'Failed to join portal'))140 notifications.length = 0141 portal = await handleURI(pack, 'atom://teletype/portal/42')142 assert(!portal)143 await condition(() => notifications.find((n) => n.message === 'Failed to join portal'))144 })145 test('opening URI when not signed in', async () => {146 const hostEnv = buildAtomEnvironment()147 const hostPackage = await buildPackage(hostEnv)148 const guestEnv = buildAtomEnvironment({askBeforeJoiningPortalViaExternalApp: false})149 const guestPackage = await buildPackage(guestEnv, {signIn: false})150 const hostPortal = await hostPackage.sharePortal()151 const uri = `atom://teletype/portal/${hostPortal.id}`152 await hostEnv.workspace.open()153 const guestPortal = await handleURI(guestPackage, uri)154 assert(!guestPortal)155 assert.equal(getRemotePaneItems(guestEnv).length, 0)156 })157 suite('prompting when opening URI', async () => {158 test('canceling prompt', async () => {159 const hostPackage = await buildPackage(buildAtomEnvironment())160 const hostPortal = await hostPackage.sharePortal()161 const guestEnv = buildAtomEnvironment()162 const guestPackage = await buildPackage(guestEnv)163 const guestPortalPromise = handleURI(guestPackage, getPortalURI(hostPortal.id))164 await condition(() => guestEnv.workspace.getModalPanels().length === 1)165 guestEnv.workspace.getModalPanels()[0].item.cancel()166 assert(!await guestPortalPromise)167 assert.equal(guestEnv.workspace.getModalPanels().length, 0)168 })169 test('allow joining once', async () => {170 const hostPackage1 = await buildPackage(buildAtomEnvironment())171 const hostPortal1 = await hostPackage1.sharePortal()172 const hostPackage2 = await buildPackage(buildAtomEnvironment())173 const hostPortal2 = await hostPackage2.sharePortal()174 const guestEnv = buildAtomEnvironment()175 const guestPackage = await buildPackage(guestEnv)176 const guestPortal1Promise = handleURI(guestPackage, getPortalURI(hostPortal1.id))177 await condition(() => guestEnv.workspace.getModalPanels().length === 1)178 guestEnv.workspace.getModalPanels()[0].item.confirmOnce()179 assert(await guestPortal1Promise)180 assert.equal(guestEnv.workspace.getModalPanels().length, 0)181 // Ensure dialog is shown again when joining another portal.182 handleURI(guestPackage, getPortalURI(hostPortal2.id))183 await condition(() => guestEnv.workspace.getModalPanels().length === 1)184 })185 test('allow joining always', async () => {186 const hostPackage1 = await buildPackage(buildAtomEnvironment())187 const hostPortal1 = await hostPackage1.sharePortal()188 const hostPackage2 = await buildPackage(buildAtomEnvironment())189 const hostPortal2 = await hostPackage2.sharePortal()190 const guestEnv = buildAtomEnvironment()191 const guestPackage = await buildPackage(guestEnv)192 const guestPortal1Promise = handleURI(guestPackage, getPortalURI(hostPortal1.id))193 await condition(() => guestEnv.workspace.getModalPanels().length === 1)194 guestEnv.workspace.getModalPanels()[0].item.confirmAlways()195 assert(await guestPortal1Promise)196 assert.equal(guestEnv.workspace.getModalPanels().length, 0)197 // Ensure dialog is NOT shown again when joining another portal.198 const guestPortal2Promise = handleURI(guestPackage, getPortalURI(hostPortal2.id))199 assert.equal(guestEnv.workspace.getModalPanels().length, 0)200 assert(await guestPortal2Promise)201 })202 })203 })204 suite('remote editor URIs', () => {205 test('opening URIs for editors that the guest has already seen', async () => {206 const hostEnv = buildAtomEnvironment()207 const hostPackage = await buildPackage(hostEnv)208 const guestEnv = buildAtomEnvironment()209 const guestPackage = await buildPackage(guestEnv)210 const portal = await hostPackage.sharePortal()211 await guestPackage.joinPortal(portal.id)212 const hostEditor = await hostEnv.workspace.open(path.join(temp.path(), 'a.md'))213 hostEditor.setText('some text')214 await hostEnv.workspace.open(path.join(temp.path(), 'b.txt'))215 await condition(() => getRemotePaneItems(guestEnv).length === 2)216 let guestEditor = guestEnv.workspace.getPaneItems()[0]217 const editorURI = guestEditor.getURI()218 guestEditor.destroy()219 guestEditor = await guestEnv.workspace.open(editorURI)220 assert(guestEditor.getTitle().endsWith('a.md'))221 assert.equal(guestEditor.getURI(), editorURI)222 assert.equal(guestEditor.getText(), 'some text')223 guestEditor.insertText('abc')224 await condition(() => hostEditor.getText() === guestEditor.getText())225 })226 test('opening URIs for editors that the guest has not yet seen', async () => {227 const hostEnv = buildAtomEnvironment()228 const hostPackage = await buildPackage(hostEnv)229 const guestEnv = buildAtomEnvironment()230 const guestPackage = await buildPackage(guestEnv)231 const portal = await hostPackage.sharePortal()232 const hostEditor = await hostEnv.workspace.open(path.join(temp.path(), 'a.md'))233 const hostEditorProxy = portal.activeEditorProxyForSiteId(1)234 const hostEditorURI = `atom://teletype/portal/${portal.id}/editor/${hostEditorProxy.id}`235 hostEditor.setText('some text')236 await hostEnv.workspace.open(path.join(temp.path(), 'b.txt'))237 guestPackage.joinPortal(portal.id)238 await condition(() => getRemotePaneItems(guestEnv).length === 1)239 const guestEditor = await guestEnv.workspace.open(hostEditorURI)240 assert(guestEditor.getTitle().endsWith('a.md'))241 assert.equal(guestEditor.getURI(), hostEditorURI)242 assert.equal(guestEditor.getText(), 'some text')243 guestEditor.insertText('abc')244 await condition(() => hostEditor.getText() === guestEditor.getText())245 })246 test('opening URIs for editors that do not exist in the portal', async () => {247 const hostEnv = buildAtomEnvironment()248 const hostPackage = await buildPackage(hostEnv)249 const guestEnv = buildAtomEnvironment()250 const guestPackage = await buildPackage(guestEnv)251 const portal = await hostPackage.sharePortal()252 await guestPackage.joinPortal(portal.id)253 const nonexistentEditorURI = `atom://teletype/portal/${portal.id}/editor/999`254 assert.equal(await guestEnv.workspace.open(nonexistentEditorURI), null)255 })256 test('opening URIs when not signed in', async () => {257 const hostEnv = buildAtomEnvironment()258 const hostPackage = await buildPackage(hostEnv)259 const guestEnv = buildAtomEnvironment()260 const guestPackage = await buildPackage(guestEnv, {signIn: false}) // eslint-disable-line no-unused-vars261 const portal = await hostPackage.sharePortal()262 await hostEnv.workspace.open()263 const hostEditorProxy = portal.activeEditorProxyForSiteId(1)264 const hostEditorURI = `atom://teletype/portal/${portal.id}/editor/${hostEditorProxy.id}`265 assert.equal(await guestEnv.workspace.open(hostEditorURI), null)266 })267 test('opening malformed URIs', async () => {268 const hostEnv = buildAtomEnvironment()269 const hostPackage = await buildPackage(hostEnv)270 const guestEnv = buildAtomEnvironment()271 const guestPackage = await buildPackage(guestEnv)272 const portal = await hostPackage.sharePortal()273 await guestPackage.joinPortal(portal.id)274 assert.equal(await guestEnv.workspace.open('atom://teletype/'), null)275 assert.equal(await guestEnv.workspace.open('atom://teletype///'), null)276 await hostEnv.workspace.open()277 const editorProxy = portal.activeEditorProxyForSiteId(1)278 assert.equal(279 await guestEnv.workspace.open(`atom://teletype/x/${portal.id}/y/${editorProxy.id}`),280 null281 )282 })283 })284 test('opening and closing multiple editors on the host', async function () {285 const hostEnv = buildAtomEnvironment()286 const hostPackage = await buildPackage(hostEnv)287 const guestEnv = buildAtomEnvironment()288 const guestPackage = await buildPackage(guestEnv)289 const portalId = (await hostPackage.sharePortal()).id290 guestPackage.joinPortal(portalId)291 const hostEditor1 = await hostEnv.workspace.open()292 const guestEditor1 = await getNextActiveTextEditorPromise(guestEnv)293 assert.equal(getPaneItems(guestEnv).length, 1)294 const hostEditor2 = await hostEnv.workspace.open()295 const guestEditor2 = await getNextActiveTextEditorPromise(guestEnv) // eslint-disable-line no-unused-vars296 assert.equal(getPaneItems(guestEnv).length, 2)297 hostEnv.workspace.paneForItem(hostEditor1).activateItem(hostEditor1)298 assert.equal(await getNextActiveTextEditorPromise(guestEnv), guestEditor1)299 assert.equal(getPaneItems(guestEnv).length, 2)300 hostEditor1.destroy()301 await condition(() => getPaneItems(guestEnv).length === 1)302 hostEditor2.destroy()303 await condition(() => getPaneItems(guestEnv).length === 0)304 await hostEnv.workspace.open()305 const guestEditor3 = await getNextRemotePaneItemPromise(guestEnv)306 assert(guestEditor3 instanceof TextEditor)307 assert.equal(getPaneItems(guestEnv).length, 1)308 })309 test('host joining another portal as a guest', async () => {310 const hostAndGuestEnv = buildAtomEnvironment()311 const hostAndGuestPackage = await buildPackage(hostAndGuestEnv)312 const guestOnlyEnv = buildAtomEnvironment()313 const guestOnlyPackage = await buildPackage(guestOnlyEnv)314 const hostOnlyEnv = buildAtomEnvironment()315 const hostOnlyPackage = await buildPackage(hostOnlyEnv)316 // Start out as a host sharing a portal with a guest (Portal 1)317 const portal1Id = (await hostAndGuestPackage.sharePortal()).id318 await guestOnlyPackage.joinPortal(portal1Id)319 const hostAndGuestLocalEditor = await hostAndGuestEnv.workspace.open(path.join(temp.path(), 'host+guest'))320 const guestOnlyRemotePaneItem1 = await getNextRemotePaneItemPromise(guestOnlyEnv)321 assert(guestOnlyRemotePaneItem1 instanceof TextEditor)322 assert.deepEqual(getPaneItems(guestOnlyEnv), [guestOnlyRemotePaneItem1])323 // While already hosting Portal 1, join Portal 2 as a guest324 const portal2Id = (await hostOnlyPackage.sharePortal()).id325 hostAndGuestPackage.joinPortal(portal2Id)326 hostOnlyEnv.workspace.open(path.join(temp.path(), 'host-only'))327 const hostAndGuestRemotePaneItem = await getNextRemotePaneItemPromise(hostAndGuestEnv)328 await condition(() => deepEqual(getPaneItems(hostAndGuestEnv), [hostAndGuestLocalEditor, hostAndGuestRemotePaneItem]))329 // No transitivity: When Portal 1 host is viewing contents of Portal 2, Portal 1 guests are placed on hold330 assert.equal(hostAndGuestEnv.workspace.getActivePaneItem(), hostAndGuestRemotePaneItem)331 await condition(() => deepEqual(getPaneItems(guestOnlyEnv), [guestOnlyRemotePaneItem1]))332 })333 test('guest sharing another portal as a host', async () => {334 const guestAndHostEnv = buildAtomEnvironment()335 const guestAndHostPackage = await buildPackage(guestAndHostEnv)336 const hostOnlyEnv = buildAtomEnvironment()337 const hostOnlyPackage = await buildPackage(hostOnlyEnv)338 const guestOnlyEnv = buildAtomEnvironment()339 const guestOnlyPackage = await buildPackage(guestOnlyEnv)340 // Start out as a guest in another user's portal (Portal 1)341 const portal1Id = (await hostOnlyPackage.sharePortal()).id342 const guestAndHostPortal1 = await guestAndHostPackage.joinPortal(portal1Id)343 hostOnlyEnv.workspace.open(path.join(temp.path(), 'host-only-buffer-1'))344 const guestAndHostRemotePaneItem1 = await getNextRemotePaneItemPromise(guestAndHostEnv)345 assert.deepEqual(getPaneItems(guestAndHostEnv), [guestAndHostRemotePaneItem1])346 // While already participating as a guest in Portal 1, share a new portal as a host (Portal 2)347 const guestAndHostLocalEditor1 = await guestAndHostEnv.workspace.open(path.join(temp.path(), 'host+guest-buffer-1'))348 assert.deepEqual(getPaneItems(guestAndHostEnv), [guestAndHostRemotePaneItem1, guestAndHostLocalEditor1])349 const portal2Id = (await guestAndHostPackage.sharePortal()).id350 guestOnlyPackage.joinPortal(portal2Id)351 const guestOnlyRemotePaneItem1 = await getNextRemotePaneItemPromise(guestOnlyEnv)352 assert(guestOnlyRemotePaneItem1 instanceof TextEditor)353 assert.deepEqual(getPaneItems(guestOnlyEnv), [guestOnlyRemotePaneItem1])354 guestAndHostPortal1.follow(1) // reconnect tether after disconnecting it due to opening a local editor.355 // Portal 2 host continues to exist as a guest in Portal 1356 hostOnlyEnv.workspace.open(path.join(temp.path(), 'host-only-buffer-2'))357 const guestAndHostRemotePaneItem2 = await getNextRemotePaneItemPromise(guestAndHostEnv)358 assert.deepEqual(getPaneItems(guestAndHostEnv), [guestAndHostRemotePaneItem1, guestAndHostRemotePaneItem2, guestAndHostLocalEditor1])359 assert.deepEqual(getPaneItems(guestOnlyEnv), [guestOnlyRemotePaneItem1])360 // No transitivity: When Portal 2 host is viewing contents of Portal 1, Portal 2 guests can only see contents of Portal 2361 guestAndHostEnv.workspace.getActivePane().activateItemAtIndex(0)362 assert.equal(guestAndHostEnv.workspace.getActivePaneItem(), guestAndHostRemotePaneItem1)363 assert.deepEqual(getPaneItems(guestOnlyEnv), [guestOnlyRemotePaneItem1])364 guestAndHostPortal1.follow(1) // reconnect tether after disconnecting it due to switching to a different editor.365 // As Portal 2 host observes changes in Portal 1, Portal 2 guests continue to only see contents of Portal 2366 await hostOnlyEnv.workspace.open(path.join(temp.path(), 'host-only-buffer-3'))367 const guestAndHostRemotePaneItem3 = await getNextRemotePaneItemPromise(guestAndHostEnv)368 assert.deepEqual(getPaneItems(guestAndHostEnv), [guestAndHostRemotePaneItem1, guestAndHostRemotePaneItem2, guestAndHostRemotePaneItem3, guestAndHostLocalEditor1])369 assert.deepEqual(getPaneItems(guestOnlyEnv), [guestOnlyRemotePaneItem1])370 // When Portal 2 host shares another local buffer, Portal 2 guests see that buffer371 await guestAndHostEnv.workspace.open(path.join(temp.path(), 'host+guest-buffer-2'))372 const guestOnlyRemotePaneItem2 = await getNextRemotePaneItemPromise(guestOnlyEnv)373 assert.deepEqual(getPaneItems(guestOnlyEnv), [guestOnlyRemotePaneItem1, guestOnlyRemotePaneItem2])374 })375 test('host attempting to share another portal', async () => {376 const hostPackage = await buildPackage(buildAtomEnvironment())377 const portal1Id = (await hostPackage.sharePortal()).id378 const portal2Id = (await hostPackage.sharePortal()).id379 assert.equal(portal1Id, portal2Id)380 await hostPackage.closeHostPortal()381 const portal3Id = (await hostPackage.sharePortal()).id382 assert.notEqual(portal3Id, portal1Id)383 })384 test('prompting for an auth token', async () => {385 testServer.identityProvider.setIdentitiesByToken({386 'invalid-token': null,387 'valid-token': {login: 'defunkt'}388 })389 const env = buildAtomEnvironment()390 // Ensure errors make the test fail instead of showing a notification.391 env.notifications.addError = (message) => { throw new Error(message) }392 const pack = await buildPackage(env, {signIn: false})393 await pack.consumeStatusBar(new FakeStatusBar())394 // Show popover when running the "Share Portal" command, but prevent sharing unless user is authenticated.395 assert(!pack.portalStatusBarIndicator.isPopoverVisible())396 assert(!await pack.sharePortal())397 assert(pack.portalStatusBarIndicator.isPopoverVisible())398 // Show popover when running the "Join Portal" command, but prevent sharing unless user is authenticated.399 pack.portalStatusBarIndicator.hidePopover()400 assert(!pack.portalStatusBarIndicator.isPopoverVisible())401 assert(!await pack.joinPortal('some-portal-id'))402 assert(pack.portalStatusBarIndicator.isPopoverVisible())403 const {popoverComponent} = pack.portalStatusBarIndicator404 assert(popoverComponent.refs.signInComponent)405 assert(!popoverComponent.refs.portalListComponent)406 // Enter an invalid token and wait for error message to appear.407 popoverComponent.refs.signInComponent.refs.editor.setText('invalid-token')408 popoverComponent.refs.signInComponent.signIn()409 await condition(() => (410 popoverComponent.refs.signInComponent.props.invalidToken &&411 popoverComponent.refs.signInComponent.refs.editor.getText() === '' &&412 popoverComponent.refs.signInComponent.refs.loginButton.disabled413 ))414 assert.equal(await pack.credentialCache.get('oauth-token'), null)415 assert(!env.workspace.element.classList.contains('teletype-Authenticated'))416 // Show portal list component after entering a valid token.417 popoverComponent.refs.signInComponent.refs.editor.setText('valid-token')418 popoverComponent.refs.signInComponent.signIn()419 await condition(() => (420 !popoverComponent.refs.signInComponent &&421 popoverComponent.refs.portalListComponent422 ))423 assert.equal(await pack.credentialCache.get('oauth-token'), 'valid-token')424 assert(env.workspace.element.classList.contains('teletype-Authenticated'))425 // Go back to sign in component after signing out.426 pack.portalStatusBarIndicator.hidePopover()427 pack.signOut()428 await condition(() => (429 popoverComponent.refs.signInComponent &&430 !popoverComponent.refs.portalListComponent431 ))432 assert(pack.portalStatusBarIndicator.isPopoverVisible())433 assert.equal(await pack.credentialCache.get('oauth-token'), null)434 assert(!env.workspace.element.classList.contains('teletype-Authenticated'))435 })436 test('prompting for a portal URL when joining', async () => {437 const pack = await buildPackage(buildAtomEnvironment())438 await pack.consumeStatusBar(new FakeStatusBar())439 assert(!pack.portalStatusBarIndicator.isPopoverVisible())440 await pack.joinPortal()441 assert(pack.portalStatusBarIndicator.isPopoverVisible())442 const {popoverComponent} = pack.portalStatusBarIndicator443 const {portalListComponent} = popoverComponent.refs444 const {joinPortalComponent} = portalListComponent.refs445 const {portalIdEditor} = joinPortalComponent.refs446 assert(portalIdEditor.element.contains(document.activeElement))447 })448 test('joining the same portal more than once', async () => {449 const host1Env = buildAtomEnvironment()450 const host1Package = await buildPackage(host1Env)451 const host2Env = buildAtomEnvironment()452 const host2Package = await buildPackage(host2Env)453 const guestEnv = buildAtomEnvironment()454 const guestPackage = await buildPackage(guestEnv)455 await host1Env.workspace.open(path.join(temp.path(), 'host-1'))456 const portal1 = await host1Package.sharePortal()457 await host2Env.workspace.open(path.join(temp.path(), 'host-2'))458 const portal2 = await host2Package.sharePortal()459 const guestEditor1Pane = guestEnv.workspace.getActivePane()460 guestPackage.joinPortal(portal1.id)461 guestPackage.joinPortal(portal1.id)462 const guestEditor1 = await getNextRemotePaneItemPromise(guestEnv)463 assert.deepEqual(getPaneItems(guestEnv), [guestEditor1])464 const guestEditor2Pane = guestEditor1Pane.splitRight()465 guestPackage.joinPortal(portal2.id)466 const guestEditor2 = await getNextRemotePaneItemPromise(guestEnv)467 assert.deepEqual(getPaneItems(guestEnv), [guestEditor1, guestEditor2])468 assert.equal(guestEnv.workspace.getActivePaneItem(), guestEditor2)469 assert.equal(guestEnv.workspace.getActivePane(), guestEditor2Pane)470 guestPackage.joinPortal(portal1.id)471 await condition(() => guestEnv.workspace.getActivePaneItem() === guestEditor1)472 assert.deepEqual(guestEnv.workspace.getPaneItems(), [guestEditor1, guestEditor2])473 })474 test('indicating portal status via status bar icon', async () => {475 const isTransmitting = function (statusBar) {476 return statusBar.getRightTiles()[0].item.element.classList.contains('transmitting')477 }478 const host1Env = buildAtomEnvironment()479 const host1Package = await buildPackage(host1Env)480 const host1StatusBar = new FakeStatusBar()481 await host1Package.consumeStatusBar(host1StatusBar)482 assert(!isTransmitting(host1StatusBar))483 const host1Portal = await host1Package.sharePortal()484 await host1Env.workspace.open()485 await condition(() => isTransmitting(host1StatusBar))486 const host2Env = buildAtomEnvironment()487 const host2Package = await buildPackage(host2Env)488 const host2Portal = await host2Package.sharePortal()489 await host2Env.workspace.open()490 const guestEnv = buildAtomEnvironment()491 const guestPackage = await buildPackage(guestEnv)492 const guestStatusBar = new FakeStatusBar()493 await guestPackage.consumeStatusBar(guestStatusBar)494 assert(!isTransmitting(guestStatusBar))495 guestPackage.joinPortal(host1Portal.id)496 await condition(() => isTransmitting(guestStatusBar))497 await guestPackage.joinPortal(host2Portal.id)498 assert(isTransmitting(guestStatusBar))499 await guestPackage.leavePortal()500 assert(isTransmitting(guestStatusBar))501 await guestPackage.leavePortal()502 await condition(() => !isTransmitting(guestStatusBar))503 await host1Package.closeHostPortal()504 await condition(() => !isTransmitting(host1StatusBar))505 })506 test('attempting to join a nonexistent portal', async () => {507 const pack = await buildPackage(buildAtomEnvironment())508 const notifications = []509 pack.notificationManager.onDidAddNotification((n) => notifications.push(n))510 await pack.joinPortal('some-nonexistent-portal-id')511 const errorNotification = notifications.find((n) => n.message === 'Portal not found')512 assert(errorNotification, 'Expected notifications to include "Portal not found" error')513 })514 suite('guest leaving portal', () => {515 test('via explicit leave action', async () => {516 const hostEnv = buildAtomEnvironment()517 const hostPackage = await buildPackage(hostEnv)518 const guestEnv = buildAtomEnvironment()519 const guestPackage = await buildPackage(guestEnv)520 const portal = await hostPackage.sharePortal()521 await guestPackage.joinPortal(portal.id)522 await hostEnv.workspace.open()523 await hostEnv.workspace.open()524 await hostEnv.workspace.open()525 await condition(() => getPaneItems(guestEnv).length === 3)526 await guestPackage.leavePortal()527 await condition(() => getPaneItems(guestEnv).length === 0)528 })529 })530 test('host closing portal', async function () {531 const hostEnv = buildAtomEnvironment()532 const hostPackage = await buildPackage(hostEnv)533 const guestEnv = buildAtomEnvironment()534 const guestPackage = await buildPackage(guestEnv)535 const hostPortal = await hostPackage.sharePortal()536 guestPackage.joinPortal(hostPortal.id)537 await hostEnv.workspace.open()538 await condition(() => getRemotePaneItems(guestEnv).length === 1)539 hostPackage.closeHostPortal()540 await condition(() => getRemotePaneItems(guestEnv).length === 0)541 })542 test('host losing connection', async function () {543 const hostEnv = buildAtomEnvironment()544 const hostPackage = await buildPackage(hostEnv)545 const hostPortal = await hostPackage.sharePortal()546 const guestEnv = buildAtomEnvironment()547 const guestPackage = await buildPackage(guestEnv)548 guestPackage.joinPortal(hostPortal.id)549 await hostEnv.workspace.open()550 await condition(() => getRemotePaneItems(guestEnv).length === 1)551 hostPortal.peerPool.disconnect()552 await condition(() => getRemotePaneItems(guestEnv).length === 0)553 })554 test('host disconnecting while there is an active shared editor', async function () {555 const hostEnv = buildAtomEnvironment()556 const hostPackage = await buildPackage(hostEnv)557 const guestEnv = buildAtomEnvironment()558 const guestPackage = await buildPackage(guestEnv)559 const hostPortal = await hostPackage.sharePortal()560 await guestPackage.joinPortal(hostPortal.id)561 await hostEnv.workspace.open()562 await getNextActiveTextEditorPromise(guestEnv)563 await hostEnv.workspace.open()564 await getNextActiveTextEditorPromise(guestEnv)565 hostPackage.closeHostPortal()566 await condition(() => getRemotePaneItems(guestEnv).length === 0)567 })568 test('peers undoing their own edits', async () => {569 const hostEnv = buildAtomEnvironment()570 const hostPackage = await buildPackage(hostEnv)571 const hostPortal = await hostPackage.sharePortal()572 const hostEditor = await hostEnv.workspace.open()573 const guestEnv = buildAtomEnvironment()574 const guestPackage = await buildPackage(guestEnv)575 guestPackage.joinPortal(hostPortal.id)576 const guestEditor = await getNextActiveTextEditorPromise(guestEnv)577 hostEditor.insertText('h1 ')578 await condition(() => guestEditor.getText() === 'h1 ')579 guestEditor.insertText('g1 ')580 await condition(() => hostEditor.getText() === 'h1 g1 ')581 hostEditor.insertText('h2 ')582 await condition(() => guestEditor.getText() === 'h1 g1 h2 ')583 guestEditor.insertText('g2')584 guestEditor.setTextInBufferRange([[0, 3], [0, 5]], 'g3')585 await condition(() => hostEditor.getText() === 'h1 g3 h2 g2')586 guestEditor.undo()587 assert.equal(guestEditor.getText(), 'h1 g1 h2 g2')588 await condition(() => hostEditor.getText() === 'h1 g1 h2 g2')589 hostEditor.undo()590 assert.equal(hostEditor.getText(), 'h1 g1 g2')591 await condition(() => guestEditor.getText() === 'h1 g1 g2')592 guestEditor.redo()593 assert.equal(guestEditor.getText(), 'h1 g3 g2')594 await condition(() => hostEditor.getText() === 'h1 g3 g2')595 hostEditor.redo()596 assert.equal(hostEditor.getText(), 'h1 g3 h2 g2')597 await condition(() => guestEditor.getText() === 'h1 g3 h2 g2')598 guestEditor.undo()599 assert.equal(guestEditor.getText(), 'h1 g1 h2 g2')600 await condition(() => hostEditor.getText() === 'h1 g1 h2 g2')601 guestEditor.undo()602 assert.equal(guestEditor.getText(), 'h1 g1 h2 ')603 await condition(() => hostEditor.getText() === 'h1 g1 h2 ')604 })605 test('preserving the history when sharing and closing a portal', async () => {606 const hostEnv = buildAtomEnvironment()607 const hostPackage = await buildPackage(hostEnv)608 const hostEditor = await hostEnv.workspace.open()609 hostEditor.insertText('h1 ')610 hostEditor.insertText('h2 ')611 hostEditor.insertText('h3 ')612 hostEditor.undo()613 hostEditor.undo()614 const hostPortal = await hostPackage.sharePortal()615 const guestEnv = buildAtomEnvironment()616 const guestPackage = await buildPackage(guestEnv)617 guestPackage.joinPortal(hostPortal.id)618 const guestEditor = await getNextActiveTextEditorPromise(guestEnv)619 await editorsEqual(guestEditor, hostEditor)620 hostEditor.redo()621 hostEditor.redo()622 assert.equal(hostEditor.getText(), 'h1 h2 h3 ')623 await editorsEqual(guestEditor, hostEditor)624 hostEditor.insertText('h4')625 assert.equal(hostEditor.getText(), 'h1 h2 h3 h4')626 hostEditor.undo()627 hostEditor.undo()628 assert.equal(hostEditor.getText(), 'h1 h2 ')629 await editorsEqual(guestEditor, hostEditor)630 await hostPackage.closeHostPortal()631 hostEditor.redo()632 hostEditor.redo()633 assert.equal(hostEditor.getText(), 'h1 h2 h3 h4')634 hostEditor.undo()635 hostEditor.undo()636 hostEditor.undo()637 assert.equal(hostEditor.getText(), 'h1 ')638 })639 test('undoing and redoing past the history boundaries', async () => {640 const hostEnv = buildAtomEnvironment()641 const hostPackage = await buildPackage(hostEnv)642 const hostPortal = await hostPackage.sharePortal()643 const hostBuffer = new TextBuffer('abcdefg')644 const hostEditor = new TextEditor({buffer: hostBuffer})645 await hostEnv.workspace.open(hostEditor)646 const guestEnv = buildAtomEnvironment()647 const guestPackage = await buildPackage(guestEnv)648 guestPackage.joinPortal(hostPortal.id)649 const guestEditor = await getNextActiveTextEditorPromise(guestEnv)650 hostEditor.undo()651 assert.equal(hostEditor.getText(), 'abcdefg')652 guestEditor.undo()653 assert.equal(guestEditor.getText(), 'abcdefg')654 guestEditor.redo()655 assert.equal(guestEditor.getText(), 'abcdefg')656 hostEditor.redo()657 assert.equal(hostEditor.getText(), 'abcdefg')658 })659 test('checkpoints', async () => {660 const hostEnv = buildAtomEnvironment()661 const hostPackage = await buildPackage(hostEnv)662 const hostEditor = await hostEnv.workspace.open()663 hostEditor.setText('abcdefg')664 const portal = await hostPackage.sharePortal()665 const guestEnv = buildAtomEnvironment()666 const guestPackage = await buildPackage(guestEnv)667 guestPackage.joinPortal(portal.id)668 const guestEditor = await getNextActiveTextEditorPromise(guestEnv)669 const checkpoint = hostEditor.createCheckpoint()670 hostEditor.setCursorBufferPosition([0, 7])671 hostEditor.insertText('h')672 hostEditor.insertText('i')673 hostEditor.insertText('j')674 assert.equal(hostEditor.getText(), 'abcdefghij')675 await editorsEqual(hostEditor, guestEditor)676 const changesSinceCheckpoint = hostEditor.getBuffer().getChangesSinceCheckpoint(checkpoint)677 assert.equal(changesSinceCheckpoint.length, 1)678 assert.deepEqual(changesSinceCheckpoint[0].oldRange, {start: {row: 0, column: 7}, end: {row: 0, column: 7}})679 assert.deepEqual(changesSinceCheckpoint[0].oldText, '')680 assert.deepEqual(changesSinceCheckpoint[0].newRange, {start: {row: 0, column: 7}, end: {row: 0, column: 10}})681 assert.deepEqual(changesSinceCheckpoint[0].newText, 'hij')682 hostEditor.revertToCheckpoint(checkpoint)683 assert.equal(hostEditor.getText(), 'abcdefg')684 await editorsEqual(hostEditor, guestEditor)685 })686 test('reloading a shared editor', async () => {687 const env = buildAtomEnvironment()688 const pack = await buildPackage(env)689 await pack.sharePortal()690 const filePath = path.join(temp.path(), 'standalone.js')691 const editor = await env.workspace.open(filePath)692 editor.setText('hello world!')693 await env.workspace.getActiveTextEditor().save()694 fs.writeFileSync(filePath, 'goodbye world.')695 await env.workspace.getActiveTextEditor().getBuffer().reload()696 assert.equal(editor.getText(), 'goodbye world.')697 editor.undo()698 assert.equal(editor.getText(), 'hello world!')699 })700 test('history serialization', async () => {701 let serializedEnvironment702 {703 const env = buildAtomEnvironment()704 const pack = await buildPackage(env)705 await pack.sharePortal()706 const editor = await env.workspace.open()707 editor.insertText('a')708 editor.insertText('b')709 editor.insertText('c')710 serializedEnvironment = env.serialize({isUnloading: true})711 }712 {713 const env = buildAtomEnvironment()714 await env.deserialize(serializedEnvironment)715 const editor = env.workspace.getActiveTextEditor()716 assert.equal(editor.getText(), 'abc')717 editor.undo()718 assert.equal(editor.getText(), 'ab')719 editor.redo()720 assert.equal(editor.getText(), 'abc')721 }722 })723 suite('host splitting editors', async () => {724 test('supporting distinct selections per editor with a shared undo stack for the buffer', async () => {725 const hostEnv = buildAtomEnvironment()726 const hostPackage = await buildPackage(hostEnv)727 const portal = await hostPackage.sharePortal()728 const guestEnv = buildAtomEnvironment()729 const guestPackage = await buildPackage(guestEnv)730 guestPackage.joinPortal(portal.id)731 const hostEditor1 = await hostEnv.workspace.open()732 hostEditor1.setText('hello = "world"')733 hostEditor1.setCursorBufferPosition([0, 0])734 hostEditor1.insertText('const ')735 hostEnv.workspace.paneForItem(hostEditor1).splitRight({copyActiveItem: true})736 const hostEditor2 = hostEnv.workspace.getActiveTextEditor()737 hostEditor2.setCursorBufferPosition([0, 8])738 assert.equal(hostEditor2.getBuffer(), hostEditor1.getBuffer())739 const guestEditor2 = await getNextActiveTextEditorPromise(guestEnv)740 guestEditor2.setCursorBufferPosition([0, Infinity])741 guestEditor2.insertText('\nconst goodbye = "moon"')742 await editorsEqual(guestEditor2, hostEditor2)743 await timeout(guestPackage.tetherDisconnectWindow)744 hostEditor2.undo()745 assert.equal(hostEditor2.getText(), 'hello = "world"\nconst goodbye = "moon"')746 assert.equal(hostEditor1.getText(), hostEditor2.getText())747 await editorsEqual(hostEditor2, guestEditor2)748 hostEnv.workspace.paneForItem(hostEditor1).activate()749 const guestEditor1 = await getNextActiveTextEditorPromise(guestEnv)750 assert.equal(guestEditor1.getBuffer(), guestEditor2.getBuffer())751 await editorsEqual(guestEditor1, hostEditor1)752 guestEditor1.undo()753 assert.equal(guestEditor1.getText(), 'hello = "world"')754 assert.equal(guestEditor2.getText(), guestEditor1.getText())755 await editorsEqual(guestEditor1, hostEditor1)756 })757 test('remotifying guest editors and buffers', async () => {758 const hostEnv = buildAtomEnvironment()759 const hostPackage = await buildPackage(hostEnv)760 const portal = await hostPackage.sharePortal()761 const guestEnv = buildAtomEnvironment()762 const guestPackage = await buildPackage(guestEnv)763 guestPackage.joinPortal(portal.id)764 const hostEditor1 = await hostEnv.workspace.open(path.join(temp.path(), 'a.txt'))765 const guestEditor1 = await getNextActiveTextEditorPromise(guestEnv)766 hostEnv.workspace.paneForItem(hostEditor1).splitRight({copyActiveItem: true})767 const hostEditor2 = hostEnv.workspace.getActiveTextEditor()768 const guestEditor2 = await getNextActiveTextEditorPromise(guestEnv)769 assert.deepEqual(getPaneItems(guestEnv), [guestEditor1, guestEditor2])770 assert(guestEditor1.isRemote)771 assert(guestEditor1.getTitle().endsWith('a.txt'))772 assert(guestEditor1.getBuffer().getPath().endsWith('a.txt'))773 assert(guestEditor2.isRemote)774 assert(guestEditor2.getTitle().endsWith('a.txt'))775 assert(guestEditor2.getBuffer().getPath().endsWith('a.txt'))776 hostEditor2.destroy()777 await condition(() => deepEqual(getPaneItems(guestEnv), [guestEditor1]))778 assert(guestEditor1.isRemote)779 assert(guestEditor1.getTitle().endsWith('a.txt'))780 assert(guestEditor1.getBuffer().getPath().endsWith('a.txt'))781 })782 })783 test('propagating nested marker layer updates that depend on text updates in a nested transaction', async () => {784 const hostEnv = buildAtomEnvironment()785 const hostPackage = await buildPackage(hostEnv)786 const hostPortal = await hostPackage.sharePortal()787 const hostEditor = await hostEnv.workspace.open()788 const guestEnv = buildAtomEnvironment()789 const guestPackage = await buildPackage(guestEnv)790 guestPackage.joinPortal(hostPortal.id)791 const guestEditor = await getNextActiveTextEditorPromise(guestEnv)792 hostEditor.transact(() => {793 hostEditor.setText('abc\ndef')794 hostEditor.transact(() => {795 hostEditor.setCursorBufferPosition([1, 2])796 })797 })798 await condition(() => deepEqual(getCursorDecoratedRanges(hostEditor), getCursorDecoratedRanges(guestEditor)))799 })800 suite('tethering', () => {801 test('guest following host', async () => {802 const hostEnv = buildAtomEnvironment()803 const hostPackage = await buildPackage(hostEnv)804 const guestEnv = buildAtomEnvironment()805 const guestPackage = await buildPackage(guestEnv)806 const hostPortal = await hostPackage.sharePortal()807 const guestPortal = await guestPackage.joinPortal(hostPortal.id)808 const hostEditor1 = await hostEnv.workspace.open()809 hostEditor1.setText(('x'.repeat(30) + '\n').repeat(30))810 hostEditor1.setCursorBufferPosition([2, 2])811 const hostEditor2 = await hostEnv.workspace.open()812 hostEditor2.setText(('y'.repeat(30) + '\n').repeat(30))813 hostEditor2.setCursorBufferPosition([2, 2])814 await condition(() => guestEnv.workspace.getTextEditors().length === 2)815 await verifyTetheringRules({816 leaderEnv: hostEnv,817 leaderPortal: hostPortal,818 followerEnv: guestEnv,819 followerPortal: guestPortal820 })821 })822 test('host following guest', async () => {823 const hostEnv = buildAtomEnvironment()824 const hostPackage = await buildPackage(hostEnv)825 const guestEnv = buildAtomEnvironment()826 const guestPackage = await buildPackage(guestEnv)827 const hostPortal = await hostPackage.sharePortal()828 const guestPortal = await guestPackage.joinPortal(hostPortal.id)829 const hostEditor1 = await hostEnv.workspace.open()830 hostEditor1.setText(('x'.repeat(30) + '\n').repeat(30))831 hostEditor1.setCursorBufferPosition([2, 2])832 const hostEditor2 = await hostEnv.workspace.open()833 hostEditor2.setText(('y'.repeat(30) + '\n').repeat(30))834 hostEditor2.setCursorBufferPosition([2, 2])835 await condition(() => guestEnv.workspace.getTextEditors().length === 2)836 await verifyTetheringRules({837 leaderEnv: guestEnv,838 leaderPortal: guestPortal,839 followerEnv: hostEnv,840 followerPortal: hostPortal841 })842 })843 test('guest following guest', async () => {844 const hostEnv = buildAtomEnvironment()845 const hostPackage = await buildPackage(hostEnv)846 const guest1Env = buildAtomEnvironment()847 const guest1Package = await buildPackage(guest1Env)848 const guest2Env = buildAtomEnvironment()849 const guest2Package = await buildPackage(guest2Env)850 const hostPortal = await hostPackage.sharePortal()851 const guest1Portal = await guest1Package.joinPortal(hostPortal.id)852 const guest2Portal = await guest2Package.joinPortal(hostPortal.id)853 const hostEditor1 = await hostEnv.workspace.open()854 hostEditor1.setText(('x'.repeat(30) + '\n').repeat(30))855 hostEditor1.setCursorBufferPosition([2, 2])856 const hostEditor2 = await hostEnv.workspace.open()857 hostEditor2.setText(('y'.repeat(30) + '\n').repeat(30))858 hostEditor2.setCursorBufferPosition([2, 2])859 await condition(() => guest1Env.workspace.getTextEditors().length === 2)860 await condition(() => guest2Env.workspace.getTextEditors().length === 2)861 await verifyTetheringRules({862 leaderEnv: guest1Env,863 leaderPortal: guest1Portal,864 followerEnv: guest2Env,865 followerPortal: guest2Portal866 })867 })868 async function verifyTetheringRules ({leaderEnv, leaderPortal, followerEnv, followerPortal}) {869 // Setup DOM for follower's workspace.870 loadPackageStyleSheets(followerEnv)871 const followerWorkspaceElement = followerEnv.views.getView(followerEnv.workspace)872 followerWorkspaceElement.style.height = '100px'873 followerWorkspaceElement.style.width = '250px'874 containerElement.appendChild(followerWorkspaceElement)875 const leaderEditors = leaderEnv.workspace.getTextEditors()876 const followerEditors = followerEnv.workspace.getTextEditors()877 // Reset follow state.878 leaderPortal.unfollow()879 followerPortal.unfollow()880 // Jump to leader cursor and follow it as it moves.881 leaderEnv.workspace.getActivePane().activateItem(leaderEditors[0])882 followerPortal.follow(leaderPortal.siteId)883 await condition(() => (884 followerEnv.workspace.getActivePaneItem() === followerEditors[0] &&885 deepEqual(followerEditors[0].getCursorBufferPosition(), leaderEditors[0].getCursorBufferPosition())886 ))887 leaderEditors[0].setCursorBufferPosition([3, 3])888 await condition(() => deepEqual(followerEditors[0].getCursorBufferPosition(), leaderEditors[0].getCursorBufferPosition()))889 // When followers move their cursor, their cursor does not follow the890 // leader's cursor so long as the leader's cursor stays within the891 // follower's viewport.892 followerEditors[0].setCursorBufferPosition([2, 10])893 leaderEditors[0].setCursorBufferPosition([3, 5])894 leaderEditors[0].insertText('Y')895 await condition(() => followerEditors[0].lineTextForBufferRow(3).includes('Y'))896 assert(followerEditors[0].getCursorBufferPosition().isEqual([2, 10]))897 // When the leader moves their cursor out of the follower's viewport, the898 // follower's cursor moves to the same position if the unfollow period899 // has elapsed.900 await timeout(followerPortal.tetherDisconnectWindow)901 leaderEditors[0].setCursorBufferPosition([20, 10])902 await condition(() => deepEqual(followerEditors[0].getCursorBufferPosition(), leaderEditors[0].getCursorBufferPosition()))903 // If the leader moves to non-visible columns (not just rows), we update904 // the tether.905 await condition(() => followerEditors[0].getFirstVisibleScreenRow() > 0)906 followerEditors[0].setCursorBufferPosition([20, 9])907 await timeout(followerPortal.tetherDisconnectWindow)908 leaderEditors[0].setCursorBufferPosition([20, 30])909 await condition(() => deepEqual(followerEditors[0].getCursorBufferPosition(), leaderEditors[0].getCursorBufferPosition()))910 // Disconnect tether if leader's cursor position moves within the tether911 // disconnect window.912 followerEditors[0].setCursorBufferPosition([20, 29])913 leaderEditors[0].setCursorBufferPosition([0, 0])914 leaderEditors[0].insertText('Y')915 await condition(() => followerEditors[0].lineTextForBufferRow(0).includes('Y'))916 assert(followerEditors[0].getCursorBufferPosition().isEqual([20, 29]))917 await timeout(followerPortal.tetherDisconnectWindow)918 leaderEditors[0].setCursorBufferPosition([1, 0])919 leaderEditors[0].insertText('Y')920 await condition(() => followerEditors[0].lineTextForBufferRow(1).includes('Y'))921 assert(followerEditors[0].getCursorBufferPosition().isEqual([20, 29]))922 // When re-following, ensure that you are taken to the leader's current tab.923 leaderEnv.workspace.paneForItem(leaderEditors[1]).activateItem(leaderEditors[1])924 followerPortal.follow(leaderPortal.siteId)925 await condition(() => deepEqual(followerEditors[1].getCursorBufferPosition(), leaderEditors[1].getCursorBufferPosition()))926 leaderEditors[1].setCursorBufferPosition([4, 4])927 await condition(() => deepEqual(followerEditors[1].getCursorBufferPosition(), leaderEditors[1].getCursorBufferPosition()))928 // Disconnect tether if follower scrolls the tether position out of view.929 followerEditors[1].setCursorBufferPosition([20, 0])930 await timeout(followerPortal.tetherDisconnectWindow)931 leaderEditors[1].setCursorBufferPosition([4, 5])932 leaderEditors[1].insertText('Z')933 await condition(() => followerEditors[1].lineTextForBufferRow(4).includes('Z'))934 assert(followerEditors[1].getCursorBufferPosition().isEqual([20, 0]))935 // Retract follower's tether and ensure it gets disconnected after switching to a different tab.936 followerPortal.follow(leaderPortal.siteId)937 await condition(() => deepEqual(followerEditors[1].getCursorBufferPosition(), leaderEditors[1].getCursorBufferPosition()))938 followerEnv.workspace.getActivePane().activateItem(followerEditors[0])939 await timeout(followerPortal.tetherDisconnectWindow)940 followerEditors[0].setCursorBufferPosition([3, 4])941 leaderEditors[1].setCursorBufferPosition([8, 2])942 leaderEditors[1].insertText('X')943 await condition(() => followerEditors[1].lineTextForBufferRow(8).includes('X'))944 assert.equal(followerEnv.workspace.getActivePaneItem(), followerEditors[0])945 assert(getCursorDecoratedRanges(followerEditors[0]).find((r) => r.isEqual([[3, 4], [3, 4]])))946 assert.equal(leaderEnv.workspace.getActivePaneItem(), leaderEditors[1])947 assert(getCursorDecoratedRanges(leaderEditors[1]).find((r) => r.isEqual([[8, 3], [8, 3]])))948 }949 })950 suite('services', () => {951 test('getRemoteEditors()', async () => {952 testServer.identityProvider.setIdentitiesByToken({953 'token-1': {login: 'user-1'},954 'token-2': {login: 'user-2'}955 })956 const host1Env = buildAtomEnvironment()957 const host1Package = await buildPackage(host1Env, {signIn: false})958 await host1Package.credentialCache.set('oauth-token', 'token-1')959 await host1Package.signInUsingSavedToken()960 const host1EditorA = await host1Env.workspace.open(path.join(temp.path(), 'a')) // eslint-disable-line no-unused-vars961 const host1Portal = await host1Package.sharePortal()962 const host1EditorB = await host1Env.workspace.open(path.join(temp.path(), 'b'))963 const host2Env = buildAtomEnvironment()964 const host2Package = await buildPackage(host2Env, {signIn: false})965 await host2Package.credentialCache.set('oauth-token', 'token-2')966 await host2Package.signInUsingSavedToken()967 const host2EditorC = await host2Env.workspace.open(path.join(temp.path(), 'c')) // eslint-disable-line no-unused-vars968 host2EditorC.setText('some text')969 const host2Portal = await host2Package.sharePortal()970 const host2EditorD = await host2Env.workspace.open(path.join(temp.path(), 'd')) // eslint-disable-line no-unused-vars971 // Create multiple editors for a single buffer (e.g. split panes), ensuring only one of them is returned.972 const host2EditorDCopy = await host2Env.workspace.open(host2EditorD.copy()) // eslint-disable-line no-unused-vars973 const guestEnv = buildAtomEnvironment()974 const guestPackage = await buildPackage(guestEnv)975 const guestService = guestPackage.provideTeletype()976 await guestPackage.joinPortal(host1Portal.id)977 await guestPackage.joinPortal(host2Portal.id)978 host1EditorB.destroy()979 await condition(async () => (await guestService.getRemoteEditors()).length === 3)980 const remoteEditors = await guestService.getRemoteEditors()981 assert.equal(remoteEditors[0].hostGitHubUsername, 'user-1')982 assert.equal(remoteEditors[0].path, host1EditorA.getPath())983 assert.equal(remoteEditors[1].hostGitHubUsername, 'user-2')984 assert.equal(remoteEditors[1].path, host2EditorC.getPath())985 assert.equal(remoteEditors[2].hostGitHubUsername, 'user-2')986 assert.equal(remoteEditors[2].path, host2EditorD.getPath())987 const guestEditorC = await guestEnv.workspace.open(remoteEditors[1].uri)988 assert(guestEditorC.isRemote)989 assert.equal(guestEditorC.getTitle(), '@user-2: c')990 assert.equal(guestEditorC.getURI(), remoteEditors[1].uri)991 assert.equal(guestEditorC.getText(), 'some text')992 guestEditorC.setText('modified text')993 await condition(() => host2EditorC.getText() === 'modified text')994 })995 })996 test('adding and removing workspace element classes when sharing a portal', async () => {997 const hostEnv = buildAtomEnvironment()998 const hostPackage = await buildPackage(hostEnv)999 await hostPackage.sharePortal()1000 assert(hostEnv.workspace.getElement().classList.contains('teletype-Host'))1001 await hostPackage.closeHostPortal()1002 assert(!hostEnv.workspace.getElement().classList.contains('teletype-Host'))1003 })1004 test('reports when the package needs to be upgraded due to an out-of-date protocol version', async () => {1005 const env = buildAtomEnvironment()1006 const pack = await buildPackage(env, {signIn: false})1007 pack.client.initialize = async function () {1008 throw new Errors.ClientOutOfDateError()1009 }1010 await pack.consumeStatusBar(new FakeStatusBar())1011 const {portalStatusBarIndicator} = pack1012 const {popoverComponent} = portalStatusBarIndicator1013 const {packageOutdatedComponent} = popoverComponent.refs1014 assert(portalStatusBarIndicator.element.classList.contains('outdated'))1015 assert(packageOutdatedComponent)1016 assert(!popoverComponent.refs.portalListComponent)1017 assert(!popoverComponent.refs.signInComponent)1018 const openedURIs = []1019 env.workspace.open = (uri) => openedURIs.push(uri)1020 packageOutdatedComponent.refs.viewPackageSettingsButton.click()1021 assert.deepEqual(openedURIs, ['atom://config/updates'])1022 })1023 test('reports errors attempting to initialize the client', async () => {1024 {1025 const env = buildAtomEnvironment()1026 const pack = await buildPackage(env, {signIn: false})1027 pack.client.initialize = async function () {1028 throw new Error('an error')1029 }1030 await pack.consumeStatusBar(new FakeStatusBar())1031 const {popoverComponent} = pack.portalStatusBarIndicator1032 assert(pack.portalStatusBarIndicator.element.classList.contains('initialization-error'))1033 assert(popoverComponent.refs.packageInitializationErrorComponent)1034 assert(popoverComponent.refs.packageInitializationErrorComponent.props.initializationError.message.includes('an error'))1035 }1036 })1037 test('client connection errors', async () => {1038 const env = buildAtomEnvironment()1039 const pack = await buildPackage(env)1040 await pack.sharePortal()1041 env.notifications.clear()1042 pack.client.emitter.emit('connection-error', new ErrorEvent('error', {message: 'connection-error'}))1043 assert.equal(env.notifications.getNotifications().length, 1)1044 const {type, message, options} = env.notifications.getNotifications()[0]1045 const {description} = options1046 assert.equal(type, 'error')1047 assert.equal(message, 'Connection Error')1048 assert(description.includes('connection-error'))1049 })1050 test('reports errors attempting to sign in', async () => {1051 const env = buildAtomEnvironment()1052 const pack = await buildPackage(env, {signIn: false})1053 await pack.consumeStatusBar(new FakeStatusBar())1054 pack.client.signIn = async function () {1055 throw new Error('some error')1056 }1057 const {popoverComponent} = pack.portalStatusBarIndicator1058 popoverComponent.refs.signInComponent.refs.editor.setText('some-token')1059 await popoverComponent.refs.signInComponent.signIn()1060 assert.equal(env.notifications.getNotifications().length, 1)1061 const {type, message, options} = env.notifications.getNotifications()[0]1062 const {description} = options1063 assert.equal(type, 'error')1064 assert.equal(message, 'Failed to authenticate to teletype')1065 assert(description.includes('some error'))1066 })...

Full Screen

Full Screen

package-spec.js

Source:package-spec.js Github

copy

Full Screen

...30 it('does not activate it', function() {31 const packagePath = atom.project32 .getDirectories()[0]33 .resolve('packages/package-with-incompatible-native-module');34 const pack = buildPackage(packagePath);35 expect(pack.isCompatible()).toBe(false);36 expect(pack.incompatibleModules[0].name).toBe('native-module');37 expect(pack.incompatibleModules[0].path).toBe(38 path.join(packagePath, 'node_modules', 'native-module')39 );40 });41 it("utilizes _atomModuleCache if present to determine the package's native dependencies", function() {42 let packagePath = atom.project43 .getDirectories()[0]44 .resolve('packages/package-with-ignored-incompatible-native-module');45 let pack = buildPackage(packagePath);46 expect(pack.getNativeModuleDependencyPaths().length).toBe(1); // doesn't see the incompatible module47 expect(pack.isCompatible()).toBe(true);48 packagePath = __guard__(atom.project.getDirectories()[0], x =>49 x.resolve('packages/package-with-cached-incompatible-native-module')50 );51 pack = buildPackage(packagePath);52 expect(pack.isCompatible()).toBe(false);53 });54 it('caches the incompatible native modules in local storage', function() {55 const packagePath = atom.project56 .getDirectories()[0]57 .resolve('packages/package-with-incompatible-native-module');58 expect(buildPackage(packagePath).isCompatible()).toBe(false);59 expect(global.localStorage.getItem.callCount).toBe(1);60 expect(global.localStorage.setItem.callCount).toBe(1);61 expect(buildPackage(packagePath).isCompatible()).toBe(false);62 expect(global.localStorage.getItem.callCount).toBe(2);63 expect(global.localStorage.setItem.callCount).toBe(1);64 });65 it('logs an error to the console describing the problem', function() {66 const packagePath = atom.project67 .getDirectories()[0]68 .resolve('packages/package-with-incompatible-native-module');69 spyOn(console, 'warn');70 spyOn(atom.notifications, 'addFatalError');71 buildPackage(packagePath).activateNow();72 expect(atom.notifications.addFatalError).not.toHaveBeenCalled();73 expect(console.warn.callCount).toBe(1);74 expect(console.warn.mostRecentCall.args[0]).toContain(75 'it requires one or more incompatible native modules (native-module)'76 );77 });78 });79 describe('::rebuild()', function() {80 beforeEach(function() {81 atom.packages.devMode = false;82 mockLocalStorage();83 });84 afterEach(() => (atom.packages.devMode = true));85 it('returns a promise resolving to the results of `apm rebuild`', function() {86 const packagePath = __guard__(atom.project.getDirectories()[0], x =>87 x.resolve('packages/package-with-index')88 );89 const pack = buildPackage(packagePath);90 const rebuildCallbacks = [];91 spyOn(pack, 'runRebuildProcess').andCallFake(callback =>92 rebuildCallbacks.push(callback)93 );94 const promise = pack.rebuild();95 rebuildCallbacks[0]({96 code: 0,97 stdout: 'stdout output',98 stderr: 'stderr output'99 });100 waitsFor(done =>101 promise.then(function(result) {102 expect(result).toEqual({103 code: 0,104 stdout: 'stdout output',105 stderr: 'stderr output'106 });107 done();108 })109 );110 });111 it('persists build failures in local storage', function() {112 const packagePath = __guard__(atom.project.getDirectories()[0], x =>113 x.resolve('packages/package-with-index')114 );115 const pack = buildPackage(packagePath);116 expect(pack.isCompatible()).toBe(true);117 expect(pack.getBuildFailureOutput()).toBeNull();118 const rebuildCallbacks = [];119 spyOn(pack, 'runRebuildProcess').andCallFake(callback =>120 rebuildCallbacks.push(callback)121 );122 pack.rebuild();123 rebuildCallbacks[0]({ code: 13, stderr: 'It is broken' });124 expect(pack.getBuildFailureOutput()).toBe('It is broken');125 expect(pack.getIncompatibleNativeModules()).toEqual([]);126 expect(pack.isCompatible()).toBe(false);127 // A different package instance has the same failure output (simulates reload)128 const pack2 = buildPackage(packagePath);129 expect(pack2.getBuildFailureOutput()).toBe('It is broken');130 expect(pack2.isCompatible()).toBe(false);131 // Clears the build failure after a successful build132 pack.rebuild();133 rebuildCallbacks[1]({ code: 0, stdout: 'It worked' });134 expect(pack.getBuildFailureOutput()).toBeNull();135 expect(pack2.getBuildFailureOutput()).toBeNull();136 });137 it('sets cached incompatible modules to an empty array when the rebuild completes (there may be a build error, but rebuilding *deletes* native modules)', function() {138 const packagePath = __guard__(atom.project.getDirectories()[0], x =>139 x.resolve('packages/package-with-incompatible-native-module')140 );141 const pack = buildPackage(packagePath);142 expect(pack.getIncompatibleNativeModules().length).toBeGreaterThan(0);143 const rebuildCallbacks = [];144 spyOn(pack, 'runRebuildProcess').andCallFake(callback =>145 rebuildCallbacks.push(callback)146 );147 pack.rebuild();148 expect(pack.getIncompatibleNativeModules().length).toBeGreaterThan(0);149 rebuildCallbacks[0]({ code: 0, stdout: 'It worked' });150 expect(pack.getIncompatibleNativeModules().length).toBe(0);151 });152 });153 describe('theme', function() {154 let [editorElement, theme] = [];155 beforeEach(function() {156 editorElement = document.createElement('atom-text-editor');157 jasmine.attachToDOM(editorElement);158 });159 afterEach(() =>160 waitsForPromise(function() {161 if (theme != null) {162 return Promise.resolve(theme.deactivate());163 }164 })165 );166 describe('when the theme contains a single style file', function() {167 it('loads and applies css', function() {168 expect(getComputedStyle(editorElement).paddingBottom).not.toBe(169 '1234px'170 );171 const themePath = __guard__(atom.project.getDirectories()[0], x =>172 x.resolve('packages/theme-with-index-css')173 );174 theme = buildThemePackage(themePath);175 theme.activate();176 expect(getComputedStyle(editorElement).paddingTop).toBe('1234px');177 });178 it('parses, loads and applies less', function() {179 expect(getComputedStyle(editorElement).paddingBottom).not.toBe(180 '1234px'181 );182 const themePath = __guard__(atom.project.getDirectories()[0], x =>183 x.resolve('packages/theme-with-index-less')184 );185 theme = buildThemePackage(themePath);186 theme.activate();187 expect(getComputedStyle(editorElement).paddingTop).toBe('4321px');188 });189 });190 describe('when the theme contains a package.json file', () =>191 it('loads and applies stylesheets from package.json in the correct order', function() {192 expect(getComputedStyle(editorElement).paddingTop).not.toBe('101px');193 expect(getComputedStyle(editorElement).paddingRight).not.toBe('102px');194 expect(getComputedStyle(editorElement).paddingBottom).not.toBe('103px');195 const themePath = __guard__(atom.project.getDirectories()[0], x =>196 x.resolve('packages/theme-with-package-file')197 );198 theme = buildThemePackage(themePath);199 theme.activate();200 expect(getComputedStyle(editorElement).paddingTop).toBe('101px');201 expect(getComputedStyle(editorElement).paddingRight).toBe('102px');202 expect(getComputedStyle(editorElement).paddingBottom).toBe('103px');203 }));204 describe('when the theme does not contain a package.json file and is a directory', () =>205 it('loads all stylesheet files in the directory', function() {206 expect(getComputedStyle(editorElement).paddingTop).not.toBe('10px');207 expect(getComputedStyle(editorElement).paddingRight).not.toBe('20px');208 expect(getComputedStyle(editorElement).paddingBottom).not.toBe('30px');209 const themePath = __guard__(atom.project.getDirectories()[0], x =>210 x.resolve('packages/theme-without-package-file')211 );212 theme = buildThemePackage(themePath);213 theme.activate();214 expect(getComputedStyle(editorElement).paddingTop).toBe('10px');215 expect(getComputedStyle(editorElement).paddingRight).toBe('20px');216 expect(getComputedStyle(editorElement).paddingBottom).toBe('30px');217 }));218 describe('reloading a theme', function() {219 beforeEach(function() {220 const themePath = __guard__(atom.project.getDirectories()[0], x =>221 x.resolve('packages/theme-with-package-file')222 );223 theme = buildThemePackage(themePath);224 theme.activate();225 });226 it('reloads without readding to the stylesheets list', function() {227 expect(theme.getStylesheetPaths().length).toBe(3);228 theme.reloadStylesheets();229 expect(theme.getStylesheetPaths().length).toBe(3);230 });231 });232 describe('events', function() {233 beforeEach(function() {234 const themePath = __guard__(atom.project.getDirectories()[0], x =>235 x.resolve('packages/theme-with-package-file')236 );237 theme = buildThemePackage(themePath);238 theme.activate();239 });240 it('deactivated event fires on .deactivate()', function() {241 let spy;242 theme.onDidDeactivate((spy = jasmine.createSpy()));243 waitsForPromise(() => Promise.resolve(theme.deactivate()));244 runs(() => expect(spy).toHaveBeenCalled());245 });246 });247 });248 describe('.loadMetadata()', function() {249 let [packagePath, metadata] = [];250 beforeEach(function() {251 packagePath = __guard__(atom.project.getDirectories()[0], x =>252 x.resolve('packages/package-with-different-directory-name')253 );254 metadata = atom.packages.loadPackageMetadata(packagePath, true);255 });256 it('uses the package name defined in package.json', () =>257 expect(metadata.name).toBe('package-with-a-totally-different-name'));258 });259 describe('the initialize() hook', function() {260 it('gets called when the package is activated', function() {261 const packagePath = atom.project262 .getDirectories()[0]263 .resolve('packages/package-with-deserializers');264 const pack = buildPackage(packagePath);265 pack.requireMainModule();266 const { mainModule } = pack;267 spyOn(mainModule, 'initialize');268 expect(mainModule.initialize).not.toHaveBeenCalled();269 pack.activate();270 expect(mainModule.initialize).toHaveBeenCalled();271 expect(mainModule.initialize.callCount).toBe(1);272 });273 it('gets called when a deserializer is used', function() {274 const packagePath = atom.project275 .getDirectories()[0]276 .resolve('packages/package-with-deserializers');277 const pack = buildPackage(packagePath);278 pack.requireMainModule();279 const { mainModule } = pack;280 spyOn(mainModule, 'initialize');281 pack.load();282 expect(mainModule.initialize).not.toHaveBeenCalled();283 atom.deserializers.deserialize({ deserializer: 'Deserializer1', a: 'b' });284 expect(mainModule.initialize).toHaveBeenCalled();285 });286 });287});288function __guard__(value, transform) {289 return typeof value !== 'undefined' && value !== null290 ? transform(value)291 : undefined;...

Full Screen

Full Screen

package.builder.panel.js

Source:package.builder.panel.js Github

copy

Full Screen

1/**2 * Loads the Package Builder3 * 4 * @class MODx.panel.PackageBuilder5 * @extends MODx.panel.Wizard6 * @param {Object} config An object of config properties7 * @xtype panel-package-builder8 */9MODx.panel.PackageBuilder = function(config) {10 config = config || {};11 Ext.applyIf(config,{12 title: _('package_builder')13 ,id: 'panel-package-builder'14 ,layout: 'card'15 ,firstPanel: 'pb-start'16 ,lastPanel: 'pb-build'17 ,txtFinish: _('build')18 ,items: [{19 xtype: 'panel-pb-start'20 },{21 xtype: 'panel-pb-info'22 },{23 xtype: 'panel-pb-autoselects' 24 },{25 xtype: 'panel-pb-selvehicle'26 },{27 xtype: 'panel-pb-build'28 },{29 xtype: 'panel-pb-xml'30 }]31 });32 MODx.panel.PackageBuilder.superclass.constructor.call(this,config);33};34Ext.extend(MODx.panel.PackageBuilder,MODx.panel.Wizard);35Ext.reg('panel-package-builder',MODx.panel.PackageBuilder);36/**37 * 38 * @class MODx.panel.PackageStart39 * @extends MODx.FormPanel40 * @param {Object} config An object of config properties41 * @xtype panel-pb-start42 */43MODx.panel.PackageStart = function(config) {44 config = config || {};45 Ext.applyIf(config,{46 id: 'pb-start'47 ,url: MODx.config.connectors_url+'workspace/builder/index.php'48 ,baseParams: {49 action: 'start'50 }51 ,defaults: { labelSeparator: '', border: false }52 ,items: [{53 html: '<h2>'+_('package_method')+'</h2>'54 },{55 html: '<p>'+_('package_method_desc')+'</p>'56 },{57 xtype: 'radio'58 ,name: 'method'59 ,boxLabel: _('use_wizard')60 ,inputValue: 'pb-info'61 ,checked: true62 },{63 xtype: 'radio'64 ,name: 'method'65 ,boxLabel: _('use_xml')66 ,inputValue: 'pb-xml'67 }]68 ,listeners: {69 'success': {fn:function(o) {70 var c = o.options;71 var d = o.form.getValues().method;72 Ext.callback(c.proceed,c.scope || this,[d]);73 },scope:this}74 }75 });76 MODx.panel.PackageStart.superclass.constructor.call(this,config);77};78Ext.extend(MODx.panel.PackageStart,MODx.panel.WizardPanel);79Ext.reg('panel-pb-start',MODx.panel.PackageStart);80/**81 * 82 * @class MODx.panel.PackageStart83 * @extends MODx.FormPanel84 * @param {Object} config An object of config properties85 * @xtype panel-pb-start86 */87MODx.panel.PackageXML = function(config) {88 config = config || {};89 Ext.applyIf(config,{90 id: 'pb-xml'91 ,back: 'pb-start'92 ,url: MODx.config.connectors_url+'workspace/builder/index.php'93 ,baseParams: {94 action: 'buildFromXML'95 ,register: 'mgr'96 ,topic: '/workspace/package/builder/'97 }98 ,fileUpload: true99 ,defaults: { labelSeparator: '', border: false }100 ,items: [{101 html: '<h2>'+_('package_build_xml')+'</h2>'102 },{103 html: '<p>'+_('package_build_xml_desc')+'</p>'104 },{105 xtype: 'textfield'106 ,name: 'file'107 ,inputType: 'file'108 }]109 ,listeners: {110 'success': {fn:function(o) {111 var c = o.options;112 this.console.complete();113 Ext.getCmp('pb-info').getForm().reset();114 Ext.callback(c.proceed,c.scope || this,['pb-start']);115 },scope:this}116 ,'beforeSubmit': {fn:function(o) {117 var topic = '/workspace/package/builder/';118 if (this.console === null) {119 this.console = MODx.load({120 xtype: 'modx-console'121 ,register: 'mgr'122 ,topic: topic123 });124 } else {125 this.console.setRegister('mgr',topic);126 }127 this.console.show(Ext.getBody());128 },scope: this}129 }130 });131 MODx.panel.PackageXML.superclass.constructor.call(this,config);132};133Ext.extend(MODx.panel.PackageXML,MODx.panel.WizardPanel,{134 console: null135});136Ext.reg('panel-pb-xml',MODx.panel.PackageXML);137/**138 * 139 * @class MODx.panel.PackageInfo140 * @extends MODx.FormPanel141 * @param {Object} config An object of config properties142 * @xtype panel-pb-info143 */144MODx.panel.PackageInfo = function(config) {145 config = config || {};146 Ext.applyIf(config,{147 id: 'pb-info'148 ,back: 'pb-start'149 ,url: MODx.config.connectors_url+'workspace/builder/index.php'150 ,baseParams: {151 action: 'create'152 }153 ,defaults: { labelSeparator: '', border: false }154 ,items: [{155 html: '<h2>'+_('package_info')+'</h2>'156 },{157 html: '<p>'+_('package_info_desc')+'</p>'158 },{159 xtype: 'textfield'160 ,fieldLabel: _('name')161 ,name: 'name'162 ,allowBlank: false163 },{164 xtype: 'textfield'165 ,fieldLabel: _('version')166 ,name: 'version'167 ,allowBlank: false168 },{169 xtype: 'textfield'170 ,fieldLabel: _('release')171 ,name: 'release'172 ,allowBlank: false173 },{174 xtype: 'combo-namespace'175 ,fieldLabel: _('namespace')176 ,id: 'pb-namespace'177 ,name: 'namespace'178 ,allowBlank: true179 }]180 ,listeners: {181 'success': {fn:function(o) {182 var c = o.options;183 184 var ns = Ext.getCmp('pb-namespace').getValue();185 var df = ns == 'core' ? false : true; 186 Ext.getCmp('pb-as-cb-ss').setValue(df);187 Ext.getCmp('pb-as-cb-cs').setValue(df);188 Ext.getCmp('pb-as-cb-le').setValue(df);189 Ext.getCmp('pb-as-cb-lf').setValue(df);190 191 Ext.getCmp('grid-vehicle').refresh();192 Ext.callback(c.proceed,c.scope || this,['pb-autoselects']);193 },scope:this}194 }195 });196 MODx.panel.PackageInfo.superclass.constructor.call(this,config);197};198Ext.extend(MODx.panel.PackageInfo,MODx.panel.WizardPanel);199Ext.reg('panel-pb-info',MODx.panel.PackageInfo);200/**201 * 202 * @class MODx.panel.PackageInfo203 * @extends MODx.FormPanel204 * @param {Object} config An object of config properties205 * @xtype panel-pb-info206 */207MODx.panel.PackageAutoSelects = function(config) {208 config = config || {};209 Ext.applyIf(config,{210 id: 'pb-autoselects'211 ,back: 'pb-info'212 ,url: MODx.config.connectors_url+'workspace/builder/index.php'213 ,baseParams: {214 action: 'autoselects'215 }216 ,defaults: { labelSeparator: '', border: false }217 ,items: [{218 html: '<h2>'+_('package_autoselects')+'</h2>'219 },{220 html: '<p>'+_('package_autoselects_desc')+'</p>'221 },{222 xtype: 'checkboxgroup'223 ,fieldLabel: _('classes')224 ,columns: 1225 ,defaults: {226 checked: Ext.getCmp('panel-package-builder').coreSelected ? false : true227 ,name: 'classes[]'228 }229 ,items: [230 {boxLabel: _('as_system_settings') ,inputValue: 'modSystemSetting' ,id: 'pb-as-cb-ss'}231 ,{boxLabel: _('as_context_settings') ,inputValue: 'modContextSetting' ,id: 'pb-as-cb-cs'}232 ,{boxLabel: _('as_lexicon_entries') ,inputValue: 'modLexiconEntry', id: 'pb-as-cb-le'}233 ,{boxLabel: _('as_lexicon_topics') ,inputValue: 'modLexiconTopic' ,id: 'pb-as-cb-lf'}234 ]235 }]236 ,listeners: {237 'success': {fn:function(o) {238 var c = o.options;239 Ext.getCmp('grid-vehicle').refresh();240 Ext.callback(c.proceed,c.scope || this,['pb-selvehicle']);241 },scope:this}242 }243 });244 MODx.panel.PackageAutoSelects.superclass.constructor.call(this,config);245};246Ext.extend(MODx.panel.PackageAutoSelects,MODx.panel.WizardPanel);247Ext.reg('panel-pb-autoselects',MODx.panel.PackageAutoSelects);248/**249 * 250 * @class MODx.panel.SelectVehicles251 * @extends MODx.FormPanel252 * @param {Object} config An object of config properties253 * @xtype panel-pb-selvehicle254 */255MODx.panel.SelectVehicles = function(config) {256 config = config || {};257 Ext.applyIf(config,{258 id: 'pb-selvehicle'259 ,back: 'pb-autoselects'260 ,url: MODx.config.connectors_url+'workspace/builder/vehicle.php'261 ,baseParams: {262 action: 'create'263 }264 ,defaults: { labelSeparator: '' }265 ,items: [{266 html: '<h2>'+_('vehicles_add')+'</h2>'267 ,border: false268 },{269 html: '<p>'+_('vehicles_desc')+'</p>'270 ,border: false271 },{272 xtype: 'grid-vehicle'273 ,id: 'grid-vehicle'274 ,preventRender: true275 }]276 });277 MODx.panel.SelectVehicles.superclass.constructor.call(this,config);278};279Ext.extend(MODx.panel.SelectVehicles,MODx.panel.WizardPanel,{280 submit: function(o) {281 Ext.callback(o.proceed,o.scope || this,['pb-build']);282 }283});284Ext.reg('panel-pb-selvehicle',MODx.panel.SelectVehicles);285/**286 * 287 * @class MODx.panel.BuildPackage288 * @extends MODx.FormPanel289 * @param {Object} config An object of config properties290 * @xtype panel-pb-build291 */292MODx.panel.BuildPackage = function(config) {293 config = config || {};294 Ext.applyIf(config,{295 id: 'pb-build'296 ,back: 'pb-selvehicle'297 ,url: MODx.config.connectors_url+'workspace/builder/index.php'298 ,baseParams: {299 action: 'build'300 ,register: 'mgr'301 ,topic: '/workspace/package/builder/'302 }303 ,defaults: { labelSeparator: '', border: false }304 ,items: [{305 html: '<h2>'+_('package_build')+'</h2>'306 },{307 html: '<p>'+_('package_build_desc')+'</p>'308 }]309 ,listeners: {310 'success': {fn:function(o) {311 var c = o.options;312 this.console.complete();313 Ext.getCmp('pb-info').getForm().reset();314 Ext.callback(c.proceed,c.scope || this,['pb-start']);315 },scope:this}316 ,'beforeSubmit': {fn:function(o) {317 var topic = '/workspace/package/builder/';318 if (this.console === null) {319 this.console = MODx.load({320 xtype: 'modx-console'321 ,register: 'mgr'322 ,topic: topic323 });324 } else {325 this.console.setRegister('mgr',topic);326 }327 this.console.show(Ext.getBody());328 },scope: this}329 }330 });331 MODx.panel.BuildPackage.superclass.constructor.call(this,config);332};333Ext.extend(MODx.panel.BuildPackage,MODx.panel.WizardPanel,{334 console: null335});...

Full Screen

Full Screen

server.js

Source:server.js Github

copy

Full Screen

1#!/usr/bin/env node2var path = require('path');3var architect = require("architect");4var spawn = require("child_process").spawn;5var fs = require("fs");6// TODO: Need better args parser.7var configName = process.argv[2] || "default";8// when command line arguments are passed into this, we ignore them9// when loading the config file.10if (configName.indexOf("-") === 0) {11 configName = "default";12}13var debug = false;14var packed = false;15var packedName = "";16for (var p = 2; p < process.argv.length; p++) {17 if (process.argv[p] === "-d") {18 debug = true;19 20 // apf debug doesn't exist, or it's older than three days--rebuild it21 if(!path.existsSync("plugins-client/lib.apf/www/apf-packaged/apf_debug.js") ||22 (path.existsSync("plugins-client/lib.apf/www/apf-packaged/apf_debug.js")) &&23 ((new Date() - fs.statSync("plugins-client/lib.apf/www/apf-packaged/apf_debug.js").mtime.valueOf()) / 86400000) >= 3) {24 console.log("Building apfdebug for first run...");25 26 var buildDebug = spawn("npm", ["run-script", "build-debug"]);27 28 buildDebug.stderr.setEncoding("utf8");29 buildDebug.stderr.on('data', function (data) {30 console.error(data);31 });32 33 buildDebug.on('exit', function (code) {34 if (code !== 0) {35 console.error('build-debug process exited with code ' + code);36 process.exit(code);37 }38 boot();39 });40 }41 else42 boot();43 }44 else if (process.argv[p] === "-P") {45 packed = true;46 if (process.argv[p + 1] && process.argv[p + 1].indexOf("-") < 0) // use this specific packed file47 packedName = process.argv[++p];48 else49 packedName = "c9os.min.js";50 configName = "packed";51 if(!path.existsSync("plugins-client/lib.packed/www/" + packedName) && !path.existsSync("plugins-client/lib.packed/www/" + packedName + ".gz")) {52 console.log("Building packed file for first run...Please wait...");53 console.log(" |\\ _,,,---,,_\n" +54 " /,`.-'`' -. ;-;;,_\n" +55 " |,4- ) )-,_..;\\ ( `'-'\n" +56 " '---''(_/--' `-'\\_) Felix Lee");57 var buildPackage = spawn("npm", ["run-script", "build-packed"]);58 59 buildPackage.stderr.setEncoding("utf8");60 buildPackage.stderr.on('data', function (data) {61 console.error(data);62 });63 buildPackage.on('exit', function (code) {64 if (code !== 0) {65 console.error('build-package process exited with code ' + code);66 process.exit(code);67 }68 boot();69 });70 }71 else72 boot();73 }74}75if (debug == false && packed == false)76 boot();77function boot() {78 var configPath = path.resolve(__dirname, "./configs/", configName);79 var plugins = require(configPath);80 // server plugins81 plugins.forEach(function(plugin) {82 if (plugin.packagePath && /\.\/cloud9.core$/.test(plugin.packagePath)) {83 plugin.debug = debug;84 plugin.packed = packed;85 plugin.packedName = packedName;86 }87 });88 architect.createApp(architect.resolveConfig(plugins, __dirname + "/plugins-server"), function (err, app) {89 if (err) {90 console.error("While starting the '%s':", configPath);91 throw err;92 }93 console.log("Started '%s'!", configPath);94 });...

Full Screen

Full Screen

build-package.spec.js

Source:build-package.spec.js Github

copy

Full Screen

...10 dependencies: {11 foo: {}12 }13 };14 const pkg = buildPackage(packageDir, packageLock, logger);15 const actualDependency = pkg.dependencies.find(d => d.name === 'foo');16 expect(actualDependency).toBeTruthy();17 expect(actualDependency.description).toBeFalsy();18 expect(actualDependency.license).toBeFalsy();19 expect(actualDependency.name).toBe('foo');20 expect(actualDependency.version).toBeFalsy();21 });22 it('processes dependencies defined in package.json and installed', () => {23 const packageDir = '.';24 const packageLock = {25 dependencies: {26 jasmine: {}27 }28 };29 const pkg = buildPackage(packageDir, packageLock, logger);30 const expectedDependency = jsonFile.readFileSync(31 './node_modules/jasmine/package.json'32 );33 const actualDependency = pkg.dependencies.find(34 d => d.name === Object.keys(packageLock.dependencies)[0]35 );36 expect(actualDependency).toBeTruthy();37 expect(actualDependency.description).toBe(expectedDependency.description);38 expect(actualDependency.license).toBe(expectedDependency.license);39 expect(actualDependency.name).toBe(expectedDependency.name);40 expect(actualDependency.version).toBe(expectedDependency.version);41 });...

Full Screen

Full Screen

build-module.js

Source:build-module.js Github

copy

Full Screen

...10 packages.forEach(async (pkg) => {11 const target = pkg.dirName;12 const pkgDir = path.resolve(`packages/${target}`);13 await fs.remove(`${pkgDir}/esm`);14 buildPackage(pkg.dirName);15 });16}17function buildPackage(dirName) {18 const pattern = '**/*.ts';19 const cwd = resolvePackagePath(dirName, 'src');20 const files = glob.sync(pattern, { cwd, });21 const targetFiles = files.map((file) => {22 return resolvePackagePath(dirName, 'src', file);23 });24 // build ts -> esm25 {26 const tsConfig = getTsConfig();27 const compilerOptions = tsConfig.compilerOptions;28 compilerOptions.target = ts.ScriptTarget.ES2015;29 compilerOptions.moduleResolution = ts.ModuleResolutionKind.NodeJs;30 compilerOptions.declaration = true;31 compilerOptions.outDir = resolvePackagePath(dirName, 'esm');...

Full Screen

Full Screen

build.js

Source:build.js Github

copy

Full Screen

1/*2 Build everything3 */4import * as gulp from 'gulp'5import * as log from 'fancy-log'6import config from 'assist'7import {blend} from 'assist/blend'8import buildPackage from './package'9import deploy from './deploy'10import publish from './publish'11import run from './run'12function setProd(done) {13 config.profile = 'prod'14 blend(config, config.profiles[config.profile])15 done()16}17function trace(cb) {18 print(`Using: profile ${config.profile} ${config.debug ? 'debug' : ''}`)19 cb()20}21function noBuild(cb) {22 print(`Skipping: no build action required`)23 cb()24}25function noClean(cb) {26 // print(`Skipping: no clean action taken`)27 cb()28}29gulp.task('build', gulp.series(noBuild))30gulp.task('clean', gulp.series(noClean))31gulp.task('deploy', gulp.series(deploy))32gulp.task('package', gulp.series(buildPackage))33gulp.task('publish', gulp.series(publish))34gulp.task('promote', gulp.series(setProd, trace, buildPackage, publish, deploy))35gulp.task('run', gulp.series(run))...

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const cypress = require('cypress')2const fs = require('fs')3const path = require('path')4const { promisify } = require('util')5const writeFile = promisify(fs.writeFile)6const mkdir = promisify(fs.mkdir)7const rimraf = promisify(require('rimraf'))8const appDir = path.join(__dirname, 'cypress', 'app')9const { buildPackage } = require('@cypress/webpack-preprocessor')10const webpackOptions = {11 resolve: {12 },13 module: {14 {15 options: {16 },17 },18 },19}20rimraf(appDir)21 .then(() => {22 return mkdir(appDir)23 })24 .then(() => {25 return writeFile(path.join(appDir, 'index.js'), 'console.log("hello")')26 })27 .then(() => {28 return writeFile(path.join(appDir, 'index.ts'), 'console.log("hello")')29 })30 .then(() => {31 return writeFile(32 path.join(appDir, 'index.tsx'),33 'console.log("hello")',34 })35 .then(() => {36 return buildPackage(webpackOptions)37 })38 .then((spec) => {39 return writeFile(path.join(__dirname, 'cypress', 'integration', 'spec.js'), spec)40 })41 .then(() => {42 return cypress.open({43 config: {44 },45 })46 })47const { buildPackage } = require('@cypress/webpack-preprocessor')48const webpackOptions = {49}50const options = {51}52buildPackage(options)

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const cypress = require('cypress')2cypress.run({3 config: {4 },5 reporterOptions: {6 },7}).then((results) => {8 console.log('results', results)9})

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const cypress = require('cypress')2const fs = require('fs-extra')3const path = require('path')4const runCypressTests = async () => {5 const { runResults } = await cypress.run({6 config: {7 },8 })9 const { totalFailed } = runResults10 if (totalFailed > 0) {11 throw new Error('Cypress tests failed')12 }13}14const buildPackage = async () => {15 const { projectType } = await cypress.config.readConfig()16 const cypressProjectPath = path.dirname(17 require.resolve(`${projectType}/package.json`),18 const cypressProjectDist = path.join(cypressProjectPath, 'dist')19 await fs.remove(cypressProjectDist)20 await cypress.run({21 config: {22 },23 })24}25const cleanUp = async () => {26 await fs.remove('screenshots')27 await fs.remove('cypress/videos')28}29const run = async () => {30 await runCypressTests()31 await buildPackage()32 await cleanUp()33}34run()35const cypress = require('cypress')36const fs = require('fs-extra')37const path = require('path')

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const cypress = require('cypress');2cypress.run({3 config: {4 },5 config: {6 },7 reporterOptions: {8 },9}).then((results) => {10 console.log(results);11 process.exit(results.totalFailed);12});13describe('Your test case', () => {14 it('Your test case', () => {15 cy.get('input[name="q"]').type('Cypress');16 cy.get('input[value="Google Search"]').click();17 cy.get('h3').should('be.visible');18 });19});

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1import { buildPackage } from '@cypress/browserify-preprocessor'2module.exports = (on, config) => {3 on('file:preprocessor', buildPackage())4}5const browserify = require('@cypress/browserify-preprocessor')6module.exports = (on, config) => {7 on('file:preprocessor', browserify())8}9const browserify = require('@cypress/browserify-preprocessor')10module.exports = (on, config) => {11 on('file:preprocessor', browserify())12}13const browserify = require('@cypress/browserify-preprocessor')14module.exports = (on, config) => {15 on('file:preprocessor', browserify())16}17const browserify = require('@cypress/browserify-preprocessor')18module.exports = (on, config) => {19 on('file:preprocessor', browserify())20}21const browserify = require('@cypress/browserify-preprocessor')22module.exports = (on, config) => {23 on('file:preprocessor', browserify())24}25const browserify = require('@cypress/browserify-preprocessor')26module.exports = (on, config) => {27 on('file:preprocessor', browserify())28}29const browserify = require('@cypress/browserify-preprocessor')30module.exports = (on, config) => {31 on('file:preprocessor', browserify())32}33const browserify = require('@cypress/browserify-preprocessor')34module.exports = (on, config) => {35 on('file:preprocessor', browserify())36}

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const fs = require('fs')2const cypress = require('cypress')3const packageJson = {4 "scripts": {5 },6 "devDependencies": {7 }8}9 .run({10 config: {11 },12 env: {13 },14 reporterOptions: {15 }16 })17 .then((results) => {18 console.log(results)19 })20 .catch((err) => {21 console.error(err)22 })23fs.writeFile('package.json', JSON.stringify(packageJson), err => {24 if (err) throw err25 console.log('package.json created')26})27const { exec } = require('child_process')28exec('npm install', (err, stdout, stderr) => {29 if (err) {30 console.error(`exec error: ${err}`)31 }32 console.log(`stdout: ${stdout}`)33 console.log(`stderr: ${stderr}`)34})35exec('npm run cy:run', (err, stdout, stderr) => {36 if (err) {37 console.error(`exec error: ${err}`)38 }39 console.log(`stdout: ${stdout}`)40 console.log(`stderr: ${stderr}`)41})42fs.unlink('package.json', err => {43 if (err) throw err44 console.log('package.json deleted')45})46fs.unlink('package-lock.json', err => {47 if (err) throw

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1const cypress = require('cypress');2const fs = require('fs-extra');3const path = require('path');4const appDir = path.dirname(require.main.filename);5const zip = require('adm-zip');6const folderName = 'cypress';7const tempFolder = 'temp';8const zipFolder = 'zip';9const zipFileName = 'cypress.zip';10const zipFilePath = path.join(appDir, zipFolder, zipFileName);11const tempFolderPath = path.join(appDir, tempFolder);12const folderPath = path.join(appDir, folderName);13const cypressZipFilePath = path.join(folderPath, zipFileName);14const cypressZipFolderPath = path.join(folderPath, tempFolder);15const cypressZipFolder = new zip(cypressZipFilePath);16async function buildPackage() {17 await cypress.run({18 config: {19 },20 });21}22async function deleteFolder() {23 await fs.remove(folderPath);24}25async function unzipFile() {26 await cypressZipFolder.extractAllTo(cypressZipFolderPath, true);27}28async function copyFolder() {29 await fs.copy(tempFolderPath, folderPath);30}31async function deleteTempFolder() {32 await fs.remove(tempFolderPath);33}34async function deleteZipFile() {35 await fs.remove(cypressZipFilePath);36}37async function deleteZipFolder() {38 await fs.remove(zipFolder);39}40async function createZipFolder() {41 await fs.mkdir(zipFolder);42}43async function createTempFolder() {44 await fs.mkdir(tempFolder);45}

Full Screen

Full Screen

Using AI Code Generation

copy

Full Screen

1import {buildPackage} from '@cypress/code-coverage/task'2buildPackage(__dirname)3module.exports = (on, config) => {4 require('@cypress/code-coverage/task')(on, config)5}6import '@cypress/code-coverage/support'7{8 "env": {9 }10}11{12}13{14 "scripts": {15 },16 "devDependencies": {17 }18}

Full Screen

Full Screen

Cypress Tutorial

Cypress is a renowned Javascript-based open-source, easy-to-use end-to-end testing framework primarily used for testing web applications. Cypress is a relatively new player in the automation testing space and has been gaining much traction lately, as evidenced by the number of Forks (2.7K) and Stars (42.1K) for the project. LambdaTest’s Cypress Tutorial covers step-by-step guides that will help you learn from the basics till you run automation tests on LambdaTest.

Chapters:

  1. What is Cypress? -
  2. Why Cypress? - Learn why Cypress might be a good choice for testing your web applications.
  3. Features of Cypress Testing - Learn about features that make Cypress a powerful and flexible tool for testing web applications.
  4. Cypress Drawbacks - Although Cypress has many strengths, it has a few limitations that you should be aware of.
  5. Cypress Architecture - Learn more about Cypress architecture and how it is designed to be run directly in the browser, i.e., it does not have any additional servers.
  6. Browsers Supported by Cypress - Cypress is built on top of the Electron browser, supporting all modern web browsers. Learn browsers that support Cypress.
  7. Selenium vs Cypress: A Detailed Comparison - Compare and explore some key differences in terms of their design and features.
  8. Cypress Learning: Best Practices - Take a deep dive into some of the best practices you should use to avoid anti-patterns in your automation tests.
  9. How To Run Cypress Tests on LambdaTest? - Set up a LambdaTest account, and now you are all set to learn how to run Cypress tests.

Certification

You can elevate your expertise with end-to-end testing using the Cypress automation framework and stay one step ahead in your career by earning a Cypress certification. Check out our Cypress 101 Certification.

YouTube

Watch this 3 hours of complete tutorial to learn the basics of Cypress and various Cypress commands with the Cypress testing at LambdaTest.

Run Cypress automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

... View sample repo... View DocumentationSign up Free
›
_

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

...
Sign up with GoogleSign up with Email
Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful