import { createClient } from '@urql/core';
import { get } from 'svelte/store';
import { vi, expect, it, describe } from 'vitest';

import { subscriptionStore } from './subscriptionStore';

describe('subscriptionStore', () => {
  const client = createClient({
    url: 'https://example.com',
    exchanges: [],
  });

  const variables = {};
  const context = {};
  const query = `subscription ($input: ExampleInput) { exampleSubscribe(input: $input) { data } }`;
  const store = subscriptionStore({
    client,
    query,
    variables,
    context,
  });

  it('creates a svelte store', () => {
    const subscriber = vi.fn();
    store.subscribe(subscriber);
    expect(subscriber).toHaveBeenCalledTimes(1);
  });

  it('fills the store with correct values', () => {
    expect(get(store).operation.kind).toBe('subscription');
    expect(get(store).operation.context.url).toBe('https://example.com');
    expect(get(store).operation.variables).toBe(variables);

    expect(get(store).operation.query.loc?.source.body).toMatchInlineSnapshot(`
      "subscription ($input: ExampleInput) {
        exampleSubscribe(input: $input) {
          data
        }
      }"
    `);
  });

  it('adds pause handles', () => {
    expect(get(store.isPaused$)).toBe(false);

    store.pause();
    expect(get(store.isPaused$)).toBe(true);

    store.resume();
    expect(get(store.isPaused$)).toBe(false);
  });
});