Function run

packages/plugins/onepassword/src/sdk/service.ts:214–239

(
      base: readonly string[],
      operation: string,
    )

): Effect.Effect<OnePasswordService, OnePasswordError> =>
  Effect.sync(() => {
    const run = (
      base: readonly string[],
      operation: string,
    ): Effect.Effect<string, OnePasswordError> => {
      const spawn = Effect.promise((signal) =>
        opCliExec({ args: cliArgs(auth, base), env: cliEnv(auth), timeoutMs, signal }),
      ).pipe(
        Effect.flatMap((result) => {
          if (result.ok) return Effect.succeed(result.stdout);
          return Effect.fail(
            result.timedOut
              ? new OnePasswordError({
                  operation,
                  message: makeTimeoutMessage(operation, timeoutMs),
                })
              : new OnePasswordError({
                  operation,
                  message: messageWithCause(`1Password CLI ${operation} failed`, result),
                }),
          );
        }),
      );
      return (auth.kind === "desktop-app" ? cliPromptLock.withPermits(1)(spawn) : spawn).pipe(
        Effect.withSpan(`onepassword.cli.${operation}`),
      );
    };

    const runJson = <A>(
      base: readonly string[],