packages/emails/src/__tests__/server.test.ts - main - githubmirror/Front-End-Checklist

packages/emails/src/__tests__/server.test.ts
137 строк4 KB
David Dias
feat: add authenticated Resend subscriber sync
30 май 2026, 02:25
30 май 2026, 02:256a2f75d
describe('@repo/emails/server', () => {
  const originalApiKey = process.env.RESEND_API_KEY
  const originalTopicId = process.env.RESEND_TOPIC_ID

  afterEach(() => {
    if (originalApiKey === undefined) {
      delete process.env.RESEND_API_KEY
    } else {
      process.env.RESEND_API_KEY = originalApiKey
    }
    if (originalTopicId === undefined) {
      delete process.env.RESEND_TOPIC_ID
    } else {
      process.env.RESEND_TOPIC_ID = originalTopicId
    }
    jest.dontMock('resend')
    jest.resetModules()
  })

  it('returns null when RESEND_API_KEY is missing', async () => {
    delete process.env.RESEND_API_KEY
    const { getResendClient, isResendConfigured } = await import('../server')

    expect(getResendClient()).toBeNull()
    expect(isResendConfigured()).toBe(false)
  })

  it('returns a client when RESEND_API_KEY is present', async () => {
    process.env.RESEND_API_KEY = 're_test_key'
    const { getResendClient, isResendConfigured } = await import('../server')

    const client = getResendClient()

    expect(client).not.toBeNull()
    expect(client?.constructor.name).toBe('Resend')
    expect(isResendConfigured()).toBe(true)
  })

  it('resolves the shared Resend topic id', async () => {
    delete process.env.RESEND_TOPIC_ID
    const { getResendTopicId } = await import('../server')

    expect(getResendTopicId()).toBe('cdb0d440-4825-412a-8152-29681e8155b7')

    process.env.RESEND_TOPIC_ID = ' topic_override '
    expect(getResendTopicId()).toBe('topic_override')
  })

  it('builds subscriber contact payloads with topic opt-in and properties', async () => {
    const { createResendContactPayload } = await import('../server')

    expect(createResendContactPayload('test@example.com', 'subscriber')).toEqual({
      email: 'test@example.com',
      properties: {
        product: 'newsletter',
        user_type: 'subscriber',
        language: 'en',
        source_domain: 'frontendchecklist.io',
        brand: 'frontendchecklist'
      },
      topics: [{ id: 'cdb0d440-4825-412a-8152-29681e8155b7', subscription: 'opt_in' }]
    })
  })

  it('builds waitlist contact payloads with distinct properties', async () => {
    const { createResendContactPayload } = await import('../server')

    expect(createResendContactPayload('test@example.com', 'waitlist', ' seg_waitlist ')).toEqual({
      email: 'test@example.com',
      properties: {
        product: 'waitlist',
        user_type: 'waitlist',
        language: 'en',
        source_domain: 'frontendchecklist.io',
        brand: 'frontendchecklist'
      },
      segments: [{ id: 'seg_waitlist' }],
      topics: [{ id: 'cdb0d440-4825-412a-8152-29681e8155b7', subscription: 'opt_in' }]
    })
  })

  it('adds subscriber contacts through Resend', async () => {
    process.env.RESEND_API_KEY = 're_test_key'
    const mockCreate = jest.fn().mockResolvedValue({ data: { id: 'contact-1' }, error: null })
    jest.doMock('resend', () => ({
      Resend: jest.fn().mockImplementation(() => ({
        contacts: {
          create: mockCreate
        }
      }))
    }))

    const { addSubscriberContact } = await import('../server')

    await expect(addSubscriberContact(' test@example.com ', ' segment-1 ')).resolves.toEqual({
      id: 'contact-1',
      status: 'created',
      success: true
    })
    expect(mockCreate).toHaveBeenCalledWith({
      email: 'test@example.com',
      properties: {
        product: 'newsletter',
        user_type: 'subscriber',
        language: 'en',
        source_domain: 'frontendchecklist.io',
        brand: 'frontendchecklist'
      },
      segments: [{ id: 'segment-1' }],
      topics: [{ id: 'cdb0d440-4825-412a-8152-29681e8155b7', subscription: 'opt_in' }]
    })
  })

  it('treats existing Resend contacts as a successful sync', async () => {
    process.env.RESEND_API_KEY = 're_test_key'
    jest.doMock('resend', () => ({
      Resend: jest.fn().mockImplementation(() => ({
        contacts: {
          create: jest.fn().mockResolvedValue({
            data: null,
            error: {
              message: 'Contact already exists',
              name: 'validation_error'
            }
          })
        }
      }))
    }))

    const { addSubscriberContact } = await import('../server')

    await expect(addSubscriberContact('test@example.com')).resolves.toEqual({
      status: 'already_exists',
      success: true
    })
  })
})