EVCB_OCPP.OCPPServer.16J/EVCB_OCPP.WSServer/Service/ServerMessageService.cs

using EVCB_OCPP.Packet.Features;
using EVCB_OCPP.Packet.Messages.Core;
using Microsoft.Extensions.Logging;
using static System.Runtime.InteropServices.JavaScript.JSType;
using System.ServiceModel.Channels;
using EVCB_OCPP.WSServer.Service.DbService;
using Azure;
using EVCB_OCPP.WSServer.Message;
using EVCB_OCPP.Packet.Messages.RemoteTrigger;
using EVCB_OCPP.Packet.Messages.SubTypes;

namespace EVCB_OCPP.WSServer.Service;

public class ServerMessageService
{
    public ServerMessageService(
        IMainDbService mainDbService
        , ILogger<ServerMessageService> logger)
    {
        this.mainDbService = mainDbService;
        this.logger = logger;
    }

    private readonly IMainDbService mainDbService;
    private readonly ILogger<ServerMessageService> logger;

    internal Task<string> SendGetEVSEConfigureRequest(string chargeBoxId, List<string> configKeys = default , string serialNo = "", CancellationToken token = default)
    {
        if (string.IsNullOrEmpty(chargeBoxId)) return null;
        List<string> toPassConfig = configKeys == default ? new List<string>() : configKeys;
        return mainDbService.AddServerMessage(
            ChargeBoxId: chargeBoxId,
            OutAction: Actions.GetConfiguration.ToString(),
            OutRequest: new GetConfigurationRequest() { key = toPassConfig },
            SerialNo: serialNo,
            token: token
            );
    }

    internal Task<string> SendChangeConfigurationRequest(string chargeBoxId, string key, string value, string serialNo = "", CancellationToken token = default)
    {
        return mainDbService.AddServerMessage(
            ChargeBoxId: chargeBoxId,
            OutAction: Actions.ChangeConfiguration.ToString(),
            OutRequest: new ChangeConfigurationRequest()
            {
                key = key,
                value = value
            },
            SerialNo: serialNo,
            token: token
            );
    }

    internal Task<string> SendDataTransferRequest(string chargeBoxId, string messageId, string vendorId, string data, string serialNo = "", CancellationToken token = default)
    {
        return mainDbService.AddServerMessage(
            ChargeBoxId: chargeBoxId,
            OutAction: Actions.DataTransfer.ToString(),
            OutRequest: new DataTransferRequest()
            {
                messageId = messageId,
                vendorId = vendorId,
                data = data
            },
            SerialNo: serialNo,
            token: token
            );
    }

    internal Task<string> SendTriggerMessageRequest(string chargeBoxId, MessageTrigger messageTrigger, string serialNo = "", CancellationToken token = default)
    {
        return mainDbService.AddServerMessage(
            ChargeBoxId: chargeBoxId,
            OutAction: Actions.TriggerMessage.ToString(),
            OutRequest: new TriggerMessageRequest()
            {
                requestedMessage = messageTrigger
            },
            SerialNo: serialNo,
            token: token
            );
    }
}