Function getLatestLogs

internal/cli/logs.go:219–251

(ctx context.Context, cli *cli, numRequested int, filter string)

}

func getLatestLogs(ctx context.Context, cli *cli, numRequested int, filter string) ([]*management.Log, error) {
	page := 0
	logs := []*management.Log{}

	for {
		perPage := logsPerPageLimit
		if numRequested < (page+1)*logsPerPageLimit {
			perPage = numRequested % logsPerPageLimit
		}

		queryParams := []management.RequestOption{
			management.Parameter("sort", "date:-1"),
			management.Parameter("page", fmt.Sprintf("%d", page)),
			management.Parameter("per_page", fmt.Sprintf("%d", perPage))}

		if filter != "" {
			queryParams = append(queryParams, management.Query(filter))
		}

		res, err := cli.api.Log.List(ctx, queryParams...)
		if err != nil {
			return nil, err
		}
		logs = append(logs, res...)

		page++
		if page == 10 || (page*logsPerPageLimit) >= numRequested {
			break
		}
	}

	return logs, nil
}

func dedupeLogs(list []*management.Log, set map[string]struct{}) []*management.Log {
	res := make([]*management.Log, 0, len(list))