// Copyright Amazon.com Inc. or its affiliates. All Rights Reserved.
//
// Licensed under the Apache License, Version 2.0 (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/apache2.0/
//
// or in the "license" file accompanying this file. This file is distributed
// on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
// express or implied. See the License for the specific language governing
// permissions and limitations under the License.

// Package acsclient wraps the generated aws-sdk-go client to provide marshalling
// and unmarshalling of data over a websocket connection in the format expected
// by ACS. It allows for bidirectional communication and acts as both a
// client-and-server in terms of requests, but only as a client in terms of
// connecting.
package acsclient

import (
	"context"
	"errors"
	"time"

	"github.com/aws/amazon-ecs-agent/ecs-agent/logger"
	"github.com/aws/amazon-ecs-agent/ecs-agent/wsclient"
	"github.com/aws/aws-sdk-go/aws/credentials"
)

// clientServer implements ClientServer for acs.
type clientServer struct {
	wsclient.ClientServerImpl
}

type acsClientFactory struct{}

// NewACSClientFactory creates a new ACS client factory object. This can be
// used to create new ACS clients.
func NewACSClientFactory() wsclient.ClientFactory {
	return &acsClientFactory{}
}

// New returns a client/server to bidirectionally communicate with ACS
// The returned struct should have both 'Connect' and 'Serve' called upon it
// before being used.
func (*acsClientFactory) New(url string, credentialProvider *credentials.Credentials, rwTimeout time.Duration, cfg *wsclient.WSClientMinAgentConfig) wsclient.ClientServer {
	cs := &clientServer{}
	cs.URL = url
	cs.CredentialProvider = credentialProvider
	cs.Cfg = cfg
	cs.ServiceError = &acsError{}
	cs.RequestHandlers = make(map[string]wsclient.RequestHandler)
	cs.TypeDecoder = NewACSDecoder()
	cs.RWTimeout = rwTimeout
	return cs
}

// Serve begins serving requests using previously registered handlers (see
// AddRequestHandler). All request handlers should be added prior to making this
// call as unhandled requests will be discarded.
func (cs *clientServer) Serve(ctx context.Context) error {
	logger.Debug("ACS client starting websocket poll loop")
	if !cs.IsReady() {
		return errors.New("acs client: websocket not ready for connections")
	}
	return cs.ConsumeMessages(ctx)
}

// Close closes the underlying connection
func (cs *clientServer) Close() error {
	return cs.Disconnect()
}