Function TestListHttpFile

input/list_test.go:410–495

(t *testing.T)

}

func TestListHttpFile(t *testing.T) {
	files := map[string]struct {
		// alternative fields
		lines int64    // number of random lines
		files []string // file names to include
	}{
		"/test7.log.gz":    {lines: 7},
		"/test100.log.gz":  {lines: 100},
		"/test500.log.gz":  {lines: 500},
		"/test1233.log.gz": {lines: 1233},
		"/testlist600":     {files: []string{"/test100.log.gz", "/test500.log.gz"}},
		"/buglist":         {files: []string{"/test100.log.gz", "/nonesisting.log.gz"}},
	}
	ts := newHTTPFileServer(t, files)
	defer ts.Close()

	var tests = []struct {
		files []string
		lines int64 // -1 for error
	}{
		{[]string{ts.URL + "/test7.log.gz"}, 7},
		{[]string{ts.URL + "/test1233.log.gz"}, 1233},
		{[]string{
			ts.URL + "/test100.log.gz",
			ts.URL + "/test500.log.gz",
		}, 600},
		{[]string{"@" + ts.URL + "/testlist600"}, 600},
		{[]string{
			ts.URL + "/test100.log.gz",
			"@" + ts.URL + "/testlist600",
			ts.URL + "/test7.log.gz",
		}, 707},
		// errors
		{[]string{
			ts.URL + "/test100.log.gz",
			ts.URL + "/nonexisting2.log.gz",
		}, -1},
		{[]string{"@" + ts.URL + "/notexistinglist"}, -1},
		{[]string{
			"@" + ts.URL + "/buglist",
			ts.URL + "/test100.log.gz",
		}, -1},
	}

	ch := make(chan *baker.Data)
	defer close(ch)
	var counter int64
	go func() {
		for data := range ch {
			atomic.AddInt64(&counter, int64(bytes.Count(data.Bytes, []byte{'\n'})))
			// Check the metadata contains a valid last modified date
			if v := data.Meta["last_modified"]; v.(time.Time).IsZero() {
				t.Errorf("Invalid last modified time in file, it should not be zero")
			}
		}
	}()

	for _, tt := range tests {