12877771264

Committed 21 Jan 2025 12:28AM UTC coverage: 71.613% (+15.7%) from 55.882%

Build # 12877771264

Build Type

push

github

Committed by

nikelborm

Commit Message

quick save: Tue Jan 21 03:28:59 MSK 2025

Run Details

69 of 78 branches covered (88.46%)

Branch coverage included in aggregate %.

2 of 2 new or added lines in 2 files covered. (100.0%)

41 existing lines in 5 files now uncovered.

486 of 697 relevant lines covered (69.73%)

3.46 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

33.33

/src/writeFileStreamToDestinationPath.ts

import { Effect, gen, tryPromise } from 'effect/Effect';
import { createWriteStream } from 'node:fs';
import { Readable } from 'node:stream';
import { pipeline } from 'node:stream/promises';
import { OutputConfigTag } from './configContext.js';
import { TaggedErrorVerifyingCause } from './TaggedErrorVerifyingCause.js';

export const writeFileStreamToDestinationPath = <E, R>(
  self: Effect<Readable, E, R>,
) =>
  gen(function* () {
    const fileStream = yield* self;

    const {
      localPathAtWhichEntityFromRepoWillBeAvailable: localDownloadedFilePath,
    } = yield* OutputConfigTag;

    yield* tryPromise({
      try: signal =>
        pipeline(fileStream, createWriteStream(localDownloadedFilePath), {
          signal,
        }),
      catch: cause => new FailedToWriteFileStreamToDestinationPath({ cause }),
    });
  });

export class FailedToWriteFileStreamToDestinationPath extends TaggedErrorVerifyingCause<{
  cause: unknown;
}>()(
  'FailedToWriteFileStreamToDestinationPath',
  'Error: Failed to write file stream to destination path',
) {}

1	import { Effect, gen, tryPromise } from 'effect/Effect';	1✔
2	import { createWriteStream } from 'node:fs';
3	import { Readable } from 'node:stream';
4	import { pipeline } from 'node:stream/promises';
5	import { OutputConfigTag } from './configContext.js';
6	import { TaggedErrorVerifyingCause } from './TaggedErrorVerifyingCause.js';
7
8	export const writeFileStreamToDestinationPath = <E, R>(	1✔
9	self: Effect<Readable, E, R>,	×
10	) =>
11	gen(function* () {	×
12	const fileStream = yield* self;	×
13
14	const {	×
15	localPathAtWhichEntityFromRepoWillBeAvailable: localDownloadedFilePath,	×
16	} = yield* OutputConfigTag;	×
17
UNCOV 18	yield* tryPromise({	×
19	try: signal =>	×
20	pipeline(fileStream, createWriteStream(localDownloadedFilePath), {	×
21	signal,	×
22	}),	×
23	catch: cause => new FailedToWriteFileStreamToDestinationPath({ cause }),	×
24	});	×
25	});	×
26
27	export class FailedToWriteFileStreamToDestinationPath extends TaggedErrorVerifyingCause<{	1✔
28	cause: unknown;
29	}>()(	1✔
30	'FailedToWriteFileStreamToDestinationPath',	1✔
31	'Error: Failed to write file stream to destination path',	1✔
32	) {}	1✔

nikelborm / fetch-github-folder / 12877771264

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous