Function agentChannelReplySendRequest

internal/api/core/agent_channels.go:283–316

(
	caller agentidentity.Caller,
	source network.Envelope,
	req decodedAgentChannelReplyRequest,
	ext map[string]json.RawMessage,
)

}

func agentChannelReplySendRequest(
	caller agentidentity.Caller,
	source network.Envelope,
	req decodedAgentChannelReplyRequest,
	ext map[string]json.RawMessage,
) (network.SendRequest, error) {
	callerPeerID := agentCallerPeerID(caller)
	workspaceID := strings.TrimSpace(caller.Session.WorkspaceID)
	sourceChannel := strings.TrimSpace(source.Channel)
	targetPeerID := strings.TrimSpace(source.From)
	directID, _, _, err := network.DirectRoomIdentity(workspaceID, sourceChannel, callerPeerID, targetPeerID)
	if err != nil {
		return network.SendRequest{}, err
	}
	sendReq := network.SendRequest{
		SessionID:   strings.TrimSpace(caller.Session.ID),
		WorkspaceID: workspaceID,
		Channel:     sourceChannel,
		Surface:     new(network.SurfaceDirect),
		DirectID:    ptrString(directID),
		Kind:        network.KindSay,
		To:          ptrString(targetPeerID),
		ReplyTo:     ptrString(req.ReplyToMessageID),
		Body:        cloneRawMessage(req.Body),
		Ext:         ext,
	}
	if source.WorkID != nil && strings.TrimSpace(*source.WorkID) != "" {
		sendReq.WorkID = ptrString(*source.WorkID)
	}
	if source.TraceID != nil && strings.TrimSpace(*source.TraceID) != "" {
		sendReq.TraceID = ptrString(*source.TraceID)
	}
	return sendReq, nil
}

func agentCallerPeerID(caller agentidentity.Caller) string {
	agentName := strings.ToLower(strings.TrimSpace(caller.Session.AgentName))