// Package websocket
// @Link  https://gitee.com/linngc/center.gf
// @Copyright  Copyright (c) 2022 center CLI
// @Author  linngc
// @title 操作行为：如登录，请求get等
// @License
package websocket

import (
	"context"
	v1 "gitee.com/linngc/center.gf/api/v1/websocket"
	"gitee.com/linngc/center.gf/contrib/module/websocket"
	websocketvo "gitee.com/linngc/center.gf/internal/model/vo/websocket"
	"gitee.com/linngc/center.gf/internal/service/platform/admin"
	"github.com/gogf/gf/v2/frame/g"
)

var Action = cAction{}

type cAction struct{}

func (c *cAction) GetActionWss(ctx context.Context, req *v1.ActionReq) (res *v1.ActionRes, err error) {
	fromCtx := g.RequestFromCtx(ctx)

	err = websocket.Websocket(ctx, fromCtx)
	if err != nil {
		return nil, err
	}

	go websocket.SendToCron(ctx, "0 */1 * * * *", websocket.MsgTypeAll,
		func(ctx context.Context, msgType string) (response *websocket.WResponse, err error) {

			wss := websocketvo.ActionWss{RequestAction: admin.AdminAction().GetRequestAction(), OptAction: admin.AdminAction().GetOptAction()}

			return &websocket.WResponse{Event: websocket.Msg, Data: wss}, err
		})

	return
}