Cloudpods/backend/pkg/cloudcommon/notifyclient/events.go

// Copyright 2019 Yunion
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package notifyclient

import (
	"fmt"
	"strings"

	api "yunion.io/x/onecloud/pkg/apis/notify"
	"yunion.io/x/onecloud/pkg/cloudcommon/db"
)

const (
	SYSTEM_ERROR   = "SYSTEM_ERROR"
	SYSTEM_WARNING = "SYSTEM_WARNING"

	SERVER_CREATED       = "SERVER_CREATED"
	SERVER_CREATED_ADMIN = "SERVER_CREATED_ADMIN"
	SERVER_DELETED       = "SERVER_DELETED"
	SERVER_DELETED_ADMIN = "SERVER_DELETED_ADMIN"
	SERVER_REBUILD_ROOT  = "SERVER_REBUILD_ROOT"
	SERVER_CHANGE_FLAVOR = "SERVER_CHANGE_FLAVOR"
	SERVER_PANICKED      = "SERVER_PANICKED"

	IMAGE_ACTIVED = "IMAGE_ACTIVED"

	USER_LOGIN_EXCEPTION = "USER_LOGIN_EXCEPTION"
)

var (
	Event SEvent

	ActionCreate         = api.ActionCreate
	ActionDelete         = api.ActionDelete
	ActionUpdate         = api.ActionUpdate
	ActionReset          = api.ActionReset
	ActionRebuildRoot    = api.ActionRebuildRoot
	ActionResetPassword  = api.ActionResetPassword
	ActionChangeConfig   = api.ActionChangeConfig
	ActionResize         = api.ActionResize
	ActionExpiredRelease = api.ActionExpiredRelease
	ActionExecute        = api.ActionExecute

	ActionMigrate            = api.ActionMigrate
	ActionCreateBackupServer = api.ActionCreateBackupServer
	ActionDelBackupServer    = api.ActionDelBackupServer
	ActionSyncStatus         = api.ActionSyncStatus
	ActionNetOutOfSync       = api.ActionNetOutOfSync
	ActionMysqlOutOfSync     = api.ActionMysqlOutOfSync
	ActionServiceAbnormal    = api.ActionServiceAbnormal
	ActionServerPanicked     = api.ActionServerPanicked

	ActionHostDown            = api.ActionHostDown
	ActionHostDownAutoMigrate = api.ActionHostDownAutoMigrate

	ActionPendingDelete = api.ActionPendingDelete

	ActionSyncCreate           = api.ActionSyncCreate
	ActionSyncUpdate           = api.ActionSyncUpdate
	ActionSyncDelete           = api.ActionSyncDelete
	ActionSyncAccountStatus    = api.ActionSyncAccountStatus
	ActionIsolatedDeviceCreate = api.ActionIsolatedDeviceCreate
	ActionIsolatedDeviceUpdate = api.ActionIsolatedDeviceUpdate
	ActionIsolatedDeviceDelete = api.ActionIsolatedDeviceDelete
)

type SEvent struct {
	resourceType string
	action       api.SAction
}

func (se SEvent) WithResourceType(manager db.IModelManager) SEvent {
	se.resourceType = manager.Keyword()
	return se
}

func (se SEvent) WithAction(a api.SAction) SEvent {
	se.action = a
	return se
}

func (se SEvent) ResourceType() string {
	return se.resourceType
}

func (se SEvent) Action() string {
	return string(se.action)
}

func (se SEvent) String() string {
	return strings.ToUpper(fmt.Sprintf("%s_%s", se.ResourceType(), se.Action()))
}