Function getRecentLogs

cmd/lambda-nat-proxy/cmd_status.go:264–323

(ctx context.Context, clients *awsclients.Clients, functionName string)

}

func getRecentLogs(ctx context.Context, clients *awsclients.Clients, functionName string) ([]LogEntry, error) {
	logGroupName := fmt.Sprintf("/aws/lambda/%s", functionName)
	
	// Get log streams
	input := &cloudwatchlogs.DescribeLogStreamsInput{
		LogGroupName: aws.String(logGroupName),
		OrderBy:      aws.String("LastEventTime"),
		Descending:   aws.Bool(true),
		Limit:        aws.Int64(5),
	}
	
	streams, err := clients.CloudWatchLogs.DescribeLogStreamsWithContext(ctx, input)
	if err != nil {
		return nil, fmt.Errorf("failed to get log streams: %w", err)
	}
	
	var entries []LogEntry
	
	// Get events from the most recent stream
	if len(streams.LogStreams) > 0 {
		eventsInput := &cloudwatchlogs.GetLogEventsInput{
			LogGroupName:  aws.String(logGroupName),
			LogStreamName: streams.LogStreams[0].LogStreamName,
			StartFromHead: aws.Bool(false),
			Limit:         aws.Int64(20),
		}
		
		events, err := clients.CloudWatchLogs.GetLogEventsWithContext(ctx, eventsInput)
		if err != nil {
			return nil, fmt.Errorf("failed to get log events: %w", err)
		}
		
		for _, event := range events.Events {
			if event.Message != nil && event.Timestamp != nil {
				timestamp := time.Unix(*event.Timestamp/1000, 0).Format("2006-01-02 15:04:05")
				message := strings.TrimSpace(*event.Message)
				
				// Try to extract log level
				level := ""
				if strings.Contains(message, "ERROR") {
					level = "ERROR"
				} else if strings.Contains(message, "WARN") {
					level = "WARN"
				} else if strings.Contains(message, "INFO") {
					level = "INFO"
				} else if strings.Contains(message, "DEBUG") {
					level = "DEBUG"
				}
				
				entries = append(entries, LogEntry{
					Timestamp: timestamp,
					Message:   message,
					Level:     level,
				})
			}
		}
	}