zotoio/github-task-manager

File EventHandler.js has 380 lines of code (exceeds 300 allowed). Consider refactoring.

Open

'use strict';
import requireDir from 'require-dir';
import { Plugin } from './Plugin';
import { default as formatJson } from 'format-json';
import { Executor } from './Executor';

Function handler has 152 lines of code (exceeds 100 allowed). Consider refactoring.

Open

function handler(event, context, callback) {
    if (process.env.IAM_ENABLED) {
        AWS.config.update({
            httpOptions: {
                agent: PROXY_AGENT(process.env.AWS_PROXY)

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    if (process.env.GTM_DYNAMO_VPCE) {
        console.log('Configuring DynamoDB to use VPC Endpoint');
        dynamo = new AWS.DynamoDB({
            httpOptions: {
                agent: new HTTPS.Agent()

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

            if (process.env.GTM_DYNAMO_VPCE) {
                log.info('Configuring DynamoDB to use VPC Endpoint');
                DDB = new AWS.DynamoDB({
                    httpOptions: {
                        agent: new https.Agent()

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

            ddbStream.on('modify record', object => {
                log.debug(`updated ${json.plain(object)}`);
                INITIAL_DATA[tableName].push(object);
                sseStream.updateInit(INITIAL_DATA[tableName]);
                sseStream.send(object);

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

            ddbStream.on('insert record', object => {
                log.debug(`inserted ${json.plain(object)}`);
                INITIAL_DATA[tableName].push(object);
                sseStream.updateInit(INITIAL_DATA[tableName]);
                sseStream.send(object);

• Read up
  Read up

AgentUtils has 27 functions (exceeds 25 allowed). Consider refactoring.

Open

export class AgentUtils {
    static agentId() {
        return AgentLogger.AGENT_ID;
    }

File AgentUtils.js has 310 lines of code (exceeds 300 allowed). Consider refactoring.

Open

'use strict';

const pullRequestData = require('./pullrequest.json');
const { URL } = require('url');
const crypto = require('crypto');

File AgentMetrics.js has 306 lines of code (exceeds 300 allowed). Consider refactoring.

Open

import { default as ExpressSSE } from 'express-sse';
import { default as AWS } from 'aws-sdk';
import { default as AgentLogger } from './AgentLogger';
import { default as json } from 'format-json';
import { default as DynamoDBStream } from 'dynamodb-stream';

Identical blocks of code found in 2 locations. Consider refactoring.

Open

        if (process.env.GTM_ELASTIC_HOST && process.env.GTM_ELASTIC_PORT) {
            let baseUrl = process.env.GTM_BASE_URL || 'http://localhost:9091';
            url = `${baseUrl}/metrics/log/gtm-${event.eventId}.txt`;
        }

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

                if (process.env.GTM_ELASTIC_HOST && process.env.GTM_ELASTIC_PORT) {
                    let baseUrl = process.env.GTM_BASE_URL || 'http://localhost:9091';
                    url = `${baseUrl}/metrics/log/gtm-${event.eventId}.txt`;
                }

• Read up
  Read up

Function processTasks has 117 lines of code (exceeds 100 allowed). Consider refactoring.

Open

    async processTasks(event, parent) {
        let promises = [];
        let log = this.log;

        if (parent.tasks) {

Similar blocks of code found in 2 locations. Consider refactoring.

Open

        app.get('/metrics/health/detail', async (req, res) => {
            let includeDetail = true;
            let result = await this.getHealth(ddb, includeDetail);
            res.json(result);
            res.end();

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

        app.get('/metrics/health', async (req, res) => {
            let includeDetail = false;
            let result = await this.getHealth(ddb, includeDetail);
            res.json(result);
            res.end();

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

                } else {
                    task.results = {
                        passed: false,
                        message: 'Response validation failed',
                        url: 'http://www.softwareishard.com/blog/har-12-spec/#request',

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

                if (this.validate(task, response)) {
                    task.results = {
                        passed: true,
                        message: 'Request completed',
                        url: 'http://www.softwareishard.com/blog/har-12-spec/#request',

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

    if (process.env.IAM_ENABLED) {
        AWS.config.update({
            httpOptions: {
                agent: PROXY_AGENT(process.env.AWS_PROXY)
            }

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

if (process.env.IAM_ENABLED) {
    AWS.config.update({
        httpOptions: {
            agent: proxy(process.env.HTTP_PROXY)
        }

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

if (process.env.AWS_PROXY) {
    AWS.config.update({
        httpOptions: {
            agent: proxy(process.env.AWS_PROXY)
        }

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

    if (process.env.AWS_PROXY) {
        AWS.config.update({
            httpOptions: {
                agent: proxy(process.env.AWS_PROXY)
            }

• Read up
  Read up