6405951401

Committed 04 Oct 2023 12:27PM UTC coverage: 100.0%. Remained the same

Build # 6405951401

Build Type

push

github

Committed by

web-flow

Commit Message

Merge pull request #26 from jeffersd/fix-docker-argument-list

Fix docker build argument list

Run Details

148 of 148 branches covered (100.0%)

Branch coverage included in aggregate %.

360 of 360 relevant lines covered (100.0%)

10.51 hits per line

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

100.0

/lib/lambda.js

const http = require('http');

async function invoke(invokeOptions) {
  const {
    port,
    data,
    retryCount,
    retryInterval,
    stdout,
  } = invokeOptions;

  const body = JSON.stringify(data);

  const options = {
    hostname: 'localhost',
    port,
    path: '/2015-03-31/functions/function/invocations',
    method: 'POST',
  };

  return new Promise((resolve, reject) => {
    const req = http.request(options, (res) => {
      const response = {
        status: res.statusCode,
        headers: res.headers,
      };

      res.pipe(stdout ? process.stdout : process.stderr);

      res.on('error', reject);

      res.on('end', () => {
        if (!stdout) {
          // For readable output, insert some new lines to console.
          // If stdout is requested, we keep outputs untouched as much as possible.
          process.stderr.write('\n\n');
        }
        resolve(response);
      });
    });

    // NOTE:
    // If the request starts immediately after the docker container starts,
    // it will fail because the container is not ready to accept requests.
    // We have to retry in case of that.
    req.on('error', (err) => {
      if (retryCount === 0) {
        reject(err);
      }

      const retryOptions = {
        ...invokeOptions,
        retryCount: retryCount - 1,
      };

      setTimeout(() => {
        resolve(invoke(retryOptions));
      }, retryInterval);
    });

    req.write(body);
    req.end();
  });
}

module.exports = { invoke };

1	const http = require('http');	2✔
2
3	async function invoke(invokeOptions) {
4	const {
5	port,
6	data,
7	retryCount,
8	retryInterval,
9	stdout,
10	} = invokeOptions;	11✔
11
12	const body = JSON.stringify(data);	11✔
13
14	const options = {	11✔
15	hostname: 'localhost',
16	port,
17	path: '/2015-03-31/functions/function/invocations',
18	method: 'POST',
19	};
20
21	return new Promise((resolve, reject) => {	11✔
22	const req = http.request(options, (res) => {	11✔
23	const response = {	7✔
24	status: res.statusCode,
25	headers: res.headers,
26	};
27
28	res.pipe(stdout ? process.stdout : process.stderr);	7✔
29
30	res.on('error', reject);	7✔
31
32	res.on('end', () => {	7✔
33	if (!stdout) {	6✔
34	// For readable output, insert some new lines to console.
35	// If stdout is requested, we keep outputs untouched as much as possible.
36	process.stderr.write('\n\n');	5✔
37	}
38	resolve(response);	6✔
39	});
40	});
41
42	// NOTE:
43	// If the request starts immediately after the docker container starts,
44	// it will fail because the container is not ready to accept requests.
45	// We have to retry in case of that.
46	req.on('error', (err) => {	11✔
47	if (retryCount === 0) {	4✔
48	reject(err);	1✔
49	}
50
51	const retryOptions = {	4✔
52	...invokeOptions,
53	retryCount: retryCount - 1,
54	};
55
56	setTimeout(() => {	4✔
57	resolve(invoke(retryOptions));	3✔
58	}, retryInterval);
59	});
60
61	req.write(body);	11✔
62	req.end();	11✔
63	});
64	}
65
66	module.exports = { invoke };	2✔

kaicoh / serverless-rust-plugin / 6405951401

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