From 05fbc6c65c8556d89d8b7fdb645f3ef3b273b5e9 Mon Sep 17 00:00:00 2001 From: Nick White Date: Tue, 13 Jul 2021 10:34:26 +0100 Subject: aws: Only look up test queue id when asked for, as for most Init()s it won't be needed --- aws.go | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) (limited to 'aws.go') diff --git a/aws.go b/aws.go index 6e0d7f8..2411c24 100644 --- a/aws.go +++ b/aws.go @@ -51,7 +51,6 @@ type AwsConn struct { downloader *s3manager.Downloader uploader *s3manager.Uploader wipequrl, prequrl, ocrpgqurl, analysequrl string - testqurl string wipstorageid string } @@ -126,15 +125,6 @@ func (a *AwsConn) Init() error { } a.analysequrl = *result.QueueUrl - a.Logger.Println("Getting test queue URL") - result, err = a.sqssvc.GetQueueUrl(&sqs.GetQueueUrlInput{ - QueueName: aws.String(queueTest), - }) - if err != nil { - return errors.New(fmt.Sprintf("Error getting test queue URL: %s", err)) - } - a.testqurl = *result.QueueUrl - return nil } @@ -347,7 +337,17 @@ func (a *AwsConn) WIPStorageId() string { } func (a *AwsConn) TestQueueId() string { - return a.testqurl + // We don't bother saving the queue id in Init(), as it's only + // used for testing + a.Logger.Println("Getting test queue URL") + result, err := a.sqssvc.GetQueueUrl(&sqs.GetQueueUrlInput{ + QueueName: aws.String(queueTest), + }) + if err != nil { + a.Logger.Printf("Error getting test queue URL: %s\n", err) + return "" + } + return *result.QueueUrl } func (a *AwsConn) ListObjects(bucket string, prefix string) ([]string, error) { -- cgit v1.2.1-24-ge1ad