package sysExport

import (
	"context"
	"gitee.com/unitedrhino/core/service/syssvr/client/tenantmanage"
	"gitee.com/unitedrhino/core/service/syssvr/pb/sys"
	"gitee.com/unitedrhino/share/caches"
	"gitee.com/unitedrhino/share/errors"
	"gitee.com/unitedrhino/share/eventBus"
	"github.com/parnurzeal/gorequest"
	"net/http"
	"time"
)

const (
	CodeDmDeviceConn           = "dmDeviceConn"
	CodeDmDevicePropertyReport = "devicePropertyReport"
)

type Webhook struct {
	*caches.Cache[sys.TenantOpenWebHook, string]
}

func NewTenantOpenWebhook(pm tenantmanage.TenantManage, fastEvent *eventBus.FastEvent) (*Webhook, error) {
	c, err := NewTenantOpenWebhookCache(pm, fastEvent)
	if err != nil {
		return nil, err
	}
	return &Webhook{Cache: c}, nil
}

func (i *Webhook) Publish(ctx context.Context, code string, in any) error {
	hook, err := i.GetData(ctx, GenWebhookCacheKey(ctx, code))
	if err != nil {
		if errors.Cmp(err, errors.NotFind) {
			return nil
		}
		return err
	}
	req := gorequest.New().Retry(3, time.Second*2)
	url := hook.Hosts[0] + hook.Uri
	req.Post(url)
	for k, v := range hook.Handler {
		req.Set(k, v)
	}
	resp, body, errs := req.Type("json").Send(in).End()
	if errs != nil {
		return errors.System.AddDetail(errs)
	}
	if resp.StatusCode != http.StatusOK {
		return errors.System.AddDetail(body)
	}
	return nil
}