Function publish

packages/plugins/apps/src/pipeline/publish.ts:140–282

(
  deps: PublishDeps,
  input: PublishInput,
)

});

export const publish = (
  deps: PublishDeps,
  input: PublishInput,
): Effect.Effect<PublishResult, PublishError> =>
  Effect.gen(function* () {
    const owner = input.owner ?? "org";
    const bundler =
      deps.bundler ??
      (yield* defaultBundleBackend().pipe(
        Effect.mapError((error) => toPublishError("bundle", "", error)),
      ));
    const limitError = enforcePublishLimits(input.files);
    if (limitError) return yield* limitError;
    const files = fileMap(input.files);
    const discovered = discover(files);
    if (isPublishError(discovered)) return yield* discovered;

    const existing = yield* deps.store.getDescriptorRecord(input.app).pipe(
      Effect.mapError(
        (cause) =>
          new PublishError({
            stage: "project",
            message: "failed to read existing app descriptor",
            diagnostics: [],
            cause,
          } as never),
      ),
    );
    if (existing?.sourceRef === input.sourceRef) {
      const descriptorBody = yield* deps.store.getBlob(existing.descriptorKey).pipe(
        Effect.mapError(
          () =>
            new PublishError({
              stage: "project",
              message: "failed to read existing descriptor blob",
              diagnostics: [],
            }),
        ),
      );
      if (descriptorBody) {
        return {
          descriptor: decodeJson(descriptorBody) as AppDescriptor,
          publishedTools: [],
          skipped: discovered.skipped,
          noop: true,
        };
      }
    }

    const staged: {
      readonly entry: string;
      readonly bundle: string;
      readonly collected: readonly CollectedTool[];
      readonly source: ModuleSourceRef;
    }[] = [];
    for (const artifact of discovered.tools) {
      const bundled = yield* bundleEntry({ files, entry: artifact.entry }, bundler).pipe(
        Effect.mapError((cause) => toPublishError("bundle", artifact.entry, cause)),