Method AILogInfo

module/service/iml.go:152–205

(ctx context.Context, serviceId string, logId string)

}

func (i *imlServiceModule) AILogInfo(ctx context.Context, serviceId string, logId string) (*service_dto.AILogInfo, error) {
	c, err := i.clusterService.Get(ctx, cluster.DefaultClusterID)
	if err != nil {
		return nil, fmt.Errorf("cluster %s not found", cluster.DefaultClusterID)
	}
	info, err := i.logService.LogInfo(ctx, "loki", c.Cluster, logId)
	if err != nil {
		return nil, err
	}
	if info.Service != serviceId {
		return nil, errors.New("service not match")
	}
	response, err := parseAIResponse(info.ResponseBody)
	if err != nil {
		response = info.ResponseBody
	}

	logInfo := &service_dto.AILogInfo{
		Id:       info.ID,
		API:      auto.UUID(info.API),
		Consumer: auto.UUID(info.Consumer),
		Status:   info.StatusCode,
		Ip:       info.RemoteIP,
		Provider: auto.UUID(info.AIProvider),
		Model:    info.AIModel,
		LogTime:  auto.TimeLabel(info.RecordTime),
		Request: service_dto.OriginAIRequest{
			OriginRequest: service_dto.OriginRequest{
				Header: formatHeader(info.RequestHeader),
				Origin: info.RequestBody,
				Body:   parseAIRequest(info.RequestBody),
			},

			Token: info.InputToken,
		},
		Response: service_dto.OriginAIRequest{
			OriginRequest: service_dto.OriginRequest{
				Header: formatHeader(info.ResponseHeader),
				Origin: info.ResponseBody,
				Body:   response,
			},

			Token: info.OutputToken,
		},
	}
	if info.Consumer == "apipark-global" {
		logInfo.IsSystemConsumer = true
		logInfo.Consumer = auto.Label{
			Id:   info.Consumer,
			Name: "System Consumer",
		}
	}
	return logInfo, nil
}

func (i *imlServiceModule) RestLogs(ctx context.Context, serviceId string, start int64, end int64, page int, size int) ([]*service_dto.RestLogItem, int64, error) {
	list, total, err := i.logService.LogRecordsByService(ctx, serviceId, time.Unix(start, 0), time.Unix(end, 0), page, size)