Function connectionsUpdate

packages/core/sdk/src/executor.ts:4672–4702

(
      ref: ConnectionRef,
      input: UpdateConnectionInput,
    )

      findConnectionRow(ref).pipe(Effect.map((row) => (row ? rowToConnection(row) : null)));

    const connectionsUpdate = (
      ref: ConnectionRef,
      input: UpdateConnectionInput,
    ): Effect.Effect<Connection, ConnectionNotFoundError | OrgWriteDeniedError | StorageFailure> =>
      transaction(
        Effect.gen(function* () {
          yield* guardOrgWrite(ref.owner);
          const row = yield* findConnectionRow(ref);
          if (!row) {
            return yield* new ConnectionNotFoundError({
              owner: ref.owner,
              integration: ref.integration,
              name: ref.name,
            });
          }
          const set: Record<string, unknown> = { updated_at: new Date() };
          if (input.description !== undefined) set.description = input.description;
          if (input.identityLabel !== undefined) set.identity_label = input.identityLabel;
          yield* core.updateMany("connection", {
            where: (b: AnyCb) =>
              b.and(
                byOwner(ref.owner)(b),
                b("integration", "=", String(ref.integration)),
                b("name", "=", String(ref.name)),
              ),
            set,
          });
          const updated = yield* findConnectionRow(ref);
          return rowToConnection(updated ?? row);
        }),
      );

    const connectionsRemove = (
      ref: ConnectionRef,