/* -*- c++ -*- */
/*
 * Copyright 2016,2017 Free Software Foundation, Inc.
 *
 * SPDX-License-Identifier: GPL-3.0-or-later
 *
 */

#ifdef HAVE_CONFIG_H
#include "config.h"
#endif

#include "catv_frame_sync_enc_bb_impl.h"
#include <gnuradio/io_signature.h>

namespace gr {
namespace dtv {

catv_frame_sync_enc_bb::sptr
catv_frame_sync_enc_bb::make(catv_constellation_t constellation, int ctrlword)
{
    return gnuradio::make_block_sptr<catv_frame_sync_enc_bb_impl>(constellation,
                                                                  ctrlword);
}

/*
 * The private constructor
 */
catv_frame_sync_enc_bb_impl::catv_frame_sync_enc_bb_impl(
    catv_constellation_t constellation, int ctrlword)
    : gr::block("catv_frame_sync_enc_bb",
                gr::io_signature::make(1, 1, sizeof(unsigned char)),
                gr::io_signature::make(1, 1, sizeof(unsigned char)))
{
    if (constellation == CATV_MOD_64QAM) {
        set_output_multiple((60 * 128 * 7) + 42);
    } else {
        set_output_multiple((88 * 128 * 7) + 40);
    }
    control_word = ctrlword;
    signal_constellation = constellation;
}

/*
 * Our virtual destructor.
 */
catv_frame_sync_enc_bb_impl::~catv_frame_sync_enc_bb_impl() {}

void catv_frame_sync_enc_bb_impl::forecast(int noutput_items,
                                           gr_vector_int& ninput_items_required)
{
    if (signal_constellation == CATV_MOD_64QAM) {
        ninput_items_required[0] = noutput_items / ((60 * 128 * 7) + 42) * (60 * 128);
    } else {
        ninput_items_required[0] = noutput_items / ((88 * 128 * 7) + 40) * (88 * 128);
    }
}

int catv_frame_sync_enc_bb_impl::general_work(int noutput_items,
                                              gr_vector_int& ninput_items,
                                              gr_vector_const_void_star& input_items,
                                              gr_vector_void_star& output_items)
{
    const unsigned char* in = (const unsigned char*)input_items[0];
    unsigned char* out = (unsigned char*)output_items[0];
    int consumed = 0;
    int i = 0;
    unsigned char b;

    while (i < noutput_items) {
        if (signal_constellation == CATV_MOD_64QAM) {
            for (int j = 0; j < 60 * 128; j++) {
                b = *in++;
                consumed++;
                for (int n = 6; n >= 0; n--) {
                    out[i++] = b & (1 << n) ? 1 : 0;
                }
            }
            b = 0x75;
            for (int n = 6; n >= 0; n--) {
                out[i++] = b & (1 << n) ? 1 : 0;
            }
            b = 0x2c;
            for (int n = 6; n >= 0; n--) {
                out[i++] = b & (1 << n) ? 1 : 0;
            }
            b = 0x0d;
            for (int n = 6; n >= 0; n--) {
                out[i++] = b & (1 << n) ? 1 : 0;
            }
            b = 0x6c;
            for (int n = 6; n >= 0; n--) {
                out[i++] = b & (1 << n) ? 1 : 0;
            }
            b = control_word << 3;
            for (int n = 6; n >= 0; n--) {
                out[i++] = b & (1 << n) ? 1 : 0;
            }
            for (int n = 6; n >= 0; n--) {
                out[i++] = 0;
            }
        } else {
            for (int j = 0; j < 88 * 128; j++) {
                b = *in++;
                consumed++;
                for (int n = 6; n >= 0; n--) {
                    out[i++] = b & (1 << n) ? 1 : 0;
                }
            }
            b = 0x71;
            for (int n = 7; n >= 0; n--) {
                out[i++] = b & (1 << n) ? 1 : 0;
            }
            b = 0xe8;
            for (int n = 7; n >= 0; n--) {
                out[i++] = b & (1 << n) ? 1 : 0;
            }
            b = 0x4d;
            for (int n = 7; n >= 0; n--) {
                out[i++] = b & (1 << n) ? 1 : 0;
            }
            b = 0xd4;
            for (int n = 7; n >= 0; n--) {
                out[i++] = b & (1 << n) ? 1 : 0;
            }
            b = control_word << 4;
            for (int n = 7; n >= 0; n--) {
                out[i++] = b & (1 << n) ? 1 : 0;
            }
        }
    }

    // Tell runtime system how many input items we consumed on
    // each input stream.
    consume_each(consumed);

    // Tell runtime system how many output items we produced.
    return noutput_items;
}

} /* namespace dtv */
} /* namespace gr */