import { CommandSet } from 'pip-services3-commons-node';
import { ICommand } from 'pip-services3-commons-node';
import { Command } from 'pip-services3-commons-node';
import { Schema } from 'pip-services3-commons-node';
import { Parameters } from 'pip-services3-commons-node';
import { ObjectSchema } from 'pip-services3-commons-node';
import { ArraySchema } from 'pip-services3-commons-node';
import { TypeCode } from 'pip-services3-commons-node';

import { SmsMessageV1Schema } from '../data/version1/SmsMessageV1Schema';
import { SmsRecipientV1Schema } from '../data/version1/SmsRecipientV1Schema';
import { SmsMessageV1 } from '../data/version1/SmsMessageV1';
import { ISmsController } from './ISmsController';

export class SmsCommandSet extends CommandSet {
    private _logic: ISmsController;

    constructor(logic: ISmsController) {
        super();

        this._logic = logic;

		this.addCommand(this.makeSendMessageCommand());
		this.addCommand(this.makeSendMessageToRecipientCommand());
		this.addCommand(this.makeSendMessageToRecipientsCommand());
    }

	private makeSendMessageCommand(): ICommand {
		return new Command(
			"send_message",
			new ObjectSchema(true)
				.withRequiredProperty('message', new SmsMessageV1Schema())
				.withOptionalProperty('parameters', TypeCode.Map),
            (correlationId: string, args: Parameters, callback: (err: any, result: any) => void) => {
                let message = args.get("message");
                let parameters = args.get("parameters");
                this._logic.sendMessage(correlationId, message, parameters, (err) => {
					callback(err, null);
				});
            }
		);
	}

	private makeSendMessageToRecipientCommand(): ICommand {
		return new Command(
			"send_message_to_recipient",
			new ObjectSchema(true)
				.withRequiredProperty('message', new SmsMessageV1Schema())
				.withRequiredProperty('recipient', new SmsRecipientV1Schema())
				.withOptionalProperty('parameters', TypeCode.Map),
            (correlationId: string, args: Parameters, callback: (err: any, result: any) => void) => {
                let message = args.get("message");
                let recipient = args.get("recipient");
                let parameters = args.get("parameters");
                this._logic.sendMessageToRecipient(correlationId, recipient, message, parameters, (err) => {
					callback(err, null);
				});
            }
		);
	}

	private makeSendMessageToRecipientsCommand(): ICommand {
		return new Command(
			"send_message_to_recipients",
			new ObjectSchema(true)
				.withRequiredProperty('message', new SmsMessageV1Schema())
				.withRequiredProperty('recipients', new ArraySchema(new SmsRecipientV1Schema()))
				.withOptionalProperty('parameters', TypeCode.Map),
            (correlationId: string, args: Parameters, callback: (err: any, result: any) => void) => {
                let message = args.get("message");
                let recipients = args.get("recipients");
                let parameters = args.get("parameters");
                this._logic.sendMessageToRecipients(correlationId, recipients, message, parameters, (err) => {
					callback(err, null);
				});
            }
		);
	}

}