trigger.spec.js

import { trigger } from './'

const { triggerStates, triggers: triggerModel } = trigger

describe('trigger states', () => {
  it('should get execution date', () => {
    expect(
      triggerStates.getLastExecution({
        current_state: {
          last_execution: '2010-09-10T00:00'
        }
      })
    ).toBe('2010-09-10T00:00')
    expect(triggerStates.getLastExecution({})).toBe(undefined)
  })

  it('should return the last execution date', () => {
    expect(
      triggerStates.getLastSuccess({
        current_state: {
          last_success: '2010-09-12T00:00'
        }
      })
    ).toBe('2010-09-12T00:00')
    expect(triggerStates.getLastSuccess({})).toBe(undefined)
  })

  it('should return whether or not the konnector is errored', () => {
    expect(
      triggerStates.isErrored({
        current_state: { status: 'errored' }
      })
    ).toBe(true)
    expect(
      triggerStates.isErrored({
        current_state: { status: 'ok' }
      })
    ).toBe(false)
    expect(triggerStates.isErrored({})).toBe(false)
  })

  it('should return the last error', () => {
    expect(
      triggerStates.getLastErrorType({
        current_state: { last_error: 'LOGIN_FAILED' }
      })
    ).toBe('LOGIN_FAILED')
    expect(
      triggerStates.getLastErrorType({
        current_state: { status: 'ok' }
      })
    ).toBe(undefined)
    expect(triggerStates.getLastErrorType({})).toBe(undefined)
  })
})

describe('trigger model', () => {
  const normalTrigger = {
    _rev: '1-31eb8f0da1db0f3196ccf0d4329ea554',
    prefix: 'toto.mycozy.cloud',
    arguments: '0 35 0 * * 3',
    message: {
      account: '4cbfe8f3d89edf60542d5fe9cdcac7b1',
      konnector: 'orangemobile'
    },
    _id: 'fa4c076914ce46a92fa3e7e5f0672ca5',
    domain: 'claire.mycozy.cloud',
    worker: 'konnector',
    debounce: '',
    options: null,
    type: '@cron'
  }

  const legacyTrigger = {
    arguments: '37 42 0 * * 3',
    domain: 'claire.mycozy.cloud',
    _rev: '2-a9f7f0eb5ccc0871e10721797ef5dcf0',
    worker: 'konnector',
    _id: '3a7c363eea2ddb4d73bd11afa9bb4691',
    type: '@cron',
    options: null,
    message: {
      Data:
        'eyJrb25uZWN0b3IiOiJhbWVsaSIsImFjY291bnQiOiIzYTdjMzYzZWVhMmRkYjRkNzNiZDExYWZhOWJiM2ViNiJ9',
      Type: 'json'
    }
  }

  const cliskTrigger = {
    _rev: '1-31eb8f0da1db0f3196ccf0d4329ea554',
    prefix: 'toto.mycozy.cloud',
    arguments: '0 35 0 * * 3',
    message: {
      account: '4cbfe8f3d89edf60542d5fe9cdcac7b1',
      konnector: 'orangemobile'
    },
    _id: 'fa4c076914ce46a92fa3e7e5f0672ca5',
    domain: 'claire.mycozy.cloud',
    worker: 'client',
    debounce: '',
    options: null,
    type: '@client'
  }

  describe('getKonnectorFromTrigger', () => {
    it('should work with normal triggers', () => {
      expect(triggerModel.getKonnector(normalTrigger)).toBe('orangemobile')
    })

    it('should work with legacy triggers', () => {
      expect(triggerModel.getKonnector(legacyTrigger)).toBe('ameli')
    })

    it('should work with clisk triggers', () => {
      expect(triggerModel.getKonnector(cliskTrigger)).toBe('orangemobile')
    })
  })

  describe('getAccountId', () => {
    it('should return the account id', () => {
      expect(triggerModel.getAccountId(normalTrigger)).toBe(
        '4cbfe8f3d89edf60542d5fe9cdcac7b1'
      )
      expect(triggerModel.getAccountId(legacyTrigger)).toBe(
        '3a7c363eea2ddb4d73bd11afa9bb3eb6'
      )
    })
  })

  describe('isLatestErrorMuted', () => {
    const triggerWithError = {
      _id: 'fa4c076914ce46a92fa3e7e5f0672ca5',
      worker: 'konnector',
      type: '@cron',
      message: {
        account: '123abc',
        konnector: 'orangemobile'
      },
      current_state: {
        status: 'errored',
        last_error: 'LOGIN_FAILED',
        last_success: '2010-09-12T00:00'
      }
    }

    it('should return false when there are no muted errors', () => {
      expect(triggerModel.isLatestErrorMuted(triggerWithError, {})).toBe(false)
    })

    it('should return true when the error is muted', () => {
      const account = {
        _id: '123abc',
        mutedErrors: [
          {
            type: 'LOGIN_FAILED',
            mutedAt: '2010-09-15T00:00'
          }
        ]
      }
      expect(triggerModel.isLatestErrorMuted(triggerWithError, account)).toBe(
        true
      )
    })

    it('should ignore errors that are not muted', () => {
      const account = {
        _id: '123abc',
        mutedErrors: [
          {
            type: 'USER_ACTION_NEEDED',
            mutedAt: '2010-09-15T00:00'
          }
        ]
      }
      expect(triggerModel.isLatestErrorMuted(triggerWithError, account)).toBe(
        false
      )
    })

    it('should ignore muted errors if the trigger has been successful after the mute', () => {
      const account = {
        _id: '123abc',
        mutedErrors: [
          {
            type: 'LOGIN_FAILED',
            mutedAt: '2010-09-01T00:00' // muted before the last_success in the trigger
          }
        ]
      }
      expect(triggerModel.isLatestErrorMuted(triggerWithError, account)).toBe(
        false
      )
    })

    it('should mute errors if there has never been a success date', () => {
      const triggerWithNoSuccess = {
        _id: 'fa4c076914ce46a92fa3e7e5f0672ca5',
        worker: 'konnector',
        type: '@cron',
        message: {
          account: '123abc',
          konnector: 'orangemobile'
        },
        current_state: {
          status: 'errored',
          last_error: 'LOGIN_FAILED'
        }
      }
      const account = {
        _id: '123abc',
        mutedErrors: [
          {
            type: 'LOGIN_FAILED',
            mutedAt: '2010-09-01T00:00'
          }
        ]
      }
      expect(
        triggerModel.isLatestErrorMuted(triggerWithNoSuccess, account)
      ).toBe(true)
    })
  })

  describe('hasActionableError', () => {
    it('should return a trigger error can be fixed by the user', () => {
      expect(
        triggerModel.hasActionableError({
          current_state: {
            last_error: 'LOGIN_FAILED'
          }
        })
      ).toBe(true)
      expect(
        triggerModel.hasActionableError({
          current_state: {
            last_error: 'UNKNOWN_ERROR'
          }
        })
      ).toBe(false)
    })
  })

  describe('buildTriggerAttributes', () => {
    const konnector = { slug: 'konnectest' }
    const account = { _id: '963a51f6cdd34401b0904de32cc5578d' }

    it('builds attributes', () => {
      expect(
        triggerModel.buildTriggerAttributes({ konnector, account })
      ).toEqual({
        arguments: '0 0 0 * * 0',
        type: '@cron',
        worker: 'konnector',
        message: {
          account: '963a51f6cdd34401b0904de32cc5578d',
          konnector: 'konnectest'
        }
      })
    })

    it('builds attributes with cron', () => {
      const cron = '0 0 0 * * 2'
      expect(
        triggerModel.buildTriggerAttributes({ konnector, account, cron })
      ).toEqual({
        arguments: '0 0 0 * * 2',
        type: '@cron',
        worker: 'konnector',
        message: {
          account: '963a51f6cdd34401b0904de32cc5578d',
          konnector: 'konnectest'
        }
      })
    })

    it('builds for client side connectors', () => {
      const clientSideConnector = { ...konnector, clientSide: true }
      expect(
        triggerModel.buildTriggerAttributes({
          konnector: clientSideConnector,
          account
        })
      ).toEqual({
        type: '@client',
        worker: 'konnector',
        message: {
          account: '963a51f6cdd34401b0904de32cc5578d',
          konnector: 'konnectest'
        }
      })
    })

    it('build attributes with folder', () => {
      const folder = { _id: '4c43f8e88e5f4a608667da6b5bae8fa4' }
      expect(
        triggerModel.buildTriggerAttributes({ konnector, account, folder })
      ).toEqual({
        arguments: '0 0 0 * * 0',
        type: '@cron',
        worker: 'konnector',
        message: {
          account: '963a51f6cdd34401b0904de32cc5578d',
          folder_to_save: '4c43f8e88e5f4a608667da6b5bae8fa4',
          konnector: 'konnectest'
        }
      })
    })
  })
})