feat: add sync asset handlers

Author: batrov

Diff for: Makefile

@@ -26,7 +26,7 @@ help:           ##@help show this help
 NAME="github.com/goto/compass"
 VERSION=$(shell git describe --always --tags 2>/dev/null)
 COVERFILE="/tmp/compass.coverprofile"
-PROTON_COMMIT := "a6b2821e8ddd1127a63d3b376f860990d58931da"
+PROTON_COMMIT := "eaca9798d1c1d7b3101ec1259c7e5fb949afba28"
 
 TOOLS_MOD_DIR = ./tools
 TOOLS_DIR = $(abspath ./.tools)

Diff for: core/asset/mocks/worker_mock.go

@@ -24,6 +24,7 @@ type Service struct {
 type Worker interface {
 	EnqueueIndexAssetJob(ctx context.Context, ast Asset) error
 	EnqueueDeleteAssetJob(ctx context.Context, urn string) error
+	EnqueueSyncAssetJob(ctx context.Context, services []string) error
 	Close() error
 }
 
@@ -229,6 +230,22 @@ func (s *Service) SuggestAssets(ctx context.Context, cfg SearchConfig) (suggesti
 	return s.discoveryRepository.Suggest(ctx, cfg)
 }
 
+func (s *Service) SyncAssets(ctx context.Context, services []string) error {
+	// select from job queue
+
+	// bad request, job already there
+
+	// if not, insert
+
+	// recreate index logic
+
+	// validate
+
+	s.worker.EnqueueSyncAssetJob(ctx, services)
+
+	return nil
+}
+
 func (s *Service) instrumentAssetOp(ctx context.Context, op, id string, err error) {
 	identifier := "URN"
 	if isValidUUID(id) {

Diff for: core/asset/service.go

@@ -39,6 +39,8 @@ type AssetService interface {
 	SuggestAssets(ctx context.Context, cfg asset.SearchConfig) (suggestions []string, err error)
 
 	AddProbe(ctx context.Context, assetURN string, probe *asset.Probe) error
+
+	SyncAssets(ctx context.Context, services []string) error
 }
 
 func (server *APIServer) GetAllAssets(ctx context.Context, req *compassv1beta1.GetAllAssetsRequest) (*compassv1beta1.GetAllAssetsResponse, error) {
@@ -344,6 +346,13 @@ func (server *APIServer) CreateAssetProbe(ctx context.Context, req *compassv1bet
 	}, nil
 }
 
+func (server *APIServer) SyncAssets(ctx context.Context, req *compassv1beta1.SyncAssetsRequest) (*compassv1beta1.SyncAssetsResponse, error) {
+
+	server.assetService.SyncAssets(ctx, req.GetServices())
+
+	return nil, nil
+}
+
 func (server *APIServer) upsertAsset(
 	ctx context.Context,
 	ast asset.Asset,

Diff for: internal/server/v1beta1/asset.go

@@ -91,3 +91,7 @@ func (m *Manager) DeleteAsset(ctx context.Context, job worker.JobSpec) error {
 	}
 	return nil
 }
+
+func (m *Manager) EnqueueSyncAssetJob(ctx context.Context, services []string) error {
+	return nil
+}

Diff for: internal/server/v1beta1/mocks/asset_service.go

@@ -32,4 +32,8 @@ func (m *InSituWorker) EnqueueDeleteAssetJob(ctx context.Context, urn string) er
 	return nil
 }
 
+func (m *InSituWorker) EnqueueSyncAssetJob(ctx context.Context, services []string) error {
+	return nil
+}
+
 func (*InSituWorker) Close() error { return nil }

Diff for: internal/server/v1beta1/mocks/discussion_service.go

@@ -420,6 +420,44 @@ paths:
           type: string
       tags:
         - Asset
+  /v1beta1/assets/sync:
+    post:
+      summary: Syncs assets in elasticsearch
+      description: Synchronize all assets in DB to elasticsearch
+      operationId: CompassService_SyncAssets
+      responses:
+        "200":
+          description: A successful response.
+          schema:
+            $ref: '#/definitions/SyncAssetsResponse'
+        "400":
+          description: Returned when the data that user input is wrong.
+          schema:
+            $ref: '#/definitions/Status'
+        "404":
+          description: Returned when the resource does not exist.
+          schema:
+            $ref: '#/definitions/Status'
+        "409":
+          description: Returned when the resource already exist.
+          schema:
+            $ref: '#/definitions/Status'
+        "500":
+          description: Returned when theres is something wrong on the server side.
+          schema:
+            $ref: '#/definitions/Status'
+        default:
+          description: An unexpected error response.
+          schema:
+            $ref: '#/definitions/Status'
+      parameters:
+        - name: body
+          in: body
+          required: true
+          schema:
+            $ref: '#/definitions/SyncAssetsRequest'
+      tags:
+        - Asset
   /v1beta1/discussions:
     get:
       summary: Get all discussions
@@ -2291,6 +2329,16 @@ definitions:
         type: array
         items:
           type: string
+  SyncAssetsRequest:
+    type: object
+    properties:
+      services:
+        type: array
+        items:
+          type: string
+        description: filter by multiple services
+  SyncAssetsResponse:
+    type: object
   TagTemplate:
     type: object
     properties: