updater: move each fetcher to its own package

cmd/clair/main.go

@@ -26,6 +26,10 @@ import (
 	"github.com/coreos/pkg/capnslog"
 
 	// Register components
+	_ "github.com/coreos/clair/notifier/notifiers"
+	_ "github.com/coreos/clair/updater/fetchers/debian"
+	_ "github.com/coreos/clair/updater/fetchers/rhel"
+	_ "github.com/coreos/clair/updater/fetchers/ubuntu"
 	_ "github.com/coreos/clair/worker/detectors/feature/dpkg"
 	_ "github.com/coreos/clair/worker/detectors/feature/rpm"
 	_ "github.com/coreos/clair/worker/detectors/namespace/aptsources"

updater/fetchers/debian.go → updater/fetchers/debian/debian.go

@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package fetchers
+package debian
 
 import (
 	"crypto/sha1"
@@ -53,7 +53,7 @@ type jsonRel struct {
 type DebianFetcher struct{}
 
 func init() {
-	//updater.RegisterFetcher("debian", &DebianFetcher{})
+	updater.RegisterFetcher("debian", &DebianFetcher{})
 }
 
 // FetchUpdate fetches vulnerability updates from the Debian Security Tracker.

updater/fetchers/debian_test.go → updater/fetchers/debian/debian_test.go

@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package fetchers
+package debian
 
 import (
 	"os"

updater/fetchers/rhel.go → updater/fetchers/rhel/rhel.go

@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package fetchers
+package rhel
 
 import (
 	"bufio"

updater/fetchers/rhel_test.go → updater/fetchers/rhel/rhel_test.go

@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package fetchers
+package rhel
 
 import (
 	"os"
@@ -56,10 +56,10 @@ func TestRHELParser(t *testing.T) {
 			},
 		}
 
-			for _, expectedPackage := range expectedPackages {
-				assert.Contains(t, packages, expectedPackage)
-				assert.Contains(t, vulnerabilities[0].FixedInNodes, expectedPackage.GetNode())
-			}
+		for _, expectedPackage := range expectedPackages {
+			assert.Contains(t, packages, expectedPackage)
+			assert.Contains(t, vulnerabilities[0].FixedInNodes, expectedPackage.GetNode())
+		}
 	}
 
 	// Test parsing testdata/fetcher_rhel_test.2.xml
@@ -84,9 +84,9 @@ func TestRHELParser(t *testing.T) {
 			},
 		}
 
-			for _, expectedPackage := range expectedPackages {
-				assert.Contains(t, packages, expectedPackage)
-				assert.Contains(t, vulnerabilities[0].FixedInNodes, expectedPackage.GetNode())
-			}
+		for _, expectedPackage := range expectedPackages {
+			assert.Contains(t, packages, expectedPackage)
+			assert.Contains(t, vulnerabilities[0].FixedInNodes, expectedPackage.GetNode())
+		}
 	}
 }

updater/fetchers/ubuntu.go → updater/fetchers/ubuntu/ubuntu.go

@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package fetchers
+package ubuntu
 
 import (
 	"bufio"

updater/fetchers/ubuntu_test.go → updater/fetchers/ubuntu/ubuntu_test.go

@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-package fetchers
+package ubuntu
 
 import (
 	"os"