autogen_aws_cloudtrail_inventory.go

//AUTOGENERATED CODE DO NOT EDIT
// This file is automatically generated from /internal/codegen/templates/aws_service_inventory_file.tmpl
package inventory

import (
	"context"

	"github.com/sheacloud/cloud-inventory/internal/db"
	"github.com/sheacloud/cloud-inventory/pkg/aws"
	"github.com/sheacloud/cloud-inventory/pkg/aws/cloudtrail"
)

func IngestAwsCloudTrailTrails(ctx context.Context, dao db.WriterDAO, input *aws.AwsFetchInput) (*aws.AwsFetchOutputMetadata, error) {
	resources, metadata := cloudtrail.FetchTrails(ctx, input)
	if resources != nil {
		err := dao.PutAwsCloudTrailTrails(ctx, resources)
		if err != nil {
			return nil, err
		}
	}

	return metadata, nil
}