13656842746

Committed 31 May 2023 01:52PM UTC coverage: 20.328%. First build

Build # 13656842746

Build Type

push

github

Committed by

web-flow

Commit Message

Merge pull request #17 from ckapps/chore/update-deps

Chore/update deps

Run Details

32 of 288 branches covered (11.11%)

Branch coverage included in aggregate %.

32 of 270 new or added lines in 73 files covered. (11.85%)

464 of 2152 relevant lines covered (21.56%)

0.76 hits per line

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

0.0

/packages/server/src/http.server.ts

import {
  bindEagerlyTo,
  BoundDependency,
  ContextDependency,
  createReader,
  ServerIO,
} from '@marblejs/core';
import { createServer, HttpServer } from '@marblejs/http';
import {
  EventBus,
  EventBusClient,
  EventBusClientToken,
  EventBusToken,
} from '@marblejs/messaging';
import { defaultServerConfig, ServerConfig } from './config';
import { eventBusListener } from './eventbus.listener';
import { listener } from './http.listener';
import { ServerConfigToken } from './tokens';

/**
 * Creates the server from the given `config`.
 *
 * @param deps Dependencies for the server
 * @param config Server configuration
 */
export function server(
  deps: BoundDependency<unknown, ContextDependency>[],
  config: ServerConfig = defaultServerConfig,
): Promise<ServerIO<HttpServer>> {
  const { port } = config;

  // Add server config to the dependencies
  const ServerConfigReader = createReader<ServerConfig>(() => config);

  return createServer({
    listener,
    port,
    dependencies: [
      ...deps,
      bindEagerlyTo(EventBusToken)(EventBus({ listener: eventBusListener })),
      bindEagerlyTo(EventBusClientToken)(EventBusClient),
      bindEagerlyTo(ServerConfigToken)(ServerConfigReader),
    ],
  });
}

1	import {	×
2	bindEagerlyTo,
3	BoundDependency,
4	ContextDependency,
5	createReader,
6	ServerIO,
7	} from '@marblejs/core';
NEW 8	import { createServer, HttpServer } from '@marblejs/http';	×
9	import {	×
10	EventBus,
11	EventBusClient,
12	EventBusClientToken,
13	EventBusToken,
14	} from '@marblejs/messaging';
15	import { defaultServerConfig, ServerConfig } from './config';	×
16	import { eventBusListener } from './eventbus.listener';	×
NEW 17	import { listener } from './http.listener';	×
18	import { ServerConfigToken } from './tokens';	×
19
20	/**
21	* Creates the server from the given `config`.
22	*
23	* @param deps Dependencies for the server
24	* @param config Server configuration
25	*/
26	export function server(	×
27	deps: BoundDependency<unknown, ContextDependency>[],
28	config: ServerConfig = defaultServerConfig,	×
29	): Promise<ServerIO<HttpServer>> {
30	const { port } = config;	×
31
32	// Add server config to the dependencies
33	const ServerConfigReader = createReader<ServerConfig>(() => config);	×
34
35	return createServer({	×
36	listener,
37	port,
38	dependencies: [
39	...deps,
40	bindEagerlyTo(EventBusToken)(EventBus({ listener: eventBusListener })),
41	bindEagerlyTo(EventBusClientToken)(EventBusClient),
42	bindEagerlyTo(ServerConfigToken)(ServerConfigReader),
43	],
44	});
45	}

ckapps / overckd / 13656842746

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