# -*- coding: utf-8 -*-

import time

import numpy as np
import pytest
from africanus.gridding.perleypolyhedron import (kernels,
                                                 gridder,
                                                 degridder)
from africanus.gridding.perleypolyhedron import dask as dwrap
from africanus.dft.kernels import im_to_vis
from africanus.constants import c as lightspeed


class clock:
    def __init__(self, identifier="untitled"):
        self._id = identifier
        self._elapsed = 0.0
        self._onenter = 0.0
        self._onexit = 0.0

    def __enter__(self):
        self._onenter = time.time()
        return self

    def __exit__(self, extype, exval, tb):
        self._onexit = time.time()
        self._elapsed = self._onexit - self._onenter

    @property
    def elapsed(self):
        return self._elapsed

    def __str__(self):
        res = "{0:s}: Walltime {1:.0f}m{2:.2f}s elapsed".format(
            self._id, self.elapsed // 60,
            self.elapsed - (self.elapsed // 60) * 60)
        return res

    __repr__ = __str__


def test_gridder_dask():
    da = pytest.importorskip("dask.array")

    with clock("DASK gridding") as tictoc:
        # construct kernel
        W = 5
        OS = 9
        kern = kernels.pack_kernel(kernels.kbsinc(W, oversample=OS), W, OS)
        nrow = int(1e6)
        np.random.seed(0)
        # simulate some ficticious baselines rotated by an hour angle
        row_chunks = nrow // 10
        uvw = np.zeros((nrow, 3), dtype=np.float64)
        blpos = np.random.uniform(26, 10000, size=(25, 3))
        ntime = int(nrow / 25.0)
        d0 = np.pi / 4.0
        for n in range(25):
            for ih0, h0 in enumerate(
                    np.linspace(np.deg2rad(-20), np.deg2rad(20), ntime)):
                s = np.sin
                c = np.cos
                R = np.array([[s(h0), c(h0), 0],
                              [-s(d0) * c(h0),
                               s(d0) * s(h0),
                               c(d0)],
                              [c(d0) * c(h0), -c(d0) * s(h0),
                               s(d0)]])
                uvw[n * ntime + ih0, :] = np.dot(R, blpos[n, :].T)
        uvw = da.from_array(uvw, chunks=(row_chunks, 3))
        pxacrossbeam = 5
        nchan = 128
        frequency = da.from_array(np.linspace(1.0e9, 1.4e9, nchan),
                                  chunks=(nchan, ))
        wavelength = lightspeed / frequency
        cell = da.rad2deg(
            wavelength[0] /
            (max(da.max(da.absolute(uvw[:, 0])),
                 da.max(da.absolute(uvw[:, 1]))) * pxacrossbeam))
        npixfacet = 100
        fftpad = 1.1

        image_centres = da.from_array(np.array([[0, d0]]), chunks=(1, 2))
        chanmap = da.from_array(np.zeros(nchan, dtype=np.int64),
                                chunks=(nchan, ))
        detaper_facet = kernels.compute_detaper_dft_seperable(
            int(npixfacet * fftpad), kernels.unpack_kernel(kern, W, OS), W,
            OS)
        vis_dft = da.ones(shape=(nrow, nchan, 2),
                          chunks=(row_chunks, nchan, 2),
                          dtype=np.complex64)
        vis_grid_facet = dwrap.gridder(
            uvw,
            vis_dft,
            wavelength,
            chanmap,
            int(npixfacet * fftpad),
            cell * 3600.0,
            image_centres, (0, d0),
            kern,
            W,
            OS,
            "None",
            "None",
            "I_FROM_XXYY",
            "conv_1d_axisymmetric_packed_scatter",
            do_normalize=True)

        vis_grid_facet = vis_grid_facet.compute()

        ftvisfacet = (np.fft.fftshift(
            np.fft.ifft2(np.fft.ifftshift(
                vis_grid_facet[0, :, :]))).reshape(
                    (1, int(npixfacet * fftpad), int(
                        npixfacet * fftpad)))).real / detaper_facet * int(
                            npixfacet * fftpad)**2
        ftvisfacet = ftvisfacet[:,
                                int(npixfacet * fftpad) // 2 - npixfacet //
                                2:int(npixfacet * fftpad) // 2 -
                                npixfacet // 2 + npixfacet,
                                int(npixfacet * fftpad) // 2 - npixfacet //
                                2:int(npixfacet * fftpad) // 2 -
                                npixfacet // 2 + npixfacet]
    print(tictoc)
    assert (np.abs(np.max(ftvisfacet[0, :, :]) - 1.0) < 1.0e-6)


def test_gridder_nondask():
    with clock("Non-DASK gridding") as tictoc:
        # construct kernel
        W = 5
        OS = 9
        kern = kernels.pack_kernel(kernels.kbsinc(W, oversample=OS), W, OS)
        nrow = int(1e6)
        np.random.seed(0)
        # simulate some ficticious baselines rotated by an hour angle
        uvw = np.zeros((nrow, 3), dtype=np.float64)
        blpos = np.random.uniform(26, 10000, size=(25, 3))
        ntime = int(nrow / 25.0)
        d0 = np.pi / 4.0
        for n in range(25):
            for ih0, h0 in enumerate(
                    np.linspace(np.deg2rad(-20), np.deg2rad(20), ntime)):
                s = np.sin
                c = np.cos
                R = np.array([[s(h0), c(h0), 0],
                              [-s(d0) * c(h0),
                               s(d0) * s(h0),
                               c(d0)],
                              [c(d0) * c(h0), -c(d0) * s(h0),
                               s(d0)]])
                uvw[n * ntime + ih0, :] = np.dot(R, blpos[n, :].T)
        pxacrossbeam = 5
        nchan = 128
        frequency = np.linspace(1.0e9, 1.4e9, nchan)
        wavelength = lightspeed / frequency
        cell = np.rad2deg(
            wavelength[0] /
            (max(np.max(np.absolute(uvw[:, 0])),
                 np.max(np.absolute(uvw[:, 1]))) * pxacrossbeam))
        npixfacet = 100
        fftpad = 1.1

        image_centres = np.array([[0, d0]])
        chanmap = np.zeros(nchan, dtype=np.int64)
        detaper_facet = kernels.compute_detaper_dft_seperable(
            int(npixfacet * fftpad), kernels.unpack_kernel(kern, W, OS), W,
            OS)
        vis_dft = np.ones((nrow, nchan, 2), dtype=np.complex64)
        vis_grid_facet = gridder.gridder(
            uvw,
            vis_dft,
            wavelength,
            chanmap,
            int(npixfacet * fftpad),
            cell * 3600.0,
            image_centres[0, :], (0, d0),
            kern,
            W,
            OS,
            "None",
            "None",
            "I_FROM_XXYY",
            "conv_1d_axisymmetric_packed_scatter",
            do_normalize=True)
        ftvisfacet = (np.fft.fftshift(
            np.fft.ifft2(np.fft.ifftshift(
                vis_grid_facet[0, :, :]))).reshape(
                    (1, int(npixfacet * fftpad), int(
                        npixfacet * fftpad)))).real / detaper_facet * int(
                            npixfacet * fftpad)**2
        ftvisfacet = ftvisfacet[:,
                                int(npixfacet * fftpad) // 2 - npixfacet //
                                2:int(npixfacet * fftpad) // 2 -
                                npixfacet // 2 + npixfacet,
                                int(npixfacet * fftpad) // 2 - npixfacet //
                                2:int(npixfacet * fftpad) // 2 -
                                npixfacet // 2 + npixfacet]
    print(tictoc)
    assert (np.abs(np.max(ftvisfacet[0, :, :]) - 1.0) < 1.0e-6)


def test_degrid_dft_packed_nondask():
    # construct kernel
    W = 5
    OS = 3
    kern = kernels.pack_kernel(kernels.kbsinc(W, oversample=OS),
                               W,
                               oversample=OS)
    nrow = int(5e4)
    uvw = np.column_stack(
        (5000.0 * np.cos(np.linspace(0, 2 * np.pi, nrow)),
            5000.0 * np.sin(np.linspace(0, 2 * np.pi, nrow)), np.zeros(nrow)))

    pxacrossbeam = 10
    nchan = 1024
    frequency = np.linspace(1.0e9, 1.4e9, nchan)
    wavelength = lightspeed / frequency

    cell = np.rad2deg(
        wavelength[0] /
        (2 * max(np.max(np.abs(uvw[:, 0])), np.max(np.abs(uvw[:, 1]))) *
            pxacrossbeam))
    npix = 512
    mod = np.zeros((1, npix, npix), dtype=np.complex64)
    mod[0, npix // 2 - 5, npix // 2 - 5] = 1.0

    ftmod = np.fft.ifftshift(np.fft.fft2(np.fft.fftshift(
        mod[0, :, :]))).reshape((1, npix, npix))
    chanmap = np.zeros(nchan, dtype=np.int64)

    with clock("Non-DASK degridding") as tictoc:
        degridder.degridder(
            uvw,
            ftmod,
            wavelength,
            chanmap,
            cell * 3600.0,
            (0, np.pi / 4.0),
            (0, np.pi / 4.0),
            kern,
            W,
            OS,
            "None",  # no faceting
            "None",  # no faceting
            "XXYY_FROM_I",
            "conv_1d_axisymmetric_packed_gather")

    print(tictoc)


def test_degrid_dft_packed_dask():
    da = pytest.importorskip("dask.array")

    # construct kernel
    W = 5
    OS = 3
    kern = kernels.pack_kernel(kernels.kbsinc(W, oversample=OS),
                               W,
                               oversample=OS)
    nrow = int(5e4)
    nrow_chunk = nrow // 32
    uvw = np.column_stack(
        (5000.0 * np.cos(np.linspace(0, 2 * np.pi, nrow)),
            5000.0 * np.sin(np.linspace(0, 2 * np.pi, nrow)), np.zeros(nrow)))

    pxacrossbeam = 10
    nchan = 1024
    frequency = np.linspace(1.0e9, 1.4e9, nchan)
    wavelength = lightspeed / frequency

    cell = np.rad2deg(
        wavelength[0] /
        (2 * max(np.max(np.abs(uvw[:, 0])), np.max(np.abs(uvw[:, 1]))) *
            pxacrossbeam))
    npix = 512
    mod = np.zeros((1, npix, npix), dtype=np.complex64)
    mod[0, npix // 2 - 5, npix // 2 - 5] = 1.0

    ftmod = np.fft.ifftshift(np.fft.fft2(np.fft.fftshift(
        mod[0, :, :]))).reshape((1, 1, npix, npix))
    chanmap = np.zeros(nchan, dtype=np.int64)

    with clock("DASK degridding") as tictoc:
        vis_degrid = dwrap.degridder(
            da.from_array(uvw, chunks=(nrow_chunk, 3)),
            da.from_array(ftmod, chunks=(1, 1, npix, npix)),
            da.from_array(wavelength, chunks=(nchan, )),
            da.from_array(chanmap, chunks=(nchan, )),
            cell * 3600.0,
            da.from_array(np.array([[0, np.pi / 4.0]]), chunks=(1, 2)),
            (0, np.pi / 4.0),
            kern,
            W,
            OS,
            "None",  # no faceting
            "None",  # no faceting
            "XXYY_FROM_I",
            "conv_1d_axisymmetric_packed_gather")

        vis_degrid = vis_degrid.compute()

    print(tictoc)


def test_degrid_dft_packed_dask_dft_check():
    da = pytest.importorskip("dask.array")

    # construct kernel
    W = 5
    OS = 3
    kern = kernels.pack_kernel(kernels.kbsinc(W, oversample=OS),
                               W,
                               oversample=OS)
    nrow = 100
    nrow_chunk = nrow // 8
    uvw = np.column_stack(
        (5000.0 * np.cos(np.linspace(0, 2 * np.pi, nrow)),
            5000.0 * np.sin(np.linspace(0, 2 * np.pi, nrow)), np.zeros(nrow)))

    pxacrossbeam = 10
    nchan = 16
    frequency = np.linspace(1.0e9, 1.4e9, nchan)
    wavelength = lightspeed / frequency

    cell = np.rad2deg(
        wavelength[0] /
        (2 * max(np.max(np.abs(uvw[:, 0])), np.max(np.abs(uvw[:, 1]))) *
            pxacrossbeam))
    npix = 512
    mod = np.zeros((1, npix, npix), dtype=np.complex64)
    mod[0, npix // 2 - 5, npix // 2 - 5] = 1.0

    ftmod = np.fft.ifftshift(np.fft.fft2(np.fft.fftshift(
        mod[0, :, :]))).reshape((1, 1, npix, npix))
    chanmap = np.zeros(nchan, dtype=np.int64)
    dec, ra = np.meshgrid(
        np.arange(-npix // 2, npix // 2) * np.deg2rad(cell),
        np.arange(-npix // 2, npix // 2) * np.deg2rad(cell))
    radec = np.column_stack((ra.flatten(), dec.flatten()))
    vis_dft = im_to_vis(mod[0, :, :].reshape(1, 1, npix * npix).T.copy(),
                        uvw, radec, frequency)

    vis_degrid = dwrap.degridder(
        da.from_array(uvw, chunks=(nrow_chunk, 3)),
        da.from_array(ftmod, chunks=(1, 1, npix, npix)),
        da.from_array(wavelength, chunks=(nchan, )),
        da.from_array(chanmap, chunks=(nchan, )),
        cell * 3600.0,
        da.from_array(np.array([[0, np.pi / 4.0]]), chunks=(1, 2)),
        (0, np.pi / 4.0),
        kern,
        W,
        OS,
        "None",  # no faceting
        "None",  # no faceting
        "XXYY_FROM_I",
        "conv_1d_axisymmetric_packed_gather")

    vis_degrid = vis_degrid.compute()

    assert np.percentile(
        np.abs(vis_dft[:, 0, 0].real - vis_degrid[:, 0, 0].real),
        99.0) < 0.05
    assert np.percentile(
        np.abs(vis_dft[:, 0, 0].imag - vis_degrid[:, 0, 0].imag),
        99.0) < 0.05

# -*- coding: utf-8 -*-

import time

import numpy as np
import pytest
from africanus.gridding.perleypolyhedron import (kernels,
                                                 gridder,
                                                 degridder)
from africanus.gridding.perleypolyhedron import dask as dwrap
from africanus.dft.kernels import im_to_vis
from africanus.constants import c as lightspeed


class clock:
    def __init__(self, identifier="untitled"):
        self._id = identifier
        self._elapsed = 0.0
        self._onenter = 0.0
        self._onexit = 0.0

    def __enter__(self):
        self._onenter = time.time()
        return self

    def __exit__(self, extype, exval, tb):
        self._onexit = time.time()
        self._elapsed = self._onexit - self._onenter

    @property
    def elapsed(self):
        return self._elapsed

    def __str__(self):
        res = "{0:s}: Walltime {1:.0f}m{2:.2f}s elapsed".format(
            self._id, self.elapsed // 60,
            self.elapsed - (self.elapsed // 60) * 60)
        return res

    __repr__ = __str__


def test_gridder_dask():
    da = pytest.importorskip("dask.array")

    with clock("DASK gridding") as tictoc:
        # construct kernel
        W = 5
        OS = 9
        kern = kernels.pack_kernel(kernels.kbsinc(W, oversample=OS), W, OS)
        nrow = int(1e6)
        np.random.seed(0)
        # simulate some ficticious baselines rotated by an hour angle
        row_chunks = nrow // 10
        uvw = np.zeros((nrow, 3), dtype=np.float64)
        blpos = np.random.uniform(26, 10000, size=(25, 3))
        ntime = int(nrow / 25.0)
        d0 = np.pi / 4.0
        for n in range(25):
            for ih0, h0 in enumerate(
                    np.linspace(np.deg2rad(-20), np.deg2rad(20), ntime)):
                s = np.sin
                c = np.cos
                R = np.array([[s(h0), c(h0), 0],
                              [-s(d0) * c(h0),
                               s(d0) * s(h0),
                               c(d0)],
                              [c(d0) * c(h0), -c(d0) * s(h0),
                               s(d0)]])
                uvw[n * ntime + ih0, :] = np.dot(R, blpos[n, :].T)
        uvw = da.from_array(uvw, chunks=(row_chunks, 3))
        pxacrossbeam = 5
        nchan = 128
        frequency = da.from_array(np.linspace(1.0e9, 1.4e9, nchan),
                                  chunks=(nchan, ))
        wavelength = lightspeed / frequency
        cell = da.rad2deg(
            wavelength[0] /
            (max(da.max(da.absolute(uvw[:, 0])),
                 da.max(da.absolute(uvw[:, 1]))) * pxacrossbeam))
        npixfacet = 100
        fftpad = 1.1

        image_centres = da.from_array(np.array([[0, d0]]), chunks=(1, 2))
        chanmap = da.from_array(np.zeros(nchan, dtype=np.int64),
                                chunks=(nchan, ))
        detaper_facet = kernels.compute_detaper_dft_seperable(
            int(npixfacet * fftpad), kernels.unpack_kernel(kern, W, OS), W,
            OS)
        vis_dft = da.ones(shape=(nrow, nchan, 2),
                          chunks=(row_chunks, nchan, 2),
                          dtype=np.complex64)
        vis_grid_facet = dwrap.gridder(
            uvw,
            vis_dft,
            wavelength,
            chanmap,
            int(npixfacet * fftpad),
            cell * 3600.0,
            image_centres, (0, d0),
            kern,
            W,
            OS,
            "None",
            "None",
            "I_FROM_XXYY",
            "conv_1d_axisymmetric_packed_scatter",
            do_normalize=True)

        vis_grid_facet = vis_grid_facet.compute()

        ftvisfacet = (np.fft.fftshift(
            np.fft.ifft2(np.fft.ifftshift(
                vis_grid_facet[0, :, :]))).reshape(
                    (1, int(npixfacet * fftpad), int(
                        npixfacet * fftpad)))).real / detaper_facet * int(
                            npixfacet * fftpad)**2
        ftvisfacet = ftvisfacet[:,
                                int(npixfacet * fftpad) // 2 - npixfacet //
                                2:int(npixfacet * fftpad) // 2 -
                                npixfacet // 2 + npixfacet,
                                int(npixfacet * fftpad) // 2 - npixfacet //
                                2:int(npixfacet * fftpad) // 2 -
                                npixfacet // 2 + npixfacet]
    print(tictoc)
    assert (np.abs(np.max(ftvisfacet[0, :, :]) - 1.0) < 1.0e-6)


def test_gridder_nondask():
    with clock("Non-DASK gridding") as tictoc:
        # construct kernel
        W = 5
        OS = 9
        kern = kernels.pack_kernel(kernels.kbsinc(W, oversample=OS), W, OS)
        nrow = int(1e6)
        np.random.seed(0)
        # simulate some ficticious baselines rotated by an hour angle
        uvw = np.zeros((nrow, 3), dtype=np.float64)
        blpos = np.random.uniform(26, 10000, size=(25, 3))
        ntime = int(nrow / 25.0)
        d0 = np.pi / 4.0
        for n in range(25):
            for ih0, h0 in enumerate(
                    np.linspace(np.deg2rad(-20), np.deg2rad(20), ntime)):
                s = np.sin
                c = np.cos
                R = np.array([[s(h0), c(h0), 0],
                              [-s(d0) * c(h0),
                               s(d0) * s(h0),
                               c(d0)],
                              [c(d0) * c(h0), -c(d0) * s(h0),
                               s(d0)]])
                uvw[n * ntime + ih0, :] = np.dot(R, blpos[n, :].T)
        pxacrossbeam = 5
        nchan = 128
        frequency = np.linspace(1.0e9, 1.4e9, nchan)
        wavelength = lightspeed / frequency
        cell = np.rad2deg(
            wavelength[0] /
            (max(np.max(np.absolute(uvw[:, 0])),
                 np.max(np.absolute(uvw[:, 1]))) * pxacrossbeam))
        npixfacet = 100
        fftpad = 1.1

        image_centres = np.array([[0, d0]])
        chanmap = np.zeros(nchan, dtype=np.int64)
        detaper_facet = kernels.compute_detaper_dft_seperable(
            int(npixfacet * fftpad), kernels.unpack_kernel(kern, W, OS), W,
            OS)
        vis_dft = np.ones((nrow, nchan, 2), dtype=np.complex64)
        vis_grid_facet = gridder.gridder(
            uvw,
            vis_dft,
            wavelength,
            chanmap,
            int(npixfacet * fftpad),
            cell * 3600.0,
            image_centres[0, :], (0, d0),
            kern,
            W,
            OS,
            "None",
            "None",
            "I_FROM_XXYY",
            "conv_1d_axisymmetric_packed_scatter",
            do_normalize=True)
        ftvisfacet = (np.fft.fftshift(
            np.fft.ifft2(np.fft.ifftshift(
                vis_grid_facet[0, :, :]))).reshape(
                    (1, int(npixfacet * fftpad), int(
                        npixfacet * fftpad)))).real / detaper_facet * int(
                            npixfacet * fftpad)**2
        ftvisfacet = ftvisfacet[:,
                                int(npixfacet * fftpad) // 2 - npixfacet //
                                2:int(npixfacet * fftpad) // 2 -
                                npixfacet // 2 + npixfacet,
                                int(npixfacet * fftpad) // 2 - npixfacet //
                                2:int(npixfacet * fftpad) // 2 -
                                npixfacet // 2 + npixfacet]
    print(tictoc)
    assert (np.abs(np.max(ftvisfacet[0, :, :]) - 1.0) < 1.0e-6)


def test_degrid_dft_packed_nondask():
    # construct kernel
    W = 5
    OS = 3
    kern = kernels.pack_kernel(kernels.kbsinc(W, oversample=OS),
                               W,
                               oversample=OS)
    nrow = int(5e4)
    uvw = np.column_stack(
        (5000.0 * np.cos(np.linspace(0, 2 * np.pi, nrow)),
            5000.0 * np.sin(np.linspace(0, 2 * np.pi, nrow)), np.zeros(nrow)))

    pxacrossbeam = 10
    nchan = 1024
    frequency = np.linspace(1.0e9, 1.4e9, nchan)
    wavelength = lightspeed / frequency

    cell = np.rad2deg(
        wavelength[0] /
        (2 * max(np.max(np.abs(uvw[:, 0])), np.max(np.abs(uvw[:, 1]))) *
            pxacrossbeam))
    npix = 512
    mod = np.zeros((1, npix, npix), dtype=np.complex64)
    mod[0, npix // 2 - 5, npix // 2 - 5] = 1.0

    ftmod = np.fft.ifftshift(np.fft.fft2(np.fft.fftshift(
        mod[0, :, :]))).reshape((1, npix, npix))
    chanmap = np.zeros(nchan, dtype=np.int64)

    with clock("Non-DASK degridding") as tictoc:
        degridder.degridder(
            uvw,
            ftmod,
            wavelength,
            chanmap,
            cell * 3600.0,
            (0, np.pi / 4.0),
            (0, np.pi / 4.0),
            kern,
            W,
            OS,
            "None",  # no faceting
            "None",  # no faceting
            "XXYY_FROM_I",
            "conv_1d_axisymmetric_packed_gather")

    print(tictoc)


def test_degrid_dft_packed_dask():
    da = pytest.importorskip("dask.array")

    # construct kernel
    W = 5
    OS = 3
    kern = kernels.pack_kernel(kernels.kbsinc(W, oversample=OS),
                               W,
                               oversample=OS)
    nrow = int(5e4)
    nrow_chunk = nrow // 32
    uvw = np.column_stack(
        (5000.0 * np.cos(np.linspace(0, 2 * np.pi, nrow)),
            5000.0 * np.sin(np.linspace(0, 2 * np.pi, nrow)), np.zeros(nrow)))

    pxacrossbeam = 10
    nchan = 1024
    frequency = np.linspace(1.0e9, 1.4e9, nchan)
    wavelength = lightspeed / frequency

    cell = np.rad2deg(
        wavelength[0] /
        (2 * max(np.max(np.abs(uvw[:, 0])), np.max(np.abs(uvw[:, 1]))) *
            pxacrossbeam))
    npix = 512
    mod = np.zeros((1, npix, npix), dtype=np.complex64)
    mod[0, npix // 2 - 5, npix // 2 - 5] = 1.0

    ftmod = np.fft.ifftshift(np.fft.fft2(np.fft.fftshift(
        mod[0, :, :]))).reshape((1, 1, npix, npix))
    chanmap = np.zeros(nchan, dtype=np.int64)

    with clock("DASK degridding") as tictoc:
        vis_degrid = dwrap.degridder(
            da.from_array(uvw, chunks=(nrow_chunk, 3)),
            da.from_array(ftmod, chunks=(1, 1, npix, npix)),
            da.from_array(wavelength, chunks=(nchan, )),
            da.from_array(chanmap, chunks=(nchan, )),
            cell * 3600.0,
            da.from_array(np.array([[0, np.pi / 4.0]]), chunks=(1, 2)),
            (0, np.pi / 4.0),
            kern,
            W,
            OS,
            "None",  # no faceting
            "None",  # no faceting
            "XXYY_FROM_I",
            "conv_1d_axisymmetric_packed_gather")

        vis_degrid = vis_degrid.compute()

    print(tictoc)


def test_degrid_dft_packed_dask_dft_check():
    da = pytest.importorskip("dask.array")

    # construct kernel
    W = 5
    OS = 3
    kern = kernels.pack_kernel(kernels.kbsinc(W, oversample=OS),
                               W,
                               oversample=OS)
    nrow = 100
    nrow_chunk = nrow // 8
    uvw = np.column_stack(
        (5000.0 * np.cos(np.linspace(0, 2 * np.pi, nrow)),
            5000.0 * np.sin(np.linspace(0, 2 * np.pi, nrow)), np.zeros(nrow)))

    pxacrossbeam = 10
    nchan = 16
    frequency = np.linspace(1.0e9, 1.4e9, nchan)
    wavelength = lightspeed / frequency

    cell = np.rad2deg(
        wavelength[0] /
        (2 * max(np.max(np.abs(uvw[:, 0])), np.max(np.abs(uvw[:, 1]))) *
            pxacrossbeam))
    npix = 512
    mod = np.zeros((1, npix, npix), dtype=np.complex64)
    mod[0, npix // 2 - 5, npix // 2 - 5] = 1.0

    ftmod = np.fft.ifftshift(np.fft.fft2(np.fft.fftshift(
        mod[0, :, :]))).reshape((1, 1, npix, npix))
    chanmap = np.zeros(nchan, dtype=np.int64)
    dec, ra = np.meshgrid(
        np.arange(-npix // 2, npix // 2) * np.deg2rad(cell),
        np.arange(-npix // 2, npix // 2) * np.deg2rad(cell))
    radec = np.column_stack((ra.flatten(), dec.flatten()))
    vis_dft = im_to_vis(mod[0, :, :].reshape(1, 1, npix * npix).T.copy(),
                        uvw, radec, frequency)

    vis_degrid = dwrap.degridder(
        da.from_array(uvw, chunks=(nrow_chunk, 3)),
        da.from_array(ftmod, chunks=(1, 1, npix, npix)),
        da.from_array(wavelength, chunks=(nchan, )),
        da.from_array(chanmap, chunks=(nchan, )),
        cell * 3600.0,
        da.from_array(np.array([[0, np.pi / 4.0]]), chunks=(1, 2)),
        (0, np.pi / 4.0),
        kern,
        W,
        OS,
        "None",  # no faceting
        "None",  # no faceting
        "XXYY_FROM_I",
        "conv_1d_axisymmetric_packed_gather")

    vis_degrid = vis_degrid.compute()

    assert np.percentile(
        np.abs(vis_dft[:, 0, 0].real - vis_degrid[:, 0, 0].real),
        99.0) < 0.05
    assert np.percentile(
        np.abs(vis_dft[:, 0, 0].imag - vis_degrid[:, 0, 0].imag),
        99.0) < 0.05

# -*- coding: utf-8 -*- # construct kernel # simulate some ficticious baselines rotated by an hour angle # construct kernel # simulate some ficticious baselines rotated by an hour angle # construct kernel # no faceting # no faceting # construct kernel # no faceting # no faceting # construct kernel # no faceting # no faceting