import { type Readable } from 'node:stream'
import { buffer } from '@toa.io/streams'
import { cases, open, rnd, read } from '../test/util'
import { providers } from './index'

describe.each(cases)('%s', (...suite) => {
  const [protocol, url, secrets, init] = suite
  const Provider = providers[protocol]
  const provider = new Provider(url, secrets)

  let dir: string

  beforeAll(async () => {
    await init?.(url, secrets)
  })

  beforeEach(() => {
    dir = '/' + rnd()
  })

  it('should be', async () => {
    expect(provider).toBeInstanceOf(Provider)
  })

  it('should return null if file not found', async () => {
    const result = await provider.get(rnd())

    expect(result).toBeNull()
  })

  it('should create entry', async () => {
    const stream = open('lenna.png')

    await provider.put(dir, 'lenna.png', stream)

    const readable = await provider.get(dir + '/lenna.png') as Readable
    const output = await buffer(readable)
    const lenna = await read('lenna.png')

    expect(output.compare(lenna)).toBe(0)
  })

  it('should overwrite existing entry', async () => {
    const stream0 = open('lenna.png')
    const stream1 = open('albert.jpg')

    await provider.put(dir, 'lenna.png', stream0)
    await provider.put(dir, 'lenna.png', stream1)

    const readable = await provider.get(dir + '/lenna.png') as Readable
    const output = await buffer(readable)
    const albert = await read('albert.jpg')

    expect(output.compare(albert)).toBe(0)
  })

  it('should get by path', async () => {
    const stream = open('lenna.png')

    await provider.put(dir, 'lenna.png', stream)

    const result = await provider.get('/bar/lenna.png')

    expect(result).toBeNull()
  })

  describe('danger', () => {
    /*

    WHEN MAKING CHANGES TO DELETION,
    ALWAYS RUN TESTS IN STEP-BY-STEP DEBUGGING MODE

    YOU MAY EVENTUALLY DELETE YOUR ENTIRE FILE SYSTEM

                              Sincerely yours, Murphy

     */

    it('should delete entry', async () => {
      const stream = open('lenna.png')

      await provider.put(dir, 'lenna.png', stream)
      await provider.delete(dir + '/lenna.png')

      const result = await provider.get(dir + '/lenna.png')

      expect(result).toBeNull()
    })

    it('should not throw if path does not exists', async () => {
      await expect(provider.delete(dir + '/whatever')).resolves.not.toThrow()
    })

    it('should delete directory', async () => {
      const stream = open('lenna.png')

      await provider.put(dir, 'lenna.png', stream)
      await provider.delete(dir)

      const result = await provider.get(dir + '/lenna.png')

      expect(result).toBeNull()
    })

    it('should move an entry', async () => {
      const stream = open('lenna.png')
      const dir2 = '/' + rnd()

      await provider.put(dir, 'lenna.png', stream)
      await provider.move(dir + '/lenna.png', dir2 + '/lenna2.png')

      const result = await provider.get(dir2 + '/lenna2.png') as Readable

      expect(result).not.toBeNull()

      const nope = await provider.get(dir + '/lenna.png')

      expect(nope).toBeNull()
    })
  })
})