openbilibili/app/admin/ep/marthe/dao/bugly.go

package dao

import (
	"context"
	"fmt"
	"net/http"
	"strconv"

	"go-common/app/admin/ep/marthe/model"
	"go-common/library/ecode"
	"go-common/library/log"
)

const (
	_buglyOkCode            = 200
	_buglyCookieExpiredCode = 100006
	_issueDetailCode        = 100000

	_issueDetailList    = "/v2/lastCrashInfo/appId/%s/platformId/%s/issues/%s/crashDataType/null?offsetTop=56&fsn=6d0260aa-331f-48b9-8557-c2aaf6e0be90"
	_issueList          = "/v2/issueList?sortOrder=desc&sortField=uploadTime&rows=50&fsn=45cdb5aa-eb6f-4bda-9bba-ba0b264bfc93&appId=%s&platformId=%s&version=%s&start=%s&rows=%s&exceptionTypeList=%s"
	_issueVersionList   = "/v2/getSelector/appId/%s/platformId/%s?types=version&fsn=8b8782b5-053d-4f58-bc17-d5c43d7f5ece"
	_issueExceptionList = "/v2/issueInfo/appId/%s/platformId/%s/issueId/%s/exceptionTypeList/Crash,Native,ExtensionCrash?fsn=114a8d02-586d-4fe4-8c23-79003fbe6882"
)

// BuglyVersion Bugly Version .
func (d *Dao) BuglyVersion(c context.Context, buglyCookie *model.BuglyCookie, projectID, platformID string) (ret []*model.BugVersion, err error) {
	var (
		req     *http.Request
		res     *model.BugVersionResponse
		hostStr string
	)

	hostStr = d.c.Bugly.Host + fmt.Sprintf(_issueVersionList, projectID, platformID)

	if req, err = d.newRequest("GET", hostStr, nil); err != nil {
		return
	}

	req.Header.Set("Cookie", buglyCookie.Cookie)
	req.Header.Set("x-token", buglyCookie.Token)
	req.Header.Set("content-type", "application/json;charset=utf-8")
	req.Header.Set("x-csrf-token", "undefined")

	if err = d.httpClient.Do(c, req, &res); err != nil {
		log.Error("d.BugVersion url(%s) err(%v)", "BugVersion", err)
		return
	}

	if res.Status != _buglyOkCode {
		if res.Code == _buglyCookieExpiredCode {
			err = ecode.MartheCookieExpired
			log.Error("maybe need to update cookie and token")
		} else {
			err = ecode.MartheBuglyErr
		}
		log.Error("Status url(%s) res(%v) err(%v)", "BugVersion", res, err)
		return
	}

	ret = res.Ret.BugVersionList
	return
}

// BuglyIssueAndRetry Bugly Issue And Retry.
func (d *Dao) BuglyIssueAndRetry(c context.Context, buglyCookie *model.BuglyCookie, bugIssueRequest *model.BugIssueRequest) (ret *model.BugRet, err error) {
	for i := 0; i < d.c.Bugly.UrlRetryCount; i++ {
		if ret, err = d.BuglyIssue(c, buglyCookie, bugIssueRequest); err == nil {
			break
		}
	}
	return
}

// BuglyIssue Get Issue.
func (d *Dao) BuglyIssue(c context.Context, buglyCookie *model.BuglyCookie, bugIssueRequest *model.BugIssueRequest) (ret *model.BugRet, err error) {
	var (
		req     *http.Request
		res     *model.BugIssueResponse
		hostStr string
	)

	hostStr = d.c.Bugly.Host + fmt.Sprintf(_issueList, bugIssueRequest.ProjectID, bugIssueRequest.PlatformID, bugIssueRequest.Version, strconv.Itoa(bugIssueRequest.StartNum), strconv.Itoa(bugIssueRequest.Rows), bugIssueRequest.ExceptionType)

	if req, err = d.newRequest("GET", hostStr, nil); err != nil {
		return
	}

	req.Header.Set("Cookie", buglyCookie.Cookie)
	req.Header.Set("x-token", buglyCookie.Token)
	req.Header.Set("content-type", "application/json;charset=utf-8")
	req.Header.Set("x-csrf-token", "undefined")

	if err = d.httpClient.Do(c, req, &res); err != nil {
		log.Error("d.BuglyIssue url(%s) err(%v)", "BuglyIssue", err)
		return
	}

	if res.Status != _buglyOkCode {
		if res.Code == _buglyCookieExpiredCode {
			err = ecode.MartheCookieExpired
			log.Error("maybe need to update cookie and token")
		} else {
			err = ecode.MartheBuglyErr
		}
		log.Error("Status url(%s) res(%v) err(%v)", "BuglyIssue", res, err)
		return
	}

	ret = res.Ret
	return
}

// BuglyIssueDetailAndRetry Bugly Issue Detail And Retry.
func (d *Dao) BuglyIssueDetailAndRetry(c context.Context, buglyCookie *model.BuglyCookie, projectID, platformID, issueNo string) (bugIssueDetail *model.BugIssueDetail, err error) {
	for i := 0; i < d.c.Bugly.UrlRetryCount; i++ {
		if bugIssueDetail, err = d.BuglyIssueDetail(c, buglyCookie, projectID, platformID, issueNo); err == nil {
			break
		}
	}
	return
}

// BuglyIssueDetail Get Issue Detail.
func (d *Dao) BuglyIssueDetail(c context.Context, buglyCookie *model.BuglyCookie, projectID, platformID, issueNo string) (bugIssueDetail *model.BugIssueDetail, err error) {
	var (
		req     *http.Request
		res     *model.BugIssueDetailResponse
		hostStr string
	)

	hostStr = d.c.Bugly.Host + fmt.Sprintf(_issueDetailList, projectID, platformID, issueNo)

	if req, err = d.newRequest("GET", hostStr, nil); err != nil {
		return
	}

	req.Header.Set("Cookie", buglyCookie.Cookie)
	req.Header.Set("x-token", buglyCookie.Token)
	req.Header.Set("content-type", "application/json;charset=utf-8")
	req.Header.Set("x-csrf-token", "undefined")

	if err = d.httpClient.Do(c, req, &res); err != nil {
		log.Error("d.BuglyIssue url(%s) err(%v)", "BuglyIssue", err)
		return
	}

	if res.Code != _issueDetailCode {
		err = ecode.MartheBuglyErr
		log.Error("Status url(%s) res(%v) err(%v)", "BuglyIssue", res, err)
		return
	}

	bugIssueDetail = res.Data
	return
}

// BuglyIssueExceptionList Bugly Issue Exception List.
func (d *Dao) BuglyIssueExceptionList(c context.Context, buglyCookie *model.BuglyCookie, projectID, platformID, issueNo string) (bugIssueException *model.IssueException, err error) {
	var (
		req     *http.Request
		res     *model.BugIssueExceptionListResponse
		hostStr string
	)

	hostStr = d.c.Bugly.Host + fmt.Sprintf(_issueExceptionList, projectID, platformID, issueNo)

	if req, err = d.newRequest("GET", hostStr, nil); err != nil {
		return
	}

	req.Header.Set("Cookie", buglyCookie.Cookie)
	req.Header.Set("x-token", buglyCookie.Token)
	req.Header.Set("content-type", "application/json;charset=utf-8")
	req.Header.Set("x-csrf-token", "undefined")

	if err = d.httpClient.Do(c, req, &res); err != nil {
		log.Error("d.BuglyIssueExceptionList url(%s) err(%v)", "BuglyIssueExceptionList", err)
		return
	}

	if res.Status != _buglyOkCode {
		err = ecode.MartheBuglyErr
		log.Error("Status url(%s) res(%v) err(%v)", "BuglyIssueExceptionList", res, err)
		return
	}

	if res.Ret != nil && len(res.Ret.IssueException) != 0 && res.Ret.IssueException[0].IssueID == issueNo {
		bugIssueException = res.Ret.IssueException[0]
	}

	return
}