// SPDX-License-Identifier: GPL-2.0
/*
 * mh-z19b CO₂ sensor driver
 *
 * Copyright (c) 2025 Gyeyoung Baek <gye976@gmail.com>
 *
 * Datasheet:
 * https://www.winsen-sensor.com/d/files/infrared-gas-sensor/mh-z19b-co2-ver1_0.pdf
 */

#include <linux/array_size.h>
#include <linux/completion.h>
#include <linux/device.h>
#include <linux/errno.h>
#include <linux/iio/iio.h>
#include <linux/iio/sysfs.h>
#include <linux/jiffies.h>
#include <linux/kstrtox.h>
#include <linux/minmax.h>
#include <linux/mod_devicetable.h>
#include <linux/module.h>
#include <linux/regulator/consumer.h>
#include <linux/serdev.h>
#include <linux/string.h>
#include <linux/types.h>
#include <linux/unaligned.h>

/*
 * Commands have following format:
 *
 * +------+------+-----+------+------+------+------+------+-------+
 * | 0xFF | 0x01 | cmd | arg0 | arg1 | 0x00 | 0x00 | 0x00 | cksum |
 * +------+------+-----+------+------+------+------+------+-------+
 */
#define MHZ19B_CMD_SIZE 9

/* ABC logic in MHZ19B means auto calibration. */
#define MHZ19B_ABC_LOGIC_CMD            0x79
#define MHZ19B_READ_CO2_CMD             0x86
#define MHZ19B_SPAN_POINT_CMD           0x88
#define MHZ19B_ZERO_POINT_CMD           0x87

#define MHZ19B_SPAN_POINT_PPM_MIN       1000
#define MHZ19B_SPAN_POINT_PPM_MAX       5000

#define MHZ19B_SERDEV_TIMEOUT msecs_to_jiffies(100)

struct mhz19b_state {
        struct serdev_device *serdev;

        /* Must wait until the 'buf' is filled with 9 bytes.*/
        struct completion buf_ready;

        u8 buf_idx;
        /*
         * Serdev receive buffer.
         * When data is received from the MH-Z19B,
         * the 'mhz19b_receive_buf' callback function is called and fills this buffer.
         */
        u8 buf[MHZ19B_CMD_SIZE] __aligned(IIO_DMA_MINALIGN);
};

static u8 mhz19b_get_checksum(u8 *cmd_buf)
{
        u8 i, checksum = 0;

/*
 * +------+------+-----+------+------+------+------+------+-------+
 * | 0xFF | 0x01 | cmd | arg0 | arg1 | 0x00 | 0x00 | 0x00 | cksum |
 * +------+------+-----+------+------+------+------+------+-------+
 *           i:1    2      3      4      5      6      7
 *
 *  Sum all cmd_buf elements from index 1 to 7.
 */
        for (i = 1; i < 8; i++)
                checksum += cmd_buf[i];

        return -checksum;
}

static int mhz19b_serdev_cmd(struct iio_dev *indio_dev, int cmd, u16 arg)
{
        struct mhz19b_state *st = iio_priv(indio_dev);
        struct serdev_device *serdev = st->serdev;
        struct device *dev = &indio_dev->dev;
        int ret;

        /*
         * cmd_buf[3,4] : arg0,1
         * cmd_buf[8]   : checksum
         */
        u8 cmd_buf[MHZ19B_CMD_SIZE] = {
                0xFF, 0x01, cmd,
        };

        switch (cmd) {
        case MHZ19B_ABC_LOGIC_CMD:
                cmd_buf[3] = arg ? 0xA0 : 0;
                break;
        case MHZ19B_SPAN_POINT_CMD:
                put_unaligned_be16(arg, &cmd_buf[3]);
                break;
        default:
                break;
        }
        cmd_buf[8] = mhz19b_get_checksum(cmd_buf);

        /* Write buf to uart ctrl synchronously */
        ret = serdev_device_write(serdev, cmd_buf, MHZ19B_CMD_SIZE, 0);
        if (ret < 0)
                return ret;
        if (ret != MHZ19B_CMD_SIZE)
                return -EIO;

        switch (cmd) {
        case MHZ19B_READ_CO2_CMD:
                ret = wait_for_completion_interruptible_timeout(&st->buf_ready,
                        MHZ19B_SERDEV_TIMEOUT);
                if (ret < 0)
                        return ret;
                if (!ret)
                        return -ETIMEDOUT;

                if (st->buf[8] != mhz19b_get_checksum(st->buf)) {
                        dev_err(dev, "checksum err");
                        return -EINVAL;
                }

                return get_unaligned_be16(&st->buf[2]);
        default:
                /* No response commands. */
                return 0;
        }
}

static int mhz19b_read_raw(struct iio_dev *indio_dev,
                           struct iio_chan_spec const *chan,
                           int *val, int *val2, long mask)
{
        int ret;

        ret = mhz19b_serdev_cmd(indio_dev, MHZ19B_READ_CO2_CMD, 0);
        if (ret < 0)
                return ret;

        *val = ret;
        return IIO_VAL_INT;
}

/*
 * echo 0 > calibration_auto_enable : ABC logic off
 * echo 1 > calibration_auto_enable : ABC logic on
 */
static ssize_t calibration_auto_enable_store(struct device *dev,
                                             struct device_attribute *attr,
                                             const char *buf, size_t len)
{
        struct iio_dev *indio_dev = dev_to_iio_dev(dev);
        bool enable;
        int ret;

        ret = kstrtobool(buf, &enable);
        if (ret)
                return ret;

        ret = mhz19b_serdev_cmd(indio_dev, MHZ19B_ABC_LOGIC_CMD, enable);
        if (ret < 0)
                return ret;

        return len;
}
static IIO_DEVICE_ATTR_WO(calibration_auto_enable, 0);

/*
 * echo 0 > calibration_forced_value             : zero point calibration
 *      (make sure the sensor has been working under 400ppm for over 20 minutes.)
 * echo [1000 1 5000] > calibration_forced_value : span point calibration
 *      (make sure the sensor has been working under a certain level CO₂ for over 20 minutes.)
 */
static ssize_t calibration_forced_value_store(struct device *dev,
                                              struct device_attribute *attr,
                                              const char *buf, size_t len)
{
        struct iio_dev *indio_dev = dev_to_iio_dev(dev);
        u16 ppm;
        int cmd, ret;

        ret = kstrtou16(buf, 0, &ppm);
        if (ret)
                return ret;

        if (ppm) {
                if (!in_range(ppm, MHZ19B_SPAN_POINT_PPM_MIN,
                        MHZ19B_SPAN_POINT_PPM_MAX - MHZ19B_SPAN_POINT_PPM_MIN + 1)) {
                        dev_dbg(&indio_dev->dev,
                                "span point ppm should be in a range [%d-%d]\n",
                                MHZ19B_SPAN_POINT_PPM_MIN, MHZ19B_SPAN_POINT_PPM_MAX);
                        return -EINVAL;
                }

                cmd = MHZ19B_SPAN_POINT_CMD;
        } else {
                cmd = MHZ19B_ZERO_POINT_CMD;
        }

        ret = mhz19b_serdev_cmd(indio_dev, cmd, ppm);
        if (ret < 0)
                return ret;

        return len;
}
static IIO_DEVICE_ATTR_WO(calibration_forced_value, 0);

static struct attribute *mhz19b_attrs[] = {
        &iio_dev_attr_calibration_auto_enable.dev_attr.attr,
        &iio_dev_attr_calibration_forced_value.dev_attr.attr,
        NULL
};

static const struct attribute_group mhz19b_attr_group = {
        .attrs = mhz19b_attrs,
};

static const struct iio_info mhz19b_info = {
        .attrs = &mhz19b_attr_group,
        .read_raw = mhz19b_read_raw,
};

static const struct iio_chan_spec mhz19b_channels[] = {
        {
                .type = IIO_CONCENTRATION,
                .channel2 = IIO_MOD_CO2,
                .modified = 1,
                .info_mask_separate = BIT(IIO_CHAN_INFO_RAW),
        },
};

static size_t mhz19b_receive_buf(struct serdev_device *serdev,
                              const u8 *data, size_t len)
{
        struct iio_dev *indio_dev = dev_get_drvdata(&serdev->dev);
        struct mhz19b_state *st = iio_priv(indio_dev);

        memcpy(st->buf + st->buf_idx, data, len);
        st->buf_idx += len;

        if (st->buf_idx == MHZ19B_CMD_SIZE) {
                st->buf_idx = 0;
                complete(&st->buf_ready);
        }

        return len;
}

static const struct serdev_device_ops mhz19b_ops = {
        .receive_buf = mhz19b_receive_buf,
        .write_wakeup = serdev_device_write_wakeup,
};

static int mhz19b_probe(struct serdev_device *serdev)
{
        int ret;
        struct device *dev = &serdev->dev;
        struct iio_dev *indio_dev;
        struct mhz19b_state *st;

        serdev_device_set_client_ops(serdev, &mhz19b_ops);
        ret = devm_serdev_device_open(dev, serdev);
        if (ret)
                return ret;
        serdev_device_set_baudrate(serdev, 9600);
        serdev_device_set_flow_control(serdev, false);
        ret = serdev_device_set_parity(serdev, SERDEV_PARITY_NONE);
        if (ret)
                return ret;

        indio_dev = devm_iio_device_alloc(dev, sizeof(*st));
        if (!indio_dev)
                return -ENOMEM;
        serdev_device_set_drvdata(serdev, indio_dev);

        st = iio_priv(indio_dev);
        st->serdev = serdev;

        init_completion(&st->buf_ready);

        ret = devm_regulator_get_enable(dev, "vin");
        if (ret)
                return ret;

        indio_dev->name = "mh-z19b";
        indio_dev->channels = mhz19b_channels;
        indio_dev->num_channels = ARRAY_SIZE(mhz19b_channels);
        indio_dev->info = &mhz19b_info;

        return devm_iio_device_register(dev, indio_dev);
}

static const struct of_device_id mhz19b_of_match[] = {
        { .compatible = "winsen,mhz19b", },
        { }
};
MODULE_DEVICE_TABLE(of, mhz19b_of_match);

static struct serdev_device_driver mhz19b_driver = {
        .driver = {
                .name = "mhz19b",
                .of_match_table = mhz19b_of_match,
        },
        .probe = mhz19b_probe,
};
module_serdev_device_driver(mhz19b_driver);

MODULE_AUTHOR("Gyeyoung Baek");
MODULE_DESCRIPTION("MH-Z19B CO2 sensor driver using serdev interface");
MODULE_LICENSE("GPL");