[WTEL-10383]feature(broker): add creating system online skill on new

app/app.go

@@ -68,7 +68,7 @@
 	cc               cc.CCManager
 	cipher           presign.PreSign
 	audit            *logger.Audit
 	ctx              context.Context
 	tracer           *Tracer
 	otelShutdownFunc otelsdk.ShutdownFunc
 	eventTrigger     EventTrigger
@@ -200,6 +200,7 @@
 	app.Store = store.NewLayeredStore(sqlSupplier)
 
 	app.MessageQueue = rabbit.NewRabbitMQ(app.Config().NodeName, &app.Config().MessageQueueSettings)
+	app.initDomainEventListener()
 	app.MessageQueue.Start()
 
 	app.Hubs = NewHubs(app)

app/online_skills.go

@@ -4,8 +4,13 @@ import (
 	"context"
 
 	"github.com/webitel/engine/model"
+	"github.com/webitel/wlog"
 )
 
+func (app *App) initDomainEventListener() {
+	app.MessageQueue.SetDomainsEventHandler(app.handleDomainEventCreated)
+}
+
 func (app *App) CreateOnlineSkills(ctx context.Context, preset *model.OnlineSkills) (*model.OnlineSkills, model.AppError) {
 	preset.PreSave()
 
@@ -35,3 +40,13 @@ func (app *App) PatchOnlineSkills(ctx context.Context, cmd *model.PatchOnlineSki
 func (app *App) DeleteOnlineSkills(ctx context.Context, cmd *model.DeleteSkillPresetCmd) model.AppError {
 	return app.Store.OnlineSkills().Delete(ctx, cmd)
 }
+
+func (app *App) handleDomainEventCreated(ctx context.Context, e *model.DomainEvent) error {
+	if err := app.Store.OnlineSkills().CreateSystem(ctx, e.ID); err != nil {
+		app.Log.Error("processing domain created event", wlog.Err(err))
+
+		return err
+	}
+
+	return nil
+}

model/domain.go

@@ -1,6 +1,44 @@
 package model
 
-import "time"
+import (
+	"fmt"
+	"strconv"
+	"strings"
+	"time"
+)
+
+type DomainEvent struct {
+	ID int64
+}
+
+func NewDomainEventFromRoutingKey(rk string) (*DomainEvent, AppError) {
+	splitted := strings.Split(rk, ".")
+	if len(splitted) < 3 {
+		return nil, NewBadRequestError(
+			"model.domain.new_domain_event.invalid_rk_len",
+			"received roting key with len less than 3",
+		)
+	}
+
+	const domainIdIndex = 2
+
+	parsedDomainId, err := strconv.ParseInt(splitted[domainIdIndex], 10, 64)
+	if err != nil {
+		return nil, NewBadRequestError(
+			"model.domain.new_domain_event.parsing_id",
+			fmt.Sprintf("parsing routing key id to integer: %+v", err),
+		)
+	}
+
+	if parsedDomainId <= 0 {
+		return nil, NewBadRequestError(
+			"model.domain.new_domain_event.domain_id_less_or_equal_zero",
+			fmt.Sprintf("received domain id less or equal zero: %d", parsedDomainId),
+		)
+	}
+
+	return &DomainEvent{ID: parsedDomainId}, nil
+}
 
 type DomainProvider interface {
 	Domain(int64) int64

mq/layered_mq.go

@@ -11,7 +11,7 @@
 }
 
 type LayeredMQ struct {
 	context context.Context
 	MQLayer LayeredMQLayer
 }
 
@@ -70,6 +70,10 @@
 	return l.MQLayer.Send(ctx, exchange, rk, body)
 }
 
-func (l *LayeredMQ) SendStartFlow(ctx context.Context, domainId int64, schemaId int32, in interface{}) model.AppError {
+func (l *LayeredMQ) SendStartFlow(ctx context.Context, domainId int64, schemaId int32, in any) model.AppError {
 	return l.MQLayer.SendStartFlow(ctx, domainId, schemaId, in)
 }
+
+func (l *LayeredMQ) SetDomainsEventHandler(h DomainEventHandler) {
+	l.MQLayer.SetDomainsEventHandler(h)
+}

mq/mq.go

@@ -2,9 +2,12 @@ package mq
 
 import (
 	"context"
+
 	"github.com/webitel/engine/model"
 )
 
+type DomainEventHandler func(ctx context.Context, e *model.DomainEvent) error
+
 type MQ interface {
 	SendJSON(name string, data []byte) model.AppError
 	BindCallEvents(domainId, userId int64) error
@@ -25,6 +28,7 @@ type MQ interface {
 	Send(ctx context.Context, exchange string, rk string, body []byte) error
 
 	SendStartFlow(ctx context.Context, domainId int64, schemaId int32, in interface{}) model.AppError
+	SetDomainsEventHandler(h DomainEventHandler)
 }
 
 type DomainQueue interface {