//
// Copyright 2014-2015 Amazon.com, 
// Inc. or its affiliates. All Rights Reserved.
// 
// Licensed under the Amazon Software License (the "License"). 
// You may not use this file except in compliance with the 
// License. A copy of the License is located at
// 
//     http://aws.amazon.com/asl/
// 
// or in the "license" file accompanying this file. This file is 
// distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR 
// CONDITIONS OF ANY KIND, express or implied. See the License 
// for the specific language governing permissions and 
// limitations under the License.
//
using UnityEngine;
using System.Collections;
using Amazon;
using Amazon.Runtime;
using Amazon.CognitoIdentity;
using Amazon.SQS;
using UnityEngine.UI;

namespace AWSSDK.Examples
{
    public class SQSExample : MonoBehaviour
    {
        //identity pool id for cognito credentials
        public string IdentityPoolId = "";

        public string CognitoIdentityRegion = RegionEndpoint.USEast1.SystemName;

        private RegionEndpoint _CognitoIdentityRegion
        {
            get { return RegionEndpoint.GetBySystemName(CognitoIdentityRegion); }
        }

        public string SQSRegion = RegionEndpoint.USEast1.SystemName;

        private RegionEndpoint _SQSRegion
        {
            get { return RegionEndpoint.GetBySystemName(SQSRegion); }
        }

        //name of the queue you want to create
        public string QueueName = "AWS_SQS_EXAMPLE_QUEUE";

        private AWSCredentials _credentials;

        private AWSCredentials Credentials
        {
            get
            {
                if (_credentials == null)
                    _credentials = new CognitoAWSCredentials(IdentityPoolId, _CognitoIdentityRegion);
                return _credentials;
            }
        }

        private IAmazonSQS _sqsClient;

        private IAmazonSQS SqsClient
        {
            get
            {
                if (_sqsClient == null)
                    _sqsClient = new AmazonSQSClient(Credentials, _SQSRegion);
                return _sqsClient;
            }
        }

        public Button CreateQueue;
        public Button SendMessage;
        public Button RetrieveMessage;
        public Button DeleteQueue;
        public InputField Message;

        private string queueUrl;

        // Use this for initialization
        void Start()
        {
            UnityInitializer.AttachToGameObject(this.gameObject);
            CreateQueue.onClick.AddListener(CreateQueueListener);
            SendMessage.onClick.AddListener(SendMessageListener);
            RetrieveMessage.onClick.AddListener(RetrieveMessageListener);
            DeleteQueue.onClick.AddListener(DeleteQueueListener);
        }

        private void CreateQueueListener()
        {
            SqsClient.CreateQueueAsync(QueueName, (result) =>
            {
                if (result.Exception == null)
                {
                    Debug.Log(@"Queue Created");
                    queueUrl = result.Response.QueueUrl;
                }
                else
                {
                    Debug.LogException(result.Exception);
                }
            });
        }

        private void DeleteQueueListener()
        {
            if (!string.IsNullOrEmpty(queueUrl))
            {
                SqsClient.DeleteQueueAsync(queueUrl, (result) =>
                {
                    if (result.Exception == null)
                    {
                        Debug.Log(@"Queue Deleted");
                    }
                    else
                    {
                        Debug.LogException(result.Exception);
                    }
                });
            }
            else
            {
                Debug.Log(@"Queue Url is empty, make sure that the queue is created first");
            }
        }

        private void SendMessageListener()
        {
            if (!string.IsNullOrEmpty(queueUrl))
            {
                var message = Message.text;
                if (string.IsNullOrEmpty(message))
                {
                    Debug.Log("No Message to send");
                    return;
                }

                SqsClient.SendMessageAsync(queueUrl, message, (result) =>
                {
                    if (result.Exception == null)
                    {
                        Debug.Log("Message Sent");
                    }
                    else
                    {
                        Debug.LogException(result.Exception);
                    }
                });
            }
            else
            {
                Debug.Log(@"Queue Url is empty, make sure that the queue is created first");
            }
        }

        private void RetrieveMessageListener()
        {
            if (!string.IsNullOrEmpty(queueUrl))
            {
                SqsClient.ReceiveMessageAsync(queueUrl, (result) =>
                {
                    if (result.Exception == null)
                    {
                        var messages = result.Response.Messages;
                        messages.ForEach(m =>
                        {
                            Debug.Log(@"Message Id  = " + m.MessageId);
                            Debug.Log(@"Mesage = " + m.Body);
                        });
                    }
                    else
                    {
                        Debug.LogException(result.Exception);
                    }
                });
            }
            else
            {
                Debug.Log(@"Queue Url is empty, make sure that the queue is created first");
            }
        }
    }
}