8ee34bb7-b502-4225-abb7-e1291f281f8e

Build # 8ee34bb7-b502-4225-abb7-e1291f281f8e

Build Type

push

circleci

Committed by Mark Riedesel

Commit Message

bump lerna to ^6.4.1

Run Details

218 of 549 branches covered (39.71%)

Branch coverage included in aggregate %.

903 of 1504 relevant lines covered (60.04%)

16.01 hits per line

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

16.13

/packages/core/src/handlers/head.ts

import { Observable, of, from as observableFrom } from "rxjs";
import type { TussleIncomingRequest } from '@tussle/spec/interface/request';
import type { TussleStorageFileInfo } from '@tussle/spec/interface/storage';
import type { Tussle } from '../core';
import { switchMap, map } from 'rxjs/operators';

export default function handleHead<Req, P>(
  _core: Tussle,
  ctx: TussleIncomingRequest<Req, P>
): Observable<TussleIncomingRequest<Req, P>>
{
  const params = extractParamsFromHeaders(ctx);
  const store = ctx.cfg.storage;
  if (!store) {
    return of(toResponse(ctx, {location: ctx.request.path, info: null}));
  } else {
    const params$ = observableFrom(ctx.source.hook('before-head', ctx, params));
    return params$.pipe(
      switchMap((params) => store.getFileInfo(params)),
      switchMap((params) => ctx.source.hook('after-head', ctx, params)),
      map(fileInfo => toResponse(ctx, fileInfo)),
    );
  }
}

const extractParamsFromHeaders = <T, P>(ctx: TussleIncomingRequest<T, P>) => {
  const location = ctx.request.path;
  return {
    location,
  };
};

export type ExtractedHeadHeaders = ReturnType<typeof extractParamsFromHeaders>;

const toResponse = <T, P>(
  ctx: TussleIncomingRequest<T, P>,
  fileInfo: TussleStorageFileInfo,
): TussleIncomingRequest<T, P> => {
  const { info } = fileInfo;
  if (info) {
    const headers: Record<string, string> = {
      'Upload-Offset': (info.currentOffset || 0).toString(),
    };
    if (typeof info.uploadLength === 'number') {
      headers['Upload-Length'] = info.uploadLength.toString();
    }
    ctx.response = {
      status: 200, // OK
      headers,
    };
  } else {
    ctx.response = {
      status: 410, // GONE
    };
  }
  return ctx;
};


1	import { Observable, of, from as observableFrom } from "rxjs";	1✔
2	import type { TussleIncomingRequest } from '@tussle/spec/interface/request';
3	import type { TussleStorageFileInfo } from '@tussle/spec/interface/storage';
4	import type { Tussle } from '../core';
5	import { switchMap, map } from 'rxjs/operators';	1✔
6
7	export default function handleHead<Req, P>(	1✔
8	_core: Tussle,
9	ctx: TussleIncomingRequest<Req, P>
10	): Observable<TussleIncomingRequest<Req, P>>
11	{
12	const params = extractParamsFromHeaders(ctx);	×
13	const store = ctx.cfg.storage;	×
14	if (!store) {	×
15	return of(toResponse(ctx, {location: ctx.request.path, info: null}));	×
16	} else {
17	const params$ = observableFrom(ctx.source.hook('before-head', ctx, params));	×
18	return params$.pipe(	×
19	switchMap((params) => store.getFileInfo(params)),	×
20	switchMap((params) => ctx.source.hook('after-head', ctx, params)),	×
21	map(fileInfo => toResponse(ctx, fileInfo)),	×
22	);
23	}
24	}
25
26	const extractParamsFromHeaders = <T, P>(ctx: TussleIncomingRequest<T, P>) => {	1✔
27	const location = ctx.request.path;	×
28	return {	×
29	location,
30	};
31	};
32
33	export type ExtractedHeadHeaders = ReturnType<typeof extractParamsFromHeaders>;
34
35	const toResponse = <T, P>(	1✔
36	ctx: TussleIncomingRequest<T, P>,
37	fileInfo: TussleStorageFileInfo,
38	): TussleIncomingRequest<T, P> => {
39	const { info } = fileInfo;	×
40	if (info) {	×
41	const headers: Record<string, string> = {	×
42	'Upload-Offset': (info.currentOffset \|\| 0).toString(),	×
43	};
44	if (typeof info.uploadLength === 'number') {	×
45	headers['Upload-Length'] = info.uploadLength.toString();	×
46	}
47	ctx.response = {	×
48	status: 200, // OK
49	headers,
50	};
51	} else {
52	ctx.response = {	×
53	status: 410, // GONE
54	};
55	}
56	return ctx;	×
57	};
58

Klowner / tussle / 8ee34bb7-b502-4225-abb7-e1291f281f8e

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