# (C) Copyright 2005- ECMWF.
#
# This software is licensed under the terms of the Apache Licence Version 2.0
# which can be obtained at http://www.apache.org/licenses/LICENSE-2.0.
#
# In applying this licence, ECMWF does not waive the privileges and immunities
# granted to it by virtue of its status as an intergovernmental organisation
# nor does it submit to any jurisdiction.

#
# Python implementation: bufr_copy_data
#
# Description: How to copy all the values in the data section that are present in the same
#              position in the data tree and with the same number of values to the output handle.
#              This example is for messages which use the operator 203YYY (overridden reference values)
#

import sys
import traceback

from eccodes import *

VERBOSE = 1  # verbose error reporting


def example(input_filename, output_filename):
    f = open(input_filename, "rb")
    ibufrin = codes_bufr_new_from_file(f)
    f.close()

    # Need to unpack to get delayed replications and reference values from input
    codes_set(ibufrin, "unpack", 1)
    references = codes_get_array(ibufrin, "inputOverriddenReferenceValues")
    replication = codes_get_array(ibufrin, "delayedDescriptorReplicationFactor")

    ibufrout = codes_clone(ibufrin)

    # Copy over to output
    codes_set_array(ibufrout, "inputOverriddenReferenceValues", references)
    codes_set_array(ibufrout, "inputDelayedDescriptorReplicationFactor", replication)
    # Keep all original descriptors and add 'meanWindDirectionForSurfaceTo1500M' (011044)
    ivalues = (
        203014,
        7030,
        7031,
        203255,
        307080,
        11044,
    )
    codes_set_array(ibufrout, "unexpandedDescriptors", ivalues)

    codes_bufr_copy_data(ibufrin, ibufrout)

    outfile = open(output_filename, "wb")
    codes_write(ibufrout, outfile)
    outfile.close()

    codes_release(ibufrin)
    codes_release(ibufrout)


def main():
    if len(sys.argv) < 3:
        print("Usage: ", sys.argv[0], " bufr_in bufr_out", file=sys.stderr)
        sys.exit(1)

    input_filename = sys.argv[1]
    output_filename = sys.argv[2]

    try:
        example(input_filename, output_filename)
    except CodesInternalError as err:
        if VERBOSE:
            traceback.print_exc(file=sys.stderr)
        else:
            sys.stderr.write(err.msg + "\n")

        return 1


if __name__ == "__main__":
    sys.exit(main())