/**
 * Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.  The ASF licenses this file to you under the Apache License, Version
 * 2.0 (the "License"); you may not use this file except in compliance with the License.  You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions
 * and limitations under the License.
 */

package org.apache.storm.testing;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.apache.storm.tuple.Values;
import org.apache.storm.utils.Utils;

public class MockedSources {
    /**
     * mocked spout sources for the [spout, stream] pair.
     */
    private Map<String, List<FixedTuple>> data = new HashMap<String, List<FixedTuple>>();

    public MockedSources() {
        //Empty
    }

    public MockedSources(Map<String, List<FixedTuple>> data) {
        this.data = new HashMap<>(data);
    }

    /**
     * add mock data for the spout.
     *
     * @param spoutId  the spout to be mocked
     * @param streamId the stream of the spout to be mocked
     * @param valueses the mocked data
     */
    public void addMockData(String spoutId, String streamId, Values... valueses) {
        if (!data.containsKey(spoutId)) {
            data.put(spoutId, new ArrayList<FixedTuple>());
        }

        List<FixedTuple> tuples = data.get(spoutId);
        for (int i = 0; i < valueses.length; i++) {
            FixedTuple tuple = new FixedTuple(streamId, valueses[i]);
            tuples.add(tuple);
        }
    }

    public void addMockData(String spoutId, Values... valueses) {
        this.addMockData(spoutId, Utils.DEFAULT_STREAM_ID, valueses);
    }

    public Map<String, List<FixedTuple>> getData() {
        return this.data;
    }
}