chore(npm): update @effect/* packages

JamieMason · Jul 31, 2023 · 3db1bc4 · 3db1bc4
1 parent ea6cacf
commit 3db1bc4
Show file tree

Hide file tree

Showing 27 changed files with 308 additions and 276 deletions.
diff --git a/package.json b/package.json
@@ -31,10 +31,10 @@
     "Tom Fletcher (https://github.com/tom-fletcher)"
   ],
   "dependencies": {
-    "@effect/data": "0.12.9",
-    "@effect/io": "0.27.0",
-    "@effect/match": "0.24.5",
-    "@effect/schema": "0.21.0",
+    "@effect/data": "0.17.1",
+    "@effect/io": "0.37.1",
+    "@effect/match": "0.31.0",
+    "@effect/schema": "0.32.0",
     "chalk": "4.1.2",
     "commander": "11.0.0",
     "cosmiconfig": "8.2.0",

diff --git a/src/bin-fix-mismatches/effects.ts b/src/bin-fix-mismatches/effects.ts
@@ -13,13 +13,13 @@ import { logGroupHeader } from '../lib/log-group-header';
 
 export const fixMismatchesEffects: VersionEffects<void> = {
   onFilteredOut() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onIgnored() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onValid() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onBanned(input) {
     return Effect.sync(() => removeVersions(input));

diff --git a/src/bin-lint-semver-ranges/effects.ts b/src/bin-lint-semver-ranges/effects.ts
@@ -11,13 +11,13 @@ import { logGroupHeader } from '../lib/log-group-header';
 
 export const lintSemverRangesEffects: SemverRangeEffects<void> = {
   onFilteredOut() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onIgnored() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onValid() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onSemverRangeMismatch(input) {
     return Effect.sync(() => pipe(input, logHeader, logRangeMismatch));
@@ -29,7 +29,7 @@ export const lintSemverRangesEffects: SemverRangeEffects<void> = {
     return Effect.sync(() => pipe(input, logHeader, logRangeMismatch));
   },
   onComplete() {
-    return Effect.unit();
+    return Effect.unit;
   },
 };
 

diff --git a/src/bin-list-mismatches/effects.ts b/src/bin-list-mismatches/effects.ts
@@ -9,13 +9,13 @@ import { logGroupHeader } from '../lib/log-group-header';
 
 export const listMismatchesEffects: VersionEffects<void> = {
   onFilteredOut() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onIgnored() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onValid() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onBanned(input) {
     return Effect.sync(() => pipe(input, logHeader, logBanned));
@@ -42,7 +42,7 @@ export const listMismatchesEffects: VersionEffects<void> = {
     return Effect.sync(() => pipe(input, logHeader, logLocalPackageMismatch));
   },
   onComplete() {
-    return Effect.unit();
+    return Effect.unit;
   },
 };
 

diff --git a/src/bin-list/effects.ts b/src/bin-list/effects.ts
@@ -11,7 +11,7 @@ import { logGroupHeader } from '../lib/log-group-header';
 
 export const listEffects: VersionEffects<void> = {
   onFilteredOut() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onIgnored(input) {
     return Effect.sync(() => pipe(input, logHeader, logIgnored));
@@ -44,7 +44,7 @@ export const listEffects: VersionEffects<void> = {
     return Effect.sync(() => pipe(input, logHeader, logFixableMismatch));
   },
   onComplete() {
-    return Effect.unit();
+    return Effect.unit;
   },
 };
 

diff --git a/src/bin-prompt/effects.ts b/src/bin-prompt/effects.ts
@@ -10,25 +10,25 @@ import { logGroupHeader } from '../lib/log-group-header';
 
 export const promptEffects: VersionEffects<void> = {
   onFilteredOut() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onIgnored() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onValid() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onBanned() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onHighestSemverMismatch() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onLowestSemverMismatch() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onPinnedMismatch() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onSameRangeMismatch(input) {
     return pipe(
@@ -37,7 +37,7 @@ export const promptEffects: VersionEffects<void> = {
     );
   },
   onSnappedToMismatch() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onNonSemverMismatch(input) {
     return pipe(
@@ -46,10 +46,10 @@ export const promptEffects: VersionEffects<void> = {
     );
   },
   onLocalPackageMismatch() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onComplete() {
-    return Effect.unit();
+    return Effect.unit;
   },
 };
 

diff --git a/src/bin-set-semver-ranges/effects.ts b/src/bin-set-semver-ranges/effects.ts
@@ -9,13 +9,13 @@ import type { SemverGroupReport } from '../get-semver-groups';
 
 export const setSemverRangesEffects: SemverRangeEffects<void> = {
   onFilteredOut() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onIgnored() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onValid() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onSemverRangeMismatch(input) {
     return Effect.sync(() => setVersions(input));
@@ -27,7 +27,7 @@ export const setSemverRangesEffects: SemverRangeEffects<void> = {
     return Effect.sync(() => setVersions(input));
   },
   onComplete() {
-    return Effect.unit();
+    return Effect.unit;
   },
 };
 

diff --git a/src/bin-update/effects.ts b/src/bin-update/effects.ts
@@ -31,37 +31,37 @@ let fetchCount = 0;
 
 export const updateEffects: VersionEffects<InputWithVersions | void> = {
   onFilteredOut() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onIgnored() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onValid(input) {
     return fetchPackageVersions(input);
   },
   onBanned() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onHighestSemverMismatch(input) {
     return fetchPackageVersions(input);
   },
   onLowestSemverMismatch() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onPinnedMismatch() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onSameRangeMismatch(input) {
     return fetchPackageVersions(input);
   },
   onSnappedToMismatch() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onNonSemverMismatch() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onLocalPackageMismatch() {
-    return Effect.unit();
+    return Effect.unit;
   },
   onComplete(ctx, results) {
     return promptForUpdates(results);
@@ -122,7 +122,7 @@ function fetchPackageVersions<T extends VersionGroupReport.Any>(input: Input<T>)
 function promptForUpdates(results: Array<InputWithVersions | void>) {
   spinner.stop();
   return pipe(
-    Effect.Do(),
+    Effect.Do,
     Effect.bind('choices', () =>
       Effect.sync(() =>
         results.reduce((arr: ChoiceAndResult[], result): ChoiceAndResult[] => {
@@ -157,8 +157,8 @@ function promptForUpdates(results: Array<InputWithVersions | void>) {
       ),
     ),
     Effect.bind('chosenUpdates', ({ choices }) =>
-      Effect.tryCatchPromise(
-        () =>
+      Effect.tryPromise({
+        try: () =>
           prompts([
             {
               name: 'indexes',
@@ -172,8 +172,8 @@ function promptForUpdates(results: Array<InputWithVersions | void>) {
           ])
             .then(({ indexes = [] }: { indexes: number[] }) => ({ choices, indexes }))
             .then(({ choices, indexes }) => indexes.map((i) => choices[i]!.result)),
-        () => new Error('Prompt failed'),
-      ),
+        catch: () => new Error('Prompt failed'),
+      }),
     ),
     Effect.flatMap(({ chosenUpdates }) =>
       Effect.sync(() => {
@@ -186,7 +186,7 @@ function promptForUpdates(results: Array<InputWithVersions | void>) {
         });
       }),
     ),
-    Effect.catchAll(() => Effect.unit()),
+    Effect.catchAll(() => Effect.unit),
   );
 }
 
@@ -210,10 +210,10 @@ function fetchUrl(url: string): Effect.Effect<never, HttpError | JsonParseError,
         });
     }),
     Effect.flatMap((body) =>
-      Effect.tryCatch(
-        () => JSON.parse(body),
-        (err) => new JsonParseError({ error: String(err) }),
-      ),
+      Effect.try({
+        try: () => JSON.parse(body),
+        catch: (err) => new JsonParseError({ error: String(err) }),
+      }),
     ),
   );
 }
diff --git a/src/bin-update/update.ts b/src/bin-update/update.ts
@@ -23,7 +23,7 @@ export function update(cli: Partial<CliConfig>, env: DefaultEnv) {
     Effect.flatMap(writeIfChanged),
     Effect.flatMap(exitIfInvalid),
     Effect.catchTags(createErrorHandlers(defaultErrorHandlers)),
-    Effect.withParallelism(10),
+    Effect.withConcurrency(10),
     Effect.provideContext(
       pipe(Context.empty(), Context.add(CliConfigTag, cli), Context.add(EnvTag, createEnv(env))),
     ),

diff --git a/src/create-program/semver-ranges.ts b/src/create-program/semver-ranges.ts
@@ -16,7 +16,7 @@ export function createSemverRangesProgram<T extends SemverRangeEffects<any>>(
   return pipe(
     getSemverGroups(ctx),
     Effect.flatMap((semverGroups) =>
-      Effect.allPar(
+      Effect.all(
         semverGroups.flatMap((group) =>
           group.inspect().map((reportEffect, index) =>
             pipe(
@@ -51,6 +51,7 @@ export function createSemverRangesProgram<T extends SemverRangeEffects<any>>(
             ),
           ),
         ),
+        { concurrency: 'inherit' },
       ),
     ),
     Effect.flatMap((results) => effects.onComplete(ctx, results)),

diff --git a/src/create-program/versions.ts b/src/create-program/versions.ts
@@ -16,7 +16,7 @@ export function createVersionsProgram<T extends VersionEffects<any>>(
   return pipe(
     getVersionGroups(ctx),
     Effect.flatMap((versionGroups) =>
-      Effect.allPar(
+      Effect.all(
         versionGroups.flatMap((group) =>
           group.inspect().map((reportEffect, index) =>
             pipe(
@@ -66,6 +66,7 @@ export function createVersionsProgram<T extends VersionEffects<any>>(
             ),
           ),
         ),
+        { concurrency: 'inherit' },
       ),
     ),
     Effect.flatMap((results) => effects.onComplete(ctx, results)),