queries: DataQuery[];
}

export interface LoadExploreDataSourcesPayload {
  exploreId: ExploreId;
  exploreDatasources: DataSourceSelectItem[];
}

export interface RunQueriesPayload {
  exploreId: ExploreId;
}

/**
 * Adds a query row after the row with the given index.
 */
export const addQueryRowAction = actionCreatorFactory<AddQueryRowPayload>('explore/ADD_QUERY_ROW').create();

/**
 * Loads a new datasource identified by the given name.
 */
export const changeDatasourceAction = noPayloadActionCreatorFactory('explore/CHANGE_DATASOURCE').create();

/**
 * Query change handler for the query row with the given index.
 * If `override` is reset the query modifications and run the queries. Use this to set queries via a link.
 */
export const changeQueryAction = actionCreatorFactory<ChangeQueryPayload>('explore/CHANGE_QUERY').create();

/**
 * Keep track of the Explore container size, in particular the width.
 * The width will be used to calculate graph intervals (number of datapoints).

  const explore: Partial<ExploreState> = {
    [exploreId]: {
      ...itemState,
      datasourceInstance,
      refreshInterval: options.refreshInterval || liveOption.value,
      queries: [{} as DataQuery],
    },
  };
  const state: any = {
    explore,
  };

  return { url, state, refId, webSocketUrl, exploreId };
};

const dataReceivedActionCreator = actionCreatorFactory<SubscriptionDataReceivedPayload>('test').create();

describe('startSubscriptionsEpic', () => {
  describe('when startSubscriptionsAction is dispatched', () => {
    describe('and datasource supports convertToStreamTargets', () => {
      describe('and explore is Live', () => {
        it('then correct actions should be dispatched', () => {
          const { state, refId, webSocketUrl, exploreId } = setup();

          epicTester(startSubscriptionsEpic, state)
            .whenActionIsDispatched(startSubscriptionsAction({ exploreId, dataReceivedActionCreator }))
            .thenResultingActionsEqual(
              startSubscriptionAction({
                exploreId,
                refId,
                url: webSocketUrl,