chore: allow to query registries not added in settings

Author: Leonardo Chaia

src/app/docker-images/generic-image-source.ts

@@ -0,0 +1,49 @@
+import { ImageSource, ImageListFilter, ImageListItemData, ImageInfo } from './image-source.model';
+import { TimCacheService } from '../tim-cache/tim-cache.service';
+import { Observable } from 'rxjs';
+import { ImageLayerHistoryV1Compatibility } from '../registry/registry.model';
+import { RegistryService } from '../registry/registry.service';
+import { RegistryImageSource } from '../registry/registry.image-source';
+import { DEFAULT_REGISTRY_CACHE } from '../settings/settings.service';
+import { CachingImageSource } from './caching-image-source';
+import { DockerRegistrySettings } from '../settings/settings.model';
+
+export class GenericImageSource extends ImageSource {
+    public readonly name = 'Generic Image Source';
+    private readonly wrapped: ImageSource;
+
+    constructor(
+        public readonly registryDNS: string,
+        private readonly registry: RegistryService,
+        private readonly cache: TimCacheService) {
+        super();
+        const registrySettings = {
+            enableCaching: true,
+            cacheDurationInMinutes: DEFAULT_REGISTRY_CACHE,
+            isDockerHub: false,
+            url: `https://${registryDNS}/`,
+            username: null,
+            password: null
+        } as DockerRegistrySettings;
+
+        const registrySource = new RegistryImageSource(registrySettings, this.registry);
+
+        this.wrapped = new CachingImageSource(registrySource, this.cache, registrySettings.cacheDurationInMinutes);
+    }
+
+    public loadList(filter?: ImageListFilter): Observable<ImageListItemData[]> {
+        return this.wrapped.loadList(filter);
+    }
+
+    public loadImageInfo(image: string): Observable<ImageInfo> {
+        return this.wrapped.loadImageInfo(image);
+    }
+
+    public loadImageHistory(image: string): Observable<ImageLayerHistoryV1Compatibility[]> {
+        return this.wrapped.loadImageHistory(image);
+    }
+
+    public loadImageTags(image: string): Observable<string[]> {
+        return this.wrapped.loadImageTags(image);
+    }
+}

src/app/docker-images/image-source.service.ts

@@ -3,6 +3,10 @@ import { ImageSourceMultiple, ImageSource } from './image-source.model';
 import { of, combineLatest, BehaviorSubject } from 'rxjs';
 import { switchMap, map, take } from 'rxjs/operators';
 import { flatten } from '../shared/array-tools';
+import { explodeImage } from './image-tools';
+import { GenericImageSource } from './generic-image-source';
+import { RegistryService } from '../registry/registry.service';
+import { TimCacheService } from '../tim-cache/tim-cache.service';
 
 @Injectable({
   providedIn: 'root'
@@ -17,7 +21,9 @@ export class ImageSourceService {
 
   constructor(
     @Inject(ImageSourceMultiple)
-    sources: ImageSourceMultiple[]) {
+    sources: ImageSourceMultiple[],
+    private readonly registry: RegistryService,
+    private readonly cache: TimCacheService) {
 
     of(sources)
       .pipe(
@@ -34,15 +40,27 @@ export class ImageSourceService {
     return this.sources
       .pipe(
         map(sources => sources.find(s => s.isImageOwner(image))),
+        map(source => !source ? this.createGenericImageSourceForImage(image) : source),
         take(1),
       );
   }
 
   public getForDNS(registryDNS: string) {
     return this.sources.pipe(
       map(srcs => srcs.find(s => s.isRegistryOwner(registryDNS))),
+      map(source => !source ? this.createGenericImageSource(registryDNS) : source),
       take(1),
     );
   }
 
+  protected createGenericImageSourceForImage(image: string): ImageSource {
+    const imageInfo = explodeImage(image);
+    if (imageInfo.registry) {
+      return this.createGenericImageSource(imageInfo.registry);
+    }
+  }
+
+  protected createGenericImageSource(registryDNS: string): ImageSource {
+    return new GenericImageSource(registryDNS, this.registry, this.cache);
+  }
 }

src/app/docker-images/image-tools.ts

@@ -12,18 +12,23 @@ export function explodeImage(image: string) {
 
   const matches = image.match(/(.+\/)?([^:]+)(:.+)?/);
 
-  let registryOrNamespace = matches[1];
+  const registryOrNamespace = matches[1];
   let registry: string;
   let reference = matches[2];
   let tag = matches[3];
 
   if (registryOrNamespace) {
-    registryOrNamespace = registryOrNamespace.replace('/', '');
 
-    // Determine registry vs namespace
-    if (registryOrNamespace.includes('.')) {
+    if (registryOrNamespace.includes('/')) {
+      // Registry and namespace
+      const split = registryOrNamespace.split('/');
+      registry = split[0];
+      reference = `${split[1]}/${reference}`;
+    } else if (registryOrNamespace.includes('.')) {
+      // Registry only
       registry = registryOrNamespace;
     } else {
+      // Namespace only
       reference = `${registryOrNamespace}/${reference}`;
     }
   }