Method handleNetworkThreadGet

internal/extension/host_api_network.go:130–160

(ctx context.Context, raw json.RawMessage)

}

func (h *HostAPIHandler) handleNetworkThreadGet(ctx context.Context, raw json.RawMessage) (any, error) {
	var params extensioncontract.NetworkThreadTargetParams
	if err := decodeHostAPIParams(raw, &params); err != nil {
		return nil, err
	}
	networkStore, err := h.requireHostAPINetworkStore()
	if err != nil {
		return nil, err
	}
	channel, err := hostAPINetworkChannel(params.Channel)
	if err != nil {
		return nil, err
	}
	threadID := strings.TrimSpace(params.ThreadID)
	if err := network.ValidateConversationID(threadID, "thread_id"); err != nil {
		return nil, invalidParamsRPCError(err)
	}
	workspaceID, err := h.hostAPINetworkWorkspaceID(ctx, params.WorkspaceID)
	if err != nil {
		return nil, err
	}
	thread, err := networkStore.GetThread(
		ctx,
		store.NetworkChannelRef{WorkspaceID: workspaceID, Channel: channel},
		threadID,
	)
	if err != nil {
		return nil, mapHostAPINetworkRPCError(err)
	}
	return hostAPINetworkThreadSummaryPayload(thread), nil
}

func (h *HostAPIHandler) handleNetworkThreadMessages(ctx context.Context, raw json.RawMessage) (any, error) {
	var params extensioncontract.NetworkThreadMessagesParams