fix(bulk-publish): polling termination, worker auth, and selection panel

- Fix indefinite bulk publish polling: worker was getting 404 on project
  fragment because masAccessToken (sessionStorage) must be used instead
  of the plain IMS token; forward aemOdinEndpoint through the dispatch
  chain so the worker hits the correct AEM environment
- Prevent double-dispatch: move publishing store flag before first await
  in startPublishing so it acts as a synchronous mutex; add early-return
  guard when project is already in-flight
- Skip hydrated references during status polls (skipReferences:true) to
  avoid repeated ?references=direct-hydrated requests while polling
- Fail fast in worker when project has no fragment paths: set FAILED
  status immediately instead of silently returning published with 0 items
- Selection panel: restore opt-in cascade publish dialog for multi-select
  and resolve fragment refs from field values instead of hydrated refs
- Publish dialog: show fragment title and studio path instead of DAM path

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: seanchoi0

io/studio/src/bulk-publish/bulk-publish-worker.js

@@ -52,6 +52,24 @@ async function runWorker(input, deps = {}) {
     const title = projTitle(fragment);
     const existingSnapshots = projSnapshots(fragment);
 
+    if (paths.length === 0 && !hasPendingSnapshot(existingSnapshots)) {
+        await updateProject(odinEndpoint, projectId, authToken, {
+            status: PROJECT_STATUS.FAILED,
+            lastError: 'No fragments found in project',
+        });
+        logger.error(JSON.stringify({ event: 'worker-no-paths', projectId }));
+        return {
+            total: 0,
+            published: 0,
+            failed: 0,
+            startedAt,
+            finishedAt: now().toISOString(),
+            reasons: {},
+            failures: [],
+            failuresTruncated: false,
+        };
+    }
+
     let snapshotEntries;
     let expandedPaths = null;
     if (hasPendingSnapshot(existingSnapshots)) {

io/studio/src/bulk-publish/index.js

@@ -27,6 +27,7 @@ async function main(params) {
                 projectId: params.projectId,
                 publishedBy: params.publishedBy || '',
                 authToken,
+                aemOdinEndpoint: odinEndpoint,
                 includeCards: params.includeCards || false,
                 includeVariations: params.includeVariations || false,
             },

io/studio/test/bulk-publish/bulk-publish-worker.test.js

@@ -315,6 +315,21 @@ describe('bulk-publish-worker — runWorker', () => {
 
         expect(deps.createSnapshot).to.have.been.calledOnce;
     });
+
+    it('sets status to Failed and returns early when project has no paths and no pending snapshot', async () => {
+        const { PROJECT_STATUS } = require('../../src/bulk-publish/project.js');
+        deps.getProjectPaths.returns([]);
+        deps.getProjectSnapshots.returns([]);
+
+        const result = await worker.runWorker({ projectId: 'proj-1', odinEndpoint: 'https://odin', authToken: 't' }, deps);
+
+        expect(deps.createSnapshot).to.not.have.been.called;
+        expect(deps.publishResolved).to.not.have.been.called;
+        const updateCall = deps.updateProjectFragment.firstCall;
+        expect(updateCall.args[3].status).to.equal(PROJECT_STATUS.FAILED);
+        expect(updateCall.args[3].lastError).to.be.a('string').and.not.be.empty;
+        expect(result.total).to.equal(0);
+    });
 });
 
 describe('bulk-publish-worker — terminalStatus', () => {

io/studio/test/bulk-publish/index.test.js

@@ -37,7 +37,7 @@ describe('bulk-publish/index.js — dispatcher', () => {
         expect(params.projectId).to.equal('proj-1');
         expect(params.publishedBy).to.equal('u@x.com');
         expect(params.authToken).to.equal('token');
-        expect(params).to.not.have.property('odinEndpoint');
+        expect(params.aemOdinEndpoint).to.equal('https://odin');
     });
 
     it('returns 400 and does not invoke worker when projectId missing', async () => {

studio/src/aem/aem.js

@@ -199,8 +199,9 @@ class AEM {
      * @param {AbortController} abortController used for cancellation
      * @returns {Promise<Object>} the raw fragment item
      */
-    async getFragmentById(baseUrl, id, headers, abortController) {
-        const response = await fetch(`${baseUrl}/adobe/sites/cf/fragments/${id}?references=direct-hydrated`, {
+    async getFragmentById(baseUrl, id, headers, abortController, { references = 'direct-hydrated' } = {}) {
+        const refParam = references ? `?references=${references}` : '';
+        const response = await fetch(`${baseUrl}/adobe/sites/cf/fragments/${id}${refParam}`, {
             headers,
             signal: abortController?.signal,
         });
@@ -1394,7 +1395,8 @@ class AEM {
                 /**
                  * @see AEM#getFragmentById
                  */
-                getById: (id, abortController) => this.getFragmentById(this.baseUrl, id, this.headers, abortController),
+                getById: (id, abortController, options) =>
+                    this.getFragmentById(this.baseUrl, id, this.headers, abortController, options),
                 /**
                  * @see AEM#getFragmentWithEtag
                  */

studio/src/bulk-publish/bulk-publish-client.js

@@ -46,11 +46,14 @@ export async function publishBulk({
     projectId,
     publishedBy = '',
     token,
+    aemOdinEndpoint,
     includeVariations = false,
     includeCards = false,
 }) {
     if (!projectId) throw new BulkPublishError('projectId is required');
-    return callAction(ioBaseUrl, ENDPOINT, { projectId, publishedBy, includeVariations, includeCards }, token);
+    const payload = { projectId, publishedBy, includeVariations, includeCards };
+    if (aemOdinEndpoint) payload.aemOdinEndpoint = aemOdinEndpoint;
+    return callAction(ioBaseUrl, ENDPOINT, payload, token);
 }
 
 export async function revertAction({ ioBaseUrl, projectId, token }) {

studio/src/bulk-publish/bulk-publish-store.js

@@ -18,6 +18,7 @@ export async function startPublishing({
     project,
     token,
     ioBaseUrl,
+    aemOdinEndpoint,
     repository,
     publishFn,
     pollIntervalMs = 2000,
@@ -26,24 +27,25 @@ export async function startPublishing({
     includeVariations = false,
     includeCards = false,
 }) {
-    const fn = publishFn ?? (await import('./bulk-publish-client.js')).publishBulk;
-    const profile = await window.adobeIMS?.getProfile?.().catch(() => null);
-    const publishedBy = profile?.email ?? '';
-
+    if (Store.bulkPublishProjects.publishing.get()[project.id]) return { alreadyPublishing: true };
     Store.bulkPublishProjects.publishing.set({
         ...Store.bulkPublishProjects.publishing.get(),
         [project.id]: true,
     });
+
+    const fn = publishFn ?? (await import('./bulk-publish-client.js')).publishBulk;
+    const profile = await window.adobeIMS?.getProfile?.().catch(() => null);
+    const publishedBy = profile?.email ?? '';
     const terminalStatuses = new Set([
         BULK_PUBLISH_STATUS.PUBLISHED,
         BULK_PUBLISH_STATUS.PARTIALLY_PUBLISHED,
         BULK_PUBLISH_STATUS.FAILED,
     ]);
     try {
-        await fn({ ioBaseUrl, projectId: project.id, publishedBy, token, includeVariations, includeCards });
+        await fn({ ioBaseUrl, projectId: project.id, publishedBy, token, aemOdinEndpoint, includeVariations, includeCards });
         let interval = pollIntervalMs;
         for (let i = 0; i < maxPolls; i++) {
-            await repository.refreshFragment(project, { skipPromoMerge: true }).catch(() => {});
+            await repository.refreshFragment(project, { skipPromoMerge: true, skipReferences: true }).catch(() => {});
             const statusField = project.get()?.fields?.find((f) => f.name === 'status');
             const status = statusField?.values?.[0];
             if (terminalStatuses.has(status)) return { status };

studio/src/bulk-publish/mas-bulk-publish-editor.js

@@ -228,7 +228,7 @@ class MasBulkPublishEditor extends LitElement {
     }
 
     get token() {
-        return window.adobeIMS?.getAccessToken()?.token;
+        return sessionStorage.getItem('masAccessToken') ?? window.adobeIMS?.getAccessToken()?.token;
     }
 
     get ioBaseUrl() {
@@ -856,10 +856,12 @@ class MasBulkPublishEditor extends LitElement {
         try {
             const outcome = await this.#withPendingAction(QUICK_ACTION.PUBLISH, async () => {
                 const { startPublishing } = await import('./bulk-publish-store.js');
+                const aemBaseUrl = this.repository?.aem?.baseUrl;
                 return startPublishing({
                     project: this.project,
                     token: this.token,
                     ioBaseUrl: this.ioBaseUrl,
+                    aemOdinEndpoint: aemBaseUrl?.startsWith('http://localhost') ? undefined : aemBaseUrl,
                     repository: this.repository,
                     includeVariations,
                     includeCards,

studio/src/mas-repository.js

@@ -2211,10 +2211,10 @@ export class MasRepository extends LitElement {
      * Updates a given fragment store with the latest data
      * @param {FragmentStore} store
      */
-    async refreshFragment(store, { skipPromoMerge = false } = {}) {
+    async refreshFragment(store, { skipPromoMerge = false, skipReferences = false } = {}) {
         store.setLoading(true);
         const id = store.get().id;
-        let latest = await this.aem.sites.cf.fragments.getById(id);
+        let latest = await this.aem.sites.cf.fragments.getById(id, null, skipReferences ? { references: null } : undefined);
         if (!skipPromoMerge) {
             latest = await promotionsRepository.mergePromoReferencesIntoFragmentData(this.aem, latest, () =>
                 this.loadPromotions(),

studio/src/mas-selection-panel.js

@@ -116,9 +116,44 @@ class MasSelectionPanel extends LitElement {
 
         if (fragmentIds.length === 0) return;
 
+        const allVariations = [];
+        const allCards = [];
+        const seen = new Set();
+
+        const hydratedFragments = await Promise.all(
+            fragmentIds.map((id) => this.repository.aem.sites.cf.fragments.getById(id).catch(() => null)),
+        );
+
+        for (const fragmentData of hydratedFragments) {
+            if (!fragmentData) continue;
+            const variationPaths = new Set(fragmentData.fields?.find((f) => f.name === 'variations')?.values ?? []);
+            const cardPaths = new Set([
+                ...(fragmentData.fields?.find((f) => f.name === 'cards')?.values ?? []),
+                ...(fragmentData.fields?.find((f) => f.name === 'collections')?.values ?? []),
+            ]);
+            for (const ref of fragmentData.references || []) {
+                if (!ref?.id || seen.has(ref.id)) continue;
+                if (variationPaths.has(ref.path)) {
+                    seen.add(ref.id);
+                    allVariations.push(ref);
+                } else if (cardPaths.has(ref.path)) {
+                    seen.add(ref.id);
+                    allCards.push(ref);
+                }
+            }
+        }
+
+        if (allVariations.length || allCards.length) {
+            const { MasPublishDialog } = await import('./publish/mas-publish-dialog.js');
+            const result = await MasPublishDialog.show({ variations: allVariations, cards: allCards });
+            if (!result.confirmed) return;
+            for (const id of result.selectedIds) {
+                if (!fragmentIds.includes(id)) fragmentIds.push(id);
+            }
+        }
+
         const success = await this.repository.bulkPublishFragments(fragmentIds);
         if (success) {
-            // Clear selection after successful publish
             this.selectionStore.set([]);
         }
     }