Function getS3Status

cmd/lambda-nat-proxy/cmd_status.go:223–262

(ctx context.Context, clients *awsclients.Clients, cfg *config.CLIConfig, bucketName string)

}

func getS3Status(ctx context.Context, clients *awsclients.Clients, cfg *config.CLIConfig, bucketName string) (*S3Status, error) {
	status := &S3Status{
		BucketName: bucketName,
	}
	
	// List objects to get count and size
	input := &s3.ListObjectsV2Input{
		Bucket: aws.String(bucketName),
	}
	
	result, err := clients.S3.ListObjectsV2WithContext(ctx, input)
	if err != nil {
		return nil, fmt.Errorf("failed to list S3 objects: %w", err)
	}
	
	status.ObjectCount = len(result.Contents)
	var totalSize int64
	var lastModified *time.Time
	
	for _, obj := range result.Contents {
		totalSize += *obj.Size
		if lastModified == nil || obj.LastModified.After(*lastModified) {
			lastModified = obj.LastModified
		}
	}
	
	status.TotalSize = totalSize
	if lastModified != nil {
		status.LastActivity = lastModified.Format("2006-01-02 15:04:05")
	}
	
	// Check bucket notifications
	triggerDeployer := deploy.NewTriggerDeployer(clients, cfg)
	notificationConfig, err := triggerDeployer.GetBucketNotifications(ctx, bucketName)
	if err == nil {
		status.NotificationsOK = len(notificationConfig.LambdaFunctionConfigurations) > 0
	}
	
	return status, nil
}

func getRecentLogs(ctx context.Context, clients *awsclients.Clients, functionName string) ([]LogEntry, error) {
	logGroupName := fmt.Sprintf("/aws/lambda/%s", functionName)